Struct hydro_deploy::hydroflow_crate::ports::HydroflowPortConfig

pub struct HydroflowPortConfig {
    pub service: Weak<RwLock<HydroflowCrateService>>,
    pub service_host: Arc<dyn Host>,
    pub service_server_defns: Arc<RwLock<HashMap<String, ServerPort>>>,
    pub port: String,
    pub merge: bool,
}

Fields

service: Weak<RwLock<HydroflowCrateService>>

service_host: Arc<dyn Host>

service_server_defns: Arc<RwLock<HashMap<String, ServerPort>>>

port: String

merge: bool

Implementations

impl HydroflowPortConfig

pub fn merge(&self) -> Self

Trait Implementations

impl Clone for HydroflowPortConfig

fn clone(&self) -> HydroflowPortConfig

Returns a copy of the value.

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

Performs copy-assignment from source.

impl HydroflowServer for HydroflowPortConfig

fn get_port(&self) -> ServerPort

fn launched_host(&self) -> Arc<dyn LaunchedHost>

impl HydroflowSink for HydroflowPortConfig

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 HydroflowPortConfig

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)