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.