zookeeperutil

Documentation

Index

• func GetClusterConfig(hosts []string) ([]string, error)
• func ReconfigureCluster(hosts []string, desiredConfig []string) ([]string, error)
• type Member
  • func (m *Member) Addr() string
  • func (m *Member) ID() int
• type MemberSet
  • func NewMemberSet(ms ...*Member) MemberSet
  • func (ms MemberSet) Add(m *Member)
  • func (ms MemberSet) ClientHostList() []string
  • func (ms MemberSet) ClusterConfig() []string
  • func (ms MemberSet) Diff(other MemberSet) MemberSet
  • func (ms MemberSet) IsEqual(other MemberSet) bool
  • func (ms MemberSet) MaxMemberID() int
  • func (ms MemberSet) PickOne() *Member
  • func (ms MemberSet) Remove(name string)
  • func (ms MemberSet) Size() int
  • func (ms MemberSet) String() string

Functions

func GetClusterConfig

func GetClusterConfig(hosts []string) ([]string, error)

func ReconfigureCluster

func ReconfigureCluster(hosts []string, desiredConfig []string) ([]string, error)

Types

type Member

type Member struct {
	// Name is of the format "clusterName-ID"
	Name string
	// Kubernetes namespace this member runs in.
	Namespace string
}

func (*Member) Addr

func (m *Member) Addr() string

func (*Member) ID

func (m *Member) ID() int

type MemberSet

type MemberSet map[string]*Member

func NewMemberSet

func NewMemberSet(ms ...*Member) MemberSet

func (MemberSet) Add

func (ms MemberSet) Add(m *Member)

func (MemberSet) ClientHostList

func (ms MemberSet) ClientHostList() []string

func (MemberSet) ClusterConfig

func (ms MemberSet) ClusterConfig() []string

func (MemberSet) Diff

func (ms MemberSet) Diff(other MemberSet) MemberSet

the set of all members of s1 that are not members of s2

func (MemberSet) IsEqual

func (ms MemberSet) IsEqual(other MemberSet) bool

IsEqual tells whether two member sets are equal by checking - they have the same set of members and member equality are judged by Name only.

func (MemberSet) MaxMemberID

func (ms MemberSet) MaxMemberID() int

func (MemberSet) PickOne

func (ms MemberSet) PickOne() *Member

func (MemberSet) Remove

func (ms MemberSet) Remove(name string)

func (MemberSet) Size

func (ms MemberSet) Size() int

func (MemberSet) String

func (ms MemberSet) String() string