mqlib

Sep 10, 2024

Changes in this version

+ const DEFAULT_MAX_RECONSUME

Jun 3, 2024

Changes in this version

+ const BROKER_ADDR_ENV

May 24, 2024

Changes in this version

+ const DEFAULT_RETRY

+ const DefaultRpcTTL

+ const MSG_IDS_CACHE_EX

+ var ErrFetchFailed = errors.New("failed to fetch msg")

+ var ErrMisformedMsg = errors.New("input msg is invalid")

+ var ErrMsgTimeout = errors.New("msg timeout")

+ var ErrNewTopicAfterStart = errors.New("add new topic after consumer started")

+ var ErrReachedLimit = errors.New("reached concurrent limit")

+ var ErrSendFailed = errors.New("failed to send msg")

+ func CreateTopic(nsName string, topics ...string) (err error)

+ func GetTTLFromContext(ctx context.Context) (ttl time.Duration)

+ func GetUniqKey() string

+ type Consumer struct

+ GroupName string

+ func NewConsumer(gpName, nsName string, broadcast bool, topics ...Topic) (c *Consumer, err error)

+ func (c *Consumer) SetDeDup(on bool)

+ func (c *Consumer) Shutdown()

+ func (c *Consumer) UnsubscribeTopic(topic string) error

+ type GenericClient interface

+ func NewGenericClient(nameServer, app string, subDispatcher SubDispatcher, ttl time.Duration, ...) (gc GenericClient, err error)

+ type Message struct

+ Body []byte

+ Id string

+ Keys []string

+ RemoteApp string

+ Tag string

+ Topic string

+ func (m *Message) ToRkMessage() *primitive.Message

+ func (m *Message) ToString() string

+ type Producer struct

+ GroupName string

+ func NewProducer(gpName, nsName string) (p *Producer, err error)

+ func (p *Producer) Shutdown()

+ type PubClient interface

+ GetPub func() *Producer

+ Request func(msg *Message, ctx ...context.Context) (resp *Message, err error)

+ RequestAsync func(msg *Message, out chan *Message, ctx ...context.Context) error

+ RequestAsyncWithFunc func(msg *Message, callback RpcCallback, ctx ...context.Context) error

+ SendMessage func(msg *Message) error

+ SetRpcTimeout func(ttl time.Duration)

+ func NewClient(nameServer, app string, ttl ...time.Duration) (pc PubClient, err error)

+ type PubSubClient interface

+ func NewPubSubClient(nameServer, consumerGroup string, topics ...Topic) (psc PubSubClient, err error)

+ type RpcCallback = func(msg *Message)

+ type RpcSrvClient interface

+ Respond func(msg *Message) error

+ func NewSrvClient(nameServer, app string, subDispatcher SubDispatcher) (rsc RpcSrvClient, err error)

+ type SubCallback = func(msg *Message) error

+ type SubClient interface

+ GetSub func() *Consumer

+ SetDeDup func(bool)

+ func NewBroadcastSubClient(nameServer, consumerGroup string, topics ...Topic) (sc SubClient, err error)

+ func NewSubClient(nameServer, consumerGroup string, topics ...Topic) (sc SubClient, err error)

+ type SubDispatcher interface

+ ProcessMsg func(msg *Message) error

+ type Topic struct

+ Callback SubCallback

+ Name string

+ Tags []string