runtime_details

Documentation

Index

• func GetRuntimeDetails(ctx context.Context, kubeClient client.Client, podWorkload *common.PodWorkload) (*odigosv1.InstrumentedApplication, error)
• func SetupWithManager(mgr ctrl.Manager) error
• type DaemonSetsReconciler
  • func (d *DaemonSetsReconciler) Reconcile(ctx context.Context, request ctrl.Request) (ctrl.Result, error)
• type DeploymentsReconciler
  • func (d *DeploymentsReconciler) Reconcile(ctx context.Context, request 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 StatefulSetsReconciler
  • func (s *StatefulSetsReconciler) Reconcile(ctx context.Context, request 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 GetRuntimeDetails

func GetRuntimeDetails(ctx context.Context, kubeClient client.Client, podWorkload *common.PodWorkload) (*odigosv1.InstrumentedApplication, error)

func SetupWithManager

func SetupWithManager(mgr ctrl.Manager) error

Types

type DaemonSetsReconciler

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

func (*DaemonSetsReconciler) Reconcile

func (d *DaemonSetsReconciler) Reconcile(ctx context.Context, request ctrl.Request) (ctrl.Result, error)

type DeploymentsReconciler

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

func (*DeploymentsReconciler) Reconcile

func (d *DeploymentsReconciler) Reconcile(ctx context.Context, request 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
}

func (*OdigosConfigReconciler) Reconcile

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

type StatefulSetsReconciler

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

func (*StatefulSetsReconciler) Reconcile

func (s *StatefulSetsReconciler) Reconcile(ctx context.Context, request 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