broker

package
v3.9.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 13, 2022 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL