hadoop_hdfs

package
Version: v1.1.3 Latest Latest
Warning

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

Go to latest
Published: Jun 22, 2018 License: MIT Imports: 4 Imported by: 143

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

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

func (*AbandonBlockRequestProto) GetB

func (*AbandonBlockRequestProto) GetFileId added in v1.0.0

func (m *AbandonBlockRequestProto) GetFileId() uint64

func (*AbandonBlockRequestProto) GetHolder

func (m *AbandonBlockRequestProto) GetHolder() string

func (*AbandonBlockRequestProto) GetSrc

func (m *AbandonBlockRequestProto) GetSrc() string

func (*AbandonBlockRequestProto) ProtoMessage

func (*AbandonBlockRequestProto) ProtoMessage()

func (*AbandonBlockRequestProto) Reset

func (m *AbandonBlockRequestProto) Reset()

func (*AbandonBlockRequestProto) String

func (m *AbandonBlockRequestProto) String() string

type AbandonBlockResponseProto

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

func (*AbandonBlockResponseProto) Descriptor added in v1.1.1

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

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

func (*AclEntryProto) Descriptor added in v1.1.1

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

func (*AclEntryProto) GetName added in v1.0.0

func (m *AclEntryProto) GetName() string

func (*AclEntryProto) GetPermissions added in v1.0.0

func (m *AclEntryProto) GetPermissions() AclEntryProto_FsActionProto

func (*AclEntryProto) GetScope added in v1.0.0

func (*AclEntryProto) GetType added in v1.0.0

func (*AclEntryProto) ProtoMessage added in v1.0.0

func (*AclEntryProto) ProtoMessage()

func (*AclEntryProto) Reset added in v1.0.0

func (m *AclEntryProto) Reset()

func (*AclEntryProto) String added in v1.0.0

func (m *AclEntryProto) String() string

type AclEntryProto_AclEntryScopeProto added in v1.0.0

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

func (AclEntryProto_AclEntryScopeProto) Enum added in v1.0.0

func (AclEntryProto_AclEntryScopeProto) EnumDescriptor added in v1.1.1

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

func (AclEntryProto_AclEntryScopeProto) String added in v1.0.0

func (*AclEntryProto_AclEntryScopeProto) UnmarshalJSON added in v1.0.0

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

type AclEntryProto_AclEntryTypeProto added in v1.0.0

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

func (AclEntryProto_AclEntryTypeProto) Enum added in v1.0.0

func (AclEntryProto_AclEntryTypeProto) EnumDescriptor added in v1.1.1

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

func (AclEntryProto_AclEntryTypeProto) String added in v1.0.0

func (*AclEntryProto_AclEntryTypeProto) UnmarshalJSON added in v1.0.0

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

type AclEntryProto_FsActionProto added in v1.0.0

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

func (AclEntryProto_FsActionProto) Enum added in v1.0.0

func (AclEntryProto_FsActionProto) EnumDescriptor added in v1.1.1

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

func (AclEntryProto_FsActionProto) String added in v1.0.0

func (*AclEntryProto_FsActionProto) UnmarshalJSON added in v1.0.0

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

type AclStatusProto added in v1.0.0

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

func (*AclStatusProto) Descriptor added in v1.1.1

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

func (*AclStatusProto) GetEntries added in v1.0.0

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

func (*AclStatusProto) GetGroup added in v1.0.0

func (m *AclStatusProto) GetGroup() string

func (*AclStatusProto) GetOwner added in v1.0.0

func (m *AclStatusProto) GetOwner() string

func (*AclStatusProto) GetPermission added in v1.0.0

func (m *AclStatusProto) GetPermission() *FsPermissionProto

func (*AclStatusProto) GetSticky added in v1.0.0

func (m *AclStatusProto) GetSticky() bool

func (*AclStatusProto) ProtoMessage added in v1.0.0

func (*AclStatusProto) ProtoMessage()

func (*AclStatusProto) Reset added in v1.0.0

func (m *AclStatusProto) Reset()

func (*AclStatusProto) String added in v1.0.0

func (m *AclStatusProto) String() string

type AddBlockRequestProto

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

func (*AddBlockRequestProto) Descriptor added in v1.1.1

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

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

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

func (*AddCacheDirectiveRequestProto) Descriptor added in v1.1.1

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

func (*AddCacheDirectiveRequestProto) GetCacheFlags added in v1.0.0

func (m *AddCacheDirectiveRequestProto) GetCacheFlags() uint32

func (*AddCacheDirectiveRequestProto) GetInfo added in v1.0.0

func (*AddCacheDirectiveRequestProto) ProtoMessage added in v1.0.0

func (*AddCacheDirectiveRequestProto) ProtoMessage()

func (*AddCacheDirectiveRequestProto) Reset added in v1.0.0

func (m *AddCacheDirectiveRequestProto) Reset()

func (*AddCacheDirectiveRequestProto) String added in v1.0.0

type AddCacheDirectiveResponseProto added in v1.0.0

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

func (*AddCacheDirectiveResponseProto) Descriptor added in v1.1.1

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

func (*AddCacheDirectiveResponseProto) GetId added in v1.0.0

func (*AddCacheDirectiveResponseProto) ProtoMessage added in v1.0.0

func (*AddCacheDirectiveResponseProto) ProtoMessage()

func (*AddCacheDirectiveResponseProto) Reset added in v1.0.0

func (m *AddCacheDirectiveResponseProto) Reset()

func (*AddCacheDirectiveResponseProto) String added in v1.0.0

type AddCachePoolRequestProto added in v1.0.0

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

func (*AddCachePoolRequestProto) Descriptor added in v1.1.1

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

func (*AddCachePoolRequestProto) GetInfo added in v1.0.0

func (*AddCachePoolRequestProto) ProtoMessage added in v1.0.0

func (*AddCachePoolRequestProto) ProtoMessage()

func (*AddCachePoolRequestProto) Reset added in v1.0.0

func (m *AddCachePoolRequestProto) Reset()

func (*AddCachePoolRequestProto) String added in v1.0.0

func (m *AddCachePoolRequestProto) String() string

type AddCachePoolResponseProto added in v1.0.0

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

func (*AddCachePoolResponseProto) Descriptor added in v1.1.1

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

func (*AddCachePoolResponseProto) ProtoMessage added in v1.0.0

func (*AddCachePoolResponseProto) ProtoMessage()

func (*AddCachePoolResponseProto) Reset added in v1.0.0

func (m *AddCachePoolResponseProto) Reset()

func (*AddCachePoolResponseProto) String added in v1.0.0

func (m *AddCachePoolResponseProto) String() string

type AllowSnapshotRequestProto

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

func (*AllowSnapshotRequestProto) Descriptor added in v1.1.1

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