hadoop_hdfs_datanode

package
v0.0.0-...-58217a2 Latest Latest
Warning

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

 Go to latest Published: Aug 28, 2014 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

Overview

Package hadoop_hdfs_datanode is a generated protocol buffer package.

It is generated from these files: 

DatanodeProtocol.proto

It has these top-level messages: 

DatanodeRegistrationProto
DatanodeStorageProto
DatanodeCommandProto
BalancerBandwidthCommandProto
BlockCommandProto
BlockIdCommandProto
BlockRecoveryCommandProto
FinalizeCommandProto
KeyUpdateCommandProto
RegisterCommandProto
RegisterDatanodeRequestProto
RegisterDatanodeResponseProto
HeartbeatRequestProto
StorageReportProto
NNHAStatusHeartbeatProto
HeartbeatResponseProto
BlockReportRequestProto
StorageBlockReportProto
BlockReportResponseProto
CacheReportRequestProto
CacheReportResponseProto
ReceivedDeletedBlockInfoProto
StorageReceivedDeletedBlocksProto
BlockReceivedAndDeletedRequestProto
BlockReceivedAndDeletedResponseProto
ErrorReportRequestProto
ErrorReportResponseProto
ReportBadBlocksRequestProto
ReportBadBlocksResponseProto
CommitBlockSynchronizationRequestProto
CommitBlockSynchronizationResponseProto

Index

Constants

View Source 
const Default_DatanodeStorageProto_StorageType hadoop_hdfs.StorageTypeProto = hadoop_hdfs.StorageTypeProto_DISK
View Source 
const Default_HeartbeatRequestProto_CacheCapacity uint64 = 0
View Source 
const Default_HeartbeatRequestProto_CacheUsed uint64 = 0
View Source 
const Default_HeartbeatRequestProto_FailedVolumes uint32 = 0
View Source 
const Default_HeartbeatRequestProto_XceiverCount uint32 = 0
View Source 
const Default_HeartbeatRequestProto_XmitsInProgress uint32 = 0
View Source 
const Default_StorageReportProto_BlockPoolUsed uint64 = 0
View Source 
const Default_StorageReportProto_Capacity uint64 = 0
View Source 
const Default_StorageReportProto_DfsUsed uint64 = 0
View Source 
const Default_StorageReportProto_Failed bool = false
View Source 
const Default_StorageReportProto_Remaining uint64 = 0

Variables

View Source 
var BlockCommandProto_Action_name = map[int32]string{
	1: "TRANSFER",
	2: "INVALIDATE",
	3: "SHUTDOWN",
}
View Source 
var BlockCommandProto_Action_value = map[string]int32{
	"TRANSFER":   1,
	"INVALIDATE": 2,
	"SHUTDOWN":   3,
}
View Source 
var BlockIdCommandProto_Action_name = map[int32]string{
	1: "CACHE",
	2: "UNCACHE",
}
View Source 
var BlockIdCommandProto_Action_value = map[string]int32{
	"CACHE":   1,
	"UNCACHE": 2,
}
View Source 
var DatanodeCommandProto_Type_name = map[int32]string{
	0: "BalancerBandwidthCommand",
	1: "BlockCommand",
	2: "BlockRecoveryCommand",
	3: "FinalizeCommand",
	4: "KeyUpdateCommand",
	5: "RegisterCommand",
	6: "UnusedUpgradeCommand",
	7: "NullDatanodeCommand",
	8: "BlockIdCommand",
}
View Source 
var DatanodeCommandProto_Type_value = map[string]int32{
	"BalancerBandwidthCommand": 0,
	"BlockCommand":             1,
	"BlockRecoveryCommand":     2,
	"FinalizeCommand":          3,
	"KeyUpdateCommand":         4,
	"RegisterCommand":          5,
	"UnusedUpgradeCommand":     6,
	"NullDatanodeCommand":      7,
	"BlockIdCommand":           8,
}
View Source 
var DatanodeStorageProto_StorageState_name = map[int32]string{
	0: "NORMAL",
	1: "READ_ONLY_SHARED",
}
View Source 
var DatanodeStorageProto_StorageState_value = map[string]int32{
	"NORMAL":           0,
	"READ_ONLY_SHARED": 1,
}
View Source 
var ErrorReportRequestProto_ErrorCode_name = map[int32]string{
	0: "NOTIFY",
	1: "DISK_ERROR",
	2: "INVALID_BLOCK",
	3: "FATAL_DISK_ERROR",
}
View Source 
var ErrorReportRequestProto_ErrorCode_value = map[string]int32{
	"NOTIFY":           0,
	"DISK_ERROR":       1,
	"INVALID_BLOCK":    2,
	"FATAL_DISK_ERROR": 3,
}
View Source 
var NNHAStatusHeartbeatProto_State_name = map[int32]string{
	0: "ACTIVE",
	1: "STANDBY",
}
View Source 
var NNHAStatusHeartbeatProto_State_value = map[string]int32{
	"ACTIVE":  0,
	"STANDBY": 1,
}
View Source 
var ReceivedDeletedBlockInfoProto_BlockStatus_name = map[int32]string{
	1: "RECEIVING",
	2: "RECEIVED",
	3: "DELETED",
}
View Source 
var ReceivedDeletedBlockInfoProto_BlockStatus_value = map[string]int32{
	"RECEIVING": 1,
	"RECEIVED":  2,
	"DELETED":   3,
}

Functions

This section is empty.

Types

type BalancerBandwidthCommandProto 

