Crate byteor_adapters 

Enterprise adapters scaffolding.

Adapters are intentionally not part of the OSS core: they encode product/integration policy (protocols, venues, customer formats, secrets) and therefore live in the enterprise workspace.

That said, the enterprise runtime needs a real, testable integration boundary so product code can plug in ingress/egress without leaking dependencies into the OSS crates.

Structs

AdapterLoopError

Adapter loop failure plus the runtime status captured before exit.

AdapterLoopOptions

Optional controls for one adapter loop run.

AdapterLoopStats

Summary stats for one adapter loop run.

AdapterRuntimeStatus

Snapshot-ready runtime status for one adapter endpoint.

GrpcEgress

Minimal blocking gRPC egress adapter.

GrpcIngress

Minimal blocking gRPC ingress adapter.

HttpEgress

Minimal blocking HTTP egress adapter.

HttpIngress

Minimal blocking HTTP ingress adapter.

KafkaEgress

Minimal blocking Kafka egress adapter.

KafkaIngress

Minimal blocking Kafka ingress adapter.

LineEgress

A simple egress adapter that writes messages to a Write target.

LineIngress

A simple line-delimited ingress adapter.

NatsEgress

Minimal blocking NATS egress adapter.

NatsIngress

Minimal blocking NATS ingress adapter.

PostgresEgress

Minimal blocking PostgreSQL egress adapter.

PostgresIngress

Minimal blocking PostgreSQL ingress adapter.

RabbitMqStreamsEgress

Minimal blocking RabbitMQ Streams egress adapter.

RabbitMqStreamsIngress

Minimal blocking RabbitMQ Streams ingress adapter.

RedisStreamsEgress

Minimal blocking Redis Streams egress adapter.

RedisStreamsIngress

Minimal blocking Redis Streams ingress adapter.

S3Egress

Minimal blocking S3 egress adapter.

S3Ingress

Minimal blocking S3 ingress adapter.

WebSocketEgress

Minimal blocking WebSocket egress adapter.

WebSocketIngress

Minimal blocking WebSocket ingress adapter.

Enums

AdapterError

Adapter-level errors.

AdapterLoopFailure

Adapter loop errors.

PostgresRowFormat

Result row serialization mode for PostgreSQL ingress.

PostgresWriteMode

Persistence mode for PostgreSQL egress.

RabbitMqOffsetSpecification

Traits

Adapter

Minimal adapter identity contract.

EgressAdapter

Egress adapter: consumes output messages.

IngressAdapter

Ingress adapter: produces input messages.

Functions

run_single_ring_adapter_loop

Run a minimal adapter loop for an in-memory SingleRing worker job.

run_single_ring_adapter_loop_with_options

Run a minimal adapter loop for an in-memory SingleRing worker job with optional controls.

run_single_ring_adapter_loop_with_options_and_observer

Run a minimal adapter loop and observe best-effort progress snapshots after each message.