Versions in this module Expand all Collapse all v0 v0.1.0 Apr 7, 2026 Changes in this version + const DefaultMaxRetries + const DefaultPollBatchSize + const DefaultPollBlock + const DefaultRetryBaseDelay + var ErrDuplicateSubscription = core.ErrDuplicateSubscription + var ErrInvalidConsumerConfig = core.ErrInvalidConsumerConfig + type Bus = core.Bus + func NewBus(rt Runtime, opts ...Option) *Bus + type Codec = core.Codec + type Config = core.Config + type ConsumerConfig = core.ConsumerConfig + type DeadLetterMessage = core.DeadLetterMessage + type Handler = core.Handler + type Message = core.Message + type Observer = core.Observer + type Option = core.Option + func WithCloseRuntime(close bool) Option + func WithCodec(codec Codec) Option + func WithObserver(observer Observer) Option + func WithRetryPollInterval(interval time.Duration) Option + type PublishOption = core.PublishOption + func WithHeaders(headers map[string]string) PublishOption + func WithMessageID(id string) PublishOption + type PublishOptions = core.PublishOptions + type RedisRuntime = redisruntime.RedisRuntime + func NewRedisRuntime(client *redis.Client, cfg RedisRuntimeConfig) *RedisRuntime + type RedisRuntimeConfig = redisruntime.Config + type RetryTask = core.RetryTask + type Runtime = core.Runtime
Go to main page