Struct hydro_deploy::custom_service::CustomClientPort

pub struct CustomClientPort {
    pub on: Weak<RwLock<CustomService>>,
    /* private fields */
}

Fields

on: Weak<RwLock<CustomService>>

Implementations

impl CustomClientPort

pub fn new(on: Weak<RwLock<CustomService>>) -> Self

pub async fn server_port(&self) -> ServerPort

pub async fn connect(&self) -> ConnectedDirect

Trait Implementations

impl HydroflowSink for CustomClientPort

fn as_any(&self) -> &dyn Any

fn instantiate( &self, _client_path: &SourcePath, ) -> Result<Box<dyn FnOnce() -> ServerConfig>>

Instantiate the sink as the source host connecting to the sink host. Returns a thunk that can be called to perform mutations that instantiate the sink.

fn instantiate_reverse( &self, server_host: &Arc<dyn Host>, server_sink: Arc<dyn HydroflowServer>, wrap_client_port: &dyn Fn(ServerConfig) -> ServerConfig, ) -> Result<ReverseSinkInstantiator>

Instantiate the sink, but as the sink host connecting to the source host. Returns a thunk that can be called to perform mutations that instantiate the sink, taking a mutable reference to this sink.

impl HydroflowSource for CustomClientPort

fn source_path(&self) -> SourcePath

fn host(&self) -> Arc<dyn Host>

fn server(&self) -> Arc<dyn HydroflowServer>

fn record_server_config(&self, config: ServerConfig)

fn record_server_strategy(&self, _config: ServerStrategy)

fn wrap_reverse_server_config(&self, config: ServerConfig) -> ServerConfig

fn send_to(&self, sink: &dyn HydroflowSink)