parallelstorepb

package
v0.9.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 12, 2024 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
var File_google_cloud_parallelstore_v1beta_parallelstore_proto protoreflect.FileDescriptor

Functions

func RegisterParallelstoreServer 

func RegisterParallelstoreServer(s *grpc.Server, srv ParallelstoreServer)

Types

type CreateInstanceRequest 

type CreateInstanceRequest struct {

	// Required. The instance's project and location, in the format
	// `projects/{project}/locations/{location}`.
	// Locations map to Google Cloud zones; for example, `us-west1-b`.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Required. The name of the Parallelstore instance.
	//
	// * Must contain only lowercase letters, numbers, and hyphens.
	// * Must start with a letter.
	// * Must be between 1-63 characters.
	// * Must end with a number or a letter.
	// * Must be unique within the customer project / location
	InstanceId string `protobuf:"bytes,2,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	// Required. The instance to create.
	Instance *Instance `protobuf:"bytes,3,opt,name=instance,proto3" json:"instance,omitempty"`
	// Optional. An optional request ID to identify requests. Specify a unique
	// request ID so that if you must retry your request, the server will know to
	// ignore the request if it has already been completed. The server will
	// guarantee that for at least 60 minutes since the first request.
	//
	// For example, consider a situation where you make an initial request and 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 deprecated 

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

Deprecated: Use CreateInstanceRequest.ProtoReflect.Descriptor instead.

func (*CreateInstanceRequest) GetInstance 

func (x *CreateInstanceRequest) GetInstance() *Instance

func (*CreateInstanceRequest) GetInstanceId 

func (x *CreateInstanceRequest) GetInstanceId() string

func (*CreateInstanceRequest) GetParent 

func (x *CreateInstanceRequest) GetParent() string

func (*CreateInstanceRequest) GetRequestId 

func (x *CreateInstanceRequest) GetRequestId() string

func (*CreateInstanceRequest) ProtoMessage 

func (*CreateInstanceRequest) ProtoMessage()

func (*CreateInstanceRequest) ProtoReflect 

func (x *CreateInstanceRequest) ProtoReflect() protoreflect.Message

func (*CreateInstanceRequest) Reset 

func (x *CreateInstanceRequest) Reset()

func (*CreateInstanceRequest) String 

func (x *CreateInstanceRequest) String() string

type DeleteInstanceRequest 

type DeleteInstanceRequest struct {

	// Required. Name of the resource
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Optional. An optional request ID to identify requests. Specify a unique
	// request ID so that if you must retry your request, the server will know to
	// ignore the request if it has already been completed. The server will
	// guarantee that for at least 60 minutes after the first request.
	//
	// For example, consider a situation where you make an initial request and 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 deprecated 

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

Deprecated: Use DeleteInstanceRequest.ProtoReflect.Descriptor instead.

func (*DeleteInstanceRequest) GetName 

func (x *DeleteInstanceRequest) GetName() string

func (*DeleteInstanceRequest) GetRequestId 

func (x *DeleteInstanceRequest) GetRequestId() string

func (*DeleteInstanceRequest) ProtoMessage 

func (*DeleteInstanceRequest) ProtoMessage()

func (*DeleteInstanceRequest) ProtoReflect 

func (x *DeleteInstanceRequest) ProtoReflect() protoreflect.Message

func (*DeleteInstanceRequest) Reset 

func (x *DeleteInstanceRequest) Reset()

func (*DeleteInstanceRequest) String 

func (x *DeleteInstanceRequest) String() string

type DeploymentType added in v0.9.0 

type DeploymentType int32

Represents the deployment type for the instance. 

const (
	// Default Deployment Type
	// It is equivalent to SCRATCH
	DeploymentType_DEPLOYMENT_TYPE_UNSPECIFIED DeploymentType = 0
	// Scratch
	DeploymentType_SCRATCH DeploymentType = 1
	// Persistent
	DeploymentType_PERSISTENT DeploymentType = 2
)

func (DeploymentType) Descriptor added in v0.9.0 

func (DeploymentType) Descriptor() protoreflect.EnumDescriptor

func (DeploymentType) Enum added in v0.9.0 

func (x DeploymentType) Enum() *DeploymentType

func (DeploymentType) EnumDescriptor deprecated added in v0.9.0 

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

Deprecated: Use DeploymentType.Descriptor instead.

func (DeploymentType) Number added in v0.9.0 

func (x DeploymentType) Number() protoreflect.EnumNumber

func (DeploymentType) String added in v0.9.0 

func (x DeploymentType) String() string

func (DeploymentType) Type added in v0.9.0 

func (DeploymentType) Type() protoreflect.EnumType

type DestinationGcsBucket added in v0.3.0 

type DestinationGcsBucket struct {

	// Required. URI to a Cloud Storage bucket in the format:
	// `gs://<bucket_name>/<path_inside_bucket>`. The path inside the bucket is
	// optional.
	Uri string `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"`
	// contains filtered or unexported fields
}

Cloud Storage as the destination of a data transfer.

func (*DestinationGcsBucket) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use DestinationGcsBucket.ProtoReflect.Descriptor instead.

func (*DestinationGcsBucket) GetUri added in v0.3.0 

func (x *DestinationGcsBucket) GetUri() string

func (*DestinationGcsBucket) ProtoMessage added in v0.3.0 

func (*DestinationGcsBucket) ProtoMessage()

func (*DestinationGcsBucket) ProtoReflect added in v0.3.0 

func (x *DestinationGcsBucket) ProtoReflect() protoreflect.Message

func (*DestinationGcsBucket) Reset added in v0.3.0 

func (x *DestinationGcsBucket) Reset()

func (*DestinationGcsBucket) String added in v0.3.0 

func (x *DestinationGcsBucket) String() string

type DestinationParallelstore added in v0.3.0 

