Package cloud.google.com/go/lustre/apiv1/lustrepb (v0.2.1)

Version latest

• 0.2.1 (latest)
• 0.2.0
• 0.1.1

Note: To get more information about this package, such as access to older versions, view this package on pkg.go.dev.

Constants

Lustre_ListInstances_FullMethodName, Lustre_GetInstance_FullMethodName, Lustre_CreateInstance_FullMethodName, Lustre_UpdateInstance_FullMethodName, Lustre_DeleteInstance_FullMethodName, Lustre_ImportData_FullMethodName, Lustre_ExportData_FullMethodName

const (
	Lustre_ListInstances_FullMethodName  = "/google.cloud.lustre.v1.Lustre/ListInstances"
	Lustre_GetInstance_FullMethodName    = "/google.cloud.lustre.v1.Lustre/GetInstance"
	Lustre_CreateInstance_FullMethodName = "/google.cloud.lustre.v1.Lustre/CreateInstance"
	Lustre_UpdateInstance_FullMethodName = "/google.cloud.lustre.v1.Lustre/UpdateInstance"
	Lustre_DeleteInstance_FullMethodName = "/google.cloud.lustre.v1.Lustre/DeleteInstance"
	Lustre_ImportData_FullMethodName     = "/google.cloud.lustre.v1.Lustre/ImportData"
	Lustre_ExportData_FullMethodName     = "/google.cloud.lustre.v1.Lustre/ExportData"
)

Variables

Instance_State_name, Instance_State_value

var (
	Instance_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "ACTIVE",
		2: "CREATING",
		3: "DELETING",
		4: "UPGRADING",
		5: "REPAIRING",
		6: "STOPPED",
		7: "UPDATING",
	}
	Instance_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"ACTIVE":            1,
		"CREATING":          2,
		"DELETING":          3,
		"UPGRADING":         4,
		"REPAIRING":         5,
		"STOPPED":           6,
		"UPDATING":          7,
	}
)

Enum value maps for Instance_State.

TransferType_name, TransferType_value

var (
	TransferType_name = map[int32]string{
		0: "TRANSFER_TYPE_UNSPECIFIED",
		1: "IMPORT",
		2: "EXPORT",
	}
	TransferType_value = map[string]int32{
		"TRANSFER_TYPE_UNSPECIFIED": 0,
		"IMPORT":                    1,
		"EXPORT":                    2,
	}
)

Enum value maps for TransferType.

File_google_cloud_lustre_v1_instance_proto

var File_google_cloud_lustre_v1_instance_proto protoreflect.FileDescriptor

File_google_cloud_lustre_v1_lustre_proto

var File_google_cloud_lustre_v1_lustre_proto protoreflect.FileDescriptor

File_google_cloud_lustre_v1_transfer_proto

var File_google_cloud_lustre_v1_transfer_proto protoreflect.FileDescriptor

Lustre_ServiceDesc

var Lustre_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "google.cloud.lustre.v1.Lustre",
	HandlerType: (*LustreServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListInstances",
			Handler:    _Lustre_ListInstances_Handler,
		},
		{
			MethodName: "GetInstance",
			Handler:    _Lustre_GetInstance_Handler,
		},
		{
			MethodName: "CreateInstance",
			Handler:    _Lustre_CreateInstance_Handler,
		},
		{
			MethodName: "UpdateInstance",
			Handler:    _Lustre_UpdateInstance_Handler,
		},
		{
			MethodName: "DeleteInstance",
			Handler:    _Lustre_DeleteInstance_Handler,
		},
		{
			MethodName: "ImportData",
			Handler:    _Lustre_ImportData_Handler,
		},
		{
			MethodName: "ExportData",
			Handler:    _Lustre_ExportData_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "google/cloud/lustre/v1/lustre.proto",
}

Lustre_ServiceDesc is the grpc.ServiceDesc for Lustre service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterLustreServer

func RegisterLustreServer(s grpc.ServiceRegistrar, srv LustreServer)

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 Managed Lustre 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.
	InstanceId string `protobuf:"bytes,2,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	// Required. The resource being created
	Instance *Instance `protobuf:"bytes,3,opt,name=instance,proto3" json:"instance,omitempty"`
	// Optional. An optional request ID to identify requests. Specify a unique
	// request ID so that if you must retry your request, the server will know to
	// ignore the request if it has already been completed. The server will
	// guarantee that for at least 60 minutes since the first request.
	//
	// For example, consider a situation where you make an initial request and the
	// request times out. If you make the request again with the same request
	// ID, the server can check if original operation with the same request ID
	// was received, and if so, will ignore the second request. This prevents
	// clients from accidentally creating duplicate commitments.
	//
	// The request ID must be a valid UUID with the exception that zero UUID is
	// not supported (00000000-0000-0000-0000-000000000000).
	RequestId string `protobuf:"bytes,4,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// contains filtered or unexported fields
}

Message for creating a Instance

func (*CreateInstanceRequest) Descriptor

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

Deprecated: Use CreateInstanceRequest.ProtoReflect.Descriptor instead.

func (*CreateInstanceRequest) GetInstance

func (x *CreateInstanceRequest) GetInstance() *Instance

func (*CreateInstanceRequest) GetInstanceId

func (x *CreateInstanceRequest) GetInstanceId() string

