kubernetes

package

Go to main page

Versions in this module

v0

v0.6.0

Mar 19, 2024

Changes in this version

type Process

+ func (p *Process) ExposeHosts() []string

+ func (p *Process) PodContainer() *PodContainer

type ProcessFinder

+ CLI *kubernetes.Clientset

+ func (f *ProcessFinder) ShouldMonitor(pid int32) bool

type TemplatePodJudgment

+ func (t *TemplatePodJudgment) HasOwnerName(names string) bool

v0.5.0

Jun 14, 2023

v0.4.0

Dec 9, 2022

Changes in this version

type PodContainer

+ func (c *PodContainer) FindContainerFromSamePod(name string) *PodContainer

type TemplateContainer

+ func (c *TemplateContainer) EnvValue(names string) (string, error)

type TemplatePod

+ func (p *TemplatePod) FindContainer(name string) (*TemplateContainer, error)

v0.3.0

Sep 7, 2022

Changes in this version

type Process

+ func (p *Process) ExposePorts() []int

v0.2.0

Jun 1, 2022

v0.1.0

May 17, 2022

Changes in this version

+ func ProcessBuildersInit(builders []*ProcessBuilder) error

+ type Config struct

+ Active bool

+ Analyzers []*ProcessBuilder

+ Namespaces string

+ NodeName string

+ func (c *Config) ActiveFinder() bool

+ type EntityRenderContext struct

+ Container *TemplateContainer

+ Pod *TemplatePod

+ Process *base.TemplateProcess

+ Rover *base.TemplateRover

+ type FilterContext struct

+ Container *TemplateContainer

+ Pod *TemplatePodJudgment

+ Process *base.TemplateProcess

+ type MeshConfig struct

+ ServiceName string

+ type PodContainer struct

+ ContainerSpec v1.Container

+ ContainerStatus v1.ContainerStatus

+ Pod *v1.Pod

+ func AnalyzeContainers(pod *v1.Pod, registry *Registry) []*PodContainer

+ func (c *PodContainer) CGroupID() string

+ func (c *PodContainer) FindOwner(ctx context.Context, kindName string, k8sConfig *rest.Config) (*metav1.OwnerReference, error)

+ func (c *PodContainer) ServiceName() string

+ type Process struct

+ func NewProcess(p *process.Process, cmdline string, pc *PodContainer, ...) *Process

+ func (p *Process) DetectType() api.ProcessDetectType

+ func (p *Process) Entity() *api.ProcessEntity

+ func (p *Process) OriginalProcess() *process.Process

+ func (p *Process) Pid() int32

+ func (p *Process) ProfilingStat() *profiling.Info

+ type ProcessBuilder struct

+ Active bool

+ Filters []string

+ FiltersBuilder []*base.TemplateBuilder

+ InstanceName string

+ InstanceNameBuilder *base.TemplateBuilder

+ Labels []string

+ LabelsStr string

+ Layer string

+ ProcessName string

+ ProcessNameBuilder *base.TemplateBuilder

+ ServiceName string

+ ServiceNameBuilder *base.TemplateBuilder

+ type ProcessFinder struct

+ func (f *ProcessFinder) BuildEBPFProcess(ctx *base.BuildEBPFProcessContext, ps base.DetectedProcess) *v3.EBPFProcessProperties

+ func (f *ProcessFinder) BuildNecessaryProperties(ps base.DetectedProcess) []*commonv3.KeyStringValuePair

+ func (f *ProcessFinder) DetectType() api.ProcessDetectType

+ func (f *ProcessFinder) Init(ctx context.Context, conf base.FinderBaseConfig, manager base.ProcessManager) error

+ func (f *ProcessFinder) ParseProcessID(ps base.DetectedProcess, downstream *v3.EBPFProcessDownstream) string

+ func (f *ProcessFinder) Start()

+ func (f *ProcessFinder) Stop() error

+ func (f *ProcessFinder) ValidateProcessIsSame(p1, p2 base.DetectedProcess) bool

+ type Registry struct

+ func NewRegistry(cli *kubernetes.Clientset, namespaces []string, nodeName string) *Registry

+ func (r *Registry) BuildPodContainers() map[string]*PodContainer

+ func (r *Registry) FindServiceName(namespace, podName string) string

+ func (r *Registry) OnAdd(_ interface{})

+ func (r *Registry) OnDelete(_ interface{})

+ func (r *Registry) OnUpdate(_, _ interface{})

+ func (r *Registry) Start(stopChan chan struct{})

+ type TemplateContainer struct

+ func (c *TemplateContainer) ID() string

+ func (c *TemplateContainer) Name() string

+ type TemplatePod struct

+ func (p *TemplatePod) LabelValue(names string) (string, error)

+ func (p *TemplatePod) Name() string

+ func (p *TemplatePod) Namespace() string

+ func (p *TemplatePod) Node() string

+ func (p *TemplatePod) OwnerName(kindNames string) (string, error)

+ func (p *TemplatePod) ServiceName() string

+ type TemplatePodJudgment struct

+ func (t *TemplatePodJudgment) HasContainer(name string) bool

+ func (t *TemplatePodJudgment) HasServiceName() bool

+ func (t *TemplatePodJudgment) LabelSelector(selector string) (bool, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL