hadoop_hdfs

package
v2.0.1-0...-3567f9a Latest Latest
Warning

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

Go to latest
Published: Jun 9, 2020 License: MIT Imports: 4 Imported by: 0

Documentation

Overview

Package hadoop_hdfs is a generated protocol buffer package.

It is generated from these files:

ReconfigurationProtocol.proto
xattr.proto
encryption.proto
erasurecoding.proto
ClientNamenodeProtocol.proto
datatransfer.proto
ClientDatanodeProtocol.proto
inotify.proto
hdfs.proto
acl.proto

It has these top-level messages:

StartReconfigurationRequestProto
StartReconfigurationResponseProto
GetReconfigurationStatusRequestProto
GetReconfigurationStatusConfigChangeProto
GetReconfigurationStatusResponseProto
ListReconfigurablePropertiesRequestProto
ListReconfigurablePropertiesResponseProto
XAttrProto
SetXAttrRequestProto
SetXAttrResponseProto
GetXAttrsRequestProto
GetXAttrsResponseProto
ListXAttrsRequestProto
ListXAttrsResponseProto
RemoveXAttrRequestProto
RemoveXAttrResponseProto
CreateEncryptionZoneRequestProto
CreateEncryptionZoneResponseProto
ListEncryptionZonesRequestProto
EncryptionZoneProto
ListEncryptionZonesResponseProto
GetEZForPathRequestProto
GetEZForPathResponseProto
SetErasureCodingPolicyRequestProto
SetErasureCodingPolicyResponseProto
GetErasureCodingPoliciesRequestProto
GetErasureCodingPoliciesResponseProto
GetErasureCodingPolicyRequestProto
GetErasureCodingPolicyResponseProto
BlockECReconstructionInfoProto
GetBlockLocationsRequestProto
GetBlockLocationsResponseProto
GetServerDefaultsRequestProto
GetServerDefaultsResponseProto
CreateRequestProto
CreateResponseProto
AppendRequestProto
AppendResponseProto
SetReplicationRequestProto
SetReplicationResponseProto
SetStoragePolicyRequestProto
SetStoragePolicyResponseProto
UnsetStoragePolicyRequestProto
UnsetStoragePolicyResponseProto
GetStoragePolicyRequestProto
GetStoragePolicyResponseProto
GetStoragePoliciesRequestProto
GetStoragePoliciesResponseProto
SetPermissionRequestProto
SetPermissionResponseProto
SetOwnerRequestProto
SetOwnerResponseProto
AbandonBlockRequestProto
AbandonBlockResponseProto
AddBlockRequestProto
AddBlockResponseProto
GetAdditionalDatanodeRequestProto
GetAdditionalDatanodeResponseProto
CompleteRequestProto
CompleteResponseProto
ReportBadBlocksRequestProto
ReportBadBlocksResponseProto
ConcatRequestProto
ConcatResponseProto
TruncateRequestProto
TruncateResponseProto
RenameRequestProto
RenameResponseProto
Rename2RequestProto
Rename2ResponseProto
DeleteRequestProto
DeleteResponseProto
MkdirsRequestProto
MkdirsResponseProto
GetListingRequestProto
GetListingResponseProto
GetSnapshottableDirListingRequestProto
GetSnapshottableDirListingResponseProto
GetSnapshotDiffReportRequestProto
GetSnapshotDiffReportResponseProto
RenewLeaseRequestProto
RenewLeaseResponseProto
RecoverLeaseRequestProto
RecoverLeaseResponseProto
GetFsStatusRequestProto
GetFsStatsResponseProto
GetDatanodeReportRequestProto
GetDatanodeReportResponseProto
GetDatanodeStorageReportRequestProto
DatanodeStorageReportProto
GetDatanodeStorageReportResponseProto
GetPreferredBlockSizeRequestProto
GetPreferredBlockSizeResponseProto
SetSafeModeRequestProto
SetSafeModeResponseProto
SaveNamespaceRequestProto
SaveNamespaceResponseProto
RollEditsRequestProto
RollEditsResponseProto
RestoreFailedStorageRequestProto
RestoreFailedStorageResponseProto
RefreshNodesRequestProto
RefreshNodesResponseProto
FinalizeUpgradeRequestProto
FinalizeUpgradeResponseProto
RollingUpgradeRequestProto
RollingUpgradeInfoProto
RollingUpgradeResponseProto
ListCorruptFileBlocksRequestProto
ListCorruptFileBlocksResponseProto
MetaSaveRequestProto
MetaSaveResponseProto
GetFileInfoRequestProto
GetFileInfoResponseProto
IsFileClosedRequestProto
IsFileClosedResponseProto
CacheDirectiveInfoProto
CacheDirectiveInfoExpirationProto
CacheDirectiveStatsProto
AddCacheDirectiveRequestProto
AddCacheDirectiveResponseProto
ModifyCacheDirectiveRequestProto
ModifyCacheDirectiveResponseProto
RemoveCacheDirectiveRequestProto
RemoveCacheDirectiveResponseProto
ListCacheDirectivesRequestProto
CacheDirectiveEntryProto
ListCacheDirectivesResponseProto
CachePoolInfoProto
CachePoolStatsProto
AddCachePoolRequestProto
AddCachePoolResponseProto
ModifyCachePoolRequestProto
ModifyCachePoolResponseProto
RemoveCachePoolRequestProto
RemoveCachePoolResponseProto
ListCachePoolsRequestProto
ListCachePoolsResponseProto
CachePoolEntryProto
GetFileLinkInfoRequestProto
GetFileLinkInfoResponseProto
GetContentSummaryRequestProto
GetContentSummaryResponseProto
GetQuotaUsageRequestProto
GetQuotaUsageResponseProto
SetQuotaRequestProto
SetQuotaResponseProto
FsyncRequestProto
FsyncResponseProto
SetTimesRequestProto
SetTimesResponseProto
CreateSymlinkRequestProto
CreateSymlinkResponseProto
GetLinkTargetRequestProto
GetLinkTargetResponseProto
UpdateBlockForPipelineRequestProto
UpdateBlockForPipelineResponseProto
UpdatePipelineRequestProto
UpdatePipelineResponseProto
SetBalancerBandwidthRequestProto
SetBalancerBandwidthResponseProto
GetDataEncryptionKeyRequestProto
GetDataEncryptionKeyResponseProto
CreateSnapshotRequestProto
CreateSnapshotResponseProto
RenameSnapshotRequestProto
RenameSnapshotResponseProto
AllowSnapshotRequestProto
AllowSnapshotResponseProto
DisallowSnapshotRequestProto
DisallowSnapshotResponseProto
DeleteSnapshotRequestProto
DeleteSnapshotResponseProto
CheckAccessRequestProto
CheckAccessResponseProto
GetCurrentEditLogTxidRequestProto
GetCurrentEditLogTxidResponseProto
GetEditsFromTxidRequestProto
GetEditsFromTxidResponseProto
DataTransferEncryptorMessageProto
BaseHeaderProto
DataTransferTraceInfoProto
ClientOperationHeaderProto
CachingStrategyProto
OpReadBlockProto
ChecksumProto
OpWriteBlockProto
OpTransferBlockProto
OpReplaceBlockProto
OpCopyBlockProto
OpBlockChecksumProto
OpBlockGroupChecksumProto
ShortCircuitShmIdProto
ShortCircuitShmSlotProto
OpRequestShortCircuitAccessProto
ReleaseShortCircuitAccessRequestProto
ReleaseShortCircuitAccessResponseProto
ShortCircuitShmRequestProto
ShortCircuitShmResponseProto
PacketHeaderProto
PipelineAckProto
ReadOpChecksumInfoProto
BlockOpResponseProto
ClientReadStatusProto
DNTransferAckProto
OpBlockChecksumResponseProto
OpCustomProto
GetReplicaVisibleLengthRequestProto
GetReplicaVisibleLengthResponseProto
RefreshNamenodesRequestProto
RefreshNamenodesResponseProto
DeleteBlockPoolRequestProto
DeleteBlockPoolResponseProto
GetBlockLocalPathInfoRequestProto
GetBlockLocalPathInfoResponseProto
ShutdownDatanodeRequestProto
ShutdownDatanodeResponseProto
EvictWritersRequestProto
EvictWritersResponseProto
GetDatanodeInfoRequestProto
GetDatanodeInfoResponseProto
TriggerBlockReportRequestProto
TriggerBlockReportResponseProto
GetBalancerBandwidthRequestProto
GetBalancerBandwidthResponseProto
EventProto
EventBatchProto
CreateEventProto
CloseEventProto
TruncateEventProto
AppendEventProto
RenameEventProto
MetadataUpdateEventProto
UnlinkEventProto
EventsListProto
ExtendedBlockProto
DatanodeIDProto
DatanodeLocalInfoProto
DatanodeInfosProto
DatanodeInfoProto
DatanodeStorageProto
StorageReportProto
ContentSummaryProto
QuotaUsageProto
StorageTypeQuotaInfosProto
StorageTypeQuotaInfoProto
CorruptFileBlocksProto
FsPermissionProto
StorageTypesProto
BlockStoragePolicyProto
LocatedBlockProto
DataEncryptionKeyProto
FileEncryptionInfoProto
PerFileEncryptionInfoProto
ZoneEncryptionInfoProto
CipherOptionProto
LocatedBlocksProto
ECSchemaOptionEntryProto
ECSchemaProto
ErasureCodingPolicyProto
HdfsFileStatusProto
FsServerDefaultsProto
DirectoryListingProto
SnapshottableDirectoryStatusProto
SnapshottableDirectoryListingProto
SnapshotDiffReportEntryProto
SnapshotDiffReportProto
BlockProto
SnapshotInfoProto
RollingUpgradeStatusProto
StorageUuidsProto
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) Descriptor

func (*AbandonBlockRequestProto) Descriptor() ([]byte, []int)

func (*AbandonBlockRequestProto) GetB

func (*AbandonBlockRequestProto) GetFileId

func (m *AbandonBlockRequestProto) GetFileId() uint64

func (*AbandonBlockRequestProto) GetHolder

func (m *AbandonBlockRequestProto) GetHolder() string

func (*AbandonBlockRequestProto) GetSrc

func (m *AbandonBlockRequestProto) GetSrc() string

func (*AbandonBlockRequestProto) ProtoMessage

func (*AbandonBlockRequestProto) ProtoMessage()

func (*AbandonBlockRequestProto) Reset

func (m *AbandonBlockRequestProto) Reset()

func (*AbandonBlockRequestProto) String

func (m *AbandonBlockRequestProto) String() string

type AbandonBlockResponseProto

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

func (*AbandonBlockResponseProto) Descriptor

func (*AbandonBlockResponseProto) Descriptor() ([]byte, []int)

func (*AbandonBlockResponseProto) ProtoMessage

func (*AbandonBlockResponseProto) ProtoMessage()

func (*AbandonBlockResponseProto) Reset

func (m *AbandonBlockResponseProto) Reset()

func (*AbandonBlockResponseProto) String

func (m *AbandonBlockResponseProto) String() string

type AclEntryProto

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

func (*AclEntryProto) Descriptor

func (*AclEntryProto) Descriptor() ([]byte, []int)

func (*AclEntryProto) GetName

func (m *AclEntryProto) GetName() string

func (*AclEntryProto) GetPermissions

func (m *AclEntryProto) GetPermissions() AclEntryProto_FsActionProto

func (*AclEntryProto) GetScope

func (*AclEntryProto) GetType

func (*AclEntryProto) ProtoMessage

func (*AclEntryProto) ProtoMessage()

func (*AclEntryProto) Reset

func (m *AclEntryProto) Reset()

func (*AclEntryProto) String

func (m *AclEntryProto) String() string

type AclEntryProto_AclEntryScopeProto

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

func (AclEntryProto_AclEntryScopeProto) Enum

func (AclEntryProto_AclEntryScopeProto) EnumDescriptor

func (AclEntryProto_AclEntryScopeProto) EnumDescriptor() ([]byte, []int)

func (AclEntryProto_AclEntryScopeProto) String

func (*AclEntryProto_AclEntryScopeProto) UnmarshalJSON

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

type AclEntryProto_AclEntryTypeProto

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

func (AclEntryProto_AclEntryTypeProto) Enum

func (AclEntryProto_AclEntryTypeProto) EnumDescriptor

func (AclEntryProto_AclEntryTypeProto) EnumDescriptor() ([]byte, []int)

func (AclEntryProto_AclEntryTypeProto) String

func (*AclEntryProto_AclEntryTypeProto) UnmarshalJSON

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

type AclEntryProto_FsActionProto

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

func (AclEntryProto_FsActionProto) Enum

func (AclEntryProto_FsActionProto) EnumDescriptor

func (AclEntryProto_FsActionProto) EnumDescriptor() ([]byte, []int)

func (AclEntryProto_FsActionProto) String

func (*AclEntryProto_FsActionProto) UnmarshalJSON

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

type AclStatusProto

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

func (*AclStatusProto) Descriptor

func (*AclStatusProto) Descriptor() ([]byte, []int)

func (*AclStatusProto) GetEntries

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

func (*AclStatusProto) GetGroup

func (m *AclStatusProto) GetGroup() string

func (*AclStatusProto) GetOwner

func (m *AclStatusProto) GetOwner() string

func (*AclStatusProto) GetPermission

func (m *AclStatusProto) GetPermission() *FsPermissionProto

func (*AclStatusProto) GetSticky

func (m *AclStatusProto) GetSticky() bool

func (*AclStatusProto) ProtoMessage

func (*AclStatusProto) ProtoMessage()

func (*AclStatusProto) Reset

func (m *AclStatusProto) Reset()

func (*AclStatusProto) String

func (m *AclStatusProto) String() string

type 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) Descriptor

func (*AddBlockRequestProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*AddBlockResponseProto) Descriptor() ([]byte, []int)

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

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) Descriptor

func (*AddCacheDirectiveRequestProto) Descriptor() ([]byte, []int)

func (*AddCacheDirectiveRequestProto) GetCacheFlags

func (m *AddCacheDirectiveRequestProto) GetCacheFlags() uint32

func (*AddCacheDirectiveRequestProto) GetInfo

func (*AddCacheDirectiveRequestProto) ProtoMessage

func (*AddCacheDirectiveRequestProto) ProtoMessage()

func (*AddCacheDirectiveRequestProto) Reset

func (m *AddCacheDirectiveRequestProto) Reset()

func (*AddCacheDirectiveRequestProto) String

type AddCacheDirectiveResponseProto

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

func (*AddCacheDirectiveResponseProto) Descriptor

func (*AddCacheDirectiveResponseProto) Descriptor() ([]byte, []int)

func (*AddCacheDirectiveResponseProto) GetId

func (*AddCacheDirectiveResponseProto) ProtoMessage

func (*AddCacheDirectiveResponseProto) ProtoMessage()

func (*AddCacheDirectiveResponseProto) Reset

func (m *AddCacheDirectiveResponseProto) Reset()

func (*AddCacheDirectiveResponseProto) String

type AddCachePoolRequestProto

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

func (*AddCachePoolRequestProto) Descriptor

func (*AddCachePoolRequestProto) Descriptor() ([]byte, []int)

func (*AddCachePoolRequestProto) GetInfo

func (*AddCachePoolRequestProto) ProtoMessage

func (*AddCachePoolRequestProto) ProtoMessage()

func (*AddCachePoolRequestProto) Reset

func (m *AddCachePoolRequestProto) Reset()

func (*AddCachePoolRequestProto) String

func (m *AddCachePoolRequestProto) String() string

type AddCachePoolResponseProto

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

func (*AddCachePoolResponseProto) Descriptor

func (*AddCachePoolResponseProto) Descriptor() ([]byte, []int)

func (*AddCachePoolResponseProto) ProtoMessage

func (*AddCachePoolResponseProto) ProtoMessage()

func (*AddCachePoolResponseProto) Reset

func (m *AddCachePoolResponseProto) Reset()

func (*AddCachePoolResponseProto) String

func (m *AddCachePoolResponseProto) String() string

type AllowSnapshotRequestProto

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

func (*AllowSnapshotRequestProto) Descriptor

func (*AllowSnapshotRequestProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*AllowSnapshotResponseProto) Descriptor() ([]byte, []int)

func (*AllowSnapshotResponseProto) ProtoMessage

func (*AllowSnapshotResponseProto) ProtoMessage()

func (*AllowSnapshotResponseProto) Reset

func (m *AllowSnapshotResponseProto) Reset()

func (*AllowSnapshotResponseProto) String

func (m *AllowSnapshotResponseProto) String() string

type AppendEventProto

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) Descriptor

func (*AppendEventProto) Descriptor() ([]byte, []int)

func (*AppendEventProto) GetNewBlock

func (m *AppendEventProto) GetNewBlock() bool

func (*AppendEventProto) GetPath

func (m *AppendEventProto) GetPath() string

func (*AppendEventProto) ProtoMessage

func (*AppendEventProto) ProtoMessage()

func (*AppendEventProto) Reset

func (m *AppendEventProto) Reset()

func (*AppendEventProto) String

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) Descriptor

func (*AppendRequestProto) Descriptor() ([]byte, []int)

func (*AppendRequestProto) GetClientName

func (m *AppendRequestProto) GetClientName() string

func (*AppendRequestProto) GetFlag

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) Descriptor

func (*AppendResponseProto) Descriptor() ([]byte, []int)

func (*AppendResponseProto) GetBlock

func (m *AppendResponseProto) GetBlock() *LocatedBlockProto

func (*AppendResponseProto) GetStat

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) Descriptor

func (*BaseHeaderProto) Descriptor() ([]byte, []int)

func (*BaseHeaderProto) GetBlock

func (m *BaseHeaderProto) GetBlock() *ExtendedBlockProto

func (*BaseHeaderProto) GetToken

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

func (*BaseHeaderProto) GetTraceInfo

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

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) Descriptor

func (*BlockECReconstructionInfoProto) Descriptor() ([]byte, []int)

func (*BlockECReconstructionInfoProto) GetBlock

func (*BlockECReconstructionInfoProto) GetEcPolicy

func (*BlockECReconstructionInfoProto) GetLiveBlockIndices

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

func (*BlockECReconstructionInfoProto) GetSourceDnInfos

func (m *BlockECReconstructionInfoProto) GetSourceDnInfos() *DatanodeInfosProto

func (*BlockECReconstructionInfoProto) GetTargetDnInfos

func (m *BlockECReconstructionInfoProto) GetTargetDnInfos() *DatanodeInfosProto

func (*BlockECReconstructionInfoProto) GetTargetStorageTypes

func (m *BlockECReconstructionInfoProto) GetTargetStorageTypes() *StorageTypesProto

func (*BlockECReconstructionInfoProto) GetTargetStorageUuids

func (m *BlockECReconstructionInfoProto) GetTargetStorageUuids() *StorageUuidsProto

func (*BlockECReconstructionInfoProto) ProtoMessage

func (*BlockECReconstructionInfoProto) ProtoMessage()

func (*BlockECReconstructionInfoProto) Reset

func (m *BlockECReconstructionInfoProto) Reset()

func (*BlockECReconstructionInfoProto) String

type BlockOpResponseProto

type BlockOpResponseProto struct {
	Status             *Status                       `protobuf:"varint,1,req,name=status,enum=hadoop.hdfs.Status" json:"status,omitempty"`
	FirstBadLink       *string                       `protobuf:"bytes,2,opt,name=firstBadLink" json:"firstBadLink,omitempty"`
	ChecksumResponse   *OpBlockChecksumResponseProto `protobuf:"bytes,3,opt,name=checksumResponse" json:"checksumResponse,omitempty"`
	ReadOpChecksumInfo *ReadOpChecksumInfoProto      `protobuf:"bytes,4,opt,name=readOpChecksumInfo" json:"readOpChecksumInfo,omitempty"`
	// * explanatory text which may be useful to log on the client side
	Message *string `protobuf:"bytes,5,opt,name=message" json:"message,omitempty"`
	// * If the server chooses to agree to the request of a client for
	// short-circuit access, it will send a response message with the relevant
	// file descriptors attached.
	//
	// In the body of the message, this version number will be set to the
	// specific version number of the block data that the client is about to
	// read.
	ShortCircuitAccessVersion *uint32 `protobuf:"varint,6,opt,name=shortCircuitAccessVersion" json:"shortCircuitAccessVersion,omitempty"`
	XXX_unrecognized          []byte  `json:"-"`
}

func (*BlockOpResponseProto) Descriptor

func (*BlockOpResponseProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*BlockProto) Descriptor() ([]byte, []int)

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

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) Descriptor

func (*BlockStoragePolicyProto) Descriptor() ([]byte, []int)

func (*BlockStoragePolicyProto) GetCreationFallbackPolicy

func (m *BlockStoragePolicyProto) GetCreationFallbackPolicy() *StorageTypesProto

func (*BlockStoragePolicyProto) GetCreationPolicy

func (m *BlockStoragePolicyProto) GetCreationPolicy() *StorageTypesProto

func (*BlockStoragePolicyProto) GetName

func (m *BlockStoragePolicyProto) GetName() string

func (*BlockStoragePolicyProto) GetPolicyId

func (m *BlockStoragePolicyProto) GetPolicyId() uint32

func (*BlockStoragePolicyProto) GetReplicationFallbackPolicy

func (m *BlockStoragePolicyProto) GetReplicationFallbackPolicy() *StorageTypesProto

func (*BlockStoragePolicyProto) ProtoMessage

func (*BlockStoragePolicyProto) ProtoMessage()

func (*BlockStoragePolicyProto) Reset

func (m *BlockStoragePolicyProto) Reset()

func (*BlockStoragePolicyProto) String

func (m *BlockStoragePolicyProto) String() string

type CacheDirectiveEntryProto

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

func (*CacheDirectiveEntryProto) Descriptor

func (*CacheDirectiveEntryProto) Descriptor() ([]byte, []int)

func (*CacheDirectiveEntryProto) GetInfo

func (*CacheDirectiveEntryProto) GetStats

func (*CacheDirectiveEntryProto) ProtoMessage

func (*CacheDirectiveEntryProto) ProtoMessage()

func (*CacheDirectiveEntryProto) Reset

func (m *CacheDirectiveEntryProto) Reset()

func (*CacheDirectiveEntryProto) String

func (m *CacheDirectiveEntryProto) String() string

type CacheDirectiveInfoExpirationProto

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

func (*CacheDirectiveInfoExpirationProto) Descriptor

func (*CacheDirectiveInfoExpirationProto) Descriptor() ([]byte, []int)

func (*CacheDirectiveInfoExpirationProto) GetIsRelative

func (m *CacheDirectiveInfoExpirationProto) GetIsRelative() bool

func (*CacheDirectiveInfoExpirationProto) GetMillis

func (*CacheDirectiveInfoExpirationProto) ProtoMessage

func (*CacheDirectiveInfoExpirationProto) ProtoMessage()

func (*CacheDirectiveInfoExpirationProto) Reset

func (*CacheDirectiveInfoExpirationProto) String

type CacheDirectiveInfoProto

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

func (*CacheDirectiveInfoProto) Descriptor

func (*CacheDirectiveInfoProto) Descriptor() ([]byte, []int)

func (*CacheDirectiveInfoProto) GetExpiration

func (*CacheDirectiveInfoProto) GetId

func (m *CacheDirectiveInfoProto) GetId() int64

func (*CacheDirectiveInfoProto) GetPath

func (m *CacheDirectiveInfoProto) GetPath() string

func (*CacheDirectiveInfoProto) GetPool

func (m *CacheDirectiveInfoProto) GetPool() string

func (*CacheDirectiveInfoProto) GetReplication

func (m *CacheDirectiveInfoProto) GetReplication() uint32

func (*CacheDirectiveInfoProto) ProtoMessage

func (*CacheDirectiveInfoProto) ProtoMessage()

func (*CacheDirectiveInfoProto) Reset

func (m *CacheDirectiveInfoProto) Reset()

func (*CacheDirectiveInfoProto) String

func (m *CacheDirectiveInfoProto) String() string

type CacheDirectiveStatsProto

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

func (*CacheDirectiveStatsProto) Descriptor

func (*CacheDirectiveStatsProto) Descriptor() ([]byte, []int)

func (*CacheDirectiveStatsProto) GetBytesCached

func (m *CacheDirectiveStatsProto) GetBytesCached() int64

func (*CacheDirectiveStatsProto) GetBytesNeeded

func (m *CacheDirectiveStatsProto) GetBytesNeeded() int64

func (*CacheDirectiveStatsProto) GetFilesCached

func (m *CacheDirectiveStatsProto) GetFilesCached() int64

func (*CacheDirectiveStatsProto) GetFilesNeeded

func (m *CacheDirectiveStatsProto) GetFilesNeeded() int64

func (*CacheDirectiveStatsProto) GetHasExpired

func (m *CacheDirectiveStatsProto) GetHasExpired() bool

func (*CacheDirectiveStatsProto) ProtoMessage

func (*CacheDirectiveStatsProto) ProtoMessage()

func (*CacheDirectiveStatsProto) Reset

func (m *CacheDirectiveStatsProto) Reset()

func (*CacheDirectiveStatsProto) String

func (m *CacheDirectiveStatsProto) String() string

type CacheFlagProto

type CacheFlagProto int32
const (
	CacheFlagProto_FORCE CacheFlagProto = 1
)

func (CacheFlagProto) Enum

func (x CacheFlagProto) Enum() *CacheFlagProto

func (CacheFlagProto) EnumDescriptor

func (CacheFlagProto) EnumDescriptor() ([]byte, []int)

func (CacheFlagProto) String

func (x CacheFlagProto) String() string

func (*CacheFlagProto) UnmarshalJSON

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

type CachePoolEntryProto

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

func (*CachePoolEntryProto) Descriptor

func (*CachePoolEntryProto) Descriptor() ([]byte, []int)

func (*CachePoolEntryProto) GetInfo

func (*CachePoolEntryProto) GetStats

func (*CachePoolEntryProto) ProtoMessage

func (*CachePoolEntryProto) ProtoMessage()

func (*CachePoolEntryProto) Reset

func (m *CachePoolEntryProto) Reset()

func (*CachePoolEntryProto) String

func (m *CachePoolEntryProto) String() string

type CachePoolInfoProto

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

func (*CachePoolInfoProto) Descriptor

func (*CachePoolInfoProto) Descriptor() ([]byte, []int)

func (*CachePoolInfoProto) GetGroupName

func (m *CachePoolInfoProto) GetGroupName() string

func (*CachePoolInfoProto) GetLimit

func (m *CachePoolInfoProto) GetLimit() int64

func (*CachePoolInfoProto) GetMaxRelativeExpiry

func (m *CachePoolInfoProto) GetMaxRelativeExpiry() int64

func (*CachePoolInfoProto) GetMode

func (m *CachePoolInfoProto) GetMode() int32

func (*CachePoolInfoProto) GetOwnerName

func (m *CachePoolInfoProto) GetOwnerName() string

func (*CachePoolInfoProto) GetPoolName

func (m *CachePoolInfoProto) GetPoolName() string

func (*CachePoolInfoProto) ProtoMessage

func (*CachePoolInfoProto) ProtoMessage()

func (*CachePoolInfoProto) Reset

func (m *CachePoolInfoProto) Reset()

func (*CachePoolInfoProto) String

func (m *CachePoolInfoProto) String() string

type CachePoolStatsProto

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

func (*CachePoolStatsProto) Descriptor

func (*CachePoolStatsProto) Descriptor() ([]byte, []int)

func (*CachePoolStatsProto) GetBytesCached

func (m *CachePoolStatsProto) GetBytesCached() int64

func (*CachePoolStatsProto) GetBytesNeeded

func (m *CachePoolStatsProto) GetBytesNeeded() int64

func (*CachePoolStatsProto) GetBytesOverlimit

func (m *CachePoolStatsProto) GetBytesOverlimit() int64

func (*CachePoolStatsProto) GetFilesCached

func (m *CachePoolStatsProto) GetFilesCached() int64

func (*CachePoolStatsProto) GetFilesNeeded

func (m *CachePoolStatsProto) GetFilesNeeded() int64

func (*CachePoolStatsProto) ProtoMessage

func (*CachePoolStatsProto) ProtoMessage()

func (*CachePoolStatsProto) Reset

func (m *CachePoolStatsProto) Reset()

func (*CachePoolStatsProto) String

func (m *CachePoolStatsProto) String() string

type CachingStrategyProto

type CachingStrategyProto struct {
	DropBehind       *bool  `protobuf:"varint,1,opt,name=dropBehind" json:"dropBehind,omitempty"`
	Readahead        *int64 `protobuf:"varint,2,opt,name=readahead" json:"readahead,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*CachingStrategyProto) Descriptor

func (*CachingStrategyProto) Descriptor() ([]byte, []int)

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

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) Descriptor

func (*CheckAccessRequestProto) Descriptor() ([]byte, []int)

func (*CheckAccessRequestProto) GetMode

func (*CheckAccessRequestProto) GetPath

func (m *CheckAccessRequestProto) GetPath() string

func (*CheckAccessRequestProto) ProtoMessage

func (*CheckAccessRequestProto) ProtoMessage()

func (*CheckAccessRequestProto) Reset

func (m *CheckAccessRequestProto) Reset()

func (*CheckAccessRequestProto) String

func (m *CheckAccessRequestProto) String() string

type CheckAccessResponseProto

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

func (*CheckAccessResponseProto) Descriptor

func (*CheckAccessResponseProto) Descriptor() ([]byte, []int)

func (*CheckAccessResponseProto) ProtoMessage

func (*CheckAccessResponseProto) ProtoMessage()

func (*CheckAccessResponseProto) Reset

func (m *CheckAccessResponseProto) Reset()

func (*CheckAccessResponseProto) String

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) Descriptor

func (*ChecksumProto) Descriptor() ([]byte, []int)

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) EnumDescriptor

func (ChecksumTypeProto) EnumDescriptor() ([]byte, []int)

func (ChecksumTypeProto) String

func (x ChecksumTypeProto) String() string

func (*ChecksumTypeProto) UnmarshalJSON

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

type CipherOptionProto

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) Descriptor

func (*CipherOptionProto) Descriptor() ([]byte, []int)

func (*CipherOptionProto) GetInIv

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

func (*CipherOptionProto) GetInKey

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

func (*CipherOptionProto) GetOutIv

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

func (*CipherOptionProto) GetOutKey

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

func (*CipherOptionProto) GetSuite

func (m *CipherOptionProto) GetSuite() CipherSuiteProto

func (*CipherOptionProto) ProtoMessage

func (*CipherOptionProto) ProtoMessage()

func (*CipherOptionProto) Reset

func (m *CipherOptionProto) Reset()

func (*CipherOptionProto) String

func (m *CipherOptionProto) String() string

type CipherSuiteProto

type CipherSuiteProto int32

* Cipher suite.

const (
	CipherSuiteProto_UNKNOWN           CipherSuiteProto = 1
	CipherSuiteProto_AES_CTR_NOPADDING CipherSuiteProto = 2
)

func (CipherSuiteProto) Enum

func (CipherSuiteProto) EnumDescriptor

func (CipherSuiteProto) EnumDescriptor() ([]byte, []int)

func (CipherSuiteProto) String

func (x CipherSuiteProto) String() string

func (*CipherSuiteProto) UnmarshalJSON

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) Descriptor

func (*ClientOperationHeaderProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*ClientReadStatusProto) Descriptor() ([]byte, []int)

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

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) Descriptor

func (*CloseEventProto) Descriptor() ([]byte, []int)

func (*CloseEventProto) GetFileSize

func (m *CloseEventProto) GetFileSize() int64

func (*CloseEventProto) GetPath

func (m *CloseEventProto) GetPath() string

func (*CloseEventProto) GetTimestamp

func (m *CloseEventProto) GetTimestamp() int64

func (*CloseEventProto) ProtoMessage

func (*CloseEventProto) ProtoMessage()

func (*CloseEventProto) Reset

func (m *CloseEventProto) Reset()

func (*CloseEventProto) String

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) Descriptor

func (*CompleteRequestProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*CompleteResponseProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*ConcatRequestProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*ConcatResponseProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*ContentSummaryProto) Descriptor() ([]byte, []int)

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

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) Descriptor

func (*CorruptFileBlocksProto) Descriptor() ([]byte, []int)

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

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) Descriptor

func (*CreateEncryptionZoneRequestProto) Descriptor() ([]byte, []int)

func (*CreateEncryptionZoneRequestProto) GetKeyName

func (m *CreateEncryptionZoneRequestProto) GetKeyName() string

func (*CreateEncryptionZoneRequestProto) GetSrc

func (*CreateEncryptionZoneRequestProto) ProtoMessage

func (*CreateEncryptionZoneRequestProto) ProtoMessage()

func (*CreateEncryptionZoneRequestProto) Reset

func (*CreateEncryptionZoneRequestProto) String

type CreateEncryptionZoneResponseProto

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

func (*CreateEncryptionZoneResponseProto) Descriptor

func (*CreateEncryptionZoneResponseProto) Descriptor() ([]byte, []int)

func (*CreateEncryptionZoneResponseProto) ProtoMessage

func (*CreateEncryptionZoneResponseProto) ProtoMessage()

func (*CreateEncryptionZoneResponseProto) Reset

func (*CreateEncryptionZoneResponseProto) String

type CreateEventProto

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) Descriptor

func (*CreateEventProto) Descriptor() ([]byte, []int)

func (*CreateEventProto) GetCtime

func (m *CreateEventProto) GetCtime() int64

func (*CreateEventProto) GetDefaultBlockSize

func (m *CreateEventProto) GetDefaultBlockSize() int64

func (*CreateEventProto) GetGroupName

func (m *CreateEventProto) GetGroupName() string

func (*CreateEventProto) GetOverwrite

func (m *CreateEventProto) GetOverwrite() bool

func (*CreateEventProto) GetOwnerName

func (m *CreateEventProto) GetOwnerName() string

func (*CreateEventProto) GetPath

func (m *CreateEventProto) GetPath() string

func (*CreateEventProto) GetPerms

func (m *CreateEventProto) GetPerms() *FsPermissionProto

func (*CreateEventProto) GetReplication

func (m *CreateEventProto) GetReplication() int32

func (*CreateEventProto) GetSymlinkTarget

func (m *CreateEventProto) GetSymlinkTarget() string

func (*CreateEventProto) GetType

func (m *CreateEventProto) GetType() INodeType

func (*CreateEventProto) ProtoMessage

func (*CreateEventProto) ProtoMessage()

func (*CreateEventProto) Reset

func (m *CreateEventProto) Reset()

func (*CreateEventProto) String

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) EnumDescriptor

func (CreateFlagProto) EnumDescriptor() ([]byte, []int)

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) Descriptor

func (*CreateRequestProto) Descriptor() ([]byte, []int)

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

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) Descriptor

func (*CreateResponseProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*CreateSnapshotRequestProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*CreateSnapshotResponseProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*CreateSymlinkRequestProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*CreateSymlinkResponseProto) Descriptor() ([]byte, []int)

func (*CreateSymlinkResponseProto) ProtoMessage

func (*CreateSymlinkResponseProto) ProtoMessage()

func (*CreateSymlinkResponseProto) Reset

func (m *CreateSymlinkResponseProto) Reset()

func (*CreateSymlinkResponseProto) String

func (m *CreateSymlinkResponseProto) String() string

type CryptoProtocolVersionProto

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

func (CryptoProtocolVersionProto) EnumDescriptor

func (CryptoProtocolVersionProto) EnumDescriptor() ([]byte, []int)

func (CryptoProtocolVersionProto) String

func (*CryptoProtocolVersionProto) UnmarshalJSON

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) Descriptor

func (*DNTransferAckProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*DataEncryptionKeyProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*DataTransferEncryptorMessageProto) Descriptor() ([]byte, []int)

func (*DataTransferEncryptorMessageProto) GetCipherOption

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) EnumDescriptor

func (DataTransferEncryptorMessageProto_DataTransferEncryptorStatus) String

func (*DataTransferEncryptorMessageProto_DataTransferEncryptorStatus) UnmarshalJSON

type DataTransferTraceInfoProto

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) Descriptor

func (*DataTransferTraceInfoProto) Descriptor() ([]byte, []int)

func (*DataTransferTraceInfoProto) GetParentId

func (m *DataTransferTraceInfoProto) GetParentId() uint64

func (*DataTransferTraceInfoProto) GetTraceId

func (m *DataTransferTraceInfoProto) GetTraceId() uint64

func (*DataTransferTraceInfoProto) ProtoMessage

func (*DataTransferTraceInfoProto) ProtoMessage()

func (*DataTransferTraceInfoProto) Reset

func (m *DataTransferTraceInfoProto) Reset()

func (*DataTransferTraceInfoProto) String

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) Descriptor

func (*DatanodeIDProto) Descriptor() ([]byte, []int)

func (*DatanodeIDProto) GetDatanodeUuid

func (m *DatanodeIDProto) GetDatanodeUuid() string

func (*DatanodeIDProto) GetHostName

func (m *DatanodeIDProto) GetHostName() string

func (*DatanodeIDProto) GetInfoPort

func (m *DatanodeIDProto) GetInfoPort() uint32

func (*DatanodeIDProto) GetInfoSecurePort

func (m *DatanodeIDProto) GetInfoSecurePort() uint32

func (*DatanodeIDProto) GetIpAddr

func (m *DatanodeIDProto) GetIpAddr() string

func (*DatanodeIDProto) GetIpcPort

func (m *DatanodeIDProto) GetIpcPort() uint32

func (*DatanodeIDProto) GetXferPort

func (m *DatanodeIDProto) GetXferPort() uint32

func (*DatanodeIDProto) ProtoMessage

func (*DatanodeIDProto) ProtoMessage()

func (*DatanodeIDProto) Reset

func (m *DatanodeIDProto) Reset()

func (*DatanodeIDProto) String

func (m *DatanodeIDProto) String() string

type DatanodeInfoProto

type DatanodeInfoProto struct {
	Id                  *DatanodeIDProto              `protobuf:"bytes,1,req,name=id" json:"id,omitempty"`
	Capacity            *uint64                       `protobuf:"varint,2,opt,name=capacity,def=0" json:"capacity,omitempty"`
	DfsUsed             *uint64                       `protobuf:"varint,3,opt,name=dfsUsed,def=0" json:"dfsUsed,omitempty"`
	Remaining           *uint64                       `protobuf:"varint,4,opt,name=remaining,def=0" json:"remaining,omitempty"`
	BlockPoolUsed       *uint64                       `protobuf:"varint,5,opt,name=blockPoolUsed,def=0" json:"blockPoolUsed,omitempty"`
	LastUpdate          *uint64                       `protobuf:"varint,6,opt,name=lastUpdate,def=0" json:"lastUpdate,omitempty"`
	XceiverCount        *uint32                       `protobuf:"varint,7,opt,name=xceiverCount,def=0" json:"xceiverCount,omitempty"`
	Location            *string                       `protobuf:"bytes,8,opt,name=location" json:"location,omitempty"`
	AdminState          *DatanodeInfoProto_AdminState `protobuf:"varint,10,opt,name=adminState,enum=hadoop.hdfs.DatanodeInfoProto_AdminState,def=0" json:"adminState,omitempty"`
	CacheCapacity       *uint64                       `protobuf:"varint,11,opt,name=cacheCapacity,def=0" json:"cacheCapacity,omitempty"`
	CacheUsed           *uint64                       `protobuf:"varint,12,opt,name=cacheUsed,def=0" json:"cacheUsed,omitempty"`
	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) Descriptor

func (*DatanodeInfoProto) Descriptor() ([]byte, []int)

func (*DatanodeInfoProto) GetAdminState

func (*DatanodeInfoProto) GetBlockPoolUsed

func (m *DatanodeInfoProto) GetBlockPoolUsed() uint64

func (*DatanodeInfoProto) GetCacheCapacity

func (m *DatanodeInfoProto) GetCacheCapacity() uint64

func (*DatanodeInfoProto) GetCacheUsed

func (m *DatanodeInfoProto) GetCacheUsed() uint64

func (*DatanodeInfoProto) GetCapacity

func (m *DatanodeInfoProto) GetCapacity() uint64

func (*DatanodeInfoProto) GetDfsUsed

func (m *DatanodeInfoProto) GetDfsUsed() uint64

func (*DatanodeInfoProto) GetId

func (m *DatanodeInfoProto) GetId() *DatanodeIDProto

func (*DatanodeInfoProto) GetLastUpdate

func (m *DatanodeInfoProto) GetLastUpdate() uint64

func (*DatanodeInfoProto) GetLastUpdateMonotonic

func (m *DatanodeInfoProto) GetLastUpdateMonotonic() uint64

func (*DatanodeInfoProto) GetLocation

func (m *DatanodeInfoProto) GetLocation() string

func (*DatanodeInfoProto) GetRemaining

func (m *DatanodeInfoProto) GetRemaining() uint64

func (*DatanodeInfoProto) GetUpgradeDomain

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) EnumDescriptor

func (DatanodeInfoProto_AdminState) EnumDescriptor() ([]byte, []int)

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) Descriptor

func (*DatanodeInfosProto) Descriptor() ([]byte, []int)

func (*DatanodeInfosProto) GetDatanodes

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

func (*DatanodeInfosProto) ProtoMessage

func (*DatanodeInfosProto) ProtoMessage()

func (*DatanodeInfosProto) Reset

func (m *DatanodeInfosProto) Reset()

func (*DatanodeInfosProto) String

func (m *DatanodeInfosProto) String() string

type DatanodeLocalInfoProto

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

* Datanode local information

func (*DatanodeLocalInfoProto) Descriptor

func (*DatanodeLocalInfoProto) Descriptor() ([]byte, []int)

func (*DatanodeLocalInfoProto) GetConfigVersion

func (m *DatanodeLocalInfoProto) GetConfigVersion() string

func (*DatanodeLocalInfoProto) GetSoftwareVersion

func (m *DatanodeLocalInfoProto) GetSoftwareVersion() string

func (*DatanodeLocalInfoProto) GetUptime

func (m *DatanodeLocalInfoProto) GetUptime() uint64

func (*DatanodeLocalInfoProto) ProtoMessage

func (*DatanodeLocalInfoProto) ProtoMessage()

func (*DatanodeLocalInfoProto) Reset

func (m *DatanodeLocalInfoProto) Reset()

func (*DatanodeLocalInfoProto) String

func (m *DatanodeLocalInfoProto) String() string

type DatanodeReportTypeProto

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

func (DatanodeReportTypeProto) Enum

func (DatanodeReportTypeProto) EnumDescriptor

func (DatanodeReportTypeProto) EnumDescriptor() ([]byte, []int)

func (DatanodeReportTypeProto) String

func (x DatanodeReportTypeProto) String() string

func (*DatanodeReportTypeProto) UnmarshalJSON

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

type DatanodeStorageProto

type DatanodeStorageProto struct {
	StorageUuid      *string                            `protobuf:"bytes,1,req,name=storageUuid" json:"storageUuid,omitempty"`
	State            *DatanodeStorageProto_StorageState `protobuf:"varint,2,opt,name=state,enum=hadoop.hdfs.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) Descriptor

func (*DatanodeStorageProto) Descriptor() ([]byte, []int)

func (*DatanodeStorageProto) GetState

func (*DatanodeStorageProto) GetStorageType

func (m *DatanodeStorageProto) GetStorageType() StorageTypeProto

func (*DatanodeStorageProto) GetStorageUuid

func (m *DatanodeStorageProto) GetStorageUuid() string

func (*DatanodeStorageProto) ProtoMessage

func (*DatanodeStorageProto) ProtoMessage()

func (*DatanodeStorageProto) Reset

func (m *DatanodeStorageProto) Reset()

func (*DatanodeStorageProto) String

func (m *DatanodeStorageProto) String() string

type DatanodeStorageProto_StorageState

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

func (DatanodeStorageProto_StorageState) Enum

func (DatanodeStorageProto_StorageState) EnumDescriptor

func (DatanodeStorageProto_StorageState) EnumDescriptor() ([]byte, []int)

func (DatanodeStorageProto_StorageState) String

func (*DatanodeStorageProto_StorageState) UnmarshalJSON

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

type DatanodeStorageReportProto

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) Descriptor

