processor

package

v0.0.0-...-4c477b2 Latest Latest Go to latest Published: Oct 27, 2025 License: Apache-2.0 Imports: 6 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/kube-logging/telemetry-controller

Documentation ¶

Index ¶

Constants
func GenerateBatchProcessorForOutput(batch v1alpha1.Batch) map[string]any
func GenerateDefaultKubernetesProcessor() map[string]any
func GenerateFilterProcessor() map[string]any
func GenerateMetricsProcessors() map[string]any
func GenerateProcessorMemoryLimiter(memoryLimiter v1alpha1.MemoryLimiter) map[string]any
func GenerateTransformProcessorForTenantPipeline(tenantName string, pipeline *otelv1beta1.Pipeline, tenants []v1alpha1.Tenant)
type Action
type AttributesProcessor
type AttributesProcessorAction
type DeltaToCumulativeConfig
type TransformProcessor
- func GenerateTransformProcessorForTenant(tenant v1alpha1.Tenant) TransformProcessor
type TransformProcessorStatement

Constants ¶

View Source

const DefaultDeltaToCumulativeProcessorID = "deltatocumulative"

Variables ¶

This section is empty.

Functions ¶

func GenerateBatchProcessorForOutput ¶

func GenerateBatchProcessorForOutput(batch v1alpha1.Batch) map[string]any

func GenerateDefaultKubernetesProcessor ¶

func GenerateDefaultKubernetesProcessor() map[string]any

func GenerateFilterProcessor ¶

func GenerateFilterProcessor() map[string]any

func GenerateMetricsProcessors ¶

func GenerateMetricsProcessors() map[string]any

func GenerateProcessorMemoryLimiter ¶

func GenerateProcessorMemoryLimiter(memoryLimiter v1alpha1.MemoryLimiter) map[string]any

func GenerateTransformProcessorForTenantPipeline ¶

func GenerateTransformProcessorForTenantPipeline(tenantName string, pipeline *otelv1beta1.Pipeline, tenants []v1alpha1.Tenant)

Types ¶

type Action ¶

type Action string

const (
	ActionInsert  Action = "insert"
	ActionUpdate  Action = "update"
	ActionUpsert  Action = "upsert"
	ActionDelete  Action = "delete"
	ActionHash    Action = "hash"
	ActionExtract Action = "extract"
	ActionConvert Action = "convert"
)

type AttributesProcessor ¶

type AttributesProcessor struct {
	Actions []AttributesProcessorAction `json:"actions"`
}

func GenerateOutputExporterNameProcessor ¶

func GenerateOutputExporterNameProcessor(outputName string) AttributesProcessor

func GenerateSubscriptionAttributeProcessor ¶

func GenerateSubscriptionAttributeProcessor(subscriptionName string) AttributesProcessor

func GenerateTenantAttributeProcessor ¶

func GenerateTenantAttributeProcessor(tenantName string) AttributesProcessor

type AttributesProcessorAction ¶

type AttributesProcessorAction struct {
	Action        Action `json:"action"`
	Key           string `json:"key"`
	Value         string `json:"value,omitempty"`
	FromAttribute string `json:"from_attribute,omitempty"`
	FromContext   string `json:"from_context,omitempty"`
}

type DeltaToCumulativeConfig ¶

type DeltaToCumulativeConfig struct {
	MaxStale   time.Duration `json:"max_stale,omitempty"`
	MaxStreams int           `json:"max_streams,omitempty"`
}

type TransformProcessor ¶

type TransformProcessor struct {
	ErrorMode        components.ErrorMode          `json:"error_mode,omitempty"`
	FlattenData      bool                          `json:"flatten_data,omitempty"`
	TraceStatements  []TransformProcessorStatement `json:"trace_statements,omitempty"`
	MetricStatements []TransformProcessorStatement `json:"metric_statements,omitempty"`
	LogStatements    []TransformProcessorStatement `json:"log_statements,omitempty"`
}

func GenerateTransformProcessorForTenant ¶

func GenerateTransformProcessorForTenant(tenant v1alpha1.Tenant) TransformProcessor

type TransformProcessorStatement ¶

type TransformProcessorStatement struct {
	Context    string               `json:"context"`
	Conditions []string             `json:"conditions"`
	Statements []string             `json:"statements"`
	ErrorMde   components.ErrorMode `json:"error_mode,omitempty"`
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL