poller

Documentation

Index

• func New(queue queue, processor processor, cfg Config) *poller
• type Config

Functions

func New

func New(queue queue, processor processor, cfg Config) *poller

Types

type Config

type Config struct {
	BatchSize  int64
	PoolSize   int64
	RetryDelay time.Duration
}