backend

Dec 17, 2022

Changes in this version

type AlertManagerApiOption

+ func WithPostResolveAlertBody(conditionId string, annotations map[string]string) AlertManagerApiOption

Nov 23, 2022

Changes in this version

type AlertManagerAPI

+ func NewAlertManagerOpniConfigClient(ctx context.Context, endpoint string, opts ...AlertManagerApiOption) *AlertManagerAPI

Nov 8, 2022

Changes in this version

+ func ConvertEndpointIdsToRoutingNode(endpointList *alertingv1.AlertEndpointList, req *alertingv1.AttachedEndpoints, ...) (*alertingv1.RoutingNode, error)

+ func NewApiPipline(ctx context.Context, apis []*AlertManagerAPI, chainRetrier *backoffv2.Policy) error

+ func NewExpectConfigEqual(expectedConfig string) func(*http.Response) error

+ func NewExpectStatusCodes(expectedCodes []int) func(*http.Response) error

+ func NewExpectStatusOk() func(*http.Response) error

+ type Alert struct

+ GeneratorURL strfmt.URI

+ Labels LabelSet

+ type AlertGroup struct

+ Alerts []GettableAlert

+ Labels map[string]string

+ Receiver Receiver

type AlertManagerAPI

+ func NewAlertManagerDeleteSilenceClient(ctx context.Context, endpoint, silenceId string, opts ...AlertManagerApiOption) *AlertManagerAPI

+ func NewAlertManagerGetAlertsClient(ctx context.Context, endpoint string, opts ...AlertManagerApiOption) *AlertManagerAPI

+ func NewAlertManagerGetSilenceClient(ctx context.Context, endpoint string, opts ...AlertManagerApiOption) *AlertManagerAPI

+ func NewAlertManagerPostAlertClient(ctx context.Context, endpoint string, opts ...AlertManagerApiOption) *AlertManagerAPI

+ func NewAlertManagerPostSilenceClient(ctx context.Context, endpoint string, opts ...AlertManagerApiOption) *AlertManagerAPI

+ func NewAlertManagerReadyClient(ctx context.Context, endpoint string, opts ...AlertManagerApiOption) *AlertManagerAPI

+ func NewAlertManagerReceiversClient(ctx context.Context, endpoint string, opts ...AlertManagerApiOption) *AlertManagerAPI

+ func NewAlertManagerReloadClient(ctx context.Context, endpoint string, opts ...AlertManagerApiOption) *AlertManagerAPI

+ func NewAlertManagerStatusClient(ctx context.Context, endpoint string, opts ...AlertManagerApiOption) *AlertManagerAPI

+ func (a *AlertManagerAPI) DoRequest() error

+ func (a *AlertManagerAPI) WithAPIV1() *AlertManagerAPI

+ func (a *AlertManagerAPI) WithAPIV2() *AlertManagerAPI

+ type AlertManagerApiOption func(*AlertManagerApiOptions)

+ func WithDefaultRetrier() AlertManagerApiOption

+ func WithExpectClosure(expectClosure func(*http.Response) error) AlertManagerApiOption

+ func WithHttpClient(client *http.Client) AlertManagerApiOption

+ func WithLogger(logger *zap.SugaredLogger) AlertManagerApiOption

+ func WithPostAlertBody(conditionId string, annotations map[string]string) AlertManagerApiOption

+ func WithPostSilenceBody(conditionId string, duration time.Duration, silenceId *string) AlertManagerApiOption

+ func WithRequestBody(body io.Reader) AlertManagerApiOption

+ func WithRetrier(retrier backoffv2.Policy) AlertManagerApiOption

+ func WithURLValues(values url.Values) AlertManagerApiOption

+ type AlertManagerApiOptions struct

+ func NewDefaultAlertManagerOptions() *AlertManagerApiOptions

+ type AlertStatus struct

+ InhibitedBy []string

+ SilencedBy []string

+ State *string

+ type GettableAlert struct

+ Annotations LabelSet

+ EndsAt *strfmt.DateTime

+ Fingerprint *string

+ Receivers []*Receiver

+ StartsAt *strfmt.DateTime

+ Status *AlertStatus

+ UpdatedAt *strfmt.DateTime

+ type LabelSet map[string]string

+ type Receiver struct

+ Name *string

Oct 20, 2022

Changes in this version

+ const DELETE

+ const GET

+ const NoSMTPFromSet

+ const NoSmartHostSet

+ const POST

+ var FieldNotFound = regexp.MustCompile("line [0-9]+: field .* not found in type config.plain")

+ var RuntimeBinaryPath = "./"