func (*CreateInstanceRequest) GetParent

func (x *CreateInstanceRequest) GetParent() string

func (*CreateInstanceRequest) GetRequestId

func (x *CreateInstanceRequest) GetRequestId() string

func (*CreateInstanceRequest) ProtoMessage

func (*CreateInstanceRequest) ProtoMessage()

func (*CreateInstanceRequest) ProtoReflect

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

func (*CreateInstanceRequest) Reset

func (x *CreateInstanceRequest) Reset()

func (*CreateInstanceRequest) String

func (x *CreateInstanceRequest) String() string

DeleteInstanceRequest

type DeleteInstanceRequest struct {

	// Required. The resource name of the instance to delete, in the format
	// `projects/{projectId}/locations/{location}/instances/{instanceId}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Optional. An optional request ID to identify requests. Specify a unique
	// request ID so that if you must retry your request, the server will know to
	// ignore the request if it has already been completed. The server will
	// guarantee that for at least 60 minutes after the first request.
	//
	// For example, consider a situation where you make an initial request and the
	// request times out. If you make the request again with the same request
	// ID, the server can check if original operation with the same request ID
	// was received, and if so, will ignore the second request. This prevents
	// clients from accidentally creating duplicate commitments.
	//
	// The request ID must be a valid UUID with the exception that zero UUID is
	// not supported (00000000-0000-0000-0000-000000000000).
	RequestId string `protobuf:"bytes,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// contains filtered or unexported fields
}

Message for deleting a Instance

func (*DeleteInstanceRequest) Descriptor

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

Deprecated: Use DeleteInstanceRequest.ProtoReflect.Descriptor instead.

func (*DeleteInstanceRequest) GetName

func (x *DeleteInstanceRequest) GetName() string

func (*DeleteInstanceRequest) GetRequestId

func (x *DeleteInstanceRequest) GetRequestId() string

func (*DeleteInstanceRequest) ProtoMessage

func (*DeleteInstanceRequest) ProtoMessage()

func (*DeleteInstanceRequest) ProtoReflect

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

func (*DeleteInstanceRequest) Reset

func (x *DeleteInstanceRequest) Reset()

func (*DeleteInstanceRequest) String

func (x *DeleteInstanceRequest) String() string

ErrorLogEntry

type ErrorLogEntry struct {

	// Required. A URL that refers to the target (a data source, a data sink,
	// or an object) with which the error is associated.
	Uri string `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"`
	// A list of messages that carry the error details.
	ErrorDetails []string `protobuf:"bytes,2,rep,name=error_details,json=errorDetails,proto3" json:"error_details,omitempty"`
	// contains filtered or unexported fields
}

An entry describing an error that has occurred.

func (*ErrorLogEntry) Descriptor

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

Deprecated: Use ErrorLogEntry.ProtoReflect.Descriptor instead.

func (*ErrorLogEntry) GetErrorDetails

func (x *ErrorLogEntry) GetErrorDetails() []string

func (*ErrorLogEntry) GetUri

func (x *ErrorLogEntry) GetUri() string

func (*ErrorLogEntry) ProtoMessage

func (*ErrorLogEntry) ProtoMessage()

func (*ErrorLogEntry) ProtoReflect

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

func (*ErrorLogEntry) Reset

func (x *ErrorLogEntry) Reset()

func (*ErrorLogEntry) String

func (x *ErrorLogEntry) String() string

ErrorSummary

type ErrorSummary struct {

	// Required.
	ErrorCode code.Code `protobuf:"varint,1,opt,name=error_code,json=errorCode,proto3,enum=google.rpc.Code" json:"error_code,omitempty"`
	// Required. Count of this type of error.
	ErrorCount int64 `protobuf:"varint,2,opt,name=error_count,json=errorCount,proto3" json:"error_count,omitempty"`
	// Error samples.
	//
	// At most 5 error log entries are recorded for a given
	// error code for a single transfer operation.
	ErrorLogEntries []*ErrorLogEntry `protobuf:"bytes,3,rep,name=error_log_entries,json=errorLogEntries,proto3" json:"error_log_entries,omitempty"`
	// contains filtered or unexported fields
}

A summary of errors by error code, plus a count and sample error log entries.

func (*ErrorSummary) Descriptor

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

Deprecated: Use ErrorSummary.ProtoReflect.Descriptor instead.

func (*ErrorSummary) GetErrorCode

func (x *ErrorSummary) GetErrorCode() code.Code

func (*ErrorSummary) GetErrorCount

func (x *ErrorSummary) GetErrorCount() int64

func (*ErrorSummary) GetErrorLogEntries

func (x *ErrorSummary) GetErrorLogEntries() []*ErrorLogEntry

func (*ErrorSummary) ProtoMessage

func (*ErrorSummary) ProtoMessage()

func (*ErrorSummary) ProtoReflect

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

func (*ErrorSummary) Reset

func (x *ErrorSummary) Reset()

func (*ErrorSummary) String

func (x *ErrorSummary) String() string

ExportDataMetadata

