Versions in this module Expand all Collapse all v1 v1.14.2 Feb 25, 2025 Changes in this version + type AbstractPartition struct + Logger logger.Logger + Stream *AbstractStream + Worker *worker.Worker + func NewAbstractPartition(logger logger.Logger, stream *AbstractStream) (*AbstractPartition, error) + type AbstractStream struct + func NewAbstractStream(parentLogger logger.Logger, workerAllocator worker.Allocator, ...) (*AbstractStream, error) + func (as *AbstractStream) GetConfig() map[string]interface{} + func (as *AbstractStream) Initialize() error + func (as *AbstractStream) Start(checkpoint functionconfig.Checkpoint) error + func (as *AbstractStream) Stop(force bool) (functionconfig.Checkpoint, error) + type Configuration struct + func NewConfiguration(id string, triggerConfiguration *functionconfig.Trigger, ...) (*Configuration, error) + type Event struct + type Partition interface + Read func() error + type Stream interface + CreatePartitions func() ([]Partition, error) + Start func(checkpoint functionconfig.Checkpoint) error + Stop func(force bool) (functionconfig.Checkpoint, error)
Go to main page