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 (m *AbandonBlockRequestProto) GetB() *ExtendedBlockProto

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 (m *AddBlockResponseProto) GetBlock() *LocatedBlockProto

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 (m *BlocksWithLocationsProto) GetBlocks() []*BlockWithLocationsProto

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 (m *CheckpointCommandProto) GetSignature() *CheckpointSignatureProto

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 (x ChecksumTypeProto) Enum() *ChecksumTypeProto

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 (m *CompleteRequestProto) GetLast() *ExtendedBlockProto

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 (m *CreateResponseProto) GetFs() *HdfsFileStatusProto

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) GetDirPerm() *FsPermissionProto
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) GetStatus 

func (m *DataTransferEncryptorMessageProto) GetStatus() DataTransferEncryptorMessageProto_DataTransferEncryptorStatus

func (*DataTransferEncryptorMessageProto) ProtoMessage 

func (*DataTransferEncryptorMessageProto) ProtoMessage()

func (*DataTransferEncryptorMessageProto) Reset 

func (m *DataTransferEncryptorMessageProto) Reset()

func (*DataTransferEncryptorMessageProto) String 

func (m *DataTransferEncryptorMessageProto) String() 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 (x DataTransferEncryptorMessageProto_DataTransferEncryptorStatus) Enum() *DataTransferEncryptorMessageProto_DataTransferEncryptorStatus

func (DataTransferEncryptorMessageProto_DataTransferEncryptorStatus) String 

func (x DataTransferEncryptorMessageProto_DataTransferEncryptorStatus) String() string

func (*DataTransferEncryptorMessageProto_DataTransferEncryptorStatus) UnmarshalJSON 

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

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 (m *DatanodeInfoProto) GetAdminState() DatanodeInfoProto_AdminState

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 (x DatanodeInfoProto_AdminState) Enum() *DatanodeInfoProto_AdminState

func (DatanodeInfoProto_AdminState) String 

func (x DatanodeInfoProto_AdminState) String() 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 (x DatanodeReportTypeProto) Enum() *DatanodeReportTypeProto

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 

func (m *DisallowSnapshotRequestProto) String() 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 

func (m *DisallowSnapshotResponseProto) String() 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 

func (m *FinalizeUpgradeResponseProto) String() 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 (m *GetAdditionalDatanodeRequestProto) GetBlk() *ExtendedBlockProto

func (*GetAdditionalDatanodeRequestProto) GetClientName 

func (m *GetAdditionalDatanodeRequestProto) GetClientName() string

func (*GetAdditionalDatanodeRequestProto) GetExcludes 

func (m *GetAdditionalDatanodeRequestProto) GetExcludes() []*DatanodeInfoProto

func (*GetAdditionalDatanodeRequestProto) GetExistings 

func (m *GetAdditionalDatanodeRequestProto) GetExistings() []*DatanodeInfoProto

func (*GetAdditionalDatanodeRequestProto) GetNumAdditionalNodes 

func (m *GetAdditionalDatanodeRequestProto) GetNumAdditionalNodes() uint32

func (*GetAdditionalDatanodeRequestProto) GetSrc 

func (m *GetAdditionalDatanodeRequestProto) GetSrc() string

func (*GetAdditionalDatanodeRequestProto) ProtoMessage 

func (*GetAdditionalDatanodeRequestProto) ProtoMessage()

func (*GetAdditionalDatanodeRequestProto) Reset 

func (m *GetAdditionalDatanodeRequestProto) Reset()

func (*GetAdditionalDatanodeRequestProto) String 

func (m *GetAdditionalDatanodeRequestProto) String() 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 (m *GetAdditionalDatanodeResponseProto) GetBlock() *LocatedBlockProto

func (*GetAdditionalDatanodeResponseProto) ProtoMessage 

func (*GetAdditionalDatanodeResponseProto) ProtoMessage()

func (*GetAdditionalDatanodeResponseProto) Reset 

func (m *GetAdditionalDatanodeResponseProto) Reset()

func (*GetAdditionalDatanodeResponseProto) String 

func (m *GetAdditionalDatanodeResponseProto) String() 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 (m *GetBlockLocationsRequestProto) GetSrc() string

func (*GetBlockLocationsRequestProto) ProtoMessage 

func (*GetBlockLocationsRequestProto) ProtoMessage()

func (*GetBlockLocationsRequestProto) Reset 

func (m *GetBlockLocationsRequestProto) Reset()

func (*GetBlockLocationsRequestProto) String 

func (m *GetBlockLocationsRequestProto) String() 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 (m *GetBlockLocationsResponseProto) GetLocations() *LocatedBlocksProto

func (*GetBlockLocationsResponseProto) ProtoMessage 

