kube

Documentation

Index

• type Database
  • func CreateDatabase(kubeMetadata *kube.Metadata) Database
  • func StartDatabase(kubeMetadata *kube.Metadata) (*Database, error)
  • func (id *Database) AddProcess(pid uint32)
  • func (id *Database) CleanProcessCaches(ns uint32)
  • func (id *Database) HostNameForIP(ip string) string
  • func (id *Database) NodeInfoForIP(ip string) *kube.NodeInfo
  • func (id *Database) OnDeletion(containerID []string)
  • func (id *Database) OwnerPodInfo(pidNamespace uint32) (*kube.PodInfo, bool)
  • func (id *Database) PodInfoForIP(ip string) *kube.PodInfo
  • func (id *Database) ServiceInfoForIP(ip string) *kube.ServiceInfo
  • func (id *Database) ServiceNameNamespaceForIP(ip string) (string, string)
  • func (id *Database) UpdateDeletedNodesByIPIndex(svc *kube.NodeInfo)
  • func (id *Database) UpdateDeletedPodsByIPIndex(pod *kube.PodInfo)
  • func (id *Database) UpdateDeletedServicesByIPIndex(svc *kube.ServiceInfo)
  • func (id *Database) UpdateNewNodesByIPIndex(svc *kube.NodeInfo)
  • func (id *Database) UpdateNewPodsByIPIndex(pod *kube.PodInfo)
  • func (id *Database) UpdateNewServicesByIPIndex(svc *kube.ServiceInfo)
  • func (id *Database) UpdatePodsByIPIndex(oldPod, newPod *kube.PodInfo)

Types

type Database

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

Database aggregates Kubernetes information from multiple sources: - the informer that keep an indexed copy of the existing pods and replicasets. - the inspected container.Info objects, indexed either by container ID and PID namespace - a cache of decorated PodInfo that would avoid reconstructing them on each trace decoration

func CreateDatabase

func CreateDatabase(kubeMetadata *kube.Metadata) Database

func StartDatabase

func StartDatabase(kubeMetadata *kube.Metadata) (*Database, error)

func (*Database) AddProcess

func (id *Database) AddProcess(pid uint32)

AddProcess also searches for the container.Info of the passed PID

func (*Database) CleanProcessCaches

func (id *Database) CleanProcessCaches(ns uint32)

func (*Database) HostNameForIP

func (id *Database) HostNameForIP(ip string) string

func (*Database) NodeInfoForIP

func (id *Database) NodeInfoForIP(ip string) *kube.NodeInfo

func (*Database) OnDeletion

func (id *Database) OnDeletion(containerID []string)

OnDeletion implements ContainerEventHandler

func (*Database) OwnerPodInfo

func (id *Database) OwnerPodInfo(pidNamespace uint32) (*kube.PodInfo, bool)

OwnerPodInfo returns the information of the pod owning the passed namespace

func (*Database) PodInfoForIP

func (id *Database) PodInfoForIP(ip string) *kube.PodInfo

func (*Database) ServiceInfoForIP

func (id *Database) ServiceInfoForIP(ip string) *kube.ServiceInfo

func (*Database) ServiceNameNamespaceForIP

func (id *Database) ServiceNameNamespaceForIP(ip string) (string, string)

func (*Database) UpdateDeletedNodesByIPIndex

func (id *Database) UpdateDeletedNodesByIPIndex(svc *kube.NodeInfo)

func (*Database) UpdateDeletedPodsByIPIndex

func (id *Database) UpdateDeletedPodsByIPIndex(pod *kube.PodInfo)

func (*Database) UpdateDeletedServicesByIPIndex

func (id *Database) UpdateDeletedServicesByIPIndex(svc *kube.ServiceInfo)

func (*Database) UpdateNewNodesByIPIndex

func (id *Database) UpdateNewNodesByIPIndex(svc *kube.NodeInfo)

func (*Database) UpdateNewPodsByIPIndex

func (id *Database) UpdateNewPodsByIPIndex(pod *kube.PodInfo)

func (*Database) UpdateNewServicesByIPIndex

func (id *Database) UpdateNewServicesByIPIndex(svc *kube.ServiceInfo)

func (*Database) UpdatePodsByIPIndex

func (id *Database) UpdatePodsByIPIndex(oldPod, newPod *kube.PodInfo)