Struct SwapEncoderRegistry 

pub struct SwapEncoderRegistry { /* private fields */ }

Registry containing all supported SwapEncoders.

Implementations

impl SwapEncoderRegistry

pub fn new(chain: Chain) -> Self

pub fn new_with_defaults(chain: Chain) -> Result<Self, EncodingError>

Creates a new registry pre-populated with all default encoders for the given chain.

pub fn add_default_encoders( self, executors_addresses: Option<String>, ) -> Result<Self, EncodingError>

Populates the registry with the default SwapEncoders for the given blockchain by parsing the executors’ addresses in the file at the given path.

pub fn register_encoder( self, protocol: &str, encoder: Box<dyn SwapEncoder>, ) -> Self

Adds an encoder to the registry, replacing any existing encoder for the same protocol.

pub fn get_encoder( &self, protocol_system: &str, ) -> Option<&Box<dyn SwapEncoder>>

Returns the encoder registered for protocol_system.

Price-level-stream protocols (pricelevelstream:{venue}) without an exact entry fall back to the family entry registered under pricelevelstream, so a single configured executor address serves every pAMM — including auto-detected, address-named ones. propammfallback:{venue} resolves the same way against propammfallback.

pub fn executor_addresses(&self) -> HashMap<String, Bytes>

The executor address of every encoder in this registry, keyed by protocol system.

Several protocol systems may share one executor address, so the returned addresses are not necessarily distinct.

Trait Implementations

impl Clone for SwapEncoderRegistry

fn clone(&self) -> SwapEncoderRegistry

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.