poller

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(logger logger.Logger) *HTTPNodePoller

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() *NopNodePoller

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(cfg Config) *Poller

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

func (p *Poller) Run() error

func (p *Poller) Stop()