hadoop_hdfs

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: 1

Documentation

Overview

Package hadoop_hdfs is a generated protocol buffer package.

It is generated from these files: 

acl.proto
ClientDatanodeProtocol.proto
ClientNamenodeProtocol.proto
datatransfer.proto
HAZKInfo.proto
hdfs.proto
InterDatanodeProtocol.proto
JournalProtocol.proto
xattr.proto

It has these top-level messages: 

AclEntryProto
AclStatusProto
AclEditLogProto
ModifyAclEntriesRequestProto
ModifyAclEntriesResponseProto
RemoveAclRequestProto
RemoveAclResponseProto
RemoveAclEntriesRequestProto
RemoveAclEntriesResponseProto
RemoveDefaultAclRequestProto
RemoveDefaultAclResponseProto
SetAclRequestProto
SetAclResponseProto
GetAclStatusRequestProto
GetAclStatusResponseProto

Index

Constants

View Source 
const Default_AbandonBlockRequestProto_FileId uint64 = 0
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_CacheCapacity uint64 = 0
View Source 
const Default_DatanodeInfoProto_CacheUsed 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_FileId uint64 = 0
View Source 
const Default_FsyncRequestProto_LastBlockLength int64 = -1
View Source 
const Default_GetAdditionalDatanodeRequestProto_FileId uint64 = 0
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 AclEntryProto_AclEntryScopeProto_name = map[int32]string{
	0: "ACCESS",
	1: "DEFAULT",
}
View Source 
var AclEntryProto_AclEntryScopeProto_value = map[string]int32{
	"ACCESS":  0,
	"DEFAULT": 1,
}
View Source 
var AclEntryProto_AclEntryTypeProto_name = map[int32]string{
	0: "USER",
	1: "GROUP",
	2: "MASK",
	3: "OTHER",
}
View Source 
var AclEntryProto_AclEntryTypeProto_value = map[string]int32{
	"USER":  0,
	"GROUP": 1,
	"MASK":  2,
	"OTHER": 3,
}
View Source 
var AclEntryProto_FsActionProto_name = map[int32]string{
	0: "NONE",
	1: "EXECUTE",
	2: "WRITE",
	3: "WRITE_EXECUTE",
	4: "READ",
	5: "READ_EXECUTE",
	6: "READ_WRITE",
	7: "PERM_ALL",
}
View Source 
var AclEntryProto_FsActionProto_value = map[string]int32{
	"NONE":          0,
	"EXECUTE":       1,
	"WRITE":         2,
	"WRITE_EXECUTE": 3,
	"READ":          4,
	"READ_EXECUTE":  5,
	"READ_WRITE":    6,
	"PERM_ALL":      7,
}
View Source 
var CacheFlagProto_name = map[int32]string{
	1: "FORCE",
}
View Source 
var CacheFlagProto_value = map[string]int32{
	"FORCE": 1,
}
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",
	4: "DECOMMISSIONING",
}
View Source 
var DatanodeReportTypeProto_value = map[string]int32{
	"ALL":             1,
	"LIVE":            2,
	"DEAD":            3,
	"DECOMMISSIONING": 4,
}
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 RollingUpgradeActionProto_name = map[int32]string{
	1: "QUERY",
	2: "START",
	3: "FINALIZE",
}
View Source 
var RollingUpgradeActionProto_value = map[string]int32{
	"QUERY":    1,
	"START":    2,
	"FINALIZE": 3,
}
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",
	8:  "OOB_RESTART",
	9:  "OOB_RESERVED1",
	10: "OOB_RESERVED2",
	11: "OOB_RESERVED3",
}
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,
	"OOB_RESTART":        8,
	"OOB_RESERVED1":      9,
	"OOB_RESERVED2":      10,
	"OOB_RESERVED3":      11,
}
View Source 
var StorageTypeProto_name = map[int32]string{
	1: "DISK",
	2: "SSD",
}
View Source 
var StorageTypeProto_value = map[string]int32{
	"DISK": 1,
	"SSD":  2,
}
View Source 
var XAttrProto_XAttrNamespaceProto_name = map[int32]string{
	0: "USER",
	1: "TRUSTED",
	2: "SECURITY",
	3: "SYSTEM",
}
View Source 
var XAttrProto_XAttrNamespaceProto_value = map[string]int32{
	"USER":     0,
	"TRUSTED":  1,
	"SECURITY": 2,
	"SYSTEM":   3,
}
View Source 
var XAttrSetFlagProto_name = map[int32]string{
	1: "XATTR_CREATE",
	2: "XATTR_REPLACE",
}
View Source 
var XAttrSetFlagProto_value = map[string]int32{
	"XATTR_CREATE":  1,
	"XATTR_REPLACE": 2,
}

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"`
	FileId           *uint64             `protobuf:"varint,4,opt,name=fileId,def=0" json:"fileId,omitempty"`
	XXX_unrecognized []byte              `json:"-"`
}

func (*AbandonBlockRequestProto) GetB 

func (m *AbandonBlockRequestProto) GetB() *ExtendedBlockProto

func (*AbandonBlockRequestProto) GetFileId 

func (m *AbandonBlockRequestProto) GetFileId() uint64

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 AclEditLogProto 

type AclEditLogProto struct {
	Src              *string          `protobuf:"bytes,1,req,name=src" json:"src,omitempty"`
	Entries          []*AclEntryProto `protobuf:"bytes,2,rep,name=entries" json:"entries,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

func (*AclEditLogProto) GetEntries 

func (m *AclEditLogProto) GetEntries() []*AclEntryProto

func (*AclEditLogProto) GetSrc 

func (m *AclEditLogProto) GetSrc() string

func (*AclEditLogProto) ProtoMessage 

func (*AclEditLogProto) ProtoMessage()

func (*AclEditLogProto) Reset 

func (m *AclEditLogProto) Reset()

func (*AclEditLogProto) String 

func (m *AclEditLogProto) String() string

type AclEntryProto 

type AclEntryProto struct {
	Type             *AclEntryProto_AclEntryTypeProto  `protobuf:"varint,1,req,name=type,enum=hadoop.hdfs.AclEntryProto_AclEntryTypeProto" json:"type,omitempty"`
	Scope            *AclEntryProto_AclEntryScopeProto `protobuf:"varint,2,req,name=scope,enum=hadoop.hdfs.AclEntryProto_AclEntryScopeProto" json:"scope,omitempty"`
	Permissions      *AclEntryProto_FsActionProto      `protobuf:"varint,3,req,name=permissions,enum=hadoop.hdfs.AclEntryProto_FsActionProto" json:"permissions,omitempty"`
	Name             *string                           `protobuf:"bytes,4,opt,name=name" json:"name,omitempty"`
	XXX_unrecognized []byte                            `json:"-"`
}

func (*AclEntryProto) GetName 

func (m *AclEntryProto) GetName() string

func (*AclEntryProto) GetPermissions 

func (m *AclEntryProto) GetPermissions() AclEntryProto_FsActionProto

func (*AclEntryProto) GetScope 

func (m *AclEntryProto) GetScope() AclEntryProto_AclEntryScopeProto

func (*AclEntryProto) GetType 

func (m *AclEntryProto) GetType() AclEntryProto_AclEntryTypeProto

func (*AclEntryProto) ProtoMessage 

func (*AclEntryProto) ProtoMessage()

func (*AclEntryProto) Reset 

func (m *AclEntryProto) Reset()

func (*AclEntryProto) String 

func (m *AclEntryProto) String() string

type AclEntryProto_AclEntryScopeProto 

type AclEntryProto_AclEntryScopeProto int32
const (
	AclEntryProto_ACCESS  AclEntryProto_AclEntryScopeProto = 0
	AclEntryProto_DEFAULT AclEntryProto_AclEntryScopeProto = 1
)

func (AclEntryProto_AclEntryScopeProto) Enum 

func (x AclEntryProto_AclEntryScopeProto) Enum() *AclEntryProto_AclEntryScopeProto

func (AclEntryProto_AclEntryScopeProto) String 

func (x AclEntryProto_AclEntryScopeProto) String() string

func (*AclEntryProto_AclEntryScopeProto) UnmarshalJSON 

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

type AclEntryProto_AclEntryTypeProto 

type AclEntryProto_AclEntryTypeProto int32
const (
	AclEntryProto_USER  AclEntryProto_AclEntryTypeProto = 0
	AclEntryProto_GROUP AclEntryProto_AclEntryTypeProto = 1
	AclEntryProto_MASK  AclEntryProto_AclEntryTypeProto = 2
	AclEntryProto_OTHER AclEntryProto_AclEntryTypeProto = 3
)

func (AclEntryProto_AclEntryTypeProto) Enum 

func (x AclEntryProto_AclEntryTypeProto) Enum() *AclEntryProto_AclEntryTypeProto

func (AclEntryProto_AclEntryTypeProto) String 

func (x AclEntryProto_AclEntryTypeProto) String() string

func (*AclEntryProto_AclEntryTypeProto) UnmarshalJSON 

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

type AclEntryProto_FsActionProto 

type AclEntryProto_FsActionProto int32
const (
	AclEntryProto_NONE          AclEntryProto_FsActionProto = 0
	AclEntryProto_EXECUTE       AclEntryProto_FsActionProto = 1
	AclEntryProto_WRITE         AclEntryProto_FsActionProto = 2
	AclEntryProto_WRITE_EXECUTE AclEntryProto_FsActionProto = 3
	AclEntryProto_READ          AclEntryProto_FsActionProto = 4
	AclEntryProto_READ_EXECUTE  AclEntryProto_FsActionProto = 5
	AclEntryProto_READ_WRITE    AclEntryProto_FsActionProto = 6
	AclEntryProto_PERM_ALL      AclEntryProto_FsActionProto = 7
)

func (AclEntryProto_FsActionProto) Enum 

func (x AclEntryProto_FsActionProto) Enum() *AclEntryProto_FsActionProto

func (AclEntryProto_FsActionProto) String 

func (x AclEntryProto_FsActionProto) String() string

func (*AclEntryProto_FsActionProto) UnmarshalJSON 

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

type AclStatusProto 

type AclStatusProto struct {
	Owner            *string          `protobuf:"bytes,1,req,name=owner" json:"owner,omitempty"`
	Group            *string          `protobuf:"bytes,2,req,name=group" json:"group,omitempty"`
	Sticky           *bool            `protobuf:"varint,3,req,name=sticky" json:"sticky,omitempty"`
	Entries          []*AclEntryProto `protobuf:"bytes,4,rep,name=entries" json:"entries,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

func (*AclStatusProto) GetEntries 

func (m *AclStatusProto) GetEntries() []*AclEntryProto

func (*AclStatusProto) GetGroup 

func (m *AclStatusProto) GetGroup() string

func (*AclStatusProto) GetOwner 

func (m *AclStatusProto) GetOwner() string

func (*AclStatusProto) GetSticky 

func (m *AclStatusProto) GetSticky() bool

func (*AclStatusProto) ProtoMessage 

func (*AclStatusProto) ProtoMessage()

func (*AclStatusProto) Reset 

func (m *AclStatusProto) Reset()

func (*AclStatusProto) String 

func (m *AclStatusProto) String() string

type ActiveNodeInfo 

type ActiveNodeInfo struct {
	NameserviceId    *string `protobuf:"bytes,1,req,name=nameserviceId" json:"nameserviceId,omitempty"`
	NamenodeId       *string `protobuf:"bytes,2,req,name=namenodeId" json:"namenodeId,omitempty"`
	Hostname         *string `protobuf:"bytes,3,req,name=hostname" json:"hostname,omitempty"`
	Port             *int32  `protobuf:"varint,4,req,name=port" json:"port,omitempty"`
	ZkfcPort         *int32  `protobuf:"varint,5,req,name=zkfcPort" json:"zkfcPort,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*ActiveNodeInfo) GetHostname 

func (m *ActiveNodeInfo) GetHostname() string

func (*ActiveNodeInfo) GetNamenodeId 

func (m *ActiveNodeInfo) GetNamenodeId() string

func (*ActiveNodeInfo) GetNameserviceId 

func (m *ActiveNodeInfo) GetNameserviceId() string

func (*ActiveNodeInfo) GetPort 

func (m *ActiveNodeInfo) GetPort() int32

func (*ActiveNodeInfo) GetZkfcPort 

func (m *ActiveNodeInfo) GetZkfcPort() int32

func (*ActiveNodeInfo) ProtoMessage 

func (*ActiveNodeInfo) ProtoMessage()

func (*ActiveNodeInfo) Reset 

func (m *ActiveNodeInfo) Reset()

func (*ActiveNodeInfo) String 

func (m *ActiveNodeInfo) 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 AddCacheDirectiveRequestProto 

type AddCacheDirectiveRequestProto struct {
	Info             *CacheDirectiveInfoProto `protobuf:"bytes,1,req,name=info" json:"info,omitempty"`
	CacheFlags       *uint32                  `protobuf:"varint,2,opt,name=cacheFlags" json:"cacheFlags,omitempty"`
	XXX_unrecognized []byte                   `json:"-"`
}

func (*AddCacheDirectiveRequestProto) GetCacheFlags 

func (m *AddCacheDirectiveRequestProto) GetCacheFlags() uint32

func (*AddCacheDirectiveRequestProto) GetInfo 

func (m *AddCacheDirectiveRequestProto) GetInfo() *CacheDirectiveInfoProto

func (*AddCacheDirectiveRequestProto) ProtoMessage 

func (*AddCacheDirectiveRequestProto) ProtoMessage()

func (*AddCacheDirectiveRequestProto) Reset 

func (m *AddCacheDirectiveRequestProto) Reset()

func (*AddCacheDirectiveRequestProto) String 

func (m *AddCacheDirectiveRequestProto) String() string

type AddCacheDirectiveResponseProto 

type AddCacheDirectiveResponseProto struct {
	Id               *int64 `protobuf:"varint,1,req,name=id" json:"id,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*AddCacheDirectiveResponseProto) GetId 

func (m *AddCacheDirectiveResponseProto) GetId() int64

func (*AddCacheDirectiveResponseProto) ProtoMessage 

func (*AddCacheDirectiveResponseProto) ProtoMessage()

func (*AddCacheDirectiveResponseProto) Reset 

func (m *AddCacheDirectiveResponseProto) Reset()

func (*AddCacheDirectiveResponseProto) String 

func (m *AddCacheDirectiveResponseProto) String() string

type AddCachePoolRequestProto 

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

func (*AddCachePoolRequestProto) GetInfo 

func (m *AddCachePoolRequestProto) GetInfo() *CachePoolInfoProto

func (*AddCachePoolRequestProto) ProtoMessage 

func (*AddCachePoolRequestProto) ProtoMessage()

func (*AddCachePoolRequestProto) Reset 

func (m *AddCachePoolRequestProto) Reset()

func (*AddCachePoolRequestProto) String 

func (m *AddCachePoolRequestProto) String() string

type AddCachePoolResponseProto 

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

func (*AddCachePoolResponseProto) ProtoMessage 

func (*AddCachePoolResponseProto) ProtoMessage()

func (*AddCachePoolResponseProto) Reset 

func (m *AddCachePoolResponseProto) Reset()

func (*AddCachePoolResponseProto) String 

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

Please be wary of adding additional fields here, since INodeFiles need to fit in PB's default max message size of 64MB. We restrict the max # of blocks per file (dfs.namenode.fs-limits.max-blocks-per-file), but it's better to avoid changing this.

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"`
	DatanodeUuids    []string    `protobuf:"bytes,2,rep,name=datanodeUuids" json:"datanodeUuids,omitempty"`
	StorageUuids     []string    `protobuf:"bytes,3,rep,name=storageUuids" json:"storageUuids,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

* Block and datanodes where is it located

func (*BlockWithLocationsProto) GetBlock 

func (m *BlockWithLocationsProto) GetBlock() *BlockProto

func (*BlockWithLocationsProto) GetDatanodeUuids 

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

func (*BlockWithLocationsProto) GetStorageUuids 

func (m *BlockWithLocationsProto) GetStorageUuids() []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 CacheDirectiveEntryProto 

type CacheDirectiveEntryProto struct {
	Info             *CacheDirectiveInfoProto  `protobuf:"bytes,1,req,name=info" json:"info,omitempty"`
	Stats            *CacheDirectiveStatsProto `protobuf:"bytes,2,req,name=stats" json:"stats,omitempty"`
	XXX_unrecognized []byte                    `json:"-"`
}

func (*CacheDirectiveEntryProto) GetInfo 

func (m *CacheDirectiveEntryProto) GetInfo() *CacheDirectiveInfoProto

func (*CacheDirectiveEntryProto) GetStats 

func (m *CacheDirectiveEntryProto) GetStats() *CacheDirectiveStatsProto

func (*CacheDirectiveEntryProto) ProtoMessage 

func (*CacheDirectiveEntryProto) ProtoMessage()

func (*CacheDirectiveEntryProto) Reset 

func (m *CacheDirectiveEntryProto) Reset()

func (*CacheDirectiveEntryProto) String 

func (m *CacheDirectiveEntryProto) String() string

type CacheDirectiveInfoExpirationProto 

type CacheDirectiveInfoExpirationProto struct {
	Millis           *int64 `protobuf:"varint,1,req,name=millis" json:"millis,omitempty"`
	IsRelative       *bool  `protobuf:"varint,2,req,name=isRelative" json:"isRelative,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*CacheDirectiveInfoExpirationProto) GetIsRelative 

func (m *CacheDirectiveInfoExpirationProto) GetIsRelative() bool

func (*CacheDirectiveInfoExpirationProto) GetMillis 

func (m *CacheDirectiveInfoExpirationProto) GetMillis() int64

func (*CacheDirectiveInfoExpirationProto) ProtoMessage 

func (*CacheDirectiveInfoExpirationProto) ProtoMessage()

func (*CacheDirectiveInfoExpirationProto) Reset 

func (m *CacheDirectiveInfoExpirationProto) Reset()

func (*CacheDirectiveInfoExpirationProto) String 

func (m *CacheDirectiveInfoExpirationProto) String() string

type CacheDirectiveInfoProto 

type CacheDirectiveInfoProto struct {
	Id               *int64                             `protobuf:"varint,1,opt,name=id" json:"id,omitempty"`
	Path             *string                            `protobuf:"bytes,2,opt,name=path" json:"path,omitempty"`
	Replication      *uint32                            `protobuf:"varint,3,opt,name=replication" json:"replication,omitempty"`
	Pool             *string                            `protobuf:"bytes,4,opt,name=pool" json:"pool,omitempty"`
	Expiration       *CacheDirectiveInfoExpirationProto `protobuf:"bytes,5,opt,name=expiration" json:"expiration,omitempty"`
	XXX_unrecognized []byte                             `json:"-"`
}

func (*CacheDirectiveInfoProto) GetExpiration 

func (m *CacheDirectiveInfoProto) GetExpiration() *CacheDirectiveInfoExpirationProto

func (*CacheDirectiveInfoProto) GetId 

func (m *CacheDirectiveInfoProto) GetId() int64

func (*CacheDirectiveInfoProto) GetPath 

func (m *CacheDirectiveInfoProto) GetPath() string

func (*CacheDirectiveInfoProto) GetPool 

func (m *CacheDirectiveInfoProto) GetPool() string

func (*CacheDirectiveInfoProto) GetReplication 

func (m *CacheDirectiveInfoProto) GetReplication() uint32

func (*CacheDirectiveInfoProto) ProtoMessage 

func (*CacheDirectiveInfoProto) ProtoMessage()

func (*CacheDirectiveInfoProto) Reset 

func (m *CacheDirectiveInfoProto) Reset()

func (*CacheDirectiveInfoProto) String 

func (m *CacheDirectiveInfoProto) String() string

type CacheDirectiveStatsProto 

type CacheDirectiveStatsProto struct {
	BytesNeeded      *int64 `protobuf:"varint,1,req,name=bytesNeeded" json:"bytesNeeded,omitempty"`
	BytesCached      *int64 `protobuf:"varint,2,req,name=bytesCached" json:"bytesCached,omitempty"`
	FilesNeeded      *int64 `protobuf:"varint,3,req,name=filesNeeded" json:"filesNeeded,omitempty"`
	FilesCached      *int64 `protobuf:"varint,4,req,name=filesCached" json:"filesCached,omitempty"`
	HasExpired       *bool  `protobuf:"varint,5,req,name=hasExpired" json:"hasExpired,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*CacheDirectiveStatsProto) GetBytesCached 

func (m *CacheDirectiveStatsProto) GetBytesCached() int64

func (*CacheDirectiveStatsProto) GetBytesNeeded 

func (m *CacheDirectiveStatsProto) GetBytesNeeded() int64

func (*CacheDirectiveStatsProto) GetFilesCached 

func (m *CacheDirectiveStatsProto) GetFilesCached() int64

func (*CacheDirectiveStatsProto) GetFilesNeeded 

func (m *CacheDirectiveStatsProto) GetFilesNeeded() int64

func (*CacheDirectiveStatsProto) GetHasExpired 

func (m *CacheDirectiveStatsProto) GetHasExpired() bool

func (*CacheDirectiveStatsProto) ProtoMessage 

func (*CacheDirectiveStatsProto) ProtoMessage()

func (*CacheDirectiveStatsProto) Reset 

func (m *CacheDirectiveStatsProto) Reset()

func (*CacheDirectiveStatsProto) String 

func (m *CacheDirectiveStatsProto) String() string

type CacheFlagProto 

type CacheFlagProto int32
const (
	CacheFlagProto_FORCE CacheFlagProto = 1
)

func (CacheFlagProto) Enum 

func (x CacheFlagProto) Enum() *CacheFlagProto

func (CacheFlagProto) String 

func (x CacheFlagProto) String() string

func (*CacheFlagProto) UnmarshalJSON 

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

type CachePoolEntryProto 

type CachePoolEntryProto struct {
	Info             *CachePoolInfoProto  `protobuf:"bytes,1,req,name=info" json:"info,omitempty"`
	Stats            *CachePoolStatsProto `protobuf:"bytes,2,req,name=stats" json:"stats,omitempty"`
	XXX_unrecognized []byte               `json:"-"`
}

func (*CachePoolEntryProto) GetInfo 

func (m *CachePoolEntryProto) GetInfo() *CachePoolInfoProto

func (*CachePoolEntryProto) GetStats 

func (m *CachePoolEntryProto) GetStats() *CachePoolStatsProto

func (*CachePoolEntryProto) ProtoMessage 

func (*CachePoolEntryProto) ProtoMessage()

func (*CachePoolEntryProto) Reset 

func (m *CachePoolEntryProto) Reset()

func (*CachePoolEntryProto) String 

func (m *CachePoolEntryProto) String() string

type CachePoolInfoProto 

type CachePoolInfoProto struct {
	PoolName          *string `protobuf:"bytes,1,opt,name=poolName" json:"poolName,omitempty"`
	OwnerName         *string `protobuf:"bytes,2,opt,name=ownerName" json:"ownerName,omitempty"`
	GroupName         *string `protobuf:"bytes,3,opt,name=groupName" json:"groupName,omitempty"`
	Mode              *int32  `protobuf:"varint,4,opt,name=mode" json:"mode,omitempty"`
	Limit             *int64  `protobuf:"varint,5,opt,name=limit" json:"limit,omitempty"`
	MaxRelativeExpiry *int64  `protobuf:"varint,6,opt,name=maxRelativeExpiry" json:"maxRelativeExpiry,omitempty"`
	XXX_unrecognized  []byte  `json:"-"`
}

func (*CachePoolInfoProto) GetGroupName 

func (m *CachePoolInfoProto) GetGroupName() string

func (*CachePoolInfoProto) GetLimit 

func (m *CachePoolInfoProto) GetLimit() int64

func (*CachePoolInfoProto) GetMaxRelativeExpiry 

func (m *CachePoolInfoProto) GetMaxRelativeExpiry() int64

func (*CachePoolInfoProto) GetMode 

func (m *CachePoolInfoProto) GetMode() int32

func (*CachePoolInfoProto) GetOwnerName 

func (m *CachePoolInfoProto) GetOwnerName() string

func (*CachePoolInfoProto) GetPoolName 

func (m *CachePoolInfoProto) GetPoolName() string

func (*CachePoolInfoProto) ProtoMessage 

func (*CachePoolInfoProto) ProtoMessage()

func (*CachePoolInfoProto) Reset 

func (m *CachePoolInfoProto) Reset()

func (*CachePoolInfoProto) String 

func (m *CachePoolInfoProto) String() string

type CachePoolStatsProto 

type CachePoolStatsProto struct {
	BytesNeeded      *int64 `protobuf:"varint,1,req,name=bytesNeeded" json:"bytesNeeded,omitempty"`
	BytesCached      *int64 `protobuf:"varint,2,req,name=bytesCached" json:"bytesCached,omitempty"`
	BytesOverlimit   *int64 `protobuf:"varint,3,req,name=bytesOverlimit" json:"bytesOverlimit,omitempty"`
	FilesNeeded      *int64 `protobuf:"varint,4,req,name=filesNeeded" json:"filesNeeded,omitempty"`
	FilesCached      *int64 `protobuf:"varint,5,req,name=filesCached" json:"filesCached,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*CachePoolStatsProto) GetBytesCached 

func (m *CachePoolStatsProto) GetBytesCached() int64

func (*CachePoolStatsProto) GetBytesNeeded 

func (m *CachePoolStatsProto) GetBytesNeeded() int64

func (*CachePoolStatsProto) GetBytesOverlimit 

func (m *CachePoolStatsProto) GetBytesOverlimit() int64

func (*CachePoolStatsProto) GetFilesCached 

func (m *CachePoolStatsProto) GetFilesCached() int64

func (*CachePoolStatsProto) GetFilesNeeded 

func (m *CachePoolStatsProto) GetFilesNeeded() int64

func (*CachePoolStatsProto) ProtoMessage 

func (*CachePoolStatsProto) ProtoMessage()

func (*CachePoolStatsProto) Reset 

func (m *CachePoolStatsProto) Reset()

func (*CachePoolStatsProto) String 

func (m *CachePoolStatsProto) 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"`
	DatanodeUuid *string `protobuf:"bytes,3,req,name=datanodeUuid" json:"datanodeUuid,omitempty"`
	// upgraded clusters this is the same
	// as the original StorageID of the
	// Datanode.
	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) GetDatanodeUuid 

func (m *DatanodeIDProto) GetDatanodeUuid() string

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) 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"`
	CacheCapacity    *uint64                       `protobuf:"varint,11,opt,name=cacheCapacity,def=0" json:"cacheCapacity,omitempty"`
	CacheUsed        *uint64                       `protobuf:"varint,12,opt,name=cacheUsed,def=0" json:"cacheUsed,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) GetCacheCapacity 

func (m *DatanodeInfoProto) GetCacheCapacity() uint64

func (*DatanodeInfoProto) GetCacheUsed 

func (m *DatanodeInfoProto) GetCacheUsed() 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 DatanodeLocalInfoProto 

type DatanodeLocalInfoProto struct {
	SoftwareVersion  *string `protobuf:"bytes,1,req,name=softwareVersion" json:"softwareVersion,omitempty"`
	ConfigVersion    *string `protobuf:"bytes,2,req,name=configVersion" json:"configVersion,omitempty"`
	Uptime           *uint64 `protobuf:"varint,3,req,name=uptime" json:"uptime,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* Datanode local information

func (*DatanodeLocalInfoProto) GetConfigVersion 

func (m *DatanodeLocalInfoProto) GetConfigVersion() string

func (*DatanodeLocalInfoProto) GetSoftwareVersion 

func (m *DatanodeLocalInfoProto) GetSoftwareVersion() string

func (*DatanodeLocalInfoProto) GetUptime 

func (m *DatanodeLocalInfoProto) GetUptime() uint64

func (*DatanodeLocalInfoProto) ProtoMessage 

func (*DatanodeLocalInfoProto) ProtoMessage()

func (*DatanodeLocalInfoProto) Reset 

func (m *DatanodeLocalInfoProto) Reset()

func (*DatanodeLocalInfoProto) String 

func (m *DatanodeLocalInfoProto) String() string

type DatanodeReportTypeProto 

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

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 DeleteBlockPoolRequestProto 

type DeleteBlockPoolRequestProto struct {
	BlockPool        *string `protobuf:"bytes,1,req,name=blockPool" json:"blockPool,omitempty"`
	Force            *bool   `protobuf:"varint,2,req,name=force" json:"force,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* blockPool - block pool to be deleted force - if false, delete the block pool only if it is empty. 

if true, delete the block pool even if it has blocks.

func (*DeleteBlockPoolRequestProto) GetBlockPool 

func (m *DeleteBlockPoolRequestProto) GetBlockPool() string

func (*DeleteBlockPoolRequestProto) GetForce 

func (m *DeleteBlockPoolRequestProto) GetForce() bool

func (*DeleteBlockPoolRequestProto) ProtoMessage 

func (*DeleteBlockPoolRequestProto) ProtoMessage()

func (*DeleteBlockPoolRequestProto) Reset 

func (m *DeleteBlockPoolRequestProto) Reset()

func (*DeleteBlockPoolRequestProto) String 

func (m *DeleteBlockPoolRequestProto) String() string

type DeleteBlockPoolResponseProto 

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

* void response

func (*DeleteBlockPoolResponseProto) ProtoMessage 

func (*DeleteBlockPoolResponseProto) ProtoMessage()

func (*DeleteBlockPoolResponseProto) Reset 

func (m *DeleteBlockPoolResponseProto) Reset()

func (*DeleteBlockPoolResponseProto) String 

func (m *DeleteBlockPoolResponseProto) String() string

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 FenceRequestProto 

type FenceRequestProto struct {
	JournalInfo      *JournalInfoProto `protobuf:"bytes,1,req,name=journalInfo" json:"journalInfo,omitempty"`
	Epoch            *uint64           `protobuf:"varint,2,req,name=epoch" json:"epoch,omitempty"`
	FencerInfo       *string           `protobuf:"bytes,3,opt,name=fencerInfo" json:"fencerInfo,omitempty"`
	XXX_unrecognized []byte            `json:"-"`
}

* journalInfo - the information about the journal txid - first txid in the new log

func (*FenceRequestProto) GetEpoch 

func (m *FenceRequestProto) GetEpoch() uint64

func (*FenceRequestProto) GetFencerInfo 

func (m *FenceRequestProto) GetFencerInfo() string

func (*FenceRequestProto) GetJournalInfo 

func (m *FenceRequestProto) GetJournalInfo() *JournalInfoProto

func (*FenceRequestProto) ProtoMessage 

func (*FenceRequestProto) ProtoMessage()

func (*FenceRequestProto) Reset 

func (m *FenceRequestProto) Reset()

func (*FenceRequestProto) String 

func (m *FenceRequestProto) String() string

type FenceResponseProto 

type FenceResponseProto struct {
	PreviousEpoch     *uint64 `protobuf:"varint,1,opt,name=previousEpoch" json:"previousEpoch,omitempty"`
	LastTransactionId *uint64 `protobuf:"varint,2,opt,name=lastTransactionId" json:"lastTransactionId,omitempty"`
	InSync            *bool   `protobuf:"varint,3,opt,name=inSync" json:"inSync,omitempty"`
	XXX_unrecognized  []byte  `json:"-"`
}

* previousEpoch - previous epoch if any or zero lastTransactionId - last valid transaction Id in the journal inSync - if all journal segments are available and in sync

func (*FenceResponseProto) GetInSync 

func (m *FenceResponseProto) GetInSync() bool

func (*FenceResponseProto) GetLastTransactionId 

func (m *FenceResponseProto) GetLastTransactionId() uint64

func (*FenceResponseProto) GetPreviousEpoch 

func (m *FenceResponseProto) GetPreviousEpoch() uint64

func (*FenceResponseProto) ProtoMessage 

func (*FenceResponseProto) ProtoMessage()

func (*FenceResponseProto) Reset 

func (m *FenceResponseProto) Reset()

func (*FenceResponseProto) String 

func (m *FenceResponseProto) 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"`
	FileId           *uint64 `protobuf:"varint,4,opt,name=fileId,def=0" json:"fileId,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*FsyncRequestProto) GetClient 

func (m *FsyncRequestProto) GetClient() string

func (*FsyncRequestProto) GetFileId 

func (m *FsyncRequestProto) GetFileId() uint64

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 GetAclStatusRequestProto 

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

func (*GetAclStatusRequestProto) GetSrc 

func (m *GetAclStatusRequestProto) GetSrc() string

func (*GetAclStatusRequestProto) ProtoMessage 

func (*GetAclStatusRequestProto) ProtoMessage()

func (*GetAclStatusRequestProto) Reset 

func (m *GetAclStatusRequestProto) Reset()

func (*GetAclStatusRequestProto) String 

func (m *GetAclStatusRequestProto) String() string

type GetAclStatusResponseProto 

type GetAclStatusResponseProto struct {
	Result           *AclStatusProto `protobuf:"bytes,1,req,name=result" json:"result,omitempty"`
	XXX_unrecognized []byte          `json:"-"`
}

func (*GetAclStatusResponseProto) GetResult 

func (m *GetAclStatusResponseProto) GetResult() *AclStatusProto

func (*GetAclStatusResponseProto) ProtoMessage 

func (*GetAclStatusResponseProto) ProtoMessage()

func (*GetAclStatusResponseProto) Reset 

func (m *GetAclStatusResponseProto) Reset()

func (*GetAclStatusResponseProto) String 

func (m *GetAclStatusResponseProto) 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"`
	ExistingStorageUuids []string             `protobuf:"bytes,7,rep,name=existingStorageUuids" json:"existingStorageUuids,omitempty"`
	FileId               *uint64              `protobuf:"varint,8,opt,name=fileId,def=0" json:"fileId,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) GetExistingStorageUuids 

func (m *GetAdditionalDatanodeRequestProto) GetExistingStorageUuids() []string

func (*GetAdditionalDatanodeRequestProto) GetExistings 

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

func (*GetAdditionalDatanodeRequestProto) GetFileId 

func (m *GetAdditionalDatanodeRequestProto) GetFileId() uint64

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 GetBlockLocalPathInfoRequestProto 

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

* Gets the file information where block and its metadata is stored block - block for which path information is being requested token - block token

This message is deprecated in favor of file descriptor passing.

func (*GetBlockLocalPathInfoRequestProto) GetBlock 

func (m *GetBlockLocalPathInfoRequestProto) GetBlock() *ExtendedBlockProto

func (*GetBlockLocalPathInfoRequestProto) GetToken 

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

func (*GetBlockLocalPathInfoRequestProto) ProtoMessage 

func (*GetBlockLocalPathInfoRequestProto) ProtoMessage()

func (*GetBlockLocalPathInfoRequestProto) Reset 

func (m *GetBlockLocalPathInfoRequestProto) Reset()

func (*GetBlockLocalPathInfoRequestProto) String 

func (m *GetBlockLocalPathInfoRequestProto) String() string

type GetBlockLocalPathInfoResponseProto 

type GetBlockLocalPathInfoResponseProto struct {
	Block            *ExtendedBlockProto `protobuf:"bytes,1,req,name=block" json:"block,omitempty"`
	LocalPath        *string             `protobuf:"bytes,2,req,name=localPath" json:"localPath,omitempty"`
	LocalMetaPath    *string             `protobuf:"bytes,3,req,name=localMetaPath" json:"localMetaPath,omitempty"`
	XXX_unrecognized []byte              `json:"-"`
}

* block - block for which file path information is being returned localPath - file path where the block data is stored localMetaPath - file path where the block meta data is stored

This message is deprecated in favor of file descriptor passing.

func (*GetBlockLocalPathInfoResponseProto) GetBlock 

func (m *GetBlockLocalPathInfoResponseProto) GetBlock() *ExtendedBlockProto

func (*GetBlockLocalPathInfoResponseProto) GetLocalMetaPath 

func (m *GetBlockLocalPathInfoResponseProto) GetLocalMetaPath() string

func (*GetBlockLocalPathInfoResponseProto) GetLocalPath 

func (m *GetBlockLocalPathInfoResponseProto) GetLocalPath() string

func (*GetBlockLocalPathInfoResponseProto) ProtoMessage 

func (*GetBlockLocalPathInfoResponseProto) ProtoMessage()

func (*GetBlockLocalPathInfoResponseProto) Reset 

func (m *GetBlockLocalPathInfoResponseProto) Reset()

func (*GetBlockLocalPathInfoResponseProto) String 

func (m *GetBlockLocalPathInfoResponseProto) 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 GetDatanodeInfoRequestProto 

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

* Ping datanode for liveness and quick info

func (*GetDatanodeInfoRequestProto) ProtoMessage 

func (*GetDatanodeInfoRequestProto) ProtoMessage()

func (*GetDatanodeInfoRequestProto) Reset 

func (m *GetDatanodeInfoRequestProto) Reset()

func (*GetDatanodeInfoRequestProto) String 

func (m *GetDatanodeInfoRequestProto) String() string

type GetDatanodeInfoResponseProto 

type GetDatanodeInfoResponseProto struct {
	LocalInfo        *DatanodeLocalInfoProto `protobuf:"bytes,1,req,name=localInfo" json:"localInfo,omitempty"`
	XXX_unrecognized []byte                  `json:"-"`
}

func (*GetDatanodeInfoResponseProto) GetLocalInfo 

func (m *GetDatanodeInfoResponseProto) GetLocalInfo() *DatanodeLocalInfoProto

func (*GetDatanodeInfoResponseProto) ProtoMessage 

func (*GetDatanodeInfoResponseProto) ProtoMessage()

func (*GetDatanodeInfoResponseProto) Reset 

func (m *GetDatanodeInfoResponseProto) Reset()

func (*GetDatanodeInfoResponseProto) String 

func (m *GetDatanodeInfoResponseProto) 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 GetHdfsBlockLocationsRequestProto 

type GetHdfsBlockLocationsRequestProto struct {
	// Removed: HDFS-3969
	// repeated ExtendedBlockProto blocks = 1;
	Tokens           []*hadoop_common.TokenProto `protobuf:"bytes,2,rep,name=tokens" json:"tokens,omitempty"`
	BlockPoolId      *string                     `protobuf:"bytes,3,req,name=blockPoolId" json:"blockPoolId,omitempty"`
	BlockIds         []int64                     `protobuf:"fixed64,4,rep,packed,name=blockIds" json:"blockIds,omitempty"`
	XXX_unrecognized []byte                      `json:"-"`
}

* Query for the disk locations of a number of blocks on this DN. blockPoolId - the pool to query blockIds - list of block IDs to query tokens - list of access tokens corresponding to list of block IDs

func (*GetHdfsBlockLocationsRequestProto) GetBlockIds 

func (m *GetHdfsBlockLocationsRequestProto) GetBlockIds() []int64

func (*GetHdfsBlockLocationsRequestProto) GetBlockPoolId 

func (m *GetHdfsBlockLocationsRequestProto) GetBlockPoolId() string

func (*GetHdfsBlockLocationsRequestProto) GetTokens 

func (m *GetHdfsBlockLocationsRequestProto) GetTokens() []*hadoop_common.TokenProto

func (*GetHdfsBlockLocationsRequestProto) ProtoMessage 

func (*GetHdfsBlockLocationsRequestProto) ProtoMessage()

func (*GetHdfsBlockLocationsRequestProto) Reset 

func (m *GetHdfsBlockLocationsRequestProto) Reset()

func (*GetHdfsBlockLocationsRequestProto) String 

func (m *GetHdfsBlockLocationsRequestProto) String() string

type GetHdfsBlockLocationsResponseProto 

type GetHdfsBlockLocationsResponseProto struct {
	VolumeIds        [][]byte `protobuf:"bytes,1,rep,name=volumeIds" json:"volumeIds,omitempty"`
	VolumeIndexes    []uint32 `protobuf:"varint,2,rep,packed,name=volumeIndexes" json:"volumeIndexes,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

* volumeIds - id of each volume, potentially multiple bytes volumeIndexes - for each block, an index into volumeIds specifying the volume 

on which it is located. If block is not present on any volume,
index is set to MAX_INT.

func (*GetHdfsBlockLocationsResponseProto) GetVolumeIds 

func (m *GetHdfsBlockLocationsResponseProto) GetVolumeIds() [][]byte

func (*GetHdfsBlockLocationsResponseProto) GetVolumeIndexes 

func (m *GetHdfsBlockLocationsResponseProto) GetVolumeIndexes() []uint32

func (*GetHdfsBlockLocationsResponseProto) ProtoMessage 

func (*GetHdfsBlockLocationsResponseProto) ProtoMessage()

func (*GetHdfsBlockLocationsResponseProto) Reset 

func (m *GetHdfsBlockLocationsResponseProto) Reset()

func (*GetHdfsBlockLocationsResponseProto) String 

func (m *GetHdfsBlockLocationsResponseProto) 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 GetReplicaVisibleLengthRequestProto 

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

* block - block for which visible length is requested

func (*GetReplicaVisibleLengthRequestProto) GetBlock 

func (m *GetReplicaVisibleLengthRequestProto) GetBlock() *ExtendedBlockProto

func (*GetReplicaVisibleLengthRequestProto) ProtoMessage 

func (*GetReplicaVisibleLengthRequestProto) ProtoMessage()

func (*GetReplicaVisibleLengthRequestProto) Reset 

func (m *GetReplicaVisibleLengthRequestProto) Reset()

func (*GetReplicaVisibleLengthRequestProto) String 

func (m *GetReplicaVisibleLengthRequestProto) String() string

type GetReplicaVisibleLengthResponseProto 

type GetReplicaVisibleLengthResponseProto struct {
	Length           *uint64 `protobuf:"varint,1,req,name=length" json:"length,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* length - visible length of the block

func (*GetReplicaVisibleLengthResponseProto) GetLength 

func (m *GetReplicaVisibleLengthResponseProto) GetLength() uint64

func (*GetReplicaVisibleLengthResponseProto) ProtoMessage 

func (*GetReplicaVisibleLengthResponseProto) ProtoMessage()

func (*GetReplicaVisibleLengthResponseProto) Reset 

func (m *GetReplicaVisibleLengthResponseProto) Reset()

func (*GetReplicaVisibleLengthResponseProto) String 

func (m *GetReplicaVisibleLengthResponseProto) 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 GetXAttrsRequestProto 

type GetXAttrsRequestProto struct {
	Src              *string       `protobuf:"bytes,1,req,name=src" json:"src,omitempty"`
	XAttrs           []*XAttrProto `protobuf:"bytes,2,rep,name=xAttrs" json:"xAttrs,omitempty"`
	XXX_unrecognized []byte        `json:"-"`
}

func (*GetXAttrsRequestProto) GetSrc 

func (m *GetXAttrsRequestProto) GetSrc() string

func (*GetXAttrsRequestProto) GetXAttrs 

func (m *GetXAttrsRequestProto) GetXAttrs() []*XAttrProto

func (*GetXAttrsRequestProto) ProtoMessage 

func (*GetXAttrsRequestProto) ProtoMessage()

func (*GetXAttrsRequestProto) Reset 

func (m *GetXAttrsRequestProto) Reset()

func (*GetXAttrsRequestProto) String 

func (m *GetXAttrsRequestProto) String() string

type GetXAttrsResponseProto 

type GetXAttrsResponseProto struct {
	XAttrs           []*XAttrProto `protobuf:"bytes,1,rep,name=xAttrs" json:"xAttrs,omitempty"`
	XXX_unrecognized []byte        `json:"-"`
}

func (*GetXAttrsResponseProto) GetXAttrs 

func (m *GetXAttrsResponseProto) GetXAttrs() []*XAttrProto

func (*GetXAttrsResponseProto) ProtoMessage 

func (*GetXAttrsResponseProto) ProtoMessage()

func (*GetXAttrsResponseProto) Reset 

func (m *GetXAttrsResponseProto) Reset()

func (*GetXAttrsResponseProto) String 

func (m *GetXAttrsResponseProto) 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 InitReplicaRecoveryRequestProto 

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

* Block with location information and new generation stamp to be used for recovery.

func (*InitReplicaRecoveryRequestProto) GetBlock 

func (m *InitReplicaRecoveryRequestProto) GetBlock() *RecoveringBlockProto

func (*InitReplicaRecoveryRequestProto) ProtoMessage 

func (*InitReplicaRecoveryRequestProto) ProtoMessage()

func (*InitReplicaRecoveryRequestProto) Reset 

func (m *InitReplicaRecoveryRequestProto) Reset()

func (*InitReplicaRecoveryRequestProto) String 

func (m *InitReplicaRecoveryRequestProto) String() string

type InitReplicaRecoveryResponseProto 

type InitReplicaRecoveryResponseProto struct {
	ReplicaFound *bool `protobuf:"varint,1,req,name=replicaFound" json:"replicaFound,omitempty"`
	// The following entries are not set if there was no replica found.
	State            *ReplicaStateProto `protobuf:"varint,2,opt,name=state,enum=hadoop.hdfs.ReplicaStateProto" json:"state,omitempty"`
	Block            *BlockProto        `protobuf:"bytes,3,opt,name=block" json:"block,omitempty"`
	XXX_unrecognized []byte             `json:"-"`
}

* Repica recovery information

func (*InitReplicaRecoveryResponseProto) GetBlock 

func (m *InitReplicaRecoveryResponseProto) GetBlock() *BlockProto

func (*InitReplicaRecoveryResponseProto) GetReplicaFound 

func (m *InitReplicaRecoveryResponseProto) GetReplicaFound() bool

func (*InitReplicaRecoveryResponseProto) GetState 

func (m *InitReplicaRecoveryResponseProto) GetState() ReplicaStateProto

func (*InitReplicaRecoveryResponseProto) ProtoMessage 

func (*InitReplicaRecoveryResponseProto) ProtoMessage()

func (*InitReplicaRecoveryResponseProto) Reset 

func (m *InitReplicaRecoveryResponseProto) Reset()

func (*InitReplicaRecoveryResponseProto) String 

func (m *InitReplicaRecoveryResponseProto) String() string

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 JournalInfoProto 

type JournalInfoProto struct {
	ClusterID        *string `protobuf:"bytes,1,req,name=clusterID" json:"clusterID,omitempty"`
	LayoutVersion    *uint32 `protobuf:"varint,2,opt,name=layoutVersion" json:"layoutVersion,omitempty"`
	NamespaceID      *uint32 `protobuf:"varint,3,opt,name=namespaceID" json:"namespaceID,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* Journal information used by the journal receiver to identify a journal.

func (*JournalInfoProto) GetClusterID 

func (m *JournalInfoProto) GetClusterID() string

func (*JournalInfoProto) GetLayoutVersion 

func (m *JournalInfoProto) GetLayoutVersion() uint32

func (*JournalInfoProto) GetNamespaceID 

func (m *JournalInfoProto) GetNamespaceID() uint32

func (*JournalInfoProto) ProtoMessage 

func (*JournalInfoProto) ProtoMessage()

func (*JournalInfoProto) Reset 

func (m *JournalInfoProto) Reset()

func (*JournalInfoProto) String 

func (m *JournalInfoProto) String() string

type JournalRequestProto 

type JournalRequestProto struct {
	JournalInfo      *JournalInfoProto `protobuf:"bytes,1,req,name=journalInfo" json:"journalInfo,omitempty"`
	FirstTxnId       *uint64           `protobuf:"varint,2,req,name=firstTxnId" json:"firstTxnId,omitempty"`
	NumTxns          *uint32           `protobuf:"varint,3,req,name=numTxns" json:"numTxns,omitempty"`
	Records          []byte            `protobuf:"bytes,4,req,name=records" json:"records,omitempty"`
	Epoch            *uint64           `protobuf:"varint,5,req,name=epoch" json:"epoch,omitempty"`
	XXX_unrecognized []byte            `json:"-"`
}

* journalInfo - the information about the journal firstTxnId - the first txid in the journal records numTxns - Number of transactions in editlog records - bytes containing serialized journal records epoch - change to this represents change of journal writer

func (*JournalRequestProto) GetEpoch 

func (m *JournalRequestProto) GetEpoch() uint64

func (*JournalRequestProto) GetFirstTxnId 

func (m *JournalRequestProto) GetFirstTxnId() uint64

func (*JournalRequestProto) GetJournalInfo 

func (m *JournalRequestProto) GetJournalInfo() *JournalInfoProto

func (*JournalRequestProto) GetNumTxns 

func (m *JournalRequestProto) GetNumTxns() uint32

func (*JournalRequestProto) GetRecords 

func (m *JournalRequestProto) GetRecords() []byte

func (*JournalRequestProto) ProtoMessage 

func (*JournalRequestProto) ProtoMessage()

func (*JournalRequestProto) Reset 

func (m *JournalRequestProto) Reset()

func (*JournalRequestProto) String 

func (m *JournalRequestProto) String() string

type JournalResponseProto 

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

* void response

func (*JournalResponseProto) ProtoMessage 

func (*JournalResponseProto) ProtoMessage()

func (*JournalResponseProto) Reset 

func (m *JournalResponseProto) Reset()

func (*JournalResponseProto) String 

func (m *JournalResponseProto) String() string

type ListCacheDirectivesRequestProto 

type ListCacheDirectivesRequestProto struct {
	PrevId           *int64                   `protobuf:"varint,1,req,name=prevId" json:"prevId,omitempty"`
	Filter           *CacheDirectiveInfoProto `protobuf:"bytes,2,req,name=filter" json:"filter,omitempty"`
	XXX_unrecognized []byte                   `json:"-"`
}

func (*ListCacheDirectivesRequestProto) GetFilter 

func (m *ListCacheDirectivesRequestProto) GetFilter() *CacheDirectiveInfoProto

func (*ListCacheDirectivesRequestProto) GetPrevId 

func (m *ListCacheDirectivesRequestProto) GetPrevId() int64

func (*ListCacheDirectivesRequestProto) ProtoMessage 

func (*ListCacheDirectivesRequestProto) ProtoMessage()

func (*ListCacheDirectivesRequestProto) Reset 

func (m *ListCacheDirectivesRequestProto) Reset()

func (*ListCacheDirectivesRequestProto) String 

func (m *ListCacheDirectivesRequestProto) String() string

type ListCacheDirectivesResponseProto 

type ListCacheDirectivesResponseProto struct {
	Elements         []*CacheDirectiveEntryProto `protobuf:"bytes,1,rep,name=elements" json:"elements,omitempty"`
	HasMore          *bool                       `protobuf:"varint,2,req,name=hasMore" json:"hasMore,omitempty"`
	XXX_unrecognized []byte                      `json:"-"`
}

func (*ListCacheDirectivesResponseProto) GetElements 

func (m *ListCacheDirectivesResponseProto) GetElements() []*CacheDirectiveEntryProto

func (*ListCacheDirectivesResponseProto) GetHasMore 

func (m *ListCacheDirectivesResponseProto) GetHasMore() bool

func (*ListCacheDirectivesResponseProto) ProtoMessage 

func (*ListCacheDirectivesResponseProto) ProtoMessage()

func (*ListCacheDirectivesResponseProto) Reset 

func (m *ListCacheDirectivesResponseProto) Reset()

func (*ListCacheDirectivesResponseProto) String 

func (m *ListCacheDirectivesResponseProto) String() string

type ListCachePoolsRequestProto 

type ListCachePoolsRequestProto struct {
	PrevPoolName     *string `protobuf:"bytes,1,req,name=prevPoolName" json:"prevPoolName,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*ListCachePoolsRequestProto) GetPrevPoolName 

func (m *ListCachePoolsRequestProto) GetPrevPoolName() string

func (*ListCachePoolsRequestProto) ProtoMessage 

func (*ListCachePoolsRequestProto) ProtoMessage()

func (*ListCachePoolsRequestProto) Reset 

func (m *ListCachePoolsRequestProto) Reset()

func (*ListCachePoolsRequestProto) String 

func (m *ListCachePoolsRequestProto) String() string

type ListCachePoolsResponseProto 

type ListCachePoolsResponseProto struct {
	Entries          []*CachePoolEntryProto `protobuf:"bytes,1,rep,name=entries" json:"entries,omitempty"`
	HasMore          *bool                  `protobuf:"varint,2,req,name=hasMore" json:"hasMore,omitempty"`
	XXX_unrecognized []byte                 `json:"-"`
}

func (*ListCachePoolsResponseProto) GetEntries 

func (m *ListCachePoolsResponseProto) GetEntries() []*CachePoolEntryProto

func (*ListCachePoolsResponseProto) GetHasMore 

func (m *ListCachePoolsResponseProto) GetHasMore() bool

func (*ListCachePoolsResponseProto) ProtoMessage 

func (*ListCachePoolsResponseProto) ProtoMessage()

func (*ListCachePoolsResponseProto) Reset 

func (m *ListCachePoolsResponseProto) Reset()

func (*ListCachePoolsResponseProto) String 

func (m *ListCachePoolsResponseProto) 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 ListXAttrsRequestProto 

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

func (*ListXAttrsRequestProto) GetSrc 

func (m *ListXAttrsRequestProto) GetSrc() string

func (*ListXAttrsRequestProto) ProtoMessage 

func (*ListXAttrsRequestProto) ProtoMessage()

func (*ListXAttrsRequestProto) Reset 

func (m *ListXAttrsRequestProto) Reset()

func (*ListXAttrsRequestProto) String 

func (m *ListXAttrsRequestProto) String() string

type ListXAttrsResponseProto 

type ListXAttrsResponseProto struct {
	XAttrs           []*XAttrProto `protobuf:"bytes,1,rep,name=xAttrs" json:"xAttrs,omitempty"`
	XXX_unrecognized []byte        `json:"-"`
}

func (*ListXAttrsResponseProto) GetXAttrs 

func (m *ListXAttrsResponseProto) GetXAttrs() []*XAttrProto

func (*ListXAttrsResponseProto) ProtoMessage 

func (*ListXAttrsResponseProto) ProtoMessage()

func (*ListXAttrsResponseProto) Reset 

func (m *ListXAttrsResponseProto) Reset()

func (*ListXAttrsResponseProto) String 

func (m *ListXAttrsResponseProto) 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"`
	IsCached         []bool                    `protobuf:"varint,6,rep,packed,name=isCached" json:"isCached,omitempty"`
	StorageTypes     []StorageTypeProto        `protobuf:"varint,7,rep,name=storageTypes,enum=hadoop.hdfs.StorageTypeProto" json:"storageTypes,omitempty"`
	StorageIDs       []string                  `protobuf:"bytes,8,rep,name=storageIDs" json:"storageIDs,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) GetIsCached 

func (m *LocatedBlockProto) GetIsCached() []bool

func (*LocatedBlockProto) GetLocs 

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

func (*LocatedBlockProto) GetOffset 

func (m *LocatedBlockProto) GetOffset() uint64

func (*LocatedBlockProto) GetStorageIDs 

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

func (*LocatedBlockProto) GetStorageTypes 

func (m *LocatedBlockProto) GetStorageTypes() []StorageTypeProto

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 ModifyAclEntriesRequestProto 

type ModifyAclEntriesRequestProto struct {
	Src              *string          `protobuf:"bytes,1,req,name=src" json:"src,omitempty"`
	AclSpec          []*AclEntryProto `protobuf:"bytes,2,rep,name=aclSpec" json:"aclSpec,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

func (*ModifyAclEntriesRequestProto) GetAclSpec 

func (m *ModifyAclEntriesRequestProto) GetAclSpec() []*AclEntryProto

func (*ModifyAclEntriesRequestProto) GetSrc 

func (m *ModifyAclEntriesRequestProto) GetSrc() string

func (*ModifyAclEntriesRequestProto) ProtoMessage 

func (*ModifyAclEntriesRequestProto) ProtoMessage()

func (*ModifyAclEntriesRequestProto) Reset 

func (m *ModifyAclEntriesRequestProto) Reset()

func (*ModifyAclEntriesRequestProto) String 

func (m *ModifyAclEntriesRequestProto) String() string

type ModifyAclEntriesResponseProto 

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

func (*ModifyAclEntriesResponseProto) ProtoMessage 

func (*ModifyAclEntriesResponseProto) ProtoMessage()

func (*ModifyAclEntriesResponseProto) Reset 

func (m *ModifyAclEntriesResponseProto) Reset()

func (*ModifyAclEntriesResponseProto) String 

func (m *ModifyAclEntriesResponseProto) String() string

type ModifyCacheDirectiveRequestProto 

type ModifyCacheDirectiveRequestProto struct {
	Info             *CacheDirectiveInfoProto `protobuf:"bytes,1,req,name=info" json:"info,omitempty"`
	CacheFlags       *uint32                  `protobuf:"varint,2,opt,name=cacheFlags" json:"cacheFlags,omitempty"`
	XXX_unrecognized []byte                   `json:"-"`
}

func (*ModifyCacheDirectiveRequestProto) GetCacheFlags 

func (m *ModifyCacheDirectiveRequestProto) GetCacheFlags() uint32

func (*ModifyCacheDirectiveRequestProto) GetInfo 

func (m *ModifyCacheDirectiveRequestProto) GetInfo() *CacheDirectiveInfoProto

func (*ModifyCacheDirectiveRequestProto) ProtoMessage 

func (*ModifyCacheDirectiveRequestProto) ProtoMessage()

func (*ModifyCacheDirectiveRequestProto) Reset 

func (m *ModifyCacheDirectiveRequestProto) Reset()

func (*ModifyCacheDirectiveRequestProto) String 

func (m *ModifyCacheDirectiveRequestProto) String() string

type ModifyCacheDirectiveResponseProto 

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

func (*ModifyCacheDirectiveResponseProto) ProtoMessage 

func (*ModifyCacheDirectiveResponseProto) ProtoMessage()

func (*ModifyCacheDirectiveResponseProto) Reset 

func (m *ModifyCacheDirectiveResponseProto) Reset()

func (*ModifyCacheDirectiveResponseProto) String 

func (m *ModifyCacheDirectiveResponseProto) String() string

type ModifyCachePoolRequestProto 

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

func (*ModifyCachePoolRequestProto) GetInfo 

func (m *ModifyCachePoolRequestProto) GetInfo() *CachePoolInfoProto

func (*ModifyCachePoolRequestProto) ProtoMessage 

func (*ModifyCachePoolRequestProto) ProtoMessage()

func (*ModifyCachePoolRequestProto) Reset 

func (m *ModifyCachePoolRequestProto) Reset()

func (*ModifyCachePoolRequestProto) String 

func (m *ModifyCachePoolRequestProto) String() string

type ModifyCachePoolResponseProto 

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

func (*ModifyCachePoolResponseProto) ProtoMessage 

func (*ModifyCachePoolResponseProto) ProtoMessage()

func (*ModifyCachePoolResponseProto) Reset 

func (m *ModifyCachePoolResponseProto) Reset()

func (*ModifyCachePoolResponseProto) String 

func (m *ModifyCachePoolResponseProto) 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"`
	// *
	// The shared memory slot to use, if we are using one.
	SlotId           *ShortCircuitShmSlotProto `protobuf:"bytes,3,opt,name=slotId" json:"slotId,omitempty"`
	XXX_unrecognized []byte                    `json:"-"`
}

func (*OpRequestShortCircuitAccessProto) GetHeader 

func (m *OpRequestShortCircuitAccessProto) GetHeader() *BaseHeaderProto

func (*OpRequestShortCircuitAccessProto) GetMaxVersion 

func (m *OpRequestShortCircuitAccessProto) GetMaxVersion() uint32

func (*OpRequestShortCircuitAccessProto) GetSlotId 

func (m *OpRequestShortCircuitAccessProto) GetSlotId() *ShortCircuitShmSlotProto

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 RefreshNamenodesRequestProto 

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

* void request

func (*RefreshNamenodesRequestProto) ProtoMessage 

func (*RefreshNamenodesRequestProto) ProtoMessage()

func (*RefreshNamenodesRequestProto) Reset 

func (m *RefreshNamenodesRequestProto) Reset()

func (*RefreshNamenodesRequestProto) String 

func (m *RefreshNamenodesRequestProto) String() string

type RefreshNamenodesResponseProto 

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

* void response

func (*RefreshNamenodesResponseProto) ProtoMessage 

func (*RefreshNamenodesResponseProto) ProtoMessage()

func (*RefreshNamenodesResponseProto) Reset 

func (m *RefreshNamenodesResponseProto) Reset()

func (*RefreshNamenodesResponseProto) String 

func (m *RefreshNamenodesResponseProto) 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 ReleaseShortCircuitAccessRequestProto 

type ReleaseShortCircuitAccessRequestProto struct {
	SlotId           *ShortCircuitShmSlotProto `protobuf:"bytes,1,req,name=slotId" json:"slotId,omitempty"`
	XXX_unrecognized []byte                    `json:"-"`
}

func (*ReleaseShortCircuitAccessRequestProto) GetSlotId 

func (m *ReleaseShortCircuitAccessRequestProto) GetSlotId() *ShortCircuitShmSlotProto

func (*ReleaseShortCircuitAccessRequestProto) ProtoMessage 

func (*ReleaseShortCircuitAccessRequestProto) ProtoMessage()

func (*ReleaseShortCircuitAccessRequestProto) Reset 

func (m *ReleaseShortCircuitAccessRequestProto) Reset()

func (*ReleaseShortCircuitAccessRequestProto) String 

func (m *ReleaseShortCircuitAccessRequestProto) String() string

type ReleaseShortCircuitAccessResponseProto 

type ReleaseShortCircuitAccessResponseProto struct {
	Status           *Status `protobuf:"varint,1,req,name=status,enum=hadoop.hdfs.Status" json:"status,omitempty"`
	Error            *string `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*ReleaseShortCircuitAccessResponseProto) GetError 

func (m *ReleaseShortCircuitAccessResponseProto) GetError() string

func (*ReleaseShortCircuitAccessResponseProto) GetStatus 

func (m *ReleaseShortCircuitAccessResponseProto) GetStatus() Status

func (*ReleaseShortCircuitAccessResponseProto) ProtoMessage 

func (*ReleaseShortCircuitAccessResponseProto) ProtoMessage()

func (*ReleaseShortCircuitAccessResponseProto) Reset 

func (m *ReleaseShortCircuitAccessResponseProto) Reset()

func (*ReleaseShortCircuitAccessResponseProto) String 

func (m *ReleaseShortCircuitAccessResponseProto) 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 RemoveAclEntriesRequestProto 

type RemoveAclEntriesRequestProto struct {
	Src              *string          `protobuf:"bytes,1,req,name=src" json:"src,omitempty"`
	AclSpec          []*AclEntryProto `protobuf:"bytes,2,rep,name=aclSpec" json:"aclSpec,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

func (*RemoveAclEntriesRequestProto) GetAclSpec 

func (m *RemoveAclEntriesRequestProto) GetAclSpec() []*AclEntryProto

func (*RemoveAclEntriesRequestProto) GetSrc 

func (m *RemoveAclEntriesRequestProto) GetSrc() string

func (*RemoveAclEntriesRequestProto) ProtoMessage 

func (*RemoveAclEntriesRequestProto) ProtoMessage()

func (*RemoveAclEntriesRequestProto) Reset 

func (m *RemoveAclEntriesRequestProto) Reset()

func (*RemoveAclEntriesRequestProto) String 

func (m *RemoveAclEntriesRequestProto) String() string

type RemoveAclEntriesResponseProto 

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

func (*RemoveAclEntriesResponseProto) ProtoMessage 

func (*RemoveAclEntriesResponseProto) ProtoMessage()

func (*RemoveAclEntriesResponseProto) Reset 

func (m *RemoveAclEntriesResponseProto) Reset()

func (*RemoveAclEntriesResponseProto) String 

func (m *RemoveAclEntriesResponseProto) String() string

type RemoveAclRequestProto 

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

func (*RemoveAclRequestProto) GetSrc 

func (m *RemoveAclRequestProto) GetSrc() string

func (*RemoveAclRequestProto) ProtoMessage 

func (*RemoveAclRequestProto) ProtoMessage()

func (*RemoveAclRequestProto) Reset 

func (m *RemoveAclRequestProto) Reset()

func (*RemoveAclRequestProto) String 

func (m *RemoveAclRequestProto) String() string

type RemoveAclResponseProto 

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

func (*RemoveAclResponseProto) ProtoMessage 

func (*RemoveAclResponseProto) ProtoMessage()

func (*RemoveAclResponseProto) Reset 

func (m *RemoveAclResponseProto) Reset()

func (*RemoveAclResponseProto) String 

func (m *RemoveAclResponseProto) String() string

type RemoveCacheDirectiveRequestProto 

type RemoveCacheDirectiveRequestProto struct {
	Id               *int64 `protobuf:"varint,1,req,name=id" json:"id,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*RemoveCacheDirectiveRequestProto) GetId 

func (m *RemoveCacheDirectiveRequestProto) GetId() int64

func (*RemoveCacheDirectiveRequestProto) ProtoMessage 

func (*RemoveCacheDirectiveRequestProto) ProtoMessage()

func (*RemoveCacheDirectiveRequestProto) Reset 

func (m *RemoveCacheDirectiveRequestProto) Reset()

func (*RemoveCacheDirectiveRequestProto) String 

func (m *RemoveCacheDirectiveRequestProto) String() string

type RemoveCacheDirectiveResponseProto 

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

func (*RemoveCacheDirectiveResponseProto) ProtoMessage 

func (*RemoveCacheDirectiveResponseProto) ProtoMessage()

func (*RemoveCacheDirectiveResponseProto) Reset 

func (m *RemoveCacheDirectiveResponseProto) Reset()

func (*RemoveCacheDirectiveResponseProto) String 

func (m *RemoveCacheDirectiveResponseProto) String() string

type RemoveCachePoolRequestProto 

type RemoveCachePoolRequestProto struct {
	PoolName         *string `protobuf:"bytes,1,req,name=poolName" json:"poolName,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*RemoveCachePoolRequestProto) GetPoolName 

func (m *RemoveCachePoolRequestProto) GetPoolName() string

func (*RemoveCachePoolRequestProto) ProtoMessage 

func (*RemoveCachePoolRequestProto) ProtoMessage()

func (*RemoveCachePoolRequestProto) Reset 

func (m *RemoveCachePoolRequestProto) Reset()

func (*RemoveCachePoolRequestProto) String 

func (m *RemoveCachePoolRequestProto) String() string

type RemoveCachePoolResponseProto 

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

func (*RemoveCachePoolResponseProto) ProtoMessage 

func (*RemoveCachePoolResponseProto) ProtoMessage()

func (*RemoveCachePoolResponseProto) Reset 

func (m *RemoveCachePoolResponseProto) Reset()

func (*RemoveCachePoolResponseProto) String 

func (m *RemoveCachePoolResponseProto) String() string

type RemoveDefaultAclRequestProto 

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

func (*RemoveDefaultAclRequestProto) GetSrc 

func (m *RemoveDefaultAclRequestProto) GetSrc() string

func (*RemoveDefaultAclRequestProto) ProtoMessage 

func (*RemoveDefaultAclRequestProto) ProtoMessage()

func (*RemoveDefaultAclRequestProto) Reset 

func (m *RemoveDefaultAclRequestProto) Reset()

func (*RemoveDefaultAclRequestProto) String 

func (m *RemoveDefaultAclRequestProto) String() string

type RemoveDefaultAclResponseProto 

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

func (*RemoveDefaultAclResponseProto) ProtoMessage 

func (*RemoveDefaultAclResponseProto) ProtoMessage()

func (*RemoveDefaultAclResponseProto) Reset 

func (m *RemoveDefaultAclResponseProto) Reset()

func (*RemoveDefaultAclResponseProto) String 

func (m *RemoveDefaultAclResponseProto) String() string

type RemoveXAttrRequestProto 

type RemoveXAttrRequestProto struct {
	Src              *string     `protobuf:"bytes,1,req,name=src" json:"src,omitempty"`
	XAttr            *XAttrProto `protobuf:"bytes,2,opt,name=xAttr" json:"xAttr,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

func (*RemoveXAttrRequestProto) GetSrc 

func (m *RemoveXAttrRequestProto) GetSrc() string

func (*RemoveXAttrRequestProto) GetXAttr 

func (m *RemoveXAttrRequestProto) GetXAttr() *XAttrProto

func (*RemoveXAttrRequestProto) ProtoMessage 

func (*RemoveXAttrRequestProto) ProtoMessage()

func (*RemoveXAttrRequestProto) Reset 

func (m *RemoveXAttrRequestProto) Reset()

func (*RemoveXAttrRequestProto) String 

func (m *RemoveXAttrRequestProto) String() string

type RemoveXAttrResponseProto 

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

func (*RemoveXAttrResponseProto) ProtoMessage 

func (*RemoveXAttrResponseProto) ProtoMessage()

func (*RemoveXAttrResponseProto) Reset 

func (m *RemoveXAttrResponseProto) Reset()

func (*RemoveXAttrResponseProto) String 

func (m *RemoveXAttrResponseProto) 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 RollingUpgradeActionProto 

type RollingUpgradeActionProto int32
const (
	RollingUpgradeActionProto_QUERY    RollingUpgradeActionProto = 1
	RollingUpgradeActionProto_START    RollingUpgradeActionProto = 2
	RollingUpgradeActionProto_FINALIZE RollingUpgradeActionProto = 3
)

func (RollingUpgradeActionProto) Enum 

func (x RollingUpgradeActionProto) Enum() *RollingUpgradeActionProto

func (RollingUpgradeActionProto) String 

func (x RollingUpgradeActionProto) String() string

func (*RollingUpgradeActionProto) UnmarshalJSON 

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

type RollingUpgradeInfoProto 

type RollingUpgradeInfoProto struct {
	Status                *RollingUpgradeStatusProto `protobuf:"bytes,1,req,name=status" json:"status,omitempty"`
	StartTime             *uint64                    `protobuf:"varint,2,req,name=startTime" json:"startTime,omitempty"`
	FinalizeTime          *uint64                    `protobuf:"varint,3,req,name=finalizeTime" json:"finalizeTime,omitempty"`
	CreatedRollbackImages *bool                      `protobuf:"varint,4,req,name=createdRollbackImages" json:"createdRollbackImages,omitempty"`
	XXX_unrecognized      []byte                     `json:"-"`
}

func (*RollingUpgradeInfoProto) GetCreatedRollbackImages 

func (m *RollingUpgradeInfoProto) GetCreatedRollbackImages() bool

func (*RollingUpgradeInfoProto) GetFinalizeTime 

func (m *RollingUpgradeInfoProto) GetFinalizeTime() uint64

func (*RollingUpgradeInfoProto) GetStartTime 

func (m *RollingUpgradeInfoProto) GetStartTime() uint64

func (*RollingUpgradeInfoProto) GetStatus 

func (m *RollingUpgradeInfoProto) GetStatus() *RollingUpgradeStatusProto

func (*RollingUpgradeInfoProto) ProtoMessage 

func (*RollingUpgradeInfoProto) ProtoMessage()

func (*RollingUpgradeInfoProto) Reset 

func (m *RollingUpgradeInfoProto) Reset()

func (*RollingUpgradeInfoProto) String 

func (m *RollingUpgradeInfoProto) String() string

type RollingUpgradeRequestProto 

type RollingUpgradeRequestProto struct {
	Action           *RollingUpgradeActionProto `protobuf:"varint,1,req,name=action,enum=hadoop.hdfs.RollingUpgradeActionProto" json:"action,omitempty"`
	XXX_unrecognized []byte                     `json:"-"`
}

func (*RollingUpgradeRequestProto) GetAction 

func (m *RollingUpgradeRequestProto) GetAction() RollingUpgradeActionProto

func (*RollingUpgradeRequestProto) ProtoMessage 

func (*RollingUpgradeRequestProto) ProtoMessage()

func (*RollingUpgradeRequestProto) Reset 

func (m *RollingUpgradeRequestProto) Reset()

func (*RollingUpgradeRequestProto) String 

func (m *RollingUpgradeRequestProto) String() string

type RollingUpgradeResponseProto 

type RollingUpgradeResponseProto struct {
	RollingUpgradeInfo *RollingUpgradeInfoProto `protobuf:"bytes,1,opt,name=rollingUpgradeInfo" json:"rollingUpgradeInfo,omitempty"`
	XXX_unrecognized   []byte                   `json:"-"`
}

func (*RollingUpgradeResponseProto) GetRollingUpgradeInfo 

func (m *RollingUpgradeResponseProto) GetRollingUpgradeInfo() *RollingUpgradeInfoProto

func (*RollingUpgradeResponseProto) ProtoMessage 

func (*RollingUpgradeResponseProto) ProtoMessage()

func (*RollingUpgradeResponseProto) Reset 

func (m *RollingUpgradeResponseProto) Reset()

func (*RollingUpgradeResponseProto) String 

func (m *RollingUpgradeResponseProto) String() string

type RollingUpgradeStatusProto 

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

* Rolling upgrade status

func (*RollingUpgradeStatusProto) GetBlockPoolId 

func (m *RollingUpgradeStatusProto) GetBlockPoolId() string

func (*RollingUpgradeStatusProto) ProtoMessage 

func (*RollingUpgradeStatusProto) ProtoMessage()

func (*RollingUpgradeStatusProto) Reset 

func (m *RollingUpgradeStatusProto) Reset()

func (*RollingUpgradeStatusProto) String 

func (m *RollingUpgradeStatusProto) 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 SetAclRequestProto 

type SetAclRequestProto struct {
	Src              *string          `protobuf:"bytes,1,req,name=src" json:"src,omitempty"`
	AclSpec          []*AclEntryProto `protobuf:"bytes,2,rep,name=aclSpec" json:"aclSpec,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

func (*SetAclRequestProto) GetAclSpec 

func (m *SetAclRequestProto) GetAclSpec() []*AclEntryProto

func (*SetAclRequestProto) GetSrc 

func (m *SetAclRequestProto) GetSrc() string

func (*SetAclRequestProto) ProtoMessage 

func (*SetAclRequestProto) ProtoMessage()

func (*SetAclRequestProto) Reset 

func (m *SetAclRequestProto) Reset()

func (*SetAclRequestProto) String 

func (m *SetAclRequestProto) String() string

type SetAclResponseProto 

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

func (*SetAclResponseProto) ProtoMessage 

func (*SetAclResponseProto) ProtoMessage()

func (*SetAclResponseProto) Reset 

func (m *SetAclResponseProto) Reset()

func (*SetAclResponseProto) String 

func (m *SetAclResponseProto) 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 SetXAttrRequestProto 

type SetXAttrRequestProto struct {
	Src              *string     `protobuf:"bytes,1,req,name=src" json:"src,omitempty"`
	XAttr            *XAttrProto `protobuf:"bytes,2,opt,name=xAttr" json:"xAttr,omitempty"`
	Flag             *uint32     `protobuf:"varint,3,opt,name=flag" json:"flag,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

func (*SetXAttrRequestProto) GetFlag 

func (m *SetXAttrRequestProto) GetFlag() uint32

func (*SetXAttrRequestProto) GetSrc 

func (m *SetXAttrRequestProto) GetSrc() string

func (*SetXAttrRequestProto) GetXAttr 

func (m *SetXAttrRequestProto) GetXAttr() *XAttrProto

func (*SetXAttrRequestProto) ProtoMessage 

func (*SetXAttrRequestProto) ProtoMessage()

func (*SetXAttrRequestProto) Reset 

func (m *SetXAttrRequestProto) Reset()

func (*SetXAttrRequestProto) String 

func (m *SetXAttrRequestProto) String() string

type SetXAttrResponseProto 

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

func (*SetXAttrResponseProto) ProtoMessage 

func (*SetXAttrResponseProto) ProtoMessage()

func (*SetXAttrResponseProto) Reset 

func (m *SetXAttrResponseProto) Reset()

func (*SetXAttrResponseProto) String 

func (m *SetXAttrResponseProto) String() string

type ShortCircuitShmIdProto 

type ShortCircuitShmIdProto struct {
	Hi               *int64 `protobuf:"varint,1,req,name=hi" json:"hi,omitempty"`
	Lo               *int64 `protobuf:"varint,2,req,name=lo" json:"lo,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

* An ID uniquely identifying a shared memory segment.

func (*ShortCircuitShmIdProto) GetHi 

func (m *ShortCircuitShmIdProto) GetHi() int64

func (*ShortCircuitShmIdProto) GetLo 

func (m *ShortCircuitShmIdProto) GetLo() int64

func (*ShortCircuitShmIdProto) ProtoMessage 

func (*ShortCircuitShmIdProto) ProtoMessage()

func (*ShortCircuitShmIdProto) Reset 

func (m *ShortCircuitShmIdProto) Reset()

func (*ShortCircuitShmIdProto) String 

func (m *ShortCircuitShmIdProto) String() string

type ShortCircuitShmRequestProto 

type ShortCircuitShmRequestProto struct {
	// The name of the client requesting the shared memory segment.  This is
	// purely for logging / debugging purposes.
	ClientName       *string `protobuf:"bytes,1,req,name=clientName" json:"clientName,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*ShortCircuitShmRequestProto) GetClientName 

func (m *ShortCircuitShmRequestProto) GetClientName() string

func (*ShortCircuitShmRequestProto) ProtoMessage 

func (*ShortCircuitShmRequestProto) ProtoMessage()

func (*ShortCircuitShmRequestProto) Reset 

func (m *ShortCircuitShmRequestProto) Reset()

func (*ShortCircuitShmRequestProto) String 

func (m *ShortCircuitShmRequestProto) String() string

type ShortCircuitShmResponseProto 

type ShortCircuitShmResponseProto struct {
	Status           *Status                 `protobuf:"varint,1,req,name=status,enum=hadoop.hdfs.Status" json:"status,omitempty"`
	Error            *string                 `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"`
	Id               *ShortCircuitShmIdProto `protobuf:"bytes,3,opt,name=id" json:"id,omitempty"`
	XXX_unrecognized []byte                  `json:"-"`
}

func (*ShortCircuitShmResponseProto) GetError 

func (m *ShortCircuitShmResponseProto) GetError() string

func (*ShortCircuitShmResponseProto) GetId 

func (m *ShortCircuitShmResponseProto) GetId() *ShortCircuitShmIdProto

func (*ShortCircuitShmResponseProto) GetStatus 

func (m *ShortCircuitShmResponseProto) GetStatus() Status

func (*ShortCircuitShmResponseProto) ProtoMessage 

func (*ShortCircuitShmResponseProto) ProtoMessage()

func (*ShortCircuitShmResponseProto) Reset 

func (m *ShortCircuitShmResponseProto) Reset()

func (*ShortCircuitShmResponseProto) String 

func (m *ShortCircuitShmResponseProto) String() string

type ShortCircuitShmSlotProto 

type ShortCircuitShmSlotProto struct {
	ShmId            *ShortCircuitShmIdProto `protobuf:"bytes,1,req,name=shmId" json:"shmId,omitempty"`
	SlotIdx          *int32                  `protobuf:"varint,2,req,name=slotIdx" json:"slotIdx,omitempty"`
	XXX_unrecognized []byte                  `json:"-"`
}

* An ID uniquely identifying a slot within a shared memory segment.

func (*ShortCircuitShmSlotProto) GetShmId 

func (m *ShortCircuitShmSlotProto) GetShmId() *ShortCircuitShmIdProto

func (*ShortCircuitShmSlotProto) GetSlotIdx 

func (m *ShortCircuitShmSlotProto) GetSlotIdx() int32

func (*ShortCircuitShmSlotProto) ProtoMessage 

func (*ShortCircuitShmSlotProto) ProtoMessage()

func (*ShortCircuitShmSlotProto) Reset 

func (m *ShortCircuitShmSlotProto) Reset()

func (*ShortCircuitShmSlotProto) String 

func (m *ShortCircuitShmSlotProto) String() string

type ShutdownDatanodeRequestProto 

type ShutdownDatanodeRequestProto struct {
	ForUpgrade       *bool  `protobuf:"varint,1,req,name=forUpgrade" json:"forUpgrade,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

* forUpgrade - if true, clients are advised to wait for restart and quick 

upgrade restart is instrumented. Otherwise, datanode does
the regular shutdown.

func (*ShutdownDatanodeRequestProto) GetForUpgrade 

func (m *ShutdownDatanodeRequestProto) GetForUpgrade() bool

func (*ShutdownDatanodeRequestProto) ProtoMessage 

func (*ShutdownDatanodeRequestProto) ProtoMessage()

func (*ShutdownDatanodeRequestProto) Reset 

func (m *ShutdownDatanodeRequestProto) Reset()

func (*ShutdownDatanodeRequestProto) String 

func (m *ShutdownDatanodeRequestProto) String() string

type ShutdownDatanodeResponseProto 

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

func (*ShutdownDatanodeResponseProto) ProtoMessage 

func (*ShutdownDatanodeResponseProto) ProtoMessage()

func (*ShutdownDatanodeResponseProto) Reset 

func (m *ShutdownDatanodeResponseProto) Reset()

func (*ShutdownDatanodeResponseProto) String 

func (m *ShutdownDatanodeResponseProto) 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"`
	TargetPath        []byte  `protobuf:"bytes,3,opt,name=targetPath" json:"targetPath,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) GetTargetPath 

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

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 StartLogSegmentRequestProto 

type StartLogSegmentRequestProto struct {
	JournalInfo      *JournalInfoProto `protobuf:"bytes,1,req,name=journalInfo" json:"journalInfo,omitempty"`
	Txid             *uint64           `protobuf:"varint,2,req,name=txid" json:"txid,omitempty"`
	Epoch            *uint64           `protobuf:"varint,3,req,name=epoch" json:"epoch,omitempty"`
	XXX_unrecognized []byte            `json:"-"`
}

* journalInfo - the information about the journal txid - first txid in the new log

func (*StartLogSegmentRequestProto) GetEpoch 

func (m *StartLogSegmentRequestProto) GetEpoch() uint64

func (*StartLogSegmentRequestProto) GetJournalInfo 

func (m *StartLogSegmentRequestProto) GetJournalInfo() *JournalInfoProto

func (*StartLogSegmentRequestProto) GetTxid 

func (m *StartLogSegmentRequestProto) GetTxid() uint64

func (*StartLogSegmentRequestProto) ProtoMessage 

func (*StartLogSegmentRequestProto) ProtoMessage()

func (*StartLogSegmentRequestProto) Reset 

func (m *StartLogSegmentRequestProto) Reset()

func (*StartLogSegmentRequestProto) String 

func (m *StartLogSegmentRequestProto) String() string

type StartLogSegmentResponseProto 

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

* void response

func (*StartLogSegmentResponseProto) ProtoMessage 

func (*StartLogSegmentResponseProto) ProtoMessage()

func (*StartLogSegmentResponseProto) Reset 

func (m *StartLogSegmentResponseProto) Reset()

func (*StartLogSegmentResponseProto) String 

func (m *StartLogSegmentResponseProto) 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
	Status_OOB_RESTART        Status = 8
	Status_OOB_RESERVED1      Status = 9
	Status_OOB_RESERVED2      Status = 10
	Status_OOB_RESERVED3      Status = 11
)

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 StorageTypeProto 

type StorageTypeProto int32

* Types of recognized storage media. 

const (
	StorageTypeProto_DISK StorageTypeProto = 1
	StorageTypeProto_SSD  StorageTypeProto = 2
)

func (StorageTypeProto) Enum 

func (x StorageTypeProto) Enum() *StorageTypeProto

func (StorageTypeProto) String 

func (x StorageTypeProto) String() string

func (*StorageTypeProto) UnmarshalJSON 

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

type StorageUuidsProto 

type StorageUuidsProto struct {
	StorageUuids     []string `protobuf:"bytes,1,rep,name=storageUuids" json:"storageUuids,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

* A list of storage IDs.

func (*StorageUuidsProto) GetStorageUuids 

func (m *StorageUuidsProto) GetStorageUuids() []string

func (*StorageUuidsProto) ProtoMessage 

func (*StorageUuidsProto) ProtoMessage()

func (*StorageUuidsProto) Reset 

func (m *StorageUuidsProto) Reset()

func (*StorageUuidsProto) String 

func (m *StorageUuidsProto) 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"`
	StorageIDs       []string            `protobuf:"bytes,5,rep,name=storageIDs" json:"storageIDs,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) GetStorageIDs 

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

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 UpdateReplicaUnderRecoveryRequestProto 

type UpdateReplicaUnderRecoveryRequestProto struct {
	Block            *ExtendedBlockProto `protobuf:"bytes,1,req,name=block" json:"block,omitempty"`
	RecoveryId       *uint64             `protobuf:"varint,2,req,name=recoveryId" json:"recoveryId,omitempty"`
	NewLength        *uint64             `protobuf:"varint,3,req,name=newLength" json:"newLength,omitempty"`
	XXX_unrecognized []byte              `json:"-"`
}

* Update replica with new generation stamp and length

func (*UpdateReplicaUnderRecoveryRequestProto) GetBlock 

func (m *UpdateReplicaUnderRecoveryRequestProto) GetBlock() *ExtendedBlockProto

func (*UpdateReplicaUnderRecoveryRequestProto) GetNewLength 

func (m *UpdateReplicaUnderRecoveryRequestProto) GetNewLength() uint64

func (*UpdateReplicaUnderRecoveryRequestProto) GetRecoveryId 

func (m *UpdateReplicaUnderRecoveryRequestProto) GetRecoveryId() uint64

func (*UpdateReplicaUnderRecoveryRequestProto) ProtoMessage 

func (*UpdateReplicaUnderRecoveryRequestProto) ProtoMessage()

func (*UpdateReplicaUnderRecoveryRequestProto) Reset 

func (m *UpdateReplicaUnderRecoveryRequestProto) Reset()

func (*UpdateReplicaUnderRecoveryRequestProto) String 

func (m *UpdateReplicaUnderRecoveryRequestProto) String() string

type UpdateReplicaUnderRecoveryResponseProto 

type UpdateReplicaUnderRecoveryResponseProto struct {
	StorageUuid      *string `protobuf:"bytes,1,opt,name=storageUuid" json:"storageUuid,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* Response returns updated block information

func (*UpdateReplicaUnderRecoveryResponseProto) GetStorageUuid 

func (m *UpdateReplicaUnderRecoveryResponseProto) GetStorageUuid() string

func (*UpdateReplicaUnderRecoveryResponseProto) ProtoMessage 

func (*UpdateReplicaUnderRecoveryResponseProto) ProtoMessage()

func (*UpdateReplicaUnderRecoveryResponseProto) Reset 

func (m *UpdateReplicaUnderRecoveryResponseProto) Reset()

func (*UpdateReplicaUnderRecoveryResponseProto) String 

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

type XAttrEditLogProto 

type XAttrEditLogProto struct {
	Src              *string       `protobuf:"bytes,1,opt,name=src" json:"src,omitempty"`
	XAttrs           []*XAttrProto `protobuf:"bytes,2,rep,name=xAttrs" json:"xAttrs,omitempty"`
	XXX_unrecognized []byte        `json:"-"`
}

func (*XAttrEditLogProto) GetSrc 

func (m *XAttrEditLogProto) GetSrc() string

func (*XAttrEditLogProto) GetXAttrs 

func (m *XAttrEditLogProto) GetXAttrs() []*XAttrProto

func (*XAttrEditLogProto) ProtoMessage 

func (*XAttrEditLogProto) ProtoMessage()

func (*XAttrEditLogProto) Reset 

func (m *XAttrEditLogProto) Reset()

func (*XAttrEditLogProto) String 

func (m *XAttrEditLogProto) String() string

type XAttrProto 

type XAttrProto struct {
	Namespace        *XAttrProto_XAttrNamespaceProto `protobuf:"varint,1,req,name=namespace,enum=hadoop.hdfs.XAttrProto_XAttrNamespaceProto" json:"namespace,omitempty"`
	Name             *string                         `protobuf:"bytes,2,req,name=name" json:"name,omitempty"`
	Value            []byte                          `protobuf:"bytes,3,opt,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte                          `json:"-"`
}

func (*XAttrProto) GetName 

func (m *XAttrProto) GetName() string

func (*XAttrProto) GetNamespace 

func (m *XAttrProto) GetNamespace() XAttrProto_XAttrNamespaceProto

func (*XAttrProto) GetValue 

func (m *XAttrProto) GetValue() []byte

func (*XAttrProto) ProtoMessage 

func (*XAttrProto) ProtoMessage()

func (*XAttrProto) Reset 

func (m *XAttrProto) Reset()

func (*XAttrProto) String 

func (m *XAttrProto) String() string

type XAttrProto_XAttrNamespaceProto 

type XAttrProto_XAttrNamespaceProto int32
const (
	XAttrProto_USER     XAttrProto_XAttrNamespaceProto = 0
	XAttrProto_TRUSTED  XAttrProto_XAttrNamespaceProto = 1
	XAttrProto_SECURITY XAttrProto_XAttrNamespaceProto = 2
	XAttrProto_SYSTEM   XAttrProto_XAttrNamespaceProto = 3
)

func (XAttrProto_XAttrNamespaceProto) Enum 

func (x XAttrProto_XAttrNamespaceProto) Enum() *XAttrProto_XAttrNamespaceProto

func (XAttrProto_XAttrNamespaceProto) String 

func (x XAttrProto_XAttrNamespaceProto) String() string

func (*XAttrProto_XAttrNamespaceProto) UnmarshalJSON 

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

type XAttrSetFlagProto 

type XAttrSetFlagProto int32
const (
	XAttrSetFlagProto_XATTR_CREATE  XAttrSetFlagProto = 1
	XAttrSetFlagProto_XATTR_REPLACE XAttrSetFlagProto = 2
)

func (XAttrSetFlagProto) Enum 

func (x XAttrSetFlagProto) Enum() *XAttrSetFlagProto

func (XAttrSetFlagProto) String 

func (x XAttrSetFlagProto) String() string

func (*XAttrSetFlagProto) UnmarshalJSON 

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

Source Files

View all Source files

Directories

Path Synopsis
Package hadoop_hdfs_datanode is a generated protocol buffer package.
 Package hadoop_hdfs_datanode is a generated protocol buffer package.
Package hadoop_hdfs_namenode is a generated protocol buffer package.
 Package hadoop_hdfs_namenode is a generated protocol buffer package.
Package hadoop_hdfs_qjournal is a generated protocol buffer package.
 Package hadoop_hdfs_qjournal is a generated protocol buffer package.

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.