routing

package
v0.10.0-rc4 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 31, 2023 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	OpniSubRoutingTreeMatcher *labels.Matcher = &labels.Matcher{
		Type:  labels.MatchEqual,
		Name:  alertingv1.RoutingPropertyDatasource,
		Value: "",
	}

	OpniMetricsSubRoutingTreeMatcher *labels.Matcher = &labels.Matcher{
		Type:  labels.MatchEqual,
		Name:  alertingv1.RoutingPropertyDatasource,
		Value: wellknown.CapabilityMetrics,
	}

	OpniSeverityTreeMatcher *labels.Matcher = &labels.Matcher{
		Type:  labels.MatchNotEqual,
		Name:  alertingv1.NotificationPropertySeverity,
		Value: "",
	}
)
View Source
var OpniMetricsSubRoutingTreeId config.Matchers = []*labels.Matcher{
	OpniMetricsSubRoutingTreeMatcher,
}

Functions

func FinalizerReceiver added in v0.9.0

func FinalizerReceiver(embeddedServerHook string) *config.Receiver

func NewNamespaceLeaf added in v0.9.0

func NewNamespaceLeaf(
	rl rateLimitingConfig,
	opniConfigs []config.OpniReceiver,
	matchers []*labels.Matcher,
	receiverId string,
) (*config.Route, *config.Receiver)

new namespace matcher

func NewNamespaceTree added in v0.9.0

func NewNamespaceTree(namespace string, defaultValues ...RouteValues) (*config.Route, []*config.Receiver)

func NewNotificationLeaf added in v0.9.0

func NewNotificationLeaf(namespace string, value RouteValues) (*config.Route, *config.Receiver)

func NewOpniMetricsSubtree

func NewOpniMetricsSubtree() *config.Route

this subtree connects to cortex

func NewOpniSubRoutingTree

func NewOpniSubRoutingTree() (*config.Route, []*config.Receiver)

returns the subtree & the default receivers contains the setup for broadcasting and conditions

func NewRootNode added in v0.9.0

func NewRootNode(embeddedServerHook string) *config.Config

This needs to expand all labels, due to assumptions we make about external backends like AiOps pushing messages to the severity tree

func NewRoutingTree added in v0.9.0

func NewRoutingTree(embeddedServerHook string) *config.Config

func NotificationSubTreeLabel added in v0.9.0

func NotificationSubTreeLabel() string

Types

type OpniRouterV1

type OpniRouterV1 struct {
	HookEndpoint url.URL `yaml:"hookEndpoint,omitempty" json:"hookEndpoint,omitempty"`
	// Contains an AlertManager config not created and managed by Opni
	SyncedConfig *config.Config `yaml:"embeddedConfig,omitempty" json:"embeddedConfig,omitempty"`

	// defaultNamespaceValue -> endpointId -> OpniConfig
	DefaultNamespaceConfigs defaultNamespaceConfigs `yaml:"defaultNamespaceConfigs,omitempty" json:"defaultNamespaceConfigs,omitempty"`
	// namespace -> routeId -> endpointId -> OpniConfig
	NamespacedSpecs namespacedSpecs `yaml:"namespacedSpecs,omitempty" json:"namespacedSpecs,omitempty"`
	// namespace -> routeId -> 	rateLimitingConfig
	NamespacedRateLimiting namespaceRateLimiting `yaml:"namespacedRateLimiting,omitempty" json:"namespacedRateLimiting,omitempty"`
}

indexes using endpointId for scalability

func NewOpniRouterV1

func NewOpniRouterV1(hookEndpoint *url.URL) *OpniRouterV1

func (*OpniRouterV1) BuildConfig

func (o *OpniRouterV1) BuildConfig() (*config.Config, error)

func (*OpniRouterV1) Clone

func (o *OpniRouterV1) Clone() OpniRouting

func (*OpniRouterV1) DeleteEndpoint

func (o *OpniRouterV1) DeleteEndpoint(id string) error

func (*OpniRouterV1) HasLabels

func (o *OpniRouterV1) HasLabels(routingId string) []*labels.Matcher

func (*OpniRouterV1) HasReceivers

func (o *OpniRouterV1) HasReceivers(routingId string) []string