+ func DeleteSilence(ctx context.Context, endpoint string, silence *DeletableSilence) (*http.Response, error)

+ func GetAlerts(ctx context.Context, endpoint string) (*http.Request, *http.Response, error)

+ func IsRateLimited(conditionId string, resp *http.Response, lg *zap.SugaredLogger) (bool, error)

+ func OnRetryResponse(req *http.Request, resp *http.Response) (*http.Response, error)

+ func PostAlert(ctx context.Context, endpoint string, alerts []*PostableAlert) (*http.Request, *http.Response, error)

+ func PostSilence(ctx context.Context, endpoint string, silence *PostableSilence) (*http.Response, error)

+ func ReconcileInvalidState(newConfig *config.ConfigMapData, incoming error) error

+ func ReconcileInvalidStateLoop(timeout time.Duration, newConfig *config.ConfigMapData, lg *zap.SugaredLogger) error

+ func ValidateIncomingConfig(fileContent string, lg *zap.SugaredLogger) error

+ type AlertManagerAPI struct

+ Api string

+ Endpoint string

+ Route string

+ Verb string

+ func (a *AlertManagerAPI) Construct() string

+ func (a *AlertManagerAPI) ConstructHTTP() string

+ func (a *AlertManagerAPI) ConstructHTTPS() string

+ func (a *AlertManagerAPI) IsHealthy() bool

+ func (a *AlertManagerAPI) IsReady() bool

+ func (a *AlertManagerAPI) WithHttpV1() *AlertManagerAPI

+ func (a *AlertManagerAPI) WithHttpV2() *AlertManagerAPI

+ type DeletableSilence struct

+ SilenceId string

+ func (d *DeletableSilence) Must() error

+ func (d *DeletableSilence) WithSilenceId(silenceId string)

+ type K8sEndpointBackend struct

+ Client client.Client

+ func (b *K8sEndpointBackend) Fetch(ctx context.Context, lg *zap.SugaredLogger, options shared.NewAlertingOptions, ...) (string, error)

+ func (b *K8sEndpointBackend) Port() int

+ func (b *K8sEndpointBackend) Put(ctx context.Context, lg *zap.SugaredLogger, options shared.NewAlertingOptions, ...) error

+ func (b *K8sEndpointBackend) Reload(ctx context.Context, lg *zap.SugaredLogger, options shared.NewAlertingOptions, ...) error

+ type LocalEndpointBackend struct

+ ConfigFilePath string

+ func (b *LocalEndpointBackend) Fetch(ctx context.Context, lg *zap.SugaredLogger, options shared.NewAlertingOptions, ...) (string, error)

+ func (b *LocalEndpointBackend) Port() int

+ func (b *LocalEndpointBackend) Put(ctx context.Context, lg *zap.SugaredLogger, options shared.NewAlertingOptions, ...) error

+ func (b *LocalEndpointBackend) Reload(ctx context.Context, lg *zap.SugaredLogger, options shared.NewAlertingOptions, ...) error

+ func (b *LocalEndpointBackend) Start(ctx context.Context, lg *zap.SugaredLogger)

+ type Matcher struct

+ IsEqual *bool

+ IsRegex bool

+ Name string

+ Value string

+ type PostSilencesResponse struct

+ SilenceID *string

+ func (p *PostSilencesResponse) GetSilenceId() string

+ type PostableAlert struct

+ Annotations *map[string]string

+ EndsAt *time.Time

+ GeneratorURL *string

+ Labels map[string]string

+ StartsAt *time.Time

+ func (p *PostableAlert) Must() error

+ func (p *PostableAlert) WithCondition(conditionId string)

+ func (p *PostableAlert) WithRuntimeInfo(key string, value string)

+ type PostableSilence struct

+ Comment string

+ CreatedBy string

+ EndsAt time.Time

+ Id *string

+ Matchers []Matcher

+ StartsAt time.Time

+ func (p *PostableSilence) Must() error

+ func (p *PostableSilence) WithCondition(conditionId string)

+ func (p *PostableSilence) WithDuration(dur time.Duration)

+ func (p *PostableSilence) WithSilenceId(silenceId string)

+ type RuntimeEndpointBackend interface

+ Fetch func(ctx context.Context, lg *zap.SugaredLogger, options shared.NewAlertingOptions, ...) (string, error)

+ Port func() int

+ Put func(ctx context.Context, lg *zap.SugaredLogger, options shared.NewAlertingOptions, ...) error

+ Reload func(ctx context.Context, lg *zap.SugaredLogger, options shared.NewAlertingOptions, ...) error