Documentation ¶
Index ¶
- func WithBroker(broker string) func(*Opts)
- func WithClientID(clientID string) func(*Opts)
- func WithKeepAlive(keepAlive time.Duration) func(*Opts)
- func WithPassword(password string) func(*Opts)
- func WithQOS(qos byte) func(*Opts)
- func WithRetained(retained bool) func(*Opts)
- func WithTopic(topic string) func(*Opts)
- func WithUserName(userName string) func(*Opts)
- type Destination
- type OptFunc
- type Opts
- type Source
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func WithBroker ¶
func WithClientID ¶
func WithKeepAlive ¶
func WithPassword ¶
func WithRetained ¶
func WithUserName ¶
Types ¶
type Destination ¶
type Destination struct {
// contains filtered or unexported fields
}
func NewDestination ¶
func NewDestination(opts ...OptFunc) (*Destination, error)
Click to show internal directories.
Click to hide internal directories.