Struct ServerRuntime 

pub struct ServerRuntime { /* private fields */ }

Standalone server runtime.

Implementations

impl ServerRuntime

pub fn new(config: ServerConfig) -> Result<Self, ServerConfigError>

Validate config and construct a runtime.

pub fn with_cluster_status_provider( self, cluster_status: Arc<dyn ClusterStatusProvider>, ) -> Self

Override the cluster-status provider.

This is the W0 seam used by tests and later by the member-role grid host.

pub fn with_observability_model( self, observability: ServerObservabilityModel, ) -> Self

Override additional read-only observability signals.

pub fn start(self) -> Self

Start storage, cluster membership, listeners, and background services.

pub fn health(&self) -> ServerHealth

Return liveness.

pub fn ready(&self) -> ServerReadiness

Return readiness.

pub fn can_serve(&self) -> bool

Return whether the runtime can serve traffic.

pub fn is_draining(&self) -> bool

Return whether the runtime is currently draining.

pub fn begin_request(&mut self) -> bool

Begin one in-flight request.

pub fn finish_request(&mut self)

Complete one in-flight request.

pub fn client_surface_ready(&self) -> bool

Return whether the external client surface is accepting work.

pub fn begin_client_subscription(&self) -> bool

Begin a modeled client subscription stream.

pub fn client_active_subscriptions(&self) -> u64

Return active modeled client subscription streams.

pub fn client_surface_drain(&self) -> Option<ClientSurfaceDrain>

Return the last client-surface drain result, if the surface is enabled.

pub fn redis_surface_ready(&self) -> bool

Return whether the optional Redis RESP surface is accepting work.

pub fn begin_redis_connection(&mut self) -> bool

Begin a modeled RESP connection.

pub fn finish_redis_connection(&mut self)

Finish a modeled RESP connection.

pub fn redis_active_connections(&self) -> u64

Return active modeled RESP connections.

pub fn redis_surface_drain(&self) -> Option<RedisSurfaceDrain>

Return the last Redis RESP surface drain result, if the surface is enabled.

pub fn redis_listener_addr(&self) -> Option<SocketAddr>

Return the Redis RESP bind address when that optional listener is enabled.

pub fn redis_resp_server( &self, ) -> Result<Option<RedisRespServer>, RedisServeError>

Build a Redis RESP executor using this runtime’s shared client-surface state.

pub fn redis_tls_acceptor( &self, ) -> Result<Option<RedisTlsAcceptor>, RedisTlsError>

Build the optional Redis TLS acceptor when rediss:// is enabled.

pub fn client_dispatch_state(&self) -> Option<Arc<ClientSurfaceState>>

Return the shared verified-dispatch state used by HC/1, RESP, and HC/2.

pub fn diagnostic_reset_enabled(&self) -> bool

Return whether the local-only destructive diagnostic reset is enabled.

pub fn diagnostic_reset_targets( &self, ) -> (HydraCache, Option<Arc<ClientSurfaceState>>)

Clone the owners cleared by the internal diagnostic reset route.

pub fn begin_drain(&mut self)

Stop accepting new work and enter the draining state.

pub fn request_admin_drain(&mut self) -> DrainOutcome

Accept an operator/admin drain request without stopping the daemon process.

pub fn graceful_shutdown(&mut self) -> DrainOutcome

Gracefully stop accepting, drain, flush, and stop services.

pub fn shutdown(&mut self) -> DrainOutcome

Backward-compatible alias for graceful shutdown.

pub fn admin_status(&self) -> ServerAdminStatus

Return admin/operator status derived from the runtime model.

pub fn raft_compaction_status( &self, ) -> Result<RaftCompactionStatus, RaftCompactionError>

Return current disk-backed Raft compaction progress without mutating it.

pub fn request_raft_compaction( &self, ) -> Result<RaftCompactionStatus, ServerAdminActionError>

Explicitly compact the durable Raft log at current applied progress.

pub fn metrics_registry(&self) -> HydraCacheRegistry

Build a metrics registry snapshot for the admin surface.

pub fn cluster_overview(&self) -> ClusterOverview

Build a read-only Management Center cluster overview.

pub fn request_reshard( &self, ) -> Result<ServerAdminAction, ServerAdminActionError>

Request an online reshard through the current runtime model.

pub fn request_backup( &self, ) -> Result<ServerAdminAction, ServerAdminActionError>

Request a backup through the current runtime model.

pub fn flushed(&self) -> bool

Return whether shutdown flushed durable state.

pub fn cache(&self) -> &HydraCache

Return cache handle used by embedded tests/adapters.

pub fn config(&self) -> &ServerConfig

Return the runtime config.

Trait Implementations

impl Clone for ServerRuntime

fn clone(&self) -> ServerRuntime

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ServerRuntime

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

Formats the value using the given formatter.