parallelstorepb

package
v0.2.0 Latest Latest
Warning

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

Go to latest
Published: May 1, 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 (
	Instance_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "CREATING",
		2: "ACTIVE",
		3: "DELETING",
		4: "FAILED",
	}
	Instance_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"CREATING":          1,
		"ACTIVE":            2,
		"DELETING":          3,
		"FAILED":            4,
	}
)

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 logical name of the Parallelstore instance in the user
	// project with the following restrictions:
	//
	// * 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
}

Request for [CreateInstance][google.cloud.parallelstore.v1beta.Parallelstore.CreateInstance]

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
}

Message for deleting a 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 ExportDataMetadata added in v0.2.0

type ExportDataMetadata struct {

	// Contains the data transfer operation metadata.
	OperationMetadata *TransferOperationMetadata `protobuf:"bytes,1,opt,name=operation_metadata,json=operationMetadata,proto3" json:"operation_metadata,omitempty"`
	// contains filtered or unexported fields
}

ExportDataMetadata contains export data operation metadata

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

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

Deprecated: Use ExportDataMetadata.ProtoReflect.Descriptor instead.

func (*ExportDataMetadata) GetOperationMetadata added in v0.2.0

func (x *ExportDataMetadata) GetOperationMetadata() *TransferOperationMetadata

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 source of the data exported from the parallelstore instance.
	//
	// Types that are assignable to Source:
	//
	//	*ExportDataRequest_SourcePath
	Source isExportDataRequest_Source `protobuf_oneof:"source"`
	// The destination of the data exported from the parallelstore instance.
	//
	// Types that are assignable to Destination:
	//
	//	*ExportDataRequest_DestinationGcsUri
	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"`
	// contains filtered or unexported fields
}

Message representing the request exporting data from Cloud Storage to parallelstore.

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

func (x *ExportDataRequest) GetDestinationGcsUri() string

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

func (m *ExportDataRequest) GetSource() isExportDataRequest_Source

func (*ExportDataRequest) GetSourcePath added in v0.2.0

func (x *ExportDataRequest) GetSourcePath() string

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

type ExportDataRequest_DestinationGcsUri struct {
	// URI to a Cloud Storage object in format:
	// 'gs://<bucket_name>/<path_inside_bucket>'.
	DestinationGcsUri string `protobuf:"bytes,3,opt,name=destination_gcs_uri,json=destinationGcsUri,proto3,oneof"`
}

type ExportDataRequest_SourcePath added in v0.2.0

type ExportDataRequest_SourcePath struct {
	// Optional. Root directory path to the Paralellstore filesystem, starting
	// with '/'. Sets to '/' if no value is set.
	SourcePath string `protobuf:"bytes,2,opt,name=source_path,json=sourcePath,proto3,oneof"`
}

type ExportDataResponse added in v0.2.0

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

ExportDataResponse is the response returned from ExportData rpc

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 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
}

Request to 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 {

	// Contains the data transfer operation metadata.
	OperationMetadata *TransferOperationMetadata `protobuf:"bytes,1,opt,name=operation_metadata,json=operationMetadata,proto3" json:"operation_metadata,omitempty"`
	// contains filtered or unexported fields
}

ImportDataMetadata contains import data operation metadata

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

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

Deprecated: Use ImportDataMetadata.ProtoReflect.Descriptor instead.

func (*ImportDataMetadata) GetOperationMetadata added in v0.2.0

func (x *ImportDataMetadata) GetOperationMetadata() *TransferOperationMetadata

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_SourceGcsUri
	Source isImportDataRequest_Source `protobuf_oneof:"source"`
	// The destination of the data being imported into the parallelstore instance.
	//
	// Types that are assignable to Destination:
	//
	//	*ImportDataRequest_DestinationPath
	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"`
	// contains filtered or unexported fields
}

Message representing the request importing data from parallelstore to Cloud Storage.

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

func (x *ImportDataRequest) GetDestinationPath() string

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

func (m *ImportDataRequest) GetSource() isImportDataRequest_Source

func (*ImportDataRequest) GetSourceGcsUri added in v0.2.0

func (x *ImportDataRequest) GetSourceGcsUri() string

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

type ImportDataRequest_DestinationPath struct {
	// Optional. Root directory path to the Paralellstore filesystem, starting
	// with '/'. Sets to '/' if no value is set.
	DestinationPath string `protobuf:"bytes,3,opt,name=destination_path,json=destinationPath,proto3,oneof"`
}

type ImportDataRequest_SourceGcsUri added in v0.2.0

type ImportDataRequest_SourceGcsUri struct {
	// URI to a Cloud Storage object in format:
	// 'gs://<bucket_name>/<path_inside_bucket>'.
	SourceGcsUri string `protobuf:"bytes,2,opt,name=source_gcs_uri,json=sourceGcsUri,proto3,oneof"`
}

type ImportDataResponse added in v0.2.0

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

