Documentation
¶
Index ¶
Constants ¶
View Source
const InternalDataTransportKafka = "kafka"
InternalDataTransportKafka is the transport name for using Kafka as the internal data transport.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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
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
Click to show internal directories.
Click to hide internal directories.