operator

Documentation

Index

• type CompletionMode
• type Config
• type Operator
  • func NewOperator(ctx context.Context, config *Config) (Operator, error)

Types

type CompletionMode

type CompletionMode int8

const (
	UpdateCompletionMode CompletionMode = iota
	DeleteCompletionMode
)

type Config

type Config struct {
	// Interval between consumer polls
	PollInterval int
	// Number of events to attempt to fetch on each
	// interval
	BatchSize int
	// Postgres connection url
	DatabaseUrl string
	// Comma-separated set of bootstrap urls
	BrokerUrls string
	// List of topics to subscribe to
	Topics []string
	// Defines how gox should handle completed events.
	CompletionMode CompletionMode
}

type Operator

type Operator interface {
	Execute(ctx context.Context) error
	Close(ctx context.Context)
}

func NewOperator

func NewOperator(ctx context.Context, config *Config) (Operator, error)