hadoop_hdfs

package

Go to main page

Versions in this module

v1

v1.1.0

Oct 26, 2017

v1.0.4

Aug 22, 2017

v1.0.3

Mar 13, 2017

v1.0.2

Feb 25, 2017

v1.0.1

Jan 23, 2017

v1.0.0

Oct 26, 2016

Changes in this version

+ const Default_AbandonBlockRequestProto_FileId

+ const Default_AppendEventProto_NewBlock

+ const Default_CreateEventProto_DefaultBlockSize

+ const Default_DatanodeInfoProto_CacheCapacity

+ const Default_DatanodeInfoProto_CacheUsed

+ const Default_DatanodeInfoProto_LastUpdateMonotonic

+ const Default_FsyncRequestProto_FileId

+ const Default_GetAdditionalDatanodeRequestProto_FileId

+ const Default_HdfsFileStatusProto_StoragePolicy

+ const Default_OpRequestShortCircuitAccessProto_SupportsReceiptVerification

+ const Default_OpWriteBlockProto_AllowLazyPersist

+ const Default_OpWriteBlockProto_Pinning

+ const Default_RollingUpgradeStatusProto_Finalized

+ const Default_SaveNamespaceRequestProto_TimeWindow

+ const Default_SaveNamespaceRequestProto_TxGap

+ const Default_SaveNamespaceResponseProto_Saved

+ const Default_StorageReportProto_BlockPoolUsed

+ const Default_StorageReportProto_Capacity

+ const Default_StorageReportProto_DfsUsed

+ const Default_StorageReportProto_Failed

+ const Default_StorageReportProto_Remaining

+ var AclEntryProto_AclEntryScopeProto_name = map[int32]string

+ var AclEntryProto_AclEntryScopeProto_value = map[string]int32

+ var AclEntryProto_AclEntryTypeProto_name = map[int32]string

+ var AclEntryProto_AclEntryTypeProto_value = map[string]int32

+ var AclEntryProto_FsActionProto_name = map[int32]string

+ var AclEntryProto_FsActionProto_value = map[string]int32

+ var CacheFlagProto_name = map[int32]string

+ var CacheFlagProto_value = map[string]int32

+ var CipherSuiteProto_name = map[int32]string

+ var CipherSuiteProto_value = map[string]int32

+ var CryptoProtocolVersionProto_name = map[int32]string

+ var CryptoProtocolVersionProto_value = map[string]int32

+ var DatanodeStorageProto_StorageState_name = map[int32]string

+ var DatanodeStorageProto_StorageState_value = map[string]int32

+ var EventType_name = map[int32]string

+ var EventType_value = map[string]int32

+ var INodeType_name = map[int32]string

+ var INodeType_value = map[string]int32

+ var MetadataUpdateType_name = map[int32]string

+ var MetadataUpdateType_value = map[string]int32

+ var RollingUpgradeActionProto_name = map[int32]string

+ var RollingUpgradeActionProto_value = map[string]int32

+ var ShortCircuitFdResponse_name = map[int32]string

+ var ShortCircuitFdResponse_value = map[string]int32

+ var StorageTypeProto_name = map[int32]string

+ var StorageTypeProto_value = map[string]int32

+ var XAttrProto_XAttrNamespaceProto_name = map[int32]string

+ var XAttrProto_XAttrNamespaceProto_value = map[string]int32

+ var XAttrSetFlagProto_name = map[int32]string

+ var XAttrSetFlagProto_value = map[string]int32

type AbandonBlockRequestProto

+ FileId *uint64

+ func (m *AbandonBlockRequestProto) GetFileId() uint64

+ type AclEntryProto struct

+ Name *string

+ Permissions *AclEntryProto_FsActionProto

+ Scope *AclEntryProto_AclEntryScopeProto

+ Type *AclEntryProto_AclEntryTypeProto

+ XXX_unrecognized []byte

+ func (*AclEntryProto) ProtoMessage()

+ func (m *AclEntryProto) GetName() string

+ func (m *AclEntryProto) GetPermissions() AclEntryProto_FsActionProto

+ func (m *AclEntryProto) GetScope() AclEntryProto_AclEntryScopeProto

+ func (m *AclEntryProto) GetType() AclEntryProto_AclEntryTypeProto

+ func (m *AclEntryProto) Reset()

+ func (m *AclEntryProto) String() string

+ type AclEntryProto_AclEntryScopeProto int32

+ const AclEntryProto_ACCESS

+ const AclEntryProto_DEFAULT

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

+ func (x AclEntryProto_AclEntryScopeProto) Enum() *AclEntryProto_AclEntryScopeProto

+ func (x AclEntryProto_AclEntryScopeProto) String() string

+ type AclEntryProto_AclEntryTypeProto int32

+ const AclEntryProto_GROUP

+ const AclEntryProto_MASK

+ const AclEntryProto_OTHER

+ const AclEntryProto_USER

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

+ func (x AclEntryProto_AclEntryTypeProto) Enum() *AclEntryProto_AclEntryTypeProto

+ func (x AclEntryProto_AclEntryTypeProto) String() string

+ type AclEntryProto_FsActionProto int32

+ const AclEntryProto_EXECUTE

+ const AclEntryProto_NONE

+ const AclEntryProto_PERM_ALL

+ const AclEntryProto_READ

+ const AclEntryProto_READ_EXECUTE

+ const AclEntryProto_READ_WRITE

+ const AclEntryProto_WRITE

+ const AclEntryProto_WRITE_EXECUTE

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

+ func (x AclEntryProto_FsActionProto) Enum() *AclEntryProto_FsActionProto

+ func (x AclEntryProto_FsActionProto) String() string

+ type AclStatusProto struct

+ Entries []*AclEntryProto

+ Group *string

+ Owner *string

+ Permission *FsPermissionProto

+ Sticky *bool

+ XXX_unrecognized []byte

+ func (*AclStatusProto) ProtoMessage()

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

+ func (m *AclStatusProto) GetGroup() string

+ func (m *AclStatusProto) GetOwner() string

+ func (m *AclStatusProto) GetPermission() *FsPermissionProto

+ func (m *AclStatusProto) GetSticky() bool

+ func (m *AclStatusProto) Reset()

+ func (m *AclStatusProto) String() string

+ type AddCacheDirectiveRequestProto struct

+ CacheFlags *uint32

+ Info *CacheDirectiveInfoProto

+ XXX_unrecognized []byte

+ func (*AddCacheDirectiveRequestProto) ProtoMessage()

+ func (m *AddCacheDirectiveRequestProto) GetCacheFlags() uint32

+ func (m *AddCacheDirectiveRequestProto) GetInfo() *CacheDirectiveInfoProto

+ func (m *AddCacheDirectiveRequestProto) Reset()

+ func (m *AddCacheDirectiveRequestProto) String() string

+ type AddCacheDirectiveResponseProto struct

+ Id *int64

+ XXX_unrecognized []byte

+ func (*AddCacheDirectiveResponseProto) ProtoMessage()

+ func (m *AddCacheDirectiveResponseProto) GetId() int64

+ func (m *AddCacheDirectiveResponseProto) Reset()

+ func (m *AddCacheDirectiveResponseProto) String() string

+ type AddCachePoolRequestProto struct

+ Info *CachePoolInfoProto

+ XXX_unrecognized []byte

+ func (*AddCachePoolRequestProto) ProtoMessage()

+ func (m *AddCachePoolRequestProto) GetInfo() *CachePoolInfoProto

+ func (m *AddCachePoolRequestProto) Reset()

+ func (m *AddCachePoolRequestProto) String() string

+ type AddCachePoolResponseProto struct

+ XXX_unrecognized []byte

+ func (*AddCachePoolResponseProto) ProtoMessage()

+ func (m *AddCachePoolResponseProto) Reset()

+ func (m *AddCachePoolResponseProto) String() string

+ type AppendEventProto struct

+ NewBlock *bool

+ Path *string

+ XXX_unrecognized []byte

+ func (*AppendEventProto) ProtoMessage()

+ func (m *AppendEventProto) GetNewBlock() bool

+ func (m *AppendEventProto) GetPath() string

+ func (m *AppendEventProto) Reset()

+ func (m *AppendEventProto) String() string

type AppendRequestProto

+ Flag *uint32

+ func (m *AppendRequestProto) GetFlag() uint32

type AppendResponseProto

+ Stat *HdfsFileStatusProto

+ func (m *AppendResponseProto) GetStat() *HdfsFileStatusProto

type BaseHeaderProto

+ TraceInfo *DataTransferTraceInfoProto

+ func (m *BaseHeaderProto) GetTraceInfo() *DataTransferTraceInfoProto

+ type BlockECReconstructionInfoProto struct

+ Block *ExtendedBlockProto

+ EcPolicy *ErasureCodingPolicyProto

+ LiveBlockIndices []byte

+ SourceDnInfos *DatanodeInfosProto

+ TargetDnInfos *DatanodeInfosProto

+ TargetStorageTypes *StorageTypesProto

+ TargetStorageUuids *StorageUuidsProto

+ XXX_unrecognized []byte

+ func (*BlockECReconstructionInfoProto) ProtoMessage()

+ func (m *BlockECReconstructionInfoProto) GetBlock() *ExtendedBlockProto

+ func (m *BlockECReconstructionInfoProto) GetEcPolicy() *ErasureCodingPolicyProto

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

+ func (m *BlockECReconstructionInfoProto) GetSourceDnInfos() *DatanodeInfosProto

+ func (m *BlockECReconstructionInfoProto) GetTargetDnInfos() *DatanodeInfosProto

+ func (m *BlockECReconstructionInfoProto) GetTargetStorageTypes() *StorageTypesProto

+ func (m *BlockECReconstructionInfoProto) GetTargetStorageUuids() *StorageUuidsProto

+ func (m *BlockECReconstructionInfoProto) Reset()

+ func (m *BlockECReconstructionInfoProto) String() string

+ type BlockStoragePolicyProto struct

+ CreationFallbackPolicy *StorageTypesProto

+ CreationPolicy *StorageTypesProto

+ Name *string

+ PolicyId *uint32

+ ReplicationFallbackPolicy *StorageTypesProto

+ XXX_unrecognized []byte

+ func (*BlockStoragePolicyProto) ProtoMessage()

+ func (m *BlockStoragePolicyProto) GetCreationFallbackPolicy() *StorageTypesProto

+ func (m *BlockStoragePolicyProto) GetCreationPolicy() *StorageTypesProto

+ func (m *BlockStoragePolicyProto) GetName() string

+ func (m *BlockStoragePolicyProto) GetPolicyId() uint32

+ func (m *BlockStoragePolicyProto) GetReplicationFallbackPolicy() *StorageTypesProto

+ func (m *BlockStoragePolicyProto) Reset()

+ func (m *BlockStoragePolicyProto) String() string

+ type CacheDirectiveEntryProto struct

+ Info *CacheDirectiveInfoProto

+ Stats *CacheDirectiveStatsProto

+ XXX_unrecognized []byte

+ func (*CacheDirectiveEntryProto) ProtoMessage()

+ func (m *CacheDirectiveEntryProto) GetInfo() *CacheDirectiveInfoProto

+ func (m *CacheDirectiveEntryProto) GetStats() *CacheDirectiveStatsProto

+ func (m *CacheDirectiveEntryProto) Reset()

+ func (m *CacheDirectiveEntryProto) String() string

+ type CacheDirectiveInfoExpirationProto struct

+ IsRelative *bool

+ Millis *int64

+ XXX_unrecognized []byte

+ func (*CacheDirectiveInfoExpirationProto) ProtoMessage()

+ func (m *CacheDirectiveInfoExpirationProto) GetIsRelative() bool

+ func (m *CacheDirectiveInfoExpirationProto) GetMillis() int64

+ func (m *CacheDirectiveInfoExpirationProto) Reset()

+ func (m *CacheDirectiveInfoExpirationProto) String() string

+ type CacheDirectiveInfoProto struct

+ Expiration *CacheDirectiveInfoExpirationProto

+ Id *int64

+ Path *string

+ Pool *string

+ Replication *uint32

+ XXX_unrecognized []byte

+ func (*CacheDirectiveInfoProto) ProtoMessage()

+ func (m *CacheDirectiveInfoProto) GetExpiration() *CacheDirectiveInfoExpirationProto

+ func (m *CacheDirectiveInfoProto) GetId() int64

+ func (m *CacheDirectiveInfoProto) GetPath() string

+ func (m *CacheDirectiveInfoProto) GetPool() string

+ func (m *CacheDirectiveInfoProto) GetReplication() uint32

+ func (m *CacheDirectiveInfoProto) Reset()

+ func (m *CacheDirectiveInfoProto) String() string

+ type CacheDirectiveStatsProto struct

+ BytesCached *int64

+ BytesNeeded *int64

+ FilesCached *int64

+ FilesNeeded *int64

+ HasExpired *bool

+ XXX_unrecognized []byte

+ func (*CacheDirectiveStatsProto) ProtoMessage()

+ func (m *CacheDirectiveStatsProto) GetBytesCached() int64

+ func (m *CacheDirectiveStatsProto) GetBytesNeeded() int64

+ func (m *CacheDirectiveStatsProto) GetFilesCached() int64

+ func (m *CacheDirectiveStatsProto) GetFilesNeeded() int64

+ func (m *CacheDirectiveStatsProto) GetHasExpired() bool

+ func (m *CacheDirectiveStatsProto) Reset()

+ func (m *CacheDirectiveStatsProto) String() string

+ type CacheFlagProto int32

+ const CacheFlagProto_FORCE

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

+ func (x CacheFlagProto) Enum() *CacheFlagProto

+ func (x CacheFlagProto) String() string

+ type CachePoolEntryProto struct

+ Info *CachePoolInfoProto

+ Stats *CachePoolStatsProto

+ XXX_unrecognized []byte

+ func (*CachePoolEntryProto) ProtoMessage()

+ func (m *CachePoolEntryProto) GetInfo() *CachePoolInfoProto

+ func (m *CachePoolEntryProto) GetStats() *CachePoolStatsProto

+ func (m *CachePoolEntryProto) Reset()

+ func (m *CachePoolEntryProto) String() string

+ type CachePoolInfoProto struct

+ GroupName *string

+ Limit *int64

+ MaxRelativeExpiry *int64

+ Mode *int32

+ OwnerName *string

+ PoolName *string

+ XXX_unrecognized []byte

+ func (*CachePoolInfoProto) ProtoMessage()

+ func (m *CachePoolInfoProto) GetGroupName() string

+ func (m *CachePoolInfoProto) GetLimit() int64

+ func (m *CachePoolInfoProto) GetMaxRelativeExpiry() int64

+ func (m *CachePoolInfoProto) GetMode() int32

+ func (m *CachePoolInfoProto) GetOwnerName() string

+ func (m *CachePoolInfoProto) GetPoolName() string

+ func (m *CachePoolInfoProto) Reset()

+ func (m *CachePoolInfoProto) String() string

+ type CachePoolStatsProto struct

+ BytesCached *int64

+ BytesNeeded *int64

+ BytesOverlimit *int64

+ FilesCached *int64

+ FilesNeeded *int64

+ XXX_unrecognized []byte

+ func (*CachePoolStatsProto) ProtoMessage()

+ func (m *CachePoolStatsProto) GetBytesCached() int64

+ func (m *CachePoolStatsProto) GetBytesNeeded() int64

+ func (m *CachePoolStatsProto) GetBytesOverlimit() int64

+ func (m *CachePoolStatsProto) GetFilesCached() int64

+ func (m *CachePoolStatsProto) GetFilesNeeded() int64

+ func (m *CachePoolStatsProto) Reset()

+ func (m *CachePoolStatsProto) String() string

+ type CheckAccessRequestProto struct

+ Mode *AclEntryProto_FsActionProto

+ Path *string

+ XXX_unrecognized []byte

+ func (*CheckAccessRequestProto) ProtoMessage()

+ func (m *CheckAccessRequestProto) GetMode() AclEntryProto_FsActionProto

+ func (m *CheckAccessRequestProto) GetPath() string

+ func (m *CheckAccessRequestProto) Reset()

+ func (m *CheckAccessRequestProto) String() string

+ type CheckAccessResponseProto struct

+ XXX_unrecognized []byte

+ func (*CheckAccessResponseProto) ProtoMessage()

+ func (m *CheckAccessResponseProto) Reset()

+ func (m *CheckAccessResponseProto) String() string

+ type CipherOptionProto struct

+ InIv []byte

+ InKey []byte

+ OutIv []byte

+ OutKey []byte

+ Suite *CipherSuiteProto

+ XXX_unrecognized []byte

+ func (*CipherOptionProto) ProtoMessage()

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

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

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

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

+ func (m *CipherOptionProto) GetSuite() CipherSuiteProto

+ func (m *CipherOptionProto) Reset()

+ func (m *CipherOptionProto) String() string

+ type CipherSuiteProto int32

+ const CipherSuiteProto_AES_CTR_NOPADDING

+ const CipherSuiteProto_UNKNOWN

+ func (x *CipherSuiteProto) UnmarshalJSON(data []byte) error

+ func (x CipherSuiteProto) Enum() *CipherSuiteProto

+ func (x CipherSuiteProto) String() string

+ type CloseEventProto struct

+ FileSize *int64

+ Path *string

+ Timestamp *int64

+ XXX_unrecognized []byte

+ func (*CloseEventProto) ProtoMessage()

+ func (m *CloseEventProto) GetFileSize() int64

+ func (m *CloseEventProto) GetPath() string

+ func (m *CloseEventProto) GetTimestamp() int64

+ func (m *CloseEventProto) Reset()

+ func (m *CloseEventProto) String() string

type ContentSummaryProto

+ TypeQuotaInfos *StorageTypeQuotaInfosProto

+ func (m *ContentSummaryProto) GetTypeQuotaInfos() *StorageTypeQuotaInfosProto

+ type CreateEncryptionZoneRequestProto struct

+ KeyName *string

+ Src *string

+ XXX_unrecognized []byte

+ func (*CreateEncryptionZoneRequestProto) ProtoMessage()

+ func (m *CreateEncryptionZoneRequestProto) GetKeyName() string

+ func (m *CreateEncryptionZoneRequestProto) GetSrc() string

+ func (m *CreateEncryptionZoneRequestProto) Reset()

+ func (m *CreateEncryptionZoneRequestProto) String() string

+ type CreateEncryptionZoneResponseProto struct

+ XXX_unrecognized []byte

+ func (*CreateEncryptionZoneResponseProto) ProtoMessage()

+ func (m *CreateEncryptionZoneResponseProto) Reset()

+ func (m *CreateEncryptionZoneResponseProto) String() string

+ type CreateEventProto struct

+ Ctime *int64

+ DefaultBlockSize *int64

+ GroupName *string

+ Overwrite *bool

+ OwnerName *string

+ Path *string

+ Perms *FsPermissionProto

+ Replication *int32

+ SymlinkTarget *string

+ Type *INodeType

+ XXX_unrecognized []byte

+ func (*CreateEventProto) ProtoMessage()

+ func (m *CreateEventProto) GetCtime() int64

+ func (m *CreateEventProto) GetDefaultBlockSize() int64

+ func (m *CreateEventProto) GetGroupName() string

+ func (m *CreateEventProto) GetOverwrite() bool

+ func (m *CreateEventProto) GetOwnerName() string

+ func (m *CreateEventProto) GetPath() string

+ func (m *CreateEventProto) GetPerms() *FsPermissionProto

+ func (m *CreateEventProto) GetReplication() int32

+ func (m *CreateEventProto) GetSymlinkTarget() string

+ func (m *CreateEventProto) GetType() INodeType

+ func (m *CreateEventProto) Reset()

+ func (m *CreateEventProto) String() string

type CreateFlagProto

+ const CreateFlagProto_LAZY_PERSIST

+ const CreateFlagProto_NEW_BLOCK

type CreateRequestProto

+ CryptoProtocolVersion []CryptoProtocolVersionProto

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

+ type CryptoProtocolVersionProto int32

+ const CryptoProtocolVersionProto_ENCRYPTION_ZONES

+ const CryptoProtocolVersionProto_UNKNOWN_PROTOCOL_VERSION

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

+ func (x CryptoProtocolVersionProto) Enum() *CryptoProtocolVersionProto

+ func (x CryptoProtocolVersionProto) String() string

type DataTransferEncryptorMessageProto

+ CipherOption []*CipherOptionProto

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

+ type DataTransferTraceInfoProto struct

+ ParentId *uint64

+ TraceId *uint64

+ XXX_unrecognized []byte

+ func (*DataTransferTraceInfoProto) ProtoMessage()

