shared

package
v0.6.2-rc1 Latest Latest
Warning

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

Go to latest
Published: Nov 15, 2022 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Overview

Shared definitions (constants & errors) for opni alerting

Index

Constants

View Source
const (
	AlertingV1Alpha      = "v1alpha"
	MonitoringDatasource = "monitoring"
	LoggingDatasource    = "logging"
	SystemDatasource     = "system"
)
View Source
const (
	ConfigMountPath                        = "/etc/config"
	DataMountPath                          = "/var/lib/alertmanager/data"
	AlertManagerConfigKey                  = "alertmanager.yaml"
	InternalRoutingConfigKey               = "internal-routing.yaml"
	OperatorAlertingControllerServiceName  = "opni-alerting-controller"
	OperatorAlertingClusterNodeServiceName = "opni-alerting"
	AlertingHookReceiverName               = "opni.hook"
	AlertingCortexHookHandler              = "/management/alerting/cortexHandler"
)
View Source
const (
	AgentDisconnectStream         = "opni_alerting_agent"
	AgentDisconnectStreamSubjects = "opni_alerting_agent.*"
	AgentDisconnectBucket         = "opni-alerting-agent-bucket"
)

Jetstream streams

View Source
const BackendConditionIdLabel = "conditionId"
View Source
const LocalAlertManagerPath = "/tmp/alertmanager.yaml"
View Source
const LocalBackendEnvToggle = "OPNI_ALERTING_BACKEND_LOCAL"

Variables

View Source
var (
	PublicLabels        = map[string]string{}
	PublicServiceLabels = map[string]string{}
)
View Source
var (
	AlertingErrNotImplemented           = WithUnimplementedError("Not implemented")
	AlertingErrNotImplementedNOOP       = WithUnimplementedError("Alerting NOOP : Not implemented")
	AlertingErrParseBucket              = WithInternalServerError("Failed to parse bucket index")
	AlertingErrBucketIndexInvalid       = WithInternalServerError("Bucket index is invalid")
	AlertingErrInvalidSlackChannel      = validation.Error("Slack channel invalid : must start with '#'")
	AlertingErrK8sRuntime               = WithInternalServerError("K8s Runtime error")
	AlertingErrMismatchedImplementation = validation.Error("Alerting endpoint did not match the given implementation")
)
View Source
var DefaultAlertManager = template.Must(template.New("DefaultManagementHook").Parse(strings.Join([]string{
	strings.TrimSpace(route),
	receivers,
	strings.TrimSpace(inihibit_rules),
}, "\n")))

Functions

func BackendDefaultFile added in v0.6.0

func BackendDefaultFile(managementUrl string) error

func DefaultAlertManagerConfig added in v0.6.1

func DefaultAlertManagerConfig(managementUrl string) (bytes.Buffer, error)

func LabelWithAlert added in v0.6.0

func LabelWithAlert(label map[string]string) map[string]string

func NewAgentDisconnectSubject added in v0.6.1

func NewAgentDisconnectSubject(agentId string) string

func NewAlertingDisconnectStream added in v0.6.1

func NewAlertingDisconnectStream() *nats.StreamConfig

func WithInternalServerError added in v0.6.0

func WithInternalServerError(msg string) error

func WithInternalServerErrorf added in v0.6.0

func WithInternalServerErrorf(format string, args ...interface{}) error

func WithNotFoundError added in v0.6.0

func WithNotFoundError(msg string) error

func WithNotFoundErrorf added in v0.6.0

func WithNotFoundErrorf(format string, args ...interface{}) error

func WithUnimplementedError

func WithUnimplementedError(msg string) error

func WithUnimplementedErrorf

func WithUnimplementedErrorf(format string, args ...interface{}) error

Types

type AlertingOptions added in v0.6.0

type AlertingOptions struct {
	Endpoints         []string
	ConfigMap         string
	Namespace         string
	StatefulSet       string
	CortexHookHandler string
}

type DefaultAlertManagerInfo added in v0.6.0

type DefaultAlertManagerInfo struct {
	CortexHandlerName string
	CortexHandlerURL  string
}

type InternalServerError added in v0.6.0

type InternalServerError struct {
	// contains filtered or unexported fields
}

func (*InternalServerError) Error added in v0.6.0

func (e *InternalServerError) Error() string

func (*InternalServerError) GRPCStatus added in v0.6.0

func (e *InternalServerError) GRPCStatus() *status.Status

type NewAlertingOptions added in v0.6.0

type NewAlertingOptions struct {
	Namespace             string
	WorkerNodesService    string
	WorkerNodePort        int
	WorkerStatefulSet     string
	ControllerNodeService string
	ControllerNodePort    int
	ControllerClusterPort int
	ControllerStatefulSet string
	ConfigMap             string
	ManagementHookHandler string
}

func (*NewAlertingOptions) GetControllerEndpoint added in v0.6.0

func (a *NewAlertingOptions) GetControllerEndpoint() string

func (*NewAlertingOptions) GetWorkerEndpoint added in v0.6.0

func (a *NewAlertingOptions) GetWorkerEndpoint() string

type NotFoundError added in v0.6.0

type NotFoundError struct {
	// contains filtered or unexported fields
}

func (*NotFoundError) Error added in v0.6.0

func (e *NotFoundError) Error() string

func (*NotFoundError) GRPCStatus added in v0.6.0

func (e *NotFoundError) GRPCStatus() *status.Status

type UnimplementedError

type UnimplementedError struct {
	// contains filtered or unexported fields
}

func (*UnimplementedError) Error

func (e *UnimplementedError) Error() string

func (*UnimplementedError) GRPCStatus

func (e *UnimplementedError) GRPCStatus() *status.Status

Jump to

Keyboard shortcuts

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