poll

Documentation

Index

• func Run(cfg LaunchConfig)
• func SimplePoller(ctx context.Context, wg *sync.WaitGroup, queues []queue.Queue, ...)
• type Config
• type LaunchConfig
• type Poller
  • func New(poller string) (Poller, error)

Functions

func Run

func Run(cfg LaunchConfig)

func SimplePoller

func SimplePoller(ctx context.Context, wg *sync.WaitGroup, queues []queue.Queue, proc process.Processor, trans transform.TransformationFunc)

Types

type Config

type Config struct {
	Type        string `koanf:"type"`
	Concurrency int    `koanf:"concurrency"`
}

type LaunchConfig

type LaunchConfig struct {
	Queues          []queue.Queue
	Poller          Poller
	Processor       process.Processor
	QueueCancelFunc context.CancelFunc
	TransformFunc   transform.TransformationFunc
	Concurrency     int
}

type Poller

type Poller func(ctx context.Context, wg *sync.WaitGroup, queues []queue.Queue, proc process.Processor, trans transform.TransformationFunc)

func New

func New(poller string) (Poller, error)