Google Cloud Managed Lustre API v1 - Package cloud.google.com/go/lustre/apiv1/lustrepb (v1.2.0)

1.2.0 (latest) 1.1.0 1.0.0 0.7.0 0.6.0 0.5.0 0.4.0 0.3.0 0.2.1 0.1.1

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

Constants

Lustre_ListInstances_FullMethodName, Lustre_GetInstance_FullMethodName, Lustre_CreateInstance_FullMethodName, Lustre_UpdateInstance_FullMethodName, Lustre_DeleteInstance_FullMethodName, Lustre_RescheduleMaintenance_FullMethodName, Lustre_ImportData_FullMethodName, Lustre_ExportData_FullMethodName, Lustre_CreateMirror_FullMethodName, Lustre_UpdateMirror_FullMethodName, Lustre_DeleteMirror_FullMethodName, Lustre_GetMirror_FullMethodName, Lustre_ListMirrors_FullMethodName, Lustre_CreateDirectoryPolicy_FullMethodName, Lustre_DeleteDirectoryPolicy_FullMethodName, Lustre_GetDirectoryPolicy_FullMethodName, Lustre_ListDirectoryPolicies_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_RescheduleMaintenance_FullMethodName = "/google.cloud.lustre.v1.Lustre/RescheduleMaintenance"
	Lustre_ImportData_FullMethodName            = "/google.cloud.lustre.v1.Lustre/ImportData"
	Lustre_ExportData_FullMethodName            = "/google.cloud.lustre.v1.Lustre/ExportData"
	Lustre_CreateMirror_FullMethodName          = "/google.cloud.lustre.v1.Lustre/CreateMirror"
	Lustre_UpdateMirror_FullMethodName          = "/google.cloud.lustre.v1.Lustre/UpdateMirror"
	Lustre_DeleteMirror_FullMethodName          = "/google.cloud.lustre.v1.Lustre/DeleteMirror"
	Lustre_GetMirror_FullMethodName             = "/google.cloud.lustre.v1.Lustre/GetMirror"
	Lustre_ListMirrors_FullMethodName           = "/google.cloud.lustre.v1.Lustre/ListMirrors"
	Lustre_CreateDirectoryPolicy_FullMethodName = "/google.cloud.lustre.v1.Lustre/CreateDirectoryPolicy"
	Lustre_DeleteDirectoryPolicy_FullMethodName = "/google.cloud.lustre.v1.Lustre/DeleteDirectoryPolicy"
	Lustre_GetDirectoryPolicy_FullMethodName    = ";/google.cloud.lustre.v1.Lustre/GetDirectoryPolicy"
	Lustre_ListDirectoryPolicies_FullMethodName = "/google.cloud.lustre.v1.Lustre/ListDirectoryPolicies"
)

Variables

DirectoryPolicy_State_name, DirectoryPolicy_State_value

var (
	DirectoryPolicy_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "CREATING",
		2: "ACTIVE",
		3: "DELETING",
	}
	DirectoryPolicy_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"CREATING":          1,
		"ACTIVE":            2,
		"DELETING":          3,
	}
)

Enum value maps for DirectoryPolicy_State.

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",
		8: "SUSPENDED",
	}
	Instance_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"ACTIVE":            1,
		"CREATING":          2,
		"DELETING":          3,
		"UPGRADING":         4,
		"REPAIRING":         5,
		"STOPPED":           6,
		"UPDATING":          7,
		"SUSPENDED":         8,
	}
)

Enum value maps for Instance_State.

DynamicTierOptions_Mode_name, DynamicTierOptions_Mode_value

var (
	DynamicTierOptions_Mode_name = map[int32]string{
		0: "MODE_UNSPECIFIED",
		1: "DISABLED",
		2: "DEFAULT_CACHE",
	}
	DynamicTierOptions_Mode_value = map[string]int32{
		"MODE_UNSPECIFIED": 0,
		"DISABLED":         1,
		"DEFAULT_CACHE":    2,
	}
)

Enum value maps for DynamicTierOptions_Mode.

AccessRulesOptions_SquashMode_name, AccessRulesOptions_SquashMode_value

var (
	AccessRulesOptions_SquashMode_name = map[int32]string{
		0: "SQUASH_MODE_UNSPECIFIED",
		1: "NO_SQUASH",
		2: "ROOT_SQUASH",
	}
	AccessRulesOptions_SquashMode_value = map[string]int32{
		"SQUASH_MODE_UNSPECIFIED": 0,
		"NO_SQUASH":               1,
		"ROOT_SQUASH":             2,
	}
)

Enum value maps for AccessRulesOptions_SquashMode.

RescheduleMaintenanceRequest_RescheduleType_name, RescheduleMaintenanceRequest_RescheduleType_value

var (
	RescheduleMaintenanceRequest_RescheduleType_name = map[int32]string{
		0: "RESCHEDULE_TYPE_UNSPECIFIED",
		1: "IMMEDIATE",
		2: "NEXT_AVAILABLE_WINDOW",
		3: "BY_TIME",
	}
	RescheduleMaintenanceRequest_RescheduleType_value = map[string]int32{
		"RESCHEDULE_TYPE_UNSPECIFIED": 0,
		"IMMEDIATE":                   1,
		"NEXT_AVAILABLE_WINDOW":       2,
		"BY_TIME":                     3,
	}
)

Enum value maps for RescheduleMaintenanceRequest_RescheduleType.

Mirror_Direction_name, Mirror_Direction_value

var (
	Mirror_Direction_name = map[int32]string{
		0: "DIRECTION_UNSPECIFIED",
		1: "FROM_CLOUD_STORAGE",
	}
	Mirror_Direction_value = map[string]int32{
		"DIRECTION_UNSPECIFIED": 0,
		"FROM_CLOUD_STORAGE":    1,
	}
)

Enum value maps for Mirror_Direction.

Mirror_State_name, Mirror_State_value

var (
	Mirror_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "CREATING",
		2: "INITIAL_SYNC",
		3: "DELETING",
		4: "ACTIVE";,
		5: "SUSPENDED",
	}
	Mirror_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"CREATING":          1,
		"INITIAL_SYNC":      2,
		"DELETING":          3,
		"ACTIVE":            4,
		"SUSPENDED":         5,
	}
)

Enum value maps for Mirror_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_directory_policy_proto

var File_google_cloud_lustre_v1_directory_policy_proto protoreflect.FileDescriptor

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_mirror_proto

var File_google_cloud_lustre_v1_mirror_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: "RescheduleMaintenance",
			Handler:    _Lustre_RescheduleMaintenance_Handler,
		},
		{
			MethodName: "ImportData",
			Handler:    _Lustre_ImportData_Handler,
		},
		{
			MethodName: "ExportData",
			Handler:    _Lustre_ExportData_Handler,
		},
		{
			MethodName: "CreateMirror",
			Handler:    _Lustre_CreateMirror_Handler,
		},
		{
			MethodName: "UpdateMirror",
			Handler:    _Lustre_UpdateMirror_Handler,
		},
		{
			MethodName: "DeleteMirror",
			Handler:    _Lustre_DeleteMirror_Handler,
		},
		{
			MethodName: "GetMirror",
			Handler:    _Lustre_GetMirror_Handler,
		},
		{
			MethodName: "ListMirrors",
			Handler:    _Lustre_ListMirrors_Handler,
		},
		{
			MethodName: "CreateDirectoryPolicy",
			Handler:    _Lustre_CreateDirectoryPolicy_Handler,
		},
		{
			MethodName: "DeleteDirectoryPolicy",
			Handler:    _Lustre_DeleteDirectoryPolicy_Handler,
		},
		{
			MethodName: "GetDirectoryPolicy",
			Handler:    _Lustre_GetDirectoryPolicy_Handler,
		},
		{
			MethodName: "ListDirectoryPolicies",
			Handler:    _Lustre_ListDirectoryPolicies_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)

AccessRulesOptions

type AccessRulesOptions struct {

	// Optional. The access rules for the instance.
	AccessRules []*AccessRulesOptions_AccessRule `protobuf:"bytes,1,rep,name=access_rules,json=accessRules,proto3" json:"access_rules,omitempty"`
	// Required. The squash mode for the default access rule.
	DefaultSquashMode AccessRulesOptions_SquashMode `protobuf:"varint,2,opt,name=default_squash_mode,json=defaultSquashMode,proto3,enum=google.cloud.lustre.v1.AccessRulesOptions_SquashMode" json:"default_squash_mode,omitempty"`
	// Optional. The user squash UID for the default access rule.
	// This user squash UID applies to all root users connecting from clients
	// that are not matched by any of the access rules. If not set, the default
	// is 0 (no UID squash).
	DefaultSquashUid int32 `protobuf:"varint,3,opt,name=default_squash_uid,json=defaultSquashUid,proto3" json:"default_squash_uid,omitempty"`
	// Optional. The user squash GID for the default access rule.
	// This user squash GID applies to all root users connecting from clients
	// that are not matched by any of the access rules. If not set, the default
	// is 0 (no GID squash).
	DefaultSquashGid int32 `protobuf:"varint,4,opt,name=default_squash_gid,json=defaultSquashGid,proto3" json:"default_squash_gid,omitempty"`
	// contains filtered or unexported fields
}

