hadoop_hdfs

package
v1.1.0 Latest Latest
Warning

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

Go to latest
Published: Oct 26, 2017 License: MIT Imports: 3 Imported by: 0

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
encryption.proto
erasurecoding.proto
hdfs.proto
inotify.proto
ReconfigurationProtocol.proto
xattr.proto

It has these top-level messages:

AclEntryProto
AclStatusProto
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_AppendEventProto_NewBlock bool = false
View Source
const Default_BlockProto_NumBytes uint64 = 0
View Source
const Default_CompleteRequestProto_FileId uint64 = 0
View Source
const Default_CreateEventProto_DefaultBlockSize int64 = 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_LastUpdateMonotonic 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_HdfsFileStatusProto_StoragePolicy uint32 = 0
View Source
const Default_OpReadBlockProto_SendChecksums bool = true
View Source
const Default_OpRequestShortCircuitAccessProto_SupportsReceiptVerification bool = false
View Source
const Default_OpWriteBlockProto_AllowLazyPersist bool = false
View Source
const Default_OpWriteBlockProto_Pinning bool = false
View Source
const Default_PacketHeaderProto_SyncBlock bool = false
View Source
const Default_PipelineAckProto_DownstreamAckTimeNanos uint64 = 0
View Source
const Default_RollingUpgradeStatusProto_Finalized bool = false
View Source
const Default_SaveNamespaceRequestProto_TimeWindow uint64 = 0
View Source
const Default_SaveNamespaceRequestProto_TxGap uint64 = 0
View Source
const Default_SaveNamespaceResponseProto_Saved bool = true
View Source
const Default_SetSafeModeRequestProto_Checked bool = false
View Source
const Default_StorageReportProto_BlockPoolUsed uint64 = 0
View Source
const Default_StorageReportProto_Capacity uint64 = 0
View Source
const Default_StorageReportProto_DfsUsed uint64 = 0
View Source
const Default_StorageReportProto_Failed bool = false
View Source
const Default_StorageReportProto_Remaining uint64 = 0

Variables

View Source
var 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 CipherSuiteProto_name = map[int32]string{
	1: "UNKNOWN",
	2: "AES_CTR_NOPADDING",
}
View Source
var CipherSuiteProto_value = map[string]int32{
	"UNKNOWN":           1,
	"AES_CTR_NOPADDING": 2,
}
View Source
var CreateFlagProto_name = map[int32]string{
	1:  "CREATE",
	2:  "OVERWRITE",
	4:  "APPEND",
	16: "LAZY_PERSIST",
	32: "NEW_BLOCK",
}
View Source
var CreateFlagProto_value = map[string]int32{
	"CREATE":       1,
	"OVERWRITE":    2,
	"APPEND":       4,
	"LAZY_PERSIST": 16,
	"NEW_BLOCK":    32,
}
View Source
var CryptoProtocolVersionProto_name = map[int32]string{
	1: "UNKNOWN_PROTOCOL_VERSION",
	2: "ENCRYPTION_ZONES",
}
View Source
var CryptoProtocolVersionProto_value = map[string]int32{
	"UNKNOWN_PROTOCOL_VERSION": 1,
	"ENCRYPTION_ZONES":         2,
}
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 DatanodeStorageProto_StorageState_name = map[int32]string{
	0: "NORMAL",
	1: "READ_ONLY_SHARED",
}
View Source
var DatanodeStorageProto_StorageState_value = map[string]int32{
	"NORMAL":           0,
	"READ_ONLY_SHARED": 1,
}
View Source
var EventType_name = map[int32]string{
	0: "EVENT_CREATE",
	1: "EVENT_CLOSE",
	2: "EVENT_APPEND",
	3: "EVENT_RENAME",
	4: "EVENT_METADATA",
	5: "EVENT_UNLINK",
	6: "EVENT_TRUNCATE",
}
View Source
var EventType_value = map[string]int32{
	"EVENT_CREATE":   0,
	"EVENT_CLOSE":    1,
	"EVENT_APPEND":   2,
	"EVENT_RENAME":   3,
	"EVENT_METADATA": 4,
	"EVENT_UNLINK":   5,
	"EVENT_TRUNCATE": 6,
}
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 INodeType_name = map[int32]string{
	0: "I_TYPE_FILE",
	1: "I_TYPE_DIRECTORY",
	2: "I_TYPE_SYMLINK",
}
View Source
var INodeType_value = map[string]int32{
	"I_TYPE_FILE":      0,
	"I_TYPE_DIRECTORY": 1,
	"I_TYPE_SYMLINK":   2,
}
View Source
var MetadataUpdateType_name = map[int32]string{
	0: "META_TYPE_TIMES",
	1: "META_TYPE_REPLICATION",
	2: "META_TYPE_OWNER",
	3: "META_TYPE_PERMS",
	4: "META_TYPE_ACLS",
	5: "META_TYPE_XATTRS",
}
View Source
var MetadataUpdateType_value = map[string]int32{
	"META_TYPE_TIMES":       0,
	"META_TYPE_REPLICATION": 1,
	"META_TYPE_OWNER":       2,
	"META_TYPE_PERMS":       3,
	"META_TYPE_ACLS":        4,
	"META_TYPE_XATTRS":      5,
}
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 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",
	4: "SAFEMODE_FORCE_EXIT",
}
View Source
var SafeModeActionProto_value = map[string]int32{
	"SAFEMODE_LEAVE":      1,
	"SAFEMODE_ENTER":      2,
	"SAFEMODE_GET":        3,
	"SAFEMODE_FORCE_EXIT": 4,
}
View Source
var ShortCircuitFdResponse_name = map[int32]string{
	0: "DO_NOT_USE_RECEIPT_VERIFICATION",
	1: "USE_RECEIPT_VERIFICATION",
}
View Source
var ShortCircuitFdResponse_value = map[string]int32{
	"DO_NOT_USE_RECEIPT_VERIFICATION": 0,
	"USE_RECEIPT_VERIFICATION":        1,
}
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",
	12: "IN_PROGRESS",
}
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,
	"IN_PROGRESS":        12,
}
View Source
var StorageTypeProto_name = map[int32]string{
	1: "DISK",
	2: "SSD",
	3: "ARCHIVE",
	4: "RAM_DISK",
}
View Source
var StorageTypeProto_value = map[string]int32{
	"DISK":     1,
	"SSD":      2,
	"ARCHIVE":  3,
	"RAM_DISK": 4,
}
View Source
var XAttrProto_XAttrNamespaceProto_name = map[int32]string{
	0: "USER",
	1: "TRUSTED",
	2: "SECURITY",
	3: "SYSTEM",
	4: "RAW",
}
View Source
var XAttrProto_XAttrNamespaceProto_value = map[string]int32{
	"USER":     0,
	"TRUSTED":  1,
	"SECURITY": 2,
	"SYSTEM":   3,
	"RAW":      4,
}
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 (*AbandonBlockRequestProto) GetFileId added in v1.0.0

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 AclEntryProto added in v1.0.0

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 added in v1.0.0

func (m *AclEntryProto) GetName() string

func (*AclEntryProto) GetPermissions added in v1.0.0

func (m *AclEntryProto) GetPermissions() AclEntryProto_FsActionProto

func (*AclEntryProto) GetScope added in v1.0.0

func (*AclEntryProto) GetType added in v1.0.0

func (*AclEntryProto) ProtoMessage added in v1.0.0

func (*AclEntryProto) ProtoMessage()

func (*AclEntryProto) Reset added in v1.0.0

func (m *AclEntryProto) Reset()

func (*AclEntryProto) String added in v1.0.0

func (m *AclEntryProto) String() string

type AclEntryProto_AclEntryScopeProto added in v1.0.0

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

func (AclEntryProto_AclEntryScopeProto) Enum added in v1.0.0

func (AclEntryProto_AclEntryScopeProto) String added in v1.0.0

func (*AclEntryProto_AclEntryScopeProto) UnmarshalJSON added in v1.0.0

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

type AclEntryProto_AclEntryTypeProto added in v1.0.0

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 added in v1.0.0

func (AclEntryProto_AclEntryTypeProto) String added in v1.0.0

func (*AclEntryProto_AclEntryTypeProto) UnmarshalJSON added in v1.0.0

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

type AclEntryProto_FsActionProto added in v1.0.0

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 added in v1.0.0

func (AclEntryProto_FsActionProto) String added in v1.0.0

func (*AclEntryProto_FsActionProto) UnmarshalJSON added in v1.0.0

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

type AclStatusProto added in v1.0.0

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"`
	Permission       *FsPermissionProto `protobuf:"bytes,5,opt,name=permission" json:"permission,omitempty"`
	XXX_unrecognized []byte             `json:"-"`
}

func (*AclStatusProto) GetEntries added in v1.0.0

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

func (*AclStatusProto) GetGroup added in v1.0.0

func (m *AclStatusProto) GetGroup() string

func (*AclStatusProto) GetOwner added in v1.0.0

func (m *AclStatusProto) GetOwner() string

func (*AclStatusProto) GetPermission added in v1.0.0

func (m *AclStatusProto) GetPermission() *FsPermissionProto

func (*AclStatusProto) GetSticky added in v1.0.0

func (m *AclStatusProto) GetSticky() bool

func (*AclStatusProto) ProtoMessage added in v1.0.0

func (*AclStatusProto) ProtoMessage()

func (*AclStatusProto) Reset added in v1.0.0

func (m *AclStatusProto) Reset()

func (*AclStatusProto) String added in v1.0.0

func (m *AclStatusProto) String() string

type AddBlockRequestProto

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

func (*AddBlockRequestProto) GetClientName

func (m *AddBlockRequestProto) GetClientName() string

func (*AddBlockRequestProto) GetExcludeNodes

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

func (*AddBlockRequestProto) GetFavoredNodes

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

func (*AddBlockRequestProto) GetFileId

func (m *AddBlockRequestProto) GetFileId() uint64

func (*AddBlockRequestProto) GetPrevious

func (m *AddBlockRequestProto) GetPrevious() *ExtendedBlockProto

func (*AddBlockRequestProto) GetSrc

func (m *AddBlockRequestProto) GetSrc() string

func (*AddBlockRequestProto) ProtoMessage

func (*AddBlockRequestProto) ProtoMessage()

func (*AddBlockRequestProto) Reset

func (m *AddBlockRequestProto) Reset()

func (*AddBlockRequestProto) String

func (m *AddBlockRequestProto) String() string

type AddBlockResponseProto

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

func (*AddBlockResponseProto) GetBlock

func (*AddBlockResponseProto) ProtoMessage

func (*AddBlockResponseProto) ProtoMessage()

func (*AddBlockResponseProto) Reset

func (m *AddBlockResponseProto) Reset()

func (*AddBlockResponseProto) String

func (m *AddBlockResponseProto) String() string

type AddCacheDirectiveRequestProto added in v1.0.0

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 added in v1.0.0

func (m *AddCacheDirectiveRequestProto) GetCacheFlags() uint32

func (*AddCacheDirectiveRequestProto) GetInfo added in v1.0.0

func (*AddCacheDirectiveRequestProto) ProtoMessage added in v1.0.0

func (*AddCacheDirectiveRequestProto) ProtoMessage()

func (*AddCacheDirectiveRequestProto) Reset added in v1.0.0

func (m *AddCacheDirectiveRequestProto) Reset()

func (*AddCacheDirectiveRequestProto) String added in v1.0.0

type AddCacheDirectiveResponseProto added in v1.0.0

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

func (*AddCacheDirectiveResponseProto) GetId added in v1.0.0

func (*AddCacheDirectiveResponseProto) ProtoMessage added in v1.0.0

func (*AddCacheDirectiveResponseProto) ProtoMessage()

func (*AddCacheDirectiveResponseProto) Reset added in v1.0.0

func (m *AddCacheDirectiveResponseProto) Reset()

func (*AddCacheDirectiveResponseProto) String added in v1.0.0

type AddCachePoolRequestProto added in v1.0.0

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

func (*AddCachePoolRequestProto) GetInfo added in v1.0.0

func (*AddCachePoolRequestProto) ProtoMessage added in v1.0.0

func (*AddCachePoolRequestProto) ProtoMessage()

func (*AddCachePoolRequestProto) Reset added in v1.0.0

func (m *AddCachePoolRequestProto) Reset()

func (*AddCachePoolRequestProto) String added in v1.0.0

func (m *AddCachePoolRequestProto) String() string

type AddCachePoolResponseProto added in v1.0.0

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

func (*AddCachePoolResponseProto) ProtoMessage added in v1.0.0

func (*AddCachePoolResponseProto) ProtoMessage()

func (*AddCachePoolResponseProto) Reset added in v1.0.0

func (m *AddCachePoolResponseProto) Reset()

func (*AddCachePoolResponseProto) String added in v1.0.0

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 AppendEventProto added in v1.0.0

type AppendEventProto struct {
	Path             *string `protobuf:"bytes,1,req,name=path" json:"path,omitempty"`
	NewBlock         *bool   `protobuf:"varint,2,opt,name=newBlock,def=0" json:"newBlock,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*AppendEventProto) GetNewBlock added in v1.0.0

func (m *AppendEventProto) GetNewBlock() bool

func (*AppendEventProto) GetPath added in v1.0.0

func (m *AppendEventProto) GetPath() string

func (*AppendEventProto) ProtoMessage added in v1.0.0

func (*AppendEventProto) ProtoMessage()

func (*AppendEventProto) Reset added in v1.0.0

func (m *AppendEventProto) Reset()

func (*AppendEventProto) String added in v1.0.0

func (m *AppendEventProto) 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"`
	Flag             *uint32 `protobuf:"varint,3,opt,name=flag" json:"flag,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*AppendRequestProto) GetClientName

func (m *AppendRequestProto) GetClientName() string

func (*AppendRequestProto) GetFlag added in v1.0.0

func (m *AppendRequestProto) GetFlag() uint32

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"`
	Stat             *HdfsFileStatusProto `protobuf:"bytes,2,opt,name=stat" json:"stat,omitempty"`
	XXX_unrecognized []byte               `json:"-"`
}

func (*AppendResponseProto) GetBlock

func (m *AppendResponseProto) GetBlock() *LocatedBlockProto

func (*AppendResponseProto) GetStat added in v1.0.0

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"`
	TraceInfo        *DataTransferTraceInfoProto `protobuf:"bytes,3,opt,name=traceInfo" json:"traceInfo,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) GetTraceInfo added in v1.0.0

func (m *BaseHeaderProto) GetTraceInfo() *DataTransferTraceInfoProto

func (*BaseHeaderProto) ProtoMessage

func (*BaseHeaderProto) ProtoMessage()

func (*BaseHeaderProto) Reset

func (m *BaseHeaderProto) Reset()

func (*BaseHeaderProto) String

func (m *BaseHeaderProto) String() string

type BlockECReconstructionInfoProto added in v1.0.0

type BlockECReconstructionInfoProto struct {
	Block              *ExtendedBlockProto       `protobuf:"bytes,1,req,name=block" json:"block,omitempty"`
	SourceDnInfos      *DatanodeInfosProto       `protobuf:"bytes,2,req,name=sourceDnInfos" json:"sourceDnInfos,omitempty"`
	TargetDnInfos      *DatanodeInfosProto       `protobuf:"bytes,3,req,name=targetDnInfos" json:"targetDnInfos,omitempty"`
	TargetStorageUuids *StorageUuidsProto        `protobuf:"bytes,4,req,name=targetStorageUuids" json:"targetStorageUuids,omitempty"`
	TargetStorageTypes *StorageTypesProto        `protobuf:"bytes,5,req,name=targetStorageTypes" json:"targetStorageTypes,omitempty"`
	LiveBlockIndices   []byte                    `protobuf:"bytes,6,req,name=liveBlockIndices" json:"liveBlockIndices,omitempty"`
	EcPolicy           *ErasureCodingPolicyProto `protobuf:"bytes,7,req,name=ecPolicy" json:"ecPolicy,omitempty"`
	XXX_unrecognized   []byte                    `json:"-"`
}

* Block erasure coding reconstruction info

func (*BlockECReconstructionInfoProto) GetBlock added in v1.0.0

func (*BlockECReconstructionInfoProto) GetEcPolicy added in v1.0.0

func (*BlockECReconstructionInfoProto) GetLiveBlockIndices added in v1.0.0

func (m *BlockECReconstructionInfoProto) GetLiveBlockIndices() []byte

func (*BlockECReconstructionInfoProto) GetSourceDnInfos added in v1.0.0

func (m *BlockECReconstructionInfoProto) GetSourceDnInfos() *DatanodeInfosProto

func (*BlockECReconstructionInfoProto) GetTargetDnInfos added in v1.0.0

func (m *BlockECReconstructionInfoProto) GetTargetDnInfos() *DatanodeInfosProto

func (*BlockECReconstructionInfoProto) GetTargetStorageTypes added in v1.0.0

func (m *BlockECReconstructionInfoProto) GetTargetStorageTypes() *StorageTypesProto

func (*BlockECReconstructionInfoProto) GetTargetStorageUuids added in v1.0.0

func (m *BlockECReconstructionInfoProto) GetTargetStorageUuids() *StorageUuidsProto

func (*BlockECReconstructionInfoProto) ProtoMessage added in v1.0.0

func (*BlockECReconstructionInfoProto) ProtoMessage()

func (*BlockECReconstructionInfoProto) Reset added in v1.0.0

func (m *BlockECReconstructionInfoProto) Reset()

func (*BlockECReconstructionInfoProto) String added in v1.0.0

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 BlockStoragePolicyProto added in v1.0.0

type BlockStoragePolicyProto struct {
	PolicyId *uint32 `protobuf:"varint,1,req,name=policyId" json:"policyId,omitempty"`
	Name     *string `protobuf:"bytes,2,req,name=name" json:"name,omitempty"`
	// a list of storage types for storing the block replicas when creating a
	// block.
	CreationPolicy *StorageTypesProto `protobuf:"bytes,3,req,name=creationPolicy" json:"creationPolicy,omitempty"`
	// A list of storage types for creation fallback storage.
	CreationFallbackPolicy    *StorageTypesProto `protobuf:"bytes,4,opt,name=creationFallbackPolicy" json:"creationFallbackPolicy,omitempty"`
	ReplicationFallbackPolicy *StorageTypesProto `protobuf:"bytes,5,opt,name=replicationFallbackPolicy" json:"replicationFallbackPolicy,omitempty"`
	XXX_unrecognized          []byte             `json:"-"`
}

* Block replica storage policy.

func (*BlockStoragePolicyProto) GetCreationFallbackPolicy added in v1.0.0

func (m *BlockStoragePolicyProto) GetCreationFallbackPolicy() *StorageTypesProto

func (*BlockStoragePolicyProto) GetCreationPolicy added in v1.0.0

func (m *BlockStoragePolicyProto) GetCreationPolicy() *StorageTypesProto

func (*BlockStoragePolicyProto) GetName added in v1.0.0

func (m *BlockStoragePolicyProto) GetName() string

func (*BlockStoragePolicyProto) GetPolicyId added in v1.0.0

func (m *BlockStoragePolicyProto) GetPolicyId() uint32

func (*BlockStoragePolicyProto) GetReplicationFallbackPolicy added in v1.0.0

func (m *BlockStoragePolicyProto) GetReplicationFallbackPolicy() *StorageTypesProto

func (*BlockStoragePolicyProto) ProtoMessage added in v1.0.0

func (*BlockStoragePolicyProto) ProtoMessage()

func (*BlockStoragePolicyProto) Reset added in v1.0.0

func (m *BlockStoragePolicyProto) Reset()

func (*BlockStoragePolicyProto) String added in v1.0.0

func (m *BlockStoragePolicyProto) String() string

type CacheDirectiveEntryProto added in v1.0.0

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 added in v1.0.0

func (*CacheDirectiveEntryProto) GetStats added in v1.0.0

func (*CacheDirectiveEntryProto) ProtoMessage added in v1.0.0

func (*CacheDirectiveEntryProto) ProtoMessage()

func (*CacheDirectiveEntryProto) Reset added in v1.0.0

func (m *CacheDirectiveEntryProto) Reset()

func (*CacheDirectiveEntryProto) String added in v1.0.0

func (m *CacheDirectiveEntryProto) String() string

type CacheDirectiveInfoExpirationProto added in v1.0.0

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 added in v1.0.0

func (m *CacheDirectiveInfoExpirationProto) GetIsRelative() bool

func (*CacheDirectiveInfoExpirationProto) GetMillis added in v1.0.0

func (*CacheDirectiveInfoExpirationProto) ProtoMessage added in v1.0.0

func (*CacheDirectiveInfoExpirationProto) ProtoMessage()

func (*CacheDirectiveInfoExpirationProto) Reset added in v1.0.0

func (*CacheDirectiveInfoExpirationProto) String added in v1.0.0

type CacheDirectiveInfoProto added in v1.0.0

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 added in v1.0.0

func (*CacheDirectiveInfoProto) GetId added in v1.0.0

func (m *CacheDirectiveInfoProto) GetId() int64

func (*CacheDirectiveInfoProto) GetPath added in v1.0.0

func (m *CacheDirectiveInfoProto) GetPath() string

func (*CacheDirectiveInfoProto) GetPool added in v1.0.0

func (m *CacheDirectiveInfoProto) GetPool() string

func (*CacheDirectiveInfoProto) GetReplication added in v1.0.0

func (m *CacheDirectiveInfoProto) GetReplication() uint32

func (*CacheDirectiveInfoProto) ProtoMessage added in v1.0.0

func (*CacheDirectiveInfoProto) ProtoMessage()

func (*CacheDirectiveInfoProto) Reset added in v1.0.0

func (m *CacheDirectiveInfoProto) Reset()

func (*CacheDirectiveInfoProto) String added in v1.0.0

func (m *CacheDirectiveInfoProto) String() string

type CacheDirectiveStatsProto added in v1.0.0

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 added in v1.0.0

func (m *CacheDirectiveStatsProto) GetBytesCached() int64

func (*CacheDirectiveStatsProto) GetBytesNeeded added in v1.0.0

func (m *CacheDirectiveStatsProto) GetBytesNeeded() int64

func (*CacheDirectiveStatsProto) GetFilesCached added in v1.0.0

func (m *CacheDirectiveStatsProto) GetFilesCached() int64

func (*CacheDirectiveStatsProto) GetFilesNeeded added in v1.0.0

func (m *CacheDirectiveStatsProto) GetFilesNeeded() int64

func (*CacheDirectiveStatsProto) GetHasExpired added in v1.0.0

func (m *CacheDirectiveStatsProto) GetHasExpired() bool

func (*CacheDirectiveStatsProto) ProtoMessage added in v1.0.0

func (*CacheDirectiveStatsProto) ProtoMessage()

func (*CacheDirectiveStatsProto) Reset added in v1.0.0

func (m *CacheDirectiveStatsProto) Reset()

func (*CacheDirectiveStatsProto) String added in v1.0.0

func (m *CacheDirectiveStatsProto) String() string

type CacheFlagProto added in v1.0.0

type CacheFlagProto int32
const (
	CacheFlagProto_FORCE CacheFlagProto = 1
)

func (CacheFlagProto) Enum added in v1.0.0

func (x CacheFlagProto) Enum() *CacheFlagProto

func (CacheFlagProto) String added in v1.0.0

func (x CacheFlagProto) String() string

func (*CacheFlagProto) UnmarshalJSON added in v1.0.0

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

type CachePoolEntryProto added in v1.0.0

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 added in v1.0.0

func (*CachePoolEntryProto) GetStats added in v1.0.0

func (*CachePoolEntryProto) ProtoMessage added in v1.0.0

func (*CachePoolEntryProto) ProtoMessage()

func (*CachePoolEntryProto) Reset added in v1.0.0

func (m *CachePoolEntryProto) Reset()

func (*CachePoolEntryProto) String added in v1.0.0

func (m *CachePoolEntryProto) String() string

type CachePoolInfoProto added in v1.0.0

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 added in v1.0.0

func (m *CachePoolInfoProto) GetGroupName() string

func (*CachePoolInfoProto) GetLimit added in v1.0.0

func (m *CachePoolInfoProto) GetLimit() int64

func (*CachePoolInfoProto) GetMaxRelativeExpiry added in v1.0.0

func (m *CachePoolInfoProto) GetMaxRelativeExpiry() int64

func (*CachePoolInfoProto) GetMode added in v1.0.0

func (m *CachePoolInfoProto) GetMode() int32

func (*CachePoolInfoProto) GetOwnerName added in v1.0.0

func (m *CachePoolInfoProto) GetOwnerName() string

func (*CachePoolInfoProto) GetPoolName added in v1.0.0

func (m *CachePoolInfoProto) GetPoolName() string

func (*CachePoolInfoProto) ProtoMessage added in v1.0.0

func (*CachePoolInfoProto) ProtoMessage()

func (*CachePoolInfoProto) Reset added in v1.0.0

func (m *CachePoolInfoProto) Reset()

func (*CachePoolInfoProto) String added in v1.0.0

func (m *CachePoolInfoProto) String() string

type CachePoolStatsProto added in v1.0.0

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 added in v1.0.0

func (m *CachePoolStatsProto) GetBytesCached() int64

func (*CachePoolStatsProto) GetBytesNeeded added in v1.0.0

func (m *CachePoolStatsProto) GetBytesNeeded() int64

func (*CachePoolStatsProto) GetBytesOverlimit added in v1.0.0

func (m *CachePoolStatsProto) GetBytesOverlimit() int64

func (*CachePoolStatsProto) GetFilesCached added in v1.0.0

func (m *CachePoolStatsProto) GetFilesCached() int64

func (*CachePoolStatsProto) GetFilesNeeded added in v1.0.0

func (m *CachePoolStatsProto) GetFilesNeeded() int64

func (*CachePoolStatsProto) ProtoMessage added in v1.0.0

func (*CachePoolStatsProto) ProtoMessage()

func (*CachePoolStatsProto) Reset added in v1.0.0

func (m *CachePoolStatsProto) Reset()

func (*CachePoolStatsProto) String added in v1.0.0

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 CheckAccessRequestProto added in v1.0.0

type CheckAccessRequestProto struct {
	Path             *string                      `protobuf:"bytes,1,req,name=path" json:"path,omitempty"`
	Mode             *AclEntryProto_FsActionProto `protobuf:"varint,2,req,name=mode,enum=hadoop.hdfs.AclEntryProto_FsActionProto" json:"mode,omitempty"`
	XXX_unrecognized []byte                       `json:"-"`
}

func (*CheckAccessRequestProto) GetMode added in v1.0.0

func (*CheckAccessRequestProto) GetPath added in v1.0.0

func (m *CheckAccessRequestProto) GetPath() string

func (*CheckAccessRequestProto) ProtoMessage added in v1.0.0

func (*CheckAccessRequestProto) ProtoMessage()

func (*CheckAccessRequestProto) Reset added in v1.0.0

func (m *CheckAccessRequestProto) Reset()

func (*CheckAccessRequestProto) String added in v1.0.0

func (m *CheckAccessRequestProto) String() string

type CheckAccessResponseProto added in v1.0.0

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

func (*CheckAccessResponseProto) ProtoMessage added in v1.0.0

func (*CheckAccessResponseProto) ProtoMessage()

func (*CheckAccessResponseProto) Reset added in v1.0.0

func (m *CheckAccessResponseProto) Reset()

func (*CheckAccessResponseProto) String added in v1.0.0

func (m *CheckAccessResponseProto) String() string

type ChecksumProto

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

func (*ChecksumProto) GetBytesPerChecksum

func (m *ChecksumProto) GetBytesPerChecksum() uint32

func (*ChecksumProto) GetType

func (m *ChecksumProto) GetType() ChecksumTypeProto

func (*ChecksumProto) ProtoMessage

func (*ChecksumProto) ProtoMessage()

func (*ChecksumProto) Reset

func (m *ChecksumProto) Reset()

func (*ChecksumProto) String

func (m *ChecksumProto) String() string

type ChecksumTypeProto

type ChecksumTypeProto int32

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

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

func (ChecksumTypeProto) Enum

func (ChecksumTypeProto) String

func (x ChecksumTypeProto) String() string

func (*ChecksumTypeProto) UnmarshalJSON

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

type CipherOptionProto added in v1.0.0

type CipherOptionProto struct {
	Suite            *CipherSuiteProto `protobuf:"varint,1,req,name=suite,enum=hadoop.hdfs.CipherSuiteProto" json:"suite,omitempty"`
	InKey            []byte            `protobuf:"bytes,2,opt,name=inKey" json:"inKey,omitempty"`
	InIv             []byte            `protobuf:"bytes,3,opt,name=inIv" json:"inIv,omitempty"`
	OutKey           []byte            `protobuf:"bytes,4,opt,name=outKey" json:"outKey,omitempty"`
	OutIv            []byte            `protobuf:"bytes,5,opt,name=outIv" json:"outIv,omitempty"`
	XXX_unrecognized []byte            `json:"-"`
}

* Cipher option

func (*CipherOptionProto) GetInIv added in v1.0.0

func (m *CipherOptionProto) GetInIv() []byte

func (*CipherOptionProto) GetInKey added in v1.0.0

func (m *CipherOptionProto) GetInKey() []byte

func (*CipherOptionProto) GetOutIv added in v1.0.0

func (m *CipherOptionProto) GetOutIv() []byte

func (*CipherOptionProto) GetOutKey added in v1.0.0

func (m *CipherOptionProto) GetOutKey() []byte

func (*CipherOptionProto) GetSuite added in v1.0.0

func (m *CipherOptionProto) GetSuite() CipherSuiteProto

func (*CipherOptionProto) ProtoMessage added in v1.0.0

func (*CipherOptionProto) ProtoMessage()

func (*CipherOptionProto) Reset added in v1.0.0

func (m *CipherOptionProto) Reset()

func (*CipherOptionProto) String added in v1.0.0

func (m *CipherOptionProto) String() string

type CipherSuiteProto added in v1.0.0

type CipherSuiteProto int32

* Cipher suite.

const (
	CipherSuiteProto_UNKNOWN           CipherSuiteProto = 1
	CipherSuiteProto_AES_CTR_NOPADDING CipherSuiteProto = 2
)

func (CipherSuiteProto) Enum added in v1.0.0

func (CipherSuiteProto) String added in v1.0.0

func (x CipherSuiteProto) String() string

func (*CipherSuiteProto) UnmarshalJSON added in v1.0.0

func (x *CipherSuiteProto) 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 CloseEventProto added in v1.0.0

type CloseEventProto struct {
	Path             *string `protobuf:"bytes,1,req,name=path" json:"path,omitempty"`
	FileSize         *int64  `protobuf:"varint,2,req,name=fileSize" json:"fileSize,omitempty"`
	Timestamp        *int64  `protobuf:"varint,3,req,name=timestamp" json:"timestamp,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*CloseEventProto) GetFileSize added in v1.0.0

