Struct K2VApiServer 

pub struct K2VApiServer { /* private fields */ }

Implementations

impl K2VApiServer

pub async fn run( garage: Arc<Garage>, bind_addr: UnixOrTCPSocketAddress, s3_region: String, must_exit: Receiver<bool>, ) -> Result<(), GarageError>

Trait Implementations

impl ApiHandler for K2VApiServer

const API_NAME: &'static str = "k2v"

const API_NAME_DISPLAY: &'static str = "K2V"

type Endpoint = K2VApiEndpoint

type Error = Error

fn parse_endpoint( &self, req: &Request<IncomingBody>, ) -> Result<K2VApiEndpoint, Error>

async fn handle( &self, req: Request<IncomingBody>, endpoint: K2VApiEndpoint, ) -> Result<Response<ResBody>, Error>

fn key_id_from_request(&self, req: &Request<IncomingBody>) -> Option<String>

Returns the key id used to authenticate this request. The ID returned must be safe to log.