ebpf

Documentation

Index

• func NewManager(client client.Client, logger logr.Logger, opts InstrumentationManagerOptions, ...) (instrumentation.Manager, error)
• type ConfigProvider
  • func NewConfigProvider[C any](initialConfig C) *ConfigProvider[C]
  • func (c *ConfigProvider[C]) InitialConfig(_ context.Context) C
  • func (c *ConfigProvider[C]) SendConfig(ctx context.Context, newConfig C) error
  • func (c *ConfigProvider[C]) Shutdown(_ context.Context) error
  • func (c *ConfigProvider[C]) Watch() <-chan C
• type InstrumentationHealth
• type InstrumentationManagerOptions
• type InstrumentationStatusReason
• type K8sConfigGroup
• type K8sProcessDetails
  • func (kd K8sProcessDetails) String() string

Functions

func NewManager

func NewManager(client client.Client, logger logr.Logger, opts InstrumentationManagerOptions, configUpdates <-chan instrumentation.ConfigUpdate[K8sConfigGroup]) (instrumentation.Manager, error)

NewManager creates a new instrumentation manager for eBPF which is configured to work with Kubernetes. Instrumentation factories must be provided in order to create the instrumentation objects. Detector options can be provided to configure the process detector, but if not provided, default options will be used.

Types

type ConfigProvider

type ConfigProvider[C any] struct {
	// contains filtered or unexported fields
}

func NewConfigProvider

func NewConfigProvider[C any](initialConfig C) *ConfigProvider[C]

NewConfigProvider creates a new configProvider with the given initial config. It allows for updating the configuration of a running instrumentation.

func (*ConfigProvider[C]) InitialConfig

func (c *ConfigProvider[C]) InitialConfig(_ context.Context) C

func (*ConfigProvider[C]) SendConfig

func (c *ConfigProvider[C]) SendConfig(ctx context.Context, newConfig C) error

SendConfig sends a new configuration to the instrumentation. If the instrumentation was closed or cannot accept the new configuration within a configured timeout, an error is returned.

func (*ConfigProvider[C]) Shutdown

func (c *ConfigProvider[C]) Shutdown(_ context.Context) error

func (*ConfigProvider[C]) Watch

func (c *ConfigProvider[C]) Watch() <-chan C

type InstrumentationHealth

type InstrumentationHealth bool

const (
	InstrumentationHealthy   InstrumentationHealth = true
	InstrumentationUnhealthy InstrumentationHealth = false
)

type InstrumentationManagerOptions

type InstrumentationManagerOptions struct {
	Factories          map[instrumentation.OtelDistribution]instrumentation.Factory
	DistributionGetter *distros.Getter
}

type InstrumentationStatusReason

type InstrumentationStatusReason string

const (
	FailedToLoad       InstrumentationStatusReason = "FailedToLoad"
	FailedToInitialize InstrumentationStatusReason = "FailedToInitialize"
	LoadedSuccessfully InstrumentationStatusReason = "LoadedSuccessfully"
	FailedToRun        InstrumentationStatusReason = "FailedToRun"
)

type K8sConfigGroup

type K8sConfigGroup struct {
	Pw   k8sconsts.PodWorkload
	Lang common.ProgrammingLanguage
}

type K8sProcessDetails

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

func (K8sProcessDetails) String

func (kd K8sProcessDetails) String() string