poller

Documentation

Index

• type Poller
  • func NewPoller(fsp fs.Poller, path string, logger *zap.SugaredLogger) (*Poller, error)
  • func (cw *Poller) AddCallback(cb PollerCallback)
  • func (cw *Poller) GetConfig() *cfgbroker.Config
  • func (cw *Poller) Start(ctx context.Context) error
• type PollerCallback

Types

type Poller

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

func NewPoller

func NewPoller(fsp fs.Poller, path string, logger *zap.SugaredLogger) (*Poller, error)

func (*Poller) AddCallback

func (cw *Poller) AddCallback(cb PollerCallback)

func (*Poller) GetConfig

func (cw *Poller) GetConfig() *cfgbroker.Config

func (*Poller) Start

func (cw *Poller) Start(ctx context.Context) error

type PollerCallback

type PollerCallback func(*cfgbroker.Config)