microsoft.opentelemetry.a365.core.exporters.durable_delivery module

Durable delivery dispositions and per-identity transmission gating.

class microsoft.opentelemetry.a365.core.exporters.durable_delivery.DeliveryDisposition(value)

Bases: Enum

The outcome of a delivery attempt.

DELIVERED = 'delivered'

RETRYABLE = 'retryable'

PERMANENT = 'permanent'

class microsoft.opentelemetry.a365.core.exporters.durable_delivery.DeliveryResult(disposition, retry_after=None)

Bases: object

Delivery outcome and optional retry delay.

disposition: DeliveryDisposition

retry_after: float | None = None

class microsoft.opentelemetry.a365.core.exporters.durable_delivery.IdentityKey(tenant_id, agent_id, agentic_user_id, use_s2s_endpoint)

Bases: object

Identity tuple used to isolate durable delivery state.

tenant_id: str

agent_id: str

agentic_user_id: str | None

use_s2s_endpoint: bool

class microsoft.opentelemetry.a365.core.exporters.durable_delivery.TransmissionGate(clock=None, random_fn=None)

Bases: object

Gate retries per identity and allows only one half-open probe.

try_acquire(key)

Acquire the probe token for an identity if it is available.

Return type:

bool

record_success(key)

Reset durable delivery state after a successful attempt.

Return type:

None

record_retryable_failure(key, retry_after)

Block the identity until the retry window expires.

Return type:

None

release_probe(key)

Release an acquired probe token without changing the retry window.

Return type:

None