storagetransfer - ActiveState ActiveGo 1.8
...

Package storagetransfer

import "google.golang.org/genproto/googleapis/storagetransfer/v1"
Overview
Index

Overview ▾

Package storagetransfer is a generated protocol buffer package.

It is generated from these files:

google/storagetransfer/v1/transfer.proto
google/storagetransfer/v1/transfer_types.proto

It has these top-level messages:

GetGoogleServiceAccountRequest
CreateTransferJobRequest
UpdateTransferJobRequest
GetTransferJobRequest
ListTransferJobsRequest
ListTransferJobsResponse
PauseTransferOperationRequest
ResumeTransferOperationRequest
GoogleServiceAccount
AwsAccessKey
ObjectConditions
GcsData
AwsS3Data
HttpData
TransferOptions
TransferSpec
Schedule
TransferJob
ErrorLogEntry
ErrorSummary
TransferCounters
TransferOperation

Index ▾

Variables
func RegisterStorageTransferServiceServer(s *grpc.Server, srv StorageTransferServiceServer)
type AwsAccessKey
    func (*AwsAccessKey) Descriptor() ([]byte, []int)
    func (m *AwsAccessKey) GetAccessKeyId() string
    func (m *AwsAccessKey) GetSecretAccessKey() string
    func (*AwsAccessKey) ProtoMessage()
    func (m *AwsAccessKey) Reset()
    func (m *AwsAccessKey) String() string
type AwsS3Data
    func (*AwsS3Data) Descriptor() ([]byte, []int)
    func (m *AwsS3Data) GetAwsAccessKey() *AwsAccessKey
    func (m *AwsS3Data) GetBucketName() string
    func (*AwsS3Data) ProtoMessage()
    func (m *AwsS3Data) Reset()
    func (m *AwsS3Data) String() string
type CreateTransferJobRequest
    func (*CreateTransferJobRequest) Descriptor() ([]byte, []int)
    func (m *CreateTransferJobRequest) GetTransferJob() *TransferJob
    func (*CreateTransferJobRequest) ProtoMessage()
    func (m *CreateTransferJobRequest) Reset()
    func (m *CreateTransferJobRequest) String() string
type ErrorLogEntry
    func (*ErrorLogEntry) Descriptor() ([]byte, []int)
    func (m *ErrorLogEntry) GetErrorDetails() []string
    func (m *ErrorLogEntry) GetUrl() string
    func (*ErrorLogEntry) ProtoMessage()
    func (m *ErrorLogEntry) Reset()
    func (m *ErrorLogEntry) String() string
type ErrorSummary
    func (*ErrorSummary) Descriptor() ([]byte, []int)
    func (m *ErrorSummary) GetErrorCode() google_rpc.Code
    func (m *ErrorSummary) GetErrorCount() int64
    func (m *ErrorSummary) GetErrorLogEntries() []*ErrorLogEntry
    func (*ErrorSummary) ProtoMessage()
    func (m *ErrorSummary) Reset()
    func (m *ErrorSummary) String() string
type GcsData
    func (*GcsData) Descriptor() ([]byte, []int)
    func (m *GcsData) GetBucketName() string
    func (*GcsData) ProtoMessage()
    func (m *GcsData) Reset()
    func (m *GcsData) String() string
type GetGoogleServiceAccountRequest
    func (*GetGoogleServiceAccountRequest) Descriptor() ([]byte, []int)
    func (m *GetGoogleServiceAccountRequest) GetProjectId() string
    func (*GetGoogleServiceAccountRequest) ProtoMessage()
    func (m *GetGoogleServiceAccountRequest) Reset()
    func (m *GetGoogleServiceAccountRequest) String() string
type GetTransferJobRequest
    func (*GetTransferJobRequest) Descriptor() ([]byte, []int)
    func (m *GetTransferJobRequest) GetJobName() string
    func (m *GetTransferJobRequest) GetProjectId() string
    func (*GetTransferJobRequest) ProtoMessage()
    func (m *GetTransferJobRequest) Reset()
    func (m *GetTransferJobRequest) String() string
type GoogleServiceAccount
    func (*GoogleServiceAccount) Descriptor() ([]byte, []int)
    func (m *GoogleServiceAccount) GetAccountEmail() string
    func (*GoogleServiceAccount) ProtoMessage()
    func (m *GoogleServiceAccount) Reset()
    func (m *GoogleServiceAccount) String() string
type HttpData
    func (*HttpData) Descriptor() ([]byte, []int)
    func (m *HttpData) GetListUrl() string
    func (*HttpData) ProtoMessage()
    func (m *HttpData) Reset()
    func (m *HttpData) String() string
type ListTransferJobsRequest
    func (*ListTransferJobsRequest) Descriptor() ([]byte, []int)
    func (m *ListTransferJobsRequest) GetFilter() string
    func (m *ListTransferJobsRequest) GetPageSize() int32
    func (m *ListTransferJobsRequest) GetPageToken() string
    func (*ListTransferJobsRequest) ProtoMessage()
    func (m *ListTransferJobsRequest) Reset()
    func (m *ListTransferJobsRequest) String() string
type ListTransferJobsResponse
    func (*ListTransferJobsResponse) Descriptor() ([]byte, []int)
    func (m *ListTransferJobsResponse) GetNextPageToken() string
    func (m *ListTransferJobsResponse) GetTransferJobs() []*TransferJob
    func (*ListTransferJobsResponse) ProtoMessage()
    func (m *ListTransferJobsResponse) Reset()
    func (m *ListTransferJobsResponse) String() string
