queue

Feb 12, 2025

Changes in this version

+ type Item struct

+ ID ItemID

+ Msg *models.MsgOut

+ TS int64

+ type ItemID string

+ type Outbox struct

+ ChannelUUID models.ChannelUUID

+ ChatID models.ChatID

+ func (q Outbox) String() string

+ type Outboxes struct

+ InstanceID string

+ KeyBase string

+ func (o *Outboxes) AddMessage(rc redis.Conn, ch *models.Channel, chatID models.ChatID, m *models.MsgOut) error

+ func (o *Outboxes) ReadReady(rc redis.Conn) (map[Outbox]*Item, error)

+ func (o *Outboxes) RecordSent(rc redis.Conn, ch *models.Channel, chatID models.ChatID, itemID ItemID) (bool, error)

+ func (o *Outboxes) SetReady(rc redis.Conn, ch *models.Channel, chatID models.ChatID, ready bool) error