types

type Client struct {
	ID        string            `json:"id"`         // Unique client identifier
	Metadata  map[string]string `json:"metadata"`   // Optional client metadata
	CreatedAt time.Time         `json:"created_at"` // When client was created
	LastSeen  time.Time         `json:"last_seen"`  // Last activity timestamp
}

type Message struct {
	ID          string            `json:"id"`                     // Unique message identifier
	Type        MessageType       `json:"type"`                   // Task or Direct
	From        string            `json:"from"`                   // Sender client ID
	To          string            `json:"to,omitempty"`           // Target client ID (for Direct)
	Topic       string            `json:"topic,omitempty"`        // Topic name (for Task)
	Payload     []byte            `json:"payload"`                // Message content
	Priority    int               `json:"priority"`               // Message priority (0-9, higher is more important)
	Status      MessageStatus     `json:"status"`                 // Current message status
	CreatedAt   time.Time         `json:"created_at"`             // Message creation timestamp
	ProcessedAt *time.Time        `json:"processed_at,omitempty"` // When message was processed
	CompletedAt *time.Time        `json:"completed_at,omitempty"` // When message was completed
	RetryCount  int               `json:"retry_count"`            // Number of retry attempts
	MaxRetries  int               `json:"max_retries"`            // Maximum retry attempts
	TTL         time.Duration     `json:"ttl,omitempty"`          // Time to live
	ExpiresAt   *time.Time        `json:"expires_at,omitempty"`   // Expiration timestamp
	Error       string            `json:"error,omitempty"`        // Error message if failed
	Metadata    map[string]string `json:"metadata,omitempty"`     // Additional metadata
}

type MessageStatus int

type MessageType int

type Queue struct {
	Name     string        `json:"name"`     // Queue/Topic name
	Type     QueueType     `json:"type"`     // Queue type
	Created  time.Time     `json:"created"`  // Queue creation time
	Settings QueueSettings `json:"settings"` // Queue-specific settings

	// Statistics
	MessageCount  int64 `json:"message_count"`  // Current message count
	TotalEnqueued int64 `json:"total_enqueued"` // Total messages enqueued
	TotalDequeued int64 `json:"total_dequeued"` // Total messages dequeued
	TotalFailed   int64 `json:"total_failed"`   // Total failed messages

	// Runtime state (not persisted)
	Subscribers []string `json:"subscribers,omitempty"` // Client IDs subscribed (for task queues)
}

type QueueSettings struct {
	MaxSize         int           `json:"max_size"`         // Maximum queue size (0 = unlimited)
	MaxMessageSize  int           `json:"max_message_size"` // Maximum message size in bytes
	DefaultTTL      time.Duration `json:"default_ttl"`      // Default message TTL
	RetentionPeriod time.Duration `json:"retention_period"` // How long to keep completed messages
	EnablePriority  bool          `json:"enable_priority"`  // Enable priority processing
	BatchSize       int           `json:"batch_size"`       // Batch size for processing
}

type QueueStats struct {
	Name         string        `json:"name"`
	Type         QueueType     `json:"type"`
	MessageCount int64         `json:"message_count"`
	Subscribers  int           `json:"subscribers"`
	EnqueueRate  float64       `json:"enqueue_rate"` // Messages per second
	DequeueRate  float64       `json:"dequeue_rate"` // Messages per second
	ErrorRate    float64       `json:"error_rate"`   // Errors per second
	AverageWait  time.Duration `json:"average_wait"` // Average time in queue
}

type QueueType int

type Response struct {
	Success bool        `json:"success"`
	Message string      `json:"message,omitempty"`
	Data    interface{} `json:"data,omitempty"`
}

type Subscription struct {
	ClientID     string    `json:"client_id"`
	Topic        string    `json:"topic"`
	SubscribedAt time.Time `json:"subscribed_at"`
}