app

Documentation

Index

• type Config
  • func LoadConfig(log *log.Logger) Config
• type MetricScraper
  • func NewMetricScraper(cfg Config, l *log.Logger, m metricsClient) *MetricScraper
  • func (m *MetricScraper) Run()
  • func (m *MetricScraper) Stop()

Types

type Config

type Config struct {
	// Loggregator Agent Certs
	ClientKeyPath  string `env:"CLIENT_KEY_PATH, report, required"`
	ClientCertPath string `env:"CLIENT_CERT_PATH, report, required"`
	CACertPath     string `env:"CA_CERT_PATH, report, required"`

	// System Metrics Agent Certs
	MetricsKeyPath    string `env:"METRICS_KEY_PATH, report, required"`
	MetricsCertPath   string `env:"METRICS_CERT_PATH, report, required"`
	MetricsCACertPath string `env:"METRICS_CA_CERT_PATH, report, required"`
	MetricsCN         string `env:"METRICS_CA_CN, report, required"`

	LoggregatorIngressAddr string `env:"LOGGREGATOR_AGENT_ADDR, report, required"`
	DefaultSourceID        string `env:"DEFAULT_SOURCE_ID, report, required"`

	ScrapeInterval time.Duration `env:"SCRAPE_INTERVAL, report"`
	ScrapeTimeout  time.Duration `env:"SCRAPE_TIMEOUT, report"`
	ScrapePort     int           `env:"SCRAPE_PORT, report, required"`
	DebugPort      int           `env:"DEBUG_PORT, report"`

	DNSFile              string `env:"DNS_FILE, report, required"`
	LeadershipServerAddr string `env:"LEADERSHIP_SERVER_ADDR, report"`
}

func LoadConfig

func LoadConfig(log *log.Logger) Config

type MetricScraper

type MetricScraper struct {
	// contains filtered or unexported fields
}

func NewMetricScraper

func NewMetricScraper(cfg Config, l *log.Logger, m metricsClient) *MetricScraper

func (*MetricScraper) Run

func (m *MetricScraper) Run()

func (*MetricScraper) Stop

func (m *MetricScraper) Stop()