Versions in this module Expand all Collapse all v0 v0.0.2 Oct 10, 2024 Changes in this version type ConfigFunc + func WithSerializer(in func(v any) ([]byte, error), out func(data []byte) (any, error)) ConfigFunc type QueueConfig + Deserialize func([]byte) (any, error) + Serialize func(any) ([]byte, error) v0.0.1 Oct 8, 2024 Changes in this version + func New[J queue.Job](name string, conn ConnexionConfig, c ...ConfigFunc) queue.Queue[J] + type Config = struct + Config QueueConfig + Name string + Redis ConnexionConfig + type ConfigFunc = func(q *QueueConfig) + func WithPollDuration(duration time.Duration) ConfigFunc + func WithPrefetchLimit(limit int64) ConfigFunc + func WithTimeout(t time.Duration) ConfigFunc + type ConnexionConfig = struct + DB int + Host string + Password string + Port string + Prefix string + Username string + type QueueConfig = struct + PollDuration time.Duration + PrefetchLimit int64 + Timeout time.Duration + func DefaultConfig() QueueConfig
Go to main page