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 OttlStatementConfig
• 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 (

	// 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 OttlStatementConfig

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

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"`
}