pubsub

type Helper[T any] struct {
	// contains filtered or unexported fields
}

type Options struct {
	Subscriptions  []string
	Concurrency    int64         // Max concurrent workers
	Backoff        bool          // Enable backoff
	BackoffBase    time.Duration // Base backoff duration
	MaxBackoff     time.Duration // Max backoff duration
	RetryLimit     int           // Limit retries, -1 for infinite retries
	ProcessTimeout time.Duration // Timeout for processing messages
}

type Subscriber[T any] struct {
	// contains filtered or unexported fields
}