+ func (m *DataTransferTraceInfoProto) GetParentId() uint64

+ func (m *DataTransferTraceInfoProto) GetTraceId() uint64

+ func (m *DataTransferTraceInfoProto) Reset()

+ func (m *DataTransferTraceInfoProto) String() string

type DatanodeIDProto

+ DatanodeUuid *string

+ func (m *DatanodeIDProto) GetDatanodeUuid() string

type DatanodeInfoProto

+ CacheCapacity *uint64

+ CacheUsed *uint64

+ LastUpdateMonotonic *uint64

+ UpgradeDomain *string

+ func (m *DatanodeInfoProto) GetCacheCapacity() uint64

+ func (m *DatanodeInfoProto) GetCacheUsed() uint64

+ func (m *DatanodeInfoProto) GetLastUpdateMonotonic() uint64

+ func (m *DatanodeInfoProto) GetUpgradeDomain() string

+ type DatanodeLocalInfoProto struct

+ ConfigVersion *string

+ SoftwareVersion *string

+ Uptime *uint64

+ XXX_unrecognized []byte

+ func (*DatanodeLocalInfoProto) ProtoMessage()

+ func (m *DatanodeLocalInfoProto) GetConfigVersion() string

+ func (m *DatanodeLocalInfoProto) GetSoftwareVersion() string

+ func (m *DatanodeLocalInfoProto) GetUptime() uint64

+ func (m *DatanodeLocalInfoProto) Reset()

+ func (m *DatanodeLocalInfoProto) String() string

type DatanodeReportTypeProto

+ const DatanodeReportTypeProto_DECOMMISSIONING

+ type DatanodeStorageProto struct

+ State *DatanodeStorageProto_StorageState

+ StorageType *StorageTypeProto

+ StorageUuid *string

+ XXX_unrecognized []byte

+ func (*DatanodeStorageProto) ProtoMessage()

+ func (m *DatanodeStorageProto) GetState() DatanodeStorageProto_StorageState

+ func (m *DatanodeStorageProto) GetStorageType() StorageTypeProto

+ func (m *DatanodeStorageProto) GetStorageUuid() string

+ func (m *DatanodeStorageProto) Reset()

+ func (m *DatanodeStorageProto) String() string

+ type DatanodeStorageProto_StorageState int32

+ const DatanodeStorageProto_NORMAL

+ const DatanodeStorageProto_READ_ONLY_SHARED

+ const Default_DatanodeStorageProto_State

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

+ func (x DatanodeStorageProto_StorageState) Enum() *DatanodeStorageProto_StorageState

+ func (x DatanodeStorageProto_StorageState) String() string

+ type DatanodeStorageReportProto struct

+ DatanodeInfo *DatanodeInfoProto

+ StorageReports []*StorageReportProto

+ XXX_unrecognized []byte

+ func (*DatanodeStorageReportProto) ProtoMessage()

+ func (m *DatanodeStorageReportProto) GetDatanodeInfo() *DatanodeInfoProto

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

+ func (m *DatanodeStorageReportProto) Reset()

+ func (m *DatanodeStorageReportProto) String() string

+ type DeleteBlockPoolRequestProto struct

+ BlockPool *string

+ Force *bool

+ XXX_unrecognized []byte

+ func (*DeleteBlockPoolRequestProto) ProtoMessage()

+ func (m *DeleteBlockPoolRequestProto) GetBlockPool() string

+ func (m *DeleteBlockPoolRequestProto) GetForce() bool

+ func (m *DeleteBlockPoolRequestProto) Reset()

+ func (m *DeleteBlockPoolRequestProto) String() string

+ type DeleteBlockPoolResponseProto struct

+ XXX_unrecognized []byte

+ func (*DeleteBlockPoolResponseProto) ProtoMessage()

+ func (m *DeleteBlockPoolResponseProto) Reset()

+ func (m *DeleteBlockPoolResponseProto) String() string

+ type ECSchemaOptionEntryProto struct

+ Key *string

+ Value *string

+ XXX_unrecognized []byte

+ func (*ECSchemaOptionEntryProto) ProtoMessage()

+ func (m *ECSchemaOptionEntryProto) GetKey() string

+ func (m *ECSchemaOptionEntryProto) GetValue() string

+ func (m *ECSchemaOptionEntryProto) Reset()

+ func (m *ECSchemaOptionEntryProto) String() string

+ type ECSchemaProto struct

+ CodecName *string

+ DataUnits *uint32

+ Options []*ECSchemaOptionEntryProto

+ ParityUnits *uint32

+ XXX_unrecognized []byte

+ func (*ECSchemaProto) ProtoMessage()

+ func (m *ECSchemaProto) GetCodecName() string

+ func (m *ECSchemaProto) GetDataUnits() uint32

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

+ func (m *ECSchemaProto) GetParityUnits() uint32

+ func (m *ECSchemaProto) Reset()

+ func (m *ECSchemaProto) String() string

+ type EncryptionZoneProto struct

+ CryptoProtocolVersion *CryptoProtocolVersionProto

+ Id *int64

+ KeyName *string

+ Path *string

+ Suite *CipherSuiteProto

+ XXX_unrecognized []byte

+ func (*EncryptionZoneProto) ProtoMessage()

+ func (m *EncryptionZoneProto) GetCryptoProtocolVersion() CryptoProtocolVersionProto

+ func (m *EncryptionZoneProto) GetId() int64

+ func (m *EncryptionZoneProto) GetKeyName() string

+ func (m *EncryptionZoneProto) GetPath() string

+ func (m *EncryptionZoneProto) GetSuite() CipherSuiteProto

+ func (m *EncryptionZoneProto) Reset()

+ func (m *EncryptionZoneProto) String() string

+ type ErasureCodingPolicyProto struct

+ CellSize *uint32

+ Id *uint32

+ Name *string

+ Schema *ECSchemaProto

+ XXX_unrecognized []byte

+ func (*ErasureCodingPolicyProto) ProtoMessage()

+ func (m *ErasureCodingPolicyProto) GetCellSize() uint32

+ func (m *ErasureCodingPolicyProto) GetId() uint32

+ func (m *ErasureCodingPolicyProto) GetName() string

+ func (m *ErasureCodingPolicyProto) GetSchema() *ECSchemaProto

+ func (m *ErasureCodingPolicyProto) Reset()

+ func (m *ErasureCodingPolicyProto) String() string

+ type EventBatchProto struct

+ Events []*EventProto

+ Txid *int64

+ XXX_unrecognized []byte

+ func (*EventBatchProto) ProtoMessage()

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

+ func (m *EventBatchProto) GetTxid() int64

+ func (m *EventBatchProto) Reset()

+ func (m *EventBatchProto) String() string

+ type EventProto struct

+ Contents []byte

+ Type *EventType

+ XXX_unrecognized []byte

+ func (*EventProto) ProtoMessage()

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

+ func (m *EventProto) GetType() EventType

+ func (m *EventProto) Reset()

+ func (m *EventProto) String() string

+ type EventType int32

+ const EventType_EVENT_APPEND

+ const EventType_EVENT_CLOSE

+ const EventType_EVENT_CREATE

+ const EventType_EVENT_METADATA

+ const EventType_EVENT_RENAME

+ const EventType_EVENT_TRUNCATE

+ const EventType_EVENT_UNLINK

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

+ func (x EventType) Enum() *EventType

+ func (x EventType) String() string

+ type EventsListProto struct

+ Batch []*EventBatchProto

+ Events []*EventProto

+ FirstTxid *int64

+ LastTxid *int64

+ SyncTxid *int64

+ XXX_unrecognized []byte

+ func (*EventsListProto) ProtoMessage()

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

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

+ func (m *EventsListProto) GetFirstTxid() int64

+ func (m *EventsListProto) GetLastTxid() int64

+ func (m *EventsListProto) GetSyncTxid() int64

+ func (m *EventsListProto) Reset()

+ func (m *EventsListProto) String() string

+ type EvictWritersRequestProto struct

+ XXX_unrecognized []byte

+ func (*EvictWritersRequestProto) ProtoMessage()

+ func (m *EvictWritersRequestProto) Reset()

+ func (m *EvictWritersRequestProto) String() string

+ type EvictWritersResponseProto struct

+ XXX_unrecognized []byte

+ func (*EvictWritersResponseProto) ProtoMessage()

+ func (m *EvictWritersResponseProto) Reset()

+ func (m *EvictWritersResponseProto) String() string

+ type FileEncryptionInfoProto struct

+ CryptoProtocolVersion *CryptoProtocolVersionProto

+ EzKeyVersionName *string

+ Iv []byte

+ Key []byte

+ KeyName *string

+ Suite *CipherSuiteProto

+ XXX_unrecognized []byte

+ func (*FileEncryptionInfoProto) ProtoMessage()

+ func (m *FileEncryptionInfoProto) GetCryptoProtocolVersion() CryptoProtocolVersionProto

+ func (m *FileEncryptionInfoProto) GetEzKeyVersionName() string

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

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

+ func (m *FileEncryptionInfoProto) GetKeyName() string

+ func (m *FileEncryptionInfoProto) GetSuite() CipherSuiteProto

+ func (m *FileEncryptionInfoProto) Reset()

+ func (m *FileEncryptionInfoProto) String() string

type FsyncRequestProto

+ FileId *uint64

+ func (m *FsyncRequestProto) GetFileId() uint64

+ type GetAclStatusRequestProto struct

+ Src *string

+ XXX_unrecognized []byte

+ func (*GetAclStatusRequestProto) ProtoMessage()

+ func (m *GetAclStatusRequestProto) GetSrc() string

+ func (m *GetAclStatusRequestProto) Reset()

+ func (m *GetAclStatusRequestProto) String() string

+ type GetAclStatusResponseProto struct

+ Result *AclStatusProto

+ XXX_unrecognized []byte

+ func (*GetAclStatusResponseProto) ProtoMessage()

+ func (m *GetAclStatusResponseProto) GetResult() *AclStatusProto

+ func (m *GetAclStatusResponseProto) Reset()

+ func (m *GetAclStatusResponseProto) String() string

type GetAdditionalDatanodeRequestProto

+ ExistingStorageUuids []string

+ FileId *uint64

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

+ func (m *GetAdditionalDatanodeRequestProto) GetFileId() uint64

+ type GetBalancerBandwidthRequestProto struct

+ XXX_unrecognized []byte

+ func (*GetBalancerBandwidthRequestProto) ProtoMessage()

+ func (m *GetBalancerBandwidthRequestProto) Reset()

+ func (m *GetBalancerBandwidthRequestProto) String() string

+ type GetBalancerBandwidthResponseProto struct

+ Bandwidth *uint64

+ XXX_unrecognized []byte

+ func (*GetBalancerBandwidthResponseProto) ProtoMessage()

+ func (m *GetBalancerBandwidthResponseProto) GetBandwidth() uint64

+ func (m *GetBalancerBandwidthResponseProto) Reset()

+ func (m *GetBalancerBandwidthResponseProto) String() string

+ type GetBlockLocalPathInfoRequestProto struct

+ Block *ExtendedBlockProto

+ Token *hadoop_common.TokenProto

+ XXX_unrecognized []byte

+ func (*GetBlockLocalPathInfoRequestProto) ProtoMessage()

+ func (m *GetBlockLocalPathInfoRequestProto) GetBlock() *ExtendedBlockProto

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

+ func (m *GetBlockLocalPathInfoRequestProto) Reset()

+ func (m *GetBlockLocalPathInfoRequestProto) String() string

+ type GetBlockLocalPathInfoResponseProto struct

+ Block *ExtendedBlockProto

+ LocalMetaPath *string

+ LocalPath *string

+ XXX_unrecognized []byte

+ func (*GetBlockLocalPathInfoResponseProto) ProtoMessage()

+ func (m *GetBlockLocalPathInfoResponseProto) GetBlock() *ExtendedBlockProto

+ func (m *GetBlockLocalPathInfoResponseProto) GetLocalMetaPath() string

+ func (m *GetBlockLocalPathInfoResponseProto) GetLocalPath() string

+ func (m *GetBlockLocalPathInfoResponseProto) Reset()

+ func (m *GetBlockLocalPathInfoResponseProto) String() string

+ type GetCurrentEditLogTxidRequestProto struct

+ XXX_unrecognized []byte

+ func (*GetCurrentEditLogTxidRequestProto) ProtoMessage()

+ func (m *GetCurrentEditLogTxidRequestProto) Reset()

+ func (m *GetCurrentEditLogTxidRequestProto) String() string

+ type GetCurrentEditLogTxidResponseProto struct

+ Txid *int64

+ XXX_unrecognized []byte

+ func (*GetCurrentEditLogTxidResponseProto) ProtoMessage()

+ func (m *GetCurrentEditLogTxidResponseProto) GetTxid() int64

+ func (m *GetCurrentEditLogTxidResponseProto) Reset()

+ func (m *GetCurrentEditLogTxidResponseProto) String() string

+ type GetDatanodeInfoRequestProto struct

+ XXX_unrecognized []byte

+ func (*GetDatanodeInfoRequestProto) ProtoMessage()

+ func (m *GetDatanodeInfoRequestProto) Reset()

+ func (m *GetDatanodeInfoRequestProto) String() string

+ type GetDatanodeInfoResponseProto struct

+ LocalInfo *DatanodeLocalInfoProto

+ XXX_unrecognized []byte

+ func (*GetDatanodeInfoResponseProto) ProtoMessage()

+ func (m *GetDatanodeInfoResponseProto) GetLocalInfo() *DatanodeLocalInfoProto

+ func (m *GetDatanodeInfoResponseProto) Reset()

+ func (m *GetDatanodeInfoResponseProto) String() string

+ type GetDatanodeStorageReportRequestProto struct

+ Type *DatanodeReportTypeProto

+ XXX_unrecognized []byte

+ func (*GetDatanodeStorageReportRequestProto) ProtoMessage()

+ func (m *GetDatanodeStorageReportRequestProto) GetType() DatanodeReportTypeProto

+ func (m *GetDatanodeStorageReportRequestProto) Reset()

+ func (m *GetDatanodeStorageReportRequestProto) String() string

+ type GetDatanodeStorageReportResponseProto struct

+ DatanodeStorageReports []*DatanodeStorageReportProto

+ XXX_unrecognized []byte

+ func (*GetDatanodeStorageReportResponseProto) ProtoMessage()

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

+ func (m *GetDatanodeStorageReportResponseProto) Reset()

+ func (m *GetDatanodeStorageReportResponseProto) String() string

+ type GetEZForPathRequestProto struct

+ Src *string

+ XXX_unrecognized []byte

+ func (*GetEZForPathRequestProto) ProtoMessage()

+ func (m *GetEZForPathRequestProto) GetSrc() string

+ func (m *GetEZForPathRequestProto) Reset()

+ func (m *GetEZForPathRequestProto) String() string

+ type GetEZForPathResponseProto struct

+ XXX_unrecognized []byte

+ Zone *EncryptionZoneProto

+ func (*GetEZForPathResponseProto) ProtoMessage()

+ func (m *GetEZForPathResponseProto) GetZone() *EncryptionZoneProto

+ func (m *GetEZForPathResponseProto) Reset()

+ func (m *GetEZForPathResponseProto) String() string

+ type GetEditsFromTxidRequestProto struct

+ Txid *int64

+ XXX_unrecognized []byte

+ func (*GetEditsFromTxidRequestProto) ProtoMessage()

+ func (m *GetEditsFromTxidRequestProto) GetTxid() int64

+ func (m *GetEditsFromTxidRequestProto) Reset()

+ func (m *GetEditsFromTxidRequestProto) String() string

+ type GetEditsFromTxidResponseProto struct

+ EventsList *EventsListProto

+ XXX_unrecognized []byte

+ func (*GetEditsFromTxidResponseProto) ProtoMessage()

+ func (m *GetEditsFromTxidResponseProto) GetEventsList() *EventsListProto

+ func (m *GetEditsFromTxidResponseProto) Reset()

+ func (m *GetEditsFromTxidResponseProto) String() string

+ type GetErasureCodingPoliciesRequestProto struct

+ XXX_unrecognized []byte

+ func (*GetErasureCodingPoliciesRequestProto) ProtoMessage()

+ func (m *GetErasureCodingPoliciesRequestProto) Reset()

+ func (m *GetErasureCodingPoliciesRequestProto) String() string

+ type GetErasureCodingPoliciesResponseProto struct

+ EcPolicies []*ErasureCodingPolicyProto

+ XXX_unrecognized []byte

+ func (*GetErasureCodingPoliciesResponseProto) ProtoMessage()

+ func (m *GetErasureCodingPoliciesResponseProto) GetEcPolicies() []*ErasureCodingPolicyProto

+ func (m *GetErasureCodingPoliciesResponseProto) Reset()

+ func (m *GetErasureCodingPoliciesResponseProto) String() string

+ type GetErasureCodingPolicyRequestProto struct

+ Src *string

+ XXX_unrecognized []byte

+ func (*GetErasureCodingPolicyRequestProto) ProtoMessage()

+ func (m *GetErasureCodingPolicyRequestProto) GetSrc() string

+ func (m *GetErasureCodingPolicyRequestProto) Reset()

+ func (m *GetErasureCodingPolicyRequestProto) String() string

+ type GetErasureCodingPolicyResponseProto struct

+ EcPolicy *ErasureCodingPolicyProto

+ XXX_unrecognized []byte

+ func (*GetErasureCodingPolicyResponseProto) ProtoMessage()

+ func (m *GetErasureCodingPolicyResponseProto) GetEcPolicy() *ErasureCodingPolicyProto

+ func (m *GetErasureCodingPolicyResponseProto) Reset()

+ func (m *GetErasureCodingPolicyResponseProto) String() string

type GetFsStatsResponseProto

+ BlocksInFuture *uint64

+ MissingReplOneBlocks *uint64

+ PendingDeletionBlocks *uint64

+ func (m *GetFsStatsResponseProto) GetBlocksInFuture() uint64

+ func (m *GetFsStatsResponseProto) GetMissingReplOneBlocks() uint64

+ func (m *GetFsStatsResponseProto) GetPendingDeletionBlocks() uint64

+ type GetQuotaUsageRequestProto struct

+ Path *string

+ XXX_unrecognized []byte

+ func (*GetQuotaUsageRequestProto) ProtoMessage()

+ func (m *GetQuotaUsageRequestProto) GetPath() string

+ func (m *GetQuotaUsageRequestProto) Reset()

+ func (m *GetQuotaUsageRequestProto) String() string

+ type GetQuotaUsageResponseProto struct

+ Usage *QuotaUsageProto

+ XXX_unrecognized []byte

+ func (*GetQuotaUsageResponseProto) ProtoMessage()

+ func (m *GetQuotaUsageResponseProto) GetUsage() *QuotaUsageProto

+ func (m *GetQuotaUsageResponseProto) Reset()

+ func (m *GetQuotaUsageResponseProto) String() string

+ type GetReconfigurationStatusConfigChangeProto struct

+ ErrorMessage *string

+ Name *string

+ NewValue *string

+ OldValue *string

+ XXX_unrecognized []byte

+ func (*GetReconfigurationStatusConfigChangeProto) ProtoMessage()

+ func (m *GetReconfigurationStatusConfigChangeProto) GetErrorMessage() string

+ func (m *GetReconfigurationStatusConfigChangeProto) GetName() string

+ func (m *GetReconfigurationStatusConfigChangeProto) GetNewValue() string

+ func (m *GetReconfigurationStatusConfigChangeProto) GetOldValue() string

+ func (m *GetReconfigurationStatusConfigChangeProto) Reset()

+ func (m *GetReconfigurationStatusConfigChangeProto) String() string

+ type GetReconfigurationStatusRequestProto struct

+ XXX_unrecognized []byte

+ func (*GetReconfigurationStatusRequestProto) ProtoMessage()

+ func (m *GetReconfigurationStatusRequestProto) Reset()

+ func (m *GetReconfigurationStatusRequestProto) String() string

+ type GetReconfigurationStatusResponseProto struct

+ Changes []*GetReconfigurationStatusConfigChangeProto

+ EndTime *int64

+ StartTime *int64

+ XXX_unrecognized []byte

+ func (*GetReconfigurationStatusResponseProto) ProtoMessage()

+ func (m *GetReconfigurationStatusResponseProto) GetChanges() []*GetReconfigurationStatusConfigChangeProto

+ func (m *GetReconfigurationStatusResponseProto) GetEndTime() int64

+ func (m *GetReconfigurationStatusResponseProto) GetStartTime() int64

+ func (m *GetReconfigurationStatusResponseProto) Reset()

+ func (m *GetReconfigurationStatusResponseProto) String() string

