storagetransfer

package
v0.0.0-...-6cb3ea0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 7, 2021 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	TransferJob_Status_name = map[int32]string{
		0: "STATUS_UNSPECIFIED",
		1: "ENABLED",
		2: "DISABLED",
		3: "DELETED",
	}
	TransferJob_Status_value = map[string]int32{
		"STATUS_UNSPECIFIED": 0,
		"ENABLED":            1,
		"DISABLED":           2,
		"DELETED":            3,
	}
)

Enum value maps for TransferJob_Status.

View Source
var (
	TransferOperation_Status_name = map[int32]string{
		0: "STATUS_UNSPECIFIED",
		1: "IN_PROGRESS",
		2: "PAUSED",
		3: "SUCCESS",
		4: "FAILED",
		5: "ABORTED",
	}
	TransferOperation_Status_value = map[string]int32{
		"STATUS_UNSPECIFIED": 0,
		"IN_PROGRESS":        1,
		"PAUSED":             2,
		"SUCCESS":            3,
		"FAILED":             4,
		"ABORTED":            5,
	}
)

Enum value maps for TransferOperation_Status.

View Source
var File_google_storagetransfer_v1_transfer_proto protoreflect.FileDescriptor
View Source
var File_google_storagetransfer_v1_transfer_types_proto protoreflect.FileDescriptor

Functions

func RegisterStorageTransferServiceServer

func RegisterStorageTransferServiceServer(s *grpc.Server, srv StorageTransferServiceServer)

Types

type AwsAccessKey

type AwsAccessKey struct {

	// AWS access key ID.
	// Required.
	AccessKeyId string `protobuf:"bytes,1,opt,name=access_key_id,json=accessKeyId,proto3" json:"access_key_id,omitempty"`
	// AWS secret access key. This field is not returned in RPC responses.
	// Required.
	SecretAccessKey string `protobuf:"bytes,2,opt,name=secret_access_key,json=secretAccessKey,proto3" json:"secret_access_key,omitempty"`
	// contains filtered or unexported fields
}

