types

type CircuitStatus string

type DeliveryOptions struct {
	Priority         DeliveryPriority
	MaxRetries       int
	RetryBackoff     time.Duration
	Timeout          time.Duration
	RequireSignature bool
	CompressPayload  bool
}

type DeliveryPriority int

type DeliveryResult struct {
	MessageID  string
	InstanceID string
	RouteID    string

	Success      bool
	StatusCode   int
	ErrorMessage string

	Attempts  int
	Duration  time.Duration
	BytesSent int64
	Cost      float64

	Timestamp time.Time
}

type FederationMessage struct {
	ID     string
	Type   MessageType
	Actor  string
	Object any
	Target []string

	Payload     []byte
	PayloadSize int64
	ContentType string

	CreatedAt time.Time
	ExpiresAt time.Time
}

type HealthStatus struct {
	Timestamp    time.Time
	Reachable    bool
	ResponseTime time.Duration
	StatusCode   int
	ErrorMessage string

	// Resource usage
	CPUUsage    float64
	MemoryUsage float64
	DiskUsage   float64

	// Federation metrics
	InboxBacklog    int
	ProcessingDelay time.Duration
	ErrorRate       float64
}

type Instance struct {
	ID             string
	Domain         string
	InboxURL       string
	SharedInboxURL string
	PublicKeyPEM   string

	// Capabilities
	SupportedTypes []MessageType
	MaxMessageSize int64
	RateLimits     RateLimits

	// Status
	Status       InstanceStatus
	LastSeen     time.Time
	RegisteredAt time.Time

	// Performance metrics
	AvgResponseTime time.Duration
	SuccessRate     float64
	ErrorRate       float64

	// Cost tracking
	TierLevel    TierLevel
	MonthlyQuota int64
	CurrentUsage int64
}

type InstanceStatus string

type MessageType string

type QueueMetrics struct {
	Depth           int64
	ProcessingCount int64
	RetryCount      int64
	DLQCount        int64

	EnqueueRate float64
	DequeueRate float64
	SuccessRate float64

	AvgWaitTime    time.Duration
	AvgProcessTime time.Duration
}

type QueueStatus string

type QueuedMessage struct {
	Message *FederationMessage
	Options DeliveryOptions

	QueuedAt    time.Time
	Attempts    int
	LastAttempt time.Time
	NextRetry   time.Time

	RouteID string
	Status  QueueStatus
}

type RateLimits struct {
	MessagesPerMinute int
	MessagesPerHour   int
	BytesPerMinute    int64
	BytesPerHour      int64
	BurstSize         int
}

type Route struct {
	ID         string
	InstanceID string
	Domain     string
	Endpoint   *url.URL
	Priority   int // Lower is higher priority

	// Performance
	Latency    time.Duration
	Bandwidth  int64 // bytes per second
	PacketLoss float64

	// Reliability
	SuccessRate      float64
	LastSuccess      time.Time
	LastFailure      time.Time
	ConsecutiveFails int

	// Circuit breaker
	CircuitStatus   CircuitStatus
	CircuitOpenedAt time.Time

	// Cost
	CostPerMessage float64
	CostPerByte    float64
}

type RouteMetrics struct {
	TotalMessages   int64
	SuccessfulCount int64
	FailedCount     int64
	RetryCount      int64

	AvgLatency time.Duration
	P95Latency time.Duration
	P99Latency time.Duration

	TotalBytes int64
	TotalCost  float64

	LastUpdated time.Time
}

type RoutingConfig struct {
	// Health checking
	HealthCheckInterval time.Duration
	HealthCheckTimeout  time.Duration
	UnhealthyThreshold  int
	HealthyThreshold    int

	// Circuit breaker
	CircuitBreakerThreshold int
	CircuitBreakerTimeout   time.Duration
	HalfOpenMaxAttempts     int

	// Routing
	MaxRoutesPerInstance    int
	RouteSelectionAlgorithm string
	EnableLoadBalancing     bool
	EnableCostOptimization  bool

	// Delivery
	DefaultTimeout time.Duration
	MaxRetries     int
	RetryBackoff   time.Duration
	MaxQueueDepth  int64

	// Performance
	EnableCompression  bool
	BatchDeliverySize  int
	ParallelDeliveries int
}

type RoutingError struct {
	Code    string
	Message string
	Details map[string]any
}

type SelectionOptions struct {
	PreferReliability bool
	PreferSpeed       bool
	PreferCost        bool
	MaxLatency        time.Duration
	MaxCost           float64
	RequiredTier      TierLevel
}

type TierLevel string