+ type GetReplicaVisibleLengthRequestProto struct

+ Block *ExtendedBlockProto

+ XXX_unrecognized []byte

+ func (*GetReplicaVisibleLengthRequestProto) ProtoMessage()

+ func (m *GetReplicaVisibleLengthRequestProto) GetBlock() *ExtendedBlockProto

+ func (m *GetReplicaVisibleLengthRequestProto) Reset()

+ func (m *GetReplicaVisibleLengthRequestProto) String() string

+ type GetReplicaVisibleLengthResponseProto struct

+ Length *uint64

+ XXX_unrecognized []byte

+ func (*GetReplicaVisibleLengthResponseProto) ProtoMessage()

+ func (m *GetReplicaVisibleLengthResponseProto) GetLength() uint64

+ func (m *GetReplicaVisibleLengthResponseProto) Reset()

+ func (m *GetReplicaVisibleLengthResponseProto) String() string

+ type GetStoragePoliciesRequestProto struct

+ XXX_unrecognized []byte

+ func (*GetStoragePoliciesRequestProto) ProtoMessage()

+ func (m *GetStoragePoliciesRequestProto) Reset()

+ func (m *GetStoragePoliciesRequestProto) String() string

+ type GetStoragePoliciesResponseProto struct

+ Policies []*BlockStoragePolicyProto

+ XXX_unrecognized []byte

+ func (*GetStoragePoliciesResponseProto) ProtoMessage()

+ func (m *GetStoragePoliciesResponseProto) GetPolicies() []*BlockStoragePolicyProto

+ func (m *GetStoragePoliciesResponseProto) Reset()

+ func (m *GetStoragePoliciesResponseProto) String() string

+ type GetStoragePolicyRequestProto struct

+ Path *string

+ XXX_unrecognized []byte

+ func (*GetStoragePolicyRequestProto) ProtoMessage()

+ func (m *GetStoragePolicyRequestProto) GetPath() string

+ func (m *GetStoragePolicyRequestProto) Reset()

+ func (m *GetStoragePolicyRequestProto) String() string

+ type GetStoragePolicyResponseProto struct

+ StoragePolicy *BlockStoragePolicyProto

+ XXX_unrecognized []byte

+ func (*GetStoragePolicyResponseProto) ProtoMessage()

+ func (m *GetStoragePolicyResponseProto) GetStoragePolicy() *BlockStoragePolicyProto

+ func (m *GetStoragePolicyResponseProto) Reset()

+ func (m *GetStoragePolicyResponseProto) String() string

+ type GetXAttrsRequestProto struct

+ Src *string

+ XAttrs []*XAttrProto

+ XXX_unrecognized []byte

+ func (*GetXAttrsRequestProto) ProtoMessage()

+ func (m *GetXAttrsRequestProto) GetSrc() string

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

+ func (m *GetXAttrsRequestProto) Reset()

+ func (m *GetXAttrsRequestProto) String() string

+ type GetXAttrsResponseProto struct

+ XAttrs []*XAttrProto

+ XXX_unrecognized []byte

+ func (*GetXAttrsResponseProto) ProtoMessage()

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

+ func (m *GetXAttrsResponseProto) Reset()

+ func (m *GetXAttrsResponseProto) String() string

type HdfsFileStatusProto

+ EcPolicy *ErasureCodingPolicyProto

+ FileEncryptionInfo *FileEncryptionInfoProto

+ StoragePolicy *uint32

+ func (m *HdfsFileStatusProto) GetEcPolicy() *ErasureCodingPolicyProto

+ func (m *HdfsFileStatusProto) GetFileEncryptionInfo() *FileEncryptionInfoProto

+ func (m *HdfsFileStatusProto) GetStoragePolicy() uint32

+ type INodeType int32

+ const INodeType_I_TYPE_DIRECTORY

+ const INodeType_I_TYPE_FILE

+ const INodeType_I_TYPE_SYMLINK

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

+ func (x INodeType) Enum() *INodeType

+ func (x INodeType) String() string

+ type ListCacheDirectivesRequestProto struct

+ Filter *CacheDirectiveInfoProto

+ PrevId *int64

+ XXX_unrecognized []byte

+ func (*ListCacheDirectivesRequestProto) ProtoMessage()

+ func (m *ListCacheDirectivesRequestProto) GetFilter() *CacheDirectiveInfoProto

+ func (m *ListCacheDirectivesRequestProto) GetPrevId() int64

+ func (m *ListCacheDirectivesRequestProto) Reset()

+ func (m *ListCacheDirectivesRequestProto) String() string

+ type ListCacheDirectivesResponseProto struct

+ Elements []*CacheDirectiveEntryProto

+ HasMore *bool

+ XXX_unrecognized []byte

+ func (*ListCacheDirectivesResponseProto) ProtoMessage()

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

+ func (m *ListCacheDirectivesResponseProto) GetHasMore() bool

+ func (m *ListCacheDirectivesResponseProto) Reset()

+ func (m *ListCacheDirectivesResponseProto) String() string

+ type ListCachePoolsRequestProto struct

+ PrevPoolName *string

+ XXX_unrecognized []byte

+ func (*ListCachePoolsRequestProto) ProtoMessage()

+ func (m *ListCachePoolsRequestProto) GetPrevPoolName() string

+ func (m *ListCachePoolsRequestProto) Reset()

+ func (m *ListCachePoolsRequestProto) String() string

+ type ListCachePoolsResponseProto struct

+ Entries []*CachePoolEntryProto

+ HasMore *bool

+ XXX_unrecognized []byte

+ func (*ListCachePoolsResponseProto) ProtoMessage()

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

+ func (m *ListCachePoolsResponseProto) GetHasMore() bool

+ func (m *ListCachePoolsResponseProto) Reset()

+ func (m *ListCachePoolsResponseProto) String() string

+ type ListEncryptionZonesRequestProto struct

+ Id *int64

+ XXX_unrecognized []byte

+ func (*ListEncryptionZonesRequestProto) ProtoMessage()

+ func (m *ListEncryptionZonesRequestProto) GetId() int64

+ func (m *ListEncryptionZonesRequestProto) Reset()

+ func (m *ListEncryptionZonesRequestProto) String() string

+ type ListEncryptionZonesResponseProto struct

+ HasMore *bool

+ XXX_unrecognized []byte

+ Zones []*EncryptionZoneProto

+ func (*ListEncryptionZonesResponseProto) ProtoMessage()

+ func (m *ListEncryptionZonesResponseProto) GetHasMore() bool

+ func (m *ListEncryptionZonesResponseProto) GetZones() []*EncryptionZoneProto

+ func (m *ListEncryptionZonesResponseProto) Reset()

+ func (m *ListEncryptionZonesResponseProto) String() string

+ type ListReconfigurablePropertiesRequestProto struct

+ XXX_unrecognized []byte

+ func (*ListReconfigurablePropertiesRequestProto) ProtoMessage()

+ func (m *ListReconfigurablePropertiesRequestProto) Reset()

+ func (m *ListReconfigurablePropertiesRequestProto) String() string

+ type ListReconfigurablePropertiesResponseProto struct

+ Name []string

+ XXX_unrecognized []byte

+ func (*ListReconfigurablePropertiesResponseProto) ProtoMessage()

+ func (m *ListReconfigurablePropertiesResponseProto) GetName() []string

+ func (m *ListReconfigurablePropertiesResponseProto) Reset()

+ func (m *ListReconfigurablePropertiesResponseProto) String() string

+ type ListXAttrsRequestProto struct

+ Src *string

+ XXX_unrecognized []byte

+ func (*ListXAttrsRequestProto) ProtoMessage()

+ func (m *ListXAttrsRequestProto) GetSrc() string

+ func (m *ListXAttrsRequestProto) Reset()

+ func (m *ListXAttrsRequestProto) String() string

+ type ListXAttrsResponseProto struct

+ XAttrs []*XAttrProto

+ XXX_unrecognized []byte

+ func (*ListXAttrsResponseProto) ProtoMessage()

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

+ func (m *ListXAttrsResponseProto) Reset()

+ func (m *ListXAttrsResponseProto) String() string

type LocatedBlockProto

+ BlockIndices []byte

+ BlockTokens []*hadoop_common.TokenProto

+ IsCached []bool

+ StorageIDs []string

+ StorageTypes []StorageTypeProto

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

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

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

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

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

type LocatedBlocksProto

+ EcPolicy *ErasureCodingPolicyProto

+ FileEncryptionInfo *FileEncryptionInfoProto

+ func (m *LocatedBlocksProto) GetEcPolicy() *ErasureCodingPolicyProto

+ func (m *LocatedBlocksProto) GetFileEncryptionInfo() *FileEncryptionInfoProto

+ type MetadataUpdateEventProto struct

+ Acls []*AclEntryProto

+ Atime *int64

+ GroupName *string

+ Mtime *int64

+ OwnerName *string

+ Path *string

+ Perms *FsPermissionProto

+ Replication *int32

+ Type *MetadataUpdateType

+ XAttrs []*XAttrProto

+ XAttrsRemoved *bool

+ XXX_unrecognized []byte

+ func (*MetadataUpdateEventProto) ProtoMessage()

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

+ func (m *MetadataUpdateEventProto) GetAtime() int64

+ func (m *MetadataUpdateEventProto) GetGroupName() string

+ func (m *MetadataUpdateEventProto) GetMtime() int64

+ func (m *MetadataUpdateEventProto) GetOwnerName() string

+ func (m *MetadataUpdateEventProto) GetPath() string

+ func (m *MetadataUpdateEventProto) GetPerms() *FsPermissionProto

+ func (m *MetadataUpdateEventProto) GetReplication() int32

+ func (m *MetadataUpdateEventProto) GetType() MetadataUpdateType

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

+ func (m *MetadataUpdateEventProto) GetXAttrsRemoved() bool

+ func (m *MetadataUpdateEventProto) Reset()

+ func (m *MetadataUpdateEventProto) String() string

+ type MetadataUpdateType int32

+ const MetadataUpdateType_META_TYPE_ACLS

+ const MetadataUpdateType_META_TYPE_OWNER

+ const MetadataUpdateType_META_TYPE_PERMS

+ const MetadataUpdateType_META_TYPE_REPLICATION

+ const MetadataUpdateType_META_TYPE_TIMES

+ const MetadataUpdateType_META_TYPE_XATTRS

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

+ func (x MetadataUpdateType) Enum() *MetadataUpdateType

+ func (x MetadataUpdateType) String() string

+ type ModifyAclEntriesRequestProto struct

+ AclSpec []*AclEntryProto

+ Src *string

+ XXX_unrecognized []byte

+ func (*ModifyAclEntriesRequestProto) ProtoMessage()

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

+ func (m *ModifyAclEntriesRequestProto) GetSrc() string

+ func (m *ModifyAclEntriesRequestProto) Reset()

+ func (m *ModifyAclEntriesRequestProto) String() string

+ type ModifyAclEntriesResponseProto struct

+ XXX_unrecognized []byte

+ func (*ModifyAclEntriesResponseProto) ProtoMessage()

+ func (m *ModifyAclEntriesResponseProto) Reset()

+ func (m *ModifyAclEntriesResponseProto) String() string

+ type ModifyCacheDirectiveRequestProto struct

+ CacheFlags *uint32

+ Info *CacheDirectiveInfoProto

+ XXX_unrecognized []byte

+ func (*ModifyCacheDirectiveRequestProto) ProtoMessage()

+ func (m *ModifyCacheDirectiveRequestProto) GetCacheFlags() uint32

+ func (m *ModifyCacheDirectiveRequestProto) GetInfo() *CacheDirectiveInfoProto

+ func (m *ModifyCacheDirectiveRequestProto) Reset()

+ func (m *ModifyCacheDirectiveRequestProto) String() string

+ type ModifyCacheDirectiveResponseProto struct

+ XXX_unrecognized []byte

+ func (*ModifyCacheDirectiveResponseProto) ProtoMessage()

+ func (m *ModifyCacheDirectiveResponseProto) Reset()

+ func (m *ModifyCacheDirectiveResponseProto) String() string

+ type ModifyCachePoolRequestProto struct

+ Info *CachePoolInfoProto

+ XXX_unrecognized []byte

+ func (*ModifyCachePoolRequestProto) ProtoMessage()

+ func (m *ModifyCachePoolRequestProto) GetInfo() *CachePoolInfoProto

+ func (m *ModifyCachePoolRequestProto) Reset()

+ func (m *ModifyCachePoolRequestProto) String() string

+ type ModifyCachePoolResponseProto struct

+ XXX_unrecognized []byte

+ func (*ModifyCachePoolResponseProto) ProtoMessage()

+ func (m *ModifyCachePoolResponseProto) Reset()

+ func (m *ModifyCachePoolResponseProto) String() string

+ type OpBlockGroupChecksumProto struct

+ BlockTokens []*hadoop_common.TokenProto

+ Datanodes *DatanodeInfosProto

+ EcPolicy *ErasureCodingPolicyProto

+ Header *BaseHeaderProto

+ XXX_unrecognized []byte

+ func (*OpBlockGroupChecksumProto) ProtoMessage()

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

+ func (m *OpBlockGroupChecksumProto) GetDatanodes() *DatanodeInfosProto

+ func (m *OpBlockGroupChecksumProto) GetEcPolicy() *ErasureCodingPolicyProto

+ func (m *OpBlockGroupChecksumProto) GetHeader() *BaseHeaderProto

+ func (m *OpBlockGroupChecksumProto) Reset()

+ func (m *OpBlockGroupChecksumProto) String() string

+ type OpCustomProto struct

+ CustomId *string

+ XXX_unrecognized []byte

+ func (*OpCustomProto) ProtoMessage()

+ func (m *OpCustomProto) GetCustomId() string

+ func (m *OpCustomProto) Reset()

+ func (m *OpCustomProto) String() string

type OpReplaceBlockProto

+ StorageType *StorageTypeProto

+ func (m *OpReplaceBlockProto) GetStorageType() StorageTypeProto

type OpRequestShortCircuitAccessProto

+ SlotId *ShortCircuitShmSlotProto

+ SupportsReceiptVerification *bool

+ func (m *OpRequestShortCircuitAccessProto) GetSlotId() *ShortCircuitShmSlotProto

+ func (m *OpRequestShortCircuitAccessProto) GetSupportsReceiptVerification() bool

type OpTransferBlockProto

+ TargetStorageTypes []StorageTypeProto

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

type OpWriteBlockProto

+ AllowLazyPersist *bool

+ Pinning *bool

+ StorageType *StorageTypeProto

+ TargetPinnings []bool

+ TargetStorageTypes []StorageTypeProto

+ func (m *OpWriteBlockProto) GetAllowLazyPersist() bool

+ func (m *OpWriteBlockProto) GetPinning() bool

+ func (m *OpWriteBlockProto) GetStorageType() StorageTypeProto

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

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

+ type PerFileEncryptionInfoProto struct

+ EzKeyVersionName *string

+ Iv []byte

+ Key []byte

+ XXX_unrecognized []byte

+ func (*PerFileEncryptionInfoProto) ProtoMessage()

+ func (m *PerFileEncryptionInfoProto) GetEzKeyVersionName() string

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

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

+ func (m *PerFileEncryptionInfoProto) Reset()

+ func (m *PerFileEncryptionInfoProto) String() string

type PipelineAckProto

+ Flag []uint32

+ Reply []Status

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

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

+ type QuotaUsageProto struct

+ FileAndDirectoryCount *uint64

+ Quota *uint64

+ SpaceConsumed *uint64

+ SpaceQuota *uint64

+ TypeQuotaInfos *StorageTypeQuotaInfosProto

+ XXX_unrecognized []byte

+ func (*QuotaUsageProto) ProtoMessage()

+ func (m *QuotaUsageProto) GetFileAndDirectoryCount() uint64

+ func (m *QuotaUsageProto) GetQuota() uint64

+ func (m *QuotaUsageProto) GetSpaceConsumed() uint64

+ func (m *QuotaUsageProto) GetSpaceQuota() uint64

+ func (m *QuotaUsageProto) GetTypeQuotaInfos() *StorageTypeQuotaInfosProto

+ func (m *QuotaUsageProto) Reset()

+ func (m *QuotaUsageProto) String() string

+ type RefreshNamenodesRequestProto struct

+ XXX_unrecognized []byte

+ func (*RefreshNamenodesRequestProto) ProtoMessage()

+ func (m *RefreshNamenodesRequestProto) Reset()

+ func (m *RefreshNamenodesRequestProto) String() string

+ type RefreshNamenodesResponseProto struct

+ XXX_unrecognized []byte

+ func (*RefreshNamenodesResponseProto) ProtoMessage()

+ func (m *RefreshNamenodesResponseProto) Reset()

+ func (m *RefreshNamenodesResponseProto) String() string

+ type ReleaseShortCircuitAccessRequestProto struct

+ SlotId *ShortCircuitShmSlotProto

+ TraceInfo *DataTransferTraceInfoProto

+ XXX_unrecognized []byte

+ func (*ReleaseShortCircuitAccessRequestProto) ProtoMessage()

+ func (m *ReleaseShortCircuitAccessRequestProto) GetSlotId() *ShortCircuitShmSlotProto

+ func (m *ReleaseShortCircuitAccessRequestProto) GetTraceInfo() *DataTransferTraceInfoProto

+ func (m *ReleaseShortCircuitAccessRequestProto) Reset()

+ func (m *ReleaseShortCircuitAccessRequestProto) String() string

+ type ReleaseShortCircuitAccessResponseProto struct

+ Error *string

+ Status *Status

+ XXX_unrecognized []byte

+ func (*ReleaseShortCircuitAccessResponseProto) ProtoMessage()

+ func (m *ReleaseShortCircuitAccessResponseProto) GetError() string

+ func (m *ReleaseShortCircuitAccessResponseProto) GetStatus() Status

+ func (m *ReleaseShortCircuitAccessResponseProto) Reset()

+ func (m *ReleaseShortCircuitAccessResponseProto) String() string

+ type RemoveAclEntriesRequestProto struct

+ AclSpec []*AclEntryProto

+ Src *string

+ XXX_unrecognized []byte

+ func (*RemoveAclEntriesRequestProto) ProtoMessage()

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

+ func (m *RemoveAclEntriesRequestProto) GetSrc() string

+ func (m *RemoveAclEntriesRequestProto) Reset()

+ func (m *RemoveAclEntriesRequestProto) String() string

+ type RemoveAclEntriesResponseProto struct

+ XXX_unrecognized []byte

+ func (*RemoveAclEntriesResponseProto) ProtoMessage()

+ func (m *RemoveAclEntriesResponseProto) Reset()

+ func (m *RemoveAclEntriesResponseProto) String() string

+ type RemoveAclRequestProto struct

+ Src *string

+ XXX_unrecognized []byte

+ func (*RemoveAclRequestProto) ProtoMessage()

+ func (m *RemoveAclRequestProto) GetSrc() string

+ func (m *RemoveAclRequestProto) Reset()

+ func (m *RemoveAclRequestProto) String() string

+ type RemoveAclResponseProto struct

+ XXX_unrecognized []byte

+ func (*RemoveAclResponseProto) ProtoMessage()

+ func (m *RemoveAclResponseProto) Reset()

+ func (m *RemoveAclResponseProto) String() string

+ type RemoveCacheDirectiveRequestProto struct

+ Id *int64

+ XXX_unrecognized []byte

+ func (*RemoveCacheDirectiveRequestProto) ProtoMessage()

+ func (m *RemoveCacheDirectiveRequestProto) GetId() int64

+ func (m *RemoveCacheDirectiveRequestProto) Reset()

+ func (m *RemoveCacheDirectiveRequestProto) String() string

+ type RemoveCacheDirectiveResponseProto struct

+ XXX_unrecognized []byte

+ func (*RemoveCacheDirectiveResponseProto) ProtoMessage()

+ func (m *RemoveCacheDirectiveResponseProto) Reset()

+ func (m *RemoveCacheDirectiveResponseProto) String() string

+ type RemoveCachePoolRequestProto struct

+ PoolName *string

+ XXX_unrecognized []byte

+ func (*RemoveCachePoolRequestProto) ProtoMessage()

+ func (m *RemoveCachePoolRequestProto) GetPoolName() string

+ func (m *RemoveCachePoolRequestProto) Reset()

+ func (m *RemoveCachePoolRequestProto) String() string

+ type RemoveCachePoolResponseProto struct

+ XXX_unrecognized []byte

+ func (*RemoveCachePoolResponseProto) ProtoMessage()

+ func (m *RemoveCachePoolResponseProto) Reset()

+ func (m *RemoveCachePoolResponseProto) String() string