type BalancerBandwidthCommandProto struct {
	// Maximum bandwidth to be used by datanode for balancing
	Bandwidth        *uint64 `protobuf:"varint,1,req,name=bandwidth" json:"bandwidth,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* Command sent from namenode to datanode to set the maximum bandwidth to be used for balancing.

func (*BalancerBandwidthCommandProto) GetBandwidth 

func (m *BalancerBandwidthCommandProto) GetBandwidth() uint64

func (*BalancerBandwidthCommandProto) ProtoMessage 

func (*BalancerBandwidthCommandProto) ProtoMessage()

func (*BalancerBandwidthCommandProto) Reset 

func (m *BalancerBandwidthCommandProto) Reset()

func (*BalancerBandwidthCommandProto) String 

func (m *BalancerBandwidthCommandProto) String() string

type BlockCommandProto 

type BlockCommandProto struct {
	Action             *BlockCommandProto_Action         `protobuf:"varint,1,req,name=action,enum=hadoop.hdfs.datanode.BlockCommandProto_Action" json:"action,omitempty"`
	BlockPoolId        *string                           `protobuf:"bytes,2,req,name=blockPoolId" json:"blockPoolId,omitempty"`
	Blocks             []*hadoop_hdfs.BlockProto         `protobuf:"bytes,3,rep,name=blocks" json:"blocks,omitempty"`
	Targets            []*hadoop_hdfs.DatanodeInfosProto `protobuf:"bytes,4,rep,name=targets" json:"targets,omitempty"`
	TargetStorageUuids []*hadoop_hdfs.StorageUuidsProto  `protobuf:"bytes,5,rep,name=targetStorageUuids" json:"targetStorageUuids,omitempty"`
	XXX_unrecognized   []byte                            `json:"-"`
}

* Command to instruct datanodes to perform certain action on the given set of blocks.

func (*BlockCommandProto) GetAction 

func (m *BlockCommandProto) GetAction() BlockCommandProto_Action

func (*BlockCommandProto) GetBlockPoolId 

func (m *BlockCommandProto) GetBlockPoolId() string

func (*BlockCommandProto) GetBlocks 

func (m *BlockCommandProto) GetBlocks() []*hadoop_hdfs.BlockProto

func (*BlockCommandProto) GetTargetStorageUuids 

func (m *BlockCommandProto) GetTargetStorageUuids() []*hadoop_hdfs.StorageUuidsProto

func (*BlockCommandProto) GetTargets 

func (m *BlockCommandProto) GetTargets() []*hadoop_hdfs.DatanodeInfosProto

func (*BlockCommandProto) ProtoMessage 

func (*BlockCommandProto) ProtoMessage()

func (*BlockCommandProto) Reset 

func (m *BlockCommandProto) Reset()

func (*BlockCommandProto) String 

func (m *BlockCommandProto) String() string

type BlockCommandProto_Action 

type BlockCommandProto_Action int32
const (
	BlockCommandProto_TRANSFER   BlockCommandProto_Action = 1
	BlockCommandProto_INVALIDATE BlockCommandProto_Action = 2
	BlockCommandProto_SHUTDOWN   BlockCommandProto_Action = 3
)

func (BlockCommandProto_Action) Enum 

func (x BlockCommandProto_Action) Enum() *BlockCommandProto_Action

func (BlockCommandProto_Action) String 

func (x BlockCommandProto_Action) String() string

func (*BlockCommandProto_Action) UnmarshalJSON 

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

type BlockIdCommandProto 

type BlockIdCommandProto struct {
	Action           *BlockIdCommandProto_Action `protobuf:"varint,1,req,name=action,enum=hadoop.hdfs.datanode.BlockIdCommandProto_Action" json:"action,omitempty"`
	BlockPoolId      *string                     `protobuf:"bytes,2,req,name=blockPoolId" json:"blockPoolId,omitempty"`
	BlockIds         []uint64                    `protobuf:"varint,3,rep,packed,name=blockIds" json:"blockIds,omitempty"`
	XXX_unrecognized []byte                      `json:"-"`
}

* Command to instruct datanodes to perform certain action on the given set of block IDs.

func (*BlockIdCommandProto) GetAction 

func (m *BlockIdCommandProto) GetAction() BlockIdCommandProto_Action

func (*BlockIdCommandProto) GetBlockIds 

func (m *BlockIdCommandProto) GetBlockIds() []uint64

func (*BlockIdCommandProto) GetBlockPoolId 

func (m *BlockIdCommandProto) GetBlockPoolId() string

func (*BlockIdCommandProto) ProtoMessage 

func (*BlockIdCommandProto) ProtoMessage()

func (*BlockIdCommandProto) Reset 

func (m *BlockIdCommandProto) Reset()

func (*BlockIdCommandProto) String 

func (m *BlockIdCommandProto) String() string

type BlockIdCommandProto_Action 

type BlockIdCommandProto_Action int32
const (
	BlockIdCommandProto_CACHE   BlockIdCommandProto_Action = 1
	BlockIdCommandProto_UNCACHE BlockIdCommandProto_Action = 2
)

func (BlockIdCommandProto_Action) Enum 

func (x BlockIdCommandProto_Action) Enum() *BlockIdCommandProto_Action

func (BlockIdCommandProto_Action) String 

func (x BlockIdCommandProto_Action) String() string

func (*BlockIdCommandProto_Action) UnmarshalJSON 

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

type BlockReceivedAndDeletedRequestProto 

type BlockReceivedAndDeletedRequestProto struct {
	Registration     *DatanodeRegistrationProto           `protobuf:"bytes,1,req,name=registration" json:"registration,omitempty"`
	BlockPoolId      *string                              `protobuf:"bytes,2,req,name=blockPoolId" json:"blockPoolId,omitempty"`
	Blocks           []*StorageReceivedDeletedBlocksProto `protobuf:"bytes,3,rep,name=blocks" json:"blocks,omitempty"`
	XXX_unrecognized []byte                               `json:"-"`
}

* registration - datanode registration information blockPoolID - block pool ID of the reported blocks blocks - Received/deleted block list

func (*BlockReceivedAndDeletedRequestProto) GetBlockPoolId 

func (m *BlockReceivedAndDeletedRequestProto) GetBlockPoolId() string

func (*BlockReceivedAndDeletedRequestProto) GetBlocks 

func (m *BlockReceivedAndDeletedRequestProto) GetBlocks() []*StorageReceivedDeletedBlocksProto

func (*BlockReceivedAndDeletedRequestProto) GetRegistration 

func (m *BlockReceivedAndDeletedRequestProto) GetRegistration() *DatanodeRegistrationProto

func (*BlockReceivedAndDeletedRequestProto) ProtoMessage 

func (*BlockReceivedAndDeletedRequestProto) ProtoMessage()

func (*BlockReceivedAndDeletedRequestProto) Reset 

func (m *BlockReceivedAndDeletedRequestProto) Reset()

func (*BlockReceivedAndDeletedRequestProto) String 

func (m *BlockReceivedAndDeletedRequestProto) String() string

type BlockReceivedAndDeletedResponseProto 

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

* void response

func (*BlockReceivedAndDeletedResponseProto) ProtoMessage 

func (*BlockReceivedAndDeletedResponseProto) ProtoMessage()

func (*BlockReceivedAndDeletedResponseProto) Reset 

func (m *BlockReceivedAndDeletedResponseProto) Reset()

func (*BlockReceivedAndDeletedResponseProto) String 

func (m *BlockReceivedAndDeletedResponseProto) String() string

type BlockRecoveryCommandProto 

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

* List of blocks to be recovered by the datanode

func (*BlockRecoveryCommandProto) GetBlocks 

func (m *BlockRecoveryCommandProto) GetBlocks() []*hadoop_hdfs.RecoveringBlockProto

func (*BlockRecoveryCommandProto) ProtoMessage 

func (*BlockRecoveryCommandProto) ProtoMessage()

func (*BlockRecoveryCommandProto) Reset 

func (m *BlockRecoveryCommandProto) Reset()

func (*BlockRecoveryCommandProto) String 

func (m *BlockRecoveryCommandProto) String() string

type BlockReportRequestProto 

type BlockReportRequestProto struct {
	Registration     *DatanodeRegistrationProto `protobuf:"bytes,1,req,name=registration" json:"registration,omitempty"`
	BlockPoolId      *string                    `protobuf:"bytes,2,req,name=blockPoolId" json:"blockPoolId,omitempty"`
	Reports          []*StorageBlockReportProto `protobuf:"bytes,3,rep,name=reports" json:"reports,omitempty"`
	XXX_unrecognized []byte                     `json:"-"`
}

* registration - datanode registration information blockPoolID - block pool ID of the reported blocks blocks - each block is represented as multiple longs in the array. 

first long represents block ID
second long represents length
third long represents gen stamp
fourth long (if under construction) represents replica state

func (*BlockReportRequestProto) GetBlockPoolId 

func (m *BlockReportRequestProto) GetBlockPoolId() string

func (*BlockReportRequestProto) GetRegistration 

func (m *BlockReportRequestProto) GetRegistration() *DatanodeRegistrationProto

func (*BlockReportRequestProto) GetReports 

func (m *BlockReportRequestProto) GetReports() []*StorageBlockReportProto

func (*BlockReportRequestProto) ProtoMessage 

func (*BlockReportRequestProto) ProtoMessage()

func (*BlockReportRequestProto) Reset 

func (m *BlockReportRequestProto) Reset()

func (*BlockReportRequestProto) String 

func (m *BlockReportRequestProto) String() string

type BlockReportResponseProto 

type BlockReportResponseProto struct {
	Cmd              *DatanodeCommandProto `protobuf:"bytes,1,opt,name=cmd" json:"cmd,omitempty"`
	XXX_unrecognized []byte                `json:"-"`
}

* cmd - Command from namenode to the datanode

func (*BlockReportResponseProto) GetCmd 

func (m *BlockReportResponseProto) GetCmd() *DatanodeCommandProto

func (*BlockReportResponseProto) ProtoMessage 

func (*BlockReportResponseProto) ProtoMessage()

func (*BlockReportResponseProto) Reset 

func (m *BlockReportResponseProto) Reset()

func (*BlockReportResponseProto) String 

func (m *BlockReportResponseProto) String() string

type CacheReportRequestProto 

type CacheReportRequestProto struct {
	Registration     *DatanodeRegistrationProto `protobuf:"bytes,1,req,name=registration" json:"registration,omitempty"`
	BlockPoolId      *string                    `protobuf:"bytes,2,req,name=blockPoolId" json:"blockPoolId,omitempty"`
	Blocks           []uint64                   `protobuf:"varint,3,rep,packed,name=blocks" json:"blocks,omitempty"`
	XXX_unrecognized []byte                     `json:"-"`
}

* registration - datanode registration information blockPoolId - block pool ID of the reported blocks blocks - representation of blocks as longs for efficiency reasons

func (*CacheReportRequestProto) GetBlockPoolId 

func (m *CacheReportRequestProto) GetBlockPoolId() string

func (*CacheReportRequestProto) GetBlocks 

func (m *CacheReportRequestProto) GetBlocks() []uint64

func (*CacheReportRequestProto) GetRegistration 

func (m *CacheReportRequestProto) GetRegistration() *DatanodeRegistrationProto

func (*CacheReportRequestProto) ProtoMessage 

func (*CacheReportRequestProto) ProtoMessage()

func (*CacheReportRequestProto) Reset 

func (m *CacheReportRequestProto) Reset()

func (*CacheReportRequestProto) String 

func (m *CacheReportRequestProto) String() string

type CacheReportResponseProto 

type CacheReportResponseProto struct {
	Cmd              *DatanodeCommandProto `protobuf:"bytes,1,opt,name=cmd" json:"cmd,omitempty"`
	XXX_unrecognized []byte                `json:"-"`
}

func (*CacheReportResponseProto) GetCmd 

func (m *CacheReportResponseProto) GetCmd() *DatanodeCommandProto

func (*CacheReportResponseProto) ProtoMessage 

func (*CacheReportResponseProto) ProtoMessage()

func (*CacheReportResponseProto) Reset 

func (m *CacheReportResponseProto) Reset()

func (*CacheReportResponseProto) String 

func (m *CacheReportResponseProto) String() string

type CommitBlockSynchronizationRequestProto 

type CommitBlockSynchronizationRequestProto struct {
	Block             *hadoop_hdfs.ExtendedBlockProto `protobuf:"bytes,1,req,name=block" json:"block,omitempty"`
	NewGenStamp       *uint64                         `protobuf:"varint,2,req,name=newGenStamp" json:"newGenStamp,omitempty"`
	NewLength         *uint64                         `protobuf:"varint,3,req,name=newLength" json:"newLength,omitempty"`
	CloseFile         *bool                           `protobuf:"varint,4,req,name=closeFile" json:"closeFile,omitempty"`
	DeleteBlock       *bool                           `protobuf:"varint,5,req,name=deleteBlock" json:"deleteBlock,omitempty"`
	NewTaragets       []*hadoop_hdfs.DatanodeIDProto  `protobuf:"bytes,6,rep,name=newTaragets" json:"newTaragets,omitempty"`
	NewTargetStorages []string                        `protobuf:"bytes,7,rep,name=newTargetStorages" json:"newTargetStorages,omitempty"`
	XXX_unrecognized  []byte                          `json:"-"`
}

* Commit block synchronization request during lease recovery

func (*CommitBlockSynchronizationRequestProto) GetBlock 

func (m *CommitBlockSynchronizationRequestProto) GetBlock() *hadoop_hdfs.ExtendedBlockProto

func (*CommitBlockSynchronizationRequestProto) GetCloseFile 

func (m *CommitBlockSynchronizationRequestProto) GetCloseFile() bool

func (*CommitBlockSynchronizationRequestProto) GetDeleteBlock 

func (m *CommitBlockSynchronizationRequestProto) GetDeleteBlock() bool

func (*CommitBlockSynchronizationRequestProto) GetNewGenStamp 

func (m *CommitBlockSynchronizationRequestProto) GetNewGenStamp() uint64

func (*CommitBlockSynchronizationRequestProto) GetNewLength 

func (m *CommitBlockSynchronizationRequestProto) GetNewLength() uint64

func (*CommitBlockSynchronizationRequestProto) GetNewTaragets 

func (m *CommitBlockSynchronizationRequestProto) GetNewTaragets() []*hadoop_hdfs.DatanodeIDProto

func (*CommitBlockSynchronizationRequestProto) GetNewTargetStorages 

func (m *CommitBlockSynchronizationRequestProto) GetNewTargetStorages() []string

func (*CommitBlockSynchronizationRequestProto) ProtoMessage 

func (*CommitBlockSynchronizationRequestProto) ProtoMessage()

func (*CommitBlockSynchronizationRequestProto) Reset 

func (m *CommitBlockSynchronizationRequestProto) Reset()

func (*CommitBlockSynchronizationRequestProto) String 

func (m *CommitBlockSynchronizationRequestProto) String() string

type CommitBlockSynchronizationResponseProto 

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

* void response

func (*CommitBlockSynchronizationResponseProto) ProtoMessage 

func (*CommitBlockSynchronizationResponseProto) ProtoMessage()

func (*CommitBlockSynchronizationResponseProto) Reset 

func (m *CommitBlockSynchronizationResponseProto) Reset()

func (*CommitBlockSynchronizationResponseProto) String 

func (m *CommitBlockSynchronizationResponseProto) String() string

type DatanodeCommandProto 

type DatanodeCommandProto struct {
	CmdType *DatanodeCommandProto_Type `protobuf:"varint,1,req,name=cmdType,enum=hadoop.hdfs.datanode.DatanodeCommandProto_Type" json:"cmdType,omitempty"`
	// One of the following command is available when the corresponding
	// cmdType is set
	BalancerCmd      *BalancerBandwidthCommandProto `protobuf:"bytes,2,opt,name=balancerCmd" json:"balancerCmd,omitempty"`
	BlkCmd           *BlockCommandProto             `protobuf:"bytes,3,opt,name=blkCmd" json:"blkCmd,omitempty"`
	RecoveryCmd      *BlockRecoveryCommandProto     `protobuf:"bytes,4,opt,name=recoveryCmd" json:"recoveryCmd,omitempty"`
	FinalizeCmd      *FinalizeCommandProto          `protobuf:"bytes,5,opt,name=finalizeCmd" json:"finalizeCmd,omitempty"`
	KeyUpdateCmd     *KeyUpdateCommandProto         `protobuf:"bytes,6,opt,name=keyUpdateCmd" json:"keyUpdateCmd,omitempty"`
	RegisterCmd      *RegisterCommandProto          `protobuf:"bytes,7,opt,name=registerCmd" json:"registerCmd,omitempty"`
	BlkIdCmd         *BlockIdCommandProto           `protobuf:"bytes,8,opt,name=blkIdCmd" json:"blkIdCmd,omitempty"`
	XXX_unrecognized []byte                         `json:"-"`
}

* Commands sent from namenode to the datanodes

func (*DatanodeCommandProto) GetBalancerCmd 

func (m *DatanodeCommandProto) GetBalancerCmd() *BalancerBandwidthCommandProto

func (*DatanodeCommandProto) GetBlkCmd 

func (m *DatanodeCommandProto) GetBlkCmd() *BlockCommandProto

func (*DatanodeCommandProto) GetBlkIdCmd 

func (m *DatanodeCommandProto) GetBlkIdCmd() *BlockIdCommandProto

func (*DatanodeCommandProto) GetCmdType 

func (m *DatanodeCommandProto) GetCmdType() DatanodeCommandProto_Type

func (*DatanodeCommandProto) GetFinalizeCmd 

func (m *DatanodeCommandProto) GetFinalizeCmd() *FinalizeCommandProto

func (*DatanodeCommandProto) GetKeyUpdateCmd 

func (m *DatanodeCommandProto) GetKeyUpdateCmd() *KeyUpdateCommandProto

func (*DatanodeCommandProto) GetRecoveryCmd 

func (m *DatanodeCommandProto) GetRecoveryCmd() *BlockRecoveryCommandProto

func (*DatanodeCommandProto) GetRegisterCmd 

func (m *DatanodeCommandProto) GetRegisterCmd() *RegisterCommandProto

func (*DatanodeCommandProto) ProtoMessage 

func (*DatanodeCommandProto) ProtoMessage()

func (*DatanodeCommandProto) Reset 

func (m *DatanodeCommandProto) Reset()

func (*DatanodeCommandProto) String 

func (m *DatanodeCommandProto) String() string

type DatanodeCommandProto_Type 

type DatanodeCommandProto_Type int32
const (
	DatanodeCommandProto_BalancerBandwidthCommand DatanodeCommandProto_Type = 0
	DatanodeCommandProto_BlockCommand             DatanodeCommandProto_Type = 1
	DatanodeCommandProto_BlockRecoveryCommand     DatanodeCommandProto_Type = 2
	DatanodeCommandProto_FinalizeCommand          DatanodeCommandProto_Type = 3
	DatanodeCommandProto_KeyUpdateCommand         DatanodeCommandProto_Type = 4
	DatanodeCommandProto_RegisterCommand          DatanodeCommandProto_Type = 5
	DatanodeCommandProto_UnusedUpgradeCommand     DatanodeCommandProto_Type = 6
	DatanodeCommandProto_NullDatanodeCommand      DatanodeCommandProto_Type = 7
	DatanodeCommandProto_BlockIdCommand           DatanodeCommandProto_Type = 8
)

func (DatanodeCommandProto_Type) Enum 

func (x DatanodeCommandProto_Type) Enum() *DatanodeCommandProto_Type

func (DatanodeCommandProto_Type) String 

func (x DatanodeCommandProto_Type) String() string

func (*DatanodeCommandProto_Type) UnmarshalJSON 

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

type DatanodeRegistrationProto 

type DatanodeRegistrationProto struct {
	DatanodeID       *hadoop_hdfs.DatanodeIDProto        `protobuf:"bytes,1,req,name=datanodeID" json:"datanodeID,omitempty"`
	StorageInfo      *hadoop_hdfs.StorageInfoProto       `protobuf:"bytes,2,req,name=storageInfo" json:"storageInfo,omitempty"`
	Keys             *hadoop_hdfs.ExportedBlockKeysProto `protobuf:"bytes,3,req,name=keys" json:"keys,omitempty"`
	SoftwareVersion  *string                             `protobuf:"bytes,4,req,name=softwareVersion" json:"softwareVersion,omitempty"`
	XXX_unrecognized []byte                              `json:"-"`
}

* Information to identify a datanode to a namenode

func (*DatanodeRegistrationProto) GetDatanodeID 

func (m *DatanodeRegistrationProto) GetDatanodeID() *hadoop_hdfs.DatanodeIDProto

func (*DatanodeRegistrationProto) GetKeys 

func (m *DatanodeRegistrationProto) GetKeys() *hadoop_hdfs.ExportedBlockKeysProto

func (*DatanodeRegistrationProto) GetSoftwareVersion 

func (m *DatanodeRegistrationProto) GetSoftwareVersion() string

func (*DatanodeRegistrationProto) GetStorageInfo 

func (m *DatanodeRegistrationProto) GetStorageInfo() *hadoop_hdfs.StorageInfoProto

func (*DatanodeRegistrationProto) ProtoMessage 

func (*DatanodeRegistrationProto) ProtoMessage()

func (*DatanodeRegistrationProto) Reset 

func (m *DatanodeRegistrationProto) Reset()

func (*DatanodeRegistrationProto) String 

func (m *DatanodeRegistrationProto) String() string

type DatanodeStorageProto 

type DatanodeStorageProto struct {
	StorageUuid      *string                            `protobuf:"bytes,1,req,name=storageUuid" json:"storageUuid,omitempty"`
	State            *DatanodeStorageProto_StorageState `protobuf:"varint,2,opt,name=state,enum=hadoop.hdfs.datanode.DatanodeStorageProto_StorageState,def=0" json:"state,omitempty"`
	StorageType      *hadoop_hdfs.StorageTypeProto      `protobuf:"varint,3,opt,name=storageType,enum=hadoop.hdfs.StorageTypeProto,def=1" json:"storageType,omitempty"`
	XXX_unrecognized []byte                             `json:"-"`
}

* Represents a storage available on the datanode

func (*DatanodeStorageProto) GetState 

func (m *DatanodeStorageProto) GetState() DatanodeStorageProto_StorageState

func (*DatanodeStorageProto) GetStorageType 

func (m *DatanodeStorageProto) GetStorageType() hadoop_hdfs.StorageTypeProto

func (*DatanodeStorageProto) GetStorageUuid 

func (m *DatanodeStorageProto) GetStorageUuid() string

func (*DatanodeStorageProto) ProtoMessage 

func (*DatanodeStorageProto) ProtoMessage()

func (*DatanodeStorageProto) Reset 

func (m *DatanodeStorageProto) Reset()

func (*DatanodeStorageProto) String 

func (m *DatanodeStorageProto) String() string

type DatanodeStorageProto_StorageState 

type DatanodeStorageProto_StorageState int32
const (
	DatanodeStorageProto_NORMAL           DatanodeStorageProto_StorageState = 0
	DatanodeStorageProto_READ_ONLY_SHARED DatanodeStorageProto_StorageState = 1
)
const Default_DatanodeStorageProto_State DatanodeStorageProto_StorageState = DatanodeStorageProto_NORMAL

func (DatanodeStorageProto_StorageState) Enum 

func (x DatanodeStorageProto_StorageState) Enum() *DatanodeStorageProto_StorageState

func (DatanodeStorageProto_StorageState) String 

func (x DatanodeStorageProto_StorageState) String() string

func (*DatanodeStorageProto_StorageState) UnmarshalJSON 

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

type ErrorReportRequestProto 

type ErrorReportRequestProto struct {
	Registartion     *DatanodeRegistrationProto `protobuf:"bytes,1,req,name=registartion" json:"registartion,omitempty"`
	ErrorCode        *uint32                    `protobuf:"varint,2,req,name=errorCode" json:"errorCode,omitempty"`
	Msg              *string                    `protobuf:"bytes,3,req,name=msg" json:"msg,omitempty"`
	XXX_unrecognized []byte                     `json:"-"`
}

* registartion - Datanode reporting the error errorCode - error code indicating the error msg - Free text description of the error

func (*ErrorReportRequestProto) GetErrorCode 

func (m *ErrorReportRequestProto) GetErrorCode() uint32

func (*ErrorReportRequestProto) GetMsg 

func (m *ErrorReportRequestProto) GetMsg() string

func (*ErrorReportRequestProto) GetRegistartion 

func (m *ErrorReportRequestProto) GetRegistartion() *DatanodeRegistrationProto

func (*ErrorReportRequestProto) ProtoMessage 

func (*ErrorReportRequestProto) ProtoMessage()

func (*ErrorReportRequestProto) Reset 

func (m *ErrorReportRequestProto) Reset()

func (*ErrorReportRequestProto) String 

func (m *ErrorReportRequestProto) String() string

type ErrorReportRequestProto_ErrorCode 

type ErrorReportRequestProto_ErrorCode int32
const (
	ErrorReportRequestProto_NOTIFY           ErrorReportRequestProto_ErrorCode = 0
	ErrorReportRequestProto_DISK_ERROR       ErrorReportRequestProto_ErrorCode = 1
	ErrorReportRequestProto_INVALID_BLOCK    ErrorReportRequestProto_ErrorCode = 2
	ErrorReportRequestProto_FATAL_DISK_ERROR ErrorReportRequestProto_ErrorCode = 3
)

func (ErrorReportRequestProto_ErrorCode) Enum 

func (x ErrorReportRequestProto_ErrorCode) Enum() *ErrorReportRequestProto_ErrorCode

func (ErrorReportRequestProto_ErrorCode) String 

func (x ErrorReportRequestProto_ErrorCode) String() string

func (*ErrorReportRequestProto_ErrorCode) UnmarshalJSON 

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

type ErrorReportResponseProto 

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

* void response

func (*ErrorReportResponseProto) ProtoMessage 

func (*ErrorReportResponseProto) ProtoMessage()

func (*ErrorReportResponseProto) Reset 

func (m *ErrorReportResponseProto) Reset()

func (*ErrorReportResponseProto) String 

func (m *ErrorReportResponseProto) String() string

type FinalizeCommandProto 

type FinalizeCommandProto struct {
	BlockPoolId      *string `protobuf:"bytes,1,req,name=blockPoolId" json:"blockPoolId,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* Finalize the upgrade at the datanode

func (*FinalizeCommandProto) GetBlockPoolId 

func (m *FinalizeCommandProto) GetBlockPoolId() string

func (*FinalizeCommandProto) ProtoMessage 

func (*FinalizeCommandProto) ProtoMessage()

func (*FinalizeCommandProto) Reset 

func (m *FinalizeCommandProto) Reset()

func (*FinalizeCommandProto) String 

func (m *FinalizeCommandProto) String() string

type HeartbeatRequestProto 

type HeartbeatRequestProto struct {
	Registration     *DatanodeRegistrationProto `protobuf:"bytes,1,req,name=registration" json:"registration,omitempty"`
	Reports          []*StorageReportProto      `protobuf:"bytes,2,rep,name=reports" json:"reports,omitempty"`
	XmitsInProgress  *uint32                    `protobuf:"varint,3,opt,name=xmitsInProgress,def=0" json:"xmitsInProgress,omitempty"`
	XceiverCount     *uint32                    `protobuf:"varint,4,opt,name=xceiverCount,def=0" json:"xceiverCount,omitempty"`
	FailedVolumes    *uint32                    `protobuf:"varint,5,opt,name=failedVolumes,def=0" json:"failedVolumes,omitempty"`
	CacheCapacity    *uint64                    `protobuf:"varint,6,opt,name=cacheCapacity,def=0" json:"cacheCapacity,omitempty"`
	CacheUsed        *uint64                    `protobuf:"varint,7,opt,name=cacheUsed,def=0" json:"cacheUsed,omitempty"`
	XXX_unrecognized []byte                     `json:"-"`
}

* registration - datanode registration information capacity - total storage capacity available at the datanode dfsUsed - storage used by HDFS remaining - remaining storage available for HDFS blockPoolUsed - storage used by the block pool xmitsInProgress - number of transfers from this datanode to others xceiverCount - number of active transceiver threads failedVolumes - number of failed volumes cacheCapacity - total cache capacity available at the datanode cacheUsed - amount of cache used

func (*HeartbeatRequestProto) GetCacheCapacity 

func (m *HeartbeatRequestProto) GetCacheCapacity() uint64

func (*HeartbeatRequestProto) GetCacheUsed 

func (m *HeartbeatRequestProto) GetCacheUsed() uint64

func (*HeartbeatRequestProto) GetFailedVolumes 

func (m *HeartbeatRequestProto) GetFailedVolumes() uint32

func (*HeartbeatRequestProto) GetRegistration 

func (m *HeartbeatRequestProto) GetRegistration() *DatanodeRegistrationProto

func (*HeartbeatRequestProto) GetReports 

func (m *HeartbeatRequestProto) GetReports() []*StorageReportProto

func (*HeartbeatRequestProto) GetXceiverCount 

func (m *HeartbeatRequestProto) GetXceiverCount() uint32

func (*HeartbeatRequestProto) GetXmitsInProgress 

func (m *HeartbeatRequestProto) GetXmitsInProgress() uint32

func (*HeartbeatRequestProto) ProtoMessage 

func (*HeartbeatRequestProto) ProtoMessage()

func (*HeartbeatRequestProto) Reset 

func (m *HeartbeatRequestProto) Reset()

func (*HeartbeatRequestProto) String 

func (m *HeartbeatRequestProto) String() string

type HeartbeatResponseProto 

type HeartbeatResponseProto struct {
	Cmds                 []*DatanodeCommandProto                `protobuf:"bytes,1,rep,name=cmds" json:"cmds,omitempty"`
	HaStatus             *NNHAStatusHeartbeatProto              `protobuf:"bytes,2,req,name=haStatus" json:"haStatus,omitempty"`
	RollingUpgradeStatus *hadoop_hdfs.RollingUpgradeStatusProto `protobuf:"bytes,3,opt,name=rollingUpgradeStatus" json:"rollingUpgradeStatus,omitempty"`
	XXX_unrecognized     []byte                                 `json:"-"`
}

* cmds - Commands from namenode to datanode. haStatus - Status (from an HA perspective) of the NN sending this response

func (*HeartbeatResponseProto) GetCmds 

func (m *HeartbeatResponseProto) GetCmds() []*DatanodeCommandProto

func (*HeartbeatResponseProto) GetHaStatus 

func (m *HeartbeatResponseProto) GetHaStatus() *NNHAStatusHeartbeatProto

func (*HeartbeatResponseProto) GetRollingUpgradeStatus 

func (m *HeartbeatResponseProto) GetRollingUpgradeStatus() *hadoop_hdfs.RollingUpgradeStatusProto

func (*HeartbeatResponseProto) ProtoMessage 

func (*HeartbeatResponseProto) ProtoMessage()

func (*HeartbeatResponseProto) Reset 

func (m *HeartbeatResponseProto) Reset()

func (*HeartbeatResponseProto) String 

func (m *HeartbeatResponseProto) String() string

type KeyUpdateCommandProto 

type KeyUpdateCommandProto struct {
	Keys             *hadoop_hdfs.ExportedBlockKeysProto `protobuf:"bytes,1,req,name=keys" json:"keys,omitempty"`
	XXX_unrecognized []byte                              `json:"-"`
}

* Update the block keys at the datanode

func (*KeyUpdateCommandProto) GetKeys 

func (m *KeyUpdateCommandProto) GetKeys() *hadoop_hdfs.ExportedBlockKeysProto

func (*KeyUpdateCommandProto) ProtoMessage 

func (*KeyUpdateCommandProto) ProtoMessage()

func (*KeyUpdateCommandProto) Reset 

func (m *KeyUpdateCommandProto) Reset()

func (*KeyUpdateCommandProto) String 

func (m *KeyUpdateCommandProto) String() string

type NNHAStatusHeartbeatProto 

type NNHAStatusHeartbeatProto struct {
	State            *NNHAStatusHeartbeatProto_State `protobuf:"varint,1,req,name=state,enum=hadoop.hdfs.datanode.NNHAStatusHeartbeatProto_State" json:"state,omitempty"`
	Txid             *uint64                         `protobuf:"varint,2,req,name=txid" json:"txid,omitempty"`
	XXX_unrecognized []byte                          `json:"-"`
}

* state - State the NN is in when returning response to the DN txid - Highest transaction ID this NN has seen

func (*NNHAStatusHeartbeatProto) GetState 

func (m *NNHAStatusHeartbeatProto) GetState() NNHAStatusHeartbeatProto_State

func (*NNHAStatusHeartbeatProto) GetTxid 

func (m *NNHAStatusHeartbeatProto) GetTxid() uint64

func (*NNHAStatusHeartbeatProto) ProtoMessage 

func (*NNHAStatusHeartbeatProto) ProtoMessage()

func (*NNHAStatusHeartbeatProto) Reset 

func (m *NNHAStatusHeartbeatProto) Reset()

func (*NNHAStatusHeartbeatProto) String 

func (m *NNHAStatusHeartbeatProto) String() string

type NNHAStatusHeartbeatProto_State 

type NNHAStatusHeartbeatProto_State int32
const (
	NNHAStatusHeartbeatProto_ACTIVE  NNHAStatusHeartbeatProto_State = 0
	NNHAStatusHeartbeatProto_STANDBY NNHAStatusHeartbeatProto_State = 1
)

func (NNHAStatusHeartbeatProto_State) Enum 

func (x NNHAStatusHeartbeatProto_State) Enum() *NNHAStatusHeartbeatProto_State

func (NNHAStatusHeartbeatProto_State) String 

func (x NNHAStatusHeartbeatProto_State) String() string

func (*NNHAStatusHeartbeatProto_State) UnmarshalJSON 

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

type ReceivedDeletedBlockInfoProto 

type ReceivedDeletedBlockInfoProto struct {
	Block            *hadoop_hdfs.BlockProto                    `protobuf:"bytes,1,req,name=block" json:"block,omitempty"`
	Status           *ReceivedDeletedBlockInfoProto_BlockStatus `` /* 127-byte string literal not displayed */
	DeleteHint       *string                                    `protobuf:"bytes,2,opt,name=deleteHint" json:"deleteHint,omitempty"`
	XXX_unrecognized []byte                                     `json:"-"`
}

* Data structure to send received or deleted block information from datanode to namenode.

func (*ReceivedDeletedBlockInfoProto) GetBlock 

func (m *ReceivedDeletedBlockInfoProto) GetBlock() *hadoop_hdfs.BlockProto

func (*ReceivedDeletedBlockInfoProto) GetDeleteHint 

func (m *ReceivedDeletedBlockInfoProto) GetDeleteHint() string

func (*ReceivedDeletedBlockInfoProto) GetStatus 

func (m *ReceivedDeletedBlockInfoProto) GetStatus() ReceivedDeletedBlockInfoProto_BlockStatus

func (*ReceivedDeletedBlockInfoProto) ProtoMessage 

func (*ReceivedDeletedBlockInfoProto) ProtoMessage()

func (*ReceivedDeletedBlockInfoProto) Reset 

func (m *ReceivedDeletedBlockInfoProto) Reset()

func (*ReceivedDeletedBlockInfoProto) String 

func (m *ReceivedDeletedBlockInfoProto) String() string

type ReceivedDeletedBlockInfoProto_BlockStatus 

type ReceivedDeletedBlockInfoProto_BlockStatus int32
const (
	ReceivedDeletedBlockInfoProto_RECEIVING ReceivedDeletedBlockInfoProto_BlockStatus = 1
	ReceivedDeletedBlockInfoProto_RECEIVED  ReceivedDeletedBlockInfoProto_BlockStatus = 2
	ReceivedDeletedBlockInfoProto_DELETED   ReceivedDeletedBlockInfoProto_BlockStatus = 3
)

func (ReceivedDeletedBlockInfoProto_BlockStatus) Enum 

func (x ReceivedDeletedBlockInfoProto_BlockStatus) Enum() *ReceivedDeletedBlockInfoProto_BlockStatus

func (ReceivedDeletedBlockInfoProto_BlockStatus) String 

func (x ReceivedDeletedBlockInfoProto_BlockStatus) String() string

func (*ReceivedDeletedBlockInfoProto_BlockStatus) UnmarshalJSON 

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

type RegisterCommandProto 

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

* Instruct datanode to register with the namenode

func (*RegisterCommandProto) ProtoMessage 

func (*RegisterCommandProto) ProtoMessage()

func (*RegisterCommandProto) Reset 

func (m *RegisterCommandProto) Reset()

func (*RegisterCommandProto) String 

func (m *RegisterCommandProto) String() string

type RegisterDatanodeRequestProto 

type RegisterDatanodeRequestProto struct {
	Registration     *DatanodeRegistrationProto `protobuf:"bytes,1,req,name=registration" json:"registration,omitempty"`
	XXX_unrecognized []byte                     `json:"-"`
}

* registration - Information of the datanode registering with the namenode

func (*RegisterDatanodeRequestProto) GetRegistration 

func (m *RegisterDatanodeRequestProto) GetRegistration() *DatanodeRegistrationProto

func (*RegisterDatanodeRequestProto) ProtoMessage 

func (*RegisterDatanodeRequestProto) ProtoMessage()

func (*RegisterDatanodeRequestProto) Reset 

func (m *RegisterDatanodeRequestProto) Reset()

func (*RegisterDatanodeRequestProto) String 

func (m *RegisterDatanodeRequestProto) String() string

type RegisterDatanodeResponseProto 

type RegisterDatanodeResponseProto struct {
	Registration     *DatanodeRegistrationProto `protobuf:"bytes,1,req,name=registration" json:"registration,omitempty"`
	XXX_unrecognized []byte                     `json:"-"`
}

* registration - Update registration of the datanode that successfully 

registered. StorageInfo will be updated to include new
storage ID if the datanode did not have one in the request.

func (*RegisterDatanodeResponseProto) GetRegistration 

func (m *RegisterDatanodeResponseProto) GetRegistration() *DatanodeRegistrationProto

func (*RegisterDatanodeResponseProto) ProtoMessage 

func (*RegisterDatanodeResponseProto) ProtoMessage()

func (*RegisterDatanodeResponseProto) Reset 

func (m *RegisterDatanodeResponseProto) Reset()

func (*RegisterDatanodeResponseProto) String 

func (m *RegisterDatanodeResponseProto) String() string

type ReportBadBlocksRequestProto 

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

* blocks - list of blocks that are reported as corrupt

func (*ReportBadBlocksRequestProto) GetBlocks 

func (m *ReportBadBlocksRequestProto) GetBlocks() []*hadoop_hdfs.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:"-"`
}

* void response

func (*ReportBadBlocksResponseProto) ProtoMessage 

func (*ReportBadBlocksResponseProto) ProtoMessage()

func (*ReportBadBlocksResponseProto) Reset 

func (m *ReportBadBlocksResponseProto) Reset()

func (*ReportBadBlocksResponseProto) String 

func (m *ReportBadBlocksResponseProto) String() string

type StorageBlockReportProto 

type StorageBlockReportProto struct {
	Storage          *DatanodeStorageProto `protobuf:"bytes,1,req,name=storage" json:"storage,omitempty"`
	Blocks           []uint64              `protobuf:"varint,2,rep,packed,name=blocks" json:"blocks,omitempty"`
	XXX_unrecognized []byte                `json:"-"`
}

* Report of blocks in a storage

func (*StorageBlockReportProto) GetBlocks 

func (m *StorageBlockReportProto) GetBlocks() []uint64

func (*StorageBlockReportProto) GetStorage 

func (m *StorageBlockReportProto) GetStorage() *DatanodeStorageProto

func (*StorageBlockReportProto) ProtoMessage 

func (*StorageBlockReportProto) ProtoMessage()

func (*StorageBlockReportProto) Reset 

func (m *StorageBlockReportProto) Reset()

func (*StorageBlockReportProto) String 

func (m *StorageBlockReportProto) String() string

type StorageReceivedDeletedBlocksProto 

type StorageReceivedDeletedBlocksProto struct {
	StorageUuid      *string                          `protobuf:"bytes,1,req,name=storageUuid" json:"storageUuid,omitempty"`
	Blocks           []*ReceivedDeletedBlockInfoProto `protobuf:"bytes,2,rep,name=blocks" json:"blocks,omitempty"`
	Storage          *DatanodeStorageProto            `protobuf:"bytes,3,opt,name=storage" json:"storage,omitempty"`
	XXX_unrecognized []byte                           `json:"-"`
}

* List of blocks received and deleted for a storage.

func (*StorageReceivedDeletedBlocksProto) GetBlocks 

func (m *StorageReceivedDeletedBlocksProto) GetBlocks() []*ReceivedDeletedBlockInfoProto

func (*StorageReceivedDeletedBlocksProto) GetStorage 

func (m *StorageReceivedDeletedBlocksProto) GetStorage() *DatanodeStorageProto

func (*StorageReceivedDeletedBlocksProto) GetStorageUuid 

func (m *StorageReceivedDeletedBlocksProto) GetStorageUuid() string

func (*StorageReceivedDeletedBlocksProto) ProtoMessage 

func (*StorageReceivedDeletedBlocksProto) ProtoMessage()

func (*StorageReceivedDeletedBlocksProto) Reset 

func (m *StorageReceivedDeletedBlocksProto) Reset()

func (*StorageReceivedDeletedBlocksProto) String 

func (m *StorageReceivedDeletedBlocksProto) String() string

type StorageReportProto 

type StorageReportProto struct {
	StorageUuid      *string               `protobuf:"bytes,1,req,name=storageUuid" json:"storageUuid,omitempty"`
	Failed           *bool                 `protobuf:"varint,2,opt,name=failed,def=0" json:"failed,omitempty"`
	Capacity         *uint64               `protobuf:"varint,3,opt,name=capacity,def=0" json:"capacity,omitempty"`
	DfsUsed          *uint64               `protobuf:"varint,4,opt,name=dfsUsed,def=0" json:"dfsUsed,omitempty"`
	Remaining        *uint64               `protobuf:"varint,5,opt,name=remaining,def=0" json:"remaining,omitempty"`
	BlockPoolUsed    *uint64               `protobuf:"varint,6,opt,name=blockPoolUsed,def=0" json:"blockPoolUsed,omitempty"`
	Storage          *DatanodeStorageProto `protobuf:"bytes,7,opt,name=storage" json:"storage,omitempty"`
	XXX_unrecognized []byte                `json:"-"`
}

func (*StorageReportProto) GetBlockPoolUsed 

func (m *StorageReportProto) GetBlockPoolUsed() uint64

func (*StorageReportProto) GetCapacity 

func (m *StorageReportProto) GetCapacity() uint64

func (*StorageReportProto) GetDfsUsed 

func (m *StorageReportProto) GetDfsUsed() uint64

func (*StorageReportProto) GetFailed 

func (m *StorageReportProto) GetFailed() bool

func (*StorageReportProto) GetRemaining 

func (m *StorageReportProto) GetRemaining() uint64

func (*StorageReportProto) GetStorage 

func (m *StorageReportProto) GetStorage() *DatanodeStorageProto

func (*StorageReportProto) GetStorageUuid 

func (m *StorageReportProto) GetStorageUuid() string

func (*StorageReportProto) ProtoMessage 

func (*StorageReportProto) ProtoMessage()

func (*StorageReportProto) Reset 

func (m *StorageReportProto) Reset()

func (*StorageReportProto) String 

func (m *StorageReportProto) 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.