cache

package

v0.0.0-...-5599d74 Latest Latest Go to latest Published: Dec 24, 2021 License: GPL-3.0 Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Options struct {
	Addr     string
	Password string
	DB       int
}

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

func NewRedisClient(ctx context.Context, options *Options) (*RedisClient, error)

func (rc *RedisClient) Get(ctx context.Context, key string) ([]byte, error)

func (rc *RedisClient) Publish(ctx context.Context, channel string, message interface{}) error

func (rc *RedisClient) Set(ctx context.Context, key string, value interface{}, expiration time.Duration) error

func (rc *RedisClient) Subscribe(ctx context.Context, channel string) <-chan string