Variables
TransferType_name, TransferType_value
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.
FileStripeLevel_name, FileStripeLevel_value
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.
DirectoryStripeLevel_name, DirectoryStripeLevel_value
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.
DeploymentType_name, DeploymentType_value
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.
Instance_State_name, Instance_State_value
var (
Instance_State_name = map[int32]string{
0: "STATE_UNSPECIFIED",
1: "CREATING",
2: "ACTIVE",
3: "DELETING",
4: "FAILED",
5: "UPGRADING",
}
Instance_State_value = map[string]int32{
"STATE_UNSPECIFIED": 0,
"CREATING": 1,
"ACTIVE": 2,
"DELETING": 3,
"FAILED": 4,
"UPGRADING": 5,
}
)
Enum value maps for Instance_State.
File_google_cloud_parallelstore_v1beta_parallelstore_proto
var File_google_cloud_parallelstore_v1beta_parallelstore_proto protoreflect.FileDescriptor
Functions
func RegisterParallelstoreServer
func RegisterParallelstoreServer(s *grpc.Server, srv ParallelstoreServer)
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 t
// he 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
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
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 t
// he 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
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
DeploymentType
type DeploymentType int32
Represents the deployment type for the instance.
DeploymentType_DEPLOYMENT_TYPE_UNSPECIFIED, DeploymentType_SCRATCH, DeploymentType_PERSISTENT
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
func (DeploymentType) Descriptor() protoreflect.EnumDescriptor
func (DeploymentType) Enum
func (x DeploymentType) Enum() *DeploymentType
func (DeploymentType) EnumDescriptor
func (DeploymentType) EnumDescriptor() ([]byte, []int)
Deprecated: Use DeploymentType.Descriptor instead.
func (DeploymentType) Number
func (x DeploymentType) Number() protoreflect.EnumNumber
func (DeploymentType) String
func (x DeploymentType) String() string
func (DeploymentType) Type
func (DeploymentType) Type() protoreflect.EnumType
DestinationGcsBucket
type DestinationGcsBucket struct {
// Required. URI to a Cloud Storage bucket in the format:
// `gs://
Cloud Storage as the destination of a data transfer.
func (*DestinationGcsBucket) Descriptor
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
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
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
DirectoryStripeLevel
type DirectoryStripeLevel int32
Represents the striping options for directories.
DirectoryStripeLevel_DIRECTORY_STRIPE_LEVEL_UNSPECIFIED, DirectoryStripeLevel_DIRECTORY_STRIPE_LEVEL_MIN, DirectoryStripeLevel_DIRECTORY_STRIPE_LEVEL_BALANCED, DirectoryStripeLevel_DIRECTORY_STRIPE_LEVEL_MAX
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
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
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
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
ExportDataRequest
type ExportDataRequest struct {
// The Parallelstore instance to export from.
//
// Types that are assignable to Source:
//
// *ExportDataRequest_SourceParallelstore
Source isExportDataRequest_Source `protobuf_oneof:"source"`
// The Cloud Storage bucket to export to.
//
// Types that are assignable 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 t
// he 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-
Export data from Parallelstore to Cloud Storage.
func (*ExportDataRequest) Descriptor
func (*ExportDataRequest) Descriptor() ([]byte, []int)
Deprecated: Use ExportDataRequest.ProtoReflect.Descriptor instead.
func (*ExportDataRequest) GetDestination
func (m *ExportDataRequest) GetDestination() isExportDataRequest_Destination
func (*ExportDataRequest) GetDestinationGcsBucket
func (x *ExportDataRequest) GetDestinationGcsBucket() *DestinationGcsBucket
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 (m *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
ExportDataRequest_DestinationGcsBucket
type ExportDataRequest_DestinationGcsBucket struct {
// Cloud Storage destination.
DestinationGcsBucket *DestinationGcsBucket `protobuf:"bytes,3,opt,name=destination_gcs_bucket,json=destinationGcsBucket,proto3,oneof"`
}
ExportDataRequest_SourceParallelstore
type ExportDataRequest_SourceParallelstore struct {
// Parallelstore source.
SourceParallelstore *SourceParallelstore `protobuf:"bytes,2,opt,name=source_parallelstore,json=sourceParallelstore,proto3,oneof"`
}
ExportDataResponse
type ExportDataResponse struct {
// contains filtered or unexported fields
}
The response to a request to export data from Parallelstore.
func (*ExportDataResponse) Descriptor
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
FileStripeLevel
type FileStripeLevel int32
Represents the striping options for files.
FileStripeLevel_FILE_STRIPE_LEVEL_UNSPECIFIED, FileStripeLevel_FILE_STRIPE_LEVEL_MIN, FileStripeLevel_FILE_STRIPE_LEVEL_BALANCED, FileStripeLevel_FILE_STRIPE_LEVEL_MAX
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
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
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
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
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
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
ImportDataRequest
type ImportDataRequest struct {
// The source of the data being imported into the Parallelstore instance.
//
// Types that are assignable to Source:
//
// *ImportDataRequest_SourceGcsBucket
Source isImportDataRequest_Source `protobuf_oneof:"source"`
// The Parallelstore instance into which to import data.
//
// Types that are assignable 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 t
// he 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-
Import data from Cloud Storage into a Parallelstore instance.
func (*ImportDataRequest) Descriptor
func (*ImportDataRequest) Descriptor() ([]byte, []int)
Deprecated: Use ImportDataRequest.ProtoReflect.Descriptor instead.
func (*ImportDataRequest) GetDestination
func (m *ImportDataRequest) GetDestination() isImportDataRequest_Destination
func (*ImportDataRequest) GetDestinationParallelstore
func (x *ImportDataRequest) GetDestinationParallelstore() *DestinationParallelstore
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 (m *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
ImportDataRequest_DestinationParallelstore
type ImportDataRequest_DestinationParallelstore struct {
// Parallelstore destination.
DestinationParallelstore *DestinationParallelstore `protobuf:"bytes,3,opt,name=destination_parallelstore,json=destinationParallelstore,proto3,oneof"`
}
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"`
}
ImportDataResponse
type ImportDataResponse struct {
// contains filtered or unexported fields
}
The response to a request to import data to Parallelstore.
func (*ImportDataResponse) Descriptor
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
Instance
type Instance struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
State Instance_State `protobuf:"varint,3,opt,name=state,proto3,enum=google.cloud.parallelstore.v1beta.Instance_State" json:"state,omitempty"`
CreateTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
UpdateTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
Labels map[string]string "" /* 153 byte string literal not displayed */
CapacityGib int64 `protobuf:"varint,8,opt,name=capacity_gib,json=capacityGib,proto3" json:"capacity_gib,omitempty"`
DaosVersion string `protobuf:"bytes,9,opt,name=daos_version,json=daosVersion,proto3" json:"daos_version,omitempty"`
AccessPoints []string `protobuf:"bytes,10,rep,name=access_points,json=accessPoints,proto3" json:"access_points,omitempty"`
Network string `protobuf:"bytes,11,opt,name=network,proto3" json:"network,omitempty"`
ReservedIpRange string `protobuf:"bytes,12,opt,name=reserved_ip_range,json=reservedIpRange,proto3" json:"reserved_ip_range,omitempty"`
EffectiveReservedIpRange string "" /* 138 byte string literal not displayed */
FileStripeLevel FileStripeLevel "" /* 165 byte string literal not displayed */
DirectoryStripeLevel DirectoryStripeLevel "" /* 185 byte string literal not displayed */
DeploymentType DeploymentType "" /* 159 byte string literal not displayed */
}
A Parallelstore instance.
func (*Instance) Descriptor
Deprecated: Use Instance.ProtoReflect.Descriptor instead.
func (*Instance) GetAccessPoints
func (*Instance) GetCapacityGib
func (*Instance) GetCreateTime
func (x *Instance) GetCreateTime() *timestamppb.Timestamp
func (*Instance) GetDaosVersion
func (*Instance) GetDeploymentType
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) GetLabels
func (*Instance) GetName
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
func (*Instance) Reset
func (x *Instance) Reset()
func (*Instance) String
Instance_State
type Instance_State int32
The possible states of a Parallelstore instance.
Instance_STATE_UNSPECIFIED, Instance_CREATING, Instance_ACTIVE, Instance_DELETING, Instance_FAILED, Instance_UPGRADING
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
)
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
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
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
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
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.v1beta.Parallelstore.ListInstances].
func (*ListInstancesResponse) Descriptor
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
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
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
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://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewParallelstoreClient
func NewParallelstoreClient(cc grpc.ClientConnInterface) ParallelstoreClient
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.
SourceGcsBucket
type SourceGcsBucket struct {
// Required. URI to a Cloud Storage bucket in the format:
// `gs://
Cloud Storage as the source of a data transfer.
func (*SourceGcsBucket) Descriptor
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
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
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
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"`
// contains filtered or unexported fields
}
A collection of counters that report the progress of a transfer operation.
func (*TransferCounters) Descriptor
func (*TransferCounters) Descriptor() ([]byte, []int)
Deprecated: Use TransferCounters.ProtoReflect.Descriptor instead.
func (*TransferCounters) GetBytesCopied
func (x *TransferCounters) GetBytesCopied() 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) 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
TransferOperationMetadata
type TransferOperationMetadata struct {
Source isTransferOperationMetadata_Source `protobuf_oneof:"source"`
Destination isTransferOperationMetadata_Destination `protobuf_oneof:"destination"`
Counters *TransferCounters `protobuf:"bytes,3,opt,name=counters,proto3" json:"counters,omitempty"`
TransferType TransferType "" /* 150 byte string literal not displayed */
}
Long-running operation metadata related to a data transfer.
func (*TransferOperationMetadata) Descriptor
func (*TransferOperationMetadata) Descriptor() ([]byte, []int)
Deprecated: Use TransferOperationMetadata.ProtoReflect.Descriptor instead.
func (*TransferOperationMetadata) GetCounters
func (x *TransferOperationMetadata) GetCounters() *TransferCounters
func (*TransferOperationMetadata) GetDestination
func (m *TransferOperationMetadata) GetDestination() isTransferOperationMetadata_Destination
func (*TransferOperationMetadata) GetDestinationGcsBucket
func (x *TransferOperationMetadata) GetDestinationGcsBucket() *DestinationGcsBucket
func (*TransferOperationMetadata) GetDestinationParallelstore
func (x *TransferOperationMetadata) GetDestinationParallelstore() *DestinationParallelstore
func (*TransferOperationMetadata) GetSource
func (m *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
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"`
}
TransferOperationMetadata_DestinationParallelstore
type TransferOperationMetadata_DestinationParallelstore struct {
// Output only. Parallelstore destination.
DestinationParallelstore *DestinationParallelstore `protobuf:"bytes,10,opt,name=destination_parallelstore,json=destinationParallelstore,proto3,oneof"`
}
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"`
}
TransferOperationMetadata_SourceParallelstore
type TransferOperationMetadata_SourceParallelstore struct {
// Output only. Parallelstore source.
SourceParallelstore *SourceParallelstore `protobuf:"bytes,7,opt,name=source_parallelstore,json=sourceParallelstore,proto3,oneof"`
}
TransferType
type TransferType int32
Type of transfer that occurred.
TransferType_TRANSFER_TYPE_UNSPECIFIED, TransferType_IMPORT, TransferType_EXPORT
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
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
UnimplementedParallelstoreServer
type UnimplementedParallelstoreServer struct {
}
UnimplementedParallelstoreServer can 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)
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 t
// he 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
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