redis

Documentation

Overview

Package redis provides a Vice implementation for REDIS.

Index

• type Option
  • func WithClient(c *redis.Client) Option
• type Options
• type Transport
  • func New(opts ...Option) *Transport
  • func (t *Transport) Done() chan struct{}
  • func (t *Transport) ErrChan() <-chan error
  • func (t *Transport) Receive(name string) <-chan []byte
  • func (t *Transport) Send(name string) chan<- []byte
  • func (t *Transport) Stop()

Types

type Option

type Option func(*Options)

func WithClient

func WithClient(c *redis.Client) Option

type Options

type Options struct {
	Client *redis.Client
}

type Transport

type Transport struct {
	sync.Mutex
	// contains filtered or unexported fields
}

Transport is a vice.Transport for redis.

func New

func New(opts ...Option) *Transport

New returns a new transport

func (*Transport) Done

func (t *Transport) Done() chan struct{}

Done gets a channel which is closed when the transport has successfully stopped.

func (*Transport) ErrChan

func (t *Transport) ErrChan() <-chan error

ErrChan gets the channel on which errors are sent.

func (*Transport) Receive

func (t *Transport) Receive(name string) <-chan []byte

Receive gets a channel on which to receive messages with the specified name.

func (*Transport) Send

func (t *Transport) Send(name string) chan<- []byte

Send gets a channel on which messages with the specified name may be sent.

func (*Transport) Stop

func (t *Transport) Stop()

Stop stops the transport. The channel returned from Done() will be closed when the transport has stopped.