Versions in this module Expand all Collapse all v1 v1.0.0 Aug 26, 2026 Changes in this version + const MaxNameBytes + var ErrCallbackPanic = errors.New("queue service callback panicked") + var ErrInvalidOptions = errors.New("invalid queue service options") + var ErrInvalidPublishAcceptance = errors.New("queue service publish acceptance invalid") + var ErrMissingCorrelation = errors.New("queue service producer correlation missing") + var ErrPublishOutcomeUnknown = errors.New("queue service publish outcome unknown") + var ErrUnavailable = errors.New("queue service adapter unavailable") + var ErrWorkerExited = errors.New("queue service worker exited unexpectedly") + type CallbackError struct + Err error + Operation CallbackOperation + func (err *CallbackError) Error() string + func (err *CallbackError) Unwrap() error + type CallbackOperation uint8 + const CallbackAdmission + const CallbackHandler + const CallbackPublish + const CallbackReadiness + const CallbackRun + const CallbackShutdown + const CallbackStartup + type CallbackPanicError struct + Operation CallbackOperation + func (err *CallbackPanicError) Error() string + func (err *CallbackPanicError) Unwrap() error + type Check func(context.Context, R) error + type CloseAdmission func(R) error + type Handler func(context.Context, core.TaskMessage) error + func NewHandler(options HandlerOptions) (Handler, error) + type HandlerOptions struct + Correlation *correlation.Factory + CorrelationOptions queuecorrelation.Options + Handler Handler + TracePropagator propagation.TextMapPropagator + TrustedMetadata bool + type LifecycleWorker struct + func NewLifecycleWorker[R any](options LifecycleWorkerOptions[R]) (*LifecycleWorker[R], error) + func (worker *LifecycleWorker[R]) Plan() service.Plan + func (worker *LifecycleWorker[R]) Resource() R + type LifecycleWorkerOptions struct + CloseAdmission CloseAdmission[R] + Correlation *correlation.Factory + CorrelationOptions queuecorrelation.Options + Handler Handler + Name string + Readiness Check[R] + Resource R + Run Run[R] + Shutdown Shutdown[R] + Startup Startup[R] + TracePropagator propagation.TextMapPropagator + TrustedMetadata bool + type OptionsError struct + Field string + Reason string + func (err *OptionsError) Error() string + func (err *OptionsError) Unwrap() error + type Producer struct + func NewProducer[R any](options ProducerOptions[R]) (*Producer[R], error) + func (producer *Producer[R]) Component() service.Component + func (producer *Producer[R]) Publish(ctx context.Context, message core.QueuedMessage, options ...job.AllowOption) (correlation.Values, error) + func (producer *Producer[R]) PublishWithAcceptance(ctx context.Context, message core.QueuedMessage, options ...job.AllowOption) (correlation.Values, PublishAcceptance, error) + func (producer *Producer[R]) Readiness() (service.ReadinessCheck, bool) + func (producer *Producer[R]) Resource() R + type ProducerOptions struct + Correlation *correlation.Factory + CorrelationOptions queuecorrelation.Options + Name string + Publish Publish[R] + PublishWithAcceptance PublishWithAcceptance[R] + Readiness Check[R] + Resource R + Shutdown Shutdown[R] + Startup Startup[R] + TracePropagator propagation.TextMapPropagator + type Publish func(context.Context, R, core.QueuedMessage, ...job.AllowOption) error + type PublishAcceptance uint8 + const PublishAccepted + const PublishNotAccepted + const PublishUnknown + type PublishError struct + Acceptance PublishAcceptance + Err error + func (err *PublishError) Error() string + func (err *PublishError) Unwrap() error + type PublishWithAcceptance func(context.Context, R, core.QueuedMessage, ...job.AllowOption) (PublishAcceptance, error) + type Run func(context.Context, R, Handler) error + type Shutdown func(context.Context, R) error + type Startup func(context.Context, R) error + type StartupError struct + Cleanup error + Validation error + func (err *StartupError) Error() string + func (err *StartupError) Unwrap() []error + type Worker struct + func NewWorker(options WorkerOptions) (*Worker, error) + func (worker *Worker) Component() service.Component + func (worker *Worker) Queue() *queue.Queue + type WorkerOptions struct + Name string + Queue *queue.Queue
Go to main page