skyfire

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
  • func (config *Config) GetLogLevel() (log.Level, error)
  • func (config *Config) KubeClientConfig() *kube.KubeClientConfig
• type ConfigManager
  • func NewConfigManager(configPath string, stop <-chan struct{}) *ConfigManager
  • func (cm *ConfigManager) DidReadConfig() <-chan *Config
  • func (cm *ConfigManager) GetConfig() (*Config, error)
• type Scraper
  • func NewScraper(kubeDumper kube.ClientInterface, kubeDumpInterval time.Duration, ...) *Scraper
  • func (sc *Scraper) SetHubs(hosts []string)
  • func (sc *Scraper) StartKubeScrapes()
  • func (sc *Scraper) StartPerceptorScrapes()
  • func (sc *Scraper) StartScraping()
• type Skyfire
  • func NewSkyfire(config *Config, stop <-chan struct{}) (*Skyfire, error)
  • func (sf *Skyfire) BuildReport()
  • func (sf *Skyfire) HandleScrapes()
  • func (sf *Skyfire) LatestReportHandler() func(http.ResponseWriter, *http.Request)
  • func (sf *Skyfire) SetHubs(hosts []string)

Functions

func IssueHubReportMetrics

func IssueHubReportMetrics(reports map[string]*report.HubReport)

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 .....

func IssueReportMetrics

func IssueReportMetrics(report *report.Report)

IssueReportMetrics .....

func RunSkyfire

func RunSkyfire(configPath string)

RunSkyfire ...

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

func (config *Config) GetLogLevel() (log.Level, error)

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) SetHubs

func (sc *Scraper) SetHubs(hosts []string)

SetHubs .....

func (*Scraper) StartKubeScrapes

func (sc *Scraper) StartKubeScrapes()

StartKubeScrapes .....

func (*Scraper) StartPerceptorScrapes

func (sc *Scraper) StartPerceptorScrapes()

StartPerceptorScrapes .....

func (*Scraper) StartScraping

func (sc *Scraper) StartScraping()

StartScraping .....

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

func NewSkyfire(config *Config, stop <-chan struct{}) (*Skyfire, error)

NewSkyfire .....

func (*Skyfire) BuildReport

func (sf *Skyfire) BuildReport()

BuildReport .....

func (*Skyfire) HandleScrapes

func (sf *Skyfire) HandleScrapes()

HandleScrapes .....

func (*Skyfire) LatestReportHandler

func (sf *Skyfire) LatestReportHandler() func(http.ResponseWriter, *http.Request)

LatestReportHandler .....

func (*Skyfire) SetHubs

func (sf *Skyfire) SetHubs(hosts []string)

SetHubs ...