mq

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

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

type BatchMessage struct {
	Body          string                 // Message body
	Properties    map[string]interface{} // Message properties
	SessionID     string                 // Session ID
	CorrelationID string                 // Correlation ID
	ReplyTo       string                 // Reply to queue
	TimeToLive    int                    // TTL in seconds
	MessageID     string                 // Message ID
	ScheduledTime *time.Time             // Scheduled delivery time
}

type Client interface {
	// Queue operations
	CreateQueue(ctx context.Context, name string, options QueueOptions) (*Queue, error)
	DeleteQueue(ctx context.Context, name string) error
	ListQueues(ctx context.Context, prefix string) ([]*Queue, error)
	GetQueue(ctx context.Context, name string) (*Queue, error)
	Exists(ctx context.Context, name string) (bool, error)
	Purge(ctx context.Context, name string) error
	GetInfo(ctx context.Context, name string) (*Queue, error)

	// Message operations
	Send(ctx context.Context, queueName, body string, options MessageOptions) (*MessageResult, error)
	Receive(ctx context.Context, queueName string, options ReceiveOptions) ([]*MessageResult, error)
	Delete(ctx context.Context, queueName string, messageIDs []string) ([]bool, error)

	// Message lock management
	Lock(ctx context.Context, queueName, messageID string, duration int) error
	Unlock(ctx context.Context, queueName, messageID string) error

	// Batch operations
	BatchSend(ctx context.Context, queueName string, messages []BatchMessage) ([]*MessageResult, error)

	// Specialized message operations
	Schedule(ctx context.Context, queueName, body string, scheduledTime time.Time, options MessageOptions) (*MessageResult, error)
	Cancel(ctx context.Context, queueName, messageID string) error
	Peek(ctx context.Context, queueName string, maxCount int) ([]*MessageResult, error)

	// Dead letter queue operations
	DeadLetterReceive(ctx context.Context, queueName string, maxCount int) ([]*MessageResult, error)
	DeadLetterRequeue(ctx context.Context, queueName, messageID string) error
	DeadLetterPurge(ctx context.Context, queueName string) error

	// Connection management
	Close() error
	GetClientInfo() map[string]interface{}
}

type ClientConfig struct {
	// Service configuration
	ServiceType      string // Service type (aws_sqs, azure_servicebus, auto)
	ConnectionString string // Azure Service Bus connection string

	// AWS specific configuration
	AWSRegion       string // AWS region
	AWSAccessKey    string // AWS access key ID
	AWSSecretKey    string // AWS secret access key
	AWSSessionToken string // AWS session token

	// Connection and performance settings
	Timeout    int // Connection timeout in seconds
	MaxRetries int // Maximum retry attempts

	// Default operation settings
	DefaultLockDuration int // Default message lock duration in seconds
	DefaultBatchSize    int // Default batch size for operations
}

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

type DeadLetterConfig struct {
	Enabled          bool   // Whether DLQ is enabled
	QueueName        string // Dead letter queue name
	MaxDeliveryCount int    // Maximum delivery count before moving to DLQ
}

type DuplicateDetection struct {
	Enabled       bool `json:"enabled"`
	WindowSeconds int  `json:"window_seconds"` // Deduplication window in seconds
}

type ErrorType string

type MQError struct {
	// Type categorizes the error
	Type ErrorType

	// Message provides a human-readable description
	Message string

	// Service indicates which service reported the error
	Service string

	// Operation indicates which operation failed
	Operation string

	// Underlying error from the service
	Err error

	// Additional context
	Context map[string]interface{}
}

type MessageOptions struct {
	// Message properties and metadata
	Properties map[string]interface{} // Message properties/attributes

	// Message scheduling
	ScheduledTime *time.Time // When message should become available for processing

	// Message grouping and correlation
	SessionID     string // Session ID for ordered processing
	CorrelationID string // Correlation ID for request tracking
	ReplyTo       string // Response destination queue

	// Message lifecycle
	TimeToLive int    // Message TTL in seconds
	MessageID  string // Message ID for deduplication
}

type MessageResult struct {
	// Message identification
	MessageID string `json:"message_id"`
	Body      string `json:"body"`

	// Message metadata and properties
	Properties map[string]interface{} `json:"properties"`

	// Message grouping and correlation
	SessionID     string `json:"session_id"`
	CorrelationID string `json:"correlation_id"`
	ReplyTo       string `json:"reply_to"`

	// Timing information
	EnqueueTime   time.Time  `json:"enqueue_time"`
	ScheduledTime *time.Time `json:"scheduled_time,omitempty"`
	LockExpiresAt *time.Time `json:"lock_expires_at,omitempty"`

	// Delivery information
	DeliveryCount int `json:"delivery_count"`
	TimeToLive    int `json:"time_to_live"` // TTL in seconds

	// Service-specific information (internal use)
	ReceiptHandle   string      `json:"receipt_handle"` // Service-specific handle for acknowledgment
	OriginalMessage interface{} `json:"-"`              // Original service-specific message object (not serialized)

	// Operation result
	Success bool   `json:"success"`
	Error   string `json:"error,omitempty"`
}

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

type Queue struct {
	// Basic queue information
	Name        string `json:"name"`
	ServiceType string `json:"service_type"` // Which service backs this queue
	URL         string `json:"url"`          // Service-specific queue URL/identifier

	// Queue statistics
	MessageCount int `json:"message_count"`

	// Queue configuration (unified across services)
	LockDuration    int `json:"lock_duration"`    // Message lock duration in seconds
	RetentionPeriod int `json:"retention_period"` // Message retention in seconds

	// Dead letter queue configuration
	MaxDeliveryCount int               `json:"max_delivery_count"`
	DeadLetterConfig *DeadLetterConfig `json:"dead_letter_config"`

	// Message ordering and deduplication
	EnableSessions     bool                `json:"enable_sessions"`     // Ordered processing support
	DuplicateDetection *DuplicateDetection `json:"duplicate_detection"` // Deduplication configuration

	// Queue limits
	MaxQueueSize int64 `json:"max_queue_size"` // Queue size in bytes (-1 for unlimited)

	// Timestamps
	CreatedTime  time.Time `json:"created_time"`
	ModifiedTime time.Time `json:"modified_time"`
}

type QueueOptions struct {
	// Lock duration for messages (unified visibility timeout/lock duration)
	LockDuration int // Message lock duration in seconds

	// Message retention settings
	RetentionPeriod int // Message retention period in seconds

	// Dead letter queue configuration
	MaxDeliveryCount int               // Maximum delivery attempts before moving to DLQ
	DeadLetterConfig *DeadLetterConfig // Dead letter queue configuration

	// Message ordering and deduplication
	EnableSessions      bool // Enable sessions for message ordering (Azure) or FIFO (AWS)
	DuplicateDetection  bool // Enable duplicate message detection
	DuplicateWindowSecs int  // Duplicate detection window in seconds

	// Queue size limits
	MaxQueueSize int64 // Maximum queue size in bytes (-1 for unlimited)
}

type ReceiveOptions struct {
	// Receive behavior
	MaxCount int  // Maximum number of messages to receive
	WaitTime int  // Long polling wait time in seconds
	PeekOnly bool // Peek messages without receiving them

	// Message lock settings
	LockDuration *int // Override default lock duration
}