shared

Documentation

Overview

Shared definitions (constants & errors) for opni alerting

Index

• Constants
• Variables
• func BackendDefaultFile(managementUrl string) error
• func DefaultAlertManagerConfig(managementUrl string) (bytes.Buffer, error)
• func LabelWithAlert(label map[string]string) map[string]string
• func NewAgentDisconnectSubject(agentId string) string
• func NewAlertingDisconnectStream() *nats.StreamConfig
• func WithInternalServerError(msg string) error
• func WithInternalServerErrorf(format string, args ...interface{}) error
• func WithNotFoundError(msg string) error
• func WithNotFoundErrorf(format string, args ...interface{}) error
• func WithUnimplementedError(msg string) error
• func WithUnimplementedErrorf(format string, args ...interface{}) error
• type AlertingOptions
• type DefaultAlertManagerInfo
• type InternalServerError
  • func (e *InternalServerError) Error() string
  • func (e *InternalServerError) GRPCStatus() *status.Status
• type NewAlertingOptions
  • func (a *NewAlertingOptions) GetControllerEndpoint() string
  • func (a *NewAlertingOptions) GetWorkerEndpoint() string
• type NotFoundError
  • func (e *NotFoundError) Error() string
  • func (e *NotFoundError) GRPCStatus() *status.Status
• type UnimplementedError
  • func (e *UnimplementedError) Error() string
  • func (e *UnimplementedError) GRPCStatus() *status.Status

Constants

const (
	AlertingV1Alpha      = "v1alpha"
	MonitoringDatasource = "monitoring"
	LoggingDatasource    = "logging"
	SystemDatasource     = "system"
)

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"
)

const (
	AgentDisconnectStream         = "opni_alerting_agent"
	AgentDisconnectStreamSubjects = "opni_alerting_agent.*"
	AgentDisconnectBucket         = "opni-alerting-agent-bucket"
)

Jetstream streams

const BackendConditionIdLabel = "conditionId"

const LocalAlertManagerPath = "/tmp/alertmanager.yaml"

const LocalBackendEnvToggle = "OPNI_ALERTING_BACKEND_LOCAL"

Variables

var (
	PublicLabels        = map[string]string{}
	PublicServiceLabels = map[string]string{}
)

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")
)

var DefaultAlertManager = template.Must(template.New("DefaultManagementHook").Parse(strings.Join([]string{
	strings.TrimSpace(route),
	receivers,
	strings.TrimSpace(inihibit_rules),
}, "\n")))

Functions

func BackendDefaultFile

func BackendDefaultFile(managementUrl string) error

func DefaultAlertManagerConfig

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

func LabelWithAlert

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

func NewAgentDisconnectSubject

func NewAgentDisconnectSubject(agentId string) string

func NewAlertingDisconnectStream

func NewAlertingDisconnectStream() *nats.StreamConfig

func WithInternalServerError

func WithInternalServerError(msg string) error

func WithInternalServerErrorf

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

func WithNotFoundError

func WithNotFoundError(msg string) error

func WithNotFoundErrorf

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

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

type DefaultAlertManagerInfo

type DefaultAlertManagerInfo struct {
	CortexHandlerName string
	CortexHandlerURL  string
}

type InternalServerError

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

func (*InternalServerError) Error

func (e *InternalServerError) Error() string

func (*InternalServerError) GRPCStatus

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

type NewAlertingOptions

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

func (a *NewAlertingOptions) GetControllerEndpoint() string

func (*NewAlertingOptions) GetWorkerEndpoint

func (a *NewAlertingOptions) GetWorkerEndpoint() string

type NotFoundError

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

func (*NotFoundError) Error

func (e *NotFoundError) Error() string

func (*NotFoundError) GRPCStatus

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