redis

Documentation

Index

• func New[J queue.Job](name string, conn ConnexionConfig, c ...ConfigFunc) queue.Queue[J]
• type Config
• type ConfigFunc
  • func WithPollDuration(duration time.Duration) ConfigFunc
  • func WithPrefetchLimit(limit int64) ConfigFunc
  • func WithSerializer(in func(v any) ([]byte, error), out func(data []byte) (any, error)) ConfigFunc
  • func WithTimeout(t time.Duration) ConfigFunc
• type ConnexionConfig
• type QueueConfig
  • func DefaultConfig() QueueConfig

Functions

func New

func New[J queue.Job](name string, conn ConnexionConfig, c ...ConfigFunc) queue.Queue[J]

Types

type Config

type Config = struct {
	Name   string
	Redis  ConnexionConfig
	Config QueueConfig
}

type ConfigFunc

type ConfigFunc = func(q *QueueConfig)

func WithPollDuration

func WithPollDuration(duration time.Duration) ConfigFunc

func WithPrefetchLimit

func WithPrefetchLimit(limit int64) ConfigFunc

func WithSerializer

func WithSerializer(in func(v any) ([]byte, error), out func(data []byte) (any, error)) ConfigFunc

func WithTimeout

func WithTimeout(t time.Duration) ConfigFunc

type ConnexionConfig

type ConnexionConfig = struct {
	Host     string
	Username string
	Password string
	Port     string
	DB       int
	Prefix   string
}

type QueueConfig

type QueueConfig = struct {
	PrefetchLimit int64         // default 10
	PollDuration  time.Duration // default 1s
	Timeout       time.Duration // default 5s
	Serialize     func(any) ([]byte, error)
	Deserialize   func([]byte) (any, error)
}

func DefaultConfig

func DefaultConfig() QueueConfig