+ type RemoveDefaultAclRequestProto struct

+ Src *string

+ XXX_unrecognized []byte

+ func (*RemoveDefaultAclRequestProto) ProtoMessage()

+ func (m *RemoveDefaultAclRequestProto) GetSrc() string

+ func (m *RemoveDefaultAclRequestProto) Reset()

+ func (m *RemoveDefaultAclRequestProto) String() string

+ type RemoveDefaultAclResponseProto struct

+ XXX_unrecognized []byte

+ func (*RemoveDefaultAclResponseProto) ProtoMessage()

+ func (m *RemoveDefaultAclResponseProto) Reset()

+ func (m *RemoveDefaultAclResponseProto) String() string

+ type RemoveXAttrRequestProto struct

+ Src *string

+ XAttr *XAttrProto

+ XXX_unrecognized []byte

+ func (*RemoveXAttrRequestProto) ProtoMessage()

+ func (m *RemoveXAttrRequestProto) GetSrc() string

+ func (m *RemoveXAttrRequestProto) GetXAttr() *XAttrProto

+ func (m *RemoveXAttrRequestProto) Reset()

+ func (m *RemoveXAttrRequestProto) String() string

+ type RemoveXAttrResponseProto struct

+ XXX_unrecognized []byte

+ func (*RemoveXAttrResponseProto) ProtoMessage()

+ func (m *RemoveXAttrResponseProto) Reset()

+ func (m *RemoveXAttrResponseProto) String() string

+ type RenameEventProto struct

+ DestPath *string

+ SrcPath *string

+ Timestamp *int64

+ XXX_unrecognized []byte

+ func (*RenameEventProto) ProtoMessage()

+ func (m *RenameEventProto) GetDestPath() string

+ func (m *RenameEventProto) GetSrcPath() string

+ func (m *RenameEventProto) GetTimestamp() int64

+ func (m *RenameEventProto) Reset()

+ func (m *RenameEventProto) String() string

+ type RollingUpgradeActionProto int32

+ const RollingUpgradeActionProto_FINALIZE

+ const RollingUpgradeActionProto_QUERY

+ const RollingUpgradeActionProto_START

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

+ func (x RollingUpgradeActionProto) Enum() *RollingUpgradeActionProto

+ func (x RollingUpgradeActionProto) String() string

+ type RollingUpgradeInfoProto struct

+ CreatedRollbackImages *bool

+ FinalizeTime *uint64

+ StartTime *uint64

+ Status *RollingUpgradeStatusProto

+ XXX_unrecognized []byte

+ func (*RollingUpgradeInfoProto) ProtoMessage()

+ func (m *RollingUpgradeInfoProto) GetCreatedRollbackImages() bool

+ func (m *RollingUpgradeInfoProto) GetFinalizeTime() uint64

+ func (m *RollingUpgradeInfoProto) GetStartTime() uint64

+ func (m *RollingUpgradeInfoProto) GetStatus() *RollingUpgradeStatusProto

+ func (m *RollingUpgradeInfoProto) Reset()

+ func (m *RollingUpgradeInfoProto) String() string

+ type RollingUpgradeRequestProto struct

+ Action *RollingUpgradeActionProto

+ XXX_unrecognized []byte

+ func (*RollingUpgradeRequestProto) ProtoMessage()

+ func (m *RollingUpgradeRequestProto) GetAction() RollingUpgradeActionProto

+ func (m *RollingUpgradeRequestProto) Reset()

+ func (m *RollingUpgradeRequestProto) String() string

+ type RollingUpgradeResponseProto struct

+ RollingUpgradeInfo *RollingUpgradeInfoProto

+ XXX_unrecognized []byte

+ func (*RollingUpgradeResponseProto) ProtoMessage()

+ func (m *RollingUpgradeResponseProto) GetRollingUpgradeInfo() *RollingUpgradeInfoProto

+ func (m *RollingUpgradeResponseProto) Reset()

+ func (m *RollingUpgradeResponseProto) String() string

+ type RollingUpgradeStatusProto struct

+ BlockPoolId *string

+ Finalized *bool

+ XXX_unrecognized []byte

+ func (*RollingUpgradeStatusProto) ProtoMessage()

+ func (m *RollingUpgradeStatusProto) GetBlockPoolId() string

+ func (m *RollingUpgradeStatusProto) GetFinalized() bool

+ func (m *RollingUpgradeStatusProto) Reset()

+ func (m *RollingUpgradeStatusProto) String() string

type SafeModeActionProto

+ const SafeModeActionProto_SAFEMODE_FORCE_EXIT

type SaveNamespaceRequestProto

+ TimeWindow *uint64

+ TxGap *uint64

+ func (m *SaveNamespaceRequestProto) GetTimeWindow() uint64

+ func (m *SaveNamespaceRequestProto) GetTxGap() uint64

type SaveNamespaceResponseProto

+ Saved *bool

+ func (m *SaveNamespaceResponseProto) GetSaved() bool

+ type SetAclRequestProto struct

+ AclSpec []*AclEntryProto

+ Src *string

+ XXX_unrecognized []byte

+ func (*SetAclRequestProto) ProtoMessage()

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

+ func (m *SetAclRequestProto) GetSrc() string

+ func (m *SetAclRequestProto) Reset()

+ func (m *SetAclRequestProto) String() string

+ type SetAclResponseProto struct

+ XXX_unrecognized []byte

+ func (*SetAclResponseProto) ProtoMessage()

+ func (m *SetAclResponseProto) Reset()

+ func (m *SetAclResponseProto) String() string

+ type SetErasureCodingPolicyRequestProto struct

+ EcPolicy *ErasureCodingPolicyProto

+ Src *string

+ XXX_unrecognized []byte

+ func (*SetErasureCodingPolicyRequestProto) ProtoMessage()

+ func (m *SetErasureCodingPolicyRequestProto) GetEcPolicy() *ErasureCodingPolicyProto

+ func (m *SetErasureCodingPolicyRequestProto) GetSrc() string

+ func (m *SetErasureCodingPolicyRequestProto) Reset()

+ func (m *SetErasureCodingPolicyRequestProto) String() string

+ type SetErasureCodingPolicyResponseProto struct

+ XXX_unrecognized []byte

+ func (*SetErasureCodingPolicyResponseProto) ProtoMessage()

+ func (m *SetErasureCodingPolicyResponseProto) Reset()

+ func (m *SetErasureCodingPolicyResponseProto) String() string

type SetQuotaRequestProto

+ StorageType *StorageTypeProto

+ StoragespaceQuota *uint64

+ func (m *SetQuotaRequestProto) GetStorageType() StorageTypeProto

+ func (m *SetQuotaRequestProto) GetStoragespaceQuota() uint64

+ type SetStoragePolicyRequestProto struct

+ PolicyName *string

+ Src *string

+ XXX_unrecognized []byte

+ func (*SetStoragePolicyRequestProto) ProtoMessage()

+ func (m *SetStoragePolicyRequestProto) GetPolicyName() string

+ func (m *SetStoragePolicyRequestProto) GetSrc() string

+ func (m *SetStoragePolicyRequestProto) Reset()

+ func (m *SetStoragePolicyRequestProto) String() string

+ type SetStoragePolicyResponseProto struct

+ XXX_unrecognized []byte

+ func (*SetStoragePolicyResponseProto) ProtoMessage()

+ func (m *SetStoragePolicyResponseProto) Reset()

+ func (m *SetStoragePolicyResponseProto) String() string

+ type SetXAttrRequestProto struct

+ Flag *uint32

+ Src *string

+ XAttr *XAttrProto

+ XXX_unrecognized []byte

+ func (*SetXAttrRequestProto) ProtoMessage()

+ func (m *SetXAttrRequestProto) GetFlag() uint32

+ func (m *SetXAttrRequestProto) GetSrc() string

+ func (m *SetXAttrRequestProto) GetXAttr() *XAttrProto

+ func (m *SetXAttrRequestProto) Reset()

+ func (m *SetXAttrRequestProto) String() string

+ type SetXAttrResponseProto struct

+ XXX_unrecognized []byte

+ func (*SetXAttrResponseProto) ProtoMessage()

+ func (m *SetXAttrResponseProto) Reset()

+ func (m *SetXAttrResponseProto) String() string

+ type ShortCircuitFdResponse int32

+ const ShortCircuitFdResponse_DO_NOT_USE_RECEIPT_VERIFICATION

+ const ShortCircuitFdResponse_USE_RECEIPT_VERIFICATION

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

+ func (x ShortCircuitFdResponse) Enum() *ShortCircuitFdResponse

+ func (x ShortCircuitFdResponse) String() string

+ type ShortCircuitShmIdProto struct

+ Hi *int64

+ Lo *int64

+ XXX_unrecognized []byte

+ func (*ShortCircuitShmIdProto) ProtoMessage()

+ func (m *ShortCircuitShmIdProto) GetHi() int64

+ func (m *ShortCircuitShmIdProto) GetLo() int64

+ func (m *ShortCircuitShmIdProto) Reset()

+ func (m *ShortCircuitShmIdProto) String() string

+ type ShortCircuitShmRequestProto struct

+ ClientName *string

+ TraceInfo *DataTransferTraceInfoProto

+ XXX_unrecognized []byte

+ func (*ShortCircuitShmRequestProto) ProtoMessage()

+ func (m *ShortCircuitShmRequestProto) GetClientName() string

+ func (m *ShortCircuitShmRequestProto) GetTraceInfo() *DataTransferTraceInfoProto

+ func (m *ShortCircuitShmRequestProto) Reset()

+ func (m *ShortCircuitShmRequestProto) String() string

+ type ShortCircuitShmResponseProto struct

+ Error *string

+ Id *ShortCircuitShmIdProto

+ Status *Status

+ XXX_unrecognized []byte

+ func (*ShortCircuitShmResponseProto) ProtoMessage()

+ func (m *ShortCircuitShmResponseProto) GetError() string

+ func (m *ShortCircuitShmResponseProto) GetId() *ShortCircuitShmIdProto

+ func (m *ShortCircuitShmResponseProto) GetStatus() Status

+ func (m *ShortCircuitShmResponseProto) Reset()

+ func (m *ShortCircuitShmResponseProto) String() string

+ type ShortCircuitShmSlotProto struct

+ ShmId *ShortCircuitShmIdProto

+ SlotIdx *int32

+ XXX_unrecognized []byte

+ func (*ShortCircuitShmSlotProto) ProtoMessage()

+ func (m *ShortCircuitShmSlotProto) GetShmId() *ShortCircuitShmIdProto

+ func (m *ShortCircuitShmSlotProto) GetSlotIdx() int32

+ func (m *ShortCircuitShmSlotProto) Reset()

+ func (m *ShortCircuitShmSlotProto) String() string

+ type ShutdownDatanodeRequestProto struct

+ ForUpgrade *bool

+ XXX_unrecognized []byte

+ func (*ShutdownDatanodeRequestProto) ProtoMessage()

+ func (m *ShutdownDatanodeRequestProto) GetForUpgrade() bool

+ func (m *ShutdownDatanodeRequestProto) Reset()

+ func (m *ShutdownDatanodeRequestProto) String() string

+ type ShutdownDatanodeResponseProto struct

+ XXX_unrecognized []byte

+ func (*ShutdownDatanodeResponseProto) ProtoMessage()

+ func (m *ShutdownDatanodeResponseProto) Reset()

+ func (m *ShutdownDatanodeResponseProto) String() string

type SnapshotDiffReportEntryProto

+ TargetPath []byte

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

+ type StartReconfigurationRequestProto struct

+ XXX_unrecognized []byte

+ func (*StartReconfigurationRequestProto) ProtoMessage()

+ func (m *StartReconfigurationRequestProto) Reset()

+ func (m *StartReconfigurationRequestProto) String() string

+ type StartReconfigurationResponseProto struct

+ XXX_unrecognized []byte

+ func (*StartReconfigurationResponseProto) ProtoMessage()

+ func (m *StartReconfigurationResponseProto) Reset()

+ func (m *StartReconfigurationResponseProto) String() string

type Status

+ const Status_IN_PROGRESS

+ const Status_OOB_RESERVED1

+ const Status_OOB_RESERVED2

+ const Status_OOB_RESERVED3

+ const Status_OOB_RESTART

+ type StorageReportProto struct

+ BlockPoolUsed *uint64

+ Capacity *uint64

+ DfsUsed *uint64

+ Failed *bool

+ Remaining *uint64

+ Storage *DatanodeStorageProto

+ StorageUuid *string

+ XXX_unrecognized []byte

+ func (*StorageReportProto) ProtoMessage()

+ func (m *StorageReportProto) GetBlockPoolUsed() uint64

+ func (m *StorageReportProto) GetCapacity() uint64

+ func (m *StorageReportProto) GetDfsUsed() uint64

+ func (m *StorageReportProto) GetFailed() bool

+ func (m *StorageReportProto) GetRemaining() uint64

+ func (m *StorageReportProto) GetStorage() *DatanodeStorageProto

+ func (m *StorageReportProto) GetStorageUuid() string

+ func (m *StorageReportProto) Reset()

+ func (m *StorageReportProto) String() string

+ type StorageTypeProto int32

+ const Default_DatanodeStorageProto_StorageType

+ const Default_OpReplaceBlockProto_StorageType

+ const Default_OpWriteBlockProto_StorageType

+ const StorageTypeProto_ARCHIVE

+ const StorageTypeProto_DISK

+ const StorageTypeProto_RAM_DISK

+ const StorageTypeProto_SSD

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

+ func (x StorageTypeProto) Enum() *StorageTypeProto

+ func (x StorageTypeProto) String() string

+ type StorageTypeQuotaInfoProto struct

+ Consumed *uint64

+ Quota *uint64

+ Type *StorageTypeProto

+ XXX_unrecognized []byte

+ func (*StorageTypeQuotaInfoProto) ProtoMessage()

+ func (m *StorageTypeQuotaInfoProto) GetConsumed() uint64

+ func (m *StorageTypeQuotaInfoProto) GetQuota() uint64

+ func (m *StorageTypeQuotaInfoProto) GetType() StorageTypeProto

+ func (m *StorageTypeQuotaInfoProto) Reset()

+ func (m *StorageTypeQuotaInfoProto) String() string

+ type StorageTypeQuotaInfosProto struct

+ TypeQuotaInfo []*StorageTypeQuotaInfoProto

+ XXX_unrecognized []byte

+ func (*StorageTypeQuotaInfosProto) ProtoMessage()

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

+ func (m *StorageTypeQuotaInfosProto) Reset()

+ func (m *StorageTypeQuotaInfosProto) String() string

+ type StorageTypesProto struct

+ StorageTypes []StorageTypeProto

+ XXX_unrecognized []byte

+ func (*StorageTypesProto) ProtoMessage()

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

+ func (m *StorageTypesProto) Reset()

+ func (m *StorageTypesProto) String() string

+ type StorageUuidsProto struct

+ StorageUuids []string

+ XXX_unrecognized []byte

+ func (*StorageUuidsProto) ProtoMessage()

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

+ func (m *StorageUuidsProto) Reset()

+ func (m *StorageUuidsProto) String() string

+ type TriggerBlockReportRequestProto struct

+ Incremental *bool

+ XXX_unrecognized []byte

+ func (*TriggerBlockReportRequestProto) ProtoMessage()

+ func (m *TriggerBlockReportRequestProto) GetIncremental() bool

+ func (m *TriggerBlockReportRequestProto) Reset()

+ func (m *TriggerBlockReportRequestProto) String() string

+ type TriggerBlockReportResponseProto struct

+ XXX_unrecognized []byte

+ func (*TriggerBlockReportResponseProto) ProtoMessage()

+ func (m *TriggerBlockReportResponseProto) Reset()

+ func (m *TriggerBlockReportResponseProto) String() string

+ type TruncateEventProto struct

+ FileSize *int64

+ Path *string

+ Timestamp *int64

+ XXX_unrecognized []byte

+ func (*TruncateEventProto) ProtoMessage()

+ func (m *TruncateEventProto) GetFileSize() int64

+ func (m *TruncateEventProto) GetPath() string

+ func (m *TruncateEventProto) GetTimestamp() int64

+ func (m *TruncateEventProto) Reset()

+ func (m *TruncateEventProto) String() string

+ type TruncateRequestProto struct

+ ClientName *string

+ NewLength *uint64

+ Src *string

+ XXX_unrecognized []byte

+ func (*TruncateRequestProto) ProtoMessage()

+ func (m *TruncateRequestProto) GetClientName() string

+ func (m *TruncateRequestProto) GetNewLength() uint64

+ func (m *TruncateRequestProto) GetSrc() string

+ func (m *TruncateRequestProto) Reset()

+ func (m *TruncateRequestProto) String() string

+ type TruncateResponseProto struct

+ Result *bool

+ XXX_unrecognized []byte

+ func (*TruncateResponseProto) ProtoMessage()

+ func (m *TruncateResponseProto) GetResult() bool

+ func (m *TruncateResponseProto) Reset()

+ func (m *TruncateResponseProto) String() string

+ type UnlinkEventProto struct

+ Path *string

+ Timestamp *int64

+ XXX_unrecognized []byte

+ func (*UnlinkEventProto) ProtoMessage()

+ func (m *UnlinkEventProto) GetPath() string

+ func (m *UnlinkEventProto) GetTimestamp() int64

+ func (m *UnlinkEventProto) Reset()

+ func (m *UnlinkEventProto) String() string

+ type UnsetStoragePolicyRequestProto struct

+ Src *string

+ XXX_unrecognized []byte

+ func (*UnsetStoragePolicyRequestProto) ProtoMessage()

+ func (m *UnsetStoragePolicyRequestProto) GetSrc() string

+ func (m *UnsetStoragePolicyRequestProto) Reset()

+ func (m *UnsetStoragePolicyRequestProto) String() string

+ type UnsetStoragePolicyResponseProto struct

+ XXX_unrecognized []byte

+ func (*UnsetStoragePolicyResponseProto) ProtoMessage()

+ func (m *UnsetStoragePolicyResponseProto) Reset()

+ func (m *UnsetStoragePolicyResponseProto) String() string

type UpdatePipelineRequestProto

+ StorageIDs []string

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

+ type XAttrProto struct

+ Name *string

+ Namespace *XAttrProto_XAttrNamespaceProto

+ Value []byte

+ XXX_unrecognized []byte

+ func (*XAttrProto) ProtoMessage()

+ func (m *XAttrProto) GetName() string

+ func (m *XAttrProto) GetNamespace() XAttrProto_XAttrNamespaceProto

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

+ func (m *XAttrProto) Reset()

+ func (m *XAttrProto) String() string

+ type XAttrProto_XAttrNamespaceProto int32

+ const XAttrProto_RAW

+ const XAttrProto_SECURITY

+ const XAttrProto_SYSTEM

+ const XAttrProto_TRUSTED

+ const XAttrProto_USER

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

+ func (x XAttrProto_XAttrNamespaceProto) Enum() *XAttrProto_XAttrNamespaceProto

+ func (x XAttrProto_XAttrNamespaceProto) String() string

+ type XAttrSetFlagProto int32

+ const XAttrSetFlagProto_XATTR_CREATE

+ const XAttrSetFlagProto_XATTR_REPLACE

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

+ func (x XAttrSetFlagProto) Enum() *XAttrSetFlagProto

+ func (x XAttrSetFlagProto) String() string

+ type ZoneEncryptionInfoProto struct

+ CryptoProtocolVersion *CryptoProtocolVersionProto

+ KeyName *string

+ Suite *CipherSuiteProto

+ XXX_unrecognized []byte

+ func (*ZoneEncryptionInfoProto) ProtoMessage()

+ func (m *ZoneEncryptionInfoProto) GetCryptoProtocolVersion() CryptoProtocolVersionProto

+ func (m *ZoneEncryptionInfoProto) GetKeyName() string

+ func (m *ZoneEncryptionInfoProto) GetSuite() CipherSuiteProto

+ func (m *ZoneEncryptionInfoProto) Reset()

+ func (m *ZoneEncryptionInfoProto) String() string

v0

v0.1.4

Feb 28, 2015

v0.1.3

Jan 6, 2015

v0.1.2

Dec 19, 2014

Changes in this version

+ const Default_AddBlockRequestProto_FileId

+ const Default_BlockProto_NumBytes

+ const Default_CompleteRequestProto_FileId

+ const Default_DatanodeIDProto_InfoSecurePort

+ const Default_DatanodeInfoProto_BlockPoolUsed

+ const Default_DatanodeInfoProto_Capacity

+ const Default_DatanodeInfoProto_DfsUsed

+ const Default_DatanodeInfoProto_LastUpdate