func (*DatanodeStorageReportProto) Descriptor() ([]byte, []int)

func (*DatanodeStorageReportProto) GetDatanodeInfo

func (m *DatanodeStorageReportProto) GetDatanodeInfo() *DatanodeInfoProto

func (*DatanodeStorageReportProto) GetStorageReports

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

func (*DatanodeStorageReportProto) ProtoMessage

func (*DatanodeStorageReportProto) ProtoMessage()

func (*DatanodeStorageReportProto) Reset

func (m *DatanodeStorageReportProto) Reset()

func (*DatanodeStorageReportProto) String

func (m *DatanodeStorageReportProto) String() string

type DeleteBlockPoolRequestProto

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

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

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

func (*DeleteBlockPoolRequestProto) Descriptor

func (*DeleteBlockPoolRequestProto) Descriptor() ([]byte, []int)

func (*DeleteBlockPoolRequestProto) GetBlockPool

func (m *DeleteBlockPoolRequestProto) GetBlockPool() string

func (*DeleteBlockPoolRequestProto) GetForce

func (m *DeleteBlockPoolRequestProto) GetForce() bool

func (*DeleteBlockPoolRequestProto) ProtoMessage

func (*DeleteBlockPoolRequestProto) ProtoMessage()

func (*DeleteBlockPoolRequestProto) Reset

func (m *DeleteBlockPoolRequestProto) Reset()

func (*DeleteBlockPoolRequestProto) String

func (m *DeleteBlockPoolRequestProto) String() string

type DeleteBlockPoolResponseProto

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

* void response

func (*DeleteBlockPoolResponseProto) Descriptor

func (*DeleteBlockPoolResponseProto) Descriptor() ([]byte, []int)

func (*DeleteBlockPoolResponseProto) ProtoMessage

func (*DeleteBlockPoolResponseProto) ProtoMessage()

func (*DeleteBlockPoolResponseProto) Reset

func (m *DeleteBlockPoolResponseProto) Reset()

func (*DeleteBlockPoolResponseProto) String

type DeleteRequestProto

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

func (*DeleteRequestProto) Descriptor

func (*DeleteRequestProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*DeleteResponseProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*DeleteSnapshotRequestProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*DeleteSnapshotResponseProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*DirectoryListingProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*DisallowSnapshotRequestProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*DisallowSnapshotResponseProto) Descriptor() ([]byte, []int)

func (*DisallowSnapshotResponseProto) ProtoMessage

func (*DisallowSnapshotResponseProto) ProtoMessage()

func (*DisallowSnapshotResponseProto) Reset

func (m *DisallowSnapshotResponseProto) Reset()

func (*DisallowSnapshotResponseProto) String

type ECSchemaOptionEntryProto

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) Descriptor

func (*ECSchemaOptionEntryProto) Descriptor() ([]byte, []int)

func (*ECSchemaOptionEntryProto) GetKey

func (m *ECSchemaOptionEntryProto) GetKey() string

func (*ECSchemaOptionEntryProto) GetValue

func (m *ECSchemaOptionEntryProto) GetValue() string

func (*ECSchemaOptionEntryProto) ProtoMessage

func (*ECSchemaOptionEntryProto) ProtoMessage()

func (*ECSchemaOptionEntryProto) Reset

func (m *ECSchemaOptionEntryProto) Reset()

func (*ECSchemaOptionEntryProto) String

func (m *ECSchemaOptionEntryProto) String() string

type ECSchemaProto

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) Descriptor

func (*ECSchemaProto) Descriptor() ([]byte, []int)

func (*ECSchemaProto) GetCodecName

func (m *ECSchemaProto) GetCodecName() string

func (*ECSchemaProto) GetDataUnits

func (m *ECSchemaProto) GetDataUnits() uint32

func (*ECSchemaProto) GetOptions

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

func (*ECSchemaProto) GetParityUnits

func (m *ECSchemaProto) GetParityUnits() uint32

func (*ECSchemaProto) ProtoMessage

func (*ECSchemaProto) ProtoMessage()

func (*ECSchemaProto) Reset

func (m *ECSchemaProto) Reset()

func (*ECSchemaProto) String

func (m *ECSchemaProto) String() string

type EncryptionZoneProto

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) Descriptor

func (*EncryptionZoneProto) Descriptor() ([]byte, []int)

func (*EncryptionZoneProto) GetCryptoProtocolVersion

func (m *EncryptionZoneProto) GetCryptoProtocolVersion() CryptoProtocolVersionProto

func (*EncryptionZoneProto) GetId

func (m *EncryptionZoneProto) GetId() int64

func (*EncryptionZoneProto) GetKeyName

func (m *EncryptionZoneProto) GetKeyName() string

func (*EncryptionZoneProto) GetPath

func (m *EncryptionZoneProto) GetPath() string

func (*EncryptionZoneProto) GetSuite

func (m *EncryptionZoneProto) GetSuite() CipherSuiteProto

func (*EncryptionZoneProto) ProtoMessage

func (*EncryptionZoneProto) ProtoMessage()

func (*EncryptionZoneProto) Reset

func (m *EncryptionZoneProto) Reset()

func (*EncryptionZoneProto) String

func (m *EncryptionZoneProto) String() string

type ErasureCodingPolicyProto

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) Descriptor

func (*ErasureCodingPolicyProto) Descriptor() ([]byte, []int)

func (*ErasureCodingPolicyProto) GetCellSize

func (m *ErasureCodingPolicyProto) GetCellSize() uint32

func (*ErasureCodingPolicyProto) GetId

func (m *ErasureCodingPolicyProto) GetId() uint32

func (*ErasureCodingPolicyProto) GetName

func (m *ErasureCodingPolicyProto) GetName() string

func (*ErasureCodingPolicyProto) GetSchema

func (m *ErasureCodingPolicyProto) GetSchema() *ECSchemaProto

func (*ErasureCodingPolicyProto) ProtoMessage

func (*ErasureCodingPolicyProto) ProtoMessage()

func (*ErasureCodingPolicyProto) Reset

func (m *ErasureCodingPolicyProto) Reset()

func (*ErasureCodingPolicyProto) String

func (m *ErasureCodingPolicyProto) String() string

type EventBatchProto

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) Descriptor

func (*EventBatchProto) Descriptor() ([]byte, []int)

func (*EventBatchProto) GetEvents

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

func (*EventBatchProto) GetTxid

func (m *EventBatchProto) GetTxid() int64

func (*EventBatchProto) ProtoMessage

func (*EventBatchProto) ProtoMessage()

func (*EventBatchProto) Reset

func (m *EventBatchProto) Reset()

func (*EventBatchProto) String

func (m *EventBatchProto) String() string

type EventProto

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) Descriptor

func (*EventProto) Descriptor() ([]byte, []int)

func (*EventProto) GetContents

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

func (*EventProto) GetType

func (m *EventProto) GetType() EventType

func (*EventProto) ProtoMessage

func (*EventProto) ProtoMessage()

func (*EventProto) Reset

func (m *EventProto) Reset()

func (*EventProto) String

func (m *EventProto) String() string

type EventType

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

func (x EventType) Enum() *EventType

func (EventType) EnumDescriptor

func (EventType) EnumDescriptor() ([]byte, []int)

func (EventType) String

func (x EventType) String() string

func (*EventType) UnmarshalJSON

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

type EventsListProto

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) Descriptor

func (*EventsListProto) Descriptor() ([]byte, []int)

func (*EventsListProto) GetBatch

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

func (*EventsListProto) GetEvents

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

func (*EventsListProto) GetFirstTxid

func (m *EventsListProto) GetFirstTxid() int64

func (*EventsListProto) GetLastTxid

func (m *EventsListProto) GetLastTxid() int64

func (*EventsListProto) GetSyncTxid

func (m *EventsListProto) GetSyncTxid() int64

func (*EventsListProto) ProtoMessage

func (*EventsListProto) ProtoMessage()

func (*EventsListProto) Reset

func (m *EventsListProto) Reset()

func (*EventsListProto) String

func (m *EventsListProto) String() string

type EvictWritersRequestProto

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

* Tell datanode to evict active clients that are writing

func (*EvictWritersRequestProto) Descriptor

func (*EvictWritersRequestProto) Descriptor() ([]byte, []int)

func (*EvictWritersRequestProto) ProtoMessage

func (*EvictWritersRequestProto) ProtoMessage()

func (*EvictWritersRequestProto) Reset

func (m *EvictWritersRequestProto) Reset()

func (*EvictWritersRequestProto) String

func (m *EvictWritersRequestProto) String() string

type EvictWritersResponseProto

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

func (*EvictWritersResponseProto) Descriptor

func (*EvictWritersResponseProto) Descriptor() ([]byte, []int)

func (*EvictWritersResponseProto) ProtoMessage

func (*EvictWritersResponseProto) ProtoMessage()

func (*EvictWritersResponseProto) Reset

func (m *EvictWritersResponseProto) Reset()

func (*EvictWritersResponseProto) String

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) Descriptor

func (*ExtendedBlockProto) Descriptor() ([]byte, []int)

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

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) Descriptor

func (*FileEncryptionInfoProto) Descriptor() ([]byte, []int)

func (*FileEncryptionInfoProto) GetCryptoProtocolVersion

func (m *FileEncryptionInfoProto) GetCryptoProtocolVersion() CryptoProtocolVersionProto

func (*FileEncryptionInfoProto) GetEzKeyVersionName

func (m *FileEncryptionInfoProto) GetEzKeyVersionName() string

func (*FileEncryptionInfoProto) GetIv

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

func (*FileEncryptionInfoProto) GetKey

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

func (*FileEncryptionInfoProto) GetKeyName

func (m *FileEncryptionInfoProto) GetKeyName() string

func (*FileEncryptionInfoProto) GetSuite

func (*FileEncryptionInfoProto) ProtoMessage

func (*FileEncryptionInfoProto) ProtoMessage()

func (*FileEncryptionInfoProto) Reset

func (m *FileEncryptionInfoProto) Reset()

func (*FileEncryptionInfoProto) String

func (m *FileEncryptionInfoProto) String() string

type FinalizeUpgradeRequestProto

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

func (*FinalizeUpgradeRequestProto) Descriptor

func (*FinalizeUpgradeRequestProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*FinalizeUpgradeResponseProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*FsPermissionProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*FsServerDefaultsProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*FsyncRequestProto) Descriptor() ([]byte, []int)

func (*FsyncRequestProto) GetClient

func (m *FsyncRequestProto) GetClient() string

func (*FsyncRequestProto) GetFileId

func (m *FsyncRequestProto) GetFileId() uint64

func (*FsyncRequestProto) GetLastBlockLength

