Struct LinuxDataServiceExecutor 

pub struct LinuxDataServiceExecutor { /* private fields */ }

A DataServiceExecutor backed by Linux /proc collectors.

Routes queries to the appropriate collector by entity name, collects all records, then delegates in-memory query processing (filter, sort, project, aggregate) to MemoryDataService.

Implementations

impl LinuxDataServiceExecutor

pub fn new() -> Self

Create a new executor with the default set of collectors.

pub fn with_collector(self, collector: Box<dyn Collector>) -> Self

Register an additional collector.

Trait Implementations

impl DataServiceExecutor for LinuxDataServiceExecutor

type Error = LinuxProviderError

fn capabilities(&self) -> DataServiceCapabilities

impl Default for LinuxDataServiceExecutor

fn default() -> Self

Returns the “default value” for a type.

impl MutationExecutor for LinuxDataServiceExecutor

async fn mutate( &self, _request: MutationRequest, ) -> Result<MutationResult, Self::Error>

impl QueryExecutor for LinuxDataServiceExecutor

async fn query(&self, request: QueryRequest) -> Result<QueryResult, Self::Error>

impl StreamQueryExecutor for LinuxDataServiceExecutor

async fn query_stream( &self, _request: QueryRequest, _chunk_size: usize, ) -> Result<Vec<StreamChunk>, Self::Error>

impl Transaction for LinuxDataServiceExecutor

type Error = LinuxProviderError

async fn commit(self) -> Result<(), Self::Error>

async fn rollback(self) -> Result<(), Self::Error>

impl TransactionExecutor for LinuxDataServiceExecutor

type Tx<'a> = LinuxDataServiceExecutor

async fn begin(&self) -> Result<Self::Tx<'_>, Self::Error>