+ const Default_DatanodeInfoProto_Remaining

+ const Default_DatanodeInfoProto_XceiverCount

+ const Default_ExtendedBlockProto_NumBytes

+ const Default_FsServerDefaultsProto_EncryptDataTransfer

+ const Default_FsServerDefaultsProto_TrashInterval

+ const Default_FsyncRequestProto_LastBlockLength

+ const Default_HdfsFileStatusProto_BlockReplication

+ const Default_HdfsFileStatusProto_Blocksize

+ const Default_HdfsFileStatusProto_ChildrenNum

+ const Default_HdfsFileStatusProto_FileId

+ const Default_OpReadBlockProto_SendChecksums

+ const Default_PacketHeaderProto_SyncBlock

+ const Default_PipelineAckProto_DownstreamAckTimeNanos

+ const Default_RemoteEditLogProto_IsInProgress

+ const Default_SetSafeModeRequestProto_Checked

+ var ChecksumTypeProto_name = map[int32]string

+ var ChecksumTypeProto_value = map[string]int32

+ var CreateFlagProto_name = map[int32]string

+ var CreateFlagProto_value = map[string]int32

+ var DataTransferEncryptorMessageProto_DataTransferEncryptorStatus_name = map[int32]string

+ var DataTransferEncryptorMessageProto_DataTransferEncryptorStatus_value = map[string]int32

+ var DatanodeInfoProto_AdminState_name = map[int32]string

+ var DatanodeInfoProto_AdminState_value = map[string]int32

+ var DatanodeReportTypeProto_name = map[int32]string

+ var DatanodeReportTypeProto_value = map[string]int32

+ var HdfsFileStatusProto_FileType_name = map[int32]string

+ var HdfsFileStatusProto_FileType_value = map[string]int32

+ var NamenodeCommandProto_Type_name = map[int32]string

+ var NamenodeCommandProto_Type_value = map[string]int32

+ var NamenodeRegistrationProto_NamenodeRoleProto_name = map[int32]string

+ var NamenodeRegistrationProto_NamenodeRoleProto_value = map[string]int32

+ var OpWriteBlockProto_BlockConstructionStage_name = map[int32]string

+ var OpWriteBlockProto_BlockConstructionStage_value = map[string]int32

+ var ReplicaStateProto_name = map[int32]string

+ var ReplicaStateProto_value = map[string]int32

+ var SafeModeActionProto_name = map[int32]string

+ var SafeModeActionProto_value = map[string]int32

+ var Status_name = map[int32]string

+ var Status_value = map[string]int32

+ type AbandonBlockRequestProto struct

+ B *ExtendedBlockProto

+ Holder *string

+ Src *string

+ XXX_unrecognized []byte

+ func (*AbandonBlockRequestProto) ProtoMessage()

+ func (m *AbandonBlockRequestProto) GetB() *ExtendedBlockProto

+ func (m *AbandonBlockRequestProto) GetHolder() string

+ func (m *AbandonBlockRequestProto) GetSrc() string

+ func (m *AbandonBlockRequestProto) Reset()

+ func (m *AbandonBlockRequestProto) String() string

+ type AbandonBlockResponseProto struct

+ XXX_unrecognized []byte

+ func (*AbandonBlockResponseProto) ProtoMessage()

+ func (m *AbandonBlockResponseProto) Reset()

+ func (m *AbandonBlockResponseProto) String() string

+ type AddBlockRequestProto struct

+ ClientName *string

+ ExcludeNodes []*DatanodeInfoProto

+ FavoredNodes []string

+ FileId *uint64

+ Previous *ExtendedBlockProto

+ Src *string

+ XXX_unrecognized []byte

+ func (*AddBlockRequestProto) ProtoMessage()

+ func (m *AddBlockRequestProto) GetClientName() string

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

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

+ func (m *AddBlockRequestProto) GetFileId() uint64

+ func (m *AddBlockRequestProto) GetPrevious() *ExtendedBlockProto

+ func (m *AddBlockRequestProto) GetSrc() string

+ func (m *AddBlockRequestProto) Reset()

+ func (m *AddBlockRequestProto) String() string

+ type AddBlockResponseProto struct

+ Block *LocatedBlockProto

+ XXX_unrecognized []byte

+ func (*AddBlockResponseProto) ProtoMessage()

+ func (m *AddBlockResponseProto) GetBlock() *LocatedBlockProto

+ func (m *AddBlockResponseProto) Reset()

+ func (m *AddBlockResponseProto) String() string

+ type AllowSnapshotRequestProto struct

+ SnapshotRoot *string

+ XXX_unrecognized []byte

+ func (*AllowSnapshotRequestProto) ProtoMessage()

+ func (m *AllowSnapshotRequestProto) GetSnapshotRoot() string

+ func (m *AllowSnapshotRequestProto) Reset()

+ func (m *AllowSnapshotRequestProto) String() string

+ type AllowSnapshotResponseProto struct

+ XXX_unrecognized []byte

+ func (*AllowSnapshotResponseProto) ProtoMessage()

+ func (m *AllowSnapshotResponseProto) Reset()

+ func (m *AllowSnapshotResponseProto) String() string

+ type AppendRequestProto struct

+ ClientName *string

+ Src *string

+ XXX_unrecognized []byte

+ func (*AppendRequestProto) ProtoMessage()

+ func (m *AppendRequestProto) GetClientName() string

+ func (m *AppendRequestProto) GetSrc() string

+ func (m *AppendRequestProto) Reset()

+ func (m *AppendRequestProto) String() string

+ type AppendResponseProto struct

+ Block *LocatedBlockProto

+ XXX_unrecognized []byte

+ func (*AppendResponseProto) ProtoMessage()

+ func (m *AppendResponseProto) GetBlock() *LocatedBlockProto

+ func (m *AppendResponseProto) Reset()

+ func (m *AppendResponseProto) String() string

+ type BaseHeaderProto struct

+ Block *ExtendedBlockProto

+ Token *hadoop_common.TokenProto

+ XXX_unrecognized []byte

+ func (*BaseHeaderProto) ProtoMessage()

+ func (m *BaseHeaderProto) GetBlock() *ExtendedBlockProto

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

+ func (m *BaseHeaderProto) Reset()

+ func (m *BaseHeaderProto) String() string

+ type BlockKeyProto struct

+ ExpiryDate *uint64

+ KeyBytes []byte

+ KeyId *uint32

+ XXX_unrecognized []byte

+ func (*BlockKeyProto) ProtoMessage()

+ func (m *BlockKeyProto) GetExpiryDate() uint64

+ func (m *BlockKeyProto) GetKeyBytes() []byte

+ func (m *BlockKeyProto) GetKeyId() uint32

+ func (m *BlockKeyProto) Reset()

+ func (m *BlockKeyProto) String() string

+ type BlockOpResponseProto struct

+ ChecksumResponse *OpBlockChecksumResponseProto

+ FirstBadLink *string

+ Message *string

+ ReadOpChecksumInfo *ReadOpChecksumInfoProto

+ ShortCircuitAccessVersion *uint32

+ Status *Status

+ XXX_unrecognized []byte

+ func (*BlockOpResponseProto) ProtoMessage()

+ func (m *BlockOpResponseProto) GetChecksumResponse() *OpBlockChecksumResponseProto

+ func (m *BlockOpResponseProto) GetFirstBadLink() string

+ func (m *BlockOpResponseProto) GetMessage() string

+ func (m *BlockOpResponseProto) GetReadOpChecksumInfo() *ReadOpChecksumInfoProto

+ func (m *BlockOpResponseProto) GetShortCircuitAccessVersion() uint32

+ func (m *BlockOpResponseProto) GetStatus() Status

+ func (m *BlockOpResponseProto) Reset()

+ func (m *BlockOpResponseProto) String() string

+ type BlockProto struct

+ BlockId *uint64

+ GenStamp *uint64

+ NumBytes *uint64

+ XXX_unrecognized []byte

+ func (*BlockProto) ProtoMessage()

+ func (m *BlockProto) GetBlockId() uint64

+ func (m *BlockProto) GetGenStamp() uint64

+ func (m *BlockProto) GetNumBytes() uint64

+ func (m *BlockProto) Reset()

+ func (m *BlockProto) String() string

+ type BlockWithLocationsProto struct

+ Block *BlockProto

+ StorageIDs []string

+ XXX_unrecognized []byte

+ func (*BlockWithLocationsProto) ProtoMessage()

+ func (m *BlockWithLocationsProto) GetBlock() *BlockProto

+ func (m *BlockWithLocationsProto) GetStorageIDs() []string

+ func (m *BlockWithLocationsProto) Reset()

+ func (m *BlockWithLocationsProto) String() string

+ type BlocksWithLocationsProto struct

+ Blocks []*BlockWithLocationsProto

+ XXX_unrecognized []byte

+ func (*BlocksWithLocationsProto) ProtoMessage()

+ func (m *BlocksWithLocationsProto) GetBlocks() []*BlockWithLocationsProto

+ func (m *BlocksWithLocationsProto) Reset()

+ func (m *BlocksWithLocationsProto) String() string

+ type CachingStrategyProto struct

+ DropBehind *bool

+ Readahead *int64

+ XXX_unrecognized []byte

+ func (*CachingStrategyProto) ProtoMessage()

+ func (m *CachingStrategyProto) GetDropBehind() bool

+ func (m *CachingStrategyProto) GetReadahead() int64

+ func (m *CachingStrategyProto) Reset()

+ func (m *CachingStrategyProto) String() string

+ type CheckpointCommandProto struct

+ NeedToReturnImage *bool

+ Signature *CheckpointSignatureProto

+ XXX_unrecognized []byte

+ func (*CheckpointCommandProto) ProtoMessage()

+ func (m *CheckpointCommandProto) GetNeedToReturnImage() bool

+ func (m *CheckpointCommandProto) GetSignature() *CheckpointSignatureProto

+ func (m *CheckpointCommandProto) Reset()

+ func (m *CheckpointCommandProto) String() string

+ type CheckpointSignatureProto struct

+ BlockPoolId *string

+ CurSegmentTxId *uint64

+ MostRecentCheckpointTxId *uint64

+ StorageInfo *StorageInfoProto

+ XXX_unrecognized []byte

+ func (*CheckpointSignatureProto) ProtoMessage()

+ func (m *CheckpointSignatureProto) GetBlockPoolId() string

+ func (m *CheckpointSignatureProto) GetCurSegmentTxId() uint64

+ func (m *CheckpointSignatureProto) GetMostRecentCheckpointTxId() uint64

+ func (m *CheckpointSignatureProto) GetStorageInfo() *StorageInfoProto

+ func (m *CheckpointSignatureProto) Reset()

+ func (m *CheckpointSignatureProto) String() string

+ type ChecksumProto struct

+ BytesPerChecksum *uint32

+ Type *ChecksumTypeProto

+ XXX_unrecognized []byte

+ func (*ChecksumProto) ProtoMessage()

+ func (m *ChecksumProto) GetBytesPerChecksum() uint32

+ func (m *ChecksumProto) GetType() ChecksumTypeProto

+ func (m *ChecksumProto) Reset()

+ func (m *ChecksumProto) String() string

+ type ChecksumTypeProto int32

+ const ChecksumTypeProto_CHECKSUM_CRC32

+ const ChecksumTypeProto_CHECKSUM_CRC32C

+ const ChecksumTypeProto_CHECKSUM_NULL

+ const Default_FsServerDefaultsProto_ChecksumType

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

+ func (x ChecksumTypeProto) Enum() *ChecksumTypeProto

+ func (x ChecksumTypeProto) String() string

+ type ClientOperationHeaderProto struct

+ BaseHeader *BaseHeaderProto

+ ClientName *string

+ XXX_unrecognized []byte

+ func (*ClientOperationHeaderProto) ProtoMessage()

+ func (m *ClientOperationHeaderProto) GetBaseHeader() *BaseHeaderProto

+ func (m *ClientOperationHeaderProto) GetClientName() string

+ func (m *ClientOperationHeaderProto) Reset()

+ func (m *ClientOperationHeaderProto) String() string

+ type ClientReadStatusProto struct

+ Status *Status

+ XXX_unrecognized []byte

+ func (*ClientReadStatusProto) ProtoMessage()

+ func (m *ClientReadStatusProto) GetStatus() Status

+ func (m *ClientReadStatusProto) Reset()

+ func (m *ClientReadStatusProto) String() string

+ type CompleteRequestProto struct

+ ClientName *string

+ FileId *uint64

+ Last *ExtendedBlockProto

+ Src *string

+ XXX_unrecognized []byte

+ func (*CompleteRequestProto) ProtoMessage()

+ func (m *CompleteRequestProto) GetClientName() string

+ func (m *CompleteRequestProto) GetFileId() uint64

+ func (m *CompleteRequestProto) GetLast() *ExtendedBlockProto

+ func (m *CompleteRequestProto) GetSrc() string

+ func (m *CompleteRequestProto) Reset()

+ func (m *CompleteRequestProto) String() string

+ type CompleteResponseProto struct

+ Result *bool

+ XXX_unrecognized []byte

+ func (*CompleteResponseProto) ProtoMessage()

+ func (m *CompleteResponseProto) GetResult() bool

+ func (m *CompleteResponseProto) Reset()

+ func (m *CompleteResponseProto) String() string

+ type ConcatRequestProto struct

+ Srcs []string

+ Trg *string

+ XXX_unrecognized []byte

+ func (*ConcatRequestProto) ProtoMessage()

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

+ func (m *ConcatRequestProto) GetTrg() string

+ func (m *ConcatRequestProto) Reset()

+ func (m *ConcatRequestProto) String() string

+ type ConcatResponseProto struct

+ XXX_unrecognized []byte

+ func (*ConcatResponseProto) ProtoMessage()

+ func (m *ConcatResponseProto) Reset()

+ func (m *ConcatResponseProto) String() string

+ type ContentSummaryProto struct

+ DirectoryCount *uint64

+ FileCount *uint64

+ Length *uint64

+ Quota *uint64

+ SpaceConsumed *uint64

+ SpaceQuota *uint64

+ XXX_unrecognized []byte

+ func (*ContentSummaryProto) ProtoMessage()

+ func (m *ContentSummaryProto) GetDirectoryCount() uint64

+ func (m *ContentSummaryProto) GetFileCount() uint64

+ func (m *ContentSummaryProto) GetLength() uint64

+ func (m *ContentSummaryProto) GetQuota() uint64

+ func (m *ContentSummaryProto) GetSpaceConsumed() uint64

+ func (m *ContentSummaryProto) GetSpaceQuota() uint64

+ func (m *ContentSummaryProto) Reset()

+ func (m *ContentSummaryProto) String() string

+ type CorruptFileBlocksProto struct

+ Cookie *string

+ Files []string

+ XXX_unrecognized []byte

+ func (*CorruptFileBlocksProto) ProtoMessage()

+ func (m *CorruptFileBlocksProto) GetCookie() string

+ func (m *CorruptFileBlocksProto) GetFiles() []string

+ func (m *CorruptFileBlocksProto) Reset()

+ func (m *CorruptFileBlocksProto) String() string

+ type CreateFlagProto int32

+ const CreateFlagProto_APPEND

+ const CreateFlagProto_CREATE

+ const CreateFlagProto_OVERWRITE

+ func (x *CreateFlagProto) UnmarshalJSON(data []byte) error

+ func (x CreateFlagProto) Enum() *CreateFlagProto

+ func (x CreateFlagProto) String() string

+ type CreateRequestProto struct

+ BlockSize *uint64

+ ClientName *string

+ CreateFlag *uint32

+ CreateParent *bool

+ Masked *FsPermissionProto

+ Replication *uint32

+ Src *string

+ XXX_unrecognized []byte

+ func (*CreateRequestProto) ProtoMessage()

+ func (m *CreateRequestProto) GetBlockSize() uint64

+ func (m *CreateRequestProto) GetClientName() string

+ func (m *CreateRequestProto) GetCreateFlag() uint32

+ func (m *CreateRequestProto) GetCreateParent() bool

+ func (m *CreateRequestProto) GetMasked() *FsPermissionProto

+ func (m *CreateRequestProto) GetReplication() uint32

+ func (m *CreateRequestProto) GetSrc() string

+ func (m *CreateRequestProto) Reset()

+ func (m *CreateRequestProto) String() string

+ type CreateResponseProto struct

+ Fs *HdfsFileStatusProto

+ XXX_unrecognized []byte

+ func (*CreateResponseProto) ProtoMessage()

+ func (m *CreateResponseProto) GetFs() *HdfsFileStatusProto

+ func (m *CreateResponseProto) Reset()

+ func (m *CreateResponseProto) String() string

+ type CreateSnapshotRequestProto struct

+ SnapshotName *string

+ SnapshotRoot *string

+ XXX_unrecognized []byte

+ func (*CreateSnapshotRequestProto) ProtoMessage()

+ func (m *CreateSnapshotRequestProto) GetSnapshotName() string

+ func (m *CreateSnapshotRequestProto) GetSnapshotRoot() string

+ func (m *CreateSnapshotRequestProto) Reset()

+ func (m *CreateSnapshotRequestProto) String() string

+ type CreateSnapshotResponseProto struct

+ SnapshotPath *string

+ XXX_unrecognized []byte

+ func (*CreateSnapshotResponseProto) ProtoMessage()

+ func (m *CreateSnapshotResponseProto) GetSnapshotPath() string

+ func (m *CreateSnapshotResponseProto) Reset()

+ func (m *CreateSnapshotResponseProto) String() string

+ type CreateSymlinkRequestProto struct

+ CreateParent *bool

+ DirPerm *FsPermissionProto

+ Link *string

+ Target *string

+ XXX_unrecognized []byte

+ func (*CreateSymlinkRequestProto) ProtoMessage()

+ func (m *CreateSymlinkRequestProto) GetCreateParent() bool

+ func (m *CreateSymlinkRequestProto) GetDirPerm() *FsPermissionProto

+ func (m *CreateSymlinkRequestProto) GetLink() string

+ func (m *CreateSymlinkRequestProto) GetTarget() string

+ func (m *CreateSymlinkRequestProto) Reset()

+ func (m *CreateSymlinkRequestProto) String() string

+ type CreateSymlinkResponseProto struct

+ XXX_unrecognized []byte

+ func (*CreateSymlinkResponseProto) ProtoMessage()

+ func (m *CreateSymlinkResponseProto) Reset()

+ func (m *CreateSymlinkResponseProto) String() string

+ type DNTransferAckProto struct

+ Status *Status

+ XXX_unrecognized []byte

+ func (*DNTransferAckProto) ProtoMessage()

+ func (m *DNTransferAckProto) GetStatus() Status

+ func (m *DNTransferAckProto) Reset()

+ func (m *DNTransferAckProto) String() string

+ type DataEncryptionKeyProto struct

+ BlockPoolId *string

+ EncryptionAlgorithm *string

+ EncryptionKey []byte

+ ExpiryDate *uint64

+ KeyId *uint32

+ Nonce []byte

+ XXX_unrecognized []byte

+ func (*DataEncryptionKeyProto) ProtoMessage()

+ func (m *DataEncryptionKeyProto) GetBlockPoolId() string

+ func (m *DataEncryptionKeyProto) GetEncryptionAlgorithm() string

+ func (m *DataEncryptionKeyProto) GetEncryptionKey() []byte

+ func (m *DataEncryptionKeyProto) GetExpiryDate() uint64

+ func (m *DataEncryptionKeyProto) GetKeyId() uint32

+ func (m *DataEncryptionKeyProto) GetNonce() []byte

+ func (m *DataEncryptionKeyProto) Reset()

+ func (m *DataEncryptionKeyProto) String() string

+ type DataTransferEncryptorMessageProto struct

+ Message *string

+ Payload []byte

+ Status *DataTransferEncryptorMessageProto_DataTransferEncryptorStatus

+ XXX_unrecognized []byte

+ func (*DataTransferEncryptorMessageProto) ProtoMessage()

+ func (m *DataTransferEncryptorMessageProto) GetMessage() string

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

+ func (m *DataTransferEncryptorMessageProto) GetStatus() DataTransferEncryptorMessageProto_DataTransferEncryptorStatus

+ func (m *DataTransferEncryptorMessageProto) Reset()

+ func (m *DataTransferEncryptorMessageProto) String() string

+ type DataTransferEncryptorMessageProto_DataTransferEncryptorStatus int32

+ const DataTransferEncryptorMessageProto_ERROR

+ const DataTransferEncryptorMessageProto_ERROR_UNKNOWN_KEY

+ const DataTransferEncryptorMessageProto_SUCCESS