func (m *FsyncRequestProto) GetLastBlockLength() int64

func (*FsyncRequestProto) GetSrc

func (m *FsyncRequestProto) GetSrc() string

func (*FsyncRequestProto) ProtoMessage

func (*FsyncRequestProto) ProtoMessage()

func (*FsyncRequestProto) Reset

func (m *FsyncRequestProto) Reset()

func (*FsyncRequestProto) String

func (m *FsyncRequestProto) String() string

type FsyncResponseProto

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

func (*FsyncResponseProto) Descriptor

func (*FsyncResponseProto) Descriptor() ([]byte, []int)

func (*FsyncResponseProto) ProtoMessage

func (*FsyncResponseProto) ProtoMessage()

func (*FsyncResponseProto) Reset

func (m *FsyncResponseProto) Reset()

func (*FsyncResponseProto) String

func (m *FsyncResponseProto) String() string

type GetAclStatusRequestProto

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

func (*GetAclStatusRequestProto) Descriptor

func (*GetAclStatusRequestProto) Descriptor() ([]byte, []int)

func (*GetAclStatusRequestProto) GetSrc

func (m *GetAclStatusRequestProto) GetSrc() string

func (*GetAclStatusRequestProto) ProtoMessage

func (*GetAclStatusRequestProto) ProtoMessage()

func (*GetAclStatusRequestProto) Reset

func (m *GetAclStatusRequestProto) Reset()

func (*GetAclStatusRequestProto) String

func (m *GetAclStatusRequestProto) String() string

type GetAclStatusResponseProto

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

func (*GetAclStatusResponseProto) Descriptor

func (*GetAclStatusResponseProto) Descriptor() ([]byte, []int)

func (*GetAclStatusResponseProto) GetResult

func (m *GetAclStatusResponseProto) GetResult() *AclStatusProto

func (*GetAclStatusResponseProto) ProtoMessage

func (*GetAclStatusResponseProto) ProtoMessage()

func (*GetAclStatusResponseProto) Reset

func (m *GetAclStatusResponseProto) Reset()

func (*GetAclStatusResponseProto) String

func (m *GetAclStatusResponseProto) String() string

type GetAdditionalDatanodeRequestProto

type GetAdditionalDatanodeRequestProto struct {
	Src                  *string              `protobuf:"bytes,1,req,name=src" json:"src,omitempty"`
	Blk                  *ExtendedBlockProto  `protobuf:"bytes,2,req,name=blk" json:"blk,omitempty"`
	Existings            []*DatanodeInfoProto `protobuf:"bytes,3,rep,name=existings" json:"existings,omitempty"`
	Excludes             []*DatanodeInfoProto `protobuf:"bytes,4,rep,name=excludes" json:"excludes,omitempty"`
	NumAdditionalNodes   *uint32              `protobuf:"varint,5,req,name=numAdditionalNodes" json:"numAdditionalNodes,omitempty"`
	ClientName           *string              `protobuf:"bytes,6,req,name=clientName" json:"clientName,omitempty"`
	ExistingStorageUuids []string             `protobuf:"bytes,7,rep,name=existingStorageUuids" json:"existingStorageUuids,omitempty"`
	FileId               *uint64              `protobuf:"varint,8,opt,name=fileId,def=0" json:"fileId,omitempty"`
	XXX_unrecognized     []byte               `json:"-"`
}

func (*GetAdditionalDatanodeRequestProto) Descriptor

func (*GetAdditionalDatanodeRequestProto) Descriptor() ([]byte, []int)

func (*GetAdditionalDatanodeRequestProto) GetBlk

func (*GetAdditionalDatanodeRequestProto) GetClientName

func (m *GetAdditionalDatanodeRequestProto) GetClientName() string

func (*GetAdditionalDatanodeRequestProto) GetExcludes

func (*GetAdditionalDatanodeRequestProto) GetExistingStorageUuids

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

func (*GetAdditionalDatanodeRequestProto) GetExistings

func (*GetAdditionalDatanodeRequestProto) GetFileId

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) Descriptor

func (*GetAdditionalDatanodeResponseProto) Descriptor() ([]byte, []int)

func (*GetAdditionalDatanodeResponseProto) GetBlock

func (*GetAdditionalDatanodeResponseProto) ProtoMessage

func (*GetAdditionalDatanodeResponseProto) ProtoMessage()

func (*GetAdditionalDatanodeResponseProto) Reset

func (*GetAdditionalDatanodeResponseProto) String

type GetBalancerBandwidthRequestProto

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

func (*GetBalancerBandwidthRequestProto) Descriptor

func (*GetBalancerBandwidthRequestProto) Descriptor() ([]byte, []int)

func (*GetBalancerBandwidthRequestProto) ProtoMessage

func (*GetBalancerBandwidthRequestProto) ProtoMessage()

func (*GetBalancerBandwidthRequestProto) Reset

func (*GetBalancerBandwidthRequestProto) String

type GetBalancerBandwidthResponseProto

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) Descriptor

func (*GetBalancerBandwidthResponseProto) Descriptor() ([]byte, []int)

func (*GetBalancerBandwidthResponseProto) GetBandwidth

func (m *GetBalancerBandwidthResponseProto) GetBandwidth() uint64

func (*GetBalancerBandwidthResponseProto) ProtoMessage

func (*GetBalancerBandwidthResponseProto) ProtoMessage()

func (*GetBalancerBandwidthResponseProto) Reset

func (*GetBalancerBandwidthResponseProto) String

type GetBlockLocalPathInfoRequestProto

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

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

This message is deprecated in favor of file descriptor passing.

func (*GetBlockLocalPathInfoRequestProto) Descriptor

func (*GetBlockLocalPathInfoRequestProto) Descriptor() ([]byte, []int)

func (*GetBlockLocalPathInfoRequestProto) GetBlock

func (*GetBlockLocalPathInfoRequestProto) GetToken

func (*GetBlockLocalPathInfoRequestProto) ProtoMessage

func (*GetBlockLocalPathInfoRequestProto) ProtoMessage()

func (*GetBlockLocalPathInfoRequestProto) Reset

func (*GetBlockLocalPathInfoRequestProto) String

type GetBlockLocalPathInfoResponseProto

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

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

This message is deprecated in favor of file descriptor passing.

func (*GetBlockLocalPathInfoResponseProto) Descriptor

func (*GetBlockLocalPathInfoResponseProto) Descriptor() ([]byte, []int)

func (*GetBlockLocalPathInfoResponseProto) GetBlock

func (*GetBlockLocalPathInfoResponseProto) GetLocalMetaPath

func (m *GetBlockLocalPathInfoResponseProto) GetLocalMetaPath() string

func (*GetBlockLocalPathInfoResponseProto) GetLocalPath

func (m *GetBlockLocalPathInfoResponseProto) GetLocalPath() string

func (*GetBlockLocalPathInfoResponseProto) ProtoMessage

func (*GetBlockLocalPathInfoResponseProto) ProtoMessage()

func (*GetBlockLocalPathInfoResponseProto) Reset

func (*GetBlockLocalPathInfoResponseProto) String

type GetBlockLocationsRequestProto

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

func (*GetBlockLocationsRequestProto) Descriptor

func (*GetBlockLocationsRequestProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*GetBlockLocationsResponseProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*GetContentSummaryRequestProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*GetContentSummaryResponseProto) Descriptor() ([]byte, []int)

func (*GetContentSummaryResponseProto) GetSummary

func (*GetContentSummaryResponseProto) ProtoMessage

func (*GetContentSummaryResponseProto) ProtoMessage()

func (*GetContentSummaryResponseProto) Reset

func (m *GetContentSummaryResponseProto) Reset()

func (*GetContentSummaryResponseProto) String

type GetCurrentEditLogTxidRequestProto

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

func (*GetCurrentEditLogTxidRequestProto) Descriptor

func (*GetCurrentEditLogTxidRequestProto) Descriptor() ([]byte, []int)

func (*GetCurrentEditLogTxidRequestProto) ProtoMessage

func (*GetCurrentEditLogTxidRequestProto) ProtoMessage()

func (*GetCurrentEditLogTxidRequestProto) Reset

func (*GetCurrentEditLogTxidRequestProto) String

type GetCurrentEditLogTxidResponseProto

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

func (*GetCurrentEditLogTxidResponseProto) Descriptor

func (*GetCurrentEditLogTxidResponseProto) Descriptor() ([]byte, []int)

func (*GetCurrentEditLogTxidResponseProto) GetTxid

func (*GetCurrentEditLogTxidResponseProto) ProtoMessage

func (*GetCurrentEditLogTxidResponseProto) ProtoMessage()

func (*GetCurrentEditLogTxidResponseProto) Reset

func (*GetCurrentEditLogTxidResponseProto) String

type GetDataEncryptionKeyRequestProto

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

func (*GetDataEncryptionKeyRequestProto) Descriptor

func (*GetDataEncryptionKeyRequestProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*GetDataEncryptionKeyResponseProto) Descriptor() ([]byte, []int)

func (*GetDataEncryptionKeyResponseProto) GetDataEncryptionKey

func (m *GetDataEncryptionKeyResponseProto) GetDataEncryptionKey() *DataEncryptionKeyProto

func (*GetDataEncryptionKeyResponseProto) ProtoMessage

func (*GetDataEncryptionKeyResponseProto) ProtoMessage()

func (*GetDataEncryptionKeyResponseProto) Reset

func (*GetDataEncryptionKeyResponseProto) String

type GetDatanodeInfoRequestProto

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

* Ping datanode for liveness and quick info

func (*GetDatanodeInfoRequestProto) Descriptor

func (*GetDatanodeInfoRequestProto) Descriptor() ([]byte, []int)

func (*GetDatanodeInfoRequestProto) ProtoMessage

func (*GetDatanodeInfoRequestProto) ProtoMessage()

func (*GetDatanodeInfoRequestProto) Reset

func (m *GetDatanodeInfoRequestProto) Reset()

func (*GetDatanodeInfoRequestProto) String

func (m *GetDatanodeInfoRequestProto) String() string

type GetDatanodeInfoResponseProto

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

func (*GetDatanodeInfoResponseProto) Descriptor

func (*GetDatanodeInfoResponseProto) Descriptor() ([]byte, []int)

func (*GetDatanodeInfoResponseProto) GetLocalInfo

func (*GetDatanodeInfoResponseProto) ProtoMessage

func (*GetDatanodeInfoResponseProto) ProtoMessage()

func (*GetDatanodeInfoResponseProto) Reset

func (m *GetDatanodeInfoResponseProto) Reset()

func (*GetDatanodeInfoResponseProto) String

type GetDatanodeReportRequestProto

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

func (*GetDatanodeReportRequestProto) Descriptor

func (*GetDatanodeReportRequestProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*GetDatanodeReportResponseProto) Descriptor() ([]byte, []int)

func (*GetDatanodeReportResponseProto) GetDi

func (*GetDatanodeReportResponseProto) ProtoMessage

func (*GetDatanodeReportResponseProto) ProtoMessage()

func (*GetDatanodeReportResponseProto) Reset

func (m *GetDatanodeReportResponseProto) Reset()

func (*GetDatanodeReportResponseProto) String

type GetDatanodeStorageReportRequestProto

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

func (*GetDatanodeStorageReportRequestProto) Descriptor

func (*GetDatanodeStorageReportRequestProto) Descriptor() ([]byte, []int)

func (*GetDatanodeStorageReportRequestProto) GetType

func (*GetDatanodeStorageReportRequestProto) ProtoMessage

func (*GetDatanodeStorageReportRequestProto) ProtoMessage()

func (*GetDatanodeStorageReportRequestProto) Reset

func (*GetDatanodeStorageReportRequestProto) String

type GetDatanodeStorageReportResponseProto

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

func (*GetDatanodeStorageReportResponseProto) Descriptor

func (*GetDatanodeStorageReportResponseProto) Descriptor() ([]byte, []int)

func (*GetDatanodeStorageReportResponseProto) GetDatanodeStorageReports

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

func (*GetDatanodeStorageReportResponseProto) ProtoMessage

func (*GetDatanodeStorageReportResponseProto) ProtoMessage()

func (*GetDatanodeStorageReportResponseProto) Reset

func (*GetDatanodeStorageReportResponseProto) String

type GetEZForPathRequestProto

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

func (*GetEZForPathRequestProto) Descriptor

func (*GetEZForPathRequestProto) Descriptor() ([]byte, []int)

func (*GetEZForPathRequestProto) GetSrc

func (m *GetEZForPathRequestProto) GetSrc() string

func (*GetEZForPathRequestProto) ProtoMessage

func (*GetEZForPathRequestProto) ProtoMessage()

func (*GetEZForPathRequestProto) Reset

func (m *GetEZForPathRequestProto) Reset()

func (*GetEZForPathRequestProto) String

func (m *GetEZForPathRequestProto) String() string

type GetEZForPathResponseProto

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

func (*GetEZForPathResponseProto) Descriptor

func (*GetEZForPathResponseProto) Descriptor() ([]byte, []int)

func (*GetEZForPathResponseProto) GetZone

func (*GetEZForPathResponseProto) ProtoMessage

func (*GetEZForPathResponseProto) ProtoMessage()

func (*GetEZForPathResponseProto) Reset

func (m *GetEZForPathResponseProto) Reset()

func (*GetEZForPathResponseProto) String

func (m *GetEZForPathResponseProto) String() string

type GetEditsFromTxidRequestProto

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

func (*GetEditsFromTxidRequestProto) Descriptor

func (*GetEditsFromTxidRequestProto) Descriptor() ([]byte, []int)

func (*GetEditsFromTxidRequestProto) GetTxid

func (m *GetEditsFromTxidRequestProto) GetTxid() int64

func (*GetEditsFromTxidRequestProto) ProtoMessage

func (*GetEditsFromTxidRequestProto) ProtoMessage()

func (*GetEditsFromTxidRequestProto) Reset

func (m *GetEditsFromTxidRequestProto) Reset()

func (*GetEditsFromTxidRequestProto) String

type GetEditsFromTxidResponseProto

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

func (*GetEditsFromTxidResponseProto) Descriptor

func (*GetEditsFromTxidResponseProto) Descriptor() ([]byte, []int)

func (*GetEditsFromTxidResponseProto) GetEventsList

func (m *GetEditsFromTxidResponseProto) GetEventsList() *EventsListProto

func (*GetEditsFromTxidResponseProto) ProtoMessage

func (*GetEditsFromTxidResponseProto) ProtoMessage()

func (*GetEditsFromTxidResponseProto) Reset

func (m *GetEditsFromTxidResponseProto) Reset()

func (*GetEditsFromTxidResponseProto) String

type GetErasureCodingPoliciesRequestProto

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

func (*GetErasureCodingPoliciesRequestProto) Descriptor

func (*GetErasureCodingPoliciesRequestProto) Descriptor() ([]byte, []int)

func (*GetErasureCodingPoliciesRequestProto) ProtoMessage

func (*GetErasureCodingPoliciesRequestProto) ProtoMessage()

func (*GetErasureCodingPoliciesRequestProto) Reset

func (*GetErasureCodingPoliciesRequestProto) String

type GetErasureCodingPoliciesResponseProto

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

func (*GetErasureCodingPoliciesResponseProto) Descriptor

func (*GetErasureCodingPoliciesResponseProto) Descriptor() ([]byte, []int)

func (*GetErasureCodingPoliciesResponseProto) GetEcPolicies

func (*GetErasureCodingPoliciesResponseProto) ProtoMessage

func (*GetErasureCodingPoliciesResponseProto) ProtoMessage()

func (*GetErasureCodingPoliciesResponseProto) Reset

func (*GetErasureCodingPoliciesResponseProto) String

type GetErasureCodingPolicyRequestProto

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

func (*GetErasureCodingPolicyRequestProto) Descriptor

func (*GetErasureCodingPolicyRequestProto) Descriptor() ([]byte, []int)

func (*GetErasureCodingPolicyRequestProto) GetSrc

func (*GetErasureCodingPolicyRequestProto) ProtoMessage

func (*GetErasureCodingPolicyRequestProto) ProtoMessage()

func (*GetErasureCodingPolicyRequestProto) Reset

func (*GetErasureCodingPolicyRequestProto) String

type GetErasureCodingPolicyResponseProto

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

func (*GetErasureCodingPolicyResponseProto) Descriptor

func (*GetErasureCodingPolicyResponseProto) Descriptor() ([]byte, []int)

func (*GetErasureCodingPolicyResponseProto) GetEcPolicy

func (*GetErasureCodingPolicyResponseProto) ProtoMessage

func (*GetErasureCodingPolicyResponseProto) ProtoMessage()

func (*GetErasureCodingPolicyResponseProto) Reset

func (*GetErasureCodingPolicyResponseProto) String

type GetFileInfoRequestProto

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

func (*GetFileInfoRequestProto) Descriptor

func (*GetFileInfoRequestProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*GetFileInfoResponseProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*GetFileLinkInfoRequestProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*GetFileLinkInfoResponseProto) Descriptor() ([]byte, []int)

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=underReplicated" json:"under_replicated,omitempty"`
	CorruptBlocks         *uint64 `protobuf:"varint,5,req,name=corrupt_blocks,json=corruptBlocks" json:"corrupt_blocks,omitempty"`
	MissingBlocks         *uint64 `protobuf:"varint,6,req,name=missing_blocks,json=missingBlocks" json:"missing_blocks,omitempty"`
	MissingReplOneBlocks  *uint64 `protobuf:"varint,7,opt,name=missing_repl_one_blocks,json=missingReplOneBlocks" json:"missing_repl_one_blocks,omitempty"`
	BlocksInFuture        *uint64 `protobuf:"varint,8,opt,name=blocks_in_future,json=blocksInFuture" json:"blocks_in_future,omitempty"`
	PendingDeletionBlocks *uint64 `protobuf:"varint,9,opt,name=pending_deletion_blocks,json=pendingDeletionBlocks" json:"pending_deletion_blocks,omitempty"`
	XXX_unrecognized      []byte  `json:"-"`
}

func (*GetFsStatsResponseProto) Descriptor

func (*GetFsStatsResponseProto) Descriptor() ([]byte, []int)

func (*GetFsStatsResponseProto) GetBlocksInFuture

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

func (m *GetFsStatsResponseProto) GetMissingReplOneBlocks() uint64

func (*GetFsStatsResponseProto) GetPendingDeletionBlocks

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) Descriptor

