datanode

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: 9 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Default_ContainerDataProto_State         = ContainerDataProto_OPEN
	Default_ContainerDataProto_ContainerType = ContainerType_KeyValueContainer
)

Default values for ContainerDataProto fields.

View Source 
const (
	Default_CreateContainerRequestProto_ContainerType = ContainerType_KeyValueContainer
)

Default values for CreateContainerRequestProto fields.

View Source 
const (
	Default_DatanodeBlockID_BlockCommitSequenceId = uint64(0)
)

Default values for DatanodeBlockID fields.

View Source 
const (
	Default_DeleteContainerRequestProto_ForceDelete = bool(false)
)

Default values for DeleteContainerRequestProto fields.

View Source 
const (
	Default_UpdateContainerRequestProto_ForceUpdate = bool(false)
)

Default values for UpdateContainerRequestProto fields.

Variables

View Source 
var (
	Type_name = map[int32]string{
		1:  "CreateContainer",
		2:  "ReadContainer",
		3:  "UpdateContainer",
		4:  "DeleteContainer",
		5:  "ListContainer",
		6:  "PutBlock",
		7:  "GetBlock",
		8:  "DeleteBlock",
		9:  "ListBlock",
		10: "ReadChunk",
		11: "DeleteChunk",
		12: "WriteChunk",
		13: "ListChunk",
		14: "CompactChunk",
		15: "PutSmallFile",
		16: "GetSmallFile",
		17: "CloseContainer",
		18: "GetCommittedBlockLength",
	}
	Type_value = map[string]int32{
		"CreateContainer":         1,
		"ReadContainer":           2,
		"UpdateContainer":         3,
		"DeleteContainer":         4,
		"ListContainer":           5,
		"PutBlock":                6,
		"GetBlock":                7,
		"DeleteBlock":             8,
		"ListBlock":               9,
		"ReadChunk":               10,
		"DeleteChunk":             11,
		"WriteChunk":              12,
		"ListChunk":               13,
		"CompactChunk":            14,
		"PutSmallFile":            15,
		"GetSmallFile":            16,
		"CloseContainer":          17,
		"GetCommittedBlockLength": 18,
	}
)

Enum value maps for Type.

View Source 
var (
	Result_name = map[int32]string{
		1:  "SUCCESS",
		2:  "UNSUPPORTED_REQUEST",
		3:  "MALFORMED_REQUEST",
		4:  "CONTAINER_INTERNAL_ERROR",
		5:  "INVALID_CONFIG",
		6:  "INVALID_FILE_HASH_FOUND",
		7:  "CONTAINER_EXISTS",
		8:  "NO_SUCH_ALGORITHM",
		9:  "CONTAINER_NOT_FOUND",
		10: "IO_EXCEPTION",
		11: "UNABLE_TO_READ_METADATA_DB",
		12: "NO_SUCH_BLOCK",
		13: "OVERWRITE_FLAG_REQUIRED",
		14: "UNABLE_TO_FIND_DATA_DIR",
		15: "INVALID_WRITE_SIZE",
		16: "CHECKSUM_MISMATCH",
		17: "UNABLE_TO_FIND_CHUNK",
		18: "PROTOC_DECODING_ERROR",
		19: "INVALID_ARGUMENT",
		20: "PUT_SMALL_FILE_ERROR",
		21: "GET_SMALL_FILE_ERROR",
		22: "CLOSED_CONTAINER_IO",
		24: "ERROR_IN_COMPACT_DB",
		25: "UNCLOSED_CONTAINER_IO",
		26: "DELETE_ON_OPEN_CONTAINER",
		27: "CLOSED_CONTAINER_RETRY",
		28: "INVALID_CONTAINER_STATE",
		29: "DISK_OUT_OF_SPACE",
		30: "CONTAINER_ALREADY_EXISTS",
		31: "CONTAINER_METADATA_ERROR",
		32: "CONTAINER_FILES_CREATE_ERROR",
		33: "CONTAINER_CHECKSUM_ERROR",
		34: "UNKNOWN_CONTAINER_TYPE",
		35: "BLOCK_NOT_COMMITTED",
		36: "CONTAINER_UNHEALTHY",
		37: "UNKNOWN_BCSID",
		38: "BCSID_MISMATCH",
		39: "CONTAINER_NOT_OPEN",
		40: "CONTAINER_MISSING",
		41: "BLOCK_TOKEN_VERIFICATION_FAILED",
		42: "ERROR_IN_DB_SYNC",
	}
	Result_value = map[string]int32{
		"SUCCESS":                         1,
		"UNSUPPORTED_REQUEST":             2,
		"MALFORMED_REQUEST":               3,
		"CONTAINER_INTERNAL_ERROR":        4,
		"INVALID_CONFIG":                  5,
		"INVALID_FILE_HASH_FOUND":         6,
		"CONTAINER_EXISTS":                7,
		"NO_SUCH_ALGORITHM":               8,
		"CONTAINER_NOT_FOUND":             9,
		"IO_EXCEPTION":                    10,
		"UNABLE_TO_READ_METADATA_DB":      11,
		"NO_SUCH_BLOCK":                   12,
		"OVERWRITE_FLAG_REQUIRED":         13,
		"UNABLE_TO_FIND_DATA_DIR":         14,
		"INVALID_WRITE_SIZE":              15,
		"CHECKSUM_MISMATCH":               16,
		"UNABLE_TO_FIND_CHUNK":            17,
		"PROTOC_DECODING_ERROR":           18,
		"INVALID_ARGUMENT":                19,
		"PUT_SMALL_FILE_ERROR":            20,
		"GET_SMALL_FILE_ERROR":            21,
		"CLOSED_CONTAINER_IO":             22,
		"ERROR_IN_COMPACT_DB":             24,
		"UNCLOSED_CONTAINER_IO":           25,
		"DELETE_ON_OPEN_CONTAINER":        26,
		"CLOSED_CONTAINER_RETRY":          27,
		"INVALID_CONTAINER_STATE":         28,
		"DISK_OUT_OF_SPACE":               29,
		"CONTAINER_ALREADY_EXISTS":        30,
		"CONTAINER_METADATA_ERROR":        31,
		"CONTAINER_FILES_CREATE_ERROR":    32,
		"CONTAINER_CHECKSUM_ERROR":        33,
		"UNKNOWN_CONTAINER_TYPE":          34,
		"BLOCK_NOT_COMMITTED":             35,
		"CONTAINER_UNHEALTHY":             36,
		"UNKNOWN_BCSID":                   37,
		"BCSID_MISMATCH":                  38,
		"CONTAINER_NOT_OPEN":              39,
		"CONTAINER_MISSING":               40,
		"BLOCK_TOKEN_VERIFICATION_FAILED": 41,
		"ERROR_IN_DB_SYNC":                42,
	}
)

Enum value maps for Result.

View Source 
var (
	ContainerType_name = map[int32]string{
		1: "KeyValueContainer",
	}
	ContainerType_value = map[string]int32{
		"KeyValueContainer": 1,
	}
)

Enum value maps for ContainerType.

View Source 
var (
	ChecksumType_name = map[int32]string{
		1: "NONE",
		2: "CRC32",
		3: "CRC32C",
		4: "SHA256",
		5: "MD5",
	}
	ChecksumType_value = map[string]int32{
		"NONE":   1,
		"CRC32":  2,
		"CRC32C": 3,
		"SHA256": 4,
		"MD5":    5,
	}
)

Enum value maps for ChecksumType.

View Source 
var (
	ContainerDataProto_State_name = map[int32]string{
		1: "OPEN",
		2: "CLOSING",
		3: "QUASI_CLOSED",
		4: "CLOSED",
		5: "UNHEALTHY",
		6: "INVALID",
		7: "DELETED",
	}
	ContainerDataProto_State_value = map[string]int32{
		"OPEN":         1,
		"CLOSING":      2,
		"QUASI_CLOSED": 3,
		"CLOSED":       4,
		"UNHEALTHY":    5,
		"INVALID":      6,
		"DELETED":      7,
	}
)

Enum value maps for ContainerDataProto_State.

View Source 
var File_DatanodeClientProtocol_proto protoreflect.FileDescriptor

Functions

func RegisterIntraDatanodeProtocolServiceServer 

func RegisterIntraDatanodeProtocolServiceServer(s *grpc.Server, srv IntraDatanodeProtocolServiceServer)

func RegisterXceiverClientProtocolServiceServer 

func RegisterXceiverClientProtocolServiceServer(s *grpc.Server, srv XceiverClientProtocolServiceServer)

Types

type BlockData 

type BlockData struct {
	BlockID  *DatanodeBlockID `protobuf:"bytes,1,req,name=blockID" json:"blockID,omitempty"`
	Flags    *int64           `protobuf:"varint,2,opt,name=flags" json:"flags,omitempty"` // for future use.
	Metadata []*KeyValue      `protobuf:"bytes,3,rep,name=metadata" json:"metadata,omitempty"`
	Chunks   []*ChunkInfo     `protobuf:"bytes,4,rep,name=chunks" json:"chunks,omitempty"`
	Size     *int64           `protobuf:"varint,5,opt,name=size" json:"size,omitempty"`
	// contains filtered or unexported fields
}

func (*BlockData) Descriptor deprecated 

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

Deprecated: Use BlockData.ProtoReflect.Descriptor instead.

func (*BlockData) GetBlockID 

func (x *BlockData) GetBlockID() *DatanodeBlockID

func (*BlockData) GetChunks 

func (x *BlockData) GetChunks() []*ChunkInfo

func (*BlockData) GetFlags 

func (x *BlockData) GetFlags() int64

func (*BlockData) GetMetadata 

func (x *BlockData) GetMetadata() []*KeyValue

func (*BlockData) GetSize 

func (x *BlockData) GetSize() int64

func (*BlockData) ProtoMessage 

func (*BlockData) ProtoMessage()

