Documentation
¶
Overview ¶
Provides a server type for starting and configuring a Kapacitor server.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
HTTP httpd.Config `toml:"http"`
Replay replay.Config `toml:"replay"`
Storage storage.Config `toml:"storage"`
Task task_store.Config `toml:"task"`
InfluxDB []influxdb.Config `toml:"influxdb"`
Logging logging.Config `toml:"logging"`
Graphites []graphite.Config `toml:"graphite"`
Collectd collectd.Config `toml:"collectd"`
OpenTSDB opentsdb.Config `toml:"opentsdb"`
UDPs []udp.Config `toml:"udp"`
SMTP smtp.Config `toml:"smtp"`
OpsGenie opsgenie.Config `toml:"opsgenie"`
VictorOps victorops.Config `toml:"victorops"`
PagerDuty pagerduty.Config `toml:"pagerduty"`
Sensu sensu.Config `toml:"sensu"`
Slack slack.Config `toml:"slack"`
Telegram telegram.Config `toml:"telegram"`
HipChat hipchat.Config `toml:"hipchat"`
Alerta alerta.Config `toml:"alerta"`
Reporting reporting.Config `toml:"reporting"`
Stats stats.Config `toml:"stats"`
UDF udf.Config `toml:"udf"`
Deadman deadman.Config `toml:"deadman"`
Talk talk.Config `toml:"talk"`
Hostname string `toml:"hostname"`
DataDir string `toml:"data_dir"`
// contains filtered or unexported fields
}
Config represents the configuration format for the kapacitord binary.
func NewConfig ¶
func NewConfig() *Config
NewConfig returns an instance of Config with reasonable defaults.
func NewDemoConfig ¶
NewDemoConfig returns the config that runs when no config is specified.
func (*Config) ApplyEnvOverrides ¶
func (*Config) PostInit ¶
func (c *Config) PostInit()
Once the config has been created and decoded, you can call this method to initialize ARRAY attributes. All ARRAY attributes have to be init after toml decode See: https://github.com/BurntSushi/toml/pull/68
type Queryexecutor ¶
type Queryexecutor struct{}
func (*Queryexecutor) ExecuteQuery ¶
type Server ¶
type Server struct {
TaskMaster *kapacitor.TaskMaster
TaskMasterLookup *kapacitor.TaskMasterLookup
AuthService auth.Interface
HTTPDService *httpd.Service
StorageService *storage.Service
TaskStore *task_store.Service
ReplayService *replay.Service
InfluxDBService *influxdb.Service
MetaClient *kapacitor.NoopMetaClient
QueryExecutor *Queryexecutor
// List of services in startup order
Services []Service
// Map of service name to index in Services list
ServicesByName map[string]int
BuildInfo BuildInfo
ClusterID string
ServerID string
// Profiling
CPUProfile string
MemProfile string
LogService logging.Interface
Logger *log.Logger
// contains filtered or unexported fields
}
Server represents a container for the metadata and storage data and services. It is built using a Config and it manages the startup and shutdown of all services in the proper order.
func (*Server) AppendService ¶
func (*Server) Err ¶
Err returns an error channel that multiplexes all out of band errors received from all services.
func (*Server) InitHTTPDService ¶
func (s *Server) InitHTTPDService()