IP-based access rules for the Managed Lustre instance. These options define the root user squash configuration.

func (*AccessRulesOptions) Descriptor

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

Deprecated: Use AccessRulesOptions.ProtoReflect.Descriptor instead.

func (*AccessRulesOptions) GetAccessRules

func (x *AccessRulesOptions) GetAccessRules() []*AccessRulesOptions_AccessRule

func (*AccessRulesOptions) GetDefaultSquashGid

func (x *AccessRulesOptions) GetDefaultSquashGid() int32

func (*AccessRulesOptions) GetDefaultSquashMode

func (x *AccessRulesOptions) GetDefaultSquashMode() AccessRulesOptions_SquashMode

func (*AccessRulesOptions) GetDefaultSquashUid

func (x *AccessRulesOptions) GetDefaultSquashUid() int32

func (*AccessRulesOptions) ProtoMessage

func (*AccessRulesOptions) ProtoMessage()

func (*AccessRulesOptions) ProtoReflect

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

func (*AccessRulesOptions) Reset

func (x *AccessRulesOptions) Reset()

func (*AccessRulesOptions) String

func (x *AccessRulesOptions) String() string

AccessRulesOptions_AccessRule

type AccessRulesOptions_AccessRule struct {

	// Required. The name of the access rule policy group.
	// Must be 16 characters or less and include only alphanumeric characters
	// or '_'.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Required. The IP address ranges to which to apply this access rule.
	// Accepts non-overlapping CIDR ranges (e.g., `192.168.1.0/24`) and IP
	// addresses (e.g., `192.168.1.0`).
	IpAddressRanges []string `protobuf:"bytes,2,rep,name=ip_address_ranges,json=ipAddressRanges,proto3" json:"ip_address_ranges,omitempty"`
	// Required. Squash mode for the access rule.
	SquashMode AccessRulesOptions_SquashMode `protobuf:"varint,6,opt,name=squash_mode,json=squashMode,proto3,enum=google.cloud.lustre.v1.AccessRulesOptions_SquashMode" json:"squash_mode,omitempty"`
	// contains filtered or unexported fields
}

A single policy group with IP-based access rules for the Managed Lustre instance.

func (*AccessRulesOptions_AccessRule) Descriptor

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

Deprecated: Use AccessRulesOptions_AccessRule.ProtoReflect.Descriptor instead.

func (*AccessRulesOptions_AccessRule) GetIpAddressRanges

func (x *AccessRulesOptions_AccessRule) GetIpAddressRanges() []string

func (*AccessRulesOptions_AccessRule) GetName

func (x *AccessRulesOptions_AccessRule) GetName() string

func (*AccessRulesOptions_AccessRule) GetSquashMode

func (x *AccessRulesOptions_AccessRule) GetSquashMode() AccessRulesOptions_SquashMode

func (*AccessRulesOptions_AccessRule) ProtoMessage

func (*AccessRulesOptions_AccessRule) ProtoMessage()

func (*AccessRulesOptions_AccessRule) ProtoReflect

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

func (*AccessRulesOptions_AccessRule) Reset

func (x *AccessRulesOptions_AccessRule) Reset()

func (*AccessRulesOptions_AccessRule) String

func (x *AccessRulesOptions_AccessRule) String() string

AccessRulesOptions_SquashMode

type AccessRulesOptions_SquashMode int32

Squash mode for an access rule.

AccessRulesOptions_SQUASH_MODE_UNSPECIFIED, AccessRulesOptions_NO_SQUASH, AccessRulesOptions_ROOT_SQUASH

const (
	// Unspecified squash mode.
	AccessRulesOptions_SQUASH_MODE_UNSPECIFIED AccessRulesOptions_SquashMode = 0
	// Squash is disabled.
	//
	// If set inside an
	// [AccessRule][google.cloud.lustre.v1.AccessRulesOptions.AccessRule], root
	// users matching the [ip_ranges][AccessRule.ip_ranges] are not squashed.
	//
	// If set as the
	// [default_squash_mode][google.cloud.lustre.v1.AccessRulesOptions.default_squash_mode],
	// root squash is disabled for this instance.
	//
	// If the default squash mode is `NO_SQUASH`, do not set the
	// [default_squash_uid][google.cloud.lustre.v1.AccessRulesOptions.default_squash_uid]
	// or
	// [default_squash_gid][google.cloud.lustre.v1.AccessRulesOptions.default_squash_gid],
	// or an `invalid argument` error is returned.
	AccessRulesOptions_NO_SQUASH AccessRulesOptions_SquashMode = 1
	// Root user squash is enabled.
	//
	// Not supported inside an
	// [AccessRule][google.cloud.lustre.v1.AccessRulesOptions.AccessRule].
	//
	// If set as the
	// [default_squash_mode][google.cloud.lustre.v1.AccessRulesOptions.default_squash_mode],
	// root users not matching any of the
	// [access_rules][google.cloud.lustre.v1.AccessRulesOptions.access_rules]
	// are squashed to the
	// [default_squash_uid][google.cloud.lustre.v1.AccessRulesOptions.default_squash_uid]
	// and
	// [default_squash_gid][google.cloud.lustre.v1.AccessRulesOptions.default_squash_gid].
	AccessRulesOptions_ROOT_SQUASH AccessRulesOptions_SquashMode = 2
)

func (AccessRulesOptions_SquashMode) Descriptor

func (AccessRulesOptions_SquashMode) Descriptor() protoreflect.EnumDescriptor

func (AccessRulesOptions_SquashMode) Enum

func (x AccessRulesOptions_SquashMode) Enum() *AccessRulesOptions_SquashMode

func (AccessRulesOptions_SquashMode) EnumDescriptor

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

Deprecated: Use AccessRulesOptions_SquashMode.Descriptor instead.

func (AccessRulesOptions_SquashMode) Number

func (x AccessRulesOptions_SquashMode) Number() protoreflect.EnumNumber

func (AccessRulesOptions_SquashMode) String

func (x AccessRulesOptions_SquashMode) String() string

func (AccessRulesOptions_SquashMode) Type

func (AccessRulesOptions_SquashMode) Type() protoreflect.EnumType

CreateDirectoryPolicyRequest

type CreateDirectoryPolicyRequest struct {

	// Required. The parent instance.
	// It must be in the format of
	// `projects/{project}/locations/{location}/instances/{instance}`.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Required. The ID for the DirectoryPolicy to create.
	DirectoryPolicyId string `protobuf:"bytes,2,opt,name=directory_policy_id,json=directoryPolicyId,proto3" json:"directory_policy_id,omitempty"`
	// Required. The directory policy to create.
	DirectoryPolicy *DirectoryPolicy `protobuf:"bytes,3,opt,name=directory_policy,json=directoryPolicy,proto3" json:"directory_policy,omitempty"`
	// contains filtered or unexported fields
}

Request message for CreateDirectoryPolicy.

func (*CreateDirectoryPolicyRequest) Descriptor

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

Deprecated: Use CreateDirectoryPolicyRequest.ProtoReflect.Descriptor instead.

func (*CreateDirectoryPolicyRequest) GetDirectoryPolicy

func (x *CreateDirectoryPolicyRequest) GetDirectoryPolicy() *DirectoryPolicy

func (*CreateDirectoryPolicyRequest) GetDirectoryPolicyId

func (x *CreateDirectoryPolicyRequest) GetDirectoryPolicyId() string

func (*CreateDirectoryPolicyRequest) GetParent

func (x *CreateDirectoryPolicyRequest) GetParent() string

func (*CreateDirectoryPolicyRequest) ProtoMessage

func (*CreateDirectoryPolicyRequest) ProtoMessage()

func (*CreateDirectoryPolicyRequest) ProtoReflect

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

func (*CreateDirectoryPolicyRequest) Reset

func (x *CreateDirectoryPolicyRequest) Reset()

func (*CreateDirectoryPolicyRequest) String

func (x *CreateDirectoryPolicyRequest) String() string

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

CreateMirrorMetadata

type CreateMirrorMetadata 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 create mirror operation.

func (*CreateMirrorMetadata) Descriptor

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

Deprecated: Use CreateMirrorMetadata.ProtoReflect.Descriptor instead.

func (*CreateMirrorMetadata) GetApiVersion

func (x *CreateMirrorMetadata) GetApiVersion() string

func (*CreateMirrorMetadata) GetCreateTime

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

func (*CreateMirrorMetadata) GetEndTime

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

func (*CreateMirrorMetadata) GetOperationMetadata

func (x *CreateMirrorMetadata) GetOperationMetadata() *TransferOperationMetadata

func (*CreateMirrorMetadata) GetRequestedCancellation

func (x *CreateMirrorMetadata) GetRequestedCancellation() bool

func (*CreateMirrorMetadata) GetStatusMessage

func (x *CreateMirrorMetadata) GetStatusMessage() string

func (*CreateMirrorMetadata) GetTarget

func (x *CreateMirrorMetadata) GetTarget() string

func (*CreateMirrorMetadata) GetVerb

func (x *CreateMirrorMetadata) GetVerb() string

func (*CreateMirrorMetadata) ProtoMessage

func (*CreateMirrorMetadata) ProtoMessage()

func (*CreateMirrorMetadata) ProtoReflect

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

func (*CreateMirrorMetadata) Reset

