consumer

Documentation

Index

• type WebhookConsumer
  • func NewWebhookConsumer(logger *zap.Logger, cache cache.WebhookCache, dao dao.WebhookDao, ...) WebhookConsumer

Types

type WebhookConsumer

type WebhookConsumer interface {
	// AlertReceiveConsumerManager 管理告警接收的消费者
	AlertReceiveConsumerManager(ctx context.Context) error
	// HandleAlert 处理单个告警接收
	HandleAlert(ctx context.Context, alert template.Alert)
}

WebhookConsumer 定义了Webhook消费者的接口

func NewWebhookConsumer

func NewWebhookConsumer(logger *zap.Logger, cache cache.WebhookCache, dao dao.WebhookDao, content content.WebhookContent, alertReceiveQueue chan template.Alert) WebhookConsumer

NewWebhookConsumer 创建一个新的WebhookConsumer实例