hdds

package
v0.0.0-...-06a9ffa Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 2, 2022 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

View Source
const (
	Default_Pipeline_State  = PipelineState_PIPELINE_ALLOCATED
	Default_Pipeline_Type   = ReplicationType_STAND_ALONE
	Default_Pipeline_Factor = ReplicationFactor_ONE
)

Default values for Pipeline fields.

View Source
const (
	Default_BlockID_BlockCommitSequenceId = uint64(0)
)

Default values for BlockID fields.

Variables

View Source
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.

View Source
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.

View Source
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.

View Source
var (
	QueryScope_name = map[int32]string{
		1: "CLUSTER",
		2: "POOL",
	}
	QueryScope_value = map[string]int32{
		"CLUSTER": 1,
		"POOL":    2,
	}
)

Enum value maps for QueryScope.

View Source
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.

View Source
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.

View Source
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.

View Source
var (
	ReplicationFactor_name = map[int32]string{
		1: "ONE",
		3: "THREE",
	}
	ReplicationFactor_value = map[string]int32{
		"ONE":   1,
		"THREE": 3,
	}
)

Enum value maps for ReplicationFactor.

View Source
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.

View Source
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.

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) Descriptor() ([]byte, []int)

Deprecated: Use BlockID.ProtoReflect.Descriptor instead.

func (*BlockID) GetBlockCommitSequenceId

func (x *BlockID) GetBlockCommitSequenceId() uint64

func (*BlockID) GetContainerBlockID

func (x *BlockID) GetContainerBlockID() *ContainerBlockID

func (*BlockID) ProtoMessage

func (*BlockID) ProtoMessage()

func (*BlockID) ProtoReflect

func (x *BlockID) ProtoReflect() protoreflect.Message

func (*BlockID) Reset

func (x *BlockID) Reset()

func (*BlockID) String

func (x *BlockID) String() string

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 (*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) Enum

func (BlockTokenSecretProto_AccessModeProto) EnumDescriptor deprecated

func (BlockTokenSecretProto_AccessModeProto) EnumDescriptor() ([]byte, []int)

Deprecated: Use BlockTokenSecretProto_AccessModeProto.Descriptor instead.

func (BlockTokenSecretProto_AccessModeProto) Number

func (BlockTokenSecretProto_AccessModeProto) String

func (BlockTokenSecretProto_AccessModeProto) Type

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) Descriptor() ([]byte, []int)

Deprecated: Use KeyValue.ProtoReflect.Descriptor instead.

func (*KeyValue) GetKey

func (x *KeyValue) GetKey() string

func (*KeyValue) GetValue

func (x *KeyValue) GetValue() string

func (*KeyValue) ProtoMessage

func (*KeyValue) ProtoMessage()

func (*KeyValue) ProtoReflect

func (x *KeyValue) ProtoReflect() protoreflect.Message

func (*KeyValue) Reset

func (x *KeyValue) Reset()

func (*KeyValue) String

func (x *KeyValue) String() string

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) Enum

func (x LifeCycleEvent) Enum() *LifeCycleEvent

func (LifeCycleEvent) EnumDescriptor deprecated

func (LifeCycleEvent) EnumDescriptor() ([]byte, []int)

Deprecated: Use LifeCycleEvent.Descriptor instead.

func (LifeCycleEvent) Number

func (LifeCycleEvent) String

func (x LifeCycleEvent) String() string

func (LifeCycleEvent) Type

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) Enum

func (x LifeCycleState) Enum() *LifeCycleState

func (LifeCycleState) EnumDescriptor deprecated

func (LifeCycleState) EnumDescriptor() ([]byte, []int)

Deprecated: Use LifeCycleState.Descriptor instead.

func (LifeCycleState) Number

func (LifeCycleState) String

func (x LifeCycleState) String() string

func (LifeCycleState) Type

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) Descriptor() ([]byte, []int)

Deprecated: Use Node.ProtoReflect.Descriptor instead.

func (*Node) GetNodeID

func (x *Node) GetNodeID() *DatanodeDetailsProto

func (*Node) GetNodeStates

func (x *Node) GetNodeStates() []NodeState

func (*Node) ProtoMessage

func (*Node) ProtoMessage()

func (*Node) ProtoReflect

func (x *Node) ProtoReflect() protoreflect.Message

func (*Node) Reset

func (x *Node) Reset()

func (*Node) String

func (x *Node) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use NodePool.ProtoReflect.Descriptor instead.

func (*NodePool) GetNodes

func (x *NodePool) GetNodes() []*Node

func (*NodePool) ProtoMessage

func (*NodePool) ProtoMessage()

func (*NodePool) ProtoReflect

func (x *NodePool) ProtoReflect() protoreflect.Message

func (*NodePool) Reset

func (x *NodePool) Reset()

func (*NodePool) String

func (x *NodePool) String() string

type NodeState

type NodeState int32

* Enum that represents the Node State. This is used in calls to getNodeList and getNodeCount.

const (
	NodeState_HEALTHY         NodeState = 1
	NodeState_STALE           NodeState = 2
	NodeState_DEAD            NodeState = 3
	NodeState_DECOMMISSIONING NodeState = 4
	NodeState_DECOMMISSIONED  NodeState = 5
)

func (NodeState) Descriptor

func (NodeState) Descriptor() protoreflect.EnumDescriptor

func (NodeState) Enum

func (x NodeState) Enum() *NodeState

func (NodeState) EnumDescriptor deprecated

func (NodeState) EnumDescriptor() ([]byte, []int)

Deprecated: Use NodeState.Descriptor instead.

func (NodeState) Number

func (x NodeState) Number() protoreflect.EnumNumber

func (NodeState) String

func (x NodeState) String() string

func (NodeState) Type

func (*NodeState) UnmarshalJSON deprecated

func (x *NodeState) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type NodeType

type NodeType int32

* Type of the node.

const (
	NodeType_OM       NodeType = 1 // Ozone Manager
	NodeType_SCM      NodeType = 2 // Storage Container Manager
	NodeType_DATANODE NodeType = 3 // DataNode
	NodeType_RECON    NodeType = 4 // Recon
)

func (NodeType) Descriptor

func (NodeType) Descriptor() protoreflect.EnumDescriptor

func (NodeType) Enum

func (x NodeType) Enum() *NodeType

func (NodeType) EnumDescriptor deprecated

func (NodeType) EnumDescriptor() ([]byte, []int)

Deprecated: Use NodeType.Descriptor instead.

func (NodeType) Number

func (x NodeType) Number() protoreflect.EnumNumber

func (NodeType) String

func (x NodeType) String() string

func (NodeType) Type

func (*NodeType) UnmarshalJSON deprecated

func (x *NodeType) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

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) Descriptor() ([]byte, []int)

Deprecated: Use Pipeline.ProtoReflect.Descriptor instead.

func (*Pipeline) GetCreationTimeStamp

func (x *Pipeline) GetCreationTimeStamp() uint64

func (*Pipeline) GetFactor

func (x *Pipeline) GetFactor() ReplicationFactor

func (*Pipeline) GetId

func (x *Pipeline) GetId() *PipelineID

func (*Pipeline) GetLeaderID

func (x *Pipeline) GetLeaderID() string

func (*Pipeline) GetLeaderID128

func (x *Pipeline) GetLeaderID128() *UUID

func (*Pipeline) GetMemberOrders

func (x *Pipeline) GetMemberOrders() []uint32

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

func (*Pipeline) Reset

func (x *Pipeline) Reset()

func (*Pipeline) String

func (x *Pipeline) String() string

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) Enum

func (x PipelineState) Enum() *PipelineState

func (PipelineState) EnumDescriptor deprecated

func (PipelineState) EnumDescriptor() ([]byte, []int)

Deprecated: Use PipelineState.Descriptor instead.

func (PipelineState) Number

func (PipelineState) String

func (x PipelineState) String() string

func (PipelineState) Type

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) Descriptor() ([]byte, []int)

Deprecated: Use Port.ProtoReflect.Descriptor instead.

func (*Port) GetName

func (x *Port) GetName() string

func (*Port) GetValue

func (x *Port) GetValue() uint32

func (*Port) ProtoMessage

func (*Port) ProtoMessage()

func (*Port) ProtoReflect

func (x *Port) ProtoReflect() protoreflect.Message

func (*Port) Reset

func (x *Port) Reset()

func (*Port) String

func (x *Port) String() string

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) 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) Enum

func (ReplicationFactor) EnumDescriptor deprecated

func (ReplicationFactor) EnumDescriptor() ([]byte, []int)

Deprecated: Use ReplicationFactor.Descriptor instead.

func (ReplicationFactor) Number

func (ReplicationFactor) String

func (x ReplicationFactor) String() string

func (ReplicationFactor) Type

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) Enum

func (x ReplicationType) Enum() *ReplicationType

func (ReplicationType) EnumDescriptor deprecated

func (ReplicationType) EnumDescriptor() ([]byte, []int)

Deprecated: Use ReplicationType.Descriptor instead.

func (ReplicationType) Number

func (ReplicationType) String

func (x ReplicationType) String() string

func (ReplicationType) Type

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) Enum

func (x ScmOps) Enum() *ScmOps

func (ScmOps) EnumDescriptor deprecated

func (ScmOps) EnumDescriptor() ([]byte, []int)

Deprecated: Use ScmOps.Descriptor instead.

func (ScmOps) Number

func (x ScmOps) Number() protoreflect.EnumNumber

func (ScmOps) String

func (x ScmOps) String() string

func (ScmOps) Type

func (ScmOps) Type() protoreflect.EnumType

func (*ScmOps) UnmarshalJSON deprecated

func (x *ScmOps) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

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) Descriptor() ([]byte, []int)

Deprecated: Use UUID.ProtoReflect.Descriptor instead.

func (*UUID) GetLeastSigBits

func (x *UUID) GetLeastSigBits() int64

func (*UUID) GetMostSigBits

func (x *UUID) GetMostSigBits() int64

func (*UUID) ProtoMessage

func (*UUID) ProtoMessage()

func (*UUID) ProtoReflect

func (x *UUID) ProtoReflect() protoreflect.Message

func (*UUID) Reset

func (x *UUID) Reset()

func (*UUID) String

func (x *UUID) String() string

Jump to

Keyboard shortcuts

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