AWS access key (see [AWS Security Credentials](http://docs.aws.amazon.com/general/latest/gr/aws-security-credentials.html)).

func (*AwsAccessKey) Descriptor deprecated

func (*AwsAccessKey) Descriptor() ([]byte, []int)

Deprecated: Use AwsAccessKey.ProtoReflect.Descriptor instead.

func (*AwsAccessKey) GetAccessKeyId

func (x *AwsAccessKey) GetAccessKeyId() string

func (*AwsAccessKey) GetSecretAccessKey

func (x *AwsAccessKey) GetSecretAccessKey() string

func (*AwsAccessKey) ProtoMessage

func (*AwsAccessKey) ProtoMessage()

func (*AwsAccessKey) ProtoReflect

func (x *AwsAccessKey) ProtoReflect() protoreflect.Message

func (*AwsAccessKey) Reset

func (x *AwsAccessKey) Reset()

func (*AwsAccessKey) String

func (x *AwsAccessKey) String() string

type AwsS3Data

type AwsS3Data struct {

	// S3 Bucket name (see
	// [Creating a
	// bucket](http://docs.aws.amazon.com/AmazonS3/latest/dev/create-bucket-get-location-example.html)).
	// Required.
	BucketName string `protobuf:"bytes,1,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	// AWS access key used to sign the API requests to the AWS S3 bucket.
	// Permissions on the bucket must be granted to the access ID of the
	// AWS access key.
	// Required.
	AwsAccessKey *AwsAccessKey `protobuf:"bytes,2,opt,name=aws_access_key,json=awsAccessKey,proto3" json:"aws_access_key,omitempty"`
	// contains filtered or unexported fields
}

An AwsS3Data can be a data source, but not a data sink. In an AwsS3Data, an object's name is the S3 object's key name.

func (*AwsS3Data) Descriptor deprecated

func (*AwsS3Data) Descriptor() ([]byte, []int)

Deprecated: Use AwsS3Data.ProtoReflect.Descriptor instead.

func (*AwsS3Data) GetAwsAccessKey

func (x *AwsS3Data) GetAwsAccessKey() *AwsAccessKey

func (*AwsS3Data) GetBucketName

func (x *AwsS3Data) GetBucketName() string

func (*AwsS3Data) ProtoMessage

func (*AwsS3Data) ProtoMessage()

func (*AwsS3Data) ProtoReflect

func (x *AwsS3Data) ProtoReflect() protoreflect.Message

func (*AwsS3Data) Reset

func (x *AwsS3Data) Reset()

func (*AwsS3Data) String

func (x *AwsS3Data) String() string

type CreateTransferJobRequest

type CreateTransferJobRequest struct {

	// The job to create.
	// Required.
	TransferJob *TransferJob `protobuf:"bytes,1,opt,name=transfer_job,json=transferJob,proto3" json:"transfer_job,omitempty"`
	// contains filtered or unexported fields
}

Request passed to CreateTransferJob.

func (*CreateTransferJobRequest) Descriptor deprecated

func (*CreateTransferJobRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateTransferJobRequest.ProtoReflect.Descriptor instead.

func (*CreateTransferJobRequest) GetTransferJob

func (x *CreateTransferJobRequest) GetTransferJob() *TransferJob

func (*CreateTransferJobRequest) ProtoMessage

func (*CreateTransferJobRequest) ProtoMessage()

func (*CreateTransferJobRequest) ProtoReflect

func (x *CreateTransferJobRequest) ProtoReflect() protoreflect.Message

func (*CreateTransferJobRequest) Reset

func (x *CreateTransferJobRequest) Reset()

func (*CreateTransferJobRequest) String

func (x *CreateTransferJobRequest) String() string

type ErrorLogEntry

type ErrorLogEntry struct {

	// A URL that refers to the target (a data source, a data sink,
	// or an object) with which the error is associated.
	// Required.
	Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	// A list of messages that carry the error details.
	ErrorDetails []string `protobuf:"bytes,3,rep,name=error_details,json=errorDetails,proto3" json:"error_details,omitempty"`
	// contains filtered or unexported fields
}

An entry describing an error that has occurred.

func (*ErrorLogEntry) Descriptor deprecated

func (*ErrorLogEntry) Descriptor() ([]byte, []int)

Deprecated: Use ErrorLogEntry.ProtoReflect.Descriptor instead.

func (*ErrorLogEntry) GetErrorDetails

func (x *ErrorLogEntry) GetErrorDetails() []string

func (*ErrorLogEntry) GetUrl

func (x *ErrorLogEntry) GetUrl() string

func (*ErrorLogEntry) ProtoMessage

func (*ErrorLogEntry) ProtoMessage()

func (*ErrorLogEntry) ProtoReflect

func (x *ErrorLogEntry) ProtoReflect() protoreflect.Message

func (*ErrorLogEntry) Reset

func (x *ErrorLogEntry) Reset()

func (*ErrorLogEntry) String

func (x *ErrorLogEntry) String() string

type ErrorSummary

type ErrorSummary struct {

	// Required.
	ErrorCode code.Code `protobuf:"varint,1,opt,name=error_code,json=errorCode,proto3,enum=google.rpc.Code" json:"error_code,omitempty"`
	// Count of this type of error.
	// Required.
	ErrorCount int64 `protobuf:"varint,2,opt,name=error_count,json=errorCount,proto3" json:"error_count,omitempty"`
	// Error samples.
	ErrorLogEntries []*ErrorLogEntry `protobuf:"bytes,3,rep,name=error_log_entries,json=errorLogEntries,proto3" json:"error_log_entries,omitempty"`
	// contains filtered or unexported fields
}

A summary of errors by error code, plus a count and sample error log entries.

func (*ErrorSummary) Descriptor deprecated

func (*ErrorSummary) Descriptor() ([]byte, []int)

Deprecated: Use ErrorSummary.ProtoReflect.Descriptor instead.

func (*ErrorSummary) GetErrorCode

func (x *ErrorSummary) GetErrorCode() code.Code

func (*ErrorSummary) GetErrorCount

func (x *ErrorSummary) GetErrorCount() int64

func (*ErrorSummary) GetErrorLogEntries

func (x *ErrorSummary) GetErrorLogEntries() []*ErrorLogEntry

func (*ErrorSummary) ProtoMessage

func (*ErrorSummary) ProtoMessage()

func (*ErrorSummary) ProtoReflect

func (x *ErrorSummary) ProtoReflect() protoreflect.Message

func (*ErrorSummary) Reset

func (x *ErrorSummary) Reset()

func (*ErrorSummary) String

func (x *ErrorSummary) String() string

type GcsData

type GcsData struct {

	// Google Cloud Storage bucket name (see
	// [Bucket Name
	// Requirements](https://cloud.google.com/storage/docs/bucket-naming#requirements)).
	// Required.
	BucketName string `protobuf:"bytes,1,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	// contains filtered or unexported fields
}

In a GcsData, an object's name is the Google Cloud Storage object's name and its `lastModificationTime` refers to the object's updated time, which changes when the content or the metadata of the object is updated.

func (*GcsData) Descriptor deprecated

func (*GcsData) Descriptor() ([]byte, []int)

Deprecated: Use GcsData.ProtoReflect.Descriptor instead.

func (*GcsData) GetBucketName

func (x *GcsData) GetBucketName() string

func (*GcsData) ProtoMessage

func (*GcsData) ProtoMessage()

func (*GcsData) ProtoReflect

func (x *GcsData) ProtoReflect() protoreflect.Message

func (*GcsData) Reset

func (x *GcsData) Reset()

func (*GcsData) String

func (x *GcsData) String() string

type GetGoogleServiceAccountRequest

type GetGoogleServiceAccountRequest struct {

	// The ID of the Google Cloud Platform Console project that the Google service
	// account is associated with.
	// Required.
	ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// contains filtered or unexported fields
}

Request passed to GetGoogleServiceAccount.

func (*GetGoogleServiceAccountRequest) Descriptor deprecated

func (*GetGoogleServiceAccountRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetGoogleServiceAccountRequest.ProtoReflect.Descriptor instead.

func (*GetGoogleServiceAccountRequest) GetProjectId

func (x *GetGoogleServiceAccountRequest) GetProjectId() string

func (*GetGoogleServiceAccountRequest) ProtoMessage

func (*GetGoogleServiceAccountRequest) ProtoMessage()

func (*GetGoogleServiceAccountRequest) ProtoReflect

func (*GetGoogleServiceAccountRequest) Reset

func (x *GetGoogleServiceAccountRequest) Reset()

func (*GetGoogleServiceAccountRequest) String

type GetTransferJobRequest

type GetTransferJobRequest struct {

	// The job to get.
	// Required.
	JobName string `protobuf:"bytes,1,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
	// The ID of the Google Cloud Platform Console project that owns the job.
	// Required.
	ProjectId string `protobuf:"bytes,2,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// contains filtered or unexported fields
}

Request passed to GetTransferJob.

func (*GetTransferJobRequest) Descriptor deprecated

func (*GetTransferJobRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetTransferJobRequest.ProtoReflect.Descriptor instead.

func (*GetTransferJobRequest) GetJobName

func (x *GetTransferJobRequest) GetJobName() string

func (*GetTransferJobRequest) GetProjectId

func (x *GetTransferJobRequest) GetProjectId() string

func (*GetTransferJobRequest) ProtoMessage

func (*GetTransferJobRequest) ProtoMessage()

func (*GetTransferJobRequest) ProtoReflect

func (x *GetTransferJobRequest) ProtoReflect() protoreflect.Message

func (*GetTransferJobRequest) Reset

func (x *GetTransferJobRequest) Reset()

func (*GetTransferJobRequest) String

func (x *GetTransferJobRequest) String() string

type GoogleServiceAccount

type GoogleServiceAccount struct {

	// Required.
	AccountEmail string `protobuf:"bytes,1,opt,name=account_email,json=accountEmail,proto3" json:"account_email,omitempty"`
	// contains filtered or unexported fields
}

Google service account

func (*GoogleServiceAccount) Descriptor deprecated

func (*GoogleServiceAccount) Descriptor() ([]byte, []int)

Deprecated: Use GoogleServiceAccount.ProtoReflect.Descriptor instead.

func (*GoogleServiceAccount) GetAccountEmail

func (x *GoogleServiceAccount) GetAccountEmail() string

func (*GoogleServiceAccount) ProtoMessage

func (*GoogleServiceAccount) ProtoMessage()

func (*GoogleServiceAccount) ProtoReflect

func (x *GoogleServiceAccount) ProtoReflect() protoreflect.Message

func (*GoogleServiceAccount) Reset

func (x *GoogleServiceAccount) Reset()

func (*GoogleServiceAccount) String

func (x *GoogleServiceAccount) String() string

type HttpData

type HttpData struct {

	// The URL that points to the file that stores the object list entries.
	// This file must allow public access.  Currently, only URLs with HTTP and
	// HTTPS schemes are supported.
	// Required.
	ListUrl string `protobuf:"bytes,1,opt,name=list_url,json=listUrl,proto3" json:"list_url,omitempty"`
	// contains filtered or unexported fields
}

An HttpData specifies a list of objects on the web to be transferred over HTTP. The information of the objects to be transferred is contained in a file referenced by a URL. The first line in the file must be "TsvHttpData-1.0", which specifies the format of the file. Subsequent lines specify the information of the list of objects, one object per list entry. Each entry has the following tab-delimited fields:

* HTTP URL - The location of the object.

* Length - The size of the object in bytes.

* MD5 - The base64-encoded MD5 hash of the object.

For an example of a valid TSV file, see [Transferring data from URLs](https://cloud.google.com/storage/transfer/create-url-list).

When transferring data based on a URL list, keep the following in mind:

* When an object located at `http(s)://hostname:port/<URL-path>` is transferred to a data sink, the name of the object at the data sink is `<hostname>/<URL-path>`.

* If the specified size of an object does not match the actual size of the object fetched, the object will not be transferred.

* If the specified MD5 does not match the MD5 computed from the transferred bytes, the object transfer will fail. For more information, see [Generating MD5 hashes](https://cloud.google.com/storage/transfer/#md5)

* Ensure that each URL you specify is publicly accessible. For example, in Google Cloud Storage you can [share an object publicly] (https://cloud.google.com/storage/docs/cloud-console#_sharingdata) and get a link to it.

* Storage Transfer Service obeys `robots.txt` rules and requires the source HTTP server to support `Range` requests and to return a `Content-Length` header in each response.

* ObjectConditions(#ObjectConditions) have no effect when filtering objects to transfer.

func (*HttpData) Descriptor deprecated

func (*HttpData) Descriptor() ([]byte, []int)

Deprecated: Use HttpData.ProtoReflect.Descriptor instead.

func (*HttpData) GetListUrl

func (x *HttpData) GetListUrl() string

func (*HttpData) ProtoMessage

func (*HttpData) ProtoMessage()

func (*HttpData) ProtoReflect

func (x *HttpData) ProtoReflect() protoreflect.Message

func (*HttpData) Reset

func (x *HttpData) Reset()

func (*HttpData) String

func (x *HttpData) String() string

type ListTransferJobsRequest

type ListTransferJobsRequest struct {

	// A list of query parameters specified as JSON text in the form of
	// {"project_id":"my_project_id",
	// "job_names":["jobid1","jobid2",...],
	// "job_statuses":["status1","status2",...]}.
	// Since `job_names` and `job_statuses` support multiple values, their values
	// must be specified with array notation. `project_id` is required.
	// `job_names` and `job_statuses` are optional.  The valid values for
	// `job_statuses` are case-insensitive: `ENABLED`, `DISABLED`, and `DELETED`.
	Filter string `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	// The list page size. The max allowed value is 256.
	PageSize int32 `protobuf:"varint,4,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// The list page token.
	PageToken string `protobuf:"bytes,5,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

`project_id`, `job_names`, and `job_statuses` are query parameters that can be specified when listing transfer jobs.

func (*ListTransferJobsRequest) Descriptor deprecated

func (*ListTransferJobsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListTransferJobsRequest.ProtoReflect.Descriptor instead.

func (*ListTransferJobsRequest) GetFilter

func (x *ListTransferJobsRequest) GetFilter() string

func (*ListTransferJobsRequest) GetPageSize

func (x *ListTransferJobsRequest) GetPageSize() int32

func (*ListTransferJobsRequest) GetPageToken

func (x *ListTransferJobsRequest) GetPageToken() string

func (*ListTransferJobsRequest) ProtoMessage

func (*ListTransferJobsRequest) ProtoMessage()

func (*ListTransferJobsRequest) ProtoReflect

func (x *ListTransferJobsRequest) ProtoReflect() protoreflect.Message

func (*ListTransferJobsRequest) Reset

func (x *ListTransferJobsRequest) Reset()

func (*ListTransferJobsRequest) String

func (x *ListTransferJobsRequest) String() string

type ListTransferJobsResponse

type ListTransferJobsResponse struct {

	// A list of transfer jobs.
	TransferJobs []*TransferJob `protobuf:"bytes,1,rep,name=transfer_jobs,json=transferJobs,proto3" json:"transfer_jobs,omitempty"`
	// The list next page token.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

Response from ListTransferJobs.

func (*ListTransferJobsResponse) Descriptor deprecated

func (*ListTransferJobsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListTransferJobsResponse.ProtoReflect.Descriptor instead.

func (*ListTransferJobsResponse) GetNextPageToken

func (x *ListTransferJobsResponse) GetNextPageToken() string

func (*ListTransferJobsResponse) GetTransferJobs

func (x *ListTransferJobsResponse) GetTransferJobs() []*TransferJob

func (*ListTransferJobsResponse) ProtoMessage

func (*ListTransferJobsResponse) ProtoMessage()

func (*ListTransferJobsResponse) ProtoReflect

func (x *ListTransferJobsResponse) ProtoReflect() protoreflect.Message

func (*ListTransferJobsResponse) Reset

func (x *ListTransferJobsResponse) Reset()

func (*ListTransferJobsResponse) String

func (x *ListTransferJobsResponse) String() string

type ObjectConditions

type ObjectConditions struct {

	// If unspecified, `minTimeElapsedSinceLastModification` takes a zero value
	// and `maxTimeElapsedSinceLastModification` takes the maximum possible
	// value of Duration. Objects that satisfy the object conditions
	// must either have a `lastModificationTime` greater or equal to
	// `NOW` - `maxTimeElapsedSinceLastModification` and less than
	// `NOW` - `minTimeElapsedSinceLastModification`, or not have a
	// `lastModificationTime`.
	MinTimeElapsedSinceLastModification *durationpb.Duration `` /* 174-byte string literal not displayed */
	// `maxTimeElapsedSinceLastModification` is the complement to
	// `minTimeElapsedSinceLastModification`.
	MaxTimeElapsedSinceLastModification *durationpb.Duration `` /* 174-byte string literal not displayed */
	// If `includePrefixes` is specified, objects that satisfy the object
	// conditions must have names that start with one of the `includePrefixes`
	// and that do not start with any of the `excludePrefixes`. If
	// `includePrefixes` is not specified, all objects except those that have
	// names starting with one of the `excludePrefixes` must satisfy the object
	// conditions.
	//
	// Requirements:
	//
	//   * Each include-prefix and exclude-prefix can contain any sequence of
	//     Unicode characters, of max length 1024 bytes when UTF8-encoded, and
	//     must not contain Carriage Return or Line Feed characters.  Wildcard
	//     matching and regular expression matching are not supported.
	//
	//   * Each include-prefix and exclude-prefix must omit the leading slash.
	//     For example, to include the `requests.gz` object in a transfer from
	//     `s3://my-aws-bucket/logs/y=2015/requests.gz`, specify the include
	//     prefix as `logs/y=2015/requests.gz`.
	//
	//   * None of the include-prefix or the exclude-prefix values can be empty,
	//     if specified.
	//
	//   * Each include-prefix must include a distinct portion of the object
	//     namespace, i.e., no include-prefix may be a prefix of another
	//     include-prefix.
	//
	//   * Each exclude-prefix must exclude a distinct portion of the object
	//     namespace, i.e., no exclude-prefix may be a prefix of another
	//     exclude-prefix.
	//
	//   * If `includePrefixes` is specified, then each exclude-prefix must start
	//     with the value of a path explicitly included by `includePrefixes`.
	//
	// The max size of `includePrefixes` is 1000.
	IncludePrefixes []string `protobuf:"bytes,3,rep,name=include_prefixes,json=includePrefixes,proto3" json:"include_prefixes,omitempty"`
	// `excludePrefixes` must follow the requirements described for
	// `includePrefixes`.
	//
	// The max size of `excludePrefixes` is 1000.
	ExcludePrefixes []string `protobuf:"bytes,4,rep,name=exclude_prefixes,json=excludePrefixes,proto3" json:"exclude_prefixes,omitempty"`
	// contains filtered or unexported fields
}

Conditions that determine which objects will be transferred.

func (*ObjectConditions) Descriptor deprecated

func (*ObjectConditions) Descriptor() ([]byte, []int)

Deprecated: Use ObjectConditions.ProtoReflect.Descriptor instead.

func (*ObjectConditions) GetExcludePrefixes

func (x *ObjectConditions) GetExcludePrefixes() []string

func (*ObjectConditions) GetIncludePrefixes

func (x *ObjectConditions) GetIncludePrefixes() []string

func (*ObjectConditions) GetMaxTimeElapsedSinceLastModification

func (x *ObjectConditions) GetMaxTimeElapsedSinceLastModification() *durationpb.Duration

func (*ObjectConditions) GetMinTimeElapsedSinceLastModification

func (x *ObjectConditions) GetMinTimeElapsedSinceLastModification() *durationpb.Duration

func (*ObjectConditions) ProtoMessage

func (*ObjectConditions) ProtoMessage()

func (*ObjectConditions) ProtoReflect

func (x *ObjectConditions) ProtoReflect() protoreflect.Message

func (*ObjectConditions) Reset

func (x *ObjectConditions) Reset()

func (*ObjectConditions) String

func (x *ObjectConditions) String() string

type PauseTransferOperationRequest

type PauseTransferOperationRequest struct {

	// The name of the transfer operation.
	// Required.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request passed to PauseTransferOperation.

func (*PauseTransferOperationRequest) Descriptor deprecated

func (*PauseTransferOperationRequest) Descriptor() ([]byte, []int)

Deprecated: Use PauseTransferOperationRequest.ProtoReflect.Descriptor instead.

func (*PauseTransferOperationRequest) GetName

func (*PauseTransferOperationRequest) ProtoMessage

func (*PauseTransferOperationRequest) ProtoMessage()

func (*PauseTransferOperationRequest) ProtoReflect

func (*PauseTransferOperationRequest) Reset

func (x *PauseTransferOperationRequest) Reset()

func (*PauseTransferOperationRequest) String

type ResumeTransferOperationRequest

type ResumeTransferOperationRequest struct {

	// The name of the transfer operation.
	// Required.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request passed to ResumeTransferOperation.

func (*ResumeTransferOperationRequest) Descriptor deprecated

func (*ResumeTransferOperationRequest) Descriptor() ([]byte, []int)

Deprecated: Use ResumeTransferOperationRequest.ProtoReflect.Descriptor instead.

func (*ResumeTransferOperationRequest) GetName

func (*ResumeTransferOperationRequest) ProtoMessage

func (*ResumeTransferOperationRequest) ProtoMessage()

func (*ResumeTransferOperationRequest) ProtoReflect

func (*ResumeTransferOperationRequest) Reset

func (x *ResumeTransferOperationRequest) Reset()

func (*ResumeTransferOperationRequest) String

type Schedule

type Schedule struct {

	// The first day the recurring transfer is scheduled to run. If
	// `scheduleStartDate` is in the past, the transfer will run for the first
	// time on the following day.
	// Required.
	ScheduleStartDate *date.Date `protobuf:"bytes,1,opt,name=schedule_start_date,json=scheduleStartDate,proto3" json:"schedule_start_date,omitempty"`
	// The last day the recurring transfer will be run. If `scheduleEndDate`
	// is the same as `scheduleStartDate`, the transfer will be executed only
	// once.
	ScheduleEndDate *date.Date `protobuf:"bytes,2,opt,name=schedule_end_date,json=scheduleEndDate,proto3" json:"schedule_end_date,omitempty"`
	// The time in UTC at which the transfer will be scheduled to start in a day.
	// Transfers may start later than this time. If not specified, recurring and
	// one-time transfers that are scheduled to run today will run immediately;
	// recurring transfers that are scheduled to run on a future date will start
	// at approximately midnight UTC on that date. Note that when configuring a
	// transfer with the Cloud Platform Console, the transfer's start time in a
	// day is specified in your local timezone.
	StartTimeOfDay *timeofday.TimeOfDay `protobuf:"bytes,3,opt,name=start_time_of_day,json=startTimeOfDay,proto3" json:"start_time_of_day,omitempty"`
	// contains filtered or unexported fields
}

Transfers can be scheduled to recur or to run just once.

func (*Schedule) Descriptor deprecated

func (*Schedule) Descriptor() ([]byte, []int)

Deprecated: Use Schedule.ProtoReflect.Descriptor instead.

func (*Schedule) GetScheduleEndDate

func (x *Schedule) GetScheduleEndDate() *date.Date

func (*Schedule) GetScheduleStartDate

func (x *Schedule) GetScheduleStartDate() *date.Date

func (*Schedule) GetStartTimeOfDay

func (x *Schedule) GetStartTimeOfDay() *timeofday.TimeOfDay

func (*Schedule) ProtoMessage

func (*Schedule) ProtoMessage()

func (*Schedule) ProtoReflect

func (x *Schedule) ProtoReflect() protoreflect.Message

func (*Schedule) Reset

func (x *Schedule) Reset()

func (*Schedule) String

func (x *Schedule) String() string

type StorageTransferServiceClient

type StorageTransferServiceClient interface {
	// Returns the Google service account that is used by Storage Transfer
	// Service to access buckets in the project where transfers
	// run or in other projects. Each Google service account is associated
	// with one Google Cloud Platform Console project. Users
	// should add this service account to the Google Cloud Storage bucket
	// ACLs to grant access to Storage Transfer Service. This service
	// account is created and owned by Storage Transfer Service and can
	// only be used by Storage Transfer Service.
	GetGoogleServiceAccount(ctx context.Context, in *GetGoogleServiceAccountRequest, opts ...grpc.CallOption) (*GoogleServiceAccount, error)
	// Creates a transfer job that runs periodically.
	CreateTransferJob(ctx context.Context, in *CreateTransferJobRequest, opts ...grpc.CallOption) (*TransferJob, error)
	// Updates a transfer job. Updating a job's transfer spec does not affect
	// transfer operations that are running already. Updating the scheduling
	// of a job is not allowed.
	UpdateTransferJob(ctx context.Context, in *UpdateTransferJobRequest, opts ...grpc.CallOption) (*TransferJob, error)
	// Gets a transfer job.
	GetTransferJob(ctx context.Context, in *GetTransferJobRequest, opts ...grpc.CallOption) (*TransferJob, error)
	// Lists transfer jobs.
	ListTransferJobs(ctx context.Context, in *ListTransferJobsRequest, opts ...grpc.CallOption) (*ListTransferJobsResponse, error)
	// Pauses a transfer operation.
	PauseTransferOperation(ctx context.Context, in *PauseTransferOperationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Resumes a transfer operation that is paused.
	ResumeTransferOperation(ctx context.Context, in *ResumeTransferOperationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

StorageTransferServiceClient is the client API for StorageTransferService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

type StorageTransferServiceServer

type StorageTransferServiceServer interface {
	// Returns the Google service account that is used by Storage Transfer
	// Service to access buckets in the project where transfers
	// run or in other projects. Each Google service account is associated
	// with one Google Cloud Platform Console project. Users
	// should add this service account to the Google Cloud Storage bucket
	// ACLs to grant access to Storage Transfer Service. This service
	// account is created and owned by Storage Transfer Service and can
	// only be used by Storage Transfer Service.
	GetGoogleServiceAccount(context.Context, *GetGoogleServiceAccountRequest) (*GoogleServiceAccount, error)
	// Creates a transfer job that runs periodically.
	CreateTransferJob(context.Context, *CreateTransferJobRequest) (*TransferJob, error)
	// Updates a transfer job. Updating a job's transfer spec does not affect
	// transfer operations that are running already. Updating the scheduling
	// of a job is not allowed.
	UpdateTransferJob(context.Context, *UpdateTransferJobRequest) (*TransferJob, error)
	// Gets a transfer job.
	GetTransferJob(context.Context, *GetTransferJobRequest) (*TransferJob, error)
	// Lists transfer jobs.
	ListTransferJobs(context.Context, *ListTransferJobsRequest) (*ListTransferJobsResponse, error)
	// Pauses a transfer operation.
	PauseTransferOperation(context.Context, *PauseTransferOperationRequest) (*emptypb.Empty, error)
	// Resumes a transfer operation that is paused.
	ResumeTransferOperation(context.Context, *ResumeTransferOperationRequest) (*emptypb.Empty, error)
}

StorageTransferServiceServer is the server API for StorageTransferService service.

type TransferCounters

type TransferCounters struct {

	// Objects found in the data source that are scheduled to be transferred,
	// excluding any that are filtered based on object conditions or skipped due
	// to sync.
	ObjectsFoundFromSource int64 `` /* 132-byte string literal not displayed */
	// Bytes found in the data source that are scheduled to be transferred,
	// excluding any that are filtered based on object conditions or skipped due
	// to sync.
	BytesFoundFromSource int64 `` /* 126-byte string literal not displayed */
	// Objects found only in the data sink that are scheduled to be deleted.
	ObjectsFoundOnlyFromSink int64 `` /* 140-byte string literal not displayed */
	// Bytes found only in the data sink that are scheduled to be deleted.
	BytesFoundOnlyFromSink int64 `` /* 134-byte string literal not displayed */
	// Objects in the data source that are not transferred because they already
	// exist in the data sink.
	ObjectsFromSourceSkippedBySync int64 `` /* 160-byte string literal not displayed */
	// Bytes in the data source that are not transferred because they already
	// exist in the data sink.
	BytesFromSourceSkippedBySync int64 `` /* 154-byte string literal not displayed */
	// Objects that are copied to the data sink.
	ObjectsCopiedToSink int64 `protobuf:"varint,7,opt,name=objects_copied_to_sink,json=objectsCopiedToSink,proto3" json:"objects_copied_to_sink,omitempty"`
	// Bytes that are copied to the data sink.
	BytesCopiedToSink int64 `protobuf:"varint,8,opt,name=bytes_copied_to_sink,json=bytesCopiedToSink,proto3" json:"bytes_copied_to_sink,omitempty"`
	// Objects that are deleted from the data source.
	ObjectsDeletedFromSource int64 `` /* 138-byte string literal not displayed */
	// Bytes that are deleted from the data source.
	BytesDeletedFromSource int64 `` /* 133-byte string literal not displayed */
	// Objects that are deleted from the data sink.
	ObjectsDeletedFromSink int64 `` /* 133-byte string literal not displayed */
	// Bytes that are deleted from the data sink.
	BytesDeletedFromSink int64 `` /* 127-byte string literal not displayed */
	// Objects in the data source that failed during the transfer.
	ObjectsFromSourceFailed int64 `` /* 136-byte string literal not displayed */
	// Bytes in the data source that failed during the transfer.
	BytesFromSourceFailed int64 `` /* 130-byte string literal not displayed */
	// Objects that failed to be deleted from the data sink.
	ObjectsFailedToDeleteFromSink int64 `` /* 158-byte string literal not displayed */
	// Bytes that failed to be deleted from the data sink.
	BytesFailedToDeleteFromSink int64 `` /* 152-byte string literal not displayed */
	// contains filtered or unexported fields
}

A collection of counters that report the progress of a transfer operation.

func (*TransferCounters) Descriptor deprecated

func (*TransferCounters) Descriptor() ([]byte, []int)

Deprecated: Use TransferCounters.ProtoReflect.Descriptor instead.

func (*TransferCounters) GetBytesCopiedToSink

func (x *TransferCounters) GetBytesCopiedToSink() int64

func (*TransferCounters) GetBytesDeletedFromSink

func (x *TransferCounters) GetBytesDeletedFromSink() int64

func (*TransferCounters) GetBytesDeletedFromSource

func (x *TransferCounters) GetBytesDeletedFromSource() int64

func (*TransferCounters) GetBytesFailedToDeleteFromSink

func (x *TransferCounters) GetBytesFailedToDeleteFromSink() int64

func (*TransferCounters) GetBytesFoundFromSource

func (x *TransferCounters) GetBytesFoundFromSource() int64

func (*TransferCounters) GetBytesFoundOnlyFromSink

func (x *TransferCounters) GetBytesFoundOnlyFromSink() int64

func (*TransferCounters) GetBytesFromSourceFailed

func (x *TransferCounters) GetBytesFromSourceFailed() int64

func (*TransferCounters) GetBytesFromSourceSkippedBySync

func (x *TransferCounters) GetBytesFromSourceSkippedBySync() int64

func (*TransferCounters) GetObjectsCopiedToSink

func (x *TransferCounters) GetObjectsCopiedToSink() int64

func (*TransferCounters) GetObjectsDeletedFromSink

func (x *TransferCounters) GetObjectsDeletedFromSink() int64

func (*TransferCounters) GetObjectsDeletedFromSource

func (x *TransferCounters) GetObjectsDeletedFromSource() int64

func (*TransferCounters) GetObjectsFailedToDeleteFromSink

func (x *TransferCounters) GetObjectsFailedToDeleteFromSink() int64

func (*TransferCounters) GetObjectsFoundFromSource

func (x *TransferCounters) GetObjectsFoundFromSource() int64

func (*TransferCounters) GetObjectsFoundOnlyFromSink

func (x *TransferCounters) GetObjectsFoundOnlyFromSink() int64

func (*TransferCounters) GetObjectsFromSourceFailed

func (x *TransferCounters) GetObjectsFromSourceFailed() int64

func (*TransferCounters) GetObjectsFromSourceSkippedBySync

func (x *TransferCounters) GetObjectsFromSourceSkippedBySync() int64

func (*TransferCounters) ProtoMessage

func (*TransferCounters) ProtoMessage()

func (*TransferCounters) ProtoReflect

func (x *TransferCounters) ProtoReflect() protoreflect.Message

func (*TransferCounters) Reset

func (x *TransferCounters) Reset()

func (*TransferCounters) String

func (x *TransferCounters) String() string

type TransferJob

type TransferJob struct {

	// A globally unique name assigned by Storage Transfer Service when the
	// job is created. This field should be left empty in requests to create a new
	// transfer job; otherwise, the requests result in an `INVALID_ARGUMENT`
	// error.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// A description provided by the user for the job. Its max length is 1024
	// bytes when Unicode-encoded.
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// The ID of the Google Cloud Platform Console project that owns the job.
	ProjectId string `protobuf:"bytes,3,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// Transfer specification.
	TransferSpec *TransferSpec `protobuf:"bytes,4,opt,name=transfer_spec,json=transferSpec,proto3" json:"transfer_spec,omitempty"`
	// Schedule specification.
	Schedule *Schedule `protobuf:"bytes,5,opt,name=schedule,proto3" json:"schedule,omitempty"`
	// Status of the job. This value MUST be specified for
	// `CreateTransferJobRequests`.
	//
	// NOTE: The effect of the new job status takes place during a subsequent job
	// run. For example, if you change the job status from `ENABLED` to
	// `DISABLED`, and an operation spawned by the transfer is running, the status
	// change would not affect the current operation.
	Status TransferJob_Status `protobuf:"varint,6,opt,name=status,proto3,enum=google.storagetransfer.v1.TransferJob_Status" json:"status,omitempty"`
	// This field cannot be changed by user requests.
	CreationTime *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=creation_time,json=creationTime,proto3" json:"creation_time,omitempty"`
	// This field cannot be changed by user requests.
	LastModificationTime *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=last_modification_time,json=lastModificationTime,proto3" json:"last_modification_time,omitempty"`
	// This field cannot be changed by user requests.
	DeletionTime *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=deletion_time,json=deletionTime,proto3" json:"deletion_time,omitempty"`
	// contains filtered or unexported fields
}

This resource represents the configuration of a transfer job that runs periodically.

func (*TransferJob) Descriptor deprecated

func (*TransferJob) Descriptor() ([]byte, []int)

Deprecated: Use TransferJob.ProtoReflect.Descriptor instead.

func (*TransferJob) GetCreationTime

func (x *TransferJob) GetCreationTime() *timestamppb.Timestamp

func (*TransferJob) GetDeletionTime

func (x *TransferJob) GetDeletionTime() *timestamppb.Timestamp

func (*TransferJob) GetDescription

func (x *TransferJob) GetDescription() string

func (*TransferJob) GetLastModificationTime

func (x *TransferJob) GetLastModificationTime() *timestamppb.Timestamp

func (*TransferJob) GetName

func (x *TransferJob) GetName() string

func (*TransferJob) GetProjectId

func (x *TransferJob) GetProjectId() string

func (*TransferJob) GetSchedule

func (x *TransferJob) GetSchedule() *Schedule

func (*TransferJob) GetStatus

func (x *TransferJob) GetStatus() TransferJob_Status

func (*TransferJob) GetTransferSpec

func (x *TransferJob) GetTransferSpec() *TransferSpec

func (*TransferJob) ProtoMessage

func (*TransferJob) ProtoMessage()

func (*TransferJob) ProtoReflect

func (x *TransferJob) ProtoReflect() protoreflect.Message

func (*TransferJob) Reset

func (x *TransferJob) Reset()

func (*TransferJob) String

func (x *TransferJob) String() string

type TransferJob_Status

type TransferJob_Status int32

The status of the transfer job.

const (
	// Zero is an illegal value.
	TransferJob_STATUS_UNSPECIFIED TransferJob_Status = 0
	// New transfers will be performed based on the schedule.
	TransferJob_ENABLED TransferJob_Status = 1
	// New transfers will not be scheduled.
	TransferJob_DISABLED TransferJob_Status = 2
	// This is a soft delete state. After a transfer job is set to this
	// state, the job and all the transfer executions are subject to
	// garbage collection.
	TransferJob_DELETED TransferJob_Status = 3
)

func (TransferJob_Status) Descriptor

func (TransferJob_Status) Enum

func (TransferJob_Status) EnumDescriptor deprecated

func (TransferJob_Status) EnumDescriptor() ([]byte, []int)

Deprecated: Use TransferJob_Status.Descriptor instead.

func (TransferJob_Status) Number

func (TransferJob_Status) String

func (x TransferJob_Status) String() string

func (TransferJob_Status) Type

type TransferOperation

type TransferOperation struct {

	// A globally unique ID assigned by the system.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The ID of the Google Cloud Platform Console project that owns the
	// operation. Required.
	ProjectId string `protobuf:"bytes,2,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// Transfer specification.
	// Required.
	TransferSpec *TransferSpec `protobuf:"bytes,3,opt,name=transfer_spec,json=transferSpec,proto3" json:"transfer_spec,omitempty"`
	// Start time of this transfer execution.
	StartTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// End time of this transfer execution.
	EndTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// Status of the transfer operation.
	Status TransferOperation_Status `protobuf:"varint,6,opt,name=status,proto3,enum=google.storagetransfer.v1.TransferOperation_Status" json:"status,omitempty"`
	// Information about the progress of the transfer operation.
	Counters *TransferCounters `protobuf:"bytes,7,opt,name=counters,proto3" json:"counters,omitempty"`
	// Summarizes errors encountered with sample error log entries.
	ErrorBreakdowns []*ErrorSummary `protobuf:"bytes,8,rep,name=error_breakdowns,json=errorBreakdowns,proto3" json:"error_breakdowns,omitempty"`
	// The name of the transfer job that triggers this transfer operation.
	TransferJobName string `protobuf:"bytes,9,opt,name=transfer_job_name,json=transferJobName,proto3" json:"transfer_job_name,omitempty"`
	// contains filtered or unexported fields
}

A description of the execution of a transfer.

func (*TransferOperation) Descriptor deprecated

func (*TransferOperation) Descriptor() ([]byte, []int)

Deprecated: Use TransferOperation.ProtoReflect.Descriptor instead.

func (*TransferOperation) GetCounters

func (x *TransferOperation) GetCounters() *TransferCounters

func (*TransferOperation) GetEndTime

func (x *TransferOperation) GetEndTime() *timestamppb.Timestamp

func (*TransferOperation) GetErrorBreakdowns

func (x *TransferOperation) GetErrorBreakdowns() []*ErrorSummary

func (*TransferOperation) GetName

func (x *TransferOperation) GetName() string

func (*TransferOperation) GetProjectId

func (x *TransferOperation) GetProjectId() string

func (*TransferOperation) GetStartTime

func (x *TransferOperation) GetStartTime() *timestamppb.Timestamp

func (*TransferOperation) GetStatus

func (*TransferOperation) GetTransferJobName

func (x *TransferOperation) GetTransferJobName() string

func (*TransferOperation) GetTransferSpec

func (x *TransferOperation) GetTransferSpec() *TransferSpec

func (*TransferOperation) ProtoMessage

func (*TransferOperation) ProtoMessage()

func (*TransferOperation) ProtoReflect

func (x *TransferOperation) ProtoReflect() protoreflect.Message

func (*TransferOperation) Reset

func (x *TransferOperation) Reset()

func (*TransferOperation) String

func (x *TransferOperation) String() string

type TransferOperation_Status

type TransferOperation_Status int32

The status of a TransferOperation.

const (
	// Zero is an illegal value.
	TransferOperation_STATUS_UNSPECIFIED TransferOperation_Status = 0
	// In progress.
	TransferOperation_IN_PROGRESS TransferOperation_Status = 1
	// Paused.
	TransferOperation_PAUSED TransferOperation_Status = 2
	// Completed successfully.
	TransferOperation_SUCCESS TransferOperation_Status = 3
	// Terminated due to an unrecoverable failure.
	TransferOperation_FAILED TransferOperation_Status = 4
	// Aborted by the user.
	TransferOperation_ABORTED TransferOperation_Status = 5
)

func (TransferOperation_Status) Descriptor

func (TransferOperation_Status) Enum

func (TransferOperation_Status) EnumDescriptor deprecated

func (TransferOperation_Status) EnumDescriptor() ([]byte, []int)

Deprecated: Use TransferOperation_Status.Descriptor instead.

func (TransferOperation_Status) Number

func (TransferOperation_Status) String

func (x TransferOperation_Status) String() string

func (TransferOperation_Status) Type

type TransferOptions

type TransferOptions struct {

	// Whether overwriting objects that already exist in the sink is allowed.
	OverwriteObjectsAlreadyExistingInSink bool `` /* 181-byte string literal not displayed */
	// Whether objects that exist only in the sink should be deleted.  Note that
	// this option and `deleteObjectsFromSourceAfterTransfer` are mutually
	// exclusive.
	DeleteObjectsUniqueInSink bool `` /* 143-byte string literal not displayed */
	// Whether objects should be deleted from the source after they are
	// transferred to the sink.  Note that this option and
	// `deleteObjectsUniqueInSink` are mutually exclusive.
	DeleteObjectsFromSourceAfterTransfer bool `` /* 178-byte string literal not displayed */
	// contains filtered or unexported fields
}

TransferOptions uses three boolean parameters to define the actions to be performed on objects in a transfer.

func (*TransferOptions) Descriptor deprecated

func (*TransferOptions) Descriptor() ([]byte, []int)

Deprecated: Use TransferOptions.ProtoReflect.Descriptor instead.

func (*TransferOptions) GetDeleteObjectsFromSourceAfterTransfer

func (x *TransferOptions) GetDeleteObjectsFromSourceAfterTransfer() bool

func (*TransferOptions) GetDeleteObjectsUniqueInSink

func (x *TransferOptions) GetDeleteObjectsUniqueInSink() bool

func (*TransferOptions) GetOverwriteObjectsAlreadyExistingInSink

func (x *TransferOptions) GetOverwriteObjectsAlreadyExistingInSink() bool

func (*TransferOptions) ProtoMessage

func (*TransferOptions) ProtoMessage()

func (*TransferOptions) ProtoReflect

func (x *TransferOptions) ProtoReflect() protoreflect.Message

func (*TransferOptions) Reset

func (x *TransferOptions) Reset()

func (*TransferOptions) String

func (x *TransferOptions) String() string

type TransferSpec

type TransferSpec struct {

	// The read source of the data.
	//
	// Types that are assignable to DataSource:
	//	*TransferSpec_GcsDataSource
	//	*TransferSpec_AwsS3DataSource
	//	*TransferSpec_HttpDataSource
	DataSource isTransferSpec_DataSource `protobuf_oneof:"data_source"`
	// The write sink for the data.
	//
	// Types that are assignable to DataSink:
	//	*TransferSpec_GcsDataSink
	DataSink isTransferSpec_DataSink `protobuf_oneof:"data_sink"`
	// Only objects that satisfy these object conditions are included in the set
	// of data source and data sink objects.  Object conditions based on
	// objects' `lastModificationTime` do not exclude objects in a data sink.
	ObjectConditions *ObjectConditions `protobuf:"bytes,5,opt,name=object_conditions,json=objectConditions,proto3" json:"object_conditions,omitempty"`
	// If the option `deleteObjectsUniqueInSink` is `true`, object conditions
	// based on objects' `lastModificationTime` are ignored and do not exclude
	// objects in a data source or a data sink.
	TransferOptions *TransferOptions `protobuf:"bytes,6,opt,name=transfer_options,json=transferOptions,proto3" json:"transfer_options,omitempty"`
	// contains filtered or unexported fields
}

Configuration for running a transfer.

func (*TransferSpec) Descriptor deprecated

func (*TransferSpec) Descriptor() ([]byte, []int)

Deprecated: Use TransferSpec.ProtoReflect.Descriptor instead.

func (*TransferSpec) GetAwsS3DataSource

func (x *TransferSpec) GetAwsS3DataSource() *AwsS3Data

func (*TransferSpec) GetDataSink

func (m *TransferSpec) GetDataSink() isTransferSpec_DataSink

func (*TransferSpec) GetDataSource

func (m *TransferSpec) GetDataSource() isTransferSpec_DataSource

func (*TransferSpec) GetGcsDataSink

func (x *TransferSpec) GetGcsDataSink() *GcsData

func (*TransferSpec) GetGcsDataSource

func (x *TransferSpec) GetGcsDataSource() *GcsData

func (*TransferSpec) GetHttpDataSource

func (x *TransferSpec) GetHttpDataSource() *HttpData

func (*TransferSpec) GetObjectConditions

func (x *TransferSpec) GetObjectConditions() *ObjectConditions

func (*TransferSpec) GetTransferOptions

func (x *TransferSpec) GetTransferOptions() *TransferOptions

func (*TransferSpec) ProtoMessage

func (*TransferSpec) ProtoMessage()

func (*TransferSpec) ProtoReflect

func (x *TransferSpec) ProtoReflect() protoreflect.Message

func (*TransferSpec) Reset

func (x *TransferSpec) Reset()

func (*TransferSpec) String

func (x *TransferSpec) String() string

type TransferSpec_AwsS3DataSource

type TransferSpec_AwsS3DataSource struct {
	// An AWS S3 data source.
	AwsS3DataSource *AwsS3Data `protobuf:"bytes,2,opt,name=aws_s3_data_source,json=awsS3DataSource,proto3,oneof"`
}

type TransferSpec_GcsDataSink

type TransferSpec_GcsDataSink struct {
	// A Google Cloud Storage data sink.
	GcsDataSink *GcsData `protobuf:"bytes,4,opt,name=gcs_data_sink,json=gcsDataSink,proto3,oneof"`
}

type TransferSpec_GcsDataSource

type TransferSpec_GcsDataSource struct {
	// A Google Cloud Storage data source.
	GcsDataSource *GcsData `protobuf:"bytes,1,opt,name=gcs_data_source,json=gcsDataSource,proto3,oneof"`
}

type TransferSpec_HttpDataSource

type TransferSpec_HttpDataSource struct {
	// An HTTP URL data source.
	HttpDataSource *HttpData `protobuf:"bytes,3,opt,name=http_data_source,json=httpDataSource,proto3,oneof"`
}

type UnimplementedStorageTransferServiceServer

type UnimplementedStorageTransferServiceServer struct {
}

UnimplementedStorageTransferServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedStorageTransferServiceServer) CreateTransferJob

func (*UnimplementedStorageTransferServiceServer) GetGoogleServiceAccount

func (*UnimplementedStorageTransferServiceServer) GetTransferJob

func (*UnimplementedStorageTransferServiceServer) ListTransferJobs

func (*UnimplementedStorageTransferServiceServer) PauseTransferOperation

func (*UnimplementedStorageTransferServiceServer) ResumeTransferOperation

func (*UnimplementedStorageTransferServiceServer) UpdateTransferJob

type UpdateTransferJobRequest

type UpdateTransferJobRequest struct {

	// The name of job to update.
	// Required.
	JobName string `protobuf:"bytes,1,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
	// The ID of the Google Cloud Platform Console project that owns the job.
	// Required.
	ProjectId string `protobuf:"bytes,2,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// The job to update. `transferJob` is expected to specify only three fields:
	// `description`, `transferSpec`, and `status`.  An UpdateTransferJobRequest
	// that specifies other fields will be rejected with an error
	// `INVALID_ARGUMENT`.
	// Required.
	TransferJob *TransferJob `protobuf:"bytes,3,opt,name=transfer_job,json=transferJob,proto3" json:"transfer_job,omitempty"`
	// The field mask of the fields in `transferJob` that are to be updated in
	// this request.  Fields in `transferJob` that can be updated are:
	// `description`, `transferSpec`, and `status`.  To update the `transferSpec`
	// of the job, a complete transfer specification has to be provided. An
	// incomplete specification which misses any required fields will be rejected
	// with the error `INVALID_ARGUMENT`.
	UpdateTransferJobFieldMask *fieldmaskpb.FieldMask `` /* 145-byte string literal not displayed */
	// contains filtered or unexported fields
}

Request passed to UpdateTransferJob.

func (*UpdateTransferJobRequest) Descriptor deprecated

func (*UpdateTransferJobRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateTransferJobRequest.ProtoReflect.Descriptor instead.

func (*UpdateTransferJobRequest) GetJobName

func (x *UpdateTransferJobRequest) GetJobName() string

func (*UpdateTransferJobRequest) GetProjectId

func (x *UpdateTransferJobRequest) GetProjectId() string

func (*UpdateTransferJobRequest) GetTransferJob

func (x *UpdateTransferJobRequest) GetTransferJob() *TransferJob

func (*UpdateTransferJobRequest) GetUpdateTransferJobFieldMask

func (x *UpdateTransferJobRequest) GetUpdateTransferJobFieldMask() *fieldmaskpb.FieldMask

func (*UpdateTransferJobRequest) ProtoMessage

func (*UpdateTransferJobRequest) ProtoMessage()

func (*UpdateTransferJobRequest) ProtoReflect

func (x *UpdateTransferJobRequest) ProtoReflect() protoreflect.Message

func (*UpdateTransferJobRequest) Reset

func (x *UpdateTransferJobRequest) Reset()

func (*UpdateTransferJobRequest) String

func (x *UpdateTransferJobRequest) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL