internal

Documentation

Index

• Variables
• type Service
  • func NewService(opts ServiceOpts) (*Service, error)
  • func (s *Service) CleanupPrometheusTargets()
  • func (s *Service) PingNodes() error
  • func (s *Service) PrometheusForTarget(target string) (*ServicePrometheus, error)
  • func (s *Service) Run(stop <-chan os.Signal) error
  • func (s *Service) UpdateNodes() error
• type ServiceNode
• type ServiceOpts
• type ServicePrometheus
  • func (sp ServicePrometheus) Register() error
  • func (sp ServicePrometheus) Unregister()

Variables

var (
	Debug = log.New(os.Stderr, "DEBUG: ", log.Ltime|log.Lshortfile)
	Info  = log.New(os.Stderr, "INFO:  ", log.Ltime|log.Lshortfile)
	Error = log.New(os.Stderr, "ERROR: ", log.Ltime|log.Lshortfile)
)

Types

type Service

type Service struct {
	Opts       ServiceOpts
	Ctx        context.Context
	Config     *rest.Config
	Clientset  *kubernetes.Clientset
	Nodes      []ServiceNode
	Prometheus map[string]*ServicePrometheus
	// contains filtered or unexported fields
}

func NewService

func NewService(opts ServiceOpts) (*Service, error)

func (*Service) CleanupPrometheusTargets

func (s *Service) CleanupPrometheusTargets()

func (*Service) PingNodes

func (s *Service) PingNodes() error

func (*Service) PrometheusForTarget

func (s *Service) PrometheusForTarget(target string) (*ServicePrometheus, error)

func (*Service) Run

func (s *Service) Run(stop <-chan os.Signal) error

func (*Service) UpdateNodes

func (s *Service) UpdateNodes() error

type ServiceNode

type ServiceNode struct {
	Name       string
	InternalIP net.IP
}

type ServiceOpts

type ServiceOpts struct {
	SelfNodeName string
	Interval     time.Duration
}

type ServicePrometheus

type ServicePrometheus struct {
	Reachable       prometheus.Gauge
	Latency         prometheus.Histogram
	PacketsSent     prometheus.Counter
	PacketsReceived prometheus.Counter
	PacketsLost     prometheus.Counter
}

func (ServicePrometheus) Register

func (sp ServicePrometheus) Register() error

func (ServicePrometheus) Unregister

func (sp ServicePrometheus) Unregister()