func (*GetFsStatusRequestProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*GetLinkTargetRequestProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*GetLinkTargetResponseProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*GetListingRequestProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*GetListingResponseProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*GetPreferredBlockSizeRequestProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*GetPreferredBlockSizeResponseProto) Descriptor() ([]byte, []int)

func (*GetPreferredBlockSizeResponseProto) GetBsize

func (*GetPreferredBlockSizeResponseProto) ProtoMessage

func (*GetPreferredBlockSizeResponseProto) ProtoMessage()

func (*GetPreferredBlockSizeResponseProto) Reset

func (*GetPreferredBlockSizeResponseProto) String

type GetQuotaUsageRequestProto

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

func (*GetQuotaUsageRequestProto) Descriptor

func (*GetQuotaUsageRequestProto) Descriptor() ([]byte, []int)

func (*GetQuotaUsageRequestProto) GetPath

func (m *GetQuotaUsageRequestProto) GetPath() string

func (*GetQuotaUsageRequestProto) ProtoMessage

func (*GetQuotaUsageRequestProto) ProtoMessage()

func (*GetQuotaUsageRequestProto) Reset

func (m *GetQuotaUsageRequestProto) Reset()

func (*GetQuotaUsageRequestProto) String

func (m *GetQuotaUsageRequestProto) String() string

type GetQuotaUsageResponseProto

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

func (*GetQuotaUsageResponseProto) Descriptor

func (*GetQuotaUsageResponseProto) Descriptor() ([]byte, []int)

func (*GetQuotaUsageResponseProto) GetUsage

func (*GetQuotaUsageResponseProto) ProtoMessage

func (*GetQuotaUsageResponseProto) ProtoMessage()

func (*GetQuotaUsageResponseProto) Reset

func (m *GetQuotaUsageResponseProto) Reset()

func (*GetQuotaUsageResponseProto) String

func (m *GetQuotaUsageResponseProto) String() string

type GetReconfigurationStatusConfigChangeProto

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) Descriptor

func (*GetReconfigurationStatusConfigChangeProto) Descriptor() ([]byte, []int)

func (*GetReconfigurationStatusConfigChangeProto) GetErrorMessage

func (*GetReconfigurationStatusConfigChangeProto) GetName

func (*GetReconfigurationStatusConfigChangeProto) GetNewValue

func (*GetReconfigurationStatusConfigChangeProto) GetOldValue

func (*GetReconfigurationStatusConfigChangeProto) ProtoMessage

func (*GetReconfigurationStatusConfigChangeProto) Reset

func (*GetReconfigurationStatusConfigChangeProto) String

type GetReconfigurationStatusRequestProto

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

* Query the running status of reconfiguration process

func (*GetReconfigurationStatusRequestProto) Descriptor

func (*GetReconfigurationStatusRequestProto) Descriptor() ([]byte, []int)

func (*GetReconfigurationStatusRequestProto) ProtoMessage

func (*GetReconfigurationStatusRequestProto) ProtoMessage()

func (*GetReconfigurationStatusRequestProto) Reset

func (*GetReconfigurationStatusRequestProto) String

type GetReconfigurationStatusResponseProto

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) Descriptor

func (*GetReconfigurationStatusResponseProto) Descriptor() ([]byte, []int)

func (*GetReconfigurationStatusResponseProto) GetChanges

func (*GetReconfigurationStatusResponseProto) GetEndTime

func (*GetReconfigurationStatusResponseProto) GetStartTime

func (m *GetReconfigurationStatusResponseProto) GetStartTime() int64

func (*GetReconfigurationStatusResponseProto) ProtoMessage

func (*GetReconfigurationStatusResponseProto) ProtoMessage()

func (*GetReconfigurationStatusResponseProto) Reset

func (*GetReconfigurationStatusResponseProto) String

type GetReplicaVisibleLengthRequestProto

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

* block - block for which visible length is requested

func (*GetReplicaVisibleLengthRequestProto) Descriptor

func (*GetReplicaVisibleLengthRequestProto) Descriptor() ([]byte, []int)

func (*GetReplicaVisibleLengthRequestProto) GetBlock

func (*GetReplicaVisibleLengthRequestProto) ProtoMessage

func (*GetReplicaVisibleLengthRequestProto) ProtoMessage()

func (*GetReplicaVisibleLengthRequestProto) Reset

func (*GetReplicaVisibleLengthRequestProto) String

type GetReplicaVisibleLengthResponseProto

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

* length - visible length of the block

func (*GetReplicaVisibleLengthResponseProto) Descriptor

func (*GetReplicaVisibleLengthResponseProto) Descriptor() ([]byte, []int)

func (*GetReplicaVisibleLengthResponseProto) GetLength

func (*GetReplicaVisibleLengthResponseProto) ProtoMessage

func (*GetReplicaVisibleLengthResponseProto) ProtoMessage()

func (*GetReplicaVisibleLengthResponseProto) Reset

func (*GetReplicaVisibleLengthResponseProto) String

type GetServerDefaultsRequestProto

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

func (*GetServerDefaultsRequestProto) Descriptor

func (*GetServerDefaultsRequestProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*GetServerDefaultsResponseProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*GetSnapshotDiffReportRequestProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*GetSnapshotDiffReportResponseProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*GetSnapshottableDirListingRequestProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*GetSnapshottableDirListingResponseProto) Descriptor() ([]byte, []int)

func (*GetSnapshottableDirListingResponseProto) GetSnapshottableDirList

func (*GetSnapshottableDirListingResponseProto) ProtoMessage

func (*GetSnapshottableDirListingResponseProto) Reset

func (*GetSnapshottableDirListingResponseProto) String

type GetStoragePoliciesRequestProto

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

func (*GetStoragePoliciesRequestProto) Descriptor

func (*GetStoragePoliciesRequestProto) Descriptor() ([]byte, []int)

func (*GetStoragePoliciesRequestProto) ProtoMessage

func (*GetStoragePoliciesRequestProto) ProtoMessage()

func (*GetStoragePoliciesRequestProto) Reset

func (m *GetStoragePoliciesRequestProto) Reset()

func (*GetStoragePoliciesRequestProto) String

type GetStoragePoliciesResponseProto

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

func (*GetStoragePoliciesResponseProto) Descriptor

func (*GetStoragePoliciesResponseProto) Descriptor() ([]byte, []int)

func (*GetStoragePoliciesResponseProto) GetPolicies

func (*GetStoragePoliciesResponseProto) ProtoMessage

func (*GetStoragePoliciesResponseProto) ProtoMessage()

func (*GetStoragePoliciesResponseProto) Reset

func (*GetStoragePoliciesResponseProto) String

type GetStoragePolicyRequestProto

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

func (*GetStoragePolicyRequestProto) Descriptor

func (*GetStoragePolicyRequestProto) Descriptor() ([]byte, []int)

func (*GetStoragePolicyRequestProto) GetPath

func (m *GetStoragePolicyRequestProto) GetPath() string

func (*GetStoragePolicyRequestProto) ProtoMessage

func (*GetStoragePolicyRequestProto) ProtoMessage()

func (*GetStoragePolicyRequestProto) Reset

func (m *GetStoragePolicyRequestProto) Reset()

func (*GetStoragePolicyRequestProto) String

type GetStoragePolicyResponseProto

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

func (*GetStoragePolicyResponseProto) Descriptor

func (*GetStoragePolicyResponseProto) Descriptor() ([]byte, []int)

func (*GetStoragePolicyResponseProto) GetStoragePolicy

func (*GetStoragePolicyResponseProto) ProtoMessage

func (*GetStoragePolicyResponseProto) ProtoMessage()

func (*GetStoragePolicyResponseProto) Reset

func (m *GetStoragePolicyResponseProto) Reset()

func (*GetStoragePolicyResponseProto) String

type GetXAttrsRequestProto

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

func (*GetXAttrsRequestProto) Descriptor

func (*GetXAttrsRequestProto) Descriptor() ([]byte, []int)

func (*GetXAttrsRequestProto) GetSrc

func (m *GetXAttrsRequestProto) GetSrc() string

func (*GetXAttrsRequestProto) GetXAttrs

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

func (*GetXAttrsRequestProto) ProtoMessage

func (*GetXAttrsRequestProto) ProtoMessage()

func (*GetXAttrsRequestProto) Reset

func (m *GetXAttrsRequestProto) Reset()

func (*GetXAttrsRequestProto) String

func (m *GetXAttrsRequestProto) String() string

type GetXAttrsResponseProto

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

func (*GetXAttrsResponseProto) Descriptor

func (*GetXAttrsResponseProto) Descriptor() ([]byte, []int)

func (*GetXAttrsResponseProto) GetXAttrs

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

func (*GetXAttrsResponseProto) ProtoMessage

func (*GetXAttrsResponseProto) ProtoMessage()

func (*GetXAttrsResponseProto) Reset

func (m *GetXAttrsResponseProto) Reset()

func (*GetXAttrsResponseProto) String

func (m *GetXAttrsResponseProto) String() string

type HdfsFileStatusProto

