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
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://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