type ObjectConditions
    func (*ObjectConditions) Descriptor() ([]byte, []int)
    func (m *ObjectConditions) GetExcludePrefixes() []string
    func (m *ObjectConditions) GetIncludePrefixes() []string
    func (m *ObjectConditions) GetMaxTimeElapsedSinceLastModification() *google_protobuf3.Duration
    func (m *ObjectConditions) GetMinTimeElapsedSinceLastModification() *google_protobuf3.Duration
    func (*ObjectConditions) ProtoMessage()
    func (m *ObjectConditions) Reset()
    func (m *ObjectConditions) String() string
type PauseTransferOperationRequest
    func (*PauseTransferOperationRequest) Descriptor() ([]byte, []int)
    func (m *PauseTransferOperationRequest) GetName() string
    func (*PauseTransferOperationRequest) ProtoMessage()
    func (m *PauseTransferOperationRequest) Reset()
    func (m *PauseTransferOperationRequest) String() string
type ResumeTransferOperationRequest
    func (*ResumeTransferOperationRequest) Descriptor() ([]byte, []int)
    func (m *ResumeTransferOperationRequest) GetName() string
    func (*ResumeTransferOperationRequest) ProtoMessage()
    func (m *ResumeTransferOperationRequest) Reset()
    func (m *ResumeTransferOperationRequest) String() string
type Schedule
    func (*Schedule) Descriptor() ([]byte, []int)
    func (m *Schedule) GetScheduleEndDate() *google_type.Date
    func (m *Schedule) GetScheduleStartDate() *google_type.Date
    func (m *Schedule) GetStartTimeOfDay() *google_type1.TimeOfDay
    func (*Schedule) ProtoMessage()
    func (m *Schedule) Reset()
    func (m *Schedule) String() string
type StorageTransferServiceClient
    func NewStorageTransferServiceClient(cc *grpc.ClientConn) StorageTransferServiceClient
type StorageTransferServiceServer
type TransferCounters
    func (*TransferCounters) Descriptor() ([]byte, []int)
    func (m *TransferCounters) GetBytesCopiedToSink() int64
    func (m *TransferCounters) GetBytesDeletedFromSink() int64
    func (m *TransferCounters) GetBytesDeletedFromSource() int64
    func (m *TransferCounters) GetBytesFailedToDeleteFromSink() int64
    func (m *TransferCounters) GetBytesFoundFromSource() int64
    func (m *TransferCounters) GetBytesFoundOnlyFromSink() int64
    func (m *TransferCounters) GetBytesFromSourceFailed() int64
    func (m *TransferCounters) GetBytesFromSourceSkippedBySync() int64
    func (m *TransferCounters) GetObjectsCopiedToSink() int64
    func (m *TransferCounters) GetObjectsDeletedFromSink() int64
    func (m *TransferCounters) GetObjectsDeletedFromSource() int64
    func (m *TransferCounters) GetObjectsFailedToDeleteFromSink() int64
    func (m *TransferCounters) GetObjectsFoundFromSource() int64
    func (m *TransferCounters) GetObjectsFoundOnlyFromSink() int64
    func (m *TransferCounters) GetObjectsFromSourceFailed() int64
    func (m *TransferCounters) GetObjectsFromSourceSkippedBySync() int64
    func (*TransferCounters) ProtoMessage()
    func (m *TransferCounters) Reset()
    func (m *TransferCounters) String() string
type TransferJob
    func (*TransferJob) Descriptor() ([]byte, []int)
    func (m *TransferJob) GetCreationTime() *google_protobuf4.Timestamp
    func (m *TransferJob) GetDeletionTime() *google_protobuf4.Timestamp
    func (m *TransferJob) GetDescription() string
    func (m *TransferJob) GetLastModificationTime() *google_protobuf4.Timestamp
    func (m *TransferJob) GetName() string
    func (m *TransferJob) GetProjectId() string
    func (m *TransferJob) GetSchedule() *Schedule
    func (m *TransferJob) GetStatus() TransferJob_Status
    func (m *TransferJob) GetTransferSpec() *TransferSpec
    func (*TransferJob) ProtoMessage()
    func (m *TransferJob) Reset()
    func (m *TransferJob) String() string
type TransferJob_Status
    func (TransferJob_Status) EnumDescriptor() ([]byte, []int)
    func (x TransferJob_Status) String() string
type TransferOperation
    func (*TransferOperation) Descriptor() ([]byte, []int)
    func (m *TransferOperation) GetCounters() *TransferCounters
    func (m *TransferOperation) GetEndTime() *google_protobuf4.Timestamp
    func (m *TransferOperation) GetErrorBreakdowns() []*ErrorSummary
    func (m *TransferOperation) GetName() string
    func (m *TransferOperation) GetProjectId() string
    func (m *TransferOperation) GetStartTime() *google_protobuf4.Timestamp
    func (m *TransferOperation) GetStatus() TransferOperation_Status
    func (m *TransferOperation) GetTransferJobName() string
    func (m *TransferOperation) GetTransferSpec() *TransferSpec
    func (*TransferOperation) ProtoMessage()
    func (m *TransferOperation) Reset()
    func (m *TransferOperation) String() string
type TransferOperation_Status
    func (TransferOperation_Status) EnumDescriptor() ([]byte, []int)
    func (x TransferOperation_Status) String() string
type TransferOptions
    func (*TransferOptions) Descriptor() ([]byte, []int)
    func (m *TransferOptions) GetDeleteObjectsFromSourceAfterTransfer() bool
    func (m *TransferOptions) GetDeleteObjectsUniqueInSink() bool
    func (m *TransferOptions) GetOverwriteObjectsAlreadyExistingInSink() bool
    func (*TransferOptions) ProtoMessage()
    func (m *TransferOptions) Reset()
    func (m *TransferOptions) String() string