type DestinationParallelstore struct {

	// Optional. Root directory path to the Paralellstore filesystem, starting
	// with `/`. Defaults to `/` if unset.
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

Parallelstore as the destination of a data transfer.

func (*DestinationParallelstore) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use DestinationParallelstore.ProtoReflect.Descriptor instead.

func (*DestinationParallelstore) GetPath added in v0.3.0 

func (x *DestinationParallelstore) GetPath() string

func (*DestinationParallelstore) ProtoMessage added in v0.3.0 

func (*DestinationParallelstore) ProtoMessage()

func (*DestinationParallelstore) ProtoReflect added in v0.3.0 

func (x *DestinationParallelstore) ProtoReflect() protoreflect.Message

func (*DestinationParallelstore) Reset added in v0.3.0 

func (x *DestinationParallelstore) Reset()

func (*DestinationParallelstore) String added in v0.3.0 

func (x *DestinationParallelstore) String() string

type DirectoryStripeLevel added in v0.5.0 

type DirectoryStripeLevel int32

Represents the striping options for directories. 

const (
	// If not set, DirectoryStripeLevel will default to DIRECTORY_STRIPE_LEVEL_MAX
	DirectoryStripeLevel_DIRECTORY_STRIPE_LEVEL_UNSPECIFIED DirectoryStripeLevel = 0
	// Minimum directory striping
	DirectoryStripeLevel_DIRECTORY_STRIPE_LEVEL_MIN DirectoryStripeLevel = 1
	// Medium directory striping
	DirectoryStripeLevel_DIRECTORY_STRIPE_LEVEL_BALANCED DirectoryStripeLevel = 2
	// Maximum directory striping
	DirectoryStripeLevel_DIRECTORY_STRIPE_LEVEL_MAX DirectoryStripeLevel = 3
)

func (DirectoryStripeLevel) Descriptor added in v0.5.0 

func (DirectoryStripeLevel) Descriptor() protoreflect.EnumDescriptor

func (DirectoryStripeLevel) Enum added in v0.5.0 

func (x DirectoryStripeLevel) Enum() *DirectoryStripeLevel

func (DirectoryStripeLevel) EnumDescriptor deprecated added in v0.5.0 

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

Deprecated: Use DirectoryStripeLevel.Descriptor instead.

func (DirectoryStripeLevel) Number added in v0.5.0 

func (x DirectoryStripeLevel) Number() protoreflect.EnumNumber

func (DirectoryStripeLevel) String added in v0.5.0 

func (x DirectoryStripeLevel) String() string

func (DirectoryStripeLevel) Type added in v0.5.0 

func (DirectoryStripeLevel) Type() protoreflect.EnumType

type ExportDataMetadata added in v0.2.0 

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][] value with a
	// [google.rpc.Status.code][google.rpc.Status.code] of 1, corresponding to
	// `Code.CANCELLED`.
	RequestedCancellation bool `protobuf:"varint,7,opt,name=requested_cancellation,json=requestedCancellation,proto3" json:"requested_cancellation,omitempty"`
	// Output only. API version used to start the operation.
	ApiVersion string `protobuf:"bytes,8,opt,name=api_version,json=apiVersion,proto3" json:"api_version,omitempty"`
	// contains filtered or unexported fields
}

Metadata related to the data export operation.

func (*ExportDataMetadata) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use ExportDataMetadata.ProtoReflect.Descriptor instead.

func (*ExportDataMetadata) GetApiVersion added in v0.3.0 

func (x *ExportDataMetadata) GetApiVersion() string

func (*ExportDataMetadata) GetCreateTime added in v0.3.0 

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

func (*ExportDataMetadata) GetEndTime added in v0.3.0 

func (x *ExportDataMetadata) GetEndTime() *timestamppb.Timestamp

func (*ExportDataMetadata) GetOperationMetadata added in v0.2.0 

func (x *ExportDataMetadata) GetOperationMetadata() *TransferOperationMetadata

func (*ExportDataMetadata) GetRequestedCancellation added in v0.3.0 

func (x *ExportDataMetadata) GetRequestedCancellation() bool

func (*ExportDataMetadata) GetStatusMessage added in v0.3.0 

func (x *ExportDataMetadata) GetStatusMessage() string

func (*ExportDataMetadata) GetTarget added in v0.3.0 

func (x *ExportDataMetadata) GetTarget() string

func (*ExportDataMetadata) GetVerb added in v0.3.0 

func (x *ExportDataMetadata) GetVerb() string

func (*ExportDataMetadata) ProtoMessage added in v0.2.0 

func (*ExportDataMetadata) ProtoMessage()

func (*ExportDataMetadata) ProtoReflect added in v0.2.0 

func (x *ExportDataMetadata) ProtoReflect() protoreflect.Message

func (*ExportDataMetadata) Reset added in v0.2.0 

func (x *ExportDataMetadata) Reset()

func (*ExportDataMetadata) String added in v0.2.0 

func (x *ExportDataMetadata) String() string

