Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MessageQueue ¶
type MessageQueue struct {
*redis.Client
}
func NewMessageQueue ¶
func NewMessageQueue(redisAddr string) *MessageQueue
func (*MessageQueue) AddTelegramMsg ¶
func (m *MessageQueue) AddTelegramMsg(ctx context.Context, msg schema.TelegramMsg) error
func (*MessageQueue) GetTelegramMsg ¶
func (m *MessageQueue) GetTelegramMsg(ctx context.Context, queueName string) (schema.TelegramMsg, error)
Source Files
Click to show internal directories.
Click to hide internal directories.