type HdfsFileStatusProto struct {
	FileType         *HdfsFileStatusProto_FileType `protobuf:"varint,1,req,name=fileType,enum=hadoop.hdfs.HdfsFileStatusProto_FileType" json:"fileType,omitempty"`
	Path             []byte                        `protobuf:"bytes,2,req,name=path" json:"path,omitempty"`
	Length           *uint64                       `protobuf:"varint,3,req,name=length" json:"length,omitempty"`
	Permission       *FsPermissionProto            `protobuf:"bytes,4,req,name=permission" json:"permission,omitempty"`
	Owner            *string                       `protobuf:"bytes,5,req,name=owner" json:"owner,omitempty"`
	Group            *string                       `protobuf:"bytes,6,req,name=group" json:"group,omitempty"`
	ModificationTime *uint64                       `protobuf:"varint,7,req,name=modification_time,json=modificationTime" json:"modification_time,omitempty"`
	AccessTime       *uint64                       `protobuf:"varint,8,req,name=access_time,json=accessTime" 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,json=blockReplication,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) Descriptor

func (*HdfsFileStatusProto) Descriptor() ([]byte, []int)

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

func (*HdfsFileStatusProto) GetFileEncryptionInfo

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

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) EnumDescriptor

func (HdfsFileStatusProto_FileType) EnumDescriptor() ([]byte, []int)

func (HdfsFileStatusProto_FileType) String

func (*HdfsFileStatusProto_FileType) UnmarshalJSON

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

type INodeType

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

func (x INodeType) Enum() *INodeType

func (INodeType) EnumDescriptor

func (INodeType) EnumDescriptor() ([]byte, []int)

func (INodeType) String

func (x INodeType) String() string

func (*INodeType) UnmarshalJSON

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) Descriptor

func (*IsFileClosedRequestProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*IsFileClosedResponseProto) Descriptor() ([]byte, []int)

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

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) Descriptor

func (*ListCacheDirectivesRequestProto) Descriptor() ([]byte, []int)

func (*ListCacheDirectivesRequestProto) GetFilter

func (*ListCacheDirectivesRequestProto) GetPrevId

func (m *ListCacheDirectivesRequestProto) GetPrevId() int64

func (*ListCacheDirectivesRequestProto) ProtoMessage

func (*ListCacheDirectivesRequestProto) ProtoMessage()

func (*ListCacheDirectivesRequestProto) Reset

func (*ListCacheDirectivesRequestProto) String

type ListCacheDirectivesResponseProto

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

func (*ListCacheDirectivesResponseProto) Descriptor

func (*ListCacheDirectivesResponseProto) Descriptor() ([]byte, []int)

func (*ListCacheDirectivesResponseProto) GetElements

func (*ListCacheDirectivesResponseProto) GetHasMore

func (m *ListCacheDirectivesResponseProto) GetHasMore() bool

func (*ListCacheDirectivesResponseProto) ProtoMessage

func (*ListCacheDirectivesResponseProto) ProtoMessage()

func (*ListCacheDirectivesResponseProto) Reset

func (*ListCacheDirectivesResponseProto) String

type ListCachePoolsRequestProto

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

func (*ListCachePoolsRequestProto) Descriptor

func (*ListCachePoolsRequestProto) Descriptor() ([]byte, []int)

func (*ListCachePoolsRequestProto) GetPrevPoolName

func (m *ListCachePoolsRequestProto) GetPrevPoolName() string

func (*ListCachePoolsRequestProto) ProtoMessage

func (*ListCachePoolsRequestProto) ProtoMessage()

func (*ListCachePoolsRequestProto) Reset

func (m *ListCachePoolsRequestProto) Reset()

func (*ListCachePoolsRequestProto) String

func (m *ListCachePoolsRequestProto) String() string

type ListCachePoolsResponseProto

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

func (*ListCachePoolsResponseProto) Descriptor

func (*ListCachePoolsResponseProto) Descriptor() ([]byte, []int)

func (*ListCachePoolsResponseProto) GetEntries

func (*ListCachePoolsResponseProto) GetHasMore

func (m *ListCachePoolsResponseProto) GetHasMore() bool

func (*ListCachePoolsResponseProto) ProtoMessage

func (*ListCachePoolsResponseProto) ProtoMessage()

func (*ListCachePoolsResponseProto) Reset

func (m *ListCachePoolsResponseProto) Reset()

func (*ListCachePoolsResponseProto) String

func (m *ListCachePoolsResponseProto) String() string

type ListCorruptFileBlocksRequestProto

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

func (*ListCorruptFileBlocksRequestProto) Descriptor

func (*ListCorruptFileBlocksRequestProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*ListCorruptFileBlocksResponseProto) Descriptor() ([]byte, []int)

func (*ListCorruptFileBlocksResponseProto) GetCorrupt

func (*ListCorruptFileBlocksResponseProto) ProtoMessage

func (*ListCorruptFileBlocksResponseProto) ProtoMessage()

func (*ListCorruptFileBlocksResponseProto) Reset

func (*ListCorruptFileBlocksResponseProto) String

type ListEncryptionZonesRequestProto

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

func (*ListEncryptionZonesRequestProto) Descriptor

func (*ListEncryptionZonesRequestProto) Descriptor() ([]byte, []int)

func (*ListEncryptionZonesRequestProto) GetId

func (*ListEncryptionZonesRequestProto) ProtoMessage

func (*ListEncryptionZonesRequestProto) ProtoMessage()

func (*ListEncryptionZonesRequestProto) Reset

func (*ListEncryptionZonesRequestProto) String

type ListEncryptionZonesResponseProto

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) Descriptor

func (*ListEncryptionZonesResponseProto) Descriptor() ([]byte, []int)

func (*ListEncryptionZonesResponseProto) GetHasMore

func (m *ListEncryptionZonesResponseProto) GetHasMore() bool

func (*ListEncryptionZonesResponseProto) GetZones

func (*ListEncryptionZonesResponseProto) ProtoMessage

func (*ListEncryptionZonesResponseProto) ProtoMessage()

func (*ListEncryptionZonesResponseProto) Reset

func (*ListEncryptionZonesResponseProto) String

type ListReconfigurablePropertiesRequestProto

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

* Query the reconfigurable properties on NN/DN.

func (*ListReconfigurablePropertiesRequestProto) Descriptor

func (*ListReconfigurablePropertiesRequestProto) Descriptor() ([]byte, []int)

func (*ListReconfigurablePropertiesRequestProto) ProtoMessage

func (*ListReconfigurablePropertiesRequestProto) Reset

func (*ListReconfigurablePropertiesRequestProto) String

type ListReconfigurablePropertiesResponseProto

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

func (*ListReconfigurablePropertiesResponseProto) Descriptor

func (*ListReconfigurablePropertiesResponseProto) Descriptor() ([]byte, []int)

func (*ListReconfigurablePropertiesResponseProto) GetName

func (*ListReconfigurablePropertiesResponseProto) ProtoMessage

func (*ListReconfigurablePropertiesResponseProto) Reset

func (*ListReconfigurablePropertiesResponseProto) String

type ListXAttrsRequestProto

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

func (*ListXAttrsRequestProto) Descriptor

func (*ListXAttrsRequestProto) Descriptor() ([]byte, []int)

func (*ListXAttrsRequestProto) GetSrc

func (m *ListXAttrsRequestProto) GetSrc() string

func (*ListXAttrsRequestProto) ProtoMessage

func (*ListXAttrsRequestProto) ProtoMessage()

func (*ListXAttrsRequestProto) Reset

func (m *ListXAttrsRequestProto) Reset()

func (*ListXAttrsRequestProto) String

func (m *ListXAttrsRequestProto) String() string

type ListXAttrsResponseProto

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

func (*ListXAttrsResponseProto) Descriptor

func (*ListXAttrsResponseProto) Descriptor() ([]byte, []int)

func (*ListXAttrsResponseProto) GetXAttrs

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

func (*ListXAttrsResponseProto) ProtoMessage

func (*ListXAttrsResponseProto) ProtoMessage()

func (*ListXAttrsResponseProto) Reset

func (m *ListXAttrsResponseProto) Reset()

func (*ListXAttrsResponseProto) String

func (m *ListXAttrsResponseProto) String() string

type LocatedBlockProto

type LocatedBlockProto struct {
	B            *ExtendedBlockProto       `protobuf:"bytes,1,req,name=b" json:"b,omitempty"`
	Offset       *uint64                   `protobuf:"varint,2,req,name=offset" json:"offset,omitempty"`
	Locs         []*DatanodeInfoProto      `protobuf:"bytes,3,rep,name=locs" json:"locs,omitempty"`
	Corrupt      *bool                     `protobuf:"varint,4,req,name=corrupt" json:"corrupt,omitempty"`
	BlockToken   *hadoop_common.TokenProto `protobuf:"bytes,5,req,name=blockToken" json:"blockToken,omitempty"`
	IsCached     []bool                    `protobuf:"varint,6,rep,packed,name=isCached" json:"isCached,omitempty"`
	StorageTypes []StorageTypeProto        `protobuf:"varint,7,rep,name=storageTypes,enum=hadoop.hdfs.StorageTypeProto" json:"storageTypes,omitempty"`
	StorageIDs   []string                  `protobuf:"bytes,8,rep,name=storageIDs" json:"storageIDs,omitempty"`
	// 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) Descriptor

func (*LocatedBlockProto) Descriptor() ([]byte, []int)

func (*LocatedBlockProto) GetB

func (*LocatedBlockProto) GetBlockIndices

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

func (*LocatedBlockProto) GetBlockToken

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

func (*LocatedBlockProto) GetBlockTokens

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

func (*LocatedBlockProto) GetCorrupt

func (m *LocatedBlockProto) GetCorrupt() bool

func (*LocatedBlockProto) GetIsCached

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

func (*LocatedBlockProto) GetLocs

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

func (*LocatedBlockProto) GetOffset

func (m *LocatedBlockProto) GetOffset() uint64

func (*LocatedBlockProto) GetStorageIDs

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

func (*LocatedBlockProto) GetStorageTypes

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

func (*LocatedBlockProto) ProtoMessage

func (*LocatedBlockProto) ProtoMessage()

func (*LocatedBlockProto) Reset

func (m *LocatedBlockProto) Reset()

func (*LocatedBlockProto) String

func (m *LocatedBlockProto) String() string

type LocatedBlocksProto

type LocatedBlocksProto struct {
	FileLength          *uint64                  `protobuf:"varint,1,req,name=fileLength" json:"fileLength,omitempty"`
	Blocks              []*LocatedBlockProto     `protobuf:"bytes,2,rep,name=blocks" json:"blocks,omitempty"`
	UnderConstruction   *bool                    `protobuf:"varint,3,req,name=underConstruction" json:"underConstruction,omitempty"`
	LastBlock           *LocatedBlockProto       `protobuf:"bytes,4,opt,name=lastBlock" json:"lastBlock,omitempty"`
	IsLastBlockComplete *bool                    `protobuf:"varint,5,req,name=isLastBlockComplete" json:"isLastBlockComplete,omitempty"`
	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) Descriptor

func (*LocatedBlocksProto) Descriptor() ([]byte, []int)

func (*LocatedBlocksProto) GetBlocks

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

func (*LocatedBlocksProto) GetEcPolicy

func (m *LocatedBlocksProto) GetEcPolicy() *ErasureCodingPolicyProto

func (*LocatedBlocksProto) GetFileEncryptionInfo

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) Descriptor

func (*MetaSaveRequestProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*MetaSaveResponseProto) Descriptor() ([]byte, []int)

func (*MetaSaveResponseProto) ProtoMessage

func (*MetaSaveResponseProto) ProtoMessage()

func (*MetaSaveResponseProto) Reset

func (m *MetaSaveResponseProto) Reset()

func (*MetaSaveResponseProto) String

func (m *MetaSaveResponseProto) String() string

type MetadataUpdateEventProto

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) Descriptor

func (*MetadataUpdateEventProto) Descriptor() ([]byte, []int)

func (*MetadataUpdateEventProto) GetAcls

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

func (*MetadataUpdateEventProto) GetAtime

func (m *MetadataUpdateEventProto) GetAtime() int64

func (*MetadataUpdateEventProto) GetGroupName

func (m *MetadataUpdateEventProto) GetGroupName() string

func (*MetadataUpdateEventProto) GetMtime

func (m *MetadataUpdateEventProto) GetMtime() int64

func (*MetadataUpdateEventProto) GetOwnerName

func (m *MetadataUpdateEventProto) GetOwnerName() string

func (*MetadataUpdateEventProto) GetPath

func (m *MetadataUpdateEventProto) GetPath() string

func (*MetadataUpdateEventProto) GetPerms

func (*MetadataUpdateEventProto) GetReplication

func (m *MetadataUpdateEventProto) GetReplication() int32

func (*MetadataUpdateEventProto) GetType

func (*MetadataUpdateEventProto) GetXAttrs

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

func (*MetadataUpdateEventProto) GetXAttrsRemoved

func (m *MetadataUpdateEventProto) GetXAttrsRemoved() bool

func (*MetadataUpdateEventProto) ProtoMessage

func (*MetadataUpdateEventProto) ProtoMessage()

func (*MetadataUpdateEventProto) Reset

func (m *MetadataUpdateEventProto) Reset()

func (*MetadataUpdateEventProto) String

func (m *MetadataUpdateEventProto) String() string

type MetadataUpdateType

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

func (MetadataUpdateType) EnumDescriptor

func (MetadataUpdateType) EnumDescriptor() ([]byte, []int)

func (MetadataUpdateType) String

func (x MetadataUpdateType) String() string

func (*MetadataUpdateType) UnmarshalJSON

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) Descriptor

func (*MkdirsRequestProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*MkdirsResponseProto) Descriptor() ([]byte, []int)

func (*MkdirsResponseProto) GetResult

func (m *MkdirsResponseProto) GetResult() bool

func (*MkdirsResponseProto) ProtoMessage

func (*MkdirsResponseProto) ProtoMessage()

func (*MkdirsResponseProto) Reset

func (m *MkdirsResponseProto) Reset()

func (*MkdirsResponseProto) String

func (m *MkdirsResponseProto) String() string

type ModifyAclEntriesRequestProto

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

func (*ModifyAclEntriesRequestProto) Descriptor

func (*ModifyAclEntriesRequestProto) Descriptor() ([]byte, []int)

func (*ModifyAclEntriesRequestProto) GetAclSpec

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

func (*ModifyAclEntriesRequestProto) GetSrc

func (*ModifyAclEntriesRequestProto) ProtoMessage

func (*ModifyAclEntriesRequestProto) ProtoMessage()

func (*ModifyAclEntriesRequestProto) Reset

func (m *ModifyAclEntriesRequestProto) Reset()

func (*ModifyAclEntriesRequestProto) String

type ModifyAclEntriesResponseProto

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

func (*ModifyAclEntriesResponseProto) Descriptor

func (*ModifyAclEntriesResponseProto) Descriptor() ([]byte, []int)

func (*ModifyAclEntriesResponseProto) ProtoMessage

func (*ModifyAclEntriesResponseProto) ProtoMessage()

func (*ModifyAclEntriesResponseProto) Reset

func (m *ModifyAclEntriesResponseProto) Reset()

func (*ModifyAclEntriesResponseProto) String

type ModifyCacheDirectiveRequestProto

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

func (*ModifyCacheDirectiveRequestProto) Descriptor

func (*ModifyCacheDirectiveRequestProto) Descriptor() ([]byte, []int)

func (*ModifyCacheDirectiveRequestProto) GetCacheFlags

func (m *ModifyCacheDirectiveRequestProto) GetCacheFlags() uint32

func (*ModifyCacheDirectiveRequestProto) GetInfo

func (*ModifyCacheDirectiveRequestProto) ProtoMessage

func (*ModifyCacheDirectiveRequestProto) ProtoMessage()

func (*ModifyCacheDirectiveRequestProto) Reset

func (*ModifyCacheDirectiveRequestProto) String

type ModifyCacheDirectiveResponseProto

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

func (*ModifyCacheDirectiveResponseProto) Descriptor

func (*ModifyCacheDirectiveResponseProto) Descriptor() ([]byte, []int)

func (*ModifyCacheDirectiveResponseProto) ProtoMessage

func (*ModifyCacheDirectiveResponseProto) ProtoMessage()

func (*ModifyCacheDirectiveResponseProto) Reset

func (*ModifyCacheDirectiveResponseProto) String

type ModifyCachePoolRequestProto

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

func (*ModifyCachePoolRequestProto) Descriptor

func (*ModifyCachePoolRequestProto) Descriptor() ([]byte, []int)

func (*ModifyCachePoolRequestProto) GetInfo

func (*ModifyCachePoolRequestProto) ProtoMessage

func (*ModifyCachePoolRequestProto) ProtoMessage()

func (*ModifyCachePoolRequestProto) Reset

func (m *ModifyCachePoolRequestProto) Reset()

func (*ModifyCachePoolRequestProto) String

func (m *ModifyCachePoolRequestProto) String() string

type ModifyCachePoolResponseProto

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

func (*ModifyCachePoolResponseProto) Descriptor

func (*ModifyCachePoolResponseProto) Descriptor() ([]byte, []int)

func (*ModifyCachePoolResponseProto) ProtoMessage

func (*ModifyCachePoolResponseProto) ProtoMessage()

func (*ModifyCachePoolResponseProto) Reset

func (m *ModifyCachePoolResponseProto) Reset()

func (*ModifyCachePoolResponseProto) String

type OpBlockChecksumProto

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

func (*OpBlockChecksumProto) Descriptor

func (*OpBlockChecksumProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*OpBlockChecksumResponseProto) Descriptor() ([]byte, []int)

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

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) Descriptor

func (*OpBlockGroupChecksumProto) Descriptor() ([]byte, []int)

func (*OpBlockGroupChecksumProto) GetBlockTokens

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

func (*OpBlockGroupChecksumProto) GetDatanodes

func (m *OpBlockGroupChecksumProto) GetDatanodes() *DatanodeInfosProto

func (*OpBlockGroupChecksumProto) GetEcPolicy

func (*OpBlockGroupChecksumProto) GetHeader

func (*OpBlockGroupChecksumProto) ProtoMessage

func (*OpBlockGroupChecksumProto) ProtoMessage()

func (*OpBlockGroupChecksumProto) Reset

func (m *OpBlockGroupChecksumProto) Reset()

func (*OpBlockGroupChecksumProto) String

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) Descriptor

func (*OpCopyBlockProto) Descriptor() ([]byte, []int)

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

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

func (*OpCustomProto) Descriptor

func (*OpCustomProto) Descriptor() ([]byte, []int)

func (*OpCustomProto) GetCustomId

func (m *OpCustomProto) GetCustomId() string

func (*OpCustomProto) ProtoMessage

func (*OpCustomProto) ProtoMessage()

func (*OpCustomProto) Reset

func (m *OpCustomProto) Reset()

func (*OpCustomProto) String

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) Descriptor

func (*OpReadBlockProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*OpReplaceBlockProto) Descriptor() ([]byte, []int)

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

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) Descriptor

func (*OpRequestShortCircuitAccessProto) Descriptor() ([]byte, []int)

func (*OpRequestShortCircuitAccessProto) GetHeader

func (*OpRequestShortCircuitAccessProto) GetMaxVersion

func (m *OpRequestShortCircuitAccessProto) GetMaxVersion() uint32

func (*OpRequestShortCircuitAccessProto) GetSlotId

func (*OpRequestShortCircuitAccessProto) GetSupportsReceiptVerification

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) Descriptor

func (*OpTransferBlockProto) Descriptor() ([]byte, []int)

func (*OpTransferBlockProto) GetHeader

func (*OpTransferBlockProto) GetTargetStorageTypes

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) Descriptor

func (*OpWriteBlockProto) Descriptor() ([]byte, []int)

func (*OpWriteBlockProto) GetAllowLazyPersist

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

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

func (m *OpWriteBlockProto) GetStorageType() StorageTypeProto

func (*OpWriteBlockProto) GetTargetPinnings

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

func (*OpWriteBlockProto) GetTargetStorageTypes

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) EnumDescriptor

func (OpWriteBlockProto_BlockConstructionStage) EnumDescriptor() ([]byte, []int)

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) Descriptor

func (*PacketHeaderProto) Descriptor() ([]byte, []int)

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

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) Descriptor

func (*PerFileEncryptionInfoProto) Descriptor() ([]byte, []int)

func (*PerFileEncryptionInfoProto) GetEzKeyVersionName

func (m *PerFileEncryptionInfoProto) GetEzKeyVersionName() string

func (*PerFileEncryptionInfoProto) GetIv

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

func (*PerFileEncryptionInfoProto) GetKey

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

func (*PerFileEncryptionInfoProto) ProtoMessage

func (*PerFileEncryptionInfoProto) ProtoMessage()

func (*PerFileEncryptionInfoProto) Reset

func (m *PerFileEncryptionInfoProto) Reset()

func (*PerFileEncryptionInfoProto) String

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) Descriptor

func (*PipelineAckProto) Descriptor() ([]byte, []int)

func (*PipelineAckProto) GetDownstreamAckTimeNanos

func (m *PipelineAckProto) GetDownstreamAckTimeNanos() uint64

func (*PipelineAckProto) GetFlag

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

func (*PipelineAckProto) GetReply

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

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) Descriptor

func (*QuotaUsageProto) Descriptor() ([]byte, []int)

func (*QuotaUsageProto) GetFileAndDirectoryCount

func (m *QuotaUsageProto) GetFileAndDirectoryCount() uint64

func (*QuotaUsageProto) GetQuota

func (m *QuotaUsageProto) GetQuota() uint64

func (*QuotaUsageProto) GetSpaceConsumed

func (m *QuotaUsageProto) GetSpaceConsumed() uint64

func (*QuotaUsageProto) GetSpaceQuota

func (m *QuotaUsageProto) GetSpaceQuota() uint64

func (*QuotaUsageProto) GetTypeQuotaInfos

func (m *QuotaUsageProto) GetTypeQuotaInfos() *StorageTypeQuotaInfosProto

func (*QuotaUsageProto) ProtoMessage

func (*QuotaUsageProto) ProtoMessage()

func (*QuotaUsageProto) Reset

func (m *QuotaUsageProto) Reset()

func (*QuotaUsageProto) String

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) Descriptor

func (*ReadOpChecksumInfoProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*RecoverLeaseRequestProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*RecoverLeaseResponseProto) Descriptor() ([]byte, []int)

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

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

* void request

func (*RefreshNamenodesRequestProto) Descriptor

func (*RefreshNamenodesRequestProto) Descriptor() ([]byte, []int)

func (*RefreshNamenodesRequestProto) ProtoMessage

func (*RefreshNamenodesRequestProto) ProtoMessage()

func (*RefreshNamenodesRequestProto) Reset

func (m *RefreshNamenodesRequestProto) Reset()

func (*RefreshNamenodesRequestProto) String

type RefreshNamenodesResponseProto

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

* void response

func (*RefreshNamenodesResponseProto) Descriptor

func (*RefreshNamenodesResponseProto) Descriptor() ([]byte, []int)

func (*RefreshNamenodesResponseProto) ProtoMessage

func (*RefreshNamenodesResponseProto) ProtoMessage()

func (*RefreshNamenodesResponseProto) Reset

func (m *RefreshNamenodesResponseProto) Reset()

func (*RefreshNamenodesResponseProto) String

type RefreshNodesRequestProto

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

func (*RefreshNodesRequestProto) Descriptor

func (*RefreshNodesRequestProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*RefreshNodesResponseProto) Descriptor() ([]byte, []int)

func (*RefreshNodesResponseProto) ProtoMessage

func (*RefreshNodesResponseProto) ProtoMessage()

func (*RefreshNodesResponseProto) Reset

func (m *RefreshNodesResponseProto) Reset()

func (*RefreshNodesResponseProto) String

func (m *RefreshNodesResponseProto) String() string

type ReleaseShortCircuitAccessRequestProto

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

func (*ReleaseShortCircuitAccessRequestProto) Descriptor

func (*ReleaseShortCircuitAccessRequestProto) Descriptor() ([]byte, []int)

func (*ReleaseShortCircuitAccessRequestProto) GetSlotId

func (*ReleaseShortCircuitAccessRequestProto) GetTraceInfo

func (*ReleaseShortCircuitAccessRequestProto) ProtoMessage

func (*ReleaseShortCircuitAccessRequestProto) ProtoMessage()

func (*ReleaseShortCircuitAccessRequestProto) Reset

func (*ReleaseShortCircuitAccessRequestProto) String

type ReleaseShortCircuitAccessResponseProto

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

func (*ReleaseShortCircuitAccessResponseProto) Descriptor

func (*ReleaseShortCircuitAccessResponseProto) Descriptor() ([]byte, []int)

func (*ReleaseShortCircuitAccessResponseProto) GetError

func (*ReleaseShortCircuitAccessResponseProto) GetStatus

func (*ReleaseShortCircuitAccessResponseProto) ProtoMessage

func (*ReleaseShortCircuitAccessResponseProto) Reset

func (*ReleaseShortCircuitAccessResponseProto) String

type RemoveAclEntriesRequestProto

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

func (*RemoveAclEntriesRequestProto) Descriptor

func (*RemoveAclEntriesRequestProto) Descriptor() ([]byte, []int)

func (*RemoveAclEntriesRequestProto) GetAclSpec

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

func (*RemoveAclEntriesRequestProto) GetSrc

func (*RemoveAclEntriesRequestProto) ProtoMessage

func (*RemoveAclEntriesRequestProto) ProtoMessage()

func (*RemoveAclEntriesRequestProto) Reset

func (m *RemoveAclEntriesRequestProto) Reset()

func (*RemoveAclEntriesRequestProto) String

type RemoveAclEntriesResponseProto

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

func (*RemoveAclEntriesResponseProto) Descriptor

func (*RemoveAclEntriesResponseProto) Descriptor() ([]byte, []int)

func (*RemoveAclEntriesResponseProto) ProtoMessage

func (*RemoveAclEntriesResponseProto) ProtoMessage()

func (*RemoveAclEntriesResponseProto) Reset

func (m *RemoveAclEntriesResponseProto) Reset()

func (*RemoveAclEntriesResponseProto) String

type RemoveAclRequestProto

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

func (*RemoveAclRequestProto) Descriptor

func (*RemoveAclRequestProto) Descriptor() ([]byte, []int)

func (*RemoveAclRequestProto) GetSrc

func (m *RemoveAclRequestProto) GetSrc() string

func (*RemoveAclRequestProto) ProtoMessage

func (*RemoveAclRequestProto) ProtoMessage()

func (*RemoveAclRequestProto) Reset

func (m *RemoveAclRequestProto) Reset()

func (*RemoveAclRequestProto) String

func (m *RemoveAclRequestProto) String() string

type RemoveAclResponseProto

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

func (*RemoveAclResponseProto) Descriptor

func (*RemoveAclResponseProto) Descriptor() ([]byte, []int)

func (*RemoveAclResponseProto) ProtoMessage

func (*RemoveAclResponseProto) ProtoMessage()

func (*RemoveAclResponseProto) Reset

func (m *RemoveAclResponseProto) Reset()

func (*RemoveAclResponseProto) String

func (m *RemoveAclResponseProto) String() string

type RemoveCacheDirectiveRequestProto

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

func (*RemoveCacheDirectiveRequestProto) Descriptor

func (*RemoveCacheDirectiveRequestProto) Descriptor() ([]byte, []int)

func (*RemoveCacheDirectiveRequestProto) GetId

func (*RemoveCacheDirectiveRequestProto) ProtoMessage

func (*RemoveCacheDirectiveRequestProto) ProtoMessage()

func (*RemoveCacheDirectiveRequestProto) Reset

func (*RemoveCacheDirectiveRequestProto) String

type RemoveCacheDirectiveResponseProto

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

func (*RemoveCacheDirectiveResponseProto) Descriptor

func (*RemoveCacheDirectiveResponseProto) Descriptor() ([]byte, []int)

func (*RemoveCacheDirectiveResponseProto) ProtoMessage

func (*RemoveCacheDirectiveResponseProto) ProtoMessage()

func (*RemoveCacheDirectiveResponseProto) Reset

func (*RemoveCacheDirectiveResponseProto) String

type RemoveCachePoolRequestProto

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

func (*RemoveCachePoolRequestProto) Descriptor

func (*RemoveCachePoolRequestProto) Descriptor() ([]byte, []int)

func (*RemoveCachePoolRequestProto) GetPoolName

func (m *RemoveCachePoolRequestProto) GetPoolName() string

func (*RemoveCachePoolRequestProto) ProtoMessage

func (*RemoveCachePoolRequestProto) ProtoMessage()

func (*RemoveCachePoolRequestProto) Reset

func (m *RemoveCachePoolRequestProto) Reset()

func (*RemoveCachePoolRequestProto) String

func (m *RemoveCachePoolRequestProto) String() string

type RemoveCachePoolResponseProto

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

func (*RemoveCachePoolResponseProto) Descriptor

func (*RemoveCachePoolResponseProto) Descriptor() ([]byte, []int)

func (*RemoveCachePoolResponseProto) ProtoMessage

func (*RemoveCachePoolResponseProto) ProtoMessage()

func (*RemoveCachePoolResponseProto) Reset

func (m *RemoveCachePoolResponseProto) Reset()

func (*RemoveCachePoolResponseProto) String

type RemoveDefaultAclRequestProto

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

func (*RemoveDefaultAclRequestProto) Descriptor

func (*RemoveDefaultAclRequestProto) Descriptor() ([]byte, []int)

func (*RemoveDefaultAclRequestProto) GetSrc

func (*RemoveDefaultAclRequestProto) ProtoMessage

func (*RemoveDefaultAclRequestProto) ProtoMessage()

func (*RemoveDefaultAclRequestProto) Reset

func (m *RemoveDefaultAclRequestProto) Reset()

func (*RemoveDefaultAclRequestProto) String

type RemoveDefaultAclResponseProto

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

func (*RemoveDefaultAclResponseProto) Descriptor

func (*RemoveDefaultAclResponseProto) Descriptor() ([]byte, []int)

func (*RemoveDefaultAclResponseProto) ProtoMessage

func (*RemoveDefaultAclResponseProto) ProtoMessage()

func (*RemoveDefaultAclResponseProto) Reset

func (m *RemoveDefaultAclResponseProto) Reset()

func (*RemoveDefaultAclResponseProto) String

type RemoveXAttrRequestProto

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

func (*RemoveXAttrRequestProto) Descriptor

func (*RemoveXAttrRequestProto) Descriptor() ([]byte, []int)

func (*RemoveXAttrRequestProto) GetSrc

func (m *RemoveXAttrRequestProto) GetSrc() string

func (*RemoveXAttrRequestProto) GetXAttr

func (m *RemoveXAttrRequestProto) GetXAttr() *XAttrProto

func (*RemoveXAttrRequestProto) ProtoMessage

func (*RemoveXAttrRequestProto) ProtoMessage()

func (*RemoveXAttrRequestProto) Reset

func (m *RemoveXAttrRequestProto) Reset()

func (*RemoveXAttrRequestProto) String

func (m *RemoveXAttrRequestProto) String() string

type RemoveXAttrResponseProto

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

func (*RemoveXAttrResponseProto) Descriptor

func (*RemoveXAttrResponseProto) Descriptor() ([]byte, []int)

func (*RemoveXAttrResponseProto) ProtoMessage

func (*RemoveXAttrResponseProto) ProtoMessage()

func (*RemoveXAttrResponseProto) Reset

func (m *RemoveXAttrResponseProto) Reset()

func (*RemoveXAttrResponseProto) String

func (m *RemoveXAttrResponseProto) String() string

type Rename2RequestProto

type Rename2RequestProto struct {
	Src              *string `protobuf:"bytes,1,req,name=src" json:"src,omitempty"`
	Dst              *string `protobuf:"bytes,2,req,name=dst" json:"dst,omitempty"`
	OverwriteDest    *bool   `protobuf:"varint,3,req,name=overwriteDest" json:"overwriteDest,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*Rename2RequestProto) Descriptor

func (*Rename2RequestProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*Rename2ResponseProto) Descriptor() ([]byte, []int)

func (*Rename2ResponseProto) ProtoMessage

func (*Rename2ResponseProto) ProtoMessage()

func (*Rename2ResponseProto) Reset

func (m *Rename2ResponseProto) Reset()

func (*Rename2ResponseProto) String

func (m *Rename2ResponseProto) String() string

type RenameEventProto

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) Descriptor

