hadoop_hdfs

package

Go to main page

Versions in this module

v1

v1.1.6

Jul 22, 2021

v1.1.5

Jul 19, 2021

v1.1.4

Jul 19, 2021

Changes in this version

+ func LoadAPI()

v1.1.3

Jun 22, 2018

v1.1.2

Jun 22, 2018

v1.1.1

May 11, 2018

Changes in this version

type AbandonBlockRequestProto

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

type AbandonBlockResponseProto

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

type AclEntryProto

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

type AclEntryProto_AclEntryScopeProto

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

type AclEntryProto_AclEntryTypeProto

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

type AclEntryProto_FsActionProto

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

type AclStatusProto

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

type AddBlockRequestProto

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

type AddBlockResponseProto

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

type AddCacheDirectiveRequestProto

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

type AddCacheDirectiveResponseProto

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

type AddCachePoolRequestProto

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

type AddCachePoolResponseProto

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

type AllowSnapshotRequestProto

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

type AllowSnapshotResponseProto

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

type AppendEventProto

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

type AppendRequestProto

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

type AppendResponseProto

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

type BaseHeaderProto

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

type BlockECReconstructionInfoProto

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

type BlockOpResponseProto

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

type BlockProto

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

type BlockStoragePolicyProto

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

type CacheDirectiveEntryProto

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

type CacheDirectiveInfoExpirationProto

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

type CacheDirectiveInfoProto

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

type CacheDirectiveStatsProto

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

type CacheFlagProto

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

type CachePoolEntryProto

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

type CachePoolInfoProto

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

type CachePoolStatsProto

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

type CachingStrategyProto

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

type CheckAccessRequestProto

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

type CheckAccessResponseProto

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

type ChecksumProto

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

type ChecksumTypeProto

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

type CipherOptionProto

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

type CipherSuiteProto

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

type ClientOperationHeaderProto

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

type ClientReadStatusProto

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

type CloseEventProto

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

type CompleteRequestProto

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

type CompleteResponseProto

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

type ConcatRequestProto

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

type ConcatResponseProto

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

type ContentSummaryProto

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

type CorruptFileBlocksProto

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

type CreateEncryptionZoneRequestProto

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

type CreateEncryptionZoneResponseProto

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

type CreateEventProto

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

type CreateFlagProto

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

type CreateRequestProto

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

type CreateResponseProto

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

type CreateSnapshotRequestProto

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

type CreateSnapshotResponseProto

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

type CreateSymlinkRequestProto

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

type CreateSymlinkResponseProto

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

type CryptoProtocolVersionProto

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

type DNTransferAckProto

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

type DataEncryptionKeyProto

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

type DataTransferEncryptorMessageProto

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

type DataTransferEncryptorMessageProto_DataTransferEncryptorStatus

+ func (DataTransferEncryptorMessageProto_DataTransferEncryptorStatus) EnumDescriptor() ([]byte, []int)

type DataTransferTraceInfoProto

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

type DatanodeIDProto

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

type DatanodeInfoProto

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

type DatanodeInfoProto_AdminState

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

type DatanodeInfosProto

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

type DatanodeLocalInfoProto

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

type DatanodeReportTypeProto

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

type DatanodeStorageProto

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

type DatanodeStorageProto_StorageState

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

type DatanodeStorageReportProto

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

type DeleteBlockPoolRequestProto

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

type DeleteBlockPoolResponseProto

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

type DeleteRequestProto

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

type DeleteResponseProto

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

type DeleteSnapshotRequestProto

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

type DeleteSnapshotResponseProto

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

type DirectoryListingProto

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

type DisallowSnapshotRequestProto

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

type DisallowSnapshotResponseProto

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

type ECSchemaOptionEntryProto

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

type ECSchemaProto

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

type EncryptionZoneProto

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

type ErasureCodingPolicyProto

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

type EventBatchProto

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

type EventProto

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

type EventType

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

type EventsListProto

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

type EvictWritersRequestProto

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

type EvictWritersResponseProto

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

type ExtendedBlockProto

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

type FileEncryptionInfoProto

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

type FinalizeUpgradeRequestProto

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

type FinalizeUpgradeResponseProto

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

type FsPermissionProto

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

type FsServerDefaultsProto

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

type FsyncRequestProto

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

type FsyncResponseProto

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

type GetAclStatusRequestProto

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

type GetAclStatusResponseProto

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

type GetAdditionalDatanodeRequestProto

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

type GetAdditionalDatanodeResponseProto

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

type GetBalancerBandwidthRequestProto

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

type GetBalancerBandwidthResponseProto

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

type GetBlockLocalPathInfoRequestProto

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

type GetBlockLocalPathInfoResponseProto

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

type GetBlockLocationsRequestProto

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

type GetBlockLocationsResponseProto

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

type GetContentSummaryRequestProto

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

type GetContentSummaryResponseProto

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

type GetCurrentEditLogTxidRequestProto

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

type GetCurrentEditLogTxidResponseProto

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

type GetDataEncryptionKeyRequestProto

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

type GetDataEncryptionKeyResponseProto

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

type GetDatanodeInfoRequestProto

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

type GetDatanodeInfoResponseProto

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

type GetDatanodeReportRequestProto

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

type GetDatanodeReportResponseProto

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

type GetDatanodeStorageReportRequestProto

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

type GetDatanodeStorageReportResponseProto

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

type GetEZForPathRequestProto

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

type GetEZForPathResponseProto

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

type GetEditsFromTxidRequestProto

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

type GetEditsFromTxidResponseProto

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

type GetErasureCodingPoliciesRequestProto

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

type GetErasureCodingPoliciesResponseProto

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

type GetErasureCodingPolicyRequestProto

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

type GetErasureCodingPolicyResponseProto

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

type GetFileInfoRequestProto

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

type GetFileInfoResponseProto

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

type GetFileLinkInfoRequestProto

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

type GetFileLinkInfoResponseProto

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

type GetFsStatsResponseProto

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

type GetFsStatusRequestProto

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

type GetLinkTargetRequestProto

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

type GetLinkTargetResponseProto

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

type GetListingRequestProto

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

type GetListingResponseProto

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

type GetPreferredBlockSizeRequestProto

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

type GetPreferredBlockSizeResponseProto

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

type GetQuotaUsageRequestProto

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

type GetQuotaUsageResponseProto

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

type GetReconfigurationStatusConfigChangeProto

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

type GetReconfigurationStatusRequestProto

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

type GetReconfigurationStatusResponseProto

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

type GetReplicaVisibleLengthRequestProto

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

type GetReplicaVisibleLengthResponseProto

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

type GetServerDefaultsRequestProto

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

type GetServerDefaultsResponseProto

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

type GetSnapshotDiffReportRequestProto

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

type GetSnapshotDiffReportResponseProto

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

type GetSnapshottableDirListingRequestProto

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

type GetSnapshottableDirListingResponseProto

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

type GetStoragePoliciesRequestProto

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

type GetStoragePoliciesResponseProto

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

type GetStoragePolicyRequestProto

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

type GetStoragePolicyResponseProto

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

type GetXAttrsRequestProto

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

type GetXAttrsResponseProto

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

type HdfsFileStatusProto

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

type HdfsFileStatusProto_FileType

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

type INodeType

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

type IsFileClosedRequestProto

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

type IsFileClosedResponseProto

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

type ListCacheDirectivesRequestProto

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

type ListCacheDirectivesResponseProto

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

type ListCachePoolsRequestProto

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

type ListCachePoolsResponseProto

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

type ListCorruptFileBlocksRequestProto

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

type ListCorruptFileBlocksResponseProto

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

type ListEncryptionZonesRequestProto

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

type ListEncryptionZonesResponseProto

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

type ListReconfigurablePropertiesRequestProto

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

type ListReconfigurablePropertiesResponseProto

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

type ListXAttrsRequestProto

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

type ListXAttrsResponseProto

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

type LocatedBlockProto

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

type LocatedBlocksProto

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

type MetaSaveRequestProto

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

type MetaSaveResponseProto

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

type MetadataUpdateEventProto

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

type MetadataUpdateType

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

type MkdirsRequestProto

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

type MkdirsResponseProto

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

type ModifyAclEntriesRequestProto

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

type ModifyAclEntriesResponseProto

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

type ModifyCacheDirectiveRequestProto

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

type ModifyCacheDirectiveResponseProto

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

type ModifyCachePoolRequestProto

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

type ModifyCachePoolResponseProto

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

type OpBlockChecksumProto

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

type OpBlockChecksumResponseProto

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

type OpBlockGroupChecksumProto

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

type OpCopyBlockProto

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

type OpCustomProto

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

type OpReadBlockProto

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

type OpReplaceBlockProto

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

type OpRequestShortCircuitAccessProto

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

type OpTransferBlockProto

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

type OpWriteBlockProto

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

type OpWriteBlockProto_BlockConstructionStage

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

type PacketHeaderProto

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

type PerFileEncryptionInfoProto

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

type PipelineAckProto

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

type QuotaUsageProto

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

type ReadOpChecksumInfoProto

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

type RecoverLeaseRequestProto

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

type RecoverLeaseResponseProto

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

type RefreshNamenodesRequestProto

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

type RefreshNamenodesResponseProto

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

type RefreshNodesRequestProto

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

type RefreshNodesResponseProto

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

type ReleaseShortCircuitAccessRequestProto

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

type ReleaseShortCircuitAccessResponseProto

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

type RemoveAclEntriesRequestProto

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

type RemoveAclEntriesResponseProto

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

type RemoveAclRequestProto

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

type RemoveAclResponseProto

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

type RemoveCacheDirectiveRequestProto

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

type RemoveCacheDirectiveResponseProto

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

type RemoveCachePoolRequestProto

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

type RemoveCachePoolResponseProto

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

type RemoveDefaultAclRequestProto

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

type RemoveDefaultAclResponseProto

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

type RemoveXAttrRequestProto

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

type RemoveXAttrResponseProto

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

type Rename2RequestProto

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

type Rename2ResponseProto

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

type RenameEventProto

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

type RenameRequestProto

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

type RenameResponseProto

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

type RenameSnapshotRequestProto

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

type RenameSnapshotResponseProto

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

type RenewLeaseRequestProto

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

type RenewLeaseResponseProto

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

type ReportBadBlocksRequestProto

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

type ReportBadBlocksResponseProto

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

type RestoreFailedStorageRequestProto

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

type RestoreFailedStorageResponseProto

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

type RollEditsRequestProto

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

type RollEditsResponseProto

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

type RollingUpgradeActionProto

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

type RollingUpgradeInfoProto

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

type RollingUpgradeRequestProto

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

type RollingUpgradeResponseProto

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

type RollingUpgradeStatusProto

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

type SafeModeActionProto

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

type SaveNamespaceRequestProto

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

type SaveNamespaceResponseProto

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

type SetAclRequestProto

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

type SetAclResponseProto

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

type SetBalancerBandwidthRequestProto

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

type SetBalancerBandwidthResponseProto

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

type SetErasureCodingPolicyRequestProto

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

type SetErasureCodingPolicyResponseProto

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

type SetOwnerRequestProto

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

type SetOwnerResponseProto

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

type SetPermissionRequestProto

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

type SetPermissionResponseProto

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

type SetQuotaRequestProto

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

type SetQuotaResponseProto

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

type SetReplicationRequestProto

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

type SetReplicationResponseProto

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

type SetSafeModeRequestProto

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

type SetSafeModeResponseProto

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

type SetStoragePolicyRequestProto

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

type SetStoragePolicyResponseProto

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

type SetTimesRequestProto

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

type SetTimesResponseProto

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

type SetXAttrRequestProto

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

type SetXAttrResponseProto

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

type ShortCircuitFdResponse

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

type ShortCircuitShmIdProto

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

type ShortCircuitShmRequestProto

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

type ShortCircuitShmResponseProto

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

type ShortCircuitShmSlotProto

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

type ShutdownDatanodeRequestProto

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

type ShutdownDatanodeResponseProto

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

type SnapshotDiffReportEntryProto

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

type SnapshotDiffReportProto

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

type SnapshotInfoProto

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

type SnapshottableDirectoryListingProto

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

type SnapshottableDirectoryStatusProto

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

type StartReconfigurationRequestProto

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

type StartReconfigurationResponseProto

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

type Status

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

type StorageReportProto

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

type StorageTypeProto

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

type StorageTypeQuotaInfoProto

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

type StorageTypeQuotaInfosProto

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

type StorageTypesProto

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

type StorageUuidsProto

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

type TriggerBlockReportRequestProto

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

type TriggerBlockReportResponseProto

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

type TruncateEventProto

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

type TruncateRequestProto

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

type TruncateResponseProto

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

type UnlinkEventProto

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

type UnsetStoragePolicyRequestProto

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

type UnsetStoragePolicyResponseProto

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

type UpdateBlockForPipelineRequestProto

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

type UpdateBlockForPipelineResponseProto

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

type UpdatePipelineRequestProto

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

type UpdatePipelineResponseProto

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

type XAttrProto

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

type XAttrProto_XAttrNamespaceProto

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

type XAttrSetFlagProto

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

type ZoneEncryptionInfoProto

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

v1.1.0

Oct 26, 2017

v1.0.4

Aug 22, 2017

v1.0.3

Mar 13, 2017

v1.0.2

Feb 25, 2017

v1.0.1

Jan 23, 2017

v1.0.0

Oct 26, 2016

Changes in this version

+ const Default_AbandonBlockRequestProto_FileId

+ const Default_AppendEventProto_NewBlock

+ const Default_CreateEventProto_DefaultBlockSize

+ const Default_DatanodeInfoProto_CacheCapacity

+ const Default_DatanodeInfoProto_CacheUsed

+ const Default_DatanodeInfoProto_LastUpdateMonotonic

+ const Default_FsyncRequestProto_FileId

+ const Default_GetAdditionalDatanodeRequestProto_FileId

+ const Default_HdfsFileStatusProto_StoragePolicy

+ const Default_OpRequestShortCircuitAccessProto_SupportsReceiptVerification

+ const Default_OpWriteBlockProto_AllowLazyPersist

+ const Default_OpWriteBlockProto_Pinning

+ const Default_RollingUpgradeStatusProto_Finalized

+ const Default_SaveNamespaceRequestProto_TimeWindow

+ const Default_SaveNamespaceRequestProto_TxGap

+ const Default_SaveNamespaceResponseProto_Saved

+ const Default_StorageReportProto_BlockPoolUsed

+ const Default_StorageReportProto_Capacity

+ const Default_StorageReportProto_DfsUsed

+ const Default_StorageReportProto_Failed

+ const Default_StorageReportProto_Remaining

+ var AclEntryProto_AclEntryScopeProto_name = map[int32]string

+ var AclEntryProto_AclEntryScopeProto_value = map[string]int32

+ var AclEntryProto_AclEntryTypeProto_name = map[int32]string

+ var AclEntryProto_AclEntryTypeProto_value = map[string]int32

+ var AclEntryProto_FsActionProto_name = map[int32]string

+ var AclEntryProto_FsActionProto_value = map[string]int32

+ var CacheFlagProto_name = map[int32]string

+ var CacheFlagProto_value = map[string]int32

+ var CipherSuiteProto_name = map[int32]string

+ var CipherSuiteProto_value = map[string]int32

+ var CryptoProtocolVersionProto_name = map[int32]string

+ var CryptoProtocolVersionProto_value = map[string]int32

+ var DatanodeStorageProto_StorageState_name = map[int32]string

+ var DatanodeStorageProto_StorageState_value = map[string]int32

+ var EventType_name = map[int32]string

+ var EventType_value = map[string]int32

+ var INodeType_name = map[int32]string

+ var INodeType_value = map[string]int32

+ var MetadataUpdateType_name = map[int32]string

+ var MetadataUpdateType_value = map[string]int32

+ var RollingUpgradeActionProto_name = map[int32]string

+ var RollingUpgradeActionProto_value = map[string]int32

+ var ShortCircuitFdResponse_name = map[int32]string

+ var ShortCircuitFdResponse_value = map[string]int32

+ var StorageTypeProto_name = map[int32]string

+ var StorageTypeProto_value = map[string]int32

+ var XAttrProto_XAttrNamespaceProto_name = map[int32]string

+ var XAttrProto_XAttrNamespaceProto_value = map[string]int32

+ var XAttrSetFlagProto_name = map[int32]string

+ var XAttrSetFlagProto_value = map[string]int32

type AbandonBlockRequestProto

+ FileId *uint64

+ func (m *AbandonBlockRequestProto) GetFileId() uint64

+ type AclEntryProto struct

+ Name *string

+ Permissions *AclEntryProto_FsActionProto

+ Scope *AclEntryProto_AclEntryScopeProto

+ Type *AclEntryProto_AclEntryTypeProto

+ XXX_unrecognized []byte

+ func (*AclEntryProto) ProtoMessage()

+ func (m *AclEntryProto) GetName() string

+ func (m *AclEntryProto) GetPermissions() AclEntryProto_FsActionProto

+ func (m *AclEntryProto) GetScope() AclEntryProto_AclEntryScopeProto

+ func (m *AclEntryProto) GetType() AclEntryProto_AclEntryTypeProto

+ func (m *AclEntryProto) Reset()

+ func (m *AclEntryProto) String() string

+ type AclEntryProto_AclEntryScopeProto int32

+ const AclEntryProto_ACCESS

+ const AclEntryProto_DEFAULT

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

+ func (x AclEntryProto_AclEntryScopeProto) Enum() *AclEntryProto_AclEntryScopeProto

+ func (x AclEntryProto_AclEntryScopeProto) String() string

+ type AclEntryProto_AclEntryTypeProto int32

+ const AclEntryProto_GROUP

+ const AclEntryProto_MASK

+ const AclEntryProto_OTHER

+ const AclEntryProto_USER

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

+ func (x AclEntryProto_AclEntryTypeProto) Enum() *AclEntryProto_AclEntryTypeProto

+ func (x AclEntryProto_AclEntryTypeProto) String() string

+ type AclEntryProto_FsActionProto int32

+ const AclEntryProto_EXECUTE

+ const AclEntryProto_NONE

+ const AclEntryProto_PERM_ALL

+ const AclEntryProto_READ

+ const AclEntryProto_READ_EXECUTE

+ const AclEntryProto_READ_WRITE

+ const AclEntryProto_WRITE

+ const AclEntryProto_WRITE_EXECUTE

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

+ func (x AclEntryProto_FsActionProto) Enum() *AclEntryProto_FsActionProto

+ func (x AclEntryProto_FsActionProto) String() string

+ type AclStatusProto struct

+ Entries []*AclEntryProto

+ Group *string

+ Owner *string

+ Permission *FsPermissionProto

+ Sticky *bool

+ XXX_unrecognized []byte

+ func (*AclStatusProto) ProtoMessage()

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

+ func (m *AclStatusProto) GetGroup() string

+ func (m *AclStatusProto) GetOwner() string

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

+ func (m *AclStatusProto) GetSticky() bool

+ func (m *AclStatusProto) Reset()

+ func (m *AclStatusProto) String() string

+ type AddCacheDirectiveRequestProto struct

+ CacheFlags *uint32

+ Info *CacheDirectiveInfoProto

+ XXX_unrecognized []byte

+ func (*AddCacheDirectiveRequestProto) ProtoMessage()

+ func (m *AddCacheDirectiveRequestProto) GetCacheFlags() uint32

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

+ func (m *AddCacheDirectiveRequestProto) Reset()

+ func (m *AddCacheDirectiveRequestProto) String() string

+ type AddCacheDirectiveResponseProto struct

+ Id *int64

+ XXX_unrecognized []byte

+ func (*AddCacheDirectiveResponseProto) ProtoMessage()

+ func (m *AddCacheDirectiveResponseProto) GetId() int64

+ func (m *AddCacheDirectiveResponseProto) Reset()

+ func (m *AddCacheDirectiveResponseProto) String() string

+ type AddCachePoolRequestProto struct

+ Info *CachePoolInfoProto

+ XXX_unrecognized []byte

+ func (*AddCachePoolRequestProto) ProtoMessage()

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

+ func (m *AddCachePoolRequestProto) Reset()

+ func (m *AddCachePoolRequestProto) String() string

+ type AddCachePoolResponseProto struct

+ XXX_unrecognized []byte

+ func (*AddCachePoolResponseProto) ProtoMessage()

+ func (m *AddCachePoolResponseProto) Reset()

+ func (m *AddCachePoolResponseProto) String() string

+ type AppendEventProto struct

+ NewBlock *bool

+ Path *string

+ XXX_unrecognized []byte

+ func (*AppendEventProto) ProtoMessage()

+ func (m *AppendEventProto) GetNewBlock() bool