type TransferSpec
    func (*TransferSpec) Descriptor() ([]byte, []int)
    func (m *TransferSpec) GetAwsS3DataSource() *AwsS3Data
    func (m *TransferSpec) GetDataSink() isTransferSpec_DataSink
    func (m *TransferSpec) GetDataSource() isTransferSpec_DataSource
    func (m *TransferSpec) GetGcsDataSink() *GcsData
    func (m *TransferSpec) GetGcsDataSource() *GcsData
    func (m *TransferSpec) GetHttpDataSource() *HttpData
    func (m *TransferSpec) GetObjectConditions() *ObjectConditions
    func (m *TransferSpec) GetTransferOptions() *TransferOptions
    func (*TransferSpec) ProtoMessage()
    func (m *TransferSpec) Reset()
    func (m *TransferSpec) String() string
    func (*TransferSpec) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
type TransferSpec_AwsS3DataSource
type TransferSpec_GcsDataSink
type TransferSpec_GcsDataSource
type TransferSpec_HttpDataSource
type UpdateTransferJobRequest
    func (*UpdateTransferJobRequest) Descriptor() ([]byte, []int)
    func (m *UpdateTransferJobRequest) GetJobName() string
    func (m *UpdateTransferJobRequest) GetProjectId() string
    func (m *UpdateTransferJobRequest) GetTransferJob() *TransferJob
    func (m *UpdateTransferJobRequest) GetUpdateTransferJobFieldMask() *google_protobuf2.FieldMask
    func (*UpdateTransferJobRequest) ProtoMessage()
    func (m *UpdateTransferJobRequest) Reset()
    func (m *UpdateTransferJobRequest) String() string

Package files

transfer.pb.go transfer_types.pb.go

Variables

var TransferJob_Status_name = map[int32]string{
    0: "STATUS_UNSPECIFIED",
    1: "ENABLED",
    2: "DISABLED",
    3: "DELETED",
}
var TransferJob_Status_value = map[string]int32{
    "STATUS_UNSPECIFIED": 0,
    "ENABLED":            1,
    "DISABLED":           2,
    "DELETED":            3,
}
var TransferOperation_Status_name = map[int32]string{
    0: "STATUS_UNSPECIFIED",
    1: "IN_PROGRESS",
    2: "PAUSED",
    3: "SUCCESS",
    4: "FAILED",
    5: "ABORTED",
}
var TransferOperation_Status_value = map[string]int32{
    "STATUS_UNSPECIFIED": 0,
    "IN_PROGRESS":        1,
    "PAUSED":             2,
    "SUCCESS":            3,
    "FAILED":             4,
    "ABORTED":            5,
}

func RegisterStorageTransferServiceServer

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

type AwsAccessKey

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

type AwsAccessKey struct {
    // AWS access key ID.
    // Required.
    AccessKeyId string `protobuf:"bytes,1,opt,name=access_key_id,json=accessKeyId" 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" json:"secret_access_key,omitempty"`
}

func (*AwsAccessKey) Descriptor

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

func (*AwsAccessKey) GetAccessKeyId

func (m *AwsAccessKey) GetAccessKeyId() string

func (*AwsAccessKey) GetSecretAccessKey

func (m *AwsAccessKey) GetSecretAccessKey() string

func (*AwsAccessKey) ProtoMessage

func (*AwsAccessKey) ProtoMessage()

func (*AwsAccessKey) Reset

func (m *AwsAccessKey) Reset()

func (*AwsAccessKey) String

func (m *AwsAccessKey) String() string

type AwsS3Data

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.

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" 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" json:"aws_access_key,omitempty"`
}

func (*AwsS3Data) Descriptor

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

func (*AwsS3Data) GetAwsAccessKey

func (m *AwsS3Data) GetAwsAccessKey() *AwsAccessKey

func (*AwsS3Data) GetBucketName

func (m *AwsS3Data) GetBucketName() string

func (*AwsS3Data) ProtoMessage

func (*AwsS3Data) ProtoMessage()

func (*AwsS3Data) Reset

func (m *AwsS3Data) Reset()

func (*AwsS3Data) String

func (m *AwsS3Data) String() string

type CreateTransferJobRequest

Request passed to CreateTransferJob.

type CreateTransferJobRequest struct {
    // The job to create.
    // Required.
    TransferJob *TransferJob `protobuf:"bytes,1,opt,name=transfer_job,json=transferJob" json:"transfer_job,omitempty"`
}

func (*CreateTransferJobRequest) Descriptor

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

func (*CreateTransferJobRequest) GetTransferJob

func (m *CreateTransferJobRequest) GetTransferJob() *TransferJob

func (*CreateTransferJobRequest) ProtoMessage

func (*CreateTransferJobRequest) ProtoMessage()

func (*CreateTransferJobRequest) Reset

func (m *CreateTransferJobRequest) Reset()

func (*CreateTransferJobRequest) String

func (m *CreateTransferJobRequest) String() string

type ErrorLogEntry

An entry describing an error that has occurred.

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" json:"url,omitempty"`
    // A list of messages that carry the error details.
    ErrorDetails []string `protobuf:"bytes,3,rep,name=error_details,json=errorDetails" json:"error_details,omitempty"`
}

func (*ErrorLogEntry) Descriptor

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

func (*ErrorLogEntry) GetErrorDetails

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

func (*ErrorLogEntry) GetUrl

func (m *ErrorLogEntry) GetUrl() string

func (*ErrorLogEntry) ProtoMessage

func (*ErrorLogEntry) ProtoMessage()

func (*ErrorLogEntry) Reset

func (m *ErrorLogEntry) Reset()

func (*ErrorLogEntry) String

func (m *ErrorLogEntry) String() string

type ErrorSummary

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

type ErrorSummary struct {
    // Required.
    ErrorCode google_rpc.Code `protobuf:"varint,1,opt,name=error_code,json=errorCode,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" json:"error_count,omitempty"`
    // Error samples.
    ErrorLogEntries []*ErrorLogEntry `protobuf:"bytes,3,rep,name=error_log_entries,json=errorLogEntries" json:"error_log_entries,omitempty"`
}

