shotover 0.7.2

Shotover API for building custom transforms
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31

use anyhow::{Error, Result};
use std::fmt;

use crate::message::Message;

pub mod cluster_connection_pool;

/// Represents a `Request` to a connection within Shotover
#[derive(Debug)]
pub struct Request {
    // Message to send upstream to connection
    pub message: Message,
    // Channel to return the response to
    pub return_chan: Option<tokio::sync::oneshot::Sender<Response>>,
}

/// Represents a `Response` to a `Request`
#[derive(Debug)]
pub struct Response {
    // Response to the original `Message`
    pub response: Result<Message>,
}

#[derive(thiserror::Error, Debug)]
pub enum ConnectionError<E: fmt::Debug + fmt::Display> {
    #[error("authenticator error: {0}")]
    Authenticator(E),

    #[error(transparent)]
    Other(#[from] Error),
}