Documentation
¶
Index ¶
- func GenerateBytesConnectors() map[string]any
- func GenerateCountConnectors() map[string]any
- func GenerateRoutingConnectorForBridgesTenantPipeline(tenantName string, pipeline *otelv1beta1.Pipeline, bridges []v1alpha1.Bridge)
- type BytesConnector
- type BytesConnectorAttributes
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GenerateBytesConnectors ¶
func GenerateCountConnectors ¶
func GenerateRoutingConnectorForBridgesTenantPipeline ¶
func GenerateRoutingConnectorForBridgesTenantPipeline(tenantName string, pipeline *otelv1beta1.Pipeline, bridges []v1alpha1.Bridge)
Types ¶
type BytesConnector ¶
type BytesConnector struct {
Description string `json:"description,omitempty"`
Attributes []BytesConnectorAttributes `json:"attributes,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"`
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
Click to show internal directories.
Click to hide internal directories.