redis

Documentation

Index

• Variables
• func PullFor[T any](ctx context.Context, app App, key string, handler func(T, error))
• func SubscribeFor[T any](ctx context.Context, app App, channel string, handler func(T, error)) func(context.Context) error
• type App
  • func New(config Config, prometheusRegisterer prometheus.Registerer, tracer trace.Tracer) App
  • func (a App) Delete(ctx context.Context, keys ...string) error
  • func (a App) DeletePattern(ctx context.Context, pattern string) 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) Load(ctx context.Context, key string) ([]byte, error)
  • func (a App) LoadMany(ctx context.Context, keys ...string) ([]string, error)
  • func (a App) Ping() error
  • func (a App) Publish(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 Config
  • func Flags(fs *flag.FlagSet, prefix string, overrides ...flags.Override) Config

Variables

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

Functions

func PullFor

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

func SubscribeFor

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

Types

type App

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

func New

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

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) 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) 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() error

func (App) Publish

func (a App) Publish(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 Config

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

func Flags

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