kube

Nov 23, 2024

Changes in this version

+ var InfoForPID = container.InfoForPID

+ func TopOwner(pod *informer.PodInfo) *informer.Owner

+ type MetaSourceLabels struct

+ ServiceName string

+ ServiceNamespace string

+ type MetadataConfig struct

+ DisabledInformers []string

+ Enable kubeflags.EnableFlag

+ KubeConfigPath string

+ MetaCacheAddr string

+ MetaSourceLabels MetaSourceLabels

+ ResyncPeriod time.Duration

+ SyncTimeout time.Duration

type MetadataProvider

+ func (mp *MetadataProvider) CurrentNodeName(ctx context.Context) (string, error)

+ type OTelServiceNamePair struct

+ Name string

+ Namespace string

+ type Store struct

+ func NewStore(kubeMetadata meta.Notifier, sourceLabels MetaSourceLabels) *Store

+ func (s *Store) AddProcess(pid uint32)

+ func (s *Store) DeleteProcess(pid uint32)

+ func (s *Store) ID() string

+ func (s *Store) ObjectMetaByIP(ip string) *informer.ObjectMeta

+ func (s *Store) On(event *informer.Event) error

+ func (s *Store) PodByContainerID(cid string) *informer.ObjectMeta

+ func (s *Store) PodContainerByPIDNs(pidns uint32) (*informer.ObjectMeta, string)

+ func (s *Store) ServiceNameNamespaceForIP(ip string) (string, string)

+ func (s *Store) ServiceNameNamespaceForMetadata(om *informer.ObjectMeta) (string, string)

+ func (s *Store) Subscribe(observer meta.Observer)

Sep 2, 2024

Changes in this version

type Metadata

+ func (k *Metadata) AddNodeEventHandler(h cache.ResourceEventHandler) error

Jul 30, 2024

Changes in this version

+ const IndexIP

+ const InformerNode

+ const InformerReplicaSet

+ const InformerService

+ type IPInfo struct

+ HostIP string

+ HostName string

+ IPs []string

+ Kind string

+ Owner Owner

type Metadata

+ func (k *Metadata) AddServiceIPEventHandler(s cache.ResourceEventHandler) error

+ func (k *Metadata) GetInfo(ip string) (*IPInfo, *metav1.ObjectMeta, bool)

+ type MetadataProvider struct

+ func NewMetadataProvider(enable kubeflags.EnableFlag, disabledInformers []string, kubeConfigPath string, ...) *MetadataProvider

+ func (mp *MetadataProvider) ForceDisable()

+ func (mp *MetadataProvider) Get(ctx context.Context) (*Metadata, error)

+ func (mp *MetadataProvider) IsKubeEnabled() bool

+ func (mp *MetadataProvider) KubeClient() (kubernetes.Interface, error)

+ type NodeInfo struct

+ IPInfo IPInfo

type Owner

+ Kind string

type PodInfo

+ IPInfo IPInfo

+ type ServiceInfo struct

+ IPInfo IPInfo

May 21, 2024

Changes in this version

type Owner

+ LabelName OwnerLabel

+ func OwnerFrom(orefs []metav1.OwnerReference) *Owner

+ type OwnerLabel attr.Name

type ReplicaSetInfo

+ Owner *Owner

Apr 19, 2024

Changes in this version

type PodInfo

+ IPs []string

+ func (i *PodInfo) ServiceName() string

Jan 26, 2024

Changes in this version

+ const DaemonSetName

+ const DeploymentName

+ const NamespaceName

+ const NodeName

+ const OwnerDaemonSet

+ const OwnerDeployment

+ const OwnerReplicaSet

+ const OwnerStatefulSet

+ const OwnerUnknown

+ const PodName

+ const PodStartTime

+ const PodUID

+ const ReplicaSetName

+ const StatefulSetName

+ type Owner struct

+ Name string

+ Owner *Owner

+ Type OwnerType

+ func OwnerFromPodInfo(pod *v1.Pod) *Owner

+ func (o *Owner) String() string

+ type OwnerType int

+ func (o OwnerType) LabelName() string

type PodInfo

+ Owner *Owner

Jan 18, 2024

Changes in this version

+ const IndexPodByContainerIDs

+ const IndexReplicaSetNames

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

+ type ContainerEventHandler interface

+ OnDeletion func(containerID []string)

+ type Metadata struct

+ 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(client kubernetes.Interface, timeout time.Duration) error

+ type PodInfo struct

+ ContainerIDs []string

+ DeploymentName string

+ NodeName string

+ ReplicaSetName string

+ StartTimeStr string

+ type ReplicaSetInfo struct

+ DeploymentName string