+ func (x *DataTransferEncryptorMessageProto_DataTransferEncryptorStatus) UnmarshalJSON(data []byte) error

+ func (x DataTransferEncryptorMessageProto_DataTransferEncryptorStatus) Enum() *DataTransferEncryptorMessageProto_DataTransferEncryptorStatus

+ func (x DataTransferEncryptorMessageProto_DataTransferEncryptorStatus) String() string

+ type DatanodeIDProto struct

+ HostName *string

+ InfoPort *uint32

+ InfoSecurePort *uint32

+ IpAddr *string

+ IpcPort *uint32

+ StorageID *string

+ XXX_unrecognized []byte

+ XferPort *uint32

+ func (*DatanodeIDProto) ProtoMessage()

+ func (m *DatanodeIDProto) GetHostName() string

+ func (m *DatanodeIDProto) GetInfoPort() uint32

+ func (m *DatanodeIDProto) GetInfoSecurePort() uint32

+ func (m *DatanodeIDProto) GetIpAddr() string

+ func (m *DatanodeIDProto) GetIpcPort() uint32

+ func (m *DatanodeIDProto) GetStorageID() string

+ func (m *DatanodeIDProto) GetXferPort() uint32

+ func (m *DatanodeIDProto) Reset()

+ func (m *DatanodeIDProto) String() string

+ type DatanodeInfoProto struct

+ AdminState *DatanodeInfoProto_AdminState

+ BlockPoolUsed *uint64

+ Capacity *uint64

+ DfsUsed *uint64

+ Id *DatanodeIDProto

+ LastUpdate *uint64

+ Location *string

+ Remaining *uint64

+ XXX_unrecognized []byte

+ XceiverCount *uint32

+ func (*DatanodeInfoProto) ProtoMessage()

+ func (m *DatanodeInfoProto) GetAdminState() DatanodeInfoProto_AdminState

+ func (m *DatanodeInfoProto) GetBlockPoolUsed() uint64

+ func (m *DatanodeInfoProto) GetCapacity() uint64

+ func (m *DatanodeInfoProto) GetDfsUsed() uint64

+ func (m *DatanodeInfoProto) GetId() *DatanodeIDProto

+ func (m *DatanodeInfoProto) GetLastUpdate() uint64

+ func (m *DatanodeInfoProto) GetLocation() string

+ func (m *DatanodeInfoProto) GetRemaining() uint64

+ func (m *DatanodeInfoProto) GetXceiverCount() uint32

+ func (m *DatanodeInfoProto) Reset()

+ func (m *DatanodeInfoProto) String() string

+ type DatanodeInfoProto_AdminState int32

+ const DatanodeInfoProto_DECOMMISSIONED

+ const DatanodeInfoProto_DECOMMISSION_INPROGRESS

+ const DatanodeInfoProto_NORMAL

+ const Default_DatanodeInfoProto_AdminState

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

+ func (x DatanodeInfoProto_AdminState) Enum() *DatanodeInfoProto_AdminState

+ func (x DatanodeInfoProto_AdminState) String() string

+ type DatanodeInfosProto struct

+ Datanodes []*DatanodeInfoProto

+ XXX_unrecognized []byte

+ func (*DatanodeInfosProto) ProtoMessage()

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

+ func (m *DatanodeInfosProto) Reset()

+ func (m *DatanodeInfosProto) String() string

+ type DatanodeReportTypeProto int32

+ const DatanodeReportTypeProto_ALL

+ const DatanodeReportTypeProto_DEAD

+ const DatanodeReportTypeProto_LIVE

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

+ func (x DatanodeReportTypeProto) Enum() *DatanodeReportTypeProto

+ func (x DatanodeReportTypeProto) String() string

+ type DeleteRequestProto struct

+ Recursive *bool

+ Src *string

+ XXX_unrecognized []byte

+ func (*DeleteRequestProto) ProtoMessage()

+ func (m *DeleteRequestProto) GetRecursive() bool

+ func (m *DeleteRequestProto) GetSrc() string

+ func (m *DeleteRequestProto) Reset()

+ func (m *DeleteRequestProto) String() string

+ type DeleteResponseProto struct

+ Result *bool

+ XXX_unrecognized []byte

+ func (*DeleteResponseProto) ProtoMessage()

+ func (m *DeleteResponseProto) GetResult() bool

+ func (m *DeleteResponseProto) Reset()

+ func (m *DeleteResponseProto) String() string

+ type DeleteSnapshotRequestProto struct

+ SnapshotName *string

+ SnapshotRoot *string

+ XXX_unrecognized []byte

+ func (*DeleteSnapshotRequestProto) ProtoMessage()

+ func (m *DeleteSnapshotRequestProto) GetSnapshotName() string

+ func (m *DeleteSnapshotRequestProto) GetSnapshotRoot() string

+ func (m *DeleteSnapshotRequestProto) Reset()

+ func (m *DeleteSnapshotRequestProto) String() string

+ type DeleteSnapshotResponseProto struct

+ XXX_unrecognized []byte

+ func (*DeleteSnapshotResponseProto) ProtoMessage()

+ func (m *DeleteSnapshotResponseProto) Reset()

+ func (m *DeleteSnapshotResponseProto) String() string

+ type DirectoryListingProto struct

+ PartialListing []*HdfsFileStatusProto

+ RemainingEntries *uint32

+ XXX_unrecognized []byte

+ func (*DirectoryListingProto) ProtoMessage()

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

+ func (m *DirectoryListingProto) GetRemainingEntries() uint32

+ func (m *DirectoryListingProto) Reset()

+ func (m *DirectoryListingProto) String() string

+ type DisallowSnapshotRequestProto struct

+ SnapshotRoot *string

+ XXX_unrecognized []byte

+ func (*DisallowSnapshotRequestProto) ProtoMessage()

+ func (m *DisallowSnapshotRequestProto) GetSnapshotRoot() string

+ func (m *DisallowSnapshotRequestProto) Reset()

+ func (m *DisallowSnapshotRequestProto) String() string

+ type DisallowSnapshotResponseProto struct

+ XXX_unrecognized []byte

+ func (*DisallowSnapshotResponseProto) ProtoMessage()

+ func (m *DisallowSnapshotResponseProto) Reset()

+ func (m *DisallowSnapshotResponseProto) String() string

+ type ExportedBlockKeysProto struct

+ AllKeys []*BlockKeyProto

+ CurrentKey *BlockKeyProto

+ IsBlockTokenEnabled *bool

+ KeyUpdateInterval *uint64

+ TokenLifeTime *uint64

+ XXX_unrecognized []byte

+ func (*ExportedBlockKeysProto) ProtoMessage()

+ func (m *ExportedBlockKeysProto) GetAllKeys() []*BlockKeyProto

+ func (m *ExportedBlockKeysProto) GetCurrentKey() *BlockKeyProto

+ func (m *ExportedBlockKeysProto) GetIsBlockTokenEnabled() bool

+ func (m *ExportedBlockKeysProto) GetKeyUpdateInterval() uint64

+ func (m *ExportedBlockKeysProto) GetTokenLifeTime() uint64

+ func (m *ExportedBlockKeysProto) Reset()

+ func (m *ExportedBlockKeysProto) String() string

+ type ExtendedBlockProto struct

+ BlockId *uint64

+ GenerationStamp *uint64

+ NumBytes *uint64

+ PoolId *string

+ XXX_unrecognized []byte

+ func (*ExtendedBlockProto) ProtoMessage()

+ func (m *ExtendedBlockProto) GetBlockId() uint64

+ func (m *ExtendedBlockProto) GetGenerationStamp() uint64

+ func (m *ExtendedBlockProto) GetNumBytes() uint64

+ func (m *ExtendedBlockProto) GetPoolId() string

+ func (m *ExtendedBlockProto) Reset()

+ func (m *ExtendedBlockProto) String() string

+ type FinalizeUpgradeRequestProto struct

+ XXX_unrecognized []byte

+ func (*FinalizeUpgradeRequestProto) ProtoMessage()

+ func (m *FinalizeUpgradeRequestProto) Reset()

+ func (m *FinalizeUpgradeRequestProto) String() string

+ type FinalizeUpgradeResponseProto struct

+ XXX_unrecognized []byte

+ func (*FinalizeUpgradeResponseProto) ProtoMessage()

+ func (m *FinalizeUpgradeResponseProto) Reset()

+ func (m *FinalizeUpgradeResponseProto) String() string

+ type FsPermissionProto struct

+ Perm *uint32

+ XXX_unrecognized []byte

+ func (*FsPermissionProto) ProtoMessage()

+ func (m *FsPermissionProto) GetPerm() uint32

+ func (m *FsPermissionProto) Reset()

+ func (m *FsPermissionProto) String() string

+ type FsServerDefaultsProto struct

+ BlockSize *uint64

+ BytesPerChecksum *uint32

+ ChecksumType *ChecksumTypeProto

+ EncryptDataTransfer *bool

+ FileBufferSize *uint32

+ Replication *uint32

+ TrashInterval *uint64

+ WritePacketSize *uint32

+ XXX_unrecognized []byte

+ func (*FsServerDefaultsProto) ProtoMessage()

+ func (m *FsServerDefaultsProto) GetBlockSize() uint64

+ func (m *FsServerDefaultsProto) GetBytesPerChecksum() uint32

+ func (m *FsServerDefaultsProto) GetChecksumType() ChecksumTypeProto

+ func (m *FsServerDefaultsProto) GetEncryptDataTransfer() bool

+ func (m *FsServerDefaultsProto) GetFileBufferSize() uint32

+ func (m *FsServerDefaultsProto) GetReplication() uint32

+ func (m *FsServerDefaultsProto) GetTrashInterval() uint64

+ func (m *FsServerDefaultsProto) GetWritePacketSize() uint32

+ func (m *FsServerDefaultsProto) Reset()

+ func (m *FsServerDefaultsProto) String() string

+ type FsyncRequestProto struct

+ Client *string

+ LastBlockLength *int64

+ Src *string

+ XXX_unrecognized []byte

+ func (*FsyncRequestProto) ProtoMessage()

+ func (m *FsyncRequestProto) GetClient() string

+ func (m *FsyncRequestProto) GetLastBlockLength() int64

+ func (m *FsyncRequestProto) GetSrc() string

+ func (m *FsyncRequestProto) Reset()

+ func (m *FsyncRequestProto) String() string

+ type FsyncResponseProto struct

+ XXX_unrecognized []byte

+ func (*FsyncResponseProto) ProtoMessage()

+ func (m *FsyncResponseProto) Reset()

+ func (m *FsyncResponseProto) String() string

+ type GetAdditionalDatanodeRequestProto struct

+ Blk *ExtendedBlockProto

+ ClientName *string

+ Excludes []*DatanodeInfoProto

+ Existings []*DatanodeInfoProto

+ NumAdditionalNodes *uint32

+ Src *string

+ XXX_unrecognized []byte

+ func (*GetAdditionalDatanodeRequestProto) ProtoMessage()

+ func (m *GetAdditionalDatanodeRequestProto) GetBlk() *ExtendedBlockProto

+ func (m *GetAdditionalDatanodeRequestProto) GetClientName() string

+ func (m *GetAdditionalDatanodeRequestProto) GetExcludes() []*DatanodeInfoProto

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

+ func (m *GetAdditionalDatanodeRequestProto) GetNumAdditionalNodes() uint32

+ func (m *GetAdditionalDatanodeRequestProto) GetSrc() string

+ func (m *GetAdditionalDatanodeRequestProto) Reset()

+ func (m *GetAdditionalDatanodeRequestProto) String() string

+ type GetAdditionalDatanodeResponseProto struct

+ Block *LocatedBlockProto

+ XXX_unrecognized []byte

+ func (*GetAdditionalDatanodeResponseProto) ProtoMessage()

+ func (m *GetAdditionalDatanodeResponseProto) GetBlock() *LocatedBlockProto

+ func (m *GetAdditionalDatanodeResponseProto) Reset()

+ func (m *GetAdditionalDatanodeResponseProto) String() string

+ type GetBlockLocationsRequestProto struct

+ Length *uint64

+ Offset *uint64

+ Src *string

+ XXX_unrecognized []byte

+ func (*GetBlockLocationsRequestProto) ProtoMessage()

+ func (m *GetBlockLocationsRequestProto) GetLength() uint64

+ func (m *GetBlockLocationsRequestProto) GetOffset() uint64

+ func (m *GetBlockLocationsRequestProto) GetSrc() string

+ func (m *GetBlockLocationsRequestProto) Reset()

+ func (m *GetBlockLocationsRequestProto) String() string

+ type GetBlockLocationsResponseProto struct

+ Locations *LocatedBlocksProto

+ XXX_unrecognized []byte

+ func (*GetBlockLocationsResponseProto) ProtoMessage()

+ func (m *GetBlockLocationsResponseProto) GetLocations() *LocatedBlocksProto

+ func (m *GetBlockLocationsResponseProto) Reset()

+ func (m *GetBlockLocationsResponseProto) String() string

+ type GetContentSummaryRequestProto struct

+ Path *string

+ XXX_unrecognized []byte

+ func (*GetContentSummaryRequestProto) ProtoMessage()

+ func (m *GetContentSummaryRequestProto) GetPath() string

+ func (m *GetContentSummaryRequestProto) Reset()

+ func (m *GetContentSummaryRequestProto) String() string

+ type GetContentSummaryResponseProto struct

+ Summary *ContentSummaryProto

+ XXX_unrecognized []byte

+ func (*GetContentSummaryResponseProto) ProtoMessage()

+ func (m *GetContentSummaryResponseProto) GetSummary() *ContentSummaryProto

+ func (m *GetContentSummaryResponseProto) Reset()

+ func (m *GetContentSummaryResponseProto) String() string

+ type GetDataEncryptionKeyRequestProto struct

+ XXX_unrecognized []byte

+ func (*GetDataEncryptionKeyRequestProto) ProtoMessage()

+ func (m *GetDataEncryptionKeyRequestProto) Reset()

+ func (m *GetDataEncryptionKeyRequestProto) String() string

+ type GetDataEncryptionKeyResponseProto struct

+ DataEncryptionKey *DataEncryptionKeyProto

+ XXX_unrecognized []byte

+ func (*GetDataEncryptionKeyResponseProto) ProtoMessage()

+ func (m *GetDataEncryptionKeyResponseProto) GetDataEncryptionKey() *DataEncryptionKeyProto

+ func (m *GetDataEncryptionKeyResponseProto) Reset()

+ func (m *GetDataEncryptionKeyResponseProto) String() string

+ type GetDatanodeReportRequestProto struct

+ Type *DatanodeReportTypeProto

+ XXX_unrecognized []byte

+ func (*GetDatanodeReportRequestProto) ProtoMessage()

+ func (m *GetDatanodeReportRequestProto) GetType() DatanodeReportTypeProto

+ func (m *GetDatanodeReportRequestProto) Reset()

+ func (m *GetDatanodeReportRequestProto) String() string

+ type GetDatanodeReportResponseProto struct

+ Di []*DatanodeInfoProto

+ XXX_unrecognized []byte

+ func (*GetDatanodeReportResponseProto) ProtoMessage()

+ func (m *GetDatanodeReportResponseProto) GetDi() []*DatanodeInfoProto

+ func (m *GetDatanodeReportResponseProto) Reset()

+ func (m *GetDatanodeReportResponseProto) String() string

+ type GetFileInfoRequestProto struct

+ Src *string

+ XXX_unrecognized []byte

+ func (*GetFileInfoRequestProto) ProtoMessage()

+ func (m *GetFileInfoRequestProto) GetSrc() string

+ func (m *GetFileInfoRequestProto) Reset()

+ func (m *GetFileInfoRequestProto) String() string

+ type GetFileInfoResponseProto struct

+ Fs *HdfsFileStatusProto

+ XXX_unrecognized []byte

+ func (*GetFileInfoResponseProto) ProtoMessage()

+ func (m *GetFileInfoResponseProto) GetFs() *HdfsFileStatusProto

+ func (m *GetFileInfoResponseProto) Reset()

+ func (m *GetFileInfoResponseProto) String() string

+ type GetFileLinkInfoRequestProto struct

+ Src *string

+ XXX_unrecognized []byte

+ func (*GetFileLinkInfoRequestProto) ProtoMessage()

+ func (m *GetFileLinkInfoRequestProto) GetSrc() string

+ func (m *GetFileLinkInfoRequestProto) Reset()

+ func (m *GetFileLinkInfoRequestProto) String() string

+ type GetFileLinkInfoResponseProto struct

+ Fs *HdfsFileStatusProto

+ XXX_unrecognized []byte

+ func (*GetFileLinkInfoResponseProto) ProtoMessage()

+ func (m *GetFileLinkInfoResponseProto) GetFs() *HdfsFileStatusProto

+ func (m *GetFileLinkInfoResponseProto) Reset()

+ func (m *GetFileLinkInfoResponseProto) String() string

+ type GetFsStatsResponseProto struct

+ Capacity *uint64

+ CorruptBlocks *uint64

+ MissingBlocks *uint64

+ Remaining *uint64

+ UnderReplicated *uint64

+ Used *uint64

+ XXX_unrecognized []byte

+ func (*GetFsStatsResponseProto) ProtoMessage()

+ func (m *GetFsStatsResponseProto) GetCapacity() uint64

+ func (m *GetFsStatsResponseProto) GetCorruptBlocks() uint64

+ func (m *GetFsStatsResponseProto) GetMissingBlocks() uint64

+ func (m *GetFsStatsResponseProto) GetRemaining() uint64

+ func (m *GetFsStatsResponseProto) GetUnderReplicated() uint64

+ func (m *GetFsStatsResponseProto) GetUsed() uint64

+ func (m *GetFsStatsResponseProto) Reset()

+ func (m *GetFsStatsResponseProto) String() string

+ type GetFsStatusRequestProto struct

+ XXX_unrecognized []byte

+ func (*GetFsStatusRequestProto) ProtoMessage()

+ func (m *GetFsStatusRequestProto) Reset()

+ func (m *GetFsStatusRequestProto) String() string

+ type GetLinkTargetRequestProto struct

+ Path *string

+ XXX_unrecognized []byte

+ func (*GetLinkTargetRequestProto) ProtoMessage()

+ func (m *GetLinkTargetRequestProto) GetPath() string

+ func (m *GetLinkTargetRequestProto) Reset()

+ func (m *GetLinkTargetRequestProto) String() string

+ type GetLinkTargetResponseProto struct

+ TargetPath *string

+ XXX_unrecognized []byte

+ func (*GetLinkTargetResponseProto) ProtoMessage()

+ func (m *GetLinkTargetResponseProto) GetTargetPath() string

+ func (m *GetLinkTargetResponseProto) Reset()

+ func (m *GetLinkTargetResponseProto) String() string

+ type GetListingRequestProto struct

+ NeedLocation *bool

+ Src *string

+ StartAfter []byte

+ XXX_unrecognized []byte

+ func (*GetListingRequestProto) ProtoMessage()

+ func (m *GetListingRequestProto) GetNeedLocation() bool

+ func (m *GetListingRequestProto) GetSrc() string

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

+ func (m *GetListingRequestProto) Reset()

+ func (m *GetListingRequestProto) String() string

+ type GetListingResponseProto struct

+ DirList *DirectoryListingProto

+ XXX_unrecognized []byte

+ func (*GetListingResponseProto) ProtoMessage()

+ func (m *GetListingResponseProto) GetDirList() *DirectoryListingProto

+ func (m *GetListingResponseProto) Reset()

+ func (m *GetListingResponseProto) String() string

+ type GetPreferredBlockSizeRequestProto struct

+ Filename *string

+ XXX_unrecognized []byte

+ func (*GetPreferredBlockSizeRequestProto) ProtoMessage()

+ func (m *GetPreferredBlockSizeRequestProto) GetFilename() string

+ func (m *GetPreferredBlockSizeRequestProto) Reset()

+ func (m *GetPreferredBlockSizeRequestProto) String() string

+ type GetPreferredBlockSizeResponseProto struct

+ Bsize *uint64

+ XXX_unrecognized []byte

+ func (*GetPreferredBlockSizeResponseProto) ProtoMessage()

+ func (m *GetPreferredBlockSizeResponseProto) GetBsize() uint64

+ func (m *GetPreferredBlockSizeResponseProto) Reset()

+ func (m *GetPreferredBlockSizeResponseProto) String() string

+ type GetServerDefaultsRequestProto struct

+ XXX_unrecognized []byte

+ func (*GetServerDefaultsRequestProto) ProtoMessage()

+ func (m *GetServerDefaultsRequestProto) Reset()

+ func (m *GetServerDefaultsRequestProto) String() string

