messagequeue

type Message struct {
	// ID uniquely identifies the message for deduplication and tracing.
	//
	// Deduplication is against every message the backend still holds for the
	// same topic and partition key — including ones already consumed, which are
	// reclaimed lazily and may outlive their delivery by an unbounded interval.
	// A publish whose ID collides is reported as a success and stores nothing.
	//
	// So the ID names the occasion to publish, not the entity published about.
	// Reusing an entity's own ID gives that entity one message for as long as
	// the backend remembers the first, and silently discards every later one.
	// Producers build IDs with platform/publish.IntentID rather than choosing
	// them by hand.
	ID string

	// Payload is the message body as raw bytes.
	Payload []byte

	// Metadata contains key-value pairs for headers and attributes.
	// Use for trace IDs, request IDs, and cross-service metadata.
	Metadata map[string]string

	// PartitionKey determines the ordering partition within Tenant.
	// Messages with the same Tenant and PartitionKey are delivered in order.
	// Optional - if empty, backend may use round-robin distribution.
	PartitionKey string

	// Tenant is the shard isolation identity persisted by the backend.
	// Domains map their queue name onto this field at publish time.
	Tenant string

	// PublishedAt is when the message was published (Unix milliseconds).
	PublishedAt int64
}

type PartitionIdentity struct {
	// Tenant is the shard isolation identity.
	Tenant string
	// PartitionKey is the partition key within the tenant.
	PartitionKey string
}