type ExportDataRequest added in v0.2.0 

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-<PROJECT_NUMBER>@gcp-sa-parallelstore.iam.gserviceaccount.com`
	ServiceAccount string `protobuf:"bytes,5,opt,name=service_account,json=serviceAccount,proto3" json:"service_account,omitempty"`
	// contains filtered or unexported fields
}

Export data from Parallelstore to Cloud Storage.

func (*ExportDataRequest) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use ExportDataRequest.ProtoReflect.Descriptor instead.

func (*ExportDataRequest) GetDestination added in v0.2.0 

func (m *ExportDataRequest) GetDestination() isExportDataRequest_Destination

func (*ExportDataRequest) GetDestinationGcsBucket added in v0.3.0 

func (x *ExportDataRequest) GetDestinationGcsBucket() *DestinationGcsBucket

func (*ExportDataRequest) GetName added in v0.2.0 

func (x *ExportDataRequest) GetName() string

func (*ExportDataRequest) GetRequestId added in v0.2.0 

func (x *ExportDataRequest) GetRequestId() string

func (*ExportDataRequest) GetServiceAccount added in v0.4.0 

func (x *ExportDataRequest) GetServiceAccount() string

func (*ExportDataRequest) GetSource added in v0.2.0 

func (m *ExportDataRequest) GetSource() isExportDataRequest_Source

func (*ExportDataRequest) GetSourceParallelstore added in v0.3.0 

func (x *ExportDataRequest) GetSourceParallelstore() *SourceParallelstore

func (*ExportDataRequest) ProtoMessage added in v0.2.0 

func (*ExportDataRequest) ProtoMessage()

func (*ExportDataRequest) ProtoReflect added in v0.2.0 

func (x *ExportDataRequest) ProtoReflect() protoreflect.Message

func (*ExportDataRequest) Reset added in v0.2.0 

func (x *ExportDataRequest) Reset()

func (*ExportDataRequest) String added in v0.2.0 

func (x *ExportDataRequest) String() string

type ExportDataRequest_DestinationGcsBucket added in v0.3.0 

type ExportDataRequest_DestinationGcsBucket struct {
	// Cloud Storage destination.
	DestinationGcsBucket *DestinationGcsBucket `protobuf:"bytes,3,opt,name=destination_gcs_bucket,json=destinationGcsBucket,proto3,oneof"`
}

type ExportDataRequest_SourceParallelstore added in v0.3.0 

type ExportDataRequest_SourceParallelstore struct {
	// Parallelstore source.
	SourceParallelstore *SourceParallelstore `protobuf:"bytes,2,opt,name=source_parallelstore,json=sourceParallelstore,proto3,oneof"`
}

type ExportDataResponse added in v0.2.0 

type ExportDataResponse struct {
	// contains filtered or unexported fields
}

The response to a request to export data from Parallelstore.

func (*ExportDataResponse) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use ExportDataResponse.ProtoReflect.Descriptor instead.

func (*ExportDataResponse) ProtoMessage added in v0.2.0 

func (*ExportDataResponse) ProtoMessage()

func (*ExportDataResponse) ProtoReflect added in v0.2.0 

func (x *ExportDataResponse) ProtoReflect() protoreflect.Message

func (*ExportDataResponse) Reset added in v0.2.0 

func (x *ExportDataResponse) Reset()

func (*ExportDataResponse) String added in v0.2.0 

func (x *ExportDataResponse) String() string

type FileStripeLevel added in v0.5.0 

type FileStripeLevel int32

Represents the striping options for files. 

const (
	// If not set, FileStripeLevel will default to FILE_STRIPE_LEVEL_BALANCED
	FileStripeLevel_FILE_STRIPE_LEVEL_UNSPECIFIED FileStripeLevel = 0
	// Minimum file striping
	FileStripeLevel_FILE_STRIPE_LEVEL_MIN FileStripeLevel = 1
	// Medium file striping
	FileStripeLevel_FILE_STRIPE_LEVEL_BALANCED FileStripeLevel = 2
	// Maximum file striping
	FileStripeLevel_FILE_STRIPE_LEVEL_MAX FileStripeLevel = 3
)

func (FileStripeLevel) Descriptor added in v0.5.0 

func (FileStripeLevel) Descriptor() protoreflect.EnumDescriptor

func (FileStripeLevel) Enum added in v0.5.0 

func (x FileStripeLevel) Enum() *FileStripeLevel

func (FileStripeLevel) EnumDescriptor deprecated added in v0.5.0 

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

Deprecated: Use FileStripeLevel.Descriptor instead.

func (FileStripeLevel) Number added in v0.5.0 

func (x FileStripeLevel) Number() protoreflect.EnumNumber

func (FileStripeLevel) String added in v0.5.0 

func (x FileStripeLevel) String() string

func (FileStripeLevel) Type added in v0.5.0 

func (FileStripeLevel) Type() protoreflect.EnumType

type GetInstanceRequest 

type GetInstanceRequest struct {

	// Required. The instance resource name, in the format
	// `projects/{project_id}/locations/{location}/instances/{instance_id}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Get an instance's details.

func (*GetInstanceRequest) Descriptor deprecated 

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

Deprecated: Use GetInstanceRequest.ProtoReflect.Descriptor instead.

func (*GetInstanceRequest) GetName 

func (x *GetInstanceRequest) GetName() string

func (*GetInstanceRequest) ProtoMessage 

func (*GetInstanceRequest) ProtoMessage()

func (*GetInstanceRequest) ProtoReflect 

func (x *GetInstanceRequest) ProtoReflect() protoreflect.Message

func (*GetInstanceRequest) Reset 

func (x *GetInstanceRequest) Reset()

func (*GetInstanceRequest) String 

func (x *GetInstanceRequest) String() string

type ImportDataMetadata added in v0.2.0 

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][] value with a
	// [google.rpc.Status.code][google.rpc.Status.code] of 1, corresponding to
	// `Code.CANCELLED`.
	RequestedCancellation bool `protobuf:"varint,7,opt,name=requested_cancellation,json=requestedCancellation,proto3" json:"requested_cancellation,omitempty"`
	// Output only. API version used to start the operation.
	ApiVersion string `protobuf:"bytes,8,opt,name=api_version,json=apiVersion,proto3" json:"api_version,omitempty"`
	// contains filtered or unexported fields
}

Metadata related to the data import operation.

func (*ImportDataMetadata) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use ImportDataMetadata.ProtoReflect.Descriptor instead.

func (*ImportDataMetadata) GetApiVersion added in v0.3.0 

func (x *ImportDataMetadata) GetApiVersion() string

func (*ImportDataMetadata) GetCreateTime added in v0.3.0 

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

