Versions in this module Expand all Collapse all v0 v0.1.0 May 7, 2026 Changes in this version + type Executor struct + func New(rootCtx context.Context, config ExecutorConfig) *Executor + func (e *Executor) Run(ctx context.Context, op *store.Operation) error + func (e *Executor) Wait(ctx context.Context) + type ExecutorConfig struct + Logger *zap.Logger + Metrics *monitoring.Metrics + NatsManager *nats.Manager + PgsqlManager *pgsql.Manager + Tracer trace.Tracer + type RunContext struct + Abort context.Context + Store context.Context + func NewRunContext(config RunContextConfig) *RunContext + func (rc *RunContext) Finish() + func (rc *RunContext) Reason() string + type RunContextConfig struct + Logger *zap.Logger + Metrics *monitoring.Metrics + NatsManager *nats.Manager + OpName string + ReqCtx context.Context + RootCtx context.Context + Tracer trace.Tracer
Go to main page