Package cloud.google.com/go/parallelstore/apiv1beta/parallelstorepb (v0.9.2)

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) Enum

func (x DeploymentType) Enum() *DeploymentType

func (DeploymentType) EnumDescriptor

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

Deprecated: Use DeploymentType.Descriptor instead.

func (DeploymentType) Number

func (DeploymentType) String

func (x DeploymentType) String() string

func (DeploymentType) Type

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) Enum

func (DirectoryStripeLevel) EnumDescriptor

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

Deprecated: Use DirectoryStripeLevel.Descriptor instead.

func (DirectoryStripeLevel) Number

func (DirectoryStripeLevel) String

func (x DirectoryStripeLevel) String() string

func (DirectoryStripeLevel) 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

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) Enum

func (x FileStripeLevel) Enum() *FileStripeLevel

func (FileStripeLevel) EnumDescriptor

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

Deprecated: Use FileStripeLevel.Descriptor instead.

func (FileStripeLevel) Number

func (FileStripeLevel) String

func (x FileStripeLevel) String() string

func (FileStripeLevel) 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

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

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

Deprecated: Use Instance.ProtoReflect.Descriptor instead.

func (*Instance) GetAccessPoints

func (x *Instance) GetAccessPoints() []string

func (*Instance) GetCapacityGib

func (x *Instance) GetCapacityGib() int64

func (*Instance) GetCreateTime

func (x *Instance) GetCreateTime() *timestamppb.Timestamp

func (*Instance) GetDaosVersion

func (x *Instance) GetDaosVersion() string

func (*Instance) GetDeploymentType

func (x *Instance) GetDeploymentType() DeploymentType

func (*Instance) GetDescription

func (x *Instance) GetDescription() string

func (*Instance) GetDirectoryStripeLevel

func (x *Instance) GetDirectoryStripeLevel() DirectoryStripeLevel

func (*Instance) GetEffectiveReservedIpRange

func (x *Instance) GetEffectiveReservedIpRange() string

func (*Instance) GetFileStripeLevel

func (x *Instance) GetFileStripeLevel() FileStripeLevel

func (*Instance) GetLabels

func (x *Instance) GetLabels() map[string]string

func (*Instance) GetName

func (x *Instance) GetName() string

func (*Instance) GetNetwork

func (x *Instance) GetNetwork() string

func (*Instance) GetReservedIpRange

func (x *Instance) GetReservedIpRange() string

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

func (x *Instance) String() 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) 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 (Instance_State) String

func (x Instance_State) String() string

func (Instance_State) 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

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 (*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) Enum

func (x TransferType) Enum() *TransferType

func (TransferType) EnumDescriptor

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

Deprecated: Use TransferType.Descriptor instead.

func (TransferType) Number

func (TransferType) String

func (x TransferType) String() string

func (TransferType) Type

UnimplementedParallelstoreServer

type UnimplementedParallelstoreServer struct {
}

UnimplementedParallelstoreServer can be embedded to have forward compatible implementations.

func (*UnimplementedParallelstoreServer) CreateInstance

func (*UnimplementedParallelstoreServer) DeleteInstance

func (*UnimplementedParallelstoreServer) ExportData

func (*UnimplementedParallelstoreServer) GetInstance

func (*UnimplementedParallelstoreServer) ImportData

func (*UnimplementedParallelstoreServer) ListInstances

func (*UnimplementedParallelstoreServer) UpdateInstance

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