serf

Documentation

Index

• type OptionFn
  • func Addr(serfAddr string) OptionFn
  • func InitMembers(serfMembers []string) OptionFn
  • func Logger(logger *simplelog.Logger) OptionFn
• type Serf
  • func New(opts ...OptionFn) (*Serf, error)
  • func (b *Serf) Addr() string
  • func (b *Serf) Bootstrap(node *jocko.ClusterMember, reconcileCh chan<- *jocko.ClusterMember) error
  • func (b *Serf) Cluster() []*jocko.ClusterMember
  • func (b *Serf) Join(addrs ...string) (int, error)
  • func (b *Serf) Member(memberID int32) *jocko.ClusterMember
  • func (b *Serf) Shutdown() error

Types

type OptionFn

type OptionFn func(b *Serf)

func Addr

func Addr(serfAddr string) OptionFn

func InitMembers

func InitMembers(serfMembers []string) OptionFn

func Logger

func Logger(logger *simplelog.Logger) OptionFn

type Serf

type Serf struct {
	// contains filtered or unexported fields
}

Serf manages membership of Jocko cluster using Hashicorp Serf

func New

func New(opts ...OptionFn) (*Serf, error)

New Serf object

func (*Serf) Addr

func (b *Serf) Addr() string

Addr of serf agent

func (*Serf) Bootstrap

func (b *Serf) Bootstrap(node *jocko.ClusterMember, reconcileCh chan<- *jocko.ClusterMember) error

Bootstrap saves the node metadata and starts the serf agent Info of node updates is returned on reconcileCh channel

func (*Serf) Cluster

func (b *Serf) Cluster() []*jocko.ClusterMember

Cluster is the list of all nodes connected to Serf

func (*Serf) Join

func (b *Serf) Join(addrs ...string) (int, error)

Join an existing serf cluster

func (*Serf) Member

func (b *Serf) Member(memberID int32) *jocko.ClusterMember

Member returns broker details of node with given ID

func (*Serf) Shutdown

func (b *Serf) Shutdown() error

Shutdown Serf agent