polling

Documentation

Index

• type EventListener
  • func NewEventListener(stateKey string, portClient *cli.PortClient) *EventListener
  • func (l *EventListener) Run(resync func()) error
• type Handler
  • func NewPollingHandler(pollingRate uint, stateKey string, portClient *cli.PortClient, ...) *Handler
  • func (h *Handler) Run(resync func())
• type ITicker
• type Ticker
  • func NewTicker(d time.Duration) *Ticker
  • func (t *Ticker) GetC() <-chan time.Time
  • func (t *Ticker) Stop()

Types

type EventListener

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

func NewEventListener

func NewEventListener(stateKey string, portClient *cli.PortClient) *EventListener

func (*EventListener) Run

func (l *EventListener) Run(resync func()) error

type Handler

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

func NewPollingHandler

func NewPollingHandler(pollingRate uint, stateKey string, portClient *cli.PortClient, tickerOverride ITicker) *Handler

func (*Handler) Run

func (h *Handler) Run(resync func())

type ITicker

type ITicker interface {
	GetC() <-chan time.Time
}

type Ticker

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

func NewTicker

func NewTicker(d time.Duration) *Ticker

func (*Ticker) GetC

func (t *Ticker) GetC() <-chan time.Time

func (*Ticker) Stop

func (t *Ticker) Stop()