func (*OpniRouterV1) MarshalYAML

func (o *OpniRouterV1) MarshalYAML() ([]byte, error)

func (*OpniRouterV1) Merge

func (o *OpniRouterV1) Merge(_ OpniRouting) (OpniRouting, error)

func (*OpniRouterV1) Search

func (o *OpniRouterV1) Search(map[string]string) []*config.Route

func (*OpniRouterV1) SetDefaultNamespaceConfig

func (o *OpniRouterV1) SetDefaultNamespaceConfig(endpoints []*alertingv1.AlertEndpoint) error

func (*OpniRouterV1) SetDefaultReceiver added in v0.9.0

func (o *OpniRouterV1) SetDefaultReceiver(endpoint url.URL)

func (*OpniRouterV1) SetNamespaceSpec

func (o *OpniRouterV1) SetNamespaceSpec(namespace, routeId string, specs *alertingv1.FullAttachedEndpoints) error

func (*OpniRouterV1) SyncExternalConfig

func (o *OpniRouterV1) SyncExternalConfig(content []byte) error

func (*OpniRouterV1) UnmarshalYAML

func (o *OpniRouterV1) UnmarshalYAML(unmarshal func(interface{}) error) error

func (*OpniRouterV1) UpdateEndpoint

func (o *OpniRouterV1) UpdateEndpoint(id string, spec *alertingv1.AlertEndpoint) error

func (*OpniRouterV1) Walk

func (o *OpniRouterV1) Walk(map[string]string, func(int, *config.Route) error) error

type OpniRouting

type OpniRouting interface {
	ProductionConfigSyncer
	RoutingIdentifer

	yaml.Unmarshaler
	MarshalYAML() ([]byte, error)

	SetDefaultNamespaceConfig(endps []*alertingv1.AlertEndpoint) error
	SetNamespaceSpec(namespace string, routeId string, specs *alertingv1.FullAttachedEndpoints) error
	// When an already attached endpoint is updated, propagate updates to the routing tree
	UpdateEndpoint(id string, spec *alertingv1.AlertEndpoint) error
	// When an already attached endpoint is delete, propagate all deletions to the routing tree
	DeleteEndpoint(endpointId string) error

	// Converts OpniRouting to a valid AlertManager config
	// Returns a NotFound error if the a route to update or delete is not found
	// Returns a Conflict error if we try to insert a duplicate config, unique up to its keys
	BuildConfig() (*config.Config, error)
	Clone() OpniRouting
}

OpniRouting Responsible for handling the mapping of ids to configured endpoints, including indexing external configs

func NewDefaultOpniRouting

func NewDefaultOpniRouting() OpniRouting

func NewDefaultOpniRoutingWithOverrideHook

func NewDefaultOpniRoutingWithOverrideHook(hook string) OpniRouting

type ProductionConfigSyncer

type ProductionConfigSyncer interface {
	// Walks the tree of routes in the config, calling the given function
	Walk(map[string]string, func(depth int, r *config.Route) error) error
	// Returns the routes that match the given labels
	Search(labels map[string]string) []*config.Route
	// Merges two OpniRouting objects (also includes merging plain AlertManager configs for users)
	Merge(other OpniRouting) (OpniRouting, error)
	// Converts a valid AlertManager config to OpniRouting
	// Returns an FailedPrecondition error if the config cannot be unmarshalled,
	// Returns an InternalServerError if the config is invalid
	SyncExternalConfig(content []byte) error
}

WIP

type RouteValues added in v0.9.0

type RouteValues lo.Tuple2[string, rateLimitingConfig]

RouteValues (receiver name, rate limiting config)

func NotificationSubTreeValues added in v0.9.0

func NotificationSubTreeValues() []RouteValues

! values must be returned sorted in a deterministic order

these are used by the router to catch eveyrthing that is not an explicit alarm that is also part of opni, i.e. plain text notifications

type RoutingIdentifer

type RoutingIdentifer interface {
	HasLabels(routingId string) []*labels.Matcher
	HasReceivers(routingId string) []string
	SetDefaultReceiver(endpoint url.URL)
}

Jump to

Keyboard shortcuts

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