config

Documentation

Index

• Constants
• type KafkaConfigArgs
  • func (c *KafkaConfigArgs) ConfigMap() kafka.ConfigMap
  • func (c *KafkaConfigArgs) Set(value string) error
  • func (c *KafkaConfigArgs) String() string
• type Server
  • func (c *Server) Init()
  • func (c Server) Validate() error
• type TopicMapping
  • func (c *TopicMapping) String() string
• type TopicMappings
  • func (c *TopicMappings) Set(value string) error
  • func (c *TopicMappings) String() string

Constants

const (
	PublisherNoop  = "noop"
	PublisherKafka = "kafka"
)

publisher names

const (
	AuthNoop  = "noop"
	AuthPlain = "plain"
)

authenticator names

Types

type KafkaConfigArgs

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

func (*KafkaConfigArgs) ConfigMap

func (c *KafkaConfigArgs) ConfigMap() kafka.ConfigMap

func (*KafkaConfigArgs) Set

func (c *KafkaConfigArgs) Set(value string) error

func (*KafkaConfigArgs) String

func (c *KafkaConfigArgs) String() string

type Server

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
			}
		}
	}
}

func (*Server) Init

func (c *Server) Init()

func (Server) Validate

func (c Server) Validate() error

type TopicMapping

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

func (*TopicMapping) String

func (c *TopicMapping) String() string

type TopicMappings

type TopicMappings struct {
	Mappings []TopicMapping
}

func (*TopicMappings) Set

func (c *TopicMappings) Set(value string) error

func (*TopicMappings) String

func (c *TopicMappings) String() string