message

type Message struct {

	// message_id: Unique identifier for this message within its queue.
	// Must be unique per queue. Used for deduplication and idempotency.
	// If you retry posting the same message_id, ChronoQueue returns the existing message.
	// Recommended format: UUID, task ID, or "{entity_type}:{entity_id}".
	MessageId string `protobuf:"bytes,1,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	// metadata: All message execution and lifecycle information.
	Metadata *Message_Metadata `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

type Message_Metadata struct {

	// payload: The business data and metadata to be processed.
	// This is what your workers receive and act upon.
	Payload *v1.Payload            `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	State   Message_Metadata_State `protobuf:"varint,2,opt,name=state,proto3,enum=chronoqueue.api.message.v1.Message_Metadata_State" json:"state,omitempty"`
	// attempts_left: Number of retry attempts remaining before moving to DLQ.
	// Decrements with each processing failure. When reaches 0 and fails, moves to ERRORED state.
	// Set max_attempts when posting to control retry behavior.
	AttemptsLeft int32 `protobuf:"varint,4,opt,name=attempts_left,json=attemptsLeft,proto3" json:"attempts_left,omitempty"`
	// lease_duration: How long a worker can process this message before the lease expires.
	// After this duration, if not acknowledged or renewed, message returns to PENDING state.
	// Workers should call RenewLease or SendHeartbeat if processing takes longer.
	// Typical values: 30s for quick tasks, 5m for longer processing.
	LeaseDuration *durationpb.Duration `protobuf:"bytes,5,opt,name=lease_duration,json=leaseDuration,proto3" json:"lease_duration,omitempty"`
	// lease_expiry: Unix timestamp (milliseconds) when the current lease expires.
	// Managed automatically by ChronoQueue. Workers can monitor this to know when to renew.
	// If current time > lease_expiry, message will be reclaimed and made PENDING again.
	LeaseExpiry int64 `protobuf:"varint,6,opt,name=lease_expiry,json=leaseExpiry,proto3" json:"lease_expiry,omitempty"`
	// lease_renewal_count: Number of times the lease has been renewed for this processing attempt.
	// Useful for detecting stuck/zombie workers that keep renewing without completing.
	// Consider implementing a max renewal limit in your worker logic.
	LeaseRenewalCount int32 `protobuf:"varint,7,opt,name=lease_renewal_count,json=leaseRenewalCount,proto3" json:"lease_renewal_count,omitempty"`
	// priority: Message priority score (0-2147483647, higher = processed first).
	// ChronoQueue uses priority streams (high: ≥70, medium: ≥30, low: <30).
	// Messages with the same priority are processed FIFO.
	// Use for: urgent tasks (100), normal (50), background (10).
	Priority int64 `protobuf:"varint,9,opt,name=priority,proto3" json:"priority,omitempty"`
	// max_attempts: Maximum number of processing attempts before moving to DLQ.
	// If omitted, uses queue's default_max_attempts.
	// Set to -1 for infinite retries (use with caution).
	// Common values: 1 (no retry), 3 (standard), 5 (persistent), -1 (infinite).
	MaxAttempts int32 `protobuf:"varint,10,opt,name=max_attempts,json=maxAttempts,proto3" json:"max_attempts,omitempty"`
	// scheduled_time: When this message should become visible for processing.
	// If set to a future time, message enters INVISIBLE state until that time.
	// If omitted or past, message immediately becomes PENDING.
	// Use for: scheduled tasks, delayed execution, rate limiting, backoff strategies.
	// Example: Schedule order fulfillment for tomorrow at 9 AM.
	ScheduledTime *timestamppb.Timestamp `protobuf:"bytes,20,opt,name=scheduled_time,json=scheduledTime,proto3" json:"scheduled_time,omitempty"`
	// priority_level: Internal priority level for stream routing (auto-calculated).
	// Managed by ChronoQueue based on priority score. Read-only from client perspective.
	// Used internally for routing to high/medium/low priority streams.
	PriorityLevel int32 `protobuf:"varint,21,opt,name=priority_level,json=priorityLevel,proto3" json:"priority_level,omitempty"`
	// contains filtered or unexported fields
}

type Message_Metadata_State int32