func (*BlockData) ProtoReflect 

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

func (*BlockData) Reset 

func (x *BlockData) Reset()

func (*BlockData) String 

func (x *BlockData) String() string

type ChecksumData 

type ChecksumData struct {
	Type             *ChecksumType `protobuf:"varint,1,req,name=type,enum=hadoop.hdds.datanode.ChecksumType" json:"type,omitempty"`
	BytesPerChecksum *uint32       `protobuf:"varint,2,req,name=bytesPerChecksum" json:"bytesPerChecksum,omitempty"`
	Checksums        [][]byte      `protobuf:"bytes,3,rep,name=checksums" json:"checksums,omitempty"`
	// contains filtered or unexported fields
}

func (*ChecksumData) Descriptor deprecated 

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

Deprecated: Use ChecksumData.ProtoReflect.Descriptor instead.

func (*ChecksumData) GetBytesPerChecksum 

func (x *ChecksumData) GetBytesPerChecksum() uint32

func (*ChecksumData) GetChecksums 

func (x *ChecksumData) GetChecksums() [][]byte

func (*ChecksumData) GetType 

func (x *ChecksumData) GetType() ChecksumType

func (*ChecksumData) ProtoMessage 

func (*ChecksumData) ProtoMessage()

func (*ChecksumData) ProtoReflect 

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

func (*ChecksumData) Reset 

func (x *ChecksumData) Reset()

func (*ChecksumData) String 

func (x *ChecksumData) String() string

type ChecksumType 

type ChecksumType int32
const (
	ChecksumType_NONE   ChecksumType = 1
	ChecksumType_CRC32  ChecksumType = 2
	ChecksumType_CRC32C ChecksumType = 3
	ChecksumType_SHA256 ChecksumType = 4
	ChecksumType_MD5    ChecksumType = 5
)

func (ChecksumType) Descriptor 

func (ChecksumType) Descriptor() protoreflect.EnumDescriptor

func (ChecksumType) Enum 

func (x ChecksumType) Enum() *ChecksumType

func (ChecksumType) EnumDescriptor deprecated 

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

Deprecated: Use ChecksumType.Descriptor instead.

func (ChecksumType) Number 

func (x ChecksumType) Number() protoreflect.EnumNumber

func (ChecksumType) String 

func (x ChecksumType) String() string

func (ChecksumType) Type 

func (ChecksumType) Type() protoreflect.EnumType

func (*ChecksumType) UnmarshalJSON deprecated 

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

Deprecated: Do not use.

type ChunkInfo 

type ChunkInfo struct {
	ChunkName    *string       `protobuf:"bytes,1,req,name=chunkName" json:"chunkName,omitempty"`
	Offset       *uint64       `protobuf:"varint,2,req,name=offset" json:"offset,omitempty"`
	Len          *uint64       `protobuf:"varint,3,req,name=len" json:"len,omitempty"`
	Metadata     []*KeyValue   `protobuf:"bytes,4,rep,name=metadata" json:"metadata,omitempty"`
	ChecksumData *ChecksumData `protobuf:"bytes,5,req,name=checksumData" json:"checksumData,omitempty"`
	// contains filtered or unexported fields
}

func (*ChunkInfo) Descriptor deprecated 

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

Deprecated: Use ChunkInfo.ProtoReflect.Descriptor instead.

func (*ChunkInfo) GetChecksumData 

func (x *ChunkInfo) GetChecksumData() *ChecksumData

func (*ChunkInfo) GetChunkName 

func (x *ChunkInfo) GetChunkName() string

func (*ChunkInfo) GetLen 

func (x *ChunkInfo) GetLen() uint64

func (*ChunkInfo) GetMetadata 

func (x *ChunkInfo) GetMetadata() []*KeyValue

func (*ChunkInfo) GetOffset 

func (x *ChunkInfo) GetOffset() uint64

func (*ChunkInfo) ProtoMessage 

func (*ChunkInfo) ProtoMessage()

func (*ChunkInfo) ProtoReflect 

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

func (*ChunkInfo) Reset 

func (x *ChunkInfo) Reset()

func (*ChunkInfo) String 

func (x *ChunkInfo) String() string

type CloseContainerRequestProto 

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

func (*CloseContainerRequestProto) Descriptor deprecated 

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

Deprecated: Use CloseContainerRequestProto.ProtoReflect.Descriptor instead.

func (*CloseContainerRequestProto) ProtoMessage 

func (*CloseContainerRequestProto) ProtoMessage()

func (*CloseContainerRequestProto) ProtoReflect 

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

func (*CloseContainerRequestProto) Reset 

func (x *CloseContainerRequestProto) Reset()

func (*CloseContainerRequestProto) String 

func (x *CloseContainerRequestProto) String() string

type CloseContainerResponseProto 

type CloseContainerResponseProto struct {
	Hash        *string `protobuf:"bytes,1,opt,name=hash" json:"hash,omitempty"`
	ContainerID *int64  `protobuf:"varint,2,opt,name=containerID" json:"containerID,omitempty"`
	// contains filtered or unexported fields
}

func (*CloseContainerResponseProto) Descriptor deprecated 

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

Deprecated: Use CloseContainerResponseProto.ProtoReflect.Descriptor instead.

func (*CloseContainerResponseProto) GetContainerID 

func (x *CloseContainerResponseProto) GetContainerID() int64

func (*CloseContainerResponseProto) GetHash 

func (x *CloseContainerResponseProto) GetHash() string

func (*CloseContainerResponseProto) ProtoMessage 

func (*CloseContainerResponseProto) ProtoMessage()

func (*CloseContainerResponseProto) ProtoReflect 

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

func (*CloseContainerResponseProto) Reset 

func (x *CloseContainerResponseProto) Reset()

func (*CloseContainerResponseProto) String 

func (x *CloseContainerResponseProto) String() string

type Container2BCSIDMapProto 

