mqtt

type BufferConfig struct {
	SendBufferSize    int `json:"send-buffer-size"`
	ReceiveBufferSize int `json:"receive-buffer-size"`
	MessageQueueSize  int `json:"message-queue-size"`
}

type ClientConfig struct {
	ID                   string `json:"id"`
	Username             string `json:"username"`
	Password             string `json:"password"`
	CleanSession         bool   `json:"clean-session"`
	KeepAlive            int    `json:"keep-alive"`
	ConnectTimeout       int    `json:"connect-timeout"`
	AutoReconnect        bool   `json:"auto-reconnect"`
	ReconnectInterval    int    `json:"reconnect-interval"`
	MaxReconnectAttempts int    `json:"max-reconnect-attempts"`
}

type LoggingConfig struct {
	Debug               bool `json:"debug"`
	LogConnectionEvents bool `json:"log-connection-events"`
	LogMessageEvents    bool `json:"log-message-events"`
}

type MQTTClient struct {
	// contains filtered or unexported fields
}

type MQTTServiceProvider struct {
	// contains filtered or unexported fields
}

type MessageConfig struct {
	DefaultQoS byte `json:"default-qos"`
	Retain     bool `json:"retain"`
	Timeout    int  `json:"timeout"`
}

type Options struct {
	Broker       string             `json:"broker"`
	Client       ClientConfig       `json:"client"`
	TLS          TLSConfig          `json:"tls"`
	Message      MessageConfig      `json:"message"`
	Subscription SubscriptionConfig `json:"subscription"`
	Publish      PublishConfig      `json:"publish"`
	Logging      LoggingConfig      `json:"logging"`
	Buffer       BufferConfig       `json:"buffer"`
	Performance  PerformanceConfig  `json:"performance"`
}

type PerformanceConfig struct {
	MaxConcurrentConnections int `json:"max-concurrent-connections"`
	MessageHandlerCount      int `json:"message-handler-count"`
	BatchSize                int `json:"batch-size"`
}

type PublishConfig struct {
	DefaultQoS byte `json:"default-qos"`
	Timeout    int  `json:"timeout"`
	WaitForAck bool `json:"wait-for-ack"`
}

type SubscriptionConfig struct {
	DefaultQoS byte `json:"default-qos"`
	Timeout    int  `json:"timeout"`
}

type TLSConfig struct {
	Enabled            bool   `json:"enabled"`
	CertFile           string `json:"cert-file"`
	KeyFile            string `json:"key-file"`
	CAFile             string `json:"ca-file"`
	InsecureSkipVerify bool   `json:"insecure-skip-verify"`
}