func (*ImportDataMetadata) GetEndTime added in v0.3.0 

func (x *ImportDataMetadata) GetEndTime() *timestamppb.Timestamp

func (*ImportDataMetadata) GetOperationMetadata added in v0.2.0 

func (x *ImportDataMetadata) GetOperationMetadata() *TransferOperationMetadata

func (*ImportDataMetadata) GetRequestedCancellation added in v0.3.0 

func (x *ImportDataMetadata) GetRequestedCancellation() bool

func (*ImportDataMetadata) GetStatusMessage added in v0.3.0 

func (x *ImportDataMetadata) GetStatusMessage() string

func (*ImportDataMetadata) GetTarget added in v0.3.0 

func (x *ImportDataMetadata) GetTarget() string

func (*ImportDataMetadata) GetVerb added in v0.3.0 

func (x *ImportDataMetadata) GetVerb() string

func (*ImportDataMetadata) ProtoMessage added in v0.2.0 

func (*ImportDataMetadata) ProtoMessage()

func (*ImportDataMetadata) ProtoReflect added in v0.2.0 

func (x *ImportDataMetadata) ProtoReflect() protoreflect.Message

func (*ImportDataMetadata) Reset added in v0.2.0 

func (x *ImportDataMetadata) Reset()

func (*ImportDataMetadata) String added in v0.2.0 

func (x *ImportDataMetadata) String() string

type ImportDataRequest added in v0.2.0 

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-<PROJECT_NUMBER>@gcp-sa-parallelstore.iam.gserviceaccount.com`
	ServiceAccount string `protobuf:"bytes,5,opt,name=service_account,json=serviceAccount,proto3" json:"service_account,omitempty"`
	// contains filtered or unexported fields
}

Import data from Cloud Storage into a Parallelstore instance.

func (*ImportDataRequest) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use ImportDataRequest.ProtoReflect.Descriptor instead.

func (*ImportDataRequest) GetDestination added in v0.2.0 

func (m *ImportDataRequest) GetDestination() isImportDataRequest_Destination

func (*ImportDataRequest) GetDestinationParallelstore added in v0.3.0 

func (x *ImportDataRequest) GetDestinationParallelstore() *DestinationParallelstore

func (*ImportDataRequest) GetName added in v0.2.0 

func (x *ImportDataRequest) GetName() string

func (*ImportDataRequest) GetRequestId added in v0.2.0 

func (x *ImportDataRequest) GetRequestId() string

func (*ImportDataRequest) GetServiceAccount added in v0.4.0 

func (x *ImportDataRequest) GetServiceAccount() string

func (*ImportDataRequest) GetSource added in v0.2.0 

func (m *ImportDataRequest) GetSource() isImportDataRequest_Source

func (*ImportDataRequest) GetSourceGcsBucket added in v0.3.0 

func (x *ImportDataRequest) GetSourceGcsBucket() *SourceGcsBucket

func (*ImportDataRequest) ProtoMessage added in v0.2.0 

func (*ImportDataRequest) ProtoMessage()

func (*ImportDataRequest) ProtoReflect added in v0.2.0 

func (x *ImportDataRequest) ProtoReflect() protoreflect.Message

func (*ImportDataRequest) Reset added in v0.2.0 

func (x *ImportDataRequest) Reset()

func (*ImportDataRequest) String added in v0.2.0 

func (x *ImportDataRequest) String() string

type ImportDataRequest_DestinationParallelstore added in v0.3.0 

type ImportDataRequest_DestinationParallelstore struct {
	// Parallelstore destination.
	DestinationParallelstore *DestinationParallelstore `protobuf:"bytes,3,opt,name=destination_parallelstore,json=destinationParallelstore,proto3,oneof"`
}

type ImportDataRequest_SourceGcsBucket added in v0.3.0 

type ImportDataRequest_SourceGcsBucket struct {
	// The Cloud Storage source bucket and, optionally, path inside the bucket.
	SourceGcsBucket *SourceGcsBucket `protobuf:"bytes,2,opt,name=source_gcs_bucket,json=sourceGcsBucket,proto3,oneof"`
}

type ImportDataResponse added in v0.2.0 

type ImportDataResponse struct {
	// contains filtered or unexported fields
}

The response to a request to import data to Parallelstore.

func (*ImportDataResponse) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use ImportDataResponse.ProtoReflect.Descriptor instead.

func (*ImportDataResponse) ProtoMessage added in v0.2.0 

func (*ImportDataResponse) ProtoMessage()

func (*ImportDataResponse) ProtoReflect added in v0.2.0 

func (x *ImportDataResponse) ProtoReflect() protoreflect.Message

func (*ImportDataResponse) Reset added in v0.2.0 

func (x *ImportDataResponse) Reset()

func (*ImportDataResponse) String added in v0.2.0 

func (x *ImportDataResponse) String() string

type Instance 

type Instance struct {

	// Identifier. The resource name of the instance, in the format
	// `projects/{project}/locations/{location}/instances/{instance_id}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Optional. The description of the instance. 2048 characters or less.
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// Output only. The instance state.
	State Instance_State `protobuf:"varint,3,opt,name=state,proto3,enum=google.cloud.parallelstore.v1beta.Instance_State" json:"state,omitempty"`
	// Output only. The time when the instance was created.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Output only. The time when the instance was updated.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// Optional. Cloud Labels are a flexible and lightweight mechanism for
	// organizing cloud resources into groups that reflect a customer's
	// organizational needs and deployment strategies. See
	// https://cloud.google.com/resource-manager/docs/labels-overview for details.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// Required. Immutable. The instance's storage capacity in Gibibytes (GiB).
	// Allowed values are between 12000 and 100000, in multiples of 4000; e.g.,
	// 12000, 16000, 20000, ...
	CapacityGib int64 `protobuf:"varint,8,opt,name=capacity_gib,json=capacityGib,proto3" json:"capacity_gib,omitempty"`
	// Output only. The version of DAOS software running in the instance.
	DaosVersion string `protobuf:"bytes,9,opt,name=daos_version,json=daosVersion,proto3" json:"daos_version,omitempty"`
	// Output only. A list of IPv4 addresses used for client side configuration.
	AccessPoints []string `protobuf:"bytes,10,rep,name=access_points,json=accessPoints,proto3" json:"access_points,omitempty"`
	// Optional. Immutable. The name of the Compute Engine
	// [VPC network](https://cloud.google.com/vpc/docs/vpc) to which the
	// instance is connected.
	Network string `protobuf:"bytes,11,opt,name=network,proto3" json:"network,omitempty"`
	// Optional. Immutable. The ID of the IP address range being used by the
	// instance's VPC network. See [Configure a VPC
	// network](https://cloud.google.com/parallelstore/docs/vpc#create_and_configure_the_vpc).
	// If no ID is provided, all ranges are considered.
	ReservedIpRange string `protobuf:"bytes,12,opt,name=reserved_ip_range,json=reservedIpRange,proto3" json:"reserved_ip_range,omitempty"`
	// Output only. Immutable. The ID of the IP address range being used by the
	// instance's VPC network. This field is populated by the service and contains
	// the value currently used by the service.
	EffectiveReservedIpRange string `` /* 138-byte string literal not displayed */
	// Optional. Stripe level for files. Allowed values are:
	//
	//   - `FILE_STRIPE_LEVEL_MIN`: offers the best performance for small size
	//     files.
	//   - `FILE_STRIPE_LEVEL_BALANCED`: balances performance for workloads
	//     involving a mix of small and large files.
	//   - `FILE_STRIPE_LEVEL_MAX`: higher throughput performance for larger files.
	FileStripeLevel FileStripeLevel `` /* 165-byte string literal not displayed */
	// Optional. Stripe level for directories. Allowed values are:
	//
	//   - `DIRECTORY_STRIPE_LEVEL_MIN`: recommended when directories contain a
	//     small number of files.
	//   - `DIRECTORY_STRIPE_LEVEL_BALANCED`: balances performance for workloads
	//     involving a mix of small and large directories.
	//   - `DIRECTORY_STRIPE_LEVEL_MAX`: recommended for directories with a large
	//     number of files.
	DirectoryStripeLevel DirectoryStripeLevel `` /* 185-byte string literal not displayed */
	// Optional. The deployment type of the instance. Allowed values are:
	//
	// * `SCRATCH`: the instance is a scratch instance.
	// * `PERSISTENT`: the instance is a persistent instance.
	DeploymentType DeploymentType `` /* 159-byte string literal not displayed */
	// contains filtered or unexported fields
}

