Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterParallelstoreServer(s grpc.ServiceRegistrar, srv ParallelstoreServer)
- type CreateInstanceRequest
- func (*CreateInstanceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateInstanceRequest) GetInstance() *Instance
- func (x *CreateInstanceRequest) GetInstanceId() string
- func (x *CreateInstanceRequest) GetParent() string
- func (x *CreateInstanceRequest) GetRequestId() string
- func (*CreateInstanceRequest) ProtoMessage()
- func (x *CreateInstanceRequest) ProtoReflect() protoreflect.Message
- func (x *CreateInstanceRequest) Reset()
- func (x *CreateInstanceRequest) String() string
- type DeleteInstanceRequest
- func (*DeleteInstanceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteInstanceRequest) GetName() string
- func (x *DeleteInstanceRequest) GetRequestId() string
- func (*DeleteInstanceRequest) ProtoMessage()
- func (x *DeleteInstanceRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteInstanceRequest) Reset()
- func (x *DeleteInstanceRequest) String() string
- type DeploymentType
- func (DeploymentType) Descriptor() protoreflect.EnumDescriptor
- func (x DeploymentType) Enum() *DeploymentType
- func (DeploymentType) EnumDescriptor() ([]byte, []int)deprecated
- func (x DeploymentType) Number() protoreflect.EnumNumber
- func (x DeploymentType) String() string
- func (DeploymentType) Type() protoreflect.EnumType
- type DestinationGcsBucket
- func (*DestinationGcsBucket) Descriptor() ([]byte, []int)deprecated
- func (x *DestinationGcsBucket) GetUri() string
- func (*DestinationGcsBucket) ProtoMessage()
- func (x *DestinationGcsBucket) ProtoReflect() protoreflect.Message
- func (x *DestinationGcsBucket) Reset()
- func (x *DestinationGcsBucket) String() string
- type DestinationParallelstore
- func (*DestinationParallelstore) Descriptor() ([]byte, []int)deprecated
- func (x *DestinationParallelstore) GetPath() string
- func (*DestinationParallelstore) ProtoMessage()
- func (x *DestinationParallelstore) ProtoReflect() protoreflect.Message
- func (x *DestinationParallelstore) Reset()
- func (x *DestinationParallelstore) String() string
- type DirectoryStripeLevel
- func (DirectoryStripeLevel) Descriptor() protoreflect.EnumDescriptor
- func (x DirectoryStripeLevel) Enum() *DirectoryStripeLevel
- func (DirectoryStripeLevel) EnumDescriptor() ([]byte, []int)deprecated
- func (x DirectoryStripeLevel) Number() protoreflect.EnumNumber
- func (x DirectoryStripeLevel) String() string
- func (DirectoryStripeLevel) Type() protoreflect.EnumType
- type ExportDataMetadata
- func (*ExportDataMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *ExportDataMetadata) GetApiVersion() string
- func (x *ExportDataMetadata) GetCreateTime() *timestamppb.Timestamp
- func (x *ExportDataMetadata) GetEndTime() *timestamppb.Timestamp
- func (x *ExportDataMetadata) GetOperationMetadata() *TransferOperationMetadata
- func (x *ExportDataMetadata) GetRequestedCancellation() bool
- func (x *ExportDataMetadata) GetStatusMessage() string
- func (x *ExportDataMetadata) GetTarget() string
- func (x *ExportDataMetadata) GetVerb() string
- func (*ExportDataMetadata) ProtoMessage()
- func (x *ExportDataMetadata) ProtoReflect() protoreflect.Message
- func (x *ExportDataMetadata) Reset()
- func (x *ExportDataMetadata) String() string
- type ExportDataRequest
- func (*ExportDataRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ExportDataRequest) GetDestination() isExportDataRequest_Destination
- func (x *ExportDataRequest) GetDestinationGcsBucket() *DestinationGcsBucket
- func (x *ExportDataRequest) GetMetadataOptions() *TransferMetadataOptions
- func (x *ExportDataRequest) GetName() string
- func (x *ExportDataRequest) GetRequestId() string
- func (x *ExportDataRequest) GetServiceAccount() string
- func (x *ExportDataRequest) GetSource() isExportDataRequest_Source
- func (x *ExportDataRequest) GetSourceParallelstore() *SourceParallelstore
- func (*ExportDataRequest) ProtoMessage()
- func (x *ExportDataRequest) ProtoReflect() protoreflect.Message
- func (x *ExportDataRequest) Reset()
- func (x *ExportDataRequest) String() string
- type ExportDataRequest_DestinationGcsBucket
- type ExportDataRequest_SourceParallelstore
- type ExportDataResponse
- type FileStripeLevel
- func (FileStripeLevel) Descriptor() protoreflect.EnumDescriptor
- func (x FileStripeLevel) Enum() *FileStripeLevel
- func (FileStripeLevel) EnumDescriptor() ([]byte, []int)deprecated
- func (x FileStripeLevel) Number() protoreflect.EnumNumber
- func (x FileStripeLevel) String() string
- func (FileStripeLevel) Type() protoreflect.EnumType
- type GetInstanceRequest
- func (*GetInstanceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetInstanceRequest) GetName() string
- func (*GetInstanceRequest) ProtoMessage()
- func (x *GetInstanceRequest) ProtoReflect() protoreflect.Message
- func (x *GetInstanceRequest) Reset()
- func (x *GetInstanceRequest) String() string
- type ImportDataMetadata
- func (*ImportDataMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *ImportDataMetadata) GetApiVersion() string
- func (x *ImportDataMetadata) GetCreateTime() *timestamppb.Timestamp
- func (x *ImportDataMetadata) GetEndTime() *timestamppb.Timestamp
- func (x *ImportDataMetadata) GetOperationMetadata() *TransferOperationMetadata
- func (x *ImportDataMetadata) GetRequestedCancellation() bool
- func (x *ImportDataMetadata) GetStatusMessage() string
- func (x *ImportDataMetadata) GetTarget() string
- func (x *ImportDataMetadata) GetVerb() string
- func (*ImportDataMetadata) ProtoMessage()
- func (x *ImportDataMetadata) ProtoReflect() protoreflect.Message
- func (x *ImportDataMetadata) Reset()
- func (x *ImportDataMetadata) String() string
- type ImportDataRequest
- func (*ImportDataRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ImportDataRequest) GetDestination() isImportDataRequest_Destination
- func (x *ImportDataRequest) GetDestinationParallelstore() *DestinationParallelstore
- func (x *ImportDataRequest) GetMetadataOptions() *TransferMetadataOptions
- func (x *ImportDataRequest) GetName() string
- func (x *ImportDataRequest) GetRequestId() string
- func (x *ImportDataRequest) GetServiceAccount() string
- func (x *ImportDataRequest) GetSource() isImportDataRequest_Source
- func (x *ImportDataRequest) GetSourceGcsBucket() *SourceGcsBucket
- func (*ImportDataRequest) ProtoMessage()
- func (x *ImportDataRequest) ProtoReflect() protoreflect.Message
- func (x *ImportDataRequest) Reset()
- func (x *ImportDataRequest) String() string
- type ImportDataRequest_DestinationParallelstore
- type ImportDataRequest_SourceGcsBucket
- type ImportDataResponse
- type Instance
- func (*Instance) Descriptor() ([]byte, []int)deprecated
- func (x *Instance) GetAccessPoints() []string
- func (x *Instance) GetCapacityGib() int64
- func (x *Instance) GetCreateTime() *timestamppb.Timestamp
- func (x *Instance) GetDaosVersion() stringdeprecated
- func (x *Instance) GetDeploymentType() DeploymentType
- func (x *Instance) GetDescription() string
- func (x *Instance) GetDirectoryStripeLevel() DirectoryStripeLevel
- func (x *Instance) GetEffectiveReservedIpRange() string
- func (x *Instance) GetFileStripeLevel() FileStripeLevel
- func (x *Instance) GetLabels() map[string]string
- func (x *Instance) GetName() string
- func (x *Instance) GetNetwork() string
- func (x *Instance) GetReservedIpRange() string
- func (x *Instance) GetState() Instance_State
- func (x *Instance) GetUpdateTime() *timestamppb.Timestamp
- func (*Instance) ProtoMessage()
- func (x *Instance) ProtoReflect() protoreflect.Message
- func (x *Instance) Reset()
- func (x *Instance) String() string
- type Instance_State
- func (Instance_State) Descriptor() protoreflect.EnumDescriptor
- func (x Instance_State) Enum() *Instance_State
- func (Instance_State) EnumDescriptor() ([]byte, []int)deprecated
- func (x Instance_State) Number() protoreflect.EnumNumber
- func (x Instance_State) String() string
- func (Instance_State) Type() protoreflect.EnumType
- type ListInstancesRequest
- func (*ListInstancesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListInstancesRequest) GetFilter() string
- func (x *ListInstancesRequest) GetOrderBy() string
- func (x *ListInstancesRequest) GetPageSize() int32
- func (x *ListInstancesRequest) GetPageToken() string
- func (x *ListInstancesRequest) GetParent() string
- func (*ListInstancesRequest) ProtoMessage()
- func (x *ListInstancesRequest) ProtoReflect() protoreflect.Message
- func (x *ListInstancesRequest) Reset()
- func (x *ListInstancesRequest) String() string
- type ListInstancesResponse
- func (*ListInstancesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListInstancesResponse) GetInstances() []*Instance
- func (x *ListInstancesResponse) GetNextPageToken() string
- func (x *ListInstancesResponse) GetUnreachable() []string
- func (*ListInstancesResponse) ProtoMessage()
- func (x *ListInstancesResponse) ProtoReflect() protoreflect.Message
- func (x *ListInstancesResponse) Reset()
- func (x *ListInstancesResponse) String() string
- type OperationMetadata
- func (*OperationMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *OperationMetadata) GetApiVersion() string
- func (x *OperationMetadata) GetCreateTime() *timestamppb.Timestamp
- func (x *OperationMetadata) GetEndTime() *timestamppb.Timestamp
- func (x *OperationMetadata) GetRequestedCancellation() bool
- func (x *OperationMetadata) GetStatusMessage() string
- func (x *OperationMetadata) GetTarget() string
- func (x *OperationMetadata) GetVerb() string
- func (*OperationMetadata) ProtoMessage()
- func (x *OperationMetadata) ProtoReflect() protoreflect.Message
- func (x *OperationMetadata) Reset()
- func (x *OperationMetadata) String() string
- type ParallelstoreClient
- type ParallelstoreServer
- type SourceGcsBucket
- type SourceParallelstore
- func (*SourceParallelstore) Descriptor() ([]byte, []int)deprecated
- func (x *SourceParallelstore) GetPath() string
- func (*SourceParallelstore) ProtoMessage()
- func (x *SourceParallelstore) ProtoReflect() protoreflect.Message
- func (x *SourceParallelstore) Reset()
- func (x *SourceParallelstore) String() string
- type TransferCounters
- func (*TransferCounters) Descriptor() ([]byte, []int)deprecated
- func (x *TransferCounters) GetBytesCopied() int64
- func (x *TransferCounters) GetBytesFailed() int64
- func (x *TransferCounters) GetBytesFound() int64
- func (x *TransferCounters) GetBytesSkipped() int64
- func (x *TransferCounters) GetObjectsCopied() int64
- func (x *TransferCounters) GetObjectsFailed() int64
- func (x *TransferCounters) GetObjectsFound() int64
- func (x *TransferCounters) GetObjectsSkipped() int64
- func (*TransferCounters) ProtoMessage()
- func (x *TransferCounters) ProtoReflect() protoreflect.Message
- func (x *TransferCounters) Reset()
- func (x *TransferCounters) String() string
- type TransferErrorLogEntry
- func (*TransferErrorLogEntry) Descriptor() ([]byte, []int)deprecated
- func (x *TransferErrorLogEntry) GetErrorDetails() []string
- func (x *TransferErrorLogEntry) GetUri() string
- func (*TransferErrorLogEntry) ProtoMessage()
- func (x *TransferErrorLogEntry) ProtoReflect() protoreflect.Message
- func (x *TransferErrorLogEntry) Reset()
- func (x *TransferErrorLogEntry) String() string
- type TransferErrorSummary
- func (*TransferErrorSummary) Descriptor() ([]byte, []int)deprecated
- func (x *TransferErrorSummary) GetErrorCode() code.Code
- func (x *TransferErrorSummary) GetErrorCount() int64
- func (x *TransferErrorSummary) GetErrorLogEntries() []*TransferErrorLogEntry
- func (*TransferErrorSummary) ProtoMessage()
- func (x *TransferErrorSummary) ProtoReflect() protoreflect.Message
- func (x *TransferErrorSummary) Reset()
- func (x *TransferErrorSummary) String() string
- type TransferMetadataOptions
- func (*TransferMetadataOptions) Descriptor() ([]byte, []int)deprecated
- func (x *TransferMetadataOptions) GetGid() TransferMetadataOptions_Gid
- func (x *TransferMetadataOptions) GetMode() TransferMetadataOptions_Mode
- func (x *TransferMetadataOptions) GetUid() TransferMetadataOptions_Uid
- func (*TransferMetadataOptions) ProtoMessage()
- func (x *TransferMetadataOptions) ProtoReflect() protoreflect.Message
- func (x *TransferMetadataOptions) Reset()
- func (x *TransferMetadataOptions) String() string
- type TransferMetadataOptions_Gid
- func (TransferMetadataOptions_Gid) Descriptor() protoreflect.EnumDescriptor
- func (x TransferMetadataOptions_Gid) Enum() *TransferMetadataOptions_Gid
- func (TransferMetadataOptions_Gid) EnumDescriptor() ([]byte, []int)deprecated
- func (x TransferMetadataOptions_Gid) Number() protoreflect.EnumNumber
- func (x TransferMetadataOptions_Gid) String() string
- func (TransferMetadataOptions_Gid) Type() protoreflect.EnumType
- type TransferMetadataOptions_Mode
- func (TransferMetadataOptions_Mode) Descriptor() protoreflect.EnumDescriptor
- func (x TransferMetadataOptions_Mode) Enum() *TransferMetadataOptions_Mode
- func (TransferMetadataOptions_Mode) EnumDescriptor() ([]byte, []int)deprecated
- func (x TransferMetadataOptions_Mode) Number() protoreflect.EnumNumber
- func (x TransferMetadataOptions_Mode) String() string
- func (TransferMetadataOptions_Mode) Type() protoreflect.EnumType
- type TransferMetadataOptions_Uid
- func (TransferMetadataOptions_Uid) Descriptor() protoreflect.EnumDescriptor
- func (x TransferMetadataOptions_Uid) Enum() *TransferMetadataOptions_Uid
- func (TransferMetadataOptions_Uid) EnumDescriptor() ([]byte, []int)deprecated
- func (x TransferMetadataOptions_Uid) Number() protoreflect.EnumNumber
- func (x TransferMetadataOptions_Uid) String() string
- func (TransferMetadataOptions_Uid) Type() protoreflect.EnumType
- type TransferOperationMetadata
- func (*TransferOperationMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *TransferOperationMetadata) GetCounters() *TransferCounters
- func (x *TransferOperationMetadata) GetDestination() isTransferOperationMetadata_Destination
- func (x *TransferOperationMetadata) GetDestinationGcsBucket() *DestinationGcsBucket
- func (x *TransferOperationMetadata) GetDestinationParallelstore() *DestinationParallelstore
- func (x *TransferOperationMetadata) GetErrorSummary() []*TransferErrorSummary
- func (x *TransferOperationMetadata) GetSource() isTransferOperationMetadata_Source
- func (x *TransferOperationMetadata) GetSourceGcsBucket() *SourceGcsBucket
- func (x *TransferOperationMetadata) GetSourceParallelstore() *SourceParallelstore
- func (x *TransferOperationMetadata) GetTransferType() TransferType
- func (*TransferOperationMetadata) ProtoMessage()
- func (x *TransferOperationMetadata) ProtoReflect() protoreflect.Message
- func (x *TransferOperationMetadata) Reset()
- func (x *TransferOperationMetadata) String() string
- type TransferOperationMetadata_DestinationGcsBucket
- type TransferOperationMetadata_DestinationParallelstore
- type TransferOperationMetadata_SourceGcsBucket
- type TransferOperationMetadata_SourceParallelstore
- type TransferType
- func (TransferType) Descriptor() protoreflect.EnumDescriptor
- func (x TransferType) Enum() *TransferType
- func (TransferType) EnumDescriptor() ([]byte, []int)deprecated
- func (x TransferType) Number() protoreflect.EnumNumber
- func (x TransferType) String() string
- func (TransferType) Type() protoreflect.EnumType
- type UnimplementedParallelstoreServer
- func (UnimplementedParallelstoreServer) CreateInstance(context.Context, *CreateInstanceRequest) (*longrunningpb.Operation, error)
- func (UnimplementedParallelstoreServer) DeleteInstance(context.Context, *DeleteInstanceRequest) (*longrunningpb.Operation, error)
- func (UnimplementedParallelstoreServer) ExportData(context.Context, *ExportDataRequest) (*longrunningpb.Operation, error)
- func (UnimplementedParallelstoreServer) GetInstance(context.Context, *GetInstanceRequest) (*Instance, error)
- func (UnimplementedParallelstoreServer) ImportData(context.Context, *ImportDataRequest) (*longrunningpb.Operation, error)
- func (UnimplementedParallelstoreServer) ListInstances(context.Context, *ListInstancesRequest) (*ListInstancesResponse, error)
- func (UnimplementedParallelstoreServer) UpdateInstance(context.Context, *UpdateInstanceRequest) (*longrunningpb.Operation, error)
- type UnsafeParallelstoreServer
- type UpdateInstanceRequest
- func (*UpdateInstanceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateInstanceRequest) GetInstance() *Instance
- func (x *UpdateInstanceRequest) GetRequestId() string
- func (x *UpdateInstanceRequest) GetUpdateMask() *fieldmaskpb.FieldMask
- func (*UpdateInstanceRequest) ProtoMessage()
- func (x *UpdateInstanceRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateInstanceRequest) Reset()
- func (x *UpdateInstanceRequest) String() string
Constants ¶
const ( Parallelstore_ListInstances_FullMethodName = "/google.cloud.parallelstore.v1.Parallelstore/ListInstances" Parallelstore_GetInstance_FullMethodName = "/google.cloud.parallelstore.v1.Parallelstore/GetInstance" Parallelstore_CreateInstance_FullMethodName = "/google.cloud.parallelstore.v1.Parallelstore/CreateInstance" Parallelstore_UpdateInstance_FullMethodName = "/google.cloud.parallelstore.v1.Parallelstore/UpdateInstance" Parallelstore_DeleteInstance_FullMethodName = "/google.cloud.parallelstore.v1.Parallelstore/DeleteInstance" Parallelstore_ImportData_FullMethodName = "/google.cloud.parallelstore.v1.Parallelstore/ImportData" Parallelstore_ExportData_FullMethodName = "/google.cloud.parallelstore.v1.Parallelstore/ExportData" )
Variables ¶
var ( TransferType_name = map[int32]string{ 0: "TRANSFER_TYPE_UNSPECIFIED", 1: "IMPORT", 2: "EXPORT", } TransferType_value = map[string]int32{ "TRANSFER_TYPE_UNSPECIFIED": 0, "IMPORT": 1, "EXPORT": 2, } )
Enum value maps for TransferType.
var ( FileStripeLevel_name = map[int32]string{ 0: "FILE_STRIPE_LEVEL_UNSPECIFIED", 1: "FILE_STRIPE_LEVEL_MIN", 2: "FILE_STRIPE_LEVEL_BALANCED", 3: "FILE_STRIPE_LEVEL_MAX", } FileStripeLevel_value = map[string]int32{ "FILE_STRIPE_LEVEL_UNSPECIFIED": 0, "FILE_STRIPE_LEVEL_MIN": 1, "FILE_STRIPE_LEVEL_BALANCED": 2, "FILE_STRIPE_LEVEL_MAX": 3, } )
Enum value maps for FileStripeLevel.
var ( DirectoryStripeLevel_name = map[int32]string{ 0: "DIRECTORY_STRIPE_LEVEL_UNSPECIFIED", 1: "DIRECTORY_STRIPE_LEVEL_MIN", 2: "DIRECTORY_STRIPE_LEVEL_BALANCED", 3: "DIRECTORY_STRIPE_LEVEL_MAX", } DirectoryStripeLevel_value = map[string]int32{ "DIRECTORY_STRIPE_LEVEL_UNSPECIFIED": 0, "DIRECTORY_STRIPE_LEVEL_MIN": 1, "DIRECTORY_STRIPE_LEVEL_BALANCED": 2, "DIRECTORY_STRIPE_LEVEL_MAX": 3, } )
Enum value maps for DirectoryStripeLevel.
var ( DeploymentType_name = map[int32]string{ 0: "DEPLOYMENT_TYPE_UNSPECIFIED", 1: "SCRATCH", 2: "PERSISTENT", } DeploymentType_value = map[string]int32{ "DEPLOYMENT_TYPE_UNSPECIFIED": 0, "SCRATCH": 1, "PERSISTENT": 2, } )
Enum value maps for DeploymentType.
var ( Instance_State_name = map[int32]string{ 0: "STATE_UNSPECIFIED", 1: "CREATING", 2: "ACTIVE", 3: "DELETING", 4: "FAILED", 5: "UPGRADING", 6: "REPAIRING", } Instance_State_value = map[string]int32{ "STATE_UNSPECIFIED": 0, "CREATING": 1, "ACTIVE": 2, "DELETING": 3, "FAILED": 4, "UPGRADING": 5, "REPAIRING": 6, } )
Enum value maps for Instance_State.
var ( TransferMetadataOptions_Uid_name = map[int32]string{ 0: "UID_UNSPECIFIED", 1: "UID_SKIP", 2: "UID_NUMBER_PRESERVE", } TransferMetadataOptions_Uid_value = map[string]int32{ "UID_UNSPECIFIED": 0, "UID_SKIP": 1, "UID_NUMBER_PRESERVE": 2, } )
Enum value maps for TransferMetadataOptions_Uid.
var ( TransferMetadataOptions_Gid_name = map[int32]string{ 0: "GID_UNSPECIFIED", 1: "GID_SKIP", 2: "GID_NUMBER_PRESERVE", } TransferMetadataOptions_Gid_value = map[string]int32{ "GID_UNSPECIFIED": 0, "GID_SKIP": 1, "GID_NUMBER_PRESERVE": 2, } )
Enum value maps for TransferMetadataOptions_Gid.
var ( TransferMetadataOptions_Mode_name = map[int32]string{ 0: "MODE_UNSPECIFIED", 1: "MODE_SKIP", 2: "MODE_PRESERVE", } TransferMetadataOptions_Mode_value = map[string]int32{ "MODE_UNSPECIFIED": 0, "MODE_SKIP": 1, "MODE_PRESERVE": 2, } )
Enum value maps for TransferMetadataOptions_Mode.
var File_google_cloud_parallelstore_v1_parallelstore_proto protoreflect.FileDescriptor
var Parallelstore_ServiceDesc = grpc.ServiceDesc{ ServiceName: "google.cloud.parallelstore.v1.Parallelstore", HandlerType: (*ParallelstoreServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "ListInstances", Handler: _Parallelstore_ListInstances_Handler, }, { MethodName: "GetInstance", Handler: _Parallelstore_GetInstance_Handler, }, { MethodName: "CreateInstance", Handler: _Parallelstore_CreateInstance_Handler, }, { MethodName: "UpdateInstance", Handler: _Parallelstore_UpdateInstance_Handler, }, { MethodName: "DeleteInstance", Handler: _Parallelstore_DeleteInstance_Handler, }, { MethodName: "ImportData", Handler: _Parallelstore_ImportData_Handler, }, { MethodName: "ExportData", Handler: _Parallelstore_ExportData_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "google/cloud/parallelstore/v1/parallelstore.proto", }
Parallelstore_ServiceDesc is the grpc.ServiceDesc for Parallelstore service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterParallelstoreServer ¶
func RegisterParallelstoreServer(s grpc.ServiceRegistrar, srv ParallelstoreServer)
Types ¶
type CreateInstanceRequest ¶
type CreateInstanceRequest struct {
// Required. The instance's project and location, in the format
// `projects/{project}/locations/{location}`.
// Locations map to Google Cloud zones; for example, `us-west1-b`.
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// Required. The name of the Parallelstore instance.
//
// * Must contain only lowercase letters, numbers, and hyphens.
// * Must start with a letter.
// * Must be between 1-63 characters.
// * Must end with a number or a letter.
// * Must be unique within the customer project / location
InstanceId string `protobuf:"bytes,2,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
// Required. The instance to create.
Instance *Instance `protobuf:"bytes,3,opt,name=instance,proto3" json:"instance,omitempty"`
// Optional. An optional request ID to identify requests. Specify a unique
// request ID so that if you must retry your request, the server will know to
// ignore the request if it has already been completed. The server will
// guarantee that for at least 60 minutes since the first request.
//
// For example, consider a situation where you make an initial request and
// the request times out. If you make the request again with the same request
// ID, the server can check if original operation with the same request ID
// was received, and if so, will ignore the second request. This prevents
// clients from accidentally creating duplicate commitments.
//
// 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
}
Create a new Parallelstore instance.
func (*CreateInstanceRequest) Descriptor
deprecated
func (*CreateInstanceRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateInstanceRequest.ProtoReflect.Descriptor instead.
func (*CreateInstanceRequest) GetInstance ¶
func (x *CreateInstanceRequest) GetInstance() *Instance
func (*CreateInstanceRequest) GetInstanceId ¶
func (x *CreateInstanceRequest) GetInstanceId() string
func (*CreateInstanceRequest) GetParent ¶
func (x *CreateInstanceRequest) GetParent() string
func (*CreateInstanceRequest) GetRequestId ¶
func (x *CreateInstanceRequest) GetRequestId() string
func (*CreateInstanceRequest) ProtoMessage ¶
func (*CreateInstanceRequest) ProtoMessage()
func (*CreateInstanceRequest) ProtoReflect ¶
func (x *CreateInstanceRequest) ProtoReflect() protoreflect.Message
func (*CreateInstanceRequest) Reset ¶
func (x *CreateInstanceRequest) Reset()
func (*CreateInstanceRequest) String ¶
func (x *CreateInstanceRequest) String() string
type DeleteInstanceRequest ¶
type DeleteInstanceRequest struct {
// Required. Name of the resource
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 so that if you must retry your request, the server will know to
// ignore the request if it has already been completed. The server will
// guarantee that for at least 60 minutes after the first request.
//
// For example, consider a situation where you make an initial request and
// the request times out. If you make the request again with the same request
// ID, the server can check if original operation with the same request ID
// was received, and if so, will ignore the second request. This prevents
// clients from accidentally creating duplicate commitments.
//
// 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"`
// contains filtered or unexported fields
}
Delete an instance.
func (*DeleteInstanceRequest) Descriptor
deprecated
func (*DeleteInstanceRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteInstanceRequest.ProtoReflect.Descriptor instead.
func (*DeleteInstanceRequest) GetName ¶
func (x *DeleteInstanceRequest) GetName() string
func (*DeleteInstanceRequest) GetRequestId ¶
func (x *DeleteInstanceRequest) GetRequestId() string
func (*DeleteInstanceRequest) ProtoMessage ¶
func (*DeleteInstanceRequest) ProtoMessage()
func (*DeleteInstanceRequest) ProtoReflect ¶
func (x *DeleteInstanceRequest) ProtoReflect() protoreflect.Message
func (*DeleteInstanceRequest) Reset ¶
func (x *DeleteInstanceRequest) Reset()
func (*DeleteInstanceRequest) String ¶
func (x *DeleteInstanceRequest) String() string
type DeploymentType ¶ added in v0.10.0
type DeploymentType int32
Represents the deployment type for the instance.
const ( // Default Deployment Type // It is equivalent to SCRATCH DeploymentType_DEPLOYMENT_TYPE_UNSPECIFIED DeploymentType = 0 // Scratch DeploymentType_SCRATCH DeploymentType = 1 // Persistent DeploymentType_PERSISTENT DeploymentType = 2 )
func (DeploymentType) Descriptor ¶ added in v0.10.0
func (DeploymentType) Descriptor() protoreflect.EnumDescriptor
func (DeploymentType) Enum ¶ added in v0.10.0
func (x DeploymentType) Enum() *DeploymentType
func (DeploymentType) EnumDescriptor
deprecated
added in
v0.10.0
func (DeploymentType) EnumDescriptor() ([]byte, []int)
Deprecated: Use DeploymentType.Descriptor instead.
func (DeploymentType) Number ¶ added in v0.10.0
func (x DeploymentType) Number() protoreflect.EnumNumber
func (DeploymentType) String ¶ added in v0.10.0
func (x DeploymentType) String() string
func (DeploymentType) Type ¶ added in v0.10.0
func (DeploymentType) Type() protoreflect.EnumType
type DestinationGcsBucket ¶
type DestinationGcsBucket struct {
// Required. URI to a Cloud Storage bucket in the format:
// `gs://<bucket_name>/<path_inside_bucket>`. The path inside the bucket is
// optional.
Uri string `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"`
// contains filtered or unexported fields
}
Cloud Storage as the destination of a data transfer.
func (*DestinationGcsBucket) Descriptor
deprecated
func (*DestinationGcsBucket) Descriptor() ([]byte, []int)
Deprecated: Use DestinationGcsBucket.ProtoReflect.Descriptor instead.
func (*DestinationGcsBucket) GetUri ¶
func (x *DestinationGcsBucket) GetUri() string
func (*DestinationGcsBucket) ProtoMessage ¶
func (*DestinationGcsBucket) ProtoMessage()
func (*DestinationGcsBucket) ProtoReflect ¶
func (x *DestinationGcsBucket) ProtoReflect() protoreflect.Message
func (*DestinationGcsBucket) Reset ¶
func (x *DestinationGcsBucket) Reset()
func (*DestinationGcsBucket) String ¶
func (x *DestinationGcsBucket) String() string
type DestinationParallelstore ¶
type DestinationParallelstore struct {
// Optional. Root directory path to the Paralellstore filesystem, starting
// with `/`. Defaults to `/` if unset.
Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
// contains filtered or unexported fields
}
Parallelstore as the destination of a data transfer.
func (*DestinationParallelstore) Descriptor
deprecated
func (*DestinationParallelstore) Descriptor() ([]byte, []int)
Deprecated: Use DestinationParallelstore.ProtoReflect.Descriptor instead.
func (*DestinationParallelstore) GetPath ¶
func (x *DestinationParallelstore) GetPath() string
func (*DestinationParallelstore) ProtoMessage ¶
func (*DestinationParallelstore) ProtoMessage()
func (*DestinationParallelstore) ProtoReflect ¶
func (x *DestinationParallelstore) ProtoReflect() protoreflect.Message
func (*DestinationParallelstore) Reset ¶
func (x *DestinationParallelstore) Reset()
func (*DestinationParallelstore) String ¶
func (x *DestinationParallelstore) String() string
type DirectoryStripeLevel ¶
type DirectoryStripeLevel int32
Represents the striping options for directories.
const ( // If not set, DirectoryStripeLevel will default to DIRECTORY_STRIPE_LEVEL_MAX DirectoryStripeLevel_DIRECTORY_STRIPE_LEVEL_UNSPECIFIED DirectoryStripeLevel = 0 // Minimum directory striping DirectoryStripeLevel_DIRECTORY_STRIPE_LEVEL_MIN DirectoryStripeLevel = 1 // Medium directory striping DirectoryStripeLevel_DIRECTORY_STRIPE_LEVEL_BALANCED DirectoryStripeLevel = 2 // Maximum directory striping DirectoryStripeLevel_DIRECTORY_STRIPE_LEVEL_MAX DirectoryStripeLevel = 3 )
func (DirectoryStripeLevel) Descriptor ¶
func (DirectoryStripeLevel) Descriptor() protoreflect.EnumDescriptor
func (DirectoryStripeLevel) Enum ¶
func (x DirectoryStripeLevel) Enum() *DirectoryStripeLevel
func (DirectoryStripeLevel) EnumDescriptor
deprecated
func (DirectoryStripeLevel) EnumDescriptor() ([]byte, []int)
Deprecated: Use DirectoryStripeLevel.Descriptor instead.
func (DirectoryStripeLevel) Number ¶
func (x DirectoryStripeLevel) Number() protoreflect.EnumNumber
func (DirectoryStripeLevel) String ¶
func (x DirectoryStripeLevel) String() string
func (DirectoryStripeLevel) Type ¶
func (DirectoryStripeLevel) Type() protoreflect.EnumType
type ExportDataMetadata ¶
type ExportDataMetadata struct {
// Data transfer operation metadata.
OperationMetadata *TransferOperationMetadata `protobuf:"bytes,1,opt,name=operation_metadata,json=operationMetadata,proto3" json:"operation_metadata,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. Server-defined resource path for the target of the operation.
Target string `protobuf:"bytes,4,opt,name=target,proto3" json:"target,omitempty"`
// Output only. Name of the verb executed by the operation.
Verb string `protobuf:"bytes,5,opt,name=verb,proto3" json:"verb,omitempty"`
// Output only. Human-readable status of the operation, if any.
StatusMessage string `protobuf:"bytes,6,opt,name=status_message,json=statusMessage,proto3" json:"status_message,omitempty"`
// Output only. Identifies whether the user has requested cancellation
// of the operation. Operations that have successfully been cancelled
// have [Operation.error][google.longrunning.Operation.error] value with a
// [google.rpc.Status.code][google.rpc.Status.code] of 1, corresponding to
// `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"`
// contains filtered or unexported fields
}
Metadata related to the data export operation.
func (*ExportDataMetadata) Descriptor
deprecated
func (*ExportDataMetadata) Descriptor() ([]byte, []int)
Deprecated: Use ExportDataMetadata.ProtoReflect.Descriptor instead.
func (*ExportDataMetadata) GetApiVersion ¶
func (x *ExportDataMetadata) GetApiVersion() string
func (*ExportDataMetadata) GetCreateTime ¶
func (x *ExportDataMetadata) GetCreateTime() *timestamppb.Timestamp
func (*ExportDataMetadata) GetEndTime ¶
func (x *ExportDataMetadata) GetEndTime() *timestamppb.Timestamp
func (*ExportDataMetadata) GetOperationMetadata ¶
func (x *ExportDataMetadata) GetOperationMetadata() *TransferOperationMetadata
func (*ExportDataMetadata) GetRequestedCancellation ¶
func (x *ExportDataMetadata) GetRequestedCancellation() bool
func (*ExportDataMetadata) GetStatusMessage ¶
func (x *ExportDataMetadata) GetStatusMessage() string
func (*ExportDataMetadata) GetTarget ¶
func (x *ExportDataMetadata) GetTarget() string
func (*ExportDataMetadata) GetVerb ¶
func (x *ExportDataMetadata) GetVerb() string
func (*ExportDataMetadata) ProtoMessage ¶
func (*ExportDataMetadata) ProtoMessage()
func (*ExportDataMetadata) ProtoReflect ¶
func (x *ExportDataMetadata) ProtoReflect() protoreflect.Message
func (*ExportDataMetadata) Reset ¶
func (x *ExportDataMetadata) Reset()
func (*ExportDataMetadata) String ¶
func (x *ExportDataMetadata) String() string
type ExportDataRequest ¶
type ExportDataRequest struct {
// The Parallelstore instance to export from.
//
// Types that are valid to be assigned to Source:
//
// *ExportDataRequest_SourceParallelstore
Source isExportDataRequest_Source `protobuf_oneof:"source"`
// The Cloud Storage bucket to export to.
//
// Types that are valid to be assigned to Destination:
//
// *ExportDataRequest_DestinationGcsBucket
Destination isExportDataRequest_Destination `protobuf_oneof:"destination"`
// Required. Name of the resource.
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 so that if you must retry your request, the server will know to
// ignore the request if it has already been completed. The server will
// guarantee that for at least 60 minutes since the first request.
//
// For example, consider a situation where you make an initial request and
// the request times out. If you make the request again with the same request
// ID, the server can check if original operation with the same request ID
// was received, and if so, will ignore the second request. This prevents
// clients from accidentally creating duplicate commitments.
//
// 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"`
// Optional. User-specified Service Account (SA) credentials to be used when
// performing the transfer.
// Use one of the following formats:
//
// * `{EMAIL_ADDRESS_OR_UNIQUE_ID}`
// * `projects/{PROJECT_ID_OR_NUMBER}/serviceAccounts/{EMAIL_ADDRESS_OR_UNIQUE_ID}`
// * `projects/-/serviceAccounts/{EMAIL_ADDRESS_OR_UNIQUE_ID}`
//
// If unspecified, the Parallelstore service agent is used:
// `service-<PROJECT_NUMBER>@gcp-sa-parallelstore.iam.gserviceaccount.com`
ServiceAccount string `protobuf:"bytes,5,opt,name=service_account,json=serviceAccount,proto3" json:"service_account,omitempty"`
// Optional. The metadata options for the export data.
MetadataOptions *TransferMetadataOptions `protobuf:"bytes,6,opt,name=metadata_options,json=metadataOptions,proto3" json:"metadata_options,omitempty"`
// contains filtered or unexported fields
}
Export data from Parallelstore to Cloud Storage.
func (*ExportDataRequest) Descriptor
deprecated
func (*ExportDataRequest) Descriptor() ([]byte, []int)
Deprecated: Use ExportDataRequest.ProtoReflect.Descriptor instead.
func (*ExportDataRequest) GetDestination ¶
func (x *ExportDataRequest) GetDestination() isExportDataRequest_Destination
func (*ExportDataRequest) GetDestinationGcsBucket ¶
func (x *ExportDataRequest) GetDestinationGcsBucket() *DestinationGcsBucket
func (*ExportDataRequest) GetMetadataOptions ¶ added in v0.12.0
func (x *ExportDataRequest) GetMetadataOptions() *TransferMetadataOptions
func (*ExportDataRequest) GetName ¶
func (x *ExportDataRequest) GetName() string
func (*ExportDataRequest) GetRequestId ¶
func (x *ExportDataRequest) GetRequestId() string
func (*ExportDataRequest) GetServiceAccount ¶
func (x *ExportDataRequest) GetServiceAccount() string
func (*ExportDataRequest) GetSource ¶
func (x *ExportDataRequest) GetSource() isExportDataRequest_Source
func (*ExportDataRequest) GetSourceParallelstore ¶
func (x *ExportDataRequest) GetSourceParallelstore() *SourceParallelstore
func (*ExportDataRequest) ProtoMessage ¶
func (*ExportDataRequest) ProtoMessage()
func (*ExportDataRequest) ProtoReflect ¶
func (x *ExportDataRequest) ProtoReflect() protoreflect.Message
func (*ExportDataRequest) Reset ¶
func (x *ExportDataRequest) Reset()
func (*ExportDataRequest) String ¶
func (x *ExportDataRequest) String() string
type ExportDataRequest_DestinationGcsBucket ¶
type ExportDataRequest_DestinationGcsBucket struct {
// Cloud Storage destination.
DestinationGcsBucket *DestinationGcsBucket `protobuf:"bytes,3,opt,name=destination_gcs_bucket,json=destinationGcsBucket,proto3,oneof"`
}
type ExportDataRequest_SourceParallelstore ¶
type ExportDataRequest_SourceParallelstore struct {
// Parallelstore source.
SourceParallelstore *SourceParallelstore `protobuf:"bytes,2,opt,name=source_parallelstore,json=sourceParallelstore,proto3,oneof"`
}
type ExportDataResponse ¶
type ExportDataResponse struct {
// contains filtered or unexported fields
}
The response to a request to export data from Parallelstore.
func (*ExportDataResponse) Descriptor
deprecated
func (*ExportDataResponse) Descriptor() ([]byte, []int)
Deprecated: Use ExportDataResponse.ProtoReflect.Descriptor instead.
func (*ExportDataResponse) ProtoMessage ¶
func (*ExportDataResponse) ProtoMessage()
func (*ExportDataResponse) ProtoReflect ¶
func (x *ExportDataResponse) ProtoReflect() protoreflect.Message
func (*ExportDataResponse) Reset ¶
func (x *ExportDataResponse) Reset()
func (*ExportDataResponse) String ¶
func (x *ExportDataResponse) String() string
type FileStripeLevel ¶
type FileStripeLevel int32
Represents the striping options for files.
const ( // If not set, FileStripeLevel will default to FILE_STRIPE_LEVEL_BALANCED FileStripeLevel_FILE_STRIPE_LEVEL_UNSPECIFIED FileStripeLevel = 0 // Minimum file striping FileStripeLevel_FILE_STRIPE_LEVEL_MIN FileStripeLevel = 1 // Medium file striping FileStripeLevel_FILE_STRIPE_LEVEL_BALANCED FileStripeLevel = 2 // Maximum file striping FileStripeLevel_FILE_STRIPE_LEVEL_MAX FileStripeLevel = 3 )
func (FileStripeLevel) Descriptor ¶
func (FileStripeLevel) Descriptor() protoreflect.EnumDescriptor
func (FileStripeLevel) Enum ¶
func (x FileStripeLevel) Enum() *FileStripeLevel
func (FileStripeLevel) EnumDescriptor
deprecated
func (FileStripeLevel) EnumDescriptor() ([]byte, []int)
Deprecated: Use FileStripeLevel.Descriptor instead.
func (FileStripeLevel) Number ¶
func (x FileStripeLevel) Number() protoreflect.EnumNumber
func (FileStripeLevel) String ¶
func (x FileStripeLevel) String() string
func (FileStripeLevel) Type ¶
func (FileStripeLevel) Type() protoreflect.EnumType
type GetInstanceRequest ¶
type GetInstanceRequest struct {
// Required. The instance resource name, in the format
// `projects/{project_id}/locations/{location}/instances/{instance_id}`.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
Get an instance's details.
func (*GetInstanceRequest) Descriptor
deprecated
func (*GetInstanceRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetInstanceRequest.ProtoReflect.Descriptor instead.
func (*GetInstanceRequest) GetName ¶
func (x *GetInstanceRequest) GetName() string
func (*GetInstanceRequest) ProtoMessage ¶
func (*GetInstanceRequest) ProtoMessage()
func (*GetInstanceRequest) ProtoReflect ¶
func (x *GetInstanceRequest) ProtoReflect() protoreflect.Message
func (*GetInstanceRequest) Reset ¶
func (x *GetInstanceRequest) Reset()
func (*GetInstanceRequest) String ¶
func (x *GetInstanceRequest) String() string
type ImportDataMetadata ¶
type ImportDataMetadata struct {
// Data transfer operation metadata.
OperationMetadata *TransferOperationMetadata `protobuf:"bytes,1,opt,name=operation_metadata,json=operationMetadata,proto3" json:"operation_metadata,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. Server-defined resource path for the target of the operation.
Target string `protobuf:"bytes,4,opt,name=target,proto3" json:"target,omitempty"`
// Output only. Name of the verb executed by the operation.
Verb string `protobuf:"bytes,5,opt,name=verb,proto3" json:"verb,omitempty"`
// Output only. Human-readable status of the operation, if any.
StatusMessage string `protobuf:"bytes,6,opt,name=status_message,json=statusMessage,proto3" json:"status_message,omitempty"`
// Output only. Identifies whether the user has requested cancellation
// of the operation. Operations that have successfully been cancelled
// have [Operation.error][google.longrunning.Operation.error] value with a
// [google.rpc.Status.code][google.rpc.Status.code] of 1, corresponding to
// `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"`
// contains filtered or unexported fields
}
Metadata related to the data import operation.
func (*ImportDataMetadata) Descriptor
deprecated
func (*ImportDataMetadata) Descriptor() ([]byte, []int)
Deprecated: Use ImportDataMetadata.ProtoReflect.Descriptor instead.
func (*ImportDataMetadata) GetApiVersion ¶
func (x *ImportDataMetadata) GetApiVersion() string
func (*ImportDataMetadata) GetCreateTime ¶
func (x *ImportDataMetadata) GetCreateTime() *timestamppb.Timestamp
func (*ImportDataMetadata) GetEndTime ¶
func (x *ImportDataMetadata) GetEndTime() *timestamppb.Timestamp
func (*ImportDataMetadata) GetOperationMetadata ¶
func (x *ImportDataMetadata) GetOperationMetadata() *TransferOperationMetadata
func (*ImportDataMetadata) GetRequestedCancellation ¶
func (x *ImportDataMetadata) GetRequestedCancellation() bool
func (*ImportDataMetadata) GetStatusMessage ¶
func (x *ImportDataMetadata) GetStatusMessage() string
func (*ImportDataMetadata) GetTarget ¶
func (x *ImportDataMetadata) GetTarget() string
func (*ImportDataMetadata) GetVerb ¶
func (x *ImportDataMetadata) GetVerb() string
func (*ImportDataMetadata) ProtoMessage ¶
func (*ImportDataMetadata) ProtoMessage()
func (*ImportDataMetadata) ProtoReflect ¶
func (x *ImportDataMetadata) ProtoReflect() protoreflect.Message
func (*ImportDataMetadata) Reset ¶
func (x *ImportDataMetadata) Reset()
func (*ImportDataMetadata) String ¶
func (x *ImportDataMetadata) String() string
type ImportDataRequest ¶
type ImportDataRequest struct {
// The source of the data being imported into the Parallelstore instance.
//
// Types that are valid to be assigned to Source:
//
// *ImportDataRequest_SourceGcsBucket
Source isImportDataRequest_Source `protobuf_oneof:"source"`
// The Parallelstore instance into which to import data.
//
// Types that are valid to be assigned to Destination:
//
// *ImportDataRequest_DestinationParallelstore
Destination isImportDataRequest_Destination `protobuf_oneof:"destination"`
// Required. Name of the resource.
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 so that if you must retry your request, the server will know to
// ignore the request if it has already been completed. The server will
// guarantee that for at least 60 minutes since the first request.
//
// For example, consider a situation where you make an initial request and
// the request times out. If you make the request again with the same request
// ID, the server can check if original operation with the same request ID
// was received, and if so, will ignore the second request. This prevents
// clients from accidentally creating duplicate commitments.
//
// 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"`
// Optional. User-specified service account credentials to be used when
// performing the transfer.
//
// Use one of the following formats:
//
// * `{EMAIL_ADDRESS_OR_UNIQUE_ID}`
// * `projects/{PROJECT_ID_OR_NUMBER}/serviceAccounts/{EMAIL_ADDRESS_OR_UNIQUE_ID}`
// * `projects/-/serviceAccounts/{EMAIL_ADDRESS_OR_UNIQUE_ID}`
//
// If unspecified, the Parallelstore service agent is used:
// `service-<PROJECT_NUMBER>@gcp-sa-parallelstore.iam.gserviceaccount.com`
ServiceAccount string `protobuf:"bytes,5,opt,name=service_account,json=serviceAccount,proto3" json:"service_account,omitempty"`
// Optional. The transfer metadata options for the import data.
MetadataOptions *TransferMetadataOptions `protobuf:"bytes,6,opt,name=metadata_options,json=metadataOptions,proto3" json:"metadata_options,omitempty"`
// contains filtered or unexported fields
}
Import data from Cloud Storage into a Parallelstore instance.
func (*ImportDataRequest) Descriptor
deprecated
func (*ImportDataRequest) Descriptor() ([]byte, []int)
Deprecated: Use ImportDataRequest.ProtoReflect.Descriptor instead.
func (*ImportDataRequest) GetDestination ¶
func (x *ImportDataRequest) GetDestination() isImportDataRequest_Destination
func (*ImportDataRequest) GetDestinationParallelstore ¶
func (x *ImportDataRequest) GetDestinationParallelstore() *DestinationParallelstore
func (*ImportDataRequest) GetMetadataOptions ¶ added in v0.12.0
func (x *ImportDataRequest) GetMetadataOptions() *TransferMetadataOptions
func (*ImportDataRequest) GetName ¶
func (x *ImportDataRequest) GetName() string
func (*ImportDataRequest) GetRequestId ¶
func (x *ImportDataRequest) GetRequestId() string
func (*ImportDataRequest) GetServiceAccount ¶
func (x *ImportDataRequest) GetServiceAccount() string
func (*ImportDataRequest) GetSource ¶
func (x *ImportDataRequest) GetSource() isImportDataRequest_Source
func (*ImportDataRequest) GetSourceGcsBucket ¶
func (x *ImportDataRequest) GetSourceGcsBucket() *SourceGcsBucket
func (*ImportDataRequest) ProtoMessage ¶
func (*ImportDataRequest) ProtoMessage()
func (*ImportDataRequest) ProtoReflect ¶
func (x *ImportDataRequest) ProtoReflect() protoreflect.Message
func (*ImportDataRequest) Reset ¶
func (x *ImportDataRequest) Reset()
func (*ImportDataRequest) String ¶
func (x *ImportDataRequest) String() string
type ImportDataRequest_DestinationParallelstore ¶
type ImportDataRequest_DestinationParallelstore struct {
// Parallelstore destination.
DestinationParallelstore *DestinationParallelstore `protobuf:"bytes,3,opt,name=destination_parallelstore,json=destinationParallelstore,proto3,oneof"`
}
type ImportDataRequest_SourceGcsBucket ¶
type ImportDataRequest_SourceGcsBucket struct {
// The Cloud Storage source bucket and, optionally, path inside the bucket.
SourceGcsBucket *SourceGcsBucket `protobuf:"bytes,2,opt,name=source_gcs_bucket,json=sourceGcsBucket,proto3,oneof"`
}
type ImportDataResponse ¶
type ImportDataResponse struct {
// contains filtered or unexported fields
}
The response to a request to import data to Parallelstore.
func (*ImportDataResponse) Descriptor
deprecated
func (*ImportDataResponse) Descriptor() ([]byte, []int)
Deprecated: Use ImportDataResponse.ProtoReflect.Descriptor instead.
func (*ImportDataResponse) ProtoMessage ¶
func (*ImportDataResponse) ProtoMessage()
func (*ImportDataResponse) ProtoReflect ¶
func (x *ImportDataResponse) ProtoReflect() protoreflect.Message
func (*ImportDataResponse) Reset ¶
func (x *ImportDataResponse) Reset()
func (*ImportDataResponse) String ¶
func (x *ImportDataResponse) String() string
type Instance ¶
type Instance struct {
// Identifier. The resource name of the instance, in the format
// `projects/{project}/locations/{location}/instances/{instance_id}`.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// Optional. The description of the instance. 2048 characters or less.
Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
// Output only. The instance state.
State Instance_State `protobuf:"varint,3,opt,name=state,proto3,enum=google.cloud.parallelstore.v1.Instance_State" json:"state,omitempty"`
// Output only. The time when the instance was created.
CreateTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
// Output only. The time when the instance was updated.
UpdateTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
// Optional. Cloud Labels are a flexible and lightweight mechanism for
// organizing cloud resources into groups that reflect a customer's
// organizational needs and deployment strategies. See
// https://cloud.google.com/resource-manager/docs/labels-overview for details.
Labels map[string]string `` /* 139-byte string literal not displayed */
// Required. Immutable. The instance's storage capacity in Gibibytes (GiB).
// Allowed values are between 12000 and 100000, in multiples of 4000; e.g.,
// 12000, 16000, 20000, ...
CapacityGib int64 `protobuf:"varint,8,opt,name=capacity_gib,json=capacityGib,proto3" json:"capacity_gib,omitempty"`
// Output only. Deprecated: The version of DAOS software running in the
// instance.
//
// Deprecated: Marked as deprecated in google/cloud/parallelstore/v1/parallelstore.proto.
DaosVersion string `protobuf:"bytes,9,opt,name=daos_version,json=daosVersion,proto3" json:"daos_version,omitempty"`
// Output only. A list of IPv4 addresses used for client side configuration.
AccessPoints []string `protobuf:"bytes,10,rep,name=access_points,json=accessPoints,proto3" json:"access_points,omitempty"`
// Optional. Immutable. The name of the Compute Engine
// [VPC network](https://cloud.google.com/vpc/docs/vpc) to which the
// instance is connected.
Network string `protobuf:"bytes,11,opt,name=network,proto3" json:"network,omitempty"`
// Optional. Immutable. The ID of the IP address range being used by the
// instance's VPC network. See [Configure a VPC
// network](https://cloud.google.com/parallelstore/docs/vpc#create_and_configure_the_vpc).
// If no ID is provided, all ranges are considered.
ReservedIpRange string `protobuf:"bytes,12,opt,name=reserved_ip_range,json=reservedIpRange,proto3" json:"reserved_ip_range,omitempty"`
// Output only. Immutable. The ID of the IP address range being used by the
// instance's VPC network. This field is populated by the service and contains
// the value currently used by the service.
EffectiveReservedIpRange string `` /* 138-byte string literal not displayed */
// Optional. Immutable. Stripe level for files. Allowed values are:
//
// - `FILE_STRIPE_LEVEL_MIN`: offers the best performance for small size
// files.
// - `FILE_STRIPE_LEVEL_BALANCED`: balances performance for workloads
// involving a mix of small and large files.
// - `FILE_STRIPE_LEVEL_MAX`: higher throughput performance for larger files.
FileStripeLevel FileStripeLevel `` /* 161-byte string literal not displayed */
// Optional. Immutable. Stripe level for directories. Allowed values are:
//
// - `DIRECTORY_STRIPE_LEVEL_MIN`: recommended when directories contain a
// small number of files.
// - `DIRECTORY_STRIPE_LEVEL_BALANCED`: balances performance for workloads
// involving a mix of small and large directories.
// - `DIRECTORY_STRIPE_LEVEL_MAX`: recommended for directories with a large
// number of files.
DirectoryStripeLevel DirectoryStripeLevel `` /* 181-byte string literal not displayed */
// Optional. Immutable. The deployment type of the instance. Allowed values
// are:
//
// * `SCRATCH`: the instance is a scratch instance.
// * `PERSISTENT`: the instance is a persistent instance.
DeploymentType DeploymentType `` /* 155-byte string literal not displayed */
// contains filtered or unexported fields
}
A Parallelstore instance.
func (*Instance) Descriptor
deprecated
func (*Instance) GetAccessPoints ¶
func (*Instance) GetCapacityGib ¶
func (*Instance) GetCreateTime ¶
func (x *Instance) GetCreateTime() *timestamppb.Timestamp
func (*Instance) GetDaosVersion
deprecated
func (*Instance) GetDeploymentType ¶ added in v0.10.0
func (x *Instance) GetDeploymentType() DeploymentType
func (*Instance) GetDescription ¶
func (*Instance) GetDirectoryStripeLevel ¶
func (x *Instance) GetDirectoryStripeLevel() DirectoryStripeLevel
func (*Instance) GetEffectiveReservedIpRange ¶
func (*Instance) GetFileStripeLevel ¶
func (x *Instance) GetFileStripeLevel() FileStripeLevel
func (*Instance) GetNetwork ¶
func (*Instance) GetReservedIpRange ¶
func (*Instance) GetState ¶
func (x *Instance) GetState() Instance_State
func (*Instance) GetUpdateTime ¶
func (x *Instance) GetUpdateTime() *timestamppb.Timestamp
func (*Instance) ProtoMessage ¶
func (*Instance) ProtoMessage()
func (*Instance) ProtoReflect ¶
func (x *Instance) ProtoReflect() protoreflect.Message
type Instance_State ¶
type Instance_State int32
The possible states of a Parallelstore instance.
const ( // Not set. Instance_STATE_UNSPECIFIED Instance_State = 0 // The instance is being created. Instance_CREATING Instance_State = 1 // The instance is available for use. Instance_ACTIVE Instance_State = 2 // The instance is being deleted. Instance_DELETING Instance_State = 3 // The instance is not usable. Instance_FAILED Instance_State = 4 // The instance is being upgraded. Instance_UPGRADING Instance_State = 5 // The instance is being repaired. This should only be used by instances // using the `PERSISTENT` deployment type. Instance_REPAIRING Instance_State = 6 )
func (Instance_State) Descriptor ¶
func (Instance_State) Descriptor() protoreflect.EnumDescriptor
func (Instance_State) Enum ¶
func (x Instance_State) Enum() *Instance_State
func (Instance_State) EnumDescriptor
deprecated
func (Instance_State) EnumDescriptor() ([]byte, []int)
Deprecated: Use Instance_State.Descriptor instead.
func (Instance_State) Number ¶
func (x Instance_State) Number() protoreflect.EnumNumber
func (Instance_State) String ¶
func (x Instance_State) String() string
func (Instance_State) Type ¶
func (Instance_State) Type() protoreflect.EnumType
type ListInstancesRequest ¶
type ListInstancesRequest struct {
// Required. The project and location for which to retrieve instance
// information, in the format `projects/{project_id}/locations/{location}`.
//
// To retrieve instance information for all locations, use "-" as the value of
// `{location}`.
Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
// Optional. Requested page size. Server may return fewer items than
// requested. If unspecified, the server will pick an appropriate default.
PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
// Optional. A token identifying a page of results the server should return.
PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
// Optional. Filtering results.
Filter string `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
// Optional. Hint for how to order the results.
OrderBy string `protobuf:"bytes,5,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"`
// contains filtered or unexported fields
}
List instances request.
func (*ListInstancesRequest) Descriptor
deprecated
func (*ListInstancesRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListInstancesRequest.ProtoReflect.Descriptor instead.
func (*ListInstancesRequest) GetFilter ¶
func (x *ListInstancesRequest) GetFilter() string
func (*ListInstancesRequest) GetOrderBy ¶
func (x *ListInstancesRequest) GetOrderBy() string
func (*ListInstancesRequest) GetPageSize ¶
func (x *ListInstancesRequest) GetPageSize() int32
func (*ListInstancesRequest) GetPageToken ¶
func (x *ListInstancesRequest) GetPageToken() string
func (*ListInstancesRequest) GetParent ¶
func (x *ListInstancesRequest) GetParent() string
func (*ListInstancesRequest) ProtoMessage ¶
func (*ListInstancesRequest) ProtoMessage()
func (*ListInstancesRequest) ProtoReflect ¶
func (x *ListInstancesRequest) ProtoReflect() protoreflect.Message
func (*ListInstancesRequest) Reset ¶
func (x *ListInstancesRequest) Reset()
func (*ListInstancesRequest) String ¶
func (x *ListInstancesRequest) String() string
type ListInstancesResponse ¶
type ListInstancesResponse struct {
// The list of Parallelstore instances.
Instances []*Instance `protobuf:"bytes,1,rep,name=instances,proto3" json:"instances,omitempty"`
// A token identifying a page of results the server should return.
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
}
Response from [ListInstances][google.cloud.parallelstore.v1.Parallelstore.ListInstances].
func (*ListInstancesResponse) Descriptor
deprecated
func (*ListInstancesResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListInstancesResponse.ProtoReflect.Descriptor instead.
func (*ListInstancesResponse) GetInstances ¶
func (x *ListInstancesResponse) GetInstances() []*Instance
func (*ListInstancesResponse) GetNextPageToken ¶
func (x *ListInstancesResponse) GetNextPageToken() string
func (*ListInstancesResponse) GetUnreachable ¶
func (x *ListInstancesResponse) GetUnreachable() []string
func (*ListInstancesResponse) ProtoMessage ¶
func (*ListInstancesResponse) ProtoMessage()
func (*ListInstancesResponse) ProtoReflect ¶
func (x *ListInstancesResponse) ProtoReflect() protoreflect.Message
func (*ListInstancesResponse) Reset ¶
func (x *ListInstancesResponse) Reset()
func (*ListInstancesResponse) String ¶
func (x *ListInstancesResponse) String() string
type OperationMetadata ¶
type OperationMetadata struct {
// Output only. The time the operation was created.
CreateTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
// Output only. The time the operation finished running.
EndTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
// Output only. Server-defined resource path for the target of the operation.
Target string `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
// Output only. Name of the verb executed by the operation.
Verb string `protobuf:"bytes,4,opt,name=verb,proto3" json:"verb,omitempty"`
// Output only. Human-readable status of the operation, if any.
StatusMessage string `protobuf:"bytes,5,opt,name=status_message,json=statusMessage,proto3" json:"status_message,omitempty"`
// Output only. Identifies whether the user has requested cancellation
// of the operation. Operations that have been cancelled successfully
// have [Operation.error][google.longrunning.Operation.error] value with a
// [google.rpc.Status.code][google.rpc.Status.code] of 1, corresponding to
// `Code.CANCELLED`.
RequestedCancellation bool `protobuf:"varint,6,opt,name=requested_cancellation,json=requestedCancellation,proto3" json:"requested_cancellation,omitempty"`
// Output only. API version used to start the operation.
ApiVersion string `protobuf:"bytes,7,opt,name=api_version,json=apiVersion,proto3" json:"api_version,omitempty"`
// contains filtered or unexported fields
}
Long-running operation metadata.
func (*OperationMetadata) Descriptor
deprecated
func (*OperationMetadata) Descriptor() ([]byte, []int)
Deprecated: Use OperationMetadata.ProtoReflect.Descriptor instead.
func (*OperationMetadata) GetApiVersion ¶
func (x *OperationMetadata) GetApiVersion() string
func (*OperationMetadata) GetCreateTime ¶
func (x *OperationMetadata) GetCreateTime() *timestamppb.Timestamp
func (*OperationMetadata) GetEndTime ¶
func (x *OperationMetadata) GetEndTime() *timestamppb.Timestamp
func (*OperationMetadata) GetRequestedCancellation ¶
func (x *OperationMetadata) GetRequestedCancellation() bool
func (*OperationMetadata) GetStatusMessage ¶
func (x *OperationMetadata) GetStatusMessage() string
func (*OperationMetadata) GetTarget ¶
func (x *OperationMetadata) GetTarget() string
func (*OperationMetadata) GetVerb ¶
func (x *OperationMetadata) GetVerb() string
func (*OperationMetadata) ProtoMessage ¶
func (*OperationMetadata) ProtoMessage()
func (*OperationMetadata) ProtoReflect ¶
func (x *OperationMetadata) ProtoReflect() protoreflect.Message
func (*OperationMetadata) Reset ¶
func (x *OperationMetadata) Reset()
func (*OperationMetadata) String ¶
func (x *OperationMetadata) String() string
type ParallelstoreClient ¶
type ParallelstoreClient interface {
// Lists all instances in a given project and location.
ListInstances(ctx context.Context, in *ListInstancesRequest, opts ...grpc.CallOption) (*ListInstancesResponse, error)
// Gets details of a single instance.
GetInstance(ctx context.Context, in *GetInstanceRequest, opts ...grpc.CallOption) (*Instance, error)
// Creates a Parallelstore instance in a given project and location.
CreateInstance(ctx context.Context, in *CreateInstanceRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
// Updates the parameters of a single instance.
UpdateInstance(ctx context.Context, in *UpdateInstanceRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
// Deletes a single instance.
DeleteInstance(ctx context.Context, in *DeleteInstanceRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
// Copies data from Cloud Storage to Parallelstore.
ImportData(ctx context.Context, in *ImportDataRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
// Copies data from Parallelstore to Cloud Storage.
ExportData(ctx context.Context, in *ExportDataRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
}
ParallelstoreClient is the client API for Parallelstore 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 NewParallelstoreClient ¶
func NewParallelstoreClient(cc grpc.ClientConnInterface) ParallelstoreClient
type ParallelstoreServer ¶
type ParallelstoreServer interface {
// Lists all instances in a given project and location.
ListInstances(context.Context, *ListInstancesRequest) (*ListInstancesResponse, error)
// Gets details of a single instance.
GetInstance(context.Context, *GetInstanceRequest) (*Instance, error)
// Creates a Parallelstore instance in a given project and location.
CreateInstance(context.Context, *CreateInstanceRequest) (*longrunningpb.Operation, error)
// Updates the parameters of a single instance.
UpdateInstance(context.Context, *UpdateInstanceRequest) (*longrunningpb.Operation, error)
// Deletes a single instance.
DeleteInstance(context.Context, *DeleteInstanceRequest) (*longrunningpb.Operation, error)
// Copies data from Cloud Storage to Parallelstore.
ImportData(context.Context, *ImportDataRequest) (*longrunningpb.Operation, error)
// Copies data from Parallelstore to Cloud Storage.
ExportData(context.Context, *ExportDataRequest) (*longrunningpb.Operation, error)
}
ParallelstoreServer is the server API for Parallelstore service. All implementations should embed UnimplementedParallelstoreServer for forward compatibility
type SourceGcsBucket ¶
type SourceGcsBucket struct {
// Required. URI to a Cloud Storage bucket in the format:
// `gs://<bucket_name>/<path_inside_bucket>`. The path inside the bucket is
// optional.
Uri string `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"`
// contains filtered or unexported fields
}
Cloud Storage as the source of a data transfer.
func (*SourceGcsBucket) Descriptor
deprecated
func (*SourceGcsBucket) Descriptor() ([]byte, []int)
Deprecated: Use SourceGcsBucket.ProtoReflect.Descriptor instead.
func (*SourceGcsBucket) GetUri ¶
func (x *SourceGcsBucket) GetUri() string
func (*SourceGcsBucket) ProtoMessage ¶
func (*SourceGcsBucket) ProtoMessage()
func (*SourceGcsBucket) ProtoReflect ¶
func (x *SourceGcsBucket) ProtoReflect() protoreflect.Message
func (*SourceGcsBucket) Reset ¶
func (x *SourceGcsBucket) Reset()
func (*SourceGcsBucket) String ¶
func (x *SourceGcsBucket) String() string
type SourceParallelstore ¶
type SourceParallelstore struct {
// Optional. Root directory path to the Paralellstore filesystem, starting
// with `/`. Defaults to `/` if unset.
Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
// contains filtered or unexported fields
}
Parallelstore as the source of a data transfer.
func (*SourceParallelstore) Descriptor
deprecated
func (*SourceParallelstore) Descriptor() ([]byte, []int)
Deprecated: Use SourceParallelstore.ProtoReflect.Descriptor instead.
func (*SourceParallelstore) GetPath ¶
func (x *SourceParallelstore) GetPath() string
func (*SourceParallelstore) ProtoMessage ¶
func (*SourceParallelstore) ProtoMessage()
func (*SourceParallelstore) ProtoReflect ¶
func (x *SourceParallelstore) ProtoReflect() protoreflect.Message
func (*SourceParallelstore) Reset ¶
func (x *SourceParallelstore) Reset()
func (*SourceParallelstore) String ¶
func (x *SourceParallelstore) String() string
type TransferCounters ¶
type TransferCounters struct {
// Objects found in the data source that are scheduled to be transferred,
// excluding any that are filtered based on object conditions or skipped due
// to sync.
ObjectsFound int64 `protobuf:"varint,1,opt,name=objects_found,json=objectsFound,proto3" json:"objects_found,omitempty"`
// Bytes found in the data source that are scheduled to be transferred,
// excluding any that are filtered based on object conditions or skipped due
// to sync.
BytesFound int64 `protobuf:"varint,2,opt,name=bytes_found,json=bytesFound,proto3" json:"bytes_found,omitempty"`
// Objects in the data source that are not transferred because they already
// exist in the data destination.
ObjectsSkipped int64 `protobuf:"varint,3,opt,name=objects_skipped,json=objectsSkipped,proto3" json:"objects_skipped,omitempty"`
// Bytes in the data source that are not transferred because they already
// exist in the data destination.
BytesSkipped int64 `protobuf:"varint,4,opt,name=bytes_skipped,json=bytesSkipped,proto3" json:"bytes_skipped,omitempty"`
// Objects that are copied to the data destination.
ObjectsCopied int64 `protobuf:"varint,5,opt,name=objects_copied,json=objectsCopied,proto3" json:"objects_copied,omitempty"`
// Bytes that are copied to the data destination.
BytesCopied int64 `protobuf:"varint,6,opt,name=bytes_copied,json=bytesCopied,proto3" json:"bytes_copied,omitempty"`
// Objects that failed to be written to the data destination.
ObjectsFailed int64 `protobuf:"varint,7,opt,name=objects_failed,json=objectsFailed,proto3" json:"objects_failed,omitempty"`
// Bytes that failed to be written to the data destination.
BytesFailed int64 `protobuf:"varint,8,opt,name=bytes_failed,json=bytesFailed,proto3" json:"bytes_failed,omitempty"`
// contains filtered or unexported fields
}
A collection of counters that report the progress of a transfer operation.
func (*TransferCounters) Descriptor
deprecated
func (*TransferCounters) Descriptor() ([]byte, []int)
Deprecated: Use TransferCounters.ProtoReflect.Descriptor instead.
func (*TransferCounters) GetBytesCopied ¶
func (x *TransferCounters) GetBytesCopied() int64
func (*TransferCounters) GetBytesFailed ¶ added in v0.10.0
func (x *TransferCounters) GetBytesFailed() int64
func (*TransferCounters) GetBytesFound ¶
func (x *TransferCounters) GetBytesFound() int64
func (*TransferCounters) GetBytesSkipped ¶
func (x *TransferCounters) GetBytesSkipped() int64
func (*TransferCounters) GetObjectsCopied ¶
func (x *TransferCounters) GetObjectsCopied() int64
func (*TransferCounters) GetObjectsFailed ¶ added in v0.10.0
func (x *TransferCounters) GetObjectsFailed() int64
func (*TransferCounters) GetObjectsFound ¶
func (x *TransferCounters) GetObjectsFound() int64
func (*TransferCounters) GetObjectsSkipped ¶
func (x *TransferCounters) GetObjectsSkipped() int64
func (*TransferCounters) ProtoMessage ¶
func (*TransferCounters) ProtoMessage()
func (*TransferCounters) ProtoReflect ¶
func (x *TransferCounters) ProtoReflect() protoreflect.Message
func (*TransferCounters) Reset ¶
func (x *TransferCounters) Reset()
func (*TransferCounters) String ¶
func (x *TransferCounters) String() string
type TransferErrorLogEntry ¶ added in v0.10.0
type TransferErrorLogEntry struct {
// A URL that refers to the target (a data source, a data sink,
// or an object) with which the error is associated.
Uri string `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"`
// A list of messages that carry the error details.
ErrorDetails []string `protobuf:"bytes,2,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 (*TransferErrorLogEntry) Descriptor
deprecated
added in
v0.10.0
func (*TransferErrorLogEntry) Descriptor() ([]byte, []int)
Deprecated: Use TransferErrorLogEntry.ProtoReflect.Descriptor instead.
func (*TransferErrorLogEntry) GetErrorDetails ¶ added in v0.10.0
func (x *TransferErrorLogEntry) GetErrorDetails() []string
func (*TransferErrorLogEntry) GetUri ¶ added in v0.10.0
func (x *TransferErrorLogEntry) GetUri() string
func (*TransferErrorLogEntry) ProtoMessage ¶ added in v0.10.0
func (*TransferErrorLogEntry) ProtoMessage()
func (*TransferErrorLogEntry) ProtoReflect ¶ added in v0.10.0
func (x *TransferErrorLogEntry) ProtoReflect() protoreflect.Message
func (*TransferErrorLogEntry) Reset ¶ added in v0.10.0
func (x *TransferErrorLogEntry) Reset()
func (*TransferErrorLogEntry) String ¶ added in v0.10.0
func (x *TransferErrorLogEntry) String() string
type TransferErrorSummary ¶ added in v0.10.0
type TransferErrorSummary struct {
// One of the error codes that caused the transfer failure.
ErrorCode code.Code `protobuf:"varint,1,opt,name=error_code,json=errorCode,proto3,enum=google.rpc.Code" json:"error_code,omitempty"`
// Count of this type of error.
ErrorCount int64 `protobuf:"varint,2,opt,name=error_count,json=errorCount,proto3" json:"error_count,omitempty"`
// A list of messages that carry the error details.
ErrorLogEntries []*TransferErrorLogEntry `protobuf:"bytes,4,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 (*TransferErrorSummary) Descriptor
deprecated
added in
v0.10.0
func (*TransferErrorSummary) Descriptor() ([]byte, []int)
Deprecated: Use TransferErrorSummary.ProtoReflect.Descriptor instead.
func (*TransferErrorSummary) GetErrorCode ¶ added in v0.10.0
func (x *TransferErrorSummary) GetErrorCode() code.Code
func (*TransferErrorSummary) GetErrorCount ¶ added in v0.10.0
func (x *TransferErrorSummary) GetErrorCount() int64
func (*TransferErrorSummary) GetErrorLogEntries ¶ added in v0.10.0
func (x *TransferErrorSummary) GetErrorLogEntries() []*TransferErrorLogEntry
func (*TransferErrorSummary) ProtoMessage ¶ added in v0.10.0
func (*TransferErrorSummary) ProtoMessage()
func (*TransferErrorSummary) ProtoReflect ¶ added in v0.10.0
func (x *TransferErrorSummary) ProtoReflect() protoreflect.Message
func (*TransferErrorSummary) Reset ¶ added in v0.10.0
func (x *TransferErrorSummary) Reset()
func (*TransferErrorSummary) String ¶ added in v0.10.0
func (x *TransferErrorSummary) String() string
type TransferMetadataOptions ¶ added in v0.12.0
type TransferMetadataOptions struct {
// Optional. The UID preservation behavior.
Uid TransferMetadataOptions_Uid `protobuf:"varint,1,opt,name=uid,proto3,enum=google.cloud.parallelstore.v1.TransferMetadataOptions_Uid" json:"uid,omitempty"`
// Optional. The GID preservation behavior.
Gid TransferMetadataOptions_Gid `protobuf:"varint,2,opt,name=gid,proto3,enum=google.cloud.parallelstore.v1.TransferMetadataOptions_Gid" json:"gid,omitempty"`
// Optional. The mode preservation behavior.
Mode TransferMetadataOptions_Mode `` /* 126-byte string literal not displayed */
// contains filtered or unexported fields
}
Transfer metadata options for the instance.
func (*TransferMetadataOptions) Descriptor
deprecated
added in
v0.12.0
func (*TransferMetadataOptions) Descriptor() ([]byte, []int)
Deprecated: Use TransferMetadataOptions.ProtoReflect.Descriptor instead.
func (*TransferMetadataOptions) GetGid ¶ added in v0.12.0
func (x *TransferMetadataOptions) GetGid() TransferMetadataOptions_Gid
func (*TransferMetadataOptions) GetMode ¶ added in v0.12.0
func (x *TransferMetadataOptions) GetMode() TransferMetadataOptions_Mode
func (*TransferMetadataOptions) GetUid ¶ added in v0.12.0
func (x *TransferMetadataOptions) GetUid() TransferMetadataOptions_Uid
func (*TransferMetadataOptions) ProtoMessage ¶ added in v0.12.0
func (*TransferMetadataOptions) ProtoMessage()
func (*TransferMetadataOptions) ProtoReflect ¶ added in v0.12.0
func (x *TransferMetadataOptions) ProtoReflect() protoreflect.Message
func (*TransferMetadataOptions) Reset ¶ added in v0.12.0
func (x *TransferMetadataOptions) Reset()
func (*TransferMetadataOptions) String ¶ added in v0.12.0
func (x *TransferMetadataOptions) String() string
type TransferMetadataOptions_Gid ¶ added in v0.12.0
type TransferMetadataOptions_Gid int32
The GID preservation behavior.
const ( // default is GID_NUMBER_PRESERVE. TransferMetadataOptions_GID_UNSPECIFIED TransferMetadataOptions_Gid = 0 // Do not preserve GID during a transfer job. TransferMetadataOptions_GID_SKIP TransferMetadataOptions_Gid = 1 // Preserve GID that is in number format during a transfer job. TransferMetadataOptions_GID_NUMBER_PRESERVE TransferMetadataOptions_Gid = 2 )
func (TransferMetadataOptions_Gid) Descriptor ¶ added in v0.12.0
func (TransferMetadataOptions_Gid) Descriptor() protoreflect.EnumDescriptor
func (TransferMetadataOptions_Gid) Enum ¶ added in v0.12.0
func (x TransferMetadataOptions_Gid) Enum() *TransferMetadataOptions_Gid
func (TransferMetadataOptions_Gid) EnumDescriptor
deprecated
added in
v0.12.0
func (TransferMetadataOptions_Gid) EnumDescriptor() ([]byte, []int)
Deprecated: Use TransferMetadataOptions_Gid.Descriptor instead.
func (TransferMetadataOptions_Gid) Number ¶ added in v0.12.0
func (x TransferMetadataOptions_Gid) Number() protoreflect.EnumNumber
func (TransferMetadataOptions_Gid) String ¶ added in v0.12.0
func (x TransferMetadataOptions_Gid) String() string
func (TransferMetadataOptions_Gid) Type ¶ added in v0.12.0
func (TransferMetadataOptions_Gid) Type() protoreflect.EnumType
type TransferMetadataOptions_Mode ¶ added in v0.12.0
type TransferMetadataOptions_Mode int32
The mode preservation behavior.
const ( // default is MODE_PRESERVE. TransferMetadataOptions_MODE_UNSPECIFIED TransferMetadataOptions_Mode = 0 // Do not preserve mode during a transfer job. TransferMetadataOptions_MODE_SKIP TransferMetadataOptions_Mode = 1 // Preserve mode during a transfer job. TransferMetadataOptions_MODE_PRESERVE TransferMetadataOptions_Mode = 2 )
func (TransferMetadataOptions_Mode) Descriptor ¶ added in v0.12.0
func (TransferMetadataOptions_Mode) Descriptor() protoreflect.EnumDescriptor
func (TransferMetadataOptions_Mode) Enum ¶ added in v0.12.0
func (x TransferMetadataOptions_Mode) Enum() *TransferMetadataOptions_Mode
func (TransferMetadataOptions_Mode) EnumDescriptor
deprecated
added in
v0.12.0
func (TransferMetadataOptions_Mode) EnumDescriptor() ([]byte, []int)
Deprecated: Use TransferMetadataOptions_Mode.Descriptor instead.
func (TransferMetadataOptions_Mode) Number ¶ added in v0.12.0
func (x TransferMetadataOptions_Mode) Number() protoreflect.EnumNumber
func (TransferMetadataOptions_Mode) String ¶ added in v0.12.0
func (x TransferMetadataOptions_Mode) String() string
func (TransferMetadataOptions_Mode) Type ¶ added in v0.12.0
func (TransferMetadataOptions_Mode) Type() protoreflect.EnumType
type TransferMetadataOptions_Uid ¶ added in v0.12.0
type TransferMetadataOptions_Uid int32
The UID preservation behavior.
const ( // default is UID_NUMBER_PRESERVE. TransferMetadataOptions_UID_UNSPECIFIED TransferMetadataOptions_Uid = 0 // Do not preserve UID during a transfer job. TransferMetadataOptions_UID_SKIP TransferMetadataOptions_Uid = 1 // Preserve UID that is in number format during a transfer job. TransferMetadataOptions_UID_NUMBER_PRESERVE TransferMetadataOptions_Uid = 2 )
func (TransferMetadataOptions_Uid) Descriptor ¶ added in v0.12.0
func (TransferMetadataOptions_Uid) Descriptor() protoreflect.EnumDescriptor
func (TransferMetadataOptions_Uid) Enum ¶ added in v0.12.0
func (x TransferMetadataOptions_Uid) Enum() *TransferMetadataOptions_Uid
func (TransferMetadataOptions_Uid) EnumDescriptor
deprecated
added in
v0.12.0
func (TransferMetadataOptions_Uid) EnumDescriptor() ([]byte, []int)
Deprecated: Use TransferMetadataOptions_Uid.Descriptor instead.
func (TransferMetadataOptions_Uid) Number ¶ added in v0.12.0
func (x TransferMetadataOptions_Uid) Number() protoreflect.EnumNumber
func (TransferMetadataOptions_Uid) String ¶ added in v0.12.0
func (x TransferMetadataOptions_Uid) String() string
func (TransferMetadataOptions_Uid) Type ¶ added in v0.12.0
func (TransferMetadataOptions_Uid) Type() protoreflect.EnumType
type TransferOperationMetadata ¶
type TransferOperationMetadata struct {
// The source of transfer operation.
//
// Types that are valid to be assigned to Source:
//
// *TransferOperationMetadata_SourceParallelstore
// *TransferOperationMetadata_SourceGcsBucket
Source isTransferOperationMetadata_Source `protobuf_oneof:"source"`
// The destination of transfer operation.
//
// Types that are valid to be assigned to Destination:
//
// *TransferOperationMetadata_DestinationGcsBucket
// *TransferOperationMetadata_DestinationParallelstore
Destination isTransferOperationMetadata_Destination `protobuf_oneof:"destination"`
// Output only. The progress of the transfer operation.
Counters *TransferCounters `protobuf:"bytes,3,opt,name=counters,proto3" json:"counters,omitempty"`
// Output only. The type of transfer occurring.
TransferType TransferType `` /* 146-byte string literal not displayed */
// Output only. List of files that failed to be transferred. This list will
// have a maximum size of 5 elements.
ErrorSummary []*TransferErrorSummary `protobuf:"bytes,13,rep,name=error_summary,json=errorSummary,proto3" json:"error_summary,omitempty"`
// contains filtered or unexported fields
}
Long-running operation metadata related to a data transfer.
func (*TransferOperationMetadata) Descriptor
deprecated
func (*TransferOperationMetadata) Descriptor() ([]byte, []int)
Deprecated: Use TransferOperationMetadata.ProtoReflect.Descriptor instead.
func (*TransferOperationMetadata) GetCounters ¶
func (x *TransferOperationMetadata) GetCounters() *TransferCounters
func (*TransferOperationMetadata) GetDestination ¶
func (x *TransferOperationMetadata) GetDestination() isTransferOperationMetadata_Destination
func (*TransferOperationMetadata) GetDestinationGcsBucket ¶
func (x *TransferOperationMetadata) GetDestinationGcsBucket() *DestinationGcsBucket
func (*TransferOperationMetadata) GetDestinationParallelstore ¶
func (x *TransferOperationMetadata) GetDestinationParallelstore() *DestinationParallelstore
func (*TransferOperationMetadata) GetErrorSummary ¶ added in v0.10.0
func (x *TransferOperationMetadata) GetErrorSummary() []*TransferErrorSummary
func (*TransferOperationMetadata) GetSource ¶
func (x *TransferOperationMetadata) GetSource() isTransferOperationMetadata_Source
func (*TransferOperationMetadata) GetSourceGcsBucket ¶
func (x *TransferOperationMetadata) GetSourceGcsBucket() *SourceGcsBucket
func (*TransferOperationMetadata) GetSourceParallelstore ¶
func (x *TransferOperationMetadata) GetSourceParallelstore() *SourceParallelstore
func (*TransferOperationMetadata) GetTransferType ¶
func (x *TransferOperationMetadata) GetTransferType() TransferType
func (*TransferOperationMetadata) ProtoMessage ¶
func (*TransferOperationMetadata) ProtoMessage()
func (*TransferOperationMetadata) ProtoReflect ¶
func (x *TransferOperationMetadata) ProtoReflect() protoreflect.Message
func (*TransferOperationMetadata) Reset ¶
func (x *TransferOperationMetadata) Reset()
func (*TransferOperationMetadata) String ¶
func (x *TransferOperationMetadata) String() string
type TransferOperationMetadata_DestinationGcsBucket ¶
type TransferOperationMetadata_DestinationGcsBucket struct {
// Output only. Cloud Storage destination.
DestinationGcsBucket *DestinationGcsBucket `protobuf:"bytes,9,opt,name=destination_gcs_bucket,json=destinationGcsBucket,proto3,oneof"`
}
type TransferOperationMetadata_DestinationParallelstore ¶
type TransferOperationMetadata_DestinationParallelstore struct {
// Output only. Parallelstore destination.
DestinationParallelstore *DestinationParallelstore `protobuf:"bytes,10,opt,name=destination_parallelstore,json=destinationParallelstore,proto3,oneof"`
}
type TransferOperationMetadata_SourceGcsBucket ¶
type TransferOperationMetadata_SourceGcsBucket struct {
// Output only. Cloud Storage source.
SourceGcsBucket *SourceGcsBucket `protobuf:"bytes,8,opt,name=source_gcs_bucket,json=sourceGcsBucket,proto3,oneof"`
}
type TransferOperationMetadata_SourceParallelstore ¶
type TransferOperationMetadata_SourceParallelstore struct {
// Output only. Parallelstore source.
SourceParallelstore *SourceParallelstore `protobuf:"bytes,7,opt,name=source_parallelstore,json=sourceParallelstore,proto3,oneof"`
}
type TransferType ¶
type TransferType int32
Type of transfer that occurred.
const ( // Zero is an illegal value. TransferType_TRANSFER_TYPE_UNSPECIFIED TransferType = 0 // Imports to Parallelstore. TransferType_IMPORT TransferType = 1 // Exports from Parallelstore. TransferType_EXPORT TransferType = 2 )
func (TransferType) Descriptor ¶
func (TransferType) Descriptor() protoreflect.EnumDescriptor
func (TransferType) Enum ¶
func (x TransferType) Enum() *TransferType
func (TransferType) EnumDescriptor
deprecated
func (TransferType) EnumDescriptor() ([]byte, []int)
Deprecated: Use TransferType.Descriptor instead.
func (TransferType) Number ¶
func (x TransferType) Number() protoreflect.EnumNumber
func (TransferType) String ¶
func (x TransferType) String() string
func (TransferType) Type ¶
func (TransferType) Type() protoreflect.EnumType
type UnimplementedParallelstoreServer ¶
type UnimplementedParallelstoreServer struct {
}
UnimplementedParallelstoreServer should be embedded to have forward compatible implementations.
func (UnimplementedParallelstoreServer) CreateInstance ¶
func (UnimplementedParallelstoreServer) CreateInstance(context.Context, *CreateInstanceRequest) (*longrunningpb.Operation, error)
func (UnimplementedParallelstoreServer) DeleteInstance ¶
func (UnimplementedParallelstoreServer) DeleteInstance(context.Context, *DeleteInstanceRequest) (*longrunningpb.Operation, error)
func (UnimplementedParallelstoreServer) ExportData ¶
func (UnimplementedParallelstoreServer) ExportData(context.Context, *ExportDataRequest) (*longrunningpb.Operation, error)
func (UnimplementedParallelstoreServer) GetInstance ¶
func (UnimplementedParallelstoreServer) GetInstance(context.Context, *GetInstanceRequest) (*Instance, error)
func (UnimplementedParallelstoreServer) ImportData ¶
func (UnimplementedParallelstoreServer) ImportData(context.Context, *ImportDataRequest) (*longrunningpb.Operation, error)
func (UnimplementedParallelstoreServer) ListInstances ¶
func (UnimplementedParallelstoreServer) ListInstances(context.Context, *ListInstancesRequest) (*ListInstancesResponse, error)
func (UnimplementedParallelstoreServer) UpdateInstance ¶
func (UnimplementedParallelstoreServer) UpdateInstance(context.Context, *UpdateInstanceRequest) (*longrunningpb.Operation, error)
type UnsafeParallelstoreServer ¶ added in v0.11.4
type UnsafeParallelstoreServer interface {
// contains filtered or unexported methods
}
UnsafeParallelstoreServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ParallelstoreServer will result in compilation errors.
type UpdateInstanceRequest ¶
type UpdateInstanceRequest struct {
// Required. Mask of fields to update. Field mask is used to specify the
// fields to be overwritten in the Instance resource by the update. At least
// one path must be supplied in this field. The fields specified in the
// update_mask are relative to the resource, not the full request.
UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,1,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
// Required. The instance to update.
Instance *Instance `protobuf:"bytes,2,opt,name=instance,proto3" json:"instance,omitempty"`
// Optional. An optional request ID to identify requests. Specify a unique
// request ID so that if you must retry your request, the server will know to
// ignore the request if it has already been completed. The server will
// guarantee that for at least 60 minutes since the first request.
//
// For example, consider a situation where you make an initial request and
// the request times out. If you make the request again with the same request
// ID, the server can check if original operation with the same request ID
// was received, and if so, will ignore the second request. This prevents
// clients from accidentally creating duplicate commitments.
//
// 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
}
Update an instance.
func (*UpdateInstanceRequest) Descriptor
deprecated
func (*UpdateInstanceRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateInstanceRequest.ProtoReflect.Descriptor instead.
func (*UpdateInstanceRequest) GetInstance ¶
func (x *UpdateInstanceRequest) GetInstance() *Instance
func (*UpdateInstanceRequest) GetRequestId ¶
func (x *UpdateInstanceRequest) GetRequestId() string
func (*UpdateInstanceRequest) GetUpdateMask ¶
func (x *UpdateInstanceRequest) GetUpdateMask() *fieldmaskpb.FieldMask
func (*UpdateInstanceRequest) ProtoMessage ¶
func (*UpdateInstanceRequest) ProtoMessage()
func (*UpdateInstanceRequest) ProtoReflect ¶
func (x *UpdateInstanceRequest) ProtoReflect() protoreflect.Message
func (*UpdateInstanceRequest) Reset ¶
func (x *UpdateInstanceRequest) Reset()
func (*UpdateInstanceRequest) String ¶
func (x *UpdateInstanceRequest) String() string