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
Functions
func RegisterLustreServer
func
RegisterLustreServer
(
s
*
grpc
.
Server
,
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
Deprecated: Use GcsPath.ProtoReflect.Descriptor instead.
func (*GcsPath) GetUri
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
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
Deprecated: Use Instance.ProtoReflect.Descriptor instead.
func (*Instance) GetCapacityGib
func (*Instance) GetCreateTime
func
(
x
*
Instance
)
GetCreateTime
()
*
timestamppb
.
Timestamp
func (*Instance) GetDescription
func (*Instance) GetFilesystem
func (*Instance) GetGkeSupportEnabled
Deprecated: Marked as deprecated in google/cloud/lustre/v1/instance.proto.
func (*Instance) GetLabels
func (*Instance) GetMountPoint
func (*Instance) GetName
func (*Instance) GetNetwork
func (*Instance) GetPerUnitStorageThroughput
func (*Instance) GetState
func
(
x
*
Instance
)
GetState
()
Instance_State
func (*Instance) GetUpdateTime
func
(
x
*
Instance
)
GetUpdateTime
()
*
timestamppb
.
Timestamp
func (*Instance) ProtoMessage
func
(
*
Instance
)
ProtoMessage
()
func (*Instance) ProtoReflect
func
(
x
*
Instance
)
ProtoReflect
()
protoreflect
.
Message
func (*Instance) Reset
func
(
x
*
Instance
)
Reset
()
func (*Instance) String
Instance_State
type
Instance_State
int32
The possible states of 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://godoc.org/google.golang.org/grpc#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.
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 can 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
)
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