func (*GetBlockLocationsResponseProto) ProtoMessage()

func (*GetBlockLocationsResponseProto) Reset 

func (m *GetBlockLocationsResponseProto) Reset()

func (*GetBlockLocationsResponseProto) String 

func (m *GetBlockLocationsResponseProto) String() 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 (m *GetContentSummaryRequestProto) GetPath() string

func (*GetContentSummaryRequestProto) ProtoMessage 

func (*GetContentSummaryRequestProto) ProtoMessage()

func (*GetContentSummaryRequestProto) Reset 

func (m *GetContentSummaryRequestProto) Reset()

func (*GetContentSummaryRequestProto) String 

func (m *GetContentSummaryRequestProto) String() 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 (m *GetContentSummaryResponseProto) GetSummary() *ContentSummaryProto

func (*GetContentSummaryResponseProto) ProtoMessage 

func (*GetContentSummaryResponseProto) ProtoMessage()

func (*GetContentSummaryResponseProto) Reset 

func (m *GetContentSummaryResponseProto) Reset()

func (*GetContentSummaryResponseProto) String 

func (m *GetContentSummaryResponseProto) String() string

type GetDataEncryptionKeyRequestProto 

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

func (*GetDataEncryptionKeyRequestProto) ProtoMessage 

func (*GetDataEncryptionKeyRequestProto) ProtoMessage()

func (*GetDataEncryptionKeyRequestProto) Reset 

func (m *GetDataEncryptionKeyRequestProto) Reset()

func (*GetDataEncryptionKeyRequestProto) String 

func (m *GetDataEncryptionKeyRequestProto) String() 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 (m *GetDataEncryptionKeyResponseProto) Reset()

func (*GetDataEncryptionKeyResponseProto) String 

func (m *GetDataEncryptionKeyResponseProto) String() 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 (m *GetDatanodeReportRequestProto) GetType() DatanodeReportTypeProto

func (*GetDatanodeReportRequestProto) ProtoMessage 

func (*GetDatanodeReportRequestProto) ProtoMessage()

func (*GetDatanodeReportRequestProto) Reset 

func (m *GetDatanodeReportRequestProto) Reset()

func (*GetDatanodeReportRequestProto) String 

func (m *GetDatanodeReportRequestProto) String() 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 (m *GetDatanodeReportResponseProto) GetDi() []*DatanodeInfoProto

func (*GetDatanodeReportResponseProto) ProtoMessage 

func (*GetDatanodeReportResponseProto) ProtoMessage()

func (*GetDatanodeReportResponseProto) Reset 

func (m *GetDatanodeReportResponseProto) Reset()

func (*GetDatanodeReportResponseProto) String 

func (m *GetDatanodeReportResponseProto) String() 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 (m *GetFileInfoResponseProto) GetFs() *HdfsFileStatusProto

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 (m *GetFileLinkInfoResponseProto) GetFs() *HdfsFileStatusProto

func (*GetFileLinkInfoResponseProto) ProtoMessage 

func (*GetFileLinkInfoResponseProto) ProtoMessage()

func (*GetFileLinkInfoResponseProto) Reset 

func (m *GetFileLinkInfoResponseProto) Reset()

func (*GetFileLinkInfoResponseProto) String 

func (m *GetFileLinkInfoResponseProto) String() 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 (m *GetListingResponseProto) GetDirList() *DirectoryListingProto

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 (m *GetPreferredBlockSizeRequestProto) Reset()

func (*GetPreferredBlockSizeRequestProto) String 

func (m *GetPreferredBlockSizeRequestProto) String() 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 (m *GetPreferredBlockSizeResponseProto) GetBsize() uint64

func (*GetPreferredBlockSizeResponseProto) ProtoMessage 

func (*GetPreferredBlockSizeResponseProto) ProtoMessage()

func (*GetPreferredBlockSizeResponseProto) Reset 

func (m *GetPreferredBlockSizeResponseProto) Reset()

func (*GetPreferredBlockSizeResponseProto) String 

func (m *GetPreferredBlockSizeResponseProto) String() 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 

func (m *GetServerDefaultsRequestProto) String() 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 

func (m *GetServerDefaultsResponseProto) String() 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 (m *GetSnapshotDiffReportRequestProto) Reset()

func (*GetSnapshotDiffReportRequestProto) String 

func (m *GetSnapshotDiffReportRequestProto) String() 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 (m *GetSnapshotDiffReportResponseProto) GetDiffReport() *SnapshotDiffReportProto

func (*GetSnapshotDiffReportResponseProto) ProtoMessage 

func (*GetSnapshotDiffReportResponseProto) ProtoMessage()

func (*GetSnapshotDiffReportResponseProto) Reset 

func (m *GetSnapshotDiffReportResponseProto) Reset()

