Versions in this module Expand all Collapse all v0 v0.1.0 Jul 15, 2026 Changes in this version + type OffsetStore interface + Load func(ctx context.Context) (int, error) + Save func(ctx context.Context, offset int) error + type OptOptionsSetter func(o *Options) + func WithAllowedUpdates(opt []string) OptOptionsSetter + func WithBufferSize(opt int) OptOptionsSetter + func WithLimit(opt int) OptOptionsSetter + func WithLogger(opt logger.Logger) OptOptionsSetter + func WithOffsetStore(opt OffsetStore) OptOptionsSetter + func WithPollingInterval(opt time.Duration) OptOptionsSetter + func WithRequestTimeout(opt time.Duration) OptOptionsSetter + func WithTimeout(opt time.Duration) OptOptionsSetter + type Options struct + func NewOptions(client client.ClientWithResponsesInterface, options ...OptOptionsSetter) Options + func (o *Options) Validate() error + type Poller struct + func NewPoller(opts Options) (*Poller, error) + func (p *Poller) Start(ctx context.Context) error + func (p *Poller) Stop(ctx context.Context) error + func (p *Poller) UpdateChan() <-chan client.Update
Go to main page