Documentation
¶
Index ¶
- func IssueHubReportMetrics(reports map[string]*report.HubReport)
- func IssueKubePerceptorReportMetrics(report *report.KubePerceptorReport)
- func IssueKubeReportMetrics(report *report.KubeReport)
- func IssuePerceptorHubMetrics(report *report.PerceptorHubReport)
- func IssueReportMetrics(report *report.Report)
- func RunSkyfire(configPath string)
- type Config
- type ConfigManager
- type Scraper
- type Skyfire
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func IssueHubReportMetrics ¶
IssueHubReportMetrics .....
func IssueKubePerceptorReportMetrics ¶
func IssueKubePerceptorReportMetrics(report *report.KubePerceptorReport)
IssueKubePerceptorReportMetrics .....
func IssueKubeReportMetrics ¶
func IssueKubeReportMetrics(report *report.KubeReport)
IssueKubeReportMetrics .....
func IssuePerceptorHubMetrics ¶
func IssuePerceptorHubMetrics(report *report.PerceptorHubReport)
IssuePerceptorHubMetrics .....
Types ¶
type Config ¶
type Config struct {
UseInClusterConfig bool
MasterURL string
KubeConfigPath string
KubeDumpIntervalSeconds int
PerceptorDumpIntervalSeconds int
HubDumpPauseSeconds int
Port int
LogLevel string
HubHosts []string
HubUser string
HubUserPasswordEnvVar string
PerceptorHost string
PerceptorPort int
}
Config .....
func (*Config) GetLogLevel ¶
GetLogLevel .....
func (*Config) KubeClientConfig ¶
func (config *Config) KubeClientConfig() *kube.KubeClientConfig
KubeClientConfig .....
type ConfigManager ¶
type ConfigManager struct {
ConfigPath string
// contains filtered or unexported fields
}
ConfigManager handles:
- getting initial config
- reporting ongoing changes to config
func NewConfigManager ¶
func NewConfigManager(configPath string, stop <-chan struct{}) *ConfigManager
NewConfigManager ...
func (*ConfigManager) DidReadConfig ¶
func (cm *ConfigManager) DidReadConfig() <-chan *Config
DidReadConfig ...
func (*ConfigManager) GetConfig ¶
func (cm *ConfigManager) GetConfig() (*Config, error)
GetConfig .....
type Scraper ¶
type Scraper struct {
KubeDumper kube.ClientInterface
KubeDumps chan *kube.Dump
KubeDumpInterval time.Duration
PerceptorDumper perceptor.ClientInterface
PerceptorDumps chan *perceptor.Dump
PerceptorDumpInterval time.Duration
Hubs map[string]*hubDumper
HubDumpPause time.Duration
HubDumps chan *hubDump
// contains filtered or unexported fields
}
Scraper .....
func NewScraper ¶
func NewScraper(kubeDumper kube.ClientInterface, kubeDumpInterval time.Duration, createHubClient func(host string) (hub.ClientInterface, error), hubDumpInterval time.Duration, perceptorDumper perceptor.ClientInterface, perceptorDumpInterval time.Duration, stop <-chan struct{}) *Scraper
NewScraper .....
func (*Scraper) StartPerceptorScrapes ¶
func (sc *Scraper) StartPerceptorScrapes()
StartPerceptorScrapes .....
type Skyfire ¶
type Skyfire struct {
Scraper *Scraper
LastPerceptorDump *perceptor.Dump
LastHubDumps map[string]*hub.Dump
LastKubeDump *kube.Dump
LastReport *report.Report
// contains filtered or unexported fields
}
Skyfire .....
func NewSkyfire ¶
NewSkyfire .....
func (*Skyfire) LatestReportHandler ¶
func (sf *Skyfire) LatestReportHandler() func(http.ResponseWriter, *http.Request)
LatestReportHandler .....
Click to show internal directories.
Click to hide internal directories.