+ func (m *AppendEventProto) GetPath() string

+ func (m *AppendEventProto) Reset()

+ func (m *AppendEventProto) String() string

type AppendRequestProto

+ Flag *uint32

+ func (m *AppendRequestProto) GetFlag() uint32

type AppendResponseProto

+ Stat *HdfsFileStatusProto

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

type BaseHeaderProto

+ TraceInfo *DataTransferTraceInfoProto

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

+ type BlockECReconstructionInfoProto struct

+ Block *ExtendedBlockProto

+ EcPolicy *ErasureCodingPolicyProto

+ LiveBlockIndices []byte

+ SourceDnInfos *DatanodeInfosProto

+ TargetDnInfos *DatanodeInfosProto

+ TargetStorageTypes *StorageTypesProto

+ TargetStorageUuids *StorageUuidsProto

+ XXX_unrecognized []byte

+ func (*BlockECReconstructionInfoProto) ProtoMessage()

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

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

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

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

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

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

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

+ func (m *BlockECReconstructionInfoProto) Reset()

+ func (m *BlockECReconstructionInfoProto) String() string

+ type BlockStoragePolicyProto struct

+ CreationFallbackPolicy *StorageTypesProto

+ CreationPolicy *StorageTypesProto

+ Name *string

+ PolicyId *uint32

+ ReplicationFallbackPolicy *StorageTypesProto

+ XXX_unrecognized []byte

+ func (*BlockStoragePolicyProto) ProtoMessage()

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

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

+ func (m *BlockStoragePolicyProto) GetName() string

+ func (m *BlockStoragePolicyProto) GetPolicyId() uint32

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

+ func (m *BlockStoragePolicyProto) Reset()

+ func (m *BlockStoragePolicyProto) String() string

+ type CacheDirectiveEntryProto struct

+ Info *CacheDirectiveInfoProto

+ Stats *CacheDirectiveStatsProto

+ XXX_unrecognized []byte

+ func (*CacheDirectiveEntryProto) ProtoMessage()

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

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

+ func (m *CacheDirectiveEntryProto) Reset()

+ func (m *CacheDirectiveEntryProto) String() string

+ type CacheDirectiveInfoExpirationProto struct

+ IsRelative *bool

+ Millis *int64

+ XXX_unrecognized []byte

+ func (*CacheDirectiveInfoExpirationProto) ProtoMessage()

+ func (m *CacheDirectiveInfoExpirationProto) GetIsRelative() bool

+ func (m *CacheDirectiveInfoExpirationProto) GetMillis() int64

+ func (m *CacheDirectiveInfoExpirationProto) Reset()

+ func (m *CacheDirectiveInfoExpirationProto) String() string

+ type CacheDirectiveInfoProto struct

+ Expiration *CacheDirectiveInfoExpirationProto

+ Id *int64

+ Path *string

+ Pool *string

+ Replication *uint32

+ XXX_unrecognized []byte

+ func (*CacheDirectiveInfoProto) ProtoMessage()

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

+ func (m *CacheDirectiveInfoProto) GetId() int64

+ func (m *CacheDirectiveInfoProto) GetPath() string

+ func (m *CacheDirectiveInfoProto) GetPool() string

+ func (m *CacheDirectiveInfoProto) GetReplication() uint32

+ func (m *CacheDirectiveInfoProto) Reset()

+ func (m *CacheDirectiveInfoProto) String() string

+ type CacheDirectiveStatsProto struct

+ BytesCached *int64

+ BytesNeeded *int64

+ FilesCached *int64

+ FilesNeeded *int64

+ HasExpired *bool

+ XXX_unrecognized []byte

+ func (*CacheDirectiveStatsProto) ProtoMessage()

+ func (m *CacheDirectiveStatsProto) GetBytesCached() int64

+ func (m *CacheDirectiveStatsProto) GetBytesNeeded() int64

+ func (m *CacheDirectiveStatsProto) GetFilesCached() int64

+ func (m *CacheDirectiveStatsProto) GetFilesNeeded() int64

+ func (m *CacheDirectiveStatsProto) GetHasExpired() bool

+ func (m *CacheDirectiveStatsProto) Reset()

+ func (m *CacheDirectiveStatsProto) String() string

+ type CacheFlagProto int32

+ const CacheFlagProto_FORCE

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

+ func (x CacheFlagProto) Enum() *CacheFlagProto

+ func (x CacheFlagProto) String() string

+ type CachePoolEntryProto struct

+ Info *CachePoolInfoProto

+ Stats *CachePoolStatsProto

+ XXX_unrecognized []byte

+ func (*CachePoolEntryProto) ProtoMessage()

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

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

+ func (m *CachePoolEntryProto) Reset()

+ func (m *CachePoolEntryProto) String() string

+ type CachePoolInfoProto struct

+ GroupName *string

+ Limit *int64

+ MaxRelativeExpiry *int64

+ Mode *int32

+ OwnerName *string

+ PoolName *string

+ XXX_unrecognized []byte

+ func (*CachePoolInfoProto) ProtoMessage()

+ func (m *CachePoolInfoProto) GetGroupName() string

+ func (m *CachePoolInfoProto) GetLimit() int64

+ func (m *CachePoolInfoProto) GetMaxRelativeExpiry() int64

+ func (m *CachePoolInfoProto) GetMode() int32

+ func (m *CachePoolInfoProto) GetOwnerName() string

+ func (m *CachePoolInfoProto) GetPoolName() string

+ func (m *CachePoolInfoProto) Reset()

+ func (m *CachePoolInfoProto) String() string

+ type CachePoolStatsProto struct

+ BytesCached *int64

+ BytesNeeded *int64

+ BytesOverlimit *int64

+ FilesCached *int64

+ FilesNeeded *int64

+ XXX_unrecognized []byte

+ func (*CachePoolStatsProto) ProtoMessage()

+ func (m *CachePoolStatsProto) GetBytesCached() int64

+ func (m *CachePoolStatsProto) GetBytesNeeded() int64

+ func (m *CachePoolStatsProto) GetBytesOverlimit() int64

+ func (m *CachePoolStatsProto) GetFilesCached() int64

+ func (m *CachePoolStatsProto) GetFilesNeeded() int64

+ func (m *CachePoolStatsProto) Reset()

+ func (m *CachePoolStatsProto) String() string

+ type CheckAccessRequestProto struct

+ Mode *AclEntryProto_FsActionProto

+ Path *string

+ XXX_unrecognized []byte

+ func (*CheckAccessRequestProto) ProtoMessage()

+ func (m *CheckAccessRequestProto) GetMode() AclEntryProto_FsActionProto

+ func (m *CheckAccessRequestProto) GetPath() string

+ func (m *CheckAccessRequestProto) Reset()

+ func (m *CheckAccessRequestProto) String() string

+ type CheckAccessResponseProto struct

+ XXX_unrecognized []byte

+ func (*CheckAccessResponseProto) ProtoMessage()

+ func (m *CheckAccessResponseProto) Reset()

+ func (m *CheckAccessResponseProto) String() string

+ type CipherOptionProto struct

+ InIv []byte

+ InKey []byte

+ OutIv []byte

+ OutKey []byte

+ Suite *CipherSuiteProto

+ XXX_unrecognized []byte

+ func (*CipherOptionProto) ProtoMessage()

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

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

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

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

+ func (m *CipherOptionProto) GetSuite() CipherSuiteProto

+ func (m *CipherOptionProto) Reset()

+ func (m *CipherOptionProto) String() string

+ type CipherSuiteProto int32

+ const CipherSuiteProto_AES_CTR_NOPADDING

+ const CipherSuiteProto_UNKNOWN

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

+ func (x CipherSuiteProto) Enum() *CipherSuiteProto

+ func (x CipherSuiteProto) String() string

+ type CloseEventProto struct

+ FileSize *int64

+ Path *string

+ Timestamp *int64

+ XXX_unrecognized []byte

+ func (*CloseEventProto) ProtoMessage()

+ func (m *CloseEventProto) GetFileSize() int64

+ func (m *CloseEventProto) GetPath() string

+ func (m *CloseEventProto) GetTimestamp() int64

+ func (m *CloseEventProto) Reset()

+ func (m *CloseEventProto) String() string

type ContentSummaryProto

+ TypeQuotaInfos *StorageTypeQuotaInfosProto

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

+ type CreateEncryptionZoneRequestProto struct

+ KeyName *string

+ Src *string

+ XXX_unrecognized []byte

+ func (*CreateEncryptionZoneRequestProto) ProtoMessage()

+ func (m *CreateEncryptionZoneRequestProto) GetKeyName() string

+ func (m *CreateEncryptionZoneRequestProto) GetSrc() string

+ func (m *CreateEncryptionZoneRequestProto) Reset()

+ func (m *CreateEncryptionZoneRequestProto) String() string

+ type CreateEncryptionZoneResponseProto struct

+ XXX_unrecognized []byte

+ func (*CreateEncryptionZoneResponseProto) ProtoMessage()

+ func (m *CreateEncryptionZoneResponseProto) Reset()

+ func (m *CreateEncryptionZoneResponseProto) String() string

+ type CreateEventProto struct

+ Ctime *int64

+ DefaultBlockSize *int64

+ GroupName *string

+ Overwrite *bool

+ OwnerName *string

+ Path *string

+ Perms *FsPermissionProto

+ Replication *int32

+ SymlinkTarget *string

+ Type *INodeType

+ XXX_unrecognized []byte

+ func (*CreateEventProto) ProtoMessage()

+ func (m *CreateEventProto) GetCtime() int64

+ func (m *CreateEventProto) GetDefaultBlockSize() int64

+ func (m *CreateEventProto) GetGroupName() string

+ func (m *CreateEventProto) GetOverwrite() bool

+ func (m *CreateEventProto) GetOwnerName() string

+ func (m *CreateEventProto) GetPath() string

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

+ func (m *CreateEventProto) GetReplication() int32

+ func (m *CreateEventProto) GetSymlinkTarget() string

+ func (m *CreateEventProto) GetType() INodeType

+ func (m *CreateEventProto) Reset()

+ func (m *CreateEventProto) String() string

type CreateFlagProto

+ const CreateFlagProto_LAZY_PERSIST

+ const CreateFlagProto_NEW_BLOCK

type CreateRequestProto

+ CryptoProtocolVersion []CryptoProtocolVersionProto

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

+ type CryptoProtocolVersionProto int32

+ const CryptoProtocolVersionProto_ENCRYPTION_ZONES

+ const CryptoProtocolVersionProto_UNKNOWN_PROTOCOL_VERSION

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

+ func (x CryptoProtocolVersionProto) Enum() *CryptoProtocolVersionProto

+ func (x CryptoProtocolVersionProto) String() string

type DataTransferEncryptorMessageProto

+ CipherOption []*CipherOptionProto

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

+ type DataTransferTraceInfoProto struct

+ ParentId *uint64

+ TraceId *uint64

+ XXX_unrecognized []byte

+ func (*DataTransferTraceInfoProto) ProtoMessage()

+ func (m *DataTransferTraceInfoProto) GetParentId() uint64

+ func (m *DataTransferTraceInfoProto) GetTraceId() uint64

+ func (m *DataTransferTraceInfoProto) Reset()

+ func (m *DataTransferTraceInfoProto) String() string

type DatanodeIDProto

+ DatanodeUuid *string

+ func (m *DatanodeIDProto) GetDatanodeUuid() string

type DatanodeInfoProto

+ CacheCapacity *uint64

+ CacheUsed *uint64

+ LastUpdateMonotonic *uint64

+ UpgradeDomain *string

+ func (m *DatanodeInfoProto) GetCacheCapacity() uint64

+ func (m *DatanodeInfoProto) GetCacheUsed() uint64

+ func (m *DatanodeInfoProto) GetLastUpdateMonotonic() uint64

+ func (m *DatanodeInfoProto) GetUpgradeDomain() string

+ type DatanodeLocalInfoProto struct

+ ConfigVersion *string

+ SoftwareVersion *string

+ Uptime *uint64

+ XXX_unrecognized []byte

+ func (*DatanodeLocalInfoProto) ProtoMessage()

+ func (m *DatanodeLocalInfoProto) GetConfigVersion() string

+ func (m *DatanodeLocalInfoProto) GetSoftwareVersion() string

+ func (m *DatanodeLocalInfoProto) GetUptime() uint64

+ func (m *DatanodeLocalInfoProto) Reset()

+ func (m *DatanodeLocalInfoProto) String() string

type DatanodeReportTypeProto

+ const DatanodeReportTypeProto_DECOMMISSIONING

+ type DatanodeStorageProto struct

+ State *DatanodeStorageProto_StorageState

+ StorageType *StorageTypeProto

+ StorageUuid *string

+ XXX_unrecognized []byte

+ func (*DatanodeStorageProto) ProtoMessage()

+ func (m *DatanodeStorageProto) GetState() DatanodeStorageProto_StorageState

+ func (m *DatanodeStorageProto) GetStorageType() StorageTypeProto

+ func (m *DatanodeStorageProto) GetStorageUuid() string

+ func (m *DatanodeStorageProto) Reset()

+ func (m *DatanodeStorageProto) String() string

+ type DatanodeStorageProto_StorageState int32

+ const DatanodeStorageProto_NORMAL

+ const DatanodeStorageProto_READ_ONLY_SHARED

+ const Default_DatanodeStorageProto_State

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

+ func (x DatanodeStorageProto_StorageState) Enum() *DatanodeStorageProto_StorageState

+ func (x DatanodeStorageProto_StorageState) String() string

+ type DatanodeStorageReportProto struct

+ DatanodeInfo *DatanodeInfoProto

+ StorageReports []*StorageReportProto

+ XXX_unrecognized []byte

+ func (*DatanodeStorageReportProto) ProtoMessage()

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

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

+ func (m *DatanodeStorageReportProto) Reset()

+ func (m *DatanodeStorageReportProto) String() string

+ type DeleteBlockPoolRequestProto struct

+ BlockPool *string

+ Force *bool

+ XXX_unrecognized []byte

+ func (*DeleteBlockPoolRequestProto) ProtoMessage()

+ func (m *DeleteBlockPoolRequestProto) GetBlockPool() string

+ func (m *DeleteBlockPoolRequestProto) GetForce() bool

+ func (m *DeleteBlockPoolRequestProto) Reset()

+ func (m *DeleteBlockPoolRequestProto) String() string

+ type DeleteBlockPoolResponseProto struct

+ XXX_unrecognized []byte

+ func (*DeleteBlockPoolResponseProto) ProtoMessage()

+ func (m *DeleteBlockPoolResponseProto) Reset()

+ func (m *DeleteBlockPoolResponseProto) String() string

+ type ECSchemaOptionEntryProto struct

+ Key *string

+ Value *string

+ XXX_unrecognized []byte

+ func (*ECSchemaOptionEntryProto) ProtoMessage()

+ func (m *ECSchemaOptionEntryProto) GetKey() string

+ func (m *ECSchemaOptionEntryProto) GetValue() string

+ func (m *ECSchemaOptionEntryProto) Reset()

+ func (m *ECSchemaOptionEntryProto) String() string

+ type ECSchemaProto struct

+ CodecName *string

+ DataUnits *uint32

+ Options []*ECSchemaOptionEntryProto

+ ParityUnits *uint32

+ XXX_unrecognized []byte

+ func (*ECSchemaProto) ProtoMessage()

+ func (m *ECSchemaProto) GetCodecName() string

+ func (m *ECSchemaProto) GetDataUnits() uint32

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

+ func (m *ECSchemaProto) GetParityUnits() uint32

+ func (m *ECSchemaProto) Reset()

+ func (m *ECSchemaProto) String() string

+ type EncryptionZoneProto struct

+ CryptoProtocolVersion *CryptoProtocolVersionProto

+ Id *int64

+ KeyName *string

+ Path *string

+ Suite *CipherSuiteProto

+ XXX_unrecognized []byte

+ func (*EncryptionZoneProto) ProtoMessage()

+ func (m *EncryptionZoneProto) GetCryptoProtocolVersion() CryptoProtocolVersionProto

+ func (m *EncryptionZoneProto) GetId() int64

+ func (m *EncryptionZoneProto) GetKeyName() string

+ func (m *EncryptionZoneProto) GetPath() string

+ func (m *EncryptionZoneProto) GetSuite() CipherSuiteProto

+ func (m *EncryptionZoneProto) Reset()

+ func (m *EncryptionZoneProto) String() string

+ type ErasureCodingPolicyProto struct

+ CellSize *uint32

+ Id *uint32

+ Name *string

+ Schema *ECSchemaProto

+ XXX_unrecognized []byte

+ func (*ErasureCodingPolicyProto) ProtoMessage()

+ func (m *ErasureCodingPolicyProto) GetCellSize() uint32

+ func (m *ErasureCodingPolicyProto) GetId() uint32

+ func (m *ErasureCodingPolicyProto) GetName() string

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

+ func (m *ErasureCodingPolicyProto) Reset()

+ func (m *ErasureCodingPolicyProto) String() string

+ type EventBatchProto struct

+ Events []*EventProto

+ Txid *int64

+ XXX_unrecognized []byte

+ func (*EventBatchProto) ProtoMessage()

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

+ func (m *EventBatchProto) GetTxid() int64

+ func (m *EventBatchProto) Reset()

+ func (m *EventBatchProto) String() string

+ type EventProto struct

+ Contents []byte

+ Type *EventType

+ XXX_unrecognized []byte

+ func (*EventProto) ProtoMessage()

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

+ func (m *EventProto) GetType() EventType

+ func (m *EventProto) Reset()

+ func (m *EventProto) String() string

+ type EventType int32

+ const EventType_EVENT_APPEND

+ const EventType_EVENT_CLOSE

+ const EventType_EVENT_CREATE

+ const EventType_EVENT_METADATA

+ const EventType_EVENT_RENAME

+ const EventType_EVENT_TRUNCATE

+ const EventType_EVENT_UNLINK

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

+ func (x EventType) Enum() *EventType

+ func (x EventType) String() string

+ type EventsListProto struct

+ Batch []*EventBatchProto

+ Events []*EventProto

+ FirstTxid *int64

+ LastTxid *int64

+ SyncTxid *int64

+ XXX_unrecognized []byte

+ func (*EventsListProto) ProtoMessage()

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

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

+ func (m *EventsListProto) GetFirstTxid() int64

+ func (m *EventsListProto) GetLastTxid() int64

+ func (m *EventsListProto) GetSyncTxid() int64

+ func (m *EventsListProto) Reset()

+ func (m *EventsListProto) String() string

+ type EvictWritersRequestProto struct

+ XXX_unrecognized []byte

+ func (*EvictWritersRequestProto) ProtoMessage()

+ func (m *EvictWritersRequestProto) Reset()

+ func (m *EvictWritersRequestProto) String() string

+ type EvictWritersResponseProto struct

+ XXX_unrecognized []byte

+ func (*EvictWritersResponseProto) ProtoMessage()

+ func (m *EvictWritersResponseProto) Reset()

+ func (m *EvictWritersResponseProto) String() string

+ type FileEncryptionInfoProto struct

+ CryptoProtocolVersion *CryptoProtocolVersionProto

+ EzKeyVersionName *string

+ Iv []byte

+ Key []byte

+ KeyName *string

+ Suite *CipherSuiteProto

+ XXX_unrecognized []byte

+ func (*FileEncryptionInfoProto) ProtoMessage()

+ func (m *FileEncryptionInfoProto) GetCryptoProtocolVersion() CryptoProtocolVersionProto

+ func (m *FileEncryptionInfoProto) GetEzKeyVersionName() string

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

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

+ func (m *FileEncryptionInfoProto) GetKeyName() string

+ func (m *FileEncryptionInfoProto) GetSuite() CipherSuiteProto

+ func (m *FileEncryptionInfoProto) Reset()

+ func (m *FileEncryptionInfoProto) String() string

type FsyncRequestProto

+ FileId *uint64

+ func (m *FsyncRequestProto) GetFileId() uint64

+ type GetAclStatusRequestProto struct

+ Src *string

+ XXX_unrecognized []byte

+ func (*GetAclStatusRequestProto) ProtoMessage()

+ func (m *GetAclStatusRequestProto) GetSrc() string

+ func (m *GetAclStatusRequestProto) Reset()

+ func (m *GetAclStatusRequestProto) String() string

+ type GetAclStatusResponseProto struct

+ Result *AclStatusProto

+ XXX_unrecognized []byte

+ func (*GetAclStatusResponseProto) ProtoMessage()

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

+ func (m *GetAclStatusResponseProto) Reset()

+ func (m *GetAclStatusResponseProto) String() string

type GetAdditionalDatanodeRequestProto