+ type GetServerDefaultsResponseProto struct

+ ServerDefaults *FsServerDefaultsProto

+ XXX_unrecognized []byte

+ func (*GetServerDefaultsResponseProto) ProtoMessage()

+ func (m *GetServerDefaultsResponseProto) GetServerDefaults() *FsServerDefaultsProto

+ func (m *GetServerDefaultsResponseProto) Reset()

+ func (m *GetServerDefaultsResponseProto) String() string

+ type GetSnapshotDiffReportRequestProto struct

+ FromSnapshot *string

+ SnapshotRoot *string

+ ToSnapshot *string

+ XXX_unrecognized []byte

+ func (*GetSnapshotDiffReportRequestProto) ProtoMessage()

+ func (m *GetSnapshotDiffReportRequestProto) GetFromSnapshot() string

+ func (m *GetSnapshotDiffReportRequestProto) GetSnapshotRoot() string

+ func (m *GetSnapshotDiffReportRequestProto) GetToSnapshot() string

+ func (m *GetSnapshotDiffReportRequestProto) Reset()

+ func (m *GetSnapshotDiffReportRequestProto) String() string

+ type GetSnapshotDiffReportResponseProto struct

+ DiffReport *SnapshotDiffReportProto

+ XXX_unrecognized []byte

+ func (*GetSnapshotDiffReportResponseProto) ProtoMessage()

+ func (m *GetSnapshotDiffReportResponseProto) GetDiffReport() *SnapshotDiffReportProto

+ func (m *GetSnapshotDiffReportResponseProto) Reset()

+ func (m *GetSnapshotDiffReportResponseProto) String() string

+ type GetSnapshottableDirListingRequestProto struct

+ XXX_unrecognized []byte

+ func (*GetSnapshottableDirListingRequestProto) ProtoMessage()

+ func (m *GetSnapshottableDirListingRequestProto) Reset()

+ func (m *GetSnapshottableDirListingRequestProto) String() string

+ type GetSnapshottableDirListingResponseProto struct

+ SnapshottableDirList *SnapshottableDirectoryListingProto

+ XXX_unrecognized []byte

+ func (*GetSnapshottableDirListingResponseProto) ProtoMessage()

+ func (m *GetSnapshottableDirListingResponseProto) GetSnapshottableDirList() *SnapshottableDirectoryListingProto

+ func (m *GetSnapshottableDirListingResponseProto) Reset()

+ func (m *GetSnapshottableDirListingResponseProto) String() string

+ type HdfsFileStatusProto struct

+ AccessTime *uint64

+ BlockReplication *uint32

+ Blocksize *uint64

+ ChildrenNum *int32

+ FileId *uint64

+ FileType *HdfsFileStatusProto_FileType

+ Group *string

+ Length *uint64

+ Locations *LocatedBlocksProto

+ ModificationTime *uint64

+ Owner *string

+ Path []byte

+ Permission *FsPermissionProto

+ Symlink []byte

+ XXX_unrecognized []byte

+ func (*HdfsFileStatusProto) ProtoMessage()

+ func (m *HdfsFileStatusProto) GetAccessTime() uint64

+ func (m *HdfsFileStatusProto) GetBlockReplication() uint32

+ func (m *HdfsFileStatusProto) GetBlocksize() uint64

+ func (m *HdfsFileStatusProto) GetChildrenNum() int32

+ func (m *HdfsFileStatusProto) GetFileId() uint64

+ func (m *HdfsFileStatusProto) GetFileType() HdfsFileStatusProto_FileType

+ func (m *HdfsFileStatusProto) GetGroup() string

+ func (m *HdfsFileStatusProto) GetLength() uint64

+ func (m *HdfsFileStatusProto) GetLocations() *LocatedBlocksProto

+ func (m *HdfsFileStatusProto) GetModificationTime() uint64

+ func (m *HdfsFileStatusProto) GetOwner() string

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

+ func (m *HdfsFileStatusProto) GetPermission() *FsPermissionProto

+ func (m *HdfsFileStatusProto) GetSymlink() []byte

+ func (m *HdfsFileStatusProto) Reset()

+ func (m *HdfsFileStatusProto) String() string

+ type HdfsFileStatusProto_FileType int32

+ const HdfsFileStatusProto_IS_DIR

+ const HdfsFileStatusProto_IS_FILE

+ const HdfsFileStatusProto_IS_SYMLINK

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

+ func (x HdfsFileStatusProto_FileType) Enum() *HdfsFileStatusProto_FileType

+ func (x HdfsFileStatusProto_FileType) String() string

+ type IsFileClosedRequestProto struct

+ Src *string

+ XXX_unrecognized []byte

+ func (*IsFileClosedRequestProto) ProtoMessage()

+ func (m *IsFileClosedRequestProto) GetSrc() string

+ func (m *IsFileClosedRequestProto) Reset()

+ func (m *IsFileClosedRequestProto) String() string

+ type IsFileClosedResponseProto struct

+ Result *bool

+ XXX_unrecognized []byte

+ func (*IsFileClosedResponseProto) ProtoMessage()

+ func (m *IsFileClosedResponseProto) GetResult() bool

+ func (m *IsFileClosedResponseProto) Reset()

+ func (m *IsFileClosedResponseProto) String() string

+ type ListCorruptFileBlocksRequestProto struct

+ Cookie *string

+ Path *string

+ XXX_unrecognized []byte

+ func (*ListCorruptFileBlocksRequestProto) ProtoMessage()

+ func (m *ListCorruptFileBlocksRequestProto) GetCookie() string

+ func (m *ListCorruptFileBlocksRequestProto) GetPath() string

+ func (m *ListCorruptFileBlocksRequestProto) Reset()

+ func (m *ListCorruptFileBlocksRequestProto) String() string

+ type ListCorruptFileBlocksResponseProto struct

+ Corrupt *CorruptFileBlocksProto

+ XXX_unrecognized []byte

+ func (*ListCorruptFileBlocksResponseProto) ProtoMessage()

+ func (m *ListCorruptFileBlocksResponseProto) GetCorrupt() *CorruptFileBlocksProto

+ func (m *ListCorruptFileBlocksResponseProto) Reset()

+ func (m *ListCorruptFileBlocksResponseProto) String() string

+ type LocatedBlockProto struct

+ B *ExtendedBlockProto

+ BlockToken *hadoop_common.TokenProto

+ Corrupt *bool

+ Locs []*DatanodeInfoProto

+ Offset *uint64

+ XXX_unrecognized []byte

+ func (*LocatedBlockProto) ProtoMessage()

+ func (m *LocatedBlockProto) GetB() *ExtendedBlockProto

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

+ func (m *LocatedBlockProto) GetCorrupt() bool

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

+ func (m *LocatedBlockProto) GetOffset() uint64

+ func (m *LocatedBlockProto) Reset()

+ func (m *LocatedBlockProto) String() string

+ type LocatedBlocksProto struct

+ Blocks []*LocatedBlockProto

+ FileLength *uint64

+ IsLastBlockComplete *bool

+ LastBlock *LocatedBlockProto

+ UnderConstruction *bool

+ XXX_unrecognized []byte

+ func (*LocatedBlocksProto) ProtoMessage()

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

+ func (m *LocatedBlocksProto) GetFileLength() uint64

+ func (m *LocatedBlocksProto) GetIsLastBlockComplete() bool

+ func (m *LocatedBlocksProto) GetLastBlock() *LocatedBlockProto

+ func (m *LocatedBlocksProto) GetUnderConstruction() bool

+ func (m *LocatedBlocksProto) Reset()

+ func (m *LocatedBlocksProto) String() string

+ type MetaSaveRequestProto struct

+ Filename *string

+ XXX_unrecognized []byte

+ func (*MetaSaveRequestProto) ProtoMessage()

+ func (m *MetaSaveRequestProto) GetFilename() string

+ func (m *MetaSaveRequestProto) Reset()

+ func (m *MetaSaveRequestProto) String() string

+ type MetaSaveResponseProto struct

+ XXX_unrecognized []byte

+ func (*MetaSaveResponseProto) ProtoMessage()

+ func (m *MetaSaveResponseProto) Reset()

+ func (m *MetaSaveResponseProto) String() string

+ type MkdirsRequestProto struct

+ CreateParent *bool

+ Masked *FsPermissionProto

+ Src *string

+ XXX_unrecognized []byte

+ func (*MkdirsRequestProto) ProtoMessage()

+ func (m *MkdirsRequestProto) GetCreateParent() bool

+ func (m *MkdirsRequestProto) GetMasked() *FsPermissionProto

+ func (m *MkdirsRequestProto) GetSrc() string

+ func (m *MkdirsRequestProto) Reset()

+ func (m *MkdirsRequestProto) String() string

+ type MkdirsResponseProto struct

+ Result *bool

+ XXX_unrecognized []byte

+ func (*MkdirsResponseProto) ProtoMessage()

+ func (m *MkdirsResponseProto) GetResult() bool

+ func (m *MkdirsResponseProto) Reset()

+ func (m *MkdirsResponseProto) String() string

+ type NamenodeCommandProto struct

+ Action *uint32

+ CheckpointCmd *CheckpointCommandProto

+ Type *NamenodeCommandProto_Type

+ XXX_unrecognized []byte

+ func (*NamenodeCommandProto) ProtoMessage()

+ func (m *NamenodeCommandProto) GetAction() uint32

+ func (m *NamenodeCommandProto) GetCheckpointCmd() *CheckpointCommandProto

+ func (m *NamenodeCommandProto) GetType() NamenodeCommandProto_Type

+ func (m *NamenodeCommandProto) Reset()

+ func (m *NamenodeCommandProto) String() string

+ type NamenodeCommandProto_Type int32

+ const NamenodeCommandProto_CheckPointCommand

+ const NamenodeCommandProto_NamenodeCommand

+ func (x *NamenodeCommandProto_Type) UnmarshalJSON(data []byte) error

+ func (x NamenodeCommandProto_Type) Enum() *NamenodeCommandProto_Type

+ func (x NamenodeCommandProto_Type) String() string

+ type NamenodeRegistrationProto struct

+ HttpAddress *string

+ Role *NamenodeRegistrationProto_NamenodeRoleProto

+ RpcAddress *string

+ StorageInfo *StorageInfoProto

+ XXX_unrecognized []byte

+ func (*NamenodeRegistrationProto) ProtoMessage()

+ func (m *NamenodeRegistrationProto) GetHttpAddress() string

+ func (m *NamenodeRegistrationProto) GetRole() NamenodeRegistrationProto_NamenodeRoleProto

+ func (m *NamenodeRegistrationProto) GetRpcAddress() string

+ func (m *NamenodeRegistrationProto) GetStorageInfo() *StorageInfoProto

+ func (m *NamenodeRegistrationProto) Reset()

+ func (m *NamenodeRegistrationProto) String() string

+ type NamenodeRegistrationProto_NamenodeRoleProto int32

+ const Default_NamenodeRegistrationProto_Role

+ const NamenodeRegistrationProto_BACKUP

+ const NamenodeRegistrationProto_CHECKPOINT

+ const NamenodeRegistrationProto_NAMENODE

+ func (x *NamenodeRegistrationProto_NamenodeRoleProto) UnmarshalJSON(data []byte) error

+ func (x NamenodeRegistrationProto_NamenodeRoleProto) Enum() *NamenodeRegistrationProto_NamenodeRoleProto

+ func (x NamenodeRegistrationProto_NamenodeRoleProto) String() string

+ type NamespaceInfoProto struct

+ BlockPoolID *string

+ BuildVersion *string

+ SoftwareVersion *string

+ StorageInfo *StorageInfoProto

+ Unused *uint32

+ XXX_unrecognized []byte

+ func (*NamespaceInfoProto) ProtoMessage()

+ func (m *NamespaceInfoProto) GetBlockPoolID() string

+ func (m *NamespaceInfoProto) GetBuildVersion() string

+ func (m *NamespaceInfoProto) GetSoftwareVersion() string

+ func (m *NamespaceInfoProto) GetStorageInfo() *StorageInfoProto

+ func (m *NamespaceInfoProto) GetUnused() uint32

+ func (m *NamespaceInfoProto) Reset()

+ func (m *NamespaceInfoProto) String() string

+ type OpBlockChecksumProto struct

+ Header *BaseHeaderProto

+ XXX_unrecognized []byte

+ func (*OpBlockChecksumProto) ProtoMessage()

+ func (m *OpBlockChecksumProto) GetHeader() *BaseHeaderProto

+ func (m *OpBlockChecksumProto) Reset()

+ func (m *OpBlockChecksumProto) String() string

+ type OpBlockChecksumResponseProto struct

+ BytesPerCrc *uint32

+ CrcPerBlock *uint64

+ CrcType *ChecksumTypeProto

+ Md5 []byte

+ XXX_unrecognized []byte

+ func (*OpBlockChecksumResponseProto) ProtoMessage()

+ func (m *OpBlockChecksumResponseProto) GetBytesPerCrc() uint32

+ func (m *OpBlockChecksumResponseProto) GetCrcPerBlock() uint64

+ func (m *OpBlockChecksumResponseProto) GetCrcType() ChecksumTypeProto

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

+ func (m *OpBlockChecksumResponseProto) Reset()

+ func (m *OpBlockChecksumResponseProto) String() string

+ type OpCopyBlockProto struct

+ Header *BaseHeaderProto

+ XXX_unrecognized []byte

+ func (*OpCopyBlockProto) ProtoMessage()

+ func (m *OpCopyBlockProto) GetHeader() *BaseHeaderProto

+ func (m *OpCopyBlockProto) Reset()

+ func (m *OpCopyBlockProto) String() string

+ type OpReadBlockProto struct

+ CachingStrategy *CachingStrategyProto

+ Header *ClientOperationHeaderProto

+ Len *uint64

+ Offset *uint64

+ SendChecksums *bool

+ XXX_unrecognized []byte

+ func (*OpReadBlockProto) ProtoMessage()

+ func (m *OpReadBlockProto) GetCachingStrategy() *CachingStrategyProto

+ func (m *OpReadBlockProto) GetHeader() *ClientOperationHeaderProto

+ func (m *OpReadBlockProto) GetLen() uint64

+ func (m *OpReadBlockProto) GetOffset() uint64

+ func (m *OpReadBlockProto) GetSendChecksums() bool

+ func (m *OpReadBlockProto) Reset()

+ func (m *OpReadBlockProto) String() string

+ type OpReplaceBlockProto struct

+ DelHint *string

+ Header *BaseHeaderProto

+ Source *DatanodeInfoProto

+ XXX_unrecognized []byte

+ func (*OpReplaceBlockProto) ProtoMessage()

+ func (m *OpReplaceBlockProto) GetDelHint() string

+ func (m *OpReplaceBlockProto) GetHeader() *BaseHeaderProto

+ func (m *OpReplaceBlockProto) GetSource() *DatanodeInfoProto

+ func (m *OpReplaceBlockProto) Reset()

+ func (m *OpReplaceBlockProto) String() string

+ type OpRequestShortCircuitAccessProto struct

+ Header *BaseHeaderProto

+ MaxVersion *uint32

+ XXX_unrecognized []byte

+ func (*OpRequestShortCircuitAccessProto) ProtoMessage()

+ func (m *OpRequestShortCircuitAccessProto) GetHeader() *BaseHeaderProto

+ func (m *OpRequestShortCircuitAccessProto) GetMaxVersion() uint32

+ func (m *OpRequestShortCircuitAccessProto) Reset()

+ func (m *OpRequestShortCircuitAccessProto) String() string

+ type OpTransferBlockProto struct

+ Header *ClientOperationHeaderProto

+ Targets []*DatanodeInfoProto

+ XXX_unrecognized []byte

+ func (*OpTransferBlockProto) ProtoMessage()

+ func (m *OpTransferBlockProto) GetHeader() *ClientOperationHeaderProto

+ func (m *OpTransferBlockProto) GetTargets() []*DatanodeInfoProto

+ func (m *OpTransferBlockProto) Reset()

+ func (m *OpTransferBlockProto) String() string

+ type OpWriteBlockProto struct

+ CachingStrategy *CachingStrategyProto

+ Header *ClientOperationHeaderProto

+ LatestGenerationStamp *uint64

+ MaxBytesRcvd *uint64

+ MinBytesRcvd *uint64

+ PipelineSize *uint32

+ RequestedChecksum *ChecksumProto

+ Source *DatanodeInfoProto

+ Stage *OpWriteBlockProto_BlockConstructionStage

+ Targets []*DatanodeInfoProto

+ XXX_unrecognized []byte

+ func (*OpWriteBlockProto) ProtoMessage()

+ func (m *OpWriteBlockProto) GetCachingStrategy() *CachingStrategyProto

+ func (m *OpWriteBlockProto) GetHeader() *ClientOperationHeaderProto

+ func (m *OpWriteBlockProto) GetLatestGenerationStamp() uint64

+ func (m *OpWriteBlockProto) GetMaxBytesRcvd() uint64

+ func (m *OpWriteBlockProto) GetMinBytesRcvd() uint64

+ func (m *OpWriteBlockProto) GetPipelineSize() uint32

+ func (m *OpWriteBlockProto) GetRequestedChecksum() *ChecksumProto

+ func (m *OpWriteBlockProto) GetSource() *DatanodeInfoProto

+ func (m *OpWriteBlockProto) GetStage() OpWriteBlockProto_BlockConstructionStage

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

+ func (m *OpWriteBlockProto) Reset()

+ func (m *OpWriteBlockProto) String() string

+ type OpWriteBlockProto_BlockConstructionStage int32

+ const OpWriteBlockProto_DATA_STREAMING

+ const OpWriteBlockProto_PIPELINE_CLOSE

+ const OpWriteBlockProto_PIPELINE_CLOSE_RECOVERY

+ const OpWriteBlockProto_PIPELINE_SETUP_APPEND

+ const OpWriteBlockProto_PIPELINE_SETUP_APPEND_RECOVERY

+ const OpWriteBlockProto_PIPELINE_SETUP_CREATE

+ const OpWriteBlockProto_PIPELINE_SETUP_STREAMING_RECOVERY

+ const OpWriteBlockProto_TRANSFER_FINALIZED

+ const OpWriteBlockProto_TRANSFER_RBW

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

+ func (x OpWriteBlockProto_BlockConstructionStage) Enum() *OpWriteBlockProto_BlockConstructionStage

+ func (x OpWriteBlockProto_BlockConstructionStage) String() string

+ type PacketHeaderProto struct

+ DataLen *int32

+ LastPacketInBlock *bool

+ OffsetInBlock *int64

+ Seqno *int64

+ SyncBlock *bool

+ XXX_unrecognized []byte

+ func (*PacketHeaderProto) ProtoMessage()

+ func (m *PacketHeaderProto) GetDataLen() int32

+ func (m *PacketHeaderProto) GetLastPacketInBlock() bool

+ func (m *PacketHeaderProto) GetOffsetInBlock() int64

+ func (m *PacketHeaderProto) GetSeqno() int64

+ func (m *PacketHeaderProto) GetSyncBlock() bool

+ func (m *PacketHeaderProto) Reset()

+ func (m *PacketHeaderProto) String() string

+ type PipelineAckProto struct

+ DownstreamAckTimeNanos *uint64

+ Seqno *int64

+ Status []Status

+ XXX_unrecognized []byte

+ func (*PipelineAckProto) ProtoMessage()

+ func (m *PipelineAckProto) GetDownstreamAckTimeNanos() uint64

+ func (m *PipelineAckProto) GetSeqno() int64

+ func (m *PipelineAckProto) GetStatus() []Status

+ func (m *PipelineAckProto) Reset()

+ func (m *PipelineAckProto) String() string

+ type ReadOpChecksumInfoProto struct

+ Checksum *ChecksumProto

+ ChunkOffset *uint64

+ XXX_unrecognized []byte

+ func (*ReadOpChecksumInfoProto) ProtoMessage()

+ func (m *ReadOpChecksumInfoProto) GetChecksum() *ChecksumProto

+ func (m *ReadOpChecksumInfoProto) GetChunkOffset() uint64

+ func (m *ReadOpChecksumInfoProto) Reset()

+ func (m *ReadOpChecksumInfoProto) String() string

+ type RecoverLeaseRequestProto struct

+ ClientName *string

+ Src *string

+ XXX_unrecognized []byte

+ func (*RecoverLeaseRequestProto) ProtoMessage()

+ func (m *RecoverLeaseRequestProto) GetClientName() string

+ func (m *RecoverLeaseRequestProto) GetSrc() string

+ func (m *RecoverLeaseRequestProto) Reset()

+ func (m *RecoverLeaseRequestProto) String() string

