models

Public event contracts and bounded diagnostic metadata.

class bedrock_server_manager.events.models.EventModel

model_config = {'extra': 'forbid'}: Configuration for the model, should be a dictionary conforming to [ConfigDict][pydantic.config.ConfigDict].

class bedrock_server_manager.events.models.EventDefinition(*, name: ~typing.Annotated[str, ~annotated_types.MinLen(min_length=1), ~annotated_types.MaxLen(max_length=160), _PydanticGeneralMetadata(pattern='^[a-zA-Z0-9_][a-zA-Z0-9_.:-]*$')], phase: ~typing.Literal['before', 'after', 'custom', 'lifecycle'] = 'custom', description: str = '', owner: str = 'application', identity_keys: tuple[str, ...] = (), public: bool = True, payload_schema: dict[str, ~pydantic.types.JsonValue] = <factory>)

model_config = {'extra': 'forbid'}: Configuration for the model, should be a dictionary conforming to [ConfigDict][pydantic.config.ConfigDict].

model_config = {'extra': 'forbid', 'frozen': True}: Configuration for the model, should be a dictionary conforming to [ConfigDict][pydantic.config.ConfigDict].

class bedrock_server_manager.events.models.EventSubscriptionInfo(*, subscription_id: str, listener_id: str, name: str, owner: str, kind: Literal['legacy', 'hook', 'observer'], priority: int, before: tuple[str, ...] = (), after: tuple[str, ...] = (), unresolved_before: tuple[str, ...] = (), unresolved_after: tuple[str, ...] = (), filters: EventFilter | None = None, once: bool, active: bool, calls: int = 0, failures: int = 0, timeouts: int = 0, last_status: str | None = None, last_duration_ms: float = 0)

model_config = {'extra': 'forbid'}: Configuration for the model, should be a dictionary conforming to [ConfigDict][pydantic.config.ConfigDict].

class bedrock_server_manager.events.models.EventSubscriptions(*, items: list[EventSubscriptionInfo] = <factory>, total: int = 0, truncated: bool = False)

model_config = {'extra': 'forbid'}: Configuration for the model, should be a dictionary conforming to [ConfigDict][pydantic.config.ConfigDict].

class bedrock_server_manager.events.models.EventContext(*, event_id: str, name: str, parent_event_id: str | None = None, correlation_id: str, source: str, phase: Literal['before', 'after', 'custom', 'lifecycle'] = 'custom', observer: bool = False, operation_id: str | None = None, sequence_id: str | None = None)

model_config = {'extra': 'forbid', 'frozen': True}: Configuration for the model, should be a dictionary conforming to [ConfigDict][pydantic.config.ConfigDict].

class bedrock_server_manager.events.models.EventEnvelope(*, event_id: str, correlation_id: str, parent_event_id: str | None = None, timestamp: float, source: str, name: str, epoch: str | None = None, revision: Annotated[int | None, Ge(ge=1), Le(le=9007199254740991)] = None, data: dict[str, JsonValue])

model_config = {'extra': 'forbid'}: Configuration for the model, should be a dictionary conforming to [ConfigDict][pydantic.config.ConfigDict].

class bedrock_server_manager.events.models.ListenerFailure(*, owner: str, error_type: str, code: Literal['event_listener_failed', 'event_listener_timeout', 'event_depth_limit', 'event_capacity'])

model_config = {'extra': 'forbid'}: Configuration for the model, should be a dictionary conforming to [ConfigDict][pydantic.config.ConfigDict].

class bedrock_server_manager.events.models.EventDelivery(*, targeted: Annotated[int, Ge(ge=0)] = 0, sent: Annotated[int, Ge(ge=0)] = 0, unavailable: Annotated[int, Ge(ge=0)] = 0, failed: Annotated[int, Ge(ge=0)] = 0, owner: str)

model_config = {'allow_inf_nan': False, 'extra': 'forbid', 'frozen': True, 'hide_input_in_errors': True, 'revalidate_instances': 'always', 'strict': True, 'validate_default': True}: Configuration for the model, should be a dictionary conforming to [ConfigDict][pydantic.config.ConfigDict].

