Documentation
¶
Overview ¶
Package hadoop_hdfs is a generated protocol buffer package.
It is generated from these files:
ReconfigurationProtocol.proto xattr.proto encryption.proto erasurecoding.proto ClientNamenodeProtocol.proto datatransfer.proto ClientDatanodeProtocol.proto inotify.proto hdfs.proto acl.proto
It has these top-level messages:
StartReconfigurationRequestProto StartReconfigurationResponseProto GetReconfigurationStatusRequestProto GetReconfigurationStatusConfigChangeProto GetReconfigurationStatusResponseProto ListReconfigurablePropertiesRequestProto ListReconfigurablePropertiesResponseProto XAttrProto SetXAttrRequestProto SetXAttrResponseProto GetXAttrsRequestProto GetXAttrsResponseProto ListXAttrsRequestProto ListXAttrsResponseProto RemoveXAttrRequestProto RemoveXAttrResponseProto CreateEncryptionZoneRequestProto CreateEncryptionZoneResponseProto ListEncryptionZonesRequestProto EncryptionZoneProto ListEncryptionZonesResponseProto GetEZForPathRequestProto GetEZForPathResponseProto SetErasureCodingPolicyRequestProto SetErasureCodingPolicyResponseProto GetErasureCodingPoliciesRequestProto GetErasureCodingPoliciesResponseProto GetErasureCodingPolicyRequestProto GetErasureCodingPolicyResponseProto BlockECReconstructionInfoProto GetBlockLocationsRequestProto GetBlockLocationsResponseProto GetServerDefaultsRequestProto GetServerDefaultsResponseProto CreateRequestProto CreateResponseProto AppendRequestProto AppendResponseProto SetReplicationRequestProto SetReplicationResponseProto SetStoragePolicyRequestProto SetStoragePolicyResponseProto UnsetStoragePolicyRequestProto UnsetStoragePolicyResponseProto GetStoragePolicyRequestProto GetStoragePolicyResponseProto GetStoragePoliciesRequestProto GetStoragePoliciesResponseProto SetPermissionRequestProto SetPermissionResponseProto SetOwnerRequestProto SetOwnerResponseProto AbandonBlockRequestProto AbandonBlockResponseProto AddBlockRequestProto AddBlockResponseProto GetAdditionalDatanodeRequestProto GetAdditionalDatanodeResponseProto CompleteRequestProto CompleteResponseProto ReportBadBlocksRequestProto ReportBadBlocksResponseProto ConcatRequestProto ConcatResponseProto TruncateRequestProto TruncateResponseProto RenameRequestProto RenameResponseProto Rename2RequestProto Rename2ResponseProto DeleteRequestProto DeleteResponseProto MkdirsRequestProto MkdirsResponseProto GetListingRequestProto GetListingResponseProto GetSnapshottableDirListingRequestProto GetSnapshottableDirListingResponseProto GetSnapshotDiffReportRequestProto GetSnapshotDiffReportResponseProto RenewLeaseRequestProto RenewLeaseResponseProto RecoverLeaseRequestProto RecoverLeaseResponseProto GetFsStatusRequestProto GetFsStatsResponseProto GetDatanodeReportRequestProto GetDatanodeReportResponseProto GetDatanodeStorageReportRequestProto DatanodeStorageReportProto GetDatanodeStorageReportResponseProto GetPreferredBlockSizeRequestProto GetPreferredBlockSizeResponseProto SetSafeModeRequestProto SetSafeModeResponseProto SaveNamespaceRequestProto SaveNamespaceResponseProto RollEditsRequestProto RollEditsResponseProto RestoreFailedStorageRequestProto RestoreFailedStorageResponseProto RefreshNodesRequestProto RefreshNodesResponseProto FinalizeUpgradeRequestProto FinalizeUpgradeResponseProto RollingUpgradeRequestProto RollingUpgradeInfoProto RollingUpgradeResponseProto ListCorruptFileBlocksRequestProto ListCorruptFileBlocksResponseProto MetaSaveRequestProto MetaSaveResponseProto GetFileInfoRequestProto GetFileInfoResponseProto IsFileClosedRequestProto IsFileClosedResponseProto CacheDirectiveInfoProto CacheDirectiveInfoExpirationProto CacheDirectiveStatsProto AddCacheDirectiveRequestProto AddCacheDirectiveResponseProto ModifyCacheDirectiveRequestProto ModifyCacheDirectiveResponseProto RemoveCacheDirectiveRequestProto RemoveCacheDirectiveResponseProto ListCacheDirectivesRequestProto CacheDirectiveEntryProto ListCacheDirectivesResponseProto CachePoolInfoProto CachePoolStatsProto AddCachePoolRequestProto AddCachePoolResponseProto ModifyCachePoolRequestProto ModifyCachePoolResponseProto RemoveCachePoolRequestProto RemoveCachePoolResponseProto ListCachePoolsRequestProto ListCachePoolsResponseProto CachePoolEntryProto GetFileLinkInfoRequestProto GetFileLinkInfoResponseProto GetContentSummaryRequestProto GetContentSummaryResponseProto GetQuotaUsageRequestProto GetQuotaUsageResponseProto SetQuotaRequestProto SetQuotaResponseProto FsyncRequestProto FsyncResponseProto SetTimesRequestProto SetTimesResponseProto CreateSymlinkRequestProto CreateSymlinkResponseProto GetLinkTargetRequestProto GetLinkTargetResponseProto UpdateBlockForPipelineRequestProto UpdateBlockForPipelineResponseProto UpdatePipelineRequestProto UpdatePipelineResponseProto SetBalancerBandwidthRequestProto SetBalancerBandwidthResponseProto GetDataEncryptionKeyRequestProto GetDataEncryptionKeyResponseProto CreateSnapshotRequestProto CreateSnapshotResponseProto RenameSnapshotRequestProto RenameSnapshotResponseProto AllowSnapshotRequestProto AllowSnapshotResponseProto DisallowSnapshotRequestProto DisallowSnapshotResponseProto DeleteSnapshotRequestProto DeleteSnapshotResponseProto CheckAccessRequestProto CheckAccessResponseProto GetCurrentEditLogTxidRequestProto GetCurrentEditLogTxidResponseProto GetEditsFromTxidRequestProto GetEditsFromTxidResponseProto DataTransferEncryptorMessageProto BaseHeaderProto DataTransferTraceInfoProto ClientOperationHeaderProto CachingStrategyProto OpReadBlockProto ChecksumProto OpWriteBlockProto OpTransferBlockProto OpReplaceBlockProto OpCopyBlockProto OpBlockChecksumProto OpBlockGroupChecksumProto ShortCircuitShmIdProto ShortCircuitShmSlotProto OpRequestShortCircuitAccessProto ReleaseShortCircuitAccessRequestProto ReleaseShortCircuitAccessResponseProto ShortCircuitShmRequestProto ShortCircuitShmResponseProto PacketHeaderProto PipelineAckProto ReadOpChecksumInfoProto BlockOpResponseProto ClientReadStatusProto DNTransferAckProto OpBlockChecksumResponseProto OpCustomProto GetReplicaVisibleLengthRequestProto GetReplicaVisibleLengthResponseProto RefreshNamenodesRequestProto RefreshNamenodesResponseProto DeleteBlockPoolRequestProto DeleteBlockPoolResponseProto GetBlockLocalPathInfoRequestProto GetBlockLocalPathInfoResponseProto ShutdownDatanodeRequestProto ShutdownDatanodeResponseProto EvictWritersRequestProto EvictWritersResponseProto GetDatanodeInfoRequestProto GetDatanodeInfoResponseProto TriggerBlockReportRequestProto TriggerBlockReportResponseProto GetBalancerBandwidthRequestProto GetBalancerBandwidthResponseProto EventProto EventBatchProto CreateEventProto CloseEventProto TruncateEventProto AppendEventProto RenameEventProto MetadataUpdateEventProto UnlinkEventProto EventsListProto ExtendedBlockProto DatanodeIDProto DatanodeLocalInfoProto DatanodeInfosProto DatanodeInfoProto DatanodeStorageProto StorageReportProto ContentSummaryProto QuotaUsageProto StorageTypeQuotaInfosProto StorageTypeQuotaInfoProto CorruptFileBlocksProto FsPermissionProto StorageTypesProto BlockStoragePolicyProto LocatedBlockProto DataEncryptionKeyProto FileEncryptionInfoProto PerFileEncryptionInfoProto ZoneEncryptionInfoProto CipherOptionProto LocatedBlocksProto ECSchemaOptionEntryProto ECSchemaProto ErasureCodingPolicyProto HdfsFileStatusProto FsServerDefaultsProto DirectoryListingProto SnapshottableDirectoryStatusProto SnapshottableDirectoryListingProto SnapshotDiffReportEntryProto SnapshotDiffReportProto BlockProto SnapshotInfoProto RollingUpgradeStatusProto StorageUuidsProto AclEntryProto AclStatusProto ModifyAclEntriesRequestProto ModifyAclEntriesResponseProto RemoveAclRequestProto RemoveAclResponseProto RemoveAclEntriesRequestProto RemoveAclEntriesResponseProto RemoveDefaultAclRequestProto RemoveDefaultAclResponseProto SetAclRequestProto SetAclResponseProto GetAclStatusRequestProto GetAclStatusResponseProto
Index ¶
- Constants
- Variables
- type AbandonBlockRequestProto
- func (*AbandonBlockRequestProto) Descriptor() ([]byte, []int)
- func (m *AbandonBlockRequestProto) GetB() *ExtendedBlockProto
- func (m *AbandonBlockRequestProto) GetFileId() uint64
- func (m *AbandonBlockRequestProto) GetHolder() string
- func (m *AbandonBlockRequestProto) GetSrc() string
- func (*AbandonBlockRequestProto) ProtoMessage()
- func (m *AbandonBlockRequestProto) Reset()
- func (m *AbandonBlockRequestProto) String() string
- type AbandonBlockResponseProto
- type AclEntryProto
- func (*AclEntryProto) Descriptor() ([]byte, []int)
- func (m *AclEntryProto) GetName() string
- func (m *AclEntryProto) GetPermissions() AclEntryProto_FsActionProto
- func (m *AclEntryProto) GetScope() AclEntryProto_AclEntryScopeProto
- func (m *AclEntryProto) GetType() AclEntryProto_AclEntryTypeProto
- func (*AclEntryProto) ProtoMessage()
- func (m *AclEntryProto) Reset()
- func (m *AclEntryProto) String() string
- type AclEntryProto_AclEntryScopeProto
- type AclEntryProto_AclEntryTypeProto
- type AclEntryProto_FsActionProto
- type AclStatusProto
- func (*AclStatusProto) Descriptor() ([]byte, []int)
- 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 (*AclStatusProto) ProtoMessage()
- func (m *AclStatusProto) Reset()
- func (m *AclStatusProto) String() string
- type AddBlockRequestProto
- func (*AddBlockRequestProto) Descriptor() ([]byte, []int)
- 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 (*AddBlockRequestProto) ProtoMessage()
- func (m *AddBlockRequestProto) Reset()
- func (m *AddBlockRequestProto) String() string
- type AddBlockResponseProto
- type AddCacheDirectiveRequestProto
- func (*AddCacheDirectiveRequestProto) Descriptor() ([]byte, []int)
- func (m *AddCacheDirectiveRequestProto) GetCacheFlags() uint32
- func (m *AddCacheDirectiveRequestProto) GetInfo() *CacheDirectiveInfoProto
- func (*AddCacheDirectiveRequestProto) ProtoMessage()
- func (m *AddCacheDirectiveRequestProto) Reset()
- func (m *AddCacheDirectiveRequestProto) String() string
- type AddCacheDirectiveResponseProto
- type AddCachePoolRequestProto
- type AddCachePoolResponseProto
- type AllowSnapshotRequestProto
- type AllowSnapshotResponseProto
- type AppendEventProto
- type AppendRequestProto
- func (*AppendRequestProto) Descriptor() ([]byte, []int)
- func (m *AppendRequestProto) GetClientName() string
- func (m *AppendRequestProto) GetFlag() uint32
- func (m *AppendRequestProto) GetSrc() string
- func (*AppendRequestProto) ProtoMessage()
- func (m *AppendRequestProto) Reset()
- func (m *AppendRequestProto) String() string
- type AppendResponseProto
- func (*AppendResponseProto) Descriptor() ([]byte, []int)
- func (m *AppendResponseProto) GetBlock() *LocatedBlockProto
- func (m *AppendResponseProto) GetStat() *HdfsFileStatusProto
- func (*AppendResponseProto) ProtoMessage()
- func (m *AppendResponseProto) Reset()
- func (m *AppendResponseProto) String() string
- type BaseHeaderProto
- func (*BaseHeaderProto) Descriptor() ([]byte, []int)
- func (m *BaseHeaderProto) GetBlock() *ExtendedBlockProto
- func (m *BaseHeaderProto) GetToken() *hadoop_common.TokenProto
- func (m *BaseHeaderProto) GetTraceInfo() *DataTransferTraceInfoProto
- func (*BaseHeaderProto) ProtoMessage()
- func (m *BaseHeaderProto) Reset()
- func (m *BaseHeaderProto) String() string
- type BlockECReconstructionInfoProto
- func (*BlockECReconstructionInfoProto) Descriptor() ([]byte, []int)
- 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 (*BlockECReconstructionInfoProto) ProtoMessage()
- func (m *BlockECReconstructionInfoProto) Reset()
- func (m *BlockECReconstructionInfoProto) String() string
- type BlockOpResponseProto
- func (*BlockOpResponseProto) Descriptor() ([]byte, []int)
- 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 (*BlockOpResponseProto) ProtoMessage()
- func (m *BlockOpResponseProto) Reset()
- func (m *BlockOpResponseProto) String() string
- type BlockProto
- type BlockStoragePolicyProto
- func (*BlockStoragePolicyProto) Descriptor() ([]byte, []int)
- 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 (*BlockStoragePolicyProto) ProtoMessage()
- func (m *BlockStoragePolicyProto) Reset()
- func (m *BlockStoragePolicyProto) String() string
- type CacheDirectiveEntryProto
- func (*CacheDirectiveEntryProto) Descriptor() ([]byte, []int)
- func (m *CacheDirectiveEntryProto) GetInfo() *CacheDirectiveInfoProto
- func (m *CacheDirectiveEntryProto) GetStats() *CacheDirectiveStatsProto
- func (*CacheDirectiveEntryProto) ProtoMessage()
- func (m *CacheDirectiveEntryProto) Reset()
- func (m *CacheDirectiveEntryProto) String() string
- type CacheDirectiveInfoExpirationProto
- func (*CacheDirectiveInfoExpirationProto) Descriptor() ([]byte, []int)
- func (m *CacheDirectiveInfoExpirationProto) GetIsRelative() bool
- func (m *CacheDirectiveInfoExpirationProto) GetMillis() int64
- func (*CacheDirectiveInfoExpirationProto) ProtoMessage()
- func (m *CacheDirectiveInfoExpirationProto) Reset()
- func (m *CacheDirectiveInfoExpirationProto) String() string
- type CacheDirectiveInfoProto
- func (*CacheDirectiveInfoProto) Descriptor() ([]byte, []int)
- 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 (*CacheDirectiveInfoProto) ProtoMessage()
- func (m *CacheDirectiveInfoProto) Reset()
- func (m *CacheDirectiveInfoProto) String() string
- type CacheDirectiveStatsProto
- func (*CacheDirectiveStatsProto) Descriptor() ([]byte, []int)
- 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 (*CacheDirectiveStatsProto) ProtoMessage()
- func (m *CacheDirectiveStatsProto) Reset()
- func (m *CacheDirectiveStatsProto) String() string
- type CacheFlagProto
- type CachePoolEntryProto
- func (*CachePoolEntryProto) Descriptor() ([]byte, []int)
- func (m *CachePoolEntryProto) GetInfo() *CachePoolInfoProto
- func (m *CachePoolEntryProto) GetStats() *CachePoolStatsProto
- func (*CachePoolEntryProto) ProtoMessage()
- func (m *CachePoolEntryProto) Reset()
- func (m *CachePoolEntryProto) String() string
- type CachePoolInfoProto
- func (*CachePoolInfoProto) Descriptor() ([]byte, []int)
- 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 (*CachePoolInfoProto) ProtoMessage()
- func (m *CachePoolInfoProto) Reset()
- func (m *CachePoolInfoProto) String() string
- type CachePoolStatsProto
- func (*CachePoolStatsProto) Descriptor() ([]byte, []int)
- 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 (*CachePoolStatsProto) ProtoMessage()
- func (m *CachePoolStatsProto) Reset()
- func (m *CachePoolStatsProto) String() string
- type CachingStrategyProto
- type CheckAccessRequestProto
- func (*CheckAccessRequestProto) Descriptor() ([]byte, []int)
- func (m *CheckAccessRequestProto) GetMode() AclEntryProto_FsActionProto
- func (m *CheckAccessRequestProto) GetPath() string
- func (*CheckAccessRequestProto) ProtoMessage()
- func (m *CheckAccessRequestProto) Reset()
- func (m *CheckAccessRequestProto) String() string
- type CheckAccessResponseProto
- type ChecksumProto
- type ChecksumTypeProto
- type CipherOptionProto
- func (*CipherOptionProto) Descriptor() ([]byte, []int)
- 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 (*CipherOptionProto) ProtoMessage()
- func (m *CipherOptionProto) Reset()
- func (m *CipherOptionProto) String() string
- type CipherSuiteProto
- type ClientOperationHeaderProto
- func (*ClientOperationHeaderProto) Descriptor() ([]byte, []int)
- func (m *ClientOperationHeaderProto) GetBaseHeader() *BaseHeaderProto
- func (m *ClientOperationHeaderProto) GetClientName() string
- func (*ClientOperationHeaderProto) ProtoMessage()
- func (m *ClientOperationHeaderProto) Reset()
- func (m *ClientOperationHeaderProto) String() string
- type ClientReadStatusProto
- type CloseEventProto
- func (*CloseEventProto) Descriptor() ([]byte, []int)
- func (m *CloseEventProto) GetFileSize() int64
- func (m *CloseEventProto) GetPath() string
- func (m *CloseEventProto) GetTimestamp() int64
- func (*CloseEventProto) ProtoMessage()
- func (m *CloseEventProto) Reset()
- func (m *CloseEventProto) String() string
- type CompleteRequestProto
- func (*CompleteRequestProto) Descriptor() ([]byte, []int)
- func (m *CompleteRequestProto) GetClientName() string
- func (m *CompleteRequestProto) GetFileId() uint64
- func (m *CompleteRequestProto) GetLast() *ExtendedBlockProto
- func (m *CompleteRequestProto) GetSrc() string
- func (*CompleteRequestProto) ProtoMessage()
- func (m *CompleteRequestProto) Reset()
- func (m *CompleteRequestProto) String() string
- type CompleteResponseProto
- type ConcatRequestProto
- type ConcatResponseProto
- type ContentSummaryProto
- func (*ContentSummaryProto) Descriptor() ([]byte, []int)
- 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 (*ContentSummaryProto) ProtoMessage()
- func (m *ContentSummaryProto) Reset()
- func (m *ContentSummaryProto) String() string
- type CorruptFileBlocksProto
- func (*CorruptFileBlocksProto) Descriptor() ([]byte, []int)
- func (m *CorruptFileBlocksProto) GetCookie() string
- func (m *CorruptFileBlocksProto) GetFiles() []string
- func (*CorruptFileBlocksProto) ProtoMessage()
- func (m *CorruptFileBlocksProto) Reset()
- func (m *CorruptFileBlocksProto) String() string
- type CreateEncryptionZoneRequestProto
- func (*CreateEncryptionZoneRequestProto) Descriptor() ([]byte, []int)
- func (m *CreateEncryptionZoneRequestProto) GetKeyName() string
- func (m *CreateEncryptionZoneRequestProto) GetSrc() string
- func (*CreateEncryptionZoneRequestProto) ProtoMessage()
- func (m *CreateEncryptionZoneRequestProto) Reset()
- func (m *CreateEncryptionZoneRequestProto) String() string
- type CreateEncryptionZoneResponseProto
- type CreateEventProto
- func (*CreateEventProto) Descriptor() ([]byte, []int)
- 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 (*CreateEventProto) ProtoMessage()
- func (m *CreateEventProto) Reset()
- func (m *CreateEventProto) String() string
- type CreateFlagProto
- type CreateRequestProto
- func (*CreateRequestProto) Descriptor() ([]byte, []int)
- 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 (*CreateRequestProto) ProtoMessage()
- func (m *CreateRequestProto) Reset()
- func (m *CreateRequestProto) String() string
- type CreateResponseProto
- type CreateSnapshotRequestProto
- func (*CreateSnapshotRequestProto) Descriptor() ([]byte, []int)
- func (m *CreateSnapshotRequestProto) GetSnapshotName() string
- func (m *CreateSnapshotRequestProto) GetSnapshotRoot() string
- func (*CreateSnapshotRequestProto) ProtoMessage()
- func (m *CreateSnapshotRequestProto) Reset()
- func (m *CreateSnapshotRequestProto) String() string
- type CreateSnapshotResponseProto
- type CreateSymlinkRequestProto
- func (*CreateSymlinkRequestProto) Descriptor() ([]byte, []int)
- func (m *CreateSymlinkRequestProto) GetCreateParent() bool
- func (m *CreateSymlinkRequestProto) GetDirPerm() *FsPermissionProto
- func (m *CreateSymlinkRequestProto) GetLink() string
- func (m *CreateSymlinkRequestProto) GetTarget() string
- func (*CreateSymlinkRequestProto) ProtoMessage()
- func (m *CreateSymlinkRequestProto) Reset()
- func (m *CreateSymlinkRequestProto) String() string
- type CreateSymlinkResponseProto
- type CryptoProtocolVersionProto
- type DNTransferAckProto
- type DataEncryptionKeyProto
- func (*DataEncryptionKeyProto) Descriptor() ([]byte, []int)
- 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 (*DataEncryptionKeyProto) ProtoMessage()
- func (m *DataEncryptionKeyProto) Reset()
- func (m *DataEncryptionKeyProto) String() string
- type DataTransferEncryptorMessageProto
- func (*DataTransferEncryptorMessageProto) Descriptor() ([]byte, []int)
- func (m *DataTransferEncryptorMessageProto) GetCipherOption() []*CipherOptionProto
- func (m *DataTransferEncryptorMessageProto) GetMessage() string
- func (m *DataTransferEncryptorMessageProto) GetPayload() []byte
- func (m *DataTransferEncryptorMessageProto) GetStatus() DataTransferEncryptorMessageProto_DataTransferEncryptorStatus
- func (*DataTransferEncryptorMessageProto) ProtoMessage()
- func (m *DataTransferEncryptorMessageProto) Reset()
- func (m *DataTransferEncryptorMessageProto) String() string
- type DataTransferEncryptorMessageProto_DataTransferEncryptorStatus
- func (x DataTransferEncryptorMessageProto_DataTransferEncryptorStatus) Enum() *DataTransferEncryptorMessageProto_DataTransferEncryptorStatus
- func (DataTransferEncryptorMessageProto_DataTransferEncryptorStatus) EnumDescriptor() ([]byte, []int)
- func (x DataTransferEncryptorMessageProto_DataTransferEncryptorStatus) String() string
- func (x *DataTransferEncryptorMessageProto_DataTransferEncryptorStatus) UnmarshalJSON(data []byte) error
- type DataTransferTraceInfoProto
- func (*DataTransferTraceInfoProto) Descriptor() ([]byte, []int)
- func (m *DataTransferTraceInfoProto) GetParentId() uint64
- func (m *DataTransferTraceInfoProto) GetTraceId() uint64
- func (*DataTransferTraceInfoProto) ProtoMessage()
- func (m *DataTransferTraceInfoProto) Reset()
- func (m *DataTransferTraceInfoProto) String() string
- type DatanodeIDProto
- func (*DatanodeIDProto) Descriptor() ([]byte, []int)
- 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 (*DatanodeIDProto) ProtoMessage()
- func (m *DatanodeIDProto) Reset()
- func (m *DatanodeIDProto) String() string
- type DatanodeInfoProto
- func (*DatanodeInfoProto) Descriptor() ([]byte, []int)
- 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 (*DatanodeInfoProto) ProtoMessage()
- func (m *DatanodeInfoProto) Reset()
- func (m *DatanodeInfoProto) String() string
- type DatanodeInfoProto_AdminState
- type DatanodeInfosProto
- type DatanodeLocalInfoProto
- func (*DatanodeLocalInfoProto) Descriptor() ([]byte, []int)
- func (m *DatanodeLocalInfoProto) GetConfigVersion() string
- func (m *DatanodeLocalInfoProto) GetSoftwareVersion() string
- func (m *DatanodeLocalInfoProto) GetUptime() uint64
- func (*DatanodeLocalInfoProto) ProtoMessage()
- func (m *DatanodeLocalInfoProto) Reset()
- func (m *DatanodeLocalInfoProto) String() string
- type DatanodeReportTypeProto
- type DatanodeStorageProto
- func (*DatanodeStorageProto) Descriptor() ([]byte, []int)
- func (m *DatanodeStorageProto) GetState() DatanodeStorageProto_StorageState
- func (m *DatanodeStorageProto) GetStorageType() StorageTypeProto
- func (m *DatanodeStorageProto) GetStorageUuid() string
- func (*DatanodeStorageProto) ProtoMessage()
- func (m *DatanodeStorageProto) Reset()
- func (m *DatanodeStorageProto) String() string
- type DatanodeStorageProto_StorageState
- type DatanodeStorageReportProto
- func (*DatanodeStorageReportProto) Descriptor() ([]byte, []int)
- func (m *DatanodeStorageReportProto) GetDatanodeInfo() *DatanodeInfoProto
- func (m *DatanodeStorageReportProto) GetStorageReports() []*StorageReportProto
- func (*DatanodeStorageReportProto) ProtoMessage()
- func (m *DatanodeStorageReportProto) Reset()
- func (m *DatanodeStorageReportProto) String() string
- type DeleteBlockPoolRequestProto
- func (*DeleteBlockPoolRequestProto) Descriptor() ([]byte, []int)
- func (m *DeleteBlockPoolRequestProto) GetBlockPool() string
- func (m *DeleteBlockPoolRequestProto) GetForce() bool
- func (*DeleteBlockPoolRequestProto) ProtoMessage()
- func (m *DeleteBlockPoolRequestProto) Reset()
- func (m *DeleteBlockPoolRequestProto) String() string
- type DeleteBlockPoolResponseProto
- type DeleteRequestProto
- type DeleteResponseProto
- type DeleteSnapshotRequestProto
- func (*DeleteSnapshotRequestProto) Descriptor() ([]byte, []int)
- func (m *DeleteSnapshotRequestProto) GetSnapshotName() string
- func (m *DeleteSnapshotRequestProto) GetSnapshotRoot() string
- func (*DeleteSnapshotRequestProto) ProtoMessage()
- func (m *DeleteSnapshotRequestProto) Reset()
- func (m *DeleteSnapshotRequestProto) String() string
- type DeleteSnapshotResponseProto
- type DirectoryListingProto
- func (*DirectoryListingProto) Descriptor() ([]byte, []int)
- func (m *DirectoryListingProto) GetPartialListing() []*HdfsFileStatusProto
- func (m *DirectoryListingProto) GetRemainingEntries() uint32
- func (*DirectoryListingProto) ProtoMessage()
- func (m *DirectoryListingProto) Reset()
- func (m *DirectoryListingProto) String() string
- type DisallowSnapshotRequestProto
- type DisallowSnapshotResponseProto
- type ECSchemaOptionEntryProto
- func (*ECSchemaOptionEntryProto) Descriptor() ([]byte, []int)
- func (m *ECSchemaOptionEntryProto) GetKey() string
- func (m *ECSchemaOptionEntryProto) GetValue() string
- func (*ECSchemaOptionEntryProto) ProtoMessage()
- func (m *ECSchemaOptionEntryProto) Reset()
- func (m *ECSchemaOptionEntryProto) String() string
- type ECSchemaProto
- func (*ECSchemaProto) Descriptor() ([]byte, []int)
- func (m *ECSchemaProto) GetCodecName() string
- func (m *ECSchemaProto) GetDataUnits() uint32
- func (m *ECSchemaProto) GetOptions() []*ECSchemaOptionEntryProto
- func (m *ECSchemaProto) GetParityUnits() uint32
- func (*ECSchemaProto) ProtoMessage()
- func (m *ECSchemaProto) Reset()
- func (m *ECSchemaProto) String() string
- type EncryptionZoneProto
- func (*EncryptionZoneProto) Descriptor() ([]byte, []int)
- 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 (*EncryptionZoneProto) ProtoMessage()
- func (m *EncryptionZoneProto) Reset()
- func (m *EncryptionZoneProto) String() string
- type ErasureCodingPolicyProto
- func (*ErasureCodingPolicyProto) Descriptor() ([]byte, []int)
- func (m *ErasureCodingPolicyProto) GetCellSize() uint32
- func (m *ErasureCodingPolicyProto) GetId() uint32
- func (m *ErasureCodingPolicyProto) GetName() string
- func (m *ErasureCodingPolicyProto) GetSchema() *ECSchemaProto
- func (*ErasureCodingPolicyProto) ProtoMessage()
- func (m *ErasureCodingPolicyProto) Reset()
- func (m *ErasureCodingPolicyProto) String() string
- type EventBatchProto
- type EventProto
- type EventType
- type EventsListProto
- func (*EventsListProto) Descriptor() ([]byte, []int)
- 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 (*EventsListProto) ProtoMessage()
- func (m *EventsListProto) Reset()
- func (m *EventsListProto) String() string
- type EvictWritersRequestProto
- type EvictWritersResponseProto
- type ExtendedBlockProto
- func (*ExtendedBlockProto) Descriptor() ([]byte, []int)
- func (m *ExtendedBlockProto) GetBlockId() uint64
- func (m *ExtendedBlockProto) GetGenerationStamp() uint64
- func (m *ExtendedBlockProto) GetNumBytes() uint64
- func (m *ExtendedBlockProto) GetPoolId() string
- func (*ExtendedBlockProto) ProtoMessage()
- func (m *ExtendedBlockProto) Reset()
- func (m *ExtendedBlockProto) String() string
- type FileEncryptionInfoProto
- func (*FileEncryptionInfoProto) Descriptor() ([]byte, []int)
- 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 (*FileEncryptionInfoProto) ProtoMessage()
- func (m *FileEncryptionInfoProto) Reset()
- func (m *FileEncryptionInfoProto) String() string
- type FinalizeUpgradeRequestProto
- type FinalizeUpgradeResponseProto
- type FsPermissionProto
- type FsServerDefaultsProto
- func (*FsServerDefaultsProto) Descriptor() ([]byte, []int)
- 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 (*FsServerDefaultsProto) ProtoMessage()
- func (m *FsServerDefaultsProto) Reset()
- func (m *FsServerDefaultsProto) String() string
- type FsyncRequestProto
- func (*FsyncRequestProto) Descriptor() ([]byte, []int)
- func (m *FsyncRequestProto) GetClient() string
- func (m *FsyncRequestProto) GetFileId() uint64
- func (m *FsyncRequestProto) GetLastBlockLength() int64
- func (m *FsyncRequestProto) GetSrc() string
- func (*FsyncRequestProto) ProtoMessage()
- func (m *FsyncRequestProto) Reset()
- func (m *FsyncRequestProto) String() string
- type FsyncResponseProto
- type GetAclStatusRequestProto
- type GetAclStatusResponseProto
- type GetAdditionalDatanodeRequestProto
- func (*GetAdditionalDatanodeRequestProto) Descriptor() ([]byte, []int)
- 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 (*GetAdditionalDatanodeRequestProto) ProtoMessage()
- func (m *GetAdditionalDatanodeRequestProto) Reset()
- func (m *GetAdditionalDatanodeRequestProto) String() string
- type GetAdditionalDatanodeResponseProto
- func (*GetAdditionalDatanodeResponseProto) Descriptor() ([]byte, []int)
- func (m *GetAdditionalDatanodeResponseProto) GetBlock() *LocatedBlockProto
- func (*GetAdditionalDatanodeResponseProto) ProtoMessage()
- func (m *GetAdditionalDatanodeResponseProto) Reset()
- func (m *GetAdditionalDatanodeResponseProto) String() string
- type GetBalancerBandwidthRequestProto
- type GetBalancerBandwidthResponseProto
- func (*GetBalancerBandwidthResponseProto) Descriptor() ([]byte, []int)
- func (m *GetBalancerBandwidthResponseProto) GetBandwidth() uint64
- func (*GetBalancerBandwidthResponseProto) ProtoMessage()
- func (m *GetBalancerBandwidthResponseProto) Reset()
- func (m *GetBalancerBandwidthResponseProto) String() string
- type GetBlockLocalPathInfoRequestProto
- func (*GetBlockLocalPathInfoRequestProto) Descriptor() ([]byte, []int)
- func (m *GetBlockLocalPathInfoRequestProto) GetBlock() *ExtendedBlockProto
- func (m *GetBlockLocalPathInfoRequestProto) GetToken() *hadoop_common.TokenProto
- func (*GetBlockLocalPathInfoRequestProto) ProtoMessage()
- func (m *GetBlockLocalPathInfoRequestProto) Reset()
- func (m *GetBlockLocalPathInfoRequestProto) String() string
- type GetBlockLocalPathInfoResponseProto
- func (*GetBlockLocalPathInfoResponseProto) Descriptor() ([]byte, []int)
- func (m *GetBlockLocalPathInfoResponseProto) GetBlock() *ExtendedBlockProto
- func (m *GetBlockLocalPathInfoResponseProto) GetLocalMetaPath() string
- func (m *GetBlockLocalPathInfoResponseProto) GetLocalPath() string
- func (*GetBlockLocalPathInfoResponseProto) ProtoMessage()
- func (m *GetBlockLocalPathInfoResponseProto) Reset()
- func (m *GetBlockLocalPathInfoResponseProto) String() string
- type GetBlockLocationsRequestProto
- func (*GetBlockLocationsRequestProto) Descriptor() ([]byte, []int)
- func (m *GetBlockLocationsRequestProto) GetLength() uint64
- func (m *GetBlockLocationsRequestProto) GetOffset() uint64
- func (m *GetBlockLocationsRequestProto) GetSrc() string
- func (*GetBlockLocationsRequestProto) ProtoMessage()
- func (m *GetBlockLocationsRequestProto) Reset()
- func (m *GetBlockLocationsRequestProto) String() string
- type GetBlockLocationsResponseProto
- func (*GetBlockLocationsResponseProto) Descriptor() ([]byte, []int)
- func (m *GetBlockLocationsResponseProto) GetLocations() *LocatedBlocksProto
- func (*GetBlockLocationsResponseProto) ProtoMessage()
- func (m *GetBlockLocationsResponseProto) Reset()
- func (m *GetBlockLocationsResponseProto) String() string
- type GetContentSummaryRequestProto
- type GetContentSummaryResponseProto
- func (*GetContentSummaryResponseProto) Descriptor() ([]byte, []int)
- func (m *GetContentSummaryResponseProto) GetSummary() *ContentSummaryProto
- func (*GetContentSummaryResponseProto) ProtoMessage()
- func (m *GetContentSummaryResponseProto) Reset()
- func (m *GetContentSummaryResponseProto) String() string
- type GetCurrentEditLogTxidRequestProto
- type GetCurrentEditLogTxidResponseProto
- func (*GetCurrentEditLogTxidResponseProto) Descriptor() ([]byte, []int)
- func (m *GetCurrentEditLogTxidResponseProto) GetTxid() int64
- func (*GetCurrentEditLogTxidResponseProto) ProtoMessage()
- func (m *GetCurrentEditLogTxidResponseProto) Reset()
- func (m *GetCurrentEditLogTxidResponseProto) String() string
- type GetDataEncryptionKeyRequestProto
- type GetDataEncryptionKeyResponseProto
- func (*GetDataEncryptionKeyResponseProto) Descriptor() ([]byte, []int)
- func (m *GetDataEncryptionKeyResponseProto) GetDataEncryptionKey() *DataEncryptionKeyProto
- func (*GetDataEncryptionKeyResponseProto) ProtoMessage()
- func (m *GetDataEncryptionKeyResponseProto) Reset()
- func (m *GetDataEncryptionKeyResponseProto) String() string
- type GetDatanodeInfoRequestProto
- type GetDatanodeInfoResponseProto
- type GetDatanodeReportRequestProto
- type GetDatanodeReportResponseProto
- type GetDatanodeStorageReportRequestProto
- func (*GetDatanodeStorageReportRequestProto) Descriptor() ([]byte, []int)
- func (m *GetDatanodeStorageReportRequestProto) GetType() DatanodeReportTypeProto
- func (*GetDatanodeStorageReportRequestProto) ProtoMessage()
- func (m *GetDatanodeStorageReportRequestProto) Reset()
- func (m *GetDatanodeStorageReportRequestProto) String() string
- type GetDatanodeStorageReportResponseProto
- func (*GetDatanodeStorageReportResponseProto) Descriptor() ([]byte, []int)
- func (m *GetDatanodeStorageReportResponseProto) GetDatanodeStorageReports() []*DatanodeStorageReportProto
- func (*GetDatanodeStorageReportResponseProto) ProtoMessage()
- func (m *GetDatanodeStorageReportResponseProto) Reset()
- func (m *GetDatanodeStorageReportResponseProto) String() string
- type GetEZForPathRequestProto
- type GetEZForPathResponseProto
- type GetEditsFromTxidRequestProto
- type GetEditsFromTxidResponseProto
- type GetErasureCodingPoliciesRequestProto
- type GetErasureCodingPoliciesResponseProto
- func (*GetErasureCodingPoliciesResponseProto) Descriptor() ([]byte, []int)
- func (m *GetErasureCodingPoliciesResponseProto) GetEcPolicies() []*ErasureCodingPolicyProto
- func (*GetErasureCodingPoliciesResponseProto) ProtoMessage()
- func (m *GetErasureCodingPoliciesResponseProto) Reset()
- func (m *GetErasureCodingPoliciesResponseProto) String() string
- type GetErasureCodingPolicyRequestProto
- func (*GetErasureCodingPolicyRequestProto) Descriptor() ([]byte, []int)
- func (m *GetErasureCodingPolicyRequestProto) GetSrc() string
- func (*GetErasureCodingPolicyRequestProto) ProtoMessage()
- func (m *GetErasureCodingPolicyRequestProto) Reset()
- func (m *GetErasureCodingPolicyRequestProto) String() string
- type GetErasureCodingPolicyResponseProto
- func (*GetErasureCodingPolicyResponseProto) Descriptor() ([]byte, []int)
- func (m *GetErasureCodingPolicyResponseProto) GetEcPolicy() *ErasureCodingPolicyProto
- func (*GetErasureCodingPolicyResponseProto) ProtoMessage()
- func (m *GetErasureCodingPolicyResponseProto) Reset()
- func (m *GetErasureCodingPolicyResponseProto) String() string
- type GetFileInfoRequestProto
- type GetFileInfoResponseProto
- type GetFileLinkInfoRequestProto
- type GetFileLinkInfoResponseProto
- type GetFsStatsResponseProto
- func (*GetFsStatsResponseProto) Descriptor() ([]byte, []int)
- 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 (*GetFsStatsResponseProto) ProtoMessage()
- func (m *GetFsStatsResponseProto) Reset()
- func (m *GetFsStatsResponseProto) String() string
- type GetFsStatusRequestProto
- type GetLinkTargetRequestProto
- type GetLinkTargetResponseProto
- type GetListingRequestProto
- func (*GetListingRequestProto) Descriptor() ([]byte, []int)
- func (m *GetListingRequestProto) GetNeedLocation() bool
- func (m *GetListingRequestProto) GetSrc() string
- func (m *GetListingRequestProto) GetStartAfter() []byte
- func (*GetListingRequestProto) ProtoMessage()
- func (m *GetListingRequestProto) Reset()
- func (m *GetListingRequestProto) String() string
- type GetListingResponseProto
- type GetPreferredBlockSizeRequestProto
- func (*GetPreferredBlockSizeRequestProto) Descriptor() ([]byte, []int)
- func (m *GetPreferredBlockSizeRequestProto) GetFilename() string
- func (*GetPreferredBlockSizeRequestProto) ProtoMessage()
- func (m *GetPreferredBlockSizeRequestProto) Reset()
- func (m *GetPreferredBlockSizeRequestProto) String() string
- type GetPreferredBlockSizeResponseProto
- func (*GetPreferredBlockSizeResponseProto) Descriptor() ([]byte, []int)
- func (m *GetPreferredBlockSizeResponseProto) GetBsize() uint64
- func (*GetPreferredBlockSizeResponseProto) ProtoMessage()
- func (m *GetPreferredBlockSizeResponseProto) Reset()
- func (m *GetPreferredBlockSizeResponseProto) String() string
- type GetQuotaUsageRequestProto
- type GetQuotaUsageResponseProto
- type GetReconfigurationStatusConfigChangeProto
- func (*GetReconfigurationStatusConfigChangeProto) Descriptor() ([]byte, []int)
- func (m *GetReconfigurationStatusConfigChangeProto) GetErrorMessage() string
- func (m *GetReconfigurationStatusConfigChangeProto) GetName() string
- func (m *GetReconfigurationStatusConfigChangeProto) GetNewValue() string
- func (m *GetReconfigurationStatusConfigChangeProto) GetOldValue() string
- func (*GetReconfigurationStatusConfigChangeProto) ProtoMessage()
- func (m *GetReconfigurationStatusConfigChangeProto) Reset()
- func (m *GetReconfigurationStatusConfigChangeProto) String() string
- type GetReconfigurationStatusRequestProto
- type GetReconfigurationStatusResponseProto
- func (*GetReconfigurationStatusResponseProto) Descriptor() ([]byte, []int)
- func (m *GetReconfigurationStatusResponseProto) GetChanges() []*GetReconfigurationStatusConfigChangeProto
- func (m *GetReconfigurationStatusResponseProto) GetEndTime() int64
- func (m *GetReconfigurationStatusResponseProto) GetStartTime() int64
- func (*GetReconfigurationStatusResponseProto) ProtoMessage()
- func (m *GetReconfigurationStatusResponseProto) Reset()
- func (m *GetReconfigurationStatusResponseProto) String() string
- type GetReplicaVisibleLengthRequestProto
- func (*GetReplicaVisibleLengthRequestProto) Descriptor() ([]byte, []int)
- func (m *GetReplicaVisibleLengthRequestProto) GetBlock() *ExtendedBlockProto
- func (*GetReplicaVisibleLengthRequestProto) ProtoMessage()
- func (m *GetReplicaVisibleLengthRequestProto) Reset()
- func (m *GetReplicaVisibleLengthRequestProto) String() string
- type GetReplicaVisibleLengthResponseProto
- func (*GetReplicaVisibleLengthResponseProto) Descriptor() ([]byte, []int)
- func (m *GetReplicaVisibleLengthResponseProto) GetLength() uint64
- func (*GetReplicaVisibleLengthResponseProto) ProtoMessage()
- func (m *GetReplicaVisibleLengthResponseProto) Reset()
- func (m *GetReplicaVisibleLengthResponseProto) String() string
- type GetServerDefaultsRequestProto
- type GetServerDefaultsResponseProto
- func (*GetServerDefaultsResponseProto) Descriptor() ([]byte, []int)
- func (m *GetServerDefaultsResponseProto) GetServerDefaults() *FsServerDefaultsProto
- func (*GetServerDefaultsResponseProto) ProtoMessage()
- func (m *GetServerDefaultsResponseProto) Reset()
- func (m *GetServerDefaultsResponseProto) String() string
- type GetSnapshotDiffReportRequestProto
- func (*GetSnapshotDiffReportRequestProto) Descriptor() ([]byte, []int)
- func (m *GetSnapshotDiffReportRequestProto) GetFromSnapshot() string
- func (m *GetSnapshotDiffReportRequestProto) GetSnapshotRoot() string
- func (m *GetSnapshotDiffReportRequestProto) GetToSnapshot() string
- func (*GetSnapshotDiffReportRequestProto) ProtoMessage()
- func (m *GetSnapshotDiffReportRequestProto) Reset()
- func (m *GetSnapshotDiffReportRequestProto) String() string
- type GetSnapshotDiffReportResponseProto
- func (*GetSnapshotDiffReportResponseProto) Descriptor() ([]byte, []int)
- func (m *GetSnapshotDiffReportResponseProto) GetDiffReport() *SnapshotDiffReportProto
- func (*GetSnapshotDiffReportResponseProto) ProtoMessage()
- func (m *GetSnapshotDiffReportResponseProto) Reset()
- func (m *GetSnapshotDiffReportResponseProto) String() string
- type GetSnapshottableDirListingRequestProto
- type GetSnapshottableDirListingResponseProto
- func (*GetSnapshottableDirListingResponseProto) Descriptor() ([]byte, []int)
- func (m *GetSnapshottableDirListingResponseProto) GetSnapshottableDirList() *SnapshottableDirectoryListingProto
- func (*GetSnapshottableDirListingResponseProto) ProtoMessage()
- func (m *GetSnapshottableDirListingResponseProto) Reset()
- func (m *GetSnapshottableDirListingResponseProto) String() string
- type GetStoragePoliciesRequestProto
- type GetStoragePoliciesResponseProto
- func (*GetStoragePoliciesResponseProto) Descriptor() ([]byte, []int)
- func (m *GetStoragePoliciesResponseProto) GetPolicies() []*BlockStoragePolicyProto
- func (*GetStoragePoliciesResponseProto) ProtoMessage()
- func (m *GetStoragePoliciesResponseProto) Reset()
- func (m *GetStoragePoliciesResponseProto) String() string
- type GetStoragePolicyRequestProto
- type GetStoragePolicyResponseProto
- func (*GetStoragePolicyResponseProto) Descriptor() ([]byte, []int)
- func (m *GetStoragePolicyResponseProto) GetStoragePolicy() *BlockStoragePolicyProto
- func (*GetStoragePolicyResponseProto) ProtoMessage()
- func (m *GetStoragePolicyResponseProto) Reset()
- func (m *GetStoragePolicyResponseProto) String() string
- type GetXAttrsRequestProto
- type GetXAttrsResponseProto
- type HdfsFileStatusProto
- func (*HdfsFileStatusProto) Descriptor() ([]byte, []int)
- 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 (*HdfsFileStatusProto) ProtoMessage()
- func (m *HdfsFileStatusProto) Reset()
- func (m *HdfsFileStatusProto) String() string
- type HdfsFileStatusProto_FileType
- type INodeType
- type IsFileClosedRequestProto
- type IsFileClosedResponseProto
- type ListCacheDirectivesRequestProto
- func (*ListCacheDirectivesRequestProto) Descriptor() ([]byte, []int)
- func (m *ListCacheDirectivesRequestProto) GetFilter() *CacheDirectiveInfoProto
- func (m *ListCacheDirectivesRequestProto) GetPrevId() int64
- func (*ListCacheDirectivesRequestProto) ProtoMessage()
- func (m *ListCacheDirectivesRequestProto) Reset()
- func (m *ListCacheDirectivesRequestProto) String() string
- type ListCacheDirectivesResponseProto
- func (*ListCacheDirectivesResponseProto) Descriptor() ([]byte, []int)
- func (m *ListCacheDirectivesResponseProto) GetElements() []*CacheDirectiveEntryProto
- func (m *ListCacheDirectivesResponseProto) GetHasMore() bool
- func (*ListCacheDirectivesResponseProto) ProtoMessage()
- func (m *ListCacheDirectivesResponseProto) Reset()
- func (m *ListCacheDirectivesResponseProto) String() string
- type ListCachePoolsRequestProto
- type ListCachePoolsResponseProto
- func (*ListCachePoolsResponseProto) Descriptor() ([]byte, []int)
- func (m *ListCachePoolsResponseProto) GetEntries() []*CachePoolEntryProto
- func (m *ListCachePoolsResponseProto) GetHasMore() bool
- func (*ListCachePoolsResponseProto) ProtoMessage()
- func (m *ListCachePoolsResponseProto) Reset()
- func (m *ListCachePoolsResponseProto) String() string
- type ListCorruptFileBlocksRequestProto
- func (*ListCorruptFileBlocksRequestProto) Descriptor() ([]byte, []int)
- func (m *ListCorruptFileBlocksRequestProto) GetCookie() string
- func (m *ListCorruptFileBlocksRequestProto) GetPath() string
- func (*ListCorruptFileBlocksRequestProto) ProtoMessage()
- func (m *ListCorruptFileBlocksRequestProto) Reset()
- func (m *ListCorruptFileBlocksRequestProto) String() string
- type ListCorruptFileBlocksResponseProto
- func (*ListCorruptFileBlocksResponseProto) Descriptor() ([]byte, []int)
- func (m *ListCorruptFileBlocksResponseProto) GetCorrupt() *CorruptFileBlocksProto
- func (*ListCorruptFileBlocksResponseProto) ProtoMessage()
- func (m *ListCorruptFileBlocksResponseProto) Reset()
- func (m *ListCorruptFileBlocksResponseProto) String() string
- type ListEncryptionZonesRequestProto
- type ListEncryptionZonesResponseProto
- func (*ListEncryptionZonesResponseProto) Descriptor() ([]byte, []int)
- func (m *ListEncryptionZonesResponseProto) GetHasMore() bool
- func (m *ListEncryptionZonesResponseProto) GetZones() []*EncryptionZoneProto
- func (*ListEncryptionZonesResponseProto) ProtoMessage()
- func (m *ListEncryptionZonesResponseProto) Reset()
- func (m *ListEncryptionZonesResponseProto) String() string
- type ListReconfigurablePropertiesRequestProto
- type ListReconfigurablePropertiesResponseProto
- func (*ListReconfigurablePropertiesResponseProto) Descriptor() ([]byte, []int)
- func (m *ListReconfigurablePropertiesResponseProto) GetName() []string
- func (*ListReconfigurablePropertiesResponseProto) ProtoMessage()
- func (m *ListReconfigurablePropertiesResponseProto) Reset()
- func (m *ListReconfigurablePropertiesResponseProto) String() string
- type ListXAttrsRequestProto
- type ListXAttrsResponseProto
- type LocatedBlockProto
- func (*LocatedBlockProto) Descriptor() ([]byte, []int)
- 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 (*LocatedBlockProto) ProtoMessage()
- func (m *LocatedBlockProto) Reset()
- func (m *LocatedBlockProto) String() string
- type LocatedBlocksProto
- func (*LocatedBlocksProto) Descriptor() ([]byte, []int)
- 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 (*LocatedBlocksProto) ProtoMessage()
- func (m *LocatedBlocksProto) Reset()
- func (m *LocatedBlocksProto) String() string
- type MetaSaveRequestProto
- type MetaSaveResponseProto
- type MetadataUpdateEventProto
- func (*MetadataUpdateEventProto) Descriptor() ([]byte, []int)
- 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 (*MetadataUpdateEventProto) ProtoMessage()
- func (m *MetadataUpdateEventProto) Reset()
- func (m *MetadataUpdateEventProto) String() string
- type MetadataUpdateType
- type MkdirsRequestProto
- func (*MkdirsRequestProto) Descriptor() ([]byte, []int)
- func (m *MkdirsRequestProto) GetCreateParent() bool
- func (m *MkdirsRequestProto) GetMasked() *FsPermissionProto
- func (m *MkdirsRequestProto) GetSrc() string
- func (*MkdirsRequestProto) ProtoMessage()
- func (m *MkdirsRequestProto) Reset()
- func (m *MkdirsRequestProto) String() string
- type MkdirsResponseProto
- type ModifyAclEntriesRequestProto
- func (*ModifyAclEntriesRequestProto) Descriptor() ([]byte, []int)
- func (m *ModifyAclEntriesRequestProto) GetAclSpec() []*AclEntryProto
- func (m *ModifyAclEntriesRequestProto) GetSrc() string
- func (*ModifyAclEntriesRequestProto) ProtoMessage()
- func (m *ModifyAclEntriesRequestProto) Reset()
- func (m *ModifyAclEntriesRequestProto) String() string
- type ModifyAclEntriesResponseProto
- type ModifyCacheDirectiveRequestProto
- func (*ModifyCacheDirectiveRequestProto) Descriptor() ([]byte, []int)
- func (m *ModifyCacheDirectiveRequestProto) GetCacheFlags() uint32
- func (m *ModifyCacheDirectiveRequestProto) GetInfo() *CacheDirectiveInfoProto
- func (*ModifyCacheDirectiveRequestProto) ProtoMessage()
- func (m *ModifyCacheDirectiveRequestProto) Reset()
- func (m *ModifyCacheDirectiveRequestProto) String() string
- type ModifyCacheDirectiveResponseProto
- type ModifyCachePoolRequestProto
- type ModifyCachePoolResponseProto
- type OpBlockChecksumProto
- type OpBlockChecksumResponseProto
- func (*OpBlockChecksumResponseProto) Descriptor() ([]byte, []int)
- func (m *OpBlockChecksumResponseProto) GetBytesPerCrc() uint32
- func (m *OpBlockChecksumResponseProto) GetCrcPerBlock() uint64
- func (m *OpBlockChecksumResponseProto) GetCrcType() ChecksumTypeProto
- func (m *OpBlockChecksumResponseProto) GetMd5() []byte
- func (*OpBlockChecksumResponseProto) ProtoMessage()
- func (m *OpBlockChecksumResponseProto) Reset()
- func (m *OpBlockChecksumResponseProto) String() string
- type OpBlockGroupChecksumProto
- func (*OpBlockGroupChecksumProto) Descriptor() ([]byte, []int)
- func (m *OpBlockGroupChecksumProto) GetBlockTokens() []*hadoop_common.TokenProto
- func (m *OpBlockGroupChecksumProto) GetDatanodes() *DatanodeInfosProto
- func (m *OpBlockGroupChecksumProto) GetEcPolicy() *ErasureCodingPolicyProto
- func (m *OpBlockGroupChecksumProto) GetHeader() *BaseHeaderProto
- func (*OpBlockGroupChecksumProto) ProtoMessage()
- func (m *OpBlockGroupChecksumProto) Reset()
- func (m *OpBlockGroupChecksumProto) String() string
- type OpCopyBlockProto
- type OpCustomProto
- type OpReadBlockProto
- func (*OpReadBlockProto) Descriptor() ([]byte, []int)
- 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 (*OpReadBlockProto) ProtoMessage()
- func (m *OpReadBlockProto) Reset()
- func (m *OpReadBlockProto) String() string
- type OpReplaceBlockProto
- func (*OpReplaceBlockProto) Descriptor() ([]byte, []int)
- func (m *OpReplaceBlockProto) GetDelHint() string
- func (m *OpReplaceBlockProto) GetHeader() *BaseHeaderProto
- func (m *OpReplaceBlockProto) GetSource() *DatanodeInfoProto
- func (m *OpReplaceBlockProto) GetStorageType() StorageTypeProto
- func (*OpReplaceBlockProto) ProtoMessage()
- func (m *OpReplaceBlockProto) Reset()
- func (m *OpReplaceBlockProto) String() string
- type OpRequestShortCircuitAccessProto
- func (*OpRequestShortCircuitAccessProto) Descriptor() ([]byte, []int)
- func (m *OpRequestShortCircuitAccessProto) GetHeader() *BaseHeaderProto
- func (m *OpRequestShortCircuitAccessProto) GetMaxVersion() uint32
- func (m *OpRequestShortCircuitAccessProto) GetSlotId() *ShortCircuitShmSlotProto
- func (m *OpRequestShortCircuitAccessProto) GetSupportsReceiptVerification() bool
- func (*OpRequestShortCircuitAccessProto) ProtoMessage()
- func (m *OpRequestShortCircuitAccessProto) Reset()
- func (m *OpRequestShortCircuitAccessProto) String() string
- type OpTransferBlockProto
- func (*OpTransferBlockProto) Descriptor() ([]byte, []int)
- func (m *OpTransferBlockProto) GetHeader() *ClientOperationHeaderProto
- func (m *OpTransferBlockProto) GetTargetStorageTypes() []StorageTypeProto
- func (m *OpTransferBlockProto) GetTargets() []*DatanodeInfoProto
- func (*OpTransferBlockProto) ProtoMessage()
- func (m *OpTransferBlockProto) Reset()
- func (m *OpTransferBlockProto) String() string
- type OpWriteBlockProto
- func (*OpWriteBlockProto) Descriptor() ([]byte, []int)
- 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 (*OpWriteBlockProto) ProtoMessage()
- func (m *OpWriteBlockProto) Reset()
- func (m *OpWriteBlockProto) String() string
- type OpWriteBlockProto_BlockConstructionStage
- func (x OpWriteBlockProto_BlockConstructionStage) Enum() *OpWriteBlockProto_BlockConstructionStage
- func (OpWriteBlockProto_BlockConstructionStage) EnumDescriptor() ([]byte, []int)
- func (x OpWriteBlockProto_BlockConstructionStage) String() string
- func (x *OpWriteBlockProto_BlockConstructionStage) UnmarshalJSON(data []byte) error
- type PacketHeaderProto
- func (*PacketHeaderProto) Descriptor() ([]byte, []int)
- 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 (*PacketHeaderProto) ProtoMessage()
- func (m *PacketHeaderProto) Reset()
- func (m *PacketHeaderProto) String() string
- type PerFileEncryptionInfoProto
- func (*PerFileEncryptionInfoProto) Descriptor() ([]byte, []int)
- func (m *PerFileEncryptionInfoProto) GetEzKeyVersionName() string
- func (m *PerFileEncryptionInfoProto) GetIv() []byte
- func (m *PerFileEncryptionInfoProto) GetKey() []byte
- func (*PerFileEncryptionInfoProto) ProtoMessage()
- func (m *PerFileEncryptionInfoProto) Reset()
- func (m *PerFileEncryptionInfoProto) String() string
- type PipelineAckProto
- func (*PipelineAckProto) Descriptor() ([]byte, []int)
- func (m *PipelineAckProto) GetDownstreamAckTimeNanos() uint64
- func (m *PipelineAckProto) GetFlag() []uint32
- func (m *PipelineAckProto) GetReply() []Status
- func (m *PipelineAckProto) GetSeqno() int64
- func (*PipelineAckProto) ProtoMessage()
- func (m *PipelineAckProto) Reset()
- func (m *PipelineAckProto) String() string
- type QuotaUsageProto
- func (*QuotaUsageProto) Descriptor() ([]byte, []int)
- 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 (*QuotaUsageProto) ProtoMessage()
- func (m *QuotaUsageProto) Reset()
- func (m *QuotaUsageProto) String() string
- type ReadOpChecksumInfoProto
- func (*ReadOpChecksumInfoProto) Descriptor() ([]byte, []int)
- func (m *ReadOpChecksumInfoProto) GetChecksum() *ChecksumProto
- func (m *ReadOpChecksumInfoProto) GetChunkOffset() uint64
- func (*ReadOpChecksumInfoProto) ProtoMessage()
- func (m *ReadOpChecksumInfoProto) Reset()
- func (m *ReadOpChecksumInfoProto) String() string
- type RecoverLeaseRequestProto
- func (*RecoverLeaseRequestProto) Descriptor() ([]byte, []int)
- func (m *RecoverLeaseRequestProto) GetClientName() string
- func (m *RecoverLeaseRequestProto) GetSrc() string
- func (*RecoverLeaseRequestProto) ProtoMessage()
- func (m *RecoverLeaseRequestProto) Reset()
- func (m *RecoverLeaseRequestProto) String() string
- type RecoverLeaseResponseProto
- type RefreshNamenodesRequestProto
- type RefreshNamenodesResponseProto
- type RefreshNodesRequestProto
- type RefreshNodesResponseProto
- type ReleaseShortCircuitAccessRequestProto
- func (*ReleaseShortCircuitAccessRequestProto) Descriptor() ([]byte, []int)
- func (m *ReleaseShortCircuitAccessRequestProto) GetSlotId() *ShortCircuitShmSlotProto
- func (m *ReleaseShortCircuitAccessRequestProto) GetTraceInfo() *DataTransferTraceInfoProto
- func (*ReleaseShortCircuitAccessRequestProto) ProtoMessage()
- func (m *ReleaseShortCircuitAccessRequestProto) Reset()
- func (m *ReleaseShortCircuitAccessRequestProto) String() string
- type ReleaseShortCircuitAccessResponseProto
- func (*ReleaseShortCircuitAccessResponseProto) Descriptor() ([]byte, []int)
- func (m *ReleaseShortCircuitAccessResponseProto) GetError() string
- func (m *ReleaseShortCircuitAccessResponseProto) GetStatus() Status
- func (*ReleaseShortCircuitAccessResponseProto) ProtoMessage()
- func (m *ReleaseShortCircuitAccessResponseProto) Reset()
- func (m *ReleaseShortCircuitAccessResponseProto) String() string
- type RemoveAclEntriesRequestProto
- func (*RemoveAclEntriesRequestProto) Descriptor() ([]byte, []int)
- func (m *RemoveAclEntriesRequestProto) GetAclSpec() []*AclEntryProto
- func (m *RemoveAclEntriesRequestProto) GetSrc() string
- func (*RemoveAclEntriesRequestProto) ProtoMessage()
- func (m *RemoveAclEntriesRequestProto) Reset()
- func (m *RemoveAclEntriesRequestProto) String() string
- type RemoveAclEntriesResponseProto
- type RemoveAclRequestProto
- type RemoveAclResponseProto
- type RemoveCacheDirectiveRequestProto
- type RemoveCacheDirectiveResponseProto
- type RemoveCachePoolRequestProto
- type RemoveCachePoolResponseProto
- type RemoveDefaultAclRequestProto
- type RemoveDefaultAclResponseProto
- type RemoveXAttrRequestProto
- func (*RemoveXAttrRequestProto) Descriptor() ([]byte, []int)
- func (m *RemoveXAttrRequestProto) GetSrc() string
- func (m *RemoveXAttrRequestProto) GetXAttr() *XAttrProto
- func (*RemoveXAttrRequestProto) ProtoMessage()
- func (m *RemoveXAttrRequestProto) Reset()
- func (m *RemoveXAttrRequestProto) String() string
- type RemoveXAttrResponseProto
- type Rename2RequestProto
- func (*Rename2RequestProto) Descriptor() ([]byte, []int)
- func (m *Rename2RequestProto) GetDst() string
- func (m *Rename2RequestProto) GetOverwriteDest() bool
- func (m *Rename2RequestProto) GetSrc() string
- func (*Rename2RequestProto) ProtoMessage()
- func (m *Rename2RequestProto) Reset()
- func (m *Rename2RequestProto) String() string
- type Rename2ResponseProto
- type RenameEventProto
- func (*RenameEventProto) Descriptor() ([]byte, []int)
- func (m *RenameEventProto) GetDestPath() string
- func (m *RenameEventProto) GetSrcPath() string
- func (m *RenameEventProto) GetTimestamp() int64
- func (*RenameEventProto) ProtoMessage()
- func (m *RenameEventProto) Reset()
- func (m *RenameEventProto) String() string
- type RenameRequestProto
- type RenameResponseProto
- type RenameSnapshotRequestProto
- func (*RenameSnapshotRequestProto) Descriptor() ([]byte, []int)
- func (m *RenameSnapshotRequestProto) GetSnapshotNewName() string
- func (m *RenameSnapshotRequestProto) GetSnapshotOldName() string
- func (m *RenameSnapshotRequestProto) GetSnapshotRoot() string
- func (*RenameSnapshotRequestProto) ProtoMessage()
- func (m *RenameSnapshotRequestProto) Reset()
- func (m *RenameSnapshotRequestProto) String() string
- type RenameSnapshotResponseProto
- type RenewLeaseRequestProto
- type RenewLeaseResponseProto
- type ReportBadBlocksRequestProto
- type ReportBadBlocksResponseProto
- type RestoreFailedStorageRequestProto
- type RestoreFailedStorageResponseProto
- func (*RestoreFailedStorageResponseProto) Descriptor() ([]byte, []int)
- func (m *RestoreFailedStorageResponseProto) GetResult() bool
- func (*RestoreFailedStorageResponseProto) ProtoMessage()
- func (m *RestoreFailedStorageResponseProto) Reset()
- func (m *RestoreFailedStorageResponseProto) String() string
- type RollEditsRequestProto
- type RollEditsResponseProto
- type RollingUpgradeActionProto
- type RollingUpgradeInfoProto
- func (*RollingUpgradeInfoProto) Descriptor() ([]byte, []int)
- func (m *RollingUpgradeInfoProto) GetCreatedRollbackImages() bool
- func (m *RollingUpgradeInfoProto) GetFinalizeTime() uint64
- func (m *RollingUpgradeInfoProto) GetStartTime() uint64
- func (m *RollingUpgradeInfoProto) GetStatus() *RollingUpgradeStatusProto
- func (*RollingUpgradeInfoProto) ProtoMessage()
- func (m *RollingUpgradeInfoProto) Reset()
- func (m *RollingUpgradeInfoProto) String() string
- type RollingUpgradeRequestProto
- type RollingUpgradeResponseProto
- func (*RollingUpgradeResponseProto) Descriptor() ([]byte, []int)
- func (m *RollingUpgradeResponseProto) GetRollingUpgradeInfo() *RollingUpgradeInfoProto
- func (*RollingUpgradeResponseProto) ProtoMessage()
- func (m *RollingUpgradeResponseProto) Reset()
- func (m *RollingUpgradeResponseProto) String() string
- type RollingUpgradeStatusProto
- func (*RollingUpgradeStatusProto) Descriptor() ([]byte, []int)
- func (m *RollingUpgradeStatusProto) GetBlockPoolId() string
- func (m *RollingUpgradeStatusProto) GetFinalized() bool
- func (*RollingUpgradeStatusProto) ProtoMessage()
- func (m *RollingUpgradeStatusProto) Reset()
- func (m *RollingUpgradeStatusProto) String() string
- type SafeModeActionProto
- type SaveNamespaceRequestProto
- func (*SaveNamespaceRequestProto) Descriptor() ([]byte, []int)
- func (m *SaveNamespaceRequestProto) GetTimeWindow() uint64
- func (m *SaveNamespaceRequestProto) GetTxGap() uint64
- func (*SaveNamespaceRequestProto) ProtoMessage()
- func (m *SaveNamespaceRequestProto) Reset()
- func (m *SaveNamespaceRequestProto) String() string
- type SaveNamespaceResponseProto
- type SetAclRequestProto
- type SetAclResponseProto
- type SetBalancerBandwidthRequestProto
- type SetBalancerBandwidthResponseProto
- type SetErasureCodingPolicyRequestProto
- func (*SetErasureCodingPolicyRequestProto) Descriptor() ([]byte, []int)
- func (m *SetErasureCodingPolicyRequestProto) GetEcPolicy() *ErasureCodingPolicyProto
- func (m *SetErasureCodingPolicyRequestProto) GetSrc() string
- func (*SetErasureCodingPolicyRequestProto) ProtoMessage()
- func (m *SetErasureCodingPolicyRequestProto) Reset()
- func (m *SetErasureCodingPolicyRequestProto) String() string
- type SetErasureCodingPolicyResponseProto
- type SetOwnerRequestProto
- func (*SetOwnerRequestProto) Descriptor() ([]byte, []int)
- func (m *SetOwnerRequestProto) GetGroupname() string
- func (m *SetOwnerRequestProto) GetSrc() string
- func (m *SetOwnerRequestProto) GetUsername() string
- func (*SetOwnerRequestProto) ProtoMessage()
- func (m *SetOwnerRequestProto) Reset()
- func (m *SetOwnerRequestProto) String() string
- type SetOwnerResponseProto
- type SetPermissionRequestProto
- func (*SetPermissionRequestProto) Descriptor() ([]byte, []int)
- func (m *SetPermissionRequestProto) GetPermission() *FsPermissionProto
- func (m *SetPermissionRequestProto) GetSrc() string
- func (*SetPermissionRequestProto) ProtoMessage()
- func (m *SetPermissionRequestProto) Reset()
- func (m *SetPermissionRequestProto) String() string
- type SetPermissionResponseProto
- type SetQuotaRequestProto
- func (*SetQuotaRequestProto) Descriptor() ([]byte, []int)
- func (m *SetQuotaRequestProto) GetNamespaceQuota() uint64
- func (m *SetQuotaRequestProto) GetPath() string
- func (m *SetQuotaRequestProto) GetStorageType() StorageTypeProto
- func (m *SetQuotaRequestProto) GetStoragespaceQuota() uint64
- func (*SetQuotaRequestProto) ProtoMessage()
- func (m *SetQuotaRequestProto) Reset()
- func (m *SetQuotaRequestProto) String() string
- type SetQuotaResponseProto
- type SetReplicationRequestProto
- func (*SetReplicationRequestProto) Descriptor() ([]byte, []int)
- func (m *SetReplicationRequestProto) GetReplication() uint32
- func (m *SetReplicationRequestProto) GetSrc() string
- func (*SetReplicationRequestProto) ProtoMessage()
- func (m *SetReplicationRequestProto) Reset()
- func (m *SetReplicationRequestProto) String() string
- type SetReplicationResponseProto
- type SetSafeModeRequestProto
- func (*SetSafeModeRequestProto) Descriptor() ([]byte, []int)
- func (m *SetSafeModeRequestProto) GetAction() SafeModeActionProto
- func (m *SetSafeModeRequestProto) GetChecked() bool
- func (*SetSafeModeRequestProto) ProtoMessage()
- func (m *SetSafeModeRequestProto) Reset()
- func (m *SetSafeModeRequestProto) String() string
- type SetSafeModeResponseProto
- type SetStoragePolicyRequestProto
- func (*SetStoragePolicyRequestProto) Descriptor() ([]byte, []int)
- func (m *SetStoragePolicyRequestProto) GetPolicyName() string
- func (m *SetStoragePolicyRequestProto) GetSrc() string
- func (*SetStoragePolicyRequestProto) ProtoMessage()
- func (m *SetStoragePolicyRequestProto) Reset()
- func (m *SetStoragePolicyRequestProto) String() string
- type SetStoragePolicyResponseProto
- type SetTimesRequestProto
- func (*SetTimesRequestProto) Descriptor() ([]byte, []int)
- func (m *SetTimesRequestProto) GetAtime() uint64
- func (m *SetTimesRequestProto) GetMtime() uint64
- func (m *SetTimesRequestProto) GetSrc() string
- func (*SetTimesRequestProto) ProtoMessage()
- func (m *SetTimesRequestProto) Reset()
- func (m *SetTimesRequestProto) String() string
- type SetTimesResponseProto
- type SetXAttrRequestProto
- func (*SetXAttrRequestProto) Descriptor() ([]byte, []int)
- func (m *SetXAttrRequestProto) GetFlag() uint32
- func (m *SetXAttrRequestProto) GetSrc() string
- func (m *SetXAttrRequestProto) GetXAttr() *XAttrProto
- func (*SetXAttrRequestProto) ProtoMessage()
- func (m *SetXAttrRequestProto) Reset()
- func (m *SetXAttrRequestProto) String() string
- type SetXAttrResponseProto
- type ShortCircuitFdResponse
- type ShortCircuitShmIdProto
- type ShortCircuitShmRequestProto
- func (*ShortCircuitShmRequestProto) Descriptor() ([]byte, []int)
- func (m *ShortCircuitShmRequestProto) GetClientName() string
- func (m *ShortCircuitShmRequestProto) GetTraceInfo() *DataTransferTraceInfoProto
- func (*ShortCircuitShmRequestProto) ProtoMessage()
- func (m *ShortCircuitShmRequestProto) Reset()
- func (m *ShortCircuitShmRequestProto) String() string
- type ShortCircuitShmResponseProto
- func (*ShortCircuitShmResponseProto) Descriptor() ([]byte, []int)
- func (m *ShortCircuitShmResponseProto) GetError() string
- func (m *ShortCircuitShmResponseProto) GetId() *ShortCircuitShmIdProto
- func (m *ShortCircuitShmResponseProto) GetStatus() Status
- func (*ShortCircuitShmResponseProto) ProtoMessage()
- func (m *ShortCircuitShmResponseProto) Reset()
- func (m *ShortCircuitShmResponseProto) String() string
- type ShortCircuitShmSlotProto
- func (*ShortCircuitShmSlotProto) Descriptor() ([]byte, []int)
- func (m *ShortCircuitShmSlotProto) GetShmId() *ShortCircuitShmIdProto
- func (m *ShortCircuitShmSlotProto) GetSlotIdx() int32
- func (*ShortCircuitShmSlotProto) ProtoMessage()
- func (m *ShortCircuitShmSlotProto) Reset()
- func (m *ShortCircuitShmSlotProto) String() string
- type ShutdownDatanodeRequestProto
- type ShutdownDatanodeResponseProto
- type SnapshotDiffReportEntryProto
- func (*SnapshotDiffReportEntryProto) Descriptor() ([]byte, []int)
- func (m *SnapshotDiffReportEntryProto) GetFullpath() []byte
- func (m *SnapshotDiffReportEntryProto) GetModificationLabel() string
- func (m *SnapshotDiffReportEntryProto) GetTargetPath() []byte
- func (*SnapshotDiffReportEntryProto) ProtoMessage()
- func (m *SnapshotDiffReportEntryProto) Reset()
- func (m *SnapshotDiffReportEntryProto) String() string
- type SnapshotDiffReportProto
- func (*SnapshotDiffReportProto) Descriptor() ([]byte, []int)
- func (m *SnapshotDiffReportProto) GetDiffReportEntries() []*SnapshotDiffReportEntryProto
- func (m *SnapshotDiffReportProto) GetFromSnapshot() string
- func (m *SnapshotDiffReportProto) GetSnapshotRoot() string
- func (m *SnapshotDiffReportProto) GetToSnapshot() string
- func (*SnapshotDiffReportProto) ProtoMessage()
- func (m *SnapshotDiffReportProto) Reset()
- func (m *SnapshotDiffReportProto) String() string
- type SnapshotInfoProto
- func (*SnapshotInfoProto) Descriptor() ([]byte, []int)
- 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 (*SnapshotInfoProto) ProtoMessage()
- func (m *SnapshotInfoProto) Reset()
- func (m *SnapshotInfoProto) String() string
- type SnapshottableDirectoryListingProto
- func (*SnapshottableDirectoryListingProto) Descriptor() ([]byte, []int)
- func (m *SnapshottableDirectoryListingProto) GetSnapshottableDirListing() []*SnapshottableDirectoryStatusProto
- func (*SnapshottableDirectoryListingProto) ProtoMessage()
- func (m *SnapshottableDirectoryListingProto) Reset()
- func (m *SnapshottableDirectoryListingProto) String() string
- type SnapshottableDirectoryStatusProto
- func (*SnapshottableDirectoryStatusProto) Descriptor() ([]byte, []int)
- func (m *SnapshottableDirectoryStatusProto) GetDirStatus() *HdfsFileStatusProto
- func (m *SnapshottableDirectoryStatusProto) GetParentFullpath() []byte
- func (m *SnapshottableDirectoryStatusProto) GetSnapshotNumber() uint32
- func (m *SnapshottableDirectoryStatusProto) GetSnapshotQuota() uint32
- func (*SnapshottableDirectoryStatusProto) ProtoMessage()
- func (m *SnapshottableDirectoryStatusProto) Reset()
- func (m *SnapshottableDirectoryStatusProto) String() string
- type StartReconfigurationRequestProto
- type StartReconfigurationResponseProto
- type Status
- type StorageReportProto
- func (*StorageReportProto) Descriptor() ([]byte, []int)
- 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 (*StorageReportProto) ProtoMessage()
- func (m *StorageReportProto) Reset()
- func (m *StorageReportProto) String() string
- type StorageTypeProto
- type StorageTypeQuotaInfoProto
- func (*StorageTypeQuotaInfoProto) Descriptor() ([]byte, []int)
- func (m *StorageTypeQuotaInfoProto) GetConsumed() uint64
- func (m *StorageTypeQuotaInfoProto) GetQuota() uint64
- func (m *StorageTypeQuotaInfoProto) GetType() StorageTypeProto
- func (*StorageTypeQuotaInfoProto) ProtoMessage()
- func (m *StorageTypeQuotaInfoProto) Reset()
- func (m *StorageTypeQuotaInfoProto) String() string
- type StorageTypeQuotaInfosProto
- type StorageTypesProto
- type StorageUuidsProto
- type TriggerBlockReportRequestProto
- type TriggerBlockReportResponseProto
- type TruncateEventProto
- func (*TruncateEventProto) Descriptor() ([]byte, []int)
- func (m *TruncateEventProto) GetFileSize() int64
- func (m *TruncateEventProto) GetPath() string
- func (m *TruncateEventProto) GetTimestamp() int64
- func (*TruncateEventProto) ProtoMessage()
- func (m *TruncateEventProto) Reset()
- func (m *TruncateEventProto) String() string
- type TruncateRequestProto
- func (*TruncateRequestProto) Descriptor() ([]byte, []int)
- func (m *TruncateRequestProto) GetClientName() string
- func (m *TruncateRequestProto) GetNewLength() uint64
- func (m *TruncateRequestProto) GetSrc() string
- func (*TruncateRequestProto) ProtoMessage()
- func (m *TruncateRequestProto) Reset()
- func (m *TruncateRequestProto) String() string
- type TruncateResponseProto
- type UnlinkEventProto
- type UnsetStoragePolicyRequestProto
- type UnsetStoragePolicyResponseProto
- type UpdateBlockForPipelineRequestProto
- func (*UpdateBlockForPipelineRequestProto) Descriptor() ([]byte, []int)
- func (m *UpdateBlockForPipelineRequestProto) GetBlock() *ExtendedBlockProto
- func (m *UpdateBlockForPipelineRequestProto) GetClientName() string
- func (*UpdateBlockForPipelineRequestProto) ProtoMessage()
- func (m *UpdateBlockForPipelineRequestProto) Reset()
- func (m *UpdateBlockForPipelineRequestProto) String() string
- type UpdateBlockForPipelineResponseProto
- func (*UpdateBlockForPipelineResponseProto) Descriptor() ([]byte, []int)
- func (m *UpdateBlockForPipelineResponseProto) GetBlock() *LocatedBlockProto
- func (*UpdateBlockForPipelineResponseProto) ProtoMessage()
- func (m *UpdateBlockForPipelineResponseProto) Reset()
- func (m *UpdateBlockForPipelineResponseProto) String() string
- type UpdatePipelineRequestProto
- func (*UpdatePipelineRequestProto) Descriptor() ([]byte, []int)
- 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 (*UpdatePipelineRequestProto) ProtoMessage()
- func (m *UpdatePipelineRequestProto) Reset()
- func (m *UpdatePipelineRequestProto) String() string
- type UpdatePipelineResponseProto
- type XAttrProto
- type XAttrProto_XAttrNamespaceProto
- type XAttrSetFlagProto
- type ZoneEncryptionInfoProto
- func (*ZoneEncryptionInfoProto) Descriptor() ([]byte, []int)
- func (m *ZoneEncryptionInfoProto) GetCryptoProtocolVersion() CryptoProtocolVersionProto
- func (m *ZoneEncryptionInfoProto) GetKeyName() string
- func (m *ZoneEncryptionInfoProto) GetSuite() CipherSuiteProto
- func (*ZoneEncryptionInfoProto) ProtoMessage()
- func (m *ZoneEncryptionInfoProto) Reset()
- func (m *ZoneEncryptionInfoProto) String() string
Constants ¶
View Source
const Default_AbandonBlockRequestProto_FileId uint64 = 0
View Source
const Default_AddBlockRequestProto_FileId uint64 = 0
View Source
const Default_AppendEventProto_NewBlock bool = false
View Source
const Default_BlockProto_NumBytes uint64 = 0
View Source
const Default_CompleteRequestProto_FileId uint64 = 0
View Source
const Default_CreateEventProto_DefaultBlockSize int64 = 0
View Source
const Default_DatanodeIDProto_InfoSecurePort uint32 = 0
View Source
const Default_DatanodeInfoProto_BlockPoolUsed uint64 = 0
View Source
const Default_DatanodeInfoProto_CacheCapacity uint64 = 0
View Source
const Default_DatanodeInfoProto_CacheUsed uint64 = 0
View Source
const Default_DatanodeInfoProto_Capacity uint64 = 0
View Source
const Default_DatanodeInfoProto_DfsUsed uint64 = 0
View Source
const Default_DatanodeInfoProto_LastUpdate uint64 = 0
View Source
const Default_DatanodeInfoProto_LastUpdateMonotonic uint64 = 0
View Source
const Default_DatanodeInfoProto_Remaining uint64 = 0
View Source
const Default_DatanodeInfoProto_XceiverCount uint32 = 0
View Source
const Default_ExtendedBlockProto_NumBytes uint64 = 0
View Source
const Default_FsServerDefaultsProto_EncryptDataTransfer bool = false
View Source
const Default_FsServerDefaultsProto_TrashInterval uint64 = 0
View Source
const Default_FsyncRequestProto_FileId uint64 = 0
View Source
const Default_FsyncRequestProto_LastBlockLength int64 = -1
View Source
const Default_GetAdditionalDatanodeRequestProto_FileId uint64 = 0
View Source
const Default_HdfsFileStatusProto_BlockReplication uint32 = 0
View Source
const Default_HdfsFileStatusProto_Blocksize uint64 = 0
View Source
const Default_HdfsFileStatusProto_ChildrenNum int32 = -1
View Source
const Default_HdfsFileStatusProto_FileId uint64 = 0
View Source
const Default_HdfsFileStatusProto_StoragePolicy uint32 = 0
View Source
const Default_OpReadBlockProto_SendChecksums bool = true
View Source
const Default_OpRequestShortCircuitAccessProto_SupportsReceiptVerification bool = false
View Source
const Default_OpWriteBlockProto_AllowLazyPersist bool = false
View Source
const Default_OpWriteBlockProto_Pinning bool = false
View Source
const Default_PacketHeaderProto_SyncBlock bool = false
View Source
const Default_PipelineAckProto_DownstreamAckTimeNanos uint64 = 0
View Source
const Default_RollingUpgradeStatusProto_Finalized bool = false
View Source
const Default_SaveNamespaceRequestProto_TimeWindow uint64 = 0
View Source
const Default_SaveNamespaceRequestProto_TxGap uint64 = 0
View Source
const Default_SaveNamespaceResponseProto_Saved bool = true
View Source
const Default_SetSafeModeRequestProto_Checked bool = false
View Source
const Default_StorageReportProto_BlockPoolUsed uint64 = 0
View Source
const Default_StorageReportProto_Capacity uint64 = 0
View Source
const Default_StorageReportProto_DfsUsed uint64 = 0
View Source
const Default_StorageReportProto_Failed bool = false
View Source
const Default_StorageReportProto_Remaining uint64 = 0
Variables ¶
View Source
var AclEntryProto_AclEntryScopeProto_name = map[int32]string{
0: "ACCESS",
1: "DEFAULT",
}
View Source
var AclEntryProto_AclEntryScopeProto_value = map[string]int32{
"ACCESS": 0,
"DEFAULT": 1,
}
View Source
var AclEntryProto_AclEntryTypeProto_name = map[int32]string{
0: "USER",
1: "GROUP",
2: "MASK",
3: "OTHER",
}
View Source
var AclEntryProto_AclEntryTypeProto_value = map[string]int32{
"USER": 0,
"GROUP": 1,
"MASK": 2,
"OTHER": 3,
}
View Source
var AclEntryProto_FsActionProto_name = map[int32]string{
0: "NONE",
1: "EXECUTE",
2: "WRITE",
3: "WRITE_EXECUTE",
4: "READ",
5: "READ_EXECUTE",
6: "READ_WRITE",
7: "PERM_ALL",
}
View Source
var AclEntryProto_FsActionProto_value = map[string]int32{
"NONE": 0,
"EXECUTE": 1,
"WRITE": 2,
"WRITE_EXECUTE": 3,
"READ": 4,
"READ_EXECUTE": 5,
"READ_WRITE": 6,
"PERM_ALL": 7,
}
View Source
var CacheFlagProto_name = map[int32]string{
1: "FORCE",
}
View Source
var CacheFlagProto_value = map[string]int32{
"FORCE": 1,
}
View Source
var ChecksumTypeProto_name = map[int32]string{
0: "CHECKSUM_NULL",
1: "CHECKSUM_CRC32",
2: "CHECKSUM_CRC32C",
}
View Source
var ChecksumTypeProto_value = map[string]int32{
"CHECKSUM_NULL": 0,
"CHECKSUM_CRC32": 1,
"CHECKSUM_CRC32C": 2,
}
View Source
var CipherSuiteProto_name = map[int32]string{
1: "UNKNOWN",
2: "AES_CTR_NOPADDING",
}
View Source
var CipherSuiteProto_value = map[string]int32{
"UNKNOWN": 1,
"AES_CTR_NOPADDING": 2,
}
View Source
var CreateFlagProto_name = map[int32]string{
1: "CREATE",
2: "OVERWRITE",
4: "APPEND",
16: "LAZY_PERSIST",
32: "NEW_BLOCK",
}
View Source
var CreateFlagProto_value = map[string]int32{
"CREATE": 1,
"OVERWRITE": 2,
"APPEND": 4,
"LAZY_PERSIST": 16,
"NEW_BLOCK": 32,
}
View Source
var CryptoProtocolVersionProto_name = map[int32]string{
1: "UNKNOWN_PROTOCOL_VERSION",
2: "ENCRYPTION_ZONES",
}
View Source
var CryptoProtocolVersionProto_value = map[string]int32{
"UNKNOWN_PROTOCOL_VERSION": 1,
"ENCRYPTION_ZONES": 2,
}
View Source
var DataTransferEncryptorMessageProto_DataTransferEncryptorStatus_name = map[int32]string{
0: "SUCCESS",
1: "ERROR_UNKNOWN_KEY",
2: "ERROR",
}
View Source
var DataTransferEncryptorMessageProto_DataTransferEncryptorStatus_value = map[string]int32{
"SUCCESS": 0,
"ERROR_UNKNOWN_KEY": 1,
"ERROR": 2,
}
View Source
var DatanodeInfoProto_AdminState_name = map[int32]string{
0: "NORMAL",
1: "DECOMMISSION_INPROGRESS",
2: "DECOMMISSIONED",
}
View Source
var DatanodeInfoProto_AdminState_value = map[string]int32{
"NORMAL": 0,
"DECOMMISSION_INPROGRESS": 1,
"DECOMMISSIONED": 2,
}
View Source
var DatanodeReportTypeProto_name = map[int32]string{
1: "ALL",
2: "LIVE",
3: "DEAD",
4: "DECOMMISSIONING",
}
View Source
var DatanodeReportTypeProto_value = map[string]int32{
"ALL": 1,
"LIVE": 2,
"DEAD": 3,
"DECOMMISSIONING": 4,
}
View Source
var DatanodeStorageProto_StorageState_name = map[int32]string{
0: "NORMAL",
1: "READ_ONLY_SHARED",
}
View Source
var DatanodeStorageProto_StorageState_value = map[string]int32{
"NORMAL": 0,
"READ_ONLY_SHARED": 1,
}
View Source
var EventType_name = map[int32]string{
0: "EVENT_CREATE",
1: "EVENT_CLOSE",
2: "EVENT_APPEND",
3: "EVENT_RENAME",
4: "EVENT_METADATA",
5: "EVENT_UNLINK",
6: "EVENT_TRUNCATE",
}
View Source
var EventType_value = map[string]int32{
"EVENT_CREATE": 0,
"EVENT_CLOSE": 1,
"EVENT_APPEND": 2,
"EVENT_RENAME": 3,
"EVENT_METADATA": 4,
"EVENT_UNLINK": 5,
"EVENT_TRUNCATE": 6,
}
View Source
var HdfsFileStatusProto_FileType_name = map[int32]string{
1: "IS_DIR",
2: "IS_FILE",
3: "IS_SYMLINK",
}
View Source
var HdfsFileStatusProto_FileType_value = map[string]int32{
"IS_DIR": 1,
"IS_FILE": 2,
"IS_SYMLINK": 3,
}
View Source
var INodeType_name = map[int32]string{
0: "I_TYPE_FILE",
1: "I_TYPE_DIRECTORY",
2: "I_TYPE_SYMLINK",
}
View Source
var INodeType_value = map[string]int32{
"I_TYPE_FILE": 0,
"I_TYPE_DIRECTORY": 1,
"I_TYPE_SYMLINK": 2,
}
View Source
var MetadataUpdateType_name = map[int32]string{
0: "META_TYPE_TIMES",
1: "META_TYPE_REPLICATION",
2: "META_TYPE_OWNER",
3: "META_TYPE_PERMS",
4: "META_TYPE_ACLS",
5: "META_TYPE_XATTRS",
}
View Source
var MetadataUpdateType_value = map[string]int32{
"META_TYPE_TIMES": 0,
"META_TYPE_REPLICATION": 1,
"META_TYPE_OWNER": 2,
"META_TYPE_PERMS": 3,
"META_TYPE_ACLS": 4,
"META_TYPE_XATTRS": 5,
}
View Source
var OpWriteBlockProto_BlockConstructionStage_name = map[int32]string{
0: "PIPELINE_SETUP_APPEND",
1: "PIPELINE_SETUP_APPEND_RECOVERY",
2: "DATA_STREAMING",
3: "PIPELINE_SETUP_STREAMING_RECOVERY",
4: "PIPELINE_CLOSE",
5: "PIPELINE_CLOSE_RECOVERY",
6: "PIPELINE_SETUP_CREATE",
7: "TRANSFER_RBW",
8: "TRANSFER_FINALIZED",
}
View Source
var OpWriteBlockProto_BlockConstructionStage_value = map[string]int32{
"PIPELINE_SETUP_APPEND": 0,
"PIPELINE_SETUP_APPEND_RECOVERY": 1,
"DATA_STREAMING": 2,
"PIPELINE_SETUP_STREAMING_RECOVERY": 3,
"PIPELINE_CLOSE": 4,
"PIPELINE_CLOSE_RECOVERY": 5,
"PIPELINE_SETUP_CREATE": 6,
"TRANSFER_RBW": 7,
"TRANSFER_FINALIZED": 8,
}
View Source
var RollingUpgradeActionProto_name = map[int32]string{
1: "QUERY",
2: "START",
3: "FINALIZE",
}
View Source
var RollingUpgradeActionProto_value = map[string]int32{
"QUERY": 1,
"START": 2,
"FINALIZE": 3,
}
View Source
var SafeModeActionProto_name = map[int32]string{
1: "SAFEMODE_LEAVE",
2: "SAFEMODE_ENTER",
3: "SAFEMODE_GET",
4: "SAFEMODE_FORCE_EXIT",
}
View Source
var SafeModeActionProto_value = map[string]int32{
"SAFEMODE_LEAVE": 1,
"SAFEMODE_ENTER": 2,
"SAFEMODE_GET": 3,
"SAFEMODE_FORCE_EXIT": 4,
}
View Source
var ShortCircuitFdResponse_name = map[int32]string{
0: "DO_NOT_USE_RECEIPT_VERIFICATION",
1: "USE_RECEIPT_VERIFICATION",
}
View Source
var ShortCircuitFdResponse_value = map[string]int32{
"DO_NOT_USE_RECEIPT_VERIFICATION": 0,
"USE_RECEIPT_VERIFICATION": 1,
}
View Source
var Status_name = map[int32]string{
0: "SUCCESS",
1: "ERROR",
2: "ERROR_CHECKSUM",
3: "ERROR_INVALID",
4: "ERROR_EXISTS",
5: "ERROR_ACCESS_TOKEN",
6: "CHECKSUM_OK",
7: "ERROR_UNSUPPORTED",
8: "OOB_RESTART",
9: "OOB_RESERVED1",
10: "OOB_RESERVED2",
11: "OOB_RESERVED3",
12: "IN_PROGRESS",
}
View Source
var Status_value = map[string]int32{
"SUCCESS": 0,
"ERROR": 1,
"ERROR_CHECKSUM": 2,
"ERROR_INVALID": 3,
"ERROR_EXISTS": 4,
"ERROR_ACCESS_TOKEN": 5,
"CHECKSUM_OK": 6,
"ERROR_UNSUPPORTED": 7,
"OOB_RESTART": 8,
"OOB_RESERVED1": 9,
"OOB_RESERVED2": 10,
"OOB_RESERVED3": 11,
"IN_PROGRESS": 12,
}
View Source
var StorageTypeProto_name = map[int32]string{
1: "DISK",
2: "SSD",
3: "ARCHIVE",
4: "RAM_DISK",
}
View Source
var StorageTypeProto_value = map[string]int32{
"DISK": 1,
"SSD": 2,
"ARCHIVE": 3,
"RAM_DISK": 4,
}
View Source
var XAttrProto_XAttrNamespaceProto_name = map[int32]string{
0: "USER",
1: "TRUSTED",
2: "SECURITY",
3: "SYSTEM",
4: "RAW",
}
View Source
var XAttrProto_XAttrNamespaceProto_value = map[string]int32{
"USER": 0,
"TRUSTED": 1,
"SECURITY": 2,
"SYSTEM": 3,
"RAW": 4,
}
View Source
var XAttrSetFlagProto_name = map[int32]string{
1: "XATTR_CREATE",
2: "XATTR_REPLACE",
}
View Source
var XAttrSetFlagProto_value = map[string]int32{
"XATTR_CREATE": 1,
"XATTR_REPLACE": 2,
}
Functions ¶
This section is empty.
Types ¶
type AbandonBlockRequestProto ¶
type AbandonBlockRequestProto struct { B *ExtendedBlockProto `protobuf:"bytes,1,req,name=b" json:"b,omitempty"` Src *string `protobuf:"bytes,2,req,name=src" json:"src,omitempty"` Holder *string `protobuf:"bytes,3,req,name=holder" json:"holder,omitempty"` FileId *uint64 `protobuf:"varint,4,opt,name=fileId,def=0" json:"fileId,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*AbandonBlockRequestProto) Descriptor ¶ added in v1.1.1
func (*AbandonBlockRequestProto) Descriptor() ([]byte, []int)
func (*AbandonBlockRequestProto) GetB ¶
func (m *AbandonBlockRequestProto) GetB() *ExtendedBlockProto
func (*AbandonBlockRequestProto) GetFileId ¶ added in v1.0.0
func (m *AbandonBlockRequestProto) GetFileId() uint64
func (*AbandonBlockRequestProto) GetHolder ¶
func (m *AbandonBlockRequestProto) GetHolder() string
func (*AbandonBlockRequestProto) GetSrc ¶
func (m *AbandonBlockRequestProto) GetSrc() string
func (*AbandonBlockRequestProto) ProtoMessage ¶
func (*AbandonBlockRequestProto) ProtoMessage()
func (*AbandonBlockRequestProto) Reset ¶
func (m *AbandonBlockRequestProto) Reset()
func (*AbandonBlockRequestProto) String ¶
func (m *AbandonBlockRequestProto) String() string
type AbandonBlockResponseProto ¶
type AbandonBlockResponseProto struct {
XXX_unrecognized []byte `json:"-"`
}
func (*AbandonBlockResponseProto) Descriptor ¶ added in v1.1.1
func (*AbandonBlockResponseProto) Descriptor() ([]byte, []int)
func (*AbandonBlockResponseProto) ProtoMessage ¶
func (*AbandonBlockResponseProto) ProtoMessage()
func (*AbandonBlockResponseProto) Reset ¶
func (m *AbandonBlockResponseProto) Reset()
func (*AbandonBlockResponseProto) String ¶
func (m *AbandonBlockResponseProto) String() string
type AclEntryProto ¶ added in v1.0.0
type AclEntryProto struct { Type *AclEntryProto_AclEntryTypeProto `protobuf:"varint,1,req,name=type,enum=hadoop.hdfs.AclEntryProto_AclEntryTypeProto" json:"type,omitempty"` Scope *AclEntryProto_AclEntryScopeProto `protobuf:"varint,2,req,name=scope,enum=hadoop.hdfs.AclEntryProto_AclEntryScopeProto" json:"scope,omitempty"` Permissions *AclEntryProto_FsActionProto `protobuf:"varint,3,req,name=permissions,enum=hadoop.hdfs.AclEntryProto_FsActionProto" json:"permissions,omitempty"` Name *string `protobuf:"bytes,4,opt,name=name" json:"name,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*AclEntryProto) Descriptor ¶ added in v1.1.1
func (*AclEntryProto) Descriptor() ([]byte, []int)
func (*AclEntryProto) GetName ¶ added in v1.0.0
func (m *AclEntryProto) GetName() string
func (*AclEntryProto) GetPermissions ¶ added in v1.0.0
func (m *AclEntryProto) GetPermissions() AclEntryProto_FsActionProto
func (*AclEntryProto) GetScope ¶ added in v1.0.0
func (m *AclEntryProto) GetScope() AclEntryProto_AclEntryScopeProto
func (*AclEntryProto) GetType ¶ added in v1.0.0
func (m *AclEntryProto) GetType() AclEntryProto_AclEntryTypeProto
func (*AclEntryProto) ProtoMessage ¶ added in v1.0.0
func (*AclEntryProto) ProtoMessage()
func (*AclEntryProto) Reset ¶ added in v1.0.0
func (m *AclEntryProto) Reset()
func (*AclEntryProto) String ¶ added in v1.0.0
func (m *AclEntryProto) String() string
type AclEntryProto_AclEntryScopeProto ¶ added in v1.0.0
type AclEntryProto_AclEntryScopeProto int32
const ( AclEntryProto_ACCESS AclEntryProto_AclEntryScopeProto = 0 AclEntryProto_DEFAULT AclEntryProto_AclEntryScopeProto = 1 )
func (AclEntryProto_AclEntryScopeProto) Enum ¶ added in v1.0.0
func (x AclEntryProto_AclEntryScopeProto) Enum() *AclEntryProto_AclEntryScopeProto
func (AclEntryProto_AclEntryScopeProto) EnumDescriptor ¶ added in v1.1.1
func (AclEntryProto_AclEntryScopeProto) EnumDescriptor() ([]byte, []int)
func (AclEntryProto_AclEntryScopeProto) String ¶ added in v1.0.0
func (x AclEntryProto_AclEntryScopeProto) String() string
func (*AclEntryProto_AclEntryScopeProto) UnmarshalJSON ¶ added in v1.0.0
func (x *AclEntryProto_AclEntryScopeProto) UnmarshalJSON(data []byte) error
type AclEntryProto_AclEntryTypeProto ¶ added in v1.0.0
type AclEntryProto_AclEntryTypeProto int32
const ( AclEntryProto_USER AclEntryProto_AclEntryTypeProto = 0 AclEntryProto_GROUP AclEntryProto_AclEntryTypeProto = 1 AclEntryProto_MASK AclEntryProto_AclEntryTypeProto = 2 AclEntryProto_OTHER AclEntryProto_AclEntryTypeProto = 3 )
func (AclEntryProto_AclEntryTypeProto) Enum ¶ added in v1.0.0
func (x AclEntryProto_AclEntryTypeProto) Enum() *AclEntryProto_AclEntryTypeProto
func (AclEntryProto_AclEntryTypeProto) EnumDescriptor ¶ added in v1.1.1
func (AclEntryProto_AclEntryTypeProto) EnumDescriptor() ([]byte, []int)
func (AclEntryProto_AclEntryTypeProto) String ¶ added in v1.0.0
func (x AclEntryProto_AclEntryTypeProto) String() string
func (*AclEntryProto_AclEntryTypeProto) UnmarshalJSON ¶ added in v1.0.0
func (x *AclEntryProto_AclEntryTypeProto) UnmarshalJSON(data []byte) error
type AclEntryProto_FsActionProto ¶ added in v1.0.0
type AclEntryProto_FsActionProto int32
const ( AclEntryProto_NONE AclEntryProto_FsActionProto = 0 AclEntryProto_EXECUTE AclEntryProto_FsActionProto = 1 AclEntryProto_WRITE AclEntryProto_FsActionProto = 2 AclEntryProto_WRITE_EXECUTE AclEntryProto_FsActionProto = 3 AclEntryProto_READ AclEntryProto_FsActionProto = 4 AclEntryProto_READ_EXECUTE AclEntryProto_FsActionProto = 5 AclEntryProto_READ_WRITE AclEntryProto_FsActionProto = 6 AclEntryProto_PERM_ALL AclEntryProto_FsActionProto = 7 )
func (AclEntryProto_FsActionProto) Enum ¶ added in v1.0.0
func (x AclEntryProto_FsActionProto) Enum() *AclEntryProto_FsActionProto
func (AclEntryProto_FsActionProto) EnumDescriptor ¶ added in v1.1.1
func (AclEntryProto_FsActionProto) EnumDescriptor() ([]byte, []int)
func (AclEntryProto_FsActionProto) String ¶ added in v1.0.0
func (x AclEntryProto_FsActionProto) String() string
func (*AclEntryProto_FsActionProto) UnmarshalJSON ¶ added in v1.0.0
func (x *AclEntryProto_FsActionProto) UnmarshalJSON(data []byte) error
type AclStatusProto ¶ added in v1.0.0
type AclStatusProto struct { Owner *string `protobuf:"bytes,1,req,name=owner" json:"owner,omitempty"` Group *string `protobuf:"bytes,2,req,name=group" json:"group,omitempty"` Sticky *bool `protobuf:"varint,3,req,name=sticky" json:"sticky,omitempty"` Entries []*AclEntryProto `protobuf:"bytes,4,rep,name=entries" json:"entries,omitempty"` Permission *FsPermissionProto `protobuf:"bytes,5,opt,name=permission" json:"permission,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*AclStatusProto) Descriptor ¶ added in v1.1.1
func (*AclStatusProto) Descriptor() ([]byte, []int)
func (*AclStatusProto) GetEntries ¶ added in v1.0.0
func (m *AclStatusProto) GetEntries() []*AclEntryProto
func (*AclStatusProto) GetGroup ¶ added in v1.0.0
func (m *AclStatusProto) GetGroup() string
func (*AclStatusProto) GetOwner ¶ added in v1.0.0
func (m *AclStatusProto) GetOwner() string
func (*AclStatusProto) GetPermission ¶ added in v1.0.0
func (m *AclStatusProto) GetPermission() *FsPermissionProto
func (*AclStatusProto) GetSticky ¶ added in v1.0.0
func (m *AclStatusProto) GetSticky() bool
func (*AclStatusProto) ProtoMessage ¶ added in v1.0.0
func (*AclStatusProto) ProtoMessage()
func (*AclStatusProto) Reset ¶ added in v1.0.0
func (m *AclStatusProto) Reset()
func (*AclStatusProto) String ¶ added in v1.0.0
func (m *AclStatusProto) String() string
type AddBlockRequestProto ¶
type AddBlockRequestProto struct { Src *string `protobuf:"bytes,1,req,name=src" json:"src,omitempty"` ClientName *string `protobuf:"bytes,2,req,name=clientName" json:"clientName,omitempty"` Previous *ExtendedBlockProto `protobuf:"bytes,3,opt,name=previous" json:"previous,omitempty"` ExcludeNodes []*DatanodeInfoProto `protobuf:"bytes,4,rep,name=excludeNodes" json:"excludeNodes,omitempty"` FileId *uint64 `protobuf:"varint,5,opt,name=fileId,def=0" json:"fileId,omitempty"` FavoredNodes []string `protobuf:"bytes,6,rep,name=favoredNodes" json:"favoredNodes,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*AddBlockRequestProto) Descriptor ¶ added in v1.1.1
func (*AddBlockRequestProto) Descriptor() ([]byte, []int)
func (*AddBlockRequestProto) GetClientName ¶
func (m *AddBlockRequestProto) GetClientName() string
func (*AddBlockRequestProto) GetExcludeNodes ¶
func (m *AddBlockRequestProto) GetExcludeNodes() []*DatanodeInfoProto
func (*AddBlockRequestProto) GetFavoredNodes ¶
func (m *AddBlockRequestProto) GetFavoredNodes() []string
func (*AddBlockRequestProto) GetFileId ¶
func (m *AddBlockRequestProto) GetFileId() uint64
func (*AddBlockRequestProto) GetPrevious ¶
func (m *AddBlockRequestProto) GetPrevious() *ExtendedBlockProto
func (*AddBlockRequestProto) GetSrc ¶
func (m *AddBlockRequestProto) GetSrc() string
func (*AddBlockRequestProto) ProtoMessage ¶
func (*AddBlockRequestProto) ProtoMessage()
func (*AddBlockRequestProto) Reset ¶
func (m *AddBlockRequestProto) Reset()
func (*AddBlockRequestProto) String ¶
func (m *AddBlockRequestProto) String() string
type AddBlockResponseProto ¶
type AddBlockResponseProto struct { Block *LocatedBlockProto `protobuf:"bytes,1,req,name=block" json:"block,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*AddBlockResponseProto) Descriptor ¶ added in v1.1.1
func (*AddBlockResponseProto) Descriptor() ([]byte, []int)
func (*AddBlockResponseProto) GetBlock ¶
func (m *AddBlockResponseProto) GetBlock() *LocatedBlockProto
func (*AddBlockResponseProto) ProtoMessage ¶
func (*AddBlockResponseProto) ProtoMessage()
func (*AddBlockResponseProto) Reset ¶
func (m *AddBlockResponseProto) Reset()
func (*AddBlockResponseProto) String ¶
func (m *AddBlockResponseProto) String() string
type AddCacheDirectiveRequestProto ¶ added in v1.0.0
type AddCacheDirectiveRequestProto struct { Info *CacheDirectiveInfoProto `protobuf:"bytes,1,req,name=info" json:"info,omitempty"` CacheFlags *uint32 `protobuf:"varint,2,opt,name=cacheFlags" json:"cacheFlags,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*AddCacheDirectiveRequestProto) Descriptor ¶ added in v1.1.1
func (*AddCacheDirectiveRequestProto) Descriptor() ([]byte, []int)
func (*AddCacheDirectiveRequestProto) GetCacheFlags ¶ added in v1.0.0
func (m *AddCacheDirectiveRequestProto) GetCacheFlags() uint32
func (*AddCacheDirectiveRequestProto) GetInfo ¶ added in v1.0.0
func (m *AddCacheDirectiveRequestProto) GetInfo() *CacheDirectiveInfoProto