sources

Documentation

Index

• Constants
• func CreateKubeSources(uri *url.URL, c cache.Cache) ([]api.Source, error)
• func NewCadvisorSources(uri *url.URL, _ cache.Cache) ([]api.Source, error)
• func NewKubeEvents(client *kubeclient.Client, ec cache.EventsCache) api.Source
• func NewKubeNodeMetrics(kubeletPort int, kubeletApi datasource.Kubelet, nodesApi nodes.NodesApi) api.Source
• func NewKubePodMetrics(kubeletPort int, kubeletApi datasource.Kubelet, nodesApi nodes.NodesApi, ...) api.Source
• func PostRequestAndGetValue(client *http.Client, req *http.Request, value interface{}) error

Constants

const (
	APIVersion = "v1"
)

const (
	KubeEventsSourceName = "Kube Events Source"
)

const (
	KubeNodeMetricsSourceName = "Kube Node Metrics Source"
)

const (
	KubePodsSourceName = "Kube Pods Source"
)

Functions

func CreateKubeSources

func CreateKubeSources(uri *url.URL, c cache.Cache) ([]api.Source, error)

func NewCadvisorSources

func NewCadvisorSources(uri *url.URL, _ cache.Cache) ([]api.Source, error)

func NewKubeEvents

func NewKubeEvents(client *kubeclient.Client, ec cache.EventsCache) api.Source

func NewKubeNodeMetrics

func NewKubeNodeMetrics(kubeletPort int, kubeletApi datasource.Kubelet, nodesApi nodes.NodesApi) api.Source

func NewKubePodMetrics

func NewKubePodMetrics(kubeletPort int, kubeletApi datasource.Kubelet, nodesApi nodes.NodesApi, podsApi podsApi) api.Source

func PostRequestAndGetValue

func PostRequestAndGetValue(client *http.Client, req *http.Request, value interface{}) error