ImportDataResponse is the response returned from ImportData rpc.

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. Cloud Labels can be used to
	// filter collections of resources. They can be used to control how resource
	// metrics are aggregated. And they can be used as arguments to policy
	// management rules (e.g. route, firewall, load balancing, etc.).
	//
	//   - Label keys must be between 1 and 63 characters long and must conform to
	//     the following regular expression: `[a-z][a-z0-9_-]{0,62}`.
	//   - Label values must be between 0 and 63 characters long and must conform
	//     to the regular expression `[a-z0-9_-]{0,63}`.
	//   - No more than 64 labels can be associated with a given resource.
	//
	// See https://goo.gl/xmQnxf for more information on and examples of labels.
	//
	// If you plan to use labels in your own code, please note that additional
	// characters may be allowed in the future. Therefore, you are advised to use
	// an internal label representation, such as JSON, which doesn't rely upon
	// specific characters being disallowed.  For example, representing labels
	// as the string:  name + "_" + value  would prove problematic if we were to
	// allow "_" in a future release.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// Required. Immutable. Storage capacity of Parallelstore instance in
	// Gibibytes (GiB).
	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. List of access_points.
	// Contains 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 Google 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. Contains the id of the allocated IP address range
	// associated with the private service access connection for example,
	// "test-default" associated with IP range 10.0.0.0/29. If no range id is
	// provided all ranges will be considered.
	ReservedIpRange string `protobuf:"bytes,12,opt,name=reserved_ip_range,json=reservedIpRange,proto3" json:"reserved_ip_range,omitempty"`
	// Output only. Immutable. Contains the id of the allocated IP address range
	// associated with the private service access connection for example,
	// "test-default" associated with IP range 10.0.0.0/29. This field is
	// populated by the service and and contains the value currently used by the
	// service.
	EffectiveReservedIpRange string `` /* 138-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) GetDescription

func (x *Instance) GetDescription() string

func (*Instance) GetEffectiveReservedIpRange added in v0.2.0

func (x *Instance) GetEffectiveReservedIpRange() string

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

Represents the different 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
)

func (Instance_State) Descriptor

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

func (x Instance_State) String() string

func (Instance_State) Type

type ListInstancesRequest

type ListInstancesRequest struct {

	// Required. The project and location for which to retrieve instance
	// information, in the format `projects/{project_id}/locations/{location}`.
	// For Parallelstore locations map to Google Cloud zones, for example
	// **us-central1-a**.
	// To retrieve instance information for all locations, use "-" for the
	// `{location}` value.
	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, 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
}

Message for requesting list of Instances

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
}

Message for response to listing Instances

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
}

Represents the metadata of the long-running operation.

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 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)
	// ImportData copies data from Cloud Storage to Parallelstore.
	ImportData(ctx context.Context, in *ImportDataRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// ExportData 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.

type ParallelstoreServer

type ParallelstoreServer interface {
	// Lists 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)
	// ImportData copies data from Cloud Storage to Parallelstore.
	ImportData(context.Context, *ImportDataRequest) (*longrunningpb.Operation, error)
	// ExportData copies data from Parallelstore to Cloud Storage
	ExportData(context.Context, *ExportDataRequest) (*longrunningpb.Operation, error)
}

ParallelstoreServer is the server API for Parallelstore service.

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 {

	// Output only. CCFE supplied fields BEGIN
	// 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"`
	// Information about the progress of the transfer operation.
	Counters *TransferCounters `protobuf:"bytes,3,opt,name=counters,proto3" json:"counters,omitempty"`
	// Required. The origin of the data transfer.
	Source string `protobuf:"bytes,4,opt,name=source,proto3" json:"source,omitempty"`
	// Required. The destination of the data transfer.
	Destination string `protobuf:"bytes,5,opt,name=destination,proto3" json:"destination,omitempty"`
	// The type of transfer occurring.
	TransferType TransferType `` /* 150-byte string literal not displayed */
	// contains filtered or unexported fields
}

Represents the metadata of the long-running operation.

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

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

func (*TransferOperationMetadata) GetDestination added in v0.2.0

func (x *TransferOperationMetadata) GetDestination() string

func (*TransferOperationMetadata) GetEndTime added in v0.2.0

func (*TransferOperationMetadata) GetSource added in v0.2.0

func (x *TransferOperationMetadata) GetSource() string

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 (*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 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) 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 (TransferType) String added in v0.2.0

func (x TransferType) String() string

func (TransferType) Type added in v0.2.0

type UnimplementedParallelstoreServer

type UnimplementedParallelstoreServer struct {
}

UnimplementedParallelstoreServer can be embedded to have forward compatible implementations.

func (*UnimplementedParallelstoreServer) CreateInstance

func (*UnimplementedParallelstoreServer) DeleteInstance

func (*UnimplementedParallelstoreServer) ExportData added in v0.2.0

func (*UnimplementedParallelstoreServer) GetInstance

func (*UnimplementedParallelstoreServer) ImportData added in v0.2.0

func (*UnimplementedParallelstoreServer) ListInstances

func (*UnimplementedParallelstoreServer) UpdateInstance

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
}

Message for updating a 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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL