redis_outbox

Documentation

Index

• type RedisOutbox
  • func MustCreate(client *redis.Client, name, instance string) *RedisOutbox
  • func (ro *RedisOutbox) Add(data dto.MessageID) error
  • func (ro *RedisOutbox) IsEmpty() bool
  • func (ro *RedisOutbox) Pop() dto.MessageID

Types

type RedisOutbox

type RedisOutbox struct {
	// contains filtered or unexported fields
}

func MustCreate

func MustCreate(client *redis.Client, name, instance string) *RedisOutbox

MustCreate создание структуры с клиентом для взаимодействия с Redis. При ошибке соединения с сервером Redis выводит ошибку в лог и прекращает работу приложения.

func (*RedisOutbox) Add

func (ro *RedisOutbox) Add(data dto.MessageID) error

Add добавляет сообщение и идентификатор в список.

func (*RedisOutbox) IsEmpty

func (ro *RedisOutbox) IsEmpty() bool

IsEmpty возвращает true, если outbox пуст.

func (*RedisOutbox) Pop

func (ro *RedisOutbox) Pop() dto.MessageID

Pop извлекает сообщение и идентификатор из списка. Если список пуст, возвращает пустую структуру.