Versions in this module Expand all Collapse all v1 v1.2.0 Dec 24, 2023 Changes in this version + type CompletionMode int8 + const DeleteCompletionMode + const UpdateCompletionMode type Config + CompletionMode CompletionMode v1.1.0 Dec 21, 2023 Changes in this version + type Config struct + BatchSize int + BrokerUrls string + DatabaseUrl string + PollInterval int + Topics []string + type Operator interface + Close func(ctx context.Context) + Execute func(ctx context.Context) error + func NewOperator(ctx context.Context, config *Config) (Operator, error)
Go to main page