type Container2BCSIDMapProto struct {

	// repeated Container2BCSIDMapEntryProto container2BCSID = 1;
	Container2BCSID map[int64]int64 `` /* 152-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Container2BCSIDMapProto) Descriptor deprecated 

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

Deprecated: Use Container2BCSIDMapProto.ProtoReflect.Descriptor instead.

func (*Container2BCSIDMapProto) GetContainer2BCSID 

func (x *Container2BCSIDMapProto) GetContainer2BCSID() map[int64]int64

func (*Container2BCSIDMapProto) ProtoMessage 

func (*Container2BCSIDMapProto) ProtoMessage()

func (*Container2BCSIDMapProto) ProtoReflect 

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

func (*Container2BCSIDMapProto) Reset 

func (x *Container2BCSIDMapProto) Reset()

func (*Container2BCSIDMapProto) String 

func (x *Container2BCSIDMapProto) String() string

type ContainerCommandRequestProto 

type ContainerCommandRequestProto struct {
	CmdType *Type `protobuf:"varint,1,req,name=cmdType,enum=hadoop.hdds.datanode.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"`
	ContainerID  *int64  `protobuf:"varint,3,req,name=containerID" json:"containerID,omitempty"`
	DatanodeUuid *string `protobuf:"bytes,4,req,name=datanodeUuid" json:"datanodeUuid,omitempty"`
	PipelineID   *string `protobuf:"bytes,5,opt,name=pipelineID" json:"pipelineID,omitempty"`
	// One of the following command is available when the corresponding
	// cmdType is set. At the protocol level we allow only
	// one command in each packet.
	// TODO : Upgrade to Protobuf 2.6 or later.
	CreateContainer         *CreateContainerRequestProto         `protobuf:"bytes,6,opt,name=createContainer" json:"createContainer,omitempty"`
	ReadContainer           *ReadContainerRequestProto           `protobuf:"bytes,7,opt,name=readContainer" json:"readContainer,omitempty"`
	UpdateContainer         *UpdateContainerRequestProto         `protobuf:"bytes,8,opt,name=updateContainer" json:"updateContainer,omitempty"`
	DeleteContainer         *DeleteContainerRequestProto         `protobuf:"bytes,9,opt,name=deleteContainer" json:"deleteContainer,omitempty"`
	ListContainer           *ListContainerRequestProto           `protobuf:"bytes,10,opt,name=listContainer" json:"listContainer,omitempty"`
	CloseContainer          *CloseContainerRequestProto          `protobuf:"bytes,11,opt,name=closeContainer" json:"closeContainer,omitempty"`
	PutBlock                *PutBlockRequestProto                `protobuf:"bytes,12,opt,name=putBlock" json:"putBlock,omitempty"`
	GetBlock                *GetBlockRequestProto                `protobuf:"bytes,13,opt,name=getBlock" json:"getBlock,omitempty"`
	DeleteBlock             *DeleteBlockRequestProto             `protobuf:"bytes,14,opt,name=deleteBlock" json:"deleteBlock,omitempty"`
	ListBlock               *ListBlockRequestProto               `protobuf:"bytes,15,opt,name=listBlock" json:"listBlock,omitempty"`
	ReadChunk               *ReadChunkRequestProto               `protobuf:"bytes,16,opt,name=readChunk" json:"readChunk,omitempty"`
	WriteChunk              *WriteChunkRequestProto              `protobuf:"bytes,17,opt,name=writeChunk" json:"writeChunk,omitempty"`
	DeleteChunk             *DeleteChunkRequestProto             `protobuf:"bytes,18,opt,name=deleteChunk" json:"deleteChunk,omitempty"`
	ListChunk               *ListChunkRequestProto               `protobuf:"bytes,19,opt,name=listChunk" json:"listChunk,omitempty"`
	PutSmallFile            *PutSmallFileRequestProto            `protobuf:"bytes,20,opt,name=putSmallFile" json:"putSmallFile,omitempty"`
	GetSmallFile            *GetSmallFileRequestProto            `protobuf:"bytes,21,opt,name=getSmallFile" json:"getSmallFile,omitempty"`
	GetCommittedBlockLength *GetCommittedBlockLengthRequestProto `protobuf:"bytes,22,opt,name=getCommittedBlockLength" json:"getCommittedBlockLength,omitempty"`
	EncodedToken            *string                              `protobuf:"bytes,23,opt,name=encodedToken" json:"encodedToken,omitempty"`
	// contains filtered or unexported fields
}

func (*ContainerCommandRequestProto) Descriptor deprecated 

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

Deprecated: Use ContainerCommandRequestProto.ProtoReflect.Descriptor instead.

func (*ContainerCommandRequestProto) GetCloseContainer 

func (x *ContainerCommandRequestProto) GetCloseContainer() *CloseContainerRequestProto

func (*ContainerCommandRequestProto) GetCmdType 

func (x *ContainerCommandRequestProto) GetCmdType() Type

func (*ContainerCommandRequestProto) GetContainerID 

func (x *ContainerCommandRequestProto) GetContainerID() int64

func (*ContainerCommandRequestProto) GetCreateContainer 

func (x *ContainerCommandRequestProto) GetCreateContainer() *CreateContainerRequestProto

func (*ContainerCommandRequestProto) GetDatanodeUuid 

func (x *ContainerCommandRequestProto) GetDatanodeUuid() string

func (*ContainerCommandRequestProto) GetDeleteBlock 

func (x *ContainerCommandRequestProto) GetDeleteBlock() *DeleteBlockRequestProto

func (*ContainerCommandRequestProto) GetDeleteChunk 

func (x *ContainerCommandRequestProto) GetDeleteChunk() *DeleteChunkRequestProto

func (*ContainerCommandRequestProto) GetDeleteContainer 

func (x *ContainerCommandRequestProto) GetDeleteContainer() *DeleteContainerRequestProto

func (*ContainerCommandRequestProto) GetEncodedToken 

func (x *ContainerCommandRequestProto) GetEncodedToken() string

func (*ContainerCommandRequestProto) GetGetBlock 

func (x *ContainerCommandRequestProto) GetGetBlock() *GetBlockRequestProto

func (*ContainerCommandRequestProto) GetGetCommittedBlockLength 

func (x *ContainerCommandRequestProto) GetGetCommittedBlockLength() *GetCommittedBlockLengthRequestProto

func (*ContainerCommandRequestProto) GetGetSmallFile 

func (x *ContainerCommandRequestProto) GetGetSmallFile() *GetSmallFileRequestProto

func (*ContainerCommandRequestProto) GetListBlock 

func (x *ContainerCommandRequestProto) GetListBlock() *ListBlockRequestProto

func (*ContainerCommandRequestProto) GetListChunk 

func (x *ContainerCommandRequestProto) GetListChunk() *ListChunkRequestProto

func (*ContainerCommandRequestProto) GetListContainer 

func (x *ContainerCommandRequestProto) GetListContainer() *ListContainerRequestProto

func (*ContainerCommandRequestProto) GetPipelineID 

func (x *ContainerCommandRequestProto) GetPipelineID() string

func (*ContainerCommandRequestProto) GetPutBlock 

func (x *ContainerCommandRequestProto) GetPutBlock() *PutBlockRequestProto

func (*ContainerCommandRequestProto) GetPutSmallFile 

func (x *ContainerCommandRequestProto) GetPutSmallFile() *PutSmallFileRequestProto

func (*ContainerCommandRequestProto) GetReadChunk 

func (x *ContainerCommandRequestProto) GetReadChunk() *ReadChunkRequestProto

func (*ContainerCommandRequestProto) GetReadContainer 

func (x *ContainerCommandRequestProto) GetReadContainer() *ReadContainerRequestProto

func (*ContainerCommandRequestProto) GetTraceID 

func (x *ContainerCommandRequestProto) GetTraceID() string

func (*ContainerCommandRequestProto) GetUpdateContainer 

func (x *ContainerCommandRequestProto) GetUpdateContainer() *UpdateContainerRequestProto

func (*ContainerCommandRequestProto) GetWriteChunk 

func (x *ContainerCommandRequestProto) GetWriteChunk() *WriteChunkRequestProto

func (*ContainerCommandRequestProto) ProtoMessage 

func (*ContainerCommandRequestProto) ProtoMessage()

func (*ContainerCommandRequestProto) ProtoReflect 

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

func (*ContainerCommandRequestProto) Reset 

func (x *ContainerCommandRequestProto) Reset()

func (*ContainerCommandRequestProto) String 

func (x *ContainerCommandRequestProto) String() string

type ContainerCommandResponseProto 

type ContainerCommandResponseProto struct {
	CmdType                 *Type                                 `protobuf:"varint,1,req,name=cmdType,enum=hadoop.hdds.datanode.Type" json:"cmdType,omitempty"`
	TraceID                 *string                               `protobuf:"bytes,2,opt,name=traceID" json:"traceID,omitempty"`
	Result                  *Result                               `protobuf:"varint,3,req,name=result,enum=hadoop.hdds.datanode.Result" json:"result,omitempty"`
	Message                 *string                               `protobuf:"bytes,4,opt,name=message" json:"message,omitempty"`
	CreateContainer         *CreateContainerResponseProto         `protobuf:"bytes,5,opt,name=createContainer" json:"createContainer,omitempty"`
	ReadContainer           *ReadContainerResponseProto           `protobuf:"bytes,6,opt,name=readContainer" json:"readContainer,omitempty"`
	UpdateContainer         *UpdateContainerResponseProto         `protobuf:"bytes,7,opt,name=updateContainer" json:"updateContainer,omitempty"`
	DeleteContainer         *DeleteContainerResponseProto         `protobuf:"bytes,8,opt,name=deleteContainer" json:"deleteContainer,omitempty"`
	ListContainer           *ListContainerResponseProto           `protobuf:"bytes,9,opt,name=listContainer" json:"listContainer,omitempty"`
	CloseContainer          *CloseContainerResponseProto          `protobuf:"bytes,10,opt,name=closeContainer" json:"closeContainer,omitempty"`
	PutBlock                *PutBlockResponseProto                `protobuf:"bytes,11,opt,name=putBlock" json:"putBlock,omitempty"`
	GetBlock                *GetBlockResponseProto                `protobuf:"bytes,12,opt,name=getBlock" json:"getBlock,omitempty"`
	DeleteBlock             *DeleteBlockResponseProto             `protobuf:"bytes,13,opt,name=deleteBlock" json:"deleteBlock,omitempty"`
	ListBlock               *ListBlockResponseProto               `protobuf:"bytes,14,opt,name=listBlock" json:"listBlock,omitempty"`
	WriteChunk              *WriteChunkResponseProto              `protobuf:"bytes,15,opt,name=writeChunk" json:"writeChunk,omitempty"`
	ReadChunk               *ReadChunkResponseProto               `protobuf:"bytes,16,opt,name=readChunk" json:"readChunk,omitempty"`
	DeleteChunk             *DeleteChunkResponseProto             `protobuf:"bytes,17,opt,name=deleteChunk" json:"deleteChunk,omitempty"`
	ListChunk               *ListChunkResponseProto               `protobuf:"bytes,18,opt,name=listChunk" json:"listChunk,omitempty"`
	PutSmallFile            *PutSmallFileResponseProto            `protobuf:"bytes,19,opt,name=putSmallFile" json:"putSmallFile,omitempty"`
	GetSmallFile            *GetSmallFileResponseProto            `protobuf:"bytes,20,opt,name=getSmallFile" json:"getSmallFile,omitempty"`
	GetCommittedBlockLength *GetCommittedBlockLengthResponseProto `protobuf:"bytes,21,opt,name=getCommittedBlockLength" json:"getCommittedBlockLength,omitempty"`
	// contains filtered or unexported fields
}

func (*ContainerCommandResponseProto) Descriptor deprecated 

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

Deprecated: Use ContainerCommandResponseProto.ProtoReflect.Descriptor instead.

func (*ContainerCommandResponseProto) GetCloseContainer 

func (x *ContainerCommandResponseProto) GetCloseContainer() *CloseContainerResponseProto

func (*ContainerCommandResponseProto) GetCmdType 

func (x *ContainerCommandResponseProto) GetCmdType() Type

func (*ContainerCommandResponseProto) GetCreateContainer 

func (x *ContainerCommandResponseProto) GetCreateContainer() *CreateContainerResponseProto

func (*ContainerCommandResponseProto) GetDeleteBlock 

func (x *ContainerCommandResponseProto) GetDeleteBlock() *DeleteBlockResponseProto

func (*ContainerCommandResponseProto) GetDeleteChunk 

func (x *ContainerCommandResponseProto) GetDeleteChunk() *DeleteChunkResponseProto

func (*ContainerCommandResponseProto) GetDeleteContainer 

func (x *ContainerCommandResponseProto) GetDeleteContainer() *DeleteContainerResponseProto

func (*ContainerCommandResponseProto) GetGetBlock 

func (x *ContainerCommandResponseProto) GetGetBlock() *GetBlockResponseProto

func (*ContainerCommandResponseProto) GetGetCommittedBlockLength 

func (x *ContainerCommandResponseProto) GetGetCommittedBlockLength() *GetCommittedBlockLengthResponseProto

func (*ContainerCommandResponseProto) GetGetSmallFile 

func (x *ContainerCommandResponseProto) GetGetSmallFile() *GetSmallFileResponseProto

func (*ContainerCommandResponseProto) GetListBlock 

func (x *ContainerCommandResponseProto) GetListBlock() *ListBlockResponseProto

func (*ContainerCommandResponseProto) GetListChunk 

func (x *ContainerCommandResponseProto) GetListChunk() *ListChunkResponseProto

func (*ContainerCommandResponseProto) GetListContainer 

func (x *ContainerCommandResponseProto) GetListContainer() *ListContainerResponseProto

func (*ContainerCommandResponseProto) GetMessage 

func (x *ContainerCommandResponseProto) GetMessage() string

func (*ContainerCommandResponseProto) GetPutBlock 

func (x *ContainerCommandResponseProto) GetPutBlock() *PutBlockResponseProto

func (*ContainerCommandResponseProto) GetPutSmallFile 

func (x *ContainerCommandResponseProto) GetPutSmallFile() *PutSmallFileResponseProto

func (*ContainerCommandResponseProto) GetReadChunk 

func (x *ContainerCommandResponseProto) GetReadChunk() *ReadChunkResponseProto

func (*ContainerCommandResponseProto) GetReadContainer 

func (x *ContainerCommandResponseProto) GetReadContainer() *ReadContainerResponseProto

func (*ContainerCommandResponseProto) GetResult 

func (x *ContainerCommandResponseProto) GetResult() Result

func (*ContainerCommandResponseProto) GetTraceID 

func (x *ContainerCommandResponseProto) GetTraceID() string

func (*ContainerCommandResponseProto) GetUpdateContainer 

func (x *ContainerCommandResponseProto) GetUpdateContainer() *UpdateContainerResponseProto

func (*ContainerCommandResponseProto) GetWriteChunk 

func (x *ContainerCommandResponseProto) GetWriteChunk() *WriteChunkResponseProto

func (*ContainerCommandResponseProto) ProtoMessage 

func (*ContainerCommandResponseProto) ProtoMessage()

func (*ContainerCommandResponseProto) ProtoReflect 

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

func (*ContainerCommandResponseProto) Reset 

func (x *ContainerCommandResponseProto) Reset()

func (*ContainerCommandResponseProto) String 

func (x *ContainerCommandResponseProto) String() string

type ContainerDataProto 

type ContainerDataProto struct {
	ContainerID   *int64                    `protobuf:"varint,1,req,name=containerID" json:"containerID,omitempty"`
	Metadata      []*KeyValue               `protobuf:"bytes,2,rep,name=metadata" json:"metadata,omitempty"`
	ContainerPath *string                   `protobuf:"bytes,4,opt,name=containerPath" json:"containerPath,omitempty"`
	BytesUsed     *int64                    `protobuf:"varint,6,opt,name=bytesUsed" json:"bytesUsed,omitempty"`
	Size          *int64                    `protobuf:"varint,7,opt,name=size" json:"size,omitempty"`
	BlockCount    *int64                    `protobuf:"varint,8,opt,name=blockCount" json:"blockCount,omitempty"`
	State         *ContainerDataProto_State `protobuf:"varint,9,opt,name=state,enum=hadoop.hdds.datanode.ContainerDataProto_State,def=1" json:"state,omitempty"`
	ContainerType *ContainerType            `protobuf:"varint,10,opt,name=containerType,enum=hadoop.hdds.datanode.ContainerType,def=1" json:"containerType,omitempty"`
	// contains filtered or unexported fields
}

func (*ContainerDataProto) Descriptor deprecated 

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

Deprecated: Use ContainerDataProto.ProtoReflect.Descriptor instead.

func (*ContainerDataProto) GetBlockCount 

func (x *ContainerDataProto) GetBlockCount() int64

func (*ContainerDataProto) GetBytesUsed 

func (x *ContainerDataProto) GetBytesUsed() int64

func (*ContainerDataProto) GetContainerID 

func (x *ContainerDataProto) GetContainerID() int64

func (*ContainerDataProto) GetContainerPath 

func (x *ContainerDataProto) GetContainerPath() string

func (*ContainerDataProto) GetContainerType 

func (x *ContainerDataProto) GetContainerType() ContainerType

func (*ContainerDataProto) GetMetadata 

func (x *ContainerDataProto) GetMetadata() []*KeyValue

func (*ContainerDataProto) GetSize 

func (x *ContainerDataProto) GetSize() int64

func (*ContainerDataProto) GetState 

func (x *ContainerDataProto) GetState() ContainerDataProto_State

func (*ContainerDataProto) ProtoMessage 

func (*ContainerDataProto) ProtoMessage()

func (*ContainerDataProto) ProtoReflect 

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

func (*ContainerDataProto) Reset 

func (x *ContainerDataProto) Reset()

func (*ContainerDataProto) String 

func (x *ContainerDataProto) String() string

type ContainerDataProto_State 

type ContainerDataProto_State int32
const (
	ContainerDataProto_OPEN         ContainerDataProto_State = 1
	ContainerDataProto_CLOSING      ContainerDataProto_State = 2
	ContainerDataProto_QUASI_CLOSED ContainerDataProto_State = 3
	ContainerDataProto_CLOSED       ContainerDataProto_State = 4
	ContainerDataProto_UNHEALTHY    ContainerDataProto_State = 5
	ContainerDataProto_INVALID      ContainerDataProto_State = 6
	ContainerDataProto_DELETED      ContainerDataProto_State = 7
)

func (ContainerDataProto_State) Descriptor 

func (ContainerDataProto_State) Descriptor() protoreflect.EnumDescriptor

func (ContainerDataProto_State) Enum 

func (x ContainerDataProto_State) Enum() *ContainerDataProto_State

func (ContainerDataProto_State) EnumDescriptor deprecated 

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

Deprecated: Use ContainerDataProto_State.Descriptor instead.

func (ContainerDataProto_State) Number 

func (x ContainerDataProto_State) Number() protoreflect.EnumNumber

func (ContainerDataProto_State) String 

func (x ContainerDataProto_State) String() string

func (ContainerDataProto_State) Type 

func (ContainerDataProto_State) Type() protoreflect.EnumType

func (*ContainerDataProto_State) UnmarshalJSON deprecated 

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

Deprecated: Do not use.

type ContainerType 

type ContainerType int32
const (
	ContainerType_KeyValueContainer ContainerType = 1
)

func (ContainerType) Descriptor 

func (ContainerType) Descriptor() protoreflect.EnumDescriptor

func (ContainerType) Enum 

func (x ContainerType) Enum() *ContainerType

func (ContainerType) EnumDescriptor deprecated 

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

Deprecated: Use ContainerType.Descriptor instead.

func (ContainerType) Number 

func (x ContainerType) Number() protoreflect.EnumNumber

func (ContainerType) String 

func (x ContainerType) String() string

func (ContainerType) Type 

func (ContainerType) Type() protoreflect.EnumType

func (*ContainerType) UnmarshalJSON deprecated 

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

Deprecated: Do not use.

type CopyContainerRequestProto 

type CopyContainerRequestProto struct {
	ContainerID *int64  `protobuf:"varint,1,req,name=containerID" json:"containerID,omitempty"`
	ReadOffset  *uint64 `protobuf:"varint,2,req,name=readOffset" json:"readOffset,omitempty"`
	Len         *uint64 `protobuf:"varint,3,opt,name=len" json:"len,omitempty"`
	// contains filtered or unexported fields
}

func (*CopyContainerRequestProto) Descriptor deprecated 

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

Deprecated: Use CopyContainerRequestProto.ProtoReflect.Descriptor instead.

func (*CopyContainerRequestProto) GetContainerID 

func (x *CopyContainerRequestProto) GetContainerID() int64

func (*CopyContainerRequestProto) GetLen 

func (x *CopyContainerRequestProto) GetLen() uint64

func (*CopyContainerRequestProto) GetReadOffset 

func (x *CopyContainerRequestProto) GetReadOffset() uint64

func (*CopyContainerRequestProto) ProtoMessage 

func (*CopyContainerRequestProto) ProtoMessage()

func (*CopyContainerRequestProto) ProtoReflect 

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

func (*CopyContainerRequestProto) Reset 

func (x *CopyContainerRequestProto) Reset()

func (*CopyContainerRequestProto) String 

func (x *CopyContainerRequestProto) String() string

type CopyContainerResponseProto 

type CopyContainerResponseProto struct {
	ContainerID *int64  `protobuf:"varint,1,req,name=containerID" json:"containerID,omitempty"`
	ReadOffset  *uint64 `protobuf:"varint,2,req,name=readOffset" json:"readOffset,omitempty"`
	Len         *uint64 `protobuf:"varint,3,req,name=len" json:"len,omitempty"`
	Eof         *bool   `protobuf:"varint,4,req,name=eof" json:"eof,omitempty"`
	Data        []byte  `protobuf:"bytes,5,req,name=data" json:"data,omitempty"`
	Checksum    *int64  `protobuf:"varint,6,opt,name=checksum" json:"checksum,omitempty"`
	// contains filtered or unexported fields
}

func (*CopyContainerResponseProto) Descriptor deprecated 

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

Deprecated: Use CopyContainerResponseProto.ProtoReflect.Descriptor instead.

func (*CopyContainerResponseProto) GetChecksum 

func (x *CopyContainerResponseProto) GetChecksum() int64

func (*CopyContainerResponseProto) GetContainerID 

func (x *CopyContainerResponseProto) GetContainerID() int64

func (*CopyContainerResponseProto) GetData 

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

func (*CopyContainerResponseProto) GetEof 

func (x *CopyContainerResponseProto) GetEof() bool

func (*CopyContainerResponseProto) GetLen 

func (x *CopyContainerResponseProto) GetLen() uint64

func (*CopyContainerResponseProto) GetReadOffset 

func (x *CopyContainerResponseProto) GetReadOffset() uint64

func (*CopyContainerResponseProto) ProtoMessage 

func (*CopyContainerResponseProto) ProtoMessage()

func (*CopyContainerResponseProto) ProtoReflect 

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

func (*CopyContainerResponseProto) Reset 

func (x *CopyContainerResponseProto) Reset()

func (*CopyContainerResponseProto) String 

func (x *CopyContainerResponseProto) String() string

type CreateContainerRequestProto 

type CreateContainerRequestProto struct {
	Metadata      []*KeyValue    `protobuf:"bytes,2,rep,name=metadata" json:"metadata,omitempty"`
	ContainerType *ContainerType `protobuf:"varint,3,opt,name=containerType,enum=hadoop.hdds.datanode.ContainerType,def=1" json:"containerType,omitempty"`
	// contains filtered or unexported fields
}

Container Messages.

func (*CreateContainerRequestProto) Descriptor deprecated 

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

Deprecated: Use CreateContainerRequestProto.ProtoReflect.Descriptor instead.

func (*CreateContainerRequestProto) GetContainerType 

func (x *CreateContainerRequestProto) GetContainerType() ContainerType

func (*CreateContainerRequestProto) GetMetadata 

func (x *CreateContainerRequestProto) GetMetadata() []*KeyValue

func (*CreateContainerRequestProto) ProtoMessage 

func (*CreateContainerRequestProto) ProtoMessage()

func (*CreateContainerRequestProto) ProtoReflect 

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

func (*CreateContainerRequestProto) Reset 

func (x *CreateContainerRequestProto) Reset()

func (*CreateContainerRequestProto) String 

func (x *CreateContainerRequestProto) String() string

type CreateContainerResponseProto 

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

func (*CreateContainerResponseProto) Descriptor deprecated 

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

Deprecated: Use CreateContainerResponseProto.ProtoReflect.Descriptor instead.

func (*CreateContainerResponseProto) ProtoMessage 

func (*CreateContainerResponseProto) ProtoMessage()

func (*CreateContainerResponseProto) ProtoReflect 

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

func (*CreateContainerResponseProto) Reset 

func (x *CreateContainerResponseProto) Reset()

func (*CreateContainerResponseProto) String 

func (x *CreateContainerResponseProto) String() string

type DatanodeBlockID 

type DatanodeBlockID struct {
	ContainerID           *int64  `protobuf:"varint,1,req,name=containerID" json:"containerID,omitempty"`
	LocalID               *int64  `protobuf:"varint,2,req,name=localID" json:"localID,omitempty"`
	BlockCommitSequenceId *uint64 `protobuf:"varint,3,opt,name=blockCommitSequenceId,def=0" json:"blockCommitSequenceId,omitempty"`
	// contains filtered or unexported fields
}

* Block ID that uniquely identify a block in Datanode.

func (*DatanodeBlockID) Descriptor deprecated 

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

Deprecated: Use DatanodeBlockID.ProtoReflect.Descriptor instead.

func (*DatanodeBlockID) GetBlockCommitSequenceId 

func (x *DatanodeBlockID) GetBlockCommitSequenceId() uint64

func (*DatanodeBlockID) GetContainerID 

func (x *DatanodeBlockID) GetContainerID() int64

func (*DatanodeBlockID) GetLocalID 

func (x *DatanodeBlockID) GetLocalID() int64

func (*DatanodeBlockID) ProtoMessage 

func (*DatanodeBlockID) ProtoMessage()

func (*DatanodeBlockID) ProtoReflect 

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

func (*DatanodeBlockID) Reset 

func (x *DatanodeBlockID) Reset()

func (*DatanodeBlockID) String 

func (x *DatanodeBlockID) String() string

type DeleteBlockRequestProto 

type DeleteBlockRequestProto struct {
	BlockID *DatanodeBlockID `protobuf:"bytes,1,req,name=blockID" json:"blockID,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteBlockRequestProto) Descriptor deprecated 

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

Deprecated: Use DeleteBlockRequestProto.ProtoReflect.Descriptor instead.

func (*DeleteBlockRequestProto) GetBlockID 

func (x *DeleteBlockRequestProto) GetBlockID() *DatanodeBlockID

func (*DeleteBlockRequestProto) ProtoMessage 

func (*DeleteBlockRequestProto) ProtoMessage()

func (*DeleteBlockRequestProto) ProtoReflect 

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

func (*DeleteBlockRequestProto) Reset 

func (x *DeleteBlockRequestProto) Reset()

func (*DeleteBlockRequestProto) String 

func (x *DeleteBlockRequestProto) String() string

type DeleteBlockResponseProto 

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

func (*DeleteBlockResponseProto) Descriptor deprecated 

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

Deprecated: Use DeleteBlockResponseProto.ProtoReflect.Descriptor instead.

func (*DeleteBlockResponseProto) ProtoMessage 

func (*DeleteBlockResponseProto) ProtoMessage()

func (*DeleteBlockResponseProto) ProtoReflect 

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

func (*DeleteBlockResponseProto) Reset 

func (x *DeleteBlockResponseProto) Reset()

func (*DeleteBlockResponseProto) String 

func (x *DeleteBlockResponseProto) String() string

type DeleteChunkRequestProto 

type DeleteChunkRequestProto struct {
	BlockID   *DatanodeBlockID `protobuf:"bytes,1,req,name=blockID" json:"blockID,omitempty"`
	ChunkData *ChunkInfo       `protobuf:"bytes,2,req,name=chunkData" json:"chunkData,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteChunkRequestProto) Descriptor deprecated 

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

Deprecated: Use DeleteChunkRequestProto.ProtoReflect.Descriptor instead.

func (*DeleteChunkRequestProto) GetBlockID 

func (x *DeleteChunkRequestProto) GetBlockID() *DatanodeBlockID

func (*DeleteChunkRequestProto) GetChunkData 

func (x *DeleteChunkRequestProto) GetChunkData() *ChunkInfo

func (*DeleteChunkRequestProto) ProtoMessage 

func (*DeleteChunkRequestProto) ProtoMessage()

func (*DeleteChunkRequestProto) ProtoReflect 

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

func (*DeleteChunkRequestProto) Reset 

func (x *DeleteChunkRequestProto) Reset()

func (*DeleteChunkRequestProto) String 

func (x *DeleteChunkRequestProto) String() string

type DeleteChunkResponseProto 

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

func (*DeleteChunkResponseProto) Descriptor deprecated 

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

Deprecated: Use DeleteChunkResponseProto.ProtoReflect.Descriptor instead.

func (*DeleteChunkResponseProto) ProtoMessage 

func (*DeleteChunkResponseProto) ProtoMessage()

func (*DeleteChunkResponseProto) ProtoReflect 

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

func (*DeleteChunkResponseProto) Reset 

func (x *DeleteChunkResponseProto) Reset()

func (*DeleteChunkResponseProto) String 

func (x *DeleteChunkResponseProto) String() string

type DeleteContainerRequestProto 

type DeleteContainerRequestProto struct {
	ForceDelete *bool `protobuf:"varint,2,opt,name=forceDelete,def=0" json:"forceDelete,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteContainerRequestProto) Descriptor deprecated 

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

Deprecated: Use DeleteContainerRequestProto.ProtoReflect.Descriptor instead.

func (*DeleteContainerRequestProto) GetForceDelete 

func (x *DeleteContainerRequestProto) GetForceDelete() bool

func (*DeleteContainerRequestProto) ProtoMessage 

func (*DeleteContainerRequestProto) ProtoMessage()

func (*DeleteContainerRequestProto) ProtoReflect 

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

func (*DeleteContainerRequestProto) Reset 

func (x *DeleteContainerRequestProto) Reset()

func (*DeleteContainerRequestProto) String 

func (x *DeleteContainerRequestProto) String() string

type DeleteContainerResponseProto 

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

func (*DeleteContainerResponseProto) Descriptor deprecated 

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

Deprecated: Use DeleteContainerResponseProto.ProtoReflect.Descriptor instead.

func (*DeleteContainerResponseProto) ProtoMessage 

func (*DeleteContainerResponseProto) ProtoMessage()

func (*DeleteContainerResponseProto) ProtoReflect 

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

func (*DeleteContainerResponseProto) Reset 

func (x *DeleteContainerResponseProto) Reset()

func (*DeleteContainerResponseProto) String 

func (x *DeleteContainerResponseProto) String() string

type GetBlockRequestProto 

type GetBlockRequestProto struct {
	BlockID *DatanodeBlockID `protobuf:"bytes,1,req,name=blockID" json:"blockID,omitempty"`
	// contains filtered or unexported fields
}

func (*GetBlockRequestProto) Descriptor deprecated 

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

Deprecated: Use GetBlockRequestProto.ProtoReflect.Descriptor instead.

func (*GetBlockRequestProto) GetBlockID 

func (x *GetBlockRequestProto) GetBlockID() *DatanodeBlockID

func (*GetBlockRequestProto) ProtoMessage 

func (*GetBlockRequestProto) ProtoMessage()

func (*GetBlockRequestProto) ProtoReflect 

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

func (*GetBlockRequestProto) Reset 

func (x *GetBlockRequestProto) Reset()

func (*GetBlockRequestProto) String 

func (x *GetBlockRequestProto) String() string

type GetBlockResponseProto 

type GetBlockResponseProto struct {
	BlockData *BlockData `protobuf:"bytes,1,req,name=blockData" json:"blockData,omitempty"`
	// contains filtered or unexported fields
}

func (*GetBlockResponseProto) Descriptor deprecated 

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

Deprecated: Use GetBlockResponseProto.ProtoReflect.Descriptor instead.

func (*GetBlockResponseProto) GetBlockData 

func (x *GetBlockResponseProto) GetBlockData() *BlockData

func (*GetBlockResponseProto) ProtoMessage 

func (*GetBlockResponseProto) ProtoMessage()

func (*GetBlockResponseProto) ProtoReflect 

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

func (*GetBlockResponseProto) Reset 

func (x *GetBlockResponseProto) Reset()

func (*GetBlockResponseProto) String 

func (x *GetBlockResponseProto) String() string

type GetCommittedBlockLengthRequestProto 

type GetCommittedBlockLengthRequestProto struct {
	BlockID *DatanodeBlockID `protobuf:"bytes,1,req,name=blockID" json:"blockID,omitempty"`
	// contains filtered or unexported fields
}

func (*GetCommittedBlockLengthRequestProto) Descriptor deprecated 

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

Deprecated: Use GetCommittedBlockLengthRequestProto.ProtoReflect.Descriptor instead.

func (*GetCommittedBlockLengthRequestProto) GetBlockID 

func (x *GetCommittedBlockLengthRequestProto) GetBlockID() *DatanodeBlockID

func (*GetCommittedBlockLengthRequestProto) ProtoMessage 

func (*GetCommittedBlockLengthRequestProto) ProtoMessage()

func (*GetCommittedBlockLengthRequestProto) ProtoReflect 

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

func (*GetCommittedBlockLengthRequestProto) Reset 

func (x *GetCommittedBlockLengthRequestProto) Reset()

func (*GetCommittedBlockLengthRequestProto) String 

func (x *GetCommittedBlockLengthRequestProto) String() string

type GetCommittedBlockLengthResponseProto 

type GetCommittedBlockLengthResponseProto struct {
	BlockID     *DatanodeBlockID `protobuf:"bytes,1,req,name=blockID" json:"blockID,omitempty"`
	BlockLength *int64           `protobuf:"varint,2,req,name=blockLength" json:"blockLength,omitempty"`
	// contains filtered or unexported fields
}

func (*GetCommittedBlockLengthResponseProto) Descriptor deprecated 

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

Deprecated: Use GetCommittedBlockLengthResponseProto.ProtoReflect.Descriptor instead.

func (*GetCommittedBlockLengthResponseProto) GetBlockID 

func (x *GetCommittedBlockLengthResponseProto) GetBlockID() *DatanodeBlockID

func (*GetCommittedBlockLengthResponseProto) GetBlockLength 

func (x *GetCommittedBlockLengthResponseProto) GetBlockLength() int64

func (*GetCommittedBlockLengthResponseProto) ProtoMessage 

func (*GetCommittedBlockLengthResponseProto) ProtoMessage()

func (*GetCommittedBlockLengthResponseProto) ProtoReflect 

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

func (*GetCommittedBlockLengthResponseProto) Reset 

func (x *GetCommittedBlockLengthResponseProto) Reset()

func (*GetCommittedBlockLengthResponseProto) String 

func (x *GetCommittedBlockLengthResponseProto) String() string

type GetSmallFileRequestProto 

type GetSmallFileRequestProto struct {
	Block *GetBlockRequestProto `protobuf:"bytes,1,req,name=block" json:"block,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSmallFileRequestProto) Descriptor deprecated 

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

Deprecated: Use GetSmallFileRequestProto.ProtoReflect.Descriptor instead.

func (*GetSmallFileRequestProto) GetBlock 

func (x *GetSmallFileRequestProto) GetBlock() *GetBlockRequestProto

func (*GetSmallFileRequestProto) ProtoMessage 

func (*GetSmallFileRequestProto) ProtoMessage()

func (*GetSmallFileRequestProto) ProtoReflect 

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

func (*GetSmallFileRequestProto) Reset 

func (x *GetSmallFileRequestProto) Reset()

func (*GetSmallFileRequestProto) String 

func (x *GetSmallFileRequestProto) String() string

type GetSmallFileResponseProto 

type GetSmallFileResponseProto struct {
	Data *ReadChunkResponseProto `protobuf:"bytes,1,req,name=data" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSmallFileResponseProto) Descriptor deprecated 

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

Deprecated: Use GetSmallFileResponseProto.ProtoReflect.Descriptor instead.

func (*GetSmallFileResponseProto) GetData 

func (x *GetSmallFileResponseProto) GetData() *ReadChunkResponseProto

func (*GetSmallFileResponseProto) ProtoMessage 

func (*GetSmallFileResponseProto) ProtoMessage()

func (*GetSmallFileResponseProto) ProtoReflect 

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

func (*GetSmallFileResponseProto) Reset 

func (x *GetSmallFileResponseProto) Reset()

func (*GetSmallFileResponseProto) String 

func (x *GetSmallFileResponseProto) String() string

type IntraDatanodeProtocolServiceClient 

type IntraDatanodeProtocolServiceClient interface {
	// An intradatanode service to copy the raw container data between nodes
	Download(ctx context.Context, in *CopyContainerRequestProto, opts ...grpc.CallOption) (IntraDatanodeProtocolService_DownloadClient, error)
}

IntraDatanodeProtocolServiceClient is the client API for IntraDatanodeProtocolService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewIntraDatanodeProtocolServiceClient 

func NewIntraDatanodeProtocolServiceClient(cc grpc.ClientConnInterface) IntraDatanodeProtocolServiceClient

type IntraDatanodeProtocolServiceServer 

type IntraDatanodeProtocolServiceServer interface {
	// An intradatanode service to copy the raw container data between nodes
	Download(*CopyContainerRequestProto, IntraDatanodeProtocolService_DownloadServer) error
}

IntraDatanodeProtocolServiceServer is the server API for IntraDatanodeProtocolService service.

type IntraDatanodeProtocolService_DownloadClient 

type IntraDatanodeProtocolService_DownloadClient interface {
	Recv() (*CopyContainerResponseProto, error)
	grpc.ClientStream
}

type IntraDatanodeProtocolService_DownloadServer 

type IntraDatanodeProtocolService_DownloadServer interface {
	Send(*CopyContainerResponseProto) error
	grpc.ServerStream
}

type KeyValue 

type KeyValue struct {
	Key   *string `protobuf:"bytes,1,req,name=key" json:"key,omitempty"`
	Value *string `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*KeyValue) Descriptor deprecated 

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

Deprecated: Use KeyValue.ProtoReflect.Descriptor instead.

func (*KeyValue) GetKey 

func (x *KeyValue) GetKey() string

func (*KeyValue) GetValue 

func (x *KeyValue) GetValue() string

func (*KeyValue) ProtoMessage 

func (*KeyValue) ProtoMessage()

func (*KeyValue) ProtoReflect 

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

func (*KeyValue) Reset 

func (x *KeyValue) Reset()

func (*KeyValue) String 

func (x *KeyValue) String() string

type ListBlockRequestProto 

type ListBlockRequestProto struct {
	StartLocalID *int64  `protobuf:"varint,2,opt,name=startLocalID" json:"startLocalID,omitempty"`
	Count        *uint32 `protobuf:"varint,3,req,name=count" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*ListBlockRequestProto) Descriptor deprecated 

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

Deprecated: Use ListBlockRequestProto.ProtoReflect.Descriptor instead.

func (*ListBlockRequestProto) GetCount 

func (x *ListBlockRequestProto) GetCount() uint32

func (*ListBlockRequestProto) GetStartLocalID 

func (x *ListBlockRequestProto) GetStartLocalID() int64

func (*ListBlockRequestProto) ProtoMessage 

func (*ListBlockRequestProto) ProtoMessage()

func (*ListBlockRequestProto) ProtoReflect 

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

func (*ListBlockRequestProto) Reset 

func (x *ListBlockRequestProto) Reset()

func (*ListBlockRequestProto) String 

func (x *ListBlockRequestProto) String() string

type ListBlockResponseProto 

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

func (*ListBlockResponseProto) Descriptor deprecated 

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

Deprecated: Use ListBlockResponseProto.ProtoReflect.Descriptor instead.

func (*ListBlockResponseProto) GetBlockData 

func (x *ListBlockResponseProto) GetBlockData() []*BlockData

func (*ListBlockResponseProto) ProtoMessage 

func (*ListBlockResponseProto) ProtoMessage()

func (*ListBlockResponseProto) ProtoReflect 

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

func (*ListBlockResponseProto) Reset 

func (x *ListBlockResponseProto) Reset()

func (*ListBlockResponseProto) String 

func (x *ListBlockResponseProto) String() string

type ListChunkRequestProto 

type ListChunkRequestProto struct {
	BlockID       *DatanodeBlockID `protobuf:"bytes,1,req,name=blockID" json:"blockID,omitempty"`
	PrevChunkName *string          `protobuf:"bytes,2,req,name=prevChunkName" json:"prevChunkName,omitempty"`
	Count         *uint32          `protobuf:"varint,3,req,name=count" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*ListChunkRequestProto) Descriptor deprecated 

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

Deprecated: Use ListChunkRequestProto.ProtoReflect.Descriptor instead.

func (*ListChunkRequestProto) GetBlockID 

func (x *ListChunkRequestProto) GetBlockID() *DatanodeBlockID

func (*ListChunkRequestProto) GetCount 

func (x *ListChunkRequestProto) GetCount() uint32

func (*ListChunkRequestProto) GetPrevChunkName 

func (x *ListChunkRequestProto) GetPrevChunkName() string

func (*ListChunkRequestProto) ProtoMessage 

func (*ListChunkRequestProto) ProtoMessage()

func (*ListChunkRequestProto) ProtoReflect 

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

func (*ListChunkRequestProto) Reset 

func (x *ListChunkRequestProto) Reset()

func (*ListChunkRequestProto) String 

func (x *ListChunkRequestProto) String() string

type ListChunkResponseProto 

type ListChunkResponseProto struct {
	ChunkData []*ChunkInfo `protobuf:"bytes,1,rep,name=chunkData" json:"chunkData,omitempty"`
	// contains filtered or unexported fields
}

func (*ListChunkResponseProto) Descriptor deprecated 

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

Deprecated: Use ListChunkResponseProto.ProtoReflect.Descriptor instead.

func (*ListChunkResponseProto) GetChunkData 

func (x *ListChunkResponseProto) GetChunkData() []*ChunkInfo

func (*ListChunkResponseProto) ProtoMessage 

func (*ListChunkResponseProto) ProtoMessage()

func (*ListChunkResponseProto) ProtoReflect 

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

func (*ListChunkResponseProto) Reset 

func (x *ListChunkResponseProto) Reset()

func (*ListChunkResponseProto) String 

func (x *ListChunkResponseProto) String() string

type ListContainerRequestProto 

type ListContainerRequestProto struct {
	Count *uint32 `protobuf:"varint,2,opt,name=count" json:"count,omitempty"` // Max Results to return
	// contains filtered or unexported fields
}

func (*ListContainerRequestProto) Descriptor deprecated 

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

Deprecated: Use ListContainerRequestProto.ProtoReflect.Descriptor instead.

func (*ListContainerRequestProto) GetCount 

func (x *ListContainerRequestProto) GetCount() uint32

func (*ListContainerRequestProto) ProtoMessage 

func (*ListContainerRequestProto) ProtoMessage()

func (*ListContainerRequestProto) ProtoReflect 

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

func (*ListContainerRequestProto) Reset 

func (x *ListContainerRequestProto) Reset()

func (*ListContainerRequestProto) String 

func (x *ListContainerRequestProto) String() string

type ListContainerResponseProto 

type ListContainerResponseProto struct {
	ContainerData []*ContainerDataProto `protobuf:"bytes,1,rep,name=containerData" json:"containerData,omitempty"`
	// contains filtered or unexported fields
}

func (*ListContainerResponseProto) Descriptor deprecated 

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

Deprecated: Use ListContainerResponseProto.ProtoReflect.Descriptor instead.

func (*ListContainerResponseProto) GetContainerData 

func (x *ListContainerResponseProto) GetContainerData() []*ContainerDataProto

func (*ListContainerResponseProto) ProtoMessage 

func (*ListContainerResponseProto) ProtoMessage()

func (*ListContainerResponseProto) ProtoReflect 

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

func (*ListContainerResponseProto) Reset 

func (x *ListContainerResponseProto) Reset()

func (*ListContainerResponseProto) String 

func (x *ListContainerResponseProto) String() string

type PutBlockRequestProto 

type PutBlockRequestProto struct {
	BlockData *BlockData `protobuf:"bytes,1,req,name=blockData" json:"blockData,omitempty"`
	Eof       *bool      `protobuf:"varint,2,opt,name=eof" json:"eof,omitempty"`
	// contains filtered or unexported fields
}

Block Messages.

func (*PutBlockRequestProto) Descriptor deprecated 

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

Deprecated: Use PutBlockRequestProto.ProtoReflect.Descriptor instead.

func (*PutBlockRequestProto) GetBlockData 

func (x *PutBlockRequestProto) GetBlockData() *BlockData

func (*PutBlockRequestProto) GetEof 

func (x *PutBlockRequestProto) GetEof() bool

func (*PutBlockRequestProto) ProtoMessage 

func (*PutBlockRequestProto) ProtoMessage()

func (*PutBlockRequestProto) ProtoReflect 

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

func (*PutBlockRequestProto) Reset 

func (x *PutBlockRequestProto) Reset()

func (*PutBlockRequestProto) String 

func (x *PutBlockRequestProto) String() string

type PutBlockResponseProto 

type PutBlockResponseProto struct {
	CommittedBlockLength *GetCommittedBlockLengthResponseProto `protobuf:"bytes,1,req,name=committedBlockLength" json:"committedBlockLength,omitempty"`
	// contains filtered or unexported fields
}

func (*PutBlockResponseProto) Descriptor deprecated 

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

Deprecated: Use PutBlockResponseProto.ProtoReflect.Descriptor instead.

func (*PutBlockResponseProto) GetCommittedBlockLength 

func (x *PutBlockResponseProto) GetCommittedBlockLength() *GetCommittedBlockLengthResponseProto

func (*PutBlockResponseProto) ProtoMessage 

func (*PutBlockResponseProto) ProtoMessage()

func (*PutBlockResponseProto) ProtoReflect 

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

func (*PutBlockResponseProto) Reset 

func (x *PutBlockResponseProto) Reset()

func (*PutBlockResponseProto) String 

func (x *PutBlockResponseProto) String() string

type PutSmallFileRequestProto 

type PutSmallFileRequestProto struct {
	Block     *PutBlockRequestProto `protobuf:"bytes,1,req,name=block" json:"block,omitempty"`
	ChunkInfo *ChunkInfo            `protobuf:"bytes,2,req,name=chunkInfo" json:"chunkInfo,omitempty"`
	Data      []byte                `protobuf:"bytes,3,req,name=data" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*PutSmallFileRequestProto) Descriptor deprecated 

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

Deprecated: Use PutSmallFileRequestProto.ProtoReflect.Descriptor instead.

func (*PutSmallFileRequestProto) GetBlock 

func (x *PutSmallFileRequestProto) GetBlock() *PutBlockRequestProto

func (*PutSmallFileRequestProto) GetChunkInfo 

func (x *PutSmallFileRequestProto) GetChunkInfo() *ChunkInfo

func (*PutSmallFileRequestProto) GetData 

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

func (*PutSmallFileRequestProto) ProtoMessage 

func (*PutSmallFileRequestProto) ProtoMessage()

func (*PutSmallFileRequestProto) ProtoReflect 

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

func (*PutSmallFileRequestProto) Reset 

func (x *PutSmallFileRequestProto) Reset()

func (*PutSmallFileRequestProto) String 

func (x *PutSmallFileRequestProto) String() string

type PutSmallFileResponseProto 

type PutSmallFileResponseProto struct {
	CommittedBlockLength *GetCommittedBlockLengthResponseProto `protobuf:"bytes,1,req,name=committedBlockLength" json:"committedBlockLength,omitempty"`
	// contains filtered or unexported fields
}

func (*PutSmallFileResponseProto) Descriptor deprecated 

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

Deprecated: Use PutSmallFileResponseProto.ProtoReflect.Descriptor instead.

func (*PutSmallFileResponseProto) GetCommittedBlockLength 

func (x *PutSmallFileResponseProto) GetCommittedBlockLength() *GetCommittedBlockLengthResponseProto

func (*PutSmallFileResponseProto) ProtoMessage 

func (*PutSmallFileResponseProto) ProtoMessage()

func (*PutSmallFileResponseProto) ProtoReflect 

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

func (*PutSmallFileResponseProto) Reset 

func (x *PutSmallFileResponseProto) Reset()

func (*PutSmallFileResponseProto) String 

func (x *PutSmallFileResponseProto) String() string

type ReadChunkRequestProto 

type ReadChunkRequestProto struct {
	BlockID   *DatanodeBlockID `protobuf:"bytes,1,req,name=blockID" json:"blockID,omitempty"`
	ChunkData *ChunkInfo       `protobuf:"bytes,2,req,name=chunkData" json:"chunkData,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadChunkRequestProto) Descriptor deprecated 

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

Deprecated: Use ReadChunkRequestProto.ProtoReflect.Descriptor instead.

func (*ReadChunkRequestProto) GetBlockID 

func (x *ReadChunkRequestProto) GetBlockID() *DatanodeBlockID

func (*ReadChunkRequestProto) GetChunkData 

func (x *ReadChunkRequestProto) GetChunkData() *ChunkInfo

func (*ReadChunkRequestProto) ProtoMessage 

func (*ReadChunkRequestProto) ProtoMessage()

func (*ReadChunkRequestProto) ProtoReflect 

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

func (*ReadChunkRequestProto) Reset 

func (x *ReadChunkRequestProto) Reset()

func (*ReadChunkRequestProto) String 

func (x *ReadChunkRequestProto) String() string

type ReadChunkResponseProto 

type ReadChunkResponseProto struct {
	BlockID   *DatanodeBlockID `protobuf:"bytes,1,req,name=blockID" json:"blockID,omitempty"`
	ChunkData *ChunkInfo       `protobuf:"bytes,2,req,name=chunkData" json:"chunkData,omitempty"`
	Data      []byte           `protobuf:"bytes,3,req,name=data" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadChunkResponseProto) Descriptor deprecated 

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

Deprecated: Use ReadChunkResponseProto.ProtoReflect.Descriptor instead.

func (*ReadChunkResponseProto) GetBlockID 

func (x *ReadChunkResponseProto) GetBlockID() *DatanodeBlockID

func (*ReadChunkResponseProto) GetChunkData 

func (x *ReadChunkResponseProto) GetChunkData() *ChunkInfo

func (*ReadChunkResponseProto) GetData 

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

func (*ReadChunkResponseProto) ProtoMessage 

func (*ReadChunkResponseProto) ProtoMessage()

func (*ReadChunkResponseProto) ProtoReflect 

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

func (*ReadChunkResponseProto) Reset 

func (x *ReadChunkResponseProto) Reset()

func (*ReadChunkResponseProto) String 

func (x *ReadChunkResponseProto) String() string

type ReadContainerRequestProto 

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

func (*ReadContainerRequestProto) Descriptor deprecated 

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

Deprecated: Use ReadContainerRequestProto.ProtoReflect.Descriptor instead.

func (*ReadContainerRequestProto) ProtoMessage 

func (*ReadContainerRequestProto) ProtoMessage()

func (*ReadContainerRequestProto) ProtoReflect 

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

func (*ReadContainerRequestProto) Reset 

func (x *ReadContainerRequestProto) Reset()

func (*ReadContainerRequestProto) String 

func (x *ReadContainerRequestProto) String() string

type ReadContainerResponseProto 

type ReadContainerResponseProto struct {
	ContainerData *ContainerDataProto `protobuf:"bytes,1,opt,name=containerData" json:"containerData,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadContainerResponseProto) Descriptor deprecated 

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

Deprecated: Use ReadContainerResponseProto.ProtoReflect.Descriptor instead.

func (*ReadContainerResponseProto) GetContainerData 

func (x *ReadContainerResponseProto) GetContainerData() *ContainerDataProto

func (*ReadContainerResponseProto) ProtoMessage 

func (*ReadContainerResponseProto) ProtoMessage()

func (*ReadContainerResponseProto) ProtoReflect 

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

func (*ReadContainerResponseProto) Reset 

func (x *ReadContainerResponseProto) Reset()

func (*ReadContainerResponseProto) String 

func (x *ReadContainerResponseProto) String() string

type Result 

type Result int32
const (
	Result_SUCCESS                         Result = 1
	Result_UNSUPPORTED_REQUEST             Result = 2
	Result_MALFORMED_REQUEST               Result = 3
	Result_CONTAINER_INTERNAL_ERROR        Result = 4
	Result_INVALID_CONFIG                  Result = 5
	Result_INVALID_FILE_HASH_FOUND         Result = 6
	Result_CONTAINER_EXISTS                Result = 7
	Result_NO_SUCH_ALGORITHM               Result = 8
	Result_CONTAINER_NOT_FOUND             Result = 9
	Result_IO_EXCEPTION                    Result = 10
	Result_UNABLE_TO_READ_METADATA_DB      Result = 11
	Result_NO_SUCH_BLOCK                   Result = 12
	Result_OVERWRITE_FLAG_REQUIRED         Result = 13
	Result_UNABLE_TO_FIND_DATA_DIR         Result = 14
	Result_INVALID_WRITE_SIZE              Result = 15
	Result_CHECKSUM_MISMATCH               Result = 16
	Result_UNABLE_TO_FIND_CHUNK            Result = 17
	Result_PROTOC_DECODING_ERROR           Result = 18
	Result_INVALID_ARGUMENT                Result = 19
	Result_PUT_SMALL_FILE_ERROR            Result = 20
	Result_GET_SMALL_FILE_ERROR            Result = 21
	Result_CLOSED_CONTAINER_IO             Result = 22
	Result_ERROR_IN_COMPACT_DB             Result = 24
	Result_UNCLOSED_CONTAINER_IO           Result = 25
	Result_DELETE_ON_OPEN_CONTAINER        Result = 26
	Result_CLOSED_CONTAINER_RETRY          Result = 27
	Result_INVALID_CONTAINER_STATE         Result = 28
	Result_DISK_OUT_OF_SPACE               Result = 29
	Result_CONTAINER_ALREADY_EXISTS        Result = 30
	Result_CONTAINER_METADATA_ERROR        Result = 31
	Result_CONTAINER_FILES_CREATE_ERROR    Result = 32
	Result_CONTAINER_CHECKSUM_ERROR        Result = 33
	Result_UNKNOWN_CONTAINER_TYPE          Result = 34
	Result_BLOCK_NOT_COMMITTED             Result = 35
	Result_CONTAINER_UNHEALTHY             Result = 36
	Result_UNKNOWN_BCSID                   Result = 37
	Result_BCSID_MISMATCH                  Result = 38
	Result_CONTAINER_NOT_OPEN              Result = 39
	Result_CONTAINER_MISSING               Result = 40
	Result_BLOCK_TOKEN_VERIFICATION_FAILED Result = 41
	Result_ERROR_IN_DB_SYNC                Result = 42
)

func (Result) Descriptor 

func (Result) Descriptor() protoreflect.EnumDescriptor

func (Result) Enum 

func (x Result) Enum() *Result

func (Result) EnumDescriptor deprecated 

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

Deprecated: Use Result.Descriptor instead.

func (Result) Number 

func (x Result) Number() protoreflect.EnumNumber

func (Result) String 

func (x Result) String() string

func (Result) Type 

func (Result) Type() protoreflect.EnumType

func (*Result) UnmarshalJSON deprecated 

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

Deprecated: Do not use.

type Type 

type Type int32
const (
	Type_CreateContainer Type = 1
	Type_ReadContainer   Type = 2
	Type_UpdateContainer Type = 3
	Type_DeleteContainer Type = 4
	Type_ListContainer   Type = 5
	Type_PutBlock        Type = 6
	Type_GetBlock        Type = 7
	Type_DeleteBlock     Type = 8
	Type_ListBlock       Type = 9
	Type_ReadChunk       Type = 10
	Type_DeleteChunk     Type = 11
	Type_WriteChunk      Type = 12
	Type_ListChunk       Type = 13
	Type_CompactChunk    Type = 14
	//* Combines Block and Chunk Operation into Single RPC.
	Type_PutSmallFile            Type = 15
	Type_GetSmallFile            Type = 16
	Type_CloseContainer          Type = 17
	Type_GetCommittedBlockLength Type = 18
)

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 UnimplementedIntraDatanodeProtocolServiceServer 

type UnimplementedIntraDatanodeProtocolServiceServer struct {
}

UnimplementedIntraDatanodeProtocolServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedIntraDatanodeProtocolServiceServer) Download 

func (*UnimplementedIntraDatanodeProtocolServiceServer) Download(*CopyContainerRequestProto, IntraDatanodeProtocolService_DownloadServer) error

type UnimplementedXceiverClientProtocolServiceServer 

type UnimplementedXceiverClientProtocolServiceServer struct {
}

UnimplementedXceiverClientProtocolServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedXceiverClientProtocolServiceServer) Send 

func (*UnimplementedXceiverClientProtocolServiceServer) Send(XceiverClientProtocolService_SendServer) error

type UpdateContainerRequestProto 

type UpdateContainerRequestProto struct {
	Metadata    []*KeyValue `protobuf:"bytes,2,rep,name=metadata" json:"metadata,omitempty"`
	ForceUpdate *bool       `protobuf:"varint,3,opt,name=forceUpdate,def=0" json:"forceUpdate,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateContainerRequestProto) Descriptor deprecated 

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

Deprecated: Use UpdateContainerRequestProto.ProtoReflect.Descriptor instead.

func (*UpdateContainerRequestProto) GetForceUpdate 

func (x *UpdateContainerRequestProto) GetForceUpdate() bool

func (*UpdateContainerRequestProto) GetMetadata 

func (x *UpdateContainerRequestProto) GetMetadata() []*KeyValue

func (*UpdateContainerRequestProto) ProtoMessage 

func (*UpdateContainerRequestProto) ProtoMessage()

func (*UpdateContainerRequestProto) ProtoReflect 

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

func (*UpdateContainerRequestProto) Reset 

func (x *UpdateContainerRequestProto) Reset()

func (*UpdateContainerRequestProto) String 

func (x *UpdateContainerRequestProto) String() string

type UpdateContainerResponseProto 

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

func (*UpdateContainerResponseProto) Descriptor deprecated 

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

Deprecated: Use UpdateContainerResponseProto.ProtoReflect.Descriptor instead.

func (*UpdateContainerResponseProto) ProtoMessage 

func (*UpdateContainerResponseProto) ProtoMessage()

func (*UpdateContainerResponseProto) ProtoReflect 

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

func (*UpdateContainerResponseProto) Reset 

func (x *UpdateContainerResponseProto) Reset()

func (*UpdateContainerResponseProto) String 

func (x *UpdateContainerResponseProto) String() string

type WriteChunkRequestProto 

type WriteChunkRequestProto struct {
	BlockID   *DatanodeBlockID `protobuf:"bytes,1,req,name=blockID" json:"blockID,omitempty"`
	ChunkData *ChunkInfo       `protobuf:"bytes,2,req,name=chunkData" json:"chunkData,omitempty"`
	Data      []byte           `protobuf:"bytes,3,opt,name=data" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*WriteChunkRequestProto) Descriptor deprecated 

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

Deprecated: Use WriteChunkRequestProto.ProtoReflect.Descriptor instead.

func (*WriteChunkRequestProto) GetBlockID 

func (x *WriteChunkRequestProto) GetBlockID() *DatanodeBlockID

func (*WriteChunkRequestProto) GetChunkData 

func (x *WriteChunkRequestProto) GetChunkData() *ChunkInfo

func (*WriteChunkRequestProto) GetData 

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

func (*WriteChunkRequestProto) ProtoMessage 

func (*WriteChunkRequestProto) ProtoMessage()

func (*WriteChunkRequestProto) ProtoReflect 

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

func (*WriteChunkRequestProto) Reset 

func (x *WriteChunkRequestProto) Reset()

func (*WriteChunkRequestProto) String 

func (x *WriteChunkRequestProto) String() string

type WriteChunkResponseProto 

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

func (*WriteChunkResponseProto) Descriptor deprecated 

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

Deprecated: Use WriteChunkResponseProto.ProtoReflect.Descriptor instead.

func (*WriteChunkResponseProto) ProtoMessage 

func (*WriteChunkResponseProto) ProtoMessage()

func (*WriteChunkResponseProto) ProtoReflect 

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

func (*WriteChunkResponseProto) Reset 

func (x *WriteChunkResponseProto) Reset()

func (*WriteChunkResponseProto) String 

func (x *WriteChunkResponseProto) String() string

type XceiverClientProtocolServiceClient 

type XceiverClientProtocolServiceClient interface {
	// A client-to-datanode RPC to send container commands
	Send(ctx context.Context, opts ...grpc.CallOption) (XceiverClientProtocolService_SendClient, error)
}

XceiverClientProtocolServiceClient is the client API for XceiverClientProtocolService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewXceiverClientProtocolServiceClient 

func NewXceiverClientProtocolServiceClient(cc grpc.ClientConnInterface) XceiverClientProtocolServiceClient

type XceiverClientProtocolServiceServer 

type XceiverClientProtocolServiceServer interface {
	// A client-to-datanode RPC to send container commands
	Send(XceiverClientProtocolService_SendServer) error
}

XceiverClientProtocolServiceServer is the server API for XceiverClientProtocolService service.

type XceiverClientProtocolService_SendClient 

type XceiverClientProtocolService_SendClient interface {
	Send(*ContainerCommandRequestProto) error
	Recv() (*ContainerCommandResponseProto, error)
	grpc.ClientStream
}

type XceiverClientProtocolService_SendServer 

type XceiverClientProtocolService_SendServer interface {
	Send(*ContainerCommandResponseProto) error
	Recv() (*ContainerCommandRequestProto, error)
	grpc.ServerStream
}

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.