redis

Documentation

Index

• 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) Exclusive(ctx context.Context, name string, timeout time.Duration, ...) (acquired bool, err error)
  • func (a App) Load(ctx context.Context, key string) (string, error)
  • func (a App) Ping() error
  • func (a App) Store(ctx context.Context, key string, value any, duration time.Duration) error
• type Config
  • func Flags(fs *flag.FlagSet, prefix string, overrides ...flags.Override) Config

Types

type App

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

App of package

func New

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

New creates new App from Config

func (App) Delete

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

Delete given keys

func (App) Exclusive

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

Exclusive get an exclusive lock for given name during duration

func (App) Load

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

Load given key

func (App) Ping

func (a App) Ping() error

Ping check redis availability

func (App) Store

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

Store give key/val with duration

type Config

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

Config of package

func Flags

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

Flags adds flags for configuring package