func (*GetSnapshotDiffReportResponseProto) String 

func (m *GetSnapshotDiffReportResponseProto) String() string

type GetSnapshottableDirListingRequestProto 

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

func (*GetSnapshottableDirListingRequestProto) ProtoMessage 

func (*GetSnapshottableDirListingRequestProto) ProtoMessage()

func (*GetSnapshottableDirListingRequestProto) Reset 

func (m *GetSnapshottableDirListingRequestProto) Reset()

func (*GetSnapshottableDirListingRequestProto) String 

func (m *GetSnapshottableDirListingRequestProto) String() 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 (m *GetSnapshottableDirListingResponseProto) GetSnapshottableDirList() *SnapshottableDirectoryListingProto

func (*GetSnapshottableDirListingResponseProto) ProtoMessage 

func (*GetSnapshottableDirListingResponseProto) ProtoMessage()

func (*GetSnapshottableDirListingResponseProto) Reset 

func (m *GetSnapshottableDirListingResponseProto) Reset()

func (*GetSnapshottableDirListingResponseProto) String 

func (m *GetSnapshottableDirListingResponseProto) String() 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 (m *HdfsFileStatusProto) GetFileType() HdfsFileStatusProto_FileType

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 (x HdfsFileStatusProto_FileType) Enum() *HdfsFileStatusProto_FileType

func (HdfsFileStatusProto_FileType) String 

func (x HdfsFileStatusProto_FileType) String() 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 (m *ListCorruptFileBlocksRequestProto) GetCookie() string

func (*ListCorruptFileBlocksRequestProto) GetPath 

func (m *ListCorruptFileBlocksRequestProto) GetPath() string

func (*ListCorruptFileBlocksRequestProto) ProtoMessage 

func (*ListCorruptFileBlocksRequestProto) ProtoMessage()

func (*ListCorruptFileBlocksRequestProto) Reset 

func (m *ListCorruptFileBlocksRequestProto) Reset()

func (*ListCorruptFileBlocksRequestProto) String 

func (m *ListCorruptFileBlocksRequestProto) String() 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 (m *ListCorruptFileBlocksResponseProto) GetCorrupt() *CorruptFileBlocksProto

func (*ListCorruptFileBlocksResponseProto) ProtoMessage 

func (*ListCorruptFileBlocksResponseProto) ProtoMessage()

func (*ListCorruptFileBlocksResponseProto) Reset 

func (m *ListCorruptFileBlocksResponseProto) Reset()

func (*ListCorruptFileBlocksResponseProto) String 

func (m *ListCorruptFileBlocksResponseProto) String() 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 (m *LocatedBlockProto) GetB() *ExtendedBlockProto

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 (m *NamenodeCommandProto) GetType() NamenodeCommandProto_Type

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 (x NamenodeCommandProto_Type) Enum() *NamenodeCommandProto_Type

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 (m *NamenodeRegistrationProto) GetRole() NamenodeRegistrationProto_NamenodeRoleProto

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
)
const Default_NamenodeRegistrationProto_Role NamenodeRegistrationProto_NamenodeRoleProto = NamenodeRegistrationProto_NAMENODE

func (NamenodeRegistrationProto_NamenodeRoleProto) Enum 

func (x NamenodeRegistrationProto_NamenodeRoleProto) Enum() *NamenodeRegistrationProto_NamenodeRoleProto

func (NamenodeRegistrationProto_NamenodeRoleProto) String 

func (x NamenodeRegistrationProto_NamenodeRoleProto) String() 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 (m *OpBlockChecksumResponseProto) GetCrcType() ChecksumTypeProto

func (*OpBlockChecksumResponseProto) GetMd5 

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

func (*OpBlockChecksumResponseProto) ProtoMessage 

func (*OpBlockChecksumResponseProto) ProtoMessage()

func (*OpBlockChecksumResponseProto) Reset 

func (m *OpBlockChecksumResponseProto) Reset()

func (*OpBlockChecksumResponseProto) String 

func (m *OpBlockChecksumResponseProto) String() 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 (m *OpReadBlockProto) GetHeader() *ClientOperationHeaderProto

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 (m *OpRequestShortCircuitAccessProto) GetHeader() *BaseHeaderProto

func (*OpRequestShortCircuitAccessProto) GetMaxVersion 

func (m *OpRequestShortCircuitAccessProto) GetMaxVersion() uint32

func (*OpRequestShortCircuitAccessProto) ProtoMessage 

func (*OpRequestShortCircuitAccessProto) ProtoMessage()

func (*OpRequestShortCircuitAccessProto) Reset 

func (m *OpRequestShortCircuitAccessProto) Reset()

func (*OpRequestShortCircuitAccessProto) String 

func (m *OpRequestShortCircuitAccessProto) String() 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 (m *OpTransferBlockProto) GetHeader() *ClientOperationHeaderProto

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 (m *OpWriteBlockProto) GetHeader() *ClientOperationHeaderProto

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 (m *OpWriteBlockProto) GetStage() OpWriteBlockProto_BlockConstructionStage

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 (x OpWriteBlockProto_BlockConstructionStage) Enum() *OpWriteBlockProto_BlockConstructionStage

func (OpWriteBlockProto_BlockConstructionStage) String 

func (x OpWriteBlockProto_BlockConstructionStage) String() 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 (m *RemoteEditLogManifestProto) GetLogs() []*RemoteEditLogProto

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 (x ReplicaStateProto) Enum() *ReplicaStateProto

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 (m *ReportBadBlocksRequestProto) GetBlocks() []*LocatedBlockProto

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 

func (m *ReportBadBlocksResponseProto) String() 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 (m *RestoreFailedStorageRequestProto) GetArg() string

func (*RestoreFailedStorageRequestProto) ProtoMessage 

func (*RestoreFailedStorageRequestProto) ProtoMessage()

func (*RestoreFailedStorageRequestProto) Reset 

func (m *RestoreFailedStorageRequestProto) Reset()

func (*RestoreFailedStorageRequestProto) String 

func (m *RestoreFailedStorageRequestProto) String() 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 (m *RestoreFailedStorageResponseProto) Reset()

func (*RestoreFailedStorageResponseProto) String 

func (m *RestoreFailedStorageResponseProto) String() 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 (x SafeModeActionProto) Enum() *SafeModeActionProto

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 (m *SetBalancerBandwidthRequestProto) Reset()

func (*SetBalancerBandwidthRequestProto) String 

func (m *SetBalancerBandwidthRequestProto) String() string

type SetBalancerBandwidthResponseProto 

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

func (*SetBalancerBandwidthResponseProto) ProtoMessage 

func (*SetBalancerBandwidthResponseProto) ProtoMessage()

func (*SetBalancerBandwidthResponseProto) Reset 

func (m *SetBalancerBandwidthResponseProto) Reset()

func (*SetBalancerBandwidthResponseProto) String 

func (m *SetBalancerBandwidthResponseProto) String() 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 (m *SetSafeModeRequestProto) GetAction() SafeModeActionProto

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 

func (m *SnapshotDiffReportEntryProto) String() 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 (m *SnapshottableDirectoryListingProto) Reset()

func (*SnapshottableDirectoryListingProto) String 

func (m *SnapshottableDirectoryListingProto) String() 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 (m *SnapshottableDirectoryStatusProto) GetDirStatus() *HdfsFileStatusProto

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 (m *SnapshottableDirectoryStatusProto) Reset()

func (*SnapshottableDirectoryStatusProto) String 

func (m *SnapshottableDirectoryStatusProto) String() 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 (m *UpdateBlockForPipelineRequestProto) GetBlock() *ExtendedBlockProto

func (*UpdateBlockForPipelineRequestProto) GetClientName 

func (m *UpdateBlockForPipelineRequestProto) GetClientName() string

func (*UpdateBlockForPipelineRequestProto) ProtoMessage 

func (*UpdateBlockForPipelineRequestProto) ProtoMessage()

func (*UpdateBlockForPipelineRequestProto) Reset 

func (m *UpdateBlockForPipelineRequestProto) Reset()

func (*UpdateBlockForPipelineRequestProto) String 

func (m *UpdateBlockForPipelineRequestProto) String() 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 (m *UpdateBlockForPipelineResponseProto) GetBlock() *LocatedBlockProto

func (*UpdateBlockForPipelineResponseProto) ProtoMessage 

func (*UpdateBlockForPipelineResponseProto) ProtoMessage()

func (*UpdateBlockForPipelineResponseProto) Reset 

func (m *UpdateBlockForPipelineResponseProto) Reset()

func (*UpdateBlockForPipelineResponseProto) String 

func (m *UpdateBlockForPipelineResponseProto) String() 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 (m *UpdatePipelineRequestProto) GetNewBlock() *ExtendedBlockProto

func (*UpdatePipelineRequestProto) GetNewNodes 

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

func (*UpdatePipelineRequestProto) GetOldBlock 

func (m *UpdatePipelineRequestProto) GetOldBlock() *ExtendedBlockProto

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 (m *VersionResponseProto) GetInfo() *NamespaceInfoProto

func (*VersionResponseProto) ProtoMessage 

func (*VersionResponseProto) ProtoMessage()

func (*VersionResponseProto) Reset 

func (m *VersionResponseProto) Reset()

func (*VersionResponseProto) String 

func (m *VersionResponseProto) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

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