pkg

Documentation

Index

• func Start(ctx context.Context, config Config) (wg *sync.WaitGroup, err error)
• type Config
  • func LoadConfig(location string) (config Config, err error)
• type Handler
  • func NewHandler(publisher *mqtt.Publisher, mappings []lib.PathTopicMappingString, ...) (handler Handler, err error)

Functions

func Start

func Start(ctx context.Context, config Config) (wg *sync.WaitGroup, err error)

Types

type Config

type Config struct {
	KafkaBootstrap string
	KafkaTopic     string
	KafkaOffset    string
	KafkaGroupId   string

	FilterQuery string

	MqttBroker       string
	MqttUser         string //keycloak-client
	MqttPw           string //keycloak-secret
	MqttClientId     string
	MqttQos          uint8
	MqttTopicMapping string

	Debug bool
}

func LoadConfig

func LoadConfig(location string) (config Config, err error)

loads config from json in location and used environment variables (e.g ZookeeperUrl --> ZOOKEEPER_URL)

type Handler

type Handler struct {
	Publisher   *mqtt.Publisher
	Mappings    []lib.PathTopicMapping
	FilterQuery *gojq.Query
}

func NewHandler

func NewHandler(publisher *mqtt.Publisher, mappings []lib.PathTopicMappingString, FilterQuery *string) (handler Handler, err error)