Struct CoreContext

Source

pub struct CoreContext {
    pub event_bus: Arc<dyn EventBus>,
    pub token_store: Arc<dyn TokenStore>,
    pub http_client_manager: Arc<HttpClientManager>,
    pub provider_service: Arc<ProviderService>,
    pub pipeline_service: Arc<PipelineService>,
    pub metrics_service: Option<Arc<MetricsService>>,
    pub refresh_manager: Arc<RefreshManager>,
    pub health: HealthHandle,
    pub health_service: Arc<ProviderHealthService>,
    pub config_state: Arc<ConfigState>,
    pub log_service: Arc<LogService>,
    pub pipeline_view_service: Arc<PipelineViewService>,
    /* private fields */
}

Fields§

§event_bus: Arc<dyn EventBus>§token_store: Arc<dyn TokenStore>§http_client_manager: Arc<HttpClientManager>§provider_service: Arc<ProviderService>§pipeline_service: Arc<PipelineService>§metrics_service: Option<Arc<MetricsService>>§refresh_manager: Arc<RefreshManager>§health: HealthHandle§health_service: Arc<ProviderHealthService>§config_state: Arc<ConfigState>§log_service: Arc<LogService>§pipeline_view_service: Arc<PipelineViewService>

Struct CoreContext Copy item path

Fields§

Implementations§

impl CoreContext

pub async fn new( data_dir: &Path, event_bus: Arc<dyn EventBus>, token_store: Arc<dyn TokenStore>, ) -> Result<Self>

pub async fn with_storage_manager( storage_manager: &StorageManager, event_bus: Arc<dyn EventBus>, ) -> Result<Self>

pub async fn start_background_tasks(&self)

pub async fn apply_config_file(&self) -> DomainResult<ConfigSyncResult>

pub async fn factory_reset(&self) -> DomainResult<usize>

pub async fn shutdown(&self)

pub async fn warmup_token_store(&self) -> Result<()>

Auto Trait Implementations§

impl !RefUnwindSafe for CoreContext

impl !UnwindSafe for CoreContext

impl Freeze for CoreContext

impl Send for CoreContext

impl Sync for CoreContext

impl Unpin for CoreContext

impl UnsafeUnpin for CoreContext

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DTwhere ST: ?Sized, DT: ?Sized,

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DTwhere ST: ?Sized, DT: ?Sized,

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self> ⓘ

fn in_current_span(self) -> Instrumented<Self> ⓘ

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> IntoEither for T

fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘwhere F: FnOnce(&Self) -> bool,

impl<T> PolicyExt for Twhere T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>where T: Sized + Policy<B, E>, P: Policy<B, E>,

fn or<P, B, E>(self, other: P) -> Or<T, P>where T: Sized + Policy<B, E>, P: Policy<B, E>,

impl<T> Read<Exclusive, BecauseExclusive> for Twhere T: ?Sized,

impl<T> Same for T

type Output = T

impl<T> ServiceExt for T

fn map_response_body<F>(self, f: F) -> MapResponseBody<Self, F>where Self: Sized,

fn trace_for_http(self) -> Trace<Self, SharedClassifier<ServerErrorsAsFailures>>where Self: Sized,

fn trace_for_grpc(self) -> Trace<Self, SharedClassifier<GrpcErrorsAsFailures>>where Self: Sized,

fn follow_redirects(self) -> FollowRedirect<Self>where Self: Sized,

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = !

fn try_from(value: U) -> Result<T, !>

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<V, T> VZip<V> for Twhere V: MultiLane<T>,

fn vzip(self) -> V

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> ⓘwhere S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self> ⓘ

Struct CoreContext

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
where ST: ?Sized, DT: ?Sized,

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
where ST: ?Sized, DT: ?Sized,

impl<T, U> Into<U> for T
where U: From<T>,

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
where F: FnOnce(&Self) -> bool,

impl<T> PolicyExt for T
where T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

impl<T> Read<Exclusive, BecauseExclusive> for T
where T: ?Sized,

fn map_response_body<F>(self, f: F) -> MapResponseBody<Self, F>
where Self: Sized,

fn trace_for_http(self) -> Trace<Self, SharedClassifier<ServerErrorsAsFailures>>
where Self: Sized,

fn trace_for_grpc(self) -> Trace<Self, SharedClassifier<GrpcErrorsAsFailures>>
where Self: Sized,

fn follow_redirects(self) -> FollowRedirect<Self>
where Self: Sized,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> ⓘ
where S: Into<Dispatch>,