stream

Documentation

Index

• func NewConsumer(ctx *mq.AppContext, options ...Option) mq.IConsumer
• type Option
  • func ConsumeGroupInfo(group, name, readMsgIndex string) Option
  • func HeartbeatInterval(duration time.Duration) Option
  • func MaxTryReconnectTimes(times uint32) Option
  • func ReconnectInterval(duration time.Duration) Option
  • func RedisAuth(user, pwd string) Option
  • func RedisDB(db int) Option

Functions

func NewConsumer

func NewConsumer(ctx *mq.AppContext, options ...Option) mq.IConsumer

Types

type Option

type Option func(o *option)

func ConsumeGroupInfo

func ConsumeGroupInfo(group, name, readMsgIndex string) Option

func HeartbeatInterval

func HeartbeatInterval(duration time.Duration) Option

less than 1s uses the server's interval

func MaxTryReconnectTimes

func MaxTryReconnectTimes(times uint32) Option

default 10,0 means no limit,The maximum number of reconnections allowed after disconnection

func ReconnectInterval

func ReconnectInterval(duration time.Duration) Option

default 10s,reconnection interval

func RedisAuth

func RedisAuth(user, pwd string) Option

func RedisDB

func RedisDB(db int) Option