internal

Documentation

Index

• Variables
• type ReplicaRole
• type ReplicaSet
  • func ClusterStatusToReplicaSet(clusterStatus *types.GetClusterStatusResponse, tlsEnabled bool) (ReplicaSet, error)
  • func (r ReplicaSet) SortByRole()
  • func (r ReplicaSet) ToConfigReplicaSet() []*config.Replica
  • func (r ReplicaSet) ToReplicaMap() map[string]*url.URL
• type ReplicaWithRole
  • func (r *ReplicaWithRole) String() string

Variables

var ReplicaRoleName = map[int32]string{
	0: "LEADER",
	1: "FOLLOWER",
	2: "UNKNOWN",
}

var ReplicaRoleValue = map[string]int32{
	"LEADER":   0,
	"FOLLOWER": 1,
	"UNKNOWN":  2,
}

Types

type ReplicaRole

type ReplicaRole int32

const (
	ReplicaRole_LEADER   ReplicaRole = 0
	ReplicaRole_FOLLOWER ReplicaRole = 1
	ReplicaRole_UNKNOWN  ReplicaRole = 2
)

type ReplicaSet

type ReplicaSet []*ReplicaWithRole

func ClusterStatusToReplicaSet

func ClusterStatusToReplicaSet(clusterStatus *types.GetClusterStatusResponse, tlsEnabled bool) (ReplicaSet, error)

ClusterStatusToReplicaSet creates a sorted array of ReplicaWithRole objects, leader first.

func (ReplicaSet) SortByRole

func (r ReplicaSet) SortByRole()

SortByRole sort the replicas such that the leader is first, then followers, then unknown.

func (ReplicaSet) ToConfigReplicaSet

func (r ReplicaSet) ToConfigReplicaSet() []*config.Replica

ToConfigReplicaSet returns an array of config.Replica objects that corresponds the ReplicaSet.

func (ReplicaSet) ToReplicaMap

func (r ReplicaSet) ToReplicaMap() map[string]*url.URL

ToReplicaMap returns map of ID->URL that corresponds the ReplicaSet.

type ReplicaWithRole

type ReplicaWithRole struct {
	Id   string
	URL  *url.URL
	Role ReplicaRole
}

func (*ReplicaWithRole) String

func (r *ReplicaWithRole) String() string