webhook

type DLQ interface {
	// Push 入队一条死信。
	Push(rec DeliveryRecord)
	// Pop 取出最早一条死信(无则返回 ok=false)。
	Pop() (DeliveryRecord, bool)
	// Len 当前死信数量。
	Len() int
}

type DeliveryRecord struct {
	EventID     string
	EndpointURL string
	Status      DeliveryStatus
	Attempts    int
	LastErr     string
	At          time.Time
}

type DeliveryStatus string

type Endpoint struct {
	URL string
	// Events 为空表示接收所有事件；否则仅接收 Type 在列表中的事件。
	Events []string
	// Headers 附加请求头。
	Headers map[string]string
	// Secret 非空时对 body 做 HMAC-SHA256 签名，写入 X-Webhook-Signature: sha256=<hex>。
	Secret string
	// BodyTemplate 为空时 body = JSON(Payload)；否则用 text/template 渲染整个 Event
	//（可用 {{.Type}} / {{.Payload.Field}}）。
	BodyTemplate string
	// contains filtered or unexported fields
}

type Event struct {
	Type    string
	Payload any
	EventID string // 业务幂等键;为空则不去重
}

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

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

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

type Option func(*Notifier)

type Store interface {
	// MarkDelivered 标记 (endpoint, eventID) 为"投递中/已投递"。
	// 返回 true 表示本次标记生效(之前未标记过),false 表示已标记过(应跳过)。
	MarkDelivered(endpointURL, eventID string) bool
	// UnmarkDelivered 撤销 MarkDelivered 的标记(投递失败时调用,允许后续重试)。
	UnmarkDelivered(endpointURL, eventID string)
	// RecordFailed 记录一次最终失败的投递(用于状态追踪)。
	RecordFailed(rec DeliveryRecord)
	// RecordDelivered 记录一次成功的投递(用于状态追踪)。
	RecordDelivered(rec DeliveryRecord)
}