func (*ErrorSummary) Descriptor

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

func (*ErrorSummary) GetErrorCode

func (m *ErrorSummary) GetErrorCode() google_rpc.Code

func (*ErrorSummary) GetErrorCount

func (m *ErrorSummary) GetErrorCount() int64

func (*ErrorSummary) GetErrorLogEntries

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

func (*ErrorSummary) ProtoMessage

func (*ErrorSummary) ProtoMessage()

func (*ErrorSummary) Reset

func (m *ErrorSummary) Reset()

func (*ErrorSummary) String

func (m *ErrorSummary) String() string

type GcsData

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.

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" json:"bucket_name,omitempty"`
}

func (*GcsData) Descriptor

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

func (*GcsData) GetBucketName

func (m *GcsData) GetBucketName() string

func (*GcsData) ProtoMessage

func (*GcsData) ProtoMessage()

func (*GcsData) Reset

func (m *GcsData) Reset()

func (*GcsData) String

func (m *GcsData) String() string

type GetGoogleServiceAccountRequest

Request passed to GetGoogleServiceAccount.

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" json:"project_id,omitempty"`
}

func (*GetGoogleServiceAccountRequest) Descriptor

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

func (*GetGoogleServiceAccountRequest) GetProjectId

func (m *GetGoogleServiceAccountRequest) GetProjectId() string

func (*GetGoogleServiceAccountRequest) ProtoMessage

func (*GetGoogleServiceAccountRequest) ProtoMessage()

func (*GetGoogleServiceAccountRequest) Reset

func (m *GetGoogleServiceAccountRequest) Reset()

func (*GetGoogleServiceAccountRequest) String

func (m *GetGoogleServiceAccountRequest) String() string

type GetTransferJobRequest

Request passed to GetTransferJob.

type GetTransferJobRequest struct {
    // The job to get.
    // Required.
    JobName string `protobuf:"bytes,1,opt,name=job_name,json=jobName" 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" json:"project_id,omitempty"`
}

func (*GetTransferJobRequest) Descriptor

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

func (*GetTransferJobRequest) GetJobName

func (m *GetTransferJobRequest) GetJobName() string

func (*GetTransferJobRequest) GetProjectId

func (m *GetTransferJobRequest) GetProjectId() string

func (*GetTransferJobRequest) ProtoMessage

func (*GetTransferJobRequest) ProtoMessage()

func (*GetTransferJobRequest) Reset

func (m *GetTransferJobRequest) Reset()

func (*GetTransferJobRequest) String

func (m *GetTransferJobRequest) String() string

type GoogleServiceAccount

Google service account

type GoogleServiceAccount struct {
    // Required.
    AccountEmail string `protobuf:"bytes,1,opt,name=account_email,json=accountEmail" json:"account_email,omitempty"`
}

func (*GoogleServiceAccount) Descriptor

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

func (*GoogleServiceAccount) GetAccountEmail

func (m *GoogleServiceAccount) GetAccountEmail() string

func (*GoogleServiceAccount) ProtoMessage

func (*GoogleServiceAccount) ProtoMessage()

func (*GoogleServiceAccount) Reset

func (m *GoogleServiceAccount) Reset()

func (*GoogleServiceAccount) String

func (m *GoogleServiceAccount) String() string

type HttpData

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/#urls)

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.

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" json:"list_url,omitempty"`
}

func (*HttpData) Descriptor

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

func (*HttpData) GetListUrl

func (m *HttpData) GetListUrl() string

func (*HttpData) ProtoMessage

func (*HttpData) ProtoMessage()

func (*HttpData) Reset

func (m *HttpData) Reset()

func (*HttpData) String

func (m *HttpData) String() string

type ListTransferJobsRequest

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

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" json:"filter,omitempty"`
    // The list page size. The max allowed value is 256.
    PageSize int32 `protobuf:"varint,4,opt,name=page_size,json=pageSize" json:"page_size,omitempty"`
    // The list page token.
    PageToken string `protobuf:"bytes,5,opt,name=page_token,json=pageToken" json:"page_token,omitempty"`
}

func (*ListTransferJobsRequest) Descriptor

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

func (*ListTransferJobsRequest) GetFilter

func (m *ListTransferJobsRequest) GetFilter() string

func (*ListTransferJobsRequest) GetPageSize

func (m *ListTransferJobsRequest) GetPageSize() int32

func (*ListTransferJobsRequest) GetPageToken

func (m *ListTransferJobsRequest) GetPageToken() string

func (*ListTransferJobsRequest) ProtoMessage

func (*ListTransferJobsRequest) ProtoMessage()

func (*ListTransferJobsRequest) Reset

func (m *ListTransferJobsRequest) Reset()

func (*ListTransferJobsRequest) String

func (m *ListTransferJobsRequest) String() string

type ListTransferJobsResponse

Response from ListTransferJobs.

type ListTransferJobsResponse struct {
    // A list of transfer jobs.
    TransferJobs []*TransferJob `protobuf:"bytes,1,rep,name=transfer_jobs,json=transferJobs" json:"transfer_jobs,omitempty"`
    // The list next page token.
    NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken" json:"next_page_token,omitempty"`
}

func (*ListTransferJobsResponse) Descriptor

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

func (*ListTransferJobsResponse) GetNextPageToken

func (m *ListTransferJobsResponse) GetNextPageToken() string

func (*ListTransferJobsResponse) GetTransferJobs

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

func (*ListTransferJobsResponse) ProtoMessage

func (*ListTransferJobsResponse) ProtoMessage()

func (*ListTransferJobsResponse) Reset

