Struct MemorySink 

pub struct MemorySink { /* private fields */ }

A non-persistent Sink/Reader that records batches, stores indexed documents, and acknowledges success.

Implementations

impl MemorySink

pub fn new() -> Self

Creates an empty recording sink.

pub fn recorded(&self) -> Vec<WriteBatch>

The batches recorded so far, in arrival order.

Recovers a poisoned lock: the recording is inert data with no invariant a panicking writer could tear, and a test asserting on it must not itself panic on poisoning.

pub fn recorded_searches(&self) -> Vec<SearchOp>

The search operations received so far, in arrival order. Recovers a poisoned lock for the same reason as MemorySink::recorded.

Trait Implementations

impl Debug for MemorySink

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for MemorySink

fn default() -> MemorySink

Returns the “default value” for a type.

impl Reader for MemorySink

async fn get(&self, op: ReadOp) -> Result<ReadOutcome, SinkError>

Fetches a single document by physical id.

async fn search(&self, op: SearchOp) -> Result<SearchOutcome, SinkError>

Runs a search, returning the raw hits envelope.

async fn search_stream( &self, op: SearchOp, ) -> Result<StreamingSearch, SinkError>

Runs a search whose response streams back (ADR-014, final stage): the upstream hits envelope is piped to the engine’s hit transform without being collected, so a large response (e.g. heavy aggregations) never lands in memory. The default is unsupported; OpenSearchSink overrides it with a real streamed upstream call.

async fn count(&self, op: SearchOp) -> Result<CountOutcome, SinkError>

Counts the documents matching a (partition-filtered) query.

fn cursor( &self, _op: CursorOp, ) -> impl Future<Output = Result<CursorOutcome, SinkError>> + Send

Forwards a raw cursor request to its pinned cluster (scroll/PIT continue, clear, close). The default is unsupported, a sink that cannot passthrough (the in-memory test sink, a write-only queue) rejects it; OpenSearchSink overrides it with a real upstream call.

fn forward_stream( &self, _op: ForwardOp, _body: ByteBody, ) -> impl Future<Output = Result<StreamingForward, SinkError>> + Send

Forwards a request to a cluster with the body supplied as a stream (ADR-014 stage 2): the verbatim-passthrough path pipes the downstream body straight upstream without buffering. The default is unsupported; OpenSearchSink overrides it with a real streamed upstream call.

impl Sink for MemorySink

async fn write(&self, batch: WriteBatch) -> Result<WriteAck, SinkError>

Applies a batch of writes, returning a per-operation acknowledgement.