class bedrock_server_manager.events.models.ListenerRecord(*, subscription_id: str, owner: str, observer: bool, listener_name: str, failure: ListenerFailure | None = None, status: Literal['running', 'completed', 'failed', 'timed_out', 'cancelled'] = 'running', duration_ms: Annotated[float, Ge(ge=0)] = 0)

model_config = {'extra': 'forbid'}: Configuration for the model, should be a dictionary conforming to [ConfigDict][pydantic.config.ConfigDict].

class bedrock_server_manager.events.models.EventRecord(*, operation_id: str | None = None, sequence_id: str | None = None, operation_name: str | None = None, server_name: str | None = None, phase: ~typing.Literal['before', 'after', 'custom', 'lifecycle'] = 'custom', event_id: str, correlation_id: str, parent_event_id: str | None = None, name: str, source: str, timestamp: float, status: ~typing.Literal['dispatching', 'completed', 'partial', 'cancelled', 'suppressed'], rejection_reason: ~typing.Literal['recursion', 'depth_limit', 'capacity', 'shutdown'] | None = None, listeners: list[~bedrock_server_manager.events.models.ListenerRecord] = <factory>, duration_ms: float = 0, listeners_called: int = 0, failures: list[~bedrock_server_manager.events.models.ListenerFailure] = <factory>, deliveries: list[~bedrock_server_manager.events.models.EventDelivery] = <factory>, cancellation_reason: str | None = None)

model_config = {'extra': 'forbid'}: Configuration for the model, should be a dictionary conforming to [ConfigDict][pydantic.config.ConfigDict].

class bedrock_server_manager.events.models.EventDiagnostics(*, active_truncated: bool = False, recent_truncated: bool = False, accepting: bool, emitted: int, suppressed: int, failed_listeners: int, subscriptions: int, active_dispatches: int = 0, subscriptions_by_owner: dict[str, int] = <factory>, active_listeners_by_owner: dict[str, int] = <factory>, notification_delivery: ~typing.Literal['inline'] = 'inline', pending_workers: int = 0, workers_by_owner: dict[str, int] = <factory>, pending_waits: int = 0, rejections_by_reason: dict[str, int] = <factory>, timeouts_by_owner: dict[str, int] = <factory>, active: list[~bedrock_server_manager.events.models.EventRecord], recent: list[~bedrock_server_manager.events.models.EventRecord])

model_config = {'extra': 'forbid'}: Configuration for the model, should be a dictionary conforming to [ConfigDict][pydantic.config.ConfigDict].

class bedrock_server_manager.events.models.EventCatalog(*, events: list[EventDefinition])

model_config = {'extra': 'forbid'}: Configuration for the model, should be a dictionary conforming to [ConfigDict][pydantic.config.ConfigDict].

class bedrock_server_manager.events.models.EventOptions(*, history_limit: Annotated[int, Ge(ge=0), Le(le=10000)] = 200, max_active: Annotated[int, Ge(ge=1), Le(le=10000)] = 256, max_workers: Annotated[int | None, Ge(ge=1), Le(le=10000)] = None, max_workers_per_owner: Annotated[int | None, Ge(ge=1), Le(le=10000)] = None, max_depth: Annotated[int, Ge(ge=1), Le(le=128)] = 32, listener_timeout_seconds: Annotated[float, Gt(gt=0), Le(le=3600)] = 30, hook_timeout_seconds: Annotated[float, Gt(gt=0), Le(le=3600)] = 120)

model_config = {'extra': 'forbid'}: Configuration for the model, should be a dictionary conforming to [ConfigDict][pydantic.config.ConfigDict].

class bedrock_server_manager.events.models.EventActivityQuery(*, operation_id: str | None = None, sequence_id: str | None = None, operation_name: str | None = None, server_name: str | None = None, source: str | None = None, phase: Literal['before', 'after', 'custom', 'lifecycle'] | None = None, name: str | None = None, owner: str | None = None, correlation_id: str | None = None, status: Literal['dispatching', 'completed', 'partial', 'cancelled', 'suppressed'] | None = None, limit: Annotated[int, Ge(ge=1), Le(le=10000)] = 200)

model_config = {'extra': 'forbid'}: Configuration for the model, should be a dictionary conforming to [ConfigDict][pydantic.config.ConfigDict].