ForwardsBatchesToActor
Shared Buffering -> Live -> Direct state machine for the actor-forwarding exporters.
Buffering: batches accumulate in a bounded ring (oldest dropped on overflow) until attach() is called, which drains the buffer to the actor ref in order and flips to Live. Live: batches are handed to the ref (offer() when BackpressureCapable, else tell()). Direct: entered permanently once the ref is found dead — including at attach() time, if the ref is already dead, which flushes the buffer through the inner exporter synchronously instead of going Live; batches are then delegated to the inner exporter synchronously.
Tags
Table of Contents
Methods
- attach() : void
Methods
attach()
public
attach(ActorRef<string|int, ExportCommand> $ref) : void
Parameters
- $ref : ActorRef<string|int, ExportCommand>