channel

type BaseChannel struct {
	Bus       *bus.MessageBus
	AllowList map[string]bool
}

type Channel interface {
	Name() string
	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
}