Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Options ¶
type Options struct {
WorkerCount uint `` /* 188-byte string literal not displayed */
WorkerQueueBuffer uint `` /* 182-byte string literal not displayed */
BatchSize uint `` /* 132-byte string literal not displayed */
EnableDebug bool `long:"outburst-debug" env:"OUTBURST_DEBUG" description:"Enable outburst debug logging."`
}
Options wires the outburst outbox consumer into the startup framework and exposes its tunables as command line flags. Zero values fall back to the library defaults (4 workers, 128 queue buffer, 128 batch size).
func (*Options) Initialize ¶
func (o *Options) Initialize( ctx context.Context, base sb.BaseOptions, kafka startup_kafka.KafkaOptions, pg *startup_postgres.PostgresOptions, )
Initialize creates the outbox table and starts the outburst background task.
Source Files
Click to show internal directories.
Click to hide internal directories.