hadoop_hdfs

package
Version: 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)