runnerq

package module

Go to main page

Versions in this module

v0

v0.5.1

Sep 17, 2026

v0.5.0

Sep 16, 2026

Changes in this version

+ func NameOf[T any]() string

type WorkerEngine

+ func (e *WorkerEngine) RegisterActivityWithName(activityType string, handler ActivityHandler)

v0.4.0

Jun 15, 2026

v0.3.0

Jun 13, 2026

Changes in this version

+ func IsActivityNotFound(err error) bool

+ func SignalActivityByKey(ctx context.Context, backend storage.Storage, activityType string, ...) error

type WorkerEngine

+ func (e *WorkerEngine) SignalByKey(ctx context.Context, activityType string, idempotencyKey string, name string, ...) error

type WorkerErrorKind

+ const ErrActivityNotFoundW

v0.2.0

Jun 13, 2026

Changes in this version

+ func IsSignalTimeout(err error) bool

+ func SignalActivity(ctx context.Context, backend storage.Storage, activityID uuid.UUID, ...) error

+ func WaitAll(ctx context.Context, futures ...*ActivityFuture) ([]json.RawMessage, error)

type ActivityBuilder

+ func (b *ActivityBuilder) Step(name string) *ActivityBuilder

type ActivityContext

+ func (c ActivityContext) Run(name string, fn func() (json.RawMessage, error)) (json.RawMessage, error)

+ func (c ActivityContext) Sleep(name string, d time.Duration) error

+ func (c ActivityContext) WaitForSignal(name string, timeout time.Duration) (json.RawMessage, error)

type ActivityFuture

+ func FutureFor(backend storage.Storage, activityID uuid.UUID) *ActivityFuture

+ func (f *ActivityFuture) ActivityID() uuid.UUID

+ type RetentionConfig struct

+ BatchSize int

+ Completed time.Duration

+ Failed time.Duration

+ Interval time.Duration

type WorkerConfig

+ Retention *RetentionConfig

type WorkerEngine

+ func (e *WorkerEngine) Signal(ctx context.Context, activityID uuid.UUID, name string, ...) error

type WorkerEngineBuilder

+ func (b *WorkerEngineBuilder) Retention(cfg RetentionConfig) *WorkerEngineBuilder

type WorkerErrorKind

+ const ErrSignalTimeoutW

v0.1.3

May 25, 2026

v0.1.2

May 15, 2026

v0.1.1

May 15, 2026

v0.1.0

May 15, 2026

Changes in this version

+ const DefaultMaxActivityDepth

+ type ActivityBuilder struct

+ func (b *ActivityBuilder) AsRoot() *ActivityBuilder

+ func (b *ActivityBuilder) Delay(d time.Duration) *ActivityBuilder

+ func (b *ActivityBuilder) Execute(ctx context.Context) (*ActivityFuture, error)

+ func (b *ActivityBuilder) IdempotencyKeyOption(key string, behavior OnDuplicate) *ActivityBuilder

+ func (b *ActivityBuilder) MaxRetries(retries uint32) *ActivityBuilder

+ func (b *ActivityBuilder) MaxRetryDelay(d time.Duration) *ActivityBuilder

+ func (b *ActivityBuilder) Metadata(key, value string) *ActivityBuilder

+ func (b *ActivityBuilder) MetadataMap(metadata map[string]string) *ActivityBuilder

+ func (b *ActivityBuilder) Payload(payload json.RawMessage) *ActivityBuilder

+ func (b *ActivityBuilder) Priority(p ActivityPriority) *ActivityBuilder

+ func (b *ActivityBuilder) Timeout(d time.Duration) *ActivityBuilder

+ type ActivityContext struct

+ ActivityExecutor ActivityExecutor

+ ActivityID uuid.UUID

+ ActivityType string

+ Ctx context.Context

+ Depth uint16

+ Metadata map[string]string

+ ParentActivityID *uuid.UUID

+ RetryCount uint32

+ RootActivityID uuid.UUID

+ type ActivityError struct

+ Message string

+ Retryable bool

+ func NewNonRetryError(msg string) *ActivityError

+ func NewRetryError(msg string) *ActivityError

+ func (e *ActivityError) Error() string

+ func (e *ActivityError) IsRetryable() bool

+ type ActivityExecutor interface

+ Activity func(activityType string) *ActivityBuilder

+ type ActivityFuture struct

+ func (f *ActivityFuture) GetResult(ctx context.Context) (json.RawMessage, error)

+ type ActivityHandler interface

+ ActivityType func() string

+ Handle func(ctx ActivityContext, payload json.RawMessage) (json.RawMessage, error)

+ OnDeadLetter func(ctx ActivityContext, payload json.RawMessage, errorMsg string)

+ type ActivityOption struct

+ DelaySeconds *uint64

+ IdempotencyKey *IdempotencyConfig

+ MaxRetries uint32

+ MaxRetryDelaySeconds *uint64

+ Metadata map[string]string