func (m *ListTransferJobsResponse) Reset()

func (*ListTransferJobsResponse) String

func (m *ListTransferJobsResponse) String() string

type ObjectConditions

Conditions that determine which objects will be transferred.

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 *google_protobuf3.Duration `protobuf:"bytes,1,opt,name=min_time_elapsed_since_last_modification,json=minTimeElapsedSinceLastModification" json:"min_time_elapsed_since_last_modification,omitempty"`
    // `maxTimeElapsedSinceLastModification` is the complement to
    // `minTimeElapsedSinceLastModification`.
    MaxTimeElapsedSinceLastModification *google_protobuf3.Duration `protobuf:"bytes,2,opt,name=max_time_elapsed_since_last_modification,json=maxTimeElapsedSinceLastModification" json:"max_time_elapsed_since_last_modification,omitempty"`
    // 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 20.
    IncludePrefixes []string `protobuf:"bytes,3,rep,name=include_prefixes,json=includePrefixes" json:"include_prefixes,omitempty"`
    // `excludePrefixes` must follow the requirements described for
    // `includePrefixes`.
    //
    // The max size of `excludePrefixes` is 20.
    ExcludePrefixes []string `protobuf:"bytes,4,rep,name=exclude_prefixes,json=excludePrefixes" json:"exclude_prefixes,omitempty"`
}

func (*ObjectConditions) Descriptor

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

func (*ObjectConditions) GetExcludePrefixes

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

func (*ObjectConditions) GetIncludePrefixes

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

func (*ObjectConditions) GetMaxTimeElapsedSinceLastModification

func (m *ObjectConditions) GetMaxTimeElapsedSinceLastModification() *google_protobuf3.Duration

func (*ObjectConditions) GetMinTimeElapsedSinceLastModification

func (m *ObjectConditions) GetMinTimeElapsedSinceLastModification() *google_protobuf3.Duration

func (*ObjectConditions) ProtoMessage

func (*ObjectConditions) ProtoMessage()

func (*ObjectConditions) Reset

func (m *ObjectConditions) Reset()

func (*ObjectConditions) String

func (m *ObjectConditions) String() string

type PauseTransferOperationRequest

Request passed to PauseTransferOperation.

type PauseTransferOperationRequest struct {
    // The name of the transfer operation.
    // Required.
    Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
}

func (*PauseTransferOperationRequest) Descriptor

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

func (*PauseTransferOperationRequest) GetName

func (m *PauseTransferOperationRequest) GetName() string

func (*PauseTransferOperationRequest) ProtoMessage

func (*PauseTransferOperationRequest) ProtoMessage()

func (*PauseTransferOperationRequest) Reset

func (m *PauseTransferOperationRequest) Reset()

func (*PauseTransferOperationRequest) String

func (m *PauseTransferOperationRequest) String() string

type ResumeTransferOperationRequest

Request passed to ResumeTransferOperation.

type ResumeTransferOperationRequest struct {
    // The name of the transfer operation.
    // Required.
    Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
}

func (*ResumeTransferOperationRequest) Descriptor

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

func (*ResumeTransferOperationRequest) GetName

func (m *ResumeTransferOperationRequest) GetName() string

func (*ResumeTransferOperationRequest) ProtoMessage

func (*ResumeTransferOperationRequest) ProtoMessage()

func (*ResumeTransferOperationRequest) Reset

func (m *ResumeTransferOperationRequest) Reset()

func (*ResumeTransferOperationRequest) String

func (m *ResumeTransferOperationRequest) String() string

type Schedule

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

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 *google_type.Date `protobuf:"bytes,1,opt,name=schedule_start_date,json=scheduleStartDate" 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 *google_type.Date `protobuf:"bytes,2,opt,name=schedule_end_date,json=scheduleEndDate" 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 *google_type1.TimeOfDay `protobuf:"bytes,3,opt,name=start_time_of_day,json=startTimeOfDay" json:"start_time_of_day,omitempty"`
}

func (*Schedule) Descriptor

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

func (*Schedule) GetScheduleEndDate

func (m *Schedule) GetScheduleEndDate() *google_type.Date

func (*Schedule) GetScheduleStartDate

func (m *Schedule) GetScheduleStartDate() *google_type.Date

func (*Schedule) GetStartTimeOfDay

func (m *Schedule) GetStartTimeOfDay() *google_type1.TimeOfDay

func (*Schedule) ProtoMessage

func (*Schedule) ProtoMessage()

func (*Schedule) Reset

func (m *Schedule) Reset()

func (*Schedule) String

func (m *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) (*google_protobuf1.Empty, error)
    // Resumes a transfer operation that is paused.
    ResumeTransferOperation(ctx context.Context, in *ResumeTransferOperationRequest, opts ...grpc.CallOption) (*google_protobuf1.Empty, error)
}

func NewStorageTransferServiceClient

func NewStorageTransferServiceClient(cc *grpc.ClientConn) StorageTransferServiceClient

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) (*google_protobuf1.Empty, error)
    // Resumes a transfer operation that is paused.
    ResumeTransferOperation(context.Context, *ResumeTransferOperationRequest) (*google_protobuf1.Empty, error)
}

type TransferCounters

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