A Parallelstore instance.

func (*Instance) Descriptor deprecated 

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 added in v0.9.0 

func (x *Instance) GetDeploymentType() DeploymentType

func (*Instance) GetDescription 

func (x *Instance) GetDescription() string

func (*Instance) GetDirectoryStripeLevel added in v0.5.0 

func (x *Instance) GetDirectoryStripeLevel() DirectoryStripeLevel

func (*Instance) GetEffectiveReservedIpRange added in v0.2.0 

func (x *Instance) GetEffectiveReservedIpRange() string

func (*Instance) GetFileStripeLevel added in v0.5.0 

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

type Instance_State 

type Instance_State int32

The possible states of a Parallelstore instance. 

const (
	// Not set.
	Instance_STATE_UNSPECIFIED Instance_State = 0
	// The instance is being created.
	Instance_CREATING Instance_State = 1
	// The instance is available for use.
	Instance_ACTIVE Instance_State = 2
	// The instance is being deleted.
	Instance_DELETING Instance_State = 3
	// The instance is not usable.
	Instance_FAILED Instance_State = 4
	// The instance is being upgraded.
	Instance_UPGRADING Instance_State = 5
)

func (Instance_State) Descriptor 

func (Instance_State) Descriptor() protoreflect.EnumDescriptor

func (Instance_State) Enum 

func (x Instance_State) Enum() *Instance_State

func (Instance_State) EnumDescriptor deprecated 

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

Deprecated: Use Instance_State.Descriptor instead.

func (Instance_State) Number 

func (x Instance_State) Number() protoreflect.EnumNumber

func (Instance_State) String 

func (x Instance_State) String() string

func (Instance_State) Type 

func (Instance_State) Type() protoreflect.EnumType

type ListInstancesRequest 

