Documentation ¶
Index ¶
- Constants
- Variables
- type BlockID
- func (*BlockID) Descriptor() ([]byte, []int)deprecated
- func (x *BlockID) GetBlockCommitSequenceId() uint64
- func (x *BlockID) GetContainerBlockID() *ContainerBlockID
- func (*BlockID) ProtoMessage()
- func (x *BlockID) ProtoReflect() protoreflect.Message
- func (x *BlockID) Reset()
- func (x *BlockID) String() string
- type BlockTokenSecretProto
- func (*BlockTokenSecretProto) Descriptor() ([]byte, []int)deprecated
- func (x *BlockTokenSecretProto) GetBlockId() string
- func (x *BlockTokenSecretProto) GetExpiryDate() uint64
- func (x *BlockTokenSecretProto) GetMaxLength() uint64
- func (x *BlockTokenSecretProto) GetModes() []BlockTokenSecretProto_AccessModeProto
- func (x *BlockTokenSecretProto) GetOmCertSerialId() string
- func (x *BlockTokenSecretProto) GetOwnerId() string
- func (*BlockTokenSecretProto) ProtoMessage()
- func (x *BlockTokenSecretProto) ProtoReflect() protoreflect.Message
- func (x *BlockTokenSecretProto) Reset()
- func (x *BlockTokenSecretProto) String() string
- type BlockTokenSecretProto_AccessModeProto
- func (BlockTokenSecretProto_AccessModeProto) Descriptor() protoreflect.EnumDescriptor
- func (x BlockTokenSecretProto_AccessModeProto) Enum() *BlockTokenSecretProto_AccessModeProto
- func (BlockTokenSecretProto_AccessModeProto) EnumDescriptor() ([]byte, []int)deprecated
- func (x BlockTokenSecretProto_AccessModeProto) Number() protoreflect.EnumNumber
- func (x BlockTokenSecretProto_AccessModeProto) String() string
- func (BlockTokenSecretProto_AccessModeProto) Type() protoreflect.EnumType
- func (x *BlockTokenSecretProto_AccessModeProto) UnmarshalJSON(b []byte) errordeprecated
- type ContainerBlockID
- func (*ContainerBlockID) Descriptor() ([]byte, []int)deprecated
- func (x *ContainerBlockID) GetContainerID() int64
- func (x *ContainerBlockID) GetLocalID() int64
- func (*ContainerBlockID) ProtoMessage()
- func (x *ContainerBlockID) ProtoReflect() protoreflect.Message
- func (x *ContainerBlockID) Reset()
- func (x *ContainerBlockID) String() string
- type ContainerInfoProto
- func (*ContainerInfoProto) Descriptor() ([]byte, []int)deprecated
- func (x *ContainerInfoProto) GetContainerID() int64
- func (x *ContainerInfoProto) GetDeleteTransactionId() int64
- func (x *ContainerInfoProto) GetNumberOfKeys() uint64
- func (x *ContainerInfoProto) GetOwner() string
- func (x *ContainerInfoProto) GetPipelineID() *PipelineID
- func (x *ContainerInfoProto) GetReplicationFactor() ReplicationFactor
- func (x *ContainerInfoProto) GetReplicationType() ReplicationType
- func (x *ContainerInfoProto) GetSequenceId() int64
- func (x *ContainerInfoProto) GetState() LifeCycleState
- func (x *ContainerInfoProto) GetStateEnterTime() int64
- func (x *ContainerInfoProto) GetUsedBytes() uint64
- func (*ContainerInfoProto) ProtoMessage()
- func (x *ContainerInfoProto) ProtoReflect() protoreflect.Message
- func (x *ContainerInfoProto) Reset()
- func (x *ContainerInfoProto) String() string
- type ContainerWithPipeline
- func (*ContainerWithPipeline) Descriptor() ([]byte, []int)deprecated
- func (x *ContainerWithPipeline) GetContainerInfo() *ContainerInfoProto
- func (x *ContainerWithPipeline) GetPipeline() *Pipeline
- func (*ContainerWithPipeline) ProtoMessage()
- func (x *ContainerWithPipeline) ProtoReflect() protoreflect.Message
- func (x *ContainerWithPipeline) Reset()
- func (x *ContainerWithPipeline) String() string
- type DatanodeDetailsProto
- func (*DatanodeDetailsProto) Descriptor() ([]byte, []int)deprecated
- func (x *DatanodeDetailsProto) GetBuildDate() string
- func (x *DatanodeDetailsProto) GetCertSerialId() string
- func (x *DatanodeDetailsProto) GetHostName() string
- func (x *DatanodeDetailsProto) GetIpAddress() string
- func (x *DatanodeDetailsProto) GetNetworkLocation() string
- func (x *DatanodeDetailsProto) GetNetworkName() string
- func (x *DatanodeDetailsProto) GetPorts() []*Port
- func (x *DatanodeDetailsProto) GetRevision() string
- func (x *DatanodeDetailsProto) GetSetupTime() int64
- func (x *DatanodeDetailsProto) GetUuid() string
- func (x *DatanodeDetailsProto) GetUuid128() *UUID
- func (x *DatanodeDetailsProto) GetVersion() string
- func (*DatanodeDetailsProto) ProtoMessage()
- func (x *DatanodeDetailsProto) ProtoReflect() protoreflect.Message
- func (x *DatanodeDetailsProto) Reset()
- func (x *DatanodeDetailsProto) String() string
- type ExcludeListProto
- func (*ExcludeListProto) Descriptor() ([]byte, []int)deprecated
- func (x *ExcludeListProto) GetContainerIds() []int64
- func (x *ExcludeListProto) GetDatanodes() []string
- func (x *ExcludeListProto) GetPipelineIds() []*PipelineID
- func (*ExcludeListProto) ProtoMessage()
- func (x *ExcludeListProto) ProtoReflect() protoreflect.Message
- func (x *ExcludeListProto) Reset()
- func (x *ExcludeListProto) String() string
- type GetScmInfoRequestProto
- func (*GetScmInfoRequestProto) Descriptor() ([]byte, []int)deprecated
- func (x *GetScmInfoRequestProto) GetTraceID() string
- func (*GetScmInfoRequestProto) ProtoMessage()
- func (x *GetScmInfoRequestProto) ProtoReflect() protoreflect.Message
- func (x *GetScmInfoRequestProto) Reset()
- func (x *GetScmInfoRequestProto) String() string
- type GetScmInfoResponseProto
- func (*GetScmInfoResponseProto) Descriptor() ([]byte, []int)deprecated
- func (x *GetScmInfoResponseProto) GetClusterId() string
- func (x *GetScmInfoResponseProto) GetScmId() string
- func (*GetScmInfoResponseProto) ProtoMessage()
- func (x *GetScmInfoResponseProto) ProtoReflect() protoreflect.Message
- func (x *GetScmInfoResponseProto) Reset()
- func (x *GetScmInfoResponseProto) String() string
- type KeyValue
- type LifeCycleEvent
- func (LifeCycleEvent) Descriptor() protoreflect.EnumDescriptor
- func (x LifeCycleEvent) Enum() *LifeCycleEvent
- func (LifeCycleEvent) EnumDescriptor() ([]byte, []int)deprecated
- func (x LifeCycleEvent) Number() protoreflect.EnumNumber
- func (x LifeCycleEvent) String() string
- func (LifeCycleEvent) Type() protoreflect.EnumType
- func (x *LifeCycleEvent) UnmarshalJSON(b []byte) errordeprecated
- type LifeCycleState
- func (LifeCycleState) Descriptor() protoreflect.EnumDescriptor
- func (x LifeCycleState) Enum() *LifeCycleState
- func (LifeCycleState) EnumDescriptor() ([]byte, []int)deprecated
- func (x LifeCycleState) Number() protoreflect.EnumNumber
- func (x LifeCycleState) String() string
- func (LifeCycleState) Type() protoreflect.EnumType
- func (x *LifeCycleState) UnmarshalJSON(b []byte) errordeprecated
- type Node
- type NodePool
- type NodeState
- func (NodeState) Descriptor() protoreflect.EnumDescriptor
- func (x NodeState) Enum() *NodeState
- func (NodeState) EnumDescriptor() ([]byte, []int)deprecated
- func (x NodeState) Number() protoreflect.EnumNumber
- func (x NodeState) String() string
- func (NodeState) Type() protoreflect.EnumType
- func (x *NodeState) UnmarshalJSON(b []byte) errordeprecated
- type NodeType
- func (NodeType) Descriptor() protoreflect.EnumDescriptor
- func (x NodeType) Enum() *NodeType
- func (NodeType) EnumDescriptor() ([]byte, []int)deprecated
- func (x NodeType) Number() protoreflect.EnumNumber
- func (x NodeType) String() string
- func (NodeType) Type() protoreflect.EnumType
- func (x *NodeType) UnmarshalJSON(b []byte) errordeprecated
- type OzoneManagerDetailsProto
- func (*OzoneManagerDetailsProto) Descriptor() ([]byte, []int)deprecated
- func (x *OzoneManagerDetailsProto) GetHostName() string
- func (x *OzoneManagerDetailsProto) GetIpAddress() string
- func (x *OzoneManagerDetailsProto) GetPorts() []*Port
- func (x *OzoneManagerDetailsProto) GetUuid() string
- func (*OzoneManagerDetailsProto) ProtoMessage()
- func (x *OzoneManagerDetailsProto) ProtoReflect() protoreflect.Message
- func (x *OzoneManagerDetailsProto) Reset()
- func (x *OzoneManagerDetailsProto) String() string
- type Pipeline
- func (*Pipeline) Descriptor() ([]byte, []int)deprecated
- func (x *Pipeline) GetCreationTimeStamp() uint64
- func (x *Pipeline) GetFactor() ReplicationFactor
- func (x *Pipeline) GetId() *PipelineID
- func (x *Pipeline) GetLeaderID() string
- func (x *Pipeline) GetLeaderID128() *UUID
- func (x *Pipeline) GetMemberOrders() []uint32
- func (x *Pipeline) GetMembers() []*DatanodeDetailsProto
- func (x *Pipeline) GetState() PipelineState
- func (x *Pipeline) GetType() ReplicationType
- func (*Pipeline) ProtoMessage()
- func (x *Pipeline) ProtoReflect() protoreflect.Message
- func (x *Pipeline) Reset()
- func (x *Pipeline) String() string
- type PipelineID
- type PipelineState
- func (PipelineState) Descriptor() protoreflect.EnumDescriptor
- func (x PipelineState) Enum() *PipelineState
- func (PipelineState) EnumDescriptor() ([]byte, []int)deprecated
- func (x PipelineState) Number() protoreflect.EnumNumber
- func (x PipelineState) String() string
- func (PipelineState) Type() protoreflect.EnumType
- func (x *PipelineState) UnmarshalJSON(b []byte) errordeprecated
- type Port
- type QueryScope
- func (QueryScope) Descriptor() protoreflect.EnumDescriptor
- func (x QueryScope) Enum() *QueryScope
- func (QueryScope) EnumDescriptor() ([]byte, []int)deprecated
- func (x QueryScope) Number() protoreflect.EnumNumber
- func (x QueryScope) String() string
- func (QueryScope) Type() protoreflect.EnumType
- func (x *QueryScope) UnmarshalJSON(b []byte) errordeprecated
- type ReplicationFactor
- func (ReplicationFactor) Descriptor() protoreflect.EnumDescriptor
- func (x ReplicationFactor) Enum() *ReplicationFactor
- func (ReplicationFactor) EnumDescriptor() ([]byte, []int)deprecated
- func (x ReplicationFactor) Number() protoreflect.EnumNumber
- func (x ReplicationFactor) String() string
- func (ReplicationFactor) Type() protoreflect.EnumType
- func (x *ReplicationFactor) UnmarshalJSON(b []byte) errordeprecated
- type ReplicationType
- func (ReplicationType) Descriptor() protoreflect.EnumDescriptor
- func (x ReplicationType) Enum() *ReplicationType
- func (ReplicationType) EnumDescriptor() ([]byte, []int)deprecated
- func (x ReplicationType) Number() protoreflect.EnumNumber
- func (x ReplicationType) String() string
- func (ReplicationType) Type() protoreflect.EnumType
- func (x *ReplicationType) UnmarshalJSON(b []byte) errordeprecated
- type ScmOps
- func (ScmOps) Descriptor() protoreflect.EnumDescriptor
- func (x ScmOps) Enum() *ScmOps
- func (ScmOps) EnumDescriptor() ([]byte, []int)deprecated
- func (x ScmOps) Number() protoreflect.EnumNumber
- func (x ScmOps) String() string
- func (ScmOps) Type() protoreflect.EnumType
- func (x *ScmOps) UnmarshalJSON(b []byte) errordeprecated
- type UUID
Constants ¶
const ( Default_Pipeline_State = PipelineState_PIPELINE_ALLOCATED Default_Pipeline_Type = ReplicationType_STAND_ALONE Default_Pipeline_Factor = ReplicationFactor_ONE )
Default values for Pipeline fields.
const (
Default_BlockID_BlockCommitSequenceId = uint64(0)
)
Default values for BlockID fields.
Variables ¶
var ( PipelineState_name = map[int32]string{ 1: "PIPELINE_ALLOCATED", 2: "PIPELINE_OPEN", 3: "PIPELINE_DORMANT", 4: "PIPELINE_CLOSED", } PipelineState_value = map[string]int32{ "PIPELINE_ALLOCATED": 1, "PIPELINE_OPEN": 2, "PIPELINE_DORMANT": 3, "PIPELINE_CLOSED": 4, } )
Enum value maps for PipelineState.
var ( NodeType_name = map[int32]string{ 1: "OM", 2: "SCM", 3: "DATANODE", 4: "RECON", } NodeType_value = map[string]int32{ "OM": 1, "SCM": 2, "DATANODE": 3, "RECON": 4, } )
Enum value maps for NodeType.
var ( NodeState_name = map[int32]string{ 1: "HEALTHY", 2: "STALE", 3: "DEAD", 4: "DECOMMISSIONING", 5: "DECOMMISSIONED", } NodeState_value = map[string]int32{ "HEALTHY": 1, "STALE": 2, "DEAD": 3, "DECOMMISSIONING": 4, "DECOMMISSIONED": 5, } )
Enum value maps for NodeState.
var ( QueryScope_name = map[int32]string{ 1: "CLUSTER", 2: "POOL", } QueryScope_value = map[string]int32{ "CLUSTER": 1, "POOL": 2, } )
Enum value maps for QueryScope.
var ( LifeCycleState_name = map[int32]string{ 1: "OPEN", 2: "CLOSING", 3: "QUASI_CLOSED", 4: "CLOSED", 5: "DELETING", 6: "DELETED", } LifeCycleState_value = map[string]int32{ "OPEN": 1, "CLOSING": 2, "QUASI_CLOSED": 3, "CLOSED": 4, "DELETING": 5, "DELETED": 6, } )
Enum value maps for LifeCycleState.
var ( LifeCycleEvent_name = map[int32]string{ 1: "FINALIZE", 2: "QUASI_CLOSE", 3: "CLOSE", 4: "FORCE_CLOSE", 5: "DELETE", 6: "CLEANUP", } LifeCycleEvent_value = map[string]int32{ "FINALIZE": 1, "QUASI_CLOSE": 2, "CLOSE": 3, "FORCE_CLOSE": 4, "DELETE": 5, "CLEANUP": 6, } )
Enum value maps for LifeCycleEvent.
var ( ReplicationType_name = map[int32]string{ 1: "RATIS", 2: "STAND_ALONE", 3: "CHAINED", } ReplicationType_value = map[string]int32{ "RATIS": 1, "STAND_ALONE": 2, "CHAINED": 3, } )
Enum value maps for ReplicationType.
var ( ReplicationFactor_name = map[int32]string{ 1: "ONE", 3: "THREE", } ReplicationFactor_value = map[string]int32{ "ONE": 1, "THREE": 3, } )
Enum value maps for ReplicationFactor.
var ( ScmOps_name = map[int32]string{ 1: "allocateBlock", 2: "keyBlocksInfoList", 3: "getScmInfo", 4: "deleteBlock", 5: "createReplicationPipeline", 6: "allocateContainer", 7: "getContainer", 8: "getContainerWithPipeline", 9: "listContainer", 10: "deleteContainer", 11: "queryNode", } ScmOps_value = map[string]int32{ "allocateBlock": 1, "keyBlocksInfoList": 2, "getScmInfo": 3, "deleteBlock": 4, "createReplicationPipeline": 5, "allocateContainer": 6, "getContainer": 7, "getContainerWithPipeline": 8, "listContainer": 9, "deleteContainer": 10, "queryNode": 11, } )
Enum value maps for ScmOps.
var ( BlockTokenSecretProto_AccessModeProto_name = map[int32]string{ 1: "READ", 2: "WRITE", 3: "COPY", 4: "DELETE", } BlockTokenSecretProto_AccessModeProto_value = map[string]int32{ "READ": 1, "WRITE": 2, "COPY": 3, "DELETE": 4, } )
Enum value maps for BlockTokenSecretProto_AccessModeProto.
var File_hdds_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type BlockID ¶
type BlockID struct { ContainerBlockID *ContainerBlockID `protobuf:"bytes,1,req,name=containerBlockID" json:"containerBlockID,omitempty"` BlockCommitSequenceId *uint64 `protobuf:"varint,2,opt,name=blockCommitSequenceId,def=0" json:"blockCommitSequenceId,omitempty"` // contains filtered or unexported fields }
func (*BlockID) Descriptor
deprecated
func (*BlockID) GetBlockCommitSequenceId ¶
func (*BlockID) GetContainerBlockID ¶
func (x *BlockID) GetContainerBlockID() *ContainerBlockID
func (*BlockID) ProtoMessage ¶
func (*BlockID) ProtoMessage()
func (*BlockID) ProtoReflect ¶
func (x *BlockID) ProtoReflect() protoreflect.Message
type BlockTokenSecretProto ¶
type BlockTokenSecretProto struct { OwnerId *string `protobuf:"bytes,1,req,name=ownerId" json:"ownerId,omitempty"` BlockId *string `protobuf:"bytes,2,req,name=blockId" json:"blockId,omitempty"` ExpiryDate *uint64 `protobuf:"varint,3,req,name=expiryDate" json:"expiryDate,omitempty"` OmCertSerialId *string `protobuf:"bytes,4,req,name=omCertSerialId" json:"omCertSerialId,omitempty"` Modes []BlockTokenSecretProto_AccessModeProto `protobuf:"varint,5,rep,name=modes,enum=hadoop.hdds.BlockTokenSecretProto_AccessModeProto" json:"modes,omitempty"` MaxLength *uint64 `protobuf:"varint,6,req,name=maxLength" json:"maxLength,omitempty"` // contains filtered or unexported fields }
* Information for the Hdds block token. When adding further fields, make sure they are optional as they would otherwise not be backwards compatible.
func (*BlockTokenSecretProto) Descriptor
deprecated
func (*BlockTokenSecretProto) Descriptor() ([]byte, []int)
Deprecated: Use BlockTokenSecretProto.ProtoReflect.Descriptor instead.
func (*BlockTokenSecretProto) GetBlockId ¶
func (x *BlockTokenSecretProto) GetBlockId() string
func (*BlockTokenSecretProto) GetExpiryDate ¶
func (x *BlockTokenSecretProto) GetExpiryDate() uint64
func (*BlockTokenSecretProto) GetMaxLength ¶
func (x *BlockTokenSecretProto) GetMaxLength() uint64
func (*BlockTokenSecretProto) GetModes ¶
func (x *BlockTokenSecretProto) GetModes() []BlockTokenSecretProto_AccessModeProto
func (*BlockTokenSecretProto) GetOmCertSerialId ¶
func (x *BlockTokenSecretProto) GetOmCertSerialId() string
func (*BlockTokenSecretProto) GetOwnerId ¶
func (x *BlockTokenSecretProto) GetOwnerId() string
func (*BlockTokenSecretProto) ProtoMessage ¶
func (*BlockTokenSecretProto) ProtoMessage()
func (*BlockTokenSecretProto) ProtoReflect ¶
func (x *BlockTokenSecretProto) ProtoReflect() protoreflect.Message
func (*BlockTokenSecretProto) Reset ¶
func (x *BlockTokenSecretProto) Reset()
func (*BlockTokenSecretProto) String ¶
func (x *BlockTokenSecretProto) String() string
type BlockTokenSecretProto_AccessModeProto ¶
type BlockTokenSecretProto_AccessModeProto int32
* File access permissions mode.
const ( BlockTokenSecretProto_READ BlockTokenSecretProto_AccessModeProto = 1 BlockTokenSecretProto_WRITE BlockTokenSecretProto_AccessModeProto = 2 BlockTokenSecretProto_COPY BlockTokenSecretProto_AccessModeProto = 3 BlockTokenSecretProto_DELETE BlockTokenSecretProto_AccessModeProto = 4 )
func (BlockTokenSecretProto_AccessModeProto) Descriptor ¶
func (BlockTokenSecretProto_AccessModeProto) Descriptor() protoreflect.EnumDescriptor
func (BlockTokenSecretProto_AccessModeProto) EnumDescriptor
deprecated
func (BlockTokenSecretProto_AccessModeProto) EnumDescriptor() ([]byte, []int)
Deprecated: Use BlockTokenSecretProto_AccessModeProto.Descriptor instead.
func (BlockTokenSecretProto_AccessModeProto) Number ¶
func (x BlockTokenSecretProto_AccessModeProto) Number() protoreflect.EnumNumber
func (BlockTokenSecretProto_AccessModeProto) String ¶
func (x BlockTokenSecretProto_AccessModeProto) String() string
func (BlockTokenSecretProto_AccessModeProto) Type ¶
func (BlockTokenSecretProto_AccessModeProto) Type() protoreflect.EnumType
func (*BlockTokenSecretProto_AccessModeProto) UnmarshalJSON
deprecated
func (x *BlockTokenSecretProto_AccessModeProto) UnmarshalJSON(b []byte) error
Deprecated: Do not use.
type ContainerBlockID ¶
type ContainerBlockID struct { ContainerID *int64 `protobuf:"varint,1,req,name=containerID" json:"containerID,omitempty"` LocalID *int64 `protobuf:"varint,2,req,name=localID" json:"localID,omitempty"` // contains filtered or unexported fields }
* Block ID that uniquely identify a block by SCM.
func (*ContainerBlockID) Descriptor
deprecated
func (*ContainerBlockID) Descriptor() ([]byte, []int)
Deprecated: Use ContainerBlockID.ProtoReflect.Descriptor instead.
func (*ContainerBlockID) GetContainerID ¶
func (x *ContainerBlockID) GetContainerID() int64
func (*ContainerBlockID) GetLocalID ¶
func (x *ContainerBlockID) GetLocalID() int64
func (*ContainerBlockID) ProtoMessage ¶
func (*ContainerBlockID) ProtoMessage()
func (*ContainerBlockID) ProtoReflect ¶
func (x *ContainerBlockID) ProtoReflect() protoreflect.Message
func (*ContainerBlockID) Reset ¶
func (x *ContainerBlockID) Reset()
func (*ContainerBlockID) String ¶
func (x *ContainerBlockID) String() string
type ContainerInfoProto ¶
type ContainerInfoProto struct { ContainerID *int64 `protobuf:"varint,1,req,name=containerID" json:"containerID,omitempty"` State *LifeCycleState `protobuf:"varint,2,req,name=state,enum=hadoop.hdds.LifeCycleState" json:"state,omitempty"` PipelineID *PipelineID `protobuf:"bytes,3,opt,name=pipelineID" json:"pipelineID,omitempty"` UsedBytes *uint64 `protobuf:"varint,4,req,name=usedBytes" json:"usedBytes,omitempty"` NumberOfKeys *uint64 `protobuf:"varint,5,req,name=numberOfKeys" json:"numberOfKeys,omitempty"` StateEnterTime *int64 `protobuf:"varint,6,opt,name=stateEnterTime" json:"stateEnterTime,omitempty"` Owner *string `protobuf:"bytes,7,req,name=owner" json:"owner,omitempty"` DeleteTransactionId *int64 `protobuf:"varint,8,opt,name=deleteTransactionId" json:"deleteTransactionId,omitempty"` SequenceId *int64 `protobuf:"varint,9,opt,name=sequenceId" json:"sequenceId,omitempty"` ReplicationFactor *ReplicationFactor `protobuf:"varint,10,req,name=replicationFactor,enum=hadoop.hdds.ReplicationFactor" json:"replicationFactor,omitempty"` ReplicationType *ReplicationType `protobuf:"varint,11,req,name=replicationType,enum=hadoop.hdds.ReplicationType" json:"replicationType,omitempty"` // contains filtered or unexported fields }
func (*ContainerInfoProto) Descriptor
deprecated
func (*ContainerInfoProto) Descriptor() ([]byte, []int)
Deprecated: Use ContainerInfoProto.ProtoReflect.Descriptor instead.
func (*ContainerInfoProto) GetContainerID ¶
func (x *ContainerInfoProto) GetContainerID() int64
func (*ContainerInfoProto) GetDeleteTransactionId ¶
func (x *ContainerInfoProto) GetDeleteTransactionId() int64
func (*ContainerInfoProto) GetNumberOfKeys ¶
func (x *ContainerInfoProto) GetNumberOfKeys() uint64
func (*ContainerInfoProto) GetOwner ¶
func (x *ContainerInfoProto) GetOwner() string
func (*ContainerInfoProto) GetPipelineID ¶
func (x *ContainerInfoProto) GetPipelineID() *PipelineID
func (*ContainerInfoProto) GetReplicationFactor ¶
func (x *ContainerInfoProto) GetReplicationFactor() ReplicationFactor
func (*ContainerInfoProto) GetReplicationType ¶
func (x *ContainerInfoProto) GetReplicationType() ReplicationType
func (*ContainerInfoProto) GetSequenceId ¶
func (x *ContainerInfoProto) GetSequenceId() int64
func (*ContainerInfoProto) GetState ¶
func (x *ContainerInfoProto) GetState() LifeCycleState
func (*ContainerInfoProto) GetStateEnterTime ¶
func (x *ContainerInfoProto) GetStateEnterTime() int64
func (*ContainerInfoProto) GetUsedBytes ¶
func (x *ContainerInfoProto) GetUsedBytes() uint64
func (*ContainerInfoProto) ProtoMessage ¶
func (*ContainerInfoProto) ProtoMessage()
func (*ContainerInfoProto) ProtoReflect ¶
func (x *ContainerInfoProto) ProtoReflect() protoreflect.Message
func (*ContainerInfoProto) Reset ¶
func (x *ContainerInfoProto) Reset()
func (*ContainerInfoProto) String ¶
func (x *ContainerInfoProto) String() string
type ContainerWithPipeline ¶
type ContainerWithPipeline struct { ContainerInfo *ContainerInfoProto `protobuf:"bytes,1,req,name=containerInfo" json:"containerInfo,omitempty"` Pipeline *Pipeline `protobuf:"bytes,2,req,name=pipeline" json:"pipeline,omitempty"` // contains filtered or unexported fields }
func (*ContainerWithPipeline) Descriptor
deprecated
func (*ContainerWithPipeline) Descriptor() ([]byte, []int)
Deprecated: Use ContainerWithPipeline.ProtoReflect.Descriptor instead.
func (*ContainerWithPipeline) GetContainerInfo ¶
func (x *ContainerWithPipeline) GetContainerInfo() *ContainerInfoProto
func (*ContainerWithPipeline) GetPipeline ¶
func (x *ContainerWithPipeline) GetPipeline() *Pipeline
func (*ContainerWithPipeline) ProtoMessage ¶
func (*ContainerWithPipeline) ProtoMessage()
func (*ContainerWithPipeline) ProtoReflect ¶
func (x *ContainerWithPipeline) ProtoReflect() protoreflect.Message
func (*ContainerWithPipeline) Reset ¶
func (x *ContainerWithPipeline) Reset()
func (*ContainerWithPipeline) String ¶
func (x *ContainerWithPipeline) String() string
type DatanodeDetailsProto ¶
type DatanodeDetailsProto struct { // deprecated, please use uuid128 instead Uuid *string `protobuf:"bytes,1,opt,name=uuid" json:"uuid,omitempty"` // UUID assigned to the Datanode. IpAddress *string `protobuf:"bytes,2,req,name=ipAddress" json:"ipAddress,omitempty"` // IP address HostName *string `protobuf:"bytes,3,req,name=hostName" json:"hostName,omitempty"` // hostname Ports []*Port `protobuf:"bytes,4,rep,name=ports" json:"ports,omitempty"` CertSerialId *string `protobuf:"bytes,5,opt,name=certSerialId" json:"certSerialId,omitempty"` // Certificate serial id. // network name, can be Ip address or host name, depends NetworkName *string `protobuf:"bytes,6,opt,name=networkName" json:"networkName,omitempty"` NetworkLocation *string `protobuf:"bytes,7,opt,name=networkLocation" json:"networkLocation,omitempty"` // Network topology location Version *string `protobuf:"bytes,8,opt,name=version" json:"version,omitempty"` // Datanode version SetupTime *int64 `protobuf:"varint,9,opt,name=setupTime" json:"setupTime,omitempty"` Revision *string `protobuf:"bytes,10,opt,name=revision" json:"revision,omitempty"` BuildDate *string `protobuf:"bytes,11,opt,name=buildDate" json:"buildDate,omitempty"` // TODO(runzhiwang): when uuid is gone, specify 1 as the index of uuid128 and mark as required Uuid128 *UUID `protobuf:"bytes,100,opt,name=uuid128" json:"uuid128,omitempty"` // UUID with 128 bits assigned to the Datanode. // contains filtered or unexported fields }
func (*DatanodeDetailsProto) Descriptor
deprecated
func (*DatanodeDetailsProto) Descriptor() ([]byte, []int)
Deprecated: Use DatanodeDetailsProto.ProtoReflect.Descriptor instead.
func (*DatanodeDetailsProto) GetBuildDate ¶
func (x *DatanodeDetailsProto) GetBuildDate() string
func (*DatanodeDetailsProto) GetCertSerialId ¶
func (x *DatanodeDetailsProto) GetCertSerialId() string
func (*DatanodeDetailsProto) GetHostName ¶
func (x *DatanodeDetailsProto) GetHostName() string
func (*DatanodeDetailsProto) GetIpAddress ¶
func (x *DatanodeDetailsProto) GetIpAddress() string
func (*DatanodeDetailsProto) GetNetworkLocation ¶
func (x *DatanodeDetailsProto) GetNetworkLocation() string
func (*DatanodeDetailsProto) GetNetworkName ¶
func (x *DatanodeDetailsProto) GetNetworkName() string
func (*DatanodeDetailsProto) GetPorts ¶
func (x *DatanodeDetailsProto) GetPorts() []*Port
func (*DatanodeDetailsProto) GetRevision ¶
func (x *DatanodeDetailsProto) GetRevision() string
func (*DatanodeDetailsProto) GetSetupTime ¶
func (x *DatanodeDetailsProto) GetSetupTime() int64
func (*DatanodeDetailsProto) GetUuid ¶
func (x *DatanodeDetailsProto) GetUuid() string
func (*DatanodeDetailsProto) GetUuid128 ¶
func (x *DatanodeDetailsProto) GetUuid128() *UUID
func (*DatanodeDetailsProto) GetVersion ¶
func (x *DatanodeDetailsProto) GetVersion() string
func (*DatanodeDetailsProto) ProtoMessage ¶
func (*DatanodeDetailsProto) ProtoMessage()
func (*DatanodeDetailsProto) ProtoReflect ¶
func (x *DatanodeDetailsProto) ProtoReflect() protoreflect.Message
func (*DatanodeDetailsProto) Reset ¶
func (x *DatanodeDetailsProto) Reset()
func (*DatanodeDetailsProto) String ¶
func (x *DatanodeDetailsProto) String() string
type ExcludeListProto ¶
type ExcludeListProto struct { Datanodes []string `protobuf:"bytes,1,rep,name=datanodes" json:"datanodes,omitempty"` ContainerIds []int64 `protobuf:"varint,2,rep,name=containerIds" json:"containerIds,omitempty"` PipelineIds []*PipelineID `protobuf:"bytes,3,rep,name=pipelineIds" json:"pipelineIds,omitempty"` // contains filtered or unexported fields }
func (*ExcludeListProto) Descriptor
deprecated
func (*ExcludeListProto) Descriptor() ([]byte, []int)
Deprecated: Use ExcludeListProto.ProtoReflect.Descriptor instead.
func (*ExcludeListProto) GetContainerIds ¶
func (x *ExcludeListProto) GetContainerIds() []int64
func (*ExcludeListProto) GetDatanodes ¶
func (x *ExcludeListProto) GetDatanodes() []string
func (*ExcludeListProto) GetPipelineIds ¶
func (x *ExcludeListProto) GetPipelineIds() []*PipelineID
func (*ExcludeListProto) ProtoMessage ¶
func (*ExcludeListProto) ProtoMessage()
func (*ExcludeListProto) ProtoReflect ¶
func (x *ExcludeListProto) ProtoReflect() protoreflect.Message
func (*ExcludeListProto) Reset ¶
func (x *ExcludeListProto) Reset()
func (*ExcludeListProto) String ¶
func (x *ExcludeListProto) String() string
type GetScmInfoRequestProto ¶
type GetScmInfoRequestProto struct { TraceID *string `protobuf:"bytes,1,opt,name=traceID" json:"traceID,omitempty"` // contains filtered or unexported fields }
func (*GetScmInfoRequestProto) Descriptor
deprecated
func (*GetScmInfoRequestProto) Descriptor() ([]byte, []int)
Deprecated: Use GetScmInfoRequestProto.ProtoReflect.Descriptor instead.
func (*GetScmInfoRequestProto) GetTraceID ¶
func (x *GetScmInfoRequestProto) GetTraceID() string
func (*GetScmInfoRequestProto) ProtoMessage ¶
func (*GetScmInfoRequestProto) ProtoMessage()
func (*GetScmInfoRequestProto) ProtoReflect ¶
func (x *GetScmInfoRequestProto) ProtoReflect() protoreflect.Message
func (*GetScmInfoRequestProto) Reset ¶
func (x *GetScmInfoRequestProto) Reset()
func (*GetScmInfoRequestProto) String ¶
func (x *GetScmInfoRequestProto) String() string
type GetScmInfoResponseProto ¶
type GetScmInfoResponseProto struct { ClusterId *string `protobuf:"bytes,1,req,name=clusterId" json:"clusterId,omitempty"` ScmId *string `protobuf:"bytes,2,req,name=scmId" json:"scmId,omitempty"` // contains filtered or unexported fields }
func (*GetScmInfoResponseProto) Descriptor
deprecated
func (*GetScmInfoResponseProto) Descriptor() ([]byte, []int)
Deprecated: Use GetScmInfoResponseProto.ProtoReflect.Descriptor instead.
func (*GetScmInfoResponseProto) GetClusterId ¶
func (x *GetScmInfoResponseProto) GetClusterId() string
func (*GetScmInfoResponseProto) GetScmId ¶
func (x *GetScmInfoResponseProto) GetScmId() string
func (*GetScmInfoResponseProto) ProtoMessage ¶
func (*GetScmInfoResponseProto) ProtoMessage()
func (*GetScmInfoResponseProto) ProtoReflect ¶
func (x *GetScmInfoResponseProto) ProtoReflect() protoreflect.Message
func (*GetScmInfoResponseProto) Reset ¶
func (x *GetScmInfoResponseProto) Reset()
func (*GetScmInfoResponseProto) String ¶
func (x *GetScmInfoResponseProto) String() string
type KeyValue ¶
type KeyValue struct { Key *string `protobuf:"bytes,1,req,name=key" json:"key,omitempty"` Value *string `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"` // contains filtered or unexported fields }
func (*KeyValue) Descriptor
deprecated
func (*KeyValue) ProtoMessage ¶
func (*KeyValue) ProtoMessage()
func (*KeyValue) ProtoReflect ¶
func (x *KeyValue) ProtoReflect() protoreflect.Message
type LifeCycleEvent ¶
type LifeCycleEvent int32
const ( LifeCycleEvent_FINALIZE LifeCycleEvent = 1 LifeCycleEvent_QUASI_CLOSE LifeCycleEvent = 2 LifeCycleEvent_CLOSE LifeCycleEvent = 3 // !!Event after this has not been used yet. LifeCycleEvent_FORCE_CLOSE LifeCycleEvent = 4 LifeCycleEvent_DELETE LifeCycleEvent = 5 LifeCycleEvent_CLEANUP LifeCycleEvent = 6 )
func (LifeCycleEvent) Descriptor ¶
func (LifeCycleEvent) Descriptor() protoreflect.EnumDescriptor
func (LifeCycleEvent) Enum ¶
func (x LifeCycleEvent) Enum() *LifeCycleEvent
func (LifeCycleEvent) EnumDescriptor
deprecated
func (LifeCycleEvent) EnumDescriptor() ([]byte, []int)
Deprecated: Use LifeCycleEvent.Descriptor instead.
func (LifeCycleEvent) Number ¶
func (x LifeCycleEvent) Number() protoreflect.EnumNumber
func (LifeCycleEvent) String ¶
func (x LifeCycleEvent) String() string
func (LifeCycleEvent) Type ¶
func (LifeCycleEvent) Type() protoreflect.EnumType
func (*LifeCycleEvent) UnmarshalJSON
deprecated
func (x *LifeCycleEvent) UnmarshalJSON(b []byte) error
Deprecated: Do not use.
type LifeCycleState ¶
type LifeCycleState int32
const ( LifeCycleState_OPEN LifeCycleState = 1 LifeCycleState_CLOSING LifeCycleState = 2 LifeCycleState_QUASI_CLOSED LifeCycleState = 3 LifeCycleState_CLOSED LifeCycleState = 4 LifeCycleState_DELETING LifeCycleState = 5 LifeCycleState_DELETED LifeCycleState = 6 // object is deleted. )
func (LifeCycleState) Descriptor ¶
func (LifeCycleState) Descriptor() protoreflect.EnumDescriptor
func (LifeCycleState) Enum ¶
func (x LifeCycleState) Enum() *LifeCycleState
func (LifeCycleState) EnumDescriptor
deprecated
func (LifeCycleState) EnumDescriptor() ([]byte, []int)
Deprecated: Use LifeCycleState.Descriptor instead.
func (LifeCycleState) Number ¶
func (x LifeCycleState) Number() protoreflect.EnumNumber
func (LifeCycleState) String ¶
func (x LifeCycleState) String() string
func (LifeCycleState) Type ¶
func (LifeCycleState) Type() protoreflect.EnumType
func (*LifeCycleState) UnmarshalJSON
deprecated
func (x *LifeCycleState) UnmarshalJSON(b []byte) error
Deprecated: Do not use.
type Node ¶
type Node struct { NodeID *DatanodeDetailsProto `protobuf:"bytes,1,req,name=nodeID" json:"nodeID,omitempty"` NodeStates []NodeState `protobuf:"varint,2,rep,name=nodeStates,enum=hadoop.hdds.NodeState" json:"nodeStates,omitempty"` // contains filtered or unexported fields }
func (*Node) Descriptor
deprecated
func (*Node) GetNodeID ¶
func (x *Node) GetNodeID() *DatanodeDetailsProto
func (*Node) GetNodeStates ¶
func (*Node) ProtoMessage ¶
func (*Node) ProtoMessage()
func (*Node) ProtoReflect ¶
func (x *Node) ProtoReflect() protoreflect.Message
type NodePool ¶
type NodePool struct { Nodes []*Node `protobuf:"bytes,1,rep,name=nodes" json:"nodes,omitempty"` // contains filtered or unexported fields }
func (*NodePool) Descriptor
deprecated
func (*NodePool) ProtoMessage ¶
func (*NodePool) ProtoMessage()
func (*NodePool) ProtoReflect ¶
func (x *NodePool) ProtoReflect() protoreflect.Message
type NodeState ¶
type NodeState int32
* Enum that represents the Node State. This is used in calls to getNodeList and getNodeCount.
func (NodeState) Descriptor ¶
func (NodeState) Descriptor() protoreflect.EnumDescriptor
func (NodeState) EnumDescriptor
deprecated
func (NodeState) Number ¶
func (x NodeState) Number() protoreflect.EnumNumber
func (NodeState) Type ¶
func (NodeState) Type() protoreflect.EnumType
func (*NodeState) UnmarshalJSON
deprecated
type NodeType ¶
type NodeType int32
* Type of the node.
func (NodeType) Descriptor ¶
func (NodeType) Descriptor() protoreflect.EnumDescriptor
func (NodeType) EnumDescriptor
deprecated
func (NodeType) Number ¶
func (x NodeType) Number() protoreflect.EnumNumber
func (NodeType) Type ¶
func (NodeType) Type() protoreflect.EnumType
func (*NodeType) UnmarshalJSON
deprecated
type OzoneManagerDetailsProto ¶
type OzoneManagerDetailsProto struct { Uuid *string `protobuf:"bytes,1,req,name=uuid" json:"uuid,omitempty"` // UUID assigned to the OzoneManager. IpAddress *string `protobuf:"bytes,2,req,name=ipAddress" json:"ipAddress,omitempty"` // IP address of OM. HostName *string `protobuf:"bytes,3,req,name=hostName" json:"hostName,omitempty"` // Hostname of OM. Ports []*Port `protobuf:"bytes,4,rep,name=ports" json:"ports,omitempty"` // contains filtered or unexported fields }
* Proto message encapsulating information required to uniquely identify a OzoneManager.
func (*OzoneManagerDetailsProto) Descriptor
deprecated
func (*OzoneManagerDetailsProto) Descriptor() ([]byte, []int)
Deprecated: Use OzoneManagerDetailsProto.ProtoReflect.Descriptor instead.
func (*OzoneManagerDetailsProto) GetHostName ¶
func (x *OzoneManagerDetailsProto) GetHostName() string
func (*OzoneManagerDetailsProto) GetIpAddress ¶
func (x *OzoneManagerDetailsProto) GetIpAddress() string
func (*OzoneManagerDetailsProto) GetPorts ¶
func (x *OzoneManagerDetailsProto) GetPorts() []*Port
func (*OzoneManagerDetailsProto) GetUuid ¶
func (x *OzoneManagerDetailsProto) GetUuid() string
func (*OzoneManagerDetailsProto) ProtoMessage ¶
func (*OzoneManagerDetailsProto) ProtoMessage()
func (*OzoneManagerDetailsProto) ProtoReflect ¶
func (x *OzoneManagerDetailsProto) ProtoReflect() protoreflect.Message
func (*OzoneManagerDetailsProto) Reset ¶
func (x *OzoneManagerDetailsProto) Reset()
func (*OzoneManagerDetailsProto) String ¶
func (x *OzoneManagerDetailsProto) String() string
type Pipeline ¶
type Pipeline struct { Members []*DatanodeDetailsProto `protobuf:"bytes,1,rep,name=members" json:"members,omitempty"` // TODO: remove the state and leaderID from this class State *PipelineState `protobuf:"varint,2,opt,name=state,enum=hadoop.hdds.PipelineState,def=1" json:"state,omitempty"` Type *ReplicationType `protobuf:"varint,3,opt,name=type,enum=hadoop.hdds.ReplicationType,def=2" json:"type,omitempty"` Factor *ReplicationFactor `protobuf:"varint,4,opt,name=factor,enum=hadoop.hdds.ReplicationFactor,def=1" json:"factor,omitempty"` Id *PipelineID `protobuf:"bytes,5,req,name=id" json:"id,omitempty"` LeaderID *string `protobuf:"bytes,6,opt,name=leaderID" json:"leaderID,omitempty"` MemberOrders []uint32 `protobuf:"varint,7,rep,name=memberOrders" json:"memberOrders,omitempty"` CreationTimeStamp *uint64 `protobuf:"varint,8,opt,name=creationTimeStamp" json:"creationTimeStamp,omitempty"` // TODO(runzhiwang): when leaderID is gone, specify 6 as the index of leaderID128 LeaderID128 *UUID `protobuf:"bytes,100,opt,name=leaderID128" json:"leaderID128,omitempty"` // contains filtered or unexported fields }
func (*Pipeline) Descriptor
deprecated
func (*Pipeline) GetCreationTimeStamp ¶
func (*Pipeline) GetFactor ¶
func (x *Pipeline) GetFactor() ReplicationFactor
func (*Pipeline) GetId ¶
func (x *Pipeline) GetId() *PipelineID
func (*Pipeline) GetLeaderID ¶
func (*Pipeline) GetLeaderID128 ¶
func (*Pipeline) GetMemberOrders ¶
func (*Pipeline) GetMembers ¶
func (x *Pipeline) GetMembers() []*DatanodeDetailsProto
func (*Pipeline) GetState ¶
func (x *Pipeline) GetState() PipelineState
func (*Pipeline) GetType ¶
func (x *Pipeline) GetType() ReplicationType
func (*Pipeline) ProtoMessage ¶
func (*Pipeline) ProtoMessage()
func (*Pipeline) ProtoReflect ¶
func (x *Pipeline) ProtoReflect() protoreflect.Message
type PipelineID ¶
type PipelineID struct { // deprecated, please use uuid128 instead Id *string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"` // TODO(runzhiwang): when id is gone, specify 1 as the index of uuid128 and mark as required Uuid128 *UUID `protobuf:"bytes,100,opt,name=uuid128" json:"uuid128,omitempty"` // contains filtered or unexported fields }
func (*PipelineID) Descriptor
deprecated
func (*PipelineID) Descriptor() ([]byte, []int)
Deprecated: Use PipelineID.ProtoReflect.Descriptor instead.
func (*PipelineID) GetId ¶
func (x *PipelineID) GetId() string
func (*PipelineID) GetUuid128 ¶
func (x *PipelineID) GetUuid128() *UUID
func (*PipelineID) ProtoMessage ¶
func (*PipelineID) ProtoMessage()
func (*PipelineID) ProtoReflect ¶
func (x *PipelineID) ProtoReflect() protoreflect.Message
func (*PipelineID) Reset ¶
func (x *PipelineID) Reset()
func (*PipelineID) String ¶
func (x *PipelineID) String() string
type PipelineState ¶
type PipelineState int32
const ( PipelineState_PIPELINE_ALLOCATED PipelineState = 1 PipelineState_PIPELINE_OPEN PipelineState = 2 PipelineState_PIPELINE_DORMANT PipelineState = 3 PipelineState_PIPELINE_CLOSED PipelineState = 4 )
func (PipelineState) Descriptor ¶
func (PipelineState) Descriptor() protoreflect.EnumDescriptor
func (PipelineState) Enum ¶
func (x PipelineState) Enum() *PipelineState
func (PipelineState) EnumDescriptor
deprecated
func (PipelineState) EnumDescriptor() ([]byte, []int)
Deprecated: Use PipelineState.Descriptor instead.
func (PipelineState) Number ¶
func (x PipelineState) Number() protoreflect.EnumNumber
func (PipelineState) String ¶
func (x PipelineState) String() string
func (PipelineState) Type ¶
func (PipelineState) Type() protoreflect.EnumType
func (*PipelineState) UnmarshalJSON
deprecated
func (x *PipelineState) UnmarshalJSON(b []byte) error
Deprecated: Do not use.
type Port ¶
type Port struct { Name *string `protobuf:"bytes,1,req,name=name" json:"name,omitempty"` Value *uint32 `protobuf:"varint,2,req,name=value" json:"value,omitempty"` // contains filtered or unexported fields }
func (*Port) Descriptor
deprecated
func (*Port) ProtoMessage ¶
func (*Port) ProtoMessage()
func (*Port) ProtoReflect ¶
func (x *Port) ProtoReflect() protoreflect.Message
type QueryScope ¶
type QueryScope int32
const ( QueryScope_CLUSTER QueryScope = 1 QueryScope_POOL QueryScope = 2 )
func (QueryScope) Descriptor ¶
func (QueryScope) Descriptor() protoreflect.EnumDescriptor
func (QueryScope) Enum ¶
func (x QueryScope) Enum() *QueryScope
func (QueryScope) EnumDescriptor
deprecated
func (QueryScope) EnumDescriptor() ([]byte, []int)
Deprecated: Use QueryScope.Descriptor instead.
func (QueryScope) Number ¶
func (x QueryScope) Number() protoreflect.EnumNumber
func (QueryScope) String ¶
func (x QueryScope) String() string
func (QueryScope) Type ¶
func (QueryScope) Type() protoreflect.EnumType
func (*QueryScope) UnmarshalJSON
deprecated
func (x *QueryScope) UnmarshalJSON(b []byte) error
Deprecated: Do not use.
type ReplicationFactor ¶
type ReplicationFactor int32
const ( ReplicationFactor_ONE ReplicationFactor = 1 ReplicationFactor_THREE ReplicationFactor = 3 )
func (ReplicationFactor) Descriptor ¶
func (ReplicationFactor) Descriptor() protoreflect.EnumDescriptor
func (ReplicationFactor) Enum ¶
func (x ReplicationFactor) Enum() *ReplicationFactor
func (ReplicationFactor) EnumDescriptor
deprecated
func (ReplicationFactor) EnumDescriptor() ([]byte, []int)
Deprecated: Use ReplicationFactor.Descriptor instead.
func (ReplicationFactor) Number ¶
func (x ReplicationFactor) Number() protoreflect.EnumNumber
func (ReplicationFactor) String ¶
func (x ReplicationFactor) String() string
func (ReplicationFactor) Type ¶
func (ReplicationFactor) Type() protoreflect.EnumType
func (*ReplicationFactor) UnmarshalJSON
deprecated
func (x *ReplicationFactor) UnmarshalJSON(b []byte) error
Deprecated: Do not use.
type ReplicationType ¶
type ReplicationType int32
const ( ReplicationType_RATIS ReplicationType = 1 ReplicationType_STAND_ALONE ReplicationType = 2 ReplicationType_CHAINED ReplicationType = 3 )
func (ReplicationType) Descriptor ¶
func (ReplicationType) Descriptor() protoreflect.EnumDescriptor
func (ReplicationType) Enum ¶
func (x ReplicationType) Enum() *ReplicationType
func (ReplicationType) EnumDescriptor
deprecated
func (ReplicationType) EnumDescriptor() ([]byte, []int)
Deprecated: Use ReplicationType.Descriptor instead.
func (ReplicationType) Number ¶
func (x ReplicationType) Number() protoreflect.EnumNumber
func (ReplicationType) String ¶
func (x ReplicationType) String() string
func (ReplicationType) Type ¶
func (ReplicationType) Type() protoreflect.EnumType
func (*ReplicationType) UnmarshalJSON
deprecated
func (x *ReplicationType) UnmarshalJSON(b []byte) error
Deprecated: Do not use.
type ScmOps ¶
type ScmOps int32
const ( ScmOps_allocateBlock ScmOps = 1 ScmOps_keyBlocksInfoList ScmOps = 2 ScmOps_getScmInfo ScmOps = 3 ScmOps_deleteBlock ScmOps = 4 ScmOps_createReplicationPipeline ScmOps = 5 ScmOps_allocateContainer ScmOps = 6 ScmOps_getContainer ScmOps = 7 ScmOps_getContainerWithPipeline ScmOps = 8 ScmOps_listContainer ScmOps = 9 ScmOps_deleteContainer ScmOps = 10 ScmOps_queryNode ScmOps = 11 )
func (ScmOps) Descriptor ¶
func (ScmOps) Descriptor() protoreflect.EnumDescriptor
func (ScmOps) EnumDescriptor
deprecated
func (ScmOps) Number ¶
func (x ScmOps) Number() protoreflect.EnumNumber
func (ScmOps) Type ¶
func (ScmOps) Type() protoreflect.EnumType
func (*ScmOps) UnmarshalJSON
deprecated
type UUID ¶
type UUID struct { MostSigBits *int64 `protobuf:"varint,1,req,name=mostSigBits" json:"mostSigBits,omitempty"` LeastSigBits *int64 `protobuf:"varint,2,req,name=leastSigBits" json:"leastSigBits,omitempty"` // contains filtered or unexported fields }
func (*UUID) Descriptor
deprecated
func (*UUID) GetLeastSigBits ¶
func (*UUID) GetMostSigBits ¶
func (*UUID) ProtoMessage ¶
func (*UUID) ProtoMessage()
func (*UUID) ProtoReflect ¶
func (x *UUID) ProtoReflect() protoreflect.Message