ozone

package
v0.0.0-...-06a9ffa Latest Latest
Warning

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

 Go to latest Published: Sep 2, 2022 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Default_BucketInfo_IsVersionEnabled = bool(false)
	Default_BucketInfo_StorageType      = StorageTypeProto_DISK
)

Default values for BucketInfo fields.

View Source 
const (
	Default_OMResponse_Success = bool(true)
)

Default values for OMResponse fields.

View Source 
const (
	Default_OzoneAclInfo_AclScope = OzoneAclInfo_ACCESS
)

Default values for OzoneAclInfo fields.

View Source 
const (
	Default_OzoneObj_StoreType = OzoneObj_S3
)

Default values for OzoneObj fields.

Variables

View Source 
var (
	Type_name = map[int32]string{
		11: "CreateVolume",
		12: "SetVolumeProperty",
		13: "CheckVolumeAccess",
		14: "InfoVolume",
		15: "DeleteVolume",
		16: "ListVolume",
		21: "CreateBucket",
		22: "InfoBucket",
		23: "SetBucketProperty",
		24: "DeleteBucket",
		25: "ListBuckets",
		31: "CreateKey",
		32: "LookupKey",
		33: "RenameKey",
		34: "DeleteKey",
		35: "ListKeys",
		36: "CommitKey",
		37: "AllocateBlock",
		38: "DeleteKeys",
		45: "InitiateMultiPartUpload",
		46: "CommitMultiPartUpload",
		47: "CompleteMultiPartUpload",
		48: "AbortMultiPartUpload",
		49: "GetS3Secret",
		50: "ListMultiPartUploadParts",
		51: "ServiceList",
		53: "DBUpdates",
		61: "GetDelegationToken",
		62: "RenewDelegationToken",
		63: "CancelDelegationToken",
		70: "GetFileStatus",
		71: "CreateDirectory",
		72: "CreateFile",
		73: "LookupFile",
		74: "ListStatus",
		75: "AddAcl",
		76: "RemoveAcl",
		77: "SetAcl",
		78: "GetAcl",
		81: "PurgeKeys",
		82: "ListMultipartUploads",
		91: "ListTrash",
		92: "RecoverTrash",
	}
	Type_value = map[string]int32{
		"CreateVolume":             11,
		"SetVolumeProperty":        12,
		"CheckVolumeAccess":        13,
		"InfoVolume":               14,
		"DeleteVolume":             15,
		"ListVolume":               16,
		"CreateBucket":             21,
		"InfoBucket":               22,
		"SetBucketProperty":        23,
		"DeleteBucket":             24,
		"ListBuckets":              25,
		"CreateKey":                31,
		"LookupKey":                32,
		"RenameKey":                33,
		"DeleteKey":                34,
		"ListKeys":                 35,
		"CommitKey":                36,
		"AllocateBlock":            37,
		"DeleteKeys":               38,
		"InitiateMultiPartUpload":  45,
		"CommitMultiPartUpload":    46,
		"CompleteMultiPartUpload":  47,
		"AbortMultiPartUpload":     48,
		"GetS3Secret":              49,
		"ListMultiPartUploadParts": 50,
		"ServiceList":              51,
		"DBUpdates":                53,
		"GetDelegationToken":       61,
		"RenewDelegationToken":     62,
		"CancelDelegationToken":    63,
		"GetFileStatus":            70,
		"CreateDirectory":          71,
		"CreateFile":               72,
		"LookupFile":               73,
		"ListStatus":               74,
		"AddAcl":                   75,
		"RemoveAcl":                76,
		"SetAcl":                   77,
		"GetAcl":                   78,
		"PurgeKeys":                81,
		"ListMultipartUploads":     82,
		"ListTrash":                91,
		"RecoverTrash":             92,
	}
)

Enum value maps for Type.

View Source 
var (
	Status_name = map[int32]string{
		1:  "OK",
		2:  "VOLUME_NOT_UNIQUE",
		3:  "VOLUME_NOT_FOUND",
		4:  "VOLUME_NOT_EMPTY",
		5:  "VOLUME_ALREADY_EXISTS",
		6:  "USER_NOT_FOUND",
		7:  "USER_TOO_MANY_VOLUMES",
		8:  "BUCKET_NOT_FOUND",
		9:  "BUCKET_NOT_EMPTY",
		10: "BUCKET_ALREADY_EXISTS",
		11: "KEY_ALREADY_EXISTS",
		12: "KEY_NOT_FOUND",
		13: "INVALID_KEY_NAME",
		14: "ACCESS_DENIED",
		15: "INTERNAL_ERROR",
		16: "KEY_ALLOCATION_ERROR",
		17: "KEY_DELETION_ERROR",
		18: "KEY_RENAME_ERROR",
		19: "METADATA_ERROR",
		20: "OM_NOT_INITIALIZED",
		21: "SCM_VERSION_MISMATCH_ERROR",
		24: "INITIATE_MULTIPART_UPLOAD_ERROR",
		25: "MULTIPART_UPLOAD_PARTFILE_ERROR",
		26: "NO_SUCH_MULTIPART_UPLOAD_ERROR",
		27: "MISMATCH_MULTIPART_LIST",
		28: "MISSING_UPLOAD_PARTS",
		29: "COMPLETE_MULTIPART_UPLOAD_ERROR",
		30: "ENTITY_TOO_SMALL",
		31: "ABORT_MULTIPART_UPLOAD_FAILED",
		32: "S3_SECRET_NOT_FOUND",
		33: "INVALID_AUTH_METHOD",
		34: "INVALID_TOKEN",
		35: "TOKEN_EXPIRED",
		36: "TOKEN_ERROR_OTHER",
		37: "LIST_MULTIPART_UPLOAD_PARTS_FAILED",
		38: "SCM_IN_SAFE_MODE",
		39: "INVALID_REQUEST",
		40: "BUCKET_ENCRYPTION_KEY_NOT_FOUND",
		41: "UNKNOWN_CIPHER_SUITE",
		42: "INVALID_KMS_PROVIDER",
		43: "TOKEN_CREATION_ERROR",
		44: "FILE_NOT_FOUND",
		45: "DIRECTORY_NOT_FOUND",
		46: "FILE_ALREADY_EXISTS",
		47: "NOT_A_FILE",
		48: "PERMISSION_DENIED",
		49: "TIMEOUT",
		50: "PREFIX_NOT_FOUND",
		52: "RATIS_ERROR",
		53: "INVALID_PATH_IN_ACL_REQUEST",
		54: "USER_MISMATCH",
		55: "INVALID_PART",
		56: "INVALID_PART_ORDER",
		57: "SCM_GET_PIPELINE_EXCEPTION",
		58: "INVALID_BUCKET_NAME",
		59: "CANNOT_CREATE_DIRECTORY_AT_ROOT",
		60: "DIRECTORY_ALREADY_EXISTS",
		61: "INVALID_VOLUME_NAME",
		62: "PARTIAL_DELETE",
		63: "DETECTED_LOOP_IN_BUCKET_LINKS",
		64: "NOT_SUPPORTED_OPERATION",
	}
	Status_value = map[string]int32{
		"OK":                                 1,
		"VOLUME_NOT_UNIQUE":                  2,
		"VOLUME_NOT_FOUND":                   3,
		"VOLUME_NOT_EMPTY":                   4,
		"VOLUME_ALREADY_EXISTS":              5,
		"USER_NOT_FOUND":                     6,
		"USER_TOO_MANY_VOLUMES":              7,
		"BUCKET_NOT_FOUND":                   8,
		"BUCKET_NOT_EMPTY":                   9,
		"BUCKET_ALREADY_EXISTS":              10,
		"KEY_ALREADY_EXISTS":                 11,
		"KEY_NOT_FOUND":                      12,
		"INVALID_KEY_NAME":                   13,
		"ACCESS_DENIED":                      14,
		"INTERNAL_ERROR":                     15,
		"KEY_ALLOCATION_ERROR":               16,
		"KEY_DELETION_ERROR":                 17,
		"KEY_RENAME_ERROR":                   18,
		"METADATA_ERROR":                     19,
		"OM_NOT_INITIALIZED":                 20,
		"SCM_VERSION_MISMATCH_ERROR":         21,
		"INITIATE_MULTIPART_UPLOAD_ERROR":    24,
		"MULTIPART_UPLOAD_PARTFILE_ERROR":    25,
		"NO_SUCH_MULTIPART_UPLOAD_ERROR":     26,
		"MISMATCH_MULTIPART_LIST":            27,
		"MISSING_UPLOAD_PARTS":               28,
		"COMPLETE_MULTIPART_UPLOAD_ERROR":    29,
		"ENTITY_TOO_SMALL":                   30,
		"ABORT_MULTIPART_UPLOAD_FAILED":      31,
		"S3_SECRET_NOT_FOUND":                32,
		"INVALID_AUTH_METHOD":                33,
		"INVALID_TOKEN":                      34,
		"TOKEN_EXPIRED":                      35,
		"TOKEN_ERROR_OTHER":                  36,
		"LIST_MULTIPART_UPLOAD_PARTS_FAILED": 37,
		"SCM_IN_SAFE_MODE":                   38,
		"INVALID_REQUEST":                    39,
		"BUCKET_ENCRYPTION_KEY_NOT_FOUND":    40,
		"UNKNOWN_CIPHER_SUITE":               41,
		"INVALID_KMS_PROVIDER":               42,
		"TOKEN_CREATION_ERROR":               43,
		"FILE_NOT_FOUND":                     44,
		"DIRECTORY_NOT_FOUND":                45,
		"FILE_ALREADY_EXISTS":                46,
		"NOT_A_FILE":                         47,
		"PERMISSION_DENIED":                  48,
		"TIMEOUT":                            49,
		"PREFIX_NOT_FOUND":                   50,
		"RATIS_ERROR":                        52,
		"INVALID_PATH_IN_ACL_REQUEST":        53,
		"USER_MISMATCH":                      54,
		"INVALID_PART":                       55,
		"INVALID_PART_ORDER":                 56,
		"SCM_GET_PIPELINE_EXCEPTION":         57,
		"INVALID_BUCKET_NAME":                58,
		"CANNOT_CREATE_DIRECTORY_AT_ROOT":    59,
		"DIRECTORY_ALREADY_EXISTS":           60,
		"INVALID_VOLUME_NAME":                61,
		"PARTIAL_DELETE":                     62,
		"DETECTED_LOOP_IN_BUCKET_LINKS":      63,
		"NOT_SUPPORTED_OPERATION":            64,
	}
)

Enum value maps for Status.

View Source 
var (
	StorageTypeProto_name = map[int32]string{
		1: "DISK",
		2: "SSD",
		3: "ARCHIVE",
		4: "RAM_DISK",
	}
	StorageTypeProto_value = map[string]int32{
		"DISK":     1,
		"SSD":      2,
		"ARCHIVE":  3,
		"RAM_DISK": 4,
	}
)

Enum value maps for StorageTypeProto.

View Source 
var (
	CipherSuiteProto_name = map[int32]string{
		1: "UNKNOWN",
		2: "AES_CTR_NOPADDING",
	}
	CipherSuiteProto_value = map[string]int32{
		"UNKNOWN":           1,
		"AES_CTR_NOPADDING": 2,
	}
)

Enum value maps for CipherSuiteProto.

View Source 
var (
	CryptoProtocolVersionProto_name = map[int32]string{
		1: "UNKNOWN_PROTOCOL_VERSION",
		2: "ENCRYPTION_ZONES",
	}
	CryptoProtocolVersionProto_value = map[string]int32{
		"UNKNOWN_PROTOCOL_VERSION": 1,
		"ENCRYPTION_ZONES":         2,
	}
)

Enum value maps for CryptoProtocolVersionProto.

View Source 
var (
	ListVolumeRequest_Scope_name = map[int32]string{
		1: "USER_VOLUMES",
		2: "VOLUMES_BY_USER",
		3: "VOLUMES_BY_CLUSTER",
	}
	ListVolumeRequest_Scope_value = map[string]int32{
		"USER_VOLUMES":       1,
		"VOLUMES_BY_USER":    2,
		"VOLUMES_BY_CLUSTER": 3,
	}
)

Enum value maps for ListVolumeRequest_Scope.

View Source 
var (
	OzoneObj_ObjectType_name = map[int32]string{
		1: "VOLUME",
		2: "BUCKET",
		3: "KEY",
		4: "PREFIX",
	}
	OzoneObj_ObjectType_value = map[string]int32{
		"VOLUME": 1,
		"BUCKET": 2,
		"KEY":    3,
		"PREFIX": 4,
	}
)

Enum value maps for OzoneObj_ObjectType.

View Source 
var (
	OzoneObj_StoreType_name = map[int32]string{
		1: "OZONE",
		2: "S3",
	}
	OzoneObj_StoreType_value = map[string]int32{
		"OZONE": 1,
		"S3":    2,
	}
)

Enum value maps for OzoneObj_StoreType.

View Source 
var (
	OzoneAclInfo_OzoneAclType_name = map[int32]string{
		1: "USER",
		2: "GROUP",
		3: "WORLD",
		4: "ANONYMOUS",
		5: "CLIENT_IP",
	}
	OzoneAclInfo_OzoneAclType_value = map[string]int32{
		"USER":      1,
		"GROUP":     2,
		"WORLD":     3,
		"ANONYMOUS": 4,
		"CLIENT_IP": 5,
	}
)

Enum value maps for OzoneAclInfo_OzoneAclType.

View Source 
var (
	OzoneAclInfo_OzoneAclScope_name = map[int32]string{
		0: "ACCESS",
		1: "DEFAULT",
	}
	OzoneAclInfo_OzoneAclScope_value = map[string]int32{
		"ACCESS":  0,
		"DEFAULT": 1,
	}
)

Enum value maps for OzoneAclInfo_OzoneAclScope.

View Source 
var (
	OMTokenProto_Type_name = map[int32]string{
		1: "DELEGATION_TOKEN",
		2: "S3AUTHINFO",
	}
	OMTokenProto_Type_value = map[string]int32{
		"DELEGATION_TOKEN": 1,
		"S3AUTHINFO":       2,
	}
)

Enum value maps for OMTokenProto_Type.

View Source 
var (
	ServicePort_Type_name = map[int32]string{
		1: "RPC",
		2: "HTTP",
		3: "HTTPS",
		4: "RATIS",
	}
	ServicePort_Type_value = map[string]int32{
		"RPC":   1,
		"HTTP":  2,
		"HTTPS": 3,
		"RATIS": 4,
	}
)

Enum value maps for ServicePort_Type.

View Source 
var File_OmClientProtocol_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AddAclRequest 

type AddAclRequest struct {
	Obj *OzoneObj     `protobuf:"bytes,1,req,name=obj" json:"obj,omitempty"`
	Acl *OzoneAclInfo `protobuf:"bytes,2,req,name=acl" json:"acl,omitempty"`
	// contains filtered or unexported fields
}

func (*AddAclRequest) Descriptor deprecated 

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

Deprecated: Use AddAclRequest.ProtoReflect.Descriptor instead.

func (*AddAclRequest) GetAcl 

func (x *AddAclRequest) GetAcl() *OzoneAclInfo

func (*AddAclRequest) GetObj 

func (x *AddAclRequest) GetObj() *OzoneObj

func (*AddAclRequest) ProtoMessage 

func (*AddAclRequest) ProtoMessage()

func (*AddAclRequest) ProtoReflect 

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

func (*AddAclRequest) Reset 

func (x *AddAclRequest) Reset()

func (*AddAclRequest) String 

func (x *AddAclRequest) String() string

type AddAclResponse 

type AddAclResponse struct {
	Response *bool `protobuf:"varint,1,req,name=response" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*AddAclResponse) Descriptor deprecated 

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

Deprecated: Use AddAclResponse.ProtoReflect.Descriptor instead.

func (*AddAclResponse) GetResponse 

func (x *AddAclResponse) GetResponse() bool

func (*AddAclResponse) ProtoMessage 

func (*AddAclResponse) ProtoMessage()

func (*AddAclResponse) ProtoReflect 

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

func (*AddAclResponse) Reset 

func (x *AddAclResponse) Reset()

func (*AddAclResponse) String 

func (x *AddAclResponse) String() string

type AllocateBlockRequest 

type AllocateBlockRequest struct {
	KeyArgs     *KeyArgs               `protobuf:"bytes,1,req,name=keyArgs" json:"keyArgs,omitempty"`
	ClientID    *uint64                `protobuf:"varint,2,req,name=clientID" json:"clientID,omitempty"`
	ExcludeList *hdds.ExcludeListProto `protobuf:"bytes,3,opt,name=excludeList" json:"excludeList,omitempty"`
	// During HA on one of the OM nodes, we allocate block and send the
	// AllocateBlockRequest with keyLocation set. If this is set, no need to
	// call scm again in OM Ratis applyTransaction just append it to DB.
	KeyLocation *KeyLocation `protobuf:"bytes,4,opt,name=keyLocation" json:"keyLocation,omitempty"`
	// contains filtered or unexported fields
}

func (*AllocateBlockRequest) Descriptor deprecated 

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

Deprecated: Use AllocateBlockRequest.ProtoReflect.Descriptor instead.

func (*AllocateBlockRequest) GetClientID 

func (x *AllocateBlockRequest) GetClientID() uint64

func (*AllocateBlockRequest) GetExcludeList 

func (x *AllocateBlockRequest) GetExcludeList() *hdds.ExcludeListProto

func (*AllocateBlockRequest) GetKeyArgs 

func (x *AllocateBlockRequest) GetKeyArgs() *KeyArgs

func (*AllocateBlockRequest) GetKeyLocation 

func (x *AllocateBlockRequest) GetKeyLocation() *KeyLocation

func (*AllocateBlockRequest) ProtoMessage 

func (*AllocateBlockRequest) ProtoMessage()

func (*AllocateBlockRequest) ProtoReflect 

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

func (*AllocateBlockRequest) Reset 

func (x *AllocateBlockRequest) Reset()

func (*AllocateBlockRequest) String 

func (x *AllocateBlockRequest) String() string

type AllocateBlockResponse 

type AllocateBlockResponse struct {
	KeyLocation *KeyLocation `protobuf:"bytes,2,opt,name=keyLocation" json:"keyLocation,omitempty"`
	// contains filtered or unexported fields
}

func (*AllocateBlockResponse) Descriptor deprecated 

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

Deprecated: Use AllocateBlockResponse.ProtoReflect.Descriptor instead.

func (*AllocateBlockResponse) GetKeyLocation 

func (x *AllocateBlockResponse) GetKeyLocation() *KeyLocation

func (*AllocateBlockResponse) ProtoMessage 

func (*AllocateBlockResponse) ProtoMessage()

func (*AllocateBlockResponse) ProtoReflect 

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

func (*AllocateBlockResponse) Reset 

func (x *AllocateBlockResponse) Reset()

func (*AllocateBlockResponse) String 

func (x *AllocateBlockResponse) String() string

type BucketArgs 

type BucketArgs struct {
	VolumeName       *string           `protobuf:"bytes,1,req,name=volumeName" json:"volumeName,omitempty"`
	BucketName       *string           `protobuf:"bytes,2,req,name=bucketName" json:"bucketName,omitempty"`
	IsVersionEnabled *bool             `protobuf:"varint,5,opt,name=isVersionEnabled" json:"isVersionEnabled,omitempty"`
	StorageType      *StorageTypeProto `protobuf:"varint,6,opt,name=storageType,enum=hadoop.ozone.StorageTypeProto" json:"storageType,omitempty"`
	Metadata         []*hdds.KeyValue  `protobuf:"bytes,7,rep,name=metadata" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*BucketArgs) Descriptor deprecated 

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

Deprecated: Use BucketArgs.ProtoReflect.Descriptor instead.

func (*BucketArgs) GetBucketName 

func (x *BucketArgs) GetBucketName() string

func (*BucketArgs) GetIsVersionEnabled 

func (x *BucketArgs) GetIsVersionEnabled() bool

func (*BucketArgs) GetMetadata 

func (x *BucketArgs) GetMetadata() []*hdds.KeyValue

func (*BucketArgs) GetStorageType 

func (x *BucketArgs) GetStorageType() StorageTypeProto

func (*BucketArgs) GetVolumeName 

func (x *BucketArgs) GetVolumeName() string

func (*BucketArgs) ProtoMessage 

func (*BucketArgs) ProtoMessage()

func (*BucketArgs) ProtoReflect 

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

func (*BucketArgs) Reset 

func (x *BucketArgs) Reset()

func (*BucketArgs) String 

func (x *BucketArgs) String() string

type BucketEncryptionInfoProto 

type BucketEncryptionInfoProto struct {
	KeyName               *string                     `protobuf:"bytes,1,req,name=keyName" json:"keyName,omitempty"`
	Suite                 *CipherSuiteProto           `protobuf:"varint,2,opt,name=suite,enum=hadoop.ozone.CipherSuiteProto" json:"suite,omitempty"`
	CryptoProtocolVersion *CryptoProtocolVersionProto `` /* 134-byte string literal not displayed */
	// contains filtered or unexported fields
}

* Encryption information for bucket (bucket key)

func (*BucketEncryptionInfoProto) Descriptor deprecated 

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

Deprecated: Use BucketEncryptionInfoProto.ProtoReflect.Descriptor instead.

func (*BucketEncryptionInfoProto) GetCryptoProtocolVersion 

func (x *BucketEncryptionInfoProto) GetCryptoProtocolVersion() CryptoProtocolVersionProto

func (*BucketEncryptionInfoProto) GetKeyName 

func (x *BucketEncryptionInfoProto) GetKeyName() string

func (*BucketEncryptionInfoProto) GetSuite 

func (x *BucketEncryptionInfoProto) GetSuite() CipherSuiteProto

func (*BucketEncryptionInfoProto) ProtoMessage 

func (*BucketEncryptionInfoProto) ProtoMessage()

func (*BucketEncryptionInfoProto) ProtoReflect 

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

func (*BucketEncryptionInfoProto) Reset 

func (x *BucketEncryptionInfoProto) Reset()

func (*BucketEncryptionInfoProto) String 

func (x *BucketEncryptionInfoProto) String() string

type BucketInfo 

type BucketInfo struct {
	VolumeName       *string                    `protobuf:"bytes,1,req,name=volumeName" json:"volumeName,omitempty"`
	BucketName       *string                    `protobuf:"bytes,2,req,name=bucketName" json:"bucketName,omitempty"`
	Acls             []*OzoneAclInfo            `protobuf:"bytes,3,rep,name=acls" json:"acls,omitempty"`
	IsVersionEnabled *bool                      `protobuf:"varint,4,req,name=isVersionEnabled,def=0" json:"isVersionEnabled,omitempty"`
	StorageType      *StorageTypeProto          `protobuf:"varint,5,req,name=storageType,enum=hadoop.ozone.StorageTypeProto,def=1" json:"storageType,omitempty"`
	CreationTime     *uint64                    `protobuf:"varint,6,opt,name=creationTime" json:"creationTime,omitempty"`
	Metadata         []*hdds.KeyValue           `protobuf:"bytes,7,rep,name=metadata" json:"metadata,omitempty"`
	Beinfo           *BucketEncryptionInfoProto `protobuf:"bytes,8,opt,name=beinfo" json:"beinfo,omitempty"`
	ObjectID         *uint64                    `protobuf:"varint,9,opt,name=objectID" json:"objectID,omitempty"`
	UpdateID         *uint64                    `protobuf:"varint,10,opt,name=updateID" json:"updateID,omitempty"`
	ModificationTime *uint64                    `protobuf:"varint,11,opt,name=modificationTime" json:"modificationTime,omitempty"`
	SourceVolume     *string                    `protobuf:"bytes,12,opt,name=sourceVolume" json:"sourceVolume,omitempty"`
	SourceBucket     *string                    `protobuf:"bytes,13,opt,name=sourceBucket" json:"sourceBucket,omitempty"`
	// contains filtered or unexported fields
}

func (*BucketInfo) Descriptor deprecated 

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

Deprecated: Use BucketInfo.ProtoReflect.Descriptor instead.

func (*BucketInfo) GetAcls 

func (x *BucketInfo) GetAcls() []*OzoneAclInfo

func (*BucketInfo) GetBeinfo 

func (x *BucketInfo) GetBeinfo() *BucketEncryptionInfoProto

func (*BucketInfo) GetBucketName 

func (x *BucketInfo) GetBucketName() string

func (*BucketInfo) GetCreationTime 

func (x *BucketInfo) GetCreationTime() uint64

func (*BucketInfo) GetIsVersionEnabled 

func (x *BucketInfo) GetIsVersionEnabled() bool

func (*BucketInfo) GetMetadata 

func (x *BucketInfo) GetMetadata() []*hdds.KeyValue

func (*BucketInfo) GetModificationTime 

func (x *BucketInfo) GetModificationTime() uint64

func (*BucketInfo) GetObjectID 

func (x *BucketInfo) GetObjectID() uint64

func (*BucketInfo) GetSourceBucket 

func (x *BucketInfo) GetSourceBucket() string

func (*BucketInfo) GetSourceVolume 

func (x *BucketInfo) GetSourceVolume() string

func (*BucketInfo) GetStorageType 

func (x *BucketInfo) GetStorageType() StorageTypeProto

func (*BucketInfo) GetUpdateID 

func (x *BucketInfo) GetUpdateID() uint64

func (*BucketInfo) GetVolumeName 

func (x *BucketInfo) GetVolumeName() string

func (*BucketInfo) ProtoMessage 

func (*BucketInfo) ProtoMessage()

func (*BucketInfo) ProtoReflect 

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

func (*BucketInfo) Reset 

func (x *BucketInfo) Reset()

func (*BucketInfo) String 

func (x *BucketInfo) String() string

type CancelDelegationTokenResponseProto 

