hadoop_hdfs

package
v0.1.4 Latest Latest
Warning

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

Go to latest
Published: Feb 28, 2015 License: MIT Imports: 3 Imported by: 0

Documentation

Overview

Package hadoop_hdfs is a generated protocol buffer package.

It is generated from these files:

ClientNamenodeProtocol.proto
datatransfer.proto
hdfs.proto

It has these top-level messages:

GetBlockLocationsRequestProto
GetBlockLocationsResponseProto
GetServerDefaultsRequestProto
GetServerDefaultsResponseProto
CreateRequestProto
CreateResponseProto
AppendRequestProto
AppendResponseProto
SetReplicationRequestProto
SetReplicationResponseProto
SetPermissionRequestProto
SetPermissionResponseProto
SetOwnerRequestProto
SetOwnerResponseProto
AbandonBlockRequestProto
AbandonBlockResponseProto
AddBlockRequestProto
AddBlockResponseProto
GetAdditionalDatanodeRequestProto
GetAdditionalDatanodeResponseProto
CompleteRequestProto
CompleteResponseProto
ReportBadBlocksRequestProto
ReportBadBlocksResponseProto
ConcatRequestProto
ConcatResponseProto
RenameRequestProto
RenameResponseProto
Rename2RequestProto
Rename2ResponseProto
DeleteRequestProto
DeleteResponseProto
MkdirsRequestProto
MkdirsResponseProto
GetListingRequestProto
GetListingResponseProto
GetSnapshottableDirListingRequestProto
GetSnapshottableDirListingResponseProto
GetSnapshotDiffReportRequestProto
GetSnapshotDiffReportResponseProto
RenewLeaseRequestProto
RenewLeaseResponseProto
RecoverLeaseRequestProto
RecoverLeaseResponseProto
GetFsStatusRequestProto
GetFsStatsResponseProto
GetDatanodeReportRequestProto
GetDatanodeReportResponseProto
GetPreferredBlockSizeRequestProto
GetPreferredBlockSizeResponseProto
SetSafeModeRequestProto
SetSafeModeResponseProto
SaveNamespaceRequestProto
SaveNamespaceResponseProto
RollEditsRequestProto
RollEditsResponseProto
RestoreFailedStorageRequestProto
RestoreFailedStorageResponseProto
RefreshNodesRequestProto
RefreshNodesResponseProto
FinalizeUpgradeRequestProto
FinalizeUpgradeResponseProto
ListCorruptFileBlocksRequestProto
ListCorruptFileBlocksResponseProto
MetaSaveRequestProto
MetaSaveResponseProto
GetFileInfoRequestProto
GetFileInfoResponseProto
IsFileClosedRequestProto
IsFileClosedResponseProto
GetFileLinkInfoRequestProto
GetFileLinkInfoResponseProto
GetContentSummaryRequestProto
GetContentSummaryResponseProto
SetQuotaRequestProto
SetQuotaResponseProto
FsyncRequestProto
FsyncResponseProto
SetTimesRequestProto
SetTimesResponseProto
CreateSymlinkRequestProto
CreateSymlinkResponseProto
GetLinkTargetRequestProto
GetLinkTargetResponseProto
UpdateBlockForPipelineRequestProto
UpdateBlockForPipelineResponseProto
UpdatePipelineRequestProto
UpdatePipelineResponseProto
SetBalancerBandwidthRequestProto
SetBalancerBandwidthResponseProto
GetDataEncryptionKeyRequestProto
GetDataEncryptionKeyResponseProto
CreateSnapshotRequestProto
CreateSnapshotResponseProto
RenameSnapshotRequestProto
RenameSnapshotResponseProto
AllowSnapshotRequestProto
AllowSnapshotResponseProto
DisallowSnapshotRequestProto
DisallowSnapshotResponseProto
DeleteSnapshotRequestProto
DeleteSnapshotResponseProto

Index

Constants

View Source
const Default_AddBlockRequestProto_FileId uint64 = 0
View Source
const Default_BlockProto_NumBytes uint64 = 0
View Source
const Default_CompleteRequestProto_FileId uint64 = 0
View Source
const Default_DatanodeIDProto_InfoSecurePort uint32 = 0
View Source
const Default_DatanodeInfoProto_BlockPoolUsed uint64 = 0
View Source
const Default_DatanodeInfoProto_Capacity uint64 = 0
View Source
const Default_DatanodeInfoProto_DfsUsed uint64 = 0
View Source
const Default_DatanodeInfoProto_LastUpdate uint64 = 0
View Source
const Default_DatanodeInfoProto_Remaining uint64 = 0
View Source
const Default_DatanodeInfoProto_XceiverCount uint32 = 0
View Source
const Default_ExtendedBlockProto_NumBytes uint64 = 0
View Source
const Default_FsServerDefaultsProto_EncryptDataTransfer bool = false
View Source
const Default_FsServerDefaultsProto_TrashInterval uint64 = 0
View Source
const Default_FsyncRequestProto_LastBlockLength int64 = -1
View Source
const Default_HdfsFileStatusProto_BlockReplication uint32 = 0
View Source
const Default_HdfsFileStatusProto_Blocksize uint64 = 0
View Source
const Default_HdfsFileStatusProto_ChildrenNum int32 = -1
View Source
const Default_HdfsFileStatusProto_FileId uint64 = 0
View Source
const Default_OpReadBlockProto_SendChecksums bool = true
View Source
const Default_PacketHeaderProto_SyncBlock bool = false
View Source
const Default_PipelineAckProto_DownstreamAckTimeNanos uint64 = 0
View Source
const Default_RemoteEditLogProto_IsInProgress bool = false
View Source
const Default_SetSafeModeRequestProto_Checked bool = false

Variables

View Source
var ChecksumTypeProto_name = map[int32]string{
	0: "CHECKSUM_NULL",
	1: "CHECKSUM_CRC32",
	2: "CHECKSUM_CRC32C",
}
View Source
var ChecksumTypeProto_value = map[string]int32{
	"CHECKSUM_NULL":   0,
	"CHECKSUM_CRC32":  1,
	"CHECKSUM_CRC32C": 2,
}
View Source
var CreateFlagProto_name = map[int32]string{
	1: "CREATE",
	2: "OVERWRITE",
	4: "APPEND",
}
View Source
var CreateFlagProto_value = map[string]int32{
	"CREATE":    1,
	"OVERWRITE": 2,
	"APPEND":    4,
}
View Source
var DataTransferEncryptorMessageProto_DataTransferEncryptorStatus_name = map[int32]string{
	0: "SUCCESS",
	1: "ERROR_UNKNOWN_KEY",
	2: "ERROR",
}
View Source
var DataTransferEncryptorMessageProto_DataTransferEncryptorStatus_value = map[string]int32{
	"SUCCESS":           0,
	"ERROR_UNKNOWN_KEY": 1,
	"ERROR":             2,
}
View Source
var DatanodeInfoProto_AdminState_name = map[int32]string{
	0: "NORMAL",
	1: "DECOMMISSION_INPROGRESS",
	2: "DECOMMISSIONED",
}
View Source
var DatanodeInfoProto_AdminState_value = map[string]int32{
	"NORMAL":                  0,
	"DECOMMISSION_INPROGRESS": 1,
	"DECOMMISSIONED":          2,
}
View Source
var DatanodeReportTypeProto_name = map[int32]string{
	1: "ALL",
	2: "LIVE",
	3: "DEAD",
}
View Source
var DatanodeReportTypeProto_value = map[string]int32{
	"ALL":  1,
	"LIVE": 2,
	"DEAD": 3,
}
View Source
var HdfsFileStatusProto_FileType_name = map[int32]string{
	1: "IS_DIR",
	2: "IS_FILE",
	3: "IS_SYMLINK",
}
View Source
var HdfsFileStatusProto_FileType_value = map[string]int32{
	"IS_DIR":     1,
	"IS_FILE":    2,
	"IS_SYMLINK": 3,
}
View Source
var NamenodeCommandProto_Type_name = map[int32]string{
	0: "NamenodeCommand",
	1: "CheckPointCommand",
}
View Source
var NamenodeCommandProto_Type_value = map[string]int32{
	"NamenodeCommand":   0,
	"CheckPointCommand": 1,
}
View Source
var NamenodeRegistrationProto_NamenodeRoleProto_name = map[int32]string{
	1: "NAMENODE",
	2: "BACKUP",
	3: "CHECKPOINT",
}
View Source
var NamenodeRegistrationProto_NamenodeRoleProto_value = map[string]int32{
	"NAMENODE":   1,
	"BACKUP":     2,
	"CHECKPOINT": 3,
}
View Source
var OpWriteBlockProto_BlockConstructionStage_name = map[int32]string{
	0: "PIPELINE_SETUP_APPEND",
	1: "PIPELINE_SETUP_APPEND_RECOVERY",
	2: "DATA_STREAMING",
	3: "PIPELINE_SETUP_STREAMING_RECOVERY",
	4: "PIPELINE_CLOSE",
	5: "PIPELINE_CLOSE_RECOVERY",
	6: "PIPELINE_SETUP_CREATE",
	7: "TRANSFER_RBW",
	8: "TRANSFER_FINALIZED",
}
View Source
var OpWriteBlockProto_BlockConstructionStage_value = map[string]int32{
	"PIPELINE_SETUP_APPEND":             0,
	"PIPELINE_SETUP_APPEND_RECOVERY":    1,
	"DATA_STREAMING":                    2,
	"PIPELINE_SETUP_STREAMING_RECOVERY": 3,
	"PIPELINE_CLOSE":                    4,
	"PIPELINE_CLOSE_RECOVERY":           5,
	"PIPELINE_SETUP_CREATE":             6,
	"TRANSFER_RBW":                      7,
	"TRANSFER_FINALIZED":                8,
}
View Source
var ReplicaStateProto_name = map[int32]string{
	0: "FINALIZED",
	1: "RBW",
	2: "RWR",
	3: "RUR",
	4: "TEMPORARY",
}
View Source
var ReplicaStateProto_value = map[string]int32{
	"FINALIZED": 0,
	"RBW":       1,
	"RWR":       2,
	"RUR":       3,
	"TEMPORARY": 4,
}
View Source
var SafeModeActionProto_name = map[int32]string{
	1: "SAFEMODE_LEAVE",
	2: "SAFEMODE_ENTER",
	3: "SAFEMODE_GET",
}
View Source
var SafeModeActionProto_value = map[string]int32{
	"SAFEMODE_LEAVE": 1,
	"SAFEMODE_ENTER": 2,
	"SAFEMODE_GET":   3,
}
View Source
var Status_name = map[int32]string{
	0: "SUCCESS",
	1: "ERROR",
	2: "ERROR_CHECKSUM",
	3: "ERROR_INVALID",
	4: "ERROR_EXISTS",
	5: "ERROR_ACCESS_TOKEN",
	6: "CHECKSUM_OK",
	7: "ERROR_UNSUPPORTED",
}
View Source
var Status_value = map[string]int32{
	"SUCCESS":            0,
	"ERROR":              1,
	"ERROR_CHECKSUM":     2,
	"ERROR_INVALID":      3,
	"ERROR_EXISTS":       4,
	"ERROR_ACCESS_TOKEN": 5,
	"CHECKSUM_OK":        6,
	"ERROR_UNSUPPORTED":  7,
}

Functions

This section is empty.

Types

type AbandonBlockRequestProto

type AbandonBlockRequestProto struct {
	B                *ExtendedBlockProto `protobuf:"bytes,1,req,name=b" json:"b,omitempty"`
	Src              *string             `protobuf:"bytes,2,req,name=src" json:"src,omitempty"`
	Holder           *string             `protobuf:"bytes,3,req,name=holder" json:"holder,omitempty"`
	XXX_unrecognized []byte              `json:"-"`
}

func (*AbandonBlockRequestProto) GetB

func (*AbandonBlockRequestProto) GetHolder

func (m *AbandonBlockRequestProto) GetHolder() string

func (*AbandonBlockRequestProto) GetSrc

func (m *AbandonBlockRequestProto) GetSrc() string

func (*AbandonBlockRequestProto) ProtoMessage

func (*AbandonBlockRequestProto) ProtoMessage()

func (*AbandonBlockRequestProto) Reset

func (m *AbandonBlockRequestProto) Reset()

func (*AbandonBlockRequestProto) String

func (m *AbandonBlockRequestProto) String() string

type AbandonBlockResponseProto

type AbandonBlockResponseProto struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*AbandonBlockResponseProto) ProtoMessage

func (*AbandonBlockResponseProto) ProtoMessage()

func (*AbandonBlockResponseProto) Reset

func (m *AbandonBlockResponseProto) Reset()

func (*AbandonBlockResponseProto) String

func (m *AbandonBlockResponseProto) String() string

type AddBlockRequestProto

type AddBlockRequestProto struct {
	Src              *string              `protobuf:"bytes,1,req,name=src" json:"src,omitempty"`
	ClientName       *string              `protobuf:"bytes,2,req,name=clientName" json:"clientName,omitempty"`
	Previous         *ExtendedBlockProto  `protobuf:"bytes,3,opt,name=previous" json:"previous,omitempty"`
	ExcludeNodes     []*DatanodeInfoProto `protobuf:"bytes,4,rep,name=excludeNodes" json:"excludeNodes,omitempty"`
	FileId           *uint64              `protobuf:"varint,5,opt,name=fileId,def=0" json:"fileId,omitempty"`
	FavoredNodes     []string             `protobuf:"bytes,6,rep,name=favoredNodes" json:"favoredNodes,omitempty"`
	XXX_unrecognized []byte               `json:"-"`
}

func (*AddBlockRequestProto) GetClientName

func (m *AddBlockRequestProto) GetClientName() string

func (*AddBlockRequestProto) GetExcludeNodes

func (m *AddBlockRequestProto) GetExcludeNodes() []*DatanodeInfoProto

func (*AddBlockRequestProto) GetFavoredNodes

func (m *AddBlockRequestProto) GetFavoredNodes() []string

func (*AddBlockRequestProto) GetFileId

func (m *AddBlockRequestProto) GetFileId() uint64

func (*AddBlockRequestProto) GetPrevious

func (m *AddBlockRequestProto) GetPrevious() *ExtendedBlockProto

func (*AddBlockRequestProto) GetSrc

func (m *AddBlockRequestProto) GetSrc() string

func (*AddBlockRequestProto) ProtoMessage

func (*AddBlockRequestProto) ProtoMessage()

func (*AddBlockRequestProto) Reset

func (m *AddBlockRequestProto) Reset()

func (*AddBlockRequestProto) String

func (m *AddBlockRequestProto) String() string

type AddBlockResponseProto

type AddBlockResponseProto struct {
	Block            *LocatedBlockProto `protobuf:"bytes,1,req,name=block" json:"block,omitempty"`
	XXX_unrecognized []byte             `json:"-"`
}

func (*AddBlockResponseProto) GetBlock

func (*AddBlockResponseProto) ProtoMessage

func (*AddBlockResponseProto) ProtoMessage()

func (*AddBlockResponseProto) Reset

func (m *AddBlockResponseProto) Reset()

func (*AddBlockResponseProto) String

func (m *AddBlockResponseProto) String() string

type AllowSnapshotRequestProto

