microsoft.opentelemetry.a365.core.exporters package

Exporter helpers for durable delivery.

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

Bases: Enum

The outcome of a delivery attempt.

DELIVERED = 'delivered'

RETRYABLE = 'retryable'

PERMANENT = 'permanent'

class microsoft.opentelemetry.a365.core.exporters.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.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.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

Submodules

• microsoft.opentelemetry.a365.core.exporters.agent365_exporter module
• microsoft.opentelemetry.a365.core.exporters.agent365_exporter_options module
  • Agent365ExporterOptions
• microsoft.opentelemetry.a365.core.exporters.durable_delivery module
  • DeliveryDisposition
    • DeliveryDisposition.DELIVERED
    • DeliveryDisposition.RETRYABLE
    • DeliveryDisposition.PERMANENT
  • DeliveryResult
    • DeliveryResult.disposition
    • DeliveryResult.retry_after
  • IdentityKey
    • IdentityKey.tenant_id
    • IdentityKey.agent_id
    • IdentityKey.agentic_user_id
    • IdentityKey.use_s2s_endpoint
  • TransmissionGate
    • TransmissionGate.try_acquire()
    • TransmissionGate.record_success()
    • TransmissionGate.record_retryable_failure()
    • TransmissionGate.release_probe()
• microsoft.opentelemetry.a365.core.exporters.enriched_span module
  • EnrichedReadableSpan
    • EnrichedReadableSpan.attributes
    • EnrichedReadableSpan.name
    • EnrichedReadableSpan.context
    • EnrichedReadableSpan.get_span_context()
    • EnrichedReadableSpan.parent
    • EnrichedReadableSpan.start_time
    • EnrichedReadableSpan.end_time
    • EnrichedReadableSpan.status
    • EnrichedReadableSpan.kind
    • EnrichedReadableSpan.events
    • EnrichedReadableSpan.links
    • EnrichedReadableSpan.resource
    • EnrichedReadableSpan.instrumentation_scope
    • EnrichedReadableSpan.to_json()
• microsoft.opentelemetry.a365.core.exporters.enriching_span_processor module
  • register_span_enricher()
  • unregister_span_enricher()
  • get_span_enricher()
• microsoft.opentelemetry.a365.core.exporters.persistent_storage module
  • DurableRecord
    • DurableRecord.schema_version
    • DurableRecord.tenant_id
    • DurableRecord.agent_id
    • DurableRecord.agentic_user_id
    • DurableRecord.use_s2s_endpoint
    • DurableRecord.payload
    • DurableRecord.created_at
    • DurableRecord.lease_until
    • DurableRecord.retry_count
    • DurableRecord.record_id
    • DurableRecord.new()
  • PersistentStorage
    • PersistentStorage.store()
    • PersistentStorage.claim()
    • PersistentStorage.delete()
    • PersistentStorage.release()
    • PersistentStorage.close()
• microsoft.opentelemetry.a365.core.exporters.replay_coordinator module
  • ReplayCoordinator
    • ReplayCoordinator.start()
    • ReplayCoordinator.wake()
    • ReplayCoordinator.shutdown()
    • ReplayCoordinator.run_once()
  • ReplayEndpointError
  • ReplayIdentityError
• microsoft.opentelemetry.a365.core.exporters.span_processor module
  • A365SpanProcessor
    • A365SpanProcessor.on_start()
    • A365SpanProcessor.on_end()
• microsoft.opentelemetry.a365.core.exporters.spectra_exporter_options module
  • SpectraExporterOptions
• microsoft.opentelemetry.a365.core.exporters.token_resolver_context module
  • AgentIdentity
    • AgentIdentity.agent_id
    • AgentIdentity.agentic_user_id
  • TokenResolverContext
    • TokenResolverContext.identity
    • TokenResolverContext.tenant_id
• microsoft.opentelemetry.a365.core.exporters.utils module
  • hex_trace_id()
  • hex_span_id()
  • kind_name()
  • status_name()
  • truncate_span()
  • filter_and_partition_by_identity()
  • get_validated_domain_override()
  • build_export_url()
  • parse_retry_after()
  • is_agent365_exporter_enabled()
  • estimate_value_bytes()
  • estimate_span_bytes()
  • chunk_by_size()
  • A365Handlers
    • A365Handlers.span_processors
  • is_a365_enabled()
  • coerce_storage_directory()
  • create_a365_components()