+ ExistingStorageUuids []string

+ FileId *uint64

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

+ func (m *GetAdditionalDatanodeRequestProto) GetFileId() uint64

+ type GetBalancerBandwidthRequestProto struct

+ XXX_unrecognized []byte

+ func (*GetBalancerBandwidthRequestProto) ProtoMessage()

+ func (m *GetBalancerBandwidthRequestProto) Reset()

+ func (m *GetBalancerBandwidthRequestProto) String() string

+ type GetBalancerBandwidthResponseProto struct

+ Bandwidth *uint64

+ XXX_unrecognized []byte

+ func (*GetBalancerBandwidthResponseProto) ProtoMessage()

+ func (m *GetBalancerBandwidthResponseProto) GetBandwidth() uint64

+ func (m *GetBalancerBandwidthResponseProto) Reset()

+ func (m *GetBalancerBandwidthResponseProto) String() string

+ type GetBlockLocalPathInfoRequestProto struct

+ Block *ExtendedBlockProto

+ Token *hadoop_common.TokenProto

+ XXX_unrecognized []byte

+ func (*GetBlockLocalPathInfoRequestProto) ProtoMessage()

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

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

+ func (m *GetBlockLocalPathInfoRequestProto) Reset()

+ func (m *GetBlockLocalPathInfoRequestProto) String() string

+ type GetBlockLocalPathInfoResponseProto struct

+ Block *ExtendedBlockProto

+ LocalMetaPath *string

+ LocalPath *string

+ XXX_unrecognized []byte

+ func (*GetBlockLocalPathInfoResponseProto) ProtoMessage()

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

+ func (m *GetBlockLocalPathInfoResponseProto) GetLocalMetaPath() string

+ func (m *GetBlockLocalPathInfoResponseProto) GetLocalPath() string

+ func (m *GetBlockLocalPathInfoResponseProto) Reset()

+ func (m *GetBlockLocalPathInfoResponseProto) String() string

+ type GetCurrentEditLogTxidRequestProto struct

+ XXX_unrecognized []byte

+ func (*GetCurrentEditLogTxidRequestProto) ProtoMessage()

+ func (m *GetCurrentEditLogTxidRequestProto) Reset()

+ func (m *GetCurrentEditLogTxidRequestProto) String() string

+ type GetCurrentEditLogTxidResponseProto struct

+ Txid *int64

+ XXX_unrecognized []byte

+ func (*GetCurrentEditLogTxidResponseProto) ProtoMessage()

+ func (m *GetCurrentEditLogTxidResponseProto) GetTxid() int64

+ func (m *GetCurrentEditLogTxidResponseProto) Reset()

+ func (m *GetCurrentEditLogTxidResponseProto) String() string

+ type GetDatanodeInfoRequestProto struct

+ XXX_unrecognized []byte

+ func (*GetDatanodeInfoRequestProto) ProtoMessage()

+ func (m *GetDatanodeInfoRequestProto) Reset()

+ func (m *GetDatanodeInfoRequestProto) String() string

+ type GetDatanodeInfoResponseProto struct

+ LocalInfo *DatanodeLocalInfoProto

+ XXX_unrecognized []byte

+ func (*GetDatanodeInfoResponseProto) ProtoMessage()

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

+ func (m *GetDatanodeInfoResponseProto) Reset()

+ func (m *GetDatanodeInfoResponseProto) String() string

+ type GetDatanodeStorageReportRequestProto struct

+ Type *DatanodeReportTypeProto

+ XXX_unrecognized []byte

+ func (*GetDatanodeStorageReportRequestProto) ProtoMessage()

+ func (m *GetDatanodeStorageReportRequestProto) GetType() DatanodeReportTypeProto

+ func (m *GetDatanodeStorageReportRequestProto) Reset()

+ func (m *GetDatanodeStorageReportRequestProto) String() string

+ type GetDatanodeStorageReportResponseProto struct

+ DatanodeStorageReports []*DatanodeStorageReportProto

+ XXX_unrecognized []byte

+ func (*GetDatanodeStorageReportResponseProto) ProtoMessage()

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

+ func (m *GetDatanodeStorageReportResponseProto) Reset()

+ func (m *GetDatanodeStorageReportResponseProto) String() string

+ type GetEZForPathRequestProto struct

+ Src *string

+ XXX_unrecognized []byte

+ func (*GetEZForPathRequestProto) ProtoMessage()

+ func (m *GetEZForPathRequestProto) GetSrc() string

+ func (m *GetEZForPathRequestProto) Reset()

+ func (m *GetEZForPathRequestProto) String() string

+ type GetEZForPathResponseProto struct

+ XXX_unrecognized []byte

+ Zone *EncryptionZoneProto

+ func (*GetEZForPathResponseProto) ProtoMessage()

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

+ func (m *GetEZForPathResponseProto) Reset()

+ func (m *GetEZForPathResponseProto) String() string

+ type GetEditsFromTxidRequestProto struct

+ Txid *int64

+ XXX_unrecognized []byte

+ func (*GetEditsFromTxidRequestProto) ProtoMessage()

+ func (m *GetEditsFromTxidRequestProto) GetTxid() int64

+ func (m *GetEditsFromTxidRequestProto) Reset()

+ func (m *GetEditsFromTxidRequestProto) String() string

+ type GetEditsFromTxidResponseProto struct

+ EventsList *EventsListProto

+ XXX_unrecognized []byte

+ func (*GetEditsFromTxidResponseProto) ProtoMessage()

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

+ func (m *GetEditsFromTxidResponseProto) Reset()

+ func (m *GetEditsFromTxidResponseProto) String() string

+ type GetErasureCodingPoliciesRequestProto struct

+ XXX_unrecognized []byte

+ func (*GetErasureCodingPoliciesRequestProto) ProtoMessage()

+ func (m *GetErasureCodingPoliciesRequestProto) Reset()

+ func (m *GetErasureCodingPoliciesRequestProto) String() string

+ type GetErasureCodingPoliciesResponseProto struct

+ EcPolicies []*ErasureCodingPolicyProto

+ XXX_unrecognized []byte

+ func (*GetErasureCodingPoliciesResponseProto) ProtoMessage()

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

+ func (m *GetErasureCodingPoliciesResponseProto) Reset()

+ func (m *GetErasureCodingPoliciesResponseProto) String() string

+ type GetErasureCodingPolicyRequestProto struct

+ Src *string

+ XXX_unrecognized []byte

+ func (*GetErasureCodingPolicyRequestProto) ProtoMessage()

+ func (m *GetErasureCodingPolicyRequestProto) GetSrc() string

+ func (m *GetErasureCodingPolicyRequestProto) Reset()

+ func (m *GetErasureCodingPolicyRequestProto) String() string

+ type GetErasureCodingPolicyResponseProto struct

+ EcPolicy *ErasureCodingPolicyProto

+ XXX_unrecognized []byte

+ func (*GetErasureCodingPolicyResponseProto) ProtoMessage()

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

+ func (m *GetErasureCodingPolicyResponseProto) Reset()

+ func (m *GetErasureCodingPolicyResponseProto) String() string

type GetFsStatsResponseProto

+ BlocksInFuture *uint64

+ MissingReplOneBlocks *uint64

+ PendingDeletionBlocks *uint64

+ func (m *GetFsStatsResponseProto) GetBlocksInFuture() uint64

+ func (m *GetFsStatsResponseProto) GetMissingReplOneBlocks() uint64

+ func (m *GetFsStatsResponseProto) GetPendingDeletionBlocks() uint64

+ type GetQuotaUsageRequestProto struct

+ Path *string

+ XXX_unrecognized []byte

+ func (*GetQuotaUsageRequestProto) ProtoMessage()

+ func (m *GetQuotaUsageRequestProto) GetPath() string

+ func (m *GetQuotaUsageRequestProto) Reset()

+ func (m *GetQuotaUsageRequestProto) String() string

+ type GetQuotaUsageResponseProto struct

+ Usage *QuotaUsageProto

+ XXX_unrecognized []byte

+ func (*GetQuotaUsageResponseProto) ProtoMessage()

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

+ func (m *GetQuotaUsageResponseProto) Reset()

+ func (m *GetQuotaUsageResponseProto) String() string

+ type GetReconfigurationStatusConfigChangeProto struct

+ ErrorMessage *string

+ Name *string

+ NewValue *string

+ OldValue *string

+ XXX_unrecognized []byte

+ func (*GetReconfigurationStatusConfigChangeProto) ProtoMessage()

+ func (m *GetReconfigurationStatusConfigChangeProto) GetErrorMessage() string

+ func (m *GetReconfigurationStatusConfigChangeProto) GetName() string

+ func (m *GetReconfigurationStatusConfigChangeProto) GetNewValue() string

+ func (m *GetReconfigurationStatusConfigChangeProto) GetOldValue() string

+ func (m *GetReconfigurationStatusConfigChangeProto) Reset()

+ func (m *GetReconfigurationStatusConfigChangeProto) String() string

+ type GetReconfigurationStatusRequestProto struct

+ XXX_unrecognized []byte

+ func (*GetReconfigurationStatusRequestProto) ProtoMessage()

+ func (m *GetReconfigurationStatusRequestProto) Reset()

+ func (m *GetReconfigurationStatusRequestProto) String() string

+ type GetReconfigurationStatusResponseProto struct

+ Changes []*GetReconfigurationStatusConfigChangeProto

+ EndTime *int64

+ StartTime *int64

+ XXX_unrecognized []byte

+ func (*GetReconfigurationStatusResponseProto) ProtoMessage()

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

+ func (m *GetReconfigurationStatusResponseProto) GetEndTime() int64

+ func (m *GetReconfigurationStatusResponseProto) GetStartTime() int64

+ func (m *GetReconfigurationStatusResponseProto) Reset()

+ func (m *GetReconfigurationStatusResponseProto) String() string

+ type GetReplicaVisibleLengthRequestProto struct

+ Block *ExtendedBlockProto

+ XXX_unrecognized []byte

+ func (*GetReplicaVisibleLengthRequestProto) ProtoMessage()

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

+ func (m *GetReplicaVisibleLengthRequestProto) Reset()

+ func (m *GetReplicaVisibleLengthRequestProto) String() string

+ type GetReplicaVisibleLengthResponseProto struct

+ Length *uint64

+ XXX_unrecognized []byte

+ func (*GetReplicaVisibleLengthResponseProto) ProtoMessage()

+ func (m *GetReplicaVisibleLengthResponseProto) GetLength() uint64

+ func (m *GetReplicaVisibleLengthResponseProto) Reset()

+ func (m *GetReplicaVisibleLengthResponseProto) String() string

+ type GetStoragePoliciesRequestProto struct

+ XXX_unrecognized []byte

+ func (*GetStoragePoliciesRequestProto) ProtoMessage()

+ func (m *GetStoragePoliciesRequestProto) Reset()

+ func (m *GetStoragePoliciesRequestProto) String() string

+ type GetStoragePoliciesResponseProto struct

+ Policies []*BlockStoragePolicyProto

+ XXX_unrecognized []byte

+ func (*GetStoragePoliciesResponseProto) ProtoMessage()

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

+ func (m *GetStoragePoliciesResponseProto) Reset()

+ func (m *GetStoragePoliciesResponseProto) String() string

+ type GetStoragePolicyRequestProto struct

+ Path *string

+ XXX_unrecognized []byte

+ func (*GetStoragePolicyRequestProto) ProtoMessage()

+ func (m *GetStoragePolicyRequestProto) GetPath() string

+ func (m *GetStoragePolicyRequestProto) Reset()

+ func (m *GetStoragePolicyRequestProto) String() string

+ type GetStoragePolicyResponseProto struct

+ StoragePolicy *BlockStoragePolicyProto

+ XXX_unrecognized []byte

+ func (*GetStoragePolicyResponseProto) ProtoMessage()

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

+ func (m *GetStoragePolicyResponseProto) Reset()

+ func (m *GetStoragePolicyResponseProto) String() string

+ type GetXAttrsRequestProto struct

+ Src *string

+ XAttrs []*XAttrProto

+ XXX_unrecognized []byte

+ func (*GetXAttrsRequestProto) ProtoMessage()

+ func (m *GetXAttrsRequestProto) GetSrc() string

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

+ func (m *GetXAttrsRequestProto) Reset()

+ func (m *GetXAttrsRequestProto) String() string

+ type GetXAttrsResponseProto struct

+ XAttrs []*XAttrProto

+ XXX_unrecognized []byte

+ func (*GetXAttrsResponseProto) ProtoMessage()

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

+ func (m *GetXAttrsResponseProto) Reset()

+ func (m *GetXAttrsResponseProto) String() string

type HdfsFileStatusProto

+ EcPolicy *ErasureCodingPolicyProto

+ FileEncryptionInfo *FileEncryptionInfoProto

+ StoragePolicy *uint32

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

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

+ func (m *HdfsFileStatusProto) GetStoragePolicy() uint32

+ type INodeType int32

+ const INodeType_I_TYPE_DIRECTORY

+ const INodeType_I_TYPE_FILE

+ const INodeType_I_TYPE_SYMLINK

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

+ func (x INodeType) Enum() *INodeType

+ func (x INodeType) String() string

+ type ListCacheDirectivesRequestProto struct

+ Filter *CacheDirectiveInfoProto

+ PrevId *int64

+ XXX_unrecognized []byte

+ func (*ListCacheDirectivesRequestProto) ProtoMessage()

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

+ func (m *ListCacheDirectivesRequestProto) GetPrevId() int64

+ func (m *ListCacheDirectivesRequestProto) Reset()

+ func (m *ListCacheDirectivesRequestProto) String() string

+ type ListCacheDirectivesResponseProto struct

+ Elements []*CacheDirectiveEntryProto

+ HasMore *bool

+ XXX_unrecognized []byte

+ func (*ListCacheDirectivesResponseProto) ProtoMessage()

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

+ func (m *ListCacheDirectivesResponseProto) GetHasMore() bool

+ func (m *ListCacheDirectivesResponseProto) Reset()

+ func (m *ListCacheDirectivesResponseProto) String() string

+ type ListCachePoolsRequestProto struct

+ PrevPoolName *string

+ XXX_unrecognized []byte

+ func (*ListCachePoolsRequestProto) ProtoMessage()

+ func (m *ListCachePoolsRequestProto) GetPrevPoolName() string

+ func (m *ListCachePoolsRequestProto) Reset()

+ func (m *ListCachePoolsRequestProto) String() string

+ type ListCachePoolsResponseProto struct

+ Entries []*CachePoolEntryProto

+ HasMore *bool

+ XXX_unrecognized []byte

+ func (*ListCachePoolsResponseProto) ProtoMessage()

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

+ func (m *ListCachePoolsResponseProto) GetHasMore() bool

+ func (m *ListCachePoolsResponseProto) Reset()

+ func (m *ListCachePoolsResponseProto) String() string

+ type ListEncryptionZonesRequestProto struct

+ Id *int64

+ XXX_unrecognized []byte

+ func (*ListEncryptionZonesRequestProto) ProtoMessage()

+ func (m *ListEncryptionZonesRequestProto) GetId() int64

+ func (m *ListEncryptionZonesRequestProto) Reset()

+ func (m *ListEncryptionZonesRequestProto) String() string

+ type ListEncryptionZonesResponseProto struct

+ HasMore *bool

+ XXX_unrecognized []byte

+ Zones []*EncryptionZoneProto

+ func (*ListEncryptionZonesResponseProto) ProtoMessage()

+ func (m *ListEncryptionZonesResponseProto) GetHasMore() bool

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

+ func (m *ListEncryptionZonesResponseProto) Reset()

+ func (m *ListEncryptionZonesResponseProto) String() string

+ type ListReconfigurablePropertiesRequestProto struct

+ XXX_unrecognized []byte

+ func (*ListReconfigurablePropertiesRequestProto) ProtoMessage()

+ func (m *ListReconfigurablePropertiesRequestProto) Reset()

+ func (m *ListReconfigurablePropertiesRequestProto) String() string

+ type ListReconfigurablePropertiesResponseProto struct

+ Name []string

+ XXX_unrecognized []byte

+ func (*ListReconfigurablePropertiesResponseProto) ProtoMessage()

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

+ func (m *ListReconfigurablePropertiesResponseProto) Reset()

+ func (m *ListReconfigurablePropertiesResponseProto) String() string

+ type ListXAttrsRequestProto struct

+ Src *string

+ XXX_unrecognized []byte

+ func (*ListXAttrsRequestProto) ProtoMessage()

+ func (m *ListXAttrsRequestProto) GetSrc() string

+ func (m *ListXAttrsRequestProto) Reset()

+ func (m *ListXAttrsRequestProto) String() string

+ type ListXAttrsResponseProto struct

+ XAttrs []*XAttrProto

+ XXX_unrecognized []byte

+ func (*ListXAttrsResponseProto) ProtoMessage()

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

+ func (m *ListXAttrsResponseProto) Reset()

+ func (m *ListXAttrsResponseProto) String() string

type LocatedBlockProto

+ BlockIndices []byte

+ BlockTokens []*hadoop_common.TokenProto

+ IsCached []bool

+ StorageIDs []string

+ StorageTypes []StorageTypeProto

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

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

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

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

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

type LocatedBlocksProto

+ EcPolicy *ErasureCodingPolicyProto

+ FileEncryptionInfo *FileEncryptionInfoProto

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

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

+ type MetadataUpdateEventProto struct

+ Acls []*AclEntryProto

+ Atime *int64

+ GroupName *string

+ Mtime *int64

+ OwnerName *string

+ Path *string

+ Perms *FsPermissionProto

+ Replication *int32

+ Type *MetadataUpdateType

+ XAttrs []*XAttrProto

+ XAttrsRemoved *bool

+ XXX_unrecognized []byte

+ func (*MetadataUpdateEventProto) ProtoMessage()

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

+ func (m *MetadataUpdateEventProto) GetAtime() int64

+ func (m *MetadataUpdateEventProto) GetGroupName() string

+ func (m *MetadataUpdateEventProto) GetMtime() int64

+ func (m *MetadataUpdateEventProto) GetOwnerName() string

+ func (m *MetadataUpdateEventProto) GetPath() string

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

+ func (m *MetadataUpdateEventProto) GetReplication() int32

+ func (m *MetadataUpdateEventProto) GetType() MetadataUpdateType

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

+ func (m *MetadataUpdateEventProto) GetXAttrsRemoved() bool

+ func (m *MetadataUpdateEventProto) Reset()

+ func (m *MetadataUpdateEventProto) String() string

+ type MetadataUpdateType int32

+ const MetadataUpdateType_META_TYPE_ACLS

+ const MetadataUpdateType_META_TYPE_OWNER

+ const MetadataUpdateType_META_TYPE_PERMS

+ const MetadataUpdateType_META_TYPE_REPLICATION

+ const MetadataUpdateType_META_TYPE_TIMES

+ const MetadataUpdateType_META_TYPE_XATTRS

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

+ func (x MetadataUpdateType) Enum() *MetadataUpdateType

+ func (x MetadataUpdateType) String() string

+ type ModifyAclEntriesRequestProto struct

+ AclSpec []*AclEntryProto

+ Src *string

+ XXX_unrecognized []byte

+ func (*ModifyAclEntriesRequestProto) ProtoMessage()

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

+ func (m *ModifyAclEntriesRequestProto) GetSrc() string

+ func (m *ModifyAclEntriesRequestProto) Reset()

+ func (m *ModifyAclEntriesRequestProto) String() string

+ type ModifyAclEntriesResponseProto struct

+ XXX_unrecognized []byte

+ func (*ModifyAclEntriesResponseProto) ProtoMessage()

+ func (m *ModifyAclEntriesResponseProto) Reset()

+ func (m *ModifyAclEntriesResponseProto) String() string

+ type ModifyCacheDirectiveRequestProto struct

+ CacheFlags *uint32

+ Info *CacheDirectiveInfoProto

+ XXX_unrecognized []byte

+ func (*ModifyCacheDirectiveRequestProto) ProtoMessage()

+ func (m *ModifyCacheDirectiveRequestProto) GetCacheFlags() uint32

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

+ func (m *ModifyCacheDirectiveRequestProto) Reset()

+ func (m *ModifyCacheDirectiveRequestProto) String() string

+ type ModifyCacheDirectiveResponseProto struct

+ XXX_unrecognized []byte

+ func (*ModifyCacheDirectiveResponseProto) ProtoMessage()

+ func (m *ModifyCacheDirectiveResponseProto) Reset()

+ func (m *ModifyCacheDirectiveResponseProto) String() string

+ type ModifyCachePoolRequestProto struct

+ Info *CachePoolInfoProto

+ XXX_unrecognized []byte

