Struct ExternalSource 

pub struct ExternalSource {
    pub sent: Vec<String>,
    pub trace: bool,
    /* private fields */
}

A connected adapter.

Fields

sent: Vec<String>

Every request line sent, without the newline (for tests and traces).

trace: bool

Keep the trace (off by default: production sends are not retained).

Implementations

impl ExternalSource

pub fn spawn( command: &str, args: &[String], env: &BTreeMap<String, String>, ) -> Result<Self>

Spawn command args… with env merged over the parent’s and connect.

pub fn spawn_source(source: &SourceRow, adapter: &AdapterRow) -> Result<Self>

Spawn a registry source: the adapter’s command, its fixed args, then render_config_flags(source.config); the source’s env.

pub fn argv(source: &SourceRow, adapter: &AdapterRow) -> Vec<String>

The argv an adapter is spawned with (§5), for callers that log it.

pub fn connect( label: &str, from_adapter: impl Read + Send + 'static, to_adapter: impl Write + Send + 'static, ) -> Result<Self>

Connect over an arbitrary pair of streams (the adapter’s stdout to read, its stdin to write) — a test or a runner playing a scripted adapter over pipes. label names the adapter in errors.

pub fn command(&self) -> &str

The label/command this source was spawned as.

pub fn call(&mut self, method: &str, params: Value) -> Result<Value>

One request/response round trip: {"id":n,"method":m,"params":{…}}, then responses until the one with our id (others are dropped, as the reference does); {"error": …} fails.

pub fn alive(&mut self) -> bool

Whether the child (if any) is still running.

Trait Implementations

impl Debug for ExternalSource

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

Formats the value using the given formatter.

impl Drop for ExternalSource

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.

impl SyncSource for ExternalSource

fn unwatch(&mut self) -> Result<()>

Stop listening, then unwatch; a failure (the process may be exiting) is ignored.

fn close(&mut self) -> Result<()>

Close stdin (EOF), give the adapter a moment to exit, then SIGTERM, then SIGKILL; reap it.

fn capabilities(&self) -> SourceCapabilities

fn enumerate(&mut self) -> Result<Vec<SourceEntry>>

The full current scope.

fn fetch(&mut self, path: &str) -> Result<Option<SourceItem>>

One member’s current state, or None when it left the scope.

fn write(&mut self, path: &str, content: &str) -> Result<()>

Persist engine-authored bytes (write-through sources only).

fn remove(&mut self, path: &str) -> Result<()>

Remove a member (write-through sources only).

fn watch(&mut self) -> Result<Receiver<Vec<String>>>

Subscribe to change batches: each received value is one batch of changed paths (watching sources only).