Documentation ¶
Index ¶
- Constants
- type Cluster
- func (cluster *Cluster) AddClusterNode(ns, nodeType string, address pb.ServerAddress, version string) []*master_pb.KeepConnectedResponse
- func (cluster *Cluster) IsOneLeader(filerGroup FilerGroup, address pb.ServerAddress) bool
- func (cluster *Cluster) ListClusterNode(filerGroup FilerGroup, nodeType string) (nodes []*ClusterNode)
- func (cluster *Cluster) RemoveClusterNode(ns string, nodeType string, address pb.ServerAddress) []*master_pb.KeepConnectedResponse
- type ClusterNode
- type FilerGroup
- type Filers
- type Leaders
Constants ¶
View Source
const ( MasterType = "master" VolumeServerType = "volumeServer" FilerType = "filer" BrokerType = "broker" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Cluster ¶
type Cluster struct {
// contains filtered or unexported fields
}
func NewCluster ¶
func NewCluster() *Cluster
func (*Cluster) AddClusterNode ¶
func (cluster *Cluster) AddClusterNode(ns, nodeType string, address pb.ServerAddress, version string) []*master_pb.KeepConnectedResponse
func (*Cluster) IsOneLeader ¶
func (cluster *Cluster) IsOneLeader(filerGroup FilerGroup, address pb.ServerAddress) bool
func (*Cluster) ListClusterNode ¶
func (cluster *Cluster) ListClusterNode(filerGroup FilerGroup, nodeType string) (nodes []*ClusterNode)
func (*Cluster) RemoveClusterNode ¶
func (cluster *Cluster) RemoveClusterNode(ns string, nodeType string, address pb.ServerAddress) []*master_pb.KeepConnectedResponse
type ClusterNode ¶
type ClusterNode struct { Address pb.ServerAddress Version string // contains filtered or unexported fields }
type FilerGroup ¶
type FilerGroup string
type Leaders ¶
type Leaders struct {
// contains filtered or unexported fields
}
func (*Leaders) GetLeaders ¶
func (leaders *Leaders) GetLeaders() (addresses []pb.ServerAddress)
Click to show internal directories.
Click to hide internal directories.