common

Documentation

Index

• func GetIPForVersion(data datasource.Data, version, ipAddr datasource.FieldAccessor) (string, error)
• type K8sInventoryCache
  • func GetK8sInventoryCache() (K8sInventoryCache, error)
• type SlimObjectMeta
• type SlimPod
  • func NewSlimPod(p *v1.Pod) *SlimPod
• type SlimPodSpec
• type SlimPodStatus
• type SlimService
  • func NewSlimService(s *v1.Service) *SlimService
• type SlimServiceSpec

Functions

func GetIPForVersion

func GetIPForVersion(data datasource.Data, version, ipAddr datasource.FieldAccessor) (string, error)

Types

type K8sInventoryCache

type K8sInventoryCache interface {
	Start()
	Stop()

	GetPods() []*SlimPod
	GetPodByName(namespace string, name string) *SlimPod
	GetPodByIp(ip string) *SlimPod

	GetSvcs() []*SlimService
	GetSvcByName(namespace string, name string) *SlimService
	GetSvcByIp(ip string) *SlimService
}

K8sInventoryCache is a cache of Kubernetes resources such as pods and services that can be used by operators to enrich events.

func GetK8sInventoryCache

func GetK8sInventoryCache() (K8sInventoryCache, error)

type SlimObjectMeta

type SlimObjectMeta struct {
	Name            string                  `json:"name"`
	Namespace       string                  `json:"namespace"`
	ResourceVersion string                  `json:"resourceVersion"`
	Labels          map[string]string       `json:"labels"`
	OwnerReferences []metav1.OwnerReference `json:"ownerReferences"`
}

type SlimPod

type SlimPod struct {
	metav1.TypeMeta `json:",inline"`
	SlimObjectMeta  `json:",inline"`
	Spec            SlimPodSpec   `json:"spec"`
	Status          SlimPodStatus `json:"status"`
}

SlimPod is a reduced version of v1.Pod, it only contains the fields that are needed to enrich events.

func NewSlimPod

func NewSlimPod(p *v1.Pod) *SlimPod

type SlimPodSpec

type SlimPodSpec struct {
	HostNetwork bool   `json:"hostNetwork"`
	NodeName    string `json:"nodeName"`
}

type SlimPodStatus

type SlimPodStatus struct {
	HostIP string `json:"hostIP"`
	PodIP  string `json:"podIP"`
}

type SlimService

type SlimService struct {
	metav1.TypeMeta `json:",inline"`
	SlimObjectMeta  `json:",inline"`
	Spec            SlimServiceSpec `json:"spec"`
}

SlimService is a reduced version of v1.Service, it only contains the fields that are needed to enrich events.

func NewSlimService

func NewSlimService(s *v1.Service) *SlimService

type SlimServiceSpec

type SlimServiceSpec struct {
	ClusterIP string `json:"clusterIP"`
}