broker

Documentation

Index

• func NewBroker(opts ...broker.Option) broker.Broker
• func RedisOptions(opts Options) broker.Option
• type Marshaler
  • func (j Marshaler) Marshal(v interface{}) ([]byte, error)
  • func (j Marshaler) String() string
  • func (j Marshaler) Unmarshal(d []byte, v interface{}) error
• type Option
  • func Address(addr string) Option
  • func Password(password string) Option
  • func TLSConfig(tlsConfig *tls.Config) Option
  • func User(user string) Option
• type Options

Functions

func NewBroker

func NewBroker(opts ...broker.Option) broker.Broker

func RedisOptions

func RedisOptions(opts Options) broker.Option

Types

type Marshaler

type Marshaler struct{}

func (Marshaler) Marshal

func (j Marshaler) Marshal(v interface{}) ([]byte, error)

func (Marshaler) String

func (j Marshaler) String() string

func (Marshaler) Unmarshal

func (j Marshaler) Unmarshal(d []byte, v interface{}) error

type Option

type Option func(o *Options)

Option is a function which configures options

func Address

func Address(addr string) Option

func Password

func Password(password string) Option

func TLSConfig

func TLSConfig(tlsConfig *tls.Config) Option

func User

func User(user string) Option

type Options

type Options struct {
	Address   string
	User      string
	Password  string
	TLSConfig *tls.Config
}

Options which are used to configure the redis broker