Constants
StorageBatchOperations_ListJobs_FullMethodName, StorageBatchOperations_GetJob_FullMethodName, StorageBatchOperations_CreateJob_FullMethodName, StorageBatchOperations_DeleteJob_FullMethodName, StorageBatchOperations_CancelJob_FullMethodName, StorageBatchOperations_ListBucketOperations_FullMethodName, StorageBatchOperations_GetBucketOperation_FullMethodName
const (
StorageBatchOperations_ListJobs_FullMethodName = "/google.cloud.storagebatchoperations.v1.StorageBatchOperations/ListJobs"
StorageBatchOperations_GetJob_FullMethodName = "/google.cloud.storagebatchoperations.v1.StorageBatchOperations/GetJob"
StorageBatchOperations_CreateJob_FullMethodName = "/google.cloud.storagebatchoperations.v1.StorageBatchOperations/CreateJob"
StorageBatchOperations_DeleteJob_FullMethodName = "/google.cloud.storagebatchoperations.v1.StorageBatchOperations/DeleteJob"
StorageBatchOperations_CancelJob_FullMethodName = "/google.cloud.storagebatchoperations.v1.StorageBatchOperations/CancelJob"
StorageBatchOperations_ListBucketOperations_FullMethodName = "/google.cloud.storagebatchoperations.v1.StorageBatchOperations/ListBucketOperations"
StorageBatchOperations_GetBucketOperation_FullMethodName = "/google.cloud.storagebatchoperations.v1.StorageBatchOperations/GetBucketOperation"
)Variables
Job_State_name, Job_State_value
var (
Job_State_name = map[int32]string{
0: "STATE_UNSPECIFIED",
1: "RUNNING",
2: "SUCCEEDED",
3: "CANCELED",
4: "FAILED",
5: "QUEUED",
}
Job_State_value = map[string]int32{
"STATE_UNSPECIFIED": 0,
"RUNNING": 1,
"SUCCEEDED": 2,
"CANCELED": 3,
"FAILED": 4,
"QUEUED": 5,
}
)Enum value maps for Job_State.
BucketOperation_State_name, BucketOperation_State_value
var (
BucketOperation_State_name = map[int32]string{
0: "STATE_UNSPECIFIED",
1: "QUEUED",
2: "RUNNING",
3: "SUCCEEDED",
4: "CANCELED",
5: "FAILED",
}
BucketOperation_State_value = map[string]int32{
"STATE_UNSPECIFIED": 0,
"QUEUED": 1,
"RUNNING": 2,
"SUCCEEDED": 3,
"CANCELED": 4,
"FAILED": 5,
}
)Enum value maps for BucketOperation_State.
PutObjectHold_HoldStatus_name, PutObjectHold_HoldStatus_value
var (
PutObjectHold_HoldStatus_name = map[int32]string{
0: "HOLD_STATUS_UNSPECIFIED",
1: "SET",
2: "UNSET",
}
PutObjectHold_HoldStatus_value = map[string]int32{
"HOLD_STATUS_UNSPECIFIED": 0,
"SET": 1,
"UNSET": 2,
}
)Enum value maps for PutObjectHold_HoldStatus.
ObjectRetention_RetentionMode_name, ObjectRetention_RetentionMode_value
var (
ObjectRetention_RetentionMode_name = map[int32]string{
0: "RETENTION_MODE_UNSPECIFIED",
1: "LOCKED",
2: "UNLOCKED",
}
ObjectRetention_RetentionMode_value = map[string]int32{
"RETENTION_MODE_UNSPECIFIED": 0,
"LOCKED": 1,
"UNLOCKED": 2,
}
)Enum value maps for ObjectRetention_RetentionMode.
LoggingConfig_LoggableAction_name, LoggingConfig_LoggableAction_value
var (
LoggingConfig_LoggableAction_name = map[int32]string{
0: "LOGGABLE_ACTION_UNSPECIFIED",
6: "TRANSFORM",
}
LoggingConfig_LoggableAction_value = map[string]int32{
"LOGGABLE_ACTION_UNSPECIFIED": 0,
"TRANSFORM": 6,
}
)Enum value maps for LoggingConfig_LoggableAction.
LoggingConfig_LoggableActionState_name, LoggingConfig_LoggableActionState_value
var (
LoggingConfig_LoggableActionState_name = map[int32]string{
0: "LOGGABLE_ACTION_STATE_UNSPECIFIED",
1: "SUCCEEDED",
2: "FAILED",
}
LoggingConfig_LoggableActionState_value = map[string]int32{
"LOGGABLE_ACTION_STATE_UNSPECIFIED": 0,
"SUCCEEDED": 1,
"FAILED": 2,
}
)Enum value maps for LoggingConfig_LoggableActionState.
File_google_cloud_storagebatchoperations_v1_storage_batch_operations_proto
var File_google_cloud_storagebatchoperations_v1_storage_batch_operations_proto protoreflect.FileDescriptorFile_google_cloud_storagebatchoperations_v1_storage_batch_operations_types_proto
var File_google_cloud_storagebatchoperations_v1_storage_batch_operations_types_proto protoreflect.FileDescriptorStorageBatchOperations_ServiceDesc
var StorageBatchOperations_ServiceDesc = grpc.ServiceDesc{
ServiceName: "google.cloud.storagebatchoperations.v1.StorageBatchOperations",
HandlerType: (*StorageBatchOperationsServer)(nil),
Methods: []grpc.MethodDesc{
{
MethodName: "ListJobs",
Handler: _StorageBatchOperations_ListJobs_Handler,
},
{
MethodName: "GetJob",
Handler: _StorageBatchOperations_GetJob_Handler,
},
{
MethodName: "CreateJob",
Handler: _StorageBatchOperations_CreateJob_Handler,
},
{
MethodName: "DeleteJob",
Handler: _StorageBatchOperations_DeleteJob_Handler,
},
{
MethodName: "CancelJob",
Handler: _StorageBatchOperations_CancelJob_Handler,
},
{
MethodName: "ListBucketOperations",
Handler: _StorageBatchOperations_ListBucketOperations_Handler,
},
{
MethodName: "GetBucketOperation",
Handler: _StorageBatchOperations_GetBucketOperation_Handler,
},
},
Streams: []grpc.StreamDesc{},
Metadata: "google/cloud/storagebatchoperations/v1/storage_batch_operations.proto",
}StorageBatchOperations_ServiceDesc is the grpc.ServiceDesc for StorageBatchOperations service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions
func RegisterStorageBatchOperationsServer
func RegisterStorageBatchOperationsServer(s grpc.ServiceRegistrar, srv StorageBatchOperationsServer)BucketList
type BucketList struct {
// Required. List of buckets and their objects to be transformed. Currently,
// only one bucket configuration is supported. If multiple buckets are
// specified, an error will be returned.
Buckets []*BucketList_Bucket `protobuf:"bytes,1,rep,name=buckets,proto3" json:"buckets,omitempty"`
// contains filtered or unexported fields
}Describes list of buckets and their objects to be transformed.
func (*BucketList) Descriptor
func (*BucketList) Descriptor() ([]byte, []int)Deprecated: Use BucketList.ProtoReflect.Descriptor instead.
func (*BucketList) GetBuckets
func (x *BucketList) GetBuckets() []*BucketList_Bucketfunc (*BucketList) ProtoMessage
func (*BucketList) ProtoMessage()func (*BucketList) ProtoReflect
func (x *BucketList) ProtoReflect() protoreflect.Messagefunc (*BucketList) Reset
func (x *BucketList) Reset()func (*BucketList) String
func (x *BucketList) String() stringBucketList_Bucket
type BucketList_Bucket struct {
// Required. Bucket name for the objects to be transformed.
Bucket string `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
// Specifies objects to be transformed.
//
// Types that are valid to be assigned to ObjectConfiguration:
//
// *BucketList_Bucket_PrefixList
// *BucketList_Bucket_Manifest
ObjectConfiguration isBucketList_Bucket_ObjectConfiguration `protobuf_oneof:"object_configuration"`
// contains filtered or unexported fields
}Describes configuration of a single bucket and its objects to be transformed.
func (*BucketList_Bucket) Descriptor
func (*BucketList_Bucket) Descriptor() ([]byte, []int)Deprecated: Use BucketList_Bucket.ProtoReflect.Descriptor instead.
func (*BucketList_Bucket) GetBucket
func (x *BucketList_Bucket) GetBucket() stringfunc (*BucketList_Bucket) GetManifest
func (x *BucketList_Bucket) GetManifest() *Manifestfunc (*BucketList_Bucket) GetObjectConfiguration
func (x *BucketList_Bucket) GetObjectConfiguration() isBucketList_Bucket_ObjectConfigurationfunc (*BucketList_Bucket) GetPrefixList
func (x *BucketList_Bucket) GetPrefixList() *PrefixListfunc (*BucketList_Bucket) ProtoMessage
func (*BucketList_Bucket) ProtoMessage()func (*BucketList_Bucket) ProtoReflect
func (x *BucketList_Bucket) ProtoReflect() protoreflect.Messagefunc (*BucketList_Bucket) Reset
func (x *BucketList_Bucket) Reset()func (*BucketList_Bucket) String
func (x *BucketList_Bucket) String() stringBucketList_Bucket_Manifest
type BucketList_Bucket_Manifest struct {
// Specifies objects in a manifest file.
Manifest *Manifest `protobuf:"bytes,3,opt,name=manifest,proto3,oneof"`
}BucketList_Bucket_PrefixList
type BucketList_Bucket_PrefixList struct {
// Specifies objects matching a prefix set.
PrefixList *PrefixList `protobuf:"bytes,2,opt,name=prefix_list,json=prefixList,proto3,oneof"`
}BucketOperation
type BucketOperation struct {
// Identifier. The resource name of the BucketOperation. This is defined by
// the service. Format:
// projects/{project}/locations/global/jobs/{job_id}/bucketOperations/{bucket_operation}.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// The bucket name of the objects to be transformed in the BucketOperation.
BucketName string `protobuf:"bytes,2,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
// Specifies objects to be transformed in the BucketOperation.
//
// Types that are valid to be assigned to ObjectConfiguration:
//
// *BucketOperation_PrefixList
// *BucketOperation_Manifest
ObjectConfiguration isBucketOperation_ObjectConfiguration `protobuf_oneof:"object_configuration"`
// Action to be performed on the objects.
//
// Types that are valid to be assigned to Transformation:
//
// *BucketOperation_PutObjectHold
// *BucketOperation_DeleteObject
// *BucketOperation_PutMetadata
// *BucketOperation_RewriteObject
// *BucketOperation_UpdateObjectCustomContext
Transformation isBucketOperation_Transformation `protobuf_oneof:"transformation"`
// Output only. The time that the BucketOperation was created.
CreateTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
// Output only. The time that the BucketOperation was started.
StartTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
// Output only. The time that the BucketOperation was completed.
CompleteTime *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=complete_time,json=completeTime,proto3" json:"complete_time,omitempty"`
// Output only. Information about the progress of the bucket operation.
Counters *Counters `protobuf:"bytes,8,opt,name=counters,proto3" json:"counters,omitempty"`
// Output only. Summarizes errors encountered with sample error log entries.
ErrorSummaries []*ErrorSummary `protobuf:"bytes,9,rep,name=error_summaries,json=errorSummaries,proto3" json:"error_summaries,omitempty"`
// Output only. State of the BucketOperation.
State BucketOperation_State `protobuf:"varint,10,opt,name=state,proto3,enum=google.cloud.storagebatchoperations.v1.BucketOperation_State" json:"state,omitempty"`
// contains filtered or unexported fields
}BucketOperation represents a bucket-level breakdown of a Job.
func (*BucketOperation) Descriptor
func (*BucketOperation) Descriptor() ([]byte, []int)Deprecated: Use BucketOperation.ProtoReflect.Descriptor instead.
func (*BucketOperation) GetBucketName
func (x *BucketOperation) GetBucketName() stringfunc (*BucketOperation) GetCompleteTime
func (x *BucketOperation) GetCompleteTime() *timestamppb.Timestampfunc (*BucketOperation) GetCounters
func (x *BucketOperation) GetCounters() *Countersfunc (*BucketOperation) GetCreateTime
func (x *BucketOperation) GetCreateTime() *timestamppb.Timestampfunc (*BucketOperation) GetDeleteObject
func (x *BucketOperation) GetDeleteObject() *DeleteObjectfunc (*BucketOperation) GetErrorSummaries
func (x *BucketOperation) GetErrorSummaries() []*ErrorSummaryfunc (*BucketOperation) GetManifest
func (x *BucketOperation) GetManifest() *Manifestfunc (*BucketOperation) GetName
func (x *BucketOperation) GetName() stringfunc (*BucketOperation) GetObjectConfiguration
func (x *BucketOperation) GetObjectConfiguration() isBucketOperation_ObjectConfigurationfunc (*BucketOperation) GetPrefixList
func (x *BucketOperation) GetPrefixList() *PrefixListfunc (*BucketOperation) GetPutMetadata
func (x *BucketOperation) GetPutMetadata() *PutMetadatafunc (*BucketOperation) GetPutObjectHold
func (x *BucketOperation) GetPutObjectHold() *PutObjectHoldfunc (*BucketOperation) GetRewriteObject
func (x *BucketOperation) GetRewriteObject() *RewriteObjectfunc (*BucketOperation) GetStartTime
func (x *BucketOperation) GetStartTime() *timestamppb.Timestampfunc (*BucketOperation) GetState
func (x *BucketOperation) GetState() BucketOperation_Statefunc (*BucketOperation) GetTransformation
func (x *BucketOperation) GetTransformation() isBucketOperation_Transformationfunc (*BucketOperation) GetUpdateObjectCustomContext
func (x *BucketOperation) GetUpdateObjectCustomContext() *UpdateObjectCustomContextfunc (*BucketOperation) ProtoMessage
func (*BucketOperation) ProtoMessage()func (*BucketOperation) ProtoReflect
func (x *BucketOperation) ProtoReflect() protoreflect.Messagefunc (*BucketOperation) Reset
func (x *BucketOperation) Reset()func (*BucketOperation) String
func (x *BucketOperation) String() stringBucketOperation_DeleteObject
type BucketOperation_DeleteObject struct {
// Delete objects.
DeleteObject *DeleteObject `protobuf:"bytes,12,opt,name=delete_object,json=deleteObject,proto3,oneof"`
}BucketOperation_Manifest
type BucketOperation_Manifest struct {
// Specifies objects in a manifest file.
Manifest *Manifest `protobuf:"bytes,4,opt,name=manifest,proto3,oneof"`
}BucketOperation_PrefixList
type BucketOperation_PrefixList struct {
// Specifies objects matching a prefix set.
PrefixList *PrefixList `protobuf:"bytes,3,opt,name=prefix_list,json=prefixList,proto3,oneof"`
}BucketOperation_PutMetadata
type BucketOperation_PutMetadata struct {
// Updates object metadata. Allows updating fixed-key and custom metadata
// and fixed-key metadata i.e. Cache-Control, Content-Disposition,
// Content-Encoding, Content-Language, Content-Type, Custom-Time.
PutMetadata *PutMetadata `protobuf:"bytes,13,opt,name=put_metadata,json=putMetadata,proto3,oneof"`
}BucketOperation_PutObjectHold
type BucketOperation_PutObjectHold struct {
// Changes object hold status.
PutObjectHold *PutObjectHold `protobuf:"bytes,11,opt,name=put_object_hold,json=putObjectHold,proto3,oneof"`
}BucketOperation_RewriteObject
type BucketOperation_RewriteObject struct {
// Rewrite the object and updates metadata like KMS key.
RewriteObject *RewriteObject `protobuf:"bytes,14,opt,name=rewrite_object,json=rewriteObject,proto3,oneof"`
}BucketOperation_State
type BucketOperation_State int32Describes state of the BucketOperation.
BucketOperation_STATE_UNSPECIFIED, BucketOperation_QUEUED, BucketOperation_RUNNING, BucketOperation_SUCCEEDED, BucketOperation_CANCELED, BucketOperation_FAILED
const (
// Default value. This value is unused.
BucketOperation_STATE_UNSPECIFIED BucketOperation_State = 0
// Created but not yet started.
BucketOperation_QUEUED BucketOperation_State = 1
// In progress.
BucketOperation_RUNNING BucketOperation_State = 2
// Completed successfully.
BucketOperation_SUCCEEDED BucketOperation_State = 3
// Cancelled by the user.
BucketOperation_CANCELED BucketOperation_State = 4
// Terminated due to an unrecoverable failure.
BucketOperation_FAILED BucketOperation_State = 5
)func (BucketOperation_State) Descriptor
func (BucketOperation_State) Descriptor() protoreflect.EnumDescriptorfunc (BucketOperation_State) Enum
func (x BucketOperation_State) Enum() *BucketOperation_Statefunc (BucketOperation_State) EnumDescriptor
func (BucketOperation_State) EnumDescriptor() ([]byte, []int)Deprecated: Use BucketOperation_State.Descriptor instead.
func (BucketOperation_State) Number
func (x BucketOperation_State) Number() protoreflect.EnumNumberfunc (BucketOperation_State) String
func (x BucketOperation_State) String() stringfunc (BucketOperation_State) Type
func (BucketOperation_State) Type() protoreflect.EnumTypeBucketOperation_UpdateObjectCustomContext
type BucketOperation_UpdateObjectCustomContext struct {
// Update object custom context.
UpdateObjectCustomContext *UpdateObjectCustomContext `protobuf:"bytes,15,opt,name=update_object_custom_context,json=updateObjectCustomContext,proto3,oneof"`
}CancelJobRequest
type CancelJobRequest struct {
// Required. The `name` of the job to cancel.
// Format: projects/{project_id}/locations/global/jobs/{job_id}.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// Optional. An optional request ID to identify requests. Specify a unique
// request ID in case you need to retry your request. Requests with same
// `request_id` will be ignored for at least 60 minutes since the first
// request. The request ID must be a valid UUID with the exception that zero
// UUID is not supported (00000000-0000-0000-0000-000000000000).
RequestId string `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
// contains filtered or unexported fields
}Message for Job to Cancel
func (*CancelJobRequest) Descriptor
func (*CancelJobRequest) Descriptor() ([]byte, []int)Deprecated: Use CancelJobRequest.ProtoReflect.Descriptor instead.
func (*CancelJobRequest) GetName
func (x *CancelJobRequest) GetName() stringfunc (*CancelJobRequest) GetRequestId
func (x *CancelJobRequest) GetRequestId() stringfunc (*CancelJobRequest) ProtoMessage
func (*CancelJobRequest) ProtoMessage()func (*CancelJobRequest) ProtoReflect
func (x *CancelJobRequest) ProtoReflect() protoreflect.Messagefunc (*CancelJobRequest) Reset
func (x *CancelJobRequest) Reset()func (*CancelJobRequest) String
func (x *CancelJobRequest) String() stringCancelJobResponse
type CancelJobResponse struct {
// contains filtered or unexported fields
}Message for response to cancel Job.
func (*CancelJobResponse) Descriptor
func (*CancelJobResponse) Descriptor() ([]byte, []int)Deprecated: Use CancelJobResponse.ProtoReflect.Descriptor instead.
func (*CancelJobResponse) ProtoMessage
func (*CancelJobResponse) ProtoMessage()func (*CancelJobResponse) ProtoReflect
func (x *CancelJobResponse) ProtoReflect() protoreflect.Messagefunc (*CancelJobResponse) Reset
func (x *CancelJobResponse) Reset()func (*CancelJobResponse) String
func (x *CancelJobResponse) String() stringCounters
type Counters struct {
// Output only. Number of objects listed.
TotalObjectCount int64 `protobuf:"varint,1,opt,name=total_object_count,json=totalObjectCount,proto3" json:"total_object_count,omitempty"`
// Output only. Number of objects completed.
SucceededObjectCount int64 `protobuf:"varint,2,opt,name=succeeded_object_count,json=succeededObjectCount,proto3" json:"succeeded_object_count,omitempty"`
// Output only. The number of objects that failed due to user errors or
// service errors.
FailedObjectCount int64 `protobuf:"varint,3,opt,name=failed_object_count,json=failedObjectCount,proto3" json:"failed_object_count,omitempty"`
// Output only. Number of bytes found from source. This field is only
// populated for jobs with a prefix list object configuration.
TotalBytesFound *int64 `protobuf:"varint,4,opt,name=total_bytes_found,json=totalBytesFound,proto3,oneof" json:"total_bytes_found,omitempty"`
// Output only. Number of object custom contexts created. This field is only
// populated for jobs with the UpdateObjectCustomContext transformation.
ObjectCustomContextsCreated *int64 `protobuf:"varint,5,opt,name=object_custom_contexts_created,json=objectCustomContextsCreated,proto3,oneof" json:"object_custom_contexts_created,omitempty"`
// Output only. Number of object custom contexts deleted. This field is only
// populated for jobs with the UpdateObjectCustomContext transformation.
ObjectCustomContextsDeleted *int64 `protobuf:"varint,6,opt,name=object_custom_contexts_deleted,json=objectCustomContextsDeleted,proto3,oneof" json:"object_custom_contexts_deleted,omitempty"`
// Output only. Number of object custom contexts updated. This counter tracks
// custom contexts where the key already existed, but the payload was
// modified. This field is only populated for jobs with the
// UpdateObjectCustomContext transformation.
ObjectCustomContextsUpdated *int64 `protobuf:"varint,7,opt,name=object_custom_contexts_updated,json=objectCustomContextsUpdated,proto3,oneof" json:"object_custom_contexts_updated,omitempty"`
// contains filtered or unexported fields
}Describes details about the progress of the job.
func (*Counters) Descriptor
Deprecated: Use Counters.ProtoReflect.Descriptor instead.
func (*Counters) GetFailedObjectCount
func (*Counters) GetObjectCustomContextsCreated
func (*Counters) GetObjectCustomContextsDeleted
func (*Counters) GetObjectCustomContextsUpdated
func (*Counters) GetSucceededObjectCount
func (*Counters) GetTotalBytesFound
func (*Counters) GetTotalObjectCount
func (*Counters) ProtoMessage
func (*Counters) ProtoMessage()func (*Counters) ProtoReflect
func (x *Counters) ProtoReflect() protoreflect.Messagefunc (*Counters) Reset
func (x *Counters) Reset()func (*Counters) String
CreateJobRequest
type CreateJobRequest struct {
// Required. Value for parent.
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// Required. The optional `job_id` for this Job . If not
// specified, an id is generated. `job_id` should be no more than 128
// characters and must include only characters available in DNS names, as
// defined by RFC-1123.
JobId string `protobuf:"bytes,2,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
// Required. The resource being created
Job *Job `protobuf:"bytes,3,opt,name=job,proto3" json:"job,omitempty"`
// Optional. An optional request ID to identify requests. Specify a unique
// request ID in case you need to retry your request. Requests with same
// `request_id` will be ignored for at least 60 minutes since the first
// request. The request ID must be a valid UUID with the exception that zero
// UUID is not supported (00000000-0000-0000-0000-000000000000).
RequestId string `protobuf:"bytes,4,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
// contains filtered or unexported fields
}Message for creating a Job
func (*CreateJobRequest) Descriptor
func (*CreateJobRequest) Descriptor() ([]byte, []int)Deprecated: Use CreateJobRequest.ProtoReflect.Descriptor instead.
func (*CreateJobRequest) GetJob
func (x *CreateJobRequest) GetJob() *Jobfunc (*CreateJobRequest) GetJobId
func (x *CreateJobRequest) GetJobId() stringfunc (*CreateJobRequest) GetParent
func (x *CreateJobRequest) GetParent() stringfunc (*CreateJobRequest) GetRequestId
func (x *CreateJobRequest) GetRequestId() stringfunc (*CreateJobRequest) ProtoMessage
func (*CreateJobRequest) ProtoMessage()func (*CreateJobRequest) ProtoReflect
func (x *CreateJobRequest) ProtoReflect() protoreflect.Messagefunc (*CreateJobRequest) Reset
func (x *CreateJobRequest) Reset()func (*CreateJobRequest) String
func (x *CreateJobRequest) String() stringCustomContextUpdates
type CustomContextUpdates struct {
// Optional. Insert or update the existing custom contexts.
Updates map[string]*ObjectCustomContextPayload `protobuf:"bytes,1,rep,name=updates,proto3" json:"updates,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
// Optional. Custom contexts to clear by key.
// A key cannot be present in both `updates` and `keys_to_clear`.
KeysToClear []string `protobuf:"bytes,2,rep,name=keys_to_clear,json=keysToClear,proto3" json:"keys_to_clear,omitempty"`
// contains filtered or unexported fields
}Describes a collection of updates to apply to custom contexts identified by key.
func (*CustomContextUpdates) Descriptor
func (*CustomContextUpdates) Descriptor() ([]byte, []int)Deprecated: Use CustomContextUpdates.ProtoReflect.Descriptor instead.
func (*CustomContextUpdates) GetKeysToClear
func (x *CustomContextUpdates) GetKeysToClear() []stringfunc (*CustomContextUpdates) GetUpdates
func (x *CustomContextUpdates) GetUpdates() map[string]*ObjectCustomContextPayloadfunc (*CustomContextUpdates) ProtoMessage
func (*CustomContextUpdates) ProtoMessage()func (*CustomContextUpdates) ProtoReflect
func (x *CustomContextUpdates) ProtoReflect() protoreflect.Messagefunc (*CustomContextUpdates) Reset
func (x *CustomContextUpdates) Reset()func (*CustomContextUpdates) String
func (x *CustomContextUpdates) String() stringDeleteJobRequest
type DeleteJobRequest struct {
// Required. The `name` of the job to delete.
// Format: projects/{project_id}/locations/global/jobs/{job_id} .
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// Optional. An optional request ID to identify requests. Specify a unique
// request ID in case you need to retry your request. Requests with same
// `request_id` will be ignored for at least 60 minutes since the first
// request. The request ID must be a valid UUID with the exception that zero
// UUID is not supported (00000000-0000-0000-0000-000000000000).
RequestId string `protobuf:"bytes,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
// Optional. If set to true, any child bucket operations of the job will also
// be deleted. Highly recommended to be set to true by all clients. Users
// cannot mutate bucket operations directly, so only the jobs.delete
// permission is required to delete a job (and its child bucket operations).
Force bool `protobuf:"varint,3,opt,name=force,proto3" json:"force,omitempty"`
// contains filtered or unexported fields
}Message for deleting a Job
func (*DeleteJobRequest) Descriptor
func (*DeleteJobRequest) Descriptor() ([]byte, []int)Deprecated: Use DeleteJobRequest.ProtoReflect.Descriptor instead.
func (*DeleteJobRequest) GetForce
func (x *DeleteJobRequest) GetForce() boolfunc (*DeleteJobRequest) GetName
func (x *DeleteJobRequest) GetName() stringfunc (*DeleteJobRequest) GetRequestId
func (x *DeleteJobRequest) GetRequestId() stringfunc (*DeleteJobRequest) ProtoMessage
func (*DeleteJobRequest) ProtoMessage()func (*DeleteJobRequest) ProtoReflect
func (x *DeleteJobRequest) ProtoReflect() protoreflect.Messagefunc (*DeleteJobRequest) Reset
func (x *DeleteJobRequest) Reset()func (*DeleteJobRequest) String
func (x *DeleteJobRequest) String() stringDeleteObject
type DeleteObject struct {
// Required. Controls deletion behavior when versioning is enabled for the
// object's bucket. If true both live and noncurrent objects will be
// permanently deleted. Otherwise live objects in versioned buckets will
// become noncurrent and objects that were already noncurrent will be skipped.
// This setting doesn't have any impact on the Soft Delete feature. All
// objects deleted by this service can be be restored for the duration of the
// Soft Delete retention duration if enabled. If enabled and the manifest
// doesn't specify an object's generation, a GetObjectMetadata call (a Class B
// operation) will be made to determine the live object generation.
PermanentObjectDeletionEnabled bool `protobuf:"varint,1,opt,name=permanent_object_deletion_enabled,json=permanentObjectDeletionEnabled,proto3" json:"permanent_object_deletion_enabled,omitempty"`
// contains filtered or unexported fields
}Describes options to delete an object.
func (*DeleteObject) Descriptor
func (*DeleteObject) Descriptor() ([]byte, []int)Deprecated: Use DeleteObject.ProtoReflect.Descriptor instead.
func (*DeleteObject) GetPermanentObjectDeletionEnabled
func (x *DeleteObject) GetPermanentObjectDeletionEnabled() boolfunc (*DeleteObject) ProtoMessage
func (*DeleteObject) ProtoMessage()func (*DeleteObject) ProtoReflect
func (x *DeleteObject) ProtoReflect() protoreflect.Messagefunc (*DeleteObject) Reset
func (x *DeleteObject) Reset()func (*DeleteObject) String
func (x *DeleteObject) String() stringErrorLogEntry
type ErrorLogEntry struct {
// Required. Output only. Object URL. e.g. gs://my_bucket/object.txt
ObjectUri string `protobuf:"bytes,1,opt,name=object_uri,json=objectUri,proto3" json:"object_uri,omitempty"`
// Optional. Output only. At most 5 error log entries are recorded for a given
// error code for a job.
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
func (*ErrorLogEntry) Descriptor() ([]byte, []int)Deprecated: Use ErrorLogEntry.ProtoReflect.Descriptor instead.
func (*ErrorLogEntry) GetErrorDetails
func (x *ErrorLogEntry) GetErrorDetails() []stringfunc (*ErrorLogEntry) GetObjectUri
func (x *ErrorLogEntry) GetObjectUri() stringfunc (*ErrorLogEntry) ProtoMessage
func (*ErrorLogEntry) ProtoMessage()func (*ErrorLogEntry) ProtoReflect
func (x *ErrorLogEntry) ProtoReflect() protoreflect.Messagefunc (*ErrorLogEntry) Reset
func (x *ErrorLogEntry) Reset()func (*ErrorLogEntry) String
func (x *ErrorLogEntry) String() stringErrorSummary
type ErrorSummary struct {
// Required. The canonical error code.
ErrorCode code.Code `protobuf:"varint,1,opt,name=error_code,json=errorCode,proto3,enum=google.rpc.Code" json:"error_code,omitempty"`
// Required. Number of errors encountered per `error_code`.
ErrorCount int64 `protobuf:"varint,2,opt,name=error_count,json=errorCount,proto3" json:"error_count,omitempty"`
// Required. Sample error logs.
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
func (*ErrorSummary) Descriptor() ([]byte, []int)Deprecated: Use ErrorSummary.ProtoReflect.Descriptor instead.
func (*ErrorSummary) GetErrorCode
func (x *ErrorSummary) GetErrorCode() code.Codefunc (*ErrorSummary) GetErrorCount
func (x *ErrorSummary) GetErrorCount() int64func (*ErrorSummary) GetErrorLogEntries
func (x *ErrorSummary) GetErrorLogEntries() []*ErrorLogEntryfunc (*ErrorSummary) ProtoMessage
func (*ErrorSummary) ProtoMessage()func (*ErrorSummary) ProtoReflect
func (x *ErrorSummary) ProtoReflect() protoreflect.Messagefunc (*ErrorSummary) Reset
func (x *ErrorSummary) Reset()func (*ErrorSummary) String
func (x *ErrorSummary) String() stringGetBucketOperationRequest
type GetBucketOperationRequest struct {
// Required. `name` of the bucket operation to retrieve.
// Format:
// projects/{project_id}/locations/global/jobs/{job_id}/bucketOperations/{bucket_operation_id}.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}Message for getting a BucketOperation.
func (*GetBucketOperationRequest) Descriptor
func (*GetBucketOperationRequest) Descriptor() ([]byte, []int)Deprecated: Use GetBucketOperationRequest.ProtoReflect.Descriptor instead.
func (*GetBucketOperationRequest) GetName
func (x *GetBucketOperationRequest) GetName() stringfunc (*GetBucketOperationRequest) ProtoMessage
func (*GetBucketOperationRequest) ProtoMessage()func (*GetBucketOperationRequest) ProtoReflect
func (x *GetBucketOperationRequest) ProtoReflect() protoreflect.Messagefunc (*GetBucketOperationRequest) Reset
func (x *GetBucketOperationRequest) Reset()func (*GetBucketOperationRequest) String
func (x *GetBucketOperationRequest) String() stringGetJobRequest
type GetJobRequest struct {
// Required. `name` of the job to retrieve.
// Format: projects/{project_id}/locations/global/jobs/{job_id} .
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}Message for getting a Job
func (*GetJobRequest) Descriptor
func (*GetJobRequest) Descriptor() ([]byte, []int)Deprecated: Use GetJobRequest.ProtoReflect.Descriptor instead.
func (*GetJobRequest) GetName
func (x *GetJobRequest) GetName() stringfunc (*GetJobRequest) ProtoMessage
func (*GetJobRequest) ProtoMessage()func (*GetJobRequest) ProtoReflect
func (x *GetJobRequest) ProtoReflect() protoreflect.Messagefunc (*GetJobRequest) Reset
func (x *GetJobRequest) Reset()func (*GetJobRequest) String
func (x *GetJobRequest) String() stringJob
type Job struct {
// Identifier. The resource name of the Job. job_id is unique
// within the project, that is either set by the customer or
// defined by the service. Format:
// projects/{project}/locations/global/jobs/{job_id} .
// For example: "projects/123456/locations/global/jobs/job01".
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// Optional. 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"`
// Specifies objects to be transformed.
//
// Types that are valid to be assigned to Source:
//
// *Job_BucketList
Source isJob_Source `protobuf_oneof:"source"`
// Operation to be performed on the objects.
//
// Types that are valid to be assigned to Transformation:
//
// *Job_PutObjectHold
// *Job_DeleteObject
// *Job_PutMetadata
// *Job_RewriteObject
// *Job_UpdateObjectCustomContext
Transformation isJob_Transformation `protobuf_oneof:"transformation"`
// Optional. Logging configuration.
LoggingConfig *LoggingConfig `protobuf:"bytes,9,opt,name=logging_config,json=loggingConfig,proto3" json:"logging_config,omitempty"`
// Output only. The time that the job was created.
CreateTime *timestamppb.Timestamp `protobuf:"bytes,10,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
// Output only. The time that the job was scheduled.
ScheduleTime *timestamppb.Timestamp `protobuf:"bytes,11,opt,name=schedule_time,json=scheduleTime,proto3" json:"schedule_time,omitempty"`
// Output only. The time that the job was completed.
CompleteTime *timestamppb.Timestamp `protobuf:"bytes,12,opt,name=complete_time,json=completeTime,proto3" json:"complete_time,omitempty"`
// Output only. Information about the progress of the job.
Counters *Counters `protobuf:"bytes,13,opt,name=counters,proto3" json:"counters,omitempty"`
// Output only. Summarizes errors encountered with sample error log entries.
ErrorSummaries []*ErrorSummary `protobuf:"bytes,14,rep,name=error_summaries,json=errorSummaries,proto3" json:"error_summaries,omitempty"`
// Output only. State of the job.
State Job_State `protobuf:"varint,15,opt,name=state,proto3,enum=google.cloud.storagebatchoperations.v1.Job_State" json:"state,omitempty"`
// Optional. If true, the job will run in dry run mode, returning the total
// object count and, if the object configuration is a prefix list, the bytes
// found from source. No transformations will be performed.
DryRun bool `protobuf:"varint,22,opt,name=dry_run,json=dryRun,proto3" json:"dry_run,omitempty"`
// Output only. If true, this Job operates on multiple buckets. Multibucket
// jobs are subject to different quota limits than single-bucket jobs.
IsMultiBucketJob bool `protobuf:"varint,24,opt,name=is_multi_bucket_job,json=isMultiBucketJob,proto3" json:"is_multi_bucket_job,omitempty"`
// contains filtered or unexported fields
}The Storage Batch Operations Job description.
func (*Job) Descriptor
Deprecated: Use Job.ProtoReflect.Descriptor instead.
func (*Job) GetBucketList
func (x *Job) GetBucketList() *BucketListfunc (*Job) GetCompleteTime
func (x *Job) GetCompleteTime() *timestamppb.Timestampfunc (*Job) GetCounters
func (*Job) GetCreateTime
func (x *Job) GetCreateTime() *timestamppb.Timestampfunc (*Job) GetDeleteObject
func (x *Job) GetDeleteObject() *DeleteObjectfunc (*Job) GetDescription
func (*Job) GetDryRun
func (*Job) GetErrorSummaries
func (x *Job) GetErrorSummaries() []*ErrorSummaryfunc (*Job) GetIsMultiBucketJob
func (*Job) GetLoggingConfig
func (x *Job) GetLoggingConfig() *LoggingConfigfunc (*Job) GetName
func (*Job) GetPutMetadata
func (x *Job) GetPutMetadata() *PutMetadatafunc (*Job) GetPutObjectHold
func (x *Job) GetPutObjectHold() *PutObjectHoldfunc (*Job) GetRewriteObject
func (x *Job) GetRewriteObject() *RewriteObjectfunc (*Job) GetScheduleTime
func (x *Job) GetScheduleTime() *timestamppb.Timestampfunc (*Job) GetSource
func (x *Job) GetSource() isJob_Sourcefunc (*Job) GetState
func (*Job) GetTransformation
func (x *Job) GetTransformation() isJob_Transformationfunc (*Job) GetUpdateObjectCustomContext
func (x *Job) GetUpdateObjectCustomContext() *UpdateObjectCustomContextfunc (*Job) ProtoMessage
func (*Job) ProtoMessage()func (*Job) ProtoReflect
func (x *Job) ProtoReflect() protoreflect.Messagefunc (*Job) Reset
func (x *Job) Reset()func (*Job) String
Job_BucketList
type Job_BucketList struct {
// Specifies a list of buckets and their objects to be transformed.
BucketList *BucketList `protobuf:"bytes,19,opt,name=bucket_list,json=bucketList,proto3,oneof"`
}Job_DeleteObject
type Job_DeleteObject struct {
// Delete objects.
DeleteObject *DeleteObject `protobuf:"bytes,6,opt,name=delete_object,json=deleteObject,proto3,oneof"`
}Job_PutMetadata
type Job_PutMetadata struct {
// Updates object metadata. Allows updating fixed-key and custom metadata
// and fixed-key metadata i.e. Cache-Control, Content-Disposition,
// Content-Encoding, Content-Language, Content-Type, Custom-Time.
PutMetadata *PutMetadata `protobuf:"bytes,8,opt,name=put_metadata,json=putMetadata,proto3,oneof"`
}Job_PutObjectHold
type Job_PutObjectHold struct {
// Changes object hold status.
PutObjectHold *PutObjectHold `protobuf:"bytes,5,opt,name=put_object_hold,json=putObjectHold,proto3,oneof"`
}Job_RewriteObject
type Job_RewriteObject struct {
// Rewrite the object and updates metadata like KMS key.
RewriteObject *RewriteObject `protobuf:"bytes,20,opt,name=rewrite_object,json=rewriteObject,proto3,oneof"`
}Job_State
type Job_State int32Describes state of a job.
Job_STATE_UNSPECIFIED, Job_RUNNING, Job_SUCCEEDED, Job_CANCELED, Job_FAILED, Job_QUEUED
const (
// Default value. This value is unused.
Job_STATE_UNSPECIFIED Job_State = 0
// In progress.
Job_RUNNING Job_State = 1
// Completed successfully.
Job_SUCCEEDED Job_State = 2
// Cancelled by the user.
Job_CANCELED Job_State = 3
// Terminated due to an unrecoverable failure.
Job_FAILED Job_State = 4
// Queued but not yet started.
Job_QUEUED Job_State = 5
)func (Job_State) Descriptor
func (Job_State) Descriptor() protoreflect.EnumDescriptorfunc (Job_State) Enum
func (Job_State) EnumDescriptor
Deprecated: Use Job_State.Descriptor instead.
func (Job_State) Number
func (x Job_State) Number() protoreflect.EnumNumberfunc (Job_State) String
func (Job_State) Type
func (Job_State) Type() protoreflect.EnumTypeJob_UpdateObjectCustomContext
type Job_UpdateObjectCustomContext struct {
// Update object custom context.
UpdateObjectCustomContext *UpdateObjectCustomContext `protobuf:"bytes,23,opt,name=update_object_custom_context,json=updateObjectCustomContext,proto3,oneof"`
}ListBucketOperationsRequest
type ListBucketOperationsRequest struct {
// Required. Format: projects/{project_id}/locations/global/jobs/{job_id}.
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// Optional. Filters results as defined by https://google.aip.dev/160.
Filter string `protobuf:"bytes,2,opt,name=filter,proto3" json:"filter,omitempty"`
// Optional. The list page size. Default page size is 100.
PageSize int32 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
// Optional. The list page token.
PageToken string `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
// Optional. Field to sort by. Supported fields are name, create_time.
OrderBy string `protobuf:"bytes,5,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"`
// contains filtered or unexported fields
}Message for request to list BucketOperations
func (*ListBucketOperationsRequest) Descriptor
func (*ListBucketOperationsRequest) Descriptor() ([]byte, []int)Deprecated: Use ListBucketOperationsRequest.ProtoReflect.Descriptor instead.
func (*ListBucketOperationsRequest) GetFilter
func (x *ListBucketOperationsRequest) GetFilter() stringfunc (*ListBucketOperationsRequest) GetOrderBy
func (x *ListBucketOperationsRequest) GetOrderBy() stringfunc (*ListBucketOperationsRequest) GetPageSize
func (x *ListBucketOperationsRequest) GetPageSize() int32func (*ListBucketOperationsRequest) GetPageToken
func (x *ListBucketOperationsRequest) GetPageToken() stringfunc (*ListBucketOperationsRequest) GetParent
func (x *ListBucketOperationsRequest) GetParent() stringfunc (*ListBucketOperationsRequest) ProtoMessage
func (*ListBucketOperationsRequest) ProtoMessage()func (*ListBucketOperationsRequest) ProtoReflect
func (x *ListBucketOperationsRequest) ProtoReflect() protoreflect.Messagefunc (*ListBucketOperationsRequest) Reset
func (x *ListBucketOperationsRequest) Reset()func (*ListBucketOperationsRequest) String
func (x *ListBucketOperationsRequest) String() stringListBucketOperationsResponse
type ListBucketOperationsResponse struct {
// A list of storage batch bucket operations.
BucketOperations []*BucketOperation `protobuf:"bytes,1,rep,name=bucket_operations,json=bucketOperations,proto3" json:"bucket_operations,omitempty"`
// A token identifying a page of results.
NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
// Locations that could not be reached.
Unreachable []string `protobuf:"bytes,3,rep,name=unreachable,proto3" json:"unreachable,omitempty"`
// contains filtered or unexported fields
}Message for response to listing BucketOperations
func (*ListBucketOperationsResponse) Descriptor
func (*ListBucketOperationsResponse) Descriptor() ([]byte, []int)Deprecated: Use ListBucketOperationsResponse.ProtoReflect.Descriptor instead.
func (*ListBucketOperationsResponse) GetBucketOperations
func (x *ListBucketOperationsResponse) GetBucketOperations() []*BucketOperationfunc (*ListBucketOperationsResponse) GetNextPageToken
func (x *ListBucketOperationsResponse) GetNextPageToken() stringfunc (*ListBucketOperationsResponse) GetUnreachable
func (x *ListBucketOperationsResponse) GetUnreachable() []stringfunc (*ListBucketOperationsResponse) ProtoMessage
func (*ListBucketOperationsResponse) ProtoMessage()func (*ListBucketOperationsResponse) ProtoReflect
func (x *ListBucketOperationsResponse) ProtoReflect() protoreflect.Messagefunc (*ListBucketOperationsResponse) Reset
func (x *ListBucketOperationsResponse) Reset()func (*ListBucketOperationsResponse) String
func (x *ListBucketOperationsResponse) String() stringListJobsRequest
type ListJobsRequest struct {
// Required. Format: projects/{project_id}/locations/global.
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// Optional. Filters results as defined by https://google.aip.dev/160.
Filter string `protobuf:"bytes,2,opt,name=filter,proto3" json:"filter,omitempty"`
// Optional. The list page size. default page size is 100.
PageSize int32 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
// Optional. The list page token.
PageToken string `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
// Optional. Field to sort by. Supported fields are name, create_time.
OrderBy string `protobuf:"bytes,5,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"`
// contains filtered or unexported fields
}Message for request to list Jobs
func (*ListJobsRequest) Descriptor
func (*ListJobsRequest) Descriptor() ([]byte, []int)Deprecated: Use ListJobsRequest.ProtoReflect.Descriptor instead.
func (*ListJobsRequest) GetFilter
func (x *ListJobsRequest) GetFilter() stringfunc (*ListJobsRequest) GetOrderBy
func (x *ListJobsRequest) GetOrderBy() stringfunc (*ListJobsRequest) GetPageSize
func (x *ListJobsRequest) GetPageSize() int32func (*ListJobsRequest) GetPageToken
func (x *ListJobsRequest) GetPageToken() stringfunc (*ListJobsRequest) GetParent
func (x *ListJobsRequest) GetParent() stringfunc (*ListJobsRequest) ProtoMessage
func (*ListJobsRequest) ProtoMessage()func (*ListJobsRequest) ProtoReflect
func (x *ListJobsRequest) ProtoReflect() protoreflect.Messagefunc (*ListJobsRequest) Reset
func (x *ListJobsRequest) Reset()func (*ListJobsRequest) String
func (x *ListJobsRequest) String() stringListJobsResponse
type ListJobsResponse struct {
// A list of storage batch jobs.
Jobs []*Job `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
// A token identifying a page of results.
NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
// Locations that could not be reached.
Unreachable []string `protobuf:"bytes,3,rep,name=unreachable,proto3" json:"unreachable,omitempty"`
// contains filtered or unexported fields
}Message for response to listing Jobs
func (*ListJobsResponse) Descriptor
func (*ListJobsResponse) Descriptor() ([]byte, []int)Deprecated: Use ListJobsResponse.ProtoReflect.Descriptor instead.
func (*ListJobsResponse) GetJobs
func (x *ListJobsResponse) GetJobs() []*Jobfunc (*ListJobsResponse) GetNextPageToken
func (x *ListJobsResponse) GetNextPageToken() stringfunc (*ListJobsResponse) GetUnreachable
func (x *ListJobsResponse) GetUnreachable() []stringfunc (*ListJobsResponse) ProtoMessage
func (*ListJobsResponse) ProtoMessage()func (*ListJobsResponse) ProtoReflect
func (x *ListJobsResponse) ProtoReflect() protoreflect.Messagefunc (*ListJobsResponse) Reset
func (x *ListJobsResponse) Reset()func (*ListJobsResponse) String
func (x *ListJobsResponse) String() stringLoggingConfig
type LoggingConfig struct {
// Required. Specifies the actions to be logged.
LogActions []LoggingConfig_LoggableAction `protobuf:"varint,1,rep,packed,name=log_actions,json=logActions,proto3,enum=google.cloud.storagebatchoperations.v1.LoggingConfig_LoggableAction" json:"log_actions,omitempty"`
// Required. States in which Action are logged.If empty, no logs are
// generated.
LogActionStates []LoggingConfig_LoggableActionState `protobuf:"varint,2,rep,packed,name=log_action_states,json=logActionStates,proto3,enum=google.cloud.storagebatchoperations.v1.LoggingConfig_LoggableActionState" json:"log_action_states,omitempty"`
// contains filtered or unexported fields
}Specifies the Cloud Logging behavior.
func (*LoggingConfig) Descriptor
func (*LoggingConfig) Descriptor() ([]byte, []int)Deprecated: Use LoggingConfig.ProtoReflect.Descriptor instead.
func (*LoggingConfig) GetLogActionStates
func (x *LoggingConfig) GetLogActionStates() []LoggingConfig_LoggableActionStatefunc (*LoggingConfig) GetLogActions
func (x *LoggingConfig) GetLogActions() []LoggingConfig_LoggableActionfunc (*LoggingConfig) ProtoMessage
func (*LoggingConfig) ProtoMessage()func (*LoggingConfig) ProtoReflect
func (x *LoggingConfig) ProtoReflect() protoreflect.Messagefunc (*LoggingConfig) Reset
func (x *LoggingConfig) Reset()func (*LoggingConfig) String
func (x *LoggingConfig) String() stringLoggingConfig_LoggableAction
type LoggingConfig_LoggableAction int32Loggable actions types.
LoggingConfig_LOGGABLE_ACTION_UNSPECIFIED, LoggingConfig_TRANSFORM
const (
// Illegal value, to avoid allowing a default.
LoggingConfig_LOGGABLE_ACTION_UNSPECIFIED LoggingConfig_LoggableAction = 0
// The corresponding transform action in this job.
LoggingConfig_TRANSFORM LoggingConfig_LoggableAction = 6
)func (LoggingConfig_LoggableAction) Descriptor
func (LoggingConfig_LoggableAction) Descriptor() protoreflect.EnumDescriptorfunc (LoggingConfig_LoggableAction) Enum
func (x LoggingConfig_LoggableAction) Enum() *LoggingConfig_LoggableActionfunc (LoggingConfig_LoggableAction) EnumDescriptor
func (LoggingConfig_LoggableAction) EnumDescriptor() ([]byte, []int)Deprecated: Use LoggingConfig_LoggableAction.Descriptor instead.
func (LoggingConfig_LoggableAction) Number
func (x LoggingConfig_LoggableAction) Number() protoreflect.EnumNumberfunc (LoggingConfig_LoggableAction) String
func (x LoggingConfig_LoggableAction) String() stringfunc (LoggingConfig_LoggableAction) Type
func (LoggingConfig_LoggableAction) Type() protoreflect.EnumTypeLoggingConfig_LoggableActionState
type LoggingConfig_LoggableActionState int32Loggable action states filter.
LoggingConfig_LOGGABLE_ACTION_STATE_UNSPECIFIED, LoggingConfig_SUCCEEDED, LoggingConfig_FAILED
const (
// Illegal value, to avoid allowing a default.
LoggingConfig_LOGGABLE_ACTION_STATE_UNSPECIFIED LoggingConfig_LoggableActionState = 0
// `LoggableAction` completed successfully. `SUCCEEDED` actions are
// logged as [INFO][google.logging.type.LogSeverity.INFO].
LoggingConfig_SUCCEEDED LoggingConfig_LoggableActionState = 1
// `LoggableAction` terminated in an error state. `FAILED` actions
// are logged as [ERROR][google.logging.type.LogSeverity.ERROR].
LoggingConfig_FAILED LoggingConfig_LoggableActionState = 2
)func (LoggingConfig_LoggableActionState) Descriptor
func (LoggingConfig_LoggableActionState) Descriptor() protoreflect.EnumDescriptorfunc (LoggingConfig_LoggableActionState) Enum
func (x LoggingConfig_LoggableActionState) Enum() *LoggingConfig_LoggableActionStatefunc (LoggingConfig_LoggableActionState) EnumDescriptor
func (LoggingConfig_LoggableActionState) EnumDescriptor() ([]byte, []int)Deprecated: Use LoggingConfig_LoggableActionState.Descriptor instead.
func (LoggingConfig_LoggableActionState) Number
func (x LoggingConfig_LoggableActionState) Number() protoreflect.EnumNumberfunc (LoggingConfig_LoggableActionState) String
func (x LoggingConfig_LoggableActionState) String() stringfunc (LoggingConfig_LoggableActionState) Type
func (LoggingConfig_LoggableActionState) Type() protoreflect.EnumTypeManifest
type Manifest struct {
// Required. `manifest_location` must contain the manifest source file that is
// a CSV file in a Google Cloud Storage bucket. Each row in the file must
// include the object details i.e. BucketId and Name. Generation may
// optionally be specified. When it is not specified the live object is acted
// upon. `manifest_location` should either be 1) An absolute path to the
// object in the format of `gs://bucket_name/path/file_name.csv`. 2) An
// absolute path with a single wildcard character in the file name, for
// example `gs://bucket_name/path/file_name*.csv`.
// If manifest location is specified with a wildcard, objects in all manifest
// files matching the pattern will be acted upon.
ManifestLocation string `protobuf:"bytes,2,opt,name=manifest_location,json=manifestLocation,proto3" json:"manifest_location,omitempty"`
// contains filtered or unexported fields
}Describes list of objects to be transformed.
func (*Manifest) Descriptor
Deprecated: Use Manifest.ProtoReflect.Descriptor instead.
func (*Manifest) GetManifestLocation
func (*Manifest) ProtoMessage
func (*Manifest) ProtoMessage()func (*Manifest) ProtoReflect
func (x *Manifest) ProtoReflect() protoreflect.Messagefunc (*Manifest) Reset
func (x *Manifest) Reset()func (*Manifest) String
ObjectCustomContextPayload
type ObjectCustomContextPayload struct {
// The value of the object custom context.
// If set, `value` must NOT be an empty string since it is a required field in
// custom context. If unset, `value` will be ignored and no changes will be
// made to the `value` field of the custom context payload.
Value *string `protobuf:"bytes,1,opt,name=value,proto3,oneof" json:"value,omitempty"`
// contains filtered or unexported fields
}Describes the payload of a user defined object custom context.
func (*ObjectCustomContextPayload) Descriptor
func (*ObjectCustomContextPayload) Descriptor() ([]byte, []int)Deprecated: Use ObjectCustomContextPayload.ProtoReflect.Descriptor instead.
func (*ObjectCustomContextPayload) GetValue
func (x *ObjectCustomContextPayload) GetValue() stringfunc (*ObjectCustomContextPayload) ProtoMessage
func (*ObjectCustomContextPayload) ProtoMessage()func (*ObjectCustomContextPayload) ProtoReflect
func (x *ObjectCustomContextPayload) ProtoReflect() protoreflect.Messagefunc (*ObjectCustomContextPayload) Reset
func (x *ObjectCustomContextPayload) Reset()func (*ObjectCustomContextPayload) String
func (x *ObjectCustomContextPayload) String() stringObjectRetention
type ObjectRetention struct {
// Required. The time when the object will be retained until. UNSET will clear
// the retention. Must be specified in RFC 3339 format e.g.
// YYYY-MM-DD'T'HH:MM:SS.SS'Z' or YYYY-MM-DD'T'HH:MM:SS'Z'.
RetainUntilTime *string `protobuf:"bytes,1,opt,name=retain_until_time,json=retainUntilTime,proto3,oneof" json:"retain_until_time,omitempty"`
// Required. The retention mode of the object.
RetentionMode *ObjectRetention_RetentionMode `protobuf:"varint,2,opt,name=retention_mode,json=retentionMode,proto3,enum=google.cloud.storagebatchoperations.v1.ObjectRetention_RetentionMode,oneof" json:"retention_mode,omitempty"`
// contains filtered or unexported fields
}Describes options for object retention update.
func (*ObjectRetention) Descriptor
func (*ObjectRetention) Descriptor() ([]byte, []int)Deprecated: Use ObjectRetention.ProtoReflect.Descriptor instead.
func (*ObjectRetention) GetRetainUntilTime
func (x *ObjectRetention) GetRetainUntilTime() stringfunc (*ObjectRetention) GetRetentionMode
func (x *ObjectRetention) GetRetentionMode() ObjectRetention_RetentionModefunc (*ObjectRetention) ProtoMessage
func (*ObjectRetention) ProtoMessage()func (*ObjectRetention) ProtoReflect
func (x *ObjectRetention) ProtoReflect() protoreflect.Messagefunc (*ObjectRetention) Reset
func (x *ObjectRetention) Reset()func (*ObjectRetention) String
func (x *ObjectRetention) String() stringObjectRetention_RetentionMode
type ObjectRetention_RetentionMode int32Describes the retention mode.
ObjectRetention_RETENTION_MODE_UNSPECIFIED, ObjectRetention_LOCKED, ObjectRetention_UNLOCKED
const (
// If set and retain_until_time is empty, clears the retention.
ObjectRetention_RETENTION_MODE_UNSPECIFIED ObjectRetention_RetentionMode = 0
// Sets the retention mode to locked.
ObjectRetention_LOCKED ObjectRetention_RetentionMode = 1
// Sets the retention mode to unlocked.
ObjectRetention_UNLOCKED ObjectRetention_RetentionMode = 2
)func (ObjectRetention_RetentionMode) Descriptor
func (ObjectRetention_RetentionMode) Descriptor() protoreflect.EnumDescriptorfunc (ObjectRetention_RetentionMode) Enum
func (x ObjectRetention_RetentionMode) Enum() *ObjectRetention_RetentionModefunc (ObjectRetention_RetentionMode) EnumDescriptor
func (ObjectRetention_RetentionMode) EnumDescriptor() ([]byte, []int)Deprecated: Use ObjectRetention_RetentionMode.Descriptor instead.
func (ObjectRetention_RetentionMode) Number
func (x ObjectRetention_RetentionMode) Number() protoreflect.EnumNumberfunc (ObjectRetention_RetentionMode) String
func (x ObjectRetention_RetentionMode) String() stringfunc (ObjectRetention_RetentionMode) Type
func (ObjectRetention_RetentionMode) Type() protoreflect.EnumTypeOperationMetadata
type OperationMetadata struct {
// Output only. The unique operation resource name.
// Format: projects/{project}/locations/global/operations/{operation}.
Operation string `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
// Output only. The time the operation was created.
CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
// Output only. The time the operation finished running.
EndTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
// Output only. Identifies whether the user has requested cancellation
// of the operation. Operations that have been cancelled successfully
// have
// [google.longrunning.Operation.error][google.longrunning.Operation.error]
// value with a [google.rpc.Status.code][google.rpc.Status.code] of 1,
// corresponding to
// `[Code.CANCELLED][google.rpc.Code.CANCELLED]`.
RequestedCancellation bool `protobuf:"varint,7,opt,name=requested_cancellation,json=requestedCancellation,proto3" json:"requested_cancellation,omitempty"`
// Output only. API version used to start the operation.
ApiVersion string `protobuf:"bytes,8,opt,name=api_version,json=apiVersion,proto3" json:"api_version,omitempty"`
// Output only. The Job associated with the operation.
Job *Job `protobuf:"bytes,10,opt,name=job,proto3" json:"job,omitempty"`
// contains filtered or unexported fields
}Represents the metadata of the long-running operation.
func (*OperationMetadata) Descriptor
func (*OperationMetadata) Descriptor() ([]byte, []int)Deprecated: Use OperationMetadata.ProtoReflect.Descriptor instead.
func (*OperationMetadata) GetApiVersion
func (x *OperationMetadata) GetApiVersion() stringfunc (*OperationMetadata) GetCreateTime
func (x *OperationMetadata) GetCreateTime() *timestamppb.Timestampfunc (*OperationMetadata) GetEndTime
func (x *OperationMetadata) GetEndTime() *timestamppb.Timestampfunc (*OperationMetadata) GetJob
func (x *OperationMetadata) GetJob() *Jobfunc (*OperationMetadata) GetOperation
func (x *OperationMetadata) GetOperation() stringfunc (*OperationMetadata) GetRequestedCancellation
func (x *OperationMetadata) GetRequestedCancellation() boolfunc (*OperationMetadata) ProtoMessage
func (*OperationMetadata) ProtoMessage()func (*OperationMetadata) ProtoReflect
func (x *OperationMetadata) ProtoReflect() protoreflect.Messagefunc (*OperationMetadata) Reset
func (x *OperationMetadata) Reset()func (*OperationMetadata) String
func (x *OperationMetadata) String() stringPrefixList
type PrefixList struct {
// Optional. Include prefixes of the objects to be transformed.
// * Supports full object name
// * Supports prefix of the object name
// * Wildcards are not supported
// * Supports empty string for all objects in a bucket.
IncludedObjectPrefixes []string `protobuf:"bytes,2,rep,name=included_object_prefixes,json=includedObjectPrefixes,proto3" json:"included_object_prefixes,omitempty"`
// contains filtered or unexported fields
}Describes prefixes of objects to be transformed.
func (*PrefixList) Descriptor
func (*PrefixList) Descriptor() ([]byte, []int)Deprecated: Use PrefixList.ProtoReflect.Descriptor instead.
func (*PrefixList) GetIncludedObjectPrefixes
func (x *PrefixList) GetIncludedObjectPrefixes() []stringfunc (*PrefixList) ProtoMessage
func (*PrefixList) ProtoMessage()func (*PrefixList) ProtoReflect
func (x *PrefixList) ProtoReflect() protoreflect.Messagefunc (*PrefixList) Reset
func (x *PrefixList) Reset()func (*PrefixList) String
func (x *PrefixList) String() stringPutMetadata
type PutMetadata struct {
// Optional. Updates objects Content-Disposition fixed metadata. Unset values
// will be ignored. Set empty values to clear the metadata. Refer
// https://cloud.google.com/storage/docs/metadata#content-disposition for
// additional documentation.
ContentDisposition *string `protobuf:"bytes,1,opt,name=content_disposition,json=contentDisposition,proto3,oneof" json:"content_disposition,omitempty"`
// Optional. Updates objects Content-Encoding fixed metadata. Unset values
// will be ignored. Set empty values to clear the metadata. Refer to
// documentation in
// https://cloud.google.com/storage/docs/metadata#content-encoding.
ContentEncoding *string `protobuf:"bytes,2,opt,name=content_encoding,json=contentEncoding,proto3,oneof" json:"content_encoding,omitempty"`
// Optional. Updates objects Content-Language fixed metadata. Refer to ISO
// 639-1 language codes for typical values of this metadata. Max length 100
// characters. Unset values will be ignored. Set empty values to clear the
// metadata. Refer to documentation in
// https://cloud.google.com/storage/docs/metadata#content-language.
ContentLanguage *string `protobuf:"bytes,3,opt,name=content_language,json=contentLanguage,proto3,oneof" json:"content_language,omitempty"`
// Optional. Updates objects Content-Type fixed metadata. Unset values will be
// ignored. Set empty values to clear the metadata. Refer to documentation in
// https://cloud.google.com/storage/docs/metadata#content-type
ContentType *string `protobuf:"bytes,4,opt,name=content_type,json=contentType,proto3,oneof" json:"content_type,omitempty"`
// Optional. Updates objects Cache-Control fixed metadata. Unset values will
// be ignored. Set empty values to clear the metadata. Additionally, the value
// for Custom-Time cannot decrease. Refer to documentation in
// https://cloud.google.com/storage/docs/metadata#caching_data.
CacheControl *string `protobuf:"bytes,5,opt,name=cache_control,json=cacheControl,proto3,oneof" json:"cache_control,omitempty"`
// Optional. Updates objects Custom-Time fixed metadata. Unset values will be
// ignored. Set empty values to clear the metadata. Refer to documentation in
// https://cloud.google.com/storage/docs/metadata#custom-time.
CustomTime *string `protobuf:"bytes,6,opt,name=custom_time,json=customTime,proto3,oneof" json:"custom_time,omitempty"`
// Optional. Updates objects custom metadata. Adds or sets individual custom
// metadata key value pairs on objects. Keys that are set with empty custom
// metadata values will have its value cleared. Existing custom metadata not
// specified with this flag is not changed. Refer to documentation in
// https://cloud.google.com/storage/docs/metadata#custom-metadata
CustomMetadata map[string]string `protobuf:"bytes,7,rep,name=custom_metadata,json=customMetadata,proto3" json:"custom_metadata,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
// Optional. Updates objects retention lock configuration. Unset values will
// be ignored. Set empty values to clear the retention for the object with
// existing `Unlocked` retention mode. Object with existing `Locked` retention
// mode cannot be cleared or reduce retain_until_time. Refer to documentation
// in https://cloud.google.com/storage/docs/object-lock
ObjectRetention *ObjectRetention `protobuf:"bytes,8,opt,name=object_retention,json=objectRetention,proto3,oneof" json:"object_retention,omitempty"`
// contains filtered or unexported fields
}Describes options for object metadata update.
func (*PutMetadata) Descriptor
func (*PutMetadata) Descriptor() ([]byte, []int)Deprecated: Use PutMetadata.ProtoReflect.Descriptor instead.
func (*PutMetadata) GetCacheControl
func (x *PutMetadata) GetCacheControl() stringfunc (*PutMetadata) GetContentDisposition
func (x *PutMetadata) GetContentDisposition() stringfunc (*PutMetadata) GetContentEncoding
func (x *PutMetadata) GetContentEncoding() stringfunc (*PutMetadata) GetContentLanguage
func (x *PutMetadata) GetContentLanguage() stringfunc (*PutMetadata) GetContentType
func (x *PutMetadata) GetContentType() stringfunc (*PutMetadata) GetCustomMetadata
func (x *PutMetadata) GetCustomMetadata() map[string]stringfunc (*PutMetadata) GetCustomTime
func (x *PutMetadata) GetCustomTime() stringfunc (*PutMetadata) GetObjectRetention
func (x *PutMetadata) GetObjectRetention() *ObjectRetentionfunc (*PutMetadata) ProtoMessage
func (*PutMetadata) ProtoMessage()func (*PutMetadata) ProtoReflect
func (x *PutMetadata) ProtoReflect() protoreflect.Messagefunc (*PutMetadata) Reset
func (x *PutMetadata) Reset()func (*PutMetadata) String
func (x *PutMetadata) String() stringPutObjectHold
type PutObjectHold struct {
// Required. Updates object temporary holds state. When object temporary hold
// is set, object cannot be deleted or replaced.
TemporaryHold PutObjectHold_HoldStatus `protobuf:"varint,1,opt,name=temporary_hold,json=temporaryHold,proto3,enum=google.cloud.storagebatchoperations.v1.PutObjectHold_HoldStatus" json:"temporary_hold,omitempty"`
// Required. Updates object event based holds state. When object event based
// hold is set, object cannot be deleted or replaced. Resets object's time in
// the bucket for the purposes of the retention period.
EventBasedHold PutObjectHold_HoldStatus `protobuf:"varint,2,opt,name=event_based_hold,json=eventBasedHold,proto3,enum=google.cloud.storagebatchoperations.v1.PutObjectHold_HoldStatus" json:"event_based_hold,omitempty"`
// contains filtered or unexported fields
}Describes options to update object hold.
func (*PutObjectHold) Descriptor
func (*PutObjectHold) Descriptor() ([]byte, []int)Deprecated: Use PutObjectHold.ProtoReflect.Descriptor instead.
func (*PutObjectHold) GetEventBasedHold
func (x *PutObjectHold) GetEventBasedHold() PutObjectHold_HoldStatusfunc (*PutObjectHold) GetTemporaryHold
func (x *PutObjectHold) GetTemporaryHold() PutObjectHold_HoldStatusfunc (*PutObjectHold) ProtoMessage
func (*PutObjectHold) ProtoMessage()func (*PutObjectHold) ProtoReflect
func (x *PutObjectHold) ProtoReflect() protoreflect.Messagefunc (*PutObjectHold) Reset
func (x *PutObjectHold) Reset()func (*PutObjectHold) String
func (x *PutObjectHold) String() stringPutObjectHold_HoldStatus
type PutObjectHold_HoldStatus int32Describes the status of the hold.
PutObjectHold_HOLD_STATUS_UNSPECIFIED, PutObjectHold_SET, PutObjectHold_UNSET
const (
// Default value, Object hold status will not be changed.
PutObjectHold_HOLD_STATUS_UNSPECIFIED PutObjectHold_HoldStatus = 0
// Places the hold.
PutObjectHold_SET PutObjectHold_HoldStatus = 1
// Releases the hold.
PutObjectHold_UNSET PutObjectHold_HoldStatus = 2
)func (PutObjectHold_HoldStatus) Descriptor
func (PutObjectHold_HoldStatus) Descriptor() protoreflect.EnumDescriptorfunc (PutObjectHold_HoldStatus) Enum
func (x PutObjectHold_HoldStatus) Enum() *PutObjectHold_HoldStatusfunc (PutObjectHold_HoldStatus) EnumDescriptor
func (PutObjectHold_HoldStatus) EnumDescriptor() ([]byte, []int)Deprecated: Use PutObjectHold_HoldStatus.Descriptor instead.
func (PutObjectHold_HoldStatus) Number
func (x PutObjectHold_HoldStatus) Number() protoreflect.EnumNumberfunc (PutObjectHold_HoldStatus) String
func (x PutObjectHold_HoldStatus) String() stringfunc (PutObjectHold_HoldStatus) Type
func (PutObjectHold_HoldStatus) Type() protoreflect.EnumTypeRewriteObject
type RewriteObject struct {
// Required. Resource name of the Cloud KMS key that will be used to encrypt
// the object. The Cloud KMS key must be located in same location as the
// object. Refer to
// https://cloud.google.com/storage/docs/encryption/using-customer-managed-keys#add-object-key
// for additional documentation. Format:
// projects/{project}/locations/{location}/keyRings/{keyring}/cryptoKeys/{key}
// For example:
// "projects/123456/locations/us-central1/keyRings/my-keyring/cryptoKeys/my-key".
// The object will be rewritten and set with the specified KMS key.
KmsKey *string `protobuf:"bytes,1,opt,name=kms_key,json=kmsKey,proto3,oneof" json:"kms_key,omitempty"`
// contains filtered or unexported fields
}Describes options for object rewrite.
func (*RewriteObject) Descriptor
func (*RewriteObject) Descriptor() ([]byte, []int)Deprecated: Use RewriteObject.ProtoReflect.Descriptor instead.
func (*RewriteObject) GetKmsKey
func (x *RewriteObject) GetKmsKey() stringfunc (*RewriteObject) ProtoMessage
func (*RewriteObject) ProtoMessage()func (*RewriteObject) ProtoReflect
func (x *RewriteObject) ProtoReflect() protoreflect.Messagefunc (*RewriteObject) Reset
func (x *RewriteObject) Reset()func (*RewriteObject) String
func (x *RewriteObject) String() stringStorageBatchOperationsClient
type StorageBatchOperationsClient interface {
// Lists Jobs in a given project.
ListJobs(ctx context.Context, in *ListJobsRequest, opts ...grpc.CallOption) (*ListJobsResponse, error)
// Gets a batch job.
GetJob(ctx context.Context, in *GetJobRequest, opts ...grpc.CallOption) (*Job, error)
// Creates a batch job.
CreateJob(ctx context.Context, in *CreateJobRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
// Deletes a batch job.
DeleteJob(ctx context.Context, in *DeleteJobRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
// Cancels a batch job.
CancelJob(ctx context.Context, in *CancelJobRequest, opts ...grpc.CallOption) (*CancelJobResponse, error)
// Lists BucketOperations in a given project and job.
ListBucketOperations(ctx context.Context, in *ListBucketOperationsRequest, opts ...grpc.CallOption) (*ListBucketOperationsResponse, error)
// Gets a BucketOperation.
GetBucketOperation(ctx context.Context, in *GetBucketOperationRequest, opts ...grpc.CallOption) (*BucketOperation, error)
}StorageBatchOperationsClient is the client API for StorageBatchOperations service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewStorageBatchOperationsClient
func NewStorageBatchOperationsClient(cc grpc.ClientConnInterface) StorageBatchOperationsClientStorageBatchOperationsServer
type StorageBatchOperationsServer interface {
// Lists Jobs in a given project.
ListJobs(context.Context, *ListJobsRequest) (*ListJobsResponse, error)
// Gets a batch job.
GetJob(context.Context, *GetJobRequest) (*Job, error)
// Creates a batch job.
CreateJob(context.Context, *CreateJobRequest) (*longrunningpb.Operation, error)
// Deletes a batch job.
DeleteJob(context.Context, *DeleteJobRequest) (*emptypb.Empty, error)
// Cancels a batch job.
CancelJob(context.Context, *CancelJobRequest) (*CancelJobResponse, error)
// Lists BucketOperations in a given project and job.
ListBucketOperations(context.Context, *ListBucketOperationsRequest) (*ListBucketOperationsResponse, error)
// Gets a BucketOperation.
GetBucketOperation(context.Context, *GetBucketOperationRequest) (*BucketOperation, error)
}StorageBatchOperationsServer is the server API for StorageBatchOperations service. All implementations should embed UnimplementedStorageBatchOperationsServer for forward compatibility
UnimplementedStorageBatchOperationsServer
type UnimplementedStorageBatchOperationsServer struct {
}UnimplementedStorageBatchOperationsServer should be embedded to have forward compatible implementations.
func (UnimplementedStorageBatchOperationsServer) CancelJob
func (UnimplementedStorageBatchOperationsServer) CancelJob(context.Context, *CancelJobRequest) (*CancelJobResponse, error)func (UnimplementedStorageBatchOperationsServer) CreateJob
func (UnimplementedStorageBatchOperationsServer) CreateJob(context.Context, *CreateJobRequest) (*longrunningpb.Operation, error)func (UnimplementedStorageBatchOperationsServer) DeleteJob
func (UnimplementedStorageBatchOperationsServer) DeleteJob(context.Context, *DeleteJobRequest) (*emptypb.Empty, error)func (UnimplementedStorageBatchOperationsServer) GetBucketOperation
func (UnimplementedStorageBatchOperationsServer) GetBucketOperation(context.Context, *GetBucketOperationRequest) (*BucketOperation, error)func (UnimplementedStorageBatchOperationsServer) GetJob
func (UnimplementedStorageBatchOperationsServer) GetJob(context.Context, *GetJobRequest) (*Job, error)func (UnimplementedStorageBatchOperationsServer) ListBucketOperations
func (UnimplementedStorageBatchOperationsServer) ListBucketOperations(context.Context, *ListBucketOperationsRequest) (*ListBucketOperationsResponse, error)func (UnimplementedStorageBatchOperationsServer) ListJobs
func (UnimplementedStorageBatchOperationsServer) ListJobs(context.Context, *ListJobsRequest) (*ListJobsResponse, error)UnsafeStorageBatchOperationsServer
type UnsafeStorageBatchOperationsServer interface {
// contains filtered or unexported methods
}UnsafeStorageBatchOperationsServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StorageBatchOperationsServer will result in compilation errors.
UpdateObjectCustomContext
type UpdateObjectCustomContext struct {
// One of the actions must be set.
//
// Types that are valid to be assigned to Action:
//
// *UpdateObjectCustomContext_CustomContextUpdates
// *UpdateObjectCustomContext_ClearAll
Action isUpdateObjectCustomContext_Action `protobuf_oneof:"action"`
// contains filtered or unexported fields
}Describes options to update object custom contexts.
func (*UpdateObjectCustomContext) Descriptor
func (*UpdateObjectCustomContext) Descriptor() ([]byte, []int)Deprecated: Use UpdateObjectCustomContext.ProtoReflect.Descriptor instead.
func (*UpdateObjectCustomContext) GetAction
func (x *UpdateObjectCustomContext) GetAction() isUpdateObjectCustomContext_Actionfunc (*UpdateObjectCustomContext) GetClearAll
func (x *UpdateObjectCustomContext) GetClearAll() boolfunc (*UpdateObjectCustomContext) GetCustomContextUpdates
func (x *UpdateObjectCustomContext) GetCustomContextUpdates() *CustomContextUpdatesfunc (*UpdateObjectCustomContext) ProtoMessage
func (*UpdateObjectCustomContext) ProtoMessage()func (*UpdateObjectCustomContext) ProtoReflect
func (x *UpdateObjectCustomContext) ProtoReflect() protoreflect.Messagefunc (*UpdateObjectCustomContext) Reset
func (x *UpdateObjectCustomContext) Reset()func (*UpdateObjectCustomContext) String
func (x *UpdateObjectCustomContext) String() stringUpdateObjectCustomContext_ClearAll
type UpdateObjectCustomContext_ClearAll struct {
// If set, must be set to true and all existing object custom contexts will
// be deleted.
ClearAll bool `protobuf:"varint,2,opt,name=clear_all,json=clearAll,proto3,oneof"`
}UpdateObjectCustomContext_CustomContextUpdates
type UpdateObjectCustomContext_CustomContextUpdates struct {
// A collection of updates to apply to specific custom contexts.
// Use this to add, update or delete individual contexts by key.
CustomContextUpdates *CustomContextUpdates `protobuf:"bytes,1,opt,name=custom_context_updates,json=customContextUpdates,proto3,oneof"`
}