func (m *CloseEventProto) GetFileSize() int64

func (*CloseEventProto) GetPath added in v1.0.0

func (m *CloseEventProto) GetPath() string

func (*CloseEventProto) GetTimestamp added in v1.0.0

func (m *CloseEventProto) GetTimestamp() int64

func (*CloseEventProto) ProtoMessage added in v1.0.0

func (*CloseEventProto) ProtoMessage()

func (*CloseEventProto) Reset added in v1.0.0

func (m *CloseEventProto) Reset()

func (*CloseEventProto) String added in v1.0.0

func (m *CloseEventProto) String() string

type CompleteRequestProto

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

func (*CompleteRequestProto) GetClientName

func (m *CompleteRequestProto) GetClientName() string

func (*CompleteRequestProto) GetFileId

func (m *CompleteRequestProto) GetFileId() uint64

func (*CompleteRequestProto) GetLast

func (*CompleteRequestProto) GetSrc

func (m *CompleteRequestProto) GetSrc() string

func (*CompleteRequestProto) ProtoMessage

func (*CompleteRequestProto) ProtoMessage()

func (*CompleteRequestProto) Reset

func (m *CompleteRequestProto) Reset()

func (*CompleteRequestProto) String

func (m *CompleteRequestProto) String() string

type CompleteResponseProto

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

func (*CompleteResponseProto) GetResult

func (m *CompleteResponseProto) GetResult() bool

func (*CompleteResponseProto) ProtoMessage

func (*CompleteResponseProto) ProtoMessage()

func (*CompleteResponseProto) Reset

func (m *CompleteResponseProto) Reset()

func (*CompleteResponseProto) String

func (m *CompleteResponseProto) String() string

type ConcatRequestProto

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

func (*ConcatRequestProto) GetSrcs

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

func (*ConcatRequestProto) GetTrg

func (m *ConcatRequestProto) GetTrg() string

func (*ConcatRequestProto) ProtoMessage

func (*ConcatRequestProto) ProtoMessage()

func (*ConcatRequestProto) Reset

func (m *ConcatRequestProto) Reset()

func (*ConcatRequestProto) String

func (m *ConcatRequestProto) String() string

type ConcatResponseProto

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

func (*ConcatResponseProto) ProtoMessage

func (*ConcatResponseProto) ProtoMessage()

func (*ConcatResponseProto) Reset

func (m *ConcatResponseProto) Reset()

func (*ConcatResponseProto) String

func (m *ConcatResponseProto) String() string

type ContentSummaryProto

type ContentSummaryProto struct {
	Length           *uint64                     `protobuf:"varint,1,req,name=length" json:"length,omitempty"`
	FileCount        *uint64                     `protobuf:"varint,2,req,name=fileCount" json:"fileCount,omitempty"`
	DirectoryCount   *uint64                     `protobuf:"varint,3,req,name=directoryCount" json:"directoryCount,omitempty"`
	Quota            *uint64                     `protobuf:"varint,4,req,name=quota" json:"quota,omitempty"`
	SpaceConsumed    *uint64                     `protobuf:"varint,5,req,name=spaceConsumed" json:"spaceConsumed,omitempty"`
	SpaceQuota       *uint64                     `protobuf:"varint,6,req,name=spaceQuota" json:"spaceQuota,omitempty"`
	TypeQuotaInfos   *StorageTypeQuotaInfosProto `protobuf:"bytes,7,opt,name=typeQuotaInfos" json:"typeQuotaInfos,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) GetTypeQuotaInfos added in v1.0.0

func (m *ContentSummaryProto) GetTypeQuotaInfos() *StorageTypeQuotaInfosProto

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 CreateEncryptionZoneRequestProto added in v1.0.0

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

func (*CreateEncryptionZoneRequestProto) GetKeyName added in v1.0.0

func (m *CreateEncryptionZoneRequestProto) GetKeyName() string

func (*CreateEncryptionZoneRequestProto) GetSrc added in v1.0.0

func (*CreateEncryptionZoneRequestProto) ProtoMessage added in v1.0.0

func (*CreateEncryptionZoneRequestProto) ProtoMessage()

func (*CreateEncryptionZoneRequestProto) Reset added in v1.0.0

func (*CreateEncryptionZoneRequestProto) String added in v1.0.0

type CreateEncryptionZoneResponseProto added in v1.0.0

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

func (*CreateEncryptionZoneResponseProto) ProtoMessage added in v1.0.0

func (*CreateEncryptionZoneResponseProto) ProtoMessage()

func (*CreateEncryptionZoneResponseProto) Reset added in v1.0.0

func (*CreateEncryptionZoneResponseProto) String added in v1.0.0

type CreateEventProto added in v1.0.0

type CreateEventProto struct {
	Type             *INodeType         `protobuf:"varint,1,req,name=type,enum=hadoop.hdfs.INodeType" json:"type,omitempty"`
	Path             *string            `protobuf:"bytes,2,req,name=path" json:"path,omitempty"`
	Ctime            *int64             `protobuf:"varint,3,req,name=ctime" json:"ctime,omitempty"`
	OwnerName        *string            `protobuf:"bytes,4,req,name=ownerName" json:"ownerName,omitempty"`
	GroupName        *string            `protobuf:"bytes,5,req,name=groupName" json:"groupName,omitempty"`
	Perms            *FsPermissionProto `protobuf:"bytes,6,req,name=perms" json:"perms,omitempty"`
	Replication      *int32             `protobuf:"varint,7,opt,name=replication" json:"replication,omitempty"`
	SymlinkTarget    *string            `protobuf:"bytes,8,opt,name=symlinkTarget" json:"symlinkTarget,omitempty"`
	Overwrite        *bool              `protobuf:"varint,9,opt,name=overwrite" json:"overwrite,omitempty"`
	DefaultBlockSize *int64             `protobuf:"varint,10,opt,name=defaultBlockSize,def=0" json:"defaultBlockSize,omitempty"`
	XXX_unrecognized []byte             `json:"-"`
}

func (*CreateEventProto) GetCtime added in v1.0.0

func (m *CreateEventProto) GetCtime() int64

func (*CreateEventProto) GetDefaultBlockSize added in v1.0.0

func (m *CreateEventProto) GetDefaultBlockSize() int64

func (*CreateEventProto) GetGroupName added in v1.0.0

func (m *CreateEventProto) GetGroupName() string

func (*CreateEventProto) GetOverwrite added in v1.0.0

func (m *CreateEventProto) GetOverwrite() bool

func (*CreateEventProto) GetOwnerName added in v1.0.0

func (m *CreateEventProto) GetOwnerName() string

func (*CreateEventProto) GetPath added in v1.0.0

func (m *CreateEventProto) GetPath() string

func (*CreateEventProto) GetPerms added in v1.0.0

func (m *CreateEventProto) GetPerms() *FsPermissionProto

func (*CreateEventProto) GetReplication added in v1.0.0

func (m *CreateEventProto) GetReplication() int32

func (*CreateEventProto) GetSymlinkTarget added in v1.0.0

func (m *CreateEventProto) GetSymlinkTarget() string

func (*CreateEventProto) GetType added in v1.0.0

func (m *CreateEventProto) GetType() INodeType

func (*CreateEventProto) ProtoMessage added in v1.0.0

func (*CreateEventProto) ProtoMessage()

func (*CreateEventProto) Reset added in v1.0.0

func (m *CreateEventProto) Reset()

func (*CreateEventProto) String added in v1.0.0

func (m *CreateEventProto) String() string

type CreateFlagProto

type CreateFlagProto int32
const (
	CreateFlagProto_CREATE       CreateFlagProto = 1
	CreateFlagProto_OVERWRITE    CreateFlagProto = 2
	CreateFlagProto_APPEND       CreateFlagProto = 4
	CreateFlagProto_LAZY_PERSIST CreateFlagProto = 16
	CreateFlagProto_NEW_BLOCK    CreateFlagProto = 32
)

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"`
	CryptoProtocolVersion []CryptoProtocolVersionProto `` /* 133-byte string literal not displayed */
	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) GetCryptoProtocolVersion added in v1.0.0

func (m *CreateRequestProto) GetCryptoProtocolVersion() []CryptoProtocolVersionProto

func (*CreateRequestProto) GetMasked

func (m *CreateRequestProto) GetMasked() *FsPermissionProto

func (*CreateRequestProto) GetReplication

func (m *CreateRequestProto) GetReplication() uint32

func (*CreateRequestProto) GetSrc

func (m *CreateRequestProto) GetSrc() string

func (*CreateRequestProto) ProtoMessage

func (*CreateRequestProto) ProtoMessage()

func (*CreateRequestProto) Reset

func (m *CreateRequestProto) Reset()

func (*CreateRequestProto) String

func (m *CreateRequestProto) String() string

type CreateResponseProto

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

func (*CreateResponseProto) GetFs

func (*CreateResponseProto) ProtoMessage

func (*CreateResponseProto) ProtoMessage()

func (*CreateResponseProto) Reset

func (m *CreateResponseProto) Reset()

func (*CreateResponseProto) String

func (m *CreateResponseProto) String() string

type CreateSnapshotRequestProto

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

func (*CreateSnapshotRequestProto) GetSnapshotName

func (m *CreateSnapshotRequestProto) GetSnapshotName() string

func (*CreateSnapshotRequestProto) GetSnapshotRoot

func (m *CreateSnapshotRequestProto) GetSnapshotRoot() string

func (*CreateSnapshotRequestProto) ProtoMessage

func (*CreateSnapshotRequestProto) ProtoMessage()

func (*CreateSnapshotRequestProto) Reset

func (m *CreateSnapshotRequestProto) Reset()

func (*CreateSnapshotRequestProto) String

func (m *CreateSnapshotRequestProto) String() string

type CreateSnapshotResponseProto

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

func (*CreateSnapshotResponseProto) GetSnapshotPath

func (m *CreateSnapshotResponseProto) GetSnapshotPath() string

func (*CreateSnapshotResponseProto) ProtoMessage

func (*CreateSnapshotResponseProto) ProtoMessage()

func (*CreateSnapshotResponseProto) Reset

func (m *CreateSnapshotResponseProto) Reset()

func (*CreateSnapshotResponseProto) String

func (m *CreateSnapshotResponseProto) String() string

type CreateSymlinkRequestProto

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

func (*CreateSymlinkRequestProto) GetCreateParent

func (m *CreateSymlinkRequestProto) GetCreateParent() bool

func (*CreateSymlinkRequestProto) GetDirPerm

func (m *CreateSymlinkRequestProto) GetLink() string

func (*CreateSymlinkRequestProto) GetTarget

func (m *CreateSymlinkRequestProto) GetTarget() string

func (*CreateSymlinkRequestProto) ProtoMessage

func (*CreateSymlinkRequestProto) ProtoMessage()

func (*CreateSymlinkRequestProto) Reset

func (m *CreateSymlinkRequestProto) Reset()

func (*CreateSymlinkRequestProto) String

func (m *CreateSymlinkRequestProto) String() string

type CreateSymlinkResponseProto

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

func (*CreateSymlinkResponseProto) ProtoMessage

func (*CreateSymlinkResponseProto) ProtoMessage()

func (*CreateSymlinkResponseProto) Reset

func (m *CreateSymlinkResponseProto) Reset()

func (*CreateSymlinkResponseProto) String

func (m *CreateSymlinkResponseProto) String() string

type CryptoProtocolVersionProto added in v1.0.0

type CryptoProtocolVersionProto int32

* Crypto protocol version used to access encrypted files.

const (
	CryptoProtocolVersionProto_UNKNOWN_PROTOCOL_VERSION CryptoProtocolVersionProto = 1
	CryptoProtocolVersionProto_ENCRYPTION_ZONES         CryptoProtocolVersionProto = 2
)

func (CryptoProtocolVersionProto) Enum added in v1.0.0

func (CryptoProtocolVersionProto) String added in v1.0.0

func (*CryptoProtocolVersionProto) UnmarshalJSON added in v1.0.0

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

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"`
	CipherOption     []*CipherOptionProto                                           `protobuf:"bytes,4,rep,name=cipherOption" json:"cipherOption,omitempty"`
	XXX_unrecognized []byte                                                         `json:"-"`
}

func (*DataTransferEncryptorMessageProto) GetCipherOption added in v1.0.0

func (m *DataTransferEncryptorMessageProto) GetCipherOption() []*CipherOptionProto

func (*DataTransferEncryptorMessageProto) GetMessage

func (m *DataTransferEncryptorMessageProto) GetMessage() string

func (*DataTransferEncryptorMessageProto) GetPayload

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

func (*DataTransferEncryptorMessageProto) ProtoMessage

func (*DataTransferEncryptorMessageProto) ProtoMessage()

func (*DataTransferEncryptorMessageProto) Reset

func (*DataTransferEncryptorMessageProto) String

type DataTransferEncryptorMessageProto_DataTransferEncryptorStatus

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

func (DataTransferEncryptorMessageProto_DataTransferEncryptorStatus) Enum

func (DataTransferEncryptorMessageProto_DataTransferEncryptorStatus) String

func (*DataTransferEncryptorMessageProto_DataTransferEncryptorStatus) UnmarshalJSON

type DataTransferTraceInfoProto added in v1.0.0

type DataTransferTraceInfoProto struct {
	TraceId          *uint64 `protobuf:"varint,1,req,name=traceId" json:"traceId,omitempty"`
	ParentId         *uint64 `protobuf:"varint,2,req,name=parentId" json:"parentId,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*DataTransferTraceInfoProto) GetParentId added in v1.0.0

func (m *DataTransferTraceInfoProto) GetParentId() uint64

func (*DataTransferTraceInfoProto) GetTraceId added in v1.0.0

func (m *DataTransferTraceInfoProto) GetTraceId() uint64

func (*DataTransferTraceInfoProto) ProtoMessage added in v1.0.0

func (*DataTransferTraceInfoProto) ProtoMessage()

func (*DataTransferTraceInfoProto) Reset added in v1.0.0

func (m *DataTransferTraceInfoProto) Reset()

func (*DataTransferTraceInfoProto) String added in v1.0.0

func (m *DataTransferTraceInfoProto) String() string

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 added in v1.0.0

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"`
	LastUpdateMonotonic *uint64                       `protobuf:"varint,13,opt,name=lastUpdateMonotonic,def=0" json:"lastUpdateMonotonic,omitempty"`
	UpgradeDomain       *string                       `protobuf:"bytes,14,opt,name=upgradeDomain" json:"upgradeDomain,omitempty"`
	XXX_unrecognized    []byte                        `json:"-"`
}

* The status of a Datanode

func (*DatanodeInfoProto) GetAdminState

func (*DatanodeInfoProto) GetBlockPoolUsed

func (m *DatanodeInfoProto) GetBlockPoolUsed() uint64

func (*DatanodeInfoProto) GetCacheCapacity added in v1.0.0

func (m *DatanodeInfoProto) GetCacheCapacity() uint64

func (*DatanodeInfoProto) GetCacheUsed added in v1.0.0

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) GetLastUpdateMonotonic added in v1.0.0

func (m *DatanodeInfoProto) GetLastUpdateMonotonic() uint64

func (*DatanodeInfoProto) GetLocation

func (m *DatanodeInfoProto) GetLocation() string

func (*DatanodeInfoProto) GetRemaining

func (m *DatanodeInfoProto) GetRemaining() uint64

func (*DatanodeInfoProto) GetUpgradeDomain added in v1.0.0

func (m *DatanodeInfoProto) GetUpgradeDomain() string

func (*DatanodeInfoProto) GetXceiverCount

func (m *DatanodeInfoProto) GetXceiverCount() uint32

func (*DatanodeInfoProto) ProtoMessage

func (*DatanodeInfoProto) ProtoMessage()

func (*DatanodeInfoProto) Reset

func (m *DatanodeInfoProto) Reset()

func (*DatanodeInfoProto) String

func (m *DatanodeInfoProto) String() string

type DatanodeInfoProto_AdminState

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

func (DatanodeInfoProto_AdminState) Enum

func (DatanodeInfoProto_AdminState) String

