workload

Documentation

Index

• func GetRuntimeObjectName(name string, kind string) string
• func GetWorkloadInfoRuntimeName(name string) (workloadName string, workloadKind string, err error)
• func GetWorkloadKind(w client.Object) string
• func IsInstrumentationDisabledExplicitly(obj client.Object) bool
• func IsObjectLabeledForInstrumentation(obj client.Object) bool
• func IsWorkloadInstrumentationEffectiveEnabled(ctx context.Context, kubeClient client.Client, obj client.Object) (bool, error)
• type DaemonSetWorkload
  • func (d *DaemonSetWorkload) AvailableReplicas() int32
• type DeploymentWorkload
  • func (d *DeploymentWorkload) AvailableReplicas() int32
• type StatefulSetWorkload
  • func (s *StatefulSetWorkload) AvailableReplicas() int32
• type Workload
  • func ObjectToWorkload(obj client.Object) (Workload, error)

Functions

func GetRuntimeObjectName

func GetRuntimeObjectName(name string, kind string) string

runtime name is a way to store workload specific CRs with odigos and give the k8s object a name which is unique and can be used to extract the workload name and kind

func GetWorkloadInfoRuntimeName

func GetWorkloadInfoRuntimeName(name string) (workloadName string, workloadKind string, err error)

func GetWorkloadKind

func GetWorkloadKind(w client.Object) string

func IsInstrumentationDisabledExplicitly

func IsInstrumentationDisabledExplicitly(obj client.Object) bool

func IsObjectLabeledForInstrumentation

func IsObjectLabeledForInstrumentation(obj client.Object) bool

func IsWorkloadInstrumentationEffectiveEnabled

func IsWorkloadInstrumentationEffectiveEnabled(ctx context.Context, kubeClient client.Client, obj client.Object) (bool, error)

Types

type DaemonSetWorkload

type DaemonSetWorkload struct {
	*v1.DaemonSet
}

func (*DaemonSetWorkload) AvailableReplicas

func (d *DaemonSetWorkload) AvailableReplicas() int32

type DeploymentWorkload

type DeploymentWorkload struct {
	*v1.Deployment
}

func (*DeploymentWorkload) AvailableReplicas

func (d *DeploymentWorkload) AvailableReplicas() int32

type StatefulSetWorkload

type StatefulSetWorkload struct {
	*v1.StatefulSet
}

func (*StatefulSetWorkload) AvailableReplicas

func (s *StatefulSetWorkload) AvailableReplicas() int32

type Workload

type Workload interface {
	client.Object
	AvailableReplicas() int32
}

func ObjectToWorkload

func ObjectToWorkload(obj client.Object) (Workload, error)