+ func (*ModifyCachePoolRequestProto) ProtoMessage()

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

+ func (m *ModifyCachePoolRequestProto) Reset()

+ func (m *ModifyCachePoolRequestProto) String() string

+ type ModifyCachePoolResponseProto struct

+ XXX_unrecognized []byte

+ func (*ModifyCachePoolResponseProto) ProtoMessage()

+ func (m *ModifyCachePoolResponseProto) Reset()

+ func (m *ModifyCachePoolResponseProto) String() string

+ type OpBlockGroupChecksumProto struct

+ BlockTokens []*hadoop_common.TokenProto

+ Datanodes *DatanodeInfosProto

+ EcPolicy *ErasureCodingPolicyProto

+ Header *BaseHeaderProto

+ XXX_unrecognized []byte

+ func (*OpBlockGroupChecksumProto) ProtoMessage()

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

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

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

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

+ func (m *OpBlockGroupChecksumProto) Reset()

+ func (m *OpBlockGroupChecksumProto) String() string

+ type OpCustomProto struct

+ CustomId *string

+ XXX_unrecognized []byte

+ func (*OpCustomProto) ProtoMessage()

+ func (m *OpCustomProto) GetCustomId() string

+ func (m *OpCustomProto) Reset()

+ func (m *OpCustomProto) String() string

type OpReplaceBlockProto

+ StorageType *StorageTypeProto

+ func (m *OpReplaceBlockProto) GetStorageType() StorageTypeProto

type OpRequestShortCircuitAccessProto

+ SlotId *ShortCircuitShmSlotProto

+ SupportsReceiptVerification *bool

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

+ func (m *OpRequestShortCircuitAccessProto) GetSupportsReceiptVerification() bool

type OpTransferBlockProto

+ TargetStorageTypes []StorageTypeProto

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

type OpWriteBlockProto

+ AllowLazyPersist *bool

+ Pinning *bool

+ StorageType *StorageTypeProto

+ TargetPinnings []bool

+ TargetStorageTypes []StorageTypeProto

+ func (m *OpWriteBlockProto) GetAllowLazyPersist() bool

+ func (m *OpWriteBlockProto) GetPinning() bool

+ func (m *OpWriteBlockProto) GetStorageType() StorageTypeProto

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

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

+ type PerFileEncryptionInfoProto struct

+ EzKeyVersionName *string

+ Iv []byte

+ Key []byte

+ XXX_unrecognized []byte

+ func (*PerFileEncryptionInfoProto) ProtoMessage()

+ func (m *PerFileEncryptionInfoProto) GetEzKeyVersionName() string

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

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

+ func (m *PerFileEncryptionInfoProto) Reset()

+ func (m *PerFileEncryptionInfoProto) String() string

type PipelineAckProto

+ Flag []uint32

+ Reply []Status

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

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

+ type QuotaUsageProto struct

+ FileAndDirectoryCount *uint64

+ Quota *uint64

+ SpaceConsumed *uint64

+ SpaceQuota *uint64

+ TypeQuotaInfos *StorageTypeQuotaInfosProto

+ XXX_unrecognized []byte

+ func (*QuotaUsageProto) ProtoMessage()

+ func (m *QuotaUsageProto) GetFileAndDirectoryCount() uint64

+ func (m *QuotaUsageProto) GetQuota() uint64

+ func (m *QuotaUsageProto) GetSpaceConsumed() uint64

+ func (m *QuotaUsageProto) GetSpaceQuota() uint64

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

+ func (m *QuotaUsageProto) Reset()

+ func (m *QuotaUsageProto) String() string

+ type RefreshNamenodesRequestProto struct

+ XXX_unrecognized []byte

+ func (*RefreshNamenodesRequestProto) ProtoMessage()

+ func (m *RefreshNamenodesRequestProto) Reset()

+ func (m *RefreshNamenodesRequestProto) String() string

+ type RefreshNamenodesResponseProto struct

+ XXX_unrecognized []byte

+ func (*RefreshNamenodesResponseProto) ProtoMessage()

+ func (m *RefreshNamenodesResponseProto) Reset()

+ func (m *RefreshNamenodesResponseProto) String() string

+ type ReleaseShortCircuitAccessRequestProto struct

+ SlotId *ShortCircuitShmSlotProto

+ TraceInfo *DataTransferTraceInfoProto

+ XXX_unrecognized []byte

+ func (*ReleaseShortCircuitAccessRequestProto) ProtoMessage()

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

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

+ func (m *ReleaseShortCircuitAccessRequestProto) Reset()

+ func (m *ReleaseShortCircuitAccessRequestProto) String() string

+ type ReleaseShortCircuitAccessResponseProto struct

+ Error *string

+ Status *Status

+ XXX_unrecognized []byte

+ func (*ReleaseShortCircuitAccessResponseProto) ProtoMessage()

+ func (m *ReleaseShortCircuitAccessResponseProto) GetError() string

+ func (m *ReleaseShortCircuitAccessResponseProto) GetStatus() Status

+ func (m *ReleaseShortCircuitAccessResponseProto) Reset()

+ func (m *ReleaseShortCircuitAccessResponseProto) String() string

+ type RemoveAclEntriesRequestProto struct

+ AclSpec []*AclEntryProto

+ Src *string

+ XXX_unrecognized []byte

+ func (*RemoveAclEntriesRequestProto) ProtoMessage()

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

+ func (m *RemoveAclEntriesRequestProto) GetSrc() string

+ func (m *RemoveAclEntriesRequestProto) Reset()

+ func (m *RemoveAclEntriesRequestProto) String() string

+ type RemoveAclEntriesResponseProto struct

+ XXX_unrecognized []byte

+ func (*RemoveAclEntriesResponseProto) ProtoMessage()

+ func (m *RemoveAclEntriesResponseProto) Reset()

+ func (m *RemoveAclEntriesResponseProto) String() string

+ type RemoveAclRequestProto struct

+ Src *string

+ XXX_unrecognized []byte

+ func (*RemoveAclRequestProto) ProtoMessage()

+ func (m *RemoveAclRequestProto) GetSrc() string

+ func (m *RemoveAclRequestProto) Reset()

+ func (m *RemoveAclRequestProto) String() string

+ type RemoveAclResponseProto struct

+ XXX_unrecognized []byte

+ func (*RemoveAclResponseProto) ProtoMessage()

+ func (m *RemoveAclResponseProto) Reset()

+ func (m *RemoveAclResponseProto) String() string

+ type RemoveCacheDirectiveRequestProto struct

+ Id *int64

+ XXX_unrecognized []byte

+ func (*RemoveCacheDirectiveRequestProto) ProtoMessage()

+ func (m *RemoveCacheDirectiveRequestProto) GetId() int64

+ func (m *RemoveCacheDirectiveRequestProto) Reset()

+ func (m *RemoveCacheDirectiveRequestProto) String() string

+ type RemoveCacheDirectiveResponseProto struct

+ XXX_unrecognized []byte

+ func (*RemoveCacheDirectiveResponseProto) ProtoMessage()

+ func (m *RemoveCacheDirectiveResponseProto) Reset()

+ func (m *RemoveCacheDirectiveResponseProto) String() string

+ type RemoveCachePoolRequestProto struct

+ PoolName *string

+ XXX_unrecognized []byte

+ func (*RemoveCachePoolRequestProto) ProtoMessage()

+ func (m *RemoveCachePoolRequestProto) GetPoolName() string

+ func (m *RemoveCachePoolRequestProto) Reset()

+ func (m *RemoveCachePoolRequestProto) String() string

+ type RemoveCachePoolResponseProto struct

+ XXX_unrecognized []byte

+ func (*RemoveCachePoolResponseProto) ProtoMessage()

+ func (m *RemoveCachePoolResponseProto) Reset()

+ func (m *RemoveCachePoolResponseProto) String() string

+ type RemoveDefaultAclRequestProto struct

+ Src *string

+ XXX_unrecognized []byte

+ func (*RemoveDefaultAclRequestProto) ProtoMessage()

+ func (m *RemoveDefaultAclRequestProto) GetSrc() string

+ func (m *RemoveDefaultAclRequestProto) Reset()

+ func (m *RemoveDefaultAclRequestProto) String() string

+ type RemoveDefaultAclResponseProto struct

+ XXX_unrecognized []byte

+ func (*RemoveDefaultAclResponseProto) ProtoMessage()

+ func (m *RemoveDefaultAclResponseProto) Reset()

+ func (m *RemoveDefaultAclResponseProto) String() string

+ type RemoveXAttrRequestProto struct

+ Src *string

+ XAttr *XAttrProto

+ XXX_unrecognized []byte

+ func (*RemoveXAttrRequestProto) ProtoMessage()

+ func (m *RemoveXAttrRequestProto) GetSrc() string

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

+ func (m *RemoveXAttrRequestProto) Reset()

+ func (m *RemoveXAttrRequestProto) String() string

+ type RemoveXAttrResponseProto struct

+ XXX_unrecognized []byte

+ func (*RemoveXAttrResponseProto) ProtoMessage()

+ func (m *RemoveXAttrResponseProto) Reset()

+ func (m *RemoveXAttrResponseProto) String() string

+ type RenameEventProto struct

+ DestPath *string

+ SrcPath *string

+ Timestamp *int64

+ XXX_unrecognized []byte

+ func (*RenameEventProto) ProtoMessage()

+ func (m *RenameEventProto) GetDestPath() string

+ func (m *RenameEventProto) GetSrcPath() string

+ func (m *RenameEventProto) GetTimestamp() int64

+ func (m *RenameEventProto) Reset()

+ func (m *RenameEventProto) String() string

+ type RollingUpgradeActionProto int32

+ const RollingUpgradeActionProto_FINALIZE

+ const RollingUpgradeActionProto_QUERY

+ const RollingUpgradeActionProto_START

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

+ func (x RollingUpgradeActionProto) Enum() *RollingUpgradeActionProto

+ func (x RollingUpgradeActionProto) String() string

+ type RollingUpgradeInfoProto struct

+ CreatedRollbackImages *bool

+ FinalizeTime *uint64

+ StartTime *uint64

+ Status *RollingUpgradeStatusProto

+ XXX_unrecognized []byte

+ func (*RollingUpgradeInfoProto) ProtoMessage()

+ func (m *RollingUpgradeInfoProto) GetCreatedRollbackImages() bool

+ func (m *RollingUpgradeInfoProto) GetFinalizeTime() uint64

+ func (m *RollingUpgradeInfoProto) GetStartTime() uint64

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

+ func (m *RollingUpgradeInfoProto) Reset()

+ func (m *RollingUpgradeInfoProto) String() string

+ type RollingUpgradeRequestProto struct

+ Action *RollingUpgradeActionProto

+ XXX_unrecognized []byte

+ func (*RollingUpgradeRequestProto) ProtoMessage()

+ func (m *RollingUpgradeRequestProto) GetAction() RollingUpgradeActionProto

+ func (m *RollingUpgradeRequestProto) Reset()

+ func (m *RollingUpgradeRequestProto) String() string

+ type RollingUpgradeResponseProto struct

+ RollingUpgradeInfo *RollingUpgradeInfoProto

+ XXX_unrecognized []byte

+ func (*RollingUpgradeResponseProto) ProtoMessage()

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

+ func (m *RollingUpgradeResponseProto) Reset()

+ func (m *RollingUpgradeResponseProto) String() string

+ type RollingUpgradeStatusProto struct

+ BlockPoolId *string

+ Finalized *bool

+ XXX_unrecognized []byte

+ func (*RollingUpgradeStatusProto) ProtoMessage()

+ func (m *RollingUpgradeStatusProto) GetBlockPoolId() string

+ func (m *RollingUpgradeStatusProto) GetFinalized() bool

+ func (m *RollingUpgradeStatusProto) Reset()

+ func (m *RollingUpgradeStatusProto) String() string

type SafeModeActionProto

+ const SafeModeActionProto_SAFEMODE_FORCE_EXIT

type SaveNamespaceRequestProto

+ TimeWindow *uint64

+ TxGap *uint64

+ func (m *SaveNamespaceRequestProto) GetTimeWindow() uint64

+ func (m *SaveNamespaceRequestProto) GetTxGap() uint64

type SaveNamespaceResponseProto

+ Saved *bool

+ func (m *SaveNamespaceResponseProto) GetSaved() bool

+ type SetAclRequestProto struct

+ AclSpec []*AclEntryProto

+ Src *string

+ XXX_unrecognized []byte

+ func (*SetAclRequestProto) ProtoMessage()

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

+ func (m *SetAclRequestProto) GetSrc() string

+ func (m *SetAclRequestProto) Reset()

+ func (m *SetAclRequestProto) String() string

+ type SetAclResponseProto struct

+ XXX_unrecognized []byte

+ func (*SetAclResponseProto) ProtoMessage()

+ func (m *SetAclResponseProto) Reset()

+ func (m *SetAclResponseProto) String() string

+ type SetErasureCodingPolicyRequestProto struct

+ EcPolicy *ErasureCodingPolicyProto

+ Src *string

+ XXX_unrecognized []byte

+ func (*SetErasureCodingPolicyRequestProto) ProtoMessage()

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

+ func (m *SetErasureCodingPolicyRequestProto) GetSrc() string

+ func (m *SetErasureCodingPolicyRequestProto) Reset()

+ func (m *SetErasureCodingPolicyRequestProto) String() string

+ type SetErasureCodingPolicyResponseProto struct

+ XXX_unrecognized []byte

+ func (*SetErasureCodingPolicyResponseProto) ProtoMessage()

+ func (m *SetErasureCodingPolicyResponseProto) Reset()

+ func (m *SetErasureCodingPolicyResponseProto) String() string

type SetQuotaRequestProto

+ StorageType *StorageTypeProto

+ StoragespaceQuota *uint64

+ func (m *SetQuotaRequestProto) GetStorageType() StorageTypeProto

+ func (m *SetQuotaRequestProto) GetStoragespaceQuota() uint64

+ type SetStoragePolicyRequestProto struct

+ PolicyName *string

+ Src *string

+ XXX_unrecognized []byte

+ func (*SetStoragePolicyRequestProto) ProtoMessage()

+ func (m *SetStoragePolicyRequestProto) GetPolicyName() string

+ func (m *SetStoragePolicyRequestProto) GetSrc() string

+ func (m *SetStoragePolicyRequestProto) Reset()

+ func (m *SetStoragePolicyRequestProto) String() string

+ type SetStoragePolicyResponseProto struct

+ XXX_unrecognized []byte

+ func (*SetStoragePolicyResponseProto) ProtoMessage()

+ func (m *SetStoragePolicyResponseProto) Reset()

+ func (m *SetStoragePolicyResponseProto) String() string

+ type SetXAttrRequestProto struct

+ Flag *uint32

+ Src *string

+ XAttr *XAttrProto

+ XXX_unrecognized []byte

+ func (*SetXAttrRequestProto) ProtoMessage()

+ func (m *SetXAttrRequestProto) GetFlag() uint32

+ func (m *SetXAttrRequestProto) GetSrc() string

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

+ func (m *SetXAttrRequestProto) Reset()

+ func (m *SetXAttrRequestProto) String() string

+ type SetXAttrResponseProto struct

+ XXX_unrecognized []byte

+ func (*SetXAttrResponseProto) ProtoMessage()

+ func (m *SetXAttrResponseProto) Reset()

+ func (m *SetXAttrResponseProto) String() string

+ type ShortCircuitFdResponse int32

+ const ShortCircuitFdResponse_DO_NOT_USE_RECEIPT_VERIFICATION

+ const ShortCircuitFdResponse_USE_RECEIPT_VERIFICATION

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

+ func (x ShortCircuitFdResponse) Enum() *ShortCircuitFdResponse

+ func (x ShortCircuitFdResponse) String() string

+ type ShortCircuitShmIdProto struct

+ Hi *int64

+ Lo *int64

+ XXX_unrecognized []byte

+ func (*ShortCircuitShmIdProto) ProtoMessage()

+ func (m *ShortCircuitShmIdProto) GetHi() int64

+ func (m *ShortCircuitShmIdProto) GetLo() int64

+ func (m *ShortCircuitShmIdProto) Reset()

+ func (m *ShortCircuitShmIdProto) String() string

+ type ShortCircuitShmRequestProto struct

+ ClientName *string

+ TraceInfo *DataTransferTraceInfoProto

+ XXX_unrecognized []byte

+ func (*ShortCircuitShmRequestProto) ProtoMessage()

+ func (m *ShortCircuitShmRequestProto) GetClientName() string

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

+ func (m *ShortCircuitShmRequestProto) Reset()

+ func (m *ShortCircuitShmRequestProto) String() string

+ type ShortCircuitShmResponseProto struct

+ Error *string

+ Id *ShortCircuitShmIdProto

+ Status *Status

+ XXX_unrecognized []byte

+ func (*ShortCircuitShmResponseProto) ProtoMessage()

+ func (m *ShortCircuitShmResponseProto) GetError() string

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

+ func (m *ShortCircuitShmResponseProto) GetStatus() Status

+ func (m *ShortCircuitShmResponseProto) Reset()

+ func (m *ShortCircuitShmResponseProto) String() string

+ type ShortCircuitShmSlotProto struct

+ ShmId *ShortCircuitShmIdProto

+ SlotIdx *int32

+ XXX_unrecognized []byte

+ func (*ShortCircuitShmSlotProto) ProtoMessage()

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

+ func (m *ShortCircuitShmSlotProto) GetSlotIdx() int32

+ func (m *ShortCircuitShmSlotProto) Reset()

+ func (m *ShortCircuitShmSlotProto) String() string

+ type ShutdownDatanodeRequestProto struct

+ ForUpgrade *bool

+ XXX_unrecognized []byte

+ func (*ShutdownDatanodeRequestProto) ProtoMessage()

+ func (m *ShutdownDatanodeRequestProto) GetForUpgrade() bool

+ func (m *ShutdownDatanodeRequestProto) Reset()

+ func (m *ShutdownDatanodeRequestProto) String() string

+ type ShutdownDatanodeResponseProto struct

+ XXX_unrecognized []byte

+ func (*ShutdownDatanodeResponseProto) ProtoMessage()

+ func (m *ShutdownDatanodeResponseProto) Reset()

+ func (m *ShutdownDatanodeResponseProto) String() string

type SnapshotDiffReportEntryProto

+ TargetPath []byte

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

+ type StartReconfigurationRequestProto struct

+ XXX_unrecognized []byte

+ func (*StartReconfigurationRequestProto) ProtoMessage()

+ func (m *StartReconfigurationRequestProto) Reset()

+ func (m *StartReconfigurationRequestProto) String() string

+ type StartReconfigurationResponseProto struct

+ XXX_unrecognized []byte

+ func (*StartReconfigurationResponseProto) ProtoMessage()

+ func (m *StartReconfigurationResponseProto) Reset()

+ func (m *StartReconfigurationResponseProto) String() string

type Status

+ const Status_IN_PROGRESS

+ const Status_OOB_RESERVED1

+ const Status_OOB_RESERVED2

+ const Status_OOB_RESERVED3

+ const Status_OOB_RESTART

+ type StorageReportProto struct

+ BlockPoolUsed *uint64

+ Capacity *uint64

+ DfsUsed *uint64

+ Failed *bool

+ Remaining *uint64

+ Storage *DatanodeStorageProto

+ StorageUuid *string

+ XXX_unrecognized []byte

+ func (*StorageReportProto) ProtoMessage()

+ func (m *StorageReportProto) GetBlockPoolUsed() uint64

+ func (m *StorageReportProto) GetCapacity() uint64

+ func (m *StorageReportProto) GetDfsUsed() uint64

+ func (m *StorageReportProto) GetFailed() bool

+ func (m *StorageReportProto) GetRemaining() uint64

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

+ func (m *StorageReportProto) GetStorageUuid() string

+ func (m *StorageReportProto) Reset()

+ func (m *StorageReportProto) String() string

+ type StorageTypeProto int32

+ const Default_DatanodeStorageProto_StorageType

+ const Default_OpReplaceBlockProto_StorageType

+ const Default_OpWriteBlockProto_StorageType

+ const StorageTypeProto_ARCHIVE

+ const StorageTypeProto_DISK

+ const StorageTypeProto_RAM_DISK

+ const StorageTypeProto_SSD

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

+ func (x StorageTypeProto) Enum() *StorageTypeProto

+ func (x StorageTypeProto) String() string

+ type StorageTypeQuotaInfoProto struct

+ Consumed *uint64

+ Quota *uint64

+ Type *StorageTypeProto

+ XXX_unrecognized []byte

+ func (*StorageTypeQuotaInfoProto) ProtoMessage()

