kube

Documentation

Index

• Constants
• func LoadConfig(kubeConfigPath string) (*rest.Config, error)
• type ContainerEventHandler
• type Metadata
  • func (k *Metadata) AddContainerEventHandler(eh ContainerEventHandler)
  • func (k *Metadata) AddPodEventHandler(h cache.ResourceEventHandler) error
  • func (k *Metadata) AddReplicaSetEventHandler(h cache.ResourceEventHandler) error
  • func (k *Metadata) FetchPodOwnerInfo(pod *PodInfo)
  • func (k *Metadata) GetContainerPod(containerID string) (*PodInfo, bool)
  • func (k *Metadata) GetReplicaSetInfo(namespace, name string) (*ReplicaSetInfo, bool)
  • func (k *Metadata) InitFromClient(ctx context.Context, client kubernetes.Interface, timeout time.Duration) error
• type Owner
  • func OwnerFromPodInfo(pod *v1.Pod) *Owner
  • func (o *Owner) String() string
• type OwnerType
  • func (o OwnerType) LabelName() string
• type PodInfo
  • func (i *PodInfo) ServiceName() string
• type ReplicaSetInfo

Constants

const (
	IndexPodByContainerIDs = "idx_pod_by_container"
	IndexReplicaSetNames   = "idx_rs"
)

const (
	NamespaceName   = "k8s.namespace.name"
	PodName         = "k8s.pod.name"
	DeploymentName  = "k8s.deployment.name"
	ReplicaSetName  = "k8s.replicaset.name"
	DaemonSetName   = "k8s.daemonset.name"
	StatefulSetName = "k8s.statefulset.name"
	NodeName        = "k8s.node.name"
	PodUID          = "k8s.pod.uid"
	PodStartTime    = "k8s.pod.start_time"
)

const (
	OwnerUnknown = OwnerType(iota)
	OwnerReplicaSet
	OwnerDeployment
	OwnerStatefulSet
	OwnerDaemonSet
)

Functions

func LoadConfig

func LoadConfig(kubeConfigPath string) (*rest.Config, error)

Types

type ContainerEventHandler

type ContainerEventHandler interface {
	OnDeletion(containerID []string)
}

ContainerEventHandler listens for the deletion of containers, as triggered by a Pod deletion.

type Metadata

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

Metadata stores an in-memory copy of the different Kubernetes objects whose metadata is relevant to us.

func (*Metadata) AddContainerEventHandler

func (k *Metadata) AddContainerEventHandler(eh ContainerEventHandler)

func (*Metadata) AddPodEventHandler

func (k *Metadata) AddPodEventHandler(h cache.ResourceEventHandler) error

func (*Metadata) AddReplicaSetEventHandler

func (k *Metadata) AddReplicaSetEventHandler(h cache.ResourceEventHandler) error

func (*Metadata) FetchPodOwnerInfo

func (k *Metadata) FetchPodOwnerInfo(pod *PodInfo)

FetchPodOwnerInfo updates the pod owner with the Deployment information, if it exists. Pod Info might include a ReplicaSet as owner, and ReplicaSet info usually has a Deployment as owner reference, which is the one that we'd really like to report as owner.

func (*Metadata) GetContainerPod

func (k *Metadata) GetContainerPod(containerID string) (*PodInfo, bool)

GetContainerPod fetches metadata from a Pod given the name of one of its containers

func (*Metadata) GetReplicaSetInfo

func (k *Metadata) GetReplicaSetInfo(namespace, name string) (*ReplicaSetInfo, bool)

GetReplicaSetInfo fetches metadata from a ReplicaSet given its name

func (*Metadata) InitFromClient

func (k *Metadata) InitFromClient(ctx context.Context, client kubernetes.Interface, timeout time.Duration) error

type Owner

type Owner struct {
	Type OwnerType
	Name string
	// Owner of the owner. For example, a ReplicaSet might be owned by a Deployment
	Owner *Owner
}

func OwnerFromPodInfo

func OwnerFromPodInfo(pod *v1.Pod) *Owner

OwnerFromPodInfo returns the pod Owner reference. It might be null if the Pod does not have any owner

func (*Owner) String

func (o *Owner) String() string

type OwnerType

type OwnerType int

func (OwnerType) LabelName

func (o OwnerType) LabelName() string

type PodInfo

type PodInfo struct {
	// Informers need that internal object is an ObjectMeta instance
	metav1.ObjectMeta
	NodeName string

	Owner *Owner

	// StartTimeStr caches value of ObjectMeta.StartTimestamp.String()
	StartTimeStr string
	ContainerIDs []string
	IPs          []string
}

PodInfo contains precollected metadata for Pods, Nodes and Services. Not all the fields are populated for all the above types. To save memory, we just keep in memory the necessary data for each Type. For more information about which fields are set for each type, please refer to the instantiation function of the respective informers.

func (*PodInfo) ServiceName

func (i *PodInfo) ServiceName() string

type ReplicaSetInfo

type ReplicaSetInfo struct {
	metav1.ObjectMeta
	DeploymentName string
}