config

Documentation

Overview

package config parses flags, environment variables and json object to build a Config object that's used throughout the monitor.

Index

• type Config
  • func Parse() (Config, error)
• type Feature
• type Feeds
• type HTTP
• type Kafka
• type Nodes
• type SchemaRegistry

Types

type Config

type Config struct {
	Kafka          Kafka
	SchemaRegistry SchemaRegistry
	Feeds          Feeds
	Nodes          Nodes
	HTTP           HTTP
	Feature        Feature
}

func Parse

func Parse() (Config, error)

type Feature

type Feature struct {
}

Feature is used to add temporary feature flags to the binary.

type Feeds

type Feeds struct {
	URL             string
	RDDReadTimeout  time.Duration
	RDDPollInterval time.Duration
	// Ids of feeds that are present in the RDD but should not be monitored.
	// These get matched against the string returned by FeedConfig#GetID() for
	// each feed in RDD. If equal, the feed will get ignored!
	IgnoreIDs []string
}

type HTTP

type HTTP struct {
	Address string
}

type Kafka

type Kafka struct {
	Brokers          string
	ClientID         string
	SecurityProtocol string

	SaslMechanism string
	SaslUsername  string
	SaslPassword  string

	TransmissionTopic        string
	ConfigSetSimplifiedTopic string
}

type Nodes

type Nodes struct {
	URL string
}

type SchemaRegistry

type SchemaRegistry struct {
	URL      string
	Username string
	Password string
}