pub struct ServerState {Show 16 fields
pub config: ServerConfig,
pub cluster_manager: Arc<RwLock<ClusterManager>>,
pub store: Arc<AnyKV>,
pub catalog: Arc<RwLock<dyn Catalog + Send + Sync>>,
pub async_store: Arc<AsyncKVStoreAdapter<AnyKV>>,
pub session_manager: Arc<SessionManager>,
pub metrics: Metrics,
pub audit: AuditLogger,
pub auth: AuthMiddleware,
pub start_time: Instant,
pub lifecycle_state: Arc<LifecycleStateManager>,
pub recovery_info: RecoveryInfo,
pub backup_coordinator: BackupCoordinator,
pub restore_coordinator: RestoreCoordinator,
pub admission_permits: Arc<Semaphore>,
pub admission_waiters: AtomicUsize,
}Fields§
§config: ServerConfig§cluster_manager: Arc<RwLock<ClusterManager>>§store: Arc<AnyKV>§catalog: Arc<RwLock<dyn Catalog + Send + Sync>>§async_store: Arc<AsyncKVStoreAdapter<AnyKV>>§session_manager: Arc<SessionManager>§metrics: Metrics§audit: AuditLogger§auth: AuthMiddleware§start_time: Instant§lifecycle_state: Arc<LifecycleStateManager>§recovery_info: RecoveryInfo§backup_coordinator: BackupCoordinator§restore_coordinator: RestoreCoordinator§admission_permits: Arc<Semaphore>§admission_waiters: AtomicUsizeImplementations§
Source§impl ServerState
impl ServerState
pub fn cluster_status_snapshot(&self) -> Result<ClusterStatusSnapshot>
pub fn cluster_join(&self) -> Result<ClusterStatusSnapshot>
pub fn cluster_leave(&self) -> Result<ClusterStatusSnapshot>
pub fn cluster_startup_diagnostics(&self) -> Result<ClusterStartupDiagnostics>
pub fn apply_table_lifecycle_effects( &self, effects: Vec<TableLifecycleEffect>, ) -> Result<()>
pub fn apply_catalog_rollback_effects( &self, effects: Vec<CatalogRollbackEffect>, ) -> Result<()>
pub async fn begin_sql_txn( &self, ) -> Result<AsyncTxnBridge<'static, AsyncKVTransactionAdapter>>
Auto Trait Implementations§
impl !Freeze for ServerState
impl !RefUnwindSafe for ServerState
impl !UnwindSafe for ServerState
impl Send for ServerState
impl Sync for ServerState
impl Unpin for ServerState
impl UnsafeUnpin for ServerState
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
Mutably borrows from an owned value. Read more
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>
Converts
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>
Converts
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 moreSource§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request