pub struct CellServerConfig {
pub bind_addr: SocketAddr,
pub tcp_nodelay: bool,
pub postgres: Option<PostgresConfig>,
pub host_id: Option<Uuid>,
pub peer_registry: Option<PeerRegistryConfig>,
pub default_persister: Option<Arc<dyn Persister>>,
pub persister_overrides: HashMap<String, Arc<dyn Persister>>,
pub peer_clients: Option<Arc<DashMap<Arc<str>, Arc<MykoClient>>>>,
}Expand description
Cell-based Myko server configuration.
Fields§
§bind_addr: SocketAddrAddress to bind the WebSocket server
tcp_nodelay: boolDisable Nagle’s algorithm (set TCP_NODELAY) on accepted connections.
Myko’s traffic is small, frequent, latency-sensitive messages (e.g.
~60Hz pulses); with Nagle on, TCP coalesces successive small writes
into fewer segments that arrive together, so an even send cadence is
delivered as bursts. Defaults to true.
postgres: Option<PostgresConfig>Optional Postgres configuration for event persistence/distribution
host_id: Option<Uuid>Server host ID (auto-generated if not provided)
peer_registry: Option<PeerRegistryConfig>Optional peer registry configuration for federation
default_persister: Option<Arc<dyn Persister>>Default persister override
persister_overrides: HashMap<String, Arc<dyn Persister>>Per-entity persister overrides keyed by entity type name
peer_clients: Option<Arc<DashMap<Arc<str>, Arc<MykoClient>>>>Optional pre-constructed peer-client map. When provided, it will be
used as-is (so any PeerPersister built against the same Arc
shares the live map). If None, the server creates its own.
Trait Implementations§
Source§impl Clone for CellServerConfig
impl Clone for CellServerConfig
Source§fn clone(&self) -> CellServerConfig
fn clone(&self) -> CellServerConfig
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read moreAuto Trait Implementations§
impl !RefUnwindSafe for CellServerConfig
impl !UnwindSafe for CellServerConfig
impl Freeze for CellServerConfig
impl Send for CellServerConfig
impl Sync for CellServerConfig
impl Unpin for CellServerConfig
impl UnsafeUnpin for CellServerConfig
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
Source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more