redis

Documentation

Index

• Variables
• func PullFor[T any](ctx context.Context, app Client, key string, handler func(T, error))
• func SubscribeFor[T any](ctx context.Context, app Client, channel string, handler func(T, error)) func(context.Context) error
• type App
  • func (a App) Delete(ctx context.Context, keys ...string) error
  • func (a App) DeletePattern(ctx context.Context, pattern string) (err error)
  • func (a App) Enabled() bool
  • func (a App) Exclusive(ctx context.Context, name string, timeout time.Duration, ...) (acquired bool, err error)
  • func (a App) Expire(ctx context.Context, key string, ttl time.Duration) error
  • func (a App) Load(ctx context.Context, key string) ([]byte, error)
  • func (a App) LoadMany(ctx context.Context, keys ...string) ([]string, error)
  • func (a App) Ping(ctx context.Context) error
  • func (a App) Publish(ctx context.Context, channel string, value any) error
  • func (a App) PublishJSON(ctx context.Context, channel string, value any) error
  • func (a App) Pull(ctx context.Context, key string, handler func(string, error))
  • func (a App) Push(ctx context.Context, key string, value any) error
  • func (a App) Scan(ctx context.Context, pattern string, output chan<- string, pageSize int64) error
  • func (a App) Store(ctx context.Context, key string, value any, duration time.Duration) error
  • func (a App) Subscribe(ctx context.Context, channel string) (<-chan *redis.Message, func(context.Context) error)
• type Client
  • func New(config Config, prometheusRegisterer prometheus.Registerer, tracer trace.Tracer) Client
• type Config
  • func Flags(fs *flag.FlagSet, prefix string, overrides ...flags.Override) Config

Variables

var ErrDisabled = errors.New("redis not enabled")

var ErrNoSubscriber = errors.New("no subscriber for channel")

Functions

func PullFor

func PullFor[T any](ctx context.Context, app Client, key string, handler func(T, error))

func SubscribeFor

func SubscribeFor[T any](ctx context.Context, app Client, channel string, handler func(T, error)) func(context.Context) error

Types

type App

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

func (App) Delete

func (a App) Delete(ctx context.Context, keys ...string) error

func (App) DeletePattern

func (a App) DeletePattern(ctx context.Context, pattern string) (err error)

func (App) Enabled

func (a App) Enabled() bool

func (App) Exclusive

func (a App) Exclusive(ctx context.Context, name string, timeout time.Duration, action func(context.Context) error) (acquired bool, err error)

func (App) Expire

func (a App) Expire(ctx context.Context, key string, ttl time.Duration) error

func (App) Load

func (a App) Load(ctx context.Context, key string) ([]byte, error)

func (App) LoadMany

func (a App) LoadMany(ctx context.Context, keys ...string) ([]string, error)

func (App) Ping

func (a App) Ping(ctx context.Context) error

func (App) Publish

func (a App) Publish(ctx context.Context, channel string, value any) error

func (App) PublishJSON

func (a App) PublishJSON(ctx context.Context, channel string, value any) error

func (App) Pull

func (a App) Pull(ctx context.Context, key string, handler func(string, error))

func (App) Push

func (a App) Push(ctx context.Context, key string, value any) error

func (App) Scan

func (a App) Scan(ctx context.Context, pattern string, output chan<- string, pageSize int64) error

func (App) Store

func (a App) Store(ctx context.Context, key string, value any, duration time.Duration) error

func (App) Subscribe

func (a App) Subscribe(ctx context.Context, channel string) (<-chan *redis.Message, func(context.Context) error)

type Client

type Client interface {
	Enabled() bool
	Ping(ctx context.Context) error
	Load(ctx context.Context, key string) ([]byte, error)
	LoadMany(ctx context.Context, keys ...string) ([]string, error)
	Store(ctx context.Context, key string, value any, ttl time.Duration) error
	Delete(ctx context.Context, keys ...string) error
	DeletePattern(ctx context.Context, pattern string) error
	Scan(ctx context.Context, pattern string, output chan<- string, pageSize int64) error
	Exclusive(ctx context.Context, name string, timeout time.Duration, action func(context.Context) error) (bool, error)
	Expire(ctx context.Context, key string, ttl time.Duration) error
	Push(ctx context.Context, key string, value any) error
	Pull(ctx context.Context, key string, handler func(string, error))
	Publish(ctx context.Context, channel string, value any) error
	PublishJSON(ctx context.Context, channel string, value any) error
	Subscribe(ctx context.Context, channel string) (<-chan *redis.Message, func(context.Context) error)
}

func New

func New(config Config, prometheusRegisterer prometheus.Registerer, tracer trace.Tracer) Client

type Config

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

func Flags

func Flags(fs *flag.FlagSet, prefix string, overrides ...flags.Override) Config