+ func (m *StorageTypeQuotaInfoProto) GetConsumed() uint64

+ func (m *StorageTypeQuotaInfoProto) GetQuota() uint64

+ func (m *StorageTypeQuotaInfoProto) GetType() StorageTypeProto

+ func (m *StorageTypeQuotaInfoProto) Reset()

+ func (m *StorageTypeQuotaInfoProto) String() string

+ type StorageTypeQuotaInfosProto struct

+ TypeQuotaInfo []*StorageTypeQuotaInfoProto

+ XXX_unrecognized []byte

+ func (*StorageTypeQuotaInfosProto) ProtoMessage()

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

+ func (m *StorageTypeQuotaInfosProto) Reset()

+ func (m *StorageTypeQuotaInfosProto) String() string

+ type StorageTypesProto struct

+ StorageTypes []StorageTypeProto

+ XXX_unrecognized []byte

+ func (*StorageTypesProto) ProtoMessage()

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

+ func (m *StorageTypesProto) Reset()

+ func (m *StorageTypesProto) String() string

+ type StorageUuidsProto struct

+ StorageUuids []string

+ XXX_unrecognized []byte

+ func (*StorageUuidsProto) ProtoMessage()

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

+ func (m *StorageUuidsProto) Reset()

+ func (m *StorageUuidsProto) String() string

+ type TriggerBlockReportRequestProto struct

+ Incremental *bool

+ XXX_unrecognized []byte

+ func (*TriggerBlockReportRequestProto) ProtoMessage()

+ func (m *TriggerBlockReportRequestProto) GetIncremental() bool

+ func (m *TriggerBlockReportRequestProto) Reset()

+ func (m *TriggerBlockReportRequestProto) String() string

+ type TriggerBlockReportResponseProto struct

+ XXX_unrecognized []byte

+ func (*TriggerBlockReportResponseProto) ProtoMessage()

+ func (m *TriggerBlockReportResponseProto) Reset()

+ func (m *TriggerBlockReportResponseProto) String() string

+ type TruncateEventProto struct

+ FileSize *int64

+ Path *string

+ Timestamp *int64

+ XXX_unrecognized []byte

+ func (*TruncateEventProto) ProtoMessage()

+ func (m *TruncateEventProto) GetFileSize() int64

+ func (m *TruncateEventProto) GetPath() string

+ func (m *TruncateEventProto) GetTimestamp() int64

+ func (m *TruncateEventProto) Reset()

+ func (m *TruncateEventProto) String() string

+ type TruncateRequestProto struct

+ ClientName *string

+ NewLength *uint64

+ Src *string

+ XXX_unrecognized []byte

+ func (*TruncateRequestProto) ProtoMessage()

+ func (m *TruncateRequestProto) GetClientName() string

+ func (m *TruncateRequestProto) GetNewLength() uint64

+ func (m *TruncateRequestProto) GetSrc() string

+ func (m *TruncateRequestProto) Reset()

+ func (m *TruncateRequestProto) String() string

+ type TruncateResponseProto struct

+ Result *bool

+ XXX_unrecognized []byte

+ func (*TruncateResponseProto) ProtoMessage()

+ func (m *TruncateResponseProto) GetResult() bool

+ func (m *TruncateResponseProto) Reset()

+ func (m *TruncateResponseProto) String() string

+ type UnlinkEventProto struct

+ Path *string

+ Timestamp *int64

+ XXX_unrecognized []byte

+ func (*UnlinkEventProto) ProtoMessage()

+ func (m *UnlinkEventProto) GetPath() string

+ func (m *UnlinkEventProto) GetTimestamp() int64

+ func (m *UnlinkEventProto) Reset()

+ func (m *UnlinkEventProto) String() string

+ type UnsetStoragePolicyRequestProto struct

+ Src *string

+ XXX_unrecognized []byte

+ func (*UnsetStoragePolicyRequestProto) ProtoMessage()

+ func (m *UnsetStoragePolicyRequestProto) GetSrc() string

+ func (m *UnsetStoragePolicyRequestProto) Reset()

+ func (m *UnsetStoragePolicyRequestProto) String() string

+ type UnsetStoragePolicyResponseProto struct

+ XXX_unrecognized []byte

+ func (*UnsetStoragePolicyResponseProto) ProtoMessage()

+ func (m *UnsetStoragePolicyResponseProto) Reset()

+ func (m *UnsetStoragePolicyResponseProto) String() string

type UpdatePipelineRequestProto

+ StorageIDs []string

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

+ type XAttrProto struct

+ Name *string

+ Namespace *XAttrProto_XAttrNamespaceProto

+ Value []byte

+ XXX_unrecognized []byte

+ func (*XAttrProto) ProtoMessage()

+ func (m *XAttrProto) GetName() string

+ func (m *XAttrProto) GetNamespace() XAttrProto_XAttrNamespaceProto

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

+ func (m *XAttrProto) Reset()

+ func (m *XAttrProto) String() string

+ type XAttrProto_XAttrNamespaceProto int32

+ const XAttrProto_RAW

+ const XAttrProto_SECURITY

+ const XAttrProto_SYSTEM

+ const XAttrProto_TRUSTED

+ const XAttrProto_USER

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

+ func (x XAttrProto_XAttrNamespaceProto) Enum() *XAttrProto_XAttrNamespaceProto

+ func (x XAttrProto_XAttrNamespaceProto) String() string

+ type XAttrSetFlagProto int32

+ const XAttrSetFlagProto_XATTR_CREATE

+ const XAttrSetFlagProto_XATTR_REPLACE

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

+ func (x XAttrSetFlagProto) Enum() *XAttrSetFlagProto

+ func (x XAttrSetFlagProto) String() string

+ type ZoneEncryptionInfoProto struct

+ CryptoProtocolVersion *CryptoProtocolVersionProto

+ KeyName *string

+ Suite *CipherSuiteProto

+ XXX_unrecognized []byte

+ func (*ZoneEncryptionInfoProto) ProtoMessage()

+ func (m *ZoneEncryptionInfoProto) GetCryptoProtocolVersion() CryptoProtocolVersionProto

+ func (m *ZoneEncryptionInfoProto) GetKeyName() string

+ func (m *ZoneEncryptionInfoProto) GetSuite() CipherSuiteProto

+ func (m *ZoneEncryptionInfoProto) Reset()

+ func (m *ZoneEncryptionInfoProto) String() string

v0

v0.1.4

Feb 28, 2015

v0.1.3

Jan 6, 2015

v0.1.2

Dec 19, 2014

Changes in this version

+ const Default_AddBlockRequestProto_FileId

+ const Default_BlockProto_NumBytes

+ const Default_CompleteRequestProto_FileId

+ const Default_DatanodeIDProto_InfoSecurePort

+ const Default_DatanodeInfoProto_BlockPoolUsed

+ const Default_DatanodeInfoProto_Capacity

+ const Default_DatanodeInfoProto_DfsUsed

+ const Default_DatanodeInfoProto_LastUpdate

+ const Default_DatanodeInfoProto_Remaining

+ const Default_DatanodeInfoProto_XceiverCount

+ const Default_ExtendedBlockProto_NumBytes

+ const Default_FsServerDefaultsProto_EncryptDataTransfer

+ const Default_FsServerDefaultsProto_TrashInterval

+ const Default_FsyncRequestProto_LastBlockLength

+ const Default_HdfsFileStatusProto_BlockReplication

+ const Default_HdfsFileStatusProto_Blocksize

+ const Default_HdfsFileStatusProto_ChildrenNum

+ const Default_HdfsFileStatusProto_FileId

+ const Default_OpReadBlockProto_SendChecksums

+ const Default_PacketHeaderProto_SyncBlock

+ const Default_PipelineAckProto_DownstreamAckTimeNanos

+ const Default_RemoteEditLogProto_IsInProgress

+ const Default_SetSafeModeRequestProto_Checked

+ var ChecksumTypeProto_name = map[int32]string

+ var ChecksumTypeProto_value = map[string]int32

+ var CreateFlagProto_name = map[int32]string

+ var CreateFlagProto_value = map[string]int32

+ var DataTransferEncryptorMessageProto_DataTransferEncryptorStatus_name = map[int32]string

+ var DataTransferEncryptorMessageProto_DataTransferEncryptorStatus_value = map[string]int32

+ var DatanodeInfoProto_AdminState_name = map[int32]string

+ var DatanodeInfoProto_AdminState_value = map[string]int32

+ var DatanodeReportTypeProto_name = map[int32]string

+ var DatanodeReportTypeProto_value = map[string]int32

+ var HdfsFileStatusProto_FileType_name = map[int32]string

+ var HdfsFileStatusProto_FileType_value = map[string]int32

+ var NamenodeCommandProto_Type_name = map[int32]string

+ var NamenodeCommandProto_Type_value = map[string]int32

+ var NamenodeRegistrationProto_NamenodeRoleProto_name = map[int32]string

+ var NamenodeRegistrationProto_NamenodeRoleProto_value = map[string]int32

+ var OpWriteBlockProto_BlockConstructionStage_name = map[int32]string

+ var OpWriteBlockProto_BlockConstructionStage_value = map[string]int32

+ var ReplicaStateProto_name = map[int32]string

+ var ReplicaStateProto_value = map[string]int32

+ var SafeModeActionProto_name = map[int32]string

+ var SafeModeActionProto_value = map[string]int32

+ var Status_name = map[int32]string

+ var Status_value = map[string]int32

+ type AbandonBlockRequestProto struct

+ B *ExtendedBlockProto

+ Holder *string

+ Src *string

+ XXX_unrecognized []byte

+ func (*AbandonBlockRequestProto) ProtoMessage()

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

+ func (m *AbandonBlockRequestProto) GetHolder() string

+ func (m *AbandonBlockRequestProto) GetSrc() string

+ func (m *AbandonBlockRequestProto) Reset()

+ func (m *AbandonBlockRequestProto) String() string

+ type AbandonBlockResponseProto struct

+ XXX_unrecognized []byte

+ func (*AbandonBlockResponseProto) ProtoMessage()

+ func (m *AbandonBlockResponseProto) Reset()

+ func (m *AbandonBlockResponseProto) String() string

+ type AddBlockRequestProto struct

+ ClientName *string

+ ExcludeNodes []*DatanodeInfoProto

+ FavoredNodes []string

+ FileId *uint64

+ Previous *ExtendedBlockProto

+ Src *string

+ XXX_unrecognized []byte

+ func (*AddBlockRequestProto) ProtoMessage()

+ func (m *AddBlockRequestProto) GetClientName() string

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

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

+ func (m *AddBlockRequestProto) GetFileId() uint64

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

+ func (m *AddBlockRequestProto) GetSrc() string

+ func (m *AddBlockRequestProto) Reset()

+ func (m *AddBlockRequestProto) String() string

+ type AddBlockResponseProto struct

+ Block *LocatedBlockProto

+ XXX_unrecognized []byte

+ func (*AddBlockResponseProto) ProtoMessage()

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

+ func (m *AddBlockResponseProto) Reset()

+ func (m *AddBlockResponseProto) String() string

+ type AllowSnapshotRequestProto struct

+ SnapshotRoot *string

+ XXX_unrecognized []byte

+ func (*AllowSnapshotRequestProto) ProtoMessage()

+ func (m *AllowSnapshotRequestProto) GetSnapshotRoot() string

+ func (m *AllowSnapshotRequestProto) Reset()

+ func (m *AllowSnapshotRequestProto) String() string

+ type AllowSnapshotResponseProto struct

+ XXX_unrecognized []byte

+ func (*AllowSnapshotResponseProto) ProtoMessage()

+ func (m *AllowSnapshotResponseProto) Reset()

+ func (m *AllowSnapshotResponseProto) String() string

+ type AppendRequestProto struct

+ ClientName *string

+ Src *string

+ XXX_unrecognized []byte

+ func (*AppendRequestProto) ProtoMessage()

+ func (m *AppendRequestProto) GetClientName() string

+ func (m *AppendRequestProto) GetSrc() string

+ func (m *AppendRequestProto) Reset()

+ func (m *AppendRequestProto) String() string

+ type AppendResponseProto struct

+ Block *LocatedBlockProto

+ XXX_unrecognized []byte

+ func (*AppendResponseProto) ProtoMessage()

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

+ func (m *AppendResponseProto) Reset()

+ func (m *AppendResponseProto) String() string

+ type BaseHeaderProto struct

+ Block *ExtendedBlockProto

+ Token *hadoop_common.TokenProto

+ XXX_unrecognized []byte

+ func (*BaseHeaderProto) ProtoMessage()

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

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

+ func (m *BaseHeaderProto) Reset()

+ func (m *BaseHeaderProto) String() string

+ type BlockKeyProto struct

+ ExpiryDate *uint64

+ KeyBytes []byte

+ KeyId *uint32

+ XXX_unrecognized []byte

+ func (*BlockKeyProto) ProtoMessage()

+ func (m *BlockKeyProto) GetExpiryDate() uint64

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

+ func (m *BlockKeyProto) GetKeyId() uint32

+ func (m *BlockKeyProto) Reset()

+ func (m *BlockKeyProto) String() string

+ type BlockOpResponseProto struct

+ ChecksumResponse *OpBlockChecksumResponseProto

+ FirstBadLink *string

+ Message *string

+ ReadOpChecksumInfo *ReadOpChecksumInfoProto

+ ShortCircuitAccessVersion *uint32

+ Status *Status

+ XXX_unrecognized []byte

+ func (*BlockOpResponseProto) ProtoMessage()

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

+ func (m *BlockOpResponseProto) GetFirstBadLink() string

+ func (m *BlockOpResponseProto) GetMessage() string

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

+ func (m *BlockOpResponseProto) GetShortCircuitAccessVersion() uint32

+ func (m *BlockOpResponseProto) GetStatus() Status

+ func (m *BlockOpResponseProto) Reset()

+ func (m *BlockOpResponseProto) String() string

+ type BlockProto struct

+ BlockId *uint64

+ GenStamp *uint64

+ NumBytes *uint64

+ XXX_unrecognized []byte

+ func (*BlockProto) ProtoMessage()

+ func (m *BlockProto) GetBlockId() uint64

+ func (m *BlockProto) GetGenStamp() uint64

+ func (m *BlockProto) GetNumBytes() uint64

+ func (m *BlockProto) Reset()

+ func (m *BlockProto) String() string

+ type BlockWithLocationsProto struct

+ Block *BlockProto

+ StorageIDs []string

+ XXX_unrecognized []byte

+ func (*BlockWithLocationsProto) ProtoMessage()

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

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

+ func (m *BlockWithLocationsProto) Reset()

+ func (m *BlockWithLocationsProto) String() string

+ type BlocksWithLocationsProto struct

+ Blocks []*BlockWithLocationsProto

+ XXX_unrecognized []byte

+ func (*BlocksWithLocationsProto) ProtoMessage()

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

+ func (m *BlocksWithLocationsProto) Reset()

+ func (m *BlocksWithLocationsProto) String() string

+ type CachingStrategyProto struct

+ DropBehind *bool

+ Readahead *int64

+ XXX_unrecognized []byte

+ func (*CachingStrategyProto) ProtoMessage()

+ func (m *CachingStrategyProto) GetDropBehind() bool

+ func (m *CachingStrategyProto) GetReadahead() int64

+ func (m *CachingStrategyProto) Reset()

+ func (m *CachingStrategyProto) String() string

+ type CheckpointCommandProto struct

+ NeedToReturnImage *bool

+ Signature *CheckpointSignatureProto

+ XXX_unrecognized []byte

+ func (*CheckpointCommandProto) ProtoMessage()

+ func (m *CheckpointCommandProto) GetNeedToReturnImage() bool

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

+ func (m *CheckpointCommandProto) Reset()

+ func (m *CheckpointCommandProto) String() string

+ type CheckpointSignatureProto struct

+ BlockPoolId *string

+ CurSegmentTxId *uint64

+ MostRecentCheckpointTxId *uint64

+ StorageInfo *StorageInfoProto

+ XXX_unrecognized []byte

+ func (*CheckpointSignatureProto) ProtoMessage()

+ func (m *CheckpointSignatureProto) GetBlockPoolId() string

+ func (m *CheckpointSignatureProto) GetCurSegmentTxId() uint64

+ func (m *CheckpointSignatureProto) GetMostRecentCheckpointTxId() uint64

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

+ func (m *CheckpointSignatureProto) Reset()

+ func (m *CheckpointSignatureProto) String() string

+ type ChecksumProto struct

+ BytesPerChecksum *uint32

+ Type *ChecksumTypeProto

+ XXX_unrecognized []byte

+ func (*ChecksumProto) ProtoMessage()

+ func (m *ChecksumProto) GetBytesPerChecksum() uint32

+ func (m *ChecksumProto) GetType() ChecksumTypeProto

+ func (m *ChecksumProto) Reset()

+ func (m *ChecksumProto) String() string

+ type ChecksumTypeProto int32

+ const ChecksumTypeProto_CHECKSUM_CRC32

+ const ChecksumTypeProto_CHECKSUM_CRC32C

+ const ChecksumTypeProto_CHECKSUM_NULL

+ const Default_FsServerDefaultsProto_ChecksumType

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

+ func (x ChecksumTypeProto) Enum() *ChecksumTypeProto

+ func (x ChecksumTypeProto) String() string

+ type ClientOperationHeaderProto struct

+ BaseHeader *BaseHeaderProto

+ ClientName *string

+ XXX_unrecognized []byte

+ func (*ClientOperationHeaderProto) ProtoMessage()

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

+ func (m *ClientOperationHeaderProto) GetClientName() string

+ func (m *ClientOperationHeaderProto) Reset()

+ func (m *ClientOperationHeaderProto) String() string

+ type ClientReadStatusProto struct

+ Status *Status

+ XXX_unrecognized []byte

+ func (*ClientReadStatusProto) ProtoMessage()

+ func (m *ClientReadStatusProto) GetStatus() Status

+ func (m *ClientReadStatusProto) Reset()

+ func (m *ClientReadStatusProto) String() string

+ type CompleteRequestProto struct

+ ClientName *string

+ FileId *uint64

+ Last *ExtendedBlockProto

+ Src *string

+ XXX_unrecognized []byte

+ func (*CompleteRequestProto) ProtoMessage()

+ func (m *CompleteRequestProto) GetClientName() string

+ func (m *CompleteRequestProto) GetFileId() uint64

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

+ func (m *CompleteRequestProto) GetSrc() string

+ func (m *CompleteRequestProto) Reset()

+ func (m *CompleteRequestProto) String() string

+ type CompleteResponseProto struct

+ Result *bool

+ XXX_unrecognized []byte

+ func (*CompleteResponseProto) ProtoMessage()

+ func (m *CompleteResponseProto) GetResult() bool

+ func (m *CompleteResponseProto) Reset()

+ func (m *CompleteResponseProto) String() string

+ type ConcatRequestProto struct

+ Srcs []string

+ Trg *string

+ XXX_unrecognized []byte

+ func (*ConcatRequestProto) ProtoMessage()

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

+ func (m *ConcatRequestProto) GetTrg() string

+ func (m *ConcatRequestProto) Reset()

+ func (m *ConcatRequestProto) String() string

+ type ConcatResponseProto struct

+ XXX_unrecognized []byte

+ func (*ConcatResponseProto) ProtoMessage()

+ func (m *ConcatResponseProto) Reset()

+ func (m *ConcatResponseProto) String() string

+ type ContentSummaryProto struct

+ DirectoryCount *uint64

+ FileCount *uint64

+ Length *uint64

+ Quota *uint64

+ SpaceConsumed *uint64

+ SpaceQuota *uint64

+ XXX_unrecognized []byte

+ func (*ContentSummaryProto) ProtoMessage()

+ func (m *ContentSummaryProto) GetDirectoryCount() uint64

+ func (m *ContentSummaryProto) GetFileCount() uint64

+ func (m *ContentSummaryProto) GetLength() uint64

+ func (m *ContentSummaryProto) GetQuota() uint64

+ func (m *ContentSummaryProto) GetSpaceConsumed() uint64

+ func (m *ContentSummaryProto) GetSpaceQuota() uint64

+ func (m *ContentSummaryProto) Reset()

+ func (m *ContentSummaryProto) String() string

+ type CorruptFileBlocksProto struct

+ Cookie *string

+ Files []string

+ XXX_unrecognized []byte

+ func (*CorruptFileBlocksProto) ProtoMessage()

+ func (m *CorruptFileBlocksProto) GetCookie() string

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

+ func (m *CorruptFileBlocksProto) Reset()

+ func (m *CorruptFileBlocksProto) String() string

+ type CreateFlagProto int32

+ const CreateFlagProto_APPEND

+ const CreateFlagProto_CREATE

+ const CreateFlagProto_OVERWRITE

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

+ func (x CreateFlagProto) Enum() *CreateFlagProto

+ func (x CreateFlagProto) String() string

+ type CreateRequestProto struct

+ BlockSize *uint64

+ ClientName *string

+ CreateFlag *uint32

+ CreateParent *bool

+ Masked *FsPermissionProto

+ Replication *uint32

+ Src *string

+ XXX_unrecognized []byte

+ func (*CreateRequestProto) ProtoMessage()

+ func (m *CreateRequestProto) GetBlockSize() uint64

+ func (m *CreateRequestProto) GetClientName() string

+ func (m *CreateRequestProto) GetCreateFlag() uint32

+ func (m *CreateRequestProto) GetCreateParent() bool

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

+ func (m *CreateRequestProto) GetReplication() uint32

+ func (m *CreateRequestProto) GetSrc() string

+ func (m *CreateRequestProto) Reset()

+ func (m *CreateRequestProto) String() string

+ type CreateResponseProto struct

+ Fs *HdfsFileStatusProto

+ XXX_unrecognized []byte

+ func (*CreateResponseProto) ProtoMessage()

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

+ func (m *CreateResponseProto) Reset()

+ func (m *CreateResponseProto) String() string

+ type CreateSnapshotRequestProto struct

+ SnapshotName *string

+ SnapshotRoot *string

+ XXX_unrecognized []byte

+ func (*CreateSnapshotRequestProto) ProtoMessage()

+ func (m *CreateSnapshotRequestProto) GetSnapshotName() string

+ func (m *CreateSnapshotRequestProto) GetSnapshotRoot() string

+ func (m *CreateSnapshotRequestProto) Reset()

+ func (m *CreateSnapshotRequestProto) String() string

+ type CreateSnapshotResponseProto struct

+ SnapshotPath *string

+ XXX_unrecognized []byte

+ func (*CreateSnapshotResponseProto) ProtoMessage()

+ func (m *CreateSnapshotResponseProto) GetSnapshotPath() string

+ func (m *CreateSnapshotResponseProto) Reset()

+ func (m *CreateSnapshotResponseProto) String() string

+ type CreateSymlinkRequestProto struct

+ CreateParent *bool

+ DirPerm *FsPermissionProto

+ Link *string

+ Target *string

+ XXX_unrecognized []byte

+ func (*CreateSymlinkRequestProto) ProtoMessage()

+ func (m *CreateSymlinkRequestProto) GetCreateParent() bool

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

+ func (m *CreateSymlinkRequestProto) GetLink() string

+ func (m *CreateSymlinkRequestProto) GetTarget() string

+ func (m *CreateSymlinkRequestProto) Reset()

+ func (m *CreateSymlinkRequestProto) String() string

+ type CreateSymlinkResponseProto struct

+ XXX_unrecognized []byte

+ func (*CreateSymlinkResponseProto) ProtoMessage()

+ func (m *CreateSymlinkResponseProto) Reset()

+ func (m *CreateSymlinkResponseProto) String() string

+ type DNTransferAckProto struct

+ Status *Status

+ XXX_unrecognized []byte

+ func (*DNTransferAckProto) ProtoMessage()

+ func (m *DNTransferAckProto) GetStatus() Status

+ func (m *DNTransferAckProto) Reset()

+ func (m *DNTransferAckProto) String() string

+ type DataEncryptionKeyProto struct

+ BlockPoolId *string

+ EncryptionAlgorithm *string

+ EncryptionKey []byte

+ ExpiryDate *uint64

+ KeyId *uint32

+ Nonce []byte

+ XXX_unrecognized []byte

+ func (*DataEncryptionKeyProto) ProtoMessage()

+ func (m *DataEncryptionKeyProto) GetBlockPoolId() string

+ func (m *DataEncryptionKeyProto) GetEncryptionAlgorithm() string

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

+ func (m *DataEncryptionKeyProto) GetExpiryDate() uint64

+ func (m *DataEncryptionKeyProto) GetKeyId() uint32

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

+ func (m *DataEncryptionKeyProto) Reset()

+ func (m *DataEncryptionKeyProto) String() string

+ type DataTransferEncryptorMessageProto struct

+ Message *string

+ Payload []byte

+ Status *DataTransferEncryptorMessageProto_DataTransferEncryptorStatus

+ XXX_unrecognized []byte

+ func (*DataTransferEncryptorMessageProto) ProtoMessage()

+ func (m *DataTransferEncryptorMessageProto) GetMessage() string

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

+ func (m *DataTransferEncryptorMessageProto) GetStatus() DataTransferEncryptorMessageProto_DataTransferEncryptorStatus

+ func (m *DataTransferEncryptorMessageProto) Reset()

+ func (m *DataTransferEncryptorMessageProto) String() string

+ type DataTransferEncryptorMessageProto_DataTransferEncryptorStatus int32

+ const DataTransferEncryptorMessageProto_ERROR

+ const DataTransferEncryptorMessageProto_ERROR_UNKNOWN_KEY

+ const DataTransferEncryptorMessageProto_SUCCESS

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

+ func (x DataTransferEncryptorMessageProto_DataTransferEncryptorStatus) Enum() *DataTransferEncryptorMessageProto_DataTransferEncryptorStatus

+ func (x DataTransferEncryptorMessageProto_DataTransferEncryptorStatus) String() string

+ type DatanodeIDProto struct

+ HostName *string

+ InfoPort *uint32

+ InfoSecurePort *uint32

+ IpAddr *string

+ IpcPort *uint32

+ StorageID *string

+ XXX_unrecognized []byte

+ XferPort *uint32

+ func (*DatanodeIDProto) ProtoMessage()

+ func (m *DatanodeIDProto) GetHostName() string

+ func (m *DatanodeIDProto) GetInfoPort() uint32

+ func (m *DatanodeIDProto) GetInfoSecurePort() uint32

+ func (m *DatanodeIDProto) GetIpAddr() string

+ func (m *DatanodeIDProto) GetIpcPort() uint32

+ func (m *DatanodeIDProto) GetStorageID() string

+ func (m *DatanodeIDProto) GetXferPort() uint32

+ func (m *DatanodeIDProto) Reset()

+ func (m *DatanodeIDProto) String() string

+ type DatanodeInfoProto struct

+ AdminState *DatanodeInfoProto_AdminState

+ BlockPoolUsed *uint64

+ Capacity *uint64

+ DfsUsed *uint64

+ Id *DatanodeIDProto

+ LastUpdate *uint64

+ Location *string

+ Remaining *uint64

+ XXX_unrecognized []byte

+ XceiverCount *uint32

+ func (*DatanodeInfoProto) ProtoMessage()

+ func (m *DatanodeInfoProto) GetAdminState() DatanodeInfoProto_AdminState

+ func (m *DatanodeInfoProto) GetBlockPoolUsed() uint64

+ func (m *DatanodeInfoProto) GetCapacity() uint64

+ func (m *DatanodeInfoProto) GetDfsUsed() uint64

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

+ func (m *DatanodeInfoProto) GetLastUpdate() uint64

+ func (m *DatanodeInfoProto) GetLocation() string

+ func (m *DatanodeInfoProto) GetRemaining() uint64

+ func (m *DatanodeInfoProto) GetXceiverCount() uint32

+ func (m *DatanodeInfoProto) Reset()

+ func (m *DatanodeInfoProto) String() string

+ type DatanodeInfoProto_AdminState int32

+ const DatanodeInfoProto_DECOMMISSIONED

+ const DatanodeInfoProto_DECOMMISSION_INPROGRESS

+ const DatanodeInfoProto_NORMAL

+ const Default_DatanodeInfoProto_AdminState

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

+ func (x DatanodeInfoProto_AdminState) Enum() *DatanodeInfoProto_AdminState

+ func (x DatanodeInfoProto_AdminState) String() string

+ type DatanodeInfosProto struct

+ Datanodes []*DatanodeInfoProto

+ XXX_unrecognized []byte

+ func (*DatanodeInfosProto) ProtoMessage()

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

+ func (m *DatanodeInfosProto) Reset()

+ func (m *DatanodeInfosProto) String() string

+ type DatanodeReportTypeProto int32

+ const DatanodeReportTypeProto_ALL

+ const DatanodeReportTypeProto_DEAD

+ const DatanodeReportTypeProto_LIVE

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

+ func (x DatanodeReportTypeProto) Enum() *DatanodeReportTypeProto

+ func (x DatanodeReportTypeProto) String() string

+ type DeleteRequestProto struct

+ Recursive *bool

+ Src *string

+ XXX_unrecognized []byte

+ func (*DeleteRequestProto) ProtoMessage()

+ func (m *DeleteRequestProto) GetRecursive() bool

+ func (m *DeleteRequestProto) GetSrc() string

+ func (m *DeleteRequestProto) Reset()

+ func (m *DeleteRequestProto) String() string

+ type DeleteResponseProto struct

+ Result *bool

+ XXX_unrecognized []byte

+ func (*DeleteResponseProto) ProtoMessage()

+ func (m *DeleteResponseProto) GetResult() bool

+ func (m *DeleteResponseProto) Reset()

+ func (m *DeleteResponseProto) String() string

+ type DeleteSnapshotRequestProto struct

+ SnapshotName *string

+ SnapshotRoot *string

+ XXX_unrecognized []byte

+ func (*DeleteSnapshotRequestProto) ProtoMessage()

+ func (m *DeleteSnapshotRequestProto) GetSnapshotName() string

+ func (m *DeleteSnapshotRequestProto) GetSnapshotRoot() string

+ func (m *DeleteSnapshotRequestProto) Reset()

+ func (m *DeleteSnapshotRequestProto) String() string

+ type DeleteSnapshotResponseProto struct

+ XXX_unrecognized []byte

+ func (*DeleteSnapshotResponseProto) ProtoMessage()

+ func (m *DeleteSnapshotResponseProto) Reset()

+ func (m *DeleteSnapshotResponseProto) String() string

+ type DirectoryListingProto struct

+ PartialListing []*HdfsFileStatusProto

+ RemainingEntries *uint32

+ XXX_unrecognized []byte

+ func (*DirectoryListingProto) ProtoMessage()

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

+ func (m *DirectoryListingProto) GetRemainingEntries() uint32

+ func (m *DirectoryListingProto) Reset()

+ func (m *DirectoryListingProto) String() string

+ type DisallowSnapshotRequestProto struct

+ SnapshotRoot *string

+ XXX_unrecognized []byte

+ func (*DisallowSnapshotRequestProto) ProtoMessage()

+ func (m *DisallowSnapshotRequestProto) GetSnapshotRoot() string

+ func (m *DisallowSnapshotRequestProto) Reset()

+ func (m *DisallowSnapshotRequestProto) String() string

+ type DisallowSnapshotResponseProto struct

+ XXX_unrecognized []byte

+ func (*DisallowSnapshotResponseProto) ProtoMessage()

+ func (m *DisallowSnapshotResponseProto) Reset()

+ func (m *DisallowSnapshotResponseProto) String() string

+ type ExportedBlockKeysProto struct

+ AllKeys []*BlockKeyProto

+ CurrentKey *BlockKeyProto

+ IsBlockTokenEnabled *bool

+ KeyUpdateInterval *uint64

+ TokenLifeTime *uint64

+ XXX_unrecognized []byte

+ func (*ExportedBlockKeysProto) ProtoMessage()

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

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

+ func (m *ExportedBlockKeysProto) GetIsBlockTokenEnabled() bool

+ func (m *ExportedBlockKeysProto) GetKeyUpdateInterval() uint64

+ func (m *ExportedBlockKeysProto) GetTokenLifeTime() uint64

+ func (m *ExportedBlockKeysProto) Reset()

+ func (m *ExportedBlockKeysProto) String() string

+ type ExtendedBlockProto struct

+ BlockId *uint64

+ GenerationStamp *uint64

+ NumBytes *uint64

+ PoolId *string

+ XXX_unrecognized []byte

+ func (*ExtendedBlockProto) ProtoMessage()

+ func (m *ExtendedBlockProto) GetBlockId() uint64

+ func (m *ExtendedBlockProto) GetGenerationStamp() uint64

+ func (m *ExtendedBlockProto) GetNumBytes() uint64

+ func (m *ExtendedBlockProto) GetPoolId() string

+ func (m *ExtendedBlockProto) Reset()

+ func (m *ExtendedBlockProto) String() string

+ type FinalizeUpgradeRequestProto struct

+ XXX_unrecognized []byte

+ func (*FinalizeUpgradeRequestProto) ProtoMessage()

+ func (m *FinalizeUpgradeRequestProto) Reset()

+ func (m *FinalizeUpgradeRequestProto) String() string

+ type FinalizeUpgradeResponseProto struct

+ XXX_unrecognized []byte

+ func (*FinalizeUpgradeResponseProto) ProtoMessage()

+ func (m *FinalizeUpgradeResponseProto) Reset()

+ func (m *FinalizeUpgradeResponseProto) String() string

+ type FsPermissionProto struct

+ Perm *uint32

+ XXX_unrecognized []byte

+ func (*FsPermissionProto) ProtoMessage()

+ func (m *FsPermissionProto) GetPerm() uint32

+ func (m *FsPermissionProto) Reset()

+ func (m *FsPermissionProto) String() string

+ type FsServerDefaultsProto struct

+ BlockSize *uint64

+ BytesPerChecksum *uint32

+ ChecksumType *ChecksumTypeProto

+ EncryptDataTransfer *bool

+ FileBufferSize *uint32

+ Replication *uint32

+ TrashInterval *uint64

+ WritePacketSize *uint32

+ XXX_unrecognized []byte

+ func (*FsServerDefaultsProto) ProtoMessage()

+ func (m *FsServerDefaultsProto) GetBlockSize() uint64

+ func (m *FsServerDefaultsProto) GetBytesPerChecksum() uint32

+ func (m *FsServerDefaultsProto) GetChecksumType() ChecksumTypeProto

+ func (m *FsServerDefaultsProto) GetEncryptDataTransfer() bool

+ func (m *FsServerDefaultsProto) GetFileBufferSize() uint32

+ func (m *FsServerDefaultsProto) GetReplication() uint32

+ func (m *FsServerDefaultsProto) GetTrashInterval() uint64

+ func (m *FsServerDefaultsProto) GetWritePacketSize() uint32

+ func (m *FsServerDefaultsProto) Reset()

+ func (m *FsServerDefaultsProto) String() string

+ type FsyncRequestProto struct

+ Client *string

+ LastBlockLength *int64

+ Src *string

+ XXX_unrecognized []byte

+ func (*FsyncRequestProto) ProtoMessage()

+ func (m *FsyncRequestProto) GetClient() string

+ func (m *FsyncRequestProto) GetLastBlockLength() int64

+ func (m *FsyncRequestProto) GetSrc() string

+ func (m *FsyncRequestProto) Reset()

+ func (m *FsyncRequestProto) String() string

+ type FsyncResponseProto struct

+ XXX_unrecognized []byte

+ func (*FsyncResponseProto) ProtoMessage()

+ func (m *FsyncResponseProto) Reset()

+ func (m *FsyncResponseProto) String() string

+ type GetAdditionalDatanodeRequestProto struct

+ Blk *ExtendedBlockProto

+ ClientName *string

+ Excludes []*DatanodeInfoProto

+ Existings []*DatanodeInfoProto

+ NumAdditionalNodes *uint32

+ Src *string

+ XXX_unrecognized []byte

+ func (*GetAdditionalDatanodeRequestProto) ProtoMessage()

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

+ func (m *GetAdditionalDatanodeRequestProto) GetClientName() string

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

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

+ func (m *GetAdditionalDatanodeRequestProto) GetNumAdditionalNodes() uint32

+ func (m *GetAdditionalDatanodeRequestProto) GetSrc() string

+ func (m *GetAdditionalDatanodeRequestProto) Reset()

+ func (m *GetAdditionalDatanodeRequestProto) String() string

+ type GetAdditionalDatanodeResponseProto struct

+ Block *LocatedBlockProto

+ XXX_unrecognized []byte

+ func (*GetAdditionalDatanodeResponseProto) ProtoMessage()

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

+ func (m *GetAdditionalDatanodeResponseProto) Reset()

+ func (m *GetAdditionalDatanodeResponseProto) String() string

+ type GetBlockLocationsRequestProto struct

+ Length *uint64

+ Offset *uint64

+ Src *string

+ XXX_unrecognized []byte

+ func (*GetBlockLocationsRequestProto) ProtoMessage()

+ func (m *GetBlockLocationsRequestProto) GetLength() uint64

+ func (m *GetBlockLocationsRequestProto) GetOffset() uint64

+ func (m *GetBlockLocationsRequestProto) GetSrc() string

+ func (m *GetBlockLocationsRequestProto) Reset()

+ func (m *GetBlockLocationsRequestProto) String() string

+ type GetBlockLocationsResponseProto struct

+ Locations *LocatedBlocksProto

+ XXX_unrecognized []byte

+ func (*GetBlockLocationsResponseProto) ProtoMessage()

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

+ func (m *GetBlockLocationsResponseProto) Reset()

+ func (m *GetBlockLocationsResponseProto) String() string

+ type GetContentSummaryRequestProto struct

+ Path *string

+ XXX_unrecognized []byte

+ func (*GetContentSummaryRequestProto) ProtoMessage()

+ func (m *GetContentSummaryRequestProto) GetPath() string

+ func (m *GetContentSummaryRequestProto) Reset()

+ func (m *GetContentSummaryRequestProto) String() string

+ type GetContentSummaryResponseProto struct

+ Summary *ContentSummaryProto

+ XXX_unrecognized []byte

+ func (*GetContentSummaryResponseProto) ProtoMessage()

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

+ func (m *GetContentSummaryResponseProto) Reset()

+ func (m *GetContentSummaryResponseProto) String() string

+ type GetDataEncryptionKeyRequestProto struct

+ XXX_unrecognized []byte

+ func (*GetDataEncryptionKeyRequestProto) ProtoMessage()

+ func (m *GetDataEncryptionKeyRequestProto) Reset()

+ func (m *GetDataEncryptionKeyRequestProto) String() string

+ type GetDataEncryptionKeyResponseProto struct

+ DataEncryptionKey *DataEncryptionKeyProto

+ XXX_unrecognized []byte

+ func (*GetDataEncryptionKeyResponseProto) ProtoMessage()

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

+ func (m *GetDataEncryptionKeyResponseProto) Reset()

+ func (m *GetDataEncryptionKeyResponseProto) String() string

+ type GetDatanodeReportRequestProto struct

+ Type *DatanodeReportTypeProto

+ XXX_unrecognized []byte

+ func (*GetDatanodeReportRequestProto) ProtoMessage()

+ func (m *GetDatanodeReportRequestProto) GetType() DatanodeReportTypeProto

+ func (m *GetDatanodeReportRequestProto) Reset()

+ func (m *GetDatanodeReportRequestProto) String() string

+ type GetDatanodeReportResponseProto struct

+ Di []*DatanodeInfoProto

+ XXX_unrecognized []byte

+ func (*GetDatanodeReportResponseProto) ProtoMessage()

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

+ func (m *GetDatanodeReportResponseProto) Reset()

+ func (m *GetDatanodeReportResponseProto) String() string

+ type GetFileInfoRequestProto struct

+ Src *string

+ XXX_unrecognized []byte

+ func (*GetFileInfoRequestProto) ProtoMessage()

+ func (m *GetFileInfoRequestProto) GetSrc() string

+ func (m *GetFileInfoRequestProto) Reset()

+ func (m *GetFileInfoRequestProto) String() string

+ type GetFileInfoResponseProto struct

+ Fs *HdfsFileStatusProto

+ XXX_unrecognized []byte

+ func (*GetFileInfoResponseProto) ProtoMessage()

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

+ func (m *GetFileInfoResponseProto) Reset()

+ func (m *GetFileInfoResponseProto) String() string

+ type GetFileLinkInfoRequestProto struct

+ Src *string

+ XXX_unrecognized []byte

+ func (*GetFileLinkInfoRequestProto) ProtoMessage()

+ func (m *GetFileLinkInfoRequestProto) GetSrc() string

+ func (m *GetFileLinkInfoRequestProto) Reset()

+ func (m *GetFileLinkInfoRequestProto) String() string

+ type GetFileLinkInfoResponseProto struct

+ Fs *HdfsFileStatusProto

+ XXX_unrecognized []byte

+ func (*GetFileLinkInfoResponseProto) ProtoMessage()

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

+ func (m *GetFileLinkInfoResponseProto) Reset()

+ func (m *GetFileLinkInfoResponseProto) String() string

