redis

Documentation

Index

• type PubSubDriver
  • func NewRedisPubSubDriver(channels []string, opts *redis.Options) (*PubSubDriver, error)
  • func (p *PubSubDriver) CloseStream() error
  • func (p *PubSubDriver) GetDriverFlags() []brokerutil.Flag
  • func (p *PubSubDriver) GetMessageReaderChannel() (<-chan interface{}, error)
  • func (p *PubSubDriver) GetMessageWriterChannel() (chan<- interface{}, error)
  • func (p *PubSubDriver) OpenStream() error

Types

type PubSubDriver

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

PubSubDriver implements the brokerutil concurrent driver interface to allow pub sub functionality over redis

func NewRedisPubSubDriver

func NewRedisPubSubDriver(channels []string, opts *redis.Options) (*PubSubDriver, error)

NewRedisPubSubDriver creates a new redis pub sub driver

func (*PubSubDriver) CloseStream

func (p *PubSubDriver) CloseStream() error

CloseStream cleans the communication routines up

func (*PubSubDriver) GetDriverFlags

func (p *PubSubDriver) GetDriverFlags() []brokerutil.Flag

GetDriverFlags returns flags which indicate the capabilities

func (*PubSubDriver) GetMessageReaderChannel

func (p *PubSubDriver) GetMessageReaderChannel() (<-chan interface{}, error)

GetMessageReaderChannel returns the channel to read from if a message was received

func (*PubSubDriver) GetMessageWriterChannel

func (p *PubSubDriver) GetMessageWriterChannel() (chan<- interface{}, error)

GetMessageWriterChannel returns the channel to write to if a message needs to be sent / published

func (*PubSubDriver) OpenStream

func (p *PubSubDriver) OpenStream() error

OpenStream initializes the communication channels protocol + network