dagoperator

Aug 20, 2026

Changes in this version

+ type DAGOperatorOpt func(*DAGOperator)

+ func WithSlots(defaultSlots int) DAGOperatorOpt

Aug 20, 2026

Changes in this version

+ func SlotConfig(op *sqlcv1.V1Operator) (map[string]int32, error)

+ type DAGOperator struct

+ func NewDAGOperator(op *sqlcv1.V1Operator, l *zerolog.Logger, repo repository.Repository, ...) (*DAGOperator, error)

+ func (d *DAGOperator) Cleanup()

+ func (d *DAGOperator) Drain()

+ func (d *DAGOperator) HandleAction(ctx context.Context, action *contracts.AssignedAction) error

+ type DAGOperatorConfig struct

+ Slots int