broker

Sep 7, 2022

Changes in this version

type Option

+ func WithConsumerAutoCommitInterval(interval time.Duration) Option

Sep 7, 2022

Changes in this version

type Options

+ ConsumerAutoCommitInterval time.Duration

type SubOption

+ func WithCommitOffsetBlock() SubOption

type SubscribeOptions

+ CommitOffsetBlock bool

Jun 22, 2022

Changes in this version

type SubOption

+ func WithSubKeyHandlers(keyHandlers map[string]SubHandler) SubOption

type SubscribeOptions

+ KeyHandlers map[string]SubHandler

Jun 15, 2022

Changes in this version

type SubOption

+ func WithSubRemainHandler(handler SubHandler) SubOption

type SubscribeOptions

+ RemainHandler SubHandler

Jun 15, 2022

Changes in this version

type SubOption

+ func WithMessageKey(key string) SubOption

type SubscribeOptions

+ MessageKey string

May 14, 2022

Changes in this version

+ var DummyLogger = LoggerFunc(func(string, ...interface{}) { ... })

+ func ParseMessage(msg interface{}) ([]byte, error)

+ func Recovery(logger Logger)

+ type Broker interface

+ Publish func(ctx context.Context, topic string, msg interface{}, opts ...PubOption) error

+ Shutdown func(ctx context.Context) error

+ Subscribe func(ctx context.Context, topic string, channel string, subHandler SubHandler, ...) error

+ type Logger interface

+ Printf func(string, ...interface{})

+ type LoggerFunc func(string, ...interface{})

+ func (f LoggerFunc) Printf(msg string, args ...interface{})

+ type Option func(o *Options)

+ func WithAuthToken(token string) Option

+ func WithBrokerAddress(addrs ...string) Option

+ func WithBrokerPrefix(prefix string) Option

+ func WithConnectionTimeout(t time.Duration) Option

+ func WithGracefulWait(t time.Duration) Option

+ func WithListenerName(name string) Option

+ func WithLogger(logger Logger) Option

+ func WithMaxConnectionsPerBroker(num int) Option

+ func WithNoDataWaitSec(sec int) Option

+ func WithOperationTimeout(t time.Duration) Option

+ func WithPassword(pwd string) Option

+ func WithRedisConf(conf *RedisConf) Option

+ func WithUser(user string) Option

+ type Options struct

+ Addrs []string

+ AuthToken string

+ ConnectionTimeout time.Duration

+ GracefulWait time.Duration

+ ListenerName string

+ Logger Logger

+ MaxConnectionsPerBroker int

+ NoDataWaitSec int

+ OperationTimeout time.Duration

+ Password string

+ Prefix string

+ RedisConf *RedisConf

+ User string

+ type PubOption func(p *PublishOptions)

+ func WithDisableBatching() PubOption

+ func WithPublishDelay(t time.Duration) PubOption

+ func WithPublishName(name string) PubOption

+ func WithSendTimeout(t time.Duration) PubOption

+ type PublishOptions struct

+ DisableBatching bool

+ Name string

+ PublishDelay time.Duration

+ SendTimeout time.Duration

+ type RedisConf struct

+ Address string

+ DB int

+ DialTimeout time.Duration

+ IdleTimeout time.Duration

+ MaxConnAge time.Duration

+ MaxRetries int

+ MinIdleConns int

+ Password string

+ PoolSize int

+ PoolTimeout time.Duration

+ ReadTimeout time.Duration

+ WriteTimeout time.Duration

+ type SubHandler func(ctx context.Context, data []byte) error

+ type SubOption func(s *SubscribeOptions)

+ func WithMessageChannel() SubOption

+ func WithMessageChannelSize(size int) SubOption

+ func WithSubConcurrencySize(size int) SubOption

+ func WithSubInterval(t time.Duration) SubOption

+ func WithSubName(name string) SubOption

+ func WithSubOffset(offset int64) SubOption

+ func WithSubRetryEnable() SubOption

+ func WithSubType(t SubscriptionType) SubOption

+ type SubscribeOptions struct

+ ConcurrencySize int

+ MessageChannel bool

+ MessageChannelSize int

+ Name string

+ Offset int64

+ ReceiverQueueSize int

+ RetryEnable bool

+ SubInterval time.Duration

+ SubType SubscriptionType

+ type SubscriptionType int

+ const Exclusive

+ const Failover

+ const KeyShared

+ const Shared