discoverer

Documentation

Index

• type Discoverer
  • func NewSerfDiscoverer(conf *serf.Config, store store.Store, logger *logrus.Logger) (Discoverer, error)
• type Serf
• type SerfDiscoverer
  • func (s *SerfDiscoverer) GetAgents() []*agentinfo.AgentsNodeInfo
  • func (s *SerfDiscoverer) GetDispatchers() []*agentinfo.AgentsNodeInfo
  • func (s *SerfDiscoverer) Join(ctx context.Context, addresses []string, agent *agentinfo.AgentsNodeInfo) error

Types

type Discoverer

type Discoverer interface {
	Join(ctx context.Context, addresses []string, agent *agentinfo.AgentsNodeInfo) error
	GetAgents() []*agentinfo.AgentsNodeInfo
	GetDispatchers() []*agentinfo.AgentsNodeInfo
}

Discoverer allow agents to discover each other.

func NewSerfDiscoverer

func NewSerfDiscoverer(conf *serf.Config, store store.Store, logger *logrus.Logger) (Discoverer, error)

type Serf

type Serf interface {
	Join(existing []string, ignoreOld bool) (int, error)
	LocalMember() serf.Member
	UserEvent(name string, payload []byte, coalesce bool) error
}

type SerfDiscoverer

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

func (*SerfDiscoverer) GetAgents

func (s *SerfDiscoverer) GetAgents() []*agentinfo.AgentsNodeInfo

func (*SerfDiscoverer) GetDispatchers

func (s *SerfDiscoverer) GetDispatchers() []*agentinfo.AgentsNodeInfo

func (*SerfDiscoverer) Join

func (s *SerfDiscoverer) Join(ctx context.Context, addresses []string, agent *agentinfo.AgentsNodeInfo) error