Struct KernelServiceCore 

pub struct KernelServiceCore<J: Journal, S: SidecarFederation = InMemorySidecarFederation> { /* private fields */ }

Implementations

impl KernelServiceCore<InMemoryJournal, InMemorySidecarFederation>

pub fn new() -> Self

impl KernelServiceCore<SqliteJournal, SqliteSidecarFederation>

pub fn open(path: impl AsRef<Path>) -> Result<Self, ApiError>

impl<J: Journal, S: SidecarFederation> KernelServiceCore<J, S>

pub fn from_parts(journal: J, sidecars: S) -> Self

impl<J, S> KernelServiceCore<J, S>

where J: Journal, S: SidecarFederation + Default,

pub fn from_journal(journal: J) -> Self

Trait Implementations

impl<J: Debug + Journal, S: Debug + SidecarFederation> Debug for KernelServiceCore<J, S>

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

Formats the value using the given formatter.

impl Default for KernelServiceCore<InMemoryJournal, InMemorySidecarFederation>

fn default() -> Self

Returns the “default value” for a type.

impl<J: Journal, S: SidecarFederation> KernelService for KernelServiceCore<J, S>

fn append(&mut self, request: AppendRequest) -> Result<AppendResponse, ApiError>

fn history(&self, request: HistoryRequest) -> Result<HistoryResponse, ApiError>

fn current_state( &self, request: CurrentStateRequest, ) -> Result<CurrentStateResponse, ApiError>

fn as_of(&self, request: AsOfRequest) -> Result<AsOfResponse, ApiError>

fn compile_program( &self, request: CompileProgramRequest, ) -> Result<CompileProgramResponse, ApiError>

fn evaluate_program( &mut self, request: EvaluateProgramRequest, ) -> Result<EvaluateProgramResponse, ApiError>

fn explain_tuple( &self, request: ExplainTupleRequest, ) -> Result<ExplainTupleResponse, ApiError>

fn explain_plan( &self, request: ExplainPlanRequest, ) -> Result<ExplainPlanResponse, ApiError>

fn parse_document( &self, request: ParseDocumentRequest, ) -> Result<ParseDocumentResponse, ApiError>

fn run_document( &mut self, request: RunDocumentRequest, ) -> Result<RunDocumentResponse, ApiError>

fn coordination_pilot_report( &mut self, request: CoordinationPilotReportRequest, ) -> Result<CoordinationPilotReport, ApiError>

fn coordination_delta_report( &mut self, request: CoordinationDeltaReportRequest, ) -> Result<CoordinationDeltaReport, ApiError>

fn register_artifact_reference( &mut self, request: RegisterArtifactReferenceRequest, ) -> Result<RegisterArtifactReferenceResponse, ApiError>

fn get_artifact_reference( &self, request: GetArtifactReferenceRequest, ) -> Result<GetArtifactReferenceResponse, ApiError>

fn register_vector_record( &mut self, request: RegisterVectorRecordRequest, ) -> Result<RegisterVectorRecordResponse, ApiError>

fn search_vectors( &self, request: SearchVectorsRequest, ) -> Result<SearchVectorsResponse, ApiError>