type CancelDelegationTokenResponseProto struct {
	Response *common.CancelDelegationTokenResponseProto `protobuf:"bytes,2,opt,name=response" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*CancelDelegationTokenResponseProto) Descriptor deprecated 

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

Deprecated: Use CancelDelegationTokenResponseProto.ProtoReflect.Descriptor instead.

func (*CancelDelegationTokenResponseProto) GetResponse 

func (x *CancelDelegationTokenResponseProto) GetResponse() *common.CancelDelegationTokenResponseProto

func (*CancelDelegationTokenResponseProto) ProtoMessage 

func (*CancelDelegationTokenResponseProto) ProtoMessage()

func (*CancelDelegationTokenResponseProto) ProtoReflect 

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

func (*CancelDelegationTokenResponseProto) Reset 

func (x *CancelDelegationTokenResponseProto) Reset()

func (*CancelDelegationTokenResponseProto) String 

func (x *CancelDelegationTokenResponseProto) String() string

type CheckVolumeAccessRequest 

type CheckVolumeAccessRequest struct {
	VolumeName *string       `protobuf:"bytes,1,req,name=volumeName" json:"volumeName,omitempty"`
	UserAcl    *OzoneAclInfo `protobuf:"bytes,2,req,name=userAcl" json:"userAcl,omitempty"`
	// contains filtered or unexported fields
}

* Checks if the user has specified permissions for the volume

func (*CheckVolumeAccessRequest) Descriptor deprecated 

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

Deprecated: Use CheckVolumeAccessRequest.ProtoReflect.Descriptor instead.

func (*CheckVolumeAccessRequest) GetUserAcl 

func (x *CheckVolumeAccessRequest) GetUserAcl() *OzoneAclInfo

func (*CheckVolumeAccessRequest) GetVolumeName 

func (x *CheckVolumeAccessRequest) GetVolumeName() string

func (*CheckVolumeAccessRequest) ProtoMessage 

func (*CheckVolumeAccessRequest) ProtoMessage()

func (*CheckVolumeAccessRequest) ProtoReflect 

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

func (*CheckVolumeAccessRequest) Reset 

func (x *CheckVolumeAccessRequest) Reset()

func (*CheckVolumeAccessRequest) String 

func (x *CheckVolumeAccessRequest) String() string

type CheckVolumeAccessResponse 

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

func (*CheckVolumeAccessResponse) Descriptor deprecated 

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

Deprecated: Use CheckVolumeAccessResponse.ProtoReflect.Descriptor instead.

func (*CheckVolumeAccessResponse) ProtoMessage 

func (*CheckVolumeAccessResponse) ProtoMessage()

func (*CheckVolumeAccessResponse) ProtoReflect 

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

func (*CheckVolumeAccessResponse) Reset 

func (x *CheckVolumeAccessResponse) Reset()

func (*CheckVolumeAccessResponse) String 

func (x *CheckVolumeAccessResponse) String() string

type CipherSuiteProto 

type CipherSuiteProto int32

* Cipher suite. 

const (
	CipherSuiteProto_UNKNOWN           CipherSuiteProto = 1
	CipherSuiteProto_AES_CTR_NOPADDING CipherSuiteProto = 2
)

func (CipherSuiteProto) Descriptor 

func (CipherSuiteProto) Descriptor() protoreflect.EnumDescriptor

func (CipherSuiteProto) Enum 

func (x CipherSuiteProto) Enum() *CipherSuiteProto

func (CipherSuiteProto) EnumDescriptor deprecated 

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

Deprecated: Use CipherSuiteProto.Descriptor instead.

func (CipherSuiteProto) Number 

func (x CipherSuiteProto) Number() protoreflect.EnumNumber

func (CipherSuiteProto) String 

func (x CipherSuiteProto) String() string

func (CipherSuiteProto) Type 

func (CipherSuiteProto) Type() protoreflect.EnumType

func (*CipherSuiteProto) UnmarshalJSON deprecated 

func (x *CipherSuiteProto) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type CommitKeyRequest 

type CommitKeyRequest struct {
	KeyArgs  *KeyArgs `protobuf:"bytes,1,req,name=keyArgs" json:"keyArgs,omitempty"`
	ClientID *uint64  `protobuf:"varint,2,req,name=clientID" json:"clientID,omitempty"`
	// contains filtered or unexported fields
}

func (*CommitKeyRequest) Descriptor deprecated 

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

Deprecated: Use CommitKeyRequest.ProtoReflect.Descriptor instead.

func (*CommitKeyRequest) GetClientID 

func (x *CommitKeyRequest) GetClientID() uint64

func (*CommitKeyRequest) GetKeyArgs 

func (x *CommitKeyRequest) GetKeyArgs() *KeyArgs

func (*CommitKeyRequest) ProtoMessage 

func (*CommitKeyRequest) ProtoMessage()

func (*CommitKeyRequest) ProtoReflect 

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

func (*CommitKeyRequest) Reset 

func (x *CommitKeyRequest) Reset()

func (*CommitKeyRequest) String 

func (x *CommitKeyRequest) String() string

type CommitKeyResponse 

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

func (*CommitKeyResponse) Descriptor deprecated 

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

Deprecated: Use CommitKeyResponse.ProtoReflect.Descriptor instead.

func (*CommitKeyResponse) ProtoMessage 

func (*CommitKeyResponse) ProtoMessage()

func (*CommitKeyResponse) ProtoReflect 

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

func (*CommitKeyResponse) Reset 

func (x *CommitKeyResponse) Reset()

func (*CommitKeyResponse) String 

func (x *CommitKeyResponse) String() string

type CreateBucketRequest 

type CreateBucketRequest struct {
	BucketInfo *BucketInfo `protobuf:"bytes,1,req,name=bucketInfo" json:"bucketInfo,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateBucketRequest) Descriptor deprecated 

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

Deprecated: Use CreateBucketRequest.ProtoReflect.Descriptor instead.

func (*CreateBucketRequest) GetBucketInfo 

func (x *CreateBucketRequest) GetBucketInfo() *BucketInfo

func (*CreateBucketRequest) ProtoMessage 

func (*CreateBucketRequest) ProtoMessage()

func (*CreateBucketRequest) ProtoReflect 

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

func (*CreateBucketRequest) Reset 

func (x *CreateBucketRequest) Reset()

func (*CreateBucketRequest) String 

func (x *CreateBucketRequest) String() string

type CreateBucketResponse 

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

func (*CreateBucketResponse) Descriptor deprecated 

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

Deprecated: Use CreateBucketResponse.ProtoReflect.Descriptor instead.

func (*CreateBucketResponse) ProtoMessage 

func (*CreateBucketResponse) ProtoMessage()

func (*CreateBucketResponse) ProtoReflect 

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

func (*CreateBucketResponse) Reset 

func (x *CreateBucketResponse) Reset()

func (*CreateBucketResponse) String 

func (x *CreateBucketResponse) String() string

type CreateDirectoryRequest 

type CreateDirectoryRequest struct {
	KeyArgs *KeyArgs `protobuf:"bytes,1,req,name=keyArgs" json:"keyArgs,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateDirectoryRequest) Descriptor deprecated 

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

Deprecated: Use CreateDirectoryRequest.ProtoReflect.Descriptor instead.

func (*CreateDirectoryRequest) GetKeyArgs 

func (x *CreateDirectoryRequest) GetKeyArgs() *KeyArgs

func (*CreateDirectoryRequest) ProtoMessage 

func (*CreateDirectoryRequest) ProtoMessage()

func (*CreateDirectoryRequest) ProtoReflect 

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

func (*CreateDirectoryRequest) Reset 

func (x *CreateDirectoryRequest) Reset()

func (*CreateDirectoryRequest) String 

func (x *CreateDirectoryRequest) String() string

type CreateDirectoryResponse 

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

func (*CreateDirectoryResponse) Descriptor deprecated 

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

Deprecated: Use CreateDirectoryResponse.ProtoReflect.Descriptor instead.

func (*CreateDirectoryResponse) ProtoMessage 

func (*CreateDirectoryResponse) ProtoMessage()

func (*CreateDirectoryResponse) ProtoReflect 

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

func (*CreateDirectoryResponse) Reset 

func (x *CreateDirectoryResponse) Reset()

func (*CreateDirectoryResponse) String 

func (x *CreateDirectoryResponse) String() string

type CreateFileRequest 

type CreateFileRequest struct {
	KeyArgs     *KeyArgs `protobuf:"bytes,1,req,name=keyArgs" json:"keyArgs,omitempty"`
	IsRecursive *bool    `protobuf:"varint,2,req,name=isRecursive" json:"isRecursive,omitempty"`
	IsOverwrite *bool    `protobuf:"varint,3,req,name=isOverwrite" json:"isOverwrite,omitempty"`
	// Set in OM HA during preExecute step. This way all OM's use same ID in
	// OM HA.
	ClientID *uint64 `protobuf:"varint,4,opt,name=clientID" json:"clientID,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateFileRequest) Descriptor deprecated 

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

Deprecated: Use CreateFileRequest.ProtoReflect.Descriptor instead.

func (*CreateFileRequest) GetClientID 

func (x *CreateFileRequest) GetClientID() uint64

func (*CreateFileRequest) GetIsOverwrite 

func (x *CreateFileRequest) GetIsOverwrite() bool

func (*CreateFileRequest) GetIsRecursive 

func (x *CreateFileRequest) GetIsRecursive() bool

func (*CreateFileRequest) GetKeyArgs 

func (x *CreateFileRequest) GetKeyArgs() *KeyArgs

func (*CreateFileRequest) ProtoMessage 

func (*CreateFileRequest) ProtoMessage()

func (*CreateFileRequest) ProtoReflect 

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

func (*CreateFileRequest) Reset 

func (x *CreateFileRequest) Reset()

func (*CreateFileRequest) String 

func (x *CreateFileRequest) String() string

type CreateFileResponse 

type CreateFileResponse struct {
	KeyInfo *KeyInfo `protobuf:"bytes,1,opt,name=keyInfo" json:"keyInfo,omitempty"`
	// clients' followup request may carry this ID for stateful operations
	// (similar to a cookie).
	ID          *uint64 `protobuf:"varint,2,opt,name=ID" json:"ID,omitempty"`
	OpenVersion *uint64 `protobuf:"varint,3,opt,name=openVersion" json:"openVersion,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateFileResponse) Descriptor deprecated 

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

Deprecated: Use CreateFileResponse.ProtoReflect.Descriptor instead.

func (*CreateFileResponse) GetID 

func (x *CreateFileResponse) GetID() uint64

func (*CreateFileResponse) GetKeyInfo 

func (x *CreateFileResponse) GetKeyInfo() *KeyInfo

func (*CreateFileResponse) GetOpenVersion 

func (x *CreateFileResponse) GetOpenVersion() uint64

func (*CreateFileResponse) ProtoMessage 

func (*CreateFileResponse) ProtoMessage()

func (*CreateFileResponse) ProtoReflect 

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

func (*CreateFileResponse) Reset 

func (x *CreateFileResponse) Reset()

func (*CreateFileResponse) String 

func (x *CreateFileResponse) String() string

type CreateKeyRequest 

type CreateKeyRequest struct {
	KeyArgs *KeyArgs `protobuf:"bytes,1,req,name=keyArgs" json:"keyArgs,omitempty"`
	// Set in OM HA during preExecute step. This way all OM's use same ID in
	// OM HA.
	ClientID *uint64 `protobuf:"varint,2,opt,name=clientID" json:"clientID,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateKeyRequest) Descriptor deprecated 

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

Deprecated: Use CreateKeyRequest.ProtoReflect.Descriptor instead.

func (*CreateKeyRequest) GetClientID 

func (x *CreateKeyRequest) GetClientID() uint64

func (*CreateKeyRequest) GetKeyArgs 

func (x *CreateKeyRequest) GetKeyArgs() *KeyArgs

func (*CreateKeyRequest) ProtoMessage 

func (*CreateKeyRequest) ProtoMessage()

func (*CreateKeyRequest) ProtoReflect 

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

func (*CreateKeyRequest) Reset 

func (x *CreateKeyRequest) Reset()

func (*CreateKeyRequest) String 

func (x *CreateKeyRequest) String() string

type CreateKeyResponse 

type CreateKeyResponse struct {
	KeyInfo *KeyInfo `protobuf:"bytes,2,opt,name=keyInfo" json:"keyInfo,omitempty"`
	// clients' followup request may carry this ID for stateful operations
	// (similar to a cookie).
	ID          *uint64 `protobuf:"varint,3,opt,name=ID" json:"ID,omitempty"`
	OpenVersion *uint64 `protobuf:"varint,4,opt,name=openVersion" json:"openVersion,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateKeyResponse) Descriptor deprecated 

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

Deprecated: Use CreateKeyResponse.ProtoReflect.Descriptor instead.

func (*CreateKeyResponse) GetID 

func (x *CreateKeyResponse) GetID() uint64

func (*CreateKeyResponse) GetKeyInfo 

func (x *CreateKeyResponse) GetKeyInfo() *KeyInfo

func (*CreateKeyResponse) GetOpenVersion 

func (x *CreateKeyResponse) GetOpenVersion() uint64

func (*CreateKeyResponse) ProtoMessage 

func (*CreateKeyResponse) ProtoMessage()

func (*CreateKeyResponse) ProtoReflect 

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

func (*CreateKeyResponse) Reset 

func (x *CreateKeyResponse) Reset()

func (*CreateKeyResponse) String 

func (x *CreateKeyResponse) String() string

type CreateVolumeRequest 

type CreateVolumeRequest struct {
	VolumeInfo *VolumeInfo `protobuf:"bytes,1,req,name=volumeInfo" json:"volumeInfo,omitempty"`
	// contains filtered or unexported fields
}

* Creates a volume

func (*CreateVolumeRequest) Descriptor deprecated 

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

Deprecated: Use CreateVolumeRequest.ProtoReflect.Descriptor instead.

func (*CreateVolumeRequest) GetVolumeInfo 

func (x *CreateVolumeRequest) GetVolumeInfo() *VolumeInfo

func (*CreateVolumeRequest) ProtoMessage 

func (*CreateVolumeRequest) ProtoMessage()

func (*CreateVolumeRequest) ProtoReflect 

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

func (*CreateVolumeRequest) Reset 

func (x *CreateVolumeRequest) Reset()

func (*CreateVolumeRequest) String 

func (x *CreateVolumeRequest) String() string

type CreateVolumeResponse 

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

func (*CreateVolumeResponse) Descriptor deprecated 

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

Deprecated: Use CreateVolumeResponse.ProtoReflect.Descriptor instead.

func (*CreateVolumeResponse) ProtoMessage 

func (*CreateVolumeResponse) ProtoMessage()

func (*CreateVolumeResponse) ProtoReflect 

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

func (*CreateVolumeResponse) Reset 

func (x *CreateVolumeResponse) Reset()

func (*CreateVolumeResponse) String 

func (x *CreateVolumeResponse) String() string

type CryptoProtocolVersionProto 

type CryptoProtocolVersionProto int32

* Crypto protocol version used to access encrypted files. 

const (
	CryptoProtocolVersionProto_UNKNOWN_PROTOCOL_VERSION CryptoProtocolVersionProto = 1
	CryptoProtocolVersionProto_ENCRYPTION_ZONES         CryptoProtocolVersionProto = 2
)

func (CryptoProtocolVersionProto) Descriptor 

func (CryptoProtocolVersionProto) Descriptor() protoreflect.EnumDescriptor

func (CryptoProtocolVersionProto) Enum 

func (x CryptoProtocolVersionProto) Enum() *CryptoProtocolVersionProto

func (CryptoProtocolVersionProto) EnumDescriptor deprecated 

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

Deprecated: Use CryptoProtocolVersionProto.Descriptor instead.

func (CryptoProtocolVersionProto) Number 

func (x CryptoProtocolVersionProto) Number() protoreflect.EnumNumber

func (CryptoProtocolVersionProto) String 

func (x CryptoProtocolVersionProto) String() string

func (CryptoProtocolVersionProto) Type 

func (CryptoProtocolVersionProto) Type() protoreflect.EnumType

func (*CryptoProtocolVersionProto) UnmarshalJSON deprecated 

func (x *CryptoProtocolVersionProto) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type DBUpdatesRequest 

type DBUpdatesRequest struct {
	SequenceNumber *uint64 `protobuf:"varint,1,req,name=sequenceNumber" json:"sequenceNumber,omitempty"`
	// contains filtered or unexported fields
}

func (*DBUpdatesRequest) Descriptor deprecated 

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

Deprecated: Use DBUpdatesRequest.ProtoReflect.Descriptor instead.

func (*DBUpdatesRequest) GetSequenceNumber 

func (x *DBUpdatesRequest) GetSequenceNumber() uint64

func (*DBUpdatesRequest) ProtoMessage 

func (*DBUpdatesRequest) ProtoMessage()

func (*DBUpdatesRequest) ProtoReflect 

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

func (*DBUpdatesRequest) Reset 

func (x *DBUpdatesRequest) Reset()

func (*DBUpdatesRequest) String 

func (x *DBUpdatesRequest) String() string

type DBUpdatesResponse 

type DBUpdatesResponse struct {
	SequenceNumber *uint64  `protobuf:"varint,1,req,name=sequenceNumber" json:"sequenceNumber,omitempty"`
	Data           [][]byte `protobuf:"bytes,2,rep,name=data" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*DBUpdatesResponse) Descriptor deprecated 

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

Deprecated: Use DBUpdatesResponse.ProtoReflect.Descriptor instead.

func (*DBUpdatesResponse) GetData 

func (x *DBUpdatesResponse) GetData() [][]byte

func (*DBUpdatesResponse) GetSequenceNumber 

func (x *DBUpdatesResponse) GetSequenceNumber() uint64

func (*DBUpdatesResponse) ProtoMessage 

func (*DBUpdatesResponse) ProtoMessage()

func (*DBUpdatesResponse) ProtoReflect 

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

func (*DBUpdatesResponse) Reset 

func (x *DBUpdatesResponse) Reset()

func (*DBUpdatesResponse) String 

func (x *DBUpdatesResponse) String() string

type DataEncryptionKeyProto 

type DataEncryptionKeyProto struct {
	KeyId               *uint32 `protobuf:"varint,1,req,name=keyId" json:"keyId,omitempty"`
	Nonce               []byte  `protobuf:"bytes,3,req,name=nonce" json:"nonce,omitempty"`
	EncryptionKey       []byte  `protobuf:"bytes,4,req,name=encryptionKey" json:"encryptionKey,omitempty"`
	ExpiryDate          *uint64 `protobuf:"varint,5,req,name=expiryDate" json:"expiryDate,omitempty"`
	EncryptionAlgorithm *string `protobuf:"bytes,6,opt,name=encryptionAlgorithm" json:"encryptionAlgorithm,omitempty"`
	// contains filtered or unexported fields
}

func (*DataEncryptionKeyProto) Descriptor deprecated 

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

Deprecated: Use DataEncryptionKeyProto.ProtoReflect.Descriptor instead.

func (*DataEncryptionKeyProto) GetEncryptionAlgorithm 

func (x *DataEncryptionKeyProto) GetEncryptionAlgorithm() string

func (*DataEncryptionKeyProto) GetEncryptionKey 

func (x *DataEncryptionKeyProto) GetEncryptionKey() []byte

func (*DataEncryptionKeyProto) GetExpiryDate 

func (x *DataEncryptionKeyProto) GetExpiryDate() uint64

func (*DataEncryptionKeyProto) GetKeyId 

func (x *DataEncryptionKeyProto) GetKeyId() uint32

func (*DataEncryptionKeyProto) GetNonce 

func (x *DataEncryptionKeyProto) GetNonce() []byte

func (*DataEncryptionKeyProto) ProtoMessage 

func (*DataEncryptionKeyProto) ProtoMessage()

func (*DataEncryptionKeyProto) ProtoReflect 

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

func (*DataEncryptionKeyProto) Reset 

func (x *DataEncryptionKeyProto) Reset()

func (*DataEncryptionKeyProto) String 

func (x *DataEncryptionKeyProto) String() string

type DeleteBucketRequest 

type DeleteBucketRequest struct {
	VolumeName *string `protobuf:"bytes,1,req,name=volumeName" json:"volumeName,omitempty"`
	BucketName *string `protobuf:"bytes,2,req,name=bucketName" json:"bucketName,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteBucketRequest) Descriptor deprecated 

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

Deprecated: Use DeleteBucketRequest.ProtoReflect.Descriptor instead.

func (*DeleteBucketRequest) GetBucketName 

func (x *DeleteBucketRequest) GetBucketName() string

func (*DeleteBucketRequest) GetVolumeName 

func (x *DeleteBucketRequest) GetVolumeName() string

func (*DeleteBucketRequest) ProtoMessage 

func (*DeleteBucketRequest) ProtoMessage()

func (*DeleteBucketRequest) ProtoReflect 

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

func (*DeleteBucketRequest) Reset 

func (x *DeleteBucketRequest) Reset()

func (*DeleteBucketRequest) String 

func (x *DeleteBucketRequest) String() string

type DeleteBucketResponse 

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

func (*DeleteBucketResponse) Descriptor deprecated 

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

Deprecated: Use DeleteBucketResponse.ProtoReflect.Descriptor instead.

func (*DeleteBucketResponse) ProtoMessage 

func (*DeleteBucketResponse) ProtoMessage()

func (*DeleteBucketResponse) ProtoReflect 

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

func (*DeleteBucketResponse) Reset 

func (x *DeleteBucketResponse) Reset()

func (*DeleteBucketResponse) String 

func (x *DeleteBucketResponse) String() string

type DeleteKeyArgs 

type DeleteKeyArgs struct {
	VolumeName *string  `protobuf:"bytes,1,req,name=volumeName" json:"volumeName,omitempty"`
	BucketName *string  `protobuf:"bytes,2,req,name=bucketName" json:"bucketName,omitempty"`
	Keys       []string `protobuf:"bytes,3,rep,name=keys" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteKeyArgs) Descriptor deprecated 

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

Deprecated: Use DeleteKeyArgs.ProtoReflect.Descriptor instead.

func (*DeleteKeyArgs) GetBucketName 

func (x *DeleteKeyArgs) GetBucketName() string

func (*DeleteKeyArgs) GetKeys 

func (x *DeleteKeyArgs) GetKeys() []string

func (*DeleteKeyArgs) GetVolumeName 

func (x *DeleteKeyArgs) GetVolumeName() string

func (*DeleteKeyArgs) ProtoMessage 

func (*DeleteKeyArgs) ProtoMessage()

func (*DeleteKeyArgs) ProtoReflect 

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

func (*DeleteKeyArgs) Reset 

func (x *DeleteKeyArgs) Reset()

func (*DeleteKeyArgs) String 

func (x *DeleteKeyArgs) String() string

type DeleteKeyRequest 

type DeleteKeyRequest struct {
	KeyArgs *KeyArgs `protobuf:"bytes,1,req,name=keyArgs" json:"keyArgs,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteKeyRequest) Descriptor deprecated 

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

Deprecated: Use DeleteKeyRequest.ProtoReflect.Descriptor instead.

func (*DeleteKeyRequest) GetKeyArgs 

func (x *DeleteKeyRequest) GetKeyArgs() *KeyArgs

func (*DeleteKeyRequest) ProtoMessage 

func (*DeleteKeyRequest) ProtoMessage()

func (*DeleteKeyRequest) ProtoReflect 

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

func (*DeleteKeyRequest) Reset 

func (x *DeleteKeyRequest) Reset()

func (*DeleteKeyRequest) String 

func (x *DeleteKeyRequest) String() string

type DeleteKeyResponse 

type DeleteKeyResponse struct {
	KeyInfo *KeyInfo `protobuf:"bytes,2,opt,name=keyInfo" json:"keyInfo,omitempty"`
	// clients' followup request may carry this ID for stateful operations
	// (similar to a cookie).
	ID          *uint64 `protobuf:"varint,3,opt,name=ID" json:"ID,omitempty"`
	OpenVersion *uint64 `protobuf:"varint,4,opt,name=openVersion" json:"openVersion,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteKeyResponse) Descriptor deprecated 

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

Deprecated: Use DeleteKeyResponse.ProtoReflect.Descriptor instead.

func (*DeleteKeyResponse) GetID 

func (x *DeleteKeyResponse) GetID() uint64

func (*DeleteKeyResponse) GetKeyInfo 

func (x *DeleteKeyResponse) GetKeyInfo() *KeyInfo

func (*DeleteKeyResponse) GetOpenVersion 

func (x *DeleteKeyResponse) GetOpenVersion() uint64

func (*DeleteKeyResponse) ProtoMessage 

func (*DeleteKeyResponse) ProtoMessage()

func (*DeleteKeyResponse) ProtoReflect 

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

func (*DeleteKeyResponse) Reset 

func (x *DeleteKeyResponse) Reset()

func (*DeleteKeyResponse) String 

func (x *DeleteKeyResponse) String() string

type DeleteKeysRequest 

type DeleteKeysRequest struct {
	DeleteKeys *DeleteKeyArgs `protobuf:"bytes,1,opt,name=deleteKeys" json:"deleteKeys,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteKeysRequest) Descriptor deprecated 

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

Deprecated: Use DeleteKeysRequest.ProtoReflect.Descriptor instead.

func (*DeleteKeysRequest) GetDeleteKeys 

func (x *DeleteKeysRequest) GetDeleteKeys() *DeleteKeyArgs

func (*DeleteKeysRequest) ProtoMessage 

func (*DeleteKeysRequest) ProtoMessage()

func (*DeleteKeysRequest) ProtoReflect 

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

func (*DeleteKeysRequest) Reset 

func (x *DeleteKeysRequest) Reset()

func (*DeleteKeysRequest) String 

func (x *DeleteKeysRequest) String() string

type DeleteKeysResponse 

type DeleteKeysResponse struct {
	UnDeletedKeys *DeleteKeyArgs `protobuf:"bytes,1,opt,name=unDeletedKeys" json:"unDeletedKeys,omitempty"`
	Status        *bool          `protobuf:"varint,2,opt,name=status" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteKeysResponse) Descriptor deprecated 

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

Deprecated: Use DeleteKeysResponse.ProtoReflect.Descriptor instead.

func (*DeleteKeysResponse) GetStatus 

func (x *DeleteKeysResponse) GetStatus() bool

func (*DeleteKeysResponse) GetUnDeletedKeys 

func (x *DeleteKeysResponse) GetUnDeletedKeys() *DeleteKeyArgs

func (*DeleteKeysResponse) ProtoMessage 

func (*DeleteKeysResponse) ProtoMessage()

func (*DeleteKeysResponse) ProtoReflect 

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

func (*DeleteKeysResponse) Reset 

func (x *DeleteKeysResponse) Reset()

func (*DeleteKeysResponse) String 

func (x *DeleteKeysResponse) String() string

type DeleteVolumeRequest 

type DeleteVolumeRequest struct {
	VolumeName *string `protobuf:"bytes,1,req,name=volumeName" json:"volumeName,omitempty"`
	// contains filtered or unexported fields
}

* Deletes an existing volume.

func (*DeleteVolumeRequest) Descriptor deprecated 

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

Deprecated: Use DeleteVolumeRequest.ProtoReflect.Descriptor instead.

func (*DeleteVolumeRequest) GetVolumeName 

func (x *DeleteVolumeRequest) GetVolumeName() string

func (*DeleteVolumeRequest) ProtoMessage 

func (*DeleteVolumeRequest) ProtoMessage()

func (*DeleteVolumeRequest) ProtoReflect 

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

func (*DeleteVolumeRequest) Reset 

func (x *DeleteVolumeRequest) Reset()

func (*DeleteVolumeRequest) String 

func (x *DeleteVolumeRequest) String() string

type DeleteVolumeResponse 

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

func (*DeleteVolumeResponse) Descriptor deprecated 

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

Deprecated: Use DeleteVolumeResponse.ProtoReflect.Descriptor instead.

func (*DeleteVolumeResponse) ProtoMessage 

func (*DeleteVolumeResponse) ProtoMessage()

func (*DeleteVolumeResponse) ProtoReflect 

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

func (*DeleteVolumeResponse) Reset 

func (x *DeleteVolumeResponse) Reset()

func (*DeleteVolumeResponse) String 

func (x *DeleteVolumeResponse) String() string

type DeletedKeys 

type DeletedKeys struct {
	VolumeName *string  `protobuf:"bytes,1,req,name=volumeName" json:"volumeName,omitempty"`
	BucketName *string  `protobuf:"bytes,2,req,name=bucketName" json:"bucketName,omitempty"`
	Keys       []string `protobuf:"bytes,3,rep,name=keys" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

func (*DeletedKeys) Descriptor deprecated 

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

Deprecated: Use DeletedKeys.ProtoReflect.Descriptor instead.

func (*DeletedKeys) GetBucketName 

func (x *DeletedKeys) GetBucketName() string

func (*DeletedKeys) GetKeys 

func (x *DeletedKeys) GetKeys() []string

func (*DeletedKeys) GetVolumeName 

func (x *DeletedKeys) GetVolumeName() string

func (*DeletedKeys) ProtoMessage 

func (*DeletedKeys) ProtoMessage()

func (*DeletedKeys) ProtoReflect 

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

func (*DeletedKeys) Reset 

func (x *DeletedKeys) Reset()

func (*DeletedKeys) String 

func (x *DeletedKeys) String() string

type FileEncryptionInfoProto 

type FileEncryptionInfoProto struct {
	Suite                 *CipherSuiteProto           `protobuf:"varint,1,req,name=suite,enum=hadoop.ozone.CipherSuiteProto" json:"suite,omitempty"`
	CryptoProtocolVersion *CryptoProtocolVersionProto `` /* 134-byte string literal not displayed */
	Key                   []byte                      `protobuf:"bytes,3,req,name=key" json:"key,omitempty"`
	Iv                    []byte                      `protobuf:"bytes,4,req,name=iv" json:"iv,omitempty"`
	KeyName               *string                     `protobuf:"bytes,5,req,name=keyName" json:"keyName,omitempty"`
	EzKeyVersionName      *string                     `protobuf:"bytes,6,req,name=ezKeyVersionName" json:"ezKeyVersionName,omitempty"`
	// contains filtered or unexported fields
}

* Encryption information for a file.

func (*FileEncryptionInfoProto) Descriptor deprecated 

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

Deprecated: Use FileEncryptionInfoProto.ProtoReflect.Descriptor instead.

func (*FileEncryptionInfoProto) GetCryptoProtocolVersion 

func (x *FileEncryptionInfoProto) GetCryptoProtocolVersion() CryptoProtocolVersionProto

func (*FileEncryptionInfoProto) GetEzKeyVersionName 

func (x *FileEncryptionInfoProto) GetEzKeyVersionName() string

func (*FileEncryptionInfoProto) GetIv 

func (x *FileEncryptionInfoProto) GetIv() []byte

func (*FileEncryptionInfoProto) GetKey 

func (x *FileEncryptionInfoProto) GetKey() []byte

func (*FileEncryptionInfoProto) GetKeyName 

func (x *FileEncryptionInfoProto) GetKeyName() string

func (*FileEncryptionInfoProto) GetSuite 

func (x *FileEncryptionInfoProto) GetSuite() CipherSuiteProto

func (*FileEncryptionInfoProto) ProtoMessage 

func (*FileEncryptionInfoProto) ProtoMessage()

func (*FileEncryptionInfoProto) ProtoReflect 

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

func (*FileEncryptionInfoProto) Reset 

func (x *FileEncryptionInfoProto) Reset()

func (*FileEncryptionInfoProto) String 

func (x *FileEncryptionInfoProto) String() string

type GetAclRequest 

type GetAclRequest struct {
	Obj *OzoneObj `protobuf:"bytes,1,req,name=obj" json:"obj,omitempty"`
	// contains filtered or unexported fields
}

func (*GetAclRequest) Descriptor deprecated 

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

Deprecated: Use GetAclRequest.ProtoReflect.Descriptor instead.

func (*GetAclRequest) GetObj 

func (x *GetAclRequest) GetObj() *OzoneObj

func (*GetAclRequest) ProtoMessage 

func (*GetAclRequest) ProtoMessage()

func (*GetAclRequest) ProtoReflect 

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

func (*GetAclRequest) Reset 

func (x *GetAclRequest) Reset()

func (*GetAclRequest) String 

func (x *GetAclRequest) String() string

type GetAclResponse 

type GetAclResponse struct {
	Acls []*OzoneAclInfo `protobuf:"bytes,1,rep,name=acls" json:"acls,omitempty"`
	// contains filtered or unexported fields
}

func (*GetAclResponse) Descriptor deprecated 

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

Deprecated: Use GetAclResponse.ProtoReflect.Descriptor instead.

func (*GetAclResponse) GetAcls 

func (x *GetAclResponse) GetAcls() []*OzoneAclInfo

func (*GetAclResponse) ProtoMessage 

func (*GetAclResponse) ProtoMessage()

func (*GetAclResponse) ProtoReflect 

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

func (*GetAclResponse) Reset 

func (x *GetAclResponse) Reset()

func (*GetAclResponse) String 

func (x *GetAclResponse) String() string

type GetDelegationTokenResponseProto 

type GetDelegationTokenResponseProto struct {
	Response *common.GetDelegationTokenResponseProto `protobuf:"bytes,2,opt,name=response" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDelegationTokenResponseProto) Descriptor deprecated 

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

Deprecated: Use GetDelegationTokenResponseProto.ProtoReflect.Descriptor instead.

func (*GetDelegationTokenResponseProto) GetResponse 

func (x *GetDelegationTokenResponseProto) GetResponse() *common.GetDelegationTokenResponseProto

func (*GetDelegationTokenResponseProto) ProtoMessage 

func (*GetDelegationTokenResponseProto) ProtoMessage()

func (*GetDelegationTokenResponseProto) ProtoReflect 

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

func (*GetDelegationTokenResponseProto) Reset 

func (x *GetDelegationTokenResponseProto) Reset()

func (*GetDelegationTokenResponseProto) String 

func (x *GetDelegationTokenResponseProto) String() string

type GetFileStatusRequest 

type GetFileStatusRequest struct {
	KeyArgs *KeyArgs `protobuf:"bytes,1,req,name=keyArgs" json:"keyArgs,omitempty"`
	// contains filtered or unexported fields
}

func (*GetFileStatusRequest) Descriptor deprecated 

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

Deprecated: Use GetFileStatusRequest.ProtoReflect.Descriptor instead.

func (*GetFileStatusRequest) GetKeyArgs 

func (x *GetFileStatusRequest) GetKeyArgs() *KeyArgs

func (*GetFileStatusRequest) ProtoMessage 

func (*GetFileStatusRequest) ProtoMessage()

func (*GetFileStatusRequest) ProtoReflect 

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

func (*GetFileStatusRequest) Reset 

func (x *GetFileStatusRequest) Reset()

func (*GetFileStatusRequest) String 

func (x *GetFileStatusRequest) String() string

type GetFileStatusResponse 

type GetFileStatusResponse struct {
	Status *OzoneFileStatusProto `protobuf:"bytes,1,req,name=status" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*GetFileStatusResponse) Descriptor deprecated 

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

Deprecated: Use GetFileStatusResponse.ProtoReflect.Descriptor instead.

func (*GetFileStatusResponse) GetStatus 

func (x *GetFileStatusResponse) GetStatus() *OzoneFileStatusProto

func (*GetFileStatusResponse) ProtoMessage 

func (*GetFileStatusResponse) ProtoMessage()

func (*GetFileStatusResponse) ProtoReflect 

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

func (*GetFileStatusResponse) Reset 

func (x *GetFileStatusResponse) Reset()

func (*GetFileStatusResponse) String 

func (x *GetFileStatusResponse) String() string

type GetS3SecretRequest 

type GetS3SecretRequest struct {
	KerberosID *string `protobuf:"bytes,1,req,name=kerberosID" json:"kerberosID,omitempty"`
	// contains filtered or unexported fields
}

func (*GetS3SecretRequest) Descriptor deprecated 

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

Deprecated: Use GetS3SecretRequest.ProtoReflect.Descriptor instead.

func (*GetS3SecretRequest) GetKerberosID 

func (x *GetS3SecretRequest) GetKerberosID() string

func (*GetS3SecretRequest) ProtoMessage 

func (*GetS3SecretRequest) ProtoMessage()

func (*GetS3SecretRequest) ProtoReflect 

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

func (*GetS3SecretRequest) Reset 

func (x *GetS3SecretRequest) Reset()

func (*GetS3SecretRequest) String 

func (x *GetS3SecretRequest) String() string

type GetS3SecretResponse 

type GetS3SecretResponse struct {
	S3Secret *S3Secret `protobuf:"bytes,2,req,name=s3Secret" json:"s3Secret,omitempty"`
	// contains filtered or unexported fields
}

func (*GetS3SecretResponse) Descriptor deprecated 

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

Deprecated: Use GetS3SecretResponse.ProtoReflect.Descriptor instead.

func (*GetS3SecretResponse) GetS3Secret 

func (x *GetS3SecretResponse) GetS3Secret() *S3Secret

func (*GetS3SecretResponse) ProtoMessage 

func (*GetS3SecretResponse) ProtoMessage()

func (*GetS3SecretResponse) ProtoReflect 

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

func (*GetS3SecretResponse) Reset 

func (x *GetS3SecretResponse) Reset()

func (*GetS3SecretResponse) String 

func (x *GetS3SecretResponse) String() string

type InfoBucketRequest 

type InfoBucketRequest struct {
	VolumeName *string `protobuf:"bytes,1,req,name=volumeName" json:"volumeName,omitempty"`
	BucketName *string `protobuf:"bytes,2,req,name=bucketName" json:"bucketName,omitempty"`
	// contains filtered or unexported fields
}

func (*InfoBucketRequest) Descriptor deprecated 

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

Deprecated: Use InfoBucketRequest.ProtoReflect.Descriptor instead.

func (*InfoBucketRequest) GetBucketName 

func (x *InfoBucketRequest) GetBucketName() string

func (*InfoBucketRequest) GetVolumeName 

func (x *InfoBucketRequest) GetVolumeName() string

func (*InfoBucketRequest) ProtoMessage 

func (*InfoBucketRequest) ProtoMessage()

func (*InfoBucketRequest) ProtoReflect 

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

func (*InfoBucketRequest) Reset 

func (x *InfoBucketRequest) Reset()

func (*InfoBucketRequest) String 

func (x *InfoBucketRequest) String() string

type InfoBucketResponse 

type InfoBucketResponse struct {
	BucketInfo *BucketInfo `protobuf:"bytes,2,opt,name=bucketInfo" json:"bucketInfo,omitempty"`
	// contains filtered or unexported fields
}

func (*InfoBucketResponse) Descriptor deprecated 

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

Deprecated: Use InfoBucketResponse.ProtoReflect.Descriptor instead.

func (*InfoBucketResponse) GetBucketInfo 

func (x *InfoBucketResponse) GetBucketInfo() *BucketInfo

func (*InfoBucketResponse) ProtoMessage 

func (*InfoBucketResponse) ProtoMessage()

func (*InfoBucketResponse) ProtoReflect 

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

func (*InfoBucketResponse) Reset 

func (x *InfoBucketResponse) Reset()

func (*InfoBucketResponse) String 

func (x *InfoBucketResponse) String() string

type InfoVolumeRequest 

type InfoVolumeRequest struct {
	VolumeName *string `protobuf:"bytes,1,req,name=volumeName" json:"volumeName,omitempty"`
	// contains filtered or unexported fields
}

func (*InfoVolumeRequest) Descriptor deprecated 

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

Deprecated: Use InfoVolumeRequest.ProtoReflect.Descriptor instead.

func (*InfoVolumeRequest) GetVolumeName 

func (x *InfoVolumeRequest) GetVolumeName() string

func (*InfoVolumeRequest) ProtoMessage 

func (*InfoVolumeRequest) ProtoMessage()

func (*InfoVolumeRequest) ProtoReflect 

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

func (*InfoVolumeRequest) Reset 

func (x *InfoVolumeRequest) Reset()

func (*InfoVolumeRequest) String 

func (x *InfoVolumeRequest) String() string

type InfoVolumeResponse 

type InfoVolumeResponse struct {
	VolumeInfo *VolumeInfo `protobuf:"bytes,2,opt,name=volumeInfo" json:"volumeInfo,omitempty"`
	// contains filtered or unexported fields
}

func (*InfoVolumeResponse) Descriptor deprecated 

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

Deprecated: Use InfoVolumeResponse.ProtoReflect.Descriptor instead.

func (*InfoVolumeResponse) GetVolumeInfo 

func (x *InfoVolumeResponse) GetVolumeInfo() *VolumeInfo

func (*InfoVolumeResponse) ProtoMessage 

func (*InfoVolumeResponse) ProtoMessage()

func (*InfoVolumeResponse) ProtoReflect 

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

func (*InfoVolumeResponse) Reset 

func (x *InfoVolumeResponse) Reset()

func (*InfoVolumeResponse) String 

func (x *InfoVolumeResponse) String() string

type KeyArgs 

type KeyArgs struct {
	VolumeName        *string                 `protobuf:"bytes,1,req,name=volumeName" json:"volumeName,omitempty"`
	BucketName        *string                 `protobuf:"bytes,2,req,name=bucketName" json:"bucketName,omitempty"`
	KeyName           *string                 `protobuf:"bytes,3,req,name=keyName" json:"keyName,omitempty"`
	DataSize          *uint64                 `protobuf:"varint,4,opt,name=dataSize" json:"dataSize,omitempty"`
	Type              *hdds.ReplicationType   `protobuf:"varint,5,opt,name=type,enum=hadoop.hdds.ReplicationType" json:"type,omitempty"`
	Factor            *hdds.ReplicationFactor `protobuf:"varint,6,opt,name=factor,enum=hadoop.hdds.ReplicationFactor" json:"factor,omitempty"`
	KeyLocations      []*KeyLocation          `protobuf:"bytes,7,rep,name=keyLocations" json:"keyLocations,omitempty"`
	IsMultipartKey    *bool                   `protobuf:"varint,8,opt,name=isMultipartKey" json:"isMultipartKey,omitempty"`
	MultipartUploadID *string                 `protobuf:"bytes,9,opt,name=multipartUploadID" json:"multipartUploadID,omitempty"`
	MultipartNumber   *uint32                 `protobuf:"varint,10,opt,name=multipartNumber" json:"multipartNumber,omitempty"`
	Metadata          []*hdds.KeyValue        `protobuf:"bytes,11,rep,name=metadata" json:"metadata,omitempty"`
	Acls              []*OzoneAclInfo         `protobuf:"bytes,12,rep,name=acls" json:"acls,omitempty"`
	// This will be set when the request is received in pre-Execute. This
	// value is used in setting creation/modification time depending on the
	// request type.
	ModificationTime *uint64 `protobuf:"varint,13,opt,name=modificationTime" json:"modificationTime,omitempty"`
	SortDatanodes    *bool   `protobuf:"varint,14,opt,name=sortDatanodes" json:"sortDatanodes,omitempty"`
	// This will be set by leader OM in HA and update the original request.
	FileEncryptionInfo *FileEncryptionInfoProto `protobuf:"bytes,15,opt,name=fileEncryptionInfo" json:"fileEncryptionInfo,omitempty"`
	// contains filtered or unexported fields
}

func (*KeyArgs) Descriptor deprecated 

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

Deprecated: Use KeyArgs.ProtoReflect.Descriptor instead.

func (*KeyArgs) GetAcls 

func (x *KeyArgs) GetAcls() []*OzoneAclInfo

func (*KeyArgs) GetBucketName 

func (x *KeyArgs) GetBucketName() string

func (*KeyArgs) GetDataSize 

func (x *KeyArgs) GetDataSize() uint64

func (*KeyArgs) GetFactor 

func (x *KeyArgs) GetFactor() hdds.ReplicationFactor

func (*KeyArgs) GetFileEncryptionInfo 

func (x *KeyArgs) GetFileEncryptionInfo() *FileEncryptionInfoProto

func (*KeyArgs) GetIsMultipartKey 

func (x *KeyArgs) GetIsMultipartKey() bool

func (*KeyArgs) GetKeyLocations 

func (x *KeyArgs) GetKeyLocations() []*KeyLocation

func (*KeyArgs) GetKeyName 

func (x *KeyArgs) GetKeyName() string

func (*KeyArgs) GetMetadata 

func (x *KeyArgs) GetMetadata() []*hdds.KeyValue

func (*KeyArgs) GetModificationTime 

func (x *KeyArgs) GetModificationTime() uint64

func (*KeyArgs) GetMultipartNumber 

func (x *KeyArgs) GetMultipartNumber() uint32

func (*KeyArgs) GetMultipartUploadID 

func (x *KeyArgs) GetMultipartUploadID() string

func (*KeyArgs) GetSortDatanodes 

func (x *KeyArgs) GetSortDatanodes() bool

func (*KeyArgs) GetType 

func (x *KeyArgs) GetType() hdds.ReplicationType

func (*KeyArgs) GetVolumeName 

func (x *KeyArgs) GetVolumeName() string

func (*KeyArgs) ProtoMessage 

func (*KeyArgs) ProtoMessage()

func (*KeyArgs) ProtoReflect 

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

func (*KeyArgs) Reset 

func (x *KeyArgs) Reset()

func (*KeyArgs) String 

func (x *KeyArgs) String() string

type KeyInfo 

type KeyInfo struct {
	VolumeName         *string                  `protobuf:"bytes,1,req,name=volumeName" json:"volumeName,omitempty"`
	BucketName         *string                  `protobuf:"bytes,2,req,name=bucketName" json:"bucketName,omitempty"`
	KeyName            *string                  `protobuf:"bytes,3,req,name=keyName" json:"keyName,omitempty"`
	DataSize           *uint64                  `protobuf:"varint,4,req,name=dataSize" json:"dataSize,omitempty"`
	Type               *hdds.ReplicationType    `protobuf:"varint,5,req,name=type,enum=hadoop.hdds.ReplicationType" json:"type,omitempty"`
	Factor             *hdds.ReplicationFactor  `protobuf:"varint,6,req,name=factor,enum=hadoop.hdds.ReplicationFactor" json:"factor,omitempty"`
	KeyLocationList    []*KeyLocationList       `protobuf:"bytes,7,rep,name=keyLocationList" json:"keyLocationList,omitempty"`
	CreationTime       *uint64                  `protobuf:"varint,8,req,name=creationTime" json:"creationTime,omitempty"`
	ModificationTime   *uint64                  `protobuf:"varint,9,req,name=modificationTime" json:"modificationTime,omitempty"`
	LatestVersion      *uint64                  `protobuf:"varint,10,opt,name=latestVersion" json:"latestVersion,omitempty"`
	Metadata           []*hdds.KeyValue         `protobuf:"bytes,11,rep,name=metadata" json:"metadata,omitempty"`
	FileEncryptionInfo *FileEncryptionInfoProto `protobuf:"bytes,12,opt,name=fileEncryptionInfo" json:"fileEncryptionInfo,omitempty"`
	Acls               []*OzoneAclInfo          `protobuf:"bytes,13,rep,name=acls" json:"acls,omitempty"`
	ObjectID           *uint64                  `protobuf:"varint,14,opt,name=objectID" json:"objectID,omitempty"`
	UpdateID           *uint64                  `protobuf:"varint,15,opt,name=updateID" json:"updateID,omitempty"`
	// contains filtered or unexported fields
}

func (*KeyInfo) Descriptor deprecated 

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

Deprecated: Use KeyInfo.ProtoReflect.Descriptor instead.

func (*KeyInfo) GetAcls 

func (x *KeyInfo) GetAcls() []*OzoneAclInfo

func (*KeyInfo) GetBucketName 

func (x *KeyInfo) GetBucketName() string

func (*KeyInfo) GetCreationTime 

func (x *KeyInfo) GetCreationTime() uint64

func (*KeyInfo) GetDataSize 

func (x *KeyInfo) GetDataSize() uint64

func (*KeyInfo) GetFactor 

func (x *KeyInfo) GetFactor() hdds.ReplicationFactor

func (*KeyInfo) GetFileEncryptionInfo 

func (x *KeyInfo) GetFileEncryptionInfo() *FileEncryptionInfoProto

func (*KeyInfo) GetKeyLocationList 

func (x *KeyInfo) GetKeyLocationList() []*KeyLocationList

func (*KeyInfo) GetKeyName 

func (x *KeyInfo) GetKeyName() string

func (*KeyInfo) GetLatestVersion 

func (x *KeyInfo) GetLatestVersion() uint64

func (*KeyInfo) GetMetadata 

func (x *KeyInfo) GetMetadata() []*hdds.KeyValue

func (*KeyInfo) GetModificationTime 

func (x *KeyInfo) GetModificationTime() uint64

func (*KeyInfo) GetObjectID 

func (x *KeyInfo) GetObjectID() uint64

func (*KeyInfo) GetType 

func (x *KeyInfo) GetType() hdds.ReplicationType

func (*KeyInfo) GetUpdateID 

func (x *KeyInfo) GetUpdateID() uint64

func (*KeyInfo) GetVolumeName 

func (x *KeyInfo) GetVolumeName() string

func (*KeyInfo) ProtoMessage 

func (*KeyInfo) ProtoMessage()

func (*KeyInfo) ProtoReflect 

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

func (*KeyInfo) Reset 

func (x *KeyInfo) Reset()

func (*KeyInfo) String 

func (x *KeyInfo) String() string

type KeyLocation 

type KeyLocation struct {
	BlockID *hdds.BlockID `protobuf:"bytes,1,req,name=blockID" json:"blockID,omitempty"`
	Offset  *uint64       `protobuf:"varint,3,req,name=offset" json:"offset,omitempty"`
	Length  *uint64       `protobuf:"varint,4,req,name=length" json:"length,omitempty"`
	// indicated at which version this block gets created.
	CreateVersion *uint64            `protobuf:"varint,5,opt,name=createVersion" json:"createVersion,omitempty"`
	Token         *common.TokenProto `protobuf:"bytes,6,opt,name=token" json:"token,omitempty"`
	// Walk around to include pipeline info for client read/write
	// without talking to scm.
	// NOTE: the pipeline info may change after pipeline close.
	// So eventually, we will have to change back to call scm to
	// get the up to date pipeline information. This will need o3fs
	// provide not only a OM delegation token but also a SCM delegation token
	Pipeline *hdds.Pipeline `protobuf:"bytes,7,opt,name=pipeline" json:"pipeline,omitempty"`
	// contains filtered or unexported fields
}

func (*KeyLocation) Descriptor deprecated 

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

Deprecated: Use KeyLocation.ProtoReflect.Descriptor instead.

func (*KeyLocation) GetBlockID 

func (x *KeyLocation) GetBlockID() *hdds.BlockID

func (*KeyLocation) GetCreateVersion 

func (x *KeyLocation) GetCreateVersion() uint64

func (*KeyLocation) GetLength 

func (x *KeyLocation) GetLength() uint64

func (*KeyLocation) GetOffset 

func (x *KeyLocation) GetOffset() uint64

func (*KeyLocation) GetPipeline 

func (x *KeyLocation) GetPipeline() *hdds.Pipeline

func (*KeyLocation) GetToken 

func (x *KeyLocation) GetToken() *common.TokenProto

func (*KeyLocation) ProtoMessage 

func (*KeyLocation) ProtoMessage()

func (*KeyLocation) ProtoReflect 

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

func (*KeyLocation) Reset 

func (x *KeyLocation) Reset()

func (*KeyLocation) String 

func (x *KeyLocation) String() string

type KeyLocationList 

type KeyLocationList struct {
	Version            *uint64                  `protobuf:"varint,1,opt,name=version" json:"version,omitempty"`
	KeyLocations       []*KeyLocation           `protobuf:"bytes,2,rep,name=keyLocations" json:"keyLocations,omitempty"`
	FileEncryptionInfo *FileEncryptionInfoProto `protobuf:"bytes,3,opt,name=fileEncryptionInfo" json:"fileEncryptionInfo,omitempty"`
	// contains filtered or unexported fields
}

func (*KeyLocationList) Descriptor deprecated 

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

Deprecated: Use KeyLocationList.ProtoReflect.Descriptor instead.

func (*KeyLocationList) GetFileEncryptionInfo 

func (x *KeyLocationList) GetFileEncryptionInfo() *FileEncryptionInfoProto

func (*KeyLocationList) GetKeyLocations 

func (x *KeyLocationList) GetKeyLocations() []*KeyLocation

func (*KeyLocationList) GetVersion 

func (x *KeyLocationList) GetVersion() uint64

func (*KeyLocationList) ProtoMessage 

func (*KeyLocationList) ProtoMessage()

func (*KeyLocationList) ProtoReflect 

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

func (*KeyLocationList) Reset 

func (x *KeyLocationList) Reset()

func (*KeyLocationList) String 

func (x *KeyLocationList) String() string

type ListBucketsRequest 

type ListBucketsRequest struct {
	VolumeName *string `protobuf:"bytes,1,req,name=volumeName" json:"volumeName,omitempty"`
	StartKey   *string `protobuf:"bytes,2,opt,name=startKey" json:"startKey,omitempty"`
	Prefix     *string `protobuf:"bytes,3,opt,name=prefix" json:"prefix,omitempty"`
	Count      *int32  `protobuf:"varint,4,opt,name=count" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*ListBucketsRequest) Descriptor deprecated 

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

Deprecated: Use ListBucketsRequest.ProtoReflect.Descriptor instead.

func (*ListBucketsRequest) GetCount 

func (x *ListBucketsRequest) GetCount() int32

func (*ListBucketsRequest) GetPrefix 

func (x *ListBucketsRequest) GetPrefix() string

func (*ListBucketsRequest) GetStartKey 

func (x *ListBucketsRequest) GetStartKey() string

func (*ListBucketsRequest) GetVolumeName 

func (x *ListBucketsRequest) GetVolumeName() string

func (*ListBucketsRequest) ProtoMessage 

func (*ListBucketsRequest) ProtoMessage()

func (*ListBucketsRequest) ProtoReflect 

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

func (*ListBucketsRequest) Reset 

func (x *ListBucketsRequest) Reset()

func (*ListBucketsRequest) String 

func (x *ListBucketsRequest) String() string

type ListBucketsResponse 

type ListBucketsResponse struct {
	BucketInfo []*BucketInfo `protobuf:"bytes,2,rep,name=bucketInfo" json:"bucketInfo,omitempty"`
	// contains filtered or unexported fields
}

func (*ListBucketsResponse) Descriptor deprecated 

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

Deprecated: Use ListBucketsResponse.ProtoReflect.Descriptor instead.

func (*ListBucketsResponse) GetBucketInfo 

func (x *ListBucketsResponse) GetBucketInfo() []*BucketInfo

func (*ListBucketsResponse) ProtoMessage 

func (*ListBucketsResponse) ProtoMessage()

func (*ListBucketsResponse) ProtoReflect 

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

func (*ListBucketsResponse) Reset 

func (x *ListBucketsResponse) Reset()

func (*ListBucketsResponse) String 

func (x *ListBucketsResponse) String() string

type ListKeysRequest 

type ListKeysRequest struct {
	VolumeName *string `protobuf:"bytes,1,req,name=volumeName" json:"volumeName,omitempty"`
	BucketName *string `protobuf:"bytes,2,req,name=bucketName" json:"bucketName,omitempty"`
	StartKey   *string `protobuf:"bytes,3,opt,name=startKey" json:"startKey,omitempty"`
	Prefix     *string `protobuf:"bytes,4,opt,name=prefix" json:"prefix,omitempty"`
	Count      *int32  `protobuf:"varint,5,opt,name=count" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*ListKeysRequest) Descriptor deprecated 

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

Deprecated: Use ListKeysRequest.ProtoReflect.Descriptor instead.

func (*ListKeysRequest) GetBucketName 

func (x *ListKeysRequest) GetBucketName() string

func (*ListKeysRequest) GetCount 

func (x *ListKeysRequest) GetCount() int32

func (*ListKeysRequest) GetPrefix 

func (x *ListKeysRequest) GetPrefix() string

func (*ListKeysRequest) GetStartKey 

func (x *ListKeysRequest) GetStartKey() string

func (*ListKeysRequest) GetVolumeName 

func (x *ListKeysRequest) GetVolumeName() string

func (*ListKeysRequest) ProtoMessage 

func (*ListKeysRequest) ProtoMessage()

func (*ListKeysRequest) ProtoReflect 

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

func (*ListKeysRequest) Reset 

func (x *ListKeysRequest) Reset()

func (*ListKeysRequest) String 

func (x *ListKeysRequest) String() string

type ListKeysResponse 

type ListKeysResponse struct {
	KeyInfo []*KeyInfo `protobuf:"bytes,2,rep,name=keyInfo" json:"keyInfo,omitempty"`
	// contains filtered or unexported fields
}

func (*ListKeysResponse) Descriptor deprecated 

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

Deprecated: Use ListKeysResponse.ProtoReflect.Descriptor instead.

func (*ListKeysResponse) GetKeyInfo 

func (x *ListKeysResponse) GetKeyInfo() []*KeyInfo

func (*ListKeysResponse) ProtoMessage 

func (*ListKeysResponse) ProtoMessage()

func (*ListKeysResponse) ProtoReflect 

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

func (*ListKeysResponse) Reset 

func (x *ListKeysResponse) Reset()

func (*ListKeysResponse) String 

func (x *ListKeysResponse) String() string

type ListMultipartUploadsRequest 

type ListMultipartUploadsRequest struct {
	Volume *string `protobuf:"bytes,1,req,name=volume" json:"volume,omitempty"`
	Bucket *string `protobuf:"bytes,2,req,name=bucket" json:"bucket,omitempty"`
	Prefix *string `protobuf:"bytes,3,req,name=prefix" json:"prefix,omitempty"`
	// contains filtered or unexported fields
}

func (*ListMultipartUploadsRequest) Descriptor deprecated 

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

Deprecated: Use ListMultipartUploadsRequest.ProtoReflect.Descriptor instead.

func (*ListMultipartUploadsRequest) GetBucket 

func (x *ListMultipartUploadsRequest) GetBucket() string

func (*ListMultipartUploadsRequest) GetPrefix 

func (x *ListMultipartUploadsRequest) GetPrefix() string

func (*ListMultipartUploadsRequest) GetVolume 

func (x *ListMultipartUploadsRequest) GetVolume() string

func (*ListMultipartUploadsRequest) ProtoMessage 

func (*ListMultipartUploadsRequest) ProtoMessage()

func (*ListMultipartUploadsRequest) ProtoReflect 

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

func (*ListMultipartUploadsRequest) Reset 

func (x *ListMultipartUploadsRequest) Reset()

func (*ListMultipartUploadsRequest) String 

func (x *ListMultipartUploadsRequest) String() string

type ListMultipartUploadsResponse 

type ListMultipartUploadsResponse struct {
	IsTruncated *bool                  `protobuf:"varint,1,opt,name=isTruncated" json:"isTruncated,omitempty"`
	UploadsList []*MultipartUploadInfo `protobuf:"bytes,2,rep,name=uploadsList" json:"uploadsList,omitempty"`
	// contains filtered or unexported fields
}

func (*ListMultipartUploadsResponse) Descriptor deprecated 

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

Deprecated: Use ListMultipartUploadsResponse.ProtoReflect.Descriptor instead.

func (*ListMultipartUploadsResponse) GetIsTruncated 

func (x *ListMultipartUploadsResponse) GetIsTruncated() bool

func (*ListMultipartUploadsResponse) GetUploadsList 

func (x *ListMultipartUploadsResponse) GetUploadsList() []*MultipartUploadInfo

func (*ListMultipartUploadsResponse) ProtoMessage 

func (*ListMultipartUploadsResponse) ProtoMessage()

func (*ListMultipartUploadsResponse) ProtoReflect 

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

func (*ListMultipartUploadsResponse) Reset 

func (x *ListMultipartUploadsResponse) Reset()

func (*ListMultipartUploadsResponse) String 

func (x *ListMultipartUploadsResponse) String() string

type ListStatusRequest 

type ListStatusRequest struct {
	KeyArgs    *KeyArgs `protobuf:"bytes,1,req,name=keyArgs" json:"keyArgs,omitempty"`
	Recursive  *bool    `protobuf:"varint,2,req,name=recursive" json:"recursive,omitempty"`
	StartKey   *string  `protobuf:"bytes,3,req,name=startKey" json:"startKey,omitempty"`
	NumEntries *uint64  `protobuf:"varint,4,req,name=numEntries" json:"numEntries,omitempty"`
	// contains filtered or unexported fields
}

func (*ListStatusRequest) Descriptor deprecated 

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

Deprecated: Use ListStatusRequest.ProtoReflect.Descriptor instead.

func (*ListStatusRequest) GetKeyArgs 

func (x *ListStatusRequest) GetKeyArgs() *KeyArgs

func (*ListStatusRequest) GetNumEntries 

func (x *ListStatusRequest) GetNumEntries() uint64

func (*ListStatusRequest) GetRecursive 

func (x *ListStatusRequest) GetRecursive() bool

func (*ListStatusRequest) GetStartKey 

func (x *ListStatusRequest) GetStartKey() string

func (*ListStatusRequest) ProtoMessage 

func (*ListStatusRequest) ProtoMessage()

func (*ListStatusRequest) ProtoReflect 

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

func (*ListStatusRequest) Reset 

func (x *ListStatusRequest) Reset()

func (*ListStatusRequest) String 

func (x *ListStatusRequest) String() string

type ListStatusResponse 

type ListStatusResponse struct {
	Statuses []*OzoneFileStatusProto `protobuf:"bytes,1,rep,name=statuses" json:"statuses,omitempty"`
	// contains filtered or unexported fields
}

func (*ListStatusResponse) Descriptor deprecated 

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

Deprecated: Use ListStatusResponse.ProtoReflect.Descriptor instead.

func (*ListStatusResponse) GetStatuses 

func (x *ListStatusResponse) GetStatuses() []*OzoneFileStatusProto

func (*ListStatusResponse) ProtoMessage 

func (*ListStatusResponse) ProtoMessage()

func (*ListStatusResponse) ProtoReflect 

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

func (*ListStatusResponse) Reset 

func (x *ListStatusResponse) Reset()

func (*ListStatusResponse) String 

func (x *ListStatusResponse) String() string

type ListTrashRequest 

type ListTrashRequest struct {
	VolumeName   *string `protobuf:"bytes,1,req,name=volumeName" json:"volumeName,omitempty"`
	BucketName   *string `protobuf:"bytes,2,req,name=bucketName" json:"bucketName,omitempty"`
	StartKeyName *string `protobuf:"bytes,3,opt,name=startKeyName" json:"startKeyName,omitempty"`
	KeyPrefix    *string `protobuf:"bytes,4,opt,name=keyPrefix" json:"keyPrefix,omitempty"`
	MaxKeys      *int32  `protobuf:"varint,5,opt,name=maxKeys" json:"maxKeys,omitempty"`
	// contains filtered or unexported fields
}

* This command acts as a list command for deleted keys that are still present in the deleted table on Ozone Manager.

func (*ListTrashRequest) Descriptor deprecated 

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

Deprecated: Use ListTrashRequest.ProtoReflect.Descriptor instead.

func (*ListTrashRequest) GetBucketName 

func (x *ListTrashRequest) GetBucketName() string

func (*ListTrashRequest) GetKeyPrefix 

func (x *ListTrashRequest) GetKeyPrefix() string

func (*ListTrashRequest) GetMaxKeys 

func (x *ListTrashRequest) GetMaxKeys() int32

func (*ListTrashRequest) GetStartKeyName 

func (x *ListTrashRequest) GetStartKeyName() string

func (*ListTrashRequest) GetVolumeName 

func (x *ListTrashRequest) GetVolumeName() string

func (*ListTrashRequest) ProtoMessage 

func (*ListTrashRequest) ProtoMessage()

func (*ListTrashRequest) ProtoReflect 

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

func (*ListTrashRequest) Reset 

func (x *ListTrashRequest) Reset()

func (*ListTrashRequest) String 

func (x *ListTrashRequest) String() string

type ListTrashResponse 

type ListTrashResponse struct {
	DeletedKeys []*RepeatedKeyInfo `protobuf:"bytes,1,rep,name=deletedKeys" json:"deletedKeys,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTrashResponse) Descriptor deprecated 

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

Deprecated: Use ListTrashResponse.ProtoReflect.Descriptor instead.

func (*ListTrashResponse) GetDeletedKeys 

func (x *ListTrashResponse) GetDeletedKeys() []*RepeatedKeyInfo

func (*ListTrashResponse) ProtoMessage 

func (*ListTrashResponse) ProtoMessage()

func (*ListTrashResponse) ProtoReflect 

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

func (*ListTrashResponse) Reset 

func (x *ListTrashResponse) Reset()

func (*ListTrashResponse) String 

func (x *ListTrashResponse) String() string

type ListVolumeRequest 

type ListVolumeRequest struct {
	Scope    *ListVolumeRequest_Scope `protobuf:"varint,1,req,name=scope,enum=hadoop.ozone.ListVolumeRequest_Scope" json:"scope,omitempty"`
	UserName *string                  `protobuf:"bytes,2,opt,name=userName" json:"userName,omitempty"`
	Prefix   *string                  `protobuf:"bytes,3,opt,name=prefix" json:"prefix,omitempty"`
	PrevKey  *string                  `protobuf:"bytes,4,opt,name=prevKey" json:"prevKey,omitempty"`
	MaxKeys  *uint32                  `protobuf:"varint,5,opt,name=maxKeys" json:"maxKeys,omitempty"`
	// contains filtered or unexported fields
}

func (*ListVolumeRequest) Descriptor deprecated 

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

Deprecated: Use ListVolumeRequest.ProtoReflect.Descriptor instead.

func (*ListVolumeRequest) GetMaxKeys 

func (x *ListVolumeRequest) GetMaxKeys() uint32

func (*ListVolumeRequest) GetPrefix 

func (x *ListVolumeRequest) GetPrefix() string

func (*ListVolumeRequest) GetPrevKey 

func (x *ListVolumeRequest) GetPrevKey() string

func (*ListVolumeRequest) GetScope 

func (x *ListVolumeRequest) GetScope() ListVolumeRequest_Scope

func (*ListVolumeRequest) GetUserName 

func (x *ListVolumeRequest) GetUserName() string

func (*ListVolumeRequest) ProtoMessage 

func (*ListVolumeRequest) ProtoMessage()

func (*ListVolumeRequest) ProtoReflect 

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

func (*ListVolumeRequest) Reset 

func (x *ListVolumeRequest) Reset()

func (*ListVolumeRequest) String 

func (x *ListVolumeRequest) String() string

type ListVolumeRequest_Scope 

type ListVolumeRequest_Scope int32
const (
	ListVolumeRequest_USER_VOLUMES       ListVolumeRequest_Scope = 1 // User volumes -- called by user
	ListVolumeRequest_VOLUMES_BY_USER    ListVolumeRequest_Scope = 2 // User volumes - called by Admin
	ListVolumeRequest_VOLUMES_BY_CLUSTER ListVolumeRequest_Scope = 3 // All volumes in the cluster
)

func (ListVolumeRequest_Scope) Descriptor 

func (ListVolumeRequest_Scope) Descriptor() protoreflect.EnumDescriptor

func (ListVolumeRequest_Scope) Enum 

func (x ListVolumeRequest_Scope) Enum() *ListVolumeRequest_Scope

func (ListVolumeRequest_Scope) EnumDescriptor deprecated 

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

Deprecated: Use ListVolumeRequest_Scope.Descriptor instead.

func (ListVolumeRequest_Scope) Number 

func (x ListVolumeRequest_Scope) Number() protoreflect.EnumNumber

func (ListVolumeRequest_Scope) String 

func (x ListVolumeRequest_Scope) String() string

func (ListVolumeRequest_Scope) Type 

func (ListVolumeRequest_Scope) Type() protoreflect.EnumType

func (*ListVolumeRequest_Scope) UnmarshalJSON deprecated 

func (x *ListVolumeRequest_Scope) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type ListVolumeResponse 

type ListVolumeResponse struct {
	VolumeInfo []*VolumeInfo `protobuf:"bytes,2,rep,name=volumeInfo" json:"volumeInfo,omitempty"`
	// contains filtered or unexported fields
}

func (*ListVolumeResponse) Descriptor deprecated 

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

Deprecated: Use ListVolumeResponse.ProtoReflect.Descriptor instead.

func (*ListVolumeResponse) GetVolumeInfo 

func (x *ListVolumeResponse) GetVolumeInfo() []*VolumeInfo

func (*ListVolumeResponse) ProtoMessage 

func (*ListVolumeResponse) ProtoMessage()

func (*ListVolumeResponse) ProtoReflect 

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

func (*ListVolumeResponse) Reset 

func (x *ListVolumeResponse) Reset()

func (*ListVolumeResponse) String 

func (x *ListVolumeResponse) String() string

type LookupFileRequest 

type LookupFileRequest struct {
	KeyArgs *KeyArgs `protobuf:"bytes,1,req,name=keyArgs" json:"keyArgs,omitempty"`
	// contains filtered or unexported fields
}

func (*LookupFileRequest) Descriptor deprecated 

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

Deprecated: Use LookupFileRequest.ProtoReflect.Descriptor instead.

func (*LookupFileRequest) GetKeyArgs 

func (x *LookupFileRequest) GetKeyArgs() *KeyArgs

func (*LookupFileRequest) ProtoMessage 

func (*LookupFileRequest) ProtoMessage()

func (*LookupFileRequest) ProtoReflect 

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

func (*LookupFileRequest) Reset 

func (x *LookupFileRequest) Reset()

func (*LookupFileRequest) String 

func (x *LookupFileRequest) String() string

type LookupFileResponse 

type LookupFileResponse struct {
	KeyInfo *KeyInfo `protobuf:"bytes,1,opt,name=keyInfo" json:"keyInfo,omitempty"`
	// contains filtered or unexported fields
}

func (*LookupFileResponse) Descriptor deprecated 

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

Deprecated: Use LookupFileResponse.ProtoReflect.Descriptor instead.

func (*LookupFileResponse) GetKeyInfo 

func (x *LookupFileResponse) GetKeyInfo() *KeyInfo

func (*LookupFileResponse) ProtoMessage 

func (*LookupFileResponse) ProtoMessage()

func (*LookupFileResponse) ProtoReflect 

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

func (*LookupFileResponse) Reset 

func (x *LookupFileResponse) Reset()

func (*LookupFileResponse) String 

func (x *LookupFileResponse) String() string

type LookupKeyRequest 

type LookupKeyRequest struct {
	KeyArgs *KeyArgs `protobuf:"bytes,1,req,name=keyArgs" json:"keyArgs,omitempty"`
	// contains filtered or unexported fields
}

func (*LookupKeyRequest) Descriptor deprecated 

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

Deprecated: Use LookupKeyRequest.ProtoReflect.Descriptor instead.

func (*LookupKeyRequest) GetKeyArgs 

func (x *LookupKeyRequest) GetKeyArgs() *KeyArgs

func (*LookupKeyRequest) ProtoMessage 

func (*LookupKeyRequest) ProtoMessage()

func (*LookupKeyRequest) ProtoReflect 

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

func (*LookupKeyRequest) Reset 

func (x *LookupKeyRequest) Reset()

func (*LookupKeyRequest) String 

func (x *LookupKeyRequest) String() string

type LookupKeyResponse 

type LookupKeyResponse struct {
	KeyInfo *KeyInfo `protobuf:"bytes,2,opt,name=keyInfo" json:"keyInfo,omitempty"`
	// clients' followup request may carry this ID for stateful operations (similar
	// to a cookie).
	ID *uint64 `protobuf:"varint,3,opt,name=ID" json:"ID,omitempty"`
	// TODO : allow specifiying a particular version to read.
	OpenVersion *uint64 `protobuf:"varint,4,opt,name=openVersion" json:"openVersion,omitempty"`
	// contains filtered or unexported fields
}

func (*LookupKeyResponse) Descriptor deprecated 

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

Deprecated: Use LookupKeyResponse.ProtoReflect.Descriptor instead.

func (*LookupKeyResponse) GetID 

func (x *LookupKeyResponse) GetID() uint64

func (*LookupKeyResponse) GetKeyInfo 

func (x *LookupKeyResponse) GetKeyInfo() *KeyInfo

func (*LookupKeyResponse) GetOpenVersion 

func (x *LookupKeyResponse) GetOpenVersion() uint64

func (*LookupKeyResponse) ProtoMessage 

func (*LookupKeyResponse) ProtoMessage()

func (*LookupKeyResponse) ProtoReflect 

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

func (*LookupKeyResponse) Reset 

func (x *LookupKeyResponse) Reset()

func (*LookupKeyResponse) String 

func (x *LookupKeyResponse) String() string

type MultipartCommitUploadPartRequest 

type MultipartCommitUploadPartRequest struct {
	KeyArgs  *KeyArgs `protobuf:"bytes,1,req,name=keyArgs" json:"keyArgs,omitempty"`
	ClientID *uint64  `protobuf:"varint,2,req,name=clientID" json:"clientID,omitempty"`
	// contains filtered or unexported fields
}

func (*MultipartCommitUploadPartRequest) Descriptor deprecated 

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

Deprecated: Use MultipartCommitUploadPartRequest.ProtoReflect.Descriptor instead.

func (*MultipartCommitUploadPartRequest) GetClientID 

func (x *MultipartCommitUploadPartRequest) GetClientID() uint64

func (*MultipartCommitUploadPartRequest) GetKeyArgs 

func (x *MultipartCommitUploadPartRequest) GetKeyArgs() *KeyArgs

func (*MultipartCommitUploadPartRequest) ProtoMessage 

func (*MultipartCommitUploadPartRequest) ProtoMessage()

func (*MultipartCommitUploadPartRequest) ProtoReflect 

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

func (*MultipartCommitUploadPartRequest) Reset 

func (x *MultipartCommitUploadPartRequest) Reset()

func (*MultipartCommitUploadPartRequest) String 

func (x *MultipartCommitUploadPartRequest) String() string

type MultipartCommitUploadPartResponse 

type MultipartCommitUploadPartResponse struct {

	// This one is returned as Etag for S3.
	PartName *string `protobuf:"bytes,1,opt,name=partName" json:"partName,omitempty"`
	// contains filtered or unexported fields
}

func (*MultipartCommitUploadPartResponse) Descriptor deprecated 

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

Deprecated: Use MultipartCommitUploadPartResponse.ProtoReflect.Descriptor instead.

func (*MultipartCommitUploadPartResponse) GetPartName 

func (x *MultipartCommitUploadPartResponse) GetPartName() string

func (*MultipartCommitUploadPartResponse) ProtoMessage 

func (*MultipartCommitUploadPartResponse) ProtoMessage()

func (*MultipartCommitUploadPartResponse) ProtoReflect 

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

func (*MultipartCommitUploadPartResponse) Reset 

func (x *MultipartCommitUploadPartResponse) Reset()

func (*MultipartCommitUploadPartResponse) String 

func (x *MultipartCommitUploadPartResponse) String() string

type MultipartInfoInitiateRequest 

type MultipartInfoInitiateRequest struct {
	KeyArgs *KeyArgs `protobuf:"bytes,1,req,name=keyArgs" json:"keyArgs,omitempty"`
	// contains filtered or unexported fields
}

func (*MultipartInfoInitiateRequest) Descriptor deprecated 

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

Deprecated: Use MultipartInfoInitiateRequest.ProtoReflect.Descriptor instead.

func (*MultipartInfoInitiateRequest) GetKeyArgs 

func (x *MultipartInfoInitiateRequest) GetKeyArgs() *KeyArgs

func (*MultipartInfoInitiateRequest) ProtoMessage 

func (*MultipartInfoInitiateRequest) ProtoMessage()

func (*MultipartInfoInitiateRequest) ProtoReflect 

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

func (*MultipartInfoInitiateRequest) Reset 

func (x *MultipartInfoInitiateRequest) Reset()

func (*MultipartInfoInitiateRequest) String 

func (x *MultipartInfoInitiateRequest) String() string

type MultipartInfoInitiateResponse 

type MultipartInfoInitiateResponse struct {
	VolumeName        *string `protobuf:"bytes,1,req,name=volumeName" json:"volumeName,omitempty"`
	BucketName        *string `protobuf:"bytes,2,req,name=bucketName" json:"bucketName,omitempty"`
	KeyName           *string `protobuf:"bytes,3,req,name=keyName" json:"keyName,omitempty"`
	MultipartUploadID *string `protobuf:"bytes,4,req,name=multipartUploadID" json:"multipartUploadID,omitempty"`
	// contains filtered or unexported fields
}

func (*MultipartInfoInitiateResponse) Descriptor deprecated 

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

Deprecated: Use MultipartInfoInitiateResponse.ProtoReflect.Descriptor instead.

func (*MultipartInfoInitiateResponse) GetBucketName 

func (x *MultipartInfoInitiateResponse) GetBucketName() string

func (*MultipartInfoInitiateResponse) GetKeyName 

func (x *MultipartInfoInitiateResponse) GetKeyName() string

func (*MultipartInfoInitiateResponse) GetMultipartUploadID 

func (x *MultipartInfoInitiateResponse) GetMultipartUploadID() string

func (*MultipartInfoInitiateResponse) GetVolumeName 

func (x *MultipartInfoInitiateResponse) GetVolumeName() string

func (*MultipartInfoInitiateResponse) ProtoMessage 

func (*MultipartInfoInitiateResponse) ProtoMessage()

func (*MultipartInfoInitiateResponse) ProtoReflect 

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

func (*MultipartInfoInitiateResponse) Reset 

func (x *MultipartInfoInitiateResponse) Reset()

func (*MultipartInfoInitiateResponse) String 

func (x *MultipartInfoInitiateResponse) String() string

type MultipartKeyInfo 

type MultipartKeyInfo struct {
	UploadID        *string                 `protobuf:"bytes,1,req,name=uploadID" json:"uploadID,omitempty"`
	CreationTime    *uint64                 `protobuf:"varint,2,req,name=creationTime" json:"creationTime,omitempty"`
	Type            *hdds.ReplicationType   `protobuf:"varint,3,req,name=type,enum=hadoop.hdds.ReplicationType" json:"type,omitempty"`
	Factor          *hdds.ReplicationFactor `protobuf:"varint,4,req,name=factor,enum=hadoop.hdds.ReplicationFactor" json:"factor,omitempty"`
	PartKeyInfoList []*PartKeyInfo          `protobuf:"bytes,5,rep,name=partKeyInfoList" json:"partKeyInfoList,omitempty"`
	ObjectID        *uint64                 `protobuf:"varint,6,opt,name=objectID" json:"objectID,omitempty"`
	UpdateID        *uint64                 `protobuf:"varint,7,opt,name=updateID" json:"updateID,omitempty"`
	// contains filtered or unexported fields
}

func (*MultipartKeyInfo) Descriptor deprecated 

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

Deprecated: Use MultipartKeyInfo.ProtoReflect.Descriptor instead.

func (*MultipartKeyInfo) GetCreationTime 

func (x *MultipartKeyInfo) GetCreationTime() uint64

func (*MultipartKeyInfo) GetFactor 

func (x *MultipartKeyInfo) GetFactor() hdds.ReplicationFactor

func (*MultipartKeyInfo) GetObjectID 

func (x *MultipartKeyInfo) GetObjectID() uint64

func (*MultipartKeyInfo) GetPartKeyInfoList 

func (x *MultipartKeyInfo) GetPartKeyInfoList() []*PartKeyInfo

func (*MultipartKeyInfo) GetType 

func (x *MultipartKeyInfo) GetType() hdds.ReplicationType

func (*MultipartKeyInfo) GetUpdateID 

func (x *MultipartKeyInfo) GetUpdateID() uint64

func (*MultipartKeyInfo) GetUploadID 

func (x *MultipartKeyInfo) GetUploadID() string

func (*MultipartKeyInfo) ProtoMessage 

func (*MultipartKeyInfo) ProtoMessage()

func (*MultipartKeyInfo) ProtoReflect 

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

func (*MultipartKeyInfo) Reset 

func (x *MultipartKeyInfo) Reset()

func (*MultipartKeyInfo) String 

func (x *MultipartKeyInfo) String() string

type MultipartUploadAbortRequest 

type MultipartUploadAbortRequest struct {
	KeyArgs *KeyArgs `protobuf:"bytes,1,req,name=keyArgs" json:"keyArgs,omitempty"`
	// contains filtered or unexported fields
}

func (*MultipartUploadAbortRequest) Descriptor deprecated 

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

Deprecated: Use MultipartUploadAbortRequest.ProtoReflect.Descriptor instead.

func (*MultipartUploadAbortRequest) GetKeyArgs 

func (x *MultipartUploadAbortRequest) GetKeyArgs() *KeyArgs

func (*MultipartUploadAbortRequest) ProtoMessage 

func (*MultipartUploadAbortRequest) ProtoMessage()

func (*MultipartUploadAbortRequest) ProtoReflect 

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

func (*MultipartUploadAbortRequest) Reset 

func (x *MultipartUploadAbortRequest) Reset()

func (*MultipartUploadAbortRequest) String 

func (x *MultipartUploadAbortRequest) String() string

type MultipartUploadAbortResponse 

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

func (*MultipartUploadAbortResponse) Descriptor deprecated 

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

Deprecated: Use MultipartUploadAbortResponse.ProtoReflect.Descriptor instead.

func (*MultipartUploadAbortResponse) ProtoMessage 

func (*MultipartUploadAbortResponse) ProtoMessage()

func (*MultipartUploadAbortResponse) ProtoReflect 

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

func (*MultipartUploadAbortResponse) Reset 

func (x *MultipartUploadAbortResponse) Reset()

func (*MultipartUploadAbortResponse) String 

func (x *MultipartUploadAbortResponse) String() string

type MultipartUploadCompleteRequest 

type MultipartUploadCompleteRequest struct {
	KeyArgs   *KeyArgs `protobuf:"bytes,1,req,name=keyArgs" json:"keyArgs,omitempty"`
	PartsList []*Part  `protobuf:"bytes,2,rep,name=partsList" json:"partsList,omitempty"`
	// contains filtered or unexported fields
}

func (*MultipartUploadCompleteRequest) Descriptor deprecated 

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

Deprecated: Use MultipartUploadCompleteRequest.ProtoReflect.Descriptor instead.

func (*MultipartUploadCompleteRequest) GetKeyArgs 

func (x *MultipartUploadCompleteRequest) GetKeyArgs() *KeyArgs

func (*MultipartUploadCompleteRequest) GetPartsList 

func (x *MultipartUploadCompleteRequest) GetPartsList() []*Part

func (*MultipartUploadCompleteRequest) ProtoMessage 

func (*MultipartUploadCompleteRequest) ProtoMessage()

func (*MultipartUploadCompleteRequest) ProtoReflect 

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

func (*MultipartUploadCompleteRequest) Reset 

func (x *MultipartUploadCompleteRequest) Reset()

func (*MultipartUploadCompleteRequest) String 

func (x *MultipartUploadCompleteRequest) String() string

type MultipartUploadCompleteResponse 

type MultipartUploadCompleteResponse struct {
	Volume *string `protobuf:"bytes,1,opt,name=volume" json:"volume,omitempty"`
	Bucket *string `protobuf:"bytes,2,opt,name=bucket" json:"bucket,omitempty"`
	Key    *string `protobuf:"bytes,3,opt,name=key" json:"key,omitempty"`
	Hash   *string `protobuf:"bytes,4,opt,name=hash" json:"hash,omitempty"` // This will be used as etag for s3
	// contains filtered or unexported fields
}

func (*MultipartUploadCompleteResponse) Descriptor deprecated 

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

Deprecated: Use MultipartUploadCompleteResponse.ProtoReflect.Descriptor instead.

func (*MultipartUploadCompleteResponse) GetBucket 

func (x *MultipartUploadCompleteResponse) GetBucket() string

func (*MultipartUploadCompleteResponse) GetHash 

func (x *MultipartUploadCompleteResponse) GetHash() string

func (*MultipartUploadCompleteResponse) GetKey 

func (x *MultipartUploadCompleteResponse) GetKey() string

func (*MultipartUploadCompleteResponse) GetVolume 

func (x *MultipartUploadCompleteResponse) GetVolume() string

func (*MultipartUploadCompleteResponse) ProtoMessage 

func (*MultipartUploadCompleteResponse) ProtoMessage()

func (*MultipartUploadCompleteResponse) ProtoReflect 

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

func (*MultipartUploadCompleteResponse) Reset 

func (x *MultipartUploadCompleteResponse) Reset()

func (*MultipartUploadCompleteResponse) String 

func (x *MultipartUploadCompleteResponse) String() string

type MultipartUploadInfo 

type MultipartUploadInfo struct {
	VolumeName   *string                 `protobuf:"bytes,1,req,name=volumeName" json:"volumeName,omitempty"`
	BucketName   *string                 `protobuf:"bytes,2,req,name=bucketName" json:"bucketName,omitempty"`
	KeyName      *string                 `protobuf:"bytes,3,req,name=keyName" json:"keyName,omitempty"`
	UploadId     *string                 `protobuf:"bytes,4,req,name=uploadId" json:"uploadId,omitempty"`
	CreationTime *uint64                 `protobuf:"varint,5,req,name=creationTime" json:"creationTime,omitempty"`
	Type         *hdds.ReplicationType   `protobuf:"varint,6,req,name=type,enum=hadoop.hdds.ReplicationType" json:"type,omitempty"`
	Factor       *hdds.ReplicationFactor `protobuf:"varint,7,req,name=factor,enum=hadoop.hdds.ReplicationFactor" json:"factor,omitempty"`
	// contains filtered or unexported fields
}

func (*MultipartUploadInfo) Descriptor deprecated 

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

Deprecated: Use MultipartUploadInfo.ProtoReflect.Descriptor instead.

func (*MultipartUploadInfo) GetBucketName 

func (x *MultipartUploadInfo) GetBucketName() string

func (*MultipartUploadInfo) GetCreationTime 

func (x *MultipartUploadInfo) GetCreationTime() uint64

func (*MultipartUploadInfo) GetFactor 

func (x *MultipartUploadInfo) GetFactor() hdds.ReplicationFactor

func (*MultipartUploadInfo) GetKeyName 

func (x *MultipartUploadInfo) GetKeyName() string

func (*MultipartUploadInfo) GetType 

func (x *MultipartUploadInfo) GetType() hdds.ReplicationType

func (*MultipartUploadInfo) GetUploadId 

func (x *MultipartUploadInfo) GetUploadId() string

func (*MultipartUploadInfo) GetVolumeName 

func (x *MultipartUploadInfo) GetVolumeName() string

func (*MultipartUploadInfo) ProtoMessage 

func (*MultipartUploadInfo) ProtoMessage()

func (*MultipartUploadInfo) ProtoReflect 

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

func (*MultipartUploadInfo) Reset 

func (x *MultipartUploadInfo) Reset()

func (*MultipartUploadInfo) String 

func (x *MultipartUploadInfo) String() string

type MultipartUploadListPartsRequest 

type MultipartUploadListPartsRequest struct {
	Volume           *string `protobuf:"bytes,1,req,name=volume" json:"volume,omitempty"`
	Bucket           *string `protobuf:"bytes,2,req,name=bucket" json:"bucket,omitempty"`
	Key              *string `protobuf:"bytes,3,req,name=key" json:"key,omitempty"`
	UploadID         *string `protobuf:"bytes,4,req,name=uploadID" json:"uploadID,omitempty"`
	PartNumbermarker *uint32 `protobuf:"varint,5,opt,name=partNumbermarker" json:"partNumbermarker,omitempty"`
	MaxParts         *uint32 `protobuf:"varint,6,opt,name=maxParts" json:"maxParts,omitempty"`
	// contains filtered or unexported fields
}

func (*MultipartUploadListPartsRequest) Descriptor deprecated 

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

Deprecated: Use MultipartUploadListPartsRequest.ProtoReflect.Descriptor instead.

func (*MultipartUploadListPartsRequest) GetBucket 

func (x *MultipartUploadListPartsRequest) GetBucket() string

func (*MultipartUploadListPartsRequest) GetKey 

func (x *MultipartUploadListPartsRequest) GetKey() string

func (*MultipartUploadListPartsRequest) GetMaxParts 

func (x *MultipartUploadListPartsRequest) GetMaxParts() uint32

func (*MultipartUploadListPartsRequest) GetPartNumbermarker 

func (x *MultipartUploadListPartsRequest) GetPartNumbermarker() uint32

func (*MultipartUploadListPartsRequest) GetUploadID 

func (x *MultipartUploadListPartsRequest) GetUploadID() string

func (*MultipartUploadListPartsRequest) GetVolume 

func (x *MultipartUploadListPartsRequest) GetVolume() string

func (*MultipartUploadListPartsRequest) ProtoMessage 

func (*MultipartUploadListPartsRequest) ProtoMessage()

func (*MultipartUploadListPartsRequest) ProtoReflect 

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

func (*MultipartUploadListPartsRequest) Reset 

func (x *MultipartUploadListPartsRequest) Reset()

func (*MultipartUploadListPartsRequest) String 

func (x *MultipartUploadListPartsRequest) String() string

type MultipartUploadListPartsResponse 

type MultipartUploadListPartsResponse struct {
	Type                 *hdds.ReplicationType   `protobuf:"varint,2,opt,name=type,enum=hadoop.hdds.ReplicationType" json:"type,omitempty"`
	Factor               *hdds.ReplicationFactor `protobuf:"varint,3,opt,name=factor,enum=hadoop.hdds.ReplicationFactor" json:"factor,omitempty"`
	NextPartNumberMarker *uint32                 `protobuf:"varint,4,opt,name=nextPartNumberMarker" json:"nextPartNumberMarker,omitempty"`
	IsTruncated          *bool                   `protobuf:"varint,5,opt,name=isTruncated" json:"isTruncated,omitempty"`
	PartsList            []*PartInfo             `protobuf:"bytes,6,rep,name=partsList" json:"partsList,omitempty"`
	// contains filtered or unexported fields
}

func (*MultipartUploadListPartsResponse) Descriptor deprecated 

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

Deprecated: Use MultipartUploadListPartsResponse.ProtoReflect.Descriptor instead.

func (*MultipartUploadListPartsResponse) GetFactor 

func (x *MultipartUploadListPartsResponse) GetFactor() hdds.ReplicationFactor

func (*MultipartUploadListPartsResponse) GetIsTruncated 

func (x *MultipartUploadListPartsResponse) GetIsTruncated() bool

func (*MultipartUploadListPartsResponse) GetNextPartNumberMarker 

func (x *MultipartUploadListPartsResponse) GetNextPartNumberMarker() uint32

func (*MultipartUploadListPartsResponse) GetPartsList 

func (x *MultipartUploadListPartsResponse) GetPartsList() []*PartInfo

func (*MultipartUploadListPartsResponse) GetType 

func (x *MultipartUploadListPartsResponse) GetType() hdds.ReplicationType

func (*MultipartUploadListPartsResponse) ProtoMessage 

func (*MultipartUploadListPartsResponse) ProtoMessage()

func (*MultipartUploadListPartsResponse) ProtoReflect 

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

func (*MultipartUploadListPartsResponse) Reset 

func (x *MultipartUploadListPartsResponse) Reset()

func (*MultipartUploadListPartsResponse) String 

func (x *MultipartUploadListPartsResponse) String() string

type OMRequest 

type OMRequest struct {
	CmdType *Type `protobuf:"varint,1,req,name=cmdType,enum=hadoop.ozone.Type" json:"cmdType,omitempty"` // Type of the command
	// A string that identifies this command, we generate  Trace ID in Ozone
	// frontend and this allows us to trace that command all over ozone.
	TraceID                            *string                                   `protobuf:"bytes,2,opt,name=traceID" json:"traceID,omitempty"`
	ClientId                           *string                                   `protobuf:"bytes,3,req,name=clientId" json:"clientId,omitempty"`
	UserInfo                           *UserInfo                                 `protobuf:"bytes,4,opt,name=userInfo" json:"userInfo,omitempty"`
	CreateVolumeRequest                *CreateVolumeRequest                      `protobuf:"bytes,11,opt,name=createVolumeRequest" json:"createVolumeRequest,omitempty"`
	SetVolumePropertyRequest           *SetVolumePropertyRequest                 `protobuf:"bytes,12,opt,name=setVolumePropertyRequest" json:"setVolumePropertyRequest,omitempty"`
	CheckVolumeAccessRequest           *CheckVolumeAccessRequest                 `protobuf:"bytes,13,opt,name=checkVolumeAccessRequest" json:"checkVolumeAccessRequest,omitempty"`
	InfoVolumeRequest                  *InfoVolumeRequest                        `protobuf:"bytes,14,opt,name=infoVolumeRequest" json:"infoVolumeRequest,omitempty"`
	DeleteVolumeRequest                *DeleteVolumeRequest                      `protobuf:"bytes,15,opt,name=deleteVolumeRequest" json:"deleteVolumeRequest,omitempty"`
	ListVolumeRequest                  *ListVolumeRequest                        `protobuf:"bytes,16,opt,name=listVolumeRequest" json:"listVolumeRequest,omitempty"`
	CreateBucketRequest                *CreateBucketRequest                      `protobuf:"bytes,21,opt,name=createBucketRequest" json:"createBucketRequest,omitempty"`
	InfoBucketRequest                  *InfoBucketRequest                        `protobuf:"bytes,22,opt,name=infoBucketRequest" json:"infoBucketRequest,omitempty"`
	SetBucketPropertyRequest           *SetBucketPropertyRequest                 `protobuf:"bytes,23,opt,name=setBucketPropertyRequest" json:"setBucketPropertyRequest,omitempty"`
	DeleteBucketRequest                *DeleteBucketRequest                      `protobuf:"bytes,24,opt,name=deleteBucketRequest" json:"deleteBucketRequest,omitempty"`
	ListBucketsRequest                 *ListBucketsRequest                       `protobuf:"bytes,25,opt,name=listBucketsRequest" json:"listBucketsRequest,omitempty"`
	CreateKeyRequest                   *CreateKeyRequest                         `protobuf:"bytes,31,opt,name=createKeyRequest" json:"createKeyRequest,omitempty"`
	LookupKeyRequest                   *LookupKeyRequest                         `protobuf:"bytes,32,opt,name=lookupKeyRequest" json:"lookupKeyRequest,omitempty"`
	RenameKeyRequest                   *RenameKeyRequest                         `protobuf:"bytes,33,opt,name=renameKeyRequest" json:"renameKeyRequest,omitempty"`
	DeleteKeyRequest                   *DeleteKeyRequest                         `protobuf:"bytes,34,opt,name=deleteKeyRequest" json:"deleteKeyRequest,omitempty"`
	ListKeysRequest                    *ListKeysRequest                          `protobuf:"bytes,35,opt,name=listKeysRequest" json:"listKeysRequest,omitempty"`
	CommitKeyRequest                   *CommitKeyRequest                         `protobuf:"bytes,36,opt,name=commitKeyRequest" json:"commitKeyRequest,omitempty"`
	AllocateBlockRequest               *AllocateBlockRequest                     `protobuf:"bytes,37,opt,name=allocateBlockRequest" json:"allocateBlockRequest,omitempty"`
	DeleteKeysRequest                  *DeleteKeysRequest                        `protobuf:"bytes,38,opt,name=deleteKeysRequest" json:"deleteKeysRequest,omitempty"`
	InitiateMultiPartUploadRequest     *MultipartInfoInitiateRequest             `protobuf:"bytes,45,opt,name=initiateMultiPartUploadRequest" json:"initiateMultiPartUploadRequest,omitempty"`
	CommitMultiPartUploadRequest       *MultipartCommitUploadPartRequest         `protobuf:"bytes,46,opt,name=commitMultiPartUploadRequest" json:"commitMultiPartUploadRequest,omitempty"`
	CompleteMultiPartUploadRequest     *MultipartUploadCompleteRequest           `protobuf:"bytes,47,opt,name=completeMultiPartUploadRequest" json:"completeMultiPartUploadRequest,omitempty"`
	AbortMultiPartUploadRequest        *MultipartUploadAbortRequest              `protobuf:"bytes,48,opt,name=abortMultiPartUploadRequest" json:"abortMultiPartUploadRequest,omitempty"`
	GetS3SecretRequest                 *GetS3SecretRequest                       `protobuf:"bytes,49,opt,name=getS3SecretRequest" json:"getS3SecretRequest,omitempty"`
	ListMultipartUploadPartsRequest    *MultipartUploadListPartsRequest          `protobuf:"bytes,50,opt,name=listMultipartUploadPartsRequest" json:"listMultipartUploadPartsRequest,omitempty"`
	ServiceListRequest                 *ServiceListRequest                       `protobuf:"bytes,51,opt,name=serviceListRequest" json:"serviceListRequest,omitempty"`
	DbUpdatesRequest                   *DBUpdatesRequest                         `protobuf:"bytes,53,opt,name=dbUpdatesRequest" json:"dbUpdatesRequest,omitempty"`
	GetDelegationTokenRequest          *common.GetDelegationTokenRequestProto    `protobuf:"bytes,61,opt,name=getDelegationTokenRequest" json:"getDelegationTokenRequest,omitempty"`
	RenewDelegationTokenRequest        *common.RenewDelegationTokenRequestProto  `protobuf:"bytes,62,opt,name=renewDelegationTokenRequest" json:"renewDelegationTokenRequest,omitempty"`
	CancelDelegationTokenRequest       *common.CancelDelegationTokenRequestProto `protobuf:"bytes,63,opt,name=cancelDelegationTokenRequest" json:"cancelDelegationTokenRequest,omitempty"`
	UpdateGetDelegationTokenRequest    *UpdateGetDelegationTokenRequest          `protobuf:"bytes,64,opt,name=updateGetDelegationTokenRequest" json:"updateGetDelegationTokenRequest,omitempty"`
	UpdatedRenewDelegationTokenRequest *UpdateRenewDelegationTokenRequest        `protobuf:"bytes,65,opt,name=updatedRenewDelegationTokenRequest" json:"updatedRenewDelegationTokenRequest,omitempty"`
	GetFileStatusRequest               *GetFileStatusRequest                     `protobuf:"bytes,70,opt,name=getFileStatusRequest" json:"getFileStatusRequest,omitempty"`
	CreateDirectoryRequest             *CreateDirectoryRequest                   `protobuf:"bytes,71,opt,name=createDirectoryRequest" json:"createDirectoryRequest,omitempty"`
	CreateFileRequest                  *CreateFileRequest                        `protobuf:"bytes,72,opt,name=createFileRequest" json:"createFileRequest,omitempty"`
	LookupFileRequest                  *LookupFileRequest                        `protobuf:"bytes,73,opt,name=lookupFileRequest" json:"lookupFileRequest,omitempty"`
	ListStatusRequest                  *ListStatusRequest                        `protobuf:"bytes,74,opt,name=listStatusRequest" json:"listStatusRequest,omitempty"`
	AddAclRequest                      *AddAclRequest                            `protobuf:"bytes,75,opt,name=addAclRequest" json:"addAclRequest,omitempty"`
	RemoveAclRequest                   *RemoveAclRequest                         `protobuf:"bytes,76,opt,name=removeAclRequest" json:"removeAclRequest,omitempty"`
	SetAclRequest                      *SetAclRequest                            `protobuf:"bytes,77,opt,name=setAclRequest" json:"setAclRequest,omitempty"`
	GetAclRequest                      *GetAclRequest                            `protobuf:"bytes,78,opt,name=getAclRequest" json:"getAclRequest,omitempty"`
	PurgeKeysRequest                   *PurgeKeysRequest                         `protobuf:"bytes,81,opt,name=purgeKeysRequest" json:"purgeKeysRequest,omitempty"`
	UpdateGetS3SecretRequest           *UpdateGetS3SecretRequest                 `protobuf:"bytes,82,opt,name=updateGetS3SecretRequest" json:"updateGetS3SecretRequest,omitempty"`
	ListMultipartUploadsRequest        *ListMultipartUploadsRequest              `protobuf:"bytes,83,opt,name=listMultipartUploadsRequest" json:"listMultipartUploadsRequest,omitempty"`
	ListTrashRequest                   *ListTrashRequest                         `protobuf:"bytes,91,opt,name=listTrashRequest" json:"listTrashRequest,omitempty"`
	RecoverTrashRequest                *RecoverTrashRequest                      `protobuf:"bytes,92,opt,name=RecoverTrashRequest" json:"RecoverTrashRequest,omitempty"`
	// contains filtered or unexported fields
}

func (*OMRequest) Descriptor deprecated 

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

Deprecated: Use OMRequest.ProtoReflect.Descriptor instead.

func (*OMRequest) GetAbortMultiPartUploadRequest 

func (x *OMRequest) GetAbortMultiPartUploadRequest() *MultipartUploadAbortRequest

func (*OMRequest) GetAddAclRequest 

func (x *OMRequest) GetAddAclRequest() *AddAclRequest

func (*OMRequest) GetAllocateBlockRequest 

func (x *OMRequest) GetAllocateBlockRequest() *AllocateBlockRequest

func (*OMRequest) GetCancelDelegationTokenRequest 

func (x *OMRequest) GetCancelDelegationTokenRequest() *common.CancelDelegationTokenRequestProto

func (*OMRequest) GetCheckVolumeAccessRequest 

func (x *OMRequest) GetCheckVolumeAccessRequest() *CheckVolumeAccessRequest

func (*OMRequest) GetClientId 

func (x *OMRequest) GetClientId() string

func (*OMRequest) GetCmdType 

func (x *OMRequest) GetCmdType() Type

func (*OMRequest) GetCommitKeyRequest 

func (x *OMRequest) GetCommitKeyRequest() *CommitKeyRequest

func (*OMRequest) GetCommitMultiPartUploadRequest 

func (x *OMRequest) GetCommitMultiPartUploadRequest() *MultipartCommitUploadPartRequest

func (*OMRequest) GetCompleteMultiPartUploadRequest 

func (x *OMRequest) GetCompleteMultiPartUploadRequest() *MultipartUploadCompleteRequest

func (*OMRequest) GetCreateBucketRequest 

func (x *OMRequest) GetCreateBucketRequest() *CreateBucketRequest

func (*OMRequest) GetCreateDirectoryRequest 

func (x *OMRequest) GetCreateDirectoryRequest() *CreateDirectoryRequest

func (*OMRequest) GetCreateFileRequest 

func (x *OMRequest) GetCreateFileRequest() *CreateFileRequest

func (*OMRequest) GetCreateKeyRequest 

func (x *OMRequest) GetCreateKeyRequest() *CreateKeyRequest

func (*OMRequest) GetCreateVolumeRequest 

func (x *OMRequest) GetCreateVolumeRequest() *CreateVolumeRequest

func (*OMRequest) GetDbUpdatesRequest 

func (x *OMRequest) GetDbUpdatesRequest() *DBUpdatesRequest

func (*OMRequest) GetDeleteBucketRequest 

func (x *OMRequest) GetDeleteBucketRequest() *DeleteBucketRequest

func (*OMRequest) GetDeleteKeyRequest 

func (x *OMRequest) GetDeleteKeyRequest() *DeleteKeyRequest

func (*OMRequest) GetDeleteKeysRequest 

func (x *OMRequest) GetDeleteKeysRequest() *DeleteKeysRequest

func (*OMRequest) GetDeleteVolumeRequest 

func (x *OMRequest) GetDeleteVolumeRequest() *DeleteVolumeRequest

func (*OMRequest) GetGetAclRequest 

func (x *OMRequest) GetGetAclRequest() *GetAclRequest

func (*OMRequest) GetGetDelegationTokenRequest 

func (x *OMRequest) GetGetDelegationTokenRequest() *common.GetDelegationTokenRequestProto

func (*OMRequest) GetGetFileStatusRequest 

func (x *OMRequest) GetGetFileStatusRequest() *GetFileStatusRequest

func (*OMRequest) GetGetS3SecretRequest 

func (x *OMRequest) GetGetS3SecretRequest() *GetS3SecretRequest

func (*OMRequest) GetInfoBucketRequest 

func (x *OMRequest) GetInfoBucketRequest() *InfoBucketRequest

func (*OMRequest) GetInfoVolumeRequest 

func (x *OMRequest) GetInfoVolumeRequest() *InfoVolumeRequest

func (*OMRequest) GetInitiateMultiPartUploadRequest 

func (x *OMRequest) GetInitiateMultiPartUploadRequest() *MultipartInfoInitiateRequest

func (*OMRequest) GetListBucketsRequest 

func (x *OMRequest) GetListBucketsRequest() *ListBucketsRequest

func (*OMRequest) GetListKeysRequest 

func (x *OMRequest) GetListKeysRequest() *ListKeysRequest

func (*OMRequest) GetListMultipartUploadPartsRequest 

func (x *OMRequest) GetListMultipartUploadPartsRequest() *MultipartUploadListPartsRequest

func (*OMRequest) GetListMultipartUploadsRequest 

func (x *OMRequest) GetListMultipartUploadsRequest() *ListMultipartUploadsRequest

func (*OMRequest) GetListStatusRequest 

func (x *OMRequest) GetListStatusRequest() *ListStatusRequest

func (*OMRequest) GetListTrashRequest 

func (x *OMRequest) GetListTrashRequest() *ListTrashRequest

func (*OMRequest) GetListVolumeRequest 

func (x *OMRequest) GetListVolumeRequest() *ListVolumeRequest

func (*OMRequest) GetLookupFileRequest 

func (x *OMRequest) GetLookupFileRequest() *LookupFileRequest

func (*OMRequest) GetLookupKeyRequest 

func (x *OMRequest) GetLookupKeyRequest() *LookupKeyRequest

func (*OMRequest) GetPurgeKeysRequest 

func (x *OMRequest) GetPurgeKeysRequest() *PurgeKeysRequest

func (*OMRequest) GetRecoverTrashRequest 

func (x *OMRequest) GetRecoverTrashRequest() *RecoverTrashRequest

func (*OMRequest) GetRemoveAclRequest 

func (x *OMRequest) GetRemoveAclRequest() *RemoveAclRequest

func (*OMRequest) GetRenameKeyRequest 

func (x *OMRequest) GetRenameKeyRequest() *RenameKeyRequest

func (*OMRequest) GetRenewDelegationTokenRequest 

func (x *OMRequest) GetRenewDelegationTokenRequest() *common.RenewDelegationTokenRequestProto

func (*OMRequest) GetServiceListRequest 

func (x *OMRequest) GetServiceListRequest() *ServiceListRequest

func (*OMRequest) GetSetAclRequest 

func (x *OMRequest) GetSetAclRequest() *SetAclRequest

func (*OMRequest) GetSetBucketPropertyRequest 

func (x *OMRequest) GetSetBucketPropertyRequest() *SetBucketPropertyRequest

func (*OMRequest) GetSetVolumePropertyRequest 

func (x *OMRequest) GetSetVolumePropertyRequest() *SetVolumePropertyRequest

func (*OMRequest) GetTraceID 

func (x *OMRequest) GetTraceID() string

func (*OMRequest) GetUpdateGetDelegationTokenRequest 

func (x *OMRequest) GetUpdateGetDelegationTokenRequest() *UpdateGetDelegationTokenRequest

func (*OMRequest) GetUpdateGetS3SecretRequest 

func (x *OMRequest) GetUpdateGetS3SecretRequest() *UpdateGetS3SecretRequest

func (*OMRequest) GetUpdatedRenewDelegationTokenRequest 

func (x *OMRequest) GetUpdatedRenewDelegationTokenRequest() *UpdateRenewDelegationTokenRequest

func (*OMRequest) GetUserInfo 

func (x *OMRequest) GetUserInfo() *UserInfo

func (*OMRequest) ProtoMessage 

func (*OMRequest) ProtoMessage()

func (*OMRequest) ProtoReflect 

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

func (*OMRequest) Reset 

func (x *OMRequest) Reset()

func (*OMRequest) String 

func (x *OMRequest) String() string

type OMResponse 

type OMResponse struct {
	CmdType *Type `protobuf:"varint,1,req,name=cmdType,enum=hadoop.ozone.Type" json:"cmdType,omitempty"` // Type of the command
	// A string that identifies this command, we generate  Trace ID in Ozone
	// frontend and this allows us to trace that command all over ozone.
	TraceID                          *string                             `protobuf:"bytes,2,opt,name=traceID" json:"traceID,omitempty"`
	Success                          *bool                               `protobuf:"varint,3,opt,name=success,def=1" json:"success,omitempty"`
	Message                          *string                             `protobuf:"bytes,4,opt,name=message" json:"message,omitempty"`
	Status                           *Status                             `protobuf:"varint,5,req,name=status,enum=hadoop.ozone.Status" json:"status,omitempty"`
	LeaderOMNodeId                   *string                             `protobuf:"bytes,6,opt,name=leaderOMNodeId" json:"leaderOMNodeId,omitempty"`
	CreateVolumeResponse             *CreateVolumeResponse               `protobuf:"bytes,11,opt,name=createVolumeResponse" json:"createVolumeResponse,omitempty"`
	SetVolumePropertyResponse        *SetVolumePropertyResponse          `protobuf:"bytes,12,opt,name=setVolumePropertyResponse" json:"setVolumePropertyResponse,omitempty"`
	CheckVolumeAccessResponse        *CheckVolumeAccessResponse          `protobuf:"bytes,13,opt,name=checkVolumeAccessResponse" json:"checkVolumeAccessResponse,omitempty"`
	InfoVolumeResponse               *InfoVolumeResponse                 `protobuf:"bytes,14,opt,name=infoVolumeResponse" json:"infoVolumeResponse,omitempty"`
	DeleteVolumeResponse             *DeleteVolumeResponse               `protobuf:"bytes,15,opt,name=deleteVolumeResponse" json:"deleteVolumeResponse,omitempty"`
	ListVolumeResponse               *ListVolumeResponse                 `protobuf:"bytes,16,opt,name=listVolumeResponse" json:"listVolumeResponse,omitempty"`
	CreateBucketResponse             *CreateBucketResponse               `protobuf:"bytes,21,opt,name=createBucketResponse" json:"createBucketResponse,omitempty"`
	InfoBucketResponse               *InfoBucketResponse                 `protobuf:"bytes,22,opt,name=infoBucketResponse" json:"infoBucketResponse,omitempty"`
	SetBucketPropertyResponse        *SetBucketPropertyResponse          `protobuf:"bytes,23,opt,name=setBucketPropertyResponse" json:"setBucketPropertyResponse,omitempty"`
	DeleteBucketResponse             *DeleteBucketResponse               `protobuf:"bytes,24,opt,name=deleteBucketResponse" json:"deleteBucketResponse,omitempty"`
	ListBucketsResponse              *ListBucketsResponse                `protobuf:"bytes,25,opt,name=listBucketsResponse" json:"listBucketsResponse,omitempty"`
	CreateKeyResponse                *CreateKeyResponse                  `protobuf:"bytes,31,opt,name=createKeyResponse" json:"createKeyResponse,omitempty"`
	LookupKeyResponse                *LookupKeyResponse                  `protobuf:"bytes,32,opt,name=lookupKeyResponse" json:"lookupKeyResponse,omitempty"`
	RenameKeyResponse                *RenameKeyResponse                  `protobuf:"bytes,33,opt,name=renameKeyResponse" json:"renameKeyResponse,omitempty"`
	DeleteKeyResponse                *DeleteKeyResponse                  `protobuf:"bytes,34,opt,name=deleteKeyResponse" json:"deleteKeyResponse,omitempty"`
	ListKeysResponse                 *ListKeysResponse                   `protobuf:"bytes,35,opt,name=listKeysResponse" json:"listKeysResponse,omitempty"`
	CommitKeyResponse                *CommitKeyResponse                  `protobuf:"bytes,36,opt,name=commitKeyResponse" json:"commitKeyResponse,omitempty"`
	AllocateBlockResponse            *AllocateBlockResponse              `protobuf:"bytes,37,opt,name=allocateBlockResponse" json:"allocateBlockResponse,omitempty"`
	DeleteKeysResponse               *DeleteKeysResponse                 `protobuf:"bytes,38,opt,name=deleteKeysResponse" json:"deleteKeysResponse,omitempty"`
	InitiateMultiPartUploadResponse  *MultipartInfoInitiateResponse      `protobuf:"bytes,45,opt,name=initiateMultiPartUploadResponse" json:"initiateMultiPartUploadResponse,omitempty"`
	CommitMultiPartUploadResponse    *MultipartCommitUploadPartResponse  `protobuf:"bytes,46,opt,name=commitMultiPartUploadResponse" json:"commitMultiPartUploadResponse,omitempty"`
	CompleteMultiPartUploadResponse  *MultipartUploadCompleteResponse    `protobuf:"bytes,47,opt,name=completeMultiPartUploadResponse" json:"completeMultiPartUploadResponse,omitempty"`
	AbortMultiPartUploadResponse     *MultipartUploadAbortResponse       `protobuf:"bytes,48,opt,name=abortMultiPartUploadResponse" json:"abortMultiPartUploadResponse,omitempty"`
	GetS3SecretResponse              *GetS3SecretResponse                `protobuf:"bytes,49,opt,name=getS3SecretResponse" json:"getS3SecretResponse,omitempty"`
	ListMultipartUploadPartsResponse *MultipartUploadListPartsResponse   `protobuf:"bytes,50,opt,name=listMultipartUploadPartsResponse" json:"listMultipartUploadPartsResponse,omitempty"`
	ServiceListResponse              *ServiceListResponse                `protobuf:"bytes,51,opt,name=ServiceListResponse" json:"ServiceListResponse,omitempty"`
	DbUpdatesResponse                *DBUpdatesResponse                  `protobuf:"bytes,52,opt,name=dbUpdatesResponse" json:"dbUpdatesResponse,omitempty"`
	GetDelegationTokenResponse       *GetDelegationTokenResponseProto    `protobuf:"bytes,61,opt,name=getDelegationTokenResponse" json:"getDelegationTokenResponse,omitempty"`
	RenewDelegationTokenResponse     *RenewDelegationTokenResponseProto  `protobuf:"bytes,62,opt,name=renewDelegationTokenResponse" json:"renewDelegationTokenResponse,omitempty"`
	CancelDelegationTokenResponse    *CancelDelegationTokenResponseProto `protobuf:"bytes,63,opt,name=cancelDelegationTokenResponse" json:"cancelDelegationTokenResponse,omitempty"`
	GetFileStatusResponse            *GetFileStatusResponse              `protobuf:"bytes,70,opt,name=getFileStatusResponse" json:"getFileStatusResponse,omitempty"`
	CreateDirectoryResponse          *CreateDirectoryResponse            `protobuf:"bytes,71,opt,name=createDirectoryResponse" json:"createDirectoryResponse,omitempty"`
	CreateFileResponse               *CreateFileResponse                 `protobuf:"bytes,72,opt,name=createFileResponse" json:"createFileResponse,omitempty"`
	LookupFileResponse               *LookupFileResponse                 `protobuf:"bytes,73,opt,name=lookupFileResponse" json:"lookupFileResponse,omitempty"`
	ListStatusResponse               *ListStatusResponse                 `protobuf:"bytes,74,opt,name=listStatusResponse" json:"listStatusResponse,omitempty"`
	AddAclResponse                   *AddAclResponse                     `protobuf:"bytes,75,opt,name=addAclResponse" json:"addAclResponse,omitempty"`
	RemoveAclResponse                *RemoveAclResponse                  `protobuf:"bytes,76,opt,name=removeAclResponse" json:"removeAclResponse,omitempty"`
	SetAclResponse                   *SetAclResponse                     `protobuf:"bytes,77,opt,name=setAclResponse" json:"setAclResponse,omitempty"`
	GetAclResponse                   *GetAclResponse                     `protobuf:"bytes,78,opt,name=getAclResponse" json:"getAclResponse,omitempty"`
	PurgeKeysResponse                *PurgeKeysResponse                  `protobuf:"bytes,81,opt,name=purgeKeysResponse" json:"purgeKeysResponse,omitempty"`
	ListMultipartUploadsResponse     *ListMultipartUploadsResponse       `protobuf:"bytes,82,opt,name=listMultipartUploadsResponse" json:"listMultipartUploadsResponse,omitempty"`
	ListTrashResponse                *ListTrashResponse                  `protobuf:"bytes,91,opt,name=listTrashResponse" json:"listTrashResponse,omitempty"`
	RecoverTrashResponse             *RecoverTrashResponse               `protobuf:"bytes,92,opt,name=RecoverTrashResponse" json:"RecoverTrashResponse,omitempty"`
	// contains filtered or unexported fields
}

func (*OMResponse) Descriptor deprecated 

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

Deprecated: Use OMResponse.ProtoReflect.Descriptor instead.

func (*OMResponse) GetAbortMultiPartUploadResponse 

func (x *OMResponse) GetAbortMultiPartUploadResponse() *MultipartUploadAbortResponse

func (*OMResponse) GetAddAclResponse 

func (x *OMResponse) GetAddAclResponse() *AddAclResponse

func (*OMResponse) GetAllocateBlockResponse 

func (x *OMResponse) GetAllocateBlockResponse() *AllocateBlockResponse

func (*OMResponse) GetCancelDelegationTokenResponse 

func (x *OMResponse) GetCancelDelegationTokenResponse() *CancelDelegationTokenResponseProto

func (*OMResponse) GetCheckVolumeAccessResponse 

func (x *OMResponse) GetCheckVolumeAccessResponse() *CheckVolumeAccessResponse

func (*OMResponse) GetCmdType 

func (x *OMResponse) GetCmdType() Type

func (*OMResponse) GetCommitKeyResponse 

func (x *OMResponse) GetCommitKeyResponse() *CommitKeyResponse

func (*OMResponse) GetCommitMultiPartUploadResponse 

func (x *OMResponse) GetCommitMultiPartUploadResponse() *MultipartCommitUploadPartResponse

func (*OMResponse) GetCompleteMultiPartUploadResponse 

func (x *OMResponse) GetCompleteMultiPartUploadResponse() *MultipartUploadCompleteResponse

func (*OMResponse) GetCreateBucketResponse 

func (x *OMResponse) GetCreateBucketResponse() *CreateBucketResponse

func (*OMResponse) GetCreateDirectoryResponse 

func (x *OMResponse) GetCreateDirectoryResponse() *CreateDirectoryResponse

func (*OMResponse) GetCreateFileResponse 

func (x *OMResponse) GetCreateFileResponse() *CreateFileResponse

func (*OMResponse) GetCreateKeyResponse 

func (x *OMResponse) GetCreateKeyResponse() *CreateKeyResponse

func (*OMResponse) GetCreateVolumeResponse 

func (x *OMResponse) GetCreateVolumeResponse() *CreateVolumeResponse

func (*OMResponse) GetDbUpdatesResponse 

func (x *OMResponse) GetDbUpdatesResponse() *DBUpdatesResponse

func (*OMResponse) GetDeleteBucketResponse 

func (x *OMResponse) GetDeleteBucketResponse() *DeleteBucketResponse

func (*OMResponse) GetDeleteKeyResponse 

func (x *OMResponse) GetDeleteKeyResponse() *DeleteKeyResponse

func (*OMResponse) GetDeleteKeysResponse 

func (x *OMResponse) GetDeleteKeysResponse() *DeleteKeysResponse

func (*OMResponse) GetDeleteVolumeResponse 

func (x *OMResponse) GetDeleteVolumeResponse() *DeleteVolumeResponse

func (*OMResponse) GetGetAclResponse 

func (x *OMResponse) GetGetAclResponse() *GetAclResponse

func (*OMResponse) GetGetDelegationTokenResponse 

func (x *OMResponse) GetGetDelegationTokenResponse() *GetDelegationTokenResponseProto

func (*OMResponse) GetGetFileStatusResponse 

func (x *OMResponse) GetGetFileStatusResponse() *GetFileStatusResponse

func (*OMResponse) GetGetS3SecretResponse 

func (x *OMResponse) GetGetS3SecretResponse() *GetS3SecretResponse

func (*OMResponse) GetInfoBucketResponse 

func (x *OMResponse) GetInfoBucketResponse() *InfoBucketResponse

func (*OMResponse) GetInfoVolumeResponse 

func (x *OMResponse) GetInfoVolumeResponse() *InfoVolumeResponse

func (*OMResponse) GetInitiateMultiPartUploadResponse 

func (x *OMResponse) GetInitiateMultiPartUploadResponse() *MultipartInfoInitiateResponse

func (*OMResponse) GetLeaderOMNodeId 

func (x *OMResponse) GetLeaderOMNodeId() string

func (*OMResponse) GetListBucketsResponse 

func (x *OMResponse) GetListBucketsResponse() *ListBucketsResponse

func (*OMResponse) GetListKeysResponse 

func (x *OMResponse) GetListKeysResponse() *ListKeysResponse

func (*OMResponse) GetListMultipartUploadPartsResponse 

func (x *OMResponse) GetListMultipartUploadPartsResponse() *MultipartUploadListPartsResponse

func (*OMResponse) GetListMultipartUploadsResponse 

func (x *OMResponse) GetListMultipartUploadsResponse() *ListMultipartUploadsResponse

func (*OMResponse) GetListStatusResponse 

func (x *OMResponse) GetListStatusResponse() *ListStatusResponse

func (*OMResponse) GetListTrashResponse 

func (x *OMResponse) GetListTrashResponse() *ListTrashResponse

func (*OMResponse) GetListVolumeResponse 

func (x *OMResponse) GetListVolumeResponse() *ListVolumeResponse

func (*OMResponse) GetLookupFileResponse 

func (x *OMResponse) GetLookupFileResponse() *LookupFileResponse

func (*OMResponse) GetLookupKeyResponse 

func (x *OMResponse) GetLookupKeyResponse() *LookupKeyResponse

func (*OMResponse) GetMessage 

func (x *OMResponse) GetMessage() string

func (*OMResponse) GetPurgeKeysResponse 

func (x *OMResponse) GetPurgeKeysResponse() *PurgeKeysResponse

func (*OMResponse) GetRecoverTrashResponse 

func (x *OMResponse) GetRecoverTrashResponse() *RecoverTrashResponse

func (*OMResponse) GetRemoveAclResponse 

func (x *OMResponse) GetRemoveAclResponse() *RemoveAclResponse

func (*OMResponse) GetRenameKeyResponse 

func (x *OMResponse) GetRenameKeyResponse() *RenameKeyResponse

func (*OMResponse) GetRenewDelegationTokenResponse 

func (x *OMResponse) GetRenewDelegationTokenResponse() *RenewDelegationTokenResponseProto

func (*OMResponse) GetServiceListResponse 

func (x *OMResponse) GetServiceListResponse() *ServiceListResponse

func (*OMResponse) GetSetAclResponse 

func (x *OMResponse) GetSetAclResponse() *SetAclResponse

func (*OMResponse) GetSetBucketPropertyResponse 

func (x *OMResponse) GetSetBucketPropertyResponse() *SetBucketPropertyResponse

func (*OMResponse) GetSetVolumePropertyResponse 

func (x *OMResponse) GetSetVolumePropertyResponse() *SetVolumePropertyResponse

func (*OMResponse) GetStatus 

func (x *OMResponse) GetStatus() Status

func (*OMResponse) GetSuccess 

func (x *OMResponse) GetSuccess() bool

func (*OMResponse) GetTraceID 

func (x *OMResponse) GetTraceID() string

func (*OMResponse) ProtoMessage 

func (*OMResponse) ProtoMessage()

func (*OMResponse) ProtoReflect 

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

func (*OMResponse) Reset 

func (x *OMResponse) Reset()

func (*OMResponse) String 

func (x *OMResponse) String() string

type OMRoleInfo 

type OMRoleInfo struct {
	NodeId     *string `protobuf:"bytes,1,req,name=nodeId" json:"nodeId,omitempty"`
	ServerRole *string `protobuf:"bytes,2,req,name=serverRole" json:"serverRole,omitempty"`
	// contains filtered or unexported fields
}

func (*OMRoleInfo) Descriptor deprecated 

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

Deprecated: Use OMRoleInfo.ProtoReflect.Descriptor instead.

func (*OMRoleInfo) GetNodeId 

func (x *OMRoleInfo) GetNodeId() string

func (*OMRoleInfo) GetServerRole 

func (x *OMRoleInfo) GetServerRole() string

func (*OMRoleInfo) ProtoMessage 

func (*OMRoleInfo) ProtoMessage()

func (*OMRoleInfo) ProtoReflect 

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

func (*OMRoleInfo) Reset 

func (x *OMRoleInfo) Reset()

func (*OMRoleInfo) String 

func (x *OMRoleInfo) String() string

type OMTokenProto 

type OMTokenProto struct {
	Type           *OMTokenProto_Type `protobuf:"varint,1,req,name=type,enum=hadoop.ozone.OMTokenProto_Type" json:"type,omitempty"`
	Version        *uint32            `protobuf:"varint,2,opt,name=version" json:"version,omitempty"`
	Owner          *string            `protobuf:"bytes,3,opt,name=owner" json:"owner,omitempty"`
	Renewer        *string            `protobuf:"bytes,4,opt,name=renewer" json:"renewer,omitempty"`
	RealUser       *string            `protobuf:"bytes,5,opt,name=realUser" json:"realUser,omitempty"`
	IssueDate      *uint64            `protobuf:"varint,6,opt,name=issueDate" json:"issueDate,omitempty"`
	MaxDate        *uint64            `protobuf:"varint,7,opt,name=maxDate" json:"maxDate,omitempty"`
	SequenceNumber *uint32            `protobuf:"varint,8,opt,name=sequenceNumber" json:"sequenceNumber,omitempty"`
	MasterKeyId    *uint32            `protobuf:"varint,9,opt,name=masterKeyId" json:"masterKeyId,omitempty"`
	ExpiryDate     *uint64            `protobuf:"varint,10,opt,name=expiryDate" json:"expiryDate,omitempty"`
	OmCertSerialId *string            `protobuf:"bytes,11,opt,name=omCertSerialId" json:"omCertSerialId,omitempty"`
	AccessKeyId    *string            `protobuf:"bytes,12,opt,name=accessKeyId" json:"accessKeyId,omitempty"`
	Signature      *string            `protobuf:"bytes,13,opt,name=signature" json:"signature,omitempty"`
	StrToSign      *string            `protobuf:"bytes,14,opt,name=strToSign" json:"strToSign,omitempty"`
	OmServiceId    *string            `protobuf:"bytes,15,opt,name=omServiceId" json:"omServiceId,omitempty"`
	// contains filtered or unexported fields
}

func (*OMTokenProto) Descriptor deprecated 

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

Deprecated: Use OMTokenProto.ProtoReflect.Descriptor instead.

func (*OMTokenProto) GetAccessKeyId 

func (x *OMTokenProto) GetAccessKeyId() string

func (*OMTokenProto) GetExpiryDate 

func (x *OMTokenProto) GetExpiryDate() uint64

func (*OMTokenProto) GetIssueDate 

func (x *OMTokenProto) GetIssueDate() uint64

func (*OMTokenProto) GetMasterKeyId 

func (x *OMTokenProto) GetMasterKeyId() uint32

func (*OMTokenProto) GetMaxDate 

func (x *OMTokenProto) GetMaxDate() uint64

func (*OMTokenProto) GetOmCertSerialId 

func (x *OMTokenProto) GetOmCertSerialId() string

func (*OMTokenProto) GetOmServiceId 

func (x *OMTokenProto) GetOmServiceId() string

func (*OMTokenProto) GetOwner 

func (x *OMTokenProto) GetOwner() string

func (*OMTokenProto) GetRealUser 

func (x *OMTokenProto) GetRealUser() string

func (*OMTokenProto) GetRenewer 

func (x *OMTokenProto) GetRenewer() string

func (*OMTokenProto) GetSequenceNumber 

func (x *OMTokenProto) GetSequenceNumber() uint32

func (*OMTokenProto) GetSignature 

func (x *OMTokenProto) GetSignature() string

func (*OMTokenProto) GetStrToSign 

func (x *OMTokenProto) GetStrToSign() string

func (*OMTokenProto) GetType 

func (x *OMTokenProto) GetType() OMTokenProto_Type

func (*OMTokenProto) GetVersion 

func (x *OMTokenProto) GetVersion() uint32

func (*OMTokenProto) ProtoMessage 

func (*OMTokenProto) ProtoMessage()

func (*OMTokenProto) ProtoReflect 

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

func (*OMTokenProto) Reset 

func (x *OMTokenProto) Reset()

func (*OMTokenProto) String 

func (x *OMTokenProto) String() string

type OMTokenProto_Type 

type OMTokenProto_Type int32
const (
	OMTokenProto_DELEGATION_TOKEN OMTokenProto_Type = 1
	OMTokenProto_S3AUTHINFO       OMTokenProto_Type = 2
)

func (OMTokenProto_Type) Descriptor 

func (OMTokenProto_Type) Descriptor() protoreflect.EnumDescriptor

func (OMTokenProto_Type) Enum 

func (x OMTokenProto_Type) Enum() *OMTokenProto_Type

func (OMTokenProto_Type) EnumDescriptor deprecated 

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

Deprecated: Use OMTokenProto_Type.Descriptor instead.

func (OMTokenProto_Type) Number 

func (x OMTokenProto_Type) Number() protoreflect.EnumNumber

func (OMTokenProto_Type) String 

func (x OMTokenProto_Type) String() string

func (OMTokenProto_Type) Type 

func (OMTokenProto_Type) Type() protoreflect.EnumType

func (*OMTokenProto_Type) UnmarshalJSON deprecated 

func (x *OMTokenProto_Type) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type OzoneAclInfo 

type OzoneAclInfo struct {
	Type     *OzoneAclInfo_OzoneAclType  `protobuf:"varint,1,req,name=type,enum=hadoop.ozone.OzoneAclInfo_OzoneAclType" json:"type,omitempty"`
	Name     *string                     `protobuf:"bytes,2,req,name=name" json:"name,omitempty"`
	Rights   []byte                      `protobuf:"bytes,3,req,name=rights" json:"rights,omitempty"`
	AclScope *OzoneAclInfo_OzoneAclScope `protobuf:"varint,4,req,name=aclScope,enum=hadoop.ozone.OzoneAclInfo_OzoneAclScope,def=0" json:"aclScope,omitempty"`
	// contains filtered or unexported fields
}

func (*OzoneAclInfo) Descriptor deprecated 

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

Deprecated: Use OzoneAclInfo.ProtoReflect.Descriptor instead.

func (*OzoneAclInfo) GetAclScope 

func (x *OzoneAclInfo) GetAclScope() OzoneAclInfo_OzoneAclScope

func (*OzoneAclInfo) GetName 

func (x *OzoneAclInfo) GetName() string

func (*OzoneAclInfo) GetRights 

func (x *OzoneAclInfo) GetRights() []byte

func (*OzoneAclInfo) GetType 

func (x *OzoneAclInfo) GetType() OzoneAclInfo_OzoneAclType

func (*OzoneAclInfo) ProtoMessage 

func (*OzoneAclInfo) ProtoMessage()

func (*OzoneAclInfo) ProtoReflect 

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

func (*OzoneAclInfo) Reset 

func (x *OzoneAclInfo) Reset()

func (*OzoneAclInfo) String 

func (x *OzoneAclInfo) String() string

type OzoneAclInfo_OzoneAclScope 

type OzoneAclInfo_OzoneAclScope int32
const (
	OzoneAclInfo_ACCESS  OzoneAclInfo_OzoneAclScope = 0
	OzoneAclInfo_DEFAULT OzoneAclInfo_OzoneAclScope = 1
)

func (OzoneAclInfo_OzoneAclScope) Descriptor 

func (OzoneAclInfo_OzoneAclScope) Descriptor() protoreflect.EnumDescriptor

func (OzoneAclInfo_OzoneAclScope) Enum 

func (x OzoneAclInfo_OzoneAclScope) Enum() *OzoneAclInfo_OzoneAclScope

func (OzoneAclInfo_OzoneAclScope) EnumDescriptor deprecated 

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

Deprecated: Use OzoneAclInfo_OzoneAclScope.Descriptor instead.

func (OzoneAclInfo_OzoneAclScope) Number 

func (x OzoneAclInfo_OzoneAclScope) Number() protoreflect.EnumNumber

func (OzoneAclInfo_OzoneAclScope) String 

func (x OzoneAclInfo_OzoneAclScope) String() string

func (OzoneAclInfo_OzoneAclScope) Type 

func (OzoneAclInfo_OzoneAclScope) Type() protoreflect.EnumType

func (*OzoneAclInfo_OzoneAclScope) UnmarshalJSON deprecated 

func (x *OzoneAclInfo_OzoneAclScope) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type OzoneAclInfo_OzoneAclType 

type OzoneAclInfo_OzoneAclType int32
const (
	OzoneAclInfo_USER      OzoneAclInfo_OzoneAclType = 1
	OzoneAclInfo_GROUP     OzoneAclInfo_OzoneAclType = 2
	OzoneAclInfo_WORLD     OzoneAclInfo_OzoneAclType = 3
	OzoneAclInfo_ANONYMOUS OzoneAclInfo_OzoneAclType = 4
	OzoneAclInfo_CLIENT_IP OzoneAclInfo_OzoneAclType = 5
)

func (OzoneAclInfo_OzoneAclType) Descriptor 

func (OzoneAclInfo_OzoneAclType) Descriptor() protoreflect.EnumDescriptor

func (OzoneAclInfo_OzoneAclType) Enum 

func (x OzoneAclInfo_OzoneAclType) Enum() *OzoneAclInfo_OzoneAclType

func (OzoneAclInfo_OzoneAclType) EnumDescriptor deprecated 

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

Deprecated: Use OzoneAclInfo_OzoneAclType.Descriptor instead.

func (OzoneAclInfo_OzoneAclType) Number 

func (x OzoneAclInfo_OzoneAclType) Number() protoreflect.EnumNumber

func (OzoneAclInfo_OzoneAclType) String 

func (x OzoneAclInfo_OzoneAclType) String() string

func (OzoneAclInfo_OzoneAclType) Type 

func (OzoneAclInfo_OzoneAclType) Type() protoreflect.EnumType

func (*OzoneAclInfo_OzoneAclType) UnmarshalJSON deprecated 

func (x *OzoneAclInfo_OzoneAclType) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type OzoneFileStatusProto 

type OzoneFileStatusProto struct {
	KeyInfo     *KeyInfo `protobuf:"bytes,2,opt,name=keyInfo" json:"keyInfo,omitempty"`
	BlockSize   *uint64  `protobuf:"varint,3,opt,name=blockSize" json:"blockSize,omitempty"`
	IsDirectory *bool    `protobuf:"varint,4,opt,name=isDirectory" json:"isDirectory,omitempty"`
	// contains filtered or unexported fields
}

func (*OzoneFileStatusProto) Descriptor deprecated 

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

Deprecated: Use OzoneFileStatusProto.ProtoReflect.Descriptor instead.

func (*OzoneFileStatusProto) GetBlockSize 

func (x *OzoneFileStatusProto) GetBlockSize() uint64

func (*OzoneFileStatusProto) GetIsDirectory 

func (x *OzoneFileStatusProto) GetIsDirectory() bool

func (*OzoneFileStatusProto) GetKeyInfo 

func (x *OzoneFileStatusProto) GetKeyInfo() *KeyInfo

func (*OzoneFileStatusProto) ProtoMessage 

func (*OzoneFileStatusProto) ProtoMessage()

func (*OzoneFileStatusProto) ProtoReflect 

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

func (*OzoneFileStatusProto) Reset 

func (x *OzoneFileStatusProto) Reset()

func (*OzoneFileStatusProto) String 

func (x *OzoneFileStatusProto) String() string

type OzoneObj 

type OzoneObj struct {
	ResType   *OzoneObj_ObjectType `protobuf:"varint,1,req,name=resType,enum=hadoop.ozone.OzoneObj_ObjectType" json:"resType,omitempty"`
	StoreType *OzoneObj_StoreType  `protobuf:"varint,2,req,name=storeType,enum=hadoop.ozone.OzoneObj_StoreType,def=2" json:"storeType,omitempty"`
	Path      *string              `protobuf:"bytes,3,req,name=path" json:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*OzoneObj) Descriptor deprecated 

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

Deprecated: Use OzoneObj.ProtoReflect.Descriptor instead.

func (*OzoneObj) GetPath 

func (x *OzoneObj) GetPath() string

func (*OzoneObj) GetResType 

func (x *OzoneObj) GetResType() OzoneObj_ObjectType

func (*OzoneObj) GetStoreType 

func (x *OzoneObj) GetStoreType() OzoneObj_StoreType

func (*OzoneObj) ProtoMessage 

func (*OzoneObj) ProtoMessage()

func (*OzoneObj) ProtoReflect 

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

func (*OzoneObj) Reset 

func (x *OzoneObj) Reset()

func (*OzoneObj) String 

func (x *OzoneObj) String() string

type OzoneObj_ObjectType 

type OzoneObj_ObjectType int32
const (
	OzoneObj_VOLUME OzoneObj_ObjectType = 1
	OzoneObj_BUCKET OzoneObj_ObjectType = 2
	OzoneObj_KEY    OzoneObj_ObjectType = 3
	OzoneObj_PREFIX OzoneObj_ObjectType = 4
)

func (OzoneObj_ObjectType) Descriptor 

func (OzoneObj_ObjectType) Descriptor() protoreflect.EnumDescriptor

func (OzoneObj_ObjectType) Enum 

func (x OzoneObj_ObjectType) Enum() *OzoneObj_ObjectType

func (OzoneObj_ObjectType) EnumDescriptor deprecated 

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

Deprecated: Use OzoneObj_ObjectType.Descriptor instead.

func (OzoneObj_ObjectType) Number 

func (x OzoneObj_ObjectType) Number() protoreflect.EnumNumber

func (OzoneObj_ObjectType) String 

func (x OzoneObj_ObjectType) String() string

func (OzoneObj_ObjectType) Type 

func (OzoneObj_ObjectType) Type() protoreflect.EnumType

func (*OzoneObj_ObjectType) UnmarshalJSON deprecated 

func (x *OzoneObj_ObjectType) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type OzoneObj_StoreType 

type OzoneObj_StoreType int32
const (
	OzoneObj_OZONE OzoneObj_StoreType = 1
	OzoneObj_S3    OzoneObj_StoreType = 2
)

func (OzoneObj_StoreType) Descriptor 

func (OzoneObj_StoreType) Descriptor() protoreflect.EnumDescriptor

func (OzoneObj_StoreType) Enum 

func (x OzoneObj_StoreType) Enum() *OzoneObj_StoreType

func (OzoneObj_StoreType) EnumDescriptor deprecated 

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

Deprecated: Use OzoneObj_StoreType.Descriptor instead.

func (OzoneObj_StoreType) Number 

func (x OzoneObj_StoreType) Number() protoreflect.EnumNumber

func (OzoneObj_StoreType) String 

func (x OzoneObj_StoreType) String() string

func (OzoneObj_StoreType) Type 

func (OzoneObj_StoreType) Type() protoreflect.EnumType

func (*OzoneObj_StoreType) UnmarshalJSON deprecated 

func (x *OzoneObj_StoreType) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type Part 

type Part struct {
	PartNumber *uint32 `protobuf:"varint,1,req,name=partNumber" json:"partNumber,omitempty"`
	PartName   *string `protobuf:"bytes,2,req,name=partName" json:"partName,omitempty"`
	// contains filtered or unexported fields
}

func (*Part) Descriptor deprecated 

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

Deprecated: Use Part.ProtoReflect.Descriptor instead.

func (*Part) GetPartName 

func (x *Part) GetPartName() string

func (*Part) GetPartNumber 

func (x *Part) GetPartNumber() uint32

func (*Part) ProtoMessage 

func (*Part) ProtoMessage()

func (*Part) ProtoReflect 

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

func (*Part) Reset 

func (x *Part) Reset()

func (*Part) String 

func (x *Part) String() string

type PartInfo 

type PartInfo struct {
	PartNumber       *uint32 `protobuf:"varint,1,req,name=partNumber" json:"partNumber,omitempty"`
	PartName         *string `protobuf:"bytes,2,req,name=partName" json:"partName,omitempty"`
	ModificationTime *uint64 `protobuf:"varint,3,req,name=modificationTime" json:"modificationTime,omitempty"`
	Size             *uint64 `protobuf:"varint,4,req,name=size" json:"size,omitempty"`
	// contains filtered or unexported fields
}

func (*PartInfo) Descriptor deprecated 

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

Deprecated: Use PartInfo.ProtoReflect.Descriptor instead.

func (*PartInfo) GetModificationTime 

func (x *PartInfo) GetModificationTime() uint64

func (*PartInfo) GetPartName 

func (x *PartInfo) GetPartName() string

func (*PartInfo) GetPartNumber 

func (x *PartInfo) GetPartNumber() uint32

func (*PartInfo) GetSize 

func (x *PartInfo) GetSize() uint64

func (*PartInfo) ProtoMessage 

func (*PartInfo) ProtoMessage()

func (*PartInfo) ProtoReflect 

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

func (*PartInfo) Reset 

func (x *PartInfo) Reset()

func (*PartInfo) String 

func (x *PartInfo) String() string

type PartKeyInfo 

type PartKeyInfo struct {
	PartName    *string  `protobuf:"bytes,1,req,name=partName" json:"partName,omitempty"`
	PartNumber  *uint32  `protobuf:"varint,2,req,name=partNumber" json:"partNumber,omitempty"`
	PartKeyInfo *KeyInfo `protobuf:"bytes,3,req,name=partKeyInfo" json:"partKeyInfo,omitempty"`
	// contains filtered or unexported fields
}

func (*PartKeyInfo) Descriptor deprecated 

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

Deprecated: Use PartKeyInfo.ProtoReflect.Descriptor instead.

func (*PartKeyInfo) GetPartKeyInfo 

func (x *PartKeyInfo) GetPartKeyInfo() *KeyInfo

func (*PartKeyInfo) GetPartName 

func (x *PartKeyInfo) GetPartName() string

func (*PartKeyInfo) GetPartNumber 

func (x *PartKeyInfo) GetPartNumber() uint32

func (*PartKeyInfo) ProtoMessage 

func (*PartKeyInfo) ProtoMessage()

func (*PartKeyInfo) ProtoReflect 

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

func (*PartKeyInfo) Reset 

func (x *PartKeyInfo) Reset()

func (*PartKeyInfo) String 

func (x *PartKeyInfo) String() string

type PerFileEncryptionInfoProto 

type PerFileEncryptionInfoProto struct {
	Key              []byte  `protobuf:"bytes,1,req,name=key" json:"key,omitempty"`
	Iv               []byte  `protobuf:"bytes,2,req,name=iv" json:"iv,omitempty"`
	EzKeyVersionName *string `protobuf:"bytes,3,req,name=ezKeyVersionName" json:"ezKeyVersionName,omitempty"`
	// contains filtered or unexported fields
}

* Encryption information for an individual file within an encryption zone

func (*PerFileEncryptionInfoProto) Descriptor deprecated 

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

Deprecated: Use PerFileEncryptionInfoProto.ProtoReflect.Descriptor instead.

func (*PerFileEncryptionInfoProto) GetEzKeyVersionName 

func (x *PerFileEncryptionInfoProto) GetEzKeyVersionName() string

func (*PerFileEncryptionInfoProto) GetIv 

func (x *PerFileEncryptionInfoProto) GetIv() []byte

func (*PerFileEncryptionInfoProto) GetKey 

func (x *PerFileEncryptionInfoProto) GetKey() []byte

func (*PerFileEncryptionInfoProto) ProtoMessage 

func (*PerFileEncryptionInfoProto) ProtoMessage()

func (*PerFileEncryptionInfoProto) ProtoReflect 

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

func (*PerFileEncryptionInfoProto) Reset 

func (x *PerFileEncryptionInfoProto) Reset()

func (*PerFileEncryptionInfoProto) String 

func (x *PerFileEncryptionInfoProto) String() string

type PrefixInfo 

type PrefixInfo struct {
	Name     *string          `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
	Acls     []*OzoneAclInfo  `protobuf:"bytes,2,rep,name=acls" json:"acls,omitempty"`
	Metadata []*hdds.KeyValue `protobuf:"bytes,3,rep,name=metadata" json:"metadata,omitempty"`
	ObjectID *uint64          `protobuf:"varint,4,opt,name=objectID" json:"objectID,omitempty"`
	UpdateID *uint64          `protobuf:"varint,5,opt,name=updateID" json:"updateID,omitempty"`
	// contains filtered or unexported fields
}

func (*PrefixInfo) Descriptor deprecated 

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

Deprecated: Use PrefixInfo.ProtoReflect.Descriptor instead.

func (*PrefixInfo) GetAcls 

func (x *PrefixInfo) GetAcls() []*OzoneAclInfo

func (*PrefixInfo) GetMetadata 

func (x *PrefixInfo) GetMetadata() []*hdds.KeyValue

func (*PrefixInfo) GetName 

func (x *PrefixInfo) GetName() string

func (*PrefixInfo) GetObjectID 

func (x *PrefixInfo) GetObjectID() uint64

func (*PrefixInfo) GetUpdateID 

func (x *PrefixInfo) GetUpdateID() uint64

func (*PrefixInfo) ProtoMessage 

func (*PrefixInfo) ProtoMessage()

func (*PrefixInfo) ProtoReflect 

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

func (*PrefixInfo) Reset 

func (x *PrefixInfo) Reset()

func (*PrefixInfo) String 

func (x *PrefixInfo) String() string

type PurgeKeysRequest 

type PurgeKeysRequest struct {
	DeletedKeys []*DeletedKeys `protobuf:"bytes,1,rep,name=deletedKeys" json:"deletedKeys,omitempty"`
	// contains filtered or unexported fields
}

func (*PurgeKeysRequest) Descriptor deprecated 

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

Deprecated: Use PurgeKeysRequest.ProtoReflect.Descriptor instead.

func (*PurgeKeysRequest) GetDeletedKeys 

func (x *PurgeKeysRequest) GetDeletedKeys() []*DeletedKeys

func (*PurgeKeysRequest) ProtoMessage 

func (*PurgeKeysRequest) ProtoMessage()

func (*PurgeKeysRequest) ProtoReflect 

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

func (*PurgeKeysRequest) Reset 

func (x *PurgeKeysRequest) Reset()

func (*PurgeKeysRequest) String 

func (x *PurgeKeysRequest) String() string

type PurgeKeysResponse 

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

func (*PurgeKeysResponse) Descriptor deprecated 

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

Deprecated: Use PurgeKeysResponse.ProtoReflect.Descriptor instead.

func (*PurgeKeysResponse) ProtoMessage 

func (*PurgeKeysResponse) ProtoMessage()

func (*PurgeKeysResponse) ProtoReflect 

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

func (*PurgeKeysResponse) Reset 

func (x *PurgeKeysResponse) Reset()

func (*PurgeKeysResponse) String 

func (x *PurgeKeysResponse) String() string

type RecoverTrashRequest 

type RecoverTrashRequest struct {
	VolumeName        *string `protobuf:"bytes,1,req,name=volumeName" json:"volumeName,omitempty"`
	BucketName        *string `protobuf:"bytes,2,req,name=bucketName" json:"bucketName,omitempty"`
	KeyName           *string `protobuf:"bytes,3,req,name=keyName" json:"keyName,omitempty"`
	DestinationBucket *string `protobuf:"bytes,4,req,name=destinationBucket" json:"destinationBucket,omitempty"`
	// contains filtered or unexported fields
}

func (*RecoverTrashRequest) Descriptor deprecated 

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

Deprecated: Use RecoverTrashRequest.ProtoReflect.Descriptor instead.

func (*RecoverTrashRequest) GetBucketName 

func (x *RecoverTrashRequest) GetBucketName() string

func (*RecoverTrashRequest) GetDestinationBucket 

func (x *RecoverTrashRequest) GetDestinationBucket() string

func (*RecoverTrashRequest) GetKeyName 

func (x *RecoverTrashRequest) GetKeyName() string

func (*RecoverTrashRequest) GetVolumeName 

func (x *RecoverTrashRequest) GetVolumeName() string

func (*RecoverTrashRequest) ProtoMessage 

func (*RecoverTrashRequest) ProtoMessage()

func (*RecoverTrashRequest) ProtoReflect 

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

func (*RecoverTrashRequest) Reset 

func (x *RecoverTrashRequest) Reset()

func (*RecoverTrashRequest) String 

func (x *RecoverTrashRequest) String() string

type RecoverTrashResponse 

type RecoverTrashResponse struct {
	Response *bool `protobuf:"varint,1,req,name=response" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*RecoverTrashResponse) Descriptor deprecated 

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

Deprecated: Use RecoverTrashResponse.ProtoReflect.Descriptor instead.

func (*RecoverTrashResponse) GetResponse 

func (x *RecoverTrashResponse) GetResponse() bool

func (*RecoverTrashResponse) ProtoMessage 

func (*RecoverTrashResponse) ProtoMessage()

func (*RecoverTrashResponse) ProtoReflect 

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

func (*RecoverTrashResponse) Reset 

func (x *RecoverTrashResponse) Reset()

func (*RecoverTrashResponse) String 

func (x *RecoverTrashResponse) String() string

type RemoveAclRequest 

type RemoveAclRequest struct {
	Obj *OzoneObj     `protobuf:"bytes,1,req,name=obj" json:"obj,omitempty"`
	Acl *OzoneAclInfo `protobuf:"bytes,2,req,name=acl" json:"acl,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveAclRequest) Descriptor deprecated 

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

Deprecated: Use RemoveAclRequest.ProtoReflect.Descriptor instead.

func (*RemoveAclRequest) GetAcl 

func (x *RemoveAclRequest) GetAcl() *OzoneAclInfo

func (*RemoveAclRequest) GetObj 

func (x *RemoveAclRequest) GetObj() *OzoneObj

func (*RemoveAclRequest) ProtoMessage 

func (*RemoveAclRequest) ProtoMessage()

func (*RemoveAclRequest) ProtoReflect 

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

func (*RemoveAclRequest) Reset 

func (x *RemoveAclRequest) Reset()

func (*RemoveAclRequest) String 

func (x *RemoveAclRequest) String() string

type RemoveAclResponse 

type RemoveAclResponse struct {
	Response *bool `protobuf:"varint,1,req,name=response" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveAclResponse) Descriptor deprecated 

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

Deprecated: Use RemoveAclResponse.ProtoReflect.Descriptor instead.

func (*RemoveAclResponse) GetResponse 

func (x *RemoveAclResponse) GetResponse() bool

func (*RemoveAclResponse) ProtoMessage 

func (*RemoveAclResponse) ProtoMessage()

func (*RemoveAclResponse) ProtoReflect 

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

func (*RemoveAclResponse) Reset 

func (x *RemoveAclResponse) Reset()

func (*RemoveAclResponse) String 

func (x *RemoveAclResponse) String() string

type RenameKeyRequest 

type RenameKeyRequest struct {
	KeyArgs   *KeyArgs `protobuf:"bytes,1,req,name=keyArgs" json:"keyArgs,omitempty"`
	ToKeyName *string  `protobuf:"bytes,2,req,name=toKeyName" json:"toKeyName,omitempty"`
	// contains filtered or unexported fields
}

func (*RenameKeyRequest) Descriptor deprecated 

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

Deprecated: Use RenameKeyRequest.ProtoReflect.Descriptor instead.

func (*RenameKeyRequest) GetKeyArgs 

func (x *RenameKeyRequest) GetKeyArgs() *KeyArgs

func (*RenameKeyRequest) GetToKeyName 

func (x *RenameKeyRequest) GetToKeyName() string

func (*RenameKeyRequest) ProtoMessage 

func (*RenameKeyRequest) ProtoMessage()

func (*RenameKeyRequest) ProtoReflect 

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

func (*RenameKeyRequest) Reset 

func (x *RenameKeyRequest) Reset()

func (*RenameKeyRequest) String 

func (x *RenameKeyRequest) String() string

type RenameKeyResponse 

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

func (*RenameKeyResponse) Descriptor deprecated 

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

Deprecated: Use RenameKeyResponse.ProtoReflect.Descriptor instead.

func (*RenameKeyResponse) ProtoMessage 

func (*RenameKeyResponse) ProtoMessage()

func (*RenameKeyResponse) ProtoReflect 

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

func (*RenameKeyResponse) Reset 

func (x *RenameKeyResponse) Reset()

func (*RenameKeyResponse) String 

func (x *RenameKeyResponse) String() string

type RenewDelegationTokenResponseProto 

type RenewDelegationTokenResponseProto struct {
	Response *common.RenewDelegationTokenResponseProto `protobuf:"bytes,2,opt,name=response" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*RenewDelegationTokenResponseProto) Descriptor deprecated 

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

Deprecated: Use RenewDelegationTokenResponseProto.ProtoReflect.Descriptor instead.

func (*RenewDelegationTokenResponseProto) GetResponse 

func (x *RenewDelegationTokenResponseProto) GetResponse() *common.RenewDelegationTokenResponseProto

func (*RenewDelegationTokenResponseProto) ProtoMessage 

func (*RenewDelegationTokenResponseProto) ProtoMessage()

func (*RenewDelegationTokenResponseProto) ProtoReflect 

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

func (*RenewDelegationTokenResponseProto) Reset 

func (x *RenewDelegationTokenResponseProto) Reset()

func (*RenewDelegationTokenResponseProto) String 

func (x *RenewDelegationTokenResponseProto) String() string

type RepeatedKeyInfo 

type RepeatedKeyInfo struct {
	KeyInfo []*KeyInfo `protobuf:"bytes,1,rep,name=keyInfo" json:"keyInfo,omitempty"`
	// contains filtered or unexported fields
}

func (*RepeatedKeyInfo) Descriptor deprecated 

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

Deprecated: Use RepeatedKeyInfo.ProtoReflect.Descriptor instead.

func (*RepeatedKeyInfo) GetKeyInfo 

func (x *RepeatedKeyInfo) GetKeyInfo() []*KeyInfo

func (*RepeatedKeyInfo) ProtoMessage 

func (*RepeatedKeyInfo) ProtoMessage()

func (*RepeatedKeyInfo) ProtoReflect 

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

func (*RepeatedKeyInfo) Reset 

func (x *RepeatedKeyInfo) Reset()

func (*RepeatedKeyInfo) String 

func (x *RepeatedKeyInfo) String() string

type S3Secret 

type S3Secret struct {
	KerberosID *string `protobuf:"bytes,1,req,name=kerberosID" json:"kerberosID,omitempty"`
	AwsSecret  *string `protobuf:"bytes,2,req,name=awsSecret" json:"awsSecret,omitempty"`
	// contains filtered or unexported fields
}

func (*S3Secret) Descriptor deprecated 

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

Deprecated: Use S3Secret.ProtoReflect.Descriptor instead.

func (*S3Secret) GetAwsSecret 

func (x *S3Secret) GetAwsSecret() string

func (*S3Secret) GetKerberosID 

func (x *S3Secret) GetKerberosID() string

func (*S3Secret) ProtoMessage 

func (*S3Secret) ProtoMessage()

func (*S3Secret) ProtoReflect 

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

func (*S3Secret) Reset 

func (x *S3Secret) Reset()

func (*S3Secret) String 

func (x *S3Secret) String() string

type SecretKeyProto 

type SecretKeyProto struct {
	KeyId           *uint32 `protobuf:"varint,1,req,name=keyId" json:"keyId,omitempty"`
	ExpiryDate      *uint64 `protobuf:"varint,2,req,name=expiryDate" json:"expiryDate,omitempty"`
	PrivateKeyBytes []byte  `protobuf:"bytes,3,req,name=privateKeyBytes" json:"privateKeyBytes,omitempty"`
	PublicKeyBytes  []byte  `protobuf:"bytes,4,req,name=publicKeyBytes" json:"publicKeyBytes,omitempty"`
	// contains filtered or unexported fields
}

func (*SecretKeyProto) Descriptor deprecated 

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

Deprecated: Use SecretKeyProto.ProtoReflect.Descriptor instead.

func (*SecretKeyProto) GetExpiryDate 

func (x *SecretKeyProto) GetExpiryDate() uint64

func (*SecretKeyProto) GetKeyId 

func (x *SecretKeyProto) GetKeyId() uint32

func (*SecretKeyProto) GetPrivateKeyBytes 

func (x *SecretKeyProto) GetPrivateKeyBytes() []byte

func (*SecretKeyProto) GetPublicKeyBytes 

func (x *SecretKeyProto) GetPublicKeyBytes() []byte

func (*SecretKeyProto) ProtoMessage 

func (*SecretKeyProto) ProtoMessage()

func (*SecretKeyProto) ProtoReflect 

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

func (*SecretKeyProto) Reset 

func (x *SecretKeyProto) Reset()

func (*SecretKeyProto) String 

func (x *SecretKeyProto) String() string

type ServiceInfo 

type ServiceInfo struct {
	NodeType     *hdds.NodeType `protobuf:"varint,1,req,name=nodeType,enum=hadoop.hdds.NodeType" json:"nodeType,omitempty"`
	Hostname     *string        `protobuf:"bytes,2,req,name=hostname" json:"hostname,omitempty"`
	ServicePorts []*ServicePort `protobuf:"bytes,3,rep,name=servicePorts" json:"servicePorts,omitempty"`
	OmRole       *OMRoleInfo    `protobuf:"bytes,4,opt,name=omRole" json:"omRole,omitempty"`
	// contains filtered or unexported fields
}

func (*ServiceInfo) Descriptor deprecated 

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

Deprecated: Use ServiceInfo.ProtoReflect.Descriptor instead.

func (*ServiceInfo) GetHostname 

func (x *ServiceInfo) GetHostname() string

func (*ServiceInfo) GetNodeType 

func (x *ServiceInfo) GetNodeType() hdds.NodeType

func (*ServiceInfo) GetOmRole 

func (x *ServiceInfo) GetOmRole() *OMRoleInfo

func (*ServiceInfo) GetServicePorts 

func (x *ServiceInfo) GetServicePorts() []*ServicePort

func (*ServiceInfo) ProtoMessage 

func (*ServiceInfo) ProtoMessage()

func (*ServiceInfo) ProtoReflect 

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

func (*ServiceInfo) Reset 

func (x *ServiceInfo) Reset()

func (*ServiceInfo) String 

func (x *ServiceInfo) String() string

type ServiceListRequest 

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

func (*ServiceListRequest) Descriptor deprecated 

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

Deprecated: Use ServiceListRequest.ProtoReflect.Descriptor instead.

func (*ServiceListRequest) ProtoMessage 

func (*ServiceListRequest) ProtoMessage()

func (*ServiceListRequest) ProtoReflect 

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

func (*ServiceListRequest) Reset 

func (x *ServiceListRequest) Reset()

func (*ServiceListRequest) String 

func (x *ServiceListRequest) String() string

type ServiceListResponse 

type ServiceListResponse struct {
	ServiceInfo []*ServiceInfo `protobuf:"bytes,2,rep,name=serviceInfo" json:"serviceInfo,omitempty"`
	// When security is enabled, return SCM CA certificate to Ozone client
	// to set up gRPC TLS for client to authenticate server(DN).
	CaCertificate *string `protobuf:"bytes,3,opt,name=caCertificate" json:"caCertificate,omitempty"`
	// contains filtered or unexported fields
}

func (*ServiceListResponse) Descriptor deprecated 

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

Deprecated: Use ServiceListResponse.ProtoReflect.Descriptor instead.

func (*ServiceListResponse) GetCaCertificate 

func (x *ServiceListResponse) GetCaCertificate() string

func (*ServiceListResponse) GetServiceInfo 

func (x *ServiceListResponse) GetServiceInfo() []*ServiceInfo

func (*ServiceListResponse) ProtoMessage 

func (*ServiceListResponse) ProtoMessage()

func (*ServiceListResponse) ProtoReflect 

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

func (*ServiceListResponse) Reset 

func (x *ServiceListResponse) Reset()

func (*ServiceListResponse) String 

func (x *ServiceListResponse) String() string

type ServicePort 

type ServicePort struct {
	Type  *ServicePort_Type `protobuf:"varint,1,req,name=type,enum=hadoop.ozone.ServicePort_Type" json:"type,omitempty"`
	Value *uint32           `protobuf:"varint,2,req,name=value" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*ServicePort) Descriptor deprecated 

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

Deprecated: Use ServicePort.ProtoReflect.Descriptor instead.

func (*ServicePort) GetType 

func (x *ServicePort) GetType() ServicePort_Type

func (*ServicePort) GetValue 

func (x *ServicePort) GetValue() uint32

func (*ServicePort) ProtoMessage 

func (*ServicePort) ProtoMessage()

func (*ServicePort) ProtoReflect 

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

func (*ServicePort) Reset 

func (x *ServicePort) Reset()

func (*ServicePort) String 

func (x *ServicePort) String() string

type ServicePort_Type 

type ServicePort_Type int32
const (
	ServicePort_RPC   ServicePort_Type = 1
	ServicePort_HTTP  ServicePort_Type = 2
	ServicePort_HTTPS ServicePort_Type = 3
	ServicePort_RATIS ServicePort_Type = 4
)

func (ServicePort_Type) Descriptor 

func (ServicePort_Type) Descriptor() protoreflect.EnumDescriptor

func (ServicePort_Type) Enum 

func (x ServicePort_Type) Enum() *ServicePort_Type

func (ServicePort_Type) EnumDescriptor deprecated 

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

Deprecated: Use ServicePort_Type.Descriptor instead.

func (ServicePort_Type) Number 

func (x ServicePort_Type) Number() protoreflect.EnumNumber

func (ServicePort_Type) String 

func (x ServicePort_Type) String() string

func (ServicePort_Type) Type 

func (ServicePort_Type) Type() protoreflect.EnumType

func (*ServicePort_Type) UnmarshalJSON deprecated 

func (x *ServicePort_Type) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type SetAclRequest 

type SetAclRequest struct {
	Obj *OzoneObj       `protobuf:"bytes,1,req,name=obj" json:"obj,omitempty"`
	Acl []*OzoneAclInfo `protobuf:"bytes,2,rep,name=acl" json:"acl,omitempty"`
	// contains filtered or unexported fields
}

func (*SetAclRequest) Descriptor deprecated 

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

Deprecated: Use SetAclRequest.ProtoReflect.Descriptor instead.

func (*SetAclRequest) GetAcl 

func (x *SetAclRequest) GetAcl() []*OzoneAclInfo

func (*SetAclRequest) GetObj 

func (x *SetAclRequest) GetObj() *OzoneObj

func (*SetAclRequest) ProtoMessage 

func (*SetAclRequest) ProtoMessage()

func (*SetAclRequest) ProtoReflect 

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

func (*SetAclRequest) Reset 

func (x *SetAclRequest) Reset()

func (*SetAclRequest) String 

func (x *SetAclRequest) String() string

type SetAclResponse 

type SetAclResponse struct {
	Response *bool `protobuf:"varint,1,req,name=response" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*SetAclResponse) Descriptor deprecated 

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

Deprecated: Use SetAclResponse.ProtoReflect.Descriptor instead.

func (*SetAclResponse) GetResponse 

func (x *SetAclResponse) GetResponse() bool

func (*SetAclResponse) ProtoMessage 

func (*SetAclResponse) ProtoMessage()

func (*SetAclResponse) ProtoReflect 

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

func (*SetAclResponse) Reset 

func (x *SetAclResponse) Reset()

func (*SetAclResponse) String 

func (x *SetAclResponse) String() string

type SetBucketPropertyRequest 

type SetBucketPropertyRequest struct {
	BucketArgs *BucketArgs `protobuf:"bytes,1,opt,name=bucketArgs" json:"bucketArgs,omitempty"`
	// contains filtered or unexported fields
}

func (*SetBucketPropertyRequest) Descriptor deprecated 

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

Deprecated: Use SetBucketPropertyRequest.ProtoReflect.Descriptor instead.

func (*SetBucketPropertyRequest) GetBucketArgs 

func (x *SetBucketPropertyRequest) GetBucketArgs() *BucketArgs

func (*SetBucketPropertyRequest) ProtoMessage 

func (*SetBucketPropertyRequest) ProtoMessage()

func (*SetBucketPropertyRequest) ProtoReflect 

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

func (*SetBucketPropertyRequest) Reset 

func (x *SetBucketPropertyRequest) Reset()

func (*SetBucketPropertyRequest) String 

func (x *SetBucketPropertyRequest) String() string

type SetBucketPropertyResponse 

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

func (*SetBucketPropertyResponse) Descriptor deprecated 

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

Deprecated: Use SetBucketPropertyResponse.ProtoReflect.Descriptor instead.

func (*SetBucketPropertyResponse) ProtoMessage 

func (*SetBucketPropertyResponse) ProtoMessage()

func (*SetBucketPropertyResponse) ProtoReflect 

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

func (*SetBucketPropertyResponse) Reset 

func (x *SetBucketPropertyResponse) Reset()

func (*SetBucketPropertyResponse) String 

func (x *SetBucketPropertyResponse) String() string

type SetVolumePropertyRequest 

type SetVolumePropertyRequest struct {
	VolumeName       *string `protobuf:"bytes,1,req,name=volumeName" json:"volumeName,omitempty"`
	OwnerName        *string `protobuf:"bytes,2,opt,name=ownerName" json:"ownerName,omitempty"`
	QuotaInBytes     *uint64 `protobuf:"varint,3,opt,name=quotaInBytes" json:"quotaInBytes,omitempty"`
	ModificationTime *uint64 `protobuf:"varint,4,opt,name=modificationTime" json:"modificationTime,omitempty"`
	// contains filtered or unexported fields
}

* Changes the Volume Properties -- like ownership and quota for a volume.

func (*SetVolumePropertyRequest) Descriptor deprecated 

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

Deprecated: Use SetVolumePropertyRequest.ProtoReflect.Descriptor instead.

func (*SetVolumePropertyRequest) GetModificationTime 

func (x *SetVolumePropertyRequest) GetModificationTime() uint64

func (*SetVolumePropertyRequest) GetOwnerName 

func (x *SetVolumePropertyRequest) GetOwnerName() string

func (*SetVolumePropertyRequest) GetQuotaInBytes 

func (x *SetVolumePropertyRequest) GetQuotaInBytes() uint64

func (*SetVolumePropertyRequest) GetVolumeName 

func (x *SetVolumePropertyRequest) GetVolumeName() string

func (*SetVolumePropertyRequest) ProtoMessage 

func (*SetVolumePropertyRequest) ProtoMessage()

func (*SetVolumePropertyRequest) ProtoReflect 

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

func (*SetVolumePropertyRequest) Reset 

func (x *SetVolumePropertyRequest) Reset()

func (*SetVolumePropertyRequest) String 

func (x *SetVolumePropertyRequest) String() string

type SetVolumePropertyResponse 

type SetVolumePropertyResponse struct {
	Response *bool `protobuf:"varint,1,opt,name=response" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*SetVolumePropertyResponse) Descriptor deprecated 

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

Deprecated: Use SetVolumePropertyResponse.ProtoReflect.Descriptor instead.

func (*SetVolumePropertyResponse) GetResponse 

func (x *SetVolumePropertyResponse) GetResponse() bool

func (*SetVolumePropertyResponse) ProtoMessage 

func (*SetVolumePropertyResponse) ProtoMessage()

func (*SetVolumePropertyResponse) ProtoReflect 

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

func (*SetVolumePropertyResponse) Reset 

func (x *SetVolumePropertyResponse) Reset()

func (*SetVolumePropertyResponse) String 

func (x *SetVolumePropertyResponse) String() string

type Status 

type Status int32
const (
	Status_OK                                 Status = 1
	Status_VOLUME_NOT_UNIQUE                  Status = 2
	Status_VOLUME_NOT_FOUND                   Status = 3
	Status_VOLUME_NOT_EMPTY                   Status = 4
	Status_VOLUME_ALREADY_EXISTS              Status = 5
	Status_USER_NOT_FOUND                     Status = 6
	Status_USER_TOO_MANY_VOLUMES              Status = 7
	Status_BUCKET_NOT_FOUND                   Status = 8
	Status_BUCKET_NOT_EMPTY                   Status = 9
	Status_BUCKET_ALREADY_EXISTS              Status = 10
	Status_KEY_ALREADY_EXISTS                 Status = 11
	Status_KEY_NOT_FOUND                      Status = 12
	Status_INVALID_KEY_NAME                   Status = 13
	Status_ACCESS_DENIED                      Status = 14
	Status_INTERNAL_ERROR                     Status = 15
	Status_KEY_ALLOCATION_ERROR               Status = 16
	Status_KEY_DELETION_ERROR                 Status = 17
	Status_KEY_RENAME_ERROR                   Status = 18
	Status_METADATA_ERROR                     Status = 19
	Status_OM_NOT_INITIALIZED                 Status = 20
	Status_SCM_VERSION_MISMATCH_ERROR         Status = 21
	Status_INITIATE_MULTIPART_UPLOAD_ERROR    Status = 24
	Status_MULTIPART_UPLOAD_PARTFILE_ERROR    Status = 25
	Status_NO_SUCH_MULTIPART_UPLOAD_ERROR     Status = 26
	Status_MISMATCH_MULTIPART_LIST            Status = 27
	Status_MISSING_UPLOAD_PARTS               Status = 28
	Status_COMPLETE_MULTIPART_UPLOAD_ERROR    Status = 29
	Status_ENTITY_TOO_SMALL                   Status = 30
	Status_ABORT_MULTIPART_UPLOAD_FAILED      Status = 31
	Status_S3_SECRET_NOT_FOUND                Status = 32
	Status_INVALID_AUTH_METHOD                Status = 33
	Status_INVALID_TOKEN                      Status = 34
	Status_TOKEN_EXPIRED                      Status = 35
	Status_TOKEN_ERROR_OTHER                  Status = 36
	Status_LIST_MULTIPART_UPLOAD_PARTS_FAILED Status = 37
	Status_SCM_IN_SAFE_MODE                   Status = 38
	Status_INVALID_REQUEST                    Status = 39
	Status_BUCKET_ENCRYPTION_KEY_NOT_FOUND    Status = 40
	Status_UNKNOWN_CIPHER_SUITE               Status = 41
	Status_INVALID_KMS_PROVIDER               Status = 42
	Status_TOKEN_CREATION_ERROR               Status = 43
	Status_FILE_NOT_FOUND                     Status = 44
	Status_DIRECTORY_NOT_FOUND                Status = 45
	Status_FILE_ALREADY_EXISTS                Status = 46
	Status_NOT_A_FILE                         Status = 47
	Status_PERMISSION_DENIED                  Status = 48
	Status_TIMEOUT                            Status = 49
	Status_PREFIX_NOT_FOUND                   Status = 50
	Status_RATIS_ERROR                        Status = 52
	Status_INVALID_PATH_IN_ACL_REQUEST        Status = 53 // Invalid path name in acl request.
	Status_USER_MISMATCH                      Status = 54 // Error code when requested user name passed is
	Status_INVALID_PART                       Status = 55
	Status_INVALID_PART_ORDER                 Status = 56
	Status_SCM_GET_PIPELINE_EXCEPTION         Status = 57
	Status_INVALID_BUCKET_NAME                Status = 58
	Status_CANNOT_CREATE_DIRECTORY_AT_ROOT    Status = 59
	Status_DIRECTORY_ALREADY_EXISTS           Status = 60
	Status_INVALID_VOLUME_NAME                Status = 61
	Status_PARTIAL_DELETE                     Status = 62
	Status_DETECTED_LOOP_IN_BUCKET_LINKS      Status = 63
	Status_NOT_SUPPORTED_OPERATION            Status = 64
)

func (Status) Descriptor 

func (Status) Descriptor() protoreflect.EnumDescriptor

func (Status) Enum 

func (x Status) Enum() *Status

func (Status) EnumDescriptor deprecated 

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

Deprecated: Use Status.Descriptor instead.

func (Status) Number 

func (x Status) Number() protoreflect.EnumNumber

func (Status) String 

func (x Status) String() string

func (Status) Type 

func (Status) Type() protoreflect.EnumType

func (*Status) UnmarshalJSON deprecated 

func (x *Status) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type StorageTypeProto 

type StorageTypeProto int32
const (
	StorageTypeProto_DISK     StorageTypeProto = 1
	StorageTypeProto_SSD      StorageTypeProto = 2
	StorageTypeProto_ARCHIVE  StorageTypeProto = 3
	StorageTypeProto_RAM_DISK StorageTypeProto = 4
)

func (StorageTypeProto) Descriptor 

func (StorageTypeProto) Descriptor() protoreflect.EnumDescriptor

func (StorageTypeProto) Enum 

func (x StorageTypeProto) Enum() *StorageTypeProto

func (StorageTypeProto) EnumDescriptor deprecated 

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

Deprecated: Use StorageTypeProto.Descriptor instead.

func (StorageTypeProto) Number 

func (x StorageTypeProto) Number() protoreflect.EnumNumber

func (StorageTypeProto) String 

func (x StorageTypeProto) String() string

func (StorageTypeProto) Type 

func (StorageTypeProto) Type() protoreflect.EnumType

func (*StorageTypeProto) UnmarshalJSON deprecated 

func (x *StorageTypeProto) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type Type 

type Type int32
const (
	Type_CreateVolume             Type = 11
	Type_SetVolumeProperty        Type = 12
	Type_CheckVolumeAccess        Type = 13
	Type_InfoVolume               Type = 14
	Type_DeleteVolume             Type = 15
	Type_ListVolume               Type = 16
	Type_CreateBucket             Type = 21
	Type_InfoBucket               Type = 22
	Type_SetBucketProperty        Type = 23
	Type_DeleteBucket             Type = 24
	Type_ListBuckets              Type = 25
	Type_CreateKey                Type = 31
	Type_LookupKey                Type = 32
	Type_RenameKey                Type = 33
	Type_DeleteKey                Type = 34
	Type_ListKeys                 Type = 35
	Type_CommitKey                Type = 36
	Type_AllocateBlock            Type = 37
	Type_DeleteKeys               Type = 38
	Type_InitiateMultiPartUpload  Type = 45
	Type_CommitMultiPartUpload    Type = 46
	Type_CompleteMultiPartUpload  Type = 47
	Type_AbortMultiPartUpload     Type = 48
	Type_GetS3Secret              Type = 49
	Type_ListMultiPartUploadParts Type = 50
	Type_ServiceList              Type = 51
	Type_DBUpdates                Type = 53
	Type_GetDelegationToken       Type = 61
	Type_RenewDelegationToken     Type = 62
	Type_CancelDelegationToken    Type = 63
	Type_GetFileStatus            Type = 70
	Type_CreateDirectory          Type = 71
	Type_CreateFile               Type = 72
	Type_LookupFile               Type = 73
	Type_ListStatus               Type = 74
	Type_AddAcl                   Type = 75
	Type_RemoveAcl                Type = 76
	Type_SetAcl                   Type = 77
	Type_GetAcl                   Type = 78
	Type_PurgeKeys                Type = 81
	Type_ListMultipartUploads     Type = 82
	Type_ListTrash                Type = 91
	Type_RecoverTrash             Type = 92
)

func (Type) Descriptor 

func (Type) Descriptor() protoreflect.EnumDescriptor

func (Type) Enum 

func (x Type) Enum() *Type

func (Type) EnumDescriptor deprecated 

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

Deprecated: Use Type.Descriptor instead.

func (Type) Number 

func (x Type) Number() protoreflect.EnumNumber

func (Type) String 

func (x Type) String() string

func (Type) Type 

func (Type) Type() protoreflect.EnumType

func (*Type) UnmarshalJSON deprecated 

func (x *Type) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type UpdateGetDelegationTokenRequest 

type UpdateGetDelegationTokenRequest struct {
	GetDelegationTokenResponse *GetDelegationTokenResponseProto `protobuf:"bytes,1,req,name=getDelegationTokenResponse" json:"getDelegationTokenResponse,omitempty"`
	TokenRenewInterval         *uint64                          `protobuf:"varint,2,opt,name=tokenRenewInterval" json:"tokenRenewInterval,omitempty"`
	// contains filtered or unexported fields
}

* This will be used during OM HA, once leader generates token sends this request via ratis to persist to OM DB. This request will be internally used by OM for replicating token across a quorum of OMs.

func (*UpdateGetDelegationTokenRequest) Descriptor deprecated 

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

Deprecated: Use UpdateGetDelegationTokenRequest.ProtoReflect.Descriptor instead.

func (*UpdateGetDelegationTokenRequest) GetGetDelegationTokenResponse 

func (x *UpdateGetDelegationTokenRequest) GetGetDelegationTokenResponse() *GetDelegationTokenResponseProto

func (*UpdateGetDelegationTokenRequest) GetTokenRenewInterval 

func (x *UpdateGetDelegationTokenRequest) GetTokenRenewInterval() uint64

func (*UpdateGetDelegationTokenRequest) ProtoMessage 

func (*UpdateGetDelegationTokenRequest) ProtoMessage()

func (*UpdateGetDelegationTokenRequest) ProtoReflect 

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

func (*UpdateGetDelegationTokenRequest) Reset 

func (x *UpdateGetDelegationTokenRequest) Reset()

func (*UpdateGetDelegationTokenRequest) String 

func (x *UpdateGetDelegationTokenRequest) String() string

type UpdateGetS3SecretRequest 

type UpdateGetS3SecretRequest struct {
	KerberosID *string `protobuf:"bytes,1,req,name=kerberosID" json:"kerberosID,omitempty"`
	AwsSecret  *string `protobuf:"bytes,2,req,name=awsSecret" json:"awsSecret,omitempty"`
	// contains filtered or unexported fields
}

* This will be used internally by OM to replicate S3 Secret across quorum of OM's.

func (*UpdateGetS3SecretRequest) Descriptor deprecated 

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

Deprecated: Use UpdateGetS3SecretRequest.ProtoReflect.Descriptor instead.

func (*UpdateGetS3SecretRequest) GetAwsSecret 

func (x *UpdateGetS3SecretRequest) GetAwsSecret() string

func (*UpdateGetS3SecretRequest) GetKerberosID 

func (x *UpdateGetS3SecretRequest) GetKerberosID() string

func (*UpdateGetS3SecretRequest) ProtoMessage 

func (*UpdateGetS3SecretRequest) ProtoMessage()

func (*UpdateGetS3SecretRequest) ProtoReflect 

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

func (*UpdateGetS3SecretRequest) Reset 

func (x *UpdateGetS3SecretRequest) Reset()

func (*UpdateGetS3SecretRequest) String 

func (x *UpdateGetS3SecretRequest) String() string

type UpdateRenewDelegationTokenRequest 

type UpdateRenewDelegationTokenRequest struct {
	RenewDelegationTokenRequest  *common.RenewDelegationTokenRequestProto `protobuf:"bytes,1,req,name=renewDelegationTokenRequest" json:"renewDelegationTokenRequest,omitempty"`
	RenewDelegationTokenResponse *RenewDelegationTokenResponseProto       `protobuf:"bytes,2,req,name=renewDelegationTokenResponse" json:"renewDelegationTokenResponse,omitempty"`
	// contains filtered or unexported fields
}

* This will be used during OM HA, once leader renews token, sends this request via ratis to persist to OM DB. This request will be internally used by OM for replicating renewed token information across a quorum of OMs.

func (*UpdateRenewDelegationTokenRequest) Descriptor deprecated 

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

Deprecated: Use UpdateRenewDelegationTokenRequest.ProtoReflect.Descriptor instead.

func (*UpdateRenewDelegationTokenRequest) GetRenewDelegationTokenRequest 

func (x *UpdateRenewDelegationTokenRequest) GetRenewDelegationTokenRequest() *common.RenewDelegationTokenRequestProto

func (*UpdateRenewDelegationTokenRequest) GetRenewDelegationTokenResponse 

func (x *UpdateRenewDelegationTokenRequest) GetRenewDelegationTokenResponse() *RenewDelegationTokenResponseProto

func (*UpdateRenewDelegationTokenRequest) ProtoMessage 

func (*UpdateRenewDelegationTokenRequest) ProtoMessage()

func (*UpdateRenewDelegationTokenRequest) ProtoReflect 

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

func (*UpdateRenewDelegationTokenRequest) Reset 

func (x *UpdateRenewDelegationTokenRequest) Reset()

func (*UpdateRenewDelegationTokenRequest) String 

func (x *UpdateRenewDelegationTokenRequest) String() string

type UserInfo 

type UserInfo struct {
	UserName      *string `protobuf:"bytes,1,opt,name=userName" json:"userName,omitempty"`
	RemoteAddress *string `protobuf:"bytes,3,opt,name=remoteAddress" json:"remoteAddress,omitempty"`
	HostName      *string `protobuf:"bytes,4,opt,name=hostName" json:"hostName,omitempty"`
	// contains filtered or unexported fields
}

* User information which will be extracted during RPC context and used during validating Acl.

func (*UserInfo) Descriptor deprecated 

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

Deprecated: Use UserInfo.ProtoReflect.Descriptor instead.

func (*UserInfo) GetHostName 

func (x *UserInfo) GetHostName() string

func (*UserInfo) GetRemoteAddress 

func (x *UserInfo) GetRemoteAddress() string

func (*UserInfo) GetUserName 

func (x *UserInfo) GetUserName() string

func (*UserInfo) ProtoMessage 

func (*UserInfo) ProtoMessage()

func (*UserInfo) ProtoReflect 

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

func (*UserInfo) Reset 

func (x *UserInfo) Reset()

func (*UserInfo) String 

func (x *UserInfo) String() string

type UserVolumeInfo 

type UserVolumeInfo struct {
	VolumeNames []string `protobuf:"bytes,1,rep,name=volumeNames" json:"volumeNames,omitempty"`
	ObjectID    *uint64  `protobuf:"varint,2,opt,name=objectID" json:"objectID,omitempty"`
	UpdateID    *uint64  `protobuf:"varint,3,opt,name=updateID" json:"updateID,omitempty"`
	// contains filtered or unexported fields
}

func (*UserVolumeInfo) Descriptor deprecated 

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

Deprecated: Use UserVolumeInfo.ProtoReflect.Descriptor instead.

func (*UserVolumeInfo) GetObjectID 

func (x *UserVolumeInfo) GetObjectID() uint64

func (*UserVolumeInfo) GetUpdateID 

func (x *UserVolumeInfo) GetUpdateID() uint64

func (*UserVolumeInfo) GetVolumeNames 

func (x *UserVolumeInfo) GetVolumeNames() []string

func (*UserVolumeInfo) ProtoMessage 

func (*UserVolumeInfo) ProtoMessage()

func (*UserVolumeInfo) ProtoReflect 

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

func (*UserVolumeInfo) Reset 

func (x *UserVolumeInfo) Reset()

func (*UserVolumeInfo) String 

func (x *UserVolumeInfo) String() string

type VolumeInfo 

type VolumeInfo struct {
	AdminName        *string          `protobuf:"bytes,1,req,name=adminName" json:"adminName,omitempty"`
	OwnerName        *string          `protobuf:"bytes,2,req,name=ownerName" json:"ownerName,omitempty"`
	Volume           *string          `protobuf:"bytes,3,req,name=volume" json:"volume,omitempty"`
	QuotaInBytes     *uint64          `protobuf:"varint,4,opt,name=quotaInBytes" json:"quotaInBytes,omitempty"`
	Metadata         []*hdds.KeyValue `protobuf:"bytes,5,rep,name=metadata" json:"metadata,omitempty"`
	VolumeAcls       []*OzoneAclInfo  `protobuf:"bytes,6,rep,name=volumeAcls" json:"volumeAcls,omitempty"`
	CreationTime     *uint64          `protobuf:"varint,7,opt,name=creationTime" json:"creationTime,omitempty"`
	ObjectID         *uint64          `protobuf:"varint,8,opt,name=objectID" json:"objectID,omitempty"`
	UpdateID         *uint64          `protobuf:"varint,9,opt,name=updateID" json:"updateID,omitempty"`
	ModificationTime *uint64          `protobuf:"varint,10,opt,name=modificationTime" json:"modificationTime,omitempty"`
	// contains filtered or unexported fields
}

func (*VolumeInfo) Descriptor deprecated 

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

Deprecated: Use VolumeInfo.ProtoReflect.Descriptor instead.

func (*VolumeInfo) GetAdminName 

func (x *VolumeInfo) GetAdminName() string

func (*VolumeInfo) GetCreationTime 

func (x *VolumeInfo) GetCreationTime() uint64

func (*VolumeInfo) GetMetadata 

func (x *VolumeInfo) GetMetadata() []*hdds.KeyValue

func (*VolumeInfo) GetModificationTime 

func (x *VolumeInfo) GetModificationTime() uint64

func (*VolumeInfo) GetObjectID 

func (x *VolumeInfo) GetObjectID() uint64

func (*VolumeInfo) GetOwnerName 

func (x *VolumeInfo) GetOwnerName() string

func (*VolumeInfo) GetQuotaInBytes 

func (x *VolumeInfo) GetQuotaInBytes() uint64

func (*VolumeInfo) GetUpdateID 

func (x *VolumeInfo) GetUpdateID() uint64

func (*VolumeInfo) GetVolume 

func (x *VolumeInfo) GetVolume() string

func (*VolumeInfo) GetVolumeAcls 

func (x *VolumeInfo) GetVolumeAcls() []*OzoneAclInfo

func (*VolumeInfo) ProtoMessage 

func (*VolumeInfo) ProtoMessage()

func (*VolumeInfo) ProtoReflect 

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

func (*VolumeInfo) Reset 

func (x *VolumeInfo) Reset()

func (*VolumeInfo) String 

func (x *VolumeInfo) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.