// Copyright 2024 Google LLC. // Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. // Code generated file. DO NOT EDIT. // Package admin provides access to the Admin SDK API. // // For product documentation, see: https://developers.google.com/admin-sdk/ // // # Library status // // These client libraries are officially supported by Google. However, this // library is considered complete and is in maintenance mode. This means // that we will address critical bugs and security issues but will not add // any new features. // // When possible, we recommend using our newer // [Cloud Client Libraries for Go](https://pkg.go.dev/cloud.google.com/go) // that are still actively being worked and iterated on. // // # Creating a client // // Usage example: // // import "google.golang.org/api/admin/datatransfer/v1" // ... // ctx := context.Background() // adminService, err := admin.NewService(ctx) // // In this example, Google Application Default Credentials are used for // authentication. For information on how to create and obtain Application // Default Credentials, see https://developers.google.com/identity/protocols/application-default-credentials. // // # Other authentication options // // By default, all available scopes (see "Constants") are used to authenticate. // To restrict scopes, use [google.golang.org/api/option.WithScopes]: // // adminService, err := admin.NewService(ctx, option.WithScopes(admin.AdminDatatransferReadonlyScope)) // // To use an API key for authentication (note: some APIs do not support API // keys), use [google.golang.org/api/option.WithAPIKey]: // // adminService, err := admin.NewService(ctx, option.WithAPIKey("AIza...")) // // To use an OAuth token (e.g., a user token obtained via a three-legged OAuth // flow, use [google.golang.org/api/option.WithTokenSource]: // // config := &oauth2.Config{...} // // ... // token, err := config.Exchange(ctx, ...) // adminService, err := admin.NewService(ctx, option.WithTokenSource(config.TokenSource(ctx, token))) // // See [google.golang.org/api/option.ClientOption] for details on options. package admin // import "google.golang.org/api/admin/datatransfer/v1" import ( "bytes" "context" "encoding/json" "errors" "fmt" "io" "net/http" "net/url" "strconv" "strings" googleapi "google.golang.org/api/googleapi" internal "google.golang.org/api/internal" gensupport "google.golang.org/api/internal/gensupport" option "google.golang.org/api/option" internaloption "google.golang.org/api/option/internaloption" htransport "google.golang.org/api/transport/http" ) // Always reference these packages, just in case the auto-generated code // below doesn't. var _ = bytes.NewBuffer var _ = strconv.Itoa var _ = fmt.Sprintf var _ = json.NewDecoder var _ = io.Copy var _ = url.Parse var _ = gensupport.MarshalJSON var _ = googleapi.Version var _ = errors.New var _ = strings.Replace var _ = context.Canceled var _ = internaloption.WithDefaultEndpoint var _ = internal.Version const apiId = "admin:datatransfer_v1" const apiName = "admin" const apiVersion = "datatransfer_v1" const basePath = "https://admin.googleapis.com/" const basePathTemplate = "https://admin.UNIVERSE_DOMAIN/" const mtlsBasePath = "https://admin.mtls.googleapis.com/" // OAuth2 scopes used by this API. const ( // View and manage data transfers between users in your organization AdminDatatransferScope = "https://www.googleapis.com/auth/admin.datatransfer" // View data transfers between users in your organization AdminDatatransferReadonlyScope = "https://www.googleapis.com/auth/admin.datatransfer.readonly" ) // NewService creates a new Service. func NewService(ctx context.Context, opts ...option.ClientOption) (*Service, error) { scopesOption := internaloption.WithDefaultScopes( "https://www.googleapis.com/auth/admin.datatransfer", "https://www.googleapis.com/auth/admin.datatransfer.readonly", ) // NOTE: prepend, so we don't override user-specified scopes. opts = append([]option.ClientOption{scopesOption}, opts...) opts = append(opts, internaloption.WithDefaultEndpoint(basePath)) opts = append(opts, internaloption.WithDefaultEndpointTemplate(basePathTemplate)) opts = append(opts, internaloption.WithDefaultMTLSEndpoint(mtlsBasePath)) opts = append(opts, internaloption.EnableNewAuthLibrary()) client, endpoint, err := htransport.NewClient(ctx, opts...) if err != nil { return nil, err } s, err := New(client) if err != nil { return nil, err } if endpoint != "" { s.BasePath = endpoint } return s, nil } // New creates a new Service. It uses the provided http.Client for requests. // // Deprecated: please use NewService instead. // To provide a custom HTTP client, use option.WithHTTPClient. // If you are using google.golang.org/api/googleapis/transport.APIKey, use option.WithAPIKey with NewService instead. func New(client *http.Client) (*Service, error) { if client == nil { return nil, errors.New("client is nil") } s := &Service{client: client, BasePath: basePath} s.Applications = NewApplicationsService(s) s.Transfers = NewTransfersService(s) return s, nil } type Service struct { client *http.Client BasePath string // API endpoint base URL UserAgent string // optional additional User-Agent fragment Applications *ApplicationsService Transfers *TransfersService } func (s *Service) userAgent() string { if s.UserAgent == "" { return googleapi.UserAgent } return googleapi.UserAgent + " " + s.UserAgent } func NewApplicationsService(s *Service) *ApplicationsService { rs := &ApplicationsService{s: s} return rs } type ApplicationsService struct { s *Service } func NewTransfersService(s *Service) *TransfersService { rs := &TransfersService{s: s} return rs } type TransfersService struct { s *Service } // Application: Application resources represent applications installed on the // domain that support transferring ownership of user data. type Application struct { // Etag: Etag of the resource. Etag string `json:"etag,omitempty"` // Id: The application's ID. Retrievable by using the `applications.list()` // (/admin-sdk/data-transfer/reference/rest/v1/applications/list) method. Id int64 `json:"id,omitempty,string"` // Kind: Identifies the resource as a DataTransfer Application Resource. Kind string `json:"kind,omitempty"` // Name: The application's name. Name string `json:"name,omitempty"` // TransferParams: The list of all possible transfer parameters for this // application. These parameters select which categories of the user's data to // transfer. TransferParams []*ApplicationTransferParam `json:"transferParams,omitempty"` // ServerResponse contains the HTTP response code and headers from the server. googleapi.ServerResponse `json:"-"` // ForceSendFields is a list of field names (e.g. "Etag") to unconditionally // include in API requests. By default, fields with empty or default values are // omitted from API requests. See // https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more // details. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "Etag") to include in API requests // with the JSON null value. By default, fields with empty values are omitted // from API requests. See // https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details. NullFields []string `json:"-"` } func (s *Application) MarshalJSON() ([]byte, error) { type NoMethod Application return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields) } // ApplicationDataTransfer: Template to map fields of ApplicationDataTransfer // resource. type ApplicationDataTransfer struct { // ApplicationId: The application's ID. ApplicationId int64 `json:"applicationId,omitempty,string"` // ApplicationTransferParams: The transfer parameters for the application. // These parameters are used to select the data which will get transferred in // context of this application. For more information about the specific values // available for each application, see the Transfer parameters // (/admin-sdk/data-transfer/v1/parameters) reference. ApplicationTransferParams []*ApplicationTransferParam `json:"applicationTransferParams,omitempty"` // ApplicationTransferStatus: Read-only. Current status of transfer for this // application. ApplicationTransferStatus string `json:"applicationTransferStatus,omitempty"` // ForceSendFields is a list of field names (e.g. "ApplicationId") to // unconditionally include in API requests. By default, fields with empty or // default values are omitted from API requests. See // https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more // details. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "ApplicationId") to include in API // requests with the JSON null value. By default, fields with empty values are // omitted from API requests. See // https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details. NullFields []string `json:"-"` } func (s *ApplicationDataTransfer) MarshalJSON() ([]byte, error) { type NoMethod ApplicationDataTransfer return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields) } // ApplicationTransferParam: Template for application transfer parameters. type ApplicationTransferParam struct { // Key: The type of the transfer parameter, such as `PRIVACY_LEVEL`. Key string `json:"key,omitempty"` // Value: The value of the transfer parameter, such as `PRIVATE` or `SHARED`. Value []string `json:"value,omitempty"` // ForceSendFields is a list of field names (e.g. "Key") to unconditionally // include in API requests. By default, fields with empty or default values are // omitted from API requests. See // https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more // details. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "Key") to include in API requests // with the JSON null value. By default, fields with empty values are omitted // from API requests. See // https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details. NullFields []string `json:"-"` } func (s *ApplicationTransferParam) MarshalJSON() ([]byte, error) { type NoMethod ApplicationTransferParam return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields) } // ApplicationsListResponse: Template for a collection of Applications. type ApplicationsListResponse struct { // Applications: The list of applications that support data transfer and are // also installed for the customer. Applications []*Application `json:"applications,omitempty"` // Etag: ETag of the resource. Etag string `json:"etag,omitempty"` // Kind: Identifies the resource as a collection of Applications. Kind string `json:"kind,omitempty"` // NextPageToken: Token to specify the next page in the list. NextPageToken string `json:"nextPageToken,omitempty"` // ServerResponse contains the HTTP response code and headers from the server. googleapi.ServerResponse `json:"-"` // ForceSendFields is a list of field names (e.g. "Applications") to // unconditionally include in API requests. By default, fields with empty or // default values are omitted from API requests. See // https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more // details. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "Applications") to include in API // requests with the JSON null value. By default, fields with empty values are // omitted from API requests. See // https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details. NullFields []string `json:"-"` } func (s *ApplicationsListResponse) MarshalJSON() ([]byte, error) { type NoMethod ApplicationsListResponse return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields) } // DataTransfer: A Transfer resource represents the transfer of the ownership // of user data between users. type DataTransfer struct { // ApplicationDataTransfers: The list of per-application data transfer // resources. It contains details of the applications associated with this // transfer resource, and also specifies the applications for which data // transfer has to be done at the time of the transfer resource creation. ApplicationDataTransfers []*ApplicationDataTransfer `json:"applicationDataTransfers,omitempty"` // Etag: ETag of the resource. Etag string `json:"etag,omitempty"` // Id: Read-only. The transfer's ID. Id string `json:"id,omitempty"` // Kind: Identifies the resource as a DataTransfer request. Kind string `json:"kind,omitempty"` // NewOwnerUserId: ID of the user to whom the data is being transferred. NewOwnerUserId string `json:"newOwnerUserId,omitempty"` // OldOwnerUserId: ID of the user whose data is being transferred. OldOwnerUserId string `json:"oldOwnerUserId,omitempty"` // OverallTransferStatusCode: Read-only. Overall transfer status. OverallTransferStatusCode string `json:"overallTransferStatusCode,omitempty"` // RequestTime: Read-only. The time at which the data transfer was requested. RequestTime string `json:"requestTime,omitempty"` // ServerResponse contains the HTTP response code and headers from the server. googleapi.ServerResponse `json:"-"` // ForceSendFields is a list of field names (e.g. "ApplicationDataTransfers") // to unconditionally include in API requests. By default, fields with empty or // default values are omitted from API requests. See // https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more // details. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "ApplicationDataTransfers") to // include in API requests with the JSON null value. By default, fields with // empty values are omitted from API requests. See // https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details. NullFields []string `json:"-"` } func (s *DataTransfer) MarshalJSON() ([]byte, error) { type NoMethod DataTransfer return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields) } // DataTransfersListResponse: Template for a collection of DataTransfer // resources. type DataTransfersListResponse struct { // DataTransfers: List of data transfer requests. DataTransfers []*DataTransfer `json:"dataTransfers,omitempty"` // Etag: ETag of the resource. Etag string `json:"etag,omitempty"` // Kind: Identifies the resource as a collection of data transfer requests. Kind string `json:"kind,omitempty"` // NextPageToken: Token to specify the next page in the list. NextPageToken string `json:"nextPageToken,omitempty"` // ServerResponse contains the HTTP response code and headers from the server. googleapi.ServerResponse `json:"-"` // ForceSendFields is a list of field names (e.g. "DataTransfers") to // unconditionally include in API requests. By default, fields with empty or // default values are omitted from API requests. See // https://pkg.go.dev/google.golang.org/api#hdr-ForceSendFields for more // details. ForceSendFields []string `json:"-"` // NullFields is a list of field names (e.g. "DataTransfers") to include in API // requests with the JSON null value. By default, fields with empty values are // omitted from API requests. See // https://pkg.go.dev/google.golang.org/api#hdr-NullFields for more details. NullFields []string `json:"-"` } func (s *DataTransfersListResponse) MarshalJSON() ([]byte, error) { type NoMethod DataTransfersListResponse return gensupport.MarshalJSON(NoMethod(*s), s.ForceSendFields, s.NullFields) } type ApplicationsGetCall struct { s *Service applicationId int64 urlParams_ gensupport.URLParams ifNoneMatch_ string ctx_ context.Context header_ http.Header } // Get: Retrieves information about an application for the given application // ID. // // - applicationId: ID of the application resource to be retrieved. func (r *ApplicationsService) Get(applicationId int64) *ApplicationsGetCall { c := &ApplicationsGetCall{s: r.s, urlParams_: make(gensupport.URLParams)} c.applicationId = applicationId return c } // Fields allows partial responses to be retrieved. See // https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more // details. func (c *ApplicationsGetCall) Fields(s ...googleapi.Field) *ApplicationsGetCall { c.urlParams_.Set("fields", googleapi.CombineFields(s)) return c } // IfNoneMatch sets an optional parameter which makes the operation fail if the // object's ETag matches the given value. This is useful for getting updates // only after the object has changed since the last request. func (c *ApplicationsGetCall) IfNoneMatch(entityTag string) *ApplicationsGetCall { c.ifNoneMatch_ = entityTag return c } // Context sets the context to be used in this call's Do method. func (c *ApplicationsGetCall) Context(ctx context.Context) *ApplicationsGetCall { c.ctx_ = ctx return c } // Header returns a http.Header that can be modified by the caller to add // headers to the request. func (c *ApplicationsGetCall) Header() http.Header { if c.header_ == nil { c.header_ = make(http.Header) } return c.header_ } func (c *ApplicationsGetCall) doRequest(alt string) (*http.Response, error) { reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "", c.header_) if c.ifNoneMatch_ != "" { reqHeaders.Set("If-None-Match", c.ifNoneMatch_) } var body io.Reader = nil c.urlParams_.Set("alt", alt) c.urlParams_.Set("prettyPrint", "false") urls := googleapi.ResolveRelative(c.s.BasePath, "admin/datatransfer/v1/applications/{applicationId}") urls += "?" + c.urlParams_.Encode() req, err := http.NewRequest("GET", urls, body) if err != nil { return nil, err } req.Header = reqHeaders googleapi.Expand(req.URL, map[string]string{ "applicationId": strconv.FormatInt(c.applicationId, 10), }) return gensupport.SendRequest(c.ctx_, c.s.client, req) } // Do executes the "datatransfer.applications.get" call. // Any non-2xx status code is an error. Response headers are in either // *Application.ServerResponse.Header or (if a response was returned at all) in // error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check // whether the returned error was because http.StatusNotModified was returned. func (c *ApplicationsGetCall) Do(opts ...googleapi.CallOption) (*Application, error) { gensupport.SetOptions(c.urlParams_, opts...) res, err := c.doRequest("json") if res != nil && res.StatusCode == http.StatusNotModified { if res.Body != nil { res.Body.Close() } return nil, gensupport.WrapError(&googleapi.Error{ Code: res.StatusCode, Header: res.Header, }) } if err != nil { return nil, err } defer googleapi.CloseBody(res) if err := googleapi.CheckResponse(res); err != nil { return nil, gensupport.WrapError(err) } ret := &Application{ ServerResponse: googleapi.ServerResponse{ Header: res.Header, HTTPStatusCode: res.StatusCode, }, } target := &ret if err := gensupport.DecodeResponse(target, res); err != nil { return nil, err } return ret, nil } type ApplicationsListCall struct { s *Service urlParams_ gensupport.URLParams ifNoneMatch_ string ctx_ context.Context header_ http.Header } // List: Lists the applications available for data transfer for a customer. func (r *ApplicationsService) List() *ApplicationsListCall { c := &ApplicationsListCall{s: r.s, urlParams_: make(gensupport.URLParams)} return c } // CustomerId sets the optional parameter "customerId": Immutable ID of the // Google Workspace account. func (c *ApplicationsListCall) CustomerId(customerId string) *ApplicationsListCall { c.urlParams_.Set("customerId", customerId) return c } // MaxResults sets the optional parameter "maxResults": Maximum number of // results to return. Default is 100. func (c *ApplicationsListCall) MaxResults(maxResults int64) *ApplicationsListCall { c.urlParams_.Set("maxResults", fmt.Sprint(maxResults)) return c } // PageToken sets the optional parameter "pageToken": Token to specify next // page in the list. func (c *ApplicationsListCall) PageToken(pageToken string) *ApplicationsListCall { c.urlParams_.Set("pageToken", pageToken) return c } // Fields allows partial responses to be retrieved. See // https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more // details. func (c *ApplicationsListCall) Fields(s ...googleapi.Field) *ApplicationsListCall { c.urlParams_.Set("fields", googleapi.CombineFields(s)) return c } // IfNoneMatch sets an optional parameter which makes the operation fail if the // object's ETag matches the given value. This is useful for getting updates // only after the object has changed since the last request. func (c *ApplicationsListCall) IfNoneMatch(entityTag string) *ApplicationsListCall { c.ifNoneMatch_ = entityTag return c } // Context sets the context to be used in this call's Do method. func (c *ApplicationsListCall) Context(ctx context.Context) *ApplicationsListCall { c.ctx_ = ctx return c } // Header returns a http.Header that can be modified by the caller to add // headers to the request. func (c *ApplicationsListCall) Header() http.Header { if c.header_ == nil { c.header_ = make(http.Header) } return c.header_ } func (c *ApplicationsListCall) doRequest(alt string) (*http.Response, error) { reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "", c.header_) if c.ifNoneMatch_ != "" { reqHeaders.Set("If-None-Match", c.ifNoneMatch_) } var body io.Reader = nil c.urlParams_.Set("alt", alt) c.urlParams_.Set("prettyPrint", "false") urls := googleapi.ResolveRelative(c.s.BasePath, "admin/datatransfer/v1/applications") urls += "?" + c.urlParams_.Encode() req, err := http.NewRequest("GET", urls, body) if err != nil { return nil, err } req.Header = reqHeaders return gensupport.SendRequest(c.ctx_, c.s.client, req) } // Do executes the "datatransfer.applications.list" call. // Any non-2xx status code is an error. Response headers are in either // *ApplicationsListResponse.ServerResponse.Header or (if a response was // returned at all) in error.(*googleapi.Error).Header. Use // googleapi.IsNotModified to check whether the returned error was because // http.StatusNotModified was returned. func (c *ApplicationsListCall) Do(opts ...googleapi.CallOption) (*ApplicationsListResponse, error) { gensupport.SetOptions(c.urlParams_, opts...) res, err := c.doRequest("json") if res != nil && res.StatusCode == http.StatusNotModified { if res.Body != nil { res.Body.Close() } return nil, gensupport.WrapError(&googleapi.Error{ Code: res.StatusCode, Header: res.Header, }) } if err != nil { return nil, err } defer googleapi.CloseBody(res) if err := googleapi.CheckResponse(res); err != nil { return nil, gensupport.WrapError(err) } ret := &ApplicationsListResponse{ ServerResponse: googleapi.ServerResponse{ Header: res.Header, HTTPStatusCode: res.StatusCode, }, } target := &ret if err := gensupport.DecodeResponse(target, res); err != nil { return nil, err } return ret, nil } // Pages invokes f for each page of results. // A non-nil error returned from f will halt the iteration. // The provided context supersedes any context provided to the Context method. func (c *ApplicationsListCall) Pages(ctx context.Context, f func(*ApplicationsListResponse) error) error { c.ctx_ = ctx defer c.PageToken(c.urlParams_.Get("pageToken")) for { x, err := c.Do() if err != nil { return err } if err := f(x); err != nil { return err } if x.NextPageToken == "" { return nil } c.PageToken(x.NextPageToken) } } type TransfersGetCall struct { s *Service dataTransferId string urlParams_ gensupport.URLParams ifNoneMatch_ string ctx_ context.Context header_ http.Header } // Get: Retrieves a data transfer request by its resource ID. // // - dataTransferId: ID of the resource to be retrieved. This is returned in // the response from the insert method. func (r *TransfersService) Get(dataTransferId string) *TransfersGetCall { c := &TransfersGetCall{s: r.s, urlParams_: make(gensupport.URLParams)} c.dataTransferId = dataTransferId return c } // Fields allows partial responses to be retrieved. See // https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more // details. func (c *TransfersGetCall) Fields(s ...googleapi.Field) *TransfersGetCall { c.urlParams_.Set("fields", googleapi.CombineFields(s)) return c } // IfNoneMatch sets an optional parameter which makes the operation fail if the // object's ETag matches the given value. This is useful for getting updates // only after the object has changed since the last request. func (c *TransfersGetCall) IfNoneMatch(entityTag string) *TransfersGetCall { c.ifNoneMatch_ = entityTag return c } // Context sets the context to be used in this call's Do method. func (c *TransfersGetCall) Context(ctx context.Context) *TransfersGetCall { c.ctx_ = ctx return c } // Header returns a http.Header that can be modified by the caller to add // headers to the request. func (c *TransfersGetCall) Header() http.Header { if c.header_ == nil { c.header_ = make(http.Header) } return c.header_ } func (c *TransfersGetCall) doRequest(alt string) (*http.Response, error) { reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "", c.header_) if c.ifNoneMatch_ != "" { reqHeaders.Set("If-None-Match", c.ifNoneMatch_) } var body io.Reader = nil c.urlParams_.Set("alt", alt) c.urlParams_.Set("prettyPrint", "false") urls := googleapi.ResolveRelative(c.s.BasePath, "admin/datatransfer/v1/transfers/{dataTransferId}") urls += "?" + c.urlParams_.Encode() req, err := http.NewRequest("GET", urls, body) if err != nil { return nil, err } req.Header = reqHeaders googleapi.Expand(req.URL, map[string]string{ "dataTransferId": c.dataTransferId, }) return gensupport.SendRequest(c.ctx_, c.s.client, req) } // Do executes the "datatransfer.transfers.get" call. // Any non-2xx status code is an error. Response headers are in either // *DataTransfer.ServerResponse.Header or (if a response was returned at all) // in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check // whether the returned error was because http.StatusNotModified was returned. func (c *TransfersGetCall) Do(opts ...googleapi.CallOption) (*DataTransfer, error) { gensupport.SetOptions(c.urlParams_, opts...) res, err := c.doRequest("json") if res != nil && res.StatusCode == http.StatusNotModified { if res.Body != nil { res.Body.Close() } return nil, gensupport.WrapError(&googleapi.Error{ Code: res.StatusCode, Header: res.Header, }) } if err != nil { return nil, err } defer googleapi.CloseBody(res) if err := googleapi.CheckResponse(res); err != nil { return nil, gensupport.WrapError(err) } ret := &DataTransfer{ ServerResponse: googleapi.ServerResponse{ Header: res.Header, HTTPStatusCode: res.StatusCode, }, } target := &ret if err := gensupport.DecodeResponse(target, res); err != nil { return nil, err } return ret, nil } type TransfersInsertCall struct { s *Service datatransfer *DataTransfer urlParams_ gensupport.URLParams ctx_ context.Context header_ http.Header } // Insert: Inserts a data transfer request. See the Transfer parameters // (/admin-sdk/data-transfer/v1/parameters) reference for specific application // requirements. func (r *TransfersService) Insert(datatransfer *DataTransfer) *TransfersInsertCall { c := &TransfersInsertCall{s: r.s, urlParams_: make(gensupport.URLParams)} c.datatransfer = datatransfer return c } // Fields allows partial responses to be retrieved. See // https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more // details. func (c *TransfersInsertCall) Fields(s ...googleapi.Field) *TransfersInsertCall { c.urlParams_.Set("fields", googleapi.CombineFields(s)) return c } // Context sets the context to be used in this call's Do method. func (c *TransfersInsertCall) Context(ctx context.Context) *TransfersInsertCall { c.ctx_ = ctx return c } // Header returns a http.Header that can be modified by the caller to add // headers to the request. func (c *TransfersInsertCall) Header() http.Header { if c.header_ == nil { c.header_ = make(http.Header) } return c.header_ } func (c *TransfersInsertCall) doRequest(alt string) (*http.Response, error) { reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "application/json", c.header_) var body io.Reader = nil body, err := googleapi.WithoutDataWrapper.JSONReader(c.datatransfer) if err != nil { return nil, err } c.urlParams_.Set("alt", alt) c.urlParams_.Set("prettyPrint", "false") urls := googleapi.ResolveRelative(c.s.BasePath, "admin/datatransfer/v1/transfers") urls += "?" + c.urlParams_.Encode() req, err := http.NewRequest("POST", urls, body) if err != nil { return nil, err } req.Header = reqHeaders return gensupport.SendRequest(c.ctx_, c.s.client, req) } // Do executes the "datatransfer.transfers.insert" call. // Any non-2xx status code is an error. Response headers are in either // *DataTransfer.ServerResponse.Header or (if a response was returned at all) // in error.(*googleapi.Error).Header. Use googleapi.IsNotModified to check // whether the returned error was because http.StatusNotModified was returned. func (c *TransfersInsertCall) Do(opts ...googleapi.CallOption) (*DataTransfer, error) { gensupport.SetOptions(c.urlParams_, opts...) res, err := c.doRequest("json") if res != nil && res.StatusCode == http.StatusNotModified { if res.Body != nil { res.Body.Close() } return nil, gensupport.WrapError(&googleapi.Error{ Code: res.StatusCode, Header: res.Header, }) } if err != nil { return nil, err } defer googleapi.CloseBody(res) if err := googleapi.CheckResponse(res); err != nil { return nil, gensupport.WrapError(err) } ret := &DataTransfer{ ServerResponse: googleapi.ServerResponse{ Header: res.Header, HTTPStatusCode: res.StatusCode, }, } target := &ret if err := gensupport.DecodeResponse(target, res); err != nil { return nil, err } return ret, nil } type TransfersListCall struct { s *Service urlParams_ gensupport.URLParams ifNoneMatch_ string ctx_ context.Context header_ http.Header } // List: Lists the transfers for a customer by source user, destination user, // or status. func (r *TransfersService) List() *TransfersListCall { c := &TransfersListCall{s: r.s, urlParams_: make(gensupport.URLParams)} return c } // CustomerId sets the optional parameter "customerId": Immutable ID of the // Google Workspace account. func (c *TransfersListCall) CustomerId(customerId string) *TransfersListCall { c.urlParams_.Set("customerId", customerId) return c } // MaxResults sets the optional parameter "maxResults": Maximum number of // results to return. Default is 100. func (c *TransfersListCall) MaxResults(maxResults int64) *TransfersListCall { c.urlParams_.Set("maxResults", fmt.Sprint(maxResults)) return c } // NewOwnerUserId sets the optional parameter "newOwnerUserId": Destination // user's profile ID. func (c *TransfersListCall) NewOwnerUserId(newOwnerUserId string) *TransfersListCall { c.urlParams_.Set("newOwnerUserId", newOwnerUserId) return c } // OldOwnerUserId sets the optional parameter "oldOwnerUserId": Source user's // profile ID. func (c *TransfersListCall) OldOwnerUserId(oldOwnerUserId string) *TransfersListCall { c.urlParams_.Set("oldOwnerUserId", oldOwnerUserId) return c } // PageToken sets the optional parameter "pageToken": Token to specify the next // page in the list. func (c *TransfersListCall) PageToken(pageToken string) *TransfersListCall { c.urlParams_.Set("pageToken", pageToken) return c } // Status sets the optional parameter "status": Status of the transfer. func (c *TransfersListCall) Status(status string) *TransfersListCall { c.urlParams_.Set("status", status) return c } // Fields allows partial responses to be retrieved. See // https://developers.google.com/gdata/docs/2.0/basics#PartialResponse for more // details. func (c *TransfersListCall) Fields(s ...googleapi.Field) *TransfersListCall { c.urlParams_.Set("fields", googleapi.CombineFields(s)) return c } // IfNoneMatch sets an optional parameter which makes the operation fail if the // object's ETag matches the given value. This is useful for getting updates // only after the object has changed since the last request. func (c *TransfersListCall) IfNoneMatch(entityTag string) *TransfersListCall { c.ifNoneMatch_ = entityTag return c } // Context sets the context to be used in this call's Do method. func (c *TransfersListCall) Context(ctx context.Context) *TransfersListCall { c.ctx_ = ctx return c } // Header returns a http.Header that can be modified by the caller to add // headers to the request. func (c *TransfersListCall) Header() http.Header { if c.header_ == nil { c.header_ = make(http.Header) } return c.header_ } func (c *TransfersListCall) doRequest(alt string) (*http.Response, error) { reqHeaders := gensupport.SetHeaders(c.s.userAgent(), "", c.header_) if c.ifNoneMatch_ != "" { reqHeaders.Set("If-None-Match", c.ifNoneMatch_) } var body io.Reader = nil c.urlParams_.Set("alt", alt) c.urlParams_.Set("prettyPrint", "false") urls := googleapi.ResolveRelative(c.s.BasePath, "admin/datatransfer/v1/transfers") urls += "?" + c.urlParams_.Encode() req, err := http.NewRequest("GET", urls, body) if err != nil { return nil, err } req.Header = reqHeaders return gensupport.SendRequest(c.ctx_, c.s.client, req) } // Do executes the "datatransfer.transfers.list" call. // Any non-2xx status code is an error. Response headers are in either // *DataTransfersListResponse.ServerResponse.Header or (if a response was // returned at all) in error.(*googleapi.Error).Header. Use // googleapi.IsNotModified to check whether the returned error was because // http.StatusNotModified was returned. func (c *TransfersListCall) Do(opts ...googleapi.CallOption) (*DataTransfersListResponse, error) { gensupport.SetOptions(c.urlParams_, opts...) res, err := c.doRequest("json") if res != nil && res.StatusCode == http.StatusNotModified { if res.Body != nil { res.Body.Close() } return nil, gensupport.WrapError(&googleapi.Error{ Code: res.StatusCode, Header: res.Header, }) } if err != nil { return nil, err } defer googleapi.CloseBody(res) if err := googleapi.CheckResponse(res); err != nil { return nil, gensupport.WrapError(err) } ret := &DataTransfersListResponse{ ServerResponse: googleapi.ServerResponse{ Header: res.Header, HTTPStatusCode: res.StatusCode, }, } target := &ret if err := gensupport.DecodeResponse(target, res); err != nil { return nil, err } return ret, nil } // Pages invokes f for each page of results. // A non-nil error returned from f will halt the iteration. // The provided context supersedes any context provided to the Context method. func (c *TransfersListCall) Pages(ctx context.Context, f func(*DataTransfersListResponse) error) error { c.ctx_ = ctx defer c.PageToken(c.urlParams_.Get("pageToken")) for { x, err := c.Do() if err != nil { return err } if err := f(x); err != nil { return err } if x.NextPageToken == "" { return nil } c.PageToken(x.NextPageToken) } }