controller

Documentation

Index

• type Client
  • func NewClient(host string, port uint, client *http.Client) (*Client, error)
  • func (c *Client) GetMetrics() (*Metrics, error)
• type Metrics
  • func NewMetrics(body []byte) (*Metrics, error)
• type Source
  • func NewSource(cfg *monitor.SourceConfig) (*Source, error)
  • func (s *Source) GetTimeSeriesReq() (*v3.CreateTimeSeriesRequest, error)
  • func (s *Source) Name() string
  • func (s *Source) ProjectPath() string
• type Translator
  • func NewTranslator(zone, project, cluster, instanceID string, resolution time.Duration) *Translator
  • func (t *Translator) Translate(metrics *Metrics) (*v3.CreateTimeSeriesRequest, error)

Types

type Client

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

Client queries metrics from the controller process.

func NewClient

func NewClient(host string, port uint, client *http.Client) (*Client, error)

NewClient generates a client to hit the given controller.

func (*Client) GetMetrics

func (c *Client) GetMetrics() (*Metrics, error)

GetMetrics returns the latest Metrics parsed from the kube-controller endpoint.

type Metrics

type Metrics struct {
	CreateTime    int64
	NodeEvictions int64
}

Metrics are parsed values from the kube-controller.

func NewMetrics

func NewMetrics(body []byte) (*Metrics, error)

NewMetrics creates a Metrics object from a Prometheus response body.

type Source

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

Source pulls data from the controller source, and translates it for GCMv3.

func NewSource

func NewSource(cfg *monitor.SourceConfig) (*Source, error)

NewSource creates a new Source for a kube-controller.

func (*Source) GetTimeSeriesReq

func (s *Source) GetTimeSeriesReq() (*v3.CreateTimeSeriesRequest, error)

GetTimeSeriesReq returns the GCM v3 TimeSeries data.

func (*Source) Name

func (s *Source) Name() string

Name returns the name of the component being monitored.

func (*Source) ProjectPath

func (s *Source) ProjectPath() string

ProjectPath returns the project's path in a way Stackdriver understands.

type Translator

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

Translator contains the required information to perform translations from kubelet summarys to GCM's GKE metrics.

func NewTranslator

func NewTranslator(zone, project, cluster, instanceID string, resolution time.Duration) *Translator

NewTranslator creates a new Translator with the given fields.

func (*Translator) Translate

func (t *Translator) Translate(metrics *Metrics) (*v3.CreateTimeSeriesRequest, error)

Translate a summary to its TimeSeries.