func (*DatanodeInfoProto_AdminState) UnmarshalJSON

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

type DatanodeInfosProto

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

* DatanodeInfo array

func (*DatanodeInfosProto) GetDatanodes

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

func (*DatanodeInfosProto) ProtoMessage

func (*DatanodeInfosProto) ProtoMessage()

func (*DatanodeInfosProto) Reset

func (m *DatanodeInfosProto) Reset()

func (*DatanodeInfosProto) String

func (m *DatanodeInfosProto) String() string

type DatanodeLocalInfoProto added in v1.0.0

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 added in v1.0.0

func (m *DatanodeLocalInfoProto) GetConfigVersion() string

func (*DatanodeLocalInfoProto) GetSoftwareVersion added in v1.0.0

func (m *DatanodeLocalInfoProto) GetSoftwareVersion() string

func (*DatanodeLocalInfoProto) GetUptime added in v1.0.0

func (m *DatanodeLocalInfoProto) GetUptime() uint64

func (*DatanodeLocalInfoProto) ProtoMessage added in v1.0.0

func (*DatanodeLocalInfoProto) ProtoMessage()

func (*DatanodeLocalInfoProto) Reset added in v1.0.0

func (m *DatanodeLocalInfoProto) Reset()

func (*DatanodeLocalInfoProto) String added in v1.0.0

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 (DatanodeReportTypeProto) String

func (x DatanodeReportTypeProto) String() string

func (*DatanodeReportTypeProto) UnmarshalJSON

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

type DatanodeStorageProto added in v1.0.0

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

* Represents a storage available on the datanode

func (*DatanodeStorageProto) GetState added in v1.0.0

func (*DatanodeStorageProto) GetStorageType added in v1.0.0

func (m *DatanodeStorageProto) GetStorageType() StorageTypeProto

func (*DatanodeStorageProto) GetStorageUuid added in v1.0.0

func (m *DatanodeStorageProto) GetStorageUuid() string

func (*DatanodeStorageProto) ProtoMessage added in v1.0.0

func (*DatanodeStorageProto) ProtoMessage()

func (*DatanodeStorageProto) Reset added in v1.0.0

func (m *DatanodeStorageProto) Reset()

func (*DatanodeStorageProto) String added in v1.0.0

func (m *DatanodeStorageProto) String() string

type DatanodeStorageProto_StorageState added in v1.0.0

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

func (DatanodeStorageProto_StorageState) Enum added in v1.0.0

func (DatanodeStorageProto_StorageState) String added in v1.0.0

func (*DatanodeStorageProto_StorageState) UnmarshalJSON added in v1.0.0

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

type DatanodeStorageReportProto added in v1.0.0

type DatanodeStorageReportProto struct {
	DatanodeInfo     *DatanodeInfoProto    `protobuf:"bytes,1,req,name=datanodeInfo" json:"datanodeInfo,omitempty"`
	StorageReports   []*StorageReportProto `protobuf:"bytes,2,rep,name=storageReports" json:"storageReports,omitempty"`
	XXX_unrecognized []byte                `json:"-"`
}

func (*DatanodeStorageReportProto) GetDatanodeInfo added in v1.0.0

func (m *DatanodeStorageReportProto) GetDatanodeInfo() *DatanodeInfoProto

func (*DatanodeStorageReportProto) GetStorageReports added in v1.0.0

func (m *DatanodeStorageReportProto) GetStorageReports() []*StorageReportProto

func (*DatanodeStorageReportProto) ProtoMessage added in v1.0.0

func (*DatanodeStorageReportProto) ProtoMessage()

func (*DatanodeStorageReportProto) Reset added in v1.0.0

func (m *DatanodeStorageReportProto) Reset()

func (*DatanodeStorageReportProto) String added in v1.0.0

func (m *DatanodeStorageReportProto) String() string

type DeleteBlockPoolRequestProto added in v1.0.0

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 added in v1.0.0

func (m *DeleteBlockPoolRequestProto) GetBlockPool() string

func (*DeleteBlockPoolRequestProto) GetForce added in v1.0.0

func (m *DeleteBlockPoolRequestProto) GetForce() bool

func (*DeleteBlockPoolRequestProto) ProtoMessage added in v1.0.0

func (*DeleteBlockPoolRequestProto) ProtoMessage()

func (*DeleteBlockPoolRequestProto) Reset added in v1.0.0

func (m *DeleteBlockPoolRequestProto) Reset()

func (*DeleteBlockPoolRequestProto) String added in v1.0.0

func (m *DeleteBlockPoolRequestProto) String() string

type DeleteBlockPoolResponseProto added in v1.0.0

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

* void response

func (*DeleteBlockPoolResponseProto) ProtoMessage added in v1.0.0

func (*DeleteBlockPoolResponseProto) ProtoMessage()

func (*DeleteBlockPoolResponseProto) Reset added in v1.0.0

func (m *DeleteBlockPoolResponseProto) Reset()

func (*DeleteBlockPoolResponseProto) String added in v1.0.0

type DeleteRequestProto

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

func (*DeleteRequestProto) GetRecursive

func (m *DeleteRequestProto) GetRecursive() bool

func (*DeleteRequestProto) GetSrc

func (m *DeleteRequestProto) GetSrc() string

func (*DeleteRequestProto) ProtoMessage

func (*DeleteRequestProto) ProtoMessage()

func (*DeleteRequestProto) Reset

func (m *DeleteRequestProto) Reset()

func (*DeleteRequestProto) String

func (m *DeleteRequestProto) String() string

type DeleteResponseProto

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

func (*DeleteResponseProto) GetResult

func (m *DeleteResponseProto) GetResult() bool

func (*DeleteResponseProto) ProtoMessage

func (*DeleteResponseProto) ProtoMessage()

func (*DeleteResponseProto) Reset

func (m *DeleteResponseProto) Reset()

func (*DeleteResponseProto) String

func (m *DeleteResponseProto) String() string

type DeleteSnapshotRequestProto

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

func (*DeleteSnapshotRequestProto) GetSnapshotName

func (m *DeleteSnapshotRequestProto) GetSnapshotName() string

func (*DeleteSnapshotRequestProto) GetSnapshotRoot

func (m *DeleteSnapshotRequestProto) GetSnapshotRoot() string

func (*DeleteSnapshotRequestProto) ProtoMessage

func (*DeleteSnapshotRequestProto) ProtoMessage()

func (*DeleteSnapshotRequestProto) Reset

func (m *DeleteSnapshotRequestProto) Reset()

func (*DeleteSnapshotRequestProto) String

func (m *DeleteSnapshotRequestProto) String() string

type DeleteSnapshotResponseProto

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

func (*DeleteSnapshotResponseProto) ProtoMessage

func (*DeleteSnapshotResponseProto) ProtoMessage()

func (*DeleteSnapshotResponseProto) Reset

func (m *DeleteSnapshotResponseProto) Reset()

func (*DeleteSnapshotResponseProto) String

func (m *DeleteSnapshotResponseProto) String() string

type DirectoryListingProto

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

* Directory listing

func (*DirectoryListingProto) GetPartialListing

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

func (*DirectoryListingProto) GetRemainingEntries

func (m *DirectoryListingProto) GetRemainingEntries() uint32

func (*DirectoryListingProto) ProtoMessage

func (*DirectoryListingProto) ProtoMessage()

func (*DirectoryListingProto) Reset

func (m *DirectoryListingProto) Reset()

func (*DirectoryListingProto) String

func (m *DirectoryListingProto) String() string

type DisallowSnapshotRequestProto

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

func (*DisallowSnapshotRequestProto) GetSnapshotRoot

func (m *DisallowSnapshotRequestProto) GetSnapshotRoot() string

func (*DisallowSnapshotRequestProto) ProtoMessage

func (*DisallowSnapshotRequestProto) ProtoMessage()

func (*DisallowSnapshotRequestProto) Reset

func (m *DisallowSnapshotRequestProto) Reset()

func (*DisallowSnapshotRequestProto) String

type DisallowSnapshotResponseProto

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

func (*DisallowSnapshotResponseProto) ProtoMessage

func (*DisallowSnapshotResponseProto) ProtoMessage()

func (*DisallowSnapshotResponseProto) Reset

func (m *DisallowSnapshotResponseProto) Reset()

func (*DisallowSnapshotResponseProto) String

type ECSchemaOptionEntryProto added in v1.0.0

type ECSchemaOptionEntryProto struct {
	Key              *string `protobuf:"bytes,1,req,name=key" json:"key,omitempty"`
	Value            *string `protobuf:"bytes,2,req,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* ECSchema options entry

func (*ECSchemaOptionEntryProto) GetKey added in v1.0.0

func (m *ECSchemaOptionEntryProto) GetKey() string

func (*ECSchemaOptionEntryProto) GetValue added in v1.0.0

func (m *ECSchemaOptionEntryProto) GetValue() string

func (*ECSchemaOptionEntryProto) ProtoMessage added in v1.0.0

func (*ECSchemaOptionEntryProto) ProtoMessage()

func (*ECSchemaOptionEntryProto) Reset added in v1.0.0

func (m *ECSchemaOptionEntryProto) Reset()

func (*ECSchemaOptionEntryProto) String added in v1.0.0

func (m *ECSchemaOptionEntryProto) String() string

type ECSchemaProto added in v1.0.0

type ECSchemaProto struct {
	CodecName        *string                     `protobuf:"bytes,1,req,name=codecName" json:"codecName,omitempty"`
	DataUnits        *uint32                     `protobuf:"varint,2,req,name=dataUnits" json:"dataUnits,omitempty"`
	ParityUnits      *uint32                     `protobuf:"varint,3,req,name=parityUnits" json:"parityUnits,omitempty"`
	Options          []*ECSchemaOptionEntryProto `protobuf:"bytes,4,rep,name=options" json:"options,omitempty"`
	XXX_unrecognized []byte                      `json:"-"`
}

* ECSchema for erasurecoding

func (*ECSchemaProto) GetCodecName added in v1.0.0

func (m *ECSchemaProto) GetCodecName() string

func (*ECSchemaProto) GetDataUnits added in v1.0.0

func (m *ECSchemaProto) GetDataUnits() uint32

func (*ECSchemaProto) GetOptions added in v1.0.0

func (m *ECSchemaProto) GetOptions() []*ECSchemaOptionEntryProto

func (*ECSchemaProto) GetParityUnits added in v1.0.0

func (m *ECSchemaProto) GetParityUnits() uint32

func (*ECSchemaProto) ProtoMessage added in v1.0.0

func (*ECSchemaProto) ProtoMessage()

func (*ECSchemaProto) Reset added in v1.0.0

func (m *ECSchemaProto) Reset()

func (*ECSchemaProto) String added in v1.0.0

func (m *ECSchemaProto) String() string

type EncryptionZoneProto added in v1.0.0

type EncryptionZoneProto struct {
	Id                    *int64                      `protobuf:"varint,1,req,name=id" json:"id,omitempty"`
	Path                  *string                     `protobuf:"bytes,2,req,name=path" json:"path,omitempty"`
	Suite                 *CipherSuiteProto           `protobuf:"varint,3,req,name=suite,enum=hadoop.hdfs.CipherSuiteProto" json:"suite,omitempty"`
	CryptoProtocolVersion *CryptoProtocolVersionProto `` /* 133-byte string literal not displayed */
	KeyName               *string                     `protobuf:"bytes,5,req,name=keyName" json:"keyName,omitempty"`
	XXX_unrecognized      []byte                      `json:"-"`
}

func (*EncryptionZoneProto) GetCryptoProtocolVersion added in v1.0.0

func (m *EncryptionZoneProto) GetCryptoProtocolVersion() CryptoProtocolVersionProto

func (*EncryptionZoneProto) GetId added in v1.0.0

func (m *EncryptionZoneProto) GetId() int64

func (*EncryptionZoneProto) GetKeyName added in v1.0.0

func (m *EncryptionZoneProto) GetKeyName() string

func (*EncryptionZoneProto) GetPath added in v1.0.0

func (m *EncryptionZoneProto) GetPath() string

func (*EncryptionZoneProto) GetSuite added in v1.0.0

func (m *EncryptionZoneProto) GetSuite() CipherSuiteProto

func (*EncryptionZoneProto) ProtoMessage added in v1.0.0

func (*EncryptionZoneProto) ProtoMessage()

func (*EncryptionZoneProto) Reset added in v1.0.0

func (m *EncryptionZoneProto) Reset()

func (*EncryptionZoneProto) String added in v1.0.0

func (m *EncryptionZoneProto) String() string

type ErasureCodingPolicyProto added in v1.0.0

type ErasureCodingPolicyProto struct {
	Name             *string        `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
	Schema           *ECSchemaProto `protobuf:"bytes,2,req,name=schema" json:"schema,omitempty"`
	CellSize         *uint32        `protobuf:"varint,3,req,name=cellSize" json:"cellSize,omitempty"`
	Id               *uint32        `protobuf:"varint,4,req,name=id" json:"id,omitempty"`
	XXX_unrecognized []byte         `json:"-"`
}

func (*ErasureCodingPolicyProto) GetCellSize added in v1.0.0

func (m *ErasureCodingPolicyProto) GetCellSize() uint32

func (*ErasureCodingPolicyProto) GetId added in v1.0.0

func (m *ErasureCodingPolicyProto) GetId() uint32

func (*ErasureCodingPolicyProto) GetName added in v1.0.0

func (m *ErasureCodingPolicyProto) GetName() string

func (*ErasureCodingPolicyProto) GetSchema added in v1.0.0

func (m *ErasureCodingPolicyProto) GetSchema() *ECSchemaProto

func (*ErasureCodingPolicyProto) ProtoMessage added in v1.0.0

func (*ErasureCodingPolicyProto) ProtoMessage()

func (*ErasureCodingPolicyProto) Reset added in v1.0.0

func (m *ErasureCodingPolicyProto) Reset()

func (*ErasureCodingPolicyProto) String added in v1.0.0

func (m *ErasureCodingPolicyProto) String() string

type EventBatchProto added in v1.0.0

type EventBatchProto struct {
	Txid             *int64        `protobuf:"varint,1,req,name=txid" json:"txid,omitempty"`
	Events           []*EventProto `protobuf:"bytes,2,rep,name=events" json:"events,omitempty"`
	XXX_unrecognized []byte        `json:"-"`
}

func (*EventBatchProto) GetEvents added in v1.0.0

func (m *EventBatchProto) GetEvents() []*EventProto

func (*EventBatchProto) GetTxid added in v1.0.0

func (m *EventBatchProto) GetTxid() int64

func (*EventBatchProto) ProtoMessage added in v1.0.0

func (*EventBatchProto) ProtoMessage()

func (*EventBatchProto) Reset added in v1.0.0

func (m *EventBatchProto) Reset()

func (*EventBatchProto) String added in v1.0.0

func (m *EventBatchProto) String() string

type EventProto added in v1.0.0

type EventProto struct {
	Type             *EventType `protobuf:"varint,1,req,name=type,enum=hadoop.hdfs.EventType" json:"type,omitempty"`
	Contents         []byte     `protobuf:"bytes,2,req,name=contents" json:"contents,omitempty"`
	XXX_unrecognized []byte     `json:"-"`
}

func (*EventProto) GetContents added in v1.0.0

func (m *EventProto) GetContents() []byte

func (*EventProto) GetType added in v1.0.0

func (m *EventProto) GetType() EventType

func (*EventProto) ProtoMessage added in v1.0.0

func (*EventProto) ProtoMessage()

func (*EventProto) Reset added in v1.0.0

func (m *EventProto) Reset()

func (*EventProto) String added in v1.0.0

func (m *EventProto) String() string

type EventType added in v1.0.0

type EventType int32
const (
	EventType_EVENT_CREATE   EventType = 0
	EventType_EVENT_CLOSE    EventType = 1
	EventType_EVENT_APPEND   EventType = 2
	EventType_EVENT_RENAME   EventType = 3
	EventType_EVENT_METADATA EventType = 4
	EventType_EVENT_UNLINK   EventType = 5
	EventType_EVENT_TRUNCATE EventType = 6
)

func (EventType) Enum added in v1.0.0

func (x EventType) Enum() *EventType

func (EventType) String added in v1.0.0

func (x EventType) String() string

func (*EventType) UnmarshalJSON added in v1.0.0

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

type EventsListProto added in v1.0.0

type EventsListProto struct {
	Events           []*EventProto      `protobuf:"bytes,1,rep,name=events" json:"events,omitempty"`
	FirstTxid        *int64             `protobuf:"varint,2,req,name=firstTxid" json:"firstTxid,omitempty"`
	LastTxid         *int64             `protobuf:"varint,3,req,name=lastTxid" json:"lastTxid,omitempty"`
	SyncTxid         *int64             `protobuf:"varint,4,req,name=syncTxid" json:"syncTxid,omitempty"`
	Batch            []*EventBatchProto `protobuf:"bytes,5,rep,name=batch" json:"batch,omitempty"`
	XXX_unrecognized []byte             `json:"-"`
}

func (*EventsListProto) GetBatch added in v1.0.0

func (m *EventsListProto) GetBatch() []*EventBatchProto

func (*EventsListProto) GetEvents added in v1.0.0

func (m *EventsListProto) GetEvents() []*EventProto

func (*EventsListProto) GetFirstTxid added in v1.0.0

func (m *EventsListProto) GetFirstTxid() int64

func (*EventsListProto) GetLastTxid added in v1.0.0

func (m *EventsListProto) GetLastTxid() int64

func (*EventsListProto) GetSyncTxid added in v1.0.0

func (m *EventsListProto) GetSyncTxid() int64

func (*EventsListProto) ProtoMessage added in v1.0.0

func (*EventsListProto) ProtoMessage()

func (*EventsListProto) Reset added in v1.0.0

func (m *EventsListProto) Reset()

func (*EventsListProto) String added in v1.0.0

func (m *EventsListProto) String() string

type EvictWritersRequestProto added in v1.0.0

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

* Tell datanode to evict active clients that are writing

func (*EvictWritersRequestProto) ProtoMessage added in v1.0.0

func (*EvictWritersRequestProto) ProtoMessage()

func (*EvictWritersRequestProto) Reset added in v1.0.0

func (m *EvictWritersRequestProto) Reset()

func (*EvictWritersRequestProto) String added in v1.0.0

func (m *EvictWritersRequestProto) String() string

type EvictWritersResponseProto added in v1.0.0

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

func (*EvictWritersResponseProto) ProtoMessage added in v1.0.0

func (*EvictWritersResponseProto) ProtoMessage()

func (*EvictWritersResponseProto) Reset added in v1.0.0

func (m *EvictWritersResponseProto) Reset()

func (*EvictWritersResponseProto) String added in v1.0.0

func (m *EvictWritersResponseProto) 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 FileEncryptionInfoProto added in v1.0.0

type FileEncryptionInfoProto struct {
	Suite                 *CipherSuiteProto           `protobuf:"varint,1,req,name=suite,enum=hadoop.hdfs.CipherSuiteProto" json:"suite,omitempty"`
	CryptoProtocolVersion *CryptoProtocolVersionProto `` /* 133-byte string literal not displayed */
	Key                   []byte                      `protobuf:"bytes,3,req,name=key" json:"key,omitempty"`
	Iv                    []byte                      `protobuf:"bytes,4,req,name=iv" json:"iv,omitempty"`
	KeyName               *string                     `protobuf:"bytes,5,req,name=keyName" json:"keyName,omitempty"`
	EzKeyVersionName      *string                     `protobuf:"bytes,6,req,name=ezKeyVersionName" json:"ezKeyVersionName,omitempty"`
	XXX_unrecognized      []byte                      `json:"-"`
}

* Encryption information for a file.

func (*FileEncryptionInfoProto) GetCryptoProtocolVersion added in v1.0.0

func (m *FileEncryptionInfoProto) GetCryptoProtocolVersion() CryptoProtocolVersionProto

func (*FileEncryptionInfoProto) GetEzKeyVersionName added in v1.0.0

func (m *FileEncryptionInfoProto) GetEzKeyVersionName() string

func (*FileEncryptionInfoProto) GetIv added in v1.0.0

func (m *FileEncryptionInfoProto) GetIv() []byte

func (*FileEncryptionInfoProto) GetKey added in v1.0.0

func (m *FileEncryptionInfoProto) GetKey() []byte

func (*FileEncryptionInfoProto) GetKeyName added in v1.0.0

func (m *FileEncryptionInfoProto) GetKeyName() string

func (*FileEncryptionInfoProto) GetSuite added in v1.0.0

func (*FileEncryptionInfoProto) ProtoMessage added in v1.0.0

func (*FileEncryptionInfoProto) ProtoMessage()

func (*FileEncryptionInfoProto) Reset added in v1.0.0

func (m *FileEncryptionInfoProto) Reset()

func (*FileEncryptionInfoProto) String added in v1.0.0

func (m *FileEncryptionInfoProto) String() string

type FinalizeUpgradeRequestProto

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

func (*FinalizeUpgradeRequestProto) ProtoMessage

func (*FinalizeUpgradeRequestProto) ProtoMessage()

func (*FinalizeUpgradeRequestProto) Reset

func (m *FinalizeUpgradeRequestProto) Reset()

func (*FinalizeUpgradeRequestProto) String

func (m *FinalizeUpgradeRequestProto) String() string

type FinalizeUpgradeResponseProto

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

func (*FinalizeUpgradeResponseProto) ProtoMessage

func (*FinalizeUpgradeResponseProto) ProtoMessage()

func (*FinalizeUpgradeResponseProto) Reset

func (m *FinalizeUpgradeResponseProto) Reset()

func (*FinalizeUpgradeResponseProto) String

type FsPermissionProto

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

* File or Directory permision - same spec as posix

func (*FsPermissionProto) GetPerm

func (m *FsPermissionProto) GetPerm() uint32

func (*FsPermissionProto) ProtoMessage

func (*FsPermissionProto) ProtoMessage()

func (*FsPermissionProto) Reset

func (m *FsPermissionProto) Reset()

func (*FsPermissionProto) String

func (m *FsPermissionProto) String() string

type FsServerDefaultsProto

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

* HDFS Server Defaults

func (*FsServerDefaultsProto) GetBlockSize

func (m *FsServerDefaultsProto) GetBlockSize() uint64

func (*FsServerDefaultsProto) GetBytesPerChecksum

func (m *FsServerDefaultsProto) GetBytesPerChecksum() uint32

func (*FsServerDefaultsProto) GetChecksumType

func (m *FsServerDefaultsProto) GetChecksumType() ChecksumTypeProto

func (*FsServerDefaultsProto) GetEncryptDataTransfer

func (m *FsServerDefaultsProto) GetEncryptDataTransfer() bool

func (*FsServerDefaultsProto) GetFileBufferSize

func (m *FsServerDefaultsProto) GetFileBufferSize() uint32

func (*FsServerDefaultsProto) GetReplication

func (m *FsServerDefaultsProto) GetReplication() uint32

func (*FsServerDefaultsProto) GetTrashInterval

func (m *FsServerDefaultsProto) GetTrashInterval() uint64

func (*FsServerDefaultsProto) GetWritePacketSize

func (m *FsServerDefaultsProto) GetWritePacketSize() uint32

func (*FsServerDefaultsProto) ProtoMessage

func (*FsServerDefaultsProto) ProtoMessage()

func (*FsServerDefaultsProto) Reset

func (m *FsServerDefaultsProto) Reset()

func (*FsServerDefaultsProto) String

