membership

Documentation

Index

• type Config
• type Member
  • func (m *Member) Marshal() (map[string]string, error)
  • func (t *Member) Unmarshal(m map[string]string) error
• type Membership
  • func New(config Config) (Membership, error)

Types

type Config

type Config struct {
	NodeId   string
	SerfAddr string
	Logger   logging.Logger
	RpcAddr  string
}

type Member

type Member struct {
	// Global unique identifier for the node
	NodeId   string `json:"nodeId"`
	RpcAddr  string `json:"addr"`
	SerfAddr string `json:"serfAddr"`
	State    string `json:"state"`
}

func (*Member) Marshal

func (m *Member) Marshal() (map[string]string, error)

func (*Member) Unmarshal

func (t *Member) Unmarshal(m map[string]string) error

type Membership

type Membership interface {
	Join(addrs ...string) (int, error)
	Leave() error
	Members() ([]Member, error)
	SerfAddr() string
	SubscribeJoinEvents() <-chan Member

	SubscribeLeaveEvents() <-chan Member

	NodeId() string
}

func New

func New(config Config) (Membership, error)