type ExportDataMetadata struct {

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

Metadata of the export data operation.

func (*ExportDataMetadata) Descriptor

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

Deprecated: Use ExportDataMetadata.ProtoReflect.Descriptor instead.

func (*ExportDataMetadata) GetApiVersion

func (x *ExportDataMetadata) GetApiVersion() string

func (*ExportDataMetadata) GetCreateTime

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

func (*ExportDataMetadata) GetEndTime

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

func (*ExportDataMetadata) GetOperationMetadata

func (x *ExportDataMetadata) GetOperationMetadata() *TransferOperationMetadata

func (*ExportDataMetadata) GetRequestedCancellation

func (x *ExportDataMetadata) GetRequestedCancellation() bool

func (*ExportDataMetadata) GetStatusMessage

func (x *ExportDataMetadata) GetStatusMessage() string

func (*ExportDataMetadata) GetTarget

func (x *ExportDataMetadata) GetTarget() string

func (*ExportDataMetadata) GetVerb

func (x *ExportDataMetadata) GetVerb() string

func (*ExportDataMetadata) ProtoMessage

func (*ExportDataMetadata) ProtoMessage()

func (*ExportDataMetadata) ProtoReflect

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

func (*ExportDataMetadata) Reset

func (x *ExportDataMetadata) Reset()

func (*ExportDataMetadata) String

func (x *ExportDataMetadata) String() string

ExportDataRequest

type ExportDataRequest struct {

	// The source of the data transfer.
	//
	// Types that are assignable to Source:
	//
	//	*ExportDataRequest_LustrePath
	Source isExportDataRequest_Source `protobuf_oneof:"source"`
	// The destination of the data transfer.
	//
	// Types that are assignable to Destination:
	//
	//	*ExportDataRequest_GcsPath
	Destination isExportDataRequest_Destination `protobuf_oneof:"destination"`
	// Required. The name of the Managed Lustre instance in the format
	// `projects/{project}/locations/{location}/instances/{instance}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Optional. UUID to identify requests.
	RequestId string `protobuf:"bytes,4,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// Optional. User-specified service account used to perform the transfer.
	// If unspecified, the Managed Lustre service agent is used.
	ServiceAccount string `protobuf:"bytes,5,opt,name=service_account,json=serviceAccount,proto3" json:"service_account,omitempty"`
	// contains filtered or unexported fields
}

Export data from Managed Lustre to a Cloud Storage bucket.

func (*ExportDataRequest) Descriptor

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

Deprecated: Use ExportDataRequest.ProtoReflect.Descriptor instead.

func (*ExportDataRequest) GetDestination

func (m *ExportDataRequest) GetDestination() isExportDataRequest_Destination

func (*ExportDataRequest) GetGcsPath

func (x *ExportDataRequest) GetGcsPath() *GcsPath

func (*ExportDataRequest) GetLustrePath

func (x *ExportDataRequest) GetLustrePath() *LustrePath

func (*ExportDataRequest) GetName

func (x *ExportDataRequest) GetName() string

func (*ExportDataRequest) GetRequestId

func (x *ExportDataRequest) GetRequestId() string

func (*ExportDataRequest) GetServiceAccount

func (x *ExportDataRequest) GetServiceAccount() string

func (*ExportDataRequest) GetSource

func (m *ExportDataRequest) GetSource() isExportDataRequest_Source

func (*ExportDataRequest) ProtoMessage

func (*ExportDataRequest) ProtoMessage()

func (*ExportDataRequest) ProtoReflect

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

func (*ExportDataRequest) Reset

func (x *ExportDataRequest) Reset()

func (*ExportDataRequest) String

func (x *ExportDataRequest) String() string

ExportDataRequest_GcsPath

type ExportDataRequest_GcsPath struct {
	// The URI to a Cloud Storage bucket, or a path within a bucket, using
	// the format `gs://

ExportDataRequest_LustrePath

type ExportDataRequest_LustrePath struct {
	// The root directory path to the Managed Lustre file system. Must start
	// with `/`. Default is `/`.
	LustrePath *LustrePath `protobuf:"bytes,2,opt,name=lustre_path,json=lustrePath,proto3,oneof"`
}

ExportDataResponse

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

Response message for ExportData.

func (*ExportDataResponse) Descriptor

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

Deprecated: Use ExportDataResponse.ProtoReflect.Descriptor instead.

func (*ExportDataResponse) ProtoMessage

func (*ExportDataResponse) ProtoMessage()

func (*ExportDataResponse) ProtoReflect

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

func (*ExportDataResponse) Reset

func (x *ExportDataResponse) Reset()

func (*ExportDataResponse) String

func (x *ExportDataResponse) String() string

GcsPath

type GcsPath struct {

	// Required. The URI to a Cloud Storage bucket, or a path within a bucket,
	// using the format `gs://

Specifies a Cloud Storage bucket and, optionally, a path inside the bucket.

func (*GcsPath) Descriptor

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

Deprecated: Use GcsPath.ProtoReflect.Descriptor instead.

func (*GcsPath) GetUri

func (x *GcsPath) GetUri() string

func (*GcsPath) ProtoMessage

func (*GcsPath) ProtoMessage()

func (*GcsPath) ProtoReflect

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

func (*GcsPath) Reset

func (x *GcsPath) Reset()

func (*GcsPath) String

func (x *GcsPath) String() string

GetInstanceRequest

type GetInstanceRequest struct {

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

Message for getting a Instance

func (*GetInstanceRequest) Descriptor

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

Deprecated: Use GetInstanceRequest.ProtoReflect.Descriptor instead.

func (*GetInstanceRequest) GetName

func (x *GetInstanceRequest) GetName() string

func (*GetInstanceRequest) ProtoMessage

func (*GetInstanceRequest) ProtoMessage()

func (*GetInstanceRequest) ProtoReflect

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

func (*GetInstanceRequest) Reset

func (x *GetInstanceRequest) Reset()

func (*GetInstanceRequest) String

func (x *GetInstanceRequest) String() string

ImportDataMetadata

type ImportDataMetadata struct {

	// Data transfer operation metadata.
	OperationMetadata *TransferOperationMetadata `protobuf:"bytes,1,opt,name=operation_metadata,json=operationMetadata,proto3" json:"operation_metadata,omitempty"`
	// Output only. The time the operation was created.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Output only. The time the operation finished running.
	EndTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// Output only. Server-defined resource path for the target of the operation.
	Target string `protobuf:"bytes,4,opt,name=target,proto3" json:"target,omitempty"`
	// Output only. Name of the verb executed by the operation.
	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
	// [google.longrunning.Operation.error][google.longrunning.Operation.error]
	// value with a [google.rpc.Status.code][google.rpc.Status.code] of 1,
	// corresponding to `Code.CANCELLED`.
	RequestedCancellation bool `protobuf:"varint,7,opt,name=requested_cancellation,json=requestedCancellation,proto3" json:"requested_cancellation,omitempty"`
	// Output only. API version used to start the operation.
	ApiVersion string `protobuf:"bytes,8,opt,name=api_version,json=apiVersion,proto3" json:"api_version,omitempty"`
	// contains filtered or unexported fields
}

Metadata of the import data operation.

func (*ImportDataMetadata) Descriptor

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

Deprecated: Use ImportDataMetadata.ProtoReflect.Descriptor instead.

func (*ImportDataMetadata) GetApiVersion

func (x *ImportDataMetadata) GetApiVersion() string

func (*ImportDataMetadata) GetCreateTime

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

func (*ImportDataMetadata) GetEndTime

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

func (*ImportDataMetadata) GetOperationMetadata

func (x *ImportDataMetadata) GetOperationMetadata() *TransferOperationMetadata

func (*ImportDataMetadata) GetRequestedCancellation

func (x *ImportDataMetadata) GetRequestedCancellation() bool

func (*ImportDataMetadata) GetStatusMessage

func (x *ImportDataMetadata) GetStatusMessage() string

func (*ImportDataMetadata) GetTarget

func (x *ImportDataMetadata) GetTarget() string

func (*ImportDataMetadata) ProtoMessage

func (*ImportDataMetadata) ProtoMessage()

func (*ImportDataMetadata) ProtoReflect

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

func (*ImportDataMetadata) Reset

func (x *ImportDataMetadata) Reset()

func (*ImportDataMetadata) String

func (x *ImportDataMetadata) String() string

ImportDataRequest

type ImportDataRequest struct {

	// A Cloud Storage URI of a folder to import file data from, in the
	// form of `gs://

Message for importing data to Lustre.

func (*ImportDataRequest) Descriptor

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

Deprecated: Use ImportDataRequest.ProtoReflect.Descriptor instead.

func (*ImportDataRequest) GetDestination

func (m *ImportDataRequest) GetDestination() isImportDataRequest_Destination

func (*ImportDataRequest) GetGcsPath

func (x *ImportDataRequest) GetGcsPath() *GcsPath

func (*ImportDataRequest) GetLustrePath

func (x *ImportDataRequest) GetLustrePath() *LustrePath

func (*ImportDataRequest) GetName

func (x *ImportDataRequest) GetName() string

func (*ImportDataRequest) GetRequestId

func (x *ImportDataRequest) GetRequestId() string

func (*ImportDataRequest) GetServiceAccount

func (x *ImportDataRequest) GetServiceAccount() string

func (*ImportDataRequest) GetSource

func (m *ImportDataRequest) GetSource() isImportDataRequest_Source

func (*ImportDataRequest) ProtoMessage

func (*ImportDataRequest) ProtoMessage()

func (*ImportDataRequest) ProtoReflect

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

func (*ImportDataRequest) Reset

func (x *ImportDataRequest) Reset()

func (*ImportDataRequest) String

func (x *ImportDataRequest) String() string

ImportDataRequest_GcsPath

type ImportDataRequest_GcsPath struct {
	// The Cloud Storage source bucket and, optionally, path inside the bucket.
	// If a path inside the bucket is specified, it must end with a forward
	// slash (`/`).
	GcsPath *GcsPath `protobuf:"bytes,2,opt,name=gcs_path,json=gcsPath,proto3,oneof"`
}

ImportDataRequest_LustrePath

type ImportDataRequest_LustrePath struct {
	// Lustre path destination.
	LustrePath *LustrePath `protobuf:"bytes,3,opt,name=lustre_path,json=lustrePath,proto3,oneof"`
}

ImportDataResponse

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

Response message for ImportData.

func (*ImportDataResponse) Descriptor

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

Deprecated: Use ImportDataResponse.ProtoReflect.Descriptor instead.

func (*ImportDataResponse) ProtoMessage

func (*ImportDataResponse) ProtoMessage()

func (*ImportDataResponse) ProtoReflect

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

func (*ImportDataResponse) Reset

func (x *ImportDataResponse) Reset()

func (*ImportDataResponse) String

func (x *ImportDataResponse) String() string

Instance

type Instance struct {

	// Identifier. The name of the instance.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Required. Immutable. The filesystem name for this instance. This name is
	// used by client-side tools, including when mounting the instance. Must be
	// eight characters or less and can only contain letters and numbers.
	Filesystem string `protobuf:"bytes,10,opt,name=filesystem,proto3" json:"filesystem,omitempty"`
	// Required. The storage capacity of the instance in gibibytes (GiB). Allowed
	// values are from `18000` to `954000`, in increments of 9000.
	CapacityGib int64 `protobuf:"varint,2,opt,name=capacity_gib,json=capacityGib,proto3" json:"capacity_gib,omitempty"`
	// Required. Immutable. The full name of the VPC network to which the instance
	// is connected. Must be in the format
	// `projects/{project_id}/global/networks/{network_name}`.
	Network string `protobuf:"bytes,3,opt,name=network,proto3" json:"network,omitempty"`
	// Output only. The state of the instance.
	State Instance_State `protobuf:"varint,4,opt,name=state,proto3,enum=google.cloud.lustre.v1.Instance_State" json:"state,omitempty"`
	// Output only. Mount point of the instance in the format
	// `IP_ADDRESS@tcp:/FILESYSTEM`.
	MountPoint string `protobuf:"bytes,5,opt,name=mount_point,json=mountPoint,proto3" json:"mount_point,omitempty"`
	// Output only. Timestamp when the instance was created.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Output only. Timestamp when the instance was last updated.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// Optional. A user-readable description of the instance.
	Description string `protobuf:"bytes,8,opt,name=description,proto3" json:"description,omitempty"`
	// Optional. Labels as key value pairs.
	Labels map[string]string `protobuf:"bytes,9,rep,name=labels,proto3" json:"labels,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
	// Required. The throughput of the instance in MB/s/TiB.
	// Valid values are 125, 250, 500, 1000.
	PerUnitStorageThroughput int64 `protobuf:"varint,11,opt,name=per_unit_storage_throughput,json=perUnitStorageThroughput,proto3" json:"per_unit_storage_throughput,omitempty"`
	// Optional. Indicates whether you want to enable support for GKE clients. By
	// default, GKE clients are not supported. Deprecated. No longer required for
	// GKE instance creation.
	//
	// Deprecated: Marked as deprecated in google/cloud/lustre/v1/instance.proto.
	GkeSupportEnabled bool `protobuf:"varint,12,opt,name=gke_support_enabled,json=gkeSupportEnabled,proto3" json:"gke_support_enabled,omitempty"`
	// contains filtered or unexported fields
}

A Managed Lustre instance.

func (*Instance) Descriptor

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

Deprecated: Use Instance.ProtoReflect.Descriptor instead.

func (*Instance) GetCapacityGib

func (x *Instance) GetCapacityGib() int64

func (*Instance) GetCreateTime

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

func (*Instance) GetDescription

func (x *Instance) GetDescription() string

func (*Instance) GetFilesystem

func (x *Instance) GetFilesystem() string

func (*Instance) GetGkeSupportEnabled

func (x *Instance) GetGkeSupportEnabled() bool

Deprecated: Marked as deprecated in google/cloud/lustre/v1/instance.proto.

func (*Instance) GetLabels

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

func (*Instance) GetMountPoint

func (x *Instance) GetMountPoint() string

func (*Instance) GetName

func (x *Instance) GetName() string

func (*Instance) GetNetwork

func (x *Instance) GetNetwork() string

func (*Instance) GetPerUnitStorageThroughput

func (x *Instance) GetPerUnitStorageThroughput() int64

func (*Instance) GetState

func (x *Instance) GetState() Instance_State

func (*Instance) GetUpdateTime

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

func (*Instance) ProtoMessage

func (*Instance) ProtoMessage()

func (*Instance) ProtoReflect

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

func (*Instance) Reset

func (x *Instance) Reset()

func (*Instance) String

func (x *Instance) String() string

Instance_State

type Instance_State int32

The possible states of an instance.

Instance_STATE_UNSPECIFIED, Instance_ACTIVE, Instance_CREATING, Instance_DELETING, Instance_UPGRADING, Instance_REPAIRING, Instance_STOPPED, Instance_UPDATING

const (
	// Not set.
	Instance_STATE_UNSPECIFIED Instance_State = 0
	// The instance is available for use.
	Instance_ACTIVE Instance_State = 1
	// The instance is being created and is not yet ready for use.
	Instance_CREATING Instance_State = 2
	// The instance is being deleted.
	Instance_DELETING Instance_State = 3
	// The instance is being upgraded.
	Instance_UPGRADING Instance_State = 4
	// The instance is being repaired.
	Instance_REPAIRING Instance_State = 5
	// The instance is stopped.
	Instance_STOPPED Instance_State = 6
	// The instance is being updated.
	Instance_UPDATING Instance_State = 7
)

func (Instance_State) Descriptor

func (Instance_State) Descriptor() protoreflect.EnumDescriptor

func (Instance_State) Enum

func (x Instance_State) Enum() *Instance_State

func (Instance_State) EnumDescriptor

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

Deprecated: Use Instance_State.Descriptor instead.

func (Instance_State) Number

func (x Instance_State) Number() protoreflect.EnumNumber

func (Instance_State) String

func (x Instance_State) String() string

func (Instance_State) Type

func (Instance_State) Type() protoreflect.EnumType

ListInstancesRequest

type ListInstancesRequest struct {

	// Required. The project and location for which to retrieve a list of
	// instances, in the format `projects/{projectId}/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 might 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. Desired order of 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

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

Deprecated: Use ListInstancesRequest.ProtoReflect.Descriptor instead.

func (*ListInstancesRequest) GetFilter

func (x *ListInstancesRequest) GetFilter() string

func (*ListInstancesRequest) GetOrderBy

func (x *ListInstancesRequest) GetOrderBy() string

func (*ListInstancesRequest) GetPageSize

func (x *ListInstancesRequest) GetPageSize() int32

func (*ListInstancesRequest) GetPageToken

func (x *ListInstancesRequest) GetPageToken() string

func (*ListInstancesRequest) GetParent

func (x *ListInstancesRequest) GetParent() string

func (*ListInstancesRequest) ProtoMessage

func (*ListInstancesRequest) ProtoMessage()

func (*ListInstancesRequest) ProtoReflect

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

func (*ListInstancesRequest) Reset

func (x *ListInstancesRequest) Reset()

func (*ListInstancesRequest) String

func (x *ListInstancesRequest) String() string

ListInstancesResponse

type ListInstancesResponse struct {

	// Response from [ListInstances][google.cloud.lustre.v1.Lustre.ListInstances].
	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"`
	// Unordered list. 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

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

LustreClient

type LustreClient 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 new 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)
	// Imports data from Cloud Storage to a Managed Lustre instance.
	ImportData(ctx context.Context, in *ImportDataRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Exports data from a Managed Lustre instance to Cloud Storage.
	ExportData(ctx context.Context, in *ExportDataRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
}

LustreClient is the client API for Lustre service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewLustreClient

func NewLustreClient(cc grpc.ClientConnInterface) LustreClient

LustrePath

type LustrePath struct {

	// Optional. The root directory path to the Managed Lustre file system. Must
	// start with
	// `/`. Default is `/`. If you're importing data into Managed Lustre, any
	// path other than the default must already exist on the file system.
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

The root directory path to the Lustre file system.

func (*LustrePath) Descriptor

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

Deprecated: Use LustrePath.ProtoReflect.Descriptor instead.

func (*LustrePath) GetPath

func (x *LustrePath) GetPath() string

func (*LustrePath) ProtoMessage

func (*LustrePath) ProtoMessage()

func (*LustrePath) ProtoReflect

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

func (*LustrePath) Reset

func (x *LustrePath) Reset()

func (*LustrePath) String

func (x *LustrePath) String() string

LustreServer

type LustreServer 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 new 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)
	// Imports data from Cloud Storage to a Managed Lustre instance.
	ImportData(context.Context, *ImportDataRequest) (*longrunningpb.Operation, error)
	// Exports data from a Managed Lustre instance to Cloud Storage.
	ExportData(context.Context, *ExportDataRequest) (*longrunningpb.Operation, error)
}

LustreServer is the server API for Lustre service. All implementations should embed UnimplementedLustreServer for forward compatibility

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 a long-running operation.

func (*OperationMetadata) Descriptor

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

Deprecated: Use OperationMetadata.ProtoReflect.Descriptor instead.

func (*OperationMetadata) GetApiVersion

func (x *OperationMetadata) GetApiVersion() string

func (*OperationMetadata) GetCreateTime

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

func (*OperationMetadata) GetEndTime

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

func (*OperationMetadata) GetRequestedCancellation

func (x *OperationMetadata) GetRequestedCancellation() bool

func (*OperationMetadata) GetStatusMessage

func (x *OperationMetadata) GetStatusMessage() string

func (*OperationMetadata) GetTarget

func (x *OperationMetadata) GetTarget() string

func (*OperationMetadata) GetVerb

func (x *OperationMetadata) GetVerb() string

func (*OperationMetadata) ProtoMessage

func (*OperationMetadata) ProtoMessage()

func (*OperationMetadata) ProtoReflect

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

func (*OperationMetadata) Reset

func (x *OperationMetadata) Reset()

func (*OperationMetadata) String

func (x *OperationMetadata) String() string

TransferCounters

type TransferCounters struct {

	// Objects found in the data source that are scheduled to be transferred,
	// excluding any that are filtered based on object conditions or skipped due
	// to sync.
	FoundObjectsCount int64 `protobuf:"varint,1,opt,name=found_objects_count,json=foundObjectsCount,proto3" json:"found_objects_count,omitempty"`
	// Total number of 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.
	BytesFoundCount int64 `protobuf:"varint,2,opt,name=bytes_found_count,json=bytesFoundCount,proto3" json:"bytes_found_count,omitempty"`
	// Objects in the data source that are not transferred because they already
	// exist in the data destination.
	ObjectsSkippedCount int64 `protobuf:"varint,3,opt,name=objects_skipped_count,json=objectsSkippedCount,proto3" json:"objects_skipped_count,omitempty"`
	// Bytes in the data source that are not transferred because they already
	// exist in the data destination.
	BytesSkippedCount int64 `protobuf:"varint,4,opt,name=bytes_skipped_count,json=bytesSkippedCount,proto3" json:"bytes_skipped_count,omitempty"`
	// Objects that are copied to the data destination.
	ObjectsCopiedCount int64 `protobuf:"varint,5,opt,name=objects_copied_count,json=objectsCopiedCount,proto3" json:"objects_copied_count,omitempty"`
	// Bytes that are copied to the data destination.
	BytesCopiedCount int64 `protobuf:"varint,6,opt,name=bytes_copied_count,json=bytesCopiedCount,proto3" json:"bytes_copied_count,omitempty"`
	// Output only. Objects that are failed to write to the data destination.
	ObjectsFailedCount int64 `protobuf:"varint,7,opt,name=objects_failed_count,json=objectsFailedCount,proto3" json:"objects_failed_count,omitempty"`
	// Output only. Bytes that are failed to write to the data destination.
	BytesFailedCount int64 `protobuf:"varint,8,opt,name=bytes_failed_count,json=bytesFailedCount,proto3" json:"bytes_failed_count,omitempty"`
	// contains filtered or unexported fields
}

A collection of counters that report the progress of a transfer operation.

func (*TransferCounters) Descriptor

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

Deprecated: Use TransferCounters.ProtoReflect.Descriptor instead.

func (*TransferCounters) GetBytesCopiedCount

func (x *TransferCounters) GetBytesCopiedCount() int64

func (*TransferCounters) GetBytesFailedCount

func (x *TransferCounters) GetBytesFailedCount() int64

func (*TransferCounters) GetBytesFoundCount

func (x *TransferCounters) GetBytesFoundCount() int64

func (*TransferCounters) GetBytesSkippedCount

func (x *TransferCounters) GetBytesSkippedCount() int64

func (*TransferCounters) GetFoundObjectsCount

func (x *TransferCounters) GetFoundObjectsCount() int64

func (*TransferCounters) GetObjectsCopiedCount

func (x *TransferCounters) GetObjectsCopiedCount() int64

func (*TransferCounters) GetObjectsFailedCount

func (x *TransferCounters) GetObjectsFailedCount() int64

func (*TransferCounters) GetObjectsSkippedCount

func (x *TransferCounters) GetObjectsSkippedCount() int64

func (*TransferCounters) ProtoMessage

func (*TransferCounters) ProtoMessage()

func (*TransferCounters) ProtoReflect

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

func (*TransferCounters) Reset

func (x *TransferCounters) Reset()

func (*TransferCounters) String

func (x *TransferCounters) String() string

TransferOperationMetadata

type TransferOperationMetadata struct {

	// The source of transfer operation.
	//
	// Types that are assignable to Source:
	//
	//	*TransferOperationMetadata_SourceLustrePath
	//	*TransferOperationMetadata_SourceGcsPath
	Source isTransferOperationMetadata_Source `protobuf_oneof:"source"`
	// The destination of transfer operation.
	//
	// Types that are assignable to Destination:
	//
	//	*TransferOperationMetadata_DestinationGcsPath
	//	*TransferOperationMetadata_DestinationLustrePath
	Destination isTransferOperationMetadata_Destination `protobuf_oneof:"destination"`
	// Output only. The progress of the transfer operation.
	Counters *TransferCounters `protobuf:"bytes,1,opt,name=counters,proto3" json:"counters,omitempty"`
	// Output only. The type of transfer occurring.
	TransferType TransferType `protobuf:"varint,2,opt,name=transfer_type,json=transferType,proto3,enum=google.cloud.lustre.v1.TransferType" json:"transfer_type,omitempty"`
	// Output only. Error summary about the transfer operation
	ErrorSummaries []*ErrorSummary `protobuf:"bytes,7,rep,name=error_summaries,json=errorSummaries,proto3" json:"error_summaries,omitempty"`
	// contains filtered or unexported fields
}

Represents the metadata of the long-running transfer operation.

func (*TransferOperationMetadata) Descriptor

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

Deprecated: Use TransferOperationMetadata.ProtoReflect.Descriptor instead.

func (*TransferOperationMetadata) GetCounters

func (x *TransferOperationMetadata) GetCounters() *TransferCounters

func (*TransferOperationMetadata) GetDestination

func (m *TransferOperationMetadata) GetDestination() isTransferOperationMetadata_Destination

func (*TransferOperationMetadata) GetDestinationGcsPath

func (x *TransferOperationMetadata) GetDestinationGcsPath() *GcsPath

func (*TransferOperationMetadata) GetDestinationLustrePath

func (x *TransferOperationMetadata) GetDestinationLustrePath() *LustrePath

func (*TransferOperationMetadata) GetErrorSummaries

func (x *TransferOperationMetadata) GetErrorSummaries() []*ErrorSummary

func (*TransferOperationMetadata) GetSource

func (m *TransferOperationMetadata) GetSource() isTransferOperationMetadata_Source

func (*TransferOperationMetadata) GetSourceGcsPath

func (x *TransferOperationMetadata) GetSourceGcsPath() *GcsPath

func (*TransferOperationMetadata) GetSourceLustrePath

func (x *TransferOperationMetadata) GetSourceLustrePath() *LustrePath

func (*TransferOperationMetadata) GetTransferType

func (x *TransferOperationMetadata) GetTransferType() TransferType

func (*TransferOperationMetadata) ProtoMessage

func (*TransferOperationMetadata) ProtoMessage()

func (*TransferOperationMetadata) ProtoReflect

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

func (*TransferOperationMetadata) Reset

func (x *TransferOperationMetadata) Reset()

func (*TransferOperationMetadata) String

func (x *TransferOperationMetadata) String() string

TransferOperationMetadata_DestinationGcsPath

type TransferOperationMetadata_DestinationGcsPath struct {
	// Output only. Cloud Storage destination.
	DestinationGcsPath *GcsPath `protobuf:"bytes,5,opt,name=destination_gcs_path,json=destinationGcsPath,proto3,oneof"`
}

TransferOperationMetadata_DestinationLustrePath

type TransferOperationMetadata_DestinationLustrePath struct {
	// Output only. Lustre destination.
	DestinationLustrePath *LustrePath `protobuf:"bytes,6,opt,name=destination_lustre_path,json=destinationLustrePath,proto3,oneof"`
}

TransferOperationMetadata_SourceGcsPath

type TransferOperationMetadata_SourceGcsPath struct {
	// Output only. Cloud Storage source.
	SourceGcsPath *GcsPath `protobuf:"bytes,4,opt,name=source_gcs_path,json=sourceGcsPath,proto3,oneof"`
}

TransferOperationMetadata_SourceLustrePath

type TransferOperationMetadata_SourceLustrePath struct {
	// Output only. Lustre source.
	SourceLustrePath *LustrePath `protobuf:"bytes,3,opt,name=source_lustre_path,json=sourceLustrePath,proto3,oneof"`
}

TransferType

type TransferType int32

Type of transfer that occurred.

TransferType_TRANSFER_TYPE_UNSPECIFIED, TransferType_IMPORT, TransferType_EXPORT

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

func (TransferType) Descriptor

func (TransferType) Descriptor() protoreflect.EnumDescriptor

func (TransferType) Enum

func (x TransferType) Enum() *TransferType

func (TransferType) EnumDescriptor

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

Deprecated: Use TransferType.Descriptor instead.

func (TransferType) Number

func (x TransferType) Number() protoreflect.EnumNumber

func (TransferType) String

func (x TransferType) String() string

func (TransferType) Type

func (TransferType) Type() protoreflect.EnumType

UnimplementedLustreServer

type UnimplementedLustreServer struct {
}

UnimplementedLustreServer should be embedded to have forward compatible implementations.

func (UnimplementedLustreServer) CreateInstance

func (UnimplementedLustreServer) CreateInstance(context.Context, *CreateInstanceRequest) (*longrunningpb.Operation, error)

func (UnimplementedLustreServer) DeleteInstance

func (UnimplementedLustreServer) DeleteInstance(context.Context, *DeleteInstanceRequest) (*longrunningpb.Operation, error)

func (UnimplementedLustreServer) ExportData

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

func (UnimplementedLustreServer) GetInstance

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

func (UnimplementedLustreServer) ImportData

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

func (UnimplementedLustreServer) ListInstances

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

func (UnimplementedLustreServer) UpdateInstance

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

UnsafeLustreServer

type UnsafeLustreServer interface {
	// contains filtered or unexported methods
}

UnsafeLustreServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to LustreServer will result in compilation errors.

UpdateInstanceRequest

type UpdateInstanceRequest struct {

	// Optional. Specifies the fields to be overwritten in the instance resource
	// by the update.
	//
	// The fields specified in the update_mask are relative to the resource, not
	// the full request. A field will be overwritten if it is in the mask. If no
	// mask is provided then all fields present in the request are
	// overwritten.
	UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,1,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
	// Required. The resource name of the instance to update, in the format
	// `projects/{projectId}/locations/{location}/instances/{instanceId}`.
	Instance *Instance `protobuf:"bytes,2,opt,name=instance,proto3" json:"instance,omitempty"`
	// Optional. An optional request ID to identify requests. Specify a unique
	// request ID so that if you must retry your request, the server will know to
	// ignore the request if it has already been completed. The server will
	// guarantee that for at least 60 minutes since the first request.
	//
	// For example, consider a situation where you make an initial request and the
	// request times out. If you make the request again with the same request
	// ID, the server can check if original operation with the same request ID
	// was received, and if so, will ignore the second request. This prevents
	// clients from accidentally creating duplicate commitments.
	//
	// The request ID must be a valid UUID with the exception that zero UUID is
	// not supported (00000000-0000-0000-0000-000000000000).
	RequestId string `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// contains filtered or unexported fields
}

Message for updating a Instance

func (*UpdateInstanceRequest) Descriptor

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

Deprecated: Use UpdateInstanceRequest.ProtoReflect.Descriptor instead.

func (*UpdateInstanceRequest) GetInstance

func (x *UpdateInstanceRequest) GetInstance() *Instance

func (*UpdateInstanceRequest) GetRequestId

func (x *UpdateInstanceRequest) GetRequestId() string

func (*UpdateInstanceRequest) GetUpdateMask

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

func (*UpdateInstanceRequest) ProtoMessage

func (*UpdateInstanceRequest) ProtoMessage()

func (*UpdateInstanceRequest) ProtoReflect

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

func (*UpdateInstanceRequest) Reset

func (x *UpdateInstanceRequest) Reset()

func (*UpdateInstanceRequest) String

func (x *UpdateInstanceRequest) String() string