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) OnDeletion(containerID []string)
  • func (id *Database) OwnerPodInfo(pidNamespace uint32) (*kube.PodInfo, bool)
  • func (id *Database) PodInfoForIP(ip string) *kube.PodInfo
  • func (id *Database) UpdateDeletedPodsByIPIndex(pod *kube.PodInfo)
  • func (id *Database) UpdateNewPodsByIPIndex(pod *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) 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) UpdateDeletedPodsByIPIndex

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

func (*Database) UpdateNewPodsByIPIndex

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