Struct SourceJsonCodec 

pub struct SourceJsonCodec;

Trait Implementations

impl Debug for SourceJsonCodec

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

Formats the value using the given formatter.

impl Default for SourceJsonCodec

fn default() -> Self

Returns the “default value” for a type.

impl JsonCapabilityCodec for SourceJsonCodec

fn capability_id(&self) -> &'static str

Stable Capability series identity.

fn descriptor_version(&self) -> &'static str

Exact Descriptor version.

fn descriptor_digest(&self) -> &'static str

Canonical digest of the exact generated Descriptor.

fn request_operations(&self) -> &'static [&'static str]

Exact request Operation table.

fn stream_operations(&self) -> &'static [&'static str]

Exact bidirectional stream Operation table.

fn event_operations(&self) -> &'static [&'static str]

Exact ephemeral Event Operation table.

fn encode_request( &self, operation: &str, request: &dyn Any, ) -> Result<Value, RuntimeFailure>

Converts one generated request into validated portable JSON.

fn decode_response( &self, operation: &str, value: Value, ) -> Result<Box<dyn Any>, RuntimeFailure>

Converts portable JSON into the generated response value.

fn decode_domain_error( &self, operation: &str, value: Value, ) -> Result<Box<dyn Any>, RuntimeFailure>

Converts portable JSON into the generated Domain Error value.

fn encode_stream_open( &self, operation: &str, _request: &dyn Any, ) -> Result<Value, RuntimeFailure>

Converts one generated stream-open request into validated portable JSON.

fn encode_stream_message( &self, operation: &str, _message: &dyn Any, ) -> Result<Value, RuntimeFailure>

Converts one generated outbound stream message into validated portable JSON.

fn decode_stream_message( &self, operation: &str, _value: Value, ) -> Result<Box<dyn Any>, RuntimeFailure>

Converts one portable JSON stream message into its generated value.

fn decode_stream_domain_error( &self, operation: &str, _value: Value, ) -> Result<Box<dyn Any>, RuntimeFailure>

Converts one portable JSON stream terminal error into its generated value.

fn encode_event( &self, operation: &str, _event: &dyn Any, ) -> Result<Value, RuntimeFailure>

Converts one generated Event value into validated portable JSON.

fn invoke_host_request( &self, dependency: PluginDependencyHandle, operation: String, request: Value, context: InvocationContext, ) -> JsonHostRequestFuture

Invokes one exact Plan-bound host Request dependency from portable JSON.

fn open_host_stream( &self, _dependency: PluginStreamDependencyHandle, operation: String, _request: Value, _context: InvocationContext, ) -> JsonHostStreamOpenFuture

Opens one exact Plan-bound host Stream dependency from portable JSON.

fn publish_host_event( &self, _dependency: PluginEventDependencyHandle, operation: String, _event: Value, _context: InvocationContext, ) -> LocalBoxFuture<'static, Result<(), RuntimeFailure>>

Publishes one exact Plan-bound host Event dependency from portable JSON.