Versions in this module Expand all Collapse all v3 v3.0.1 Jul 15, 2019 v3.0.0 Apr 30, 2019 Changes in this version + const Default_AbandonBlockRequestProto_FileId + const Default_AddBlockRequestProto_FileId + const Default_AppendEventProto_NewBlock + const Default_BlockProto_NumBytes + const Default_CompleteRequestProto_FileId + const Default_CreateEventProto_DefaultBlockSize + const Default_DatanodeIDProto_InfoSecurePort + const Default_DatanodeInfoProto_BlockPoolUsed + const Default_DatanodeInfoProto_CacheCapacity + const Default_DatanodeInfoProto_CacheUsed + const Default_DatanodeInfoProto_Capacity + const Default_DatanodeInfoProto_DfsUsed + const Default_DatanodeInfoProto_LastUpdate + const Default_DatanodeInfoProto_LastUpdateMonotonic + const Default_DatanodeInfoProto_Remaining + const Default_DatanodeInfoProto_XceiverCount + const Default_ExtendedBlockProto_NumBytes + const Default_FsServerDefaultsProto_EncryptDataTransfer + const Default_FsServerDefaultsProto_TrashInterval + const Default_FsyncRequestProto_FileId + const Default_FsyncRequestProto_LastBlockLength + const Default_GetAdditionalDatanodeRequestProto_FileId + const Default_HdfsFileStatusProto_BlockReplication + const Default_HdfsFileStatusProto_Blocksize + const Default_HdfsFileStatusProto_ChildrenNum + const Default_HdfsFileStatusProto_FileId + const Default_HdfsFileStatusProto_StoragePolicy + const Default_OpReadBlockProto_SendChecksums + const Default_OpRequestShortCircuitAccessProto_SupportsReceiptVerification + const Default_OpWriteBlockProto_AllowLazyPersist + const Default_OpWriteBlockProto_Pinning + const Default_PacketHeaderProto_SyncBlock + const Default_PipelineAckProto_DownstreamAckTimeNanos + const Default_RollingUpgradeStatusProto_Finalized + const Default_SaveNamespaceRequestProto_TimeWindow + const Default_SaveNamespaceRequestProto_TxGap + const Default_SaveNamespaceResponseProto_Saved + const Default_SetSafeModeRequestProto_Checked + 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 ChecksumTypeProto_name = map[int32]string + var ChecksumTypeProto_value = map[string]int32 + var CipherSuiteProto_name = map[int32]string + var CipherSuiteProto_value = map[string]int32 + var CreateFlagProto_name = map[int32]string + var CreateFlagProto_value = map[string]int32 + var CryptoProtocolVersionProto_name = map[int32]string + var CryptoProtocolVersionProto_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 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 HdfsFileStatusProto_FileType_name = map[int32]string + var HdfsFileStatusProto_FileType_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 OpWriteBlockProto_BlockConstructionStage_name = map[int32]string + var OpWriteBlockProto_BlockConstructionStage_value = map[string]int32 + var RollingUpgradeActionProto_name = map[int32]string + var RollingUpgradeActionProto_value = map[string]int32 + var SafeModeActionProto_name = map[int32]string + var SafeModeActionProto_value = map[string]int32 + var ShortCircuitFdResponse_name = map[int32]string + var ShortCircuitFdResponse_value = map[string]int32 + var Status_name = map[int32]string + var Status_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 struct + B *ExtendedBlockProto + FileId *uint64 + Holder *string + Src *string + XXX_unrecognized []byte + func (*AbandonBlockRequestProto) Descriptor() ([]byte, []int) + func (*AbandonBlockRequestProto) ProtoMessage() + func (m *AbandonBlockRequestProto) GetB() *ExtendedBlockProto + func (m *AbandonBlockRequestProto) GetFileId() uint64 + 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) Descriptor() ([]byte, []int) + func (*AbandonBlockResponseProto) ProtoMessage() + func (m *AbandonBlockResponseProto) Reset() + func (m *AbandonBlockResponseProto) String() string + type AclEntryProto struct + Name *string + Permissions *AclEntryProto_FsActionProto + Scope *AclEntryProto_AclEntryScopeProto + Type *AclEntryProto_AclEntryTypeProto + XXX_unrecognized []byte + func (*AclEntryProto) Descriptor() ([]byte, []int) + 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 (AclEntryProto_AclEntryScopeProto) EnumDescriptor() ([]byte, []int) + 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 (AclEntryProto_AclEntryTypeProto) EnumDescriptor() ([]byte, []int) + 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 (AclEntryProto_FsActionProto) EnumDescriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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 AddBlockRequestProto struct + ClientName *string + ExcludeNodes []*DatanodeInfoProto + FavoredNodes []string + FileId *uint64 + Previous *ExtendedBlockProto + Src *string + XXX_unrecognized []byte + func (*AddBlockRequestProto) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + func (*AddBlockResponseProto) ProtoMessage() + func (m *AddBlockResponseProto) GetBlock() *LocatedBlockProto + func (m *AddBlockResponseProto) Reset() + func (m *AddBlockResponseProto) String() string + type AddCacheDirectiveRequestProto struct + CacheFlags *uint32 + Info *CacheDirectiveInfoProto + XXX_unrecognized []byte + func (*AddCacheDirectiveRequestProto) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + func (*AddCachePoolResponseProto) ProtoMessage() + func (m *AddCachePoolResponseProto) Reset() + func (m *AddCachePoolResponseProto) String() string + type AllowSnapshotRequestProto struct + SnapshotRoot *string + XXX_unrecognized []byte + func (*AllowSnapshotRequestProto) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + func (*AllowSnapshotResponseProto) ProtoMessage() + func (m *AllowSnapshotResponseProto) Reset() + func (m *AllowSnapshotResponseProto) String() string + type AppendEventProto struct + NewBlock *bool + Path *string + XXX_unrecognized []byte + func (*AppendEventProto) Descriptor() ([]byte, []int) + func (*AppendEventProto) ProtoMessage() + func (m *AppendEventProto) GetNewBlock() bool + func (m *AppendEventProto) GetPath() string + func (m *AppendEventProto) Reset() + func (m *AppendEventProto) String() string + type AppendRequestProto struct + ClientName *string + Flag *uint32 + Src *string + XXX_unrecognized []byte + func (*AppendRequestProto) Descriptor() ([]byte, []int) + func (*AppendRequestProto) ProtoMessage() + func (m *AppendRequestProto) GetClientName() string + func (m *AppendRequestProto) GetFlag() uint32 + func (m *AppendRequestProto) GetSrc() string + func (m *AppendRequestProto) Reset() + func (m *AppendRequestProto) String() string + type AppendResponseProto struct + Block *LocatedBlockProto + Stat *HdfsFileStatusProto + XXX_unrecognized []byte + func (*AppendResponseProto) Descriptor() ([]byte, []int) + func (*AppendResponseProto) ProtoMessage() + func (m *AppendResponseProto) GetBlock() *LocatedBlockProto + func (m *AppendResponseProto) GetStat() *HdfsFileStatusProto + func (m *AppendResponseProto) Reset() + func (m *AppendResponseProto) String() string + type BaseHeaderProto struct + Block *ExtendedBlockProto + Token *hadoop_common.TokenProto + TraceInfo *DataTransferTraceInfoProto + XXX_unrecognized []byte + func (*BaseHeaderProto) Descriptor() ([]byte, []int) + func (*BaseHeaderProto) ProtoMessage() + func (m *BaseHeaderProto) GetBlock() *ExtendedBlockProto + func (m *BaseHeaderProto) GetToken() *hadoop_common.TokenProto + func (m *BaseHeaderProto) GetTraceInfo() *DataTransferTraceInfoProto + func (m *BaseHeaderProto) Reset() + func (m *BaseHeaderProto) String() string + type BlockECReconstructionInfoProto struct + Block *ExtendedBlockProto + EcPolicy *ErasureCodingPolicyProto + LiveBlockIndices []byte + SourceDnInfos *DatanodeInfosProto + TargetDnInfos *DatanodeInfosProto + TargetStorageTypes *StorageTypesProto + TargetStorageUuids *StorageUuidsProto + XXX_unrecognized []byte + func (*BlockECReconstructionInfoProto) Descriptor() ([]byte, []int) + 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 BlockOpResponseProto struct + ChecksumResponse *OpBlockChecksumResponseProto + FirstBadLink *string + Message *string + ReadOpChecksumInfo *ReadOpChecksumInfoProto + ShortCircuitAccessVersion *uint32 + Status *Status + XXX_unrecognized []byte + func (*BlockOpResponseProto) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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 BlockStoragePolicyProto struct + CreationFallbackPolicy *StorageTypesProto + CreationPolicy *StorageTypesProto + Name *string + PolicyId *uint32 + ReplicationFallbackPolicy *StorageTypesProto + XXX_unrecognized []byte + func (*BlockStoragePolicyProto) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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 (CacheFlagProto) EnumDescriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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 CachingStrategyProto struct + DropBehind *bool + Readahead *int64 + XXX_unrecognized []byte + func (*CachingStrategyProto) Descriptor() ([]byte, []int) + func (*CachingStrategyProto) ProtoMessage() + func (m *CachingStrategyProto) GetDropBehind() bool + func (m *CachingStrategyProto) GetReadahead() int64 + func (m *CachingStrategyProto) Reset() + func (m *CachingStrategyProto) String() string + type CheckAccessRequestProto struct + Mode *AclEntryProto_FsActionProto + Path *string + XXX_unrecognized []byte + func (*CheckAccessRequestProto) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + func (*CheckAccessResponseProto) ProtoMessage() + func (m *CheckAccessResponseProto) Reset() + func (m *CheckAccessResponseProto) String() string + type ChecksumProto struct + BytesPerChecksum *uint32 + Type *ChecksumTypeProto + XXX_unrecognized []byte + func (*ChecksumProto) Descriptor() ([]byte, []int) + 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 (ChecksumTypeProto) EnumDescriptor() ([]byte, []int) + func (x *ChecksumTypeProto) UnmarshalJSON(data []byte) error + func (x ChecksumTypeProto) Enum() *ChecksumTypeProto + func (x ChecksumTypeProto) String() string + type CipherOptionProto struct + InIv []byte + InKey []byte + OutIv []byte + OutKey []byte + Suite *CipherSuiteProto + XXX_unrecognized []byte + func (*CipherOptionProto) Descriptor() ([]byte, []int) + 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 (CipherSuiteProto) EnumDescriptor() ([]byte, []int) + func (x *CipherSuiteProto) UnmarshalJSON(data []byte) error + func (x CipherSuiteProto) Enum() *CipherSuiteProto + func (x CipherSuiteProto) String() string + type ClientOperationHeaderProto struct + BaseHeader *BaseHeaderProto + ClientName *string + XXX_unrecognized []byte + func (*ClientOperationHeaderProto) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + func (*ClientReadStatusProto) ProtoMessage() + func (m *ClientReadStatusProto) GetStatus() Status + func (m *ClientReadStatusProto) Reset() + func (m *ClientReadStatusProto) String() string + type CloseEventProto struct + FileSize *int64 + Path *string + Timestamp *int64 + XXX_unrecognized []byte + func (*CloseEventProto) Descriptor() ([]byte, []int) + 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 CompleteRequestProto struct + ClientName *string + FileId *uint64 + Last *ExtendedBlockProto + Src *string + XXX_unrecognized []byte + func (*CompleteRequestProto) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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 + TypeQuotaInfos *StorageTypeQuotaInfosProto + XXX_unrecognized []byte + func (*ContentSummaryProto) Descriptor() ([]byte, []int) + 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) GetTypeQuotaInfos() *StorageTypeQuotaInfosProto + func (m *ContentSummaryProto) Reset() + func (m *ContentSummaryProto) String() string + type CorruptFileBlocksProto struct + Cookie *string + Files []string + XXX_unrecognized []byte + func (*CorruptFileBlocksProto) Descriptor() ([]byte, []int) + func (*CorruptFileBlocksProto) ProtoMessage() + func (m *CorruptFileBlocksProto) GetCookie() string + func (m *CorruptFileBlocksProto) GetFiles() []string + func (m *CorruptFileBlocksProto) Reset() + func (m *CorruptFileBlocksProto) String() string + type CreateEncryptionZoneRequestProto struct + KeyName *string + Src *string + XXX_unrecognized []byte + func (*CreateEncryptionZoneRequestProto) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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 int32 + const CreateFlagProto_APPEND + const CreateFlagProto_CREATE + const CreateFlagProto_LAZY_PERSIST + const CreateFlagProto_NEW_BLOCK + const CreateFlagProto_OVERWRITE + func (CreateFlagProto) EnumDescriptor() ([]byte, []int) + 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 + CryptoProtocolVersion []CryptoProtocolVersionProto + Masked *FsPermissionProto + Replication *uint32 + Src *string + XXX_unrecognized []byte + func (*CreateRequestProto) Descriptor() ([]byte, []int) + 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) GetCryptoProtocolVersion() []CryptoProtocolVersionProto + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + func (*CreateSymlinkResponseProto) ProtoMessage() + func (m *CreateSymlinkResponseProto) Reset() + func (m *CreateSymlinkResponseProto) String() string + type CryptoProtocolVersionProto int32 + const CryptoProtocolVersionProto_ENCRYPTION_ZONES + const CryptoProtocolVersionProto_UNKNOWN_PROTOCOL_VERSION + func (CryptoProtocolVersionProto) EnumDescriptor() ([]byte, []int) + func (x *CryptoProtocolVersionProto) UnmarshalJSON(data []byte) error + func (x CryptoProtocolVersionProto) Enum() *CryptoProtocolVersionProto + func (x CryptoProtocolVersionProto) String() string + type DNTransferAckProto struct + Status *Status + XXX_unrecognized []byte + func (*DNTransferAckProto) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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 + CipherOption []*CipherOptionProto + Message *string + Payload []byte + Status *DataTransferEncryptorMessageProto_DataTransferEncryptorStatus + XXX_unrecognized []byte + func (*DataTransferEncryptorMessageProto) Descriptor() ([]byte, []int) + func (*DataTransferEncryptorMessageProto) ProtoMessage() + func (m *DataTransferEncryptorMessageProto) GetCipherOption() []*CipherOptionProto + 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 (DataTransferEncryptorMessageProto_DataTransferEncryptorStatus) EnumDescriptor() ([]byte, []int) + func (x *DataTransferEncryptorMessageProto_DataTransferEncryptorStatus) UnmarshalJSON(data []byte) error + func (x DataTransferEncryptorMessageProto_DataTransferEncryptorStatus) Enum() *DataTransferEncryptorMessageProto_DataTransferEncryptorStatus + func (x DataTransferEncryptorMessageProto_DataTransferEncryptorStatus) String() string + type DataTransferTraceInfoProto struct + ParentId *uint64 + TraceId *uint64 + XXX_unrecognized []byte + func (*DataTransferTraceInfoProto) Descriptor() ([]byte, []int) + func (*DataTransferTraceInfoProto) ProtoMessage() + func (m *DataTransferTraceInfoProto) GetParentId() uint64 + func (m *DataTransferTraceInfoProto) GetTraceId() uint64 + func (m *DataTransferTraceInfoProto) Reset() + func (m *DataTransferTraceInfoProto) String() string + type DatanodeIDProto struct + DatanodeUuid *string + HostName *string + InfoPort *uint32 + InfoSecurePort *uint32 + IpAddr *string + IpcPort *uint32 + XXX_unrecognized []byte + XferPort *uint32 + func (*DatanodeIDProto) Descriptor() ([]byte, []int) + func (*DatanodeIDProto) ProtoMessage() + func (m *DatanodeIDProto) GetDatanodeUuid() string + 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) GetXferPort() uint32 + func (m *DatanodeIDProto) Reset() + func (m *DatanodeIDProto) String() string + type DatanodeInfoProto struct + AdminState *DatanodeInfoProto_AdminState + BlockPoolUsed *uint64 + CacheCapacity *uint64 + CacheUsed *uint64 + Capacity *uint64 + DfsUsed *uint64 + Id *DatanodeIDProto + LastUpdate *uint64 + LastUpdateMonotonic *uint64 + Location *string + Remaining *uint64 + UpgradeDomain *string + XXX_unrecognized []byte + XceiverCount *uint32 + func (*DatanodeInfoProto) Descriptor() ([]byte, []int) + func (*DatanodeInfoProto) ProtoMessage() + func (m *DatanodeInfoProto) GetAdminState() DatanodeInfoProto_AdminState + func (m *DatanodeInfoProto) GetBlockPoolUsed() uint64 + func (m *DatanodeInfoProto) GetCacheCapacity() uint64 + func (m *DatanodeInfoProto) GetCacheUsed() uint64 + func (m *DatanodeInfoProto) GetCapacity() uint64 + func (m *DatanodeInfoProto) GetDfsUsed() uint64 + func (m *DatanodeInfoProto) GetId() *DatanodeIDProto + func (m *DatanodeInfoProto) GetLastUpdate() uint64 + func (m *DatanodeInfoProto) GetLastUpdateMonotonic() uint64 + func (m *DatanodeInfoProto) GetLocation() string + func (m *DatanodeInfoProto) GetRemaining() uint64 + func (m *DatanodeInfoProto) GetUpgradeDomain() string + 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 (DatanodeInfoProto_AdminState) EnumDescriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + func (*DatanodeInfosProto) ProtoMessage() + func (m *DatanodeInfosProto) GetDatanodes() []*DatanodeInfoProto + func (m *DatanodeInfosProto) Reset() + func (m *DatanodeInfosProto) String() string + type DatanodeLocalInfoProto struct + ConfigVersion *string + SoftwareVersion *string + Uptime *uint64 + XXX_unrecognized []byte + func (*DatanodeLocalInfoProto) Descriptor() ([]byte, []int) + 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 int32 + const DatanodeReportTypeProto_ALL + const DatanodeReportTypeProto_DEAD + const DatanodeReportTypeProto_DECOMMISSIONING + const DatanodeReportTypeProto_LIVE + func (DatanodeReportTypeProto) EnumDescriptor() ([]byte, []int) + func (x *DatanodeReportTypeProto) UnmarshalJSON(data []byte) error + func (x DatanodeReportTypeProto) Enum() *DatanodeReportTypeProto + func (x DatanodeReportTypeProto) String() string + type DatanodeStorageProto struct + State *DatanodeStorageProto_StorageState + StorageType *StorageTypeProto + StorageUuid *string + XXX_unrecognized []byte + func (*DatanodeStorageProto) Descriptor() ([]byte, []int) + 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 (DatanodeStorageProto_StorageState) EnumDescriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + func (*DeleteBlockPoolResponseProto) ProtoMessage() + func (m *DeleteBlockPoolResponseProto) Reset() + func (m *DeleteBlockPoolResponseProto) String() string + type DeleteRequestProto struct + Recursive *bool + Src *string + XXX_unrecognized []byte + func (*DeleteRequestProto) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + func (*DeleteSnapshotResponseProto) ProtoMessage() + func (m *DeleteSnapshotResponseProto) Reset() + func (m *DeleteSnapshotResponseProto) String() string + type DirectoryListingProto struct + PartialListing []*HdfsFileStatusProto + RemainingEntries *uint32 + XXX_unrecognized []byte + func (*DirectoryListingProto) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + func (*DisallowSnapshotResponseProto) ProtoMessage() + func (m *DisallowSnapshotResponseProto) Reset() + func (m *DisallowSnapshotResponseProto) String() string + type ECSchemaOptionEntryProto struct + Key *string + Value *string + XXX_unrecognized []byte + func (*ECSchemaOptionEntryProto) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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 (EventType) EnumDescriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + func (*EvictWritersRequestProto) ProtoMessage() + func (m *EvictWritersRequestProto) Reset() + func (m *EvictWritersRequestProto) String() string + type EvictWritersResponseProto struct + XXX_unrecognized []byte + func (*EvictWritersResponseProto) Descriptor() ([]byte, []int) + func (*EvictWritersResponseProto) ProtoMessage() + func (m *EvictWritersResponseProto) Reset() + func (m *EvictWritersResponseProto) String() string + type ExtendedBlockProto struct + BlockId *uint64 + GenerationStamp *uint64 + NumBytes *uint64 + PoolId *string + XXX_unrecognized []byte + func (*ExtendedBlockProto) Descriptor() ([]byte, []int) + 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 FileEncryptionInfoProto struct + CryptoProtocolVersion *CryptoProtocolVersionProto + EzKeyVersionName *string + Iv []byte + Key []byte + KeyName *string + Suite *CipherSuiteProto + XXX_unrecognized []byte + func (*FileEncryptionInfoProto) Descriptor() ([]byte, []int) + 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 FinalizeUpgradeRequestProto struct + XXX_unrecognized []byte + func (*FinalizeUpgradeRequestProto) Descriptor() ([]byte, []int) + func (*FinalizeUpgradeRequestProto) ProtoMessage() + func (m *FinalizeUpgradeRequestProto) Reset() + func (m *FinalizeUpgradeRequestProto) String() string + type FinalizeUpgradeResponseProto struct + XXX_unrecognized []byte + func (*FinalizeUpgradeResponseProto) Descriptor() ([]byte, []int) + func (*FinalizeUpgradeResponseProto) ProtoMessage() + func (m *FinalizeUpgradeResponseProto) Reset() + func (m *FinalizeUpgradeResponseProto) String() string + type FsPermissionProto struct + Perm *uint32 + XXX_unrecognized []byte + func (*FsPermissionProto) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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 + FileId *uint64 + LastBlockLength *int64 + Src *string + XXX_unrecognized []byte + func (*FsyncRequestProto) Descriptor() ([]byte, []int) + func (*FsyncRequestProto) ProtoMessage() + func (m *FsyncRequestProto) GetClient() string + func (m *FsyncRequestProto) GetFileId() uint64 + 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) Descriptor() ([]byte, []int) + func (*FsyncResponseProto) ProtoMessage() + func (m *FsyncResponseProto) Reset() + func (m *FsyncResponseProto) String() string + type GetAclStatusRequestProto struct + Src *string + XXX_unrecognized []byte + func (*GetAclStatusRequestProto) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + func (*GetAclStatusResponseProto) ProtoMessage() + func (m *GetAclStatusResponseProto) GetResult() *AclStatusProto + func (m *GetAclStatusResponseProto) Reset() + func (m *GetAclStatusResponseProto) String() string + type GetAdditionalDatanodeRequestProto struct + Blk *ExtendedBlockProto + ClientName *string + Excludes []*DatanodeInfoProto + ExistingStorageUuids []string + Existings []*DatanodeInfoProto + FileId *uint64 + NumAdditionalNodes *uint32 + Src *string + XXX_unrecognized []byte + func (*GetAdditionalDatanodeRequestProto) Descriptor() ([]byte, []int) + func (*GetAdditionalDatanodeRequestProto) ProtoMessage() + func (m *GetAdditionalDatanodeRequestProto) GetBlk() *ExtendedBlockProto + func (m *GetAdditionalDatanodeRequestProto) GetClientName() string + func (m *GetAdditionalDatanodeRequestProto) GetExcludes() []*DatanodeInfoProto + func (m *GetAdditionalDatanodeRequestProto) GetExistingStorageUuids() []string + func (m *GetAdditionalDatanodeRequestProto) GetExistings() []*DatanodeInfoProto + func (m *GetAdditionalDatanodeRequestProto) GetFileId() uint64 + 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) Descriptor() ([]byte, []int) + func (*GetAdditionalDatanodeResponseProto) ProtoMessage() + func (m *GetAdditionalDatanodeResponseProto) GetBlock() *LocatedBlockProto + func (m *GetAdditionalDatanodeResponseProto) Reset() + func (m *GetAdditionalDatanodeResponseProto) String() string + type GetBalancerBandwidthRequestProto struct + XXX_unrecognized []byte + func (*GetBalancerBandwidthRequestProto) Descriptor() ([]byte, []int) + func (*GetBalancerBandwidthRequestProto) ProtoMessage() + func (m *GetBalancerBandwidthRequestProto) Reset() + func (m *GetBalancerBandwidthRequestProto) String() string + type GetBalancerBandwidthResponseProto struct + Bandwidth *uint64 + XXX_unrecognized []byte + func (*GetBalancerBandwidthResponseProto) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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 GetBlockLocationsRequestProto struct + Length *uint64 + Offset *uint64 + Src *string + XXX_unrecognized []byte + func (*GetBlockLocationsRequestProto) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + func (*GetContentSummaryResponseProto) ProtoMessage() + func (m *GetContentSummaryResponseProto) GetSummary() *ContentSummaryProto + func (m *GetContentSummaryResponseProto) Reset() + func (m *GetContentSummaryResponseProto) String() string + type GetCurrentEditLogTxidRequestProto struct + XXX_unrecognized []byte + func (*GetCurrentEditLogTxidRequestProto) Descriptor() ([]byte, []int) + func (*GetCurrentEditLogTxidRequestProto) ProtoMessage() + func (m *GetCurrentEditLogTxidRequestProto) Reset() + func (m *GetCurrentEditLogTxidRequestProto) String() string + type GetCurrentEditLogTxidResponseProto struct + Txid *int64 + XXX_unrecognized []byte + func (*GetCurrentEditLogTxidResponseProto) Descriptor() ([]byte, []int) + func (*GetCurrentEditLogTxidResponseProto) ProtoMessage() + func (m *GetCurrentEditLogTxidResponseProto) GetTxid() int64 + func (m *GetCurrentEditLogTxidResponseProto) Reset() + func (m *GetCurrentEditLogTxidResponseProto) String() string + type GetDataEncryptionKeyRequestProto struct + XXX_unrecognized []byte + func (*GetDataEncryptionKeyRequestProto) Descriptor() ([]byte, []int) + func (*GetDataEncryptionKeyRequestProto) ProtoMessage() + func (m *GetDataEncryptionKeyRequestProto) Reset() + func (m *GetDataEncryptionKeyRequestProto) String() string + type GetDataEncryptionKeyResponseProto struct + DataEncryptionKey *DataEncryptionKeyProto + XXX_unrecognized []byte + func (*GetDataEncryptionKeyResponseProto) Descriptor() ([]byte, []int) + func (*GetDataEncryptionKeyResponseProto) ProtoMessage() + func (m *GetDataEncryptionKeyResponseProto) GetDataEncryptionKey() *DataEncryptionKeyProto + func (m *GetDataEncryptionKeyResponseProto) Reset() + func (m *GetDataEncryptionKeyResponseProto) String() string + type GetDatanodeInfoRequestProto struct + XXX_unrecognized []byte + func (*GetDatanodeInfoRequestProto) Descriptor() ([]byte, []int) + func (*GetDatanodeInfoRequestProto) ProtoMessage() + func (m *GetDatanodeInfoRequestProto) Reset() + func (m *GetDatanodeInfoRequestProto) String() string + type GetDatanodeInfoResponseProto struct + LocalInfo *DatanodeLocalInfoProto + XXX_unrecognized []byte + func (*GetDatanodeInfoResponseProto) Descriptor() ([]byte, []int) + func (*GetDatanodeInfoResponseProto) ProtoMessage() + func (m *GetDatanodeInfoResponseProto) GetLocalInfo() *DatanodeLocalInfoProto + func (m *GetDatanodeInfoResponseProto) Reset() + func (m *GetDatanodeInfoResponseProto) String() string + type GetDatanodeReportRequestProto struct + Type *DatanodeReportTypeProto + XXX_unrecognized []byte + func (*GetDatanodeReportRequestProto) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + func (*GetDatanodeReportResponseProto) ProtoMessage() + func (m *GetDatanodeReportResponseProto) GetDi() []*DatanodeInfoProto + func (m *GetDatanodeReportResponseProto) Reset() + func (m *GetDatanodeReportResponseProto) String() string + type GetDatanodeStorageReportRequestProto struct + Type *DatanodeReportTypeProto + XXX_unrecognized []byte + func (*GetDatanodeStorageReportRequestProto) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + func (*GetErasureCodingPoliciesRequestProto) ProtoMessage() + func (m *GetErasureCodingPoliciesRequestProto) Reset() + func (m *GetErasureCodingPoliciesRequestProto) String() string + type GetErasureCodingPoliciesResponseProto struct + EcPolicies []*ErasureCodingPolicyProto + XXX_unrecognized []byte + func (*GetErasureCodingPoliciesResponseProto) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + func (*GetErasureCodingPolicyResponseProto) ProtoMessage() + func (m *GetErasureCodingPolicyResponseProto) GetEcPolicy() *ErasureCodingPolicyProto + func (m *GetErasureCodingPolicyResponseProto) Reset() + func (m *GetErasureCodingPolicyResponseProto) String() string + type GetFileInfoRequestProto struct + Src *string + XXX_unrecognized []byte + func (*GetFileInfoRequestProto) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + func (*GetFileLinkInfoResponseProto) ProtoMessage() + func (m *GetFileLinkInfoResponseProto) GetFs() *HdfsFileStatusProto + func (m *GetFileLinkInfoResponseProto) Reset() + func (m *GetFileLinkInfoResponseProto) String() string + type GetFsStatsResponseProto struct + BlocksInFuture *uint64 + Capacity *uint64 + CorruptBlocks *uint64 + MissingBlocks *uint64 + MissingReplOneBlocks *uint64 + PendingDeletionBlocks *uint64 + Remaining *uint64 + UnderReplicated *uint64 + Used *uint64 + XXX_unrecognized []byte + func (*GetFsStatsResponseProto) Descriptor() ([]byte, []int) + func (*GetFsStatsResponseProto) ProtoMessage() + func (m *GetFsStatsResponseProto) GetBlocksInFuture() uint64 + func (m *GetFsStatsResponseProto) GetCapacity() uint64 + func (m *GetFsStatsResponseProto) GetCorruptBlocks() uint64 + func (m *GetFsStatsResponseProto) GetMissingBlocks() uint64 + func (m *GetFsStatsResponseProto) GetMissingReplOneBlocks() uint64 + func (m *GetFsStatsResponseProto) GetPendingDeletionBlocks() 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) Descriptor() ([]byte, []int) + func (*GetFsStatusRequestProto) ProtoMessage() + func (m *GetFsStatusRequestProto) Reset() + func (m *GetFsStatusRequestProto) String() string + type GetLinkTargetRequestProto struct + Path *string + XXX_unrecognized []byte + func (*GetLinkTargetRequestProto) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + func (*GetPreferredBlockSizeResponseProto) ProtoMessage() + func (m *GetPreferredBlockSizeResponseProto) GetBsize() uint64 + func (m *GetPreferredBlockSizeResponseProto) Reset() + func (m *GetPreferredBlockSizeResponseProto) String() string + type GetQuotaUsageRequestProto struct + Path *string + XXX_unrecognized []byte + func (*GetQuotaUsageRequestProto) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + func (*GetReplicaVisibleLengthResponseProto) ProtoMessage() + func (m *GetReplicaVisibleLengthResponseProto) GetLength() uint64 + func (m *GetReplicaVisibleLengthResponseProto) Reset() + func (m *GetReplicaVisibleLengthResponseProto) String() string + type GetServerDefaultsRequestProto struct + XXX_unrecognized []byte + func (*GetServerDefaultsRequestProto) Descriptor() ([]byte, []int) + func (*GetServerDefaultsRequestProto) ProtoMessage() + func (m *GetServerDefaultsRequestProto) Reset() + func (m *GetServerDefaultsRequestProto) String() string + type GetServerDefaultsResponseProto struct + ServerDefaults *FsServerDefaultsProto + XXX_unrecognized []byte + func (*GetServerDefaultsResponseProto) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + func (*GetSnapshottableDirListingRequestProto) ProtoMessage() + func (m *GetSnapshottableDirListingRequestProto) Reset() + func (m *GetSnapshottableDirListingRequestProto) String() string + type GetSnapshottableDirListingResponseProto struct + SnapshottableDirList *SnapshottableDirectoryListingProto + XXX_unrecognized []byte + func (*GetSnapshottableDirListingResponseProto) Descriptor() ([]byte, []int) + func (*GetSnapshottableDirListingResponseProto) ProtoMessage() + func (m *GetSnapshottableDirListingResponseProto) GetSnapshottableDirList() *SnapshottableDirectoryListingProto + func (m *GetSnapshottableDirListingResponseProto) Reset() + func (m *GetSnapshottableDirListingResponseProto) String() string + type GetStoragePoliciesRequestProto struct + XXX_unrecognized []byte + func (*GetStoragePoliciesRequestProto) Descriptor() ([]byte, []int) + func (*GetStoragePoliciesRequestProto) ProtoMessage() + func (m *GetStoragePoliciesRequestProto) Reset() + func (m *GetStoragePoliciesRequestProto) String() string + type GetStoragePoliciesResponseProto struct + Policies []*BlockStoragePolicyProto + XXX_unrecognized []byte + func (*GetStoragePoliciesResponseProto) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + func (*GetXAttrsResponseProto) ProtoMessage() + func (m *GetXAttrsResponseProto) GetXAttrs() []*XAttrProto + func (m *GetXAttrsResponseProto) Reset() + func (m *GetXAttrsResponseProto) String() string + type HdfsFileStatusProto struct + AccessTime *uint64 + BlockReplication *uint32 + Blocksize *uint64 + ChildrenNum *int32 + EcPolicy *ErasureCodingPolicyProto + FileEncryptionInfo *FileEncryptionInfoProto + FileId *uint64 + FileType *HdfsFileStatusProto_FileType + Group *string + Length *uint64 + Locations *LocatedBlocksProto + ModificationTime *uint64 + Owner *string + Path []byte + Permission *FsPermissionProto + StoragePolicy *uint32 + Symlink []byte + XXX_unrecognized []byte + func (*HdfsFileStatusProto) Descriptor() ([]byte, []int) + 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) GetEcPolicy() *ErasureCodingPolicyProto + func (m *HdfsFileStatusProto) GetFileEncryptionInfo() *FileEncryptionInfoProto + 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) GetStoragePolicy() uint32 + 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 (HdfsFileStatusProto_FileType) EnumDescriptor() ([]byte, []int) + func (x *HdfsFileStatusProto_FileType) UnmarshalJSON(data []byte) error + func (x HdfsFileStatusProto_FileType) Enum() *HdfsFileStatusProto_FileType + func (x HdfsFileStatusProto_FileType) String() string + type INodeType int32 + const INodeType_I_TYPE_DIRECTORY + const INodeType_I_TYPE_FILE + const INodeType_I_TYPE_SYMLINK + func (INodeType) EnumDescriptor() ([]byte, []int) + func (x *INodeType) UnmarshalJSON(data []byte) error + func (x INodeType) Enum() *INodeType + func (x INodeType) String() string + type IsFileClosedRequestProto struct + Src *string + XXX_unrecognized []byte + func (*IsFileClosedRequestProto) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + func (*IsFileClosedResponseProto) ProtoMessage() + func (m *IsFileClosedResponseProto) GetResult() bool + func (m *IsFileClosedResponseProto) Reset() + func (m *IsFileClosedResponseProto) String() string + type ListCacheDirectivesRequestProto struct + Filter *CacheDirectiveInfoProto + PrevId *int64 + XXX_unrecognized []byte + func (*ListCacheDirectivesRequestProto) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + func (*ListCachePoolsResponseProto) ProtoMessage() + func (m *ListCachePoolsResponseProto) GetEntries() []*CachePoolEntryProto + func (m *ListCachePoolsResponseProto) GetHasMore() bool + func (m *ListCachePoolsResponseProto) Reset() + func (m *ListCachePoolsResponseProto) String() string + type ListCorruptFileBlocksRequestProto struct + Cookie *string + Path *string + XXX_unrecognized []byte + func (*ListCorruptFileBlocksRequestProto) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + func (*ListCorruptFileBlocksResponseProto) ProtoMessage() + func (m *ListCorruptFileBlocksResponseProto) GetCorrupt() *CorruptFileBlocksProto + func (m *ListCorruptFileBlocksResponseProto) Reset() + func (m *ListCorruptFileBlocksResponseProto) String() string + type ListEncryptionZonesRequestProto struct + Id *int64 + XXX_unrecognized []byte + func (*ListEncryptionZonesRequestProto) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + func (*ListReconfigurablePropertiesRequestProto) ProtoMessage() + func (m *ListReconfigurablePropertiesRequestProto) Reset() + func (m *ListReconfigurablePropertiesRequestProto) String() string + type ListReconfigurablePropertiesResponseProto struct + Name []string + XXX_unrecognized []byte + func (*ListReconfigurablePropertiesResponseProto) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + func (*ListXAttrsResponseProto) ProtoMessage() + func (m *ListXAttrsResponseProto) GetXAttrs() []*XAttrProto + func (m *ListXAttrsResponseProto) Reset() + func (m *ListXAttrsResponseProto) String() string + type LocatedBlockProto struct + B *ExtendedBlockProto + BlockIndices []byte + BlockToken *hadoop_common.TokenProto + BlockTokens []*hadoop_common.TokenProto + Corrupt *bool + IsCached []bool + Locs []*DatanodeInfoProto + Offset *uint64 + StorageIDs []string + StorageTypes []StorageTypeProto + XXX_unrecognized []byte + func (*LocatedBlockProto) Descriptor() ([]byte, []int) + func (*LocatedBlockProto) ProtoMessage() + func (m *LocatedBlockProto) GetB() *ExtendedBlockProto + func (m *LocatedBlockProto) GetBlockIndices() []byte + func (m *LocatedBlockProto) GetBlockToken() *hadoop_common.TokenProto + func (m *LocatedBlockProto) GetBlockTokens() []*hadoop_common.TokenProto + func (m *LocatedBlockProto) GetCorrupt() bool + func (m *LocatedBlockProto) GetIsCached() []bool + func (m *LocatedBlockProto) GetLocs() []*DatanodeInfoProto + func (m *LocatedBlockProto) GetOffset() uint64 + func (m *LocatedBlockProto) GetStorageIDs() []string + func (m *LocatedBlockProto) GetStorageTypes() []StorageTypeProto + func (m *LocatedBlockProto) Reset() + func (m *LocatedBlockProto) String() string + type LocatedBlocksProto struct + Blocks []*LocatedBlockProto + EcPolicy *ErasureCodingPolicyProto + FileEncryptionInfo *FileEncryptionInfoProto + FileLength *uint64 + IsLastBlockComplete *bool + LastBlock *LocatedBlockProto + UnderConstruction *bool + XXX_unrecognized []byte + func (*LocatedBlocksProto) Descriptor() ([]byte, []int) + func (*LocatedBlocksProto) ProtoMessage() + func (m *LocatedBlocksProto) GetBlocks() []*LocatedBlockProto + func (m *LocatedBlocksProto) GetEcPolicy() *ErasureCodingPolicyProto + func (m *LocatedBlocksProto) GetFileEncryptionInfo() *FileEncryptionInfoProto + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + func (*MetaSaveResponseProto) ProtoMessage() + func (m *MetaSaveResponseProto) Reset() + func (m *MetaSaveResponseProto) String() string + 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) Descriptor() ([]byte, []int) + 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 (MetadataUpdateType) EnumDescriptor() ([]byte, []int) + func (x *MetadataUpdateType) UnmarshalJSON(data []byte) error + func (x MetadataUpdateType) Enum() *MetadataUpdateType + func (x MetadataUpdateType) String() string + type MkdirsRequestProto struct + CreateParent *bool + Masked *FsPermissionProto + Src *string + XXX_unrecognized []byte + func (*MkdirsRequestProto) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + func (*MkdirsResponseProto) ProtoMessage() + func (m *MkdirsResponseProto) GetResult() bool + func (m *MkdirsResponseProto) Reset() + func (m *MkdirsResponseProto) String() string + type ModifyAclEntriesRequestProto struct + AclSpec []*AclEntryProto + Src *string + XXX_unrecognized []byte + func (*ModifyAclEntriesRequestProto) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + func (*ModifyAclEntriesResponseProto) ProtoMessage() + func (m *ModifyAclEntriesResponseProto) Reset() + func (m *ModifyAclEntriesResponseProto) String() string + type ModifyCacheDirectiveRequestProto struct + CacheFlags *uint32 + Info *CacheDirectiveInfoProto + XXX_unrecognized []byte + func (*ModifyCacheDirectiveRequestProto) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + func (*ModifyCacheDirectiveResponseProto) ProtoMessage() + func (m *ModifyCacheDirectiveResponseProto) Reset() + func (m *ModifyCacheDirectiveResponseProto) String() string + type ModifyCachePoolRequestProto struct + Info *CachePoolInfoProto + XXX_unrecognized []byte + func (*ModifyCachePoolRequestProto) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + func (*ModifyCachePoolResponseProto) ProtoMessage() + func (m *ModifyCachePoolResponseProto) Reset() + func (m *ModifyCachePoolResponseProto) String() string + type OpBlockChecksumProto struct + Header *BaseHeaderProto + XXX_unrecognized []byte + func (*OpBlockChecksumProto) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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 OpBlockGroupChecksumProto struct + BlockTokens []*hadoop_common.TokenProto + Datanodes *DatanodeInfosProto + EcPolicy *ErasureCodingPolicyProto + Header *BaseHeaderProto + XXX_unrecognized []byte + func (*OpBlockGroupChecksumProto) Descriptor() ([]byte, []int) + 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 OpCopyBlockProto struct + Header *BaseHeaderProto + XXX_unrecognized []byte + func (*OpCopyBlockProto) Descriptor() ([]byte, []int) + func (*OpCopyBlockProto) ProtoMessage() + func (m *OpCopyBlockProto) GetHeader() *BaseHeaderProto + func (m *OpCopyBlockProto) Reset() + func (m *OpCopyBlockProto) String() string + type OpCustomProto struct + CustomId *string + XXX_unrecognized []byte + func (*OpCustomProto) Descriptor() ([]byte, []int) + func (*OpCustomProto) ProtoMessage() + func (m *OpCustomProto) GetCustomId() string + func (m *OpCustomProto) Reset() + func (m *OpCustomProto) String() string + type OpReadBlockProto struct + CachingStrategy *CachingStrategyProto + Header *ClientOperationHeaderProto + Len *uint64 + Offset *uint64 + SendChecksums *bool + XXX_unrecognized []byte + func (*OpReadBlockProto) Descriptor() ([]byte, []int) + 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 + StorageType *StorageTypeProto + XXX_unrecognized []byte + func (*OpReplaceBlockProto) Descriptor() ([]byte, []int) + func (*OpReplaceBlockProto) ProtoMessage() + func (m *OpReplaceBlockProto) GetDelHint() string + func (m *OpReplaceBlockProto) GetHeader() *BaseHeaderProto + func (m *OpReplaceBlockProto) GetSource() *DatanodeInfoProto + func (m *OpReplaceBlockProto) GetStorageType() StorageTypeProto + func (m *OpReplaceBlockProto) Reset() + func (m *OpReplaceBlockProto) String() string + type OpRequestShortCircuitAccessProto struct + Header *BaseHeaderProto + MaxVersion *uint32 + SlotId *ShortCircuitShmSlotProto + SupportsReceiptVerification *bool + XXX_unrecognized []byte + func (*OpRequestShortCircuitAccessProto) Descriptor() ([]byte, []int) + func (*OpRequestShortCircuitAccessProto) ProtoMessage() + func (m *OpRequestShortCircuitAccessProto) GetHeader() *BaseHeaderProto + func (m *OpRequestShortCircuitAccessProto) GetMaxVersion() uint32 + func (m *OpRequestShortCircuitAccessProto) GetSlotId() *ShortCircuitShmSlotProto + func (m *OpRequestShortCircuitAccessProto) GetSupportsReceiptVerification() bool + func (m *OpRequestShortCircuitAccessProto) Reset() + func (m *OpRequestShortCircuitAccessProto) String() string + type OpTransferBlockProto struct + Header *ClientOperationHeaderProto + TargetStorageTypes []StorageTypeProto + Targets []*DatanodeInfoProto + XXX_unrecognized []byte + func (*OpTransferBlockProto) Descriptor() ([]byte, []int) + func (*OpTransferBlockProto) ProtoMessage() + func (m *OpTransferBlockProto) GetHeader() *ClientOperationHeaderProto + func (m *OpTransferBlockProto) GetTargetStorageTypes() []StorageTypeProto + func (m *OpTransferBlockProto) GetTargets() []*DatanodeInfoProto + func (m *OpTransferBlockProto) Reset() + func (m *OpTransferBlockProto) String() string + type OpWriteBlockProto struct + AllowLazyPersist *bool + CachingStrategy *CachingStrategyProto + Header *ClientOperationHeaderProto + LatestGenerationStamp *uint64 + MaxBytesRcvd *uint64 + MinBytesRcvd *uint64 + Pinning *bool + PipelineSize *uint32 + RequestedChecksum *ChecksumProto + Source *DatanodeInfoProto + Stage *OpWriteBlockProto_BlockConstructionStage + StorageType *StorageTypeProto + TargetPinnings []bool + TargetStorageTypes []StorageTypeProto + Targets []*DatanodeInfoProto + XXX_unrecognized []byte + func (*OpWriteBlockProto) Descriptor() ([]byte, []int) + func (*OpWriteBlockProto) ProtoMessage() + func (m *OpWriteBlockProto) GetAllowLazyPersist() bool + 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) GetPinning() bool + func (m *OpWriteBlockProto) GetPipelineSize() uint32 + func (m *OpWriteBlockProto) GetRequestedChecksum() *ChecksumProto + func (m *OpWriteBlockProto) GetSource() *DatanodeInfoProto + func (m *OpWriteBlockProto) GetStage() OpWriteBlockProto_BlockConstructionStage + func (m *OpWriteBlockProto) GetStorageType() StorageTypeProto + func (m *OpWriteBlockProto) GetTargetPinnings() []bool + func (m *OpWriteBlockProto) GetTargetStorageTypes() []StorageTypeProto + 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 (OpWriteBlockProto_BlockConstructionStage) EnumDescriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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 PerFileEncryptionInfoProto struct + EzKeyVersionName *string + Iv []byte + Key []byte + XXX_unrecognized []byte + func (*PerFileEncryptionInfoProto) Descriptor() ([]byte, []int) + 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 struct + DownstreamAckTimeNanos *uint64 + Flag []uint32 + Reply []Status + Seqno *int64 + XXX_unrecognized []byte + func (*PipelineAckProto) Descriptor() ([]byte, []int) + func (*PipelineAckProto) ProtoMessage() + func (m *PipelineAckProto) GetDownstreamAckTimeNanos() uint64 + func (m *PipelineAckProto) GetFlag() []uint32 + func (m *PipelineAckProto) GetReply() []Status + func (m *PipelineAckProto) GetSeqno() int64 + func (m *PipelineAckProto) Reset() + func (m *PipelineAckProto) String() string + type QuotaUsageProto struct + FileAndDirectoryCount *uint64 + Quota *uint64 + SpaceConsumed *uint64 + SpaceQuota *uint64 + TypeQuotaInfos *StorageTypeQuotaInfosProto + XXX_unrecognized []byte + func (*QuotaUsageProto) Descriptor() ([]byte, []int) + 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 ReadOpChecksumInfoProto struct + Checksum *ChecksumProto + ChunkOffset *uint64 + XXX_unrecognized []byte + func (*ReadOpChecksumInfoProto) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + func (*RecoverLeaseResponseProto) ProtoMessage() + func (m *RecoverLeaseResponseProto) GetResult() bool + func (m *RecoverLeaseResponseProto) Reset() + func (m *RecoverLeaseResponseProto) String() string + type RefreshNamenodesRequestProto struct + XXX_unrecognized []byte + func (*RefreshNamenodesRequestProto) Descriptor() ([]byte, []int) + func (*RefreshNamenodesRequestProto) ProtoMessage() + func (m *RefreshNamenodesRequestProto) Reset() + func (m *RefreshNamenodesRequestProto) String() string + type RefreshNamenodesResponseProto struct + XXX_unrecognized []byte + func (*RefreshNamenodesResponseProto) Descriptor() ([]byte, []int) + func (*RefreshNamenodesResponseProto) ProtoMessage() + func (m *RefreshNamenodesResponseProto) Reset() + func (m *RefreshNamenodesResponseProto) String() string + type RefreshNodesRequestProto struct + XXX_unrecognized []byte + func (*RefreshNodesRequestProto) Descriptor() ([]byte, []int) + func (*RefreshNodesRequestProto) ProtoMessage() + func (m *RefreshNodesRequestProto) Reset() + func (m *RefreshNodesRequestProto) String() string + type RefreshNodesResponseProto struct + XXX_unrecognized []byte + func (*RefreshNodesResponseProto) Descriptor() ([]byte, []int) + func (*RefreshNodesResponseProto) ProtoMessage() + func (m *RefreshNodesResponseProto) Reset() + func (m *RefreshNodesResponseProto) String() string + type ReleaseShortCircuitAccessRequestProto struct + SlotId *ShortCircuitShmSlotProto + TraceInfo *DataTransferTraceInfoProto + XXX_unrecognized []byte + func (*ReleaseShortCircuitAccessRequestProto) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + func (*RemoveAclEntriesResponseProto) ProtoMessage() + func (m *RemoveAclEntriesResponseProto) Reset() + func (m *RemoveAclEntriesResponseProto) String() string + type RemoveAclRequestProto struct + Src *string + XXX_unrecognized []byte + func (*RemoveAclRequestProto) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + func (*RemoveAclResponseProto) ProtoMessage() + func (m *RemoveAclResponseProto) Reset() + func (m *RemoveAclResponseProto) String() string + type RemoveCacheDirectiveRequestProto struct + Id *int64 + XXX_unrecognized []byte + func (*RemoveCacheDirectiveRequestProto) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + func (*RemoveCacheDirectiveResponseProto) ProtoMessage() + func (m *RemoveCacheDirectiveResponseProto) Reset() + func (m *RemoveCacheDirectiveResponseProto) String() string + type RemoveCachePoolRequestProto struct + PoolName *string + XXX_unrecognized []byte + func (*RemoveCachePoolRequestProto) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + func (*RemoveCachePoolResponseProto) ProtoMessage() + func (m *RemoveCachePoolResponseProto) Reset() + func (m *RemoveCachePoolResponseProto) String() string + type RemoveDefaultAclRequestProto struct + Src *string + XXX_unrecognized []byte + func (*RemoveDefaultAclRequestProto) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + func (*RemoveDefaultAclResponseProto) ProtoMessage() + func (m *RemoveDefaultAclResponseProto) Reset() + func (m *RemoveDefaultAclResponseProto) String() string + type RemoveXAttrRequestProto struct + Src *string + XAttr *XAttrProto + XXX_unrecognized []byte + func (*RemoveXAttrRequestProto) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + func (*RemoveXAttrResponseProto) ProtoMessage() + func (m *RemoveXAttrResponseProto) Reset() + func (m *RemoveXAttrResponseProto) String() string + type Rename2RequestProto struct + Dst *string + OverwriteDest *bool + Src *string + XXX_unrecognized []byte + func (*Rename2RequestProto) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + func (*Rename2ResponseProto) ProtoMessage() + func (m *Rename2ResponseProto) Reset() + func (m *Rename2ResponseProto) String() string + type RenameEventProto struct + DestPath *string + SrcPath *string + Timestamp *int64 + XXX_unrecognized []byte + func (*RenameEventProto) Descriptor() ([]byte, []int) + 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 RenameRequestProto struct + Dst *string + Src *string + XXX_unrecognized []byte + func (*RenameRequestProto) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + func (*RenameSnapshotResponseProto) ProtoMessage() + func (m *RenameSnapshotResponseProto) Reset() + func (m *RenameSnapshotResponseProto) String() string + type RenewLeaseRequestProto struct + ClientName *string + XXX_unrecognized []byte + func (*RenewLeaseRequestProto) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + func (*RenewLeaseResponseProto) ProtoMessage() + func (m *RenewLeaseResponseProto) Reset() + func (m *RenewLeaseResponseProto) String() string + type ReportBadBlocksRequestProto struct + Blocks []*LocatedBlockProto + XXX_unrecognized []byte + func (*ReportBadBlocksRequestProto) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + func (*ReportBadBlocksResponseProto) ProtoMessage() + func (m *ReportBadBlocksResponseProto) Reset() + func (m *ReportBadBlocksResponseProto) String() string + type RestoreFailedStorageRequestProto struct + Arg *string + XXX_unrecognized []byte + func (*RestoreFailedStorageRequestProto) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + func (*RollEditsRequestProto) ProtoMessage() + func (m *RollEditsRequestProto) Reset() + func (m *RollEditsRequestProto) String() string + type RollEditsResponseProto struct + NewSegmentTxId *uint64 + XXX_unrecognized []byte + func (*RollEditsResponseProto) Descriptor() ([]byte, []int) + func (*RollEditsResponseProto) ProtoMessage() + func (m *RollEditsResponseProto) GetNewSegmentTxId() uint64 + func (m *RollEditsResponseProto) Reset() + func (m *RollEditsResponseProto) String() string + type RollingUpgradeActionProto int32 + const RollingUpgradeActionProto_FINALIZE + const RollingUpgradeActionProto_QUERY + const RollingUpgradeActionProto_START + func (RollingUpgradeActionProto) EnumDescriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + func (*RollingUpgradeStatusProto) ProtoMessage() + func (m *RollingUpgradeStatusProto) GetBlockPoolId() string + func (m *RollingUpgradeStatusProto) GetFinalized() bool + func (m *RollingUpgradeStatusProto) Reset() + func (m *RollingUpgradeStatusProto) String() string + type SafeModeActionProto int32 + const SafeModeActionProto_SAFEMODE_ENTER + const SafeModeActionProto_SAFEMODE_FORCE_EXIT + const SafeModeActionProto_SAFEMODE_GET + const SafeModeActionProto_SAFEMODE_LEAVE + func (SafeModeActionProto) EnumDescriptor() ([]byte, []int) + func (x *SafeModeActionProto) UnmarshalJSON(data []byte) error + func (x SafeModeActionProto) Enum() *SafeModeActionProto + func (x SafeModeActionProto) String() string + type SaveNamespaceRequestProto struct + TimeWindow *uint64 + TxGap *uint64 + XXX_unrecognized []byte + func (*SaveNamespaceRequestProto) Descriptor() ([]byte, []int) + func (*SaveNamespaceRequestProto) ProtoMessage() + func (m *SaveNamespaceRequestProto) GetTimeWindow() uint64 + func (m *SaveNamespaceRequestProto) GetTxGap() uint64 + func (m *SaveNamespaceRequestProto) Reset() + func (m *SaveNamespaceRequestProto) String() string + type SaveNamespaceResponseProto struct + Saved *bool + XXX_unrecognized []byte + func (*SaveNamespaceResponseProto) Descriptor() ([]byte, []int) + func (*SaveNamespaceResponseProto) ProtoMessage() + func (m *SaveNamespaceResponseProto) GetSaved() bool + func (m *SaveNamespaceResponseProto) Reset() + func (m *SaveNamespaceResponseProto) String() string + type SetAclRequestProto struct + AclSpec []*AclEntryProto + Src *string + XXX_unrecognized []byte + func (*SetAclRequestProto) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + func (*SetAclResponseProto) ProtoMessage() + func (m *SetAclResponseProto) Reset() + func (m *SetAclResponseProto) String() string + type SetBalancerBandwidthRequestProto struct + Bandwidth *int64 + XXX_unrecognized []byte + func (*SetBalancerBandwidthRequestProto) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + func (*SetBalancerBandwidthResponseProto) ProtoMessage() + func (m *SetBalancerBandwidthResponseProto) Reset() + func (m *SetBalancerBandwidthResponseProto) String() string + type SetErasureCodingPolicyRequestProto struct + EcPolicy *ErasureCodingPolicyProto + Src *string + XXX_unrecognized []byte + func (*SetErasureCodingPolicyRequestProto) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + func (*SetErasureCodingPolicyResponseProto) ProtoMessage() + func (m *SetErasureCodingPolicyResponseProto) Reset() + func (m *SetErasureCodingPolicyResponseProto) String() string + type SetOwnerRequestProto struct + Groupname *string + Src *string + Username *string + XXX_unrecognized []byte + func (*SetOwnerRequestProto) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + func (*SetOwnerResponseProto) ProtoMessage() + func (m *SetOwnerResponseProto) Reset() + func (m *SetOwnerResponseProto) String() string + type SetPermissionRequestProto struct + Permission *FsPermissionProto + Src *string + XXX_unrecognized []byte + func (*SetPermissionRequestProto) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + func (*SetPermissionResponseProto) ProtoMessage() + func (m *SetPermissionResponseProto) Reset() + func (m *SetPermissionResponseProto) String() string + type SetQuotaRequestProto struct + NamespaceQuota *uint64 + Path *string + StorageType *StorageTypeProto + StoragespaceQuota *uint64 + XXX_unrecognized []byte + func (*SetQuotaRequestProto) Descriptor() ([]byte, []int) + func (*SetQuotaRequestProto) ProtoMessage() + func (m *SetQuotaRequestProto) GetNamespaceQuota() uint64 + func (m *SetQuotaRequestProto) GetPath() string + func (m *SetQuotaRequestProto) GetStorageType() StorageTypeProto + func (m *SetQuotaRequestProto) GetStoragespaceQuota() uint64 + func (m *SetQuotaRequestProto) Reset() + func (m *SetQuotaRequestProto) String() string + type SetQuotaResponseProto struct + XXX_unrecognized []byte + func (*SetQuotaResponseProto) Descriptor() ([]byte, []int) + func (*SetQuotaResponseProto) ProtoMessage() + func (m *SetQuotaResponseProto) Reset() + func (m *SetQuotaResponseProto) String() string + type SetReplicationRequestProto struct + Replication *uint32 + Src *string + XXX_unrecognized []byte + func (*SetReplicationRequestProto) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + func (*SetSafeModeResponseProto) ProtoMessage() + func (m *SetSafeModeResponseProto) GetResult() bool + func (m *SetSafeModeResponseProto) Reset() + func (m *SetSafeModeResponseProto) String() string + type SetStoragePolicyRequestProto struct + PolicyName *string + Src *string + XXX_unrecognized []byte + func (*SetStoragePolicyRequestProto) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + func (*SetStoragePolicyResponseProto) ProtoMessage() + func (m *SetStoragePolicyResponseProto) Reset() + func (m *SetStoragePolicyResponseProto) String() string + type SetTimesRequestProto struct + Atime *uint64 + Mtime *uint64 + Src *string + XXX_unrecognized []byte + func (*SetTimesRequestProto) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + func (*SetTimesResponseProto) ProtoMessage() + func (m *SetTimesResponseProto) Reset() + func (m *SetTimesResponseProto) String() string + type SetXAttrRequestProto struct + Flag *uint32 + Src *string + XAttr *XAttrProto + XXX_unrecognized []byte + func (*SetXAttrRequestProto) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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 (ShortCircuitFdResponse) EnumDescriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + func (*ShutdownDatanodeResponseProto) ProtoMessage() + func (m *ShutdownDatanodeResponseProto) Reset() + func (m *ShutdownDatanodeResponseProto) String() string + type SnapshotDiffReportEntryProto struct + Fullpath []byte + ModificationLabel *string + TargetPath []byte + XXX_unrecognized []byte + func (*SnapshotDiffReportEntryProto) Descriptor() ([]byte, []int) + func (*SnapshotDiffReportEntryProto) ProtoMessage() + func (m *SnapshotDiffReportEntryProto) GetFullpath() []byte + func (m *SnapshotDiffReportEntryProto) GetModificationLabel() string + func (m *SnapshotDiffReportEntryProto) GetTargetPath() []byte + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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 StartReconfigurationRequestProto struct + XXX_unrecognized []byte + func (*StartReconfigurationRequestProto) Descriptor() ([]byte, []int) + func (*StartReconfigurationRequestProto) ProtoMessage() + func (m *StartReconfigurationRequestProto) Reset() + func (m *StartReconfigurationRequestProto) String() string + type StartReconfigurationResponseProto struct + XXX_unrecognized []byte + func (*StartReconfigurationResponseProto) Descriptor() ([]byte, []int) + func (*StartReconfigurationResponseProto) ProtoMessage() + func (m *StartReconfigurationResponseProto) Reset() + func (m *StartReconfigurationResponseProto) 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_IN_PROGRESS + const Status_OOB_RESERVED1 + const Status_OOB_RESERVED2 + const Status_OOB_RESERVED3 + const Status_OOB_RESTART + const Status_SUCCESS + func (Status) EnumDescriptor() ([]byte, []int) + func (x *Status) UnmarshalJSON(data []byte) error + func (x Status) Enum() *Status + func (x Status) String() string + type StorageReportProto struct + BlockPoolUsed *uint64 + Capacity *uint64 + DfsUsed *uint64 + Failed *bool + Remaining *uint64 + Storage *DatanodeStorageProto + StorageUuid *string + XXX_unrecognized []byte + func (*StorageReportProto) Descriptor() ([]byte, []int) + 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 (StorageTypeProto) EnumDescriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + func (*UnsetStoragePolicyResponseProto) ProtoMessage() + func (m *UnsetStoragePolicyResponseProto) Reset() + func (m *UnsetStoragePolicyResponseProto) String() string + type UpdateBlockForPipelineRequestProto struct + Block *ExtendedBlockProto + ClientName *string + XXX_unrecognized []byte + func (*UpdateBlockForPipelineRequestProto) Descriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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 + StorageIDs []string + XXX_unrecognized []byte + func (*UpdatePipelineRequestProto) Descriptor() ([]byte, []int) + 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) GetStorageIDs() []string + func (m *UpdatePipelineRequestProto) Reset() + func (m *UpdatePipelineRequestProto) String() string + type UpdatePipelineResponseProto struct + XXX_unrecognized []byte + func (*UpdatePipelineResponseProto) Descriptor() ([]byte, []int) + func (*UpdatePipelineResponseProto) ProtoMessage() + func (m *UpdatePipelineResponseProto) Reset() + func (m *UpdatePipelineResponseProto) String() string + type XAttrProto struct + Name *string + Namespace *XAttrProto_XAttrNamespaceProto + Value []byte + XXX_unrecognized []byte + func (*XAttrProto) Descriptor() ([]byte, []int) + 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 (XAttrProto_XAttrNamespaceProto) EnumDescriptor() ([]byte, []int) + 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 (XAttrSetFlagProto) EnumDescriptor() ([]byte, []int) + 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) Descriptor() ([]byte, []int) + 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
Go to main page