func (m *FsServerDefaultsProto) String() string

type FsyncRequestProto

type FsyncRequestProto struct {
	Src              *string `protobuf:"bytes,1,req,name=src" json:"src,omitempty"`
	Client           *string `protobuf:"bytes,2,req,name=client" json:"client,omitempty"`
	LastBlockLength  *int64  `protobuf:"zigzag64,3,opt,name=lastBlockLength,def=-1" json:"lastBlockLength,omitempty"`
	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 added in v1.0.0

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 added in v1.0.0

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

func (*GetAclStatusRequestProto) GetSrc added in v1.0.0

func (m *GetAclStatusRequestProto) GetSrc() string

func (*GetAclStatusRequestProto) ProtoMessage added in v1.0.0

func (*GetAclStatusRequestProto) ProtoMessage()

func (*GetAclStatusRequestProto) Reset added in v1.0.0

func (m *GetAclStatusRequestProto) Reset()

func (*GetAclStatusRequestProto) String added in v1.0.0

func (m *GetAclStatusRequestProto) String() string

type GetAclStatusResponseProto added in v1.0.0

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

func (*GetAclStatusResponseProto) GetResult added in v1.0.0

func (m *GetAclStatusResponseProto) GetResult() *AclStatusProto

func (*GetAclStatusResponseProto) ProtoMessage added in v1.0.0

func (*GetAclStatusResponseProto) ProtoMessage()

func (*GetAclStatusResponseProto) Reset added in v1.0.0

func (m *GetAclStatusResponseProto) Reset()

func (*GetAclStatusResponseProto) String added in v1.0.0

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 (*GetAdditionalDatanodeRequestProto) GetClientName

func (m *GetAdditionalDatanodeRequestProto) GetClientName() string

func (*GetAdditionalDatanodeRequestProto) GetExcludes

func (*GetAdditionalDatanodeRequestProto) GetExistingStorageUuids added in v1.0.0

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

func (*GetAdditionalDatanodeRequestProto) GetExistings

func (*GetAdditionalDatanodeRequestProto) GetFileId added in v1.0.0

func (*GetAdditionalDatanodeRequestProto) GetNumAdditionalNodes

func (m *GetAdditionalDatanodeRequestProto) GetNumAdditionalNodes() uint32

func (*GetAdditionalDatanodeRequestProto) GetSrc

func (*GetAdditionalDatanodeRequestProto) ProtoMessage

func (*GetAdditionalDatanodeRequestProto) ProtoMessage()

func (*GetAdditionalDatanodeRequestProto) Reset

func (*GetAdditionalDatanodeRequestProto) String

type GetAdditionalDatanodeResponseProto

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

func (*GetAdditionalDatanodeResponseProto) GetBlock

func (*GetAdditionalDatanodeResponseProto) ProtoMessage

func (*GetAdditionalDatanodeResponseProto) ProtoMessage()

func (*GetAdditionalDatanodeResponseProto) Reset

func (*GetAdditionalDatanodeResponseProto) String

type GetBalancerBandwidthRequestProto added in v1.0.0

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

func (*GetBalancerBandwidthRequestProto) ProtoMessage added in v1.0.0

func (*GetBalancerBandwidthRequestProto) ProtoMessage()

func (*GetBalancerBandwidthRequestProto) Reset added in v1.0.0

func (*GetBalancerBandwidthRequestProto) String added in v1.0.0

type GetBalancerBandwidthResponseProto added in v1.0.0

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

* bandwidth - balancer bandwidth value of the datanode.

func (*GetBalancerBandwidthResponseProto) GetBandwidth added in v1.0.0

func (m *GetBalancerBandwidthResponseProto) GetBandwidth() uint64

func (*GetBalancerBandwidthResponseProto) ProtoMessage added in v1.0.0

func (*GetBalancerBandwidthResponseProto) ProtoMessage()

func (*GetBalancerBandwidthResponseProto) Reset added in v1.0.0

func (*GetBalancerBandwidthResponseProto) String added in v1.0.0

type GetBlockLocalPathInfoRequestProto added in v1.0.0

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 added in v1.0.0

func (*GetBlockLocalPathInfoRequestProto) GetToken added in v1.0.0

func (*GetBlockLocalPathInfoRequestProto) ProtoMessage added in v1.0.0

func (*GetBlockLocalPathInfoRequestProto) ProtoMessage()

func (*GetBlockLocalPathInfoRequestProto) Reset added in v1.0.0

func (*GetBlockLocalPathInfoRequestProto) String added in v1.0.0

type GetBlockLocalPathInfoResponseProto added in v1.0.0

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 added in v1.0.0

func (*GetBlockLocalPathInfoResponseProto) GetLocalMetaPath added in v1.0.0

func (m *GetBlockLocalPathInfoResponseProto) GetLocalMetaPath() string

func (*GetBlockLocalPathInfoResponseProto) GetLocalPath added in v1.0.0

func (m *GetBlockLocalPathInfoResponseProto) GetLocalPath() string

func (*GetBlockLocalPathInfoResponseProto) ProtoMessage added in v1.0.0

func (*GetBlockLocalPathInfoResponseProto) ProtoMessage()

func (*GetBlockLocalPathInfoResponseProto) Reset added in v1.0.0

func (*GetBlockLocalPathInfoResponseProto) String added in v1.0.0

type GetBlockLocationsRequestProto

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

func (*GetBlockLocationsRequestProto) GetLength

func (m *GetBlockLocationsRequestProto) GetLength() uint64

func (*GetBlockLocationsRequestProto) GetOffset

func (m *GetBlockLocationsRequestProto) GetOffset() uint64

func (*GetBlockLocationsRequestProto) GetSrc

func (*GetBlockLocationsRequestProto) ProtoMessage

func (*GetBlockLocationsRequestProto) ProtoMessage()

func (*GetBlockLocationsRequestProto) Reset

func (m *GetBlockLocationsRequestProto) Reset()

func (*GetBlockLocationsRequestProto) String

type GetBlockLocationsResponseProto

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

func (*GetBlockLocationsResponseProto) GetLocations

func (*GetBlockLocationsResponseProto) ProtoMessage

func (*GetBlockLocationsResponseProto) ProtoMessage()

func (*GetBlockLocationsResponseProto) Reset

func (m *GetBlockLocationsResponseProto) Reset()

func (*GetBlockLocationsResponseProto) String

type GetContentSummaryRequestProto

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

func (*GetContentSummaryRequestProto) GetPath

func (*GetContentSummaryRequestProto) ProtoMessage

func (*GetContentSummaryRequestProto) ProtoMessage()

func (*GetContentSummaryRequestProto) Reset

func (m *GetContentSummaryRequestProto) Reset()

func (*GetContentSummaryRequestProto) String

type GetContentSummaryResponseProto

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

func (*GetContentSummaryResponseProto) GetSummary

func (*GetContentSummaryResponseProto) ProtoMessage

func (*GetContentSummaryResponseProto) ProtoMessage()

func (*GetContentSummaryResponseProto) Reset

func (m *GetContentSummaryResponseProto) Reset()

func (*GetContentSummaryResponseProto) String

type GetCurrentEditLogTxidRequestProto added in v1.0.0

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

func (*GetCurrentEditLogTxidRequestProto) ProtoMessage added in v1.0.0

func (*GetCurrentEditLogTxidRequestProto) ProtoMessage()

func (*GetCurrentEditLogTxidRequestProto) Reset added in v1.0.0

func (*GetCurrentEditLogTxidRequestProto) String added in v1.0.0

type GetCurrentEditLogTxidResponseProto added in v1.0.0

type GetCurrentEditLogTxidResponseProto struct {
	Txid             *int64 `protobuf:"varint,1,req,name=txid" json:"txid,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*GetCurrentEditLogTxidResponseProto) GetTxid added in v1.0.0

func (*GetCurrentEditLogTxidResponseProto) ProtoMessage added in v1.0.0

func (*GetCurrentEditLogTxidResponseProto) ProtoMessage()

func (*GetCurrentEditLogTxidResponseProto) Reset added in v1.0.0

func (*GetCurrentEditLogTxidResponseProto) String added in v1.0.0

type GetDataEncryptionKeyRequestProto

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

func (*GetDataEncryptionKeyRequestProto) ProtoMessage

func (*GetDataEncryptionKeyRequestProto) ProtoMessage()

func (*GetDataEncryptionKeyRequestProto) Reset

func (*GetDataEncryptionKeyRequestProto) String

type GetDataEncryptionKeyResponseProto

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

func (*GetDataEncryptionKeyResponseProto) GetDataEncryptionKey

func (m *GetDataEncryptionKeyResponseProto) GetDataEncryptionKey() *DataEncryptionKeyProto

func (*GetDataEncryptionKeyResponseProto) ProtoMessage

func (*GetDataEncryptionKeyResponseProto) ProtoMessage()

func (*GetDataEncryptionKeyResponseProto) Reset

func (*GetDataEncryptionKeyResponseProto) String

type GetDatanodeInfoRequestProto added in v1.0.0

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

* Ping datanode for liveness and quick info

func (*GetDatanodeInfoRequestProto) ProtoMessage added in v1.0.0

func (*GetDatanodeInfoRequestProto) ProtoMessage()

func (*GetDatanodeInfoRequestProto) Reset added in v1.0.0

func (m *GetDatanodeInfoRequestProto) Reset()

func (*GetDatanodeInfoRequestProto) String added in v1.0.0

func (m *GetDatanodeInfoRequestProto) String() string

type GetDatanodeInfoResponseProto added in v1.0.0

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

func (*GetDatanodeInfoResponseProto) GetLocalInfo added in v1.0.0

func (*GetDatanodeInfoResponseProto) ProtoMessage added in v1.0.0

func (*GetDatanodeInfoResponseProto) ProtoMessage()

func (*GetDatanodeInfoResponseProto) Reset added in v1.0.0

func (m *GetDatanodeInfoResponseProto) Reset()

func (*GetDatanodeInfoResponseProto) String added in v1.0.0

type GetDatanodeReportRequestProto

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

func (*GetDatanodeReportRequestProto) GetType

func (*GetDatanodeReportRequestProto) ProtoMessage

func (*GetDatanodeReportRequestProto) ProtoMessage()

func (*GetDatanodeReportRequestProto) Reset

func (m *GetDatanodeReportRequestProto) Reset()

func (*GetDatanodeReportRequestProto) String

type GetDatanodeReportResponseProto

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

func (*GetDatanodeReportResponseProto) GetDi

func (*GetDatanodeReportResponseProto) ProtoMessage

func (*GetDatanodeReportResponseProto) ProtoMessage()

func (*GetDatanodeReportResponseProto) Reset

func (m *GetDatanodeReportResponseProto) Reset()

func (*GetDatanodeReportResponseProto) String

type GetDatanodeStorageReportRequestProto added in v1.0.0

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

func (*GetDatanodeStorageReportRequestProto) GetType added in v1.0.0

func (*GetDatanodeStorageReportRequestProto) ProtoMessage added in v1.0.0

func (*GetDatanodeStorageReportRequestProto) ProtoMessage()

func (*GetDatanodeStorageReportRequestProto) Reset added in v1.0.0

func (*GetDatanodeStorageReportRequestProto) String added in v1.0.0

type GetDatanodeStorageReportResponseProto added in v1.0.0

type GetDatanodeStorageReportResponseProto struct {
	DatanodeStorageReports []*DatanodeStorageReportProto `protobuf:"bytes,1,rep,name=datanodeStorageReports" json:"datanodeStorageReports,omitempty"`
	XXX_unrecognized       []byte                        `json:"-"`
}

func (*GetDatanodeStorageReportResponseProto) GetDatanodeStorageReports added in v1.0.0

func (m *GetDatanodeStorageReportResponseProto) GetDatanodeStorageReports() []*DatanodeStorageReportProto

func (*GetDatanodeStorageReportResponseProto) ProtoMessage added in v1.0.0

func (*GetDatanodeStorageReportResponseProto) ProtoMessage()

func (*GetDatanodeStorageReportResponseProto) Reset added in v1.0.0

func (*GetDatanodeStorageReportResponseProto) String added in v1.0.0

type GetEZForPathRequestProto added in v1.0.0

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

func (*GetEZForPathRequestProto) GetSrc added in v1.0.0

func (m *GetEZForPathRequestProto) GetSrc() string

func (*GetEZForPathRequestProto) ProtoMessage added in v1.0.0

func (*GetEZForPathRequestProto) ProtoMessage()

func (*GetEZForPathRequestProto) Reset added in v1.0.0

func (m *GetEZForPathRequestProto) Reset()

func (*GetEZForPathRequestProto) String added in v1.0.0

func (m *GetEZForPathRequestProto) String() string

type GetEZForPathResponseProto added in v1.0.0

type GetEZForPathResponseProto struct {
	Zone             *EncryptionZoneProto `protobuf:"bytes,1,opt,name=zone" json:"zone,omitempty"`
	XXX_unrecognized []byte               `json:"-"`
}

func (*GetEZForPathResponseProto) GetZone added in v1.0.0

func (*GetEZForPathResponseProto) ProtoMessage added in v1.0.0

func (*GetEZForPathResponseProto) ProtoMessage()

func (*GetEZForPathResponseProto) Reset added in v1.0.0

func (m *GetEZForPathResponseProto) Reset()

func (*GetEZForPathResponseProto) String added in v1.0.0

func (m *GetEZForPathResponseProto) String() string

type GetEditsFromTxidRequestProto added in v1.0.0

type GetEditsFromTxidRequestProto struct {
	Txid             *int64 `protobuf:"varint,1,req,name=txid" json:"txid,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*GetEditsFromTxidRequestProto) GetTxid added in v1.0.0

func (m *GetEditsFromTxidRequestProto) GetTxid() int64

func (*GetEditsFromTxidRequestProto) ProtoMessage added in v1.0.0

func (*GetEditsFromTxidRequestProto) ProtoMessage()

func (*GetEditsFromTxidRequestProto) Reset added in v1.0.0

func (m *GetEditsFromTxidRequestProto) Reset()

func (*GetEditsFromTxidRequestProto) String added in v1.0.0

type GetEditsFromTxidResponseProto added in v1.0.0

type GetEditsFromTxidResponseProto struct {
	EventsList       *EventsListProto `protobuf:"bytes,1,req,name=eventsList" json:"eventsList,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

func (*GetEditsFromTxidResponseProto) GetEventsList added in v1.0.0

func (m *GetEditsFromTxidResponseProto) GetEventsList() *EventsListProto

func (*GetEditsFromTxidResponseProto) ProtoMessage added in v1.0.0

func (*GetEditsFromTxidResponseProto) ProtoMessage()

func (*GetEditsFromTxidResponseProto) Reset added in v1.0.0

func (m *GetEditsFromTxidResponseProto) Reset()

func (*GetEditsFromTxidResponseProto) String added in v1.0.0

type GetErasureCodingPoliciesRequestProto added in v1.0.0

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

func (*GetErasureCodingPoliciesRequestProto) ProtoMessage added in v1.0.0

func (*GetErasureCodingPoliciesRequestProto) ProtoMessage()

func (*GetErasureCodingPoliciesRequestProto) Reset added in v1.0.0

func (*GetErasureCodingPoliciesRequestProto) String added in v1.0.0

type GetErasureCodingPoliciesResponseProto added in v1.0.0

type GetErasureCodingPoliciesResponseProto struct {
	EcPolicies       []*ErasureCodingPolicyProto `protobuf:"bytes,1,rep,name=ecPolicies" json:"ecPolicies,omitempty"`
	XXX_unrecognized []byte                      `json:"-"`
}

func (*GetErasureCodingPoliciesResponseProto) GetEcPolicies added in v1.0.0

func (*GetErasureCodingPoliciesResponseProto) ProtoMessage added in v1.0.0

func (*GetErasureCodingPoliciesResponseProto) ProtoMessage()

func (*GetErasureCodingPoliciesResponseProto) Reset added in v1.0.0

func (*GetErasureCodingPoliciesResponseProto) String added in v1.0.0

type GetErasureCodingPolicyRequestProto added in v1.0.0

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

func (*GetErasureCodingPolicyRequestProto) GetSrc added in v1.0.0

func (*GetErasureCodingPolicyRequestProto) ProtoMessage added in v1.0.0

func (*GetErasureCodingPolicyRequestProto) ProtoMessage()

func (*GetErasureCodingPolicyRequestProto) Reset added in v1.0.0

func (*GetErasureCodingPolicyRequestProto) String added in v1.0.0

type GetErasureCodingPolicyResponseProto added in v1.0.0

type GetErasureCodingPolicyResponseProto struct {
	EcPolicy         *ErasureCodingPolicyProto `protobuf:"bytes,1,opt,name=ecPolicy" json:"ecPolicy,omitempty"`
	XXX_unrecognized []byte                    `json:"-"`
}

func (*GetErasureCodingPolicyResponseProto) GetEcPolicy added in v1.0.0

func (*GetErasureCodingPolicyResponseProto) ProtoMessage added in v1.0.0

func (*GetErasureCodingPolicyResponseProto) ProtoMessage()

func (*GetErasureCodingPolicyResponseProto) Reset added in v1.0.0

func (*GetErasureCodingPolicyResponseProto) String added in v1.0.0

type GetFileInfoRequestProto

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

func (*GetFileInfoRequestProto) GetSrc

func (m *GetFileInfoRequestProto) GetSrc() string

func (*GetFileInfoRequestProto) ProtoMessage

func (*GetFileInfoRequestProto) ProtoMessage()

func (*GetFileInfoRequestProto) Reset

func (m *GetFileInfoRequestProto) Reset()

func (*GetFileInfoRequestProto) String

func (m *GetFileInfoRequestProto) String() string

type GetFileInfoResponseProto

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

func (*GetFileInfoResponseProto) GetFs

func (*GetFileInfoResponseProto) ProtoMessage

func (*GetFileInfoResponseProto) ProtoMessage()

func (*GetFileInfoResponseProto) Reset

func (m *GetFileInfoResponseProto) Reset()

func (*GetFileInfoResponseProto) String

func (m *GetFileInfoResponseProto) String() string

type GetFileLinkInfoRequestProto

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

func (*GetFileLinkInfoRequestProto) GetSrc

func (m *GetFileLinkInfoRequestProto) GetSrc() string

func (*GetFileLinkInfoRequestProto) ProtoMessage

func (*GetFileLinkInfoRequestProto) ProtoMessage()

func (*GetFileLinkInfoRequestProto) Reset

func (m *GetFileLinkInfoRequestProto) Reset()

func (*GetFileLinkInfoRequestProto) String

func (m *GetFileLinkInfoRequestProto) String() string

type GetFileLinkInfoResponseProto

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

func (*GetFileLinkInfoResponseProto) GetFs

func (*GetFileLinkInfoResponseProto) ProtoMessage

func (*GetFileLinkInfoResponseProto) ProtoMessage()

func (*GetFileLinkInfoResponseProto) Reset

func (m *GetFileLinkInfoResponseProto) Reset()

func (*GetFileLinkInfoResponseProto) String

type GetFsStatsResponseProto

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

func (*GetFsStatsResponseProto) GetBlocksInFuture added in v1.0.0

func (m *GetFsStatsResponseProto) GetBlocksInFuture() uint64

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) GetMissingReplOneBlocks added in v1.0.0

func (m *GetFsStatsResponseProto) GetMissingReplOneBlocks() uint64

func (*GetFsStatsResponseProto) GetPendingDeletionBlocks added in v1.0.0

func (m *GetFsStatsResponseProto) GetPendingDeletionBlocks() uint64

func (*GetFsStatsResponseProto) GetRemaining

func (m *GetFsStatsResponseProto) GetRemaining() uint64

func (*GetFsStatsResponseProto) GetUnderReplicated

func (m *GetFsStatsResponseProto) GetUnderReplicated() uint64

func (*GetFsStatsResponseProto) GetUsed

func (m *GetFsStatsResponseProto) GetUsed() uint64

func (*GetFsStatsResponseProto) ProtoMessage

func (*GetFsStatsResponseProto) ProtoMessage()

func (*GetFsStatsResponseProto) Reset

func (m *GetFsStatsResponseProto) Reset()

func (*GetFsStatsResponseProto) String

func (m *GetFsStatsResponseProto) String() string

type GetFsStatusRequestProto

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

func (*GetFsStatusRequestProto) ProtoMessage

func (*GetFsStatusRequestProto) ProtoMessage()

func (*GetFsStatusRequestProto) Reset

func (m *GetFsStatusRequestProto) Reset()

func (*GetFsStatusRequestProto) String

func (m *GetFsStatusRequestProto) String() string

type GetLinkTargetRequestProto

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

func (*GetLinkTargetRequestProto) GetPath

func (m *GetLinkTargetRequestProto) GetPath() string

func (*GetLinkTargetRequestProto) ProtoMessage

func (*GetLinkTargetRequestProto) ProtoMessage()

func (*GetLinkTargetRequestProto) Reset

func (m *GetLinkTargetRequestProto) Reset()

func (*GetLinkTargetRequestProto) String

func (m *GetLinkTargetRequestProto) String() string

type GetLinkTargetResponseProto

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

func (*GetLinkTargetResponseProto) GetTargetPath

func (m *GetLinkTargetResponseProto) GetTargetPath() string

func (*GetLinkTargetResponseProto) ProtoMessage

func (*GetLinkTargetResponseProto) ProtoMessage()

func (*GetLinkTargetResponseProto) Reset

func (m *GetLinkTargetResponseProto) Reset()

func (*GetLinkTargetResponseProto) String

func (m *GetLinkTargetResponseProto) String() string

type GetListingRequestProto

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

func (*GetListingRequestProto) GetNeedLocation

func (m *GetListingRequestProto) GetNeedLocation() bool

func (*GetListingRequestProto) GetSrc

func (m *GetListingRequestProto) GetSrc() string

func (*GetListingRequestProto) GetStartAfter

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

func (*GetListingRequestProto) ProtoMessage

func (*GetListingRequestProto) ProtoMessage()

func (*GetListingRequestProto) Reset

func (m *GetListingRequestProto) Reset()

func (*GetListingRequestProto) String

func (m *GetListingRequestProto) String() string

type GetListingResponseProto

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

func (*GetListingResponseProto) GetDirList

func (*GetListingResponseProto) ProtoMessage

func (*GetListingResponseProto) ProtoMessage()

func (*GetListingResponseProto) Reset

func (m *GetListingResponseProto) Reset()

func (*GetListingResponseProto) String

func (m *GetListingResponseProto) String() string

type GetPreferredBlockSizeRequestProto

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

func (*GetPreferredBlockSizeRequestProto) GetFilename

func (m *GetPreferredBlockSizeRequestProto) GetFilename() string

func (*GetPreferredBlockSizeRequestProto) ProtoMessage

func (*GetPreferredBlockSizeRequestProto) ProtoMessage()

func (*GetPreferredBlockSizeRequestProto) Reset

func (*GetPreferredBlockSizeRequestProto) String

type GetPreferredBlockSizeResponseProto

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

func (*GetPreferredBlockSizeResponseProto) GetBsize

func (*GetPreferredBlockSizeResponseProto) ProtoMessage

func (*GetPreferredBlockSizeResponseProto) ProtoMessage()

func (*GetPreferredBlockSizeResponseProto) Reset

func (*GetPreferredBlockSizeResponseProto) String

type GetQuotaUsageRequestProto added in v1.0.0

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

func (*GetQuotaUsageRequestProto) GetPath added in v1.0.0

func (m *GetQuotaUsageRequestProto) GetPath() string

func (*GetQuotaUsageRequestProto) ProtoMessage added in v1.0.0

func (*GetQuotaUsageRequestProto) ProtoMessage()

func (*GetQuotaUsageRequestProto) Reset added in v1.0.0

func (m *GetQuotaUsageRequestProto) Reset()

func (*GetQuotaUsageRequestProto) String added in v1.0.0

func (m *GetQuotaUsageRequestProto) String() string

type GetQuotaUsageResponseProto added in v1.0.0

type GetQuotaUsageResponseProto struct {
	Usage            *QuotaUsageProto `protobuf:"bytes,1,req,name=usage" json:"usage,omitempty"`
	XXX_unrecognized []byte           `json:"-"`
}

func (*GetQuotaUsageResponseProto) GetUsage added in v1.0.0

func (*GetQuotaUsageResponseProto) ProtoMessage added in v1.0.0

func (*GetQuotaUsageResponseProto) ProtoMessage()

func (*GetQuotaUsageResponseProto) Reset added in v1.0.0

func (m *GetQuotaUsageResponseProto) Reset()

func (*GetQuotaUsageResponseProto) String added in v1.0.0

func (m *GetQuotaUsageResponseProto) String() string

type GetReconfigurationStatusConfigChangeProto added in v1.0.0

type GetReconfigurationStatusConfigChangeProto struct {
	Name             *string `protobuf:"bytes,1,req,name=name" json:"name,omitempty"`
	OldValue         *string `protobuf:"bytes,2,req,name=oldValue" json:"oldValue,omitempty"`
	NewValue         *string `protobuf:"bytes,3,opt,name=newValue" json:"newValue,omitempty"`
	ErrorMessage     *string `protobuf:"bytes,4,opt,name=errorMessage" json:"errorMessage,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*GetReconfigurationStatusConfigChangeProto) GetErrorMessage added in v1.0.0

func (*GetReconfigurationStatusConfigChangeProto) GetName added in v1.0.0

func (*GetReconfigurationStatusConfigChangeProto) GetNewValue added in v1.0.0

func (*GetReconfigurationStatusConfigChangeProto) GetOldValue added in v1.0.0

func (*GetReconfigurationStatusConfigChangeProto) ProtoMessage added in v1.0.0

func (*GetReconfigurationStatusConfigChangeProto) Reset added in v1.0.0

func (*GetReconfigurationStatusConfigChangeProto) String added in v1.0.0

type GetReconfigurationStatusRequestProto added in v1.0.0

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

* Query the running status of reconfiguration process

func (*GetReconfigurationStatusRequestProto) ProtoMessage added in v1.0.0

func (*GetReconfigurationStatusRequestProto) ProtoMessage()

func (*GetReconfigurationStatusRequestProto) Reset added in v1.0.0

func (*GetReconfigurationStatusRequestProto) String added in v1.0.0

type GetReconfigurationStatusResponseProto added in v1.0.0

type GetReconfigurationStatusResponseProto struct {
	StartTime        *int64                                       `protobuf:"varint,1,req,name=startTime" json:"startTime,omitempty"`
	EndTime          *int64                                       `protobuf:"varint,2,opt,name=endTime" json:"endTime,omitempty"`
	Changes          []*GetReconfigurationStatusConfigChangeProto `protobuf:"bytes,3,rep,name=changes" json:"changes,omitempty"`
	XXX_unrecognized []byte                                       `json:"-"`
}

func (*GetReconfigurationStatusResponseProto) GetChanges added in v1.0.0

func (*GetReconfigurationStatusResponseProto) GetEndTime added in v1.0.0

func (*GetReconfigurationStatusResponseProto) GetStartTime added in v1.0.0

func (m *GetReconfigurationStatusResponseProto) GetStartTime() int64

func (*GetReconfigurationStatusResponseProto) ProtoMessage added in v1.0.0

func (*GetReconfigurationStatusResponseProto) ProtoMessage()

func (*GetReconfigurationStatusResponseProto) Reset added in v1.0.0

func (*GetReconfigurationStatusResponseProto) String added in v1.0.0

type GetReplicaVisibleLengthRequestProto added in v1.0.0

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 added in v1.0.0

func (*GetReplicaVisibleLengthRequestProto) ProtoMessage added in v1.0.0

func (*GetReplicaVisibleLengthRequestProto) ProtoMessage()

func (*GetReplicaVisibleLengthRequestProto) Reset added in v1.0.0

func (*GetReplicaVisibleLengthRequestProto) String added in v1.0.0

type GetReplicaVisibleLengthResponseProto added in v1.0.0

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 added in v1.0.0

func (*GetReplicaVisibleLengthResponseProto) ProtoMessage added in v1.0.0

func (*GetReplicaVisibleLengthResponseProto) ProtoMessage()

func (*GetReplicaVisibleLengthResponseProto) Reset added in v1.0.0

func (*GetReplicaVisibleLengthResponseProto) String added in v1.0.0

type GetServerDefaultsRequestProto

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

func (*GetServerDefaultsRequestProto) ProtoMessage

func (*GetServerDefaultsRequestProto) ProtoMessage()

func (*GetServerDefaultsRequestProto) Reset

func (m *GetServerDefaultsRequestProto) Reset()

func (*GetServerDefaultsRequestProto) String

type GetServerDefaultsResponseProto

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

func (*GetServerDefaultsResponseProto) GetServerDefaults

func (m *GetServerDefaultsResponseProto) GetServerDefaults() *FsServerDefaultsProto

func (*GetServerDefaultsResponseProto) ProtoMessage

func (*GetServerDefaultsResponseProto) ProtoMessage()

func (*GetServerDefaultsResponseProto) Reset

func (m *GetServerDefaultsResponseProto) Reset()

func (*GetServerDefaultsResponseProto) String

type GetSnapshotDiffReportRequestProto

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

func (*GetSnapshotDiffReportRequestProto) GetFromSnapshot

func (m *GetSnapshotDiffReportRequestProto) GetFromSnapshot() string

func (*GetSnapshotDiffReportRequestProto) GetSnapshotRoot

func (m *GetSnapshotDiffReportRequestProto) GetSnapshotRoot() string

func (*GetSnapshotDiffReportRequestProto) GetToSnapshot

func (m *GetSnapshotDiffReportRequestProto) GetToSnapshot() string

func (*GetSnapshotDiffReportRequestProto) ProtoMessage

func (*GetSnapshotDiffReportRequestProto) ProtoMessage()

func (*GetSnapshotDiffReportRequestProto) Reset

func (*GetSnapshotDiffReportRequestProto) String

type GetSnapshotDiffReportResponseProto

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

func (*GetSnapshotDiffReportResponseProto) GetDiffReport

func (*GetSnapshotDiffReportResponseProto) ProtoMessage

func (*GetSnapshotDiffReportResponseProto) ProtoMessage()

func (*GetSnapshotDiffReportResponseProto) Reset

func (*GetSnapshotDiffReportResponseProto) String

type GetSnapshottableDirListingRequestProto

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

func (*GetSnapshottableDirListingRequestProto) ProtoMessage

func (*GetSnapshottableDirListingRequestProto) Reset

func (*GetSnapshottableDirListingRequestProto) String

type GetSnapshottableDirListingResponseProto

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

func (*GetSnapshottableDirListingResponseProto) GetSnapshottableDirList

func (*GetSnapshottableDirListingResponseProto) ProtoMessage

func (*GetSnapshottableDirListingResponseProto) Reset

func (*GetSnapshottableDirListingResponseProto) String

type GetStoragePoliciesRequestProto added in v1.0.0

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

func (*GetStoragePoliciesRequestProto) ProtoMessage added in v1.0.0

func (*GetStoragePoliciesRequestProto) ProtoMessage()

func (*GetStoragePoliciesRequestProto) Reset added in v1.0.0

func (m *GetStoragePoliciesRequestProto) Reset()

func (*GetStoragePoliciesRequestProto) String added in v1.0.0

type GetStoragePoliciesResponseProto added in v1.0.0

type GetStoragePoliciesResponseProto struct {
	Policies         []*BlockStoragePolicyProto `protobuf:"bytes,1,rep,name=policies" json:"policies,omitempty"`
	XXX_unrecognized []byte                     `json:"-"`
}

func (*GetStoragePoliciesResponseProto) GetPolicies added in v1.0.0

func (*GetStoragePoliciesResponseProto) ProtoMessage added in v1.0.0

func (*GetStoragePoliciesResponseProto) ProtoMessage()

func (*GetStoragePoliciesResponseProto) Reset added in v1.0.0

func (*GetStoragePoliciesResponseProto) String added in v1.0.0

type GetStoragePolicyRequestProto added in v1.0.0

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

func (*GetStoragePolicyRequestProto) GetPath added in v1.0.0

func (m *GetStoragePolicyRequestProto) GetPath() string

func (*GetStoragePolicyRequestProto) ProtoMessage added in v1.0.0

func (*GetStoragePolicyRequestProto) ProtoMessage()

func (*GetStoragePolicyRequestProto) Reset added in v1.0.0

func (m *GetStoragePolicyRequestProto) Reset()

func (*GetStoragePolicyRequestProto) String added in v1.0.0

type GetStoragePolicyResponseProto added in v1.0.0

type GetStoragePolicyResponseProto struct {
	StoragePolicy    *BlockStoragePolicyProto `protobuf:"bytes,1,req,name=storagePolicy" json:"storagePolicy,omitempty"`
	XXX_unrecognized []byte                   `json:"-"`
}

func (*GetStoragePolicyResponseProto) GetStoragePolicy added in v1.0.0

func (*GetStoragePolicyResponseProto) ProtoMessage added in v1.0.0

func (*GetStoragePolicyResponseProto) ProtoMessage()

func (*GetStoragePolicyResponseProto) Reset added in v1.0.0

func (m *GetStoragePolicyResponseProto) Reset()

func (*GetStoragePolicyResponseProto) String added in v1.0.0

type GetXAttrsRequestProto added in v1.0.0

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 added in v1.0.0

func (m *GetXAttrsRequestProto) GetSrc() string

func (*GetXAttrsRequestProto) GetXAttrs added in v1.0.0

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

func (*GetXAttrsRequestProto) ProtoMessage added in v1.0.0

func (*GetXAttrsRequestProto) ProtoMessage()

func (*GetXAttrsRequestProto) Reset added in v1.0.0

func (m *GetXAttrsRequestProto) Reset()

func (*GetXAttrsRequestProto) String added in v1.0.0

func (m *GetXAttrsRequestProto) String() string

type GetXAttrsResponseProto added in v1.0.0

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

func (*GetXAttrsResponseProto) GetXAttrs added in v1.0.0

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

func (*GetXAttrsResponseProto) ProtoMessage added in v1.0.0

func (*GetXAttrsResponseProto) ProtoMessage()

func (*GetXAttrsResponseProto) Reset added in v1.0.0

func (m *GetXAttrsResponseProto) Reset()

func (*GetXAttrsResponseProto) String added in v1.0.0

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"`
	// Optional field for file encryption
	FileEncryptionInfo *FileEncryptionInfoProto `protobuf:"bytes,15,opt,name=fileEncryptionInfo" json:"fileEncryptionInfo,omitempty"`
	StoragePolicy      *uint32                  `protobuf:"varint,16,opt,name=storagePolicy,def=0" json:"storagePolicy,omitempty"`
	// Optional field for erasure coding
	EcPolicy         *ErasureCodingPolicyProto `protobuf:"bytes,17,opt,name=ecPolicy" json:"ecPolicy,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) GetEcPolicy added in v1.0.0

func (*HdfsFileStatusProto) GetFileEncryptionInfo added in v1.0.0

func (m *HdfsFileStatusProto) GetFileEncryptionInfo() *FileEncryptionInfoProto

func (*HdfsFileStatusProto) GetFileId

func (m *HdfsFileStatusProto) GetFileId() uint64

func (*HdfsFileStatusProto) GetFileType

func (*HdfsFileStatusProto) GetGroup

func (m *HdfsFileStatusProto) GetGroup() string

func (*HdfsFileStatusProto) GetLength

func (m *HdfsFileStatusProto) GetLength() uint64

func (*HdfsFileStatusProto) GetLocations

func (m *HdfsFileStatusProto) GetLocations() *LocatedBlocksProto

func (*HdfsFileStatusProto) GetModificationTime

func (m *HdfsFileStatusProto) GetModificationTime() uint64

func (*HdfsFileStatusProto) GetOwner

func (m *HdfsFileStatusProto) GetOwner() string

func (*HdfsFileStatusProto) GetPath

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

func (*HdfsFileStatusProto) GetPermission

func (m *HdfsFileStatusProto) GetPermission() *FsPermissionProto

func (*HdfsFileStatusProto) GetStoragePolicy added in v1.0.0

func (m *HdfsFileStatusProto) GetStoragePolicy() uint32
func (m *HdfsFileStatusProto) GetSymlink() []byte

func (*HdfsFileStatusProto) ProtoMessage

func (*HdfsFileStatusProto) ProtoMessage()

func (*HdfsFileStatusProto) Reset

func (m *HdfsFileStatusProto) Reset()

func (*HdfsFileStatusProto) String

func (m *HdfsFileStatusProto) String() string

type HdfsFileStatusProto_FileType

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

func (HdfsFileStatusProto_FileType) Enum

func (HdfsFileStatusProto_FileType) String

func (*HdfsFileStatusProto_FileType) UnmarshalJSON

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

type INodeType added in v1.0.0

type INodeType int32
const (
	INodeType_I_TYPE_FILE      INodeType = 0
	INodeType_I_TYPE_DIRECTORY INodeType = 1
	INodeType_I_TYPE_SYMLINK   INodeType = 2
)

func (INodeType) Enum added in v1.0.0

func (x INodeType) Enum() *INodeType

func (INodeType) String added in v1.0.0

func (x INodeType) String() string

func (*INodeType) UnmarshalJSON added in v1.0.0

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

type IsFileClosedRequestProto

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

func (*IsFileClosedRequestProto) GetSrc

func (m *IsFileClosedRequestProto) GetSrc() string

func (*IsFileClosedRequestProto) ProtoMessage

func (*IsFileClosedRequestProto) ProtoMessage()

func (*IsFileClosedRequestProto) Reset

func (m *IsFileClosedRequestProto) Reset()

func (*IsFileClosedRequestProto) String

func (m *IsFileClosedRequestProto) String() string

type IsFileClosedResponseProto

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

func (*IsFileClosedResponseProto) GetResult

func (m *IsFileClosedResponseProto) GetResult() bool

func (*IsFileClosedResponseProto) ProtoMessage

func (*IsFileClosedResponseProto) ProtoMessage()

func (*IsFileClosedResponseProto) Reset

func (m *IsFileClosedResponseProto) Reset()

func (*IsFileClosedResponseProto) String

func (m *IsFileClosedResponseProto) String() string

type ListCacheDirectivesRequestProto added in v1.0.0

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 added in v1.0.0

func (*ListCacheDirectivesRequestProto) GetPrevId added in v1.0.0

func (m *ListCacheDirectivesRequestProto) GetPrevId() int64

func (*ListCacheDirectivesRequestProto) ProtoMessage added in v1.0.0

func (*ListCacheDirectivesRequestProto) ProtoMessage()

func (*ListCacheDirectivesRequestProto) Reset added in v1.0.0

func (*ListCacheDirectivesRequestProto) String added in v1.0.0

type ListCacheDirectivesResponseProto added in v1.0.0

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 added in v1.0.0

func (*ListCacheDirectivesResponseProto) GetHasMore added in v1.0.0

func (m *ListCacheDirectivesResponseProto) GetHasMore() bool

func (*ListCacheDirectivesResponseProto) ProtoMessage added in v1.0.0

func (*ListCacheDirectivesResponseProto) ProtoMessage()

func (*ListCacheDirectivesResponseProto) Reset added in v1.0.0

func (*ListCacheDirectivesResponseProto) String added in v1.0.0

type ListCachePoolsRequestProto added in v1.0.0

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

func (*ListCachePoolsRequestProto) GetPrevPoolName added in v1.0.0

func (m *ListCachePoolsRequestProto) GetPrevPoolName() string

func (*ListCachePoolsRequestProto) ProtoMessage added in v1.0.0

func (*ListCachePoolsRequestProto) ProtoMessage()

func (*ListCachePoolsRequestProto) Reset added in v1.0.0

func (m *ListCachePoolsRequestProto) Reset()

func (*ListCachePoolsRequestProto) String added in v1.0.0

func (m *ListCachePoolsRequestProto) String() string

type ListCachePoolsResponseProto added in v1.0.0

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 added in v1.0.0

func (*ListCachePoolsResponseProto) GetHasMore added in v1.0.0

func (m *ListCachePoolsResponseProto) GetHasMore() bool

func (*ListCachePoolsResponseProto) ProtoMessage added in v1.0.0

func (*ListCachePoolsResponseProto) ProtoMessage()

func (*ListCachePoolsResponseProto) Reset added in v1.0.0

func (m *ListCachePoolsResponseProto) Reset()

func (*ListCachePoolsResponseProto) String added in v1.0.0

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 (*ListCorruptFileBlocksRequestProto) GetPath

func (*ListCorruptFileBlocksRequestProto) ProtoMessage

func (*ListCorruptFileBlocksRequestProto) ProtoMessage()

func (*ListCorruptFileBlocksRequestProto) Reset

func (*ListCorruptFileBlocksRequestProto) String

type ListCorruptFileBlocksResponseProto

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

func (*ListCorruptFileBlocksResponseProto) GetCorrupt

func (*ListCorruptFileBlocksResponseProto) ProtoMessage

func (*ListCorruptFileBlocksResponseProto) ProtoMessage()

func (*ListCorruptFileBlocksResponseProto) Reset

func (*ListCorruptFileBlocksResponseProto) String

type ListEncryptionZonesRequestProto added in v1.0.0

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

func (*ListEncryptionZonesRequestProto) GetId added in v1.0.0

func (*ListEncryptionZonesRequestProto) ProtoMessage added in v1.0.0

func (*ListEncryptionZonesRequestProto) ProtoMessage()

func (*ListEncryptionZonesRequestProto) Reset added in v1.0.0

func (*ListEncryptionZonesRequestProto) String added in v1.0.0

type ListEncryptionZonesResponseProto added in v1.0.0

type ListEncryptionZonesResponseProto struct {
	Zones            []*EncryptionZoneProto `protobuf:"bytes,1,rep,name=zones" json:"zones,omitempty"`
	HasMore          *bool                  `protobuf:"varint,2,req,name=hasMore" json:"hasMore,omitempty"`
	XXX_unrecognized []byte                 `json:"-"`
}

func (*ListEncryptionZonesResponseProto) GetHasMore added in v1.0.0

func (m *ListEncryptionZonesResponseProto) GetHasMore() bool

func (*ListEncryptionZonesResponseProto) GetZones added in v1.0.0

func (*ListEncryptionZonesResponseProto) ProtoMessage added in v1.0.0

func (*ListEncryptionZonesResponseProto) ProtoMessage()

func (*ListEncryptionZonesResponseProto) Reset added in v1.0.0

func (*ListEncryptionZonesResponseProto) String added in v1.0.0

type ListReconfigurablePropertiesRequestProto added in v1.0.0

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

* Query the reconfigurable properties on NN/DN.

func (*ListReconfigurablePropertiesRequestProto) ProtoMessage added in v1.0.0

func (*ListReconfigurablePropertiesRequestProto) Reset added in v1.0.0

func (*ListReconfigurablePropertiesRequestProto) String added in v1.0.0

type ListReconfigurablePropertiesResponseProto added in v1.0.0

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

func (*ListReconfigurablePropertiesResponseProto) GetName added in v1.0.0

func (*ListReconfigurablePropertiesResponseProto) ProtoMessage added in v1.0.0

func (*ListReconfigurablePropertiesResponseProto) Reset added in v1.0.0

func (*ListReconfigurablePropertiesResponseProto) String added in v1.0.0

type ListXAttrsRequestProto added in v1.0.0

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

func (*ListXAttrsRequestProto) GetSrc added in v1.0.0

func (m *ListXAttrsRequestProto) GetSrc() string

func (*ListXAttrsRequestProto) ProtoMessage added in v1.0.0

func (*ListXAttrsRequestProto) ProtoMessage()

func (*ListXAttrsRequestProto) Reset added in v1.0.0

func (m *ListXAttrsRequestProto) Reset()

func (*ListXAttrsRequestProto) String added in v1.0.0

func (m *ListXAttrsRequestProto) String() string

type ListXAttrsResponseProto added in v1.0.0

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

func (*ListXAttrsResponseProto) GetXAttrs added in v1.0.0

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

func (*ListXAttrsResponseProto) ProtoMessage added in v1.0.0

func (*ListXAttrsResponseProto) ProtoMessage()

func (*ListXAttrsResponseProto) Reset added in v1.0.0

func (m *ListXAttrsResponseProto) Reset()

func (*ListXAttrsResponseProto) String added in v1.0.0

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"`
	// striped block related fields
	BlockIndices     []byte                      `protobuf:"bytes,9,opt,name=blockIndices" json:"blockIndices,omitempty"`
	BlockTokens      []*hadoop_common.TokenProto `protobuf:"bytes,10,rep,name=blockTokens" json:"blockTokens,omitempty"`
	XXX_unrecognized []byte                      `json:"-"`
}

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

func (*LocatedBlockProto) GetB

func (*LocatedBlockProto) GetBlockIndices added in v1.0.0

func (m *LocatedBlockProto) GetBlockIndices() []byte

func (*LocatedBlockProto) GetBlockToken

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

func (*LocatedBlockProto) GetBlockTokens added in v1.0.0

func (m *LocatedBlockProto) GetBlockTokens() []*hadoop_common.TokenProto

func (*LocatedBlockProto) GetCorrupt

func (m *LocatedBlockProto) GetCorrupt() bool

func (*LocatedBlockProto) GetIsCached added in v1.0.0

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

func (*LocatedBlockProto) GetLocs

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

func (*LocatedBlockProto) GetOffset

func (m *LocatedBlockProto) GetOffset() uint64

func (*LocatedBlockProto) GetStorageIDs added in v1.0.0

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

func (*LocatedBlockProto) GetStorageTypes added in v1.0.0

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"`
	FileEncryptionInfo  *FileEncryptionInfoProto `protobuf:"bytes,6,opt,name=fileEncryptionInfo" json:"fileEncryptionInfo,omitempty"`
	// Optional field for erasure coding
	EcPolicy         *ErasureCodingPolicyProto `protobuf:"bytes,7,opt,name=ecPolicy" json:"ecPolicy,omitempty"`
	XXX_unrecognized []byte                    `json:"-"`
}

* A set of file blocks and their locations.

func (*LocatedBlocksProto) GetBlocks

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

func (*LocatedBlocksProto) GetEcPolicy added in v1.0.0

func (m *LocatedBlocksProto) GetEcPolicy() *ErasureCodingPolicyProto

func (*LocatedBlocksProto) GetFileEncryptionInfo added in v1.0.0

func (m *LocatedBlocksProto) GetFileEncryptionInfo() *FileEncryptionInfoProto

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 MetadataUpdateEventProto added in v1.0.0

type MetadataUpdateEventProto struct {
	Path             *string             `protobuf:"bytes,1,req,name=path" json:"path,omitempty"`
	Type             *MetadataUpdateType `protobuf:"varint,2,req,name=type,enum=hadoop.hdfs.MetadataUpdateType" json:"type,omitempty"`
	Mtime            *int64              `protobuf:"varint,3,opt,name=mtime" json:"mtime,omitempty"`
	Atime            *int64              `protobuf:"varint,4,opt,name=atime" json:"atime,omitempty"`
	Replication      *int32              `protobuf:"varint,5,opt,name=replication" json:"replication,omitempty"`
	OwnerName        *string             `protobuf:"bytes,6,opt,name=ownerName" json:"ownerName,omitempty"`
	GroupName        *string             `protobuf:"bytes,7,opt,name=groupName" json:"groupName,omitempty"`
	Perms            *FsPermissionProto  `protobuf:"bytes,8,opt,name=perms" json:"perms,omitempty"`
	Acls             []*AclEntryProto    `protobuf:"bytes,9,rep,name=acls" json:"acls,omitempty"`
	XAttrs           []*XAttrProto       `protobuf:"bytes,10,rep,name=xAttrs" json:"xAttrs,omitempty"`
	XAttrsRemoved    *bool               `protobuf:"varint,11,opt,name=xAttrsRemoved" json:"xAttrsRemoved,omitempty"`
	XXX_unrecognized []byte              `json:"-"`
}

func (*MetadataUpdateEventProto) GetAcls added in v1.0.0

func (m *MetadataUpdateEventProto) GetAcls() []*AclEntryProto

func (*MetadataUpdateEventProto) GetAtime added in v1.0.0

func (m *MetadataUpdateEventProto) GetAtime() int64

func (*MetadataUpdateEventProto) GetGroupName added in v1.0.0

func (m *MetadataUpdateEventProto) GetGroupName() string

func (*MetadataUpdateEventProto) GetMtime added in v1.0.0

func (m *MetadataUpdateEventProto) GetMtime() int64

func (*MetadataUpdateEventProto) GetOwnerName added in v1.0.0

func (m *MetadataUpdateEventProto) GetOwnerName() string

func (*MetadataUpdateEventProto) GetPath added in v1.0.0

func (m *MetadataUpdateEventProto) GetPath() string

func (*MetadataUpdateEventProto) GetPerms added in v1.0.0

func (*MetadataUpdateEventProto) GetReplication added in v1.0.0

func (m *MetadataUpdateEventProto) GetReplication() int32

func (*MetadataUpdateEventProto) GetType added in v1.0.0

func (*MetadataUpdateEventProto) GetXAttrs added in v1.0.0

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

func (*MetadataUpdateEventProto) GetXAttrsRemoved added in v1.0.0

func (m *MetadataUpdateEventProto) GetXAttrsRemoved() bool

func (*MetadataUpdateEventProto) ProtoMessage added in v1.0.0

func (*MetadataUpdateEventProto) ProtoMessage()

func (*MetadataUpdateEventProto) Reset added in v1.0.0

func (m *MetadataUpdateEventProto) Reset()

func (*MetadataUpdateEventProto) String added in v1.0.0

func (m *MetadataUpdateEventProto) String() string

type MetadataUpdateType added in v1.0.0

type MetadataUpdateType int32
const (
	MetadataUpdateType_META_TYPE_TIMES       MetadataUpdateType = 0
	MetadataUpdateType_META_TYPE_REPLICATION MetadataUpdateType = 1
	MetadataUpdateType_META_TYPE_OWNER       MetadataUpdateType = 2
	MetadataUpdateType_META_TYPE_PERMS       MetadataUpdateType = 3
	MetadataUpdateType_META_TYPE_ACLS        MetadataUpdateType = 4
	MetadataUpdateType_META_TYPE_XATTRS      MetadataUpdateType = 5
)

func (MetadataUpdateType) Enum added in v1.0.0

func (MetadataUpdateType) String added in v1.0.0

func (x MetadataUpdateType) String() string

func (*MetadataUpdateType) UnmarshalJSON added in v1.0.0

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

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 added in v1.0.0

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 added in v1.0.0

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

func (*ModifyAclEntriesRequestProto) GetSrc added in v1.0.0

func (*ModifyAclEntriesRequestProto) ProtoMessage added in v1.0.0

func (*ModifyAclEntriesRequestProto) ProtoMessage()

func (*ModifyAclEntriesRequestProto) Reset added in v1.0.0

func (m *ModifyAclEntriesRequestProto) Reset()

func (*ModifyAclEntriesRequestProto) String added in v1.0.0

type ModifyAclEntriesResponseProto added in v1.0.0

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

func (*ModifyAclEntriesResponseProto) ProtoMessage added in v1.0.0

func (*ModifyAclEntriesResponseProto) ProtoMessage()

func (*ModifyAclEntriesResponseProto) Reset added in v1.0.0

func (m *ModifyAclEntriesResponseProto) Reset()

func (*ModifyAclEntriesResponseProto) String added in v1.0.0

type ModifyCacheDirectiveRequestProto added in v1.0.0

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 added in v1.0.0

func (m *ModifyCacheDirectiveRequestProto) GetCacheFlags() uint32

func (*ModifyCacheDirectiveRequestProto) GetInfo added in v1.0.0

func (*ModifyCacheDirectiveRequestProto) ProtoMessage added in v1.0.0

func (*ModifyCacheDirectiveRequestProto) ProtoMessage()

func (*ModifyCacheDirectiveRequestProto) Reset added in v1.0.0

func (*ModifyCacheDirectiveRequestProto) String added in v1.0.0

type ModifyCacheDirectiveResponseProto added in v1.0.0

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

func (*ModifyCacheDirectiveResponseProto) ProtoMessage added in v1.0.0

func (*ModifyCacheDirectiveResponseProto) ProtoMessage()

func (*ModifyCacheDirectiveResponseProto) Reset added in v1.0.0

func (*ModifyCacheDirectiveResponseProto) String added in v1.0.0

type ModifyCachePoolRequestProto added in v1.0.0

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

func (*ModifyCachePoolRequestProto) GetInfo added in v1.0.0

func (*ModifyCachePoolRequestProto) ProtoMessage added in v1.0.0

func (*ModifyCachePoolRequestProto) ProtoMessage()

func (*ModifyCachePoolRequestProto) Reset added in v1.0.0

func (m *ModifyCachePoolRequestProto) Reset()

func (*ModifyCachePoolRequestProto) String added in v1.0.0

func (m *ModifyCachePoolRequestProto) String() string

type ModifyCachePoolResponseProto added in v1.0.0

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

func (*ModifyCachePoolResponseProto) ProtoMessage added in v1.0.0

func (*ModifyCachePoolResponseProto) ProtoMessage()

func (*ModifyCachePoolResponseProto) Reset added in v1.0.0

func (m *ModifyCachePoolResponseProto) Reset()

func (*ModifyCachePoolResponseProto) String added in v1.0.0

type OpBlockChecksumProto

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

func (*OpBlockChecksumProto) GetHeader

func (m *OpBlockChecksumProto) GetHeader() *BaseHeaderProto

func (*OpBlockChecksumProto) ProtoMessage

func (*OpBlockChecksumProto) ProtoMessage()

func (*OpBlockChecksumProto) Reset

func (m *OpBlockChecksumProto) Reset()

func (*OpBlockChecksumProto) String

func (m *OpBlockChecksumProto) String() string

type OpBlockChecksumResponseProto

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

func (*OpBlockChecksumResponseProto) GetBytesPerCrc

func (m *OpBlockChecksumResponseProto) GetBytesPerCrc() uint32

func (*OpBlockChecksumResponseProto) GetCrcPerBlock

func (m *OpBlockChecksumResponseProto) GetCrcPerBlock() uint64

func (*OpBlockChecksumResponseProto) GetCrcType

func (*OpBlockChecksumResponseProto) GetMd5

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

func (*OpBlockChecksumResponseProto) ProtoMessage

func (*OpBlockChecksumResponseProto) ProtoMessage()

func (*OpBlockChecksumResponseProto) Reset

func (m *OpBlockChecksumResponseProto) Reset()

func (*OpBlockChecksumResponseProto) String

type OpBlockGroupChecksumProto added in v1.0.0

type OpBlockGroupChecksumProto struct {
	Header    *BaseHeaderProto    `protobuf:"bytes,1,req,name=header" json:"header,omitempty"`
	Datanodes *DatanodeInfosProto `protobuf:"bytes,2,req,name=datanodes" json:"datanodes,omitempty"`
	// each internal block has a block token
	BlockTokens      []*hadoop_common.TokenProto `protobuf:"bytes,3,rep,name=blockTokens" json:"blockTokens,omitempty"`
	EcPolicy         *ErasureCodingPolicyProto   `protobuf:"bytes,4,req,name=ecPolicy" json:"ecPolicy,omitempty"`
	XXX_unrecognized []byte                      `json:"-"`
}

func (*OpBlockGroupChecksumProto) GetBlockTokens added in v1.0.0

func (m *OpBlockGroupChecksumProto) GetBlockTokens() []*hadoop_common.TokenProto

func (*OpBlockGroupChecksumProto) GetDatanodes added in v1.0.0

func (m *OpBlockGroupChecksumProto) GetDatanodes() *DatanodeInfosProto

func (*OpBlockGroupChecksumProto) GetEcPolicy added in v1.0.0

func (*OpBlockGroupChecksumProto) GetHeader added in v1.0.0

func (*OpBlockGroupChecksumProto) ProtoMessage added in v1.0.0

func (*OpBlockGroupChecksumProto) ProtoMessage()

func (*OpBlockGroupChecksumProto) Reset added in v1.0.0

func (m *OpBlockGroupChecksumProto) Reset()

func (*OpBlockGroupChecksumProto) String added in v1.0.0

func (m *OpBlockGroupChecksumProto) 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 OpCustomProto added in v1.0.0

type OpCustomProto struct {
	CustomId         *string `protobuf:"bytes,1,req,name=customId" json:"customId,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*OpCustomProto) GetCustomId added in v1.0.0

func (m *OpCustomProto) GetCustomId() string

func (*OpCustomProto) ProtoMessage added in v1.0.0

func (*OpCustomProto) ProtoMessage()

func (*OpCustomProto) Reset added in v1.0.0

func (m *OpCustomProto) Reset()

func (*OpCustomProto) String added in v1.0.0

func (m *OpCustomProto) String() string

type OpReadBlockProto

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

func (*OpReadBlockProto) GetCachingStrategy

func (m *OpReadBlockProto) GetCachingStrategy() *CachingStrategyProto

func (*OpReadBlockProto) GetHeader

func (*OpReadBlockProto) GetLen

func (m *OpReadBlockProto) GetLen() uint64

func (*OpReadBlockProto) GetOffset

func (m *OpReadBlockProto) GetOffset() uint64

func (*OpReadBlockProto) GetSendChecksums

func (m *OpReadBlockProto) GetSendChecksums() bool

func (*OpReadBlockProto) ProtoMessage

func (*OpReadBlockProto) ProtoMessage()

func (*OpReadBlockProto) Reset

func (m *OpReadBlockProto) Reset()

func (*OpReadBlockProto) String

func (m *OpReadBlockProto) String() string

type OpReplaceBlockProto

type OpReplaceBlockProto struct {
	Header           *BaseHeaderProto   `protobuf:"bytes,1,req,name=header" json:"header,omitempty"`
	DelHint          *string            `protobuf:"bytes,2,req,name=delHint" json:"delHint,omitempty"`
	Source           *DatanodeInfoProto `protobuf:"bytes,3,req,name=source" json:"source,omitempty"`
	StorageType      *StorageTypeProto  `protobuf:"varint,4,opt,name=storageType,enum=hadoop.hdfs.StorageTypeProto,def=1" json:"storageType,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) GetStorageType added in v1.0.0

func (m *OpReplaceBlockProto) GetStorageType() StorageTypeProto

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"`
	// *
	// True if the client supports verifying that the file descriptor has been
	// sent successfully.
	SupportsReceiptVerification *bool  `protobuf:"varint,4,opt,name=supportsReceiptVerification,def=0" json:"supportsReceiptVerification,omitempty"`
	XXX_unrecognized            []byte `json:"-"`
}

func (*OpRequestShortCircuitAccessProto) GetHeader

func (*OpRequestShortCircuitAccessProto) GetMaxVersion

func (m *OpRequestShortCircuitAccessProto) GetMaxVersion() uint32

func (*OpRequestShortCircuitAccessProto) GetSlotId added in v1.0.0

func (*OpRequestShortCircuitAccessProto) GetSupportsReceiptVerification added in v1.0.0

func (m *OpRequestShortCircuitAccessProto) GetSupportsReceiptVerification() bool

func (*OpRequestShortCircuitAccessProto) ProtoMessage

func (*OpRequestShortCircuitAccessProto) ProtoMessage()

func (*OpRequestShortCircuitAccessProto) Reset

func (*OpRequestShortCircuitAccessProto) String

type OpTransferBlockProto

type OpTransferBlockProto struct {
	Header             *ClientOperationHeaderProto `protobuf:"bytes,1,req,name=header" json:"header,omitempty"`
	Targets            []*DatanodeInfoProto        `protobuf:"bytes,2,rep,name=targets" json:"targets,omitempty"`
	TargetStorageTypes []StorageTypeProto          `protobuf:"varint,3,rep,name=targetStorageTypes,enum=hadoop.hdfs.StorageTypeProto" json:"targetStorageTypes,omitempty"`
	XXX_unrecognized   []byte                      `json:"-"`
}

func (*OpTransferBlockProto) GetHeader

func (*OpTransferBlockProto) GetTargetStorageTypes added in v1.0.0

func (m *OpTransferBlockProto) GetTargetStorageTypes() []StorageTypeProto

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"`
	StorageType        *StorageTypeProto     `protobuf:"varint,11,opt,name=storageType,enum=hadoop.hdfs.StorageTypeProto,def=1" json:"storageType,omitempty"`
	TargetStorageTypes []StorageTypeProto    `protobuf:"varint,12,rep,name=targetStorageTypes,enum=hadoop.hdfs.StorageTypeProto" json:"targetStorageTypes,omitempty"`
	// *
	// Hint to the DataNode that the block can be allocated on transient
	// storage i.e. memory and written to disk lazily. The DataNode is free
	// to ignore this hint.
	AllowLazyPersist *bool `protobuf:"varint,13,opt,name=allowLazyPersist,def=0" json:"allowLazyPersist,omitempty"`
	// whether to pin the block, so Balancer won't move it.
	Pinning          *bool  `protobuf:"varint,14,opt,name=pinning,def=0" json:"pinning,omitempty"`
	TargetPinnings   []bool `protobuf:"varint,15,rep,name=targetPinnings" json:"targetPinnings,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*OpWriteBlockProto) GetAllowLazyPersist added in v1.0.0

func (m *OpWriteBlockProto) GetAllowLazyPersist() bool

func (*OpWriteBlockProto) GetCachingStrategy

func (m *OpWriteBlockProto) GetCachingStrategy() *CachingStrategyProto

func (*OpWriteBlockProto) GetHeader

func (*OpWriteBlockProto) GetLatestGenerationStamp

func (m *OpWriteBlockProto) GetLatestGenerationStamp() uint64

func (*OpWriteBlockProto) GetMaxBytesRcvd

func (m *OpWriteBlockProto) GetMaxBytesRcvd() uint64

func (*OpWriteBlockProto) GetMinBytesRcvd

func (m *OpWriteBlockProto) GetMinBytesRcvd() uint64

func (*OpWriteBlockProto) GetPinning added in v1.0.0

func (m *OpWriteBlockProto) GetPinning() bool

func (*OpWriteBlockProto) GetPipelineSize

func (m *OpWriteBlockProto) GetPipelineSize() uint32

func (*OpWriteBlockProto) GetRequestedChecksum

func (m *OpWriteBlockProto) GetRequestedChecksum() *ChecksumProto

func (*OpWriteBlockProto) GetSource

func (m *OpWriteBlockProto) GetSource() *DatanodeInfoProto

func (*OpWriteBlockProto) GetStage

func (*OpWriteBlockProto) GetStorageType added in v1.0.0

func (m *OpWriteBlockProto) GetStorageType() StorageTypeProto

func (*OpWriteBlockProto) GetTargetPinnings added in v1.0.0

func (m *OpWriteBlockProto) GetTargetPinnings() []bool

func (*OpWriteBlockProto) GetTargetStorageTypes added in v1.0.0

func (m *OpWriteBlockProto) GetTargetStorageTypes() []StorageTypeProto

func (*OpWriteBlockProto) GetTargets

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

func (*OpWriteBlockProto) ProtoMessage

func (*OpWriteBlockProto) ProtoMessage()

func (*OpWriteBlockProto) Reset

func (m *OpWriteBlockProto) Reset()

func (*OpWriteBlockProto) String

func (m *OpWriteBlockProto) String() string

type OpWriteBlockProto_BlockConstructionStage

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

func (OpWriteBlockProto_BlockConstructionStage) Enum

func (OpWriteBlockProto_BlockConstructionStage) String

func (*OpWriteBlockProto_BlockConstructionStage) UnmarshalJSON

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

type PacketHeaderProto

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

func (*PacketHeaderProto) GetDataLen

func (m *PacketHeaderProto) GetDataLen() int32

func (*PacketHeaderProto) GetLastPacketInBlock

func (m *PacketHeaderProto) GetLastPacketInBlock() bool

func (*PacketHeaderProto) GetOffsetInBlock

func (m *PacketHeaderProto) GetOffsetInBlock() int64

func (*PacketHeaderProto) GetSeqno

func (m *PacketHeaderProto) GetSeqno() int64

func (*PacketHeaderProto) GetSyncBlock

func (m *PacketHeaderProto) GetSyncBlock() bool

func (*PacketHeaderProto) ProtoMessage

func (*PacketHeaderProto) ProtoMessage()

func (*PacketHeaderProto) Reset

func (m *PacketHeaderProto) Reset()

func (*PacketHeaderProto) String

func (m *PacketHeaderProto) String() string

type PerFileEncryptionInfoProto added in v1.0.0

type PerFileEncryptionInfoProto struct {
	Key              []byte  `protobuf:"bytes,1,req,name=key" json:"key,omitempty"`
	Iv               []byte  `protobuf:"bytes,2,req,name=iv" json:"iv,omitempty"`
	EzKeyVersionName *string `protobuf:"bytes,3,req,name=ezKeyVersionName" json:"ezKeyVersionName,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* Encryption information for an individual file within an encryption zone

func (*PerFileEncryptionInfoProto) GetEzKeyVersionName added in v1.0.0

func (m *PerFileEncryptionInfoProto) GetEzKeyVersionName() string

func (*PerFileEncryptionInfoProto) GetIv added in v1.0.0

func (m *PerFileEncryptionInfoProto) GetIv() []byte

func (*PerFileEncryptionInfoProto) GetKey added in v1.0.0

func (m *PerFileEncryptionInfoProto) GetKey() []byte

func (*PerFileEncryptionInfoProto) ProtoMessage added in v1.0.0

func (*PerFileEncryptionInfoProto) ProtoMessage()

func (*PerFileEncryptionInfoProto) Reset added in v1.0.0

func (m *PerFileEncryptionInfoProto) Reset()

func (*PerFileEncryptionInfoProto) String added in v1.0.0

func (m *PerFileEncryptionInfoProto) String() string

type PipelineAckProto

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

func (*PipelineAckProto) GetDownstreamAckTimeNanos

func (m *PipelineAckProto) GetDownstreamAckTimeNanos() uint64

func (*PipelineAckProto) GetFlag added in v1.0.0

func (m *PipelineAckProto) GetFlag() []uint32

func (*PipelineAckProto) GetReply added in v1.0.0

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

func (*PipelineAckProto) GetSeqno

func (m *PipelineAckProto) GetSeqno() int64

func (*PipelineAckProto) ProtoMessage

func (*PipelineAckProto) ProtoMessage()

func (*PipelineAckProto) Reset

func (m *PipelineAckProto) Reset()

func (*PipelineAckProto) String

func (m *PipelineAckProto) String() string

type QuotaUsageProto added in v1.0.0

type QuotaUsageProto struct {
	FileAndDirectoryCount *uint64                     `protobuf:"varint,1,req,name=fileAndDirectoryCount" json:"fileAndDirectoryCount,omitempty"`
	Quota                 *uint64                     `protobuf:"varint,2,req,name=quota" json:"quota,omitempty"`
	SpaceConsumed         *uint64                     `protobuf:"varint,3,req,name=spaceConsumed" json:"spaceConsumed,omitempty"`
	SpaceQuota            *uint64                     `protobuf:"varint,4,req,name=spaceQuota" json:"spaceQuota,omitempty"`
	TypeQuotaInfos        *StorageTypeQuotaInfosProto `protobuf:"bytes,5,opt,name=typeQuotaInfos" json:"typeQuotaInfos,omitempty"`
	XXX_unrecognized      []byte                      `json:"-"`
}

* Summary of quota usage of a directory

func (*QuotaUsageProto) GetFileAndDirectoryCount added in v1.0.0

func (m *QuotaUsageProto) GetFileAndDirectoryCount() uint64

func (*QuotaUsageProto) GetQuota added in v1.0.0

func (m *QuotaUsageProto) GetQuota() uint64

func (*QuotaUsageProto) GetSpaceConsumed added in v1.0.0

func (m *QuotaUsageProto) GetSpaceConsumed() uint64

func (*QuotaUsageProto) GetSpaceQuota added in v1.0.0

func (m *QuotaUsageProto) GetSpaceQuota() uint64

func (*QuotaUsageProto) GetTypeQuotaInfos added in v1.0.0

func (m *QuotaUsageProto) GetTypeQuotaInfos() *StorageTypeQuotaInfosProto

func (*QuotaUsageProto) ProtoMessage added in v1.0.0

func (*QuotaUsageProto) ProtoMessage()

func (*QuotaUsageProto) Reset added in v1.0.0

func (m *QuotaUsageProto) Reset()

func (*QuotaUsageProto) String added in v1.0.0

func (m *QuotaUsageProto) 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 RefreshNamenodesRequestProto added in v1.0.0

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

* void request

func (*RefreshNamenodesRequestProto) ProtoMessage added in v1.0.0

func (*RefreshNamenodesRequestProto) ProtoMessage()

func (*RefreshNamenodesRequestProto) Reset added in v1.0.0

func (m *RefreshNamenodesRequestProto) Reset()

func (*RefreshNamenodesRequestProto) String added in v1.0.0

type RefreshNamenodesResponseProto added in v1.0.0

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

* void response

func (*RefreshNamenodesResponseProto) ProtoMessage added in v1.0.0

func (*RefreshNamenodesResponseProto) ProtoMessage()

func (*RefreshNamenodesResponseProto) Reset added in v1.0.0

func (m *RefreshNamenodesResponseProto) Reset()

func (*RefreshNamenodesResponseProto) String added in v1.0.0

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 added in v1.0.0

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

func (*ReleaseShortCircuitAccessRequestProto) GetSlotId added in v1.0.0

func (*ReleaseShortCircuitAccessRequestProto) GetTraceInfo added in v1.0.0

func (*ReleaseShortCircuitAccessRequestProto) ProtoMessage added in v1.0.0

func (*ReleaseShortCircuitAccessRequestProto) ProtoMessage()

func (*ReleaseShortCircuitAccessRequestProto) Reset added in v1.0.0

func (*ReleaseShortCircuitAccessRequestProto) String added in v1.0.0

type ReleaseShortCircuitAccessResponseProto added in v1.0.0

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 added in v1.0.0

func (*ReleaseShortCircuitAccessResponseProto) GetStatus added in v1.0.0

func (*ReleaseShortCircuitAccessResponseProto) ProtoMessage added in v1.0.0

func (*ReleaseShortCircuitAccessResponseProto) Reset added in v1.0.0

func (*ReleaseShortCircuitAccessResponseProto) String added in v1.0.0

type RemoveAclEntriesRequestProto added in v1.0.0

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 added in v1.0.0

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

func (*RemoveAclEntriesRequestProto) GetSrc added in v1.0.0

func (*RemoveAclEntriesRequestProto) ProtoMessage added in v1.0.0

func (*RemoveAclEntriesRequestProto) ProtoMessage()

func (*RemoveAclEntriesRequestProto) Reset added in v1.0.0

func (m *RemoveAclEntriesRequestProto) Reset()

func (*RemoveAclEntriesRequestProto) String added in v1.0.0

type RemoveAclEntriesResponseProto added in v1.0.0

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

func (*RemoveAclEntriesResponseProto) ProtoMessage added in v1.0.0

func (*RemoveAclEntriesResponseProto) ProtoMessage()

func (*RemoveAclEntriesResponseProto) Reset added in v1.0.0

func (m *RemoveAclEntriesResponseProto) Reset()

func (*RemoveAclEntriesResponseProto) String added in v1.0.0

type RemoveAclRequestProto added in v1.0.0

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

func (*RemoveAclRequestProto) GetSrc added in v1.0.0

func (m *RemoveAclRequestProto) GetSrc() string

func (*RemoveAclRequestProto) ProtoMessage added in v1.0.0

func (*RemoveAclRequestProto) ProtoMessage()

func (*RemoveAclRequestProto) Reset added in v1.0.0

func (m *RemoveAclRequestProto) Reset()

func (*RemoveAclRequestProto) String added in v1.0.0

func (m *RemoveAclRequestProto) String() string

type RemoveAclResponseProto added in v1.0.0

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

func (*RemoveAclResponseProto) ProtoMessage added in v1.0.0

func (*RemoveAclResponseProto) ProtoMessage()

func (*RemoveAclResponseProto) Reset added in v1.0.0

func (m *RemoveAclResponseProto) Reset()

func (*RemoveAclResponseProto) String added in v1.0.0

func (m *RemoveAclResponseProto) String() string

type RemoveCacheDirectiveRequestProto added in v1.0.0

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

func (*RemoveCacheDirectiveRequestProto) GetId added in v1.0.0

func (*RemoveCacheDirectiveRequestProto) ProtoMessage added in v1.0.0

func (*RemoveCacheDirectiveRequestProto) ProtoMessage()

func (*RemoveCacheDirectiveRequestProto) Reset added in v1.0.0

func (*RemoveCacheDirectiveRequestProto) String added in v1.0.0

type RemoveCacheDirectiveResponseProto added in v1.0.0

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

func (*RemoveCacheDirectiveResponseProto) ProtoMessage added in v1.0.0

func (*RemoveCacheDirectiveResponseProto) ProtoMessage()

func (*RemoveCacheDirectiveResponseProto) Reset added in v1.0.0

func (*RemoveCacheDirectiveResponseProto) String added in v1.0.0

type RemoveCachePoolRequestProto added in v1.0.0

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

func (*RemoveCachePoolRequestProto) GetPoolName added in v1.0.0

func (m *RemoveCachePoolRequestProto) GetPoolName() string

func (*RemoveCachePoolRequestProto) ProtoMessage added in v1.0.0

func (*RemoveCachePoolRequestProto) ProtoMessage()

func (*RemoveCachePoolRequestProto) Reset added in v1.0.0

func (m *RemoveCachePoolRequestProto) Reset()

func (*RemoveCachePoolRequestProto) String added in v1.0.0

func (m *RemoveCachePoolRequestProto) String() string

type RemoveCachePoolResponseProto added in v1.0.0

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

func (*RemoveCachePoolResponseProto) ProtoMessage added in v1.0.0

func (*RemoveCachePoolResponseProto) ProtoMessage()

func (*RemoveCachePoolResponseProto) Reset added in v1.0.0

func (m *RemoveCachePoolResponseProto) Reset()

func (*RemoveCachePoolResponseProto) String added in v1.0.0

type RemoveDefaultAclRequestProto added in v1.0.0

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

func (*RemoveDefaultAclRequestProto) GetSrc added in v1.0.0

func (*RemoveDefaultAclRequestProto) ProtoMessage added in v1.0.0

func (*RemoveDefaultAclRequestProto) ProtoMessage()

func (*RemoveDefaultAclRequestProto) Reset added in v1.0.0

func (m *RemoveDefaultAclRequestProto) Reset()

func (*RemoveDefaultAclRequestProto) String added in v1.0.0

type RemoveDefaultAclResponseProto added in v1.0.0

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

func (*RemoveDefaultAclResponseProto) ProtoMessage added in v1.0.0

func (*RemoveDefaultAclResponseProto) ProtoMessage()

func (*RemoveDefaultAclResponseProto) Reset added in v1.0.0

func (m *RemoveDefaultAclResponseProto) Reset()

func (*RemoveDefaultAclResponseProto) String added in v1.0.0

type RemoveXAttrRequestProto added in v1.0.0

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 added in v1.0.0

func (m *RemoveXAttrRequestProto) GetSrc() string

func (*RemoveXAttrRequestProto) GetXAttr added in v1.0.0

func (m *RemoveXAttrRequestProto) GetXAttr() *XAttrProto

func (*RemoveXAttrRequestProto) ProtoMessage added in v1.0.0

func (*RemoveXAttrRequestProto) ProtoMessage()

func (*RemoveXAttrRequestProto) Reset added in v1.0.0

func (m *RemoveXAttrRequestProto) Reset()

func (*RemoveXAttrRequestProto) String added in v1.0.0

func (m *RemoveXAttrRequestProto) String() string

type RemoveXAttrResponseProto added in v1.0.0

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

func (*RemoveXAttrResponseProto) ProtoMessage added in v1.0.0

func (*RemoveXAttrResponseProto) ProtoMessage()

func (*RemoveXAttrResponseProto) Reset added in v1.0.0

func (m *RemoveXAttrResponseProto) Reset()

func (*RemoveXAttrResponseProto) String added in v1.0.0

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 RenameEventProto added in v1.0.0

type RenameEventProto struct {
	SrcPath          *string `protobuf:"bytes,1,req,name=srcPath" json:"srcPath,omitempty"`
	DestPath         *string `protobuf:"bytes,2,req,name=destPath" json:"destPath,omitempty"`
	Timestamp        *int64  `protobuf:"varint,3,req,name=timestamp" json:"timestamp,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*RenameEventProto) GetDestPath added in v1.0.0

func (m *RenameEventProto) GetDestPath() string

func (*RenameEventProto) GetSrcPath added in v1.0.0

func (m *RenameEventProto) GetSrcPath() string

func (*RenameEventProto) GetTimestamp added in v1.0.0

func (m *RenameEventProto) GetTimestamp() int64

func (*RenameEventProto) ProtoMessage added in v1.0.0

func (*RenameEventProto) ProtoMessage()

func (*RenameEventProto) Reset added in v1.0.0

func (m *RenameEventProto) Reset()

func (*RenameEventProto) String added in v1.0.0

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

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

func (*ReportBadBlocksRequestProto) GetBlocks

func (*ReportBadBlocksRequestProto) ProtoMessage

func (*ReportBadBlocksRequestProto) ProtoMessage()

func (*ReportBadBlocksRequestProto) Reset

func (m *ReportBadBlocksRequestProto) Reset()

func (*ReportBadBlocksRequestProto) String

func (m *ReportBadBlocksRequestProto) String() string

type ReportBadBlocksResponseProto

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

func (*ReportBadBlocksResponseProto) ProtoMessage

func (*ReportBadBlocksResponseProto) ProtoMessage()

func (*ReportBadBlocksResponseProto) Reset

func (m *ReportBadBlocksResponseProto) Reset()

func (*ReportBadBlocksResponseProto) String

type RestoreFailedStorageRequestProto

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

func (*RestoreFailedStorageRequestProto) GetArg

func (*RestoreFailedStorageRequestProto) ProtoMessage

func (*RestoreFailedStorageRequestProto) ProtoMessage()

func (*RestoreFailedStorageRequestProto) Reset

func (*RestoreFailedStorageRequestProto) String

type RestoreFailedStorageResponseProto

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

func (*RestoreFailedStorageResponseProto) GetResult

func (m *RestoreFailedStorageResponseProto) GetResult() bool

func (*RestoreFailedStorageResponseProto) ProtoMessage

func (*RestoreFailedStorageResponseProto) ProtoMessage()

func (*RestoreFailedStorageResponseProto) Reset

func (*RestoreFailedStorageResponseProto) String

type RollEditsRequestProto

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

func (*RollEditsRequestProto) ProtoMessage

func (*RollEditsRequestProto) ProtoMessage()

func (*RollEditsRequestProto) Reset

func (m *RollEditsRequestProto) Reset()

func (*RollEditsRequestProto) String

func (m *RollEditsRequestProto) String() string

type RollEditsResponseProto

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

func (*RollEditsResponseProto) GetNewSegmentTxId

func (m *RollEditsResponseProto) GetNewSegmentTxId() uint64

func (*RollEditsResponseProto) ProtoMessage

func (*RollEditsResponseProto) ProtoMessage()

func (*RollEditsResponseProto) Reset

func (m *RollEditsResponseProto) Reset()

func (*RollEditsResponseProto) String

func (m *RollEditsResponseProto) String() string

type RollingUpgradeActionProto added in v1.0.0

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

func (RollingUpgradeActionProto) Enum added in v1.0.0

func (RollingUpgradeActionProto) String added in v1.0.0

func (x RollingUpgradeActionProto) String() string

func (*RollingUpgradeActionProto) UnmarshalJSON added in v1.0.0

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

type RollingUpgradeInfoProto added in v1.0.0

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 added in v1.0.0

func (m *RollingUpgradeInfoProto) GetCreatedRollbackImages() bool

func (*RollingUpgradeInfoProto) GetFinalizeTime added in v1.0.0

func (m *RollingUpgradeInfoProto) GetFinalizeTime() uint64

func (*RollingUpgradeInfoProto) GetStartTime added in v1.0.0

func (m *RollingUpgradeInfoProto) GetStartTime() uint64

func (*RollingUpgradeInfoProto) GetStatus added in v1.0.0

func (*RollingUpgradeInfoProto) ProtoMessage added in v1.0.0

func (*RollingUpgradeInfoProto) ProtoMessage()

func (*RollingUpgradeInfoProto) Reset added in v1.0.0

func (m *RollingUpgradeInfoProto) Reset()

func (*RollingUpgradeInfoProto) String added in v1.0.0

func (m *RollingUpgradeInfoProto) String() string

type RollingUpgradeRequestProto added in v1.0.0

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 added in v1.0.0

func (*RollingUpgradeRequestProto) ProtoMessage added in v1.0.0

func (*RollingUpgradeRequestProto) ProtoMessage()

func (*RollingUpgradeRequestProto) Reset added in v1.0.0

func (m *RollingUpgradeRequestProto) Reset()

func (*RollingUpgradeRequestProto) String added in v1.0.0

func (m *RollingUpgradeRequestProto) String() string

type RollingUpgradeResponseProto added in v1.0.0

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

func (*RollingUpgradeResponseProto) GetRollingUpgradeInfo added in v1.0.0

func (m *RollingUpgradeResponseProto) GetRollingUpgradeInfo() *RollingUpgradeInfoProto

func (*RollingUpgradeResponseProto) ProtoMessage added in v1.0.0

func (*RollingUpgradeResponseProto) ProtoMessage()

func (*RollingUpgradeResponseProto) Reset added in v1.0.0

func (m *RollingUpgradeResponseProto) Reset()

func (*RollingUpgradeResponseProto) String added in v1.0.0

func (m *RollingUpgradeResponseProto) String() string

type RollingUpgradeStatusProto added in v1.0.0

type RollingUpgradeStatusProto struct {
	BlockPoolId      *string `protobuf:"bytes,1,req,name=blockPoolId" json:"blockPoolId,omitempty"`
	Finalized        *bool   `protobuf:"varint,2,opt,name=finalized,def=0" json:"finalized,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

* Rolling upgrade status

func (*RollingUpgradeStatusProto) GetBlockPoolId added in v1.0.0

func (m *RollingUpgradeStatusProto) GetBlockPoolId() string

func (*RollingUpgradeStatusProto) GetFinalized added in v1.0.0

func (m *RollingUpgradeStatusProto) GetFinalized() bool

func (*RollingUpgradeStatusProto) ProtoMessage added in v1.0.0

func (*RollingUpgradeStatusProto) ProtoMessage()

func (*RollingUpgradeStatusProto) Reset added in v1.0.0

func (m *RollingUpgradeStatusProto) Reset()

func (*RollingUpgradeStatusProto) String added in v1.0.0

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
	SafeModeActionProto_SAFEMODE_FORCE_EXIT SafeModeActionProto = 4
)

func (SafeModeActionProto) Enum

func (SafeModeActionProto) String

func (x SafeModeActionProto) String() string

func (*SafeModeActionProto) UnmarshalJSON

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

type SaveNamespaceRequestProto

type SaveNamespaceRequestProto struct {
	TimeWindow       *uint64 `protobuf:"varint,1,opt,name=timeWindow,def=0" json:"timeWindow,omitempty"`
	TxGap            *uint64 `protobuf:"varint,2,opt,name=txGap,def=0" json:"txGap,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*SaveNamespaceRequestProto) GetTimeWindow added in v1.0.0

func (m *SaveNamespaceRequestProto) GetTimeWindow() uint64

func (*SaveNamespaceRequestProto) GetTxGap added in v1.0.0

func (m *SaveNamespaceRequestProto) GetTxGap() uint64

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 {
	Saved            *bool  `protobuf:"varint,1,opt,name=saved,def=1" json:"saved,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*SaveNamespaceResponseProto) GetSaved added in v1.0.0

func (m *SaveNamespaceResponseProto) GetSaved() bool

func (*SaveNamespaceResponseProto) ProtoMessage

func (*SaveNamespaceResponseProto) ProtoMessage()

func (*SaveNamespaceResponseProto) Reset

func (m *SaveNamespaceResponseProto) Reset()

func (*SaveNamespaceResponseProto) String

func (m *SaveNamespaceResponseProto) String() string

type SetAclRequestProto added in v1.0.0

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 added in v1.0.0

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

func (*SetAclRequestProto) GetSrc added in v1.0.0

func (m *SetAclRequestProto) GetSrc() string

func (*SetAclRequestProto) ProtoMessage added in v1.0.0

func (*SetAclRequestProto) ProtoMessage()

func (*SetAclRequestProto) Reset added in v1.0.0

func (m *SetAclRequestProto) Reset()

func (*SetAclRequestProto) String added in v1.0.0

func (m *SetAclRequestProto) String() string

type SetAclResponseProto added in v1.0.0

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

func (*SetAclResponseProto) ProtoMessage added in v1.0.0

func (*SetAclResponseProto) ProtoMessage()

func (*SetAclResponseProto) Reset added in v1.0.0

func (m *SetAclResponseProto) Reset()

func (*SetAclResponseProto) String added in v1.0.0

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

type SetBalancerBandwidthResponseProto

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

func (*SetBalancerBandwidthResponseProto) ProtoMessage

func (*SetBalancerBandwidthResponseProto) ProtoMessage()

func (*SetBalancerBandwidthResponseProto) Reset

func (*SetBalancerBandwidthResponseProto) String

type SetErasureCodingPolicyRequestProto added in v1.0.0

type SetErasureCodingPolicyRequestProto struct {
	Src              *string                   `protobuf:"bytes,1,req,name=src" json:"src,omitempty"`
	EcPolicy         *ErasureCodingPolicyProto `protobuf:"bytes,2,opt,name=ecPolicy" json:"ecPolicy,omitempty"`
	XXX_unrecognized []byte                    `json:"-"`
}

func (*SetErasureCodingPolicyRequestProto) GetEcPolicy added in v1.0.0

func (*SetErasureCodingPolicyRequestProto) GetSrc added in v1.0.0

func (*SetErasureCodingPolicyRequestProto) ProtoMessage added in v1.0.0

func (*SetErasureCodingPolicyRequestProto) ProtoMessage()

func (*SetErasureCodingPolicyRequestProto) Reset added in v1.0.0

func (*SetErasureCodingPolicyRequestProto) String added in v1.0.0

type SetErasureCodingPolicyResponseProto added in v1.0.0

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

func (*SetErasureCodingPolicyResponseProto) ProtoMessage added in v1.0.0

func (*SetErasureCodingPolicyResponseProto) ProtoMessage()

func (*SetErasureCodingPolicyResponseProto) Reset added in v1.0.0

func (*SetErasureCodingPolicyResponseProto) String added in v1.0.0

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"`
	StoragespaceQuota *uint64           `protobuf:"varint,3,req,name=storagespaceQuota" json:"storagespaceQuota,omitempty"`
	StorageType       *StorageTypeProto `protobuf:"varint,4,opt,name=storageType,enum=hadoop.hdfs.StorageTypeProto" json:"storageType,omitempty"`
	XXX_unrecognized  []byte            `json:"-"`
}

func (*SetQuotaRequestProto) GetNamespaceQuota

func (m *SetQuotaRequestProto) GetNamespaceQuota() uint64

func (*SetQuotaRequestProto) GetPath

func (m *SetQuotaRequestProto) GetPath() string

func (*SetQuotaRequestProto) GetStorageType added in v1.0.0

func (m *SetQuotaRequestProto) GetStorageType() StorageTypeProto

func (*SetQuotaRequestProto) GetStoragespaceQuota added in v1.0.0

func (m *SetQuotaRequestProto) GetStoragespaceQuota() uint64

func (*SetQuotaRequestProto) ProtoMessage

func (*SetQuotaRequestProto) ProtoMessage()

func (*SetQuotaRequestProto) Reset

func (m *SetQuotaRequestProto) Reset()

func (*SetQuotaRequestProto) String

func (m *SetQuotaRequestProto) String() string

type SetQuotaResponseProto

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

func (*SetQuotaResponseProto) ProtoMessage

func (*SetQuotaResponseProto) ProtoMessage()

func (*SetQuotaResponseProto) Reset

func (m *SetQuotaResponseProto) Reset()

func (*SetQuotaResponseProto) String

func (m *SetQuotaResponseProto) String() string

type SetReplicationRequestProto

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

func (*SetReplicationRequestProto) GetReplication

func (m *SetReplicationRequestProto) GetReplication() uint32

func (*SetReplicationRequestProto) GetSrc

func (m *SetReplicationRequestProto) GetSrc() string

func (*SetReplicationRequestProto) ProtoMessage

func (*SetReplicationRequestProto) ProtoMessage()

func (*SetReplicationRequestProto) Reset

func (m *SetReplicationRequestProto) Reset()

func (*SetReplicationRequestProto) String

func (m *SetReplicationRequestProto) String() string

type SetReplicationResponseProto

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

func (*SetReplicationResponseProto) GetResult

func (m *SetReplicationResponseProto) GetResult() bool

func (*SetReplicationResponseProto) ProtoMessage

func (*SetReplicationResponseProto) ProtoMessage()

func (*SetReplicationResponseProto) Reset

func (m *SetReplicationResponseProto) Reset()

func (*SetReplicationResponseProto) String

func (m *SetReplicationResponseProto) String() string

type SetSafeModeRequestProto

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

func (*SetSafeModeRequestProto) GetAction

func (*SetSafeModeRequestProto) GetChecked

func (m *SetSafeModeRequestProto) GetChecked() bool

func (*SetSafeModeRequestProto) ProtoMessage

func (*SetSafeModeRequestProto) ProtoMessage()

func (*SetSafeModeRequestProto) Reset

func (m *SetSafeModeRequestProto) Reset()

func (*SetSafeModeRequestProto) String

func (m *SetSafeModeRequestProto) String() string

type SetSafeModeResponseProto

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

func (*SetSafeModeResponseProto) GetResult

func (m *SetSafeModeResponseProto) GetResult() bool

func (*SetSafeModeResponseProto) ProtoMessage

func (*SetSafeModeResponseProto) ProtoMessage()

func (*SetSafeModeResponseProto) Reset

func (m *SetSafeModeResponseProto) Reset()

func (*SetSafeModeResponseProto) String

func (m *SetSafeModeResponseProto) String() string

type SetStoragePolicyRequestProto added in v1.0.0

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

func (*SetStoragePolicyRequestProto) GetPolicyName added in v1.0.0

func (m *SetStoragePolicyRequestProto) GetPolicyName() string

func (*SetStoragePolicyRequestProto) GetSrc added in v1.0.0

func (*SetStoragePolicyRequestProto) ProtoMessage added in v1.0.0

func (*SetStoragePolicyRequestProto) ProtoMessage()

func (*SetStoragePolicyRequestProto) Reset added in v1.0.0

func (m *SetStoragePolicyRequestProto) Reset()

func (*SetStoragePolicyRequestProto) String added in v1.0.0

type SetStoragePolicyResponseProto added in v1.0.0

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

func (*SetStoragePolicyResponseProto) ProtoMessage added in v1.0.0

func (*SetStoragePolicyResponseProto) ProtoMessage()

func (*SetStoragePolicyResponseProto) Reset added in v1.0.0

func (m *SetStoragePolicyResponseProto) Reset()

func (*SetStoragePolicyResponseProto) String added in v1.0.0

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 added in v1.0.0

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 added in v1.0.0

func (m *SetXAttrRequestProto) GetFlag() uint32

func (*SetXAttrRequestProto) GetSrc added in v1.0.0

func (m *SetXAttrRequestProto) GetSrc() string

func (*SetXAttrRequestProto) GetXAttr added in v1.0.0

func (m *SetXAttrRequestProto) GetXAttr() *XAttrProto

func (*SetXAttrRequestProto) ProtoMessage added in v1.0.0

func (*SetXAttrRequestProto) ProtoMessage()

func (*SetXAttrRequestProto) Reset added in v1.0.0

func (m *SetXAttrRequestProto) Reset()

func (*SetXAttrRequestProto) String added in v1.0.0

func (m *SetXAttrRequestProto) String() string

type SetXAttrResponseProto added in v1.0.0

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

func (*SetXAttrResponseProto) ProtoMessage added in v1.0.0

func (*SetXAttrResponseProto) ProtoMessage()

func (*SetXAttrResponseProto) Reset added in v1.0.0

func (m *SetXAttrResponseProto) Reset()

func (*SetXAttrResponseProto) String added in v1.0.0

func (m *SetXAttrResponseProto) String() string

type ShortCircuitFdResponse added in v1.0.0

type ShortCircuitFdResponse int32
const (
	ShortCircuitFdResponse_DO_NOT_USE_RECEIPT_VERIFICATION ShortCircuitFdResponse = 0
	ShortCircuitFdResponse_USE_RECEIPT_VERIFICATION        ShortCircuitFdResponse = 1
)

func (ShortCircuitFdResponse) Enum added in v1.0.0

func (ShortCircuitFdResponse) String added in v1.0.0

func (x ShortCircuitFdResponse) String() string

func (*ShortCircuitFdResponse) UnmarshalJSON added in v1.0.0

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

type ShortCircuitShmIdProto added in v1.0.0

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 added in v1.0.0

func (m *ShortCircuitShmIdProto) GetHi() int64

func (*ShortCircuitShmIdProto) GetLo added in v1.0.0

func (m *ShortCircuitShmIdProto) GetLo() int64

func (*ShortCircuitShmIdProto) ProtoMessage added in v1.0.0

func (*ShortCircuitShmIdProto) ProtoMessage()

func (*ShortCircuitShmIdProto) Reset added in v1.0.0

func (m *ShortCircuitShmIdProto) Reset()

func (*ShortCircuitShmIdProto) String added in v1.0.0

func (m *ShortCircuitShmIdProto) String() string

type ShortCircuitShmRequestProto added in v1.0.0

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"`
	TraceInfo        *DataTransferTraceInfoProto `protobuf:"bytes,2,opt,name=traceInfo" json:"traceInfo,omitempty"`
	XXX_unrecognized []byte                      `json:"-"`
}

