redis

Documentation

Index

• type Config
• type Redis
  • func New() *Redis
  • func (r Redis) Close() error
  • func (r Redis) Init(ctx context.Context) error
  • func (r Redis) Publish(ctx context.Context, target string, message query.Message) error
  • func (r Redis) Subscribe(target string, message query.Response) error
  • func (r Redis) UnSubscribe(target string) error

Types

type Config

type Config struct{}

type Redis

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

func New

func New() *Redis

func (Redis) Close

func (r Redis) Close() error

func (Redis) Init

func (r Redis) Init(ctx context.Context) error

func (Redis) Publish

func (r Redis) Publish(ctx context.Context, target string, message query.Message) error

func (Redis) Subscribe

func (r Redis) Subscribe(target string, message query.Response) error

func (Redis) UnSubscribe

func (r Redis) UnSubscribe(target string) error