channel

type BaseChannel struct {
	Bus       *bus.MessageBus // 关联的消息总线，用于转发入站消息
	AllowList map[string]bool // 允许访问此通道的用户 ID 列表（为空则不限制）
}

type Channel interface {
	Name() string                                             // 返回通道名称（如 "telegram"）
	Start(ctx context.Context) error                          // 启动通道连接或监听
	Stop(ctx context.Context) error                           // 停止通道连接
	Send(ctx context.Context, msg *bus.OutboundMessage) error // 发送出站消息到平台
	IsAllowed(senderID string) bool                           // 检查指定的发送者是否有权限使用此通道
}

type DeliveryPolicy struct {
	MaxConcurrentSends int           // 最大并发发送连接数
	RetryMaxAttempts   int           // 发送失败后的最大重试次数
	RetryBaseBackoff   time.Duration // 基础重试退避间隔
	RetryMaxBackoff    time.Duration // 最大重试退避间隔
	RateLimitPerSecond int           // 每秒允许发送的消息数上限
	DedupWindow        time.Duration // 消息去重的时间窗口大小
}

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