type ListInstancesRequest struct {

	// Required. The project and location for which to retrieve instance
	// information, in the format `projects/{project_id}/locations/{location}`.
	//
	// To retrieve instance information for all locations, use "-" as the value of
	// `{location}`.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Optional. Requested page size. Server may return fewer items than
	// requested. If unspecified, the server will pick an appropriate default.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Optional. A token identifying a page of results the server should return.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// Optional. Filtering results.
	Filter string `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
	// Optional. Hint for how to order the results.
	OrderBy string `protobuf:"bytes,5,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"`
	// contains filtered or unexported fields
}

List instances request.

func (*ListInstancesRequest) Descriptor deprecated 

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

Deprecated: Use ListInstancesRequest.ProtoReflect.Descriptor instead.

func (*ListInstancesRequest) GetFilter 

func (x *ListInstancesRequest) GetFilter() string

func (*ListInstancesRequest) GetOrderBy 

func (x *ListInstancesRequest) GetOrderBy() string

func (*ListInstancesRequest) GetPageSize 

func (x *ListInstancesRequest) GetPageSize() int32

func (*ListInstancesRequest) GetPageToken 

func (x *ListInstancesRequest) GetPageToken() string

func (*ListInstancesRequest) GetParent 

func (x *ListInstancesRequest) GetParent() string

func (*ListInstancesRequest) ProtoMessage 

func (*ListInstancesRequest) ProtoMessage()

func (*ListInstancesRequest) ProtoReflect 

func (x *ListInstancesRequest) ProtoReflect() protoreflect.Message

func (*ListInstancesRequest) Reset 

func (x *ListInstancesRequest) Reset()

func (*ListInstancesRequest) String 

func (x *ListInstancesRequest) String() string

type ListInstancesResponse 

type ListInstancesResponse struct {

	// The list of Parallelstore instances.
	Instances []*Instance `protobuf:"bytes,1,rep,name=instances,proto3" json:"instances,omitempty"`
	// A token identifying a page of results the server should return.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// Locations that could not be reached.
	Unreachable []string `protobuf:"bytes,3,rep,name=unreachable,proto3" json:"unreachable,omitempty"`
	// contains filtered or unexported fields
}

Response from [ListInstances][google.cloud.parallelstore.v1beta.Parallelstore.ListInstances].

func (*ListInstancesResponse) Descriptor deprecated 

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

Deprecated: Use ListInstancesResponse.ProtoReflect.Descriptor instead.

func (*ListInstancesResponse) GetInstances 

func (x *ListInstancesResponse) GetInstances() []*Instance

func (*ListInstancesResponse) GetNextPageToken 

func (x *ListInstancesResponse) GetNextPageToken() string

func (*ListInstancesResponse) GetUnreachable 

func (x *ListInstancesResponse) GetUnreachable() []string

func (*ListInstancesResponse) ProtoMessage 

func (*ListInstancesResponse) ProtoMessage()

func (*ListInstancesResponse) ProtoReflect 

func (x *ListInstancesResponse) ProtoReflect() protoreflect.Message

func (*ListInstancesResponse) Reset 

func (x *ListInstancesResponse) Reset()

func (*ListInstancesResponse) String 

func (x *ListInstancesResponse) String() string

type OperationMetadata 

type OperationMetadata struct {

	// Output only. The time the operation was created.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Output only. The time the operation finished running.
	EndTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// Output only. Server-defined resource path for the target of the operation.
	Target string `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
	// Output only. Name of the verb executed by the operation.
	Verb string `protobuf:"bytes,4,opt,name=verb,proto3" json:"verb,omitempty"`
	// Output only. Human-readable status of the operation, if any.
	StatusMessage string `protobuf:"bytes,5,opt,name=status_message,json=statusMessage,proto3" json:"status_message,omitempty"`
	// Output only. Identifies whether the user has requested cancellation
	// of the operation. Operations that have been cancelled successfully
	// have [Operation.error][] value with a
	// [google.rpc.Status.code][google.rpc.Status.code] of 1, corresponding to
	// `Code.CANCELLED`.
	RequestedCancellation bool `protobuf:"varint,6,opt,name=requested_cancellation,json=requestedCancellation,proto3" json:"requested_cancellation,omitempty"`
	// Output only. API version used to start the operation.
	ApiVersion string `protobuf:"bytes,7,opt,name=api_version,json=apiVersion,proto3" json:"api_version,omitempty"`
	// contains filtered or unexported fields
}

Long-running operation metadata.

func (*OperationMetadata) Descriptor deprecated 

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

Deprecated: Use OperationMetadata.ProtoReflect.Descriptor instead.

func (*OperationMetadata) GetApiVersion 

func (x *OperationMetadata) GetApiVersion() string

func (*OperationMetadata) GetCreateTime 

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

func (*OperationMetadata) GetEndTime 

func (x *OperationMetadata) GetEndTime() *timestamppb.Timestamp

func (*OperationMetadata) GetRequestedCancellation 

func (x *OperationMetadata) GetRequestedCancellation() bool

func (*OperationMetadata) GetStatusMessage 

func (x *OperationMetadata) GetStatusMessage() string

func (*OperationMetadata) GetTarget 

func (x *OperationMetadata) GetTarget() string

func (*OperationMetadata) GetVerb 

func (x *OperationMetadata) GetVerb() string

func (*OperationMetadata) ProtoMessage 

func (*OperationMetadata) ProtoMessage()

func (*OperationMetadata) ProtoReflect 

func (x *OperationMetadata) ProtoReflect() protoreflect.Message

func (*OperationMetadata) Reset 

func (x *OperationMetadata) Reset()

func (*OperationMetadata) String 

func (x *OperationMetadata) String() string

type ParallelstoreClient 

