scraper

Documentation

Index

• Variables
• func License()
• func Query(query string) map[string]interface{}
• func Scraper(OKASAN_SCRAPERS map[string]*OkasanScraper)
• type KodomoScraper
  • func NewKodomoScraper(name string, window string, sleepTime int8) *KodomoScraper
• type Metrics
  • func NewMetrics() *Metrics
• type OkasanScraper
  • func NewOkasanScraper(name string, window string, sleepTime int8) *OkasanScraper
• type StopChan
  • func NewStopChan() *StopChan
  • func (s *StopChan) Stop()

Variables

var (
	PROMSERVER      = "http://prometheus-kube-prometheus-prometheus.default.svc.cluster.local:9090/api/v1/query?query="
	NODENAMES       = miporin.GetNodenames()
	CLIENTSET       = miporin.GetClientSet()
	DYNCLIENT       = miporin.GetDynamicClient()
	OKASAN_SCRAPERS = map[string]*OkasanScraper{}
)

Functions

func License

func License()

func Query

func Query(query string) map[string]interface{}

func Scraper

func Scraper(OKASAN_SCRAPERS map[string]*OkasanScraper)

Types

type KodomoScraper

type KodomoScraper struct {
	Name    string
	Metrics *Metrics

	Okasan     *OkasanScraper
	PodOnNode  map[string]int32
	Weight     [][]int32
	ScrapeStop *StopChan
	// contains filtered or unexported fields
}

func NewKodomoScraper

func NewKodomoScraper(
	name string,
	window string,
	sleepTime int8,
) *KodomoScraper

type Metrics

type Metrics struct {
	Servt [][]int32
	Respt [][]int32
}

func NewMetrics

func NewMetrics() *Metrics

type OkasanScraper

type OkasanScraper struct {
	Name    string
	Latency [][]int32
	Window  string

	Kodomo map[string]*KodomoScraper
	// contains filtered or unexported fields
}

func NewOkasanScraper

func NewOkasanScraper(
	name string,
	window string,
	sleepTime int8,
) *OkasanScraper

type StopChan

type StopChan struct {
	Kodomo chan bool
}

func NewStopChan

func NewStopChan() *StopChan

func (*StopChan) Stop

func (s *StopChan) Stop()