type TransferCounters struct {
    // Objects found in the data source that are scheduled to be transferred,
    // which will be copied, excluded based on conditions, or skipped due to
    // failures.
    ObjectsFoundFromSource int64 `protobuf:"varint,1,opt,name=objects_found_from_source,json=objectsFoundFromSource" json:"objects_found_from_source,omitempty"`
    // Bytes found in the data source that are scheduled to be transferred,
    // which will be copied, excluded based on conditions, or skipped due to
    // failures.
    BytesFoundFromSource int64 `protobuf:"varint,2,opt,name=bytes_found_from_source,json=bytesFoundFromSource" json:"bytes_found_from_source,omitempty"`
    // Objects found only in the data sink that are scheduled to be deleted.
    ObjectsFoundOnlyFromSink int64 `protobuf:"varint,3,opt,name=objects_found_only_from_sink,json=objectsFoundOnlyFromSink" json:"objects_found_only_from_sink,omitempty"`
    // Bytes found only in the data sink that are scheduled to be deleted.
    BytesFoundOnlyFromSink int64 `protobuf:"varint,4,opt,name=bytes_found_only_from_sink,json=bytesFoundOnlyFromSink" json:"bytes_found_only_from_sink,omitempty"`
    // Objects in the data source that are not transferred because they already
    // exist in the data sink.
    ObjectsFromSourceSkippedBySync int64 `protobuf:"varint,5,opt,name=objects_from_source_skipped_by_sync,json=objectsFromSourceSkippedBySync" json:"objects_from_source_skipped_by_sync,omitempty"`
    // Bytes in the data source that are not transferred because they already
    // exist in the data sink.
    BytesFromSourceSkippedBySync int64 `protobuf:"varint,6,opt,name=bytes_from_source_skipped_by_sync,json=bytesFromSourceSkippedBySync" json:"bytes_from_source_skipped_by_sync,omitempty"`
    // Objects that are copied to the data sink.
    ObjectsCopiedToSink int64 `protobuf:"varint,7,opt,name=objects_copied_to_sink,json=objectsCopiedToSink" 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" json:"bytes_copied_to_sink,omitempty"`
    // Objects that are deleted from the data source.
    ObjectsDeletedFromSource int64 `protobuf:"varint,9,opt,name=objects_deleted_from_source,json=objectsDeletedFromSource" json:"objects_deleted_from_source,omitempty"`
    // Bytes that are deleted from the data source.
    BytesDeletedFromSource int64 `protobuf:"varint,10,opt,name=bytes_deleted_from_source,json=bytesDeletedFromSource" json:"bytes_deleted_from_source,omitempty"`
    // Objects that are deleted from the data sink.
    ObjectsDeletedFromSink int64 `protobuf:"varint,11,opt,name=objects_deleted_from_sink,json=objectsDeletedFromSink" json:"objects_deleted_from_sink,omitempty"`
    // Bytes that are deleted from the data sink.
    BytesDeletedFromSink int64 `protobuf:"varint,12,opt,name=bytes_deleted_from_sink,json=bytesDeletedFromSink" json:"bytes_deleted_from_sink,omitempty"`
    // Objects in the data source that failed during the transfer.
    ObjectsFromSourceFailed int64 `protobuf:"varint,13,opt,name=objects_from_source_failed,json=objectsFromSourceFailed" json:"objects_from_source_failed,omitempty"`
    // Bytes in the data source that failed during the transfer.
    BytesFromSourceFailed int64 `protobuf:"varint,14,opt,name=bytes_from_source_failed,json=bytesFromSourceFailed" json:"bytes_from_source_failed,omitempty"`
    // Objects that failed to be deleted from the data sink.
    ObjectsFailedToDeleteFromSink int64 `protobuf:"varint,15,opt,name=objects_failed_to_delete_from_sink,json=objectsFailedToDeleteFromSink" json:"objects_failed_to_delete_from_sink,omitempty"`
    // Bytes that failed to be deleted from the data sink.
    BytesFailedToDeleteFromSink int64 `protobuf:"varint,16,opt,name=bytes_failed_to_delete_from_sink,json=bytesFailedToDeleteFromSink" json:"bytes_failed_to_delete_from_sink,omitempty"`
}

func (*TransferCounters) Descriptor

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

func (*TransferCounters) GetBytesCopiedToSink

func (m *TransferCounters) GetBytesCopiedToSink() int64

func (*TransferCounters) GetBytesDeletedFromSink

func (m *TransferCounters) GetBytesDeletedFromSink() int64

func (*TransferCounters) GetBytesDeletedFromSource

func (m *TransferCounters) GetBytesDeletedFromSource() int64

func (*TransferCounters) GetBytesFailedToDeleteFromSink

func (m *TransferCounters) GetBytesFailedToDeleteFromSink() int64

func (*TransferCounters) GetBytesFoundFromSource

func (m *TransferCounters) GetBytesFoundFromSource() int64

func (*TransferCounters) GetBytesFoundOnlyFromSink

func (m *TransferCounters) GetBytesFoundOnlyFromSink() int64

func (*TransferCounters) GetBytesFromSourceFailed

func (m *TransferCounters) GetBytesFromSourceFailed() int64

func (*TransferCounters) GetBytesFromSourceSkippedBySync

func (m *TransferCounters) GetBytesFromSourceSkippedBySync() int64

func (*TransferCounters) GetObjectsCopiedToSink

func (m *TransferCounters) GetObjectsCopiedToSink() int64

func (*TransferCounters) GetObjectsDeletedFromSink

func (m *TransferCounters) GetObjectsDeletedFromSink() int64

func (*TransferCounters) GetObjectsDeletedFromSource

func (m *TransferCounters) GetObjectsDeletedFromSource() int64

func (*TransferCounters) GetObjectsFailedToDeleteFromSink

func (m *TransferCounters) GetObjectsFailedToDeleteFromSink() int64

func (*TransferCounters) GetObjectsFoundFromSource

func (m *TransferCounters) GetObjectsFoundFromSource() int64

func (*TransferCounters) GetObjectsFoundOnlyFromSink

func (m *TransferCounters) GetObjectsFoundOnlyFromSink() int64

func (*TransferCounters) GetObjectsFromSourceFailed

func (m *TransferCounters) GetObjectsFromSourceFailed() int64

func (*TransferCounters) GetObjectsFromSourceSkippedBySync