func (*ShortCircuitShmRequestProto) GetClientName added in v1.0.0

func (m *ShortCircuitShmRequestProto) GetClientName() string

func (*ShortCircuitShmRequestProto) GetTraceInfo added in v1.0.0

func (*ShortCircuitShmRequestProto) ProtoMessage added in v1.0.0

func (*ShortCircuitShmRequestProto) ProtoMessage()

func (*ShortCircuitShmRequestProto) Reset added in v1.0.0

func (m *ShortCircuitShmRequestProto) Reset()

func (*ShortCircuitShmRequestProto) String added in v1.0.0

func (m *ShortCircuitShmRequestProto) String() string

type ShortCircuitShmResponseProto added in v1.0.0

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 added in v1.0.0

func (m *ShortCircuitShmResponseProto) GetError() string

func (*ShortCircuitShmResponseProto) GetId added in v1.0.0

func (*ShortCircuitShmResponseProto) GetStatus added in v1.0.0

func (m *ShortCircuitShmResponseProto) GetStatus() Status

func (*ShortCircuitShmResponseProto) ProtoMessage added in v1.0.0

func (*ShortCircuitShmResponseProto) ProtoMessage()

func (*ShortCircuitShmResponseProto) Reset added in v1.0.0

func (m *ShortCircuitShmResponseProto) Reset()