+ type RecoverLeaseResponseProto struct

+ Result *bool

+ XXX_unrecognized []byte

+ func (*RecoverLeaseResponseProto) ProtoMessage()

+ func (m *RecoverLeaseResponseProto) GetResult() bool

+ func (m *RecoverLeaseResponseProto) Reset()

+ func (m *RecoverLeaseResponseProto) String() string

+ type RecoveringBlockProto struct

+ Block *LocatedBlockProto

+ NewGenStamp *uint64

+ XXX_unrecognized []byte

+ func (*RecoveringBlockProto) ProtoMessage()

+ func (m *RecoveringBlockProto) GetBlock() *LocatedBlockProto

+ func (m *RecoveringBlockProto) GetNewGenStamp() uint64

+ func (m *RecoveringBlockProto) Reset()

+ func (m *RecoveringBlockProto) String() string

+ type RefreshNodesRequestProto struct

+ XXX_unrecognized []byte

+ func (*RefreshNodesRequestProto) ProtoMessage()

+ func (m *RefreshNodesRequestProto) Reset()

+ func (m *RefreshNodesRequestProto) String() string

+ type RefreshNodesResponseProto struct

+ XXX_unrecognized []byte

+ func (*RefreshNodesResponseProto) ProtoMessage()

+ func (m *RefreshNodesResponseProto) Reset()

+ func (m *RefreshNodesResponseProto) String() string

+ type RemoteEditLogManifestProto struct

+ Logs []*RemoteEditLogProto

+ XXX_unrecognized []byte

+ func (*RemoteEditLogManifestProto) ProtoMessage()

+ func (m *RemoteEditLogManifestProto) GetLogs() []*RemoteEditLogProto

+ func (m *RemoteEditLogManifestProto) Reset()

+ func (m *RemoteEditLogManifestProto) String() string

+ type RemoteEditLogProto struct

+ EndTxId *uint64

+ IsInProgress *bool

+ StartTxId *uint64

+ XXX_unrecognized []byte

+ func (*RemoteEditLogProto) ProtoMessage()

+ func (m *RemoteEditLogProto) GetEndTxId() uint64

+ func (m *RemoteEditLogProto) GetIsInProgress() bool

+ func (m *RemoteEditLogProto) GetStartTxId() uint64

+ func (m *RemoteEditLogProto) Reset()

+ func (m *RemoteEditLogProto) String() string

+ type Rename2RequestProto struct

+ Dst *string

+ OverwriteDest *bool

+ Src *string

+ XXX_unrecognized []byte

+ func (*Rename2RequestProto) ProtoMessage()

+ func (m *Rename2RequestProto) GetDst() string

+ func (m *Rename2RequestProto) GetOverwriteDest() bool

+ func (m *Rename2RequestProto) GetSrc() string

+ func (m *Rename2RequestProto) Reset()

+ func (m *Rename2RequestProto) String() string

+ type Rename2ResponseProto struct

+ XXX_unrecognized []byte

+ func (*Rename2ResponseProto) ProtoMessage()

+ func (m *Rename2ResponseProto) Reset()

+ func (m *Rename2ResponseProto) String() string

+ type RenameRequestProto struct

+ Dst *string

+ Src *string

+ XXX_unrecognized []byte

+ func (*RenameRequestProto) ProtoMessage()

+ func (m *RenameRequestProto) GetDst() string

+ func (m *RenameRequestProto) GetSrc() string

+ func (m *RenameRequestProto) Reset()

+ func (m *RenameRequestProto) String() string

+ type RenameResponseProto struct

+ Result *bool

+ XXX_unrecognized []byte

+ func (*RenameResponseProto) ProtoMessage()

+ func (m *RenameResponseProto) GetResult() bool

+ func (m *RenameResponseProto) Reset()

+ func (m *RenameResponseProto) String() string

+ type RenameSnapshotRequestProto struct

+ SnapshotNewName *string

+ SnapshotOldName *string

+ SnapshotRoot *string

+ XXX_unrecognized []byte

+ func (*RenameSnapshotRequestProto) ProtoMessage()

+ func (m *RenameSnapshotRequestProto) GetSnapshotNewName() string

+ func (m *RenameSnapshotRequestProto) GetSnapshotOldName() string

+ func (m *RenameSnapshotRequestProto) GetSnapshotRoot() string

+ func (m *RenameSnapshotRequestProto) Reset()

+ func (m *RenameSnapshotRequestProto) String() string

+ type RenameSnapshotResponseProto struct

+ XXX_unrecognized []byte

+ func (*RenameSnapshotResponseProto) ProtoMessage()

+ func (m *RenameSnapshotResponseProto) Reset()

+ func (m *RenameSnapshotResponseProto) String() string

+ type RenewLeaseRequestProto struct

+ ClientName *string

+ XXX_unrecognized []byte

+ func (*RenewLeaseRequestProto) ProtoMessage()

+ func (m *RenewLeaseRequestProto) GetClientName() string

+ func (m *RenewLeaseRequestProto) Reset()

+ func (m *RenewLeaseRequestProto) String() string

+ type RenewLeaseResponseProto struct

+ XXX_unrecognized []byte

+ func (*RenewLeaseResponseProto) ProtoMessage()

+ func (m *RenewLeaseResponseProto) Reset()

+ func (m *RenewLeaseResponseProto) String() string

+ type ReplicaStateProto int32

+ const ReplicaStateProto_FINALIZED

+ const ReplicaStateProto_RBW

+ const ReplicaStateProto_RUR

+ const ReplicaStateProto_RWR

+ const ReplicaStateProto_TEMPORARY

+ func (x *ReplicaStateProto) UnmarshalJSON(data []byte) error

+ func (x ReplicaStateProto) Enum() *ReplicaStateProto

+ func (x ReplicaStateProto) String() string

+ type ReportBadBlocksRequestProto struct

+ Blocks []*LocatedBlockProto

+ XXX_unrecognized []byte

+ func (*ReportBadBlocksRequestProto) ProtoMessage()

+ func (m *ReportBadBlocksRequestProto) GetBlocks() []*LocatedBlockProto

+ func (m *ReportBadBlocksRequestProto) Reset()

+ func (m *ReportBadBlocksRequestProto) String() string

+ type ReportBadBlocksResponseProto struct

+ XXX_unrecognized []byte

+ func (*ReportBadBlocksResponseProto) ProtoMessage()

+ func (m *ReportBadBlocksResponseProto) Reset()

+ func (m *ReportBadBlocksResponseProto) String() string

+ type RestoreFailedStorageRequestProto struct

+ Arg *string

+ XXX_unrecognized []byte

+ func (*RestoreFailedStorageRequestProto) ProtoMessage()

+ func (m *RestoreFailedStorageRequestProto) GetArg() string

+ func (m *RestoreFailedStorageRequestProto) Reset()

+ func (m *RestoreFailedStorageRequestProto) String() string

+ type RestoreFailedStorageResponseProto struct

+ Result *bool

+ XXX_unrecognized []byte

+ func (*RestoreFailedStorageResponseProto) ProtoMessage()

+ func (m *RestoreFailedStorageResponseProto) GetResult() bool

+ func (m *RestoreFailedStorageResponseProto) Reset()

+ func (m *RestoreFailedStorageResponseProto) String() string

+ type RollEditsRequestProto struct

+ XXX_unrecognized []byte

+ func (*RollEditsRequestProto) ProtoMessage()

+ func (m *RollEditsRequestProto) Reset()

+ func (m *RollEditsRequestProto) String() string

+ type RollEditsResponseProto struct

+ NewSegmentTxId *uint64

+ XXX_unrecognized []byte

+ func (*RollEditsResponseProto) ProtoMessage()

+ func (m *RollEditsResponseProto) GetNewSegmentTxId() uint64

+ func (m *RollEditsResponseProto) Reset()

+ func (m *RollEditsResponseProto) String() string

+ type SafeModeActionProto int32

+ const SafeModeActionProto_SAFEMODE_ENTER

+ const SafeModeActionProto_SAFEMODE_GET

+ const SafeModeActionProto_SAFEMODE_LEAVE

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

+ func (x SafeModeActionProto) Enum() *SafeModeActionProto

+ func (x SafeModeActionProto) String() string

+ type SaveNamespaceRequestProto struct

+ XXX_unrecognized []byte

+ func (*SaveNamespaceRequestProto) ProtoMessage()

+ func (m *SaveNamespaceRequestProto) Reset()

+ func (m *SaveNamespaceRequestProto) String() string

+ type SaveNamespaceResponseProto struct

+ XXX_unrecognized []byte

+ func (*SaveNamespaceResponseProto) ProtoMessage()

+ func (m *SaveNamespaceResponseProto) Reset()

+ func (m *SaveNamespaceResponseProto) String() string

+ type SetBalancerBandwidthRequestProto struct

+ Bandwidth *int64

+ XXX_unrecognized []byte

+ func (*SetBalancerBandwidthRequestProto) ProtoMessage()

+ func (m *SetBalancerBandwidthRequestProto) GetBandwidth() int64

+ func (m *SetBalancerBandwidthRequestProto) Reset()

+ func (m *SetBalancerBandwidthRequestProto) String() string

+ type SetBalancerBandwidthResponseProto struct

+ XXX_unrecognized []byte

+ func (*SetBalancerBandwidthResponseProto) ProtoMessage()

+ func (m *SetBalancerBandwidthResponseProto) Reset()

+ func (m *SetBalancerBandwidthResponseProto) String() string

+ type SetOwnerRequestProto struct

+ Groupname *string

+ Src *string

+ Username *string

+ XXX_unrecognized []byte

+ func (*SetOwnerRequestProto) ProtoMessage()

+ func (m *SetOwnerRequestProto) GetGroupname() string

+ func (m *SetOwnerRequestProto) GetSrc() string

+ func (m *SetOwnerRequestProto) GetUsername() string

+ func (m *SetOwnerRequestProto) Reset()

+ func (m *SetOwnerRequestProto) String() string

+ type SetOwnerResponseProto struct

+ XXX_unrecognized []byte

+ func (*SetOwnerResponseProto) ProtoMessage()

+ func (m *SetOwnerResponseProto) Reset()

+ func (m *SetOwnerResponseProto) String() string

+ type SetPermissionRequestProto struct

+ Permission *FsPermissionProto

+ Src *string

+ XXX_unrecognized []byte

+ func (*SetPermissionRequestProto) ProtoMessage()

+ func (m *SetPermissionRequestProto) GetPermission() *FsPermissionProto

+ func (m *SetPermissionRequestProto) GetSrc() string

+ func (m *SetPermissionRequestProto) Reset()

+ func (m *SetPermissionRequestProto) String() string

+ type SetPermissionResponseProto struct

+ XXX_unrecognized []byte

+ func (*SetPermissionResponseProto) ProtoMessage()

+ func (m *SetPermissionResponseProto) Reset()

+ func (m *SetPermissionResponseProto) String() string

+ type SetQuotaRequestProto struct

+ DiskspaceQuota *uint64

+ NamespaceQuota *uint64

+ Path *string

+ XXX_unrecognized []byte

+ func (*SetQuotaRequestProto) ProtoMessage()

+ func (m *SetQuotaRequestProto) GetDiskspaceQuota() uint64

+ func (m *SetQuotaRequestProto) GetNamespaceQuota() uint64

+ func (m *SetQuotaRequestProto) GetPath() string

+ func (m *SetQuotaRequestProto) Reset()

+ func (m *SetQuotaRequestProto) String() string

+ type SetQuotaResponseProto struct

+ XXX_unrecognized []byte

+ func (*SetQuotaResponseProto) ProtoMessage()

+ func (m *SetQuotaResponseProto) Reset()

+ func (m *SetQuotaResponseProto) String() string

+ type SetReplicationRequestProto struct

+ Replication *uint32

+ Src *string

+ XXX_unrecognized []byte

+ func (*SetReplicationRequestProto) ProtoMessage()

+ func (m *SetReplicationRequestProto) GetReplication() uint32

+ func (m *SetReplicationRequestProto) GetSrc() string

+ func (m *SetReplicationRequestProto) Reset()

+ func (m *SetReplicationRequestProto) String() string

+ type SetReplicationResponseProto struct

+ Result *bool

+ XXX_unrecognized []byte

+ func (*SetReplicationResponseProto) ProtoMessage()

+ func (m *SetReplicationResponseProto) GetResult() bool

+ func (m *SetReplicationResponseProto) Reset()

+ func (m *SetReplicationResponseProto) String() string

+ type SetSafeModeRequestProto struct

+ Action *SafeModeActionProto

+ Checked *bool

+ XXX_unrecognized []byte

+ func (*SetSafeModeRequestProto) ProtoMessage()

+ func (m *SetSafeModeRequestProto) GetAction() SafeModeActionProto

+ func (m *SetSafeModeRequestProto) GetChecked() bool

+ func (m *SetSafeModeRequestProto) Reset()

+ func (m *SetSafeModeRequestProto) String() string

+ type SetSafeModeResponseProto struct

+ Result *bool

+ XXX_unrecognized []byte

+ func (*SetSafeModeResponseProto) ProtoMessage()

+ func (m *SetSafeModeResponseProto) GetResult() bool

+ func (m *SetSafeModeResponseProto) Reset()

+ func (m *SetSafeModeResponseProto) String() string

+ type SetTimesRequestProto struct

+ Atime *uint64

+ Mtime *uint64

+ Src *string

+ XXX_unrecognized []byte

+ func (*SetTimesRequestProto) ProtoMessage()

+ func (m *SetTimesRequestProto) GetAtime() uint64

+ func (m *SetTimesRequestProto) GetMtime() uint64

+ func (m *SetTimesRequestProto) GetSrc() string

+ func (m *SetTimesRequestProto) Reset()

+ func (m *SetTimesRequestProto) String() string

+ type SetTimesResponseProto struct

+ XXX_unrecognized []byte

+ func (*SetTimesResponseProto) ProtoMessage()

+ func (m *SetTimesResponseProto) Reset()

+ func (m *SetTimesResponseProto) String() string

+ type SnapshotDiffReportEntryProto struct

+ Fullpath []byte

+ ModificationLabel *string

+ XXX_unrecognized []byte

+ func (*SnapshotDiffReportEntryProto) ProtoMessage()

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

+ func (m *SnapshotDiffReportEntryProto) GetModificationLabel() string

+ func (m *SnapshotDiffReportEntryProto) Reset()

+ func (m *SnapshotDiffReportEntryProto) String() string

+ type SnapshotDiffReportProto struct

+ DiffReportEntries []*SnapshotDiffReportEntryProto

+ FromSnapshot *string

+ SnapshotRoot *string

+ ToSnapshot *string

+ XXX_unrecognized []byte

+ func (*SnapshotDiffReportProto) ProtoMessage()

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

+ func (m *SnapshotDiffReportProto) GetFromSnapshot() string

+ func (m *SnapshotDiffReportProto) GetSnapshotRoot() string

+ func (m *SnapshotDiffReportProto) GetToSnapshot() string

+ func (m *SnapshotDiffReportProto) Reset()

+ func (m *SnapshotDiffReportProto) String() string

+ type SnapshotInfoProto struct

+ CreateTime *string

+ Group *string

+ Owner *string

+ Permission *FsPermissionProto

+ SnapshotName *string

+ SnapshotRoot *string

+ XXX_unrecognized []byte

+ func (*SnapshotInfoProto) ProtoMessage()

+ func (m *SnapshotInfoProto) GetCreateTime() string

+ func (m *SnapshotInfoProto) GetGroup() string

+ func (m *SnapshotInfoProto) GetOwner() string

+ func (m *SnapshotInfoProto) GetPermission() *FsPermissionProto

+ func (m *SnapshotInfoProto) GetSnapshotName() string

+ func (m *SnapshotInfoProto) GetSnapshotRoot() string

+ func (m *SnapshotInfoProto) Reset()

+ func (m *SnapshotInfoProto) String() string

+ type SnapshottableDirectoryListingProto struct

+ SnapshottableDirListing []*SnapshottableDirectoryStatusProto

+ XXX_unrecognized []byte

+ func (*SnapshottableDirectoryListingProto) ProtoMessage()

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

+ func (m *SnapshottableDirectoryListingProto) Reset()

+ func (m *SnapshottableDirectoryListingProto) String() string

+ type SnapshottableDirectoryStatusProto struct

+ DirStatus *HdfsFileStatusProto

+ ParentFullpath []byte

+ SnapshotNumber *uint32

+ SnapshotQuota *uint32

+ XXX_unrecognized []byte

+ func (*SnapshottableDirectoryStatusProto) ProtoMessage()

+ func (m *SnapshottableDirectoryStatusProto) GetDirStatus() *HdfsFileStatusProto

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

+ func (m *SnapshottableDirectoryStatusProto) GetSnapshotNumber() uint32

+ func (m *SnapshottableDirectoryStatusProto) GetSnapshotQuota() uint32

+ func (m *SnapshottableDirectoryStatusProto) Reset()

+ func (m *SnapshottableDirectoryStatusProto) String() string

+ type Status int32

+ const Status_CHECKSUM_OK

+ const Status_ERROR

+ const Status_ERROR_ACCESS_TOKEN

+ const Status_ERROR_CHECKSUM

+ const Status_ERROR_EXISTS

+ const Status_ERROR_INVALID

+ const Status_ERROR_UNSUPPORTED

+ const Status_SUCCESS

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

+ func (x Status) Enum() *Status

+ func (x Status) String() string

+ type StorageInfoProto struct

+ CTime *uint64

+ ClusterID *string

+ LayoutVersion *uint32

+ NamespceID *uint32

+ XXX_unrecognized []byte

+ func (*StorageInfoProto) ProtoMessage()

+ func (m *StorageInfoProto) GetCTime() uint64

+ func (m *StorageInfoProto) GetClusterID() string

+ func (m *StorageInfoProto) GetLayoutVersion() uint32

+ func (m *StorageInfoProto) GetNamespceID() uint32

+ func (m *StorageInfoProto) Reset()

+ func (m *StorageInfoProto) String() string

+ type UpdateBlockForPipelineRequestProto struct

+ Block *ExtendedBlockProto

+ ClientName *string

+ XXX_unrecognized []byte

+ func (*UpdateBlockForPipelineRequestProto) ProtoMessage()

+ func (m *UpdateBlockForPipelineRequestProto) GetBlock() *ExtendedBlockProto

+ func (m *UpdateBlockForPipelineRequestProto) GetClientName() string

+ func (m *UpdateBlockForPipelineRequestProto) Reset()

+ func (m *UpdateBlockForPipelineRequestProto) String() string

+ type UpdateBlockForPipelineResponseProto struct

+ Block *LocatedBlockProto

+ XXX_unrecognized []byte

+ func (*UpdateBlockForPipelineResponseProto) ProtoMessage()

+ func (m *UpdateBlockForPipelineResponseProto) GetBlock() *LocatedBlockProto

+ func (m *UpdateBlockForPipelineResponseProto) Reset()

+ func (m *UpdateBlockForPipelineResponseProto) String() string

+ type UpdatePipelineRequestProto struct

+ ClientName *string

+ NewBlock *ExtendedBlockProto

+ NewNodes []*DatanodeIDProto

+ OldBlock *ExtendedBlockProto

+ XXX_unrecognized []byte

+ func (*UpdatePipelineRequestProto) ProtoMessage()

+ func (m *UpdatePipelineRequestProto) GetClientName() string

+ func (m *UpdatePipelineRequestProto) GetNewBlock() *ExtendedBlockProto

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

+ func (m *UpdatePipelineRequestProto) GetOldBlock() *ExtendedBlockProto

+ func (m *UpdatePipelineRequestProto) Reset()

+ func (m *UpdatePipelineRequestProto) String() string

+ type UpdatePipelineResponseProto struct

+ XXX_unrecognized []byte

+ func (*UpdatePipelineResponseProto) ProtoMessage()

+ func (m *UpdatePipelineResponseProto) Reset()

+ func (m *UpdatePipelineResponseProto) String() string

+ type VersionRequestProto struct

+ XXX_unrecognized []byte

+ func (*VersionRequestProto) ProtoMessage()

+ func (m *VersionRequestProto) Reset()

+ func (m *VersionRequestProto) String() string

+ type VersionResponseProto struct

+ Info *NamespaceInfoProto

+ XXX_unrecognized []byte

+ func (*VersionResponseProto) ProtoMessage()

+ func (m *VersionResponseProto) GetInfo() *NamespaceInfoProto

+ func (m *VersionResponseProto) Reset()

+ func (m *VersionResponseProto) String() string

v0.1.1

Nov 19, 2014

v0.1.0

Nov 3, 2014

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