queue

Documentation

Index

• type Config
• type Queue
• type Redis
  • func (r Redis[T]) Pop(ctx context.Context, popRange int) ([]T, error)
  • func (r Redis[T]) Push(ctx context.Context, items ...T) error

Types

type Config

type Config struct {
	QueueName string
}

type Queue

type Queue[T any] interface {
	Push(ctx context.Context, items ...T) error
	Pop(ctx context.Context, popRange int) ([]T, error)
}

type Redis

type Redis[T any] struct {
	QueueConfig Config
	Client      redis.UniversalClient
	Codec       codec.Msgpack
}

func (Redis[T]) Pop

func (r Redis[T]) Pop(ctx context.Context, popRange int) ([]T, error)

func (Redis[T]) Push

func (r Redis[T]) Push(ctx context.Context, items ...T) error