func (*RenameEventProto) Descriptor() ([]byte, []int)

func (*RenameEventProto) GetDestPath

func (m *RenameEventProto) GetDestPath() string

func (*RenameEventProto) GetSrcPath

func (m *RenameEventProto) GetSrcPath() string

func (*RenameEventProto) GetTimestamp

func (m *RenameEventProto) GetTimestamp() int64

func (*RenameEventProto) ProtoMessage

func (*RenameEventProto) ProtoMessage()

func (*RenameEventProto) Reset

func (m *RenameEventProto) Reset()

func (*RenameEventProto) String

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) Descriptor

func (*RenameRequestProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*RenameResponseProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*RenameSnapshotRequestProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*RenameSnapshotResponseProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*RenewLeaseRequestProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*RenewLeaseResponseProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*ReportBadBlocksRequestProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*ReportBadBlocksResponseProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*RestoreFailedStorageRequestProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*RestoreFailedStorageResponseProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*RollEditsRequestProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*RollEditsResponseProto) Descriptor() ([]byte, []int)

func (*RollEditsResponseProto) GetNewSegmentTxId

func (m *RollEditsResponseProto) GetNewSegmentTxId() uint64

func (*RollEditsResponseProto) ProtoMessage

func (*RollEditsResponseProto) ProtoMessage()

func (*RollEditsResponseProto) Reset

func (m *RollEditsResponseProto) Reset()

func (*RollEditsResponseProto) String

func (m *RollEditsResponseProto) String() string

type RollingUpgradeActionProto

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

func (RollingUpgradeActionProto) Enum

func (RollingUpgradeActionProto) EnumDescriptor

func (RollingUpgradeActionProto) EnumDescriptor() ([]byte, []int)

func (RollingUpgradeActionProto) String

func (x RollingUpgradeActionProto) String() string

func (*RollingUpgradeActionProto) UnmarshalJSON

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

type RollingUpgradeInfoProto

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

func (*RollingUpgradeInfoProto) Descriptor

func (*RollingUpgradeInfoProto) Descriptor() ([]byte, []int)

func (*RollingUpgradeInfoProto) GetCreatedRollbackImages

func (m *RollingUpgradeInfoProto) GetCreatedRollbackImages() bool

func (*RollingUpgradeInfoProto) GetFinalizeTime

func (m *RollingUpgradeInfoProto) GetFinalizeTime() uint64

func (*RollingUpgradeInfoProto) GetStartTime

func (m *RollingUpgradeInfoProto) GetStartTime() uint64

func (*RollingUpgradeInfoProto) GetStatus

func (*RollingUpgradeInfoProto) ProtoMessage

func (*RollingUpgradeInfoProto) ProtoMessage()

func (*RollingUpgradeInfoProto) Reset

func (m *RollingUpgradeInfoProto) Reset()

func (*RollingUpgradeInfoProto) String

func (m *RollingUpgradeInfoProto) String() string

type RollingUpgradeRequestProto

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

func (*RollingUpgradeRequestProto) Descriptor

func (*RollingUpgradeRequestProto) Descriptor() ([]byte, []int)

func (*RollingUpgradeRequestProto) GetAction

func (*RollingUpgradeRequestProto) ProtoMessage

func (*RollingUpgradeRequestProto) ProtoMessage()

func (*RollingUpgradeRequestProto) Reset

func (m *RollingUpgradeRequestProto) Reset()

func (*RollingUpgradeRequestProto) String

func (m *RollingUpgradeRequestProto) String() string

type RollingUpgradeResponseProto

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

func (*RollingUpgradeResponseProto) Descriptor

func (*RollingUpgradeResponseProto) Descriptor() ([]byte, []int)

func (*RollingUpgradeResponseProto) GetRollingUpgradeInfo

func (m *RollingUpgradeResponseProto) GetRollingUpgradeInfo() *RollingUpgradeInfoProto

func (*RollingUpgradeResponseProto) ProtoMessage

func (*RollingUpgradeResponseProto) ProtoMessage()

func (*RollingUpgradeResponseProto) Reset

func (m *RollingUpgradeResponseProto) Reset()

func (*RollingUpgradeResponseProto) String

func (m *RollingUpgradeResponseProto) String() string

type RollingUpgradeStatusProto

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

* Rolling upgrade status

func (*RollingUpgradeStatusProto) Descriptor

func (*RollingUpgradeStatusProto) Descriptor() ([]byte, []int)

func (*RollingUpgradeStatusProto) GetBlockPoolId

func (m *RollingUpgradeStatusProto) GetBlockPoolId() string

func (*RollingUpgradeStatusProto) GetFinalized

func (m *RollingUpgradeStatusProto) GetFinalized() bool

func (*RollingUpgradeStatusProto) ProtoMessage

func (*RollingUpgradeStatusProto) ProtoMessage()

func (*RollingUpgradeStatusProto) Reset

func (m *RollingUpgradeStatusProto) Reset()

func (*RollingUpgradeStatusProto) String

func (m *RollingUpgradeStatusProto) String() string

type SafeModeActionProto

type SafeModeActionProto int32
const (
	SafeModeActionProto_SAFEMODE_LEAVE      SafeModeActionProto = 1
	SafeModeActionProto_SAFEMODE_ENTER      SafeModeActionProto = 2
	SafeModeActionProto_SAFEMODE_GET        SafeModeActionProto = 3
	SafeModeActionProto_SAFEMODE_FORCE_EXIT SafeModeActionProto = 4
)

func (SafeModeActionProto) Enum

func (SafeModeActionProto) EnumDescriptor

func (SafeModeActionProto) EnumDescriptor() ([]byte, []int)

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) Descriptor

func (*SaveNamespaceRequestProto) Descriptor() ([]byte, []int)

func (*SaveNamespaceRequestProto) GetTimeWindow

func (m *SaveNamespaceRequestProto) GetTimeWindow() uint64

func (*SaveNamespaceRequestProto) GetTxGap

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) Descriptor

func (*SaveNamespaceResponseProto) Descriptor() ([]byte, []int)

func (*SaveNamespaceResponseProto) GetSaved

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

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) Descriptor

func (*SetAclRequestProto) Descriptor() ([]byte, []int)

func (*SetAclRequestProto) GetAclSpec

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

func (*SetAclRequestProto) GetSrc

func (m *SetAclRequestProto) GetSrc() string

func (*SetAclRequestProto) ProtoMessage

func (*SetAclRequestProto) ProtoMessage()

func (*SetAclRequestProto) Reset

func (m *SetAclRequestProto) Reset()

func (*SetAclRequestProto) String

func (m *SetAclRequestProto) String() string

type SetAclResponseProto

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

func (*SetAclResponseProto) Descriptor

func (*SetAclResponseProto) Descriptor() ([]byte, []int)

func (*SetAclResponseProto) ProtoMessage

func (*SetAclResponseProto) ProtoMessage()

func (*SetAclResponseProto) Reset

func (m *SetAclResponseProto) Reset()

func (*SetAclResponseProto) String

func (m *SetAclResponseProto) String() string

type SetBalancerBandwidthRequestProto

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

func (*SetBalancerBandwidthRequestProto) Descriptor

func (*SetBalancerBandwidthRequestProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*SetBalancerBandwidthResponseProto) Descriptor() ([]byte, []int)

func (*SetBalancerBandwidthResponseProto) ProtoMessage

func (*SetBalancerBandwidthResponseProto) ProtoMessage()

func (*SetBalancerBandwidthResponseProto) Reset

func (*SetBalancerBandwidthResponseProto) String

type SetErasureCodingPolicyRequestProto

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) Descriptor

func (*SetErasureCodingPolicyRequestProto) Descriptor() ([]byte, []int)

func (*SetErasureCodingPolicyRequestProto) GetEcPolicy

func (*SetErasureCodingPolicyRequestProto) GetSrc

func (*SetErasureCodingPolicyRequestProto) ProtoMessage

func (*SetErasureCodingPolicyRequestProto) ProtoMessage()

func (*SetErasureCodingPolicyRequestProto) Reset

func (*SetErasureCodingPolicyRequestProto) String

type SetErasureCodingPolicyResponseProto

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

func (*SetErasureCodingPolicyResponseProto) Descriptor

func (*SetErasureCodingPolicyResponseProto) Descriptor() ([]byte, []int)

func (*SetErasureCodingPolicyResponseProto) ProtoMessage

func (*SetErasureCodingPolicyResponseProto) ProtoMessage()

func (*SetErasureCodingPolicyResponseProto) Reset

func (*SetErasureCodingPolicyResponseProto) String

type SetOwnerRequestProto

