spooler

Documentation

Index

• func StartSpooler(c SpoolerConfig, es v1.Eventstore, view *view.View, sql *sql.DB, ...) *spooler.Spooler
• type SpoolerConfig

Functions

func StartSpooler

func StartSpooler(c SpoolerConfig, es v1.Eventstore, view *view.View, sql *sql.DB, static static.Storage) *spooler.Spooler

Types

type SpoolerConfig

type SpoolerConfig struct {
	BulkLimit             uint64
	FailureCountUntilSkip uint64
	ConcurrentWorkers     int
	ConcurrentInstances   int
	Handlers              handler.Configs
}