Versions in this module Expand all Collapse all v1 v1.0.0 Jun 12, 2026 Changes in this version + var ErrConnectionFailed = errors.New("connection to storage failed") + var ErrHandlerNotFound = errors.New("handler not found for topic") + var ErrInvalidConfig = errors.New("invalid configuration") + var ErrInvalidPayload = errors.New("invalid payload") + var ErrInvalidScheduleTime = errors.New("invalid schedule time") + var ErrInvalidStorageType = errors.New("invalid storage type") + var ErrInvalidTopic = errors.New("invalid topic name") + var ErrQueueEmpty = errors.New("queue is empty") + var ErrQueueFull = errors.New("queue is full") + var ErrStorageFull = errors.New("storage is full") + var ErrStorageTimeout = errors.New("storage operation timeout") + var ErrTaskAlreadyComplete = errors.New("task already completed") + var ErrTaskAlreadyExists = errors.New("task already exists") + var ErrTaskNotFound = errors.New("task not found") + var ErrWorkerPoolFull = errors.New("worker pool is full") + var ErrWorkerTimeout = errors.New("worker execution timeout") + type Config struct + BatchSize int + DashboardAddr string + DashboardAuth bool + DashboardPass string + DashboardUser string + FailedRetention time.Duration + MaxRetries int + MemoryLimit int64 + RetryBackoff time.Duration + RetryMaxDelay time.Duration + RingBufferSize int + StorageDSN string + StorageType string + TaskRetention time.Duration + VisibilityTimeout time.Duration + WorkerBatchSize int + WorkerCount int + func DefaultConfig() *Config + func (c *Config) Validate() error + type Option func(*Config) + func WithDashboard(addr string) Option + func WithMaxRetries(retries int) Option + func WithStorage(dsn string) Option + func WithWorkerCount(count int) Option + type Relay struct + func New(opts ...Option) *Relay + func (r *Relay) EnableDashboard(addr string) + func (r *Relay) Enqueue(topic string, payload interface{}) (string, error) + func (r *Relay) Register(topic string, fn registry.HandlerFunc, payloadType interface{}) error + func (r *Relay) Schedule(executeAt time.Time, topic string, payload interface{}) (string, error) + func (r *Relay) Shutdown(ctx context.Context) error + func (r *Relay) Start() error + type RelayError struct + Err error + Op string + func (e *RelayError) Error() string + func (e *RelayError) Unwrap() error
Go to main page