processor

Documentation

Index

• func GenerateBatchProcessorForOutput(batch v1alpha1.Batch) map[string]any
• func GenerateDefaultKubernetesProcessor() 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
  • func GenerateOutputExporterNameProcessor(outputName string) AttributesProcessor
  • func GenerateSubscriptionAttributeProcessor(subscriptionName string) AttributesProcessor
  • func GenerateTenantAttributeProcessor(tenantName string) AttributesProcessor
• type AttributesProcessorAction
• type DeltaToCumulativeConfig
• type TransformProcessor
  • func GenerateTransformProcessorForTenant(tenant v1alpha1.Tenant) TransformProcessor
• type TransformProcessorStatement

Functions

func GenerateBatchProcessorForOutput

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

func GenerateDefaultKubernetesProcessor

func GenerateDefaultKubernetesProcessor() 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"`
}