func (*ShortCircuitShmResponseProto) String added in v1.0.0

type ShortCircuitShmSlotProto added in v1.0.0

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 added in v1.0.0

func (*ShortCircuitShmSlotProto) GetSlotIdx added in v1.0.0

func (m *ShortCircuitShmSlotProto) GetSlotIdx() int32

func (*ShortCircuitShmSlotProto) ProtoMessage added in v1.0.0

func (*ShortCircuitShmSlotProto) ProtoMessage()

func (*ShortCircuitShmSlotProto) Reset added in v1.0.0

func (m *ShortCircuitShmSlotProto) Reset()

func (*ShortCircuitShmSlotProto) String added in v1.0.0

func (m *ShortCircuitShmSlotProto) String() string

type ShutdownDatanodeRequestProto added in v1.0.0

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 added in v1.0.0

func (m *ShutdownDatanodeRequestProto) GetForUpgrade() bool

func (*ShutdownDatanodeRequestProto) ProtoMessage added in v1.0.0

func (*ShutdownDatanodeRequestProto) ProtoMessage()

func (*ShutdownDatanodeRequestProto) Reset added in v1.0.0

func (m *ShutdownDatanodeRequestProto) Reset()

func (*ShutdownDatanodeRequestProto) String added in v1.0.0

type ShutdownDatanodeResponseProto added in v1.0.0

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

