poller

Documentation

Index

• type Poller
  • func New(ctx context.Context, storage *storage.Storage, searcher *catalog.Searcher, ...) *Poller
  • func (p *Poller) Refresh(prov storage.Provider)
  • func (p *Poller) RefreshAll()
  • func (p *Poller) Run() error
  • func (p *Poller) Shutdown()
  • func (p *Poller) StartWorker(prov *storage.Provider)
  • func (p *Poller) StopWorker(prov *storage.Provider, update bool)
  • func (p *Poller) WorkerError(id string) error

Types

type Poller

type Poller struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Poller represents a poller instance.

func New

func New(
	ctx context.Context,
	storage *storage.Storage,
	searcher *catalog.Searcher,
	config *config.Config,
	logger *logger.Logger,
) *Poller

New creates a new poller instance.

func (*Poller) Refresh

func (p *Poller) Refresh(prov storage.Provider)

Refresh triggers a refresh on an existing poller worker.

func (*Poller) RefreshAll

func (p *Poller) RefreshAll()

RefreshAll triggers a refresh on all the registered poller workers.

func (*Poller) Run

func (p *Poller) Run() error

Run starts polling the providers.

func (*Poller) Shutdown

func (p *Poller) Shutdown()

Shutdown stops the providers polling.

func (*Poller) StartWorker

func (p *Poller) StartWorker(prov *storage.Provider)

StartWorker starts a new poller worker given a storage provider.

func (*Poller) StopWorker

func (p *Poller) StopWorker(prov *storage.Provider, update bool)

StopWorker stops an existing poller worker.

func (*Poller) WorkerError

func (p *Poller) WorkerError(id string) error

WorkerError returns the error returned on poller worker initialization.