func (m *TransferCounters) GetObjectsFromSourceSkippedBySync() int64

func (*TransferCounters) ProtoMessage

func (*TransferCounters) ProtoMessage()

func (*TransferCounters) Reset

func (m *TransferCounters) Reset()

func (*TransferCounters) String

func (m *TransferCounters) String() string

type TransferJob

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

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" 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" json:"description,omitempty"`
    // The ID of the Google Cloud Platform Console project that owns the job.
    // Required.
    ProjectId string `protobuf:"bytes,3,opt,name=project_id,json=projectId" json:"project_id,omitempty"`
    // Transfer specification.
    // Required.
    TransferSpec *TransferSpec `protobuf:"bytes,4,opt,name=transfer_spec,json=transferSpec" json:"transfer_spec,omitempty"`
    // Schedule specification.
    // Required.
    Schedule *Schedule `protobuf:"bytes,5,opt,name=schedule" 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,enum=google.storagetransfer.v1.TransferJob_Status" json:"status,omitempty"`
    // This field cannot be changed by user requests.
    CreationTime *google_protobuf4.Timestamp `protobuf:"bytes,7,opt,name=creation_time,json=creationTime" json:"creation_time,omitempty"`
    // This field cannot be changed by user requests.
    LastModificationTime *google_protobuf4.Timestamp `protobuf:"bytes,8,opt,name=last_modification_time,json=lastModificationTime" json:"last_modification_time,omitempty"`
    // This field cannot be changed by user requests.
    DeletionTime *google_protobuf4.Timestamp `protobuf:"bytes,9,opt,name=deletion_time,json=deletionTime" json:"deletion_time,omitempty"`
}

func (*TransferJob) Descriptor

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

func (*TransferJob) GetCreationTime

func (m *TransferJob) GetCreationTime() *google_protobuf4.Timestamp

func (*TransferJob) GetDeletionTime

func (m *TransferJob) GetDeletionTime() *google_protobuf4.Timestamp

func (*TransferJob) GetDescription

func (m *TransferJob) GetDescription() string

func (*TransferJob) GetLastModificationTime

func (m *TransferJob) GetLastModificationTime() *google_protobuf4.Timestamp

func (*TransferJob) GetName

func (m *TransferJob) GetName() string

func (*TransferJob) GetProjectId

func (m *TransferJob) GetProjectId() string

func (*TransferJob) GetSchedule

func (m *TransferJob) GetSchedule() *Schedule

func (*TransferJob) GetStatus

func (m *TransferJob) GetStatus() TransferJob_Status

func (*TransferJob) GetTransferSpec

func (m *TransferJob) GetTransferSpec() *TransferSpec

func (*TransferJob) ProtoMessage

func (*TransferJob) ProtoMessage()

func (*TransferJob) Reset

func (m *TransferJob) Reset()

func (*TransferJob) String

func (m *TransferJob) String() string

type TransferJob_Status

The status of the transfer job.

type TransferJob_Status int32
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) EnumDescriptor

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

func (TransferJob_Status) String

func (x TransferJob_Status) String() string

type TransferOperation

A description of the execution of a transfer.

type TransferOperation struct {
    // A globally unique ID assigned by the system.
    Name string `protobuf:"bytes,1,opt,name=name" 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" json:"project_id,omitempty"`
    // Transfer specification.
    // Required.
    TransferSpec *TransferSpec `protobuf:"bytes,3,opt,name=transfer_spec,json=transferSpec" json:"transfer_spec,omitempty"`
    // Start time of this transfer execution.
    StartTime *google_protobuf4.Timestamp `protobuf:"bytes,4,opt,name=start_time,json=startTime" json:"start_time,omitempty"`
    // End time of this transfer execution.
    EndTime *google_protobuf4.Timestamp `protobuf:"bytes,5,opt,name=end_time,json=endTime" json:"end_time,omitempty"`
    // Status of the transfer operation.
    Status TransferOperation_Status `protobuf:"varint,6,opt,name=status,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" json:"counters,omitempty"`
    // Summarizes errors encountered with sample error log entries.
    ErrorBreakdowns []*ErrorSummary `protobuf:"bytes,8,rep,name=error_breakdowns,json=errorBreakdowns" 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" json:"transfer_job_name,omitempty"`
}

func (*TransferOperation) Descriptor

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

func (*TransferOperation) GetCounters

func (m *TransferOperation) GetCounters() *TransferCounters

func (*TransferOperation) GetEndTime

func (m *TransferOperation) GetEndTime() *google_protobuf4.Timestamp

func (*TransferOperation) GetErrorBreakdowns

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

func (*TransferOperation) GetName

func (m *TransferOperation) GetName() string

func (*TransferOperation) GetProjectId

func (m *TransferOperation) GetProjectId() string

func (*TransferOperation) GetStartTime

func (m *TransferOperation) GetStartTime() *google_protobuf4.Timestamp

func (*TransferOperation) GetStatus

func (m *TransferOperation) GetStatus() TransferOperation_Status

func (*TransferOperation) GetTransferJobName

func (m *TransferOperation) GetTransferJobName() string

func (*TransferOperation) GetTransferSpec

func (m *TransferOperation) GetTransferSpec() *TransferSpec

func (*TransferOperation) ProtoMessage

func (*TransferOperation) ProtoMessage()

func (*TransferOperation) Reset

func (m *TransferOperation) Reset()

func (*TransferOperation) String

func (m *TransferOperation) String() string

type TransferOperation_Status

The status of a TransferOperation.

type TransferOperation_Status int32
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) EnumDescriptor

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

func (TransferOperation_Status) String

func (x TransferOperation_Status) String() string

type TransferOptions

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

