redis

Documentation

Index

• type MessageQueue
  • func NewRedisClient() (*MessageQueue, error)
  • func (m *MessageQueue) PopMessageFromQueue(queueName string) (string, error)
  • func (m *MessageQueue) PushMessageToQueue(queueName string, message string) error

Types

type MessageQueue

type MessageQueue struct {
	Client *redis.Client
}

func NewRedisClient

func NewRedisClient() (*MessageQueue, error)

func (*MessageQueue) PopMessageFromQueue

func (m *MessageQueue) PopMessageFromQueue(queueName string) (string, error)

func (*MessageQueue) PushMessageToQueue

func (m *MessageQueue) PushMessageToQueue(queueName string, message string) error