redis

Documentation

Index

• Variables
• func CreateRedisTransporter(options RedisOptions) transit.Transport
• type RedisOptions
• type RedisTransporter
  • func (t *RedisTransporter) Connect() chan error
  • func (t *RedisTransporter) Disconnect() chan error
  • func (t *RedisTransporter) Publish(command, nodeID string, message moleculer.Payload)
  • func (t *RedisTransporter) SetNodeID(nodeID string)
  • func (t *RedisTransporter) SetPrefix(prefix string)
  • func (t *RedisTransporter) SetSerializer(serializer serializer.Serializer)
  • func (t *RedisTransporter) Subscribe(command, nodeID string, handler transit.TransportHandler)

Variables

var ChannelOptions = make([]redis.ChannelOption, 0)

Functions

func CreateRedisTransporter

func CreateRedisTransporter(options RedisOptions) transit.Transport

Types

type RedisOptions

type RedisOptions struct {
	Addr           string
	PassWord       string
	DB             int
	Name           string
	Logger         *log.Entry
	Serializer     serializer.Serializer
	ValidateMsg    transit.ValidateMsgFunc
	AllowReconnect bool
	ReconnectWait  time.Duration
	MaxReconnect   int
}

type RedisTransporter

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

func (*RedisTransporter) Connect

func (t *RedisTransporter) Connect() chan error

func (*RedisTransporter) Disconnect

func (t *RedisTransporter) Disconnect() chan error

func (*RedisTransporter) Publish

func (t *RedisTransporter) Publish(command, nodeID string, message moleculer.Payload)

func (*RedisTransporter) SetNodeID

func (t *RedisTransporter) SetNodeID(nodeID string)

func (*RedisTransporter) SetPrefix

func (t *RedisTransporter) SetPrefix(prefix string)

func (*RedisTransporter) SetSerializer

func (t *RedisTransporter) SetSerializer(serializer serializer.Serializer)

func (*RedisTransporter) Subscribe

func (t *RedisTransporter) Subscribe(command, nodeID string, handler transit.TransportHandler)