aggregation

package

v0.1.11 Latest Latest Go to latest Published: Mar 11, 2026 License: Apache-2.0 Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Config struct {
	Store      *store.RedisStore
	Dispatcher *dispatcher.Dispatcher
	Group      types.GroupConfig
	Logger     gochainedlog.Logger
}

Config configures the group aggregation processor.

type Processor struct {
	// contains filtered or unexported fields
}

Processor periodically flushes ready groups and dispatches the aggregated tasks for processing.

func New(cfg Config) *Processor

New creates a new group aggregation processor.

func (p *Processor) Start(ctx context.Context)

Start begins the flush loop. Runs until context is cancelled.

func (p *Processor) Stop()

Stop halts the flush loop.