type AllowSnapshotRequestProto struct {
	SnapshotRoot     *string `protobuf:"bytes,1,req,name=snapshotRoot" json:"snapshotRoot,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*AllowSnapshotRequestProto) GetSnapshotRoot

func (m *AllowSnapshotRequestProto) GetSnapshotRoot() string

func (*AllowSnapshotRequestProto) ProtoMessage

func (*AllowSnapshotRequestProto) ProtoMessage()

func (*AllowSnapshotRequestProto) Reset

func (m *AllowSnapshotRequestProto) Reset()

func (*AllowSnapshotRequestProto) String

func (m *AllowSnapshotRequestProto) String() string

type AllowSnapshotResponseProto

type AllowSnapshotResponseProto struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*AllowSnapshotResponseProto) ProtoMessage

func (*AllowSnapshotResponseProto) ProtoMessage()

func (*AllowSnapshotResponseProto) Reset

func (m *AllowSnapshotResponseProto) Reset()

func (*AllowSnapshotResponseProto) String

func (m *AllowSnapshotResponseProto) String() string

type AppendRequestProto

type AppendRequestProto struct {
	Src              *string `protobuf:"bytes,1,req,name=src" json:"src,omitempty"`
	ClientName       *string `protobuf:"bytes,2,req,name=clientName" json:"clientName,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*AppendRequestProto) GetClientName

func (m *AppendRequestProto) GetClientName() string

func (*AppendRequestProto) GetSrc

func (m *AppendRequestProto) GetSrc() string

func (*AppendRequestProto) ProtoMessage

func (*AppendRequestProto) ProtoMessage()

func (*AppendRequestProto) Reset

func (m *AppendRequestProto) Reset()

func (*AppendRequestProto) String

func (m *AppendRequestProto) String() string

type AppendResponseProto

type AppendResponseProto struct {
	Block            *LocatedBlockProto `protobuf:"bytes,1,opt,name=block" json:"block,omitempty"`
	XXX_unrecognized []byte             `json:"-"`
}

func (*AppendResponseProto) GetBlock

func (m *AppendResponseProto) GetBlock() *LocatedBlockProto

func (*AppendResponseProto) ProtoMessage

func (*AppendResponseProto) ProtoMessage()

func (*AppendResponseProto) Reset

func (m *AppendResponseProto) Reset()

func (*AppendResponseProto) String

func (m *AppendResponseProto) String() string

type BaseHeaderProto

type BaseHeaderProto struct {
	Block            *ExtendedBlockProto       `protobuf:"bytes,1,req,name=block" json:"block,omitempty"`
	Token            *hadoop_common.TokenProto `protobuf:"bytes,2,opt,name=token" json:"token,omitempty"`
	XXX_unrecognized []byte                    `json:"-"`
}

func (*BaseHeaderProto) GetBlock

func (m *BaseHeaderProto) GetBlock() *ExtendedBlockProto

func (*BaseHeaderProto) GetToken

func (m *BaseHeaderProto) GetToken() *hadoop_common.TokenProto

func (*BaseHeaderProto) ProtoMessage

func (*BaseHeaderProto) ProtoMessage()

func (*BaseHeaderProto) Reset

func (m *BaseHeaderProto) Reset()

func (*BaseHeaderProto) String

func (m *BaseHeaderProto) String() string

type BlockKeyProto

type BlockKeyProto struct {
	KeyId            *uint32 `protobuf:"varint,1,req,name=keyId" json:"keyId,omitempty"`
	ExpiryDate       *uint64 `protobuf:"varint,2,req,name=expiryDate" json:"expiryDate,omitempty"`
	KeyBytes         []byte  `protobuf:"bytes,3,opt,name=keyBytes" json:"keyBytes,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* Block access token information

func (*BlockKeyProto) GetExpiryDate

func (m *BlockKeyProto) GetExpiryDate() uint64

func (*BlockKeyProto) GetKeyBytes

func (m *BlockKeyProto) GetKeyBytes() []byte

func (*BlockKeyProto) GetKeyId

func (m *BlockKeyProto) GetKeyId() uint32

func (*BlockKeyProto) ProtoMessage

func (*BlockKeyProto) ProtoMessage()

func (*BlockKeyProto) Reset

func (m *BlockKeyProto) Reset()

func (*BlockKeyProto) String

func (m *BlockKeyProto) String() string

type BlockOpResponseProto

type BlockOpResponseProto struct {
	Status             *Status                       `protobuf:"varint,1,req,name=status,enum=hadoop.hdfs.Status" json:"status,omitempty"`
	FirstBadLink       *string                       `protobuf:"bytes,2,opt,name=firstBadLink" json:"firstBadLink,omitempty"`
	ChecksumResponse   *OpBlockChecksumResponseProto `protobuf:"bytes,3,opt,name=checksumResponse" json:"checksumResponse,omitempty"`
	ReadOpChecksumInfo *ReadOpChecksumInfoProto      `protobuf:"bytes,4,opt,name=readOpChecksumInfo" json:"readOpChecksumInfo,omitempty"`
	// * explanatory text which may be useful to log on the client side
	Message *string `protobuf:"bytes,5,opt,name=message" json:"message,omitempty"`
	// * If the server chooses to agree to the request of a client for
	// short-circuit access, it will send a response message with the relevant
	// file descriptors attached.
	//
	// In the body of the message, this version number will be set to the
	// specific version number of the block data that the client is about to
	// read.
	ShortCircuitAccessVersion *uint32 `protobuf:"varint,6,opt,name=shortCircuitAccessVersion" json:"shortCircuitAccessVersion,omitempty"`
	XXX_unrecognized          []byte  `json:"-"`
}

func (*BlockOpResponseProto) GetChecksumResponse

func (m *BlockOpResponseProto) GetChecksumResponse() *OpBlockChecksumResponseProto
func (m *BlockOpResponseProto) GetFirstBadLink() string

func (*BlockOpResponseProto) GetMessage

func (m *BlockOpResponseProto) GetMessage() string

func (*BlockOpResponseProto) GetReadOpChecksumInfo

func (m *BlockOpResponseProto) GetReadOpChecksumInfo() *ReadOpChecksumInfoProto

func (*BlockOpResponseProto) GetShortCircuitAccessVersion

func (m *BlockOpResponseProto) GetShortCircuitAccessVersion() uint32

func (*BlockOpResponseProto) GetStatus

func (m *BlockOpResponseProto) GetStatus() Status

func (*BlockOpResponseProto) ProtoMessage

func (*BlockOpResponseProto) ProtoMessage()

func (*BlockOpResponseProto) Reset

func (m *BlockOpResponseProto) Reset()

func (*BlockOpResponseProto) String

func (m *BlockOpResponseProto) String() string

type BlockProto

type BlockProto struct {
	BlockId          *uint64 `protobuf:"varint,1,req,name=blockId" json:"blockId,omitempty"`
	GenStamp         *uint64 `protobuf:"varint,2,req,name=genStamp" json:"genStamp,omitempty"`
	NumBytes         *uint64 `protobuf:"varint,3,opt,name=numBytes,def=0" json:"numBytes,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* Block information

func (*BlockProto) GetBlockId

func (m *BlockProto) GetBlockId() uint64

func (*BlockProto) GetGenStamp

func (m *BlockProto) GetGenStamp() uint64

func (*BlockProto) GetNumBytes

func (m *BlockProto) GetNumBytes() uint64

func (*BlockProto) ProtoMessage

func (*BlockProto) ProtoMessage()

func (*BlockProto) Reset

func (m *BlockProto) Reset()

func (*BlockProto) String

func (m *BlockProto) String() string

type BlockWithLocationsProto

type BlockWithLocationsProto struct {
	Block            *BlockProto `protobuf:"bytes,1,req,name=block" json:"block,omitempty"`
	StorageIDs       []string    `protobuf:"bytes,2,rep,name=storageIDs" json:"storageIDs,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

* Block and datanodes where is it located

func (*BlockWithLocationsProto) GetBlock

func (m *BlockWithLocationsProto) GetBlock() *BlockProto

func (*BlockWithLocationsProto) GetStorageIDs

func (m *BlockWithLocationsProto) GetStorageIDs() []string

func (*BlockWithLocationsProto) ProtoMessage

func (*BlockWithLocationsProto) ProtoMessage()

func (*BlockWithLocationsProto) Reset

func (m *BlockWithLocationsProto) Reset()

func (*BlockWithLocationsProto) String

func (m *BlockWithLocationsProto) String() string

type BlocksWithLocationsProto

type BlocksWithLocationsProto struct {
	Blocks           []*BlockWithLocationsProto `protobuf:"bytes,1,rep,name=blocks" json:"blocks,omitempty"`
	XXX_unrecognized []byte                     `json:"-"`
}

* List of block with locations

func (*BlocksWithLocationsProto) GetBlocks

func (*BlocksWithLocationsProto) ProtoMessage

func (*BlocksWithLocationsProto) ProtoMessage()

func (*BlocksWithLocationsProto) Reset

func (m *BlocksWithLocationsProto) Reset()

func (*BlocksWithLocationsProto) String

func (m *BlocksWithLocationsProto) String() string

type CachingStrategyProto

type CachingStrategyProto struct {
	DropBehind       *bool  `protobuf:"varint,1,opt,name=dropBehind" json:"dropBehind,omitempty"`
	Readahead        *int64 `protobuf:"varint,2,opt,name=readahead" json:"readahead,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*CachingStrategyProto) GetDropBehind

func (m *CachingStrategyProto) GetDropBehind() bool

func (*CachingStrategyProto) GetReadahead

func (m *CachingStrategyProto) GetReadahead() int64

func (*CachingStrategyProto) ProtoMessage

func (*CachingStrategyProto) ProtoMessage()

func (*CachingStrategyProto) Reset

func (m *CachingStrategyProto) Reset()

func (*CachingStrategyProto) String

func (m *CachingStrategyProto) String() string

type CheckpointCommandProto

type CheckpointCommandProto struct {
	// Unique signature to identify checkpoint transation
	Signature *CheckpointSignatureProto `protobuf:"bytes,1,req,name=signature" json:"signature,omitempty"`
	// If true, return transfer image to primary upon the completion of checkpoint
	NeedToReturnImage *bool  `protobuf:"varint,2,req,name=needToReturnImage" json:"needToReturnImage,omitempty"`
	XXX_unrecognized  []byte `json:"-"`
}

* Command returned from primary to checkpointing namenode. This command has checkpoint signature that identifies checkpoint transaction and is needed for further communication related to checkpointing.

func (*CheckpointCommandProto) GetNeedToReturnImage

func (m *CheckpointCommandProto) GetNeedToReturnImage() bool

func (*CheckpointCommandProto) GetSignature

func (*CheckpointCommandProto) ProtoMessage

func (*CheckpointCommandProto) ProtoMessage()

func (*CheckpointCommandProto) Reset

func (m *CheckpointCommandProto) Reset()

func (*CheckpointCommandProto) String

func (m *CheckpointCommandProto) String() string

type CheckpointSignatureProto

type CheckpointSignatureProto struct {
	BlockPoolId              *string           `protobuf:"bytes,1,req,name=blockPoolId" json:"blockPoolId,omitempty"`
	MostRecentCheckpointTxId *uint64           `protobuf:"varint,2,req,name=mostRecentCheckpointTxId" json:"mostRecentCheckpointTxId,omitempty"`
	CurSegmentTxId           *uint64           `protobuf:"varint,3,req,name=curSegmentTxId" json:"curSegmentTxId,omitempty"`
	StorageInfo              *StorageInfoProto `protobuf:"bytes,4,req,name=storageInfo" json:"storageInfo,omitempty"`
	XXX_unrecognized         []byte            `json:"-"`
}

* Unique signature to identify checkpoint transactions.

func (*CheckpointSignatureProto) GetBlockPoolId

func (m *CheckpointSignatureProto) GetBlockPoolId() string

func (*CheckpointSignatureProto) GetCurSegmentTxId

func (m *CheckpointSignatureProto) GetCurSegmentTxId() uint64

func (*CheckpointSignatureProto) GetMostRecentCheckpointTxId

func (m *CheckpointSignatureProto) GetMostRecentCheckpointTxId() uint64

func (*CheckpointSignatureProto) GetStorageInfo

func (m *CheckpointSignatureProto) GetStorageInfo() *StorageInfoProto

func (*CheckpointSignatureProto) ProtoMessage

func (*CheckpointSignatureProto) ProtoMessage()

func (*CheckpointSignatureProto) Reset

func (m *CheckpointSignatureProto) Reset()

func (*CheckpointSignatureProto) String

func (m *CheckpointSignatureProto) String() string

type ChecksumProto

type ChecksumProto struct {
	Type             *ChecksumTypeProto `protobuf:"varint,1,req,name=type,enum=hadoop.hdfs.ChecksumTypeProto" json:"type,omitempty"`
	BytesPerChecksum *uint32            `protobuf:"varint,2,req,name=bytesPerChecksum" json:"bytesPerChecksum,omitempty"`
	XXX_unrecognized []byte             `json:"-"`
}

func (*ChecksumProto) GetBytesPerChecksum

func (m *ChecksumProto) GetBytesPerChecksum() uint32

func (*ChecksumProto) GetType

func (m *ChecksumProto) GetType() ChecksumTypeProto

func (*ChecksumProto) ProtoMessage

func (*ChecksumProto) ProtoMessage()

func (*ChecksumProto) Reset

func (m *ChecksumProto) Reset()

func (*ChecksumProto) String

func (m *ChecksumProto) String() string

type ChecksumTypeProto

type ChecksumTypeProto int32

* Checksum algorithms/types used in HDFS Make sure this enum's integer values match enum values' id properties defined in org.apache.hadoop.util.DataChecksum.Type

const (
	ChecksumTypeProto_CHECKSUM_NULL   ChecksumTypeProto = 0
	ChecksumTypeProto_CHECKSUM_CRC32  ChecksumTypeProto = 1
	ChecksumTypeProto_CHECKSUM_CRC32C ChecksumTypeProto = 2
)
const Default_FsServerDefaultsProto_ChecksumType ChecksumTypeProto = ChecksumTypeProto_CHECKSUM_CRC32

func (ChecksumTypeProto) Enum

func (ChecksumTypeProto) String

func (x ChecksumTypeProto) String() string

func (*ChecksumTypeProto) UnmarshalJSON

func (x *ChecksumTypeProto) UnmarshalJSON(data []byte) error

type ClientOperationHeaderProto

type ClientOperationHeaderProto struct {
	BaseHeader       *BaseHeaderProto `protobuf:"bytes,1,req,name=baseHeader" json:"baseHeader,omitempty"`
	ClientName       *string          `protobuf:"bytes,2,req,name=clientName" json:"clientName,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

func (*ClientOperationHeaderProto) GetBaseHeader

func (m *ClientOperationHeaderProto) GetBaseHeader() *BaseHeaderProto

func (*ClientOperationHeaderProto) GetClientName

func (m *ClientOperationHeaderProto) GetClientName() string

func (*ClientOperationHeaderProto) ProtoMessage

func (*ClientOperationHeaderProto) ProtoMessage()

func (*ClientOperationHeaderProto) Reset

func (m *ClientOperationHeaderProto) Reset()

func (*ClientOperationHeaderProto) String

func (m *ClientOperationHeaderProto) String() string

type ClientReadStatusProto

type ClientReadStatusProto struct {
	Status           *Status `protobuf:"varint,1,req,name=status,enum=hadoop.hdfs.Status" json:"status,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* Message sent from the client to the DN after reading the entire read request.

func (*ClientReadStatusProto) GetStatus

func (m *ClientReadStatusProto) GetStatus() Status

func (*ClientReadStatusProto) ProtoMessage

func (*ClientReadStatusProto) ProtoMessage()

func (*ClientReadStatusProto) Reset

func (m *ClientReadStatusProto) Reset()

func (*ClientReadStatusProto) String

func (m *ClientReadStatusProto) String() string

type CompleteRequestProto

type CompleteRequestProto struct {
	Src              *string             `protobuf:"bytes,1,req,name=src" json:"src,omitempty"`
	ClientName       *string             `protobuf:"bytes,2,req,name=clientName" json:"clientName,omitempty"`
	Last             *ExtendedBlockProto `protobuf:"bytes,3,opt,name=last" json:"last,omitempty"`
	FileId           *uint64             `protobuf:"varint,4,opt,name=fileId,def=0" json:"fileId,omitempty"`
	XXX_unrecognized []byte              `json:"-"`
}

func (*CompleteRequestProto) GetClientName

func (m *CompleteRequestProto) GetClientName() string

func (*CompleteRequestProto) GetFileId

func (m *CompleteRequestProto) GetFileId() uint64

func (*CompleteRequestProto) GetLast

func (*CompleteRequestProto) GetSrc

func (m *CompleteRequestProto) GetSrc() string

func (*CompleteRequestProto) ProtoMessage

func (*CompleteRequestProto) ProtoMessage()

func (*CompleteRequestProto) Reset

func (m *CompleteRequestProto) Reset()

func (*CompleteRequestProto) String

func (m *CompleteRequestProto) String() string

type CompleteResponseProto

type CompleteResponseProto struct {
	Result           *bool  `protobuf:"varint,1,req,name=result" json:"result,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*CompleteResponseProto) GetResult

func (m *CompleteResponseProto) GetResult() bool

func (*CompleteResponseProto) ProtoMessage

func (*CompleteResponseProto) ProtoMessage()

func (*CompleteResponseProto) Reset

func (m *CompleteResponseProto) Reset()

func (*CompleteResponseProto) String

func (m *CompleteResponseProto) String() string

type ConcatRequestProto

type ConcatRequestProto struct {
	Trg              *string  `protobuf:"bytes,1,req,name=trg" json:"trg,omitempty"`
	Srcs             []string `protobuf:"bytes,2,rep,name=srcs" json:"srcs,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*ConcatRequestProto) GetSrcs

func (m *ConcatRequestProto) GetSrcs() []string

func (*ConcatRequestProto) GetTrg

func (m *ConcatRequestProto) GetTrg() string

func (*ConcatRequestProto) ProtoMessage

func (*ConcatRequestProto) ProtoMessage()

func (*ConcatRequestProto) Reset

func (m *ConcatRequestProto) Reset()

func (*ConcatRequestProto) String

func (m *ConcatRequestProto) String() string

type ConcatResponseProto

type ConcatResponseProto struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*ConcatResponseProto) ProtoMessage

func (*ConcatResponseProto) ProtoMessage()

func (*ConcatResponseProto) Reset

func (m *ConcatResponseProto) Reset()

func (*ConcatResponseProto) String

func (m *ConcatResponseProto) String() string

type ContentSummaryProto

type ContentSummaryProto struct {
	Length           *uint64 `protobuf:"varint,1,req,name=length" json:"length,omitempty"`
	FileCount        *uint64 `protobuf:"varint,2,req,name=fileCount" json:"fileCount,omitempty"`
	DirectoryCount   *uint64 `protobuf:"varint,3,req,name=directoryCount" json:"directoryCount,omitempty"`
	Quota            *uint64 `protobuf:"varint,4,req,name=quota" json:"quota,omitempty"`
	SpaceConsumed    *uint64 `protobuf:"varint,5,req,name=spaceConsumed" json:"spaceConsumed,omitempty"`
	SpaceQuota       *uint64 `protobuf:"varint,6,req,name=spaceQuota" json:"spaceQuota,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* Summary of a file or directory

func (*ContentSummaryProto) GetDirectoryCount

func (m *ContentSummaryProto) GetDirectoryCount() uint64

func (*ContentSummaryProto) GetFileCount

func (m *ContentSummaryProto) GetFileCount() uint64

func (*ContentSummaryProto) GetLength

func (m *ContentSummaryProto) GetLength() uint64

func (*ContentSummaryProto) GetQuota

func (m *ContentSummaryProto) GetQuota() uint64

func (*ContentSummaryProto) GetSpaceConsumed

func (m *ContentSummaryProto) GetSpaceConsumed() uint64

func (*ContentSummaryProto) GetSpaceQuota

func (m *ContentSummaryProto) GetSpaceQuota() uint64

func (*ContentSummaryProto) ProtoMessage

func (*ContentSummaryProto) ProtoMessage()

func (*ContentSummaryProto) Reset

func (m *ContentSummaryProto) Reset()

func (*ContentSummaryProto) String

func (m *ContentSummaryProto) String() string

type CorruptFileBlocksProto

type CorruptFileBlocksProto struct {
	Files            []string `protobuf:"bytes,1,rep,name=files" json:"files,omitempty"`
	Cookie           *string  `protobuf:"bytes,2,req,name=cookie" json:"cookie,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

* Contains a list of paths corresponding to corrupt files and a cookie used for iterative calls to NameNode.listCorruptFileBlocks.

func (*CorruptFileBlocksProto) GetCookie

func (m *CorruptFileBlocksProto) GetCookie() string

func (*CorruptFileBlocksProto) GetFiles

func (m *CorruptFileBlocksProto) GetFiles() []string

func (*CorruptFileBlocksProto) ProtoMessage

func (*CorruptFileBlocksProto) ProtoMessage()

func (*CorruptFileBlocksProto) Reset

func (m *CorruptFileBlocksProto) Reset()

func (*CorruptFileBlocksProto) String

func (m *CorruptFileBlocksProto) String() string

type CreateFlagProto

type CreateFlagProto int32
const (
	CreateFlagProto_CREATE    CreateFlagProto = 1
	CreateFlagProto_OVERWRITE CreateFlagProto = 2
	CreateFlagProto_APPEND    CreateFlagProto = 4
)

func (CreateFlagProto) Enum

func (x CreateFlagProto) Enum() *CreateFlagProto

func (CreateFlagProto) String

func (x CreateFlagProto) String() string

func (*CreateFlagProto) UnmarshalJSON

func (x *CreateFlagProto) UnmarshalJSON(data []byte) error

type CreateRequestProto

type CreateRequestProto struct {
	Src              *string            `protobuf:"bytes,1,req,name=src" json:"src,omitempty"`
	Masked           *FsPermissionProto `protobuf:"bytes,2,req,name=masked" json:"masked,omitempty"`
	ClientName       *string            `protobuf:"bytes,3,req,name=clientName" json:"clientName,omitempty"`
	CreateFlag       *uint32            `protobuf:"varint,4,req,name=createFlag" json:"createFlag,omitempty"`
	CreateParent     *bool              `protobuf:"varint,5,req,name=createParent" json:"createParent,omitempty"`
	Replication      *uint32            `protobuf:"varint,6,req,name=replication" json:"replication,omitempty"`
	BlockSize        *uint64            `protobuf:"varint,7,req,name=blockSize" json:"blockSize,omitempty"`
	XXX_unrecognized []byte             `json:"-"`
}

func (*CreateRequestProto) GetBlockSize

func (m *CreateRequestProto) GetBlockSize() uint64

func (*CreateRequestProto) GetClientName

func (m *CreateRequestProto) GetClientName() string

func (*CreateRequestProto) GetCreateFlag

func (m *CreateRequestProto) GetCreateFlag() uint32

func (*CreateRequestProto) GetCreateParent

func (m *CreateRequestProto) GetCreateParent() bool

func (*CreateRequestProto) GetMasked

func (m *CreateRequestProto) GetMasked() *FsPermissionProto

func (*CreateRequestProto) GetReplication

func (m *CreateRequestProto) GetReplication() uint32

func (*CreateRequestProto) GetSrc

func (m *CreateRequestProto) GetSrc() string

func (*CreateRequestProto) ProtoMessage

func (*CreateRequestProto) ProtoMessage()

func (*CreateRequestProto) Reset

func (m *CreateRequestProto) Reset()

func (*CreateRequestProto) String

func (m *CreateRequestProto) String() string

type CreateResponseProto

type CreateResponseProto struct {
	Fs               *HdfsFileStatusProto `protobuf:"bytes,1,opt,name=fs" json:"fs,omitempty"`
	XXX_unrecognized []byte               `json:"-"`
}

func (*CreateResponseProto) GetFs

func (*CreateResponseProto) ProtoMessage

func (*CreateResponseProto) ProtoMessage()

func (*CreateResponseProto) Reset

func (m *CreateResponseProto) Reset()

func (*CreateResponseProto) String

func (m *CreateResponseProto) String() string

type CreateSnapshotRequestProto

type CreateSnapshotRequestProto struct {
	SnapshotRoot     *string `protobuf:"bytes,1,req,name=snapshotRoot" json:"snapshotRoot,omitempty"`
	SnapshotName     *string `protobuf:"bytes,2,opt,name=snapshotName" json:"snapshotName,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*CreateSnapshotRequestProto) GetSnapshotName

func (m *CreateSnapshotRequestProto) GetSnapshotName() string

func (*CreateSnapshotRequestProto) GetSnapshotRoot

func (m *CreateSnapshotRequestProto) GetSnapshotRoot() string

func (*CreateSnapshotRequestProto) ProtoMessage

func (*CreateSnapshotRequestProto) ProtoMessage()

func (*CreateSnapshotRequestProto) Reset

func (m *CreateSnapshotRequestProto) Reset()

func (*CreateSnapshotRequestProto) String

func (m *CreateSnapshotRequestProto) String() string

type CreateSnapshotResponseProto

type CreateSnapshotResponseProto struct {
	SnapshotPath     *string `protobuf:"bytes,1,req,name=snapshotPath" json:"snapshotPath,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*CreateSnapshotResponseProto) GetSnapshotPath

func (m *CreateSnapshotResponseProto) GetSnapshotPath() string

func (*CreateSnapshotResponseProto) ProtoMessage

func (*CreateSnapshotResponseProto) ProtoMessage()

func (*CreateSnapshotResponseProto) Reset

func (m *CreateSnapshotResponseProto) Reset()

func (*CreateSnapshotResponseProto) String

func (m *CreateSnapshotResponseProto) String() string

type CreateSymlinkRequestProto

type CreateSymlinkRequestProto struct {
	Target           *string            `protobuf:"bytes,1,req,name=target" json:"target,omitempty"`
	Link             *string            `protobuf:"bytes,2,req,name=link" json:"link,omitempty"`
	DirPerm          *FsPermissionProto `protobuf:"bytes,3,req,name=dirPerm" json:"dirPerm,omitempty"`
	CreateParent     *bool              `protobuf:"varint,4,req,name=createParent" json:"createParent,omitempty"`
	XXX_unrecognized []byte             `json:"-"`
}

func (*CreateSymlinkRequestProto) GetCreateParent

func (m *CreateSymlinkRequestProto) GetCreateParent() bool

func (*CreateSymlinkRequestProto) GetDirPerm

func (m *CreateSymlinkRequestProto) GetLink() string

func (*CreateSymlinkRequestProto) GetTarget

func (m *CreateSymlinkRequestProto) GetTarget() string

func (*CreateSymlinkRequestProto) ProtoMessage

func (*CreateSymlinkRequestProto) ProtoMessage()

func (*CreateSymlinkRequestProto) Reset

func (m *CreateSymlinkRequestProto) Reset()

func (*CreateSymlinkRequestProto) String

func (m *CreateSymlinkRequestProto) String() string

type CreateSymlinkResponseProto

type CreateSymlinkResponseProto struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*CreateSymlinkResponseProto) ProtoMessage

func (*CreateSymlinkResponseProto) ProtoMessage()

func (*CreateSymlinkResponseProto) Reset

func (m *CreateSymlinkResponseProto) Reset()

func (*CreateSymlinkResponseProto) String

func (m *CreateSymlinkResponseProto) String() string

type DNTransferAckProto

type DNTransferAckProto struct {
	Status           *Status `protobuf:"varint,1,req,name=status,enum=hadoop.hdfs.Status" json:"status,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*DNTransferAckProto) GetStatus

func (m *DNTransferAckProto) GetStatus() Status

func (*DNTransferAckProto) ProtoMessage

func (*DNTransferAckProto) ProtoMessage()

func (*DNTransferAckProto) Reset

func (m *DNTransferAckProto) Reset()

func (*DNTransferAckProto) String

func (m *DNTransferAckProto) String() string

type DataEncryptionKeyProto

type DataEncryptionKeyProto struct {
	KeyId               *uint32 `protobuf:"varint,1,req,name=keyId" json:"keyId,omitempty"`
	BlockPoolId         *string `protobuf:"bytes,2,req,name=blockPoolId" json:"blockPoolId,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"`
	XXX_unrecognized    []byte  `json:"-"`
}

func (*DataEncryptionKeyProto) GetBlockPoolId

func (m *DataEncryptionKeyProto) GetBlockPoolId() string

func (*DataEncryptionKeyProto) GetEncryptionAlgorithm

func (m *DataEncryptionKeyProto) GetEncryptionAlgorithm() string

func (*DataEncryptionKeyProto) GetEncryptionKey

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

func (*DataEncryptionKeyProto) GetExpiryDate

func (m *DataEncryptionKeyProto) GetExpiryDate() uint64

func (*DataEncryptionKeyProto) GetKeyId

func (m *DataEncryptionKeyProto) GetKeyId() uint32

func (*DataEncryptionKeyProto) GetNonce

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

func (*DataEncryptionKeyProto) ProtoMessage

func (*DataEncryptionKeyProto) ProtoMessage()

func (*DataEncryptionKeyProto) Reset

func (m *DataEncryptionKeyProto) Reset()

func (*DataEncryptionKeyProto) String

func (m *DataEncryptionKeyProto) String() string

type DataTransferEncryptorMessageProto

type DataTransferEncryptorMessageProto struct {
	Status           *DataTransferEncryptorMessageProto_DataTransferEncryptorStatus `` /* 138-byte string literal not displayed */
	Payload          []byte                                                         `protobuf:"bytes,2,opt,name=payload" json:"payload,omitempty"`
	Message          *string                                                        `protobuf:"bytes,3,opt,name=message" json:"message,omitempty"`
	XXX_unrecognized []byte                                                         `json:"-"`
}

func (*DataTransferEncryptorMessageProto) GetMessage

func (m *DataTransferEncryptorMessageProto) GetMessage() string

func (*DataTransferEncryptorMessageProto) GetPayload

func (m *DataTransferEncryptorMessageProto) GetPayload() []byte

func (*DataTransferEncryptorMessageProto) ProtoMessage

func (*DataTransferEncryptorMessageProto) ProtoMessage()

func (*DataTransferEncryptorMessageProto) Reset

func (*DataTransferEncryptorMessageProto) String

type DataTransferEncryptorMessageProto_DataTransferEncryptorStatus

type DataTransferEncryptorMessageProto_DataTransferEncryptorStatus int32
const (
	DataTransferEncryptorMessageProto_SUCCESS           DataTransferEncryptorMessageProto_DataTransferEncryptorStatus = 0
	DataTransferEncryptorMessageProto_ERROR_UNKNOWN_KEY DataTransferEncryptorMessageProto_DataTransferEncryptorStatus = 1
	DataTransferEncryptorMessageProto_ERROR             DataTransferEncryptorMessageProto_DataTransferEncryptorStatus = 2
)

func (DataTransferEncryptorMessageProto_DataTransferEncryptorStatus) Enum

func (DataTransferEncryptorMessageProto_DataTransferEncryptorStatus) String

func (*DataTransferEncryptorMessageProto_DataTransferEncryptorStatus) UnmarshalJSON

type DatanodeIDProto

type DatanodeIDProto struct {
	IpAddr           *string `protobuf:"bytes,1,req,name=ipAddr" json:"ipAddr,omitempty"`
	HostName         *string `protobuf:"bytes,2,req,name=hostName" json:"hostName,omitempty"`
	StorageID        *string `protobuf:"bytes,3,req,name=storageID" json:"storageID,omitempty"`
	XferPort         *uint32 `protobuf:"varint,4,req,name=xferPort" json:"xferPort,omitempty"`
	InfoPort         *uint32 `protobuf:"varint,5,req,name=infoPort" json:"infoPort,omitempty"`
	IpcPort          *uint32 `protobuf:"varint,6,req,name=ipcPort" json:"ipcPort,omitempty"`
	InfoSecurePort   *uint32 `protobuf:"varint,7,opt,name=infoSecurePort,def=0" json:"infoSecurePort,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* Identifies a Datanode

func (*DatanodeIDProto) GetHostName

func (m *DatanodeIDProto) GetHostName() string

func (*DatanodeIDProto) GetInfoPort

func (m *DatanodeIDProto) GetInfoPort() uint32

func (*DatanodeIDProto) GetInfoSecurePort

func (m *DatanodeIDProto) GetInfoSecurePort() uint32

func (*DatanodeIDProto) GetIpAddr

func (m *DatanodeIDProto) GetIpAddr() string

func (*DatanodeIDProto) GetIpcPort

func (m *DatanodeIDProto) GetIpcPort() uint32

func (*DatanodeIDProto) GetStorageID

func (m *DatanodeIDProto) GetStorageID() string

func (*DatanodeIDProto) GetXferPort

func (m *DatanodeIDProto) GetXferPort() uint32

func (*DatanodeIDProto) ProtoMessage

func (*DatanodeIDProto) ProtoMessage()

func (*DatanodeIDProto) Reset

func (m *DatanodeIDProto) Reset()

func (*DatanodeIDProto) String

func (m *DatanodeIDProto) String() string

type DatanodeInfoProto

type DatanodeInfoProto struct {
	Id               *DatanodeIDProto              `protobuf:"bytes,1,req,name=id" json:"id,omitempty"`
	Capacity         *uint64                       `protobuf:"varint,2,opt,name=capacity,def=0" json:"capacity,omitempty"`
	DfsUsed          *uint64                       `protobuf:"varint,3,opt,name=dfsUsed,def=0" json:"dfsUsed,omitempty"`
	Remaining        *uint64                       `protobuf:"varint,4,opt,name=remaining,def=0" json:"remaining,omitempty"`
	BlockPoolUsed    *uint64                       `protobuf:"varint,5,opt,name=blockPoolUsed,def=0" json:"blockPoolUsed,omitempty"`
	LastUpdate       *uint64                       `protobuf:"varint,6,opt,name=lastUpdate,def=0" json:"lastUpdate,omitempty"`
	XceiverCount     *uint32                       `protobuf:"varint,7,opt,name=xceiverCount,def=0" json:"xceiverCount,omitempty"`
	Location         *string                       `protobuf:"bytes,8,opt,name=location" json:"location,omitempty"`
	AdminState       *DatanodeInfoProto_AdminState `protobuf:"varint,10,opt,name=adminState,enum=hadoop.hdfs.DatanodeInfoProto_AdminState,def=0" json:"adminState,omitempty"`
	XXX_unrecognized []byte                        `json:"-"`
}

* The status of a Datanode

func (*DatanodeInfoProto) GetAdminState

func (*DatanodeInfoProto) GetBlockPoolUsed

func (m *DatanodeInfoProto) GetBlockPoolUsed() uint64

func (*DatanodeInfoProto) GetCapacity

func (m *DatanodeInfoProto) GetCapacity() uint64

func (*DatanodeInfoProto) GetDfsUsed

func (m *DatanodeInfoProto) GetDfsUsed() uint64

func (*DatanodeInfoProto) GetId

func (m *DatanodeInfoProto) GetId() *DatanodeIDProto

func (*DatanodeInfoProto) GetLastUpdate

func (m *DatanodeInfoProto) GetLastUpdate() uint64

func (*DatanodeInfoProto) GetLocation

func (m *DatanodeInfoProto) GetLocation() string

func (*DatanodeInfoProto) GetRemaining

func (m *DatanodeInfoProto) GetRemaining() uint64

func (*DatanodeInfoProto) GetXceiverCount

func (m *DatanodeInfoProto) GetXceiverCount() uint32

func (*DatanodeInfoProto) ProtoMessage

func (*DatanodeInfoProto) ProtoMessage()

func (*DatanodeInfoProto) Reset

func (m *DatanodeInfoProto) Reset()

func (*DatanodeInfoProto) String

func (m *DatanodeInfoProto) String() string

type DatanodeInfoProto_AdminState

type DatanodeInfoProto_AdminState int32
const (
	DatanodeInfoProto_NORMAL                  DatanodeInfoProto_AdminState = 0
	DatanodeInfoProto_DECOMMISSION_INPROGRESS DatanodeInfoProto_AdminState = 1
	DatanodeInfoProto_DECOMMISSIONED          DatanodeInfoProto_AdminState = 2
)
const Default_DatanodeInfoProto_AdminState DatanodeInfoProto_AdminState = DatanodeInfoProto_NORMAL

func (DatanodeInfoProto_AdminState) Enum

func (DatanodeInfoProto_AdminState) String

func (*DatanodeInfoProto_AdminState) UnmarshalJSON

func (x *DatanodeInfoProto_AdminState) UnmarshalJSON(data []byte) error

type DatanodeInfosProto

type DatanodeInfosProto struct {
	Datanodes        []*DatanodeInfoProto `protobuf:"bytes,1,rep,name=datanodes" json:"datanodes,omitempty"`
	XXX_unrecognized []byte               `json:"-"`
}

* DatanodeInfo array

func (*DatanodeInfosProto) GetDatanodes

func (m *DatanodeInfosProto) GetDatanodes() []*DatanodeInfoProto

func (*DatanodeInfosProto) ProtoMessage

func (*DatanodeInfosProto) ProtoMessage()

func (*DatanodeInfosProto) Reset

func (m *DatanodeInfosProto) Reset()

func (*DatanodeInfosProto) String

func (m *DatanodeInfosProto) String() string

type DatanodeReportTypeProto

type DatanodeReportTypeProto int32
const (
	DatanodeReportTypeProto_ALL  DatanodeReportTypeProto = 1
	DatanodeReportTypeProto_LIVE DatanodeReportTypeProto = 2
	DatanodeReportTypeProto_DEAD DatanodeReportTypeProto = 3
)

func (DatanodeReportTypeProto) Enum

func (DatanodeReportTypeProto) String

func (x DatanodeReportTypeProto) String() string

func (*DatanodeReportTypeProto) UnmarshalJSON

func (x *DatanodeReportTypeProto) UnmarshalJSON(data []byte) error

type DeleteRequestProto

type DeleteRequestProto struct {
	Src              *string `protobuf:"bytes,1,req,name=src" json:"src,omitempty"`
	Recursive        *bool   `protobuf:"varint,2,req,name=recursive" json:"recursive,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*DeleteRequestProto) GetRecursive

func (m *DeleteRequestProto) GetRecursive() bool

func (*DeleteRequestProto) GetSrc

func (m *DeleteRequestProto) GetSrc() string

func (*DeleteRequestProto) ProtoMessage

func (*DeleteRequestProto) ProtoMessage()

func (*DeleteRequestProto) Reset

func (m *DeleteRequestProto) Reset()

func (*DeleteRequestProto) String

func (m *DeleteRequestProto) String() string

type DeleteResponseProto

type DeleteResponseProto struct {
	Result           *bool  `protobuf:"varint,1,req,name=result" json:"result,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*DeleteResponseProto) GetResult

func (m *DeleteResponseProto) GetResult() bool

func (*DeleteResponseProto) ProtoMessage

func (*DeleteResponseProto) ProtoMessage()

func (*DeleteResponseProto) Reset

func (m *DeleteResponseProto) Reset()

func (*DeleteResponseProto) String

func (m *DeleteResponseProto) String() string

type DeleteSnapshotRequestProto

type DeleteSnapshotRequestProto struct {
	SnapshotRoot     *string `protobuf:"bytes,1,req,name=snapshotRoot" json:"snapshotRoot,omitempty"`
	SnapshotName     *string `protobuf:"bytes,2,req,name=snapshotName" json:"snapshotName,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*DeleteSnapshotRequestProto) GetSnapshotName

func (m *DeleteSnapshotRequestProto) GetSnapshotName() string

func (*DeleteSnapshotRequestProto) GetSnapshotRoot

func (m *DeleteSnapshotRequestProto) GetSnapshotRoot() string

func (*DeleteSnapshotRequestProto) ProtoMessage

func (*DeleteSnapshotRequestProto) ProtoMessage()

func (*DeleteSnapshotRequestProto) Reset

func (m *DeleteSnapshotRequestProto) Reset()

func (*DeleteSnapshotRequestProto) String

func (m *DeleteSnapshotRequestProto) String() string

type DeleteSnapshotResponseProto

type DeleteSnapshotResponseProto struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*DeleteSnapshotResponseProto) ProtoMessage

func (*DeleteSnapshotResponseProto) ProtoMessage()

func (*DeleteSnapshotResponseProto) Reset

func (m *DeleteSnapshotResponseProto) Reset()

func (*DeleteSnapshotResponseProto) String

func (m *DeleteSnapshotResponseProto) String() string

type DirectoryListingProto

type DirectoryListingProto struct {
	PartialListing   []*HdfsFileStatusProto `protobuf:"bytes,1,rep,name=partialListing" json:"partialListing,omitempty"`
	RemainingEntries *uint32                `protobuf:"varint,2,req,name=remainingEntries" json:"remainingEntries,omitempty"`
	XXX_unrecognized []byte                 `json:"-"`
}

* Directory listing

func (*DirectoryListingProto) GetPartialListing

func (m *DirectoryListingProto) GetPartialListing() []*HdfsFileStatusProto

func (*DirectoryListingProto) GetRemainingEntries

func (m *DirectoryListingProto) GetRemainingEntries() uint32

func (*DirectoryListingProto) ProtoMessage

func (*DirectoryListingProto) ProtoMessage()

func (*DirectoryListingProto) Reset

func (m *DirectoryListingProto) Reset()

func (*DirectoryListingProto) String

func (m *DirectoryListingProto) String() string

type DisallowSnapshotRequestProto

type DisallowSnapshotRequestProto struct {
	SnapshotRoot     *string `protobuf:"bytes,1,req,name=snapshotRoot" json:"snapshotRoot,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*DisallowSnapshotRequestProto) GetSnapshotRoot

func (m *DisallowSnapshotRequestProto) GetSnapshotRoot() string

func (*DisallowSnapshotRequestProto) ProtoMessage

func (*DisallowSnapshotRequestProto) ProtoMessage()

func (*DisallowSnapshotRequestProto) Reset

func (m *DisallowSnapshotRequestProto) Reset()

func (*DisallowSnapshotRequestProto) String

type DisallowSnapshotResponseProto

type DisallowSnapshotResponseProto struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*DisallowSnapshotResponseProto) ProtoMessage

func (*DisallowSnapshotResponseProto) ProtoMessage()

func (*DisallowSnapshotResponseProto) Reset

func (m *DisallowSnapshotResponseProto) Reset()

func (*DisallowSnapshotResponseProto) String

type ExportedBlockKeysProto

type ExportedBlockKeysProto struct {
	IsBlockTokenEnabled *bool            `protobuf:"varint,1,req,name=isBlockTokenEnabled" json:"isBlockTokenEnabled,omitempty"`
	KeyUpdateInterval   *uint64          `protobuf:"varint,2,req,name=keyUpdateInterval" json:"keyUpdateInterval,omitempty"`
	TokenLifeTime       *uint64          `protobuf:"varint,3,req,name=tokenLifeTime" json:"tokenLifeTime,omitempty"`
	CurrentKey          *BlockKeyProto   `protobuf:"bytes,4,req,name=currentKey" json:"currentKey,omitempty"`
	AllKeys             []*BlockKeyProto `protobuf:"bytes,5,rep,name=allKeys" json:"allKeys,omitempty"`
	XXX_unrecognized    []byte           `json:"-"`
}

* Current key and set of block keys at the namenode.

func (*ExportedBlockKeysProto) GetAllKeys

func (m *ExportedBlockKeysProto) GetAllKeys() []*BlockKeyProto

func (*ExportedBlockKeysProto) GetCurrentKey

func (m *ExportedBlockKeysProto) GetCurrentKey() *BlockKeyProto

func (*ExportedBlockKeysProto) GetIsBlockTokenEnabled

func (m *ExportedBlockKeysProto) GetIsBlockTokenEnabled() bool

func (*ExportedBlockKeysProto) GetKeyUpdateInterval

func (m *ExportedBlockKeysProto) GetKeyUpdateInterval() uint64

func (*ExportedBlockKeysProto) GetTokenLifeTime

func (m *ExportedBlockKeysProto) GetTokenLifeTime() uint64

func (*ExportedBlockKeysProto) ProtoMessage

func (*ExportedBlockKeysProto) ProtoMessage()

func (*ExportedBlockKeysProto) Reset

func (m *ExportedBlockKeysProto) Reset()

func (*ExportedBlockKeysProto) String

func (m *ExportedBlockKeysProto) String() string

type ExtendedBlockProto

type ExtendedBlockProto struct {
	PoolId           *string `protobuf:"bytes,1,req,name=poolId" json:"poolId,omitempty"`
	BlockId          *uint64 `protobuf:"varint,2,req,name=blockId" json:"blockId,omitempty"`
	GenerationStamp  *uint64 `protobuf:"varint,3,req,name=generationStamp" json:"generationStamp,omitempty"`
	NumBytes         *uint64 `protobuf:"varint,4,opt,name=numBytes,def=0" json:"numBytes,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* Extended block idenfies a block

func (*ExtendedBlockProto) GetBlockId

func (m *ExtendedBlockProto) GetBlockId() uint64

func (*ExtendedBlockProto) GetGenerationStamp

func (m *ExtendedBlockProto) GetGenerationStamp() uint64

func (*ExtendedBlockProto) GetNumBytes

func (m *ExtendedBlockProto) GetNumBytes() uint64

func (*ExtendedBlockProto) GetPoolId

func (m *ExtendedBlockProto) GetPoolId() string

func (*ExtendedBlockProto) ProtoMessage

func (*ExtendedBlockProto) ProtoMessage()

func (*ExtendedBlockProto) Reset

func (m *ExtendedBlockProto) Reset()

func (*ExtendedBlockProto) String

func (m *ExtendedBlockProto) String() string

type FinalizeUpgradeRequestProto

type FinalizeUpgradeRequestProto struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*FinalizeUpgradeRequestProto) ProtoMessage

func (*FinalizeUpgradeRequestProto) ProtoMessage()

func (*FinalizeUpgradeRequestProto) Reset

func (m *FinalizeUpgradeRequestProto) Reset()

func (*FinalizeUpgradeRequestProto) String

func (m *FinalizeUpgradeRequestProto) String() string

type FinalizeUpgradeResponseProto

type FinalizeUpgradeResponseProto struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*FinalizeUpgradeResponseProto) ProtoMessage

func (*FinalizeUpgradeResponseProto) ProtoMessage()

func (*FinalizeUpgradeResponseProto) Reset

func (m *FinalizeUpgradeResponseProto) Reset()

func (*FinalizeUpgradeResponseProto) String

type FsPermissionProto

type FsPermissionProto struct {
	Perm             *uint32 `protobuf:"varint,1,req,name=perm" json:"perm,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* File or Directory permision - same spec as posix

func (*FsPermissionProto) GetPerm

func (m *FsPermissionProto) GetPerm() uint32

func (*FsPermissionProto) ProtoMessage

func (*FsPermissionProto) ProtoMessage()

func (*FsPermissionProto) Reset

func (m *FsPermissionProto) Reset()

func (*FsPermissionProto) String

func (m *FsPermissionProto) String() string

type FsServerDefaultsProto

type FsServerDefaultsProto struct {
	BlockSize           *uint64            `protobuf:"varint,1,req,name=blockSize" json:"blockSize,omitempty"`
	BytesPerChecksum    *uint32            `protobuf:"varint,2,req,name=bytesPerChecksum" json:"bytesPerChecksum,omitempty"`
	WritePacketSize     *uint32            `protobuf:"varint,3,req,name=writePacketSize" json:"writePacketSize,omitempty"`
	Replication         *uint32            `protobuf:"varint,4,req,name=replication" json:"replication,omitempty"`
	FileBufferSize      *uint32            `protobuf:"varint,5,req,name=fileBufferSize" json:"fileBufferSize,omitempty"`
	EncryptDataTransfer *bool              `protobuf:"varint,6,opt,name=encryptDataTransfer,def=0" json:"encryptDataTransfer,omitempty"`
	TrashInterval       *uint64            `protobuf:"varint,7,opt,name=trashInterval,def=0" json:"trashInterval,omitempty"`
	ChecksumType        *ChecksumTypeProto `protobuf:"varint,8,opt,name=checksumType,enum=hadoop.hdfs.ChecksumTypeProto,def=1" json:"checksumType,omitempty"`
	XXX_unrecognized    []byte             `json:"-"`
}

* HDFS Server Defaults

func (*FsServerDefaultsProto) GetBlockSize

func (m *FsServerDefaultsProto) GetBlockSize() uint64

func (*FsServerDefaultsProto) GetBytesPerChecksum

func (m *FsServerDefaultsProto) GetBytesPerChecksum() uint32

func (*FsServerDefaultsProto) GetChecksumType

func (m *FsServerDefaultsProto) GetChecksumType() ChecksumTypeProto

func (*FsServerDefaultsProto) GetEncryptDataTransfer

func (m *FsServerDefaultsProto) GetEncryptDataTransfer() bool

func (*FsServerDefaultsProto) GetFileBufferSize

func (m *FsServerDefaultsProto) GetFileBufferSize() uint32

func (*FsServerDefaultsProto) GetReplication

func (m *FsServerDefaultsProto) GetReplication() uint32

func (*FsServerDefaultsProto) GetTrashInterval

func (m *FsServerDefaultsProto) GetTrashInterval() uint64

func (*FsServerDefaultsProto) GetWritePacketSize

func (m *FsServerDefaultsProto) GetWritePacketSize() uint32

func (*FsServerDefaultsProto) ProtoMessage

func (*FsServerDefaultsProto) ProtoMessage()

func (*FsServerDefaultsProto) Reset

func (m *FsServerDefaultsProto) Reset()

func (*FsServerDefaultsProto) String

func (m *FsServerDefaultsProto) String() string

type FsyncRequestProto

type FsyncRequestProto struct {
	Src              *string `protobuf:"bytes,1,req,name=src" json:"src,omitempty"`
	Client           *string `protobuf:"bytes,2,req,name=client" json:"client,omitempty"`
	LastBlockLength  *int64  `protobuf:"zigzag64,3,opt,name=lastBlockLength,def=-1" json:"lastBlockLength,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*FsyncRequestProto) GetClient

func (m *FsyncRequestProto) GetClient() string

func (*FsyncRequestProto) GetLastBlockLength

func (m *FsyncRequestProto) GetLastBlockLength() int64

func (*FsyncRequestProto) GetSrc

func (m *FsyncRequestProto) GetSrc() string

func (*FsyncRequestProto) ProtoMessage

func (*FsyncRequestProto) ProtoMessage()

func (*FsyncRequestProto) Reset

func (m *FsyncRequestProto) Reset()

func (*FsyncRequestProto) String

func (m *FsyncRequestProto) String() string

type FsyncResponseProto

type FsyncResponseProto struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*FsyncResponseProto) ProtoMessage

func (*FsyncResponseProto) ProtoMessage()

func (*FsyncResponseProto) Reset

func (m *FsyncResponseProto) Reset()

func (*FsyncResponseProto) String

func (m *FsyncResponseProto) String() string

type GetAdditionalDatanodeRequestProto

type GetAdditionalDatanodeRequestProto struct {
	Src                *string              `protobuf:"bytes,1,req,name=src" json:"src,omitempty"`
	Blk                *ExtendedBlockProto  `protobuf:"bytes,2,req,name=blk" json:"blk,omitempty"`
	Existings          []*DatanodeInfoProto `protobuf:"bytes,3,rep,name=existings" json:"existings,omitempty"`
	Excludes           []*DatanodeInfoProto `protobuf:"bytes,4,rep,name=excludes" json:"excludes,omitempty"`
	NumAdditionalNodes *uint32              `protobuf:"varint,5,req,name=numAdditionalNodes" json:"numAdditionalNodes,omitempty"`
	ClientName         *string              `protobuf:"bytes,6,req,name=clientName" json:"clientName,omitempty"`
	XXX_unrecognized   []byte               `json:"-"`
}

func (*GetAdditionalDatanodeRequestProto) GetBlk

func (*GetAdditionalDatanodeRequestProto) GetClientName

func (m *GetAdditionalDatanodeRequestProto) GetClientName() string

func (*GetAdditionalDatanodeRequestProto) GetExcludes

func (*GetAdditionalDatanodeRequestProto) GetExistings

func (*GetAdditionalDatanodeRequestProto) GetNumAdditionalNodes

func (m *GetAdditionalDatanodeRequestProto) GetNumAdditionalNodes() uint32

func (*GetAdditionalDatanodeRequestProto) GetSrc

func (*GetAdditionalDatanodeRequestProto) ProtoMessage

func (*GetAdditionalDatanodeRequestProto) ProtoMessage()

func (*GetAdditionalDatanodeRequestProto) Reset

func (*GetAdditionalDatanodeRequestProto) String

type GetAdditionalDatanodeResponseProto

type GetAdditionalDatanodeResponseProto struct {
	Block            *LocatedBlockProto `protobuf:"bytes,1,req,name=block" json:"block,omitempty"`
	XXX_unrecognized []byte             `json:"-"`
}

func (*GetAdditionalDatanodeResponseProto) GetBlock

func (*GetAdditionalDatanodeResponseProto) ProtoMessage

func (*GetAdditionalDatanodeResponseProto) ProtoMessage()

func (*GetAdditionalDatanodeResponseProto) Reset

func (*GetAdditionalDatanodeResponseProto) String

type GetBlockLocationsRequestProto

type GetBlockLocationsRequestProto struct {
	Src              *string `protobuf:"bytes,1,req,name=src" json:"src,omitempty"`
	Offset           *uint64 `protobuf:"varint,2,req,name=offset" json:"offset,omitempty"`
	Length           *uint64 `protobuf:"varint,3,req,name=length" json:"length,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*GetBlockLocationsRequestProto) GetLength

func (m *GetBlockLocationsRequestProto) GetLength() uint64

func (*GetBlockLocationsRequestProto) GetOffset

func (m *GetBlockLocationsRequestProto) GetOffset() uint64

func (*GetBlockLocationsRequestProto) GetSrc

func (*GetBlockLocationsRequestProto) ProtoMessage

func (*GetBlockLocationsRequestProto) ProtoMessage()

func (*GetBlockLocationsRequestProto) Reset

func (m *GetBlockLocationsRequestProto) Reset()

func (*GetBlockLocationsRequestProto) String

type GetBlockLocationsResponseProto

type GetBlockLocationsResponseProto struct {
	Locations        *LocatedBlocksProto `protobuf:"bytes,1,opt,name=locations" json:"locations,omitempty"`
	XXX_unrecognized []byte              `json:"-"`
}

func (*GetBlockLocationsResponseProto) GetLocations

func (*GetBlockLocationsResponseProto) ProtoMessage

func (*GetBlockLocationsResponseProto) ProtoMessage()

func (*GetBlockLocationsResponseProto) Reset

func (m *GetBlockLocationsResponseProto) Reset()

func (*GetBlockLocationsResponseProto) String

type GetContentSummaryRequestProto

type GetContentSummaryRequestProto struct {
	Path             *string `protobuf:"bytes,1,req,name=path" json:"path,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*GetContentSummaryRequestProto) GetPath

func (*GetContentSummaryRequestProto) ProtoMessage

func (*GetContentSummaryRequestProto) ProtoMessage()

func (*GetContentSummaryRequestProto) Reset

func (m *GetContentSummaryRequestProto) Reset()

func (*GetContentSummaryRequestProto) String

type GetContentSummaryResponseProto

type GetContentSummaryResponseProto struct {
	Summary          *ContentSummaryProto `protobuf:"bytes,1,req,name=summary" json:"summary,omitempty"`
	XXX_unrecognized []byte               `json:"-"`
}

func (*GetContentSummaryResponseProto) GetSummary

func (*GetContentSummaryResponseProto) ProtoMessage

func (*GetContentSummaryResponseProto) ProtoMessage()

func (*GetContentSummaryResponseProto) Reset

func (m *GetContentSummaryResponseProto) Reset()

func (*GetContentSummaryResponseProto) String

type GetDataEncryptionKeyRequestProto

type GetDataEncryptionKeyRequestProto struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*GetDataEncryptionKeyRequestProto) ProtoMessage

func (*GetDataEncryptionKeyRequestProto) ProtoMessage()

func (*GetDataEncryptionKeyRequestProto) Reset

func (*GetDataEncryptionKeyRequestProto) String

type GetDataEncryptionKeyResponseProto

type GetDataEncryptionKeyResponseProto struct {
	DataEncryptionKey *DataEncryptionKeyProto `protobuf:"bytes,1,opt,name=dataEncryptionKey" json:"dataEncryptionKey,omitempty"`
	XXX_unrecognized  []byte                  `json:"-"`
}

func (*GetDataEncryptionKeyResponseProto) GetDataEncryptionKey

func (m *GetDataEncryptionKeyResponseProto) GetDataEncryptionKey() *DataEncryptionKeyProto

func (*GetDataEncryptionKeyResponseProto) ProtoMessage

func (*GetDataEncryptionKeyResponseProto) ProtoMessage()

func (*GetDataEncryptionKeyResponseProto) Reset

func (*GetDataEncryptionKeyResponseProto) String

type GetDatanodeReportRequestProto

type GetDatanodeReportRequestProto struct {
	Type             *DatanodeReportTypeProto `protobuf:"varint,1,req,name=type,enum=hadoop.hdfs.DatanodeReportTypeProto" json:"type,omitempty"`
	XXX_unrecognized []byte                   `json:"-"`
}

func (*GetDatanodeReportRequestProto) GetType

func (*GetDatanodeReportRequestProto) ProtoMessage

func (*GetDatanodeReportRequestProto) ProtoMessage()

func (*GetDatanodeReportRequestProto) Reset

func (m *GetDatanodeReportRequestProto) Reset()

func (*GetDatanodeReportRequestProto) String

type GetDatanodeReportResponseProto

type GetDatanodeReportResponseProto struct {
	Di               []*DatanodeInfoProto `protobuf:"bytes,1,rep,name=di" json:"di,omitempty"`
	XXX_unrecognized []byte               `json:"-"`
}

func (*GetDatanodeReportResponseProto) GetDi

func (*GetDatanodeReportResponseProto) ProtoMessage

func (*GetDatanodeReportResponseProto) ProtoMessage()

func (*GetDatanodeReportResponseProto) Reset

func (m *GetDatanodeReportResponseProto) Reset()

func (*GetDatanodeReportResponseProto) String

type GetFileInfoRequestProto

type GetFileInfoRequestProto struct {
	Src              *string `protobuf:"bytes,1,req,name=src" json:"src,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*GetFileInfoRequestProto) GetSrc

func (m *GetFileInfoRequestProto) GetSrc() string

func (*GetFileInfoRequestProto) ProtoMessage

func (*GetFileInfoRequestProto) ProtoMessage()

func (*GetFileInfoRequestProto) Reset

func (m *GetFileInfoRequestProto) Reset()

func (*GetFileInfoRequestProto) String

func (m *GetFileInfoRequestProto) String() string

type GetFileInfoResponseProto

type GetFileInfoResponseProto struct {
	Fs               *HdfsFileStatusProto `protobuf:"bytes,1,opt,name=fs" json:"fs,omitempty"`
	XXX_unrecognized []byte               `json:"-"`
}

func (*GetFileInfoResponseProto) GetFs

func (*GetFileInfoResponseProto) ProtoMessage

func (*GetFileInfoResponseProto) ProtoMessage()

func (*GetFileInfoResponseProto) Reset

func (m *GetFileInfoResponseProto) Reset()

func (*GetFileInfoResponseProto) String

func (m *GetFileInfoResponseProto) String() string

type GetFileLinkInfoRequestProto

type GetFileLinkInfoRequestProto struct {
	Src              *string `protobuf:"bytes,1,req,name=src" json:"src,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*GetFileLinkInfoRequestProto) GetSrc

func (m *GetFileLinkInfoRequestProto) GetSrc() string

func (*GetFileLinkInfoRequestProto) ProtoMessage

func (*GetFileLinkInfoRequestProto) ProtoMessage()

func (*GetFileLinkInfoRequestProto) Reset

func (m *GetFileLinkInfoRequestProto) Reset()

func (*GetFileLinkInfoRequestProto) String

func (m *GetFileLinkInfoRequestProto) String() string

type GetFileLinkInfoResponseProto

type GetFileLinkInfoResponseProto struct {
	Fs               *HdfsFileStatusProto `protobuf:"bytes,1,opt,name=fs" json:"fs,omitempty"`
	XXX_unrecognized []byte               `json:"-"`
}

func (*GetFileLinkInfoResponseProto) GetFs

func (*GetFileLinkInfoResponseProto) ProtoMessage

func (*GetFileLinkInfoResponseProto) ProtoMessage()

func (*GetFileLinkInfoResponseProto) Reset

func (m *GetFileLinkInfoResponseProto) Reset()

func (*GetFileLinkInfoResponseProto) String

type GetFsStatsResponseProto

type GetFsStatsResponseProto struct {
	Capacity         *uint64 `protobuf:"varint,1,req,name=capacity" json:"capacity,omitempty"`
	Used             *uint64 `protobuf:"varint,2,req,name=used" json:"used,omitempty"`
	Remaining        *uint64 `protobuf:"varint,3,req,name=remaining" json:"remaining,omitempty"`
	UnderReplicated  *uint64 `protobuf:"varint,4,req,name=under_replicated" json:"under_replicated,omitempty"`
	CorruptBlocks    *uint64 `protobuf:"varint,5,req,name=corrupt_blocks" json:"corrupt_blocks,omitempty"`
	MissingBlocks    *uint64 `protobuf:"varint,6,req,name=missing_blocks" json:"missing_blocks,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*GetFsStatsResponseProto) GetCapacity

func (m *GetFsStatsResponseProto) GetCapacity() uint64

func (*GetFsStatsResponseProto) GetCorruptBlocks

func (m *GetFsStatsResponseProto) GetCorruptBlocks() uint64

func (*GetFsStatsResponseProto) GetMissingBlocks

func (m *GetFsStatsResponseProto) GetMissingBlocks() uint64

func (*GetFsStatsResponseProto) GetRemaining

func (m *GetFsStatsResponseProto) GetRemaining() uint64

func (*GetFsStatsResponseProto) GetUnderReplicated

func (m *GetFsStatsResponseProto) GetUnderReplicated() uint64

func (*GetFsStatsResponseProto) GetUsed

func (m *GetFsStatsResponseProto) GetUsed() uint64

func (*GetFsStatsResponseProto) ProtoMessage

func (*GetFsStatsResponseProto) ProtoMessage()

func (*GetFsStatsResponseProto) Reset

func (m *GetFsStatsResponseProto) Reset()

func (*GetFsStatsResponseProto) String

func (m *GetFsStatsResponseProto) String() string

type GetFsStatusRequestProto

type GetFsStatusRequestProto struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*GetFsStatusRequestProto) ProtoMessage

func (*GetFsStatusRequestProto) ProtoMessage()

func (*GetFsStatusRequestProto) Reset

func (m *GetFsStatusRequestProto) Reset()

func (*GetFsStatusRequestProto) String

func (m *GetFsStatusRequestProto) String() string

type GetLinkTargetRequestProto

type GetLinkTargetRequestProto struct {
	Path             *string `protobuf:"bytes,1,req,name=path" json:"path,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*GetLinkTargetRequestProto) GetPath

func (m *GetLinkTargetRequestProto) GetPath() string

func (*GetLinkTargetRequestProto) ProtoMessage

func (*GetLinkTargetRequestProto) ProtoMessage()

func (*GetLinkTargetRequestProto) Reset

func (m *GetLinkTargetRequestProto) Reset()

func (*GetLinkTargetRequestProto) String

func (m *GetLinkTargetRequestProto) String() string

type GetLinkTargetResponseProto

type GetLinkTargetResponseProto struct {
	TargetPath       *string `protobuf:"bytes,1,opt,name=targetPath" json:"targetPath,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*GetLinkTargetResponseProto) GetTargetPath

func (m *GetLinkTargetResponseProto) GetTargetPath() string

func (*GetLinkTargetResponseProto) ProtoMessage

func (*GetLinkTargetResponseProto) ProtoMessage()

func (*GetLinkTargetResponseProto) Reset

func (m *GetLinkTargetResponseProto) Reset()

func (*GetLinkTargetResponseProto) String

func (m *GetLinkTargetResponseProto) String() string

type GetListingRequestProto

type GetListingRequestProto struct {
	Src              *string `protobuf:"bytes,1,req,name=src" json:"src,omitempty"`
	StartAfter       []byte  `protobuf:"bytes,2,req,name=startAfter" json:"startAfter,omitempty"`
	NeedLocation     *bool   `protobuf:"varint,3,req,name=needLocation" json:"needLocation,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*GetListingRequestProto) GetNeedLocation

func (m *GetListingRequestProto) GetNeedLocation() bool

func (*GetListingRequestProto) GetSrc

func (m *GetListingRequestProto) GetSrc() string

func (*GetListingRequestProto) GetStartAfter

func (m *GetListingRequestProto) GetStartAfter() []byte

func (*GetListingRequestProto) ProtoMessage

func (*GetListingRequestProto) ProtoMessage()

func (*GetListingRequestProto) Reset

func (m *GetListingRequestProto) Reset()

func (*GetListingRequestProto) String

func (m *GetListingRequestProto) String() string

type GetListingResponseProto

type GetListingResponseProto struct {
	DirList          *DirectoryListingProto `protobuf:"bytes,1,opt,name=dirList" json:"dirList,omitempty"`
	XXX_unrecognized []byte                 `json:"-"`
}

func (*GetListingResponseProto) GetDirList

func (*GetListingResponseProto) ProtoMessage

func (*GetListingResponseProto) ProtoMessage()

func (*GetListingResponseProto) Reset

func (m *GetListingResponseProto) Reset()

func (*GetListingResponseProto) String

func (m *GetListingResponseProto) String() string

type GetPreferredBlockSizeRequestProto

type GetPreferredBlockSizeRequestProto struct {
	Filename         *string `protobuf:"bytes,1,req,name=filename" json:"filename,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*GetPreferredBlockSizeRequestProto) GetFilename

func (m *GetPreferredBlockSizeRequestProto) GetFilename() string

func (*GetPreferredBlockSizeRequestProto) ProtoMessage

func (*GetPreferredBlockSizeRequestProto) ProtoMessage()

func (*GetPreferredBlockSizeRequestProto) Reset

func (*GetPreferredBlockSizeRequestProto) String

type GetPreferredBlockSizeResponseProto

type GetPreferredBlockSizeResponseProto struct {
	Bsize            *uint64 `protobuf:"varint,1,req,name=bsize" json:"bsize,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*GetPreferredBlockSizeResponseProto) GetBsize

func (*GetPreferredBlockSizeResponseProto) ProtoMessage

func (*GetPreferredBlockSizeResponseProto) ProtoMessage()

func (*GetPreferredBlockSizeResponseProto) Reset

func (*GetPreferredBlockSizeResponseProto) String

type GetServerDefaultsRequestProto

type GetServerDefaultsRequestProto struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*GetServerDefaultsRequestProto) ProtoMessage

func (*GetServerDefaultsRequestProto) ProtoMessage()

func (*GetServerDefaultsRequestProto) Reset

func (m *GetServerDefaultsRequestProto) Reset()

func (*GetServerDefaultsRequestProto) String

type GetServerDefaultsResponseProto

type GetServerDefaultsResponseProto struct {
	ServerDefaults   *FsServerDefaultsProto `protobuf:"bytes,1,req,name=serverDefaults" json:"serverDefaults,omitempty"`
	XXX_unrecognized []byte                 `json:"-"`
}

func (*GetServerDefaultsResponseProto) GetServerDefaults

func (m *GetServerDefaultsResponseProto) GetServerDefaults() *FsServerDefaultsProto

func (*GetServerDefaultsResponseProto) ProtoMessage

func (*GetServerDefaultsResponseProto) ProtoMessage()

func (*GetServerDefaultsResponseProto) Reset

func (m *GetServerDefaultsResponseProto) Reset()

func (*GetServerDefaultsResponseProto) String

type GetSnapshotDiffReportRequestProto

type GetSnapshotDiffReportRequestProto struct {
	SnapshotRoot     *string `protobuf:"bytes,1,req,name=snapshotRoot" json:"snapshotRoot,omitempty"`
	FromSnapshot     *string `protobuf:"bytes,2,req,name=fromSnapshot" json:"fromSnapshot,omitempty"`
	ToSnapshot       *string `protobuf:"bytes,3,req,name=toSnapshot" json:"toSnapshot,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*GetSnapshotDiffReportRequestProto) GetFromSnapshot

func (m *GetSnapshotDiffReportRequestProto) GetFromSnapshot() string

func (*GetSnapshotDiffReportRequestProto) GetSnapshotRoot

func (m *GetSnapshotDiffReportRequestProto) GetSnapshotRoot() string

func (*GetSnapshotDiffReportRequestProto) GetToSnapshot

func (m *GetSnapshotDiffReportRequestProto) GetToSnapshot() string

func (*GetSnapshotDiffReportRequestProto) ProtoMessage

func (*GetSnapshotDiffReportRequestProto) ProtoMessage()

func (*GetSnapshotDiffReportRequestProto) Reset

func (*GetSnapshotDiffReportRequestProto) String

type GetSnapshotDiffReportResponseProto

type GetSnapshotDiffReportResponseProto struct {
	DiffReport       *SnapshotDiffReportProto `protobuf:"bytes,1,req,name=diffReport" json:"diffReport,omitempty"`
	XXX_unrecognized []byte                   `json:"-"`
}

func (*GetSnapshotDiffReportResponseProto) GetDiffReport

func (*GetSnapshotDiffReportResponseProto) ProtoMessage

func (*GetSnapshotDiffReportResponseProto) ProtoMessage()

func (*GetSnapshotDiffReportResponseProto) Reset

func (*GetSnapshotDiffReportResponseProto) String

type GetSnapshottableDirListingRequestProto

type GetSnapshottableDirListingRequestProto struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*GetSnapshottableDirListingRequestProto) ProtoMessage

func (*GetSnapshottableDirListingRequestProto) Reset

func (*GetSnapshottableDirListingRequestProto) String

type GetSnapshottableDirListingResponseProto

type GetSnapshottableDirListingResponseProto struct {
	SnapshottableDirList *SnapshottableDirectoryListingProto `protobuf:"bytes,1,opt,name=snapshottableDirList" json:"snapshottableDirList,omitempty"`
	XXX_unrecognized     []byte                              `json:"-"`
}

func (*GetSnapshottableDirListingResponseProto) GetSnapshottableDirList

func (*GetSnapshottableDirListingResponseProto) ProtoMessage

func (*GetSnapshottableDirListingResponseProto) Reset

func (*GetSnapshottableDirListingResponseProto) String

type HdfsFileStatusProto

type HdfsFileStatusProto struct {
	FileType         *HdfsFileStatusProto_FileType `protobuf:"varint,1,req,name=fileType,enum=hadoop.hdfs.HdfsFileStatusProto_FileType" json:"fileType,omitempty"`
	Path             []byte                        `protobuf:"bytes,2,req,name=path" json:"path,omitempty"`
	Length           *uint64                       `protobuf:"varint,3,req,name=length" json:"length,omitempty"`
	Permission       *FsPermissionProto            `protobuf:"bytes,4,req,name=permission" json:"permission,omitempty"`
	Owner            *string                       `protobuf:"bytes,5,req,name=owner" json:"owner,omitempty"`
	Group            *string                       `protobuf:"bytes,6,req,name=group" json:"group,omitempty"`
	ModificationTime *uint64                       `protobuf:"varint,7,req,name=modification_time" json:"modification_time,omitempty"`
	AccessTime       *uint64                       `protobuf:"varint,8,req,name=access_time" json:"access_time,omitempty"`
	// Optional fields for symlink
	Symlink []byte `protobuf:"bytes,9,opt,name=symlink" json:"symlink,omitempty"`
	// Optional fields for file
	BlockReplication *uint32             `protobuf:"varint,10,opt,name=block_replication,def=0" json:"block_replication,omitempty"`
	Blocksize        *uint64             `protobuf:"varint,11,opt,name=blocksize,def=0" json:"blocksize,omitempty"`
	Locations        *LocatedBlocksProto `protobuf:"bytes,12,opt,name=locations" json:"locations,omitempty"`
	// Optional field for fileId
	FileId           *uint64 `protobuf:"varint,13,opt,name=fileId,def=0" json:"fileId,omitempty"`
	ChildrenNum      *int32  `protobuf:"varint,14,opt,name=childrenNum,def=-1" json:"childrenNum,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* Status of a file, directory or symlink Optionally includes a file's block locations if requested by client on the rpc call.

func (*HdfsFileStatusProto) GetAccessTime

func (m *HdfsFileStatusProto) GetAccessTime() uint64

func (*HdfsFileStatusProto) GetBlockReplication

func (m *HdfsFileStatusProto) GetBlockReplication() uint32

func (*HdfsFileStatusProto) GetBlocksize

func (m *HdfsFileStatusProto) GetBlocksize() uint64

func (*HdfsFileStatusProto) GetChildrenNum

func (m *HdfsFileStatusProto) GetChildrenNum() int32

func (*HdfsFileStatusProto) GetFileId

func (m *HdfsFileStatusProto) GetFileId() uint64

func (*HdfsFileStatusProto) GetFileType

func (*HdfsFileStatusProto) GetGroup

func (m *HdfsFileStatusProto) GetGroup() string

func (*HdfsFileStatusProto) GetLength

func (m *HdfsFileStatusProto) GetLength() uint64

func (*HdfsFileStatusProto) GetLocations

func (m *HdfsFileStatusProto) GetLocations() *LocatedBlocksProto

func (*HdfsFileStatusProto) GetModificationTime

func (m *HdfsFileStatusProto) GetModificationTime() uint64

func (*HdfsFileStatusProto) GetOwner

func (m *HdfsFileStatusProto) GetOwner() string

func (*HdfsFileStatusProto) GetPath

func (m *HdfsFileStatusProto) GetPath() []byte

func (*HdfsFileStatusProto) GetPermission

func (m *HdfsFileStatusProto) GetPermission() *FsPermissionProto
func (m *HdfsFileStatusProto) GetSymlink() []byte

func (*HdfsFileStatusProto) ProtoMessage

func (*HdfsFileStatusProto) ProtoMessage()

func (*HdfsFileStatusProto) Reset

func (m *HdfsFileStatusProto) Reset()

func (*HdfsFileStatusProto) String

func (m *HdfsFileStatusProto) String() string

type HdfsFileStatusProto_FileType

type HdfsFileStatusProto_FileType int32
const (
	HdfsFileStatusProto_IS_DIR     HdfsFileStatusProto_FileType = 1
	HdfsFileStatusProto_IS_FILE    HdfsFileStatusProto_FileType = 2
	HdfsFileStatusProto_IS_SYMLINK HdfsFileStatusProto_FileType = 3
)

func (HdfsFileStatusProto_FileType) Enum

func (HdfsFileStatusProto_FileType) String

func (*HdfsFileStatusProto_FileType) UnmarshalJSON

func (x *HdfsFileStatusProto_FileType) UnmarshalJSON(data []byte) error

type IsFileClosedRequestProto

type IsFileClosedRequestProto struct {
	Src              *string `protobuf:"bytes,1,req,name=src" json:"src,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*IsFileClosedRequestProto) GetSrc

func (m *IsFileClosedRequestProto) GetSrc() string

func (*IsFileClosedRequestProto) ProtoMessage

func (*IsFileClosedRequestProto) ProtoMessage()

func (*IsFileClosedRequestProto) Reset

func (m *IsFileClosedRequestProto) Reset()

func (*IsFileClosedRequestProto) String

func (m *IsFileClosedRequestProto) String() string

type IsFileClosedResponseProto

type IsFileClosedResponseProto struct {
	Result           *bool  `protobuf:"varint,1,req,name=result" json:"result,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*IsFileClosedResponseProto) GetResult

func (m *IsFileClosedResponseProto) GetResult() bool

func (*IsFileClosedResponseProto) ProtoMessage

func (*IsFileClosedResponseProto) ProtoMessage()

func (*IsFileClosedResponseProto) Reset

func (m *IsFileClosedResponseProto) Reset()

func (*IsFileClosedResponseProto) String

func (m *IsFileClosedResponseProto) String() string

type ListCorruptFileBlocksRequestProto

type ListCorruptFileBlocksRequestProto struct {
	Path             *string `protobuf:"bytes,1,req,name=path" json:"path,omitempty"`
	Cookie           *string `protobuf:"bytes,2,opt,name=cookie" json:"cookie,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*ListCorruptFileBlocksRequestProto) GetCookie

func (*ListCorruptFileBlocksRequestProto) GetPath

func (*ListCorruptFileBlocksRequestProto) ProtoMessage

func (*ListCorruptFileBlocksRequestProto) ProtoMessage()

func (*ListCorruptFileBlocksRequestProto) Reset

func (*ListCorruptFileBlocksRequestProto) String

type ListCorruptFileBlocksResponseProto

type ListCorruptFileBlocksResponseProto struct {
	Corrupt          *CorruptFileBlocksProto `protobuf:"bytes,1,req,name=corrupt" json:"corrupt,omitempty"`
	XXX_unrecognized []byte                  `json:"-"`
}

func (*ListCorruptFileBlocksResponseProto) GetCorrupt

func (*ListCorruptFileBlocksResponseProto) ProtoMessage

func (*ListCorruptFileBlocksResponseProto) ProtoMessage()

func (*ListCorruptFileBlocksResponseProto) Reset

func (*ListCorruptFileBlocksResponseProto) String

type LocatedBlockProto

type LocatedBlockProto struct {
	B                *ExtendedBlockProto       `protobuf:"bytes,1,req,name=b" json:"b,omitempty"`
	Offset           *uint64                   `protobuf:"varint,2,req,name=offset" json:"offset,omitempty"`
	Locs             []*DatanodeInfoProto      `protobuf:"bytes,3,rep,name=locs" json:"locs,omitempty"`
	Corrupt          *bool                     `protobuf:"varint,4,req,name=corrupt" json:"corrupt,omitempty"`
	BlockToken       *hadoop_common.TokenProto `protobuf:"bytes,5,req,name=blockToken" json:"blockToken,omitempty"`
	XXX_unrecognized []byte                    `json:"-"`
}

* A LocatedBlock gives information about a block and its location.

func (*LocatedBlockProto) GetB

func (*LocatedBlockProto) GetBlockToken

func (m *LocatedBlockProto) GetBlockToken() *hadoop_common.TokenProto

func (*LocatedBlockProto) GetCorrupt

func (m *LocatedBlockProto) GetCorrupt() bool

func (*LocatedBlockProto) GetLocs

func (m *LocatedBlockProto) GetLocs() []*DatanodeInfoProto

func (*LocatedBlockProto) GetOffset

func (m *LocatedBlockProto) GetOffset() uint64

func (*LocatedBlockProto) ProtoMessage

func (*LocatedBlockProto) ProtoMessage()

func (*LocatedBlockProto) Reset

func (m *LocatedBlockProto) Reset()

func (*LocatedBlockProto) String

func (m *LocatedBlockProto) String() string

type LocatedBlocksProto

type LocatedBlocksProto struct {
	FileLength          *uint64              `protobuf:"varint,1,req,name=fileLength" json:"fileLength,omitempty"`
	Blocks              []*LocatedBlockProto `protobuf:"bytes,2,rep,name=blocks" json:"blocks,omitempty"`
	UnderConstruction   *bool                `protobuf:"varint,3,req,name=underConstruction" json:"underConstruction,omitempty"`
	LastBlock           *LocatedBlockProto   `protobuf:"bytes,4,opt,name=lastBlock" json:"lastBlock,omitempty"`
	IsLastBlockComplete *bool                `protobuf:"varint,5,req,name=isLastBlockComplete" json:"isLastBlockComplete,omitempty"`
	XXX_unrecognized    []byte               `json:"-"`
}

* A set of file blocks and their locations.

func (*LocatedBlocksProto) GetBlocks

func (m *LocatedBlocksProto) GetBlocks() []*LocatedBlockProto

func (*LocatedBlocksProto) GetFileLength

func (m *LocatedBlocksProto) GetFileLength() uint64

func (*LocatedBlocksProto) GetIsLastBlockComplete

func (m *LocatedBlocksProto) GetIsLastBlockComplete() bool

func (*LocatedBlocksProto) GetLastBlock

func (m *LocatedBlocksProto) GetLastBlock() *LocatedBlockProto

func (*LocatedBlocksProto) GetUnderConstruction

func (m *LocatedBlocksProto) GetUnderConstruction() bool

func (*LocatedBlocksProto) ProtoMessage

func (*LocatedBlocksProto) ProtoMessage()

func (*LocatedBlocksProto) Reset

func (m *LocatedBlocksProto) Reset()

func (*LocatedBlocksProto) String

func (m *LocatedBlocksProto) String() string

type MetaSaveRequestProto

type MetaSaveRequestProto struct {
	Filename         *string `protobuf:"bytes,1,req,name=filename" json:"filename,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*MetaSaveRequestProto) GetFilename

func (m *MetaSaveRequestProto) GetFilename() string

func (*MetaSaveRequestProto) ProtoMessage

func (*MetaSaveRequestProto) ProtoMessage()

func (*MetaSaveRequestProto) Reset

func (m *MetaSaveRequestProto) Reset()

func (*MetaSaveRequestProto) String

func (m *MetaSaveRequestProto) String() string

type MetaSaveResponseProto

type MetaSaveResponseProto struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*MetaSaveResponseProto) ProtoMessage

func (*MetaSaveResponseProto) ProtoMessage()

func (*MetaSaveResponseProto) Reset

func (m *MetaSaveResponseProto) Reset()

func (*MetaSaveResponseProto) String

func (m *MetaSaveResponseProto) String() string

type MkdirsRequestProto

type MkdirsRequestProto struct {
	Src              *string            `protobuf:"bytes,1,req,name=src" json:"src,omitempty"`
	Masked           *FsPermissionProto `protobuf:"bytes,2,req,name=masked" json:"masked,omitempty"`
	CreateParent     *bool              `protobuf:"varint,3,req,name=createParent" json:"createParent,omitempty"`
	XXX_unrecognized []byte             `json:"-"`
}

func (*MkdirsRequestProto) GetCreateParent

func (m *MkdirsRequestProto) GetCreateParent() bool

func (*MkdirsRequestProto) GetMasked

func (m *MkdirsRequestProto) GetMasked() *FsPermissionProto

func (*MkdirsRequestProto) GetSrc

func (m *MkdirsRequestProto) GetSrc() string

func (*MkdirsRequestProto) ProtoMessage

func (*MkdirsRequestProto) ProtoMessage()

func (*MkdirsRequestProto) Reset

func (m *MkdirsRequestProto) Reset()

func (*MkdirsRequestProto) String

func (m *MkdirsRequestProto) String() string

type MkdirsResponseProto

type MkdirsResponseProto struct {
	Result           *bool  `protobuf:"varint,1,req,name=result" json:"result,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*MkdirsResponseProto) GetResult

func (m *MkdirsResponseProto) GetResult() bool

func (*MkdirsResponseProto) ProtoMessage

func (*MkdirsResponseProto) ProtoMessage()

func (*MkdirsResponseProto) Reset

func (m *MkdirsResponseProto) Reset()

func (*MkdirsResponseProto) String

func (m *MkdirsResponseProto) String() string

type NamenodeCommandProto

type NamenodeCommandProto struct {
	Action           *uint32                    `protobuf:"varint,1,req,name=action" json:"action,omitempty"`
	Type             *NamenodeCommandProto_Type `protobuf:"varint,2,req,name=type,enum=hadoop.hdfs.NamenodeCommandProto_Type" json:"type,omitempty"`
	CheckpointCmd    *CheckpointCommandProto    `protobuf:"bytes,3,opt,name=checkpointCmd" json:"checkpointCmd,omitempty"`
	XXX_unrecognized []byte                     `json:"-"`
}

* Command sent from one namenode to another namenode.

func (*NamenodeCommandProto) GetAction

func (m *NamenodeCommandProto) GetAction() uint32

func (*NamenodeCommandProto) GetCheckpointCmd

func (m *NamenodeCommandProto) GetCheckpointCmd() *CheckpointCommandProto

func (*NamenodeCommandProto) GetType

func (*NamenodeCommandProto) ProtoMessage

func (*NamenodeCommandProto) ProtoMessage()

func (*NamenodeCommandProto) Reset

func (m *NamenodeCommandProto) Reset()

func (*NamenodeCommandProto) String

func (m *NamenodeCommandProto) String() string

type NamenodeCommandProto_Type

type NamenodeCommandProto_Type int32
const (
	NamenodeCommandProto_NamenodeCommand   NamenodeCommandProto_Type = 0
	NamenodeCommandProto_CheckPointCommand NamenodeCommandProto_Type = 1
)

func (NamenodeCommandProto_Type) Enum

func (NamenodeCommandProto_Type) String

func (x NamenodeCommandProto_Type) String() string

func (*NamenodeCommandProto_Type) UnmarshalJSON

func (x *NamenodeCommandProto_Type) UnmarshalJSON(data []byte) error

type NamenodeRegistrationProto

type NamenodeRegistrationProto struct {
	RpcAddress       *string                                      `protobuf:"bytes,1,req,name=rpcAddress" json:"rpcAddress,omitempty"`
	HttpAddress      *string                                      `protobuf:"bytes,2,req,name=httpAddress" json:"httpAddress,omitempty"`
	StorageInfo      *StorageInfoProto                            `protobuf:"bytes,3,req,name=storageInfo" json:"storageInfo,omitempty"`
	Role             *NamenodeRegistrationProto_NamenodeRoleProto `protobuf:"varint,4,opt,name=role,enum=hadoop.hdfs.NamenodeRegistrationProto_NamenodeRoleProto,def=1" json:"role,omitempty"`
	XXX_unrecognized []byte                                       `json:"-"`
}

* Information sent by a namenode to identify itself to the primary namenode.

func (*NamenodeRegistrationProto) GetHttpAddress

func (m *NamenodeRegistrationProto) GetHttpAddress() string

func (*NamenodeRegistrationProto) GetRole

func (*NamenodeRegistrationProto) GetRpcAddress

func (m *NamenodeRegistrationProto) GetRpcAddress() string

func (*NamenodeRegistrationProto) GetStorageInfo

func (m *NamenodeRegistrationProto) GetStorageInfo() *StorageInfoProto

func (*NamenodeRegistrationProto) ProtoMessage

func (*NamenodeRegistrationProto) ProtoMessage()

func (*NamenodeRegistrationProto) Reset

func (m *NamenodeRegistrationProto) Reset()

func (*NamenodeRegistrationProto) String

func (m *NamenodeRegistrationProto) String() string

type NamenodeRegistrationProto_NamenodeRoleProto

type NamenodeRegistrationProto_NamenodeRoleProto int32
const (
	NamenodeRegistrationProto_NAMENODE   NamenodeRegistrationProto_NamenodeRoleProto = 1
	NamenodeRegistrationProto_BACKUP     NamenodeRegistrationProto_NamenodeRoleProto = 2
	NamenodeRegistrationProto_CHECKPOINT NamenodeRegistrationProto_NamenodeRoleProto = 3
)

func (NamenodeRegistrationProto_NamenodeRoleProto) Enum

func (NamenodeRegistrationProto_NamenodeRoleProto) String

func (*NamenodeRegistrationProto_NamenodeRoleProto) UnmarshalJSON

func (x *NamenodeRegistrationProto_NamenodeRoleProto) UnmarshalJSON(data []byte) error

type NamespaceInfoProto

type NamespaceInfoProto struct {
	BuildVersion     *string           `protobuf:"bytes,1,req,name=buildVersion" json:"buildVersion,omitempty"`
	Unused           *uint32           `protobuf:"varint,2,req,name=unused" json:"unused,omitempty"`
	BlockPoolID      *string           `protobuf:"bytes,3,req,name=blockPoolID" json:"blockPoolID,omitempty"`
	StorageInfo      *StorageInfoProto `protobuf:"bytes,4,req,name=storageInfo" json:"storageInfo,omitempty"`
	SoftwareVersion  *string           `protobuf:"bytes,5,req,name=softwareVersion" json:"softwareVersion,omitempty"`
	XXX_unrecognized []byte            `json:"-"`
}

* Namespace information that describes namespace on a namenode

func (*NamespaceInfoProto) GetBlockPoolID

func (m *NamespaceInfoProto) GetBlockPoolID() string

func (*NamespaceInfoProto) GetBuildVersion

func (m *NamespaceInfoProto) GetBuildVersion() string

func (*NamespaceInfoProto) GetSoftwareVersion

func (m *NamespaceInfoProto) GetSoftwareVersion() string

func (*NamespaceInfoProto) GetStorageInfo

func (m *NamespaceInfoProto) GetStorageInfo() *StorageInfoProto

func (*NamespaceInfoProto) GetUnused

func (m *NamespaceInfoProto) GetUnused() uint32

func (*NamespaceInfoProto) ProtoMessage

func (*NamespaceInfoProto) ProtoMessage()

func (*NamespaceInfoProto) Reset

func (m *NamespaceInfoProto) Reset()

func (*NamespaceInfoProto) String

func (m *NamespaceInfoProto) String() string

type OpBlockChecksumProto

type OpBlockChecksumProto struct {
	Header           *BaseHeaderProto `protobuf:"bytes,1,req,name=header" json:"header,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

func (*OpBlockChecksumProto) GetHeader

func (m *OpBlockChecksumProto) GetHeader() *BaseHeaderProto

func (*OpBlockChecksumProto) ProtoMessage

func (*OpBlockChecksumProto) ProtoMessage()

func (*OpBlockChecksumProto) Reset

func (m *OpBlockChecksumProto) Reset()

func (*OpBlockChecksumProto) String

func (m *OpBlockChecksumProto) String() string

type OpBlockChecksumResponseProto

type OpBlockChecksumResponseProto struct {
	BytesPerCrc      *uint32            `protobuf:"varint,1,req,name=bytesPerCrc" json:"bytesPerCrc,omitempty"`
	CrcPerBlock      *uint64            `protobuf:"varint,2,req,name=crcPerBlock" json:"crcPerBlock,omitempty"`
	Md5              []byte             `protobuf:"bytes,3,req,name=md5" json:"md5,omitempty"`
	CrcType          *ChecksumTypeProto `protobuf:"varint,4,opt,name=crcType,enum=hadoop.hdfs.ChecksumTypeProto" json:"crcType,omitempty"`
	XXX_unrecognized []byte             `json:"-"`
}

func (*OpBlockChecksumResponseProto) GetBytesPerCrc

func (m *OpBlockChecksumResponseProto) GetBytesPerCrc() uint32

func (*OpBlockChecksumResponseProto) GetCrcPerBlock

func (m *OpBlockChecksumResponseProto) GetCrcPerBlock() uint64

func (*OpBlockChecksumResponseProto) GetCrcType

func (*OpBlockChecksumResponseProto) GetMd5

func (m *OpBlockChecksumResponseProto) GetMd5() []byte

func (*OpBlockChecksumResponseProto) ProtoMessage

func (*OpBlockChecksumResponseProto) ProtoMessage()

func (*OpBlockChecksumResponseProto) Reset

func (m *OpBlockChecksumResponseProto) Reset()

func (*OpBlockChecksumResponseProto) String

type OpCopyBlockProto

type OpCopyBlockProto struct {
	Header           *BaseHeaderProto `protobuf:"bytes,1,req,name=header" json:"header,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

func (*OpCopyBlockProto) GetHeader

func (m *OpCopyBlockProto) GetHeader() *BaseHeaderProto

func (*OpCopyBlockProto) ProtoMessage

func (*OpCopyBlockProto) ProtoMessage()

func (*OpCopyBlockProto) Reset

func (m *OpCopyBlockProto) Reset()

func (*OpCopyBlockProto) String

func (m *OpCopyBlockProto) String() string

type OpReadBlockProto

type OpReadBlockProto struct {
	Header           *ClientOperationHeaderProto `protobuf:"bytes,1,req,name=header" json:"header,omitempty"`
	Offset           *uint64                     `protobuf:"varint,2,req,name=offset" json:"offset,omitempty"`
	Len              *uint64                     `protobuf:"varint,3,req,name=len" json:"len,omitempty"`
	SendChecksums    *bool                       `protobuf:"varint,4,opt,name=sendChecksums,def=1" json:"sendChecksums,omitempty"`
	CachingStrategy  *CachingStrategyProto       `protobuf:"bytes,5,opt,name=cachingStrategy" json:"cachingStrategy,omitempty"`
	XXX_unrecognized []byte                      `json:"-"`
}

func (*OpReadBlockProto) GetCachingStrategy

func (m *OpReadBlockProto) GetCachingStrategy() *CachingStrategyProto

func (*OpReadBlockProto) GetHeader

func (*OpReadBlockProto) GetLen

func (m *OpReadBlockProto) GetLen() uint64

func (*OpReadBlockProto) GetOffset

func (m *OpReadBlockProto) GetOffset() uint64

func (*OpReadBlockProto) GetSendChecksums

func (m *OpReadBlockProto) GetSendChecksums() bool

func (*OpReadBlockProto) ProtoMessage

func (*OpReadBlockProto) ProtoMessage()

func (*OpReadBlockProto) Reset

func (m *OpReadBlockProto) Reset()

func (*OpReadBlockProto) String

func (m *OpReadBlockProto) String() string

type OpReplaceBlockProto

type OpReplaceBlockProto struct {
	Header           *BaseHeaderProto   `protobuf:"bytes,1,req,name=header" json:"header,omitempty"`
	DelHint          *string            `protobuf:"bytes,2,req,name=delHint" json:"delHint,omitempty"`
	Source           *DatanodeInfoProto `protobuf:"bytes,3,req,name=source" json:"source,omitempty"`
	XXX_unrecognized []byte             `json:"-"`
}

func (*OpReplaceBlockProto) GetDelHint

func (m *OpReplaceBlockProto) GetDelHint() string

func (*OpReplaceBlockProto) GetHeader

func (m *OpReplaceBlockProto) GetHeader() *BaseHeaderProto

func (*OpReplaceBlockProto) GetSource

func (m *OpReplaceBlockProto) GetSource() *DatanodeInfoProto

func (*OpReplaceBlockProto) ProtoMessage

func (*OpReplaceBlockProto) ProtoMessage()

func (*OpReplaceBlockProto) Reset

func (m *OpReplaceBlockProto) Reset()

func (*OpReplaceBlockProto) String

func (m *OpReplaceBlockProto) String() string

type OpRequestShortCircuitAccessProto

type OpRequestShortCircuitAccessProto struct {
	Header *BaseHeaderProto `protobuf:"bytes,1,req,name=header" json:"header,omitempty"`
	// * In order to get short-circuit access to block data, clients must set this
	// to the highest version of the block data that they can understand.
	// Currently 1 is the only version, but more versions may exist in the future
	// if the on-disk format changes.
	MaxVersion       *uint32 `protobuf:"varint,2,req,name=maxVersion" json:"maxVersion,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*OpRequestShortCircuitAccessProto) GetHeader

func (*OpRequestShortCircuitAccessProto) GetMaxVersion

func (m *OpRequestShortCircuitAccessProto) GetMaxVersion() uint32

func (*OpRequestShortCircuitAccessProto) ProtoMessage

func (*OpRequestShortCircuitAccessProto) ProtoMessage()

func (*OpRequestShortCircuitAccessProto) Reset

func (*OpRequestShortCircuitAccessProto) String

type OpTransferBlockProto

type OpTransferBlockProto struct {
	Header           *ClientOperationHeaderProto `protobuf:"bytes,1,req,name=header" json:"header,omitempty"`
	Targets          []*DatanodeInfoProto        `protobuf:"bytes,2,rep,name=targets" json:"targets,omitempty"`
	XXX_unrecognized []byte                      `json:"-"`
}

func (*OpTransferBlockProto) GetHeader

func (*OpTransferBlockProto) GetTargets

func (m *OpTransferBlockProto) GetTargets() []*DatanodeInfoProto

func (*OpTransferBlockProto) ProtoMessage

func (*OpTransferBlockProto) ProtoMessage()

func (*OpTransferBlockProto) Reset

func (m *OpTransferBlockProto) Reset()

func (*OpTransferBlockProto) String

func (m *OpTransferBlockProto) String() string

type OpWriteBlockProto

type OpWriteBlockProto struct {
	Header                *ClientOperationHeaderProto               `protobuf:"bytes,1,req,name=header" json:"header,omitempty"`
	Targets               []*DatanodeInfoProto                      `protobuf:"bytes,2,rep,name=targets" json:"targets,omitempty"`
	Source                *DatanodeInfoProto                        `protobuf:"bytes,3,opt,name=source" json:"source,omitempty"`
	Stage                 *OpWriteBlockProto_BlockConstructionStage `protobuf:"varint,4,req,name=stage,enum=hadoop.hdfs.OpWriteBlockProto_BlockConstructionStage" json:"stage,omitempty"`
	PipelineSize          *uint32                                   `protobuf:"varint,5,req,name=pipelineSize" json:"pipelineSize,omitempty"`
	MinBytesRcvd          *uint64                                   `protobuf:"varint,6,req,name=minBytesRcvd" json:"minBytesRcvd,omitempty"`
	MaxBytesRcvd          *uint64                                   `protobuf:"varint,7,req,name=maxBytesRcvd" json:"maxBytesRcvd,omitempty"`
	LatestGenerationStamp *uint64                                   `protobuf:"varint,8,req,name=latestGenerationStamp" json:"latestGenerationStamp,omitempty"`
	// *
	// The requested checksum mechanism for this block write.
	RequestedChecksum *ChecksumProto        `protobuf:"bytes,9,req,name=requestedChecksum" json:"requestedChecksum,omitempty"`
	CachingStrategy   *CachingStrategyProto `protobuf:"bytes,10,opt,name=cachingStrategy" json:"cachingStrategy,omitempty"`
	XXX_unrecognized  []byte                `json:"-"`
}

func (*OpWriteBlockProto) GetCachingStrategy

func (m *OpWriteBlockProto) GetCachingStrategy() *CachingStrategyProto

func (*OpWriteBlockProto) GetHeader

func (*OpWriteBlockProto) GetLatestGenerationStamp

func (m *OpWriteBlockProto) GetLatestGenerationStamp() uint64

func (*OpWriteBlockProto) GetMaxBytesRcvd

func (m *OpWriteBlockProto) GetMaxBytesRcvd() uint64

func (*OpWriteBlockProto) GetMinBytesRcvd

func (m *OpWriteBlockProto) GetMinBytesRcvd() uint64

func (*OpWriteBlockProto) GetPipelineSize

func (m *OpWriteBlockProto) GetPipelineSize() uint32

func (*OpWriteBlockProto) GetRequestedChecksum

func (m *OpWriteBlockProto) GetRequestedChecksum() *ChecksumProto

func (*OpWriteBlockProto) GetSource

func (m *OpWriteBlockProto) GetSource() *DatanodeInfoProto

func (*OpWriteBlockProto) GetStage

func (*OpWriteBlockProto) GetTargets

func (m *OpWriteBlockProto) GetTargets() []*DatanodeInfoProto

func (*OpWriteBlockProto) ProtoMessage

func (*OpWriteBlockProto) ProtoMessage()

func (*OpWriteBlockProto) Reset

func (m *OpWriteBlockProto) Reset()

func (*OpWriteBlockProto) String

func (m *OpWriteBlockProto) String() string

type OpWriteBlockProto_BlockConstructionStage

type OpWriteBlockProto_BlockConstructionStage int32
const (
	OpWriteBlockProto_PIPELINE_SETUP_APPEND OpWriteBlockProto_BlockConstructionStage = 0
	// pipeline set up for failed PIPELINE_SETUP_APPEND recovery
	OpWriteBlockProto_PIPELINE_SETUP_APPEND_RECOVERY OpWriteBlockProto_BlockConstructionStage = 1
	// data streaming
	OpWriteBlockProto_DATA_STREAMING OpWriteBlockProto_BlockConstructionStage = 2
	// pipeline setup for failed data streaming recovery
	OpWriteBlockProto_PIPELINE_SETUP_STREAMING_RECOVERY OpWriteBlockProto_BlockConstructionStage = 3
	// close the block and pipeline
	OpWriteBlockProto_PIPELINE_CLOSE OpWriteBlockProto_BlockConstructionStage = 4
	// Recover a failed PIPELINE_CLOSE
	OpWriteBlockProto_PIPELINE_CLOSE_RECOVERY OpWriteBlockProto_BlockConstructionStage = 5
	// pipeline set up for block creation
	OpWriteBlockProto_PIPELINE_SETUP_CREATE OpWriteBlockProto_BlockConstructionStage = 6
	// transfer RBW for adding datanodes
	OpWriteBlockProto_TRANSFER_RBW OpWriteBlockProto_BlockConstructionStage = 7
	// transfer Finalized for adding datanodes
	OpWriteBlockProto_TRANSFER_FINALIZED OpWriteBlockProto_BlockConstructionStage = 8
)

func (OpWriteBlockProto_BlockConstructionStage) Enum

func (OpWriteBlockProto_BlockConstructionStage) String

func (*OpWriteBlockProto_BlockConstructionStage) UnmarshalJSON

func (x *OpWriteBlockProto_BlockConstructionStage) UnmarshalJSON(data []byte) error

type PacketHeaderProto

type PacketHeaderProto struct {
	// All fields must be fixed-length!
	OffsetInBlock     *int64 `protobuf:"fixed64,1,req,name=offsetInBlock" json:"offsetInBlock,omitempty"`
	Seqno             *int64 `protobuf:"fixed64,2,req,name=seqno" json:"seqno,omitempty"`
	LastPacketInBlock *bool  `protobuf:"varint,3,req,name=lastPacketInBlock" json:"lastPacketInBlock,omitempty"`
	DataLen           *int32 `protobuf:"fixed32,4,req,name=dataLen" json:"dataLen,omitempty"`
	SyncBlock         *bool  `protobuf:"varint,5,opt,name=syncBlock,def=0" json:"syncBlock,omitempty"`
	XXX_unrecognized  []byte `json:"-"`
}

func (*PacketHeaderProto) GetDataLen

func (m *PacketHeaderProto) GetDataLen() int32

func (*PacketHeaderProto) GetLastPacketInBlock

func (m *PacketHeaderProto) GetLastPacketInBlock() bool

func (*PacketHeaderProto) GetOffsetInBlock

func (m *PacketHeaderProto) GetOffsetInBlock() int64

func (*PacketHeaderProto) GetSeqno

func (m *PacketHeaderProto) GetSeqno() int64

func (*PacketHeaderProto) GetSyncBlock

func (m *PacketHeaderProto) GetSyncBlock() bool

func (*PacketHeaderProto) ProtoMessage

func (*PacketHeaderProto) ProtoMessage()

func (*PacketHeaderProto) Reset

func (m *PacketHeaderProto) Reset()

func (*PacketHeaderProto) String

func (m *PacketHeaderProto) String() string

type PipelineAckProto

type PipelineAckProto struct {
	Seqno                  *int64   `protobuf:"zigzag64,1,req,name=seqno" json:"seqno,omitempty"`
	Status                 []Status `protobuf:"varint,2,rep,name=status,enum=hadoop.hdfs.Status" json:"status,omitempty"`
	DownstreamAckTimeNanos *uint64  `protobuf:"varint,3,opt,name=downstreamAckTimeNanos,def=0" json:"downstreamAckTimeNanos,omitempty"`
	XXX_unrecognized       []byte   `json:"-"`
}

func (*PipelineAckProto) GetDownstreamAckTimeNanos

func (m *PipelineAckProto) GetDownstreamAckTimeNanos() uint64

func (*PipelineAckProto) GetSeqno

func (m *PipelineAckProto) GetSeqno() int64

func (*PipelineAckProto) GetStatus

func (m *PipelineAckProto) GetStatus() []Status

func (*PipelineAckProto) ProtoMessage

func (*PipelineAckProto) ProtoMessage()

func (*PipelineAckProto) Reset

func (m *PipelineAckProto) Reset()

func (*PipelineAckProto) String

func (m *PipelineAckProto) String() string

type ReadOpChecksumInfoProto

type ReadOpChecksumInfoProto struct {
	Checksum *ChecksumProto `protobuf:"bytes,1,req,name=checksum" json:"checksum,omitempty"`
	// *
	// The offset into the block at which the first packet
	// will start. This is necessary since reads will align
	// backwards to a checksum chunk boundary.
	ChunkOffset      *uint64 `protobuf:"varint,2,req,name=chunkOffset" json:"chunkOffset,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* Sent as part of the BlockOpResponseProto for READ_BLOCK and COPY_BLOCK operations.

func (*ReadOpChecksumInfoProto) GetChecksum

func (m *ReadOpChecksumInfoProto) GetChecksum() *ChecksumProto

func (*ReadOpChecksumInfoProto) GetChunkOffset

func (m *ReadOpChecksumInfoProto) GetChunkOffset() uint64

func (*ReadOpChecksumInfoProto) ProtoMessage

func (*ReadOpChecksumInfoProto) ProtoMessage()

func (*ReadOpChecksumInfoProto) Reset

func (m *ReadOpChecksumInfoProto) Reset()

func (*ReadOpChecksumInfoProto) String

func (m *ReadOpChecksumInfoProto) String() string

type RecoverLeaseRequestProto

type RecoverLeaseRequestProto struct {
	Src              *string `protobuf:"bytes,1,req,name=src" json:"src,omitempty"`
	ClientName       *string `protobuf:"bytes,2,req,name=clientName" json:"clientName,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*RecoverLeaseRequestProto) GetClientName

func (m *RecoverLeaseRequestProto) GetClientName() string

func (*RecoverLeaseRequestProto) GetSrc

func (m *RecoverLeaseRequestProto) GetSrc() string

func (*RecoverLeaseRequestProto) ProtoMessage

func (*RecoverLeaseRequestProto) ProtoMessage()

func (*RecoverLeaseRequestProto) Reset

func (m *RecoverLeaseRequestProto) Reset()

func (*RecoverLeaseRequestProto) String

func (m *RecoverLeaseRequestProto) String() string

type RecoverLeaseResponseProto

type RecoverLeaseResponseProto struct {
	Result           *bool  `protobuf:"varint,1,req,name=result" json:"result,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*RecoverLeaseResponseProto) GetResult

func (m *RecoverLeaseResponseProto) GetResult() bool

func (*RecoverLeaseResponseProto) ProtoMessage

func (*RecoverLeaseResponseProto) ProtoMessage()

func (*RecoverLeaseResponseProto) Reset

func (m *RecoverLeaseResponseProto) Reset()

func (*RecoverLeaseResponseProto) String

func (m *RecoverLeaseResponseProto) String() string

type RecoveringBlockProto

type RecoveringBlockProto struct {
	NewGenStamp      *uint64            `protobuf:"varint,1,req,name=newGenStamp" json:"newGenStamp,omitempty"`
	Block            *LocatedBlockProto `protobuf:"bytes,2,req,name=block" json:"block,omitempty"`
	XXX_unrecognized []byte             `json:"-"`
}

* Block that needs to be recovered with at a given location

func (*RecoveringBlockProto) GetBlock

func (m *RecoveringBlockProto) GetBlock() *LocatedBlockProto

func (*RecoveringBlockProto) GetNewGenStamp

func (m *RecoveringBlockProto) GetNewGenStamp() uint64

func (*RecoveringBlockProto) ProtoMessage

func (*RecoveringBlockProto) ProtoMessage()

func (*RecoveringBlockProto) Reset

func (m *RecoveringBlockProto) Reset()

func (*RecoveringBlockProto) String

func (m *RecoveringBlockProto) String() string

type RefreshNodesRequestProto

type RefreshNodesRequestProto struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*RefreshNodesRequestProto) ProtoMessage

func (*RefreshNodesRequestProto) ProtoMessage()

func (*RefreshNodesRequestProto) Reset

func (m *RefreshNodesRequestProto) Reset()

func (*RefreshNodesRequestProto) String

func (m *RefreshNodesRequestProto) String() string

type RefreshNodesResponseProto

type RefreshNodesResponseProto struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*RefreshNodesResponseProto) ProtoMessage

func (*RefreshNodesResponseProto) ProtoMessage()

func (*RefreshNodesResponseProto) Reset

func (m *RefreshNodesResponseProto) Reset()

func (*RefreshNodesResponseProto) String

func (m *RefreshNodesResponseProto) String() string

type RemoteEditLogManifestProto

type RemoteEditLogManifestProto struct {
	Logs             []*RemoteEditLogProto `protobuf:"bytes,1,rep,name=logs" json:"logs,omitempty"`
	XXX_unrecognized []byte                `json:"-"`
}

* Enumeration of editlogs available on a remote namenode

func (*RemoteEditLogManifestProto) GetLogs

func (*RemoteEditLogManifestProto) ProtoMessage

func (*RemoteEditLogManifestProto) ProtoMessage()

func (*RemoteEditLogManifestProto) Reset

func (m *RemoteEditLogManifestProto) Reset()

func (*RemoteEditLogManifestProto) String

func (m *RemoteEditLogManifestProto) String() string

type RemoteEditLogProto

type RemoteEditLogProto struct {
	StartTxId        *uint64 `protobuf:"varint,1,req,name=startTxId" json:"startTxId,omitempty"`
	EndTxId          *uint64 `protobuf:"varint,2,req,name=endTxId" json:"endTxId,omitempty"`
	IsInProgress     *bool   `protobuf:"varint,3,opt,name=isInProgress,def=0" json:"isInProgress,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* Editlog information with available transactions

func (*RemoteEditLogProto) GetEndTxId

func (m *RemoteEditLogProto) GetEndTxId() uint64

func (*RemoteEditLogProto) GetIsInProgress

func (m *RemoteEditLogProto) GetIsInProgress() bool

func (*RemoteEditLogProto) GetStartTxId

func (m *RemoteEditLogProto) GetStartTxId() uint64

func (*RemoteEditLogProto) ProtoMessage

func (*RemoteEditLogProto) ProtoMessage()

func (*RemoteEditLogProto) Reset

func (m *RemoteEditLogProto) Reset()

func (*RemoteEditLogProto) String

func (m *RemoteEditLogProto) String() string

type Rename2RequestProto

type Rename2RequestProto struct {
	Src              *string `protobuf:"bytes,1,req,name=src" json:"src,omitempty"`
	Dst              *string `protobuf:"bytes,2,req,name=dst" json:"dst,omitempty"`
	OverwriteDest    *bool   `protobuf:"varint,3,req,name=overwriteDest" json:"overwriteDest,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*Rename2RequestProto) GetDst

func (m *Rename2RequestProto) GetDst() string

func (*Rename2RequestProto) GetOverwriteDest

func (m *Rename2RequestProto) GetOverwriteDest() bool

func (*Rename2RequestProto) GetSrc

func (m *Rename2RequestProto) GetSrc() string

func (*Rename2RequestProto) ProtoMessage

func (*Rename2RequestProto) ProtoMessage()

func (*Rename2RequestProto) Reset

func (m *Rename2RequestProto) Reset()

func (*Rename2RequestProto) String

func (m *Rename2RequestProto) String() string

type Rename2ResponseProto

type Rename2ResponseProto struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*Rename2ResponseProto) ProtoMessage

func (*Rename2ResponseProto) ProtoMessage()

func (*Rename2ResponseProto) Reset

func (m *Rename2ResponseProto) Reset()

func (*Rename2ResponseProto) String

func (m *Rename2ResponseProto) String() string

type RenameRequestProto

type RenameRequestProto struct {
	Src              *string `protobuf:"bytes,1,req,name=src" json:"src,omitempty"`
	Dst              *string `protobuf:"bytes,2,req,name=dst" json:"dst,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*RenameRequestProto) GetDst

func (m *RenameRequestProto) GetDst() string

func (*RenameRequestProto) GetSrc

func (m *RenameRequestProto) GetSrc() string

func (*RenameRequestProto) ProtoMessage

func (*RenameRequestProto) ProtoMessage()

func (*RenameRequestProto) Reset

func (m *RenameRequestProto) Reset()

func (*RenameRequestProto) String

func (m *RenameRequestProto) String() string

type RenameResponseProto

type RenameResponseProto struct {
	Result           *bool  `protobuf:"varint,1,req,name=result" json:"result,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*RenameResponseProto) GetResult

func (m *RenameResponseProto) GetResult() bool

func (*RenameResponseProto) ProtoMessage

func (*RenameResponseProto) ProtoMessage()

func (*RenameResponseProto) Reset

func (m *RenameResponseProto) Reset()

func (*RenameResponseProto) String

func (m *RenameResponseProto) String() string

type RenameSnapshotRequestProto

type RenameSnapshotRequestProto struct {
	SnapshotRoot     *string `protobuf:"bytes,1,req,name=snapshotRoot" json:"snapshotRoot,omitempty"`
	SnapshotOldName  *string `protobuf:"bytes,2,req,name=snapshotOldName" json:"snapshotOldName,omitempty"`
	SnapshotNewName  *string `protobuf:"bytes,3,req,name=snapshotNewName" json:"snapshotNewName,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*RenameSnapshotRequestProto) GetSnapshotNewName

func (m *RenameSnapshotRequestProto) GetSnapshotNewName() string

func (*RenameSnapshotRequestProto) GetSnapshotOldName

func (m *RenameSnapshotRequestProto) GetSnapshotOldName() string

func (*RenameSnapshotRequestProto) GetSnapshotRoot

func (m *RenameSnapshotRequestProto) GetSnapshotRoot() string

func (*RenameSnapshotRequestProto) ProtoMessage

func (*RenameSnapshotRequestProto) ProtoMessage()

func (*RenameSnapshotRequestProto) Reset

func (m *RenameSnapshotRequestProto) Reset()

func (*RenameSnapshotRequestProto) String

func (m *RenameSnapshotRequestProto) String() string

type RenameSnapshotResponseProto

type RenameSnapshotResponseProto struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*RenameSnapshotResponseProto) ProtoMessage

func (*RenameSnapshotResponseProto) ProtoMessage()

func (*RenameSnapshotResponseProto) Reset

func (m *RenameSnapshotResponseProto) Reset()

func (*RenameSnapshotResponseProto) String

func (m *RenameSnapshotResponseProto) String() string

type RenewLeaseRequestProto

type RenewLeaseRequestProto struct {
	ClientName       *string `protobuf:"bytes,1,req,name=clientName" json:"clientName,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*RenewLeaseRequestProto) GetClientName

func (m *RenewLeaseRequestProto) GetClientName() string

func (*RenewLeaseRequestProto) ProtoMessage

func (*RenewLeaseRequestProto) ProtoMessage()

func (*RenewLeaseRequestProto) Reset

func (m *RenewLeaseRequestProto) Reset()

func (*RenewLeaseRequestProto) String

func (m *RenewLeaseRequestProto) String() string

type RenewLeaseResponseProto

type RenewLeaseResponseProto struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*RenewLeaseResponseProto) ProtoMessage

func (*RenewLeaseResponseProto) ProtoMessage()

func (*RenewLeaseResponseProto) Reset

func (m *RenewLeaseResponseProto) Reset()

func (*RenewLeaseResponseProto) String

func (m *RenewLeaseResponseProto) String() string

type ReplicaStateProto

type ReplicaStateProto int32

* State of a block replica at a datanode

const (
	ReplicaStateProto_FINALIZED ReplicaStateProto = 0
	ReplicaStateProto_RBW       ReplicaStateProto = 1
	ReplicaStateProto_RWR       ReplicaStateProto = 2
	ReplicaStateProto_RUR       ReplicaStateProto = 3
	ReplicaStateProto_TEMPORARY ReplicaStateProto = 4
)

func (ReplicaStateProto) Enum

func (ReplicaStateProto) String

func (x ReplicaStateProto) String() string

func (*ReplicaStateProto) UnmarshalJSON

func (x *ReplicaStateProto) UnmarshalJSON(data []byte) error

type ReportBadBlocksRequestProto

type ReportBadBlocksRequestProto struct {
	Blocks           []*LocatedBlockProto `protobuf:"bytes,1,rep,name=blocks" json:"blocks,omitempty"`
	XXX_unrecognized []byte               `json:"-"`
}

func (*ReportBadBlocksRequestProto) GetBlocks

func (*ReportBadBlocksRequestProto) ProtoMessage

func (*ReportBadBlocksRequestProto) ProtoMessage()

func (*ReportBadBlocksRequestProto) Reset

func (m *ReportBadBlocksRequestProto) Reset()

func (*ReportBadBlocksRequestProto) String

func (m *ReportBadBlocksRequestProto) String() string

type ReportBadBlocksResponseProto

type ReportBadBlocksResponseProto struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*ReportBadBlocksResponseProto) ProtoMessage

func (*ReportBadBlocksResponseProto) ProtoMessage()

func (*ReportBadBlocksResponseProto) Reset

func (m *ReportBadBlocksResponseProto) Reset()

func (*ReportBadBlocksResponseProto) String

type RestoreFailedStorageRequestProto

type RestoreFailedStorageRequestProto struct {
	Arg              *string `protobuf:"bytes,1,req,name=arg" json:"arg,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*RestoreFailedStorageRequestProto) GetArg

func (*RestoreFailedStorageRequestProto) ProtoMessage

func (*RestoreFailedStorageRequestProto) ProtoMessage()

func (*RestoreFailedStorageRequestProto) Reset

func (*RestoreFailedStorageRequestProto) String

type RestoreFailedStorageResponseProto

type RestoreFailedStorageResponseProto struct {
	Result           *bool  `protobuf:"varint,1,req,name=result" json:"result,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*RestoreFailedStorageResponseProto) GetResult

func (m *RestoreFailedStorageResponseProto) GetResult() bool

func (*RestoreFailedStorageResponseProto) ProtoMessage

func (*RestoreFailedStorageResponseProto) ProtoMessage()

func (*RestoreFailedStorageResponseProto) Reset

func (*RestoreFailedStorageResponseProto) String

type RollEditsRequestProto

type RollEditsRequestProto struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*RollEditsRequestProto) ProtoMessage

func (*RollEditsRequestProto) ProtoMessage()

func (*RollEditsRequestProto) Reset

func (m *RollEditsRequestProto) Reset()

func (*RollEditsRequestProto) String

func (m *RollEditsRequestProto) String() string

type RollEditsResponseProto

type RollEditsResponseProto struct {
	NewSegmentTxId   *uint64 `protobuf:"varint,1,req,name=newSegmentTxId" json:"newSegmentTxId,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*RollEditsResponseProto) GetNewSegmentTxId

func (m *RollEditsResponseProto) GetNewSegmentTxId() uint64

func (*RollEditsResponseProto) ProtoMessage

func (*RollEditsResponseProto) ProtoMessage()

func (*RollEditsResponseProto) Reset

func (m *RollEditsResponseProto) Reset()

func (*RollEditsResponseProto) String

func (m *RollEditsResponseProto) String() string

type SafeModeActionProto

type SafeModeActionProto int32
const (
	SafeModeActionProto_SAFEMODE_LEAVE SafeModeActionProto = 1
	SafeModeActionProto_SAFEMODE_ENTER SafeModeActionProto = 2
	SafeModeActionProto_SAFEMODE_GET   SafeModeActionProto = 3
)

func (SafeModeActionProto) Enum

func (SafeModeActionProto) String

func (x SafeModeActionProto) String() string

func (*SafeModeActionProto) UnmarshalJSON

func (x *SafeModeActionProto) UnmarshalJSON(data []byte) error

type SaveNamespaceRequestProto

type SaveNamespaceRequestProto struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*SaveNamespaceRequestProto) ProtoMessage

func (*SaveNamespaceRequestProto) ProtoMessage()

func (*SaveNamespaceRequestProto) Reset

func (m *SaveNamespaceRequestProto) Reset()

func (*SaveNamespaceRequestProto) String

func (m *SaveNamespaceRequestProto) String() string

type SaveNamespaceResponseProto

type SaveNamespaceResponseProto struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*SaveNamespaceResponseProto) ProtoMessage

func (*SaveNamespaceResponseProto) ProtoMessage()

func (*SaveNamespaceResponseProto) Reset

func (m *SaveNamespaceResponseProto) Reset()

func (*SaveNamespaceResponseProto) String

func (m *SaveNamespaceResponseProto) String() string

type SetBalancerBandwidthRequestProto

type SetBalancerBandwidthRequestProto struct {
	Bandwidth        *int64 `protobuf:"varint,1,req,name=bandwidth" json:"bandwidth,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*SetBalancerBandwidthRequestProto) GetBandwidth

func (m *SetBalancerBandwidthRequestProto) GetBandwidth() int64

func (*SetBalancerBandwidthRequestProto) ProtoMessage

func (*SetBalancerBandwidthRequestProto) ProtoMessage()

func (*SetBalancerBandwidthRequestProto) Reset

func (*SetBalancerBandwidthRequestProto) String

type SetBalancerBandwidthResponseProto

type SetBalancerBandwidthResponseProto struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*SetBalancerBandwidthResponseProto) ProtoMessage

func (*SetBalancerBandwidthResponseProto) ProtoMessage()

func (*SetBalancerBandwidthResponseProto) Reset

func (*SetBalancerBandwidthResponseProto) String

type SetOwnerRequestProto

type SetOwnerRequestProto struct {
	Src              *string `protobuf:"bytes,1,req,name=src" json:"src,omitempty"`
	Username         *string `protobuf:"bytes,2,opt,name=username" json:"username,omitempty"`
	Groupname        *string `protobuf:"bytes,3,opt,name=groupname" json:"groupname,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*SetOwnerRequestProto) GetGroupname

func (m *SetOwnerRequestProto) GetGroupname() string

func (*SetOwnerRequestProto) GetSrc

func (m *SetOwnerRequestProto) GetSrc() string

func (*SetOwnerRequestProto) GetUsername

func (m *SetOwnerRequestProto) GetUsername() string

func (*SetOwnerRequestProto) ProtoMessage

func (*SetOwnerRequestProto) ProtoMessage()

func (*SetOwnerRequestProto) Reset

func (m *SetOwnerRequestProto) Reset()

func (*SetOwnerRequestProto) String

func (m *SetOwnerRequestProto) String() string

type SetOwnerResponseProto

type SetOwnerResponseProto struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*SetOwnerResponseProto) ProtoMessage

func (*SetOwnerResponseProto) ProtoMessage()

func (*SetOwnerResponseProto) Reset

func (m *SetOwnerResponseProto) Reset()

func (*SetOwnerResponseProto) String

func (m *SetOwnerResponseProto) String() string

type SetPermissionRequestProto

type SetPermissionRequestProto struct {
	Src              *string            `protobuf:"bytes,1,req,name=src" json:"src,omitempty"`
	Permission       *FsPermissionProto `protobuf:"bytes,2,req,name=permission" json:"permission,omitempty"`
	XXX_unrecognized []byte             `json:"-"`
}

func (*SetPermissionRequestProto) GetPermission

func (m *SetPermissionRequestProto) GetPermission() *FsPermissionProto

func (*SetPermissionRequestProto) GetSrc

func (m *SetPermissionRequestProto) GetSrc() string

func (*SetPermissionRequestProto) ProtoMessage

func (*SetPermissionRequestProto) ProtoMessage()

func (*SetPermissionRequestProto) Reset

func (m *SetPermissionRequestProto) Reset()

func (*SetPermissionRequestProto) String

func (m *SetPermissionRequestProto) String() string

type SetPermissionResponseProto

type SetPermissionResponseProto struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*SetPermissionResponseProto) ProtoMessage

func (*SetPermissionResponseProto) ProtoMessage()

func (*SetPermissionResponseProto) Reset

func (m *SetPermissionResponseProto) Reset()

func (*SetPermissionResponseProto) String

func (m *SetPermissionResponseProto) String() string

type SetQuotaRequestProto

type SetQuotaRequestProto struct {
	Path             *string `protobuf:"bytes,1,req,name=path" json:"path,omitempty"`
	NamespaceQuota   *uint64 `protobuf:"varint,2,req,name=namespaceQuota" json:"namespaceQuota,omitempty"`
	DiskspaceQuota   *uint64 `protobuf:"varint,3,req,name=diskspaceQuota" json:"diskspaceQuota,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*SetQuotaRequestProto) GetDiskspaceQuota

func (m *SetQuotaRequestProto) GetDiskspaceQuota() uint64

func (*SetQuotaRequestProto) GetNamespaceQuota

func (m *SetQuotaRequestProto) GetNamespaceQuota() uint64

func (*SetQuotaRequestProto) GetPath

func (m *SetQuotaRequestProto) GetPath() string

func (*SetQuotaRequestProto) ProtoMessage

func (*SetQuotaRequestProto) ProtoMessage()

func (*SetQuotaRequestProto) Reset

func (m *SetQuotaRequestProto) Reset()

func (*SetQuotaRequestProto) String

func (m *SetQuotaRequestProto) String() string

type SetQuotaResponseProto

type SetQuotaResponseProto struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*SetQuotaResponseProto) ProtoMessage

func (*SetQuotaResponseProto) ProtoMessage()

func (*SetQuotaResponseProto) Reset

func (m *SetQuotaResponseProto) Reset()

func (*SetQuotaResponseProto) String

func (m *SetQuotaResponseProto) String() string

type SetReplicationRequestProto

type SetReplicationRequestProto struct {
	Src              *string `protobuf:"bytes,1,req,name=src" json:"src,omitempty"`
	Replication      *uint32 `protobuf:"varint,2,req,name=replication" json:"replication,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*SetReplicationRequestProto) GetReplication

func (m *SetReplicationRequestProto) GetReplication() uint32

func (*SetReplicationRequestProto) GetSrc

func (m *SetReplicationRequestProto) GetSrc() string

func (*SetReplicationRequestProto) ProtoMessage

func (*SetReplicationRequestProto) ProtoMessage()

func (*SetReplicationRequestProto) Reset

func (m *SetReplicationRequestProto) Reset()

func (*SetReplicationRequestProto) String

func (m *SetReplicationRequestProto) String() string

type SetReplicationResponseProto

type SetReplicationResponseProto struct {
	Result           *bool  `protobuf:"varint,1,req,name=result" json:"result,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*SetReplicationResponseProto) GetResult

func (m *SetReplicationResponseProto) GetResult() bool

func (*SetReplicationResponseProto) ProtoMessage

func (*SetReplicationResponseProto) ProtoMessage()

func (*SetReplicationResponseProto) Reset

func (m *SetReplicationResponseProto) Reset()

func (*SetReplicationResponseProto) String

func (m *SetReplicationResponseProto) String() string

type SetSafeModeRequestProto

type SetSafeModeRequestProto struct {
	Action           *SafeModeActionProto `protobuf:"varint,1,req,name=action,enum=hadoop.hdfs.SafeModeActionProto" json:"action,omitempty"`
	Checked          *bool                `protobuf:"varint,2,opt,name=checked,def=0" json:"checked,omitempty"`
	XXX_unrecognized []byte               `json:"-"`
}

func (*SetSafeModeRequestProto) GetAction

func (*SetSafeModeRequestProto) GetChecked

func (m *SetSafeModeRequestProto) GetChecked() bool

func (*SetSafeModeRequestProto) ProtoMessage

func (*SetSafeModeRequestProto) ProtoMessage()

func (*SetSafeModeRequestProto) Reset

func (m *SetSafeModeRequestProto) Reset()

func (*SetSafeModeRequestProto) String

func (m *SetSafeModeRequestProto) String() string

type SetSafeModeResponseProto

type SetSafeModeResponseProto struct {
	Result           *bool  `protobuf:"varint,1,req,name=result" json:"result,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*SetSafeModeResponseProto) GetResult

func (m *SetSafeModeResponseProto) GetResult() bool

func (*SetSafeModeResponseProto) ProtoMessage

func (*SetSafeModeResponseProto) ProtoMessage()

func (*SetSafeModeResponseProto) Reset

func (m *SetSafeModeResponseProto) Reset()

func (*SetSafeModeResponseProto) String

func (m *SetSafeModeResponseProto) String() string

type SetTimesRequestProto

type SetTimesRequestProto struct {
	Src              *string `protobuf:"bytes,1,req,name=src" json:"src,omitempty"`
	Mtime            *uint64 `protobuf:"varint,2,req,name=mtime" json:"mtime,omitempty"`
	Atime            *uint64 `protobuf:"varint,3,req,name=atime" json:"atime,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*SetTimesRequestProto) GetAtime

func (m *SetTimesRequestProto) GetAtime() uint64

func (*SetTimesRequestProto) GetMtime

func (m *SetTimesRequestProto) GetMtime() uint64

func (*SetTimesRequestProto) GetSrc

func (m *SetTimesRequestProto) GetSrc() string

func (*SetTimesRequestProto) ProtoMessage

func (*SetTimesRequestProto) ProtoMessage()

func (*SetTimesRequestProto) Reset

func (m *SetTimesRequestProto) Reset()

func (*SetTimesRequestProto) String

func (m *SetTimesRequestProto) String() string

type SetTimesResponseProto

type SetTimesResponseProto struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*SetTimesResponseProto) ProtoMessage

func (*SetTimesResponseProto) ProtoMessage()

func (*SetTimesResponseProto) Reset

func (m *SetTimesResponseProto) Reset()

func (*SetTimesResponseProto) String

func (m *SetTimesResponseProto) String() string

type SnapshotDiffReportEntryProto

type SnapshotDiffReportEntryProto struct {
	Fullpath          []byte  `protobuf:"bytes,1,req,name=fullpath" json:"fullpath,omitempty"`
	ModificationLabel *string `protobuf:"bytes,2,req,name=modificationLabel" json:"modificationLabel,omitempty"`
	XXX_unrecognized  []byte  `json:"-"`
}

* Snapshot diff report entry

func (*SnapshotDiffReportEntryProto) GetFullpath

func (m *SnapshotDiffReportEntryProto) GetFullpath() []byte

func (*SnapshotDiffReportEntryProto) GetModificationLabel

func (m *SnapshotDiffReportEntryProto) GetModificationLabel() string

func (*SnapshotDiffReportEntryProto) ProtoMessage

func (*SnapshotDiffReportEntryProto) ProtoMessage()

func (*SnapshotDiffReportEntryProto) Reset

func (m *SnapshotDiffReportEntryProto) Reset()

func (*SnapshotDiffReportEntryProto) String

type SnapshotDiffReportProto

type SnapshotDiffReportProto struct {
	// full path of the directory where snapshots were taken
	SnapshotRoot      *string                         `protobuf:"bytes,1,req,name=snapshotRoot" json:"snapshotRoot,omitempty"`
	FromSnapshot      *string                         `protobuf:"bytes,2,req,name=fromSnapshot" json:"fromSnapshot,omitempty"`
	ToSnapshot        *string                         `protobuf:"bytes,3,req,name=toSnapshot" json:"toSnapshot,omitempty"`
	DiffReportEntries []*SnapshotDiffReportEntryProto `protobuf:"bytes,4,rep,name=diffReportEntries" json:"diffReportEntries,omitempty"`
	XXX_unrecognized  []byte                          `json:"-"`
}

* Snapshot diff report

func (*SnapshotDiffReportProto) GetDiffReportEntries

func (m *SnapshotDiffReportProto) GetDiffReportEntries() []*SnapshotDiffReportEntryProto

func (*SnapshotDiffReportProto) GetFromSnapshot

func (m *SnapshotDiffReportProto) GetFromSnapshot() string

func (*SnapshotDiffReportProto) GetSnapshotRoot

func (m *SnapshotDiffReportProto) GetSnapshotRoot() string

func (*SnapshotDiffReportProto) GetToSnapshot

func (m *SnapshotDiffReportProto) GetToSnapshot() string

func (*SnapshotDiffReportProto) ProtoMessage

func (*SnapshotDiffReportProto) ProtoMessage()

func (*SnapshotDiffReportProto) Reset

func (m *SnapshotDiffReportProto) Reset()

func (*SnapshotDiffReportProto) String

func (m *SnapshotDiffReportProto) String() string

type SnapshotInfoProto

type SnapshotInfoProto struct {
	SnapshotName     *string            `protobuf:"bytes,1,req,name=snapshotName" json:"snapshotName,omitempty"`
	SnapshotRoot     *string            `protobuf:"bytes,2,req,name=snapshotRoot" json:"snapshotRoot,omitempty"`
	Permission       *FsPermissionProto `protobuf:"bytes,3,req,name=permission" json:"permission,omitempty"`
	Owner            *string            `protobuf:"bytes,4,req,name=owner" json:"owner,omitempty"`
	Group            *string            `protobuf:"bytes,5,req,name=group" json:"group,omitempty"`
	CreateTime       *string            `protobuf:"bytes,6,req,name=createTime" json:"createTime,omitempty"`
	XXX_unrecognized []byte             `json:"-"`
}

* Information related to a snapshot TODO: add more information

func (*SnapshotInfoProto) GetCreateTime

func (m *SnapshotInfoProto) GetCreateTime() string

func (*SnapshotInfoProto) GetGroup

func (m *SnapshotInfoProto) GetGroup() string

func (*SnapshotInfoProto) GetOwner

func (m *SnapshotInfoProto) GetOwner() string

func (*SnapshotInfoProto) GetPermission

func (m *SnapshotInfoProto) GetPermission() *FsPermissionProto

func (*SnapshotInfoProto) GetSnapshotName

func (m *SnapshotInfoProto) GetSnapshotName() string

func (*SnapshotInfoProto) GetSnapshotRoot

func (m *SnapshotInfoProto) GetSnapshotRoot() string

func (*SnapshotInfoProto) ProtoMessage

func (*SnapshotInfoProto) ProtoMessage()

func (*SnapshotInfoProto) Reset

func (m *SnapshotInfoProto) Reset()

func (*SnapshotInfoProto) String

func (m *SnapshotInfoProto) String() string

type SnapshottableDirectoryListingProto

type SnapshottableDirectoryListingProto struct {
	SnapshottableDirListing []*SnapshottableDirectoryStatusProto `protobuf:"bytes,1,rep,name=snapshottableDirListing" json:"snapshottableDirListing,omitempty"`
	XXX_unrecognized        []byte                               `json:"-"`
}

* Snapshottable directory listing

func (*SnapshottableDirectoryListingProto) GetSnapshottableDirListing

func (m *SnapshottableDirectoryListingProto) GetSnapshottableDirListing() []*SnapshottableDirectoryStatusProto

func (*SnapshottableDirectoryListingProto) ProtoMessage

func (*SnapshottableDirectoryListingProto) ProtoMessage()

func (*SnapshottableDirectoryListingProto) Reset

func (*SnapshottableDirectoryListingProto) String

type SnapshottableDirectoryStatusProto

type SnapshottableDirectoryStatusProto struct {
	DirStatus *HdfsFileStatusProto `protobuf:"bytes,1,req,name=dirStatus" json:"dirStatus,omitempty"`
	// Fields specific for snapshottable directory
	SnapshotQuota    *uint32 `protobuf:"varint,2,req,name=snapshot_quota" json:"snapshot_quota,omitempty"`
	SnapshotNumber   *uint32 `protobuf:"varint,3,req,name=snapshot_number" json:"snapshot_number,omitempty"`
	ParentFullpath   []byte  `protobuf:"bytes,4,req,name=parent_fullpath" json:"parent_fullpath,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* Status of a snapshottable directory: besides the normal information for a directory status, also include snapshot quota, number of snapshots, and the full path of the parent directory.

func (*SnapshottableDirectoryStatusProto) GetDirStatus

func (*SnapshottableDirectoryStatusProto) GetParentFullpath

func (m *SnapshottableDirectoryStatusProto) GetParentFullpath() []byte

func (*SnapshottableDirectoryStatusProto) GetSnapshotNumber

func (m *SnapshottableDirectoryStatusProto) GetSnapshotNumber() uint32

func (*SnapshottableDirectoryStatusProto) GetSnapshotQuota

func (m *SnapshottableDirectoryStatusProto) GetSnapshotQuota() uint32

func (*SnapshottableDirectoryStatusProto) ProtoMessage

func (*SnapshottableDirectoryStatusProto) ProtoMessage()

func (*SnapshottableDirectoryStatusProto) Reset

func (*SnapshottableDirectoryStatusProto) String

type Status

type Status int32
const (
	Status_SUCCESS            Status = 0
	Status_ERROR              Status = 1
	Status_ERROR_CHECKSUM     Status = 2
	Status_ERROR_INVALID      Status = 3
	Status_ERROR_EXISTS       Status = 4
	Status_ERROR_ACCESS_TOKEN Status = 5
	Status_CHECKSUM_OK        Status = 6
	Status_ERROR_UNSUPPORTED  Status = 7
)

func (Status) Enum

func (x Status) Enum() *Status

func (Status) String

func (x Status) String() string

func (*Status) UnmarshalJSON

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

type StorageInfoProto

type StorageInfoProto struct {
	LayoutVersion    *uint32 `protobuf:"varint,1,req,name=layoutVersion" json:"layoutVersion,omitempty"`
	NamespceID       *uint32 `protobuf:"varint,2,req,name=namespceID" json:"namespceID,omitempty"`
	ClusterID        *string `protobuf:"bytes,3,req,name=clusterID" json:"clusterID,omitempty"`
	CTime            *uint64 `protobuf:"varint,4,req,name=cTime" json:"cTime,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* Common node information shared by all the nodes in the cluster

func (*StorageInfoProto) GetCTime

func (m *StorageInfoProto) GetCTime() uint64

func (*StorageInfoProto) GetClusterID

func (m *StorageInfoProto) GetClusterID() string

func (*StorageInfoProto) GetLayoutVersion

func (m *StorageInfoProto) GetLayoutVersion() uint32

func (*StorageInfoProto) GetNamespceID

func (m *StorageInfoProto) GetNamespceID() uint32

func (*StorageInfoProto) ProtoMessage

func (*StorageInfoProto) ProtoMessage()

func (*StorageInfoProto) Reset

func (m *StorageInfoProto) Reset()

func (*StorageInfoProto) String

func (m *StorageInfoProto) String() string

type UpdateBlockForPipelineRequestProto

type UpdateBlockForPipelineRequestProto struct {
	Block            *ExtendedBlockProto `protobuf:"bytes,1,req,name=block" json:"block,omitempty"`
	ClientName       *string             `protobuf:"bytes,2,req,name=clientName" json:"clientName,omitempty"`
	XXX_unrecognized []byte              `json:"-"`
}

func (*UpdateBlockForPipelineRequestProto) GetBlock

func (*UpdateBlockForPipelineRequestProto) GetClientName

func (m *UpdateBlockForPipelineRequestProto) GetClientName() string

func (*UpdateBlockForPipelineRequestProto) ProtoMessage

func (*UpdateBlockForPipelineRequestProto) ProtoMessage()

func (*UpdateBlockForPipelineRequestProto) Reset

func (*UpdateBlockForPipelineRequestProto) String

type UpdateBlockForPipelineResponseProto

type UpdateBlockForPipelineResponseProto struct {
	Block            *LocatedBlockProto `protobuf:"bytes,1,req,name=block" json:"block,omitempty"`
	XXX_unrecognized []byte             `json:"-"`
}

func (*UpdateBlockForPipelineResponseProto) GetBlock

func (*UpdateBlockForPipelineResponseProto) ProtoMessage

func (*UpdateBlockForPipelineResponseProto) ProtoMessage()

func (*UpdateBlockForPipelineResponseProto) Reset

func (*UpdateBlockForPipelineResponseProto) String

type UpdatePipelineRequestProto

type UpdatePipelineRequestProto struct {
	ClientName       *string             `protobuf:"bytes,1,req,name=clientName" json:"clientName,omitempty"`
	OldBlock         *ExtendedBlockProto `protobuf:"bytes,2,req,name=oldBlock" json:"oldBlock,omitempty"`
	NewBlock         *ExtendedBlockProto `protobuf:"bytes,3,req,name=newBlock" json:"newBlock,omitempty"`
	NewNodes         []*DatanodeIDProto  `protobuf:"bytes,4,rep,name=newNodes" json:"newNodes,omitempty"`
	XXX_unrecognized []byte              `json:"-"`
}

func (*UpdatePipelineRequestProto) GetClientName

func (m *UpdatePipelineRequestProto) GetClientName() string

func (*UpdatePipelineRequestProto) GetNewBlock

func (*UpdatePipelineRequestProto) GetNewNodes

func (m *UpdatePipelineRequestProto) GetNewNodes() []*DatanodeIDProto

func (*UpdatePipelineRequestProto) GetOldBlock

func (*UpdatePipelineRequestProto) ProtoMessage

func (*UpdatePipelineRequestProto) ProtoMessage()

func (*UpdatePipelineRequestProto) Reset

func (m *UpdatePipelineRequestProto) Reset()

func (*UpdatePipelineRequestProto) String

func (m *UpdatePipelineRequestProto) String() string

type UpdatePipelineResponseProto

type UpdatePipelineResponseProto struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*UpdatePipelineResponseProto) ProtoMessage

func (*UpdatePipelineResponseProto) ProtoMessage()

func (*UpdatePipelineResponseProto) Reset

func (m *UpdatePipelineResponseProto) Reset()

func (*UpdatePipelineResponseProto) String

func (m *UpdatePipelineResponseProto) String() string

type VersionRequestProto

type VersionRequestProto struct {
	XXX_unrecognized []byte `json:"-"`
}

* void request

func (*VersionRequestProto) ProtoMessage

func (*VersionRequestProto) ProtoMessage()

func (*VersionRequestProto) Reset

func (m *VersionRequestProto) Reset()

func (*VersionRequestProto) String

func (m *VersionRequestProto) String() string

type VersionResponseProto

type VersionResponseProto struct {
	Info             *NamespaceInfoProto `protobuf:"bytes,1,req,name=info" json:"info,omitempty"`
	XXX_unrecognized []byte              `json:"-"`
}

* Version response from namenode.

func (*VersionResponseProto) GetInfo

func (*VersionResponseProto) ProtoMessage

func (*VersionResponseProto) ProtoMessage()

func (*VersionResponseProto) Reset

func (m *VersionResponseProto) Reset()

func (*VersionResponseProto) String

func (m *VersionResponseProto) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL