redis

Documentation

Index

• Variables
• func PullFor[T any](ctx context.Context, client Client, key string, handler func(T, error))
• func SubscribeFor[T any](ctx context.Context, client Client, channel string, handler func(T, error)) (<-chan struct{}, func(context.Context) error)
• type Client
  • func New(config *Config, meter metric.MeterProvider, tracer trace.TracerProvider) (Client, error)
• type Config
  • func Flags(fs *flag.FlagSet, prefix string, overrides ...flags.Override) *Config
• type Noop
  • func (n Noop) Close()
  • func (n Noop) Delete(_ context.Context, _ ...string) error
  • func (n Noop) DeletePattern(_ context.Context, _ string) error
  • func (n Noop) Enabled() bool
  • func (n Noop) Exclusive(_ context.Context, _ string, _ time.Duration, _ func(context.Context) error) (bool, error)
  • func (n Noop) Expire(_ context.Context, _ time.Duration, _ ...string) error
  • func (n Noop) FlushAll(_ context.Context) error
  • func (n Noop) Load(_ context.Context, _ string) ([]byte, error)
  • func (n Noop) LoadMany(_ context.Context, keys ...string) ([]string, error)
  • func (n Noop) Ping(_ context.Context) error
  • func (n Noop) Pipeline() redis.Pipeliner
  • func (n Noop) Publish(_ context.Context, _ string, _ any) error
  • func (n Noop) PublishJSON(_ context.Context, _ string, _ any) error
  • func (n Noop) Pull(_ context.Context, _ string, _ func(string, error))
  • func (n Noop) Push(_ context.Context, _ string, _ any) error
  • func (n Noop) Scan(_ context.Context, _ string, output chan<- string, _ int64) error
  • func (n Noop) Store(_ context.Context, _ string, _ any, _ time.Duration) error
  • func (n Noop) StoreMany(_ context.Context, _ map[string]any, _ time.Duration) error
  • func (n Noop) Subscribe(_ context.Context, _ string) (<-chan *redis.Message, func(context.Context) error)
• type Service
  • func (s *Service) Close()
  • func (s *Service) Delete(ctx context.Context, keys ...string) (err error)
  • func (s *Service) DeletePattern(ctx context.Context, pattern string) (err error)
  • func (s *Service) Enabled() bool
  • func (s *Service) Exclusive(ctx context.Context, name string, timeout time.Duration, ...) (acquired bool, err error)
  • func (s *Service) Expire(ctx context.Context, ttl time.Duration, keys ...string) error
  • func (s *Service) FlushAll(ctx context.Context) error
  • func (s *Service) Load(ctx context.Context, key string) ([]byte, error)
  • func (s *Service) LoadMany(ctx context.Context, keys ...string) ([]string, error)
  • func (s *Service) Ping(ctx context.Context) error
  • func (s *Service) Pipeline() redis.Pipeliner
  • func (s Service) Publish(ctx context.Context, channel string, value any) (err error)
  • func (s Service) PublishJSON(ctx context.Context, channel string, value any) error
  • func (s Service) Pull(ctx context.Context, key string, handler func(string, error))
  • func (s Service) Push(ctx context.Context, key string, value any) error
  • func (s *Service) Scan(ctx context.Context, pattern string, output chan<- string, pageSize int64) error
  • func (s *Service) Store(ctx context.Context, key string, value any, ttl time.Duration) error
  • func (s *Service) StoreMany(ctx context.Context, values map[string]any, ttl time.Duration) error
  • func (s Service) Subscribe(ctx context.Context, channel string) (<-chan *redis.Message, func(context.Context) error)

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, client Client, key string, handler func(T, error))

func SubscribeFor

func SubscribeFor[T any](ctx context.Context, client Client, channel string, handler func(T, error)) (<-chan struct{}, func(context.Context) error)

Types

type Client

