redis

Sep 27, 2023

Changes in this version

+ type Subscriber interface

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

Sep 20, 2023

Changes in this version

type Client

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

type Noop

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

type Service

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

Aug 26, 2023

Changes in this version

type Config

+ Address []string

+ Database int

+ MinIdleConn int

+ Password string

+ PoolSize int

+ Username string

+ type Service struct

+ func (a *Service) Close()

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

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

+ func (a *Service) Enabled() bool

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

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

+ func (a *Service) FlushAll(ctx context.Context) error

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

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

+ func (a *Service) Ping(ctx context.Context) error

+ func (a *Service) Pipeline() redis.Pipeliner

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

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

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

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

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

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

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

Aug 17, 2023

Changes in this version

type App

+ func (a *App) FlushAll(ctx context.Context) error

type Client

+ FlushAll func(context.Context) error

type Noop

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

Jul 27, 2023

Changes in this version

type App

+ func (a *App) WithPipelineSize(size int) *App

Jul 16, 2023

Changes in this version

+ type Noop struct

+ 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) 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) Subscribe(_ context.Context, _ string) (<-chan *redis.Message, func(context.Context) error)

Mar 19, 2023

Changes in this version

type App

+ func (a App) Close()

type Client

+ Close func()

Feb 8, 2023

Changes in this version

type App

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

type Client

+ Pipeline func() redis.Pipeliner

Jan 21, 2023

Changes in this version

type Client

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

Jan 21, 2023

Changes in this version

type App

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

Jan 20, 2023

Changes in this version

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

type App

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

+ type Client interface

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

+ DeletePattern func(ctx context.Context, pattern string) error

+ Enabled func() bool

+ Exclusive func(ctx context.Context, name string, timeout time.Duration, ...) (bool, error)

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

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

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

+ Ping func(ctx context.Context) error

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

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

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

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

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

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

Nov 5, 2022

Changes in this version

type App

+ func (a App) Enabled() bool

Sep 25, 2022

Changes in this version

type App

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

Sep 2, 2022

Changes in this version

type App

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

Sep 1, 2022

Changes in this version

type App

+ func (a App) BatchLoad(ctx context.Context, keys ...string) (map[string]string, error)

+ func (a App) Scan(ctx context.Context, pattern string, pageSize int64) (output []string, err error)

Jul 20, 2022

Changes in this version

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

+ func PullFor(ctx context.Context, app App, key string, done <-chan struct{}, ...)

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

type App

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

+ func (a App) Pull(ctx context.Context, key string, done <-chan struct{}, ...)

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

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

Apr 16, 2021

Changes in this version

+ type App interface

+ Delete func(context.Context, string) error

+ Exclusive func(context.Context, string, time.Duration, func(context.Context) error) error

+ Load func(context.Context, string) (string, error)

+ Ping func() error

+ Store func(context.Context, string, string, time.Duration) error

+ func New(config Config) App

+ type Config struct

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