Versions in this module Expand all Collapse all v0 v0.0.1 Feb 9, 2021 Changes in this version + type Config interface + Authenticate func(login, passcode string) bool + HeartBeat func() time.Duration + type Conn struct + func NewConn(config Config, rw net.Conn, ch chan Request) *Conn + func (c *Conn) Send(f *frame.Frame) + func (c *Conn) SendError(err error) + type Request struct + Conn *Conn + Frame *frame.Frame + Op RequestOp + Sub *Subscription + type RequestOp int + const ConnectedOp + const DisconnectedOp + const EnqueueOp + const RequeueOp + const SubscribeOp + const UnsubscribeOp + func (r RequestOp) String() string + type Subscription struct + func (s *Subscription) Ack() string + func (s *Subscription) Destination() string + func (s *Subscription) Id() string + func (s *Subscription) IsAckedBy(msgId uint64) bool + func (s *Subscription) IsNackedBy(msgId uint64) bool + func (s *Subscription) SendQueueFrame(f *frame.Frame) + func (s *Subscription) SendTopicFrame(f *frame.Frame) + type SubscriptionList struct + func NewSubscriptionList() *SubscriptionList + func (sl *SubscriptionList) Ack(msgId uint64, callback func(s *Subscription)) + func (sl *SubscriptionList) Add(sub *Subscription) + func (sl *SubscriptionList) FindByIdAndRemove(id string) *Subscription + func (sl *SubscriptionList) ForEach(callback func(s *Subscription, isLast bool)) + func (sl *SubscriptionList) Get() *Subscription + func (sl *SubscriptionList) Nack(msgId uint64, callback func(s *Subscription)) + func (sl *SubscriptionList) Remove(s *Subscription) Incompatible versions in this module v2.1.2+incompatible Jan 13, 2021
Go to main page