receiver

package
v0.0.0-...-b273383 Latest Latest
Warning

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

Go to latest
Published: Jan 12, 2026 License: Apache-2.0 Imports: 30 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type InnerReceivers

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

func (*InnerReceivers) AddAMConfigReceiver

func (r *InnerReceivers) AddAMConfigReceiver(ctx core.Context, receiver amconfig.Receiver) error

func (*InnerReceivers) DeleteAMConfigReceiver

func (r *InnerReceivers) DeleteAMConfigReceiver(ctx core.Context, name string) error

func (*InnerReceivers) GetAMConfigReceiver

func (r *InnerReceivers) GetAMConfigReceiver(ctx core.Context, filter *request.AMConfigReceiverFilter, pageParam *request.PageParam) ([]amconfig.Receiver, int)

func (*InnerReceivers) GetSlienceConfigByAlertID

func (r *InnerReceivers) GetSlienceConfigByAlertID(ctx core.Context, alertID string) (*sc.AlertSlienceConfig, error)

func (*InnerReceivers) HandleAlertCheckRecord

func (r *InnerReceivers) HandleAlertCheckRecord(ctx core.Context, record *model.WorkflowRecord) error

func (*InnerReceivers) HandleAlertEvent

func (r *InnerReceivers) HandleAlertEvent(ctx core.Context, alerts []alert.AlertEvent) error

func (*InnerReceivers) ListSlienceConfig

func (r *InnerReceivers) ListSlienceConfig(ctx core.Context) ([]sc.AlertSlienceConfig, error)

func (*InnerReceivers) RemoveSlienceConfigByAlertID

func (r *InnerReceivers) RemoveSlienceConfigByAlertID(ctx core.Context, alertID string) error

func (*InnerReceivers) SetSlienceConfigByAlertID

func (r *InnerReceivers) SetSlienceConfigByAlertID(ctx core.Context, alertID string, forDuration string) error

func (*InnerReceivers) UpdateAMConfigReceiver

func (r *InnerReceivers) UpdateAMConfigReceiver(ctx core.Context, receiver amconfig.Receiver, oldName string) error

type Receivers

type Receivers interface {
	HandleAlertEvent(ctx core.Context, alerts []alert.AlertEvent) error
	HandleAlertCheckRecord(ctx core.Context, record *model.WorkflowRecord) error

	GetAMConfigReceiver(ctx core.Context, filter *request.AMConfigReceiverFilter, pageParam *request.PageParam) ([]amconfig.Receiver, int)
	AddAMConfigReceiver(ctx core.Context, receiver amconfig.Receiver) error
	UpdateAMConfigReceiver(ctx core.Context, receiver amconfig.Receiver, oldName string) error
	DeleteAMConfigReceiver(ctx core.Context, name string) error

	ListSlienceConfig(ctx core.Context) ([]slienceconfig.AlertSlienceConfig, error)
	GetSlienceConfigByAlertID(ctx core.Context, alertID string) (*slienceconfig.AlertSlienceConfig, error)
	SetSlienceConfigByAlertID(ctx core.Context, alertID string, forDuration string) error
	RemoveSlienceConfigByAlertID(ctx core.Context, alertID string) error
}

func SetupReceiver

func SetupReceiver(externalURL string, logger *zap.Logger, dbRepo database.Repo, chRepo clickhouse.Repo) (Receivers, error)

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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