Versions in this module Expand all Collapse all v1 v1.14.2 Feb 25, 2025 Changes in this version + type AbstractPoller struct + func NewAbstractPoller(logger logger.Logger, workerAllocator worker.Allocator, ...) (*AbstractPoller, error) + func (ap *AbstractPoller) SetPoller(poller Poller) + func (ap *AbstractPoller) Start(checkpoint functionconfig.Checkpoint) error + func (ap *AbstractPoller) Stop(force bool) (functionconfig.Checkpoint, error) + type Configuration struct + IntervalMs int + MaxBatchSize int + MaxBatchWaitMs int + func NewConfiguration(id string, triggerConfiguration *functionconfig.Trigger, ...) (*Configuration, error) + type Poller interface + GetNewEvents func(chan nuclio.Event) error + PostProcessEvents func([]nuclio.Event, []interface{}, []error)
Go to main page