type ParallelstoreClient interface {
	// Lists all instances in a given project and location.
	ListInstances(ctx context.Context, in *ListInstancesRequest, opts ...grpc.CallOption) (*ListInstancesResponse, error)
	// Gets details of a single instance.
	GetInstance(ctx context.Context, in *GetInstanceRequest, opts ...grpc.CallOption) (*Instance, error)
	// Creates a Parallelstore instance in a given project and location.
	CreateInstance(ctx context.Context, in *CreateInstanceRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Updates the parameters of a single instance.
	UpdateInstance(ctx context.Context, in *UpdateInstanceRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Deletes a single instance.
	DeleteInstance(ctx context.Context, in *DeleteInstanceRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Copies data from Cloud Storage to Parallelstore.
	ImportData(ctx context.Context, in *ImportDataRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Copies data from Parallelstore to Cloud Storage.
	ExportData(ctx context.Context, in *ExportDataRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
}

ParallelstoreClient is the client API for Parallelstore service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewParallelstoreClient 

func NewParallelstoreClient(cc grpc.ClientConnInterface) ParallelstoreClient

type ParallelstoreServer 

type ParallelstoreServer interface {
	// Lists all instances in a given project and location.
	ListInstances(context.Context, *ListInstancesRequest) (*ListInstancesResponse, error)
	// Gets details of a single instance.
	GetInstance(context.Context, *GetInstanceRequest) (*Instance, error)
	// Creates a Parallelstore instance in a given project and location.
	CreateInstance(context.Context, *CreateInstanceRequest) (*longrunningpb.Operation, error)
	// Updates the parameters of a single instance.
	UpdateInstance(context.Context, *UpdateInstanceRequest) (*longrunningpb.Operation, error)
	// Deletes a single instance.
	DeleteInstance(context.Context, *DeleteInstanceRequest) (*longrunningpb.Operation, error)
	// Copies data from Cloud Storage to Parallelstore.
	ImportData(context.Context, *ImportDataRequest) (*longrunningpb.Operation, error)
	// Copies data from Parallelstore to Cloud Storage.
	ExportData(context.Context, *ExportDataRequest) (*longrunningpb.Operation, error)
}

ParallelstoreServer is the server API for Parallelstore service.

type SourceGcsBucket added in v0.3.0 

type SourceGcsBucket struct {

	// Required. URI to a Cloud Storage bucket in the format:
	// `gs://<bucket_name>/<path_inside_bucket>`. The path inside the bucket is
	// optional.
	Uri string `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"`
	// contains filtered or unexported fields
}

Cloud Storage as the source of a data transfer.

func (*SourceGcsBucket) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use SourceGcsBucket.ProtoReflect.Descriptor instead.

func (*SourceGcsBucket) GetUri added in v0.3.0 

func (x *SourceGcsBucket) GetUri() string

func (*SourceGcsBucket) ProtoMessage added in v0.3.0 

func (*SourceGcsBucket) ProtoMessage()

func (*SourceGcsBucket) ProtoReflect added in v0.3.0 

func (x *SourceGcsBucket) ProtoReflect() protoreflect.Message

func (*SourceGcsBucket) Reset added in v0.3.0 

func (x *SourceGcsBucket) Reset()

func (*SourceGcsBucket) String added in v0.3.0 

func (x *SourceGcsBucket) String() string

type SourceParallelstore added in v0.3.0 

type SourceParallelstore struct {

	// Optional. Root directory path to the Paralellstore filesystem, starting
	// with `/`. Defaults to `/` if unset.
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

Parallelstore as the source of a data transfer.

func (*SourceParallelstore) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use SourceParallelstore.ProtoReflect.Descriptor instead.

func (*SourceParallelstore) GetPath added in v0.3.0 

func (x *SourceParallelstore) GetPath() string

func (*SourceParallelstore) ProtoMessage added in v0.3.0 

func (*SourceParallelstore) ProtoMessage()

func (*SourceParallelstore) ProtoReflect added in v0.3.0 

func (x *SourceParallelstore) ProtoReflect() protoreflect.Message

func (*SourceParallelstore) Reset added in v0.3.0 

func (x *SourceParallelstore) Reset()

func (*SourceParallelstore) String added in v0.3.0 

func (x *SourceParallelstore) String() string

type TransferCounters added in v0.2.0 

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 deprecated added in v0.2.0 

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

Deprecated: Use TransferCounters.ProtoReflect.Descriptor instead.

func (*TransferCounters) GetBytesCopied added in v0.2.0 

func (x *TransferCounters) GetBytesCopied() int64

func (*TransferCounters) GetBytesFound added in v0.2.0 

func (x *TransferCounters) GetBytesFound() int64

func (*TransferCounters) GetBytesSkipped added in v0.2.0 

func (x *TransferCounters) GetBytesSkipped() int64

func (*TransferCounters) GetObjectsCopied added in v0.2.0 

func (x *TransferCounters) GetObjectsCopied() int64

func (*TransferCounters) GetObjectsFound added in v0.2.0 

func (x *TransferCounters) GetObjectsFound() int64

func (*TransferCounters) GetObjectsSkipped added in v0.2.0 

func (x *TransferCounters) GetObjectsSkipped() int64

func (*TransferCounters) ProtoMessage added in v0.2.0 

func (*TransferCounters) ProtoMessage()

func (*TransferCounters) ProtoReflect added in v0.2.0 

func (x *TransferCounters) ProtoReflect() protoreflect.Message

func (*TransferCounters) Reset added in v0.2.0 

func (x *TransferCounters) Reset()

func (*TransferCounters) String added in v0.2.0 

func (x *TransferCounters) String() string

type TransferOperationMetadata added in v0.2.0 

type TransferOperationMetadata struct {

	// The source of transfer operation.
	//
	// Types that are assignable to Source:
	//
	//	*TransferOperationMetadata_SourceParallelstore
	//	*TransferOperationMetadata_SourceGcsBucket
	Source isTransferOperationMetadata_Source `protobuf_oneof:"source"`
	// The destination of transfer operation.
	//
	// Types that are assignable to Destination:
	//
	//	*TransferOperationMetadata_DestinationGcsBucket
	//	*TransferOperationMetadata_DestinationParallelstore
	Destination isTransferOperationMetadata_Destination `protobuf_oneof:"destination"`
	// Output only. The progress of the transfer operation.
	Counters *TransferCounters `protobuf:"bytes,3,opt,name=counters,proto3" json:"counters,omitempty"`
	// Output only. The type of transfer occurring.
	TransferType TransferType `` /* 150-byte string literal not displayed */
	// contains filtered or unexported fields
}

Long-running operation metadata related to a data transfer.

func (*TransferOperationMetadata) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use TransferOperationMetadata.ProtoReflect.Descriptor instead.

func (*TransferOperationMetadata) GetCounters added in v0.2.0 

func (x *TransferOperationMetadata) GetCounters() *TransferCounters

func (*TransferOperationMetadata) GetDestination added in v0.2.0 

func (m *TransferOperationMetadata) GetDestination() isTransferOperationMetadata_Destination

func (*TransferOperationMetadata) GetDestinationGcsBucket added in v0.3.0 

func (x *TransferOperationMetadata) GetDestinationGcsBucket() *DestinationGcsBucket

func (*TransferOperationMetadata) GetDestinationParallelstore added in v0.3.0 

func (x *TransferOperationMetadata) GetDestinationParallelstore() *DestinationParallelstore

func (*TransferOperationMetadata) GetSource added in v0.2.0 

func (m *TransferOperationMetadata) GetSource() isTransferOperationMetadata_Source

func (*TransferOperationMetadata) GetSourceGcsBucket added in v0.3.0 

func (x *TransferOperationMetadata) GetSourceGcsBucket() *SourceGcsBucket

func (*TransferOperationMetadata) GetSourceParallelstore added in v0.3.0 

func (x *TransferOperationMetadata) GetSourceParallelstore() *SourceParallelstore

func (*TransferOperationMetadata) GetTransferType added in v0.2.0 

func (x *TransferOperationMetadata) GetTransferType() TransferType

func (*TransferOperationMetadata) ProtoMessage added in v0.2.0 

func (*TransferOperationMetadata) ProtoMessage()

func (*TransferOperationMetadata) ProtoReflect added in v0.2.0 

func (x *TransferOperationMetadata) ProtoReflect() protoreflect.Message

func (*TransferOperationMetadata) Reset added in v0.2.0 

func (x *TransferOperationMetadata) Reset()

func (*TransferOperationMetadata) String added in v0.2.0 

func (x *TransferOperationMetadata) String() string

type TransferOperationMetadata_DestinationGcsBucket added in v0.3.0 

type TransferOperationMetadata_DestinationGcsBucket struct {
	// Output only. Cloud Storage destination.
	DestinationGcsBucket *DestinationGcsBucket `protobuf:"bytes,9,opt,name=destination_gcs_bucket,json=destinationGcsBucket,proto3,oneof"`
}

type TransferOperationMetadata_DestinationParallelstore added in v0.3.0 

type TransferOperationMetadata_DestinationParallelstore struct {
	// Output only. Parallelstore destination.
	DestinationParallelstore *DestinationParallelstore `protobuf:"bytes,10,opt,name=destination_parallelstore,json=destinationParallelstore,proto3,oneof"`
}

type TransferOperationMetadata_SourceGcsBucket added in v0.3.0 

type TransferOperationMetadata_SourceGcsBucket struct {
	// Output only. Cloud Storage source.
	SourceGcsBucket *SourceGcsBucket `protobuf:"bytes,8,opt,name=source_gcs_bucket,json=sourceGcsBucket,proto3,oneof"`
}

type TransferOperationMetadata_SourceParallelstore added in v0.3.0 

type TransferOperationMetadata_SourceParallelstore struct {
	// Output only. Parallelstore source.
	SourceParallelstore *SourceParallelstore `protobuf:"bytes,7,opt,name=source_parallelstore,json=sourceParallelstore,proto3,oneof"`
}

type TransferType added in v0.2.0 

type TransferType int32

Type of transfer that occurred. 

const (
	// Zero is an illegal value.
	TransferType_TRANSFER_TYPE_UNSPECIFIED TransferType = 0
	// Imports to Parallelstore.
	TransferType_IMPORT TransferType = 1
	// Exports from Parallelstore.
	TransferType_EXPORT TransferType = 2
)

func (TransferType) Descriptor added in v0.2.0 

func (TransferType) Descriptor() protoreflect.EnumDescriptor

func (TransferType) Enum added in v0.2.0 

func (x TransferType) Enum() *TransferType

func (TransferType) EnumDescriptor deprecated added in v0.2.0 

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

Deprecated: Use TransferType.Descriptor instead.

func (TransferType) Number added in v0.2.0 

func (x TransferType) Number() protoreflect.EnumNumber

func (TransferType) String added in v0.2.0 

func (x TransferType) String() string

func (TransferType) Type added in v0.2.0 

func (TransferType) Type() protoreflect.EnumType

type 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 added in v0.2.0 

func (*UnimplementedParallelstoreServer) ExportData(context.Context, *ExportDataRequest) (*longrunningpb.Operation, error)

func (*UnimplementedParallelstoreServer) GetInstance 

func (*UnimplementedParallelstoreServer) GetInstance(context.Context, *GetInstanceRequest) (*Instance, error)

func (*UnimplementedParallelstoreServer) ImportData added in v0.2.0 

func (*UnimplementedParallelstoreServer) ImportData(context.Context, *ImportDataRequest) (*longrunningpb.Operation, error)

func (*UnimplementedParallelstoreServer) ListInstances 

func (*UnimplementedParallelstoreServer) ListInstances(context.Context, *ListInstancesRequest) (*ListInstancesResponse, error)

func (*UnimplementedParallelstoreServer) UpdateInstance 

func (*UnimplementedParallelstoreServer) UpdateInstance(context.Context, *UpdateInstanceRequest) (*longrunningpb.Operation, error)

type 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 deprecated 

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

Deprecated: Use UpdateInstanceRequest.ProtoReflect.Descriptor instead.

func (*UpdateInstanceRequest) GetInstance 

func (x *UpdateInstanceRequest) GetInstance() *Instance

func (*UpdateInstanceRequest) GetRequestId 

func (x *UpdateInstanceRequest) GetRequestId() string

func (*UpdateInstanceRequest) GetUpdateMask 

func (x *UpdateInstanceRequest) GetUpdateMask() *fieldmaskpb.FieldMask

func (*UpdateInstanceRequest) ProtoMessage 

func (*UpdateInstanceRequest) ProtoMessage()

func (*UpdateInstanceRequest) ProtoReflect 

func (x *UpdateInstanceRequest) ProtoReflect() protoreflect.Message

func (*UpdateInstanceRequest) Reset 

func (x *UpdateInstanceRequest) Reset()

func (*UpdateInstanceRequest) String 

func (x *UpdateInstanceRequest) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.