Versions in this module Expand all Collapse all v1 v1.0.0 May 31, 2023 Changes in this version + const DefaultBatchSize + const DefaultDequeueTimeout + const DefaultMaxRetries + const DefaultRunningTimeout + const DefaultSyncPeriod + const DefaultWorkers + type Options struct + BatchSize int + DequeueTimeout time.Duration + MaxRetries int + RunningTimeout time.Duration + SyncPeriod time.Duration + Workers int + func NewOptions() *Options + func (o *Options) AddFlags(fs *pflag.FlagSet) + func (o *Options) Enabled() bool + func (o *Options) Validate() error
Go to main page