actions

Documentation

Index

• Constants
• func SetupWithManager(mgr ctrl.Manager) error
• type AddClusterInfoReconciler
  • func (r *AddClusterInfoReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *AddClusterInfoReconciler) ReportReconciledToProcessor(ctx context.Context, action *actionv1.AddClusterInfo) error
  • func (r *AddClusterInfoReconciler) ReportReconciledToProcessorFailed(ctx context.Context, action *actionv1.AddClusterInfo, reason string, ...) error
• type DeleteAttributeReconciler
  • func (r *DeleteAttributeReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *DeleteAttributeReconciler) ReportReconciledToProcessor(ctx context.Context, action *actionv1.DeleteAttribute) error
  • func (r *DeleteAttributeReconciler) ReportReconciledToProcessorFailed(ctx context.Context, action *actionv1.DeleteAttribute, reason string, ...) error
• type OdigosSamplingReconciler
  • func (r *OdigosSamplingReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *OdigosSamplingReconciler) ReportReconciledToProcessor(ctx context.Context, action metav1.Object) error
  • func (r *OdigosSamplingReconciler) ReportReconciledToProcessorFailed(ctx context.Context, action metav1.Object, reason, msg string) error
• type OttlStatementConfig
• type PiiMaskingConfig
• type PiiMaskingReconciler
  • func (r *PiiMaskingReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *PiiMaskingReconciler) ReportReconciledToProcessor(ctx context.Context, action *actionv1.PiiMasking) error
  • func (r *PiiMaskingReconciler) ReportReconciledToProcessorFailed(ctx context.Context, action *actionv1.PiiMasking, reason string, msg string) error
• type ProbabilisticSamplerConfig
• type ProbabilisticSamplerReconciler
  • func (r *ProbabilisticSamplerReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *ProbabilisticSamplerReconciler) ReportReconciledToProcessor(ctx context.Context, action *actionv1.ProbabilisticSampler) error
  • func (r *ProbabilisticSamplerReconciler) ReportReconciledToProcessorFailed(ctx context.Context, action *actionv1.ProbabilisticSampler, reason string, ...) error
• type RenameAttributeReconciler
  • func (r *RenameAttributeReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *RenameAttributeReconciler) ReportReconciledToProcessor(ctx context.Context, action *actionv1.RenameAttribute) error
  • func (r *RenameAttributeReconciler) ReportReconciledToProcessorFailed(ctx context.Context, action *actionv1.RenameAttribute, reason string, ...) error
• type TransformProcessorConfig

Constants

const (
	// Processor types
	SamplingProcessorType = "odigossampling"
	GroupByTraceType      = "groupbytrace"
)

const (

	// ProcessorCreatedReason is added to the action when the processor CR is created.
	ProcessorCreatedReason = "ProcessorCreated"
	// FailedToCreateProcessorReason is added to the action when the processor CR creation fails.
	FailedToCreateProcessorReason = "FailedToCreateProcessor"
	// FailedToTransformToProcessorReason is added to the action when the transformation to processor object fails.
	FailedToTransformToProcessorReason = "FailedToTransformToProcessor"
)

Reasons for action condition types

const (
	// TransformedToProcessor is the condition when the action CR is transformed to a processor CR.
	// This is the first step in the reconciliation process.
	ActionTransformedToProcessorType = "TransformedToProcessor"
)

These are the valid conditions for an odigos action

Functions

func SetupWithManager

func SetupWithManager(mgr ctrl.Manager) error

Types

type AddClusterInfoReconciler

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

func (*AddClusterInfoReconciler) Reconcile

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

func (*AddClusterInfoReconciler) ReportReconciledToProcessor

func (r *AddClusterInfoReconciler) ReportReconciledToProcessor(ctx context.Context, action *actionv1.AddClusterInfo) error

func (*AddClusterInfoReconciler) ReportReconciledToProcessorFailed

func (r *AddClusterInfoReconciler) ReportReconciledToProcessorFailed(ctx context.Context, action *actionv1.AddClusterInfo, reason string, msg string) error

type DeleteAttributeReconciler

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

func (*DeleteAttributeReconciler) Reconcile

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

func (*DeleteAttributeReconciler) ReportReconciledToProcessor

func (r *DeleteAttributeReconciler) ReportReconciledToProcessor(ctx context.Context, action *actionv1.DeleteAttribute) error

func (*DeleteAttributeReconciler) ReportReconciledToProcessorFailed

func (r *DeleteAttributeReconciler) ReportReconciledToProcessorFailed(ctx context.Context, action *actionv1.DeleteAttribute, reason string, msg string) error

type OdigosSamplingReconciler

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

func (*OdigosSamplingReconciler) Reconcile

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

func (*OdigosSamplingReconciler) ReportReconciledToProcessor

func (r *OdigosSamplingReconciler) ReportReconciledToProcessor(ctx context.Context, action metav1.Object) error

func (*OdigosSamplingReconciler) ReportReconciledToProcessorFailed

func (r *OdigosSamplingReconciler) ReportReconciledToProcessorFailed(ctx context.Context, action metav1.Object, reason, msg string) error

type OttlStatementConfig

type OttlStatementConfig struct {
	Context    string   `json:"context"`
	Statements []string `json:"statements"`
}

type PiiMaskingConfig

type PiiMaskingConfig struct {
	AllowAllKeys  bool     `json:"allow_all_keys"`
	BlockedValues []string `json:"blocked_values"`
}

type PiiMaskingReconciler

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

func (*PiiMaskingReconciler) Reconcile

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

func (*PiiMaskingReconciler) ReportReconciledToProcessor

func (r *PiiMaskingReconciler) ReportReconciledToProcessor(ctx context.Context, action *actionv1.PiiMasking) error

func (*PiiMaskingReconciler) ReportReconciledToProcessorFailed

func (r *PiiMaskingReconciler) ReportReconciledToProcessorFailed(ctx context.Context, action *actionv1.PiiMasking, reason string, msg string) error

type ProbabilisticSamplerConfig

type ProbabilisticSamplerConfig struct {
	Value    float64 `json:"sampling_percentage"`
	HashSeed int     `json:"hash_seed"`
}

type ProbabilisticSamplerReconciler

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

func (*ProbabilisticSamplerReconciler) Reconcile

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

func (*ProbabilisticSamplerReconciler) ReportReconciledToProcessor

func (r *ProbabilisticSamplerReconciler) ReportReconciledToProcessor(ctx context.Context, action *actionv1.ProbabilisticSampler) error

func (*ProbabilisticSamplerReconciler) ReportReconciledToProcessorFailed

func (r *ProbabilisticSamplerReconciler) ReportReconciledToProcessorFailed(ctx context.Context, action *actionv1.ProbabilisticSampler, reason string, msg string) error

type RenameAttributeReconciler

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

func (*RenameAttributeReconciler) Reconcile

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

func (*RenameAttributeReconciler) ReportReconciledToProcessor

func (r *RenameAttributeReconciler) ReportReconciledToProcessor(ctx context.Context, action *actionv1.RenameAttribute) error

func (*RenameAttributeReconciler) ReportReconciledToProcessorFailed

func (r *RenameAttributeReconciler) ReportReconciledToProcessorFailed(ctx context.Context, action *actionv1.RenameAttribute, reason string, msg string) error

type TransformProcessorConfig

type TransformProcessorConfig struct {
	ErrorMode        string                `json:"error_mode"`
	TraceStatements  []OttlStatementConfig `json:"trace_statements,omitempty"`
	MetricStatements []OttlStatementConfig `json:"metric_statements,omitempty"`
	LogStatements    []OttlStatementConfig `json:"log_statements,omitempty"`
}