pub struct ClickhouseSink { /* private fields */ }Expand description
Configurable ClickHouse-backed analytics sink.
Implementations§
Source§impl ClickhouseSink
impl ClickhouseSink
Sourcepub fn from_env() -> Result<Self>
pub fn from_env() -> Result<Self>
Build a sink from environment variables or sensible defaults.
pub fn with_client( client: Client, run_table: impl Into<String>, step_table: impl Into<String>, ) -> Self
Sourcepub async fn insert_run_event(&self, event: RunEvent) -> Result<()>
pub async fn insert_run_event(&self, event: RunEvent) -> Result<()>
Inserts a normalized run event row.
Sourcepub async fn insert_step_event(&self, event: StepEvent) -> Result<()>
pub async fn insert_step_event(&self, event: StepEvent) -> Result<()>
Inserts a normalized step event row.
Trait Implementations§
Source§impl Clone for ClickhouseSink
impl Clone for ClickhouseSink
Source§fn clone(&self) -> ClickhouseSink
fn clone(&self) -> ClickhouseSink
Returns a duplicate of the value. Read more
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreAuto Trait Implementations§
impl Freeze for ClickhouseSink
impl !RefUnwindSafe for ClickhouseSink
impl Send for ClickhouseSink
impl Sync for ClickhouseSink
impl Unpin for ClickhouseSink
impl !UnwindSafe for ClickhouseSink
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> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
§impl<T> FutureExt for T
impl<T> FutureExt for T
§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§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::RequestSource§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