redis

Documentation

Index

• type Redis
  • func New() *Redis
  • func (r *Redis) Init(ctx context.Context, log logger.Logger) error
  • func (r *Redis) Publish(_ context.Context, _ string, _, _ []byte) error
  • func (r *Redis) Subscribe(_ context.Context, _ string, _ query.Response) error
  • func (r *Redis) UnSubscribe(_ string) error

Types

type Redis

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

func New

func New() *Redis

func (*Redis) Init

func (r *Redis) Init(ctx context.Context, log logger.Logger) error

func (*Redis) Publish

func (r *Redis) Publish(_ context.Context, _ string, _, _ []byte) error

func (*Redis) Subscribe

func (r *Redis) Subscribe(_ context.Context, _ string, _ query.Response) error

func (*Redis) UnSubscribe

func (r *Redis) UnSubscribe(_ string) error