type TransferOptions struct {
    // Whether overwriting objects that already exist in the sink is allowed.
    OverwriteObjectsAlreadyExistingInSink bool `protobuf:"varint,1,opt,name=overwrite_objects_already_existing_in_sink,json=overwriteObjectsAlreadyExistingInSink" json:"overwrite_objects_already_existing_in_sink,omitempty"`
    // Whether objects that exist only in the sink should be deleted.
    DeleteObjectsUniqueInSink bool `protobuf:"varint,2,opt,name=delete_objects_unique_in_sink,json=deleteObjectsUniqueInSink" json:"delete_objects_unique_in_sink,omitempty"`
    // Whether objects should be deleted from the source after they are
    // transferred to the sink.
    DeleteObjectsFromSourceAfterTransfer bool `protobuf:"varint,3,opt,name=delete_objects_from_source_after_transfer,json=deleteObjectsFromSourceAfterTransfer" json:"delete_objects_from_source_after_transfer,omitempty"`
}

func (*TransferOptions) Descriptor

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

func (*TransferOptions) GetDeleteObjectsFromSourceAfterTransfer

func (m *TransferOptions) GetDeleteObjectsFromSourceAfterTransfer() bool

func (*TransferOptions) GetDeleteObjectsUniqueInSink

func (m *TransferOptions) GetDeleteObjectsUniqueInSink() bool

func (*TransferOptions) GetOverwriteObjectsAlreadyExistingInSink

func (m *TransferOptions) GetOverwriteObjectsAlreadyExistingInSink() bool

func (*TransferOptions) ProtoMessage

func (*TransferOptions) ProtoMessage()

func (*TransferOptions) Reset

func (m *TransferOptions) Reset()

func (*TransferOptions) String

func (m *TransferOptions) String() string

type TransferSpec

Configuration for running a transfer.

type TransferSpec struct {
    // The read source of the data.
    //
    // Types that are valid to be assigned to DataSource:
    //	*TransferSpec_GcsDataSource
    //	*TransferSpec_AwsS3DataSource
    //	*TransferSpec_HttpDataSource
    DataSource isTransferSpec_DataSource `protobuf_oneof:"data_source"`
    // The write sink for the data.
    //
    // Types that are valid to be assigned 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" 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" json:"transfer_options,omitempty"`
}

func (*TransferSpec) Descriptor

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

func (*TransferSpec) GetAwsS3DataSource

func (m *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 (m *TransferSpec) GetGcsDataSink() *GcsData

func (*TransferSpec) GetGcsDataSource

func (m *TransferSpec) GetGcsDataSource() *GcsData

func (*TransferSpec) GetHttpDataSource

func (m *TransferSpec) GetHttpDataSource() *HttpData

func (*TransferSpec) GetObjectConditions

func (m *TransferSpec) GetObjectConditions() *ObjectConditions

func (*TransferSpec) GetTransferOptions

func (m *TransferSpec) GetTransferOptions() *TransferOptions

func (*TransferSpec) ProtoMessage

func (*TransferSpec) ProtoMessage()

func (*TransferSpec) Reset

func (m *TransferSpec) Reset()

func (*TransferSpec) String

func (m *TransferSpec) String() string

func (*TransferSpec) XXX_OneofFuncs

func (*TransferSpec) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type TransferSpec_AwsS3DataSource

type TransferSpec_AwsS3DataSource struct {
    AwsS3DataSource *AwsS3Data `protobuf:"bytes,2,opt,name=aws_s3_data_source,json=awsS3DataSource,oneof"`
}

type TransferSpec_GcsDataSink

type TransferSpec_GcsDataSink struct {
    GcsDataSink *GcsData `protobuf:"bytes,4,opt,name=gcs_data_sink,json=gcsDataSink,oneof"`
}

type TransferSpec_GcsDataSource

type TransferSpec_GcsDataSource struct {
    GcsDataSource *GcsData `protobuf:"bytes,1,opt,name=gcs_data_source,json=gcsDataSource,oneof"`
}

type TransferSpec_HttpDataSource

type TransferSpec_HttpDataSource struct {
    HttpDataSource *HttpData `protobuf:"bytes,3,opt,name=http_data_source,json=httpDataSource,oneof"`
}

type UpdateTransferJobRequest

Request passed to UpdateTransferJob.

type UpdateTransferJobRequest struct {
    // The name of job to update.
    // Required.
    JobName string `protobuf:"bytes,1,opt,name=job_name,json=jobName" 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" json:"project_id,omitempty"`
    // The job to update.
    // Required.
    TransferJob *TransferJob `protobuf:"bytes,3,opt,name=transfer_job,json=transferJob" 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 *google_protobuf2.FieldMask `protobuf:"bytes,4,opt,name=update_transfer_job_field_mask,json=updateTransferJobFieldMask" json:"update_transfer_job_field_mask,omitempty"`
}

func (*UpdateTransferJobRequest) Descriptor

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

func (*UpdateTransferJobRequest) GetJobName

func (m *UpdateTransferJobRequest) GetJobName() string

func (*UpdateTransferJobRequest) GetProjectId

func (m *UpdateTransferJobRequest) GetProjectId() string

func (*UpdateTransferJobRequest) GetTransferJob

func (m *UpdateTransferJobRequest) GetTransferJob() *TransferJob

func (*UpdateTransferJobRequest) GetUpdateTransferJobFieldMask

func (m *UpdateTransferJobRequest) GetUpdateTransferJobFieldMask() *google_protobuf2.FieldMask

func (*UpdateTransferJobRequest) ProtoMessage

func (*UpdateTransferJobRequest) ProtoMessage()

func (*UpdateTransferJobRequest) Reset

func (m *UpdateTransferJobRequest) Reset()

func (*UpdateTransferJobRequest) String

func (m *UpdateTransferJobRequest) String() string