func (*ShutdownDatanodeResponseProto) ProtoMessage added in v1.0.0

func (*ShutdownDatanodeResponseProto) ProtoMessage()

func (*ShutdownDatanodeResponseProto) Reset added in v1.0.0

func (m *ShutdownDatanodeResponseProto) Reset()

func (*ShutdownDatanodeResponseProto) String added in v1.0.0

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 added in v1.0.0

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

func (*SnapshotDiffReportEntryProto) ProtoMessage

func (*SnapshotDiffReportEntryProto) ProtoMessage()

func (*SnapshotDiffReportEntryProto) Reset

func (m *SnapshotDiffReportEntryProto) Reset()

func (*SnapshotDiffReportEntryProto) String

type SnapshotDiffReportProto

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

* Snapshot diff report

func (*SnapshotDiffReportProto) GetDiffReportEntries

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

func (*SnapshotDiffReportProto) GetFromSnapshot

func (m *SnapshotDiffReportProto) GetFromSnapshot() string

func (*SnapshotDiffReportProto) GetSnapshotRoot

func (m *SnapshotDiffReportProto) GetSnapshotRoot() string

func (*SnapshotDiffReportProto) GetToSnapshot

func (m *SnapshotDiffReportProto) GetToSnapshot() string

func (*SnapshotDiffReportProto) ProtoMessage

func (*SnapshotDiffReportProto) ProtoMessage()

func (*SnapshotDiffReportProto) Reset

func (m *SnapshotDiffReportProto) Reset()

func (*SnapshotDiffReportProto) String

func (m *SnapshotDiffReportProto) String() string

type SnapshotInfoProto

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

* Information related to a snapshot TODO: add more information

func (*SnapshotInfoProto) GetCreateTime

func (m *SnapshotInfoProto) GetCreateTime() string

func (*SnapshotInfoProto) GetGroup

func (m *SnapshotInfoProto) GetGroup() string

func (*SnapshotInfoProto) GetOwner

func (m *SnapshotInfoProto) GetOwner() string

func (*SnapshotInfoProto) GetPermission

func (m *SnapshotInfoProto) GetPermission() *FsPermissionProto

func (*SnapshotInfoProto) GetSnapshotName

func (m *SnapshotInfoProto) GetSnapshotName() string

func (*SnapshotInfoProto) GetSnapshotRoot

func (m *SnapshotInfoProto) GetSnapshotRoot() string

func (*SnapshotInfoProto) ProtoMessage

func (*SnapshotInfoProto) ProtoMessage()

func (*SnapshotInfoProto) Reset

func (m *SnapshotInfoProto) Reset()

func (*SnapshotInfoProto) String

func (m *SnapshotInfoProto) String() string

type SnapshottableDirectoryListingProto

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

* Snapshottable directory listing

func (*SnapshottableDirectoryListingProto) GetSnapshottableDirListing

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

func (*SnapshottableDirectoryListingProto) ProtoMessage

func (*SnapshottableDirectoryListingProto) ProtoMessage()

func (*SnapshottableDirectoryListingProto) Reset

func (*SnapshottableDirectoryListingProto) String

type SnapshottableDirectoryStatusProto

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

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

func (*SnapshottableDirectoryStatusProto) GetDirStatus

func (*SnapshottableDirectoryStatusProto) GetParentFullpath

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

func (*SnapshottableDirectoryStatusProto) GetSnapshotNumber

func (m *SnapshottableDirectoryStatusProto) GetSnapshotNumber() uint32

func (*SnapshottableDirectoryStatusProto) GetSnapshotQuota

func (m *SnapshottableDirectoryStatusProto) GetSnapshotQuota() uint32

func (*SnapshottableDirectoryStatusProto) ProtoMessage

func (*SnapshottableDirectoryStatusProto) ProtoMessage()

func (*SnapshottableDirectoryStatusProto) Reset

func (*SnapshottableDirectoryStatusProto) String

type StartReconfigurationRequestProto added in v1.0.0

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

* Asks NN/DN to reload configuration file.

func (*StartReconfigurationRequestProto) ProtoMessage added in v1.0.0

func (*StartReconfigurationRequestProto) ProtoMessage()

func (*StartReconfigurationRequestProto) Reset added in v1.0.0

func (*StartReconfigurationRequestProto) String added in v1.0.0

type StartReconfigurationResponseProto added in v1.0.0

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

func (*StartReconfigurationResponseProto) ProtoMessage added in v1.0.0

func (*StartReconfigurationResponseProto) ProtoMessage()

func (*StartReconfigurationResponseProto) Reset added in v1.0.0

func (*StartReconfigurationResponseProto) String added in v1.0.0

type Status

type Status int32

Status is a 4-bit enum

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
	Status_IN_PROGRESS        Status = 12
)

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 StorageReportProto added in v1.0.0

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

func (*StorageReportProto) GetBlockPoolUsed added in v1.0.0

func (m *StorageReportProto) GetBlockPoolUsed() uint64

func (*StorageReportProto) GetCapacity added in v1.0.0

func (m *StorageReportProto) GetCapacity() uint64

func (*StorageReportProto) GetDfsUsed added in v1.0.0

func (m *StorageReportProto) GetDfsUsed() uint64

func (*StorageReportProto) GetFailed added in v1.0.0

func (m *StorageReportProto) GetFailed() bool

func (*StorageReportProto) GetRemaining added in v1.0.0

func (m *StorageReportProto) GetRemaining() uint64

func (*StorageReportProto) GetStorage added in v1.0.0

func (m *StorageReportProto) GetStorage() *DatanodeStorageProto

func (*StorageReportProto) GetStorageUuid added in v1.0.0

func (m *StorageReportProto) GetStorageUuid() string

func (*StorageReportProto) ProtoMessage added in v1.0.0

func (*StorageReportProto) ProtoMessage()

func (*StorageReportProto) Reset added in v1.0.0

func (m *StorageReportProto) Reset()

func (*StorageReportProto) String added in v1.0.0

func (m *StorageReportProto) String() string

type StorageTypeProto added in v1.0.0

type StorageTypeProto int32

* Types of recognized storage media.

const (
	StorageTypeProto_DISK     StorageTypeProto = 1
	StorageTypeProto_SSD      StorageTypeProto = 2
	StorageTypeProto_ARCHIVE  StorageTypeProto = 3
	StorageTypeProto_RAM_DISK StorageTypeProto = 4
)
const Default_DatanodeStorageProto_StorageType StorageTypeProto = StorageTypeProto_DISK
const Default_OpReplaceBlockProto_StorageType StorageTypeProto = StorageTypeProto_DISK
const Default_OpWriteBlockProto_StorageType StorageTypeProto = StorageTypeProto_DISK

func (StorageTypeProto) Enum added in v1.0.0

func (StorageTypeProto) String added in v1.0.0

func (x StorageTypeProto) String() string

func (*StorageTypeProto) UnmarshalJSON added in v1.0.0

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

type StorageTypeQuotaInfoProto added in v1.0.0

type StorageTypeQuotaInfoProto struct {
	Type             *StorageTypeProto `protobuf:"varint,1,req,name=type,enum=hadoop.hdfs.StorageTypeProto" json:"type,omitempty"`
	Quota            *uint64           `protobuf:"varint,2,req,name=quota" json:"quota,omitempty"`
	Consumed         *uint64           `protobuf:"varint,3,req,name=consumed" json:"consumed,omitempty"`
	XXX_unrecognized []byte            `json:"-"`
}

func (*StorageTypeQuotaInfoProto) GetConsumed added in v1.0.0

func (m *StorageTypeQuotaInfoProto) GetConsumed() uint64

func (*StorageTypeQuotaInfoProto) GetQuota added in v1.0.0

func (m *StorageTypeQuotaInfoProto) GetQuota() uint64

func (*StorageTypeQuotaInfoProto) GetType added in v1.0.0

func (*StorageTypeQuotaInfoProto) ProtoMessage added in v1.0.0

func (*StorageTypeQuotaInfoProto) ProtoMessage()

func (*StorageTypeQuotaInfoProto) Reset added in v1.0.0

func (m *StorageTypeQuotaInfoProto) Reset()

func (*StorageTypeQuotaInfoProto) String added in v1.0.0

func (m *StorageTypeQuotaInfoProto) String() string

type StorageTypeQuotaInfosProto added in v1.0.0

type StorageTypeQuotaInfosProto struct {
	TypeQuotaInfo    []*StorageTypeQuotaInfoProto `protobuf:"bytes,1,rep,name=typeQuotaInfo" json:"typeQuotaInfo,omitempty"`
	XXX_unrecognized []byte                       `json:"-"`
}

* Storage type quota and usage information of a file or directory

func (*StorageTypeQuotaInfosProto) GetTypeQuotaInfo added in v1.0.0

func (m *StorageTypeQuotaInfosProto) GetTypeQuotaInfo() []*StorageTypeQuotaInfoProto

func (*StorageTypeQuotaInfosProto) ProtoMessage added in v1.0.0

func (*StorageTypeQuotaInfosProto) ProtoMessage()

func (*StorageTypeQuotaInfosProto) Reset added in v1.0.0

func (m *StorageTypeQuotaInfosProto) Reset()

func (*StorageTypeQuotaInfosProto) String added in v1.0.0

func (m *StorageTypeQuotaInfosProto) String() string

type StorageTypesProto added in v1.0.0

type StorageTypesProto struct {
	StorageTypes     []StorageTypeProto `protobuf:"varint,1,rep,name=storageTypes,enum=hadoop.hdfs.StorageTypeProto" json:"storageTypes,omitempty"`
	XXX_unrecognized []byte             `json:"-"`
}

* A list of storage types.

func (*StorageTypesProto) GetStorageTypes added in v1.0.0

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

func (*StorageTypesProto) ProtoMessage added in v1.0.0

func (*StorageTypesProto) ProtoMessage()

func (*StorageTypesProto) Reset added in v1.0.0

func (m *StorageTypesProto) Reset()

func (*StorageTypesProto) String added in v1.0.0

func (m *StorageTypesProto) String() string

type StorageUuidsProto added in v1.0.0

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 added in v1.0.0

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

func (*StorageUuidsProto) ProtoMessage added in v1.0.0

func (*StorageUuidsProto) ProtoMessage()

func (*StorageUuidsProto) Reset added in v1.0.0

func (m *StorageUuidsProto) Reset()

func (*StorageUuidsProto) String added in v1.0.0

func (m *StorageUuidsProto) String() string

type TriggerBlockReportRequestProto added in v1.0.0

type TriggerBlockReportRequestProto struct {
	Incremental      *bool  `protobuf:"varint,1,req,name=incremental" json:"incremental,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*TriggerBlockReportRequestProto) GetIncremental added in v1.0.0

func (m *TriggerBlockReportRequestProto) GetIncremental() bool

func (*TriggerBlockReportRequestProto) ProtoMessage added in v1.0.0

func (*TriggerBlockReportRequestProto) ProtoMessage()

func (*TriggerBlockReportRequestProto) Reset added in v1.0.0

func (m *TriggerBlockReportRequestProto) Reset()

func (*TriggerBlockReportRequestProto) String added in v1.0.0

type TriggerBlockReportResponseProto added in v1.0.0

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

func (*TriggerBlockReportResponseProto) ProtoMessage added in v1.0.0

func (*TriggerBlockReportResponseProto) ProtoMessage()

func (*TriggerBlockReportResponseProto) Reset added in v1.0.0

func (*TriggerBlockReportResponseProto) String added in v1.0.0

type TruncateEventProto added in v1.0.0

type TruncateEventProto struct {
	Path             *string `protobuf:"bytes,1,req,name=path" json:"path,omitempty"`
	FileSize         *int64  `protobuf:"varint,2,req,name=fileSize" json:"fileSize,omitempty"`
	Timestamp        *int64  `protobuf:"varint,3,req,name=timestamp" json:"timestamp,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*TruncateEventProto) GetFileSize added in v1.0.0

func (m *TruncateEventProto) GetFileSize() int64

func (*TruncateEventProto) GetPath added in v1.0.0

func (m *TruncateEventProto) GetPath() string

func (*TruncateEventProto) GetTimestamp added in v1.0.0

func (m *TruncateEventProto) GetTimestamp() int64

func (*TruncateEventProto) ProtoMessage added in v1.0.0

func (*TruncateEventProto) ProtoMessage()

func (*TruncateEventProto) Reset added in v1.0.0

func (m *TruncateEventProto) Reset()

func (*TruncateEventProto) String added in v1.0.0

func (m *TruncateEventProto) String() string

type TruncateRequestProto added in v1.0.0

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

func (*TruncateRequestProto) GetClientName added in v1.0.0

func (m *TruncateRequestProto) GetClientName() string

func (*TruncateRequestProto) GetNewLength added in v1.0.0

func (m *TruncateRequestProto) GetNewLength() uint64

func (*TruncateRequestProto) GetSrc added in v1.0.0

func (m *TruncateRequestProto) GetSrc() string

func (*TruncateRequestProto) ProtoMessage added in v1.0.0

func (*TruncateRequestProto) ProtoMessage()

func (*TruncateRequestProto) Reset added in v1.0.0

func (m *TruncateRequestProto) Reset()

func (*TruncateRequestProto) String added in v1.0.0

func (m *TruncateRequestProto) String() string

type TruncateResponseProto added in v1.0.0

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

func (*TruncateResponseProto) GetResult added in v1.0.0

func (m *TruncateResponseProto) GetResult() bool

func (*TruncateResponseProto) ProtoMessage added in v1.0.0

func (*TruncateResponseProto) ProtoMessage()

func (*TruncateResponseProto) Reset added in v1.0.0

func (m *TruncateResponseProto) Reset()

func (*TruncateResponseProto) String added in v1.0.0

func (m *TruncateResponseProto) String() string

type UnlinkEventProto added in v1.0.0

type UnlinkEventProto struct {
	Path             *string `protobuf:"bytes,1,req,name=path" json:"path,omitempty"`
	Timestamp        *int64  `protobuf:"varint,2,req,name=timestamp" json:"timestamp,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*UnlinkEventProto) GetPath added in v1.0.0

func (m *UnlinkEventProto) GetPath() string

func (*UnlinkEventProto) GetTimestamp added in v1.0.0

func (m *UnlinkEventProto) GetTimestamp() int64

func (*UnlinkEventProto) ProtoMessage added in v1.0.0

func (*UnlinkEventProto) ProtoMessage()

func (*UnlinkEventProto) Reset added in v1.0.0

func (m *UnlinkEventProto) Reset()

func (*UnlinkEventProto) String added in v1.0.0

func (m *UnlinkEventProto) String() string

type UnsetStoragePolicyRequestProto added in v1.0.0

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

func (*UnsetStoragePolicyRequestProto) GetSrc added in v1.0.0

func (*UnsetStoragePolicyRequestProto) ProtoMessage added in v1.0.0

func (*UnsetStoragePolicyRequestProto) ProtoMessage()

func (*UnsetStoragePolicyRequestProto) Reset added in v1.0.0

func (m *UnsetStoragePolicyRequestProto) Reset()

func (*UnsetStoragePolicyRequestProto) String added in v1.0.0

type UnsetStoragePolicyResponseProto added in v1.0.0

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

func (*UnsetStoragePolicyResponseProto) ProtoMessage added in v1.0.0

func (*UnsetStoragePolicyResponseProto) ProtoMessage()

func (*UnsetStoragePolicyResponseProto) Reset added in v1.0.0

func (*UnsetStoragePolicyResponseProto) String added in v1.0.0

type UpdateBlockForPipelineRequestProto

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

func (*UpdateBlockForPipelineRequestProto) GetBlock

func (*UpdateBlockForPipelineRequestProto) GetClientName

func (m *UpdateBlockForPipelineRequestProto) GetClientName() string

func (*UpdateBlockForPipelineRequestProto) ProtoMessage

func (*UpdateBlockForPipelineRequestProto) ProtoMessage()

func (*UpdateBlockForPipelineRequestProto) Reset

func (*UpdateBlockForPipelineRequestProto) String

type UpdateBlockForPipelineResponseProto

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

func (*UpdateBlockForPipelineResponseProto) GetBlock

func (*UpdateBlockForPipelineResponseProto) ProtoMessage

func (*UpdateBlockForPipelineResponseProto) ProtoMessage()

func (*UpdateBlockForPipelineResponseProto) Reset

func (*UpdateBlockForPipelineResponseProto) String

type UpdatePipelineRequestProto

type UpdatePipelineRequestProto struct {
	ClientName       *string             `protobuf:"bytes,1,req,name=clientName" json:"clientName,omitempty"`
	OldBlock         *ExtendedBlockProto `protobuf:"bytes,2,req,name=oldBlock" json:"oldBlock,omitempty"`
	NewBlock         *ExtendedBlockProto `protobuf:"bytes,3,req,name=newBlock" json:"newBlock,omitempty"`
	NewNodes         []*DatanodeIDProto  `protobuf:"bytes,4,rep,name=newNodes" json:"newNodes,omitempty"`
	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 (*UpdatePipelineRequestProto) GetNewNodes

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

func (*UpdatePipelineRequestProto) GetOldBlock

func (*UpdatePipelineRequestProto) GetStorageIDs added in v1.0.0

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 XAttrProto added in v1.0.0

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 added in v1.0.0

func (m *XAttrProto) GetName() string

func (*XAttrProto) GetNamespace added in v1.0.0

func (m *XAttrProto) GetNamespace() XAttrProto_XAttrNamespaceProto

func (*XAttrProto) GetValue added in v1.0.0

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

func (*XAttrProto) ProtoMessage added in v1.0.0

func (*XAttrProto) ProtoMessage()

func (*XAttrProto) Reset added in v1.0.0

func (m *XAttrProto) Reset()

func (*XAttrProto) String added in v1.0.0

func (m *XAttrProto) String() string

type XAttrProto_XAttrNamespaceProto added in v1.0.0

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
	XAttrProto_RAW      XAttrProto_XAttrNamespaceProto = 4
)

func (XAttrProto_XAttrNamespaceProto) Enum added in v1.0.0

func (XAttrProto_XAttrNamespaceProto) String added in v1.0.0

func (*XAttrProto_XAttrNamespaceProto) UnmarshalJSON added in v1.0.0

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

type XAttrSetFlagProto added in v1.0.0

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

func (XAttrSetFlagProto) Enum added in v1.0.0

func (XAttrSetFlagProto) String added in v1.0.0

func (x XAttrSetFlagProto) String() string

func (*XAttrSetFlagProto) UnmarshalJSON added in v1.0.0

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

type ZoneEncryptionInfoProto added in v1.0.0

type ZoneEncryptionInfoProto struct {
	Suite                 *CipherSuiteProto           `protobuf:"varint,1,req,name=suite,enum=hadoop.hdfs.CipherSuiteProto" json:"suite,omitempty"`
	CryptoProtocolVersion *CryptoProtocolVersionProto `` /* 133-byte string literal not displayed */
	KeyName               *string                     `protobuf:"bytes,3,req,name=keyName" json:"keyName,omitempty"`
	XXX_unrecognized      []byte                      `json:"-"`
}

* Encryption information for an encryption zone

func (*ZoneEncryptionInfoProto) GetCryptoProtocolVersion added in v1.0.0

func (m *ZoneEncryptionInfoProto) GetCryptoProtocolVersion() CryptoProtocolVersionProto

func (*ZoneEncryptionInfoProto) GetKeyName added in v1.0.0

func (m *ZoneEncryptionInfoProto) GetKeyName() string

func (*ZoneEncryptionInfoProto) GetSuite added in v1.0.0

func (*ZoneEncryptionInfoProto) ProtoMessage added in v1.0.0

func (*ZoneEncryptionInfoProto) ProtoMessage()

func (*ZoneEncryptionInfoProto) Reset added in v1.0.0

func (m *ZoneEncryptionInfoProto) Reset()

func (*ZoneEncryptionInfoProto) String added in v1.0.0

func (m *ZoneEncryptionInfoProto) String() string

Jump to

Keyboard shortcuts

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