Versions in this module Expand all Collapse all v0 v0.25.3 Nov 1, 2026 Changes in this version + const NatsRetentionInterest + const NatsRetentionLimits + const NatsRetentionWorkQueue + const NatsStorageFile + const NatsStorageMemory + type Mqtt struct + AutoReconnect bool + CleanSession bool + ClientID string + ConnectTimeout int + Endpoint string + KeepAlive int + MaxReconnectInterval int + ModuleName string + Password string + PingTimeout int + ProtocolVersion uint + Username string + WillTopic string + WriteTimeout int + func Default() *Mqtt + func DefaultMqtt() Mqtt + func NewMqtt(opt *Mqtt) *Mqtt + func (m *Mqtt) Clone() internal.Configurable + func (m *Mqtt) Get() interface{} + func (m *Mqtt) Set(data interface{}) + func (m *Mqtt) Validate() error + func (m *Mqtt) WithAutoReconnect(autoReconnect bool) *Mqtt + func (m *Mqtt) WithCleanSession(cleanSession bool) *Mqtt + func (m *Mqtt) WithClientID(clientID string) *Mqtt + func (m *Mqtt) WithConnectTimeout(connectTimeout int) *Mqtt + func (m *Mqtt) WithEndpoint(endpoint string) *Mqtt + func (m *Mqtt) WithKeepAlive(keepAlive int) *Mqtt + func (m *Mqtt) WithMaxReconnectInterval(maxReconnectInterval int) *Mqtt + func (m *Mqtt) WithModuleName(moduleName string) *Mqtt + func (m *Mqtt) WithPassword(password string) *Mqtt + func (m *Mqtt) WithPingTimeout(pingTimeout int) *Mqtt + func (m *Mqtt) WithProtocolVersion(protocolVersion uint) *Mqtt + func (m *Mqtt) WithUsername(username string) *Mqtt + func (m *Mqtt) WithWillTopic(willTopic string) *Mqtt + func (m *Mqtt) WithWriteTimeout(writeTimeout int) *Mqtt + type Nats struct + ConnectTimeout int + DrainTimeout int + DuplicatesWindow int64 + Enabled bool + FlushTimeout int + JetStream bool + MaxAge int64 + MaxBytes int64 + MaxPingsOut int + MaxReconnects int + ModuleName string + Name string + Password string + PingInterval int + ReconnectBufSize int64 + ReconnectJitter int + ReconnectWait int + Replicas int + Retention string + Storage string + Token string + URL string + Username string + WorkerPoolSize int + WorkerQueueSize int + func DefaultNats() Nats + func DefaultNatsPtr() *Nats + func NewNats(opt *Nats) *Nats + func (n *Nats) Clone() internal.Configurable + func (n *Nats) Get() interface{} + func (n *Nats) IsEnabled() bool + func (n *Nats) Set(data interface{}) + func (n *Nats) Validate() error + func (n *Nats) WithConnectTimeout(seconds int) *Nats + func (n *Nats) WithDrainTimeout(seconds int) *Nats + func (n *Nats) WithDuplicatesWindow(seconds int64) *Nats + func (n *Nats) WithEnabled(enabled bool) *Nats + func (n *Nats) WithFlushTimeout(seconds int) *Nats + func (n *Nats) WithJetStream(enabled bool) *Nats + func (n *Nats) WithMaxAge(seconds int64) *Nats + func (n *Nats) WithMaxBytes(bytes int64) *Nats + func (n *Nats) WithMaxPingsOut(max int) *Nats + func (n *Nats) WithMaxReconnects(max int) *Nats + func (n *Nats) WithModuleName(moduleName string) *Nats + func (n *Nats) WithName(name string) *Nats + func (n *Nats) WithPassword(password string) *Nats + func (n *Nats) WithPingInterval(seconds int) *Nats + func (n *Nats) WithReconnectBufSize(bytes int64) *Nats + func (n *Nats) WithReconnectJitter(seconds int) *Nats + func (n *Nats) WithReconnectWait(seconds int) *Nats + func (n *Nats) WithReplicas(replicas int) *Nats + func (n *Nats) WithRetention(retention string) *Nats + func (n *Nats) WithStorage(storage string) *Nats + func (n *Nats) WithToken(token string) *Nats + func (n *Nats) WithURL(url string) *Nats + func (n *Nats) WithUsername(username string) *Nats + func (n *Nats) WithWorkerPoolSize(size int) *Nats + func (n *Nats) WithWorkerQueueSize(size int) *Nats
Go to main page