poller

Documentation

Overview

Package poller provides the core Poller struct.

Index

• type Config
• type HTTPNodePoller
  • func NewHTTPNodePoller(logger logger.Logger) *HTTPNodePoller
  • func (p *HTTPNodePoller) Poll(addr dax.Address) bool
• type NodePoller
• type NopNodePoller
  • func NewNopNodePoller() *NopNodePoller
  • func (p *NopNodePoller) Poll(addr dax.Address) bool
• type Poller
  • func New(cfg Config) *Poller
  • func (p *Poller) Addresses() []dax.Address
  • func (p *Poller) Run() error
  • func (p *Poller) Stop()

Types

type Config

type Config struct {
	AddressManager dax.AddressManager
	NodeService    dax.NodeService
	NodePoller     NodePoller
	PollInterval   time.Duration
	Logger         logger.Logger
}

type HTTPNodePoller

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

HTTPNodePoller is an http implementation of the NodePoller interface.

func NewHTTPNodePoller

func NewHTTPNodePoller(logger logger.Logger) *HTTPNodePoller

func (*HTTPNodePoller) Poll

func (p *HTTPNodePoller) Poll(addr dax.Address) bool

type NodePoller

type NodePoller interface {
	Poll(dax.Address) bool
}

NodePoller is an interface to anything which has the ability to poll a node.

type NopNodePoller

type NopNodePoller struct{}

NopNodePoller is a no-op implementation of the NodePoller interface.

func NewNopNodePoller

func NewNopNodePoller() *NopNodePoller

func (*NopNodePoller) Poll

func (p *NopNodePoller) Poll(addr dax.Address) bool

type Poller

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

Poller maintains a list of nodes to poll. It also polls them.

func New

func New(cfg Config) *Poller

New returns a new instance of Poller with default values.

func (*Poller) Addresses

func (p *Poller) Addresses() []dax.Address

func (*Poller) Run

func (p *Poller) Run() error

Run starts the polling goroutine.

func (*Poller) Stop

func (p *Poller) Stop()

Stop stops the polling routine.