archastro.platform.types.events

  1# Copyright (c) 2026 ArchAstro Inc. Licensed under the MIT License.
  2# This file is auto-generated by @archastro/sdk-generator. Do not edit.
  3# Content hash: 60b20f07ddae
  4
  5from datetime import datetime
  6from typing import Any, Literal
  7
  8from pydantic import BaseModel
  9
 10from .common import DomainEvent
 11
 12
 13class EventSubscription(BaseModel):
 14    """
 15    An app-scoped subscription to exact domain-event names.
 16    """
 17
 18    agent: str | None = None
 19    available_count: int
 20    created_at: datetime
 21    dropped_events_total: int
 22    dropped_through_position: int
 23    event_names: list[str]
 24    filter: dict[str, Any] | None = None
 25    id: str
 26    last_overflow_at: datetime | None = None
 27    leased_count: int
 28    max_pending_events: int
 29    name: str
 30    org: str | None = None
 31    queue_epoch: int
 32    retention_seconds: int
 33    sandbox: str | None = None
 34    status: Literal["active", "paused"]
 35    team: str | None = None
 36    updated_at: datetime
 37    user: str | None = None
 38    visibility_timeout_seconds: int
 39    watch_key: str | None = None
 40
 41
 42class EventSubscriptionDelivery(BaseModel):
 43    """
 44    A domain event leased from a subscription queue.
 45    """
 46
 47    delivery_id: str
 48    event: DomainEvent
 49    lease_expires_at: datetime
 50    receipt_handle: str
 51    receive_count: int
 52    sequence: int
 53
 54
 55class EventSubscriptionClaim(BaseModel):
 56    """
 57    Result of atomically claiming the head delivery.
 58    """
 59
 60    data: list[EventSubscriptionDelivery]
 61    dropped_events_total: int
 62    dropped_through_position: int
 63    has_more: bool
 64    queue_epoch: int
 65
 66
 67class EventSubscriptionQueueEntry(BaseModel):
 68    """
 69    A non-reserving view of one queued delivery.
 70    """
 71
 72    delivery_id: str
 73    event: DomainEvent
 74    lease_expires_at: datetime | None = None
 75    receive_count: int
 76    sequence: int
 77    state: Literal["available", "leased"]
 78
 79
 80class EventSubscriptionHead(BaseModel):
 81    """
 82    A non-reserving view of the queue head.
 83    """
 84
 85    data: EventSubscriptionQueueEntry | None = None
 86
 87
 88class EventSubscriptionPage(BaseModel):
 89    """
 90    A page of domain-event subscriptions.
 91    """
 92
 93    data: list[EventSubscription]
 94    page: int
 95    per_page: int
 96    total_count: int
 97    total_pages: int
 98
 99
100class EventSubscriptionQueue(BaseModel):
101    """
102    A cursor-paginated non-reserving view of a subscription queue.
103    """
104
105    after_cursor: str | None = None
106    before_cursor: str | None = None
107    data: list[EventSubscriptionQueueEntry]
108    dropped_events_total: int
109    dropped_through_position: int
110    has_more: bool
111    queue_epoch: int