config

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

type Server struct {
	HTTP struct {
		ListenAddress string
		GracePeriod   time.Duration
	}
	MQTT struct {
		ListenAddress    string
		GracePeriod      time.Duration
		ReadTimeout      time.Duration
		WriteTimeout     time.Duration
		IdleTimeout      time.Duration
		ReaderBufferSize int
		WriterBufferSize int
		TLSSrv           struct {
			Cert     string
			Key      string
			ClientCA string
		}
		Handler struct {
			IgnoreUnsupported    []string
			AllowUnauthenticated []string
			Publish              struct {
				Timeout time.Duration
				Async   struct {
					AtMostOnce  bool
					AtLeastOnce bool
					ExactlyOnce bool
				}
			}
			Authenticator struct {
				Name  string
				Plain struct {
					Credentials     map[string]string
					CredentialsFile string
				}
			}
		}
		Publisher struct {
			Name  string
			Kafka struct {
				BootstrapServers string
				GracePeriod      time.Duration
				ConfArgs         KafkaConfigArgs
				DefaultTopic     string
				TopicMappings    TopicMappings
				Workers          int
			}
		}
	}
}

type TopicMapping struct {
	Topic  string
	RegExp *regexp.Regexp
}

type TopicMappings struct {
	Mappings []TopicMapping
}