type SetOwnerRequestProto struct {
	Src              *string `protobuf:"bytes,1,req,name=src" json:"src,omitempty"`
	Username         *string `protobuf:"bytes,2,opt,name=username" json:"username,omitempty"`
	Groupname        *string `protobuf:"bytes,3,opt,name=groupname" json:"groupname,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*SetOwnerRequestProto) Descriptor

func (*SetOwnerRequestProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*SetOwnerResponseProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*SetPermissionRequestProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*SetPermissionResponseProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*SetQuotaRequestProto) Descriptor() ([]byte, []int)

func (*SetQuotaRequestProto) GetNamespaceQuota

func (m *SetQuotaRequestProto) GetNamespaceQuota() uint64

func (*SetQuotaRequestProto) GetPath

func (m *SetQuotaRequestProto) GetPath() string

func (*SetQuotaRequestProto) GetStorageType

func (m *SetQuotaRequestProto) GetStorageType() StorageTypeProto

func (*SetQuotaRequestProto) GetStoragespaceQuota

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) Descriptor

func (*SetQuotaResponseProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*SetReplicationRequestProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*SetReplicationResponseProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*SetSafeModeRequestProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*SetSafeModeResponseProto) Descriptor() ([]byte, []int)

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

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) Descriptor

func (*SetStoragePolicyRequestProto) Descriptor() ([]byte, []int)

func (*SetStoragePolicyRequestProto) GetPolicyName

func (m *SetStoragePolicyRequestProto) GetPolicyName() string

func (*SetStoragePolicyRequestProto) GetSrc

func (*SetStoragePolicyRequestProto) ProtoMessage

func (*SetStoragePolicyRequestProto) ProtoMessage()

func (*SetStoragePolicyRequestProto) Reset

func (m *SetStoragePolicyRequestProto) Reset()

func (*SetStoragePolicyRequestProto) String

type SetStoragePolicyResponseProto

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

func (*SetStoragePolicyResponseProto) Descriptor

func (*SetStoragePolicyResponseProto) Descriptor() ([]byte, []int)

func (*SetStoragePolicyResponseProto) ProtoMessage

func (*SetStoragePolicyResponseProto) ProtoMessage()

func (*SetStoragePolicyResponseProto) Reset

func (m *SetStoragePolicyResponseProto) Reset()

func (*SetStoragePolicyResponseProto) String

type SetTimesRequestProto

type SetTimesRequestProto struct {
	Src              *string `protobuf:"bytes,1,req,name=src" json:"src,omitempty"`
	Mtime            *uint64 `protobuf:"varint,2,req,name=mtime" json:"mtime,omitempty"`
	Atime            *uint64 `protobuf:"varint,3,req,name=atime" json:"atime,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*SetTimesRequestProto) Descriptor

func (*SetTimesRequestProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*SetTimesResponseProto) Descriptor() ([]byte, []int)

func (*SetTimesResponseProto) ProtoMessage

func (*SetTimesResponseProto) ProtoMessage()

func (*SetTimesResponseProto) Reset

func (m *SetTimesResponseProto) Reset()

func (*SetTimesResponseProto) String

func (m *SetTimesResponseProto) String() string

type SetXAttrRequestProto

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

func (*SetXAttrRequestProto) Descriptor

func (*SetXAttrRequestProto) Descriptor() ([]byte, []int)

func (*SetXAttrRequestProto) GetFlag

func (m *SetXAttrRequestProto) GetFlag() uint32

func (*SetXAttrRequestProto) GetSrc

func (m *SetXAttrRequestProto) GetSrc() string

func (*SetXAttrRequestProto) GetXAttr

func (m *SetXAttrRequestProto) GetXAttr() *XAttrProto

func (*SetXAttrRequestProto) ProtoMessage

func (*SetXAttrRequestProto) ProtoMessage()

func (*SetXAttrRequestProto) Reset

func (m *SetXAttrRequestProto) Reset()

func (*SetXAttrRequestProto) String

func (m *SetXAttrRequestProto) String() string

type SetXAttrResponseProto

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

func (*SetXAttrResponseProto) Descriptor

func (*SetXAttrResponseProto) Descriptor() ([]byte, []int)

func (*SetXAttrResponseProto) ProtoMessage

func (*SetXAttrResponseProto) ProtoMessage()

func (*SetXAttrResponseProto) Reset

func (m *SetXAttrResponseProto) Reset()

func (*SetXAttrResponseProto) String

func (m *SetXAttrResponseProto) String() string

type ShortCircuitFdResponse

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

func (ShortCircuitFdResponse) Enum

func (ShortCircuitFdResponse) EnumDescriptor

func (ShortCircuitFdResponse) EnumDescriptor() ([]byte, []int)

func (ShortCircuitFdResponse) String

func (x ShortCircuitFdResponse) String() string

func (*ShortCircuitFdResponse) UnmarshalJSON

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

type ShortCircuitShmIdProto

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

* An ID uniquely identifying a shared memory segment.

func (*ShortCircuitShmIdProto) Descriptor

func (*ShortCircuitShmIdProto) Descriptor() ([]byte, []int)

func (*ShortCircuitShmIdProto) GetHi

func (m *ShortCircuitShmIdProto) GetHi() int64

func (*ShortCircuitShmIdProto) GetLo

func (m *ShortCircuitShmIdProto) GetLo() int64

func (*ShortCircuitShmIdProto) ProtoMessage

func (*ShortCircuitShmIdProto) ProtoMessage()

func (*ShortCircuitShmIdProto) Reset

func (m *ShortCircuitShmIdProto) Reset()

func (*ShortCircuitShmIdProto) String

func (m *ShortCircuitShmIdProto) String() string

type ShortCircuitShmRequestProto

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

func (*ShortCircuitShmRequestProto) Descriptor

func (*ShortCircuitShmRequestProto) Descriptor() ([]byte, []int)

func (*ShortCircuitShmRequestProto) GetClientName

func (m *ShortCircuitShmRequestProto) GetClientName() string

func (*ShortCircuitShmRequestProto) GetTraceInfo

func (*ShortCircuitShmRequestProto) ProtoMessage

func (*ShortCircuitShmRequestProto) ProtoMessage()

func (*ShortCircuitShmRequestProto) Reset

func (m *ShortCircuitShmRequestProto) Reset()

func (*ShortCircuitShmRequestProto) String

func (m *ShortCircuitShmRequestProto) String() string

type ShortCircuitShmResponseProto

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

func (*ShortCircuitShmResponseProto) Descriptor

func (*ShortCircuitShmResponseProto) Descriptor() ([]byte, []int)

func (*ShortCircuitShmResponseProto) GetError

func (m *ShortCircuitShmResponseProto) GetError() string

func (*ShortCircuitShmResponseProto) GetId

func (*ShortCircuitShmResponseProto) GetStatus

func (m *ShortCircuitShmResponseProto) GetStatus() Status

func (*ShortCircuitShmResponseProto) ProtoMessage

func (*ShortCircuitShmResponseProto) ProtoMessage()

func (*ShortCircuitShmResponseProto) Reset

func (m *ShortCircuitShmResponseProto) Reset()

func (*ShortCircuitShmResponseProto) String

type ShortCircuitShmSlotProto

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

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

func (*ShortCircuitShmSlotProto) Descriptor

func (*ShortCircuitShmSlotProto) Descriptor() ([]byte, []int)

func (*ShortCircuitShmSlotProto) GetShmId

func (*ShortCircuitShmSlotProto) GetSlotIdx

func (m *ShortCircuitShmSlotProto) GetSlotIdx() int32

func (*ShortCircuitShmSlotProto) ProtoMessage

func (*ShortCircuitShmSlotProto) ProtoMessage()

func (*ShortCircuitShmSlotProto) Reset

func (m *ShortCircuitShmSlotProto) Reset()

func (*ShortCircuitShmSlotProto) String

func (m *ShortCircuitShmSlotProto) String() string

type ShutdownDatanodeRequestProto

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

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

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

func (*ShutdownDatanodeRequestProto) Descriptor

func (*ShutdownDatanodeRequestProto) Descriptor() ([]byte, []int)

func (*ShutdownDatanodeRequestProto) GetForUpgrade

func (m *ShutdownDatanodeRequestProto) GetForUpgrade() bool

func (*ShutdownDatanodeRequestProto) ProtoMessage

func (*ShutdownDatanodeRequestProto) ProtoMessage()

func (*ShutdownDatanodeRequestProto) Reset

func (m *ShutdownDatanodeRequestProto) Reset()

func (*ShutdownDatanodeRequestProto) String

type ShutdownDatanodeResponseProto

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

func (*ShutdownDatanodeResponseProto) Descriptor

func (*ShutdownDatanodeResponseProto) Descriptor() ([]byte, []int)

func (*ShutdownDatanodeResponseProto) ProtoMessage

func (*ShutdownDatanodeResponseProto) ProtoMessage()

func (*ShutdownDatanodeResponseProto) Reset

func (m *ShutdownDatanodeResponseProto) Reset()

func (*ShutdownDatanodeResponseProto) String

type SnapshotDiffReportEntryProto

type SnapshotDiffReportEntryProto struct {
	Fullpath          []byte  `protobuf:"bytes,1,req,name=fullpath" json:"fullpath,omitempty"`
	ModificationLabel *string `protobuf:"bytes,2,req,name=modificationLabel" json:"modificationLabel,omitempty"`
	TargetPath        []byte  `protobuf:"bytes,3,opt,name=targetPath" json:"targetPath,omitempty"`
	XXX_unrecognized  []byte  `json:"-"`
}

* Snapshot diff report entry

func (*SnapshotDiffReportEntryProto) Descriptor

func (*SnapshotDiffReportEntryProto) Descriptor() ([]byte, []int)

func (*SnapshotDiffReportEntryProto) GetFullpath

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

func (*SnapshotDiffReportEntryProto) GetModificationLabel

func (m *SnapshotDiffReportEntryProto) GetModificationLabel() string

func (*SnapshotDiffReportEntryProto) GetTargetPath

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

func (*SnapshotDiffReportEntryProto) ProtoMessage

func (*SnapshotDiffReportEntryProto) ProtoMessage()

func (*SnapshotDiffReportEntryProto) Reset

func (m *SnapshotDiffReportEntryProto) Reset()

func (*SnapshotDiffReportEntryProto) String

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) Descriptor

func (*SnapshotDiffReportProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*SnapshotInfoProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*SnapshottableDirectoryListingProto) Descriptor() ([]byte, []int)

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=snapshotQuota" json:"snapshot_quota,omitempty"`
	SnapshotNumber   *uint32 `protobuf:"varint,3,req,name=snapshot_number,json=snapshotNumber" json:"snapshot_number,omitempty"`
	ParentFullpath   []byte  `protobuf:"bytes,4,req,name=parent_fullpath,json=parentFullpath" 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) Descriptor

func (*SnapshottableDirectoryStatusProto) Descriptor() ([]byte, []int)

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

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

* Asks NN/DN to reload configuration file.

func (*StartReconfigurationRequestProto) Descriptor

func (*StartReconfigurationRequestProto) Descriptor() ([]byte, []int)

func (*StartReconfigurationRequestProto) ProtoMessage

func (*StartReconfigurationRequestProto) ProtoMessage()

func (*StartReconfigurationRequestProto) Reset

func (*StartReconfigurationRequestProto) String

type StartReconfigurationResponseProto

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

func (*StartReconfigurationResponseProto) Descriptor

func (*StartReconfigurationResponseProto) Descriptor() ([]byte, []int)

func (*StartReconfigurationResponseProto) ProtoMessage

func (*StartReconfigurationResponseProto) ProtoMessage()

func (*StartReconfigurationResponseProto) Reset

func (*StartReconfigurationResponseProto) String

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) EnumDescriptor

func (Status) EnumDescriptor() ([]byte, []int)

func (Status) String

func (x Status) String() string

func (*Status) UnmarshalJSON

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

type StorageReportProto

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

func (*StorageReportProto) Descriptor

func (*StorageReportProto) Descriptor() ([]byte, []int)

func (*StorageReportProto) GetBlockPoolUsed

func (m *StorageReportProto) GetBlockPoolUsed() uint64

func (*StorageReportProto) GetCapacity

func (m *StorageReportProto) GetCapacity() uint64

func (*StorageReportProto) GetDfsUsed

func (m *StorageReportProto) GetDfsUsed() uint64

func (*StorageReportProto) GetFailed

func (m *StorageReportProto) GetFailed() bool

func (*StorageReportProto) GetRemaining

func (m *StorageReportProto) GetRemaining() uint64

func (*StorageReportProto) GetStorage

func (m *StorageReportProto) GetStorage() *DatanodeStorageProto

func (*StorageReportProto) GetStorageUuid

func (m *StorageReportProto) GetStorageUuid() string

func (*StorageReportProto) ProtoMessage

func (*StorageReportProto) ProtoMessage()

func (*StorageReportProto) Reset

func (m *StorageReportProto) Reset()

func (*StorageReportProto) String

func (m *StorageReportProto) String() string

type StorageTypeProto

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

func (StorageTypeProto) EnumDescriptor

func (StorageTypeProto) EnumDescriptor() ([]byte, []int)

func (StorageTypeProto) String

func (x StorageTypeProto) String() string

func (*StorageTypeProto) UnmarshalJSON

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

type StorageTypeQuotaInfoProto

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) Descriptor

func (*StorageTypeQuotaInfoProto) Descriptor() ([]byte, []int)

func (*StorageTypeQuotaInfoProto) GetConsumed

func (m *StorageTypeQuotaInfoProto) GetConsumed() uint64

func (*StorageTypeQuotaInfoProto) GetQuota

func (m *StorageTypeQuotaInfoProto) GetQuota() uint64

func (*StorageTypeQuotaInfoProto) GetType

func (*StorageTypeQuotaInfoProto) ProtoMessage

func (*StorageTypeQuotaInfoProto) ProtoMessage()

func (*StorageTypeQuotaInfoProto) Reset

func (m *StorageTypeQuotaInfoProto) Reset()

func (*StorageTypeQuotaInfoProto) String

func (m *StorageTypeQuotaInfoProto) String() string

type StorageTypeQuotaInfosProto

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) Descriptor

func (*StorageTypeQuotaInfosProto) Descriptor() ([]byte, []int)

func (*StorageTypeQuotaInfosProto) GetTypeQuotaInfo

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

func (*StorageTypeQuotaInfosProto) ProtoMessage

func (*StorageTypeQuotaInfosProto) ProtoMessage()

func (*StorageTypeQuotaInfosProto) Reset

func (m *StorageTypeQuotaInfosProto) Reset()

func (*StorageTypeQuotaInfosProto) String

func (m *StorageTypeQuotaInfosProto) String() string

type StorageTypesProto

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) Descriptor

func (*StorageTypesProto) Descriptor() ([]byte, []int)

func (*StorageTypesProto) GetStorageTypes

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

func (*StorageTypesProto) ProtoMessage

func (*StorageTypesProto) ProtoMessage()

func (*StorageTypesProto) Reset

func (m *StorageTypesProto) Reset()

func (*StorageTypesProto) String

func (m *StorageTypesProto) String() string

type StorageUuidsProto

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

* A list of storage IDs.

func (*StorageUuidsProto) Descriptor

func (*StorageUuidsProto) Descriptor() ([]byte, []int)

func (*StorageUuidsProto) GetStorageUuids

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

func (*StorageUuidsProto) ProtoMessage

func (*StorageUuidsProto) ProtoMessage()

func (*StorageUuidsProto) Reset

func (m *StorageUuidsProto) Reset()

func (*StorageUuidsProto) String

func (m *StorageUuidsProto) String() string

type TriggerBlockReportRequestProto

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

func (*TriggerBlockReportRequestProto) Descriptor

func (*TriggerBlockReportRequestProto) Descriptor() ([]byte, []int)

func (*TriggerBlockReportRequestProto) GetIncremental

func (m *TriggerBlockReportRequestProto) GetIncremental() bool

func (*TriggerBlockReportRequestProto) ProtoMessage

func (*TriggerBlockReportRequestProto) ProtoMessage()

func (*TriggerBlockReportRequestProto) Reset

func (m *TriggerBlockReportRequestProto) Reset()

func (*TriggerBlockReportRequestProto) String

type TriggerBlockReportResponseProto

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

func (*TriggerBlockReportResponseProto) Descriptor

func (*TriggerBlockReportResponseProto) Descriptor() ([]byte, []int)

func (*TriggerBlockReportResponseProto) ProtoMessage

func (*TriggerBlockReportResponseProto) ProtoMessage()

func (*TriggerBlockReportResponseProto) Reset

func (*TriggerBlockReportResponseProto) String

type TruncateEventProto

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) Descriptor

func (*TruncateEventProto) Descriptor() ([]byte, []int)

func (*TruncateEventProto) GetFileSize

func (m *TruncateEventProto) GetFileSize() int64

func (*TruncateEventProto) GetPath

func (m *TruncateEventProto) GetPath() string

func (*TruncateEventProto) GetTimestamp

func (m *TruncateEventProto) GetTimestamp() int64

func (*TruncateEventProto) ProtoMessage

func (*TruncateEventProto) ProtoMessage()

func (*TruncateEventProto) Reset

func (m *TruncateEventProto) Reset()

func (*TruncateEventProto) String

func (m *TruncateEventProto) String() string

type TruncateRequestProto

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) Descriptor

func (*TruncateRequestProto) Descriptor() ([]byte, []int)

func (*TruncateRequestProto) GetClientName

func (m *TruncateRequestProto) GetClientName() string

func (*TruncateRequestProto) GetNewLength

func (m *TruncateRequestProto) GetNewLength() uint64

func (*TruncateRequestProto) GetSrc

func (m *TruncateRequestProto) GetSrc() string

func (*TruncateRequestProto) ProtoMessage

func (*TruncateRequestProto) ProtoMessage()

func (*TruncateRequestProto) Reset

func (m *TruncateRequestProto) Reset()

func (*TruncateRequestProto) String

func (m *TruncateRequestProto) String() string

type TruncateResponseProto

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

func (*TruncateResponseProto) Descriptor

func (*TruncateResponseProto) Descriptor() ([]byte, []int)

func (*TruncateResponseProto) GetResult

func (m *TruncateResponseProto) GetResult() bool

func (*TruncateResponseProto) ProtoMessage

func (*TruncateResponseProto) ProtoMessage()

func (*TruncateResponseProto) Reset

func (m *TruncateResponseProto) Reset()

func (*TruncateResponseProto) String

func (m *TruncateResponseProto) String() string

type UnlinkEventProto

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) Descriptor

func (*UnlinkEventProto) Descriptor() ([]byte, []int)

func (*UnlinkEventProto) GetPath

func (m *UnlinkEventProto) GetPath() string

func (*UnlinkEventProto) GetTimestamp

func (m *UnlinkEventProto) GetTimestamp() int64

func (*UnlinkEventProto) ProtoMessage

func (*UnlinkEventProto) ProtoMessage()

func (*UnlinkEventProto) Reset

func (m *UnlinkEventProto) Reset()

func (*UnlinkEventProto) String

func (m *UnlinkEventProto) String() string

type UnsetStoragePolicyRequestProto

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

func (*UnsetStoragePolicyRequestProto) Descriptor

func (*UnsetStoragePolicyRequestProto) Descriptor() ([]byte, []int)

func (*UnsetStoragePolicyRequestProto) GetSrc

func (*UnsetStoragePolicyRequestProto) ProtoMessage

func (*UnsetStoragePolicyRequestProto) ProtoMessage()

func (*UnsetStoragePolicyRequestProto) Reset

func (m *UnsetStoragePolicyRequestProto) Reset()

func (*UnsetStoragePolicyRequestProto) String

type UnsetStoragePolicyResponseProto

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

func (*UnsetStoragePolicyResponseProto) Descriptor

func (*UnsetStoragePolicyResponseProto) Descriptor() ([]byte, []int)

func (*UnsetStoragePolicyResponseProto) ProtoMessage

func (*UnsetStoragePolicyResponseProto) ProtoMessage()

func (*UnsetStoragePolicyResponseProto) Reset

func (*UnsetStoragePolicyResponseProto) String

type UpdateBlockForPipelineRequestProto

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

func (*UpdateBlockForPipelineRequestProto) Descriptor

func (*UpdateBlockForPipelineRequestProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*UpdateBlockForPipelineResponseProto) Descriptor() ([]byte, []int)

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) Descriptor

func (*UpdatePipelineRequestProto) Descriptor() ([]byte, []int)

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

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) Descriptor

func (*UpdatePipelineResponseProto) Descriptor() ([]byte, []int)

func (*UpdatePipelineResponseProto) ProtoMessage

func (*UpdatePipelineResponseProto) ProtoMessage()

func (*UpdatePipelineResponseProto) Reset

func (m *UpdatePipelineResponseProto) Reset()

func (*UpdatePipelineResponseProto) String

func (m *UpdatePipelineResponseProto) String() string

type XAttrProto

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

func (*XAttrProto) Descriptor

func (*XAttrProto) Descriptor() ([]byte, []int)

func (*XAttrProto) GetName

func (m *XAttrProto) GetName() string

func (*XAttrProto) GetNamespace

func (m *XAttrProto) GetNamespace() XAttrProto_XAttrNamespaceProto

func (*XAttrProto) GetValue

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

func (*XAttrProto) ProtoMessage

func (*XAttrProto) ProtoMessage()

func (*XAttrProto) Reset

func (m *XAttrProto) Reset()

func (*XAttrProto) String

func (m *XAttrProto) String() string

type XAttrProto_XAttrNamespaceProto

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

func (XAttrProto_XAttrNamespaceProto) Enum

func (XAttrProto_XAttrNamespaceProto) EnumDescriptor

func (XAttrProto_XAttrNamespaceProto) EnumDescriptor() ([]byte, []int)

func (XAttrProto_XAttrNamespaceProto) String

func (*XAttrProto_XAttrNamespaceProto) UnmarshalJSON

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

type XAttrSetFlagProto

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

func (XAttrSetFlagProto) Enum

func (XAttrSetFlagProto) EnumDescriptor

func (XAttrSetFlagProto) EnumDescriptor() ([]byte, []int)

func (XAttrSetFlagProto) String

func (x XAttrSetFlagProto) String() string

func (*XAttrSetFlagProto) UnmarshalJSON

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

type ZoneEncryptionInfoProto

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) Descriptor

func (*ZoneEncryptionInfoProto) Descriptor() ([]byte, []int)

func (*ZoneEncryptionInfoProto) GetCryptoProtocolVersion

func (m *ZoneEncryptionInfoProto) GetCryptoProtocolVersion() CryptoProtocolVersionProto

func (*ZoneEncryptionInfoProto) GetKeyName

func (m *ZoneEncryptionInfoProto) GetKeyName() string

func (*ZoneEncryptionInfoProto) GetSuite

func (*ZoneEncryptionInfoProto) ProtoMessage

func (*ZoneEncryptionInfoProto) ProtoMessage()

func (*ZoneEncryptionInfoProto) Reset

func (m *ZoneEncryptionInfoProto) Reset()

func (*ZoneEncryptionInfoProto) String

func (m *ZoneEncryptionInfoProto) String() string

Jump to

Keyboard shortcuts

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