Struct StandardLoki 

pub struct StandardLoki {}

The standard implementation of the Loki transport logic.

StandardLokiService provides the baseline behavior for the logging pipeline, using the standard batching and retry mechanisms defined in the LokiService default trait methods.

Behavior

• Transport: Uses the reqwest blocking client to push JSON payloads.
• Fallback: Inherits the default LokiFallback behavior, which redirects failed logs to the system’s standard error and output streams.

This struct is stateless, acting primarily as a marker to satisfy the trait requirements of the LokiLogger.

Trait Implementations

impl Fallback for StandardLoki

fn fallback(&self, error: &ServiceError, msg: &Message)

Handles the ultimate delivery failure for a log message.

This method is the “safety net” of the logging pipeline. It is invoked when a message cannot be sent to Loki after exhausting all retry attempts or encountering a non-recoverable error (like a 400 Bad Request).

Default Behavior

The default implementation performs a Best-Effort recovery:

1. Formats the failure reason (HTTP status or Network error) to stderr.
2. Prints the original log content to stdout with its timestamp, level, and payload.

This ensures that even in a total network collapse, the logs are captured by the system’s standard output streams (useful for Docker/K8s logs collectors).

Thread Safety

This is called from the background worker thread. Any custom implementation must be non-blocking and thread-safe to avoid stalling the entire logging pipeline.

impl Loki for StandardLoki

fn work(&self, receiver: Receiver<LokiMessage>, data: Arc<LokiData>)

Orchestrates the background worker loop.

fn work_batch( &self, level: &str, batch: &mut Vec<LokiMessage>, data: &Arc<LokiData>, ) -> Result<Response, ServiceError>

Handles the transformation and transmission of a specific log batch.