server

Documentation

Index

• type Config
• type Emitter
  • func NewAPIEmitter(kubeconfig string) (Emitter, error)
  • func NewKubeletEmitter(source string) Emitter
• type Metric
• type MetricsBundle
  • func (b *MetricsBundle) Metrics() <-chan Metric
• type Publisher
  • func NewDogstatsdPublisher(dest string, tags []string) (Publisher, error)
  • func NewLogPublisher() Publisher
• type Server
  • func New(cfg Config) (*Server, error)
  • func (s *Server) Run()

Types

type Config

type Config struct {
	Emitter       Emitter
	DogStatsDHost string
	Period        time.Duration
	Tags          []string
	NoPublish     bool
}

type Emitter

type Emitter interface {
	Emit() (MetricsBundle, error)
}

func NewAPIEmitter

func NewAPIEmitter(kubeconfig string) (Emitter, error)

func NewKubeletEmitter

func NewKubeletEmitter(source string) Emitter

type Metric

type Metric struct {
	Name  string
	Value int
	Tags  []string
}

type MetricsBundle

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

func (*MetricsBundle) Metrics

func (b *MetricsBundle) Metrics() <-chan Metric

type Publisher

type Publisher interface {
	Publish(MetricsBundle)
}

func NewDogstatsdPublisher

func NewDogstatsdPublisher(dest string, tags []string) (Publisher, error)

func NewLogPublisher

func NewLogPublisher() Publisher

type Server

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

func New

func New(cfg Config) (*Server, error)

func (*Server) Run

func (s *Server) Run()