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)) (<-chan struct{}, func(context.Context) error)
• type App
  • func (a *App) Close()
  • func (a *App) Delete(ctx context.Context, keys ...string) (err 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, ttl time.Duration, keys ...string) 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) Pipeline() redis.Pipeliner
  • func (a App) Publish(ctx context.Context, channel string, value any) (err 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, tracer trace.TracerProvider) (Client, error)
• 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)) (<-chan struct{}, func(context.Context) error)

Types

type App

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

func (*App) Close

func (a *App) Close()

func (*App) Delete

func (a *App) Delete(ctx context.Context, keys ...string) (err 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, ttl time.Duration, keys ...string) 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) Pipeline

func (a *App) Pipeline() redis.Pipeliner

func (App) Publish

func (a App) Publish(ctx context.Context, channel string, value any) (err 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
	Close()
	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, ttl time.Duration, keys ...string) 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)
	Pipeline() redis.Pipeliner
}

func New

func New(config Config, tracer trace.TracerProvider) (Client, error)

type Config

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

func Flags

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