startlangdetection

Documentation

Index

• func SetupWithManager(mgr ctrl.Manager) error
• type DaemonSetReconciler
  • func (r *DaemonSetReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
• type DeploymentReconciler
  • func (r *DeploymentReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
• type NamespacesReconciler
  • func (n *NamespacesReconciler) Reconcile(ctx context.Context, request ctrl.Request) (ctrl.Result, error)
• type OdigosConfigReconciler
  • func (r *OdigosConfigReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
• type StatefulSetReconciler
  • func (r *StatefulSetReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
• type WorkloadEnabledPredicate
  • func (i *WorkloadEnabledPredicate) Create(e event.CreateEvent) bool
  • func (i *WorkloadEnabledPredicate) Delete(e event.DeleteEvent) bool
  • func (i *WorkloadEnabledPredicate) Generic(e event.GenericEvent) bool
  • func (i *WorkloadEnabledPredicate) Update(e event.UpdateEvent) bool

Functions

func SetupWithManager

func SetupWithManager(mgr ctrl.Manager) error

Types

type DaemonSetReconciler

type DaemonSetReconciler struct {
	client.Client
	Scheme *runtime.Scheme
}

func (*DaemonSetReconciler) Reconcile

func (r *DaemonSetReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

type DeploymentReconciler

type DeploymentReconciler struct {
	client.Client
	Scheme *runtime.Scheme
}

func (*DeploymentReconciler) Reconcile

func (r *DeploymentReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

type NamespacesReconciler

type NamespacesReconciler struct {
	client.Client
	Scheme *runtime.Scheme
}

func (*NamespacesReconciler) Reconcile

func (n *NamespacesReconciler) Reconcile(ctx context.Context, request ctrl.Request) (ctrl.Result, error)

type OdigosConfigReconciler

type OdigosConfigReconciler struct {
	client.Client
	Scheme *runtime.Scheme
}

This reconiler is responsible for recalculating the instrumented application for potential changes of ignored container list, and trigger runtime detection.

func (*OdigosConfigReconciler) Reconcile

func (r *OdigosConfigReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

type StatefulSetReconciler

type StatefulSetReconciler struct {
	client.Client
	Scheme *runtime.Scheme
}

func (*StatefulSetReconciler) Reconcile

func (r *StatefulSetReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

type WorkloadEnabledPredicate

type WorkloadEnabledPredicate struct {
	predicate.Funcs
}

this predicate is used for workload reconciler, and will only pass events where the workload is changed to odigos instrumentation enabled. This way, we don't need to run language detection downstream when unnecessary. This also helps in managing race conditions, where we might re-add runtime details which were just deleted by instrumentor controller and generate unnecessary noise in the k8s eventual consistency model.

func (*WorkloadEnabledPredicate) Create

func (i *WorkloadEnabledPredicate) Create(e event.CreateEvent) bool

func (*WorkloadEnabledPredicate) Delete

func (i *WorkloadEnabledPredicate) Delete(e event.DeleteEvent) bool

func (*WorkloadEnabledPredicate) Generic

func (i *WorkloadEnabledPredicate) Generic(e event.GenericEvent) bool

func (*WorkloadEnabledPredicate) Update

func (i *WorkloadEnabledPredicate) Update(e event.UpdateEvent) bool