connector

Documentation

Index

• func GenerateCountConnectors() map[string]any
• func GenerateRoutingConnectorForBridgesTenantPipeline(tenantName string, pipeline *otelv1beta1.Pipeline, bridges []v1alpha1.Bridge)
• type CountConnectorAttributeConfig
• type CountConnectorMetricInfo
• type RoutingConnector
  • func GenerateRoutingConnectorForBridge(bridge v1alpha1.Bridge) RoutingConnector
  • func GenerateRoutingConnectorForSubscriptionsOutputs(subscriptionRef v1alpha1.NamespacedName, outputNames []v1alpha1.NamespacedName) RoutingConnector
  • func GenerateRoutingConnectorForTenantsSubscriptions(tenantName string, tenantRouteConfig v1alpha1.RouteConfig, ...) RoutingConnector
• type RoutingConnectorTableItem

Functions

func GenerateCountConnectors

func GenerateCountConnectors() map[string]any

func GenerateRoutingConnectorForBridgesTenantPipeline

func GenerateRoutingConnectorForBridgesTenantPipeline(tenantName string, pipeline *otelv1beta1.Pipeline, bridges []v1alpha1.Bridge)

Types

type CountConnectorAttributeConfig

type CountConnectorAttributeConfig struct {
	Key          string `json:"key,omitempty"`
	DefaultValue string `json:"default_value,omitempty"`
}

type CountConnectorMetricInfo

type CountConnectorMetricInfo struct {
	Description        string                          `json:"description,omitempty"`
	Conditions         []string                        `json:"conditions,omitempty"`
	Attributes         []CountConnectorAttributeConfig `json:"attributes,omitempty"`
	ResourceAttributes []CountConnectorAttributeConfig `json:"resource_attributes,omitempty"`
}

type RoutingConnector

type RoutingConnector struct {
	Name             string                      `json:"-"`
	DefaultPipelines []string                    `json:"default_pipelines,omitempty"`
	ErrorMode        components.ErrorMode        `json:"error_mode,omitempty"`
	MatchOnce        bool                        `json:"match_once,omitempty"`
	Table            []RoutingConnectorTableItem `json:"table"`
}

func GenerateRoutingConnectorForBridge

func GenerateRoutingConnectorForBridge(bridge v1alpha1.Bridge) RoutingConnector

func GenerateRoutingConnectorForSubscriptionsOutputs

func GenerateRoutingConnectorForSubscriptionsOutputs(subscriptionRef v1alpha1.NamespacedName, outputNames []v1alpha1.NamespacedName) RoutingConnector

func GenerateRoutingConnectorForTenantsSubscriptions

func GenerateRoutingConnectorForTenantsSubscriptions(tenantName string, tenantRouteConfig v1alpha1.RouteConfig, subscriptionNames []v1alpha1.NamespacedName, subscriptions map[v1alpha1.NamespacedName]v1alpha1.Subscription) RoutingConnector

type RoutingConnectorTableItem

type RoutingConnectorTableItem struct {
	Condition string   `json:"condition,omitempty"`
	Pipelines []string `json:"pipelines,omitempty"`
}