redis

func (s *Source) Attach(ctx context.Context, _ *db.Pool) error

func (s *Source) ConfigGet(ctx context.Context, key string) (string, error)

func (s *Source) ConfigSet(ctx context.Context, key string, value string) error

func (s *Source) Definition() types.DataSource

func (s *Source) Del(ctx context.Context, key string) error

func (s *Source) Detach(_ context.Context, _ *db.Pool) error

func (s *Source) Engine() engines.Engine

func (s *Source) Expire(ctx context.Context, key string, ttlSeconds int) error

func (s *Source) Get(ctx context.Context, key string) (string, bool, error)

func (s *Source) Incr(ctx context.Context, key string) (int64, error)

func (s *Source) IncrBy(ctx context.Context, key string, value int64) (int64, error)

func (s *Source) IsAttached() bool

func (s *Source) Keys(ctx context.Context, pattern string) ([]string, error)

func (s *Source) Name() string

func (s *Source) PSubscribe(ctx context.Context, pattern string) (*sources.SubscriptionResult, error)

func (s *Source) Publish(ctx context.Context, channel string, message string) error

func (s *Source) ReadOnly() bool

func (s *Source) Set(ctx context.Context, key string, value string, ttlSeconds int) error

func (s *Source) Subscribe(ctx context.Context, channel string) (*sources.SubscriptionResult, error)