+ type GetFsStatsResponseProto struct

+ Capacity *uint64

+ CorruptBlocks *uint64

+ MissingBlocks *uint64

+ Remaining *uint64

+ UnderReplicated *uint64

+ Used *uint64

+ XXX_unrecognized []byte

+ func (*GetFsStatsResponseProto) ProtoMessage()

+ func (m *GetFsStatsResponseProto) GetCapacity() uint64

+ func (m *GetFsStatsResponseProto) GetCorruptBlocks() uint64

+ func (m *GetFsStatsResponseProto) GetMissingBlocks() uint64

+ func (m *GetFsStatsResponseProto) GetRemaining() uint64

+ func (m *GetFsStatsResponseProto) GetUnderReplicated() uint64

+ func (m *GetFsStatsResponseProto) GetUsed() uint64

+ func (m *GetFsStatsResponseProto) Reset()

+ func (m *GetFsStatsResponseProto) String() string

+ type GetFsStatusRequestProto struct

+ XXX_unrecognized []byte

+ func (*GetFsStatusRequestProto) ProtoMessage()

+ func (m *GetFsStatusRequestProto) Reset()

+ func (m *GetFsStatusRequestProto) String() string

+ type GetLinkTargetRequestProto struct

+ Path *string

+ XXX_unrecognized []byte

+ func (*GetLinkTargetRequestProto) ProtoMessage()

+ func (m *GetLinkTargetRequestProto) GetPath() string

+ func (m *GetLinkTargetRequestProto) Reset()

+ func (m *GetLinkTargetRequestProto) String() string

+ type GetLinkTargetResponseProto struct

+ TargetPath *string

+ XXX_unrecognized []byte

+ func (*GetLinkTargetResponseProto) ProtoMessage()

+ func (m *GetLinkTargetResponseProto) GetTargetPath() string

+ func (m *GetLinkTargetResponseProto) Reset()

+ func (m *GetLinkTargetResponseProto) String() string

+ type GetListingRequestProto struct

+ NeedLocation *bool

+ Src *string

+ StartAfter []byte

+ XXX_unrecognized []byte

+ func (*GetListingRequestProto) ProtoMessage()

+ func (m *GetListingRequestProto) GetNeedLocation() bool

+ func (m *GetListingRequestProto) GetSrc() string

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

+ func (m *GetListingRequestProto) Reset()

+ func (m *GetListingRequestProto) String() string

+ type GetListingResponseProto struct

+ DirList *DirectoryListingProto

+ XXX_unrecognized []byte

+ func (*GetListingResponseProto) ProtoMessage()

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

+ func (m *GetListingResponseProto) Reset()

+ func (m *GetListingResponseProto) String() string

+ type GetPreferredBlockSizeRequestProto struct

+ Filename *string

+ XXX_unrecognized []byte

+ func (*GetPreferredBlockSizeRequestProto) ProtoMessage()

+ func (m *GetPreferredBlockSizeRequestProto) GetFilename() string

+ func (m *GetPreferredBlockSizeRequestProto) Reset()

+ func (m *GetPreferredBlockSizeRequestProto) String() string

+ type GetPreferredBlockSizeResponseProto struct

+ Bsize *uint64

+ XXX_unrecognized []byte

+ func (*GetPreferredBlockSizeResponseProto) ProtoMessage()

+ func (m *GetPreferredBlockSizeResponseProto) GetBsize() uint64

+ func (m *GetPreferredBlockSizeResponseProto) Reset()

+ func (m *GetPreferredBlockSizeResponseProto) String() string

+ type GetServerDefaultsRequestProto struct

+ XXX_unrecognized []byte

+ func (*GetServerDefaultsRequestProto) ProtoMessage()

+ func (m *GetServerDefaultsRequestProto) Reset()

+ func (m *GetServerDefaultsRequestProto) String() string

+ type GetServerDefaultsResponseProto struct

+ ServerDefaults *FsServerDefaultsProto

+ XXX_unrecognized []byte

+ func (*GetServerDefaultsResponseProto) ProtoMessage()

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

+ func (m *GetServerDefaultsResponseProto) Reset()

+ func (m *GetServerDefaultsResponseProto) String() string

+ type GetSnapshotDiffReportRequestProto struct

+ FromSnapshot *string

+ SnapshotRoot *string

+ ToSnapshot *string

+ XXX_unrecognized []byte

+ func (*GetSnapshotDiffReportRequestProto) ProtoMessage()

+ func (m *GetSnapshotDiffReportRequestProto) GetFromSnapshot() string

+ func (m *GetSnapshotDiffReportRequestProto) GetSnapshotRoot() string

+ func (m *GetSnapshotDiffReportRequestProto) GetToSnapshot() string

+ func (m *GetSnapshotDiffReportRequestProto) Reset()

+ func (m *GetSnapshotDiffReportRequestProto) String() string

+ type GetSnapshotDiffReportResponseProto struct

+ DiffReport *SnapshotDiffReportProto

+ XXX_unrecognized []byte

+ func (*GetSnapshotDiffReportResponseProto) ProtoMessage()

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

+ func (m *GetSnapshotDiffReportResponseProto) Reset()

+ func (m *GetSnapshotDiffReportResponseProto) String() string

+ type GetSnapshottableDirListingRequestProto struct

+ XXX_unrecognized []byte

+ func (*GetSnapshottableDirListingRequestProto) ProtoMessage()

+ func (m *GetSnapshottableDirListingRequestProto) Reset()

+ func (m *GetSnapshottableDirListingRequestProto) String() string

+ type GetSnapshottableDirListingResponseProto struct

+ SnapshottableDirList *SnapshottableDirectoryListingProto

+ XXX_unrecognized []byte

+ func (*GetSnapshottableDirListingResponseProto) ProtoMessage()

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

+ func (m *GetSnapshottableDirListingResponseProto) Reset()

+ func (m *GetSnapshottableDirListingResponseProto) String() string

+ type HdfsFileStatusProto struct

+ AccessTime *uint64

+ BlockReplication *uint32

+ Blocksize *uint64

+ ChildrenNum *int32

+ FileId *uint64

+ FileType *HdfsFileStatusProto_FileType

+ Group *string

+ Length *uint64

+ Locations *LocatedBlocksProto

+ ModificationTime *uint64

+ Owner *string

+ Path []byte

+ Permission *FsPermissionProto

+ Symlink []byte

+ XXX_unrecognized []byte

+ func (*HdfsFileStatusProto) ProtoMessage()

+ func (m *HdfsFileStatusProto) GetAccessTime() uint64

+ func (m *HdfsFileStatusProto) GetBlockReplication() uint32

+ func (m *HdfsFileStatusProto) GetBlocksize() uint64

+ func (m *HdfsFileStatusProto) GetChildrenNum() int32

+ func (m *HdfsFileStatusProto) GetFileId() uint64

+ func (m *HdfsFileStatusProto) GetFileType() HdfsFileStatusProto_FileType

+ func (m *HdfsFileStatusProto) GetGroup() string

+ func (m *HdfsFileStatusProto) GetLength() uint64

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

+ func (m *HdfsFileStatusProto) GetModificationTime() uint64

+ func (m *HdfsFileStatusProto) GetOwner() string

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

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

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

+ func (m *HdfsFileStatusProto) Reset()

+ func (m *HdfsFileStatusProto) String() string

+ type HdfsFileStatusProto_FileType int32

+ const HdfsFileStatusProto_IS_DIR

+ const HdfsFileStatusProto_IS_FILE

+ const HdfsFileStatusProto_IS_SYMLINK

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

+ func (x HdfsFileStatusProto_FileType) Enum() *HdfsFileStatusProto_FileType

+ func (x HdfsFileStatusProto_FileType) String() string

+ type IsFileClosedRequestProto struct

+ Src *string

+ XXX_unrecognized []byte

+ func (*IsFileClosedRequestProto) ProtoMessage()

+ func (m *IsFileClosedRequestProto) GetSrc() string

+ func (m *IsFileClosedRequestProto) Reset()

+ func (m *IsFileClosedRequestProto) String() string

+ type IsFileClosedResponseProto struct

+ Result *bool

+ XXX_unrecognized []byte

+ func (*IsFileClosedResponseProto) ProtoMessage()

+ func (m *IsFileClosedResponseProto) GetResult() bool

+ func (m *IsFileClosedResponseProto) Reset()

+ func (m *IsFileClosedResponseProto) String() string

+ type ListCorruptFileBlocksRequestProto struct

+ Cookie *string

+ Path *string

+ XXX_unrecognized []byte

+ func (*ListCorruptFileBlocksRequestProto) ProtoMessage()

+ func (m *ListCorruptFileBlocksRequestProto) GetCookie() string

+ func (m *ListCorruptFileBlocksRequestProto) GetPath() string

+ func (m *ListCorruptFileBlocksRequestProto) Reset()

+ func (m *ListCorruptFileBlocksRequestProto) String() string

+ type ListCorruptFileBlocksResponseProto struct

+ Corrupt *CorruptFileBlocksProto

+ XXX_unrecognized []byte

+ func (*ListCorruptFileBlocksResponseProto) ProtoMessage()

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

+ func (m *ListCorruptFileBlocksResponseProto) Reset()

+ func (m *ListCorruptFileBlocksResponseProto) String() string

+ type LocatedBlockProto struct

+ B *ExtendedBlockProto

+ BlockToken *hadoop_common.TokenProto

+ Corrupt *bool

+ Locs []*DatanodeInfoProto

+ Offset *uint64

+ XXX_unrecognized []byte

+ func (*LocatedBlockProto) ProtoMessage()

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

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

+ func (m *LocatedBlockProto) GetCorrupt() bool

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

+ func (m *LocatedBlockProto) GetOffset() uint64

+ func (m *LocatedBlockProto) Reset()

+ func (m *LocatedBlockProto) String() string

+ type LocatedBlocksProto struct

+ Blocks []*LocatedBlockProto

+ FileLength *uint64

+ IsLastBlockComplete *bool

+ LastBlock *LocatedBlockProto

+ UnderConstruction *bool

+ XXX_unrecognized []byte

+ func (*LocatedBlocksProto) ProtoMessage()

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

+ func (m *LocatedBlocksProto) GetFileLength() uint64

+ func (m *LocatedBlocksProto) GetIsLastBlockComplete() bool

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

+ func (m *LocatedBlocksProto) GetUnderConstruction() bool

+ func (m *LocatedBlocksProto) Reset()

+ func (m *LocatedBlocksProto) String() string

+ type MetaSaveRequestProto struct

+ Filename *string

+ XXX_unrecognized []byte

+ func (*MetaSaveRequestProto) ProtoMessage()

+ func (m *MetaSaveRequestProto) GetFilename() string

+ func (m *MetaSaveRequestProto) Reset()

+ func (m *MetaSaveRequestProto) String() string

+ type MetaSaveResponseProto struct

+ XXX_unrecognized []byte

+ func (*MetaSaveResponseProto) ProtoMessage()

+ func (m *MetaSaveResponseProto) Reset()

+ func (m *MetaSaveResponseProto) String() string

+ type MkdirsRequestProto struct

+ CreateParent *bool

+ Masked *FsPermissionProto

+ Src *string

+ XXX_unrecognized []byte

+ func (*MkdirsRequestProto) ProtoMessage()

+ func (m *MkdirsRequestProto) GetCreateParent() bool

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

+ func (m *MkdirsRequestProto) GetSrc() string

+ func (m *MkdirsRequestProto) Reset()

+ func (m *MkdirsRequestProto) String() string

+ type MkdirsResponseProto struct

+ Result *bool

+ XXX_unrecognized []byte

+ func (*MkdirsResponseProto) ProtoMessage()

+ func (m *MkdirsResponseProto) GetResult() bool

+ func (m *MkdirsResponseProto) Reset()

+ func (m *MkdirsResponseProto) String() string

+ type NamenodeCommandProto struct

+ Action *uint32

+ CheckpointCmd *CheckpointCommandProto

+ Type *NamenodeCommandProto_Type

+ XXX_unrecognized []byte

+ func (*NamenodeCommandProto) ProtoMessage()

+ func (m *NamenodeCommandProto) GetAction() uint32

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

+ func (m *NamenodeCommandProto) GetType() NamenodeCommandProto_Type

+ func (m *NamenodeCommandProto) Reset()

+ func (m *NamenodeCommandProto) String() string

+ type NamenodeCommandProto_Type int32

+ const NamenodeCommandProto_CheckPointCommand

+ const NamenodeCommandProto_NamenodeCommand

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

+ func (x NamenodeCommandProto_Type) Enum() *NamenodeCommandProto_Type

+ func (x NamenodeCommandProto_Type) String() string

+ type NamenodeRegistrationProto struct

+ HttpAddress *string

+ Role *NamenodeRegistrationProto_NamenodeRoleProto

+ RpcAddress *string

+ StorageInfo *StorageInfoProto

+ XXX_unrecognized []byte

+ func (*NamenodeRegistrationProto) ProtoMessage()

+ func (m *NamenodeRegistrationProto) GetHttpAddress() string

+ func (m *NamenodeRegistrationProto) GetRole() NamenodeRegistrationProto_NamenodeRoleProto

+ func (m *NamenodeRegistrationProto) GetRpcAddress() string

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

+ func (m *NamenodeRegistrationProto) Reset()

+ func (m *NamenodeRegistrationProto) String() string

+ type NamenodeRegistrationProto_NamenodeRoleProto int32

+ const Default_NamenodeRegistrationProto_Role

+ const NamenodeRegistrationProto_BACKUP

+ const NamenodeRegistrationProto_CHECKPOINT

+ const NamenodeRegistrationProto_NAMENODE

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

+ func (x NamenodeRegistrationProto_NamenodeRoleProto) Enum() *NamenodeRegistrationProto_NamenodeRoleProto

+ func (x NamenodeRegistrationProto_NamenodeRoleProto) String() string

+ type NamespaceInfoProto struct

+ BlockPoolID *string

+ BuildVersion *string

+ SoftwareVersion *string

+ StorageInfo *StorageInfoProto

+ Unused *uint32

+ XXX_unrecognized []byte

+ func (*NamespaceInfoProto) ProtoMessage()

+ func (m *NamespaceInfoProto) GetBlockPoolID() string

+ func (m *NamespaceInfoProto) GetBuildVersion() string

+ func (m *NamespaceInfoProto) GetSoftwareVersion() string

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

+ func (m *NamespaceInfoProto) GetUnused() uint32

+ func (m *NamespaceInfoProto) Reset()

+ func (m *NamespaceInfoProto) String() string

+ type OpBlockChecksumProto struct

+ Header *BaseHeaderProto

+ XXX_unrecognized []byte

+ func (*OpBlockChecksumProto) ProtoMessage()

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

+ func (m *OpBlockChecksumProto) Reset()

+ func (m *OpBlockChecksumProto) String() string

+ type OpBlockChecksumResponseProto struct

+ BytesPerCrc *uint32

+ CrcPerBlock *uint64

+ CrcType *ChecksumTypeProto

+ Md5 []byte

+ XXX_unrecognized []byte

+ func (*OpBlockChecksumResponseProto) ProtoMessage()

+ func (m *OpBlockChecksumResponseProto) GetBytesPerCrc() uint32

+ func (m *OpBlockChecksumResponseProto) GetCrcPerBlock() uint64

+ func (m *OpBlockChecksumResponseProto) GetCrcType() ChecksumTypeProto

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

+ func (m *OpBlockChecksumResponseProto) Reset()

+ func (m *OpBlockChecksumResponseProto) String() string

+ type OpCopyBlockProto struct

+ Header *BaseHeaderProto

+ XXX_unrecognized []byte

+ func (*OpCopyBlockProto) ProtoMessage()

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

+ func (m *OpCopyBlockProto) Reset()

+ func (m *OpCopyBlockProto) String() string

+ type OpReadBlockProto struct

+ CachingStrategy *CachingStrategyProto

+ Header *ClientOperationHeaderProto

+ Len *uint64

+ Offset *uint64

+ SendChecksums *bool

+ XXX_unrecognized []byte

+ func (*OpReadBlockProto) ProtoMessage()

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

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

+ func (m *OpReadBlockProto) GetLen() uint64

+ func (m *OpReadBlockProto) GetOffset() uint64

+ func (m *OpReadBlockProto) GetSendChecksums() bool

+ func (m *OpReadBlockProto) Reset()

+ func (m *OpReadBlockProto) String() string

+ type OpReplaceBlockProto struct

+ DelHint *string

+ Header *BaseHeaderProto

+ Source *DatanodeInfoProto

+ XXX_unrecognized []byte

+ func (*OpReplaceBlockProto) ProtoMessage()

+ func (m *OpReplaceBlockProto) GetDelHint() string

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

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

+ func (m *OpReplaceBlockProto) Reset()

+ func (m *OpReplaceBlockProto) String() string

+ type OpRequestShortCircuitAccessProto struct

+ Header *BaseHeaderProto

+ MaxVersion *uint32

+ XXX_unrecognized []byte

+ func (*OpRequestShortCircuitAccessProto) ProtoMessage()

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

+ func (m *OpRequestShortCircuitAccessProto) GetMaxVersion() uint32

+ func (m *OpRequestShortCircuitAccessProto) Reset()

+ func (m *OpRequestShortCircuitAccessProto) String() string

+ type OpTransferBlockProto struct

+ Header *ClientOperationHeaderProto

+ Targets []*DatanodeInfoProto

+ XXX_unrecognized []byte

+ func (*OpTransferBlockProto) ProtoMessage()

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

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

+ func (m *OpTransferBlockProto) Reset()

+ func (m *OpTransferBlockProto) String() string

+ type OpWriteBlockProto struct

+ CachingStrategy *CachingStrategyProto

+ Header *ClientOperationHeaderProto

+ LatestGenerationStamp *uint64

+ MaxBytesRcvd *uint64

+ MinBytesRcvd *uint64

+ PipelineSize *uint32

+ RequestedChecksum *ChecksumProto

+ Source *DatanodeInfoProto

+ Stage *OpWriteBlockProto_BlockConstructionStage

+ Targets []*DatanodeInfoProto

+ XXX_unrecognized []byte

+ func (*OpWriteBlockProto) ProtoMessage()

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

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

+ func (m *OpWriteBlockProto) GetLatestGenerationStamp() uint64

+ func (m *OpWriteBlockProto) GetMaxBytesRcvd() uint64

+ func (m *OpWriteBlockProto) GetMinBytesRcvd() uint64

+ func (m *OpWriteBlockProto) GetPipelineSize() uint32

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

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

+ func (m *OpWriteBlockProto) GetStage() OpWriteBlockProto_BlockConstructionStage

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

+ func (m *OpWriteBlockProto) Reset()

+ func (m *OpWriteBlockProto) String() string

+ type OpWriteBlockProto_BlockConstructionStage int32

+ const OpWriteBlockProto_DATA_STREAMING

+ const OpWriteBlockProto_PIPELINE_CLOSE

+ const OpWriteBlockProto_PIPELINE_CLOSE_RECOVERY

+ const OpWriteBlockProto_PIPELINE_SETUP_APPEND

+ const OpWriteBlockProto_PIPELINE_SETUP_APPEND_RECOVERY

+ const OpWriteBlockProto_PIPELINE_SETUP_CREATE

+ const OpWriteBlockProto_PIPELINE_SETUP_STREAMING_RECOVERY

+ const OpWriteBlockProto_TRANSFER_FINALIZED

+ const OpWriteBlockProto_TRANSFER_RBW

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

+ func (x OpWriteBlockProto_BlockConstructionStage) Enum() *OpWriteBlockProto_BlockConstructionStage

+ func (x OpWriteBlockProto_BlockConstructionStage) String() string

+ type PacketHeaderProto struct

+ DataLen *int32

+ LastPacketInBlock *bool

+ OffsetInBlock *int64

+ Seqno *int64

+ SyncBlock *bool

+ XXX_unrecognized []byte

+ func (*PacketHeaderProto) ProtoMessage()

+ func (m *PacketHeaderProto) GetDataLen() int32

+ func (m *PacketHeaderProto) GetLastPacketInBlock() bool

+ func (m *PacketHeaderProto) GetOffsetInBlock() int64

+ func (m *PacketHeaderProto) GetSeqno() int64

+ func (m *PacketHeaderProto) GetSyncBlock() bool

+ func (m *PacketHeaderProto) Reset()

+ func (m *PacketHeaderProto) String() string

+ type PipelineAckProto struct

+ DownstreamAckTimeNanos *uint64

+ Seqno *int64

+ Status []Status

+ XXX_unrecognized []byte

+ func (*PipelineAckProto) ProtoMessage()

+ func (m *PipelineAckProto) GetDownstreamAckTimeNanos() uint64

