queue

type FairnessPolicy int32

type PriorityConfig struct {

	// policy: The fairness strategy to use.
	// See FairnessPolicy enum for detailed descriptions.
	Policy FairnessPolicy `protobuf:"varint,1,opt,name=policy,proto3,enum=chronoqueue.api.queue.v1.FairnessPolicy" json:"policy,omitempty"`
	// priority_weights: For WEIGHTED/HYBRID policies, maps priority levels to weights.
	// Key: priority level (e.g., 100, 50, 10)
	// Value: relative weight (e.g., 70, 20, 10 = 70% high, 20% medium, 10% low)
	// Weights are relative - they're normalized to percentages.
	PriorityWeights map[int32]int32 `` /* 182-byte string literal not displayed */
	// age_boost_threshold: For AGING/HYBRID policies, how long before boosting priority.
	// Messages waiting longer than this duration get their priority boosted.
	// Prevents indefinite starvation of low-priority messages.
	// Typical values: 15m (aggressive), 30m (standard), 1h (relaxed).
	AgeBoostThreshold *durationpb.Duration `protobuf:"bytes,3,opt,name=age_boost_threshold,json=ageBoostThreshold,proto3" json:"age_boost_threshold,omitempty"`
	// age_boost_multiplier: For AGING/HYBRID policies, how much to boost priority.
	// Priority multiplied by this factor every age_boost_threshold period.
	// Example: multiplier=2, threshold=30m means priority doubles every 30 minutes.
	// Typical values: 1.5 (gentle), 2 (standard), 3 (aggressive).
	AgeBoostMultiplier int32 `protobuf:"varint,4,opt,name=age_boost_multiplier,json=ageBoostMultiplier,proto3" json:"age_boost_multiplier,omitempty"`
	// contains filtered or unexported fields
}

type Queue struct {

	// name: Unique identifier for this queue.
	// Must be unique across your ChronoQueue instance.
	// Naming convention: lowercase, hyphens, descriptive
	// Examples: "order-processing", "email-sender", "webhook-delivery"
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// metadata: Queue configuration and behavior settings.
	Metadata *QueueMetadata `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

type QueueMetadata struct {

	// type: Determines message consumption pattern.
	// SIMPLE: Multiple workers process concurrently (most common).
	// EXCLUSIVE: Single worker processes sequentially (ensures order).
	Type QueueType `protobuf:"varint,1,opt,name=type,proto3,enum=chronoqueue.api.queue.v1.QueueType" json:"type,omitempty"`
	// default_max_attempts: Default retry count for messages without explicit max_attempts.
	// Messages failing this many times move to the dead letter queue.
	// Common values: 1 (no retry), 3 (standard), 5 (aggressive retry).
	// Set to -1 for infinite retries (use with extreme caution).
	DefaultMaxAttempts int32 `protobuf:"varint,2,opt,name=default_max_attempts,json=defaultMaxAttempts,proto3" json:"default_max_attempts,omitempty"`
	// lease_duration: Default time workers have to process a message.
	// If a worker doesn't acknowledge within this time, message returns to queue.
	// Workers can renew leases for longer operations via RenewLease/SendHeartbeat.
	// Common values: 30s (quick tasks), 5m (standard), 30m (long-running).
	// Balance between: too short = unnecessary retries, too long = slow failure detection.
	LeaseDuration *durationpb.Duration `protobuf:"bytes,3,opt,name=lease_duration,json=leaseDuration,proto3" json:"lease_duration,omitempty"`
	// exclusivity_key: For EXCLUSIVE queues, this key ensures single-consumer access.
	// Only one worker with a matching exclusivity key can consume from this queue.
	// Leave empty for non-exclusive queues.
	// Use cases: ordered processing, singleton workers, distributed locks.
	ExclusivityKey string `protobuf:"bytes,4,opt,name=exclusivity_key,json=exclusivityKey,proto3" json:"exclusivity_key,omitempty"`
	// dead_letter_queue_name: Name of the DLQ for messages that exhaust retries.
	// Messages that fail after max_attempts are moved here for investigation.
	// Naming convention: "{original-queue}-dlq" or "{original-queue}-errors"
	// Access DLQ messages via DLQ APIs: GetDLQMessage, ListDLQMessages, RequeueDLQMessage.
	DeadLetterQueueName string `protobuf:"bytes,6,opt,name=dead_letter_queue_name,json=deadLetterQueueName,proto3" json:"dead_letter_queue_name,omitempty"`
	// auto_create_dlq: If true, ChronoQueue automatically creates the DLQ if it doesn't exist.
	// Recommended: true for production (ensures no messages are lost).
	// Set to false if you want to manually control DLQ creation and configuration.
	AutoCreateDlq bool `protobuf:"varint,7,opt,name=auto_create_dlq,json=autoCreateDlq,proto3" json:"auto_create_dlq,omitempty"`
	// schema_id: Default schema for validating messages posted to this queue.
	// All messages must conform to this schema (if schema_required is true).
	// Helps ensure data quality and catch errors before processing.
	// Example: "order.created.v1", "user.profile.v2"
	// Register schemas via RegisterSchema API.
	SchemaId string `protobuf:"bytes,8,opt,name=schema_id,json=schemaId,proto3" json:"schema_id,omitempty"`
	// schema_required: If true, all messages must have a valid schema and pass validation.
	// Messages without a schema or failing validation are rejected.
	// Use in production for critical data pipelines to prevent bad data.
	// Set to false for development or when schema validation isn't needed.
	SchemaRequired bool `protobuf:"varint,9,opt,name=schema_required,json=schemaRequired,proto3" json:"schema_required,omitempty"`
	// max_payload_size: Maximum size of message payload in bytes.
	// Messages exceeding this limit are rejected.
	// If not set or 0, uses system default (typically 256KB).
	// Increase for large payloads (e.g., 1MB = 1048576).
	// Note: Very large messages impact performance - consider using references instead.
	MaxPayloadSize int32 `protobuf:"varint,10,opt,name=max_payload_size,json=maxPayloadSize,proto3" json:"max_payload_size,omitempty"`
	// allowed_content_types: List of permitted MIME types for message payloads.
	// Empty list = all content types allowed (default).
	// Examples: ["application/json"], ["application/json", "application/xml"]
	// Use to enforce data format standards across your organization.
	AllowedContentTypes []string `protobuf:"bytes,11,rep,name=allowed_content_types,json=allowedContentTypes,proto3" json:"allowed_content_types,omitempty"`
	// priority_config: Advanced priority scheduling configuration.
	// Controls how messages with different priorities are processed.
	// Most users can omit this - defaults work well for common cases.
	// Customize for: complex fairness requirements, aging prevention, weighted priorities.
	PriorityConfig *PriorityConfig `protobuf:"bytes,12,opt,name=priority_config,json=priorityConfig,proto3" json:"priority_config,omitempty"`
	// ---------------------------------------------------------------------------
	// Lease model defaults (queue-level)
	// ---------------------------------------------------------------------------
	// Message-level policies can selectively override these fields.
	LeasePolicy *v1.LeasePolicy `protobuf:"bytes,13,opt,name=lease_policy,json=leasePolicy,proto3" json:"lease_policy,omitempty"`
	// contains filtered or unexported fields
}

type QueueType int32