Struct CoreClient 

pub struct CoreClient { /* private fields */ }

Client for AllSource Core (writes).

Connects directly to Core (default port 3900) for event ingestion. Use this for write operations; use QueryClient for reads.

Implementations

impl CoreClient

pub fn new(base_url: &str, api_key: &str) -> Result<Self, Error>

Create a new Core client.

pub fn with_config(config: ClientConfig) -> Result<Self, Error>

Create with full configuration.

pub async fn ingest_event( &self, input: IngestEventInput, ) -> Result<IngestResponse, Error>

Ingest a single event.

Event types are automatically normalized to AllSource’s lowercase.dot.separated convention. For example, VerificationCreated becomes verification.created.

pub async fn ingest_batch( &self, events: Vec<IngestEventInput>, ) -> Result<BatchIngestResponse, Error>

Ingest a batch of events.

Event types are automatically normalized to AllSource’s lowercase.dot.separated convention. For example, VerificationCreated becomes verification.created.

pub async fn health(&self) -> Result<HealthResponse, Error>

Check Core health.

Trait Implementations

impl Clone for CoreClient

fn clone(&self) -> CoreClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CoreClient

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

Formats the value using the given formatter.