+ func (m *PipelineAckProto) GetSeqno() int64

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

+ func (m *PipelineAckProto) Reset()

+ func (m *PipelineAckProto) String() string

+ type ReadOpChecksumInfoProto struct

+ Checksum *ChecksumProto

+ ChunkOffset *uint64

+ XXX_unrecognized []byte

+ func (*ReadOpChecksumInfoProto) ProtoMessage()

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

+ func (m *ReadOpChecksumInfoProto) GetChunkOffset() uint64

+ func (m *ReadOpChecksumInfoProto) Reset()

+ func (m *ReadOpChecksumInfoProto) String() string

+ type RecoverLeaseRequestProto struct

+ ClientName *string

+ Src *string

+ XXX_unrecognized []byte

+ func (*RecoverLeaseRequestProto) ProtoMessage()

+ func (m *RecoverLeaseRequestProto) GetClientName() string

+ func (m *RecoverLeaseRequestProto) GetSrc() string

+ func (m *RecoverLeaseRequestProto) Reset()

+ func (m *RecoverLeaseRequestProto) String() string

+ type RecoverLeaseResponseProto struct

+ Result *bool

+ XXX_unrecognized []byte

+ func (*RecoverLeaseResponseProto) ProtoMessage()

+ func (m *RecoverLeaseResponseProto) GetResult() bool

+ func (m *RecoverLeaseResponseProto) Reset()

+ func (m *RecoverLeaseResponseProto) String() string

+ type RecoveringBlockProto struct

+ Block *LocatedBlockProto

+ NewGenStamp *uint64

+ XXX_unrecognized []byte

+ func (*RecoveringBlockProto) ProtoMessage()

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

+ func (m *RecoveringBlockProto) GetNewGenStamp() uint64

+ func (m *RecoveringBlockProto) Reset()

+ func (m *RecoveringBlockProto) String() string

+ type RefreshNodesRequestProto struct

+ XXX_unrecognized []byte

+ func (*RefreshNodesRequestProto) ProtoMessage()

+ func (m *RefreshNodesRequestProto) Reset()

+ func (m *RefreshNodesRequestProto) String() string

+ type RefreshNodesResponseProto struct

+ XXX_unrecognized []byte

+ func (*RefreshNodesResponseProto) ProtoMessage()

+ func (m *RefreshNodesResponseProto) Reset()

+ func (m *RefreshNodesResponseProto) String() string

+ type RemoteEditLogManifestProto struct

+ Logs []*RemoteEditLogProto

+ XXX_unrecognized []byte

+ func (*RemoteEditLogManifestProto) ProtoMessage()

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

+ func (m *RemoteEditLogManifestProto) Reset()

+ func (m *RemoteEditLogManifestProto) String() string

+ type RemoteEditLogProto struct

+ EndTxId *uint64

+ IsInProgress *bool

+ StartTxId *uint64

+ XXX_unrecognized []byte

+ func (*RemoteEditLogProto) ProtoMessage()

+ func (m *RemoteEditLogProto) GetEndTxId() uint64

+ func (m *RemoteEditLogProto) GetIsInProgress() bool

+ func (m *RemoteEditLogProto) GetStartTxId() uint64

+ func (m *RemoteEditLogProto) Reset()

+ func (m *RemoteEditLogProto) String() string

+ type Rename2RequestProto struct

+ Dst *string

+ OverwriteDest *bool

+ Src *string

+ XXX_unrecognized []byte

+ func (*Rename2RequestProto) ProtoMessage()

+ func (m *Rename2RequestProto) GetDst() string

+ func (m *Rename2RequestProto) GetOverwriteDest() bool

+ func (m *Rename2RequestProto) GetSrc() string

+ func (m *Rename2RequestProto) Reset()

+ func (m *Rename2RequestProto) String() string

+ type Rename2ResponseProto struct

+ XXX_unrecognized []byte

+ func (*Rename2ResponseProto) ProtoMessage()

+ func (m *Rename2ResponseProto) Reset()

+ func (m *Rename2ResponseProto) String() string

+ type RenameRequestProto struct

+ Dst *string

+ Src *string

+ XXX_unrecognized []byte

+ func (*RenameRequestProto) ProtoMessage()

+ func (m *RenameRequestProto) GetDst() string

+ func (m *RenameRequestProto) GetSrc() string

+ func (m *RenameRequestProto) Reset()

+ func (m *RenameRequestProto) String() string

+ type RenameResponseProto struct

+ Result *bool

+ XXX_unrecognized []byte

+ func (*RenameResponseProto) ProtoMessage()

+ func (m *RenameResponseProto) GetResult() bool

+ func (m *RenameResponseProto) Reset()

+ func (m *RenameResponseProto) String() string

+ type RenameSnapshotRequestProto struct

+ SnapshotNewName *string

+ SnapshotOldName *string

+ SnapshotRoot *string

+ XXX_unrecognized []byte

+ func (*RenameSnapshotRequestProto) ProtoMessage()

+ func (m *RenameSnapshotRequestProto) GetSnapshotNewName() string

+ func (m *RenameSnapshotRequestProto) GetSnapshotOldName() string

+ func (m *RenameSnapshotRequestProto) GetSnapshotRoot() string

+ func (m *RenameSnapshotRequestProto) Reset()

+ func (m *RenameSnapshotRequestProto) String() string

+ type RenameSnapshotResponseProto struct

+ XXX_unrecognized []byte

+ func (*RenameSnapshotResponseProto) ProtoMessage()

+ func (m *RenameSnapshotResponseProto) Reset()

+ func (m *RenameSnapshotResponseProto) String() string

+ type RenewLeaseRequestProto struct

+ ClientName *string

+ XXX_unrecognized []byte

+ func (*RenewLeaseRequestProto) ProtoMessage()

+ func (m *RenewLeaseRequestProto) GetClientName() string

+ func (m *RenewLeaseRequestProto) Reset()

+ func (m *RenewLeaseRequestProto) String() string

+ type RenewLeaseResponseProto struct

+ XXX_unrecognized []byte

+ func (*RenewLeaseResponseProto) ProtoMessage()

+ func (m *RenewLeaseResponseProto) Reset()

+ func (m *RenewLeaseResponseProto) String() string

+ type ReplicaStateProto int32

+ const ReplicaStateProto_FINALIZED

+ const ReplicaStateProto_RBW

+ const ReplicaStateProto_RUR

+ const ReplicaStateProto_RWR

+ const ReplicaStateProto_TEMPORARY

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

+ func (x ReplicaStateProto) Enum() *ReplicaStateProto

+ func (x ReplicaStateProto) String() string

+ type ReportBadBlocksRequestProto struct

+ Blocks []*LocatedBlockProto

+ XXX_unrecognized []byte

+ func (*ReportBadBlocksRequestProto) ProtoMessage()

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

+ func (m *ReportBadBlocksRequestProto) Reset()

+ func (m *ReportBadBlocksRequestProto) String() string

+ type ReportBadBlocksResponseProto struct

+ XXX_unrecognized []byte

+ func (*ReportBadBlocksResponseProto) ProtoMessage()

+ func (m *ReportBadBlocksResponseProto) Reset()

+ func (m *ReportBadBlocksResponseProto) String() string

+ type RestoreFailedStorageRequestProto struct

+ Arg *string

+ XXX_unrecognized []byte

+ func (*RestoreFailedStorageRequestProto) ProtoMessage()

+ func (m *RestoreFailedStorageRequestProto) GetArg() string

+ func (m *RestoreFailedStorageRequestProto) Reset()

+ func (m *RestoreFailedStorageRequestProto) String() string

+ type RestoreFailedStorageResponseProto struct

+ Result *bool

+ XXX_unrecognized []byte

+ func (*RestoreFailedStorageResponseProto) ProtoMessage()

+ func (m *RestoreFailedStorageResponseProto) GetResult() bool

+ func (m *RestoreFailedStorageResponseProto) Reset()

+ func (m *RestoreFailedStorageResponseProto) String() string

+ type RollEditsRequestProto struct

+ XXX_unrecognized []byte

+ func (*RollEditsRequestProto) ProtoMessage()

+ func (m *RollEditsRequestProto) Reset()

+ func (m *RollEditsRequestProto) String() string

+ type RollEditsResponseProto struct

+ NewSegmentTxId *uint64

+ XXX_unrecognized []byte

+ func (*RollEditsResponseProto) ProtoMessage()

+ func (m *RollEditsResponseProto) GetNewSegmentTxId() uint64

+ func (m *RollEditsResponseProto) Reset()

+ func (m *RollEditsResponseProto) String() string

+ type SafeModeActionProto int32

+ const SafeModeActionProto_SAFEMODE_ENTER

+ const SafeModeActionProto_SAFEMODE_GET

+ const SafeModeActionProto_SAFEMODE_LEAVE

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

+ func (x SafeModeActionProto) Enum() *SafeModeActionProto

+ func (x SafeModeActionProto) String() string

+ type SaveNamespaceRequestProto struct

+ XXX_unrecognized []byte

+ func (*SaveNamespaceRequestProto) ProtoMessage()

+ func (m *SaveNamespaceRequestProto) Reset()

+ func (m *SaveNamespaceRequestProto) String() string

+ type SaveNamespaceResponseProto struct

+ XXX_unrecognized []byte

+ func (*SaveNamespaceResponseProto) ProtoMessage()

+ func (m *SaveNamespaceResponseProto) Reset()

+ func (m *SaveNamespaceResponseProto) String() string

+ type SetBalancerBandwidthRequestProto struct

+ Bandwidth *int64

+ XXX_unrecognized []byte

+ func (*SetBalancerBandwidthRequestProto) ProtoMessage()

+ func (m *SetBalancerBandwidthRequestProto) GetBandwidth() int64

+ func (m *SetBalancerBandwidthRequestProto) Reset()

+ func (m *SetBalancerBandwidthRequestProto) String() string

+ type SetBalancerBandwidthResponseProto struct

+ XXX_unrecognized []byte

+ func (*SetBalancerBandwidthResponseProto) ProtoMessage()

+ func (m *SetBalancerBandwidthResponseProto) Reset()

+ func (m *SetBalancerBandwidthResponseProto) String() string

+ type SetOwnerRequestProto struct

+ Groupname *string

+ Src *string

+ Username *string

+ XXX_unrecognized []byte

+ func (*SetOwnerRequestProto) ProtoMessage()

+ func (m *SetOwnerRequestProto) GetGroupname() string

+ func (m *SetOwnerRequestProto) GetSrc() string

+ func (m *SetOwnerRequestProto) GetUsername() string

+ func (m *SetOwnerRequestProto) Reset()

+ func (m *SetOwnerRequestProto) String() string

+ type SetOwnerResponseProto struct

+ XXX_unrecognized []byte

+ func (*SetOwnerResponseProto) ProtoMessage()

+ func (m *SetOwnerResponseProto) Reset()

+ func (m *SetOwnerResponseProto) String() string

+ type SetPermissionRequestProto struct

+ Permission *FsPermissionProto

+ Src *string

+ XXX_unrecognized []byte

+ func (*SetPermissionRequestProto) ProtoMessage()

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

+ func (m *SetPermissionRequestProto) GetSrc() string

+ func (m *SetPermissionRequestProto) Reset()

+ func (m *SetPermissionRequestProto) String() string

+ type SetPermissionResponseProto struct

+ XXX_unrecognized []byte

+ func (*SetPermissionResponseProto) ProtoMessage()

+ func (m *SetPermissionResponseProto) Reset()

+ func (m *SetPermissionResponseProto) String() string

+ type SetQuotaRequestProto struct

+ DiskspaceQuota *uint64

+ NamespaceQuota *uint64

+ Path *string

+ XXX_unrecognized []byte

+ func (*SetQuotaRequestProto) ProtoMessage()

+ func (m *SetQuotaRequestProto) GetDiskspaceQuota() uint64

+ func (m *SetQuotaRequestProto) GetNamespaceQuota() uint64

+ func (m *SetQuotaRequestProto) GetPath() string

+ func (m *SetQuotaRequestProto) Reset()

+ func (m *SetQuotaRequestProto) String() string

+ type SetQuotaResponseProto struct

+ XXX_unrecognized []byte

+ func (*SetQuotaResponseProto) ProtoMessage()

+ func (m *SetQuotaResponseProto) Reset()

+ func (m *SetQuotaResponseProto) String() string

+ type SetReplicationRequestProto struct

+ Replication *uint32

+ Src *string

+ XXX_unrecognized []byte

+ func (*SetReplicationRequestProto) ProtoMessage()

+ func (m *SetReplicationRequestProto) GetReplication() uint32

+ func (m *SetReplicationRequestProto) GetSrc() string

+ func (m *SetReplicationRequestProto) Reset()

+ func (m *SetReplicationRequestProto) String() string

+ type SetReplicationResponseProto struct

+ Result *bool

+ XXX_unrecognized []byte

+ func (*SetReplicationResponseProto) ProtoMessage()

+ func (m *SetReplicationResponseProto) GetResult() bool

+ func (m *SetReplicationResponseProto) Reset()

+ func (m *SetReplicationResponseProto) String() string

+ type SetSafeModeRequestProto struct

+ Action *SafeModeActionProto

+ Checked *bool

+ XXX_unrecognized []byte

+ func (*SetSafeModeRequestProto) ProtoMessage()

+ func (m *SetSafeModeRequestProto) GetAction() SafeModeActionProto

+ func (m *SetSafeModeRequestProto) GetChecked() bool

+ func (m *SetSafeModeRequestProto) Reset()

+ func (m *SetSafeModeRequestProto) String() string

+ type SetSafeModeResponseProto struct

+ Result *bool

+ XXX_unrecognized []byte

+ func (*SetSafeModeResponseProto) ProtoMessage()

+ func (m *SetSafeModeResponseProto) GetResult() bool

+ func (m *SetSafeModeResponseProto) Reset()

+ func (m *SetSafeModeResponseProto) String() string

+ type SetTimesRequestProto struct

+ Atime *uint64

+ Mtime *uint64

+ Src *string

+ XXX_unrecognized []byte

+ func (*SetTimesRequestProto) ProtoMessage()

+ func (m *SetTimesRequestProto) GetAtime() uint64

+ func (m *SetTimesRequestProto) GetMtime() uint64

+ func (m *SetTimesRequestProto) GetSrc() string

+ func (m *SetTimesRequestProto) Reset()

+ func (m *SetTimesRequestProto) String() string

+ type SetTimesResponseProto struct

+ XXX_unrecognized []byte

+ func (*SetTimesResponseProto) ProtoMessage()

+ func (m *SetTimesResponseProto) Reset()

+ func (m *SetTimesResponseProto) String() string

+ type SnapshotDiffReportEntryProto struct

+ Fullpath []byte

+ ModificationLabel *string

+ XXX_unrecognized []byte

+ func (*SnapshotDiffReportEntryProto) ProtoMessage()

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

+ func (m *SnapshotDiffReportEntryProto) GetModificationLabel() string

+ func (m *SnapshotDiffReportEntryProto) Reset()

+ func (m *SnapshotDiffReportEntryProto) String() string

+ type SnapshotDiffReportProto struct

+ DiffReportEntries []*SnapshotDiffReportEntryProto

+ FromSnapshot *string

+ SnapshotRoot *string

+ ToSnapshot *string

+ XXX_unrecognized []byte

+ func (*SnapshotDiffReportProto) ProtoMessage()

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

+ func (m *SnapshotDiffReportProto) GetFromSnapshot() string

+ func (m *SnapshotDiffReportProto) GetSnapshotRoot() string

+ func (m *SnapshotDiffReportProto) GetToSnapshot() string

+ func (m *SnapshotDiffReportProto) Reset()

+ func (m *SnapshotDiffReportProto) String() string

+ type SnapshotInfoProto struct

+ CreateTime *string

+ Group *string

+ Owner *string

+ Permission *FsPermissionProto

+ SnapshotName *string

+ SnapshotRoot *string

+ XXX_unrecognized []byte

+ func (*SnapshotInfoProto) ProtoMessage()

+ func (m *SnapshotInfoProto) GetCreateTime() string

+ func (m *SnapshotInfoProto) GetGroup() string

+ func (m *SnapshotInfoProto) GetOwner() string

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

+ func (m *SnapshotInfoProto) GetSnapshotName() string

+ func (m *SnapshotInfoProto) GetSnapshotRoot() string

+ func (m *SnapshotInfoProto) Reset()

+ func (m *SnapshotInfoProto) String() string

+ type SnapshottableDirectoryListingProto struct

+ SnapshottableDirListing []*SnapshottableDirectoryStatusProto

+ XXX_unrecognized []byte

+ func (*SnapshottableDirectoryListingProto) ProtoMessage()

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

+ func (m *SnapshottableDirectoryListingProto) Reset()

+ func (m *SnapshottableDirectoryListingProto) String() string

+ type SnapshottableDirectoryStatusProto struct

+ DirStatus *HdfsFileStatusProto

+ ParentFullpath []byte

+ SnapshotNumber *uint32

+ SnapshotQuota *uint32

+ XXX_unrecognized []byte

+ func (*SnapshottableDirectoryStatusProto) ProtoMessage()

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

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

+ func (m *SnapshottableDirectoryStatusProto) GetSnapshotNumber() uint32

+ func (m *SnapshottableDirectoryStatusProto) GetSnapshotQuota() uint32

+ func (m *SnapshottableDirectoryStatusProto) Reset()

+ func (m *SnapshottableDirectoryStatusProto) String() string

+ type Status int32

+ const Status_CHECKSUM_OK

+ const Status_ERROR

+ const Status_ERROR_ACCESS_TOKEN

+ const Status_ERROR_CHECKSUM

+ const Status_ERROR_EXISTS

+ const Status_ERROR_INVALID

+ const Status_ERROR_UNSUPPORTED

+ const Status_SUCCESS

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

+ func (x Status) Enum() *Status

+ func (x Status) String() string

+ type StorageInfoProto struct

+ CTime *uint64

+ ClusterID *string

+ LayoutVersion *uint32

+ NamespceID *uint32

+ XXX_unrecognized []byte

+ func (*StorageInfoProto) ProtoMessage()

+ func (m *StorageInfoProto) GetCTime() uint64

+ func (m *StorageInfoProto) GetClusterID() string

+ func (m *StorageInfoProto) GetLayoutVersion() uint32

+ func (m *StorageInfoProto) GetNamespceID() uint32

+ func (m *StorageInfoProto) Reset()

+ func (m *StorageInfoProto) String() string

+ type UpdateBlockForPipelineRequestProto struct

+ Block *ExtendedBlockProto

+ ClientName *string

+ XXX_unrecognized []byte

+ func (*UpdateBlockForPipelineRequestProto) ProtoMessage()

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

+ func (m *UpdateBlockForPipelineRequestProto) GetClientName() string

+ func (m *UpdateBlockForPipelineRequestProto) Reset()

+ func (m *UpdateBlockForPipelineRequestProto) String() string

+ type UpdateBlockForPipelineResponseProto struct

+ Block *LocatedBlockProto

+ XXX_unrecognized []byte

+ func (*UpdateBlockForPipelineResponseProto) ProtoMessage()

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

+ func (m *UpdateBlockForPipelineResponseProto) Reset()

+ func (m *UpdateBlockForPipelineResponseProto) String() string

+ type UpdatePipelineRequestProto struct

+ ClientName *string

+ NewBlock *ExtendedBlockProto

+ NewNodes []*DatanodeIDProto

+ OldBlock *ExtendedBlockProto

+ XXX_unrecognized []byte

+ func (*UpdatePipelineRequestProto) ProtoMessage()

+ func (m *UpdatePipelineRequestProto) GetClientName() string

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

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

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

+ func (m *UpdatePipelineRequestProto) Reset()

+ func (m *UpdatePipelineRequestProto) String() string

+ type UpdatePipelineResponseProto struct

+ XXX_unrecognized []byte

+ func (*UpdatePipelineResponseProto) ProtoMessage()

+ func (m *UpdatePipelineResponseProto) Reset()

+ func (m *UpdatePipelineResponseProto) String() string

+ type VersionRequestProto struct

+ XXX_unrecognized []byte

+ func (*VersionRequestProto) ProtoMessage()

+ func (m *VersionRequestProto) Reset()

+ func (m *VersionRequestProto) String() string

+ type VersionResponseProto struct

+ Info *NamespaceInfoProto

+ XXX_unrecognized []byte

+ func (*VersionResponseProto) ProtoMessage()

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

+ func (m *VersionResponseProto) Reset()

+ func (m *VersionResponseProto) String() string

v0.1.1

Nov 19, 2014

v0.1.0

Nov 3, 2014

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