func (x *CreateMirrorMetadata) Reset()

func (*CreateMirrorMetadata) String

func (x *CreateMirrorMetadata) String() string

CreateMirrorRequest

type CreateMirrorRequest struct {

	// Required. Parent instance resource where the mirror will be created, in the
	// format: `projects/{project}/locations/{location}/instances/{instance}`
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Required. The ID to use for the mirror.
	//
	// * 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.
	//
	// The ID cannot be changed after the mirror is created.
	MirrorId string `protobuf:"bytes,2,opt,name=mirror_id,json=mirrorId,proto3" json:"mirror_id,omitempty"`
	// Required. The mirror to create.
	Mirror *Mirror `protobuf:"bytes,3,opt,name=mirror,proto3" json:"mirror,omitempty"`
	// Optional. The unique 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 guarantees that a
	// request doesn't result in creation of duplicate mirrors for at least 60
	// minutes.
	//
	// 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 mirrors.
	//
	// The request ID must be a valid UUID version 4 with the exception that zero
	// UUID is not supported (`00000000-0000-0000-0000-000000000000`).
	// This request is only idempotent if a `request_id` is provided.
	RequestId string `protobuf:"bytes,4,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// contains filtered or unexported fields
}

Request for CreateMirror.

func (*CreateMirrorRequest) Descriptor

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

Deprecated: Use CreateMirrorRequest.ProtoReflect.Descriptor instead.

func (*CreateMirrorRequest) GetMirror

func (x *CreateMirrorRequest) GetMirror() *Mirror

func (*CreateMirrorRequest) GetMirrorId

func (x *CreateMirrorRequest) GetMirrorId() string

func (*CreateMirrorRequest) GetParent

func (x *CreateMirrorRequest) GetParent() string

func (*CreateMirrorRequest) GetRequestId

func (x *CreateMirrorRequest) GetRequestId() string

func (*CreateMirrorRequest) ProtoMessage

func (*CreateMirrorRequest) ProtoMessage()

func (*CreateMirrorRequest) ProtoReflect

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

func (*CreateMirrorRequest) Reset

func (x *CreateMirrorRequest) Reset()

func (*CreateMirrorRequest) String

func (x *CreateMirrorRequest) String() string

DeleteDirectoryPolicyRequest

type DeleteDirectoryPolicyRequest struct {

	// Required. The resource name of the directory policy.
	// DirectoryPolicy names have the form
	// `projects/{project}/locations/{location}/instances/{instance}/directoryPolicies/{id}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request message for DeleteDirectoryPolicy.

func (*DeleteDirectoryPolicyRequest) Descriptor

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

Deprecated: Use DeleteDirectoryPolicyRequest.ProtoReflect.Descriptor instead.

func (*DeleteDirectoryPolicyRequest) GetName

func (x *DeleteDirectoryPolicyRequest) GetName() string

func (*DeleteDirectoryPolicyRequest) ProtoMessage

func (*DeleteDirectoryPolicyRequest) ProtoMessage()

func (*DeleteDirectoryPolicyRequest) ProtoReflect

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

func (*DeleteDirectoryPolicyRequest) Reset

func (x *DeleteDirectoryPolicyRequest) Reset()

func (*DeleteDirectoryPolicyRequest) String

func (x *DeleteDirectoryPolicyRequest) 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"`
	// Optional. If set to true, any sub-resources from this instance will also be
	// deleted. Otherwise, the request will only work if the instance has no
	// sub-resources.
	Force bool `protobuf:"varint,3,opt,name=force,proto3" json:"force,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) GetForce

func (x *DeleteInstanceRequest) GetForce() bool

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

DeleteMirrorRequest

type DeleteMirrorRequest struct {

	// Required. Name of the mirror to delete, in the format:
	// `projects/{project}/locations/{location}/instances/{instance}/mirrors/{mirror}`
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Optional. The unique 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 guarantees that a
	// request doesn't result in the same delete request being executed for at
	// least 60 minutes.
	//
	// 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.
	//
	// The request ID must be a valid UUID version 4 with the exception that zero
	// UUID is not supported (`00000000-0000-0000-0000-000000000000`).
	// This request is only idempotent if a `request_id` is provided.
	RequestId string `protobuf:"bytes,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// contains filtered or unexported fields
}

Request for DeleteMirror.

func (*DeleteMirrorRequest) Descriptor

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

Deprecated: Use DeleteMirrorRequest.ProtoReflect.Descriptor instead.

func (*DeleteMirrorRequest) GetName

func (x *DeleteMirrorRequest) GetName() string

func (*DeleteMirrorRequest) GetRequestId

func (x *DeleteMirrorRequest) GetRequestId() string

func (*DeleteMirrorRequest) ProtoMessage

func (*DeleteMirrorRequest) ProtoMessage()

func (*DeleteMirrorRequest) ProtoReflect

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

func (*DeleteMirrorRequest) Reset

func (x *DeleteMirrorRequest) Reset()

func (*DeleteMirrorRequest) String

func (x *DeleteMirrorRequest) String() string

DirectoryPolicy

type DirectoryPolicy struct {

	// Immutable. Identifier. The resource name of the directory policy.
	// DirectoryPolicy names have the form
	// `projects/{project}/locations/{location}/instances/{instance}/directoryPolicies/{id}`.
	// {id} is user provided.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Required. Immutable. The lustre instance filesystem full path of the
	// directory. It must start with a slash. e.g. /lustre/testFolder
	DirectoryPath string `protobuf:"bytes,2,opt,name=directory_path,json=directoryPath,proto3" json:"directory_path,omitempty"`
	// Output only. The lustre project ID assigned for the directory by the
	// service. This read-only ID can be used to manage quotas. See more details
	// in
	// https://docs.cloud.google.com/managed-lustre/docs/file-system-quotas#set_quotas
	LustreProjectId int64 `protobuf:"varint,3,opt,name=lustre_project_id,json=lustreProjectId,proto3" json:"lustre_project_id,omitempty"`
	// Output only. Unique ID of the resource.
	Uid string `protobuf:"bytes,4,opt,name=uid,proto3" json:"uid,omitempty"`
	// Output only. The current state of the directory policy.
	State DirectoryPolicy_State `protobuf:"varint,5,opt,name=state,proto3,enum=google.cloud.lustre.v1.DirectoryPolicy_State" json:"state,omitempty"`
	// contains filtered or unexported fields
}

A directory policy for a Managed Lustre instance.

func (*DirectoryPolicy) Descriptor

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

Deprecated: Use DirectoryPolicy.ProtoReflect.Descriptor instead.

func (*DirectoryPolicy) GetDirectoryPath

func (x *DirectoryPolicy) GetDirectoryPath() string

func (*DirectoryPolicy) GetLustreProjectId

func (x *DirectoryPolicy) GetLustreProjectId() int64

func (*DirectoryPolicy) GetName

func (x *DirectoryPolicy) GetName() string

func (*DirectoryPolicy) GetState

func (x *DirectoryPolicy) GetState() DirectoryPolicy_State

func (*DirectoryPolicy) GetUid

func (x *DirectoryPolicy) GetUid() string

func (*DirectoryPolicy) ProtoMessage

func (*DirectoryPolicy) ProtoMessage()

func (*DirectoryPolicy) ProtoReflect

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

func (*DirectoryPolicy) Reset

func (x *DirectoryPolicy) Reset()

func (*DirectoryPolicy) String

func (x *DirectoryPolicy) String() string

DirectoryPolicy_State

type DirectoryPolicy_State int32

State of the directory policy.

DirectoryPolicy_STATE_UNSPECIFIED, DirectoryPolicy_CREATING, DirectoryPolicy_ACTIVE, DirectoryPolicy_DELETING

const (
	// State is unspecified.
	DirectoryPolicy_STATE_UNSPECIFIED DirectoryPolicy_State = 0
	// Directory policy is being created.
	DirectoryPolicy_CREATING DirectoryPolicy_State = 1
	// Directory policy is active and ready to be used.
	DirectoryPolicy_ACTIVE DirectoryPolicy_State = 2
	// Directory policy is being deleted.
	DirectoryPolicy_DELETING DirectoryPolicy_State = 3
)

func (DirectoryPolicy_State) Descriptor

func (DirectoryPolicy_State) Descriptor() protoreflect.EnumDescriptor

func (DirectoryPolicy_State) Enum

func (x DirectoryPolicy_State) Enum() *DirectoryPolicy_State

func (DirectoryPolicy_State) EnumDescriptor

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

Deprecated: Use DirectoryPolicy_State.Descriptor instead.

func (DirectoryPolicy_State) Number

func (x DirectoryPolicy_State) Number() protoreflect.EnumNumber

func (DirectoryPolicy_State) String

func (x DirectoryPolicy_State) String() string

func (DirectoryPolicy_State) Type

func (DirectoryPolicy_State) Type() protoreflect.EnumType

DynamicTierOptions

type DynamicTierOptions struct {

	// Required. Immutable. The dynamic tier mode of the instance.
	Mode DynamicTierOptions_Mode `protobuf:"varint,1,opt,name=mode,proto3,enum=google.cloud.lustre.v1.DynamicTierOptions_Mode" json:"mode,omitempty"`
	// contains filtered or unexported fields
}

Dynamic tier options for a Managed Lustre instance.