type Client interface {
	Enabled() bool
	Close()
	FlushAll(context.Context) error
	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
	StoreMany(ctx context.Context, values map[string]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, meter metric.MeterProvider, tracer trace.TracerProvider) (Client, error)

type Config

type Config struct {
	Username    string
	Password    string
	Address     []string
	Database    int
	PoolSize    int
	MinIdleConn int
}

func Flags

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

type Noop

type Noop struct{}

func (Noop) Close

func (n Noop) Close()

func (Noop) Delete

func (n Noop) Delete(_ context.Context, _ ...string) error

func (Noop) DeletePattern

func (n Noop) DeletePattern(_ context.Context, _ string) error

func (Noop) Enabled

func (n Noop) Enabled() bool

func (Noop) Exclusive

func (n Noop) Exclusive(_ context.Context, _ string, _ time.Duration, _ func(context.Context) error) (bool, error)

func (Noop) Expire

func (n Noop) Expire(_ context.Context, _ time.Duration, _ ...string) error

func (Noop) FlushAll

func (n Noop) FlushAll(_ context.Context) error

func (Noop) Load

func (n Noop) Load(_ context.Context, _ string) ([]byte, error)

func (Noop) LoadMany

func (n Noop) LoadMany(_ context.Context, keys ...string) ([]string, error)

func (Noop) Ping

func (n Noop) Ping(_ context.Context) error

func (Noop) Pipeline

func (n Noop) Pipeline() redis.Pipeliner

func (Noop) Publish

func (n Noop) Publish(_ context.Context, _ string, _ any) error

func (Noop) PublishJSON

func (n Noop) PublishJSON(_ context.Context, _ string, _ any) error

func (Noop) Pull

func (n Noop) Pull(_ context.Context, _ string, _ func(string, error))

func (Noop) Push

func (n Noop) Push(_ context.Context, _ string, _ any) error

func (Noop) Scan

func (n Noop) Scan(_ context.Context, _ string, output chan<- string, _ int64) error

func (Noop) Store

func (n Noop) Store(_ context.Context, _ string, _ any, _ time.Duration) error

func (Noop) StoreMany

func (n Noop) StoreMany(_ context.Context, _ map[string]any, _ time.Duration) error

func (Noop) Subscribe

func (n Noop) Subscribe(_ context.Context, _ string) (<-chan *redis.Message, func(context.Context) error)

type Service

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

func (*Service) Close

func (s *Service) Close()

func (*Service) Delete

func (s *Service) Delete(ctx context.Context, keys ...string) (err error)

func (*Service) DeletePattern

func (s *Service) DeletePattern(ctx context.Context, pattern string) (err error)

func (*Service) Enabled

func (s *Service) Enabled() bool

func (*Service) Exclusive

func (s *Service) Exclusive(ctx context.Context, name string, timeout time.Duration, action func(context.Context) error) (acquired bool, err error)

func (*Service) Expire

func (s *Service) Expire(ctx context.Context, ttl time.Duration, keys ...string) error

func (*Service) FlushAll

func (s *Service) FlushAll(ctx context.Context) error

func (*Service) Load

func (s *Service) Load(ctx context.Context, key string) ([]byte, error)

func (*Service) LoadMany

func (s *Service) LoadMany(ctx context.Context, keys ...string) ([]string, error)

func (*Service) Ping

func (s *Service) Ping(ctx context.Context) error

func (*Service) Pipeline

func (s *Service) Pipeline() redis.Pipeliner

func (Service) Publish

func (s Service) Publish(ctx context.Context, channel string, value any) (err error)

func (Service) PublishJSON

func (s Service) PublishJSON(ctx context.Context, channel string, value any) error

func (Service) Pull

func (s Service) Pull(ctx context.Context, key string, handler func(string, error))

func (Service) Push

func (s Service) Push(ctx context.Context, key string, value any) error

func (*Service) Scan

func (s *Service) Scan(ctx context.Context, pattern string, output chan<- string, pageSize int64) error

func (*Service) Store

func (s *Service) Store(ctx context.Context, key string, value any, ttl time.Duration) error

func (*Service) StoreMany

func (s *Service) StoreMany(ctx context.Context, values map[string]any, ttl time.Duration) error

func (Service) Subscribe

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