Versions in this module Expand all Collapse all v0 v0.35.1 Feb 18, 2026 v0.35.0 Feb 18, 2026 Changes in this version + func GenerateTaskID() string + func GenerateTaskKey(taskID string) string + func ParseTimestampFromKey(key string) (int64, error) + type Consumer struct + func NewConsumer(ctx context.Context, bucket *blob.Bucket, messageFormat worker.MessageFormat, ...) (*Consumer, error) + func (c *Consumer) Consume(handler worker.TaskHandlerFunc) error + type Option func(*config) + func WithIntervalExpFactor(factor float64) Option + func WithMaxInterval(interval time.Duration) Option + func WithMaxItemsToReadAtOnce(maxItems int) Option + func WithMinInterval(interval time.Duration) Option + func WithPrefix(prefix string) Option + func WithProcessingTimeout(timeout time.Duration) Option + func WithRetryAttempts(attempts int) Option + type Publisher struct + func NewPublisher(bucket *blob.Bucket, messageFormat worker.MessageFormat, opts ...Option) (*Publisher, error) + func (p *Publisher) Publish(task *worker.Task) error + func (p *Publisher) PublishWithRetry(task *worker.Task) error
Go to main page