func (*DynamicTierOptions) Descriptor

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

Deprecated: Use DynamicTierOptions.ProtoReflect.Descriptor instead.

func (*DynamicTierOptions) GetMode

func (x *DynamicTierOptions) GetMode() DynamicTierOptions_Mode

func (*DynamicTierOptions) ProtoMessage

func (*DynamicTierOptions) ProtoMessage()

func (*DynamicTierOptions) ProtoReflect

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

func (*DynamicTierOptions) Reset

func (x *DynamicTierOptions) Reset()

func (*DynamicTierOptions) String

func (x *DynamicTierOptions) String() string

DynamicTierOptions_Mode

type DynamicTierOptions_Mode int32

Specifies the Dynamic performance tier for the instance.

If this field is set to DEFAULT_CACHE, per_unit_storage_throughput must not be set or must be set to zero.

DynamicTierOptions_MODE_UNSPECIFIED, DynamicTierOptions_DISABLED, DynamicTierOptions_DEFAULT_CACHE

const (
	// Unspecified dynamic tier mode.
	DynamicTierOptions_MODE_UNSPECIFIED DynamicTierOptions_Mode = 0
	// The dynamic tier is explicitly disabled.
	DynamicTierOptions_DISABLED DynamicTierOptions_Mode = 1
	// The dynamic tier is enabled.
	DynamicTierOptions_DEFAULT_CACHE DynamicTierOptions_Mode = 2
)

func (DynamicTierOptions_Mode) Descriptor

func (DynamicTierOptions_Mode) Descriptor() protoreflect.EnumDescriptor

func (DynamicTierOptions_Mode) Enum

func (x DynamicTierOptions_Mode) Enum() *DynamicTierOptions_Mode

func (DynamicTierOptions_Mode) EnumDescriptor

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

Deprecated: Use DynamicTierOptions_Mode.Descriptor instead.

func (DynamicTierOptions_Mode) Number

func (x DynamicTierOptions_Mode) Number() protoreflect.EnumNumber

func (DynamicTierOptions_Mode) String

func (x DynamicTierOptions_Mode) String() string

func (DynamicTierOptions_Mode) Type

func (DynamicTierOptions_Mode) Type() protoreflect.EnumType

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 valid to be assigned to Source:
	//
	//	*ExportDataRequest_LustrePath
	Source isExportDataRequest_Source `protobuf_oneof:"source"`
	// The destination of the data transfer.
	//
	// Types that are valid to be assigned 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.
	//
	// Use one of the following formats:
	//
	// * `{EMAIL_ADDRESS_OR_UNIQUE_ID}`
	// * `projects/{PROJECT_ID}/serviceAccounts/{EMAIL_ADDRESS_OR_UNIQUE_ID}`
	// * `projects/-/serviceAccounts/{EMAIL_ADDRESS_OR_UNIQUE_ID}`
	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 (x *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 (x *ExportDataRequest) GetSource() isExportDataRequest_Source

func (*ExportDataRequest) ProtoMessage

func (*ExportDataRequest) ProtoMessage()

func (*ExportDataRequest) ProtoReflect

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

func (*ExportDataRequest) Reset

func (x *ExportDataRequest) Reset()

func (*ExportDataRequest) String

func (x *ExportDataRequest) String() string

ExportDataRequest_GcsPath

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

ExportDataRequest_LustrePath

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

ExportDataResponse

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

Response message for ExportData.

func (*ExportDataResponse) Descriptor

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

Deprecated: Use ExportDataResponse.ProtoReflect.Descriptor instead.

func (*ExportDataResponse) ProtoMessage

func (*ExportDataResponse) ProtoMessage()

func (*ExportDataResponse) ProtoReflect

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

func (*ExportDataResponse) Reset

func (x *ExportDataResponse) Reset()

func (*ExportDataResponse) String

func (x *ExportDataResponse) String() string

GcsPath

type GcsPath struct {

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

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

func (*GcsPath) Descriptor

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

Deprecated: Use GcsPath.ProtoReflect.Descriptor instead.

func (*GcsPath) GetUri

func (x *GcsPath) GetUri() string

func (*GcsPath) ProtoMessage

func (*GcsPath) ProtoMessage()

func (*GcsPath) ProtoReflect

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

func (*GcsPath) Reset

func (x *GcsPath) Reset()

func (*GcsPath) String

func (x *GcsPath) String() string

GetDirectoryPolicyRequest

type GetDirectoryPolicyRequest struct {

	// Required. The resource name of the directory policy.
	// DirectoryPolicy names have the form
	// `projects/{project}/locations/{location}/instances/{instance}/directoryPolicies/{id}`.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request message for GetDirectoryPolicy.

func (*GetDirectoryPolicyRequest) Descriptor

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

Deprecated: Use GetDirectoryPolicyRequest.ProtoReflect.Descriptor instead.

func (*GetDirectoryPolicyRequest) GetName

func (x *GetDirectoryPolicyRequest) GetName() string

func (*GetDirectoryPolicyRequest) ProtoMessage

func (*GetDirectoryPolicyRequest) ProtoMessage()

func (*GetDirectoryPolicyRequest) ProtoReflect

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

func (*GetDirectoryPolicyRequest) Reset

func (x *GetDirectoryPolicyRequest) Reset()

func (*GetDirectoryPolicyRequest) String

func (x *GetDirectoryPolicyRequest) String() string

GetInstanceRequest

type GetInstanceRequest struct {

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

Message for getting a Instance

func (*GetInstanceRequest) Descriptor

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

Deprecated: Use GetInstanceRequest.ProtoReflect.Descriptor instead.

func (*GetInstanceRequest) GetName

func (x *GetInstanceRequest) GetName() string

func (*GetInstanceRequest) ProtoMessage

func (*GetInstanceRequest) ProtoMessage()

func (*GetInstanceRequest) ProtoReflect

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

func (*GetInstanceRequest) Reset

func (x *GetInstanceRequest) Reset()

func (*GetInstanceRequest) String

func (x *GetInstanceRequest) String() string

GetMirrorRequest

type GetMirrorRequest struct {

	// Required. Name of the mirror to retrieve, in the format:
	// `projects/{project}/locations/{location}/instances/{instance}/mirrors/{mirror}`
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request for GetMirror.

func (*GetMirrorRequest) Descriptor

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

Deprecated: Use GetMirrorRequest.ProtoReflect.Descriptor instead.

func (*GetMirrorRequest) GetName

func (x *GetMirrorRequest) GetName() string

func (*GetMirrorRequest) ProtoMessage

func (*GetMirrorRequest) ProtoMessage()

func (*GetMirrorRequest) ProtoReflect

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

func (*GetMirrorRequest) Reset

func (x *GetMirrorRequest) Reset()

func (*GetMirrorRequest) String

func (x *GetMirrorRequest) 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 (x *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 (x *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 depend on the `perUnitStorageThroughput`. See [Performance
	// tiers](https://docs.cloud.google.com/managed-lustre/docs/performance-tiers)
	// for specific minimums, maximums, and step sizes for each performance tier.
	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" protobuf_val:"bytes,2,opt,name=value"`
	// Optional. The throughput of the instance in MBps per TiB. Valid values are
	// 0, 125, 250, 500, 1000. See [Performance
	// tiers](https://docs.cloud.google.com/managed-lustre/docs/performance-tiers)
	// for more information.
	//
	// If the instance is using the Dynamic tier, this field must not be set or
	// must be set to zero.
	PerUnitStorageThroughput int64 `protobuf:"varint,11,opt,name=per_unit_storage_throughput,json=perUnitStorageThroughput,proto3" json:"per_unit_storage_throughput,omitempty"`
	// Optional. Deprecated: No longer required for GKE instance creation.
	// Indicates whether you want to enable support for GKE clients. By default,
	// GKE clients are not supported.
	//
	// 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"`
	// Optional. Immutable. The Cloud KMS key name to use for data encryption.
	// If not set, the instance will use Google-managed encryption keys.
	// If set, the instance will use customer-managed encryption keys.
	// The key must be in the same region as the instance.
	// The key format is:
	// projects/{project}/locations/{location}/keyRings/{key_ring}/cryptoKeys/{key}
	KmsKey string `protobuf:"bytes,13,opt,name=kms_key,json=kmsKey,proto3" json:"kms_key,omitempty"`
	// Output only. The reason why the instance is in a certain state (e.g.
	// SUSPENDED).
	StateReason string `protobuf:"bytes,14,opt,name=state_reason,json=stateReason,proto3" json:"state_reason,omitempty"`
	// Optional. The placement policy name for the instance in the format of
	// projects/{project}/locations/{location}/resourcePolicies/{resource_policy}
	PlacementPolicy string `protobuf:"bytes,17,opt,name=placement_policy,json=placementPolicy,proto3" json:"placement_policy,omitempty"`
	// Optional. The access rules options for the instance.
	AccessRulesOptions *AccessRulesOptions `protobuf:"bytes,18,opt,name=access_rules_options,json=accessRulesOptions,proto3" json:"access_rules_options,omitempty"`
	// Output only. Unique ID of the resource.
	// This is unrelated to the access rules which allow specifying the root
	// squash uid.
	Uid string `protobuf:"bytes,19,opt,name=uid,proto3" json:"uid,omitempty"`
	// Optional. The maintenance policy for the instance to determine when to
	// allow or exclude the instance from maintenance updates.
	MaintenancePolicy *MaintenancePolicy `protobuf:"bytes,20,opt,name=maintenance_policy,json=maintenancePolicy,proto3" json:"maintenance_policy,omitempty"`
	// Output only. Date and time of upcoming maintenance for the instance, if a
	// maintenance policy is set.
	UpcomingMaintenanceSchedule *MaintenanceSchedule `protobuf:"bytes,21,opt,name=upcoming_maintenance_schedule,json=upcomingMaintenanceSchedule,proto3" json:"upcoming_maintenance_schedule,omitempty"`
	// Optional. Immutable. Specifies whether the instance is on the Dynamic tier.
	// See [Performance
	// tiers](https://docs.cloud.google.com/managed-lustre/docs/performance-tiers)
	// for more information.
	DynamicTierOptions *DynamicTierOptions `protobuf:"bytes,24,opt,name=dynamic_tier_options,json=dynamicTierOptions,proto3" json:"dynamic_tier_options,omitempty"`
	// Output only. The available version that this instance can be upgraded to.
	// Format: `Lustre_YYYYMMDD.NN_pXX`
	AvailableVersion *string `protobuf:"bytes,33,opt,name=available_version,json=availableVersion,proto3,oneof" json:"available_version,omitempty"`
	// Optional. The target version of the instance. Setting this field triggers a
	// self-service update to the specified version.
	// Format: `Lustre_YYYYMMDD.NN_pXX` or `latest`
	TargetVersion *string `protobuf:"bytes,34,opt,name=target_version,json=targetVersion,proto3,oneof" json:"target_version,omitempty"`
	// Output only. The effective version of the instance.
	// Format: `Lustre_YYYYMMDD.NN_pXX`
	EffectiveVersion *string `protobuf:"bytes,35,opt,name=effective_version,json=effectiveVersion,proto3,oneof" json:"effective_version,omitempty"`
	// contains filtered or unexported fields
}

A Managed Lustre instance.

func (*Instance) Descriptor

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

Deprecated: Use Instance.ProtoReflect.Descriptor instead.

func (*Instance) GetAccessRulesOptions

func (x *Instance) GetAccessRulesOptions() *AccessRulesOptions

func (*Instance) GetAvailableVersion

func (x *Instance) GetAvailableVersion() string

func (*Instance) GetCapacityGib

func (x *Instance) GetCapacityGib() int64

func (*Instance) GetCreateTime

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

func (*Instance) GetDescription

func (x *Instance) GetDescription() string

func (*Instance) GetDynamicTierOptions

func (x *Instance) GetDynamicTierOptions() *DynamicTierOptions

func (*Instance) GetEffectiveVersion

func (x *Instance) GetEffectiveVersion() string

func (*Instance) GetFilesystem

func (x *Instance) GetFilesystem() string

func (*Instance) GetGkeSupportEnabled

func (x *Instance) GetGkeSupportEnabled() bool

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

func (*Instance) GetKmsKey

func (x *Instance) GetKmsKey() string

func (*Instance) GetLabels

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

func (*Instance) GetMaintenancePolicy

func (x *Instance) GetMaintenancePolicy() *MaintenancePolicy

func (*Instance) GetMountPoint

func (x *Instance) GetMountPoint() string

func (*Instance) GetName

func (x *Instance) GetName() string

func (*Instance) GetNetwork

func (x *Instance) GetNetwork() string

func (*Instance) GetPerUnitStorageThroughput

func (x *Instance) GetPerUnitStorageThroughput() int64

func (*Instance) GetPlacementPolicy

func (x *Instance) GetPlacementPolicy() string

func (*Instance) GetState

func (x *Instance) GetState() Instance_State

func (*Instance) GetStateReason

func (x *Instance) GetStateReason() string

func (*Instance) GetTargetVersion

func (x *Instance) GetTargetVersion() string

func (*Instance) GetUid

func (x *Instance) GetUid() string

func (*Instance) GetUpcomingMaintenanceSchedule

func (x *Instance) GetUpcomingMaintenanceSchedule() *MaintenanceSchedule

func (*Instance) GetUpdateTime

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

func (*Instance) ProtoMessage

func (*Instance) ProtoMessage()

func (*Instance) ProtoReflect

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

func (*Instance) Reset

func (x *Instance) Reset()

func (*Instance) String

func (x *Instance) String() string

Instance_State

type Instance_State int32

The possible states of an instance.

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

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.
	//
	// Deprecated: Marked as deprecated in google/cloud/lustre/v1/instance.proto.
	Instance_UPDATING Instance_State = 7
	// The instance is suspended due to an issue related to Cloud KMS. The
	// details are available in
	// [state_reason][google.cloud.lustre.v1.Instance.state_reason].
	Instance_SUSPENDED Instance_State = 8
)

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

ListDirectoryPoliciesRequest

type ListDirectoryPoliciesRequest struct {

	// Required. The parent instance.
	// It must be in the format of
	// `projects/{project}/locations/{location}/instances/{instance}`.
	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. The
	// maximum value is 1000; values above 1000 will be coerced to 1000.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Optional. A page token, received from a previous `ListDirectoryPolicies`
	// call. Provide this to retrieve the subsequent page. When paginating, all
	// other parameters provided to `ListDirectoryPolicies` must match the call
	// that provided the page token.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

Request message for ListDirectoryPolicies.

func (*ListDirectoryPoliciesRequest) Descriptor

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

Deprecated: Use ListDirectoryPoliciesRequest.ProtoReflect.Descriptor instead.

func (*ListDirectoryPoliciesRequest) GetPageSize

func (x *ListDirectoryPoliciesRequest) GetPageSize() int32

func (*ListDirectoryPoliciesRequest) GetPageToken

func (x *ListDirectoryPoliciesRequest) GetPageToken() string

func (*ListDirectoryPoliciesRequest) GetParent

func (x *ListDirectoryPoliciesRequest) GetParent() string

func (*ListDirectoryPoliciesRequest) ProtoMessage

func (*ListDirectoryPoliciesRequest) ProtoMessage()

func (*ListDirectoryPoliciesRequest) ProtoReflect

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

func (*ListDirectoryPoliciesRequest) Reset

func (x *ListDirectoryPoliciesRequest) Reset()

func (*ListDirectoryPoliciesRequest) String

func (x *ListDirectoryPoliciesRequest) String() string

ListDirectoryPoliciesResponse

type ListDirectoryPoliciesResponse struct {

	// The list of DirectoryPolicies.
	DirectoryPolicies []*DirectoryPolicy `protobuf:"bytes,1,rep,name=directory_policies,json=directoryPolicies,proto3" json:"directory_policies,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"`
	// contains filtered or unexported fields
}

Response message for ListDirectoryPolicies.

func (*ListDirectoryPoliciesResponse) Descriptor

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

Deprecated: Use ListDirectoryPoliciesResponse.ProtoReflect.Descriptor instead.

func (*ListDirectoryPoliciesResponse) GetDirectoryPolicies

func (x *ListDirectoryPoliciesResponse) GetDirectoryPolicies() []*DirectoryPolicy

func (*ListDirectoryPoliciesResponse) GetNextPageToken

func (x *ListDirectoryPoliciesResponse) GetNextPageToken() string

func (*ListDirectoryPoliciesResponse) ProtoMessage

func (*ListDirectoryPoliciesResponse) ProtoMessage()

func (*ListDirectoryPoliciesResponse) ProtoReflect

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

func (*ListDirectoryPoliciesResponse) Reset

func (x *ListDirectoryPoliciesResponse) Reset()

func (*ListDirectoryPoliciesResponse) String

func (x *ListDirectoryPoliciesResponse) String() string

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

ListMirrorsRequest

type ListMirrorsRequest struct {

	// Required. Parent instance resource where the mirrors will be listed, in the
	// format: `projects/{project}/locations/{location}/instances/{instance}`
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Optional. Requested page size. The server might return fewer items than
	// requested. If unspecified, the default page size is 10. The maximum value
	// is 1000.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Optional. A page token, received from a previous `ListMirrors` call.
	// Provide this to retrieve the subsequent page.
	// When paginating, all other parameters provided to `ListMirrors` must match
	// the call that provided the page token.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// Optional. Desired order of results.
	OrderBy string `protobuf:"bytes,4,opt,name=order_by,json=orderBy,proto3"; json:"order_by,omitempty"`
	// Optional. Filtering results.
	Filter string `protobuf:"bytes,5,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

Request for ListMirrors.

func (*ListMirrorsRequest) Descriptor

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

Deprecated: Use ListMirrorsRequest.ProtoReflect.Descriptor instead.

func (*ListMirrorsRequest) GetFilter

func (x *ListMirrorsRequest) GetFilter() string

func (*ListMirrorsRequest) GetOrderBy

func (x *ListMirrorsRequest) GetOrderBy() string

func (*ListMirrorsRequest) GetPageSize

func (x *ListMirrorsRequest) GetPageSize() int32

func (*ListMirrorsRequest) GetPageToken

func (x *ListMirrorsRequest) GetPageToken() string

func (*ListMirrorsRequest) GetParent

func (x *ListMirrorsRequest) GetParent() string

func (*ListMirrorsRequest) ProtoMessage

func (*ListMirrorsRequest) ProtoMessage()

func (*ListMirrorsRequest) ProtoReflect

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

func (*ListMirrorsRequest) Reset

func (x *ListMirrorsRequest) Reset()

func (*ListMirrorsRequest) String

func (x *ListMirrorsRequest) String() string

ListMirrorsResponse

type ListMirrorsResponse struct {

	// List of mirrors on the instance.
	Mirrors []*Mirror `protobuf:"bytes,1,rep,name=mirrors,proto3" json:"mirrors,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
}

Response for ListMirrors.

func (*ListMirrorsResponse) Descriptor

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

Deprecated: Use ListMirrorsResponse.ProtoReflect.Descriptor instead.

func (*ListMirrorsResponse) GetMirrors

func (x *ListMirrorsResponse) GetMirrors() []*Mirror

func (*ListMirrorsResponse) GetNextPageToken

func (x *ListMirrorsResponse) GetNextPageToken() string

func (*ListMirrorsResponse) GetUnreachable

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

func (*ListMirrorsResponse) ProtoMessage

func (*ListMirrorsResponse) ProtoMessage()

func (*ListMirrorsResponse) ProtoReflect

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

func (*ListMirrorsResponse) Reset

func (x *ListMirrorsResponse) Reset()

func (*ListMirrorsResponse) String

func (x *ListMirrorsResponse) 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)
	// Reschedules a planned maintenance event for a specific instance.
	RescheduleMaintenance(ctx context.Context, in *RescheduleMaintenanceRequest, 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)
	// Creates a new mirror in a given instance.
	CreateMirror(ctx context.Context, in *CreateMirrorRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Updates the parameters of a single mirror.
	UpdateMirror(ctx context.Context, in *UpdateMirrorRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Deletes a single mirror.
	DeleteMirror(ctx context.Context, in *DeleteMirrorRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Gets details of a single mirror.
	GetMirror(ctx context.Context, in *GetMirrorRequest, opts ...grpc.CallOption) (*Mirror, error)
	// Gets details of multiple mirrors under a given instance.
	ListMirrors(ctx context.Context, in *ListMirrorsRequest, opts ...grpc.CallOption) (*ListMirrorsResponse, error)
	// Creates a directory policy resource.
	CreateDirectoryPolicy(ctx context.Context, in *CreateDirectoryPolicyRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Deletes a directory policy resource.
	DeleteDirectoryPolicy(ctx context.Context, in *DeleteDirectoryPolicyRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Gets details of a single directory policy.
	GetDirectoryPolicy(ctx context.Context, in *GetDirectoryPolicyRequest, opts ...grpc.CallOption) (*DirectoryPolicy, error)
	// Gets details of multiple directory policies under a given instance.
	ListDirectoryPolicies(ctx context.Context, in *ListDirectoryPoliciesRequest, opts ...grpc.CallOption) (*ListDirectoryPoliciesResponse, 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)
	// Reschedules a planned maintenance event for a specific instance.
	RescheduleMaintenance(context.Context, *RescheduleMaintenanceRequest) (*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)
	// Creates a new mirror in a given instance.
	CreateMirror(context.Context, *CreateMirrorRequest) (*longrunningpb.Operation, error)
	// Updates the parameters of a single mirror.
	UpdateMirror(context.Context, *UpdateMirrorRequest) (*longrunningpb.Operation, error)
	// Deletes a single mirror.
	DeleteMirror(context.Context, *DeleteMirrorRequest) (*longrunningpb.Operation, error)
	// Gets details of a single mirror.
	GetMirror(context.Context, *GetMirrorRequest) (*Mirror, error)
	// Gets details of multiple mirrors under a given instance.
	ListMirrors(context.Context, *ListMirrorsRequest) (*ListMirrorsResponse, error)
	// Creates a directory policy resource.
	CreateDirectoryPolicy(context.Context, *CreateDirectoryPolicyRequest) (*longrunningpb.Operation, error)
	// Deletes a directory policy resource.
	DeleteDirectoryPolicy(context.Context, *DeleteDirectoryPolicyRequest) (*longrunningpb.Operation, error)
	// Gets details of a single directory policy.
	GetDirectoryPolicy(context.Context, *GetDirectoryPolicyRequest) (*DirectoryPolicy, error)
	// Gets details of multiple directory policies under a given instance.
	ListDirectoryPolicies(context.Context, *ListDirectoryPoliciesRequest) (*ListDirectoryPoliciesResponse, error)
}

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

MaintenancePolicy

type MaintenancePolicy struct {

	// Required. The weekly maintenance windows for the instance. Currently
	// limited to 1 window.
	WeeklyMaintenanceWindows []*MaintenancePolicy_WeeklyMaintenanceWindow `protobuf:"bytes,3,rep,name=weekly_maintenance_windows,json=weeklyMaintenanceWindows,proto3" json:"weekly_maintenance_windows,omitempty"`
	// Optional. The exclusion windows for the instance. Currently limited to 1
	// window.
	MaintenanceExclusionWindow []*MaintenancePolicy_MaintenanceExclusionWindow `protobuf:"bytes,4,rep,name=maintenance_exclusion_window,json=maintenanceExclusionWindow,proto3" json:"maintenance_exclusion_window,omitempty"`
	// contains filtered or unexported fields
}

Defines a maintenance policy for a resource.

func (*MaintenancePolicy) Descriptor

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

Deprecated: Use MaintenancePolicy.ProtoReflect.Descriptor instead.

func (*MaintenancePolicy) GetMaintenanceExclusionWindow

func (x *MaintenancePolicy) GetMaintenanceExclusionWindow() []*MaintenancePolicy_MaintenanceExclusionWindow

func (*MaintenancePolicy) GetWeeklyMaintenanceWindows

func (x *MaintenancePolicy) GetWeeklyMaintenanceWindows() []*MaintenancePolicy_WeeklyMaintenanceWindow

func (*MaintenancePolicy) ProtoMessage

func (*MaintenancePolicy) ProtoMessage()

func (*MaintenancePolicy) ProtoReflect

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

func (*MaintenancePolicy) Reset

func (x *MaintenancePolicy) Reset()

func (*MaintenancePolicy) String

func (x *MaintenancePolicy) String() string

MaintenancePolicy_MaintenanceExclusionWindow

type MaintenancePolicy_MaintenanceExclusionWindow struct {

	// Required. Start date of the exclusion period in UTC time zone. This date
	// is inclusive.
	StartDate *date.Date `protobuf:"bytes,1,opt,name=start_date,json=startDate,proto3" json:"start_date,omitempty"`
	// Required. End date of the exclusion period in UTC time zone. This date is
	// inclusive.
	EndDate *date.Date `protobuf:"bytes,2,opt,name=end_date,json=endDate,proto3" json:"end_date,omitempty"`
	// Required. Time in UTC when the exclusion window starts on start_date and
	// ends on end_date. This can be:
	// * Full time OR
	// * All zeros for 00:00:00 UTC
	Time *timeofday.TimeOfDay `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

Exclusion period when maintenance updates should not occur. An exclusion window can be in either of the following two formats:

• Non-recurring : A full date, with non-zero year, month and day values.
• Recurring : A month and day value, with a zero year. Time zone is UTC.

func (*MaintenancePolicy_MaintenanceExclusionWindow) Descriptor

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

Deprecated: Use MaintenancePolicy_MaintenanceExclusionWindow.ProtoReflect.Descriptor instead.

func (*MaintenancePolicy_MaintenanceExclusionWindow) GetEndDate

func (x *MaintenancePolicy_MaintenanceExclusionWindow) GetEndDate() *date.Date

func (*MaintenancePolicy_MaintenanceExclusionWindow) GetStartDate

func (x *MaintenancePolicy_MaintenanceExclusionWindow) GetStartDate() *date.Date

func (*MaintenancePolicy_MaintenanceExclusionWindow) GetTime

func (x *MaintenancePolicy_MaintenanceExclusionWindow) GetTime() *timeofday.TimeOfDay

func (*MaintenancePolicy_MaintenanceExclusionWindow) ProtoMessage

func (*MaintenancePolicy_MaintenanceExclusionWindow) ProtoMessage()

func (*MaintenancePolicy_MaintenanceExclusionWindow) ProtoReflect

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

func (*MaintenancePolicy_MaintenanceExclusionWindow) Reset

func (x *MaintenancePolicy_MaintenanceExclusionWindow) Reset()

func (*MaintenancePolicy_MaintenanceExclusionWindow) String

func (x *MaintenancePolicy_MaintenanceExclusionWindow) String() string

MaintenancePolicy_WeeklyMaintenanceWindow

type MaintenancePolicy_WeeklyMaintenanceWindow struct {

	// Required. Day of the week for the maintenance window.
	DayOfWeek dayofweek.DayOfWeek `protobuf:"varint,1,opt,name=day_of_week,json=dayOfWeek,proto3,enum=google.type.DayOfWeek" json:"day_of_week,omitempty"`
	// Required. Start time of the maintenance window in UTC time zone.
	StartTime *timeofday.TimeOfDay `protobuf:"bytes,2,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// contains filtered or unexported fields
}

Weekly time window in which maintenance updates may occur. Duration of the window is currently fixed at 1 hour. Time zone is UTC.

func (*MaintenancePolicy_WeeklyMaintenanceWindow) Descriptor

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

Deprecated: Use MaintenancePolicy_WeeklyMaintenanceWindow.ProtoReflect.Descriptor instead.

func (*MaintenancePolicy_WeeklyMaintenanceWindow) GetDayOfWeek

func (x *MaintenancePolicy_WeeklyMaintenanceWindow) GetDayOfWeek() dayofweek.DayOfWeek

func (*MaintenancePolicy_WeeklyMaintenanceWindow) GetStartTime

func (x *MaintenancePolicy_WeeklyMaintenanceWindow) GetStartTime() *timeofday.TimeOfDay

func (*MaintenancePolicy_WeeklyMaintenanceWindow) ProtoMessage

func (*MaintenancePolicy_WeeklyMaintenanceWindow) ProtoMessage()

func (*MaintenancePolicy_WeeklyMaintenanceWindow) ProtoReflect

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

func (*MaintenancePolicy_WeeklyMaintenanceWindow) Reset

func (x *MaintenancePolicy_WeeklyMaintenanceWindow) Reset()

func (*MaintenancePolicy_WeeklyMaintenanceWindow) String

func (x *MaintenancePolicy_WeeklyMaintenanceWindow) String() string

MaintenanceSchedule

type MaintenanceSchedule struct {

	// Output only. The scheduled start time for the maintenance.
	StartTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// Output only. The scheduled end time for the maintenance.
	EndTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// contains filtered or unexported fields
}

Represents a scheduled maintenance event.

func (*MaintenanceSchedule) Descriptor

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

Deprecated: Use MaintenanceSchedule.ProtoReflect.Descriptor instead.

func (*MaintenanceSchedule) GetEndTime

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

func (*MaintenanceSchedule) GetStartTime

func (x *MaintenanceSchedule) GetStartTime() *timestamppb.Timestamp

func (*MaintenanceSchedule) ProtoMessage

func (*MaintenanceSchedule) ProtoMessage()

func (*MaintenanceSchedule) ProtoReflect

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

func (*MaintenanceSchedule) Reset

func (x *MaintenanceSchedule) Reset()

func (*MaintenanceSchedule) String

func (x *MaintenanceSchedule) String() string

Mirror

type Mirror struct {

	// Identifier. Name of the mirror.
	// Format:
	// `projects/{project}/locations/{location}/instances/{instance}/mirrors/{mirror}`
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Required. Immutable. The URI to a Cloud Storage bucket, or a path within a
	// bucket, using the format `gs://{BUCKET_NAME}/{OPTIONAL_PATH}/`. If a path
	// inside the bucket is specified, it must end with a forward slash (`/`).
	GcsPath *GcsPath `protobuf:"bytes,3,opt,name=gcs_path,json=gcsPath,proto3" json:"gcs_path,omitempty"`
	// Required. Immutable. The Managed Lustre directory to mirror to. Must be an
	// absolute path starting with `/`, for example `/data` or `/data/subdir`.
	// Defaults to the root directory, `/`. If the specified directory doesn't
	// exist, it is created.
	LustrePath *LustrePath `protobuf:"bytes,4,opt,name=lustre_path,json=lustrePath,proto3" json:"lustre_path,omitempty"`
	// Required. Immutable. Represents the direction of the mirror.
	Direction Mirror_Direction `protobuf:"varint,5,opt,name=direction,proto3,enum=google.cloud.lustre.v1.Mirror_Direction" json:"direction,omitempty"`
	// Optional. If `true`, files are not deleted from Managed Lustre when the
	// source files are deleted from Cloud Storage. Default is `false`.
	DeletedFilesRetained bool `protobuf:"varint,6,opt,name=deleted_files_retained,json=deletedFilesRetained,proto3" json:"deleted_files_retained,omitempty"`
	// Optional. Description of the mirror.
	Description string `protobuf:"bytes,7,opt,name=description,proto3" json:"description,omitempty"`
	// Optional. Labels to apply to the mirror.
	Labels map[string]string `protobuf:"bytes,8,rep,name=labels,proto3" json:"labels,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
	// Output only. [Output only] Create time stamp.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Output only. [Output only] Update time stamp.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,10,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// Output only. Unique ID of the resource.
	Uid string `protobuf:"bytes,11,opt,name=uid,proto3" json:"uid,omitempty"`
	// Output only. [Output only] The current state of the mirror.
	State Mirror_State `protobuf:"varint,12,opt,name=state,proto3,enum=google.cloud.lustre.v1.Mirror_State" json:"state,omitempty"`
	// contains filtered or unexported fields
}

Represents a Cloud Storage mirror.

func (*Mirror) Descriptor

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

Deprecated: Use Mirror.ProtoReflect.Descriptor instead.

func (*Mirror) GetCreateTime

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

func (*Mirror) GetDeletedFilesRetained

func (x *Mirror) GetDeletedFilesRetained() bool

func (*Mirror) GetDescription

func (x *Mirror) GetDescription() string

func (*Mirror) GetDirection

func (x *Mirror) GetDirection() Mirror_Direction

func (*Mirror) GetGcsPath

func (x *Mirror) GetGcsPath() *GcsPath

func (*Mirror) GetLabels

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

func (*Mirror) GetLustrePath

func (x *Mirror) GetLustrePath() *LustrePath

func (*Mirror) GetName

func (x *Mirror) GetName() string

func (*Mirror) GetState

func (x *Mirror) GetState() Mirror_State

func (*Mirror) GetUid

func (x *Mirror) GetUid() string

func (*Mirror) GetUpdateTime

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

func (*Mirror) ProtoMessage

func (*Mirror) ProtoMessage()

func (*Mirror) ProtoReflect

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

func (*Mirror) Reset

func (x *Mirror) Reset()

func (*Mirror) String

func (x *Mirror) String() string

Mirror_Direction

type Mirror_Direction int32

Represents the direction of the mirror. This enum expects to be extended in future with new mirror types.

Mirror_DIRECTION_UNSPECIFIED, Mirror_FROM_CLOUD_STORAGE

const (
	// Invalid value.
	Mirror_DIRECTION_UNSPECIFIED Mirror_Direction = 0
	// Mirror from Cloud Storage to Lustre.
	Mirror_FROM_CLOUD_STORAGE Mirror_Direction = 1
)

func (Mirror_Direction) Descriptor

func (Mirror_Direction) Descriptor() protoreflect.EnumDescriptor

func (Mirror_Direction) Enum

func (x Mirror_Direction) Enum() *Mirror_Direction

func (Mirror_Direction) EnumDescriptor

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

Deprecated: Use Mirror_Direction.Descriptor instead.

func (Mirror_Direction) Number

func (x Mirror_Direction) Number() protoreflect.EnumNumber

func (Mirror_Direction) String

func (x Mirror_Direction) String() string

func (Mirror_Direction) Type

func (Mirror_Direction) Type() protoreflect.EnumType

Mirror_State

type Mirror_State int32

State of the mirror.

Mirror_STATE_UNSPECIFIED, Mirror_CREATING, Mirror_INITIAL_SYNC, Mirror_DELETING, Mirror_ACTIVE, Mirror_SUSPENDED

const (
	// State is unspecified.
	Mirror_STATE_UNSPECIFIED Mirror_State = 0
	// The mirror resource is being created.
	Mirror_CREATING Mirror_State = 1
	// The initial sync is copying existing objects from Cloud Storage.
	Mirror_INITIAL_SYNC Mirror_State = 2
	// The mirror is being deleted.
	Mirror_DELETING Mirror_State = 3
	// The mirror is synchronizing changes as they occur.
	Mirror_ACTIVE Mirror_State = 4
	// Synchronization is paused because the file system is close to capacity.
	Mirror_SUSPENDED Mirror_State = 5
)

func (Mirror_State) Descriptor

func (Mirror_State) Descriptor() protoreflect.EnumDescriptor

func (Mirror_State) Enum

func (x Mirror_State) Enum() *Mirror_State

func (Mirror_State) EnumDescriptor

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

Deprecated: Use Mirror_State.Descriptor instead.

func (Mirror_State) Number

func (x Mirror_State) Number() protoreflect.EnumNumber

func (Mirror_State) String

func (x Mirror_State) String() string

func (Mirror_State) Type

func (Mirror_State) Type() protoreflect.EnumType

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

RescheduleMaintenanceRequest

type RescheduleMaintenanceRequest struct {

	// Required. Format:
	// projects/{project}/locations/{location}/instances/{instance}
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Required. The desired reschedule settings.
	Reschedule *RescheduleMaintenanceRequest_Reschedule `protobuf:"bytes,2,opt,name=reschedule,proto3" json:"reschedule,omitempty"`
	// Optional. A unique identifier for this request. A random UUID is
	// recommended. This request is only idempotent if a `request_id` is provided.
	RequestId string `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// contains filtered or unexported fields
}

Message for requesting to reschedule a maintenance event for a specific instance.

func (*RescheduleMaintenanceRequest) Descriptor

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

Deprecated: Use RescheduleMaintenanceRequest.ProtoReflect.Descriptor instead.

func (*RescheduleMaintenanceRequest) GetName

func (x *RescheduleMaintenanceRequest) GetName() string

func (*RescheduleMaintenanceRequest) GetRequestId

func (x *RescheduleMaintenanceRequest) GetRequestId() string

func (*RescheduleMaintenanceRequest) GetReschedule

func (x *RescheduleMaintenanceRequest) GetReschedule() *RescheduleMaintenanceRequest_Reschedule

func (*RescheduleMaintenanceRequest) ProtoMessage

func (*RescheduleMaintenanceRequest) ProtoMessage()

func (*RescheduleMaintenanceRequest) ProtoReflect

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

func (*RescheduleMaintenanceRequest) Reset

func (x *RescheduleMaintenanceRequest) Reset()

func (*RescheduleMaintenanceRequest) String

func (x *RescheduleMaintenanceRequest) String() string

RescheduleMaintenanceRequest_Reschedule

type RescheduleMaintenanceRequest_Reschedule struct {

	// Required. The type of rescheduling.
	RescheduleType RescheduleMaintenanceRequest_RescheduleType `protobuf:"varint,1,opt,name=reschedule_type,json=rescheduleType,proto3,enum=google.cloud.lustre.v1.RescheduleMaintenanceRequest_RescheduleType" json:"reschedule_type,omitempty"`
	// Optional. Required if reschedule_type is BY_TIME. Timestamp when the
	// maintenance shall be rescheduled to. This time must be within
	// 28 days of the original scheduled maintenance start time.
	ScheduleTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=schedule_time,json=scheduleTime,proto3" json:"schedule_time,omitempty"`
	// contains filtered or unexported fields
}

The desired reschedule settings.

func (*RescheduleMaintenanceRequest_Reschedule) Descriptor

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

Deprecated: Use RescheduleMaintenanceRequest_Reschedule.ProtoReflect.Descriptor instead.

func (*RescheduleMaintenanceRequest_Reschedule) GetRescheduleType

func (x *RescheduleMaintenanceRequest_Reschedule) GetRescheduleType() RescheduleMaintenanceRequest_RescheduleType

func (*RescheduleMaintenanceRequest_Reschedule) GetScheduleTime

func (x *RescheduleMaintenanceRequest_Reschedule) GetScheduleTime() *timestamppb.Timestamp

func (*RescheduleMaintenanceRequest_Reschedule) ProtoMessage

func (*RescheduleMaintenanceRequest_Reschedule) ProtoMessage()

func (*RescheduleMaintenanceRequest_Reschedule) ProtoReflect

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

func (*RescheduleMaintenanceRequest_Reschedule) Reset

func (x *RescheduleMaintenanceRequest_Reschedule) Reset()

func (*RescheduleMaintenanceRequest_Reschedule) String

func (x *RescheduleMaintenanceRequest_Reschedule) String() string

RescheduleMaintenanceRequest_RescheduleType

type RescheduleMaintenanceRequest_RescheduleType int32

The type of rescheduling event. More reschedule types may be added in the future.

RescheduleMaintenanceRequest_RESCHEDULE_TYPE_UNSPECIFIED, RescheduleMaintenanceRequest_IMMEDIATE, RescheduleMaintenanceRequest_NEXT_AVAILABLE_WINDOW, RescheduleMaintenanceRequest_BY_TIME

const (
	// Unspecified schedule type.
	RescheduleMaintenanceRequest_RESCHEDULE_TYPE_UNSPECIFIED RescheduleMaintenanceRequest_RescheduleType = 0
	// Apply update immediately
	RescheduleMaintenanceRequest_IMMEDIATE RescheduleMaintenanceRequest_RescheduleType = 1
	// Reschedule to the next available window.
	RescheduleMaintenanceRequest_NEXT_AVAILABLE_WINDOW RescheduleMaintenanceRequest_RescheduleType = 2
	// Reschedule to a specific time.
	RescheduleMaintenanceRequest_BY_TIME RescheduleMaintenanceRequest_RescheduleType = 3
)

func (RescheduleMaintenanceRequest_RescheduleType) Descriptor

func (RescheduleMaintenanceRequest_RescheduleType) Descriptor() protoreflect.EnumDescriptor

func (RescheduleMaintenanceRequest_RescheduleType) Enum

func (x RescheduleMaintenanceRequest_RescheduleType) Enum() *RescheduleMaintenanceRequest_RescheduleType

func (RescheduleMaintenanceRequest_RescheduleType) EnumDescriptor

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

Deprecated: Use RescheduleMaintenanceRequest_RescheduleType.Descriptor instead.

func (RescheduleMaintenanceRequest_RescheduleType) Number

func (x RescheduleMaintenanceRequest_RescheduleType) Number() protoreflect.EnumNumber

func (RescheduleMaintenanceRequest_RescheduleType) String

func (x RescheduleMaintenanceRequest_RescheduleType) String() string

func (RescheduleMaintenanceRequest_RescheduleType) Type

func (RescheduleMaintenanceRequest_RescheduleType) Type() protoreflect.EnumType

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 valid to be assigned to Source:
	//
	//	*TransferOperationMetadata_SourceLustrePath
	//	*TransferOperationMetadata_SourceGcsPath
	Source isTransferOperationMetadata_Source `protobuf_oneof:"source"`
	// The destination of transfer operation.
	//
	// Types that are valid to be assigned 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 (x *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 (x *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) CreateDirectoryPolicy

func (UnimplementedLustreServer) CreateDirectoryPolicy(context.Context, *CreateDirectoryPolicyRequest) (*longrunningpb.Operation, error)

func (UnimplementedLustreServer) CreateInstance

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

func (UnimplementedLustreServer) CreateMirror

func (UnimplementedLustreServer) CreateMirror(context.Context, *CreateMirrorRequest) (*longrunningpb.Operation, error)

func (UnimplementedLustreServer) DeleteDirectoryPolicy

func (UnimplementedLustreServer) DeleteDirectoryPolicy(context.Context, *DeleteDirectoryPolicyRequest) (*longrunningpb.Operation, error)

func (UnimplementedLustreServer) DeleteInstance

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

func (UnimplementedLustreServer) DeleteMirror

func (UnimplementedLustreServer) DeleteMirror(context.Context, *DeleteMirrorRequest) (*longrunningpb.Operation, error)

func (UnimplementedLustreServer) ExportData

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

func (UnimplementedLustreServer) GetDirectoryPolicy

func (UnimplementedLustreServer) GetDirectoryPolicy(context.Context, *GetDirectoryPolicyRequest) (*DirectoryPolicy, error)

func (UnimplementedLustreServer) GetInstance

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

func (UnimplementedLustreServer) GetMirror

func (UnimplementedLustreServer) GetMirror(context.Context, *GetMirrorRequest) (*Mirror, error)

func (UnimplementedLustreServer) ImportData

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

func (UnimplementedLustreServer) ListDirectoryPolicies

func (UnimplementedLustreServer) ListDirectoryPolicies(context.Context, *ListDirectoryPoliciesRequest) (*ListDirectoryPoliciesResponse, error)

func (UnimplementedLustreServer) ListInstances

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

func (UnimplementedLustreServer) ListMirrors

func (UnimplementedLustreServer) ListMirrors(context.Context, *ListMirrorsRequest) (*ListMirrorsResponse, error)

func (UnimplementedLustreServer) RescheduleMaintenance

func (UnimplementedLustreServer) RescheduleMaintenance(context.Context, *RescheduleMaintenanceRequest) (*longrunningpb.Operation, error)

func (UnimplementedLustreServer) UpdateInstance

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

func (UnimplementedLustreServer) UpdateMirror

func (UnimplementedLustreServer) UpdateMirror(context.Context, *UpdateMirrorRequest) (*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

UpdateMirrorRequest

type UpdateMirrorRequest struct {

	// Required. Mirror to update. The mirror's `name` field is used to identify
	// the mirror to update, in the format:
	// `projects/{project}/locations/{location}/instances/{instance}/mirrors/{mirror}`
	Mirror *Mirror `protobuf:"bytes,1,opt,name=mirror,proto3" json:"mirror,omitempty"`
	// Optional. 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,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
	// Optional. The unique 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 guarantees that a
	// request doesn't result in the same update request being executed for at
	// least 60 minutes.
	//
	// 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.
	//
	// The request ID must be a valid UUID version 4 with the exception that zero
	// UUID is not supported (`00000000-0000-0000-0000-000000000000`).
	// This request is only idempotent if a `request_id` is provided.
	RequestId string `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// contains filtered or unexported fields
}

Request for UpdateMirror.

func (*UpdateMirrorRequest) Descriptor

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

Deprecated: Use UpdateMirrorRequest.ProtoReflect.Descriptor instead.

func (*UpdateMirrorRequest) GetMirror

func (x *UpdateMirrorRequest) GetMirror() *Mirror

func (*UpdateMirrorRequest) GetRequestId

func (x *UpdateMirrorRequest) GetRequestId() string

func (*UpdateMirrorRequest) GetUpdateMask

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

func (*UpdateMirrorRequest) ProtoMessage

func (*UpdateMirrorRequest) ProtoMessage()

func (*UpdateMirrorRequest) ProtoReflect

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

func (*UpdateMirrorRequest) Reset

func (x *UpdateMirrorRequest) Reset()

func (*UpdateMirrorRequest) String

func (x *UpdateMirrorRequest) String() string