membership

Documentation

Index

• type MemberPool
  • func NewZkMemberPool(zk *zk.Conn, host string, path string, onChange OnMembershipChanged) (MemberPool, error)
• type Members
  • func (a Members) Len() int
  • func (a Members) Less(i, j int) bool
  • func (a Members) Swap(i, j int)
• type OnMembershipChanged
• type PoolMember
  • func (pm *PoolMember) Node() string

Types

type MemberPool

type MemberPool interface {
	Leave()
	Join() (PoolMember, error)
	IsLeader() bool
}

func NewZkMemberPool

func NewZkMemberPool(zk *zk.Conn, host string, path string, onChange OnMembershipChanged) (MemberPool, error)

type Members

type Members []PoolMember

func (Members) Len

func (a Members) Len() int

func (Members) Less

func (a Members) Less(i, j int) bool

func (Members) Swap

func (a Members) Swap(i, j int)

type OnMembershipChanged

type OnMembershipChanged func(bool)

type PoolMember

type PoolMember struct {
	Host    string `json:"host"`
	Id      string `json:"id"`
	Version int32  `json:"version"`
	Leader  bool   `json:"-"`
}

func (*PoolMember) Node

func (pm *PoolMember) Node() string