config

Documentation

Index

• Constants
• type Config
  • func Read(file string) (*Config, error)
• type InternalDataConfig

Constants

const InternalDataTransportKafka = "kafka"

InternalDataTransportKafka is the transport name for using Kafka as the internal data transport.

Types

type Config

type Config struct {
	ApplicationName string              `yaml:"application"`
	MetricsPrefix   string              `yaml:"metricsprefix"`
	MetricsPort     int                 `yaml:"metricsport"`
	Zookeeper       string              `yaml:"zookeeper"`
	ZkElectionPath  string              `yaml:"zkleaderelectionpath"`
	InternalData    *InternalDataConfig `yaml:"internaldata"`
	Source          *node.SourceConfig  `yaml:"source"`
	Nodes           []*node.Config      `yaml:"nodes"`
	ShutdownTimeOut int                 `yaml:"shutdowntimeout"`
}

Config is the firebolt application configuration, including the configured source and all processing nodes

func Read

func Read(file string) (*Config, error)

Read reads the file at the provided path and parses a firebolt configuration. It may return an error if there is any failure while reading or parsing this file.

type InternalDataConfig

type InternalDataConfig struct {
	Transport string            `yaml:"transport"`
	Params    map[string]string `yaml:"params"`
}

InternalDataConfig is the set of configuration values for all consumers of the internal datastore