redis

Documentation

Index

• type Publisher
  • func NewPublisher(ctx context.Context, client *redis.Client, ns Namespace) *Publisher
  • func (r *Publisher) Close() error
  • func (r *Publisher) Flush() error
  • func (r *Publisher) Write(channel api.Channel, payload []byte) error

Types

type Publisher

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

func NewPublisher

func NewPublisher(ctx context.Context, client *redis.Client, ns Namespace) *Publisher

func (*Publisher) Close

func (r *Publisher) Close() error

func (*Publisher) Flush

func (r *Publisher) Flush() error

func (*Publisher) Write

func (r *Publisher) Write(channel api.Channel, payload []byte) error