kubelet

Documentation

Index

• type Client
  • func NewClient(host string, port uint, client *http.Client) (*Client, error)
  • func (k *Client) GetSummary() (*stats.Summary, 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(...) *Translator
  • func (t *Translator) Translate(summary *stats.Summary) (*v3.CreateTimeSeriesRequest, error)

Types

type Client

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

Client contains all the information and methods to encapsulate communication with the Kubelet.

func NewClient

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

NewClient returns a new Client.

func (*Client) GetSummary

func (k *Client) GetSummary() (*stats.Summary, error)

GetSummary gets the kubelet's Summary metrics.

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 kubelet.

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, clusterLocation, instance, instanceID, schemaPrefix string, monitoredResourceLabels map[string]string, resolution time.Duration) *Translator

NewTranslator creates a new Translator with the given fields.

func (*Translator) Translate

func (t *Translator) Translate(summary *stats.Summary) (*v3.CreateTimeSeriesRequest, error)

Translate translates a summary to its TimeSeries.