+ Priority *ActivityPriority

+ TimeoutSeconds uint64

+ type ActivityPriority int

+ const PriorityCritical

+ const PriorityHigh

+ const PriorityLow

+ const PriorityNormal

+ func (p *ActivityPriority) UnmarshalJSON(data []byte) error

+ func (p ActivityPriority) MarshalJSON() ([]byte, error)

+ func (p ActivityPriority) String() string

+ type ActivityStatus string

+ const StatusCompleted

+ const StatusDeadLetter

+ const StatusFailed

+ const StatusPending

+ const StatusRetrying

+ const StatusRunning

+ type DefaultDeadLetterHandler struct

+ func (DefaultDeadLetterHandler) OnDeadLetter(_ ActivityContext, _ json.RawMessage, _ string)

+ type IdempotencyConfig struct

+ Behavior OnDuplicate

+ Key string

+ type MetricsSink interface

+ IncCounter func(name string, value uint64)

+ ObserveDuration func(name string, dur time.Duration)

+ type NoopMetrics struct

+ func (NoopMetrics) IncCounter(_ string, _ uint64)

+ func (NoopMetrics) ObserveDuration(_ string, _ time.Duration)

+ type OnDuplicate int

+ const AllowReuse

+ const AllowReuseOnFailure

+ const NoReuse

+ const ReturnExisting

+ type ResultState int

+ const ResultErr

+ const ResultOk

+ type RetryableError interface

+ IsRetryable func() bool

+ type WorkerConfig struct

+ ActivityTypes []string

+ LeaseMS *uint64

+ MaxActivityDepth uint16

+ MaxConcurrentActivities int

+ QueueName string

+ ReaperBatchSize *int

+ ReaperIntervalSeconds *uint64

+ SchedulePollIntervalSeconds *uint64

+ ShutdownGraceSeconds *uint64

+ SuspendLeafActivityTypes []string

+ SuspendLeavesReserved int

+ SuspendOnAwait bool

+ func DefaultWorkerConfig() WorkerConfig

+ type WorkerEngine struct

+ func NewWorkerEngineWithBackend(backend storage.Storage, config WorkerConfig) *WorkerEngine

+ func (e *WorkerEngine) Backend() storage.Storage

+ func (e *WorkerEngine) GetActivityExecutor() ActivityExecutor

+ func (e *WorkerEngine) MaxConcurrentActivities() int

+ func (e *WorkerEngine) RegisterActivity(activityType string, handler ActivityHandler)

+ func (e *WorkerEngine) SetMetrics(sink MetricsSink)

+ func (e *WorkerEngine) Start(ctx context.Context) error

+ func (e *WorkerEngine) Stop()

+ type WorkerEngineBuilder struct

+ func Builder() *WorkerEngineBuilder

+ func (b *WorkerEngineBuilder) ActivityTypes(types []string) *WorkerEngineBuilder

+ func (b *WorkerEngineBuilder) Backend(backend storage.Storage) *WorkerEngineBuilder

+ func (b *WorkerEngineBuilder) Build() (*WorkerEngine, error)

+ func (b *WorkerEngineBuilder) MaxWorkers(max int) *WorkerEngineBuilder

+ func (b *WorkerEngineBuilder) Metrics(sink MetricsSink) *WorkerEngineBuilder

+ func (b *WorkerEngineBuilder) QueueName(name string) *WorkerEngineBuilder

+ func (b *WorkerEngineBuilder) ReserveSlotsForLeaves(n int, leafTypes []string) *WorkerEngineBuilder

+ func (b *WorkerEngineBuilder) SchedulePollInterval(interval time.Duration) *WorkerEngineBuilder

+ func (b *WorkerEngineBuilder) ShutdownGrace(d time.Duration) *WorkerEngineBuilder

+ func (b *WorkerEngineBuilder) SuspendOnAwait(enabled bool) *WorkerEngineBuilder

+ type WorkerEngineWrapper struct

+ func (w *WorkerEngineWrapper) Activity(activityType string) *ActivityBuilder

+ type WorkerError struct

+ Cause error

+ Kind WorkerErrorKind

+ Message string

+ func IsWorkerError(err error) (*WorkerError, bool)

+ func WorkerErrorFromStorage(err error) *WorkerError

+ func (e *WorkerError) Error() string

+ func (e *WorkerError) IsRetryable() bool

+ func (e *WorkerError) Unwrap() error

+ type WorkerErrorKind int

+ const ErrAlreadyRunning

+ const ErrBackend

+ const ErrConfiguration

+ const ErrCustom

+ const ErrDatabase

+ const ErrDepthExceeded

+ const ErrDuplicateActivityW

+ const ErrExecution

+ const ErrHandlerNotFound

+ const ErrIdempotencyConflictW

+ const ErrQueue

+ const ErrScheduling

+ const ErrSerializationW

+ const ErrShutdown

+ const ErrTimeoutW

+ const ErrUnknown

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL