Versions in this module Expand all Collapse all v0 v0.5.2 Jul 27, 2023 v0.5.1 Jul 27, 2023 Changes in this version + const OnlyOnce + const Overlap + var DefaultListeners = []*ListenerConfig + var DefaultMQTTConfig = MQTT + var DefaultPersistenceConfig = Persistence + var DefaultTopicAliasManager = TopicAliasManager + func RegisterDefaultPluginConfig(name string, config Configuration) + type API struct + GRPC []*Endpoint + HTTP []*Endpoint + var DefaultAPI API + func (a API) Validate() error + type Config struct + API API + ConfigDir string + GRPC GRPC + Listeners []*ListenerConfig + Log LogConfig + MQTT MQTT + Persistence Persistence + PidFile string + PluginOrder []string + Plugins pluginConfig + TopicAliasManager TopicAliasManager + func DefaultConfig() Config + func ParseConfig(filePath string) (c Config, err error) + func (c *Config) UnmarshalYAML(unmarshal func(interface{}) error) error + func (c Config) GetLogger(config LogConfig) (l *zap.Logger, err error) + func (c Config) Validate() (err error) + type Configuration interface + Validate func() error + type Endpoint struct + Address string + Map string + TLS *TLSOptions + type GRPC struct + Endpoint string + type ListenerConfig struct + Address string + Websocket *WebsocketOptions + type LogConfig struct + DumpPacket bool + Format string + Level string + func (l LogConfig) Validate() error + type MQTT struct + AllowZeroLenClientID bool + DeliveryMode string + InflightExpiry time.Duration + MaxInflight uint16 + MaxKeepAlive uint16 + MaxPacketSize uint32 + MaxQueuedMsg int + MaximumQoS uint8 + MessageExpiry time.Duration + QueueQos0Msg bool + ReceiveMax uint16 + RetainAvailable bool + SessionExpiry time.Duration + SessionExpiryCheckInterval time.Duration + SharedSubAvailable bool + SubscriptionIDAvailable bool + TopicAliasMax uint16 + WildcardAvailable bool + func (c MQTT) Validate() error + type MockConfiguration struct + func NewMockConfiguration(ctrl *gomock.Controller) *MockConfiguration + func (m *MockConfiguration) EXPECT() *MockConfigurationMockRecorder + func (m *MockConfiguration) UnmarshalYAML(unmarshal func(interface{}) error) error + func (m *MockConfiguration) Validate() error + type MockConfigurationMockRecorder struct + func (mr *MockConfigurationMockRecorder) UnmarshalYAML(unmarshal interface{}) *gomock.Call + func (mr *MockConfigurationMockRecorder) Validate() *gomock.Call + type Persistence struct + Redis RedisPersistence + Type PersistenceType + func (p *Persistence) Validate() error + type PersistenceType = string + const PersistenceTypeMemory + const PersistenceTypeRedis + type RedisPersistence struct + Addr string + Database uint + IdleTimeout time.Duration + MaxActive *uint + MaxIdle *uint + Password string + type TLSOptions struct + CACert string + Cert string + Key string + Verify bool + type TopicAliasManager struct + Type TopicAliasType + type TopicAliasType = string + const TopicAliasMgrTypeFIFO + type WebsocketOptions struct + Path string