mizchi/x/http - mooncakes.io

mizchi/x/http does not have a README file

HttpError

pub suberror HttpError {
  NetworkError(String)
  InvalidUrl(String)
  TimeoutError
  NotSupported
} derive(@moonbitlang/core/debug.Debug
Debug)

impl Show for HttpError

Addr

source

pub(all) struct Addr {
  text : String
  port : Int
}

Client

source

pub struct Client {
  inner : @moonbitlang/async/http.Client
Client
  // private fields
}

impl Reader for Client

impl Writer for Client

Client::close

source

fn Client::close(self : Client) -> Unit

Client::end_request

source

async fn Client::end_request(self : Client) -> Response raise HttpError

Client::enter_passthrough_mode

source

async fn Client::enter_passthrough_mode(self : Client) -> Unit raise HttpError

Client::flush

source

async fn Client::flush(self : Client) -> Unit raise HttpError

Client::get

source

async fn Client::get(self : Client, path : String, extra_headers? : Map[String, String], body? : &@moonbitlang/async/io.Data
Data) -> Response raise HttpError

Client::new

source

async fn Client::new(url : String, headers? : Map[String, String], proxy? : Client, verify? : Bool, trust? : @moonbitlang/async/tls.TrustedRoot
TrustedRoot) -> Client raise HttpError

Client::post

source

async fn Client::post(self : Client, path : String, body : &@moonbitlang/async/io.Data
Data, extra_headers? : Map[String, String]) -> Response raise HttpError

Client::put

source

async fn Client::put(self : Client, path : String, body : &@moonbitlang/async/io.Data
Data, extra_headers? : Map[String, String]) -> Response raise HttpError

Client::request

source

async fn Client::request(self : Client, meth : RequestMethod, path : StringView, extra_headers? : Map[String, String]) -> Unit raise HttpError

Client::skip_response_body

source

async fn Client::skip_response_body(self : Client) -> Unit raise HttpError

pub struct Cookie {
  name : String
  value : String
  path : String?
  expires_raw : String?
  max_age : Int64?
  domain : String?
  secure : Bool
  http_only : Bool
  extensions : Array[String]
} derive(@moonbitlang/core/debug.Debug
Debug)

#alias(new, deprecated="`new` is deprecated, use `Cookie` instead")
fn Cookie::Cookie(name : String, value : String, path? : String, expires_raw? : String, max_age? : Int64, domain? : String, secure? : Bool, http_only? : Bool, extensions? : Array[String]) -> Cookie

Request

source

pub(all) struct Request {
  meth : RequestMethod
  path : String
  headers : Map[String, String]
}

RequestMethod

source

pub(all) enum RequestMethod {
  Get
  Head
  Post
  Put
  Delete
  Connect
  Options
  Trace
  Patch
} derive(Compare, Eq, Hash, @moonbitlang/core/debug.Debug
Debug)

impl Show for RequestMethod

Response

source

pub(all) struct Response {
  code : Int
  reason : String
  headers : Map[String, String]
  cookies : Array[Cookie]
}

Server

source

pub struct Server {
  inner : @moonbitlang/async/http.Server
Server
}

Server::accept

source

async fn Server::accept(self : Server) -> (ServerConnection, Addr) raise HttpError

Server::addr

source

fn Server::addr(self : Server) -> Addr

Server::close

source

fn Server::close(self : Server) -> Unit

Server::close_graceful

source

async fn Server::close_graceful(self : Server, timeout_ms? : Int) -> Unit raise HttpError

Server::new

source

async fn Server::new(host? : String, port? : Int, headers? : Map[String, String], dual_stack? : Bool, reuse_addr? : Bool, max_request_body_bytes? : Int, request_timeout_ms? : Int, keep_alive_timeout_ms? : Int, headers_timeout_ms? : Int, accept_queue_limit? : Int, trust_proxy? : Bool) -> Server raise HttpError

Server::port

source

fn Server::port(self : Server) -> Int

Server::run_forever

source

async fn Server::run_forever(self : Server, f : async (Request, &@moonbitlang/async/io.Reader
Reader, ServerConnection) -> Unit, allow_failure? : Bool, max_connections? : Int) -> Unit raise HttpError

ServerConnection

source

pub struct ServerConnection {
  inner : @moonbitlang/async/http.ServerConnection
ServerConnection
}

impl Reader for ServerConnection

async fn _direct_read(self : ServerConnection, buf : FixedArray[Byte], offset~ : Int, max_len~ : Int) -> Int

source

fn _get_internal_buffer(self : ServerConnection) -> @moonbitlang/async/io.ReaderBuffer
ReaderBuffer

source

impl Writer for ServerConnection

ServerConnection::client_addr

source

fn ServerConnection::client_addr(self : ServerConnection) -> Addr

ServerConnection::close

source

fn ServerConnection::close(self : ServerConnection) -> Unit

ServerConnection::end_response

source

async fn ServerConnection::end_response(self : ServerConnection) -> Unit raise HttpError

ServerConnection::enter_passthrough_mode

source

async fn ServerConnection::enter_passthrough_mode(self : ServerConnection) -> Unit raise HttpError

ServerConnection::flush

source

async fn ServerConnection::flush(self : ServerConnection) -> Unit raise HttpError

ServerConnection::read_request

source

async fn ServerConnection::read_request(self : ServerConnection) -> Request raise HttpError

ServerConnection::send_response

source

async fn ServerConnection::send_response(self : ServerConnection, code : Int, reason : String, extra_headers? : Map[String, String], cookies? : Array[Cookie]) -> Unit raise HttpError

ServerConnection::skip_request_body

source

async fn ServerConnection::skip_request_body(self : ServerConnection) -> Unit raise HttpError

Stream

source

pub struct Stream {
  inner : @moonbitlang/async/http.Client
Client
}

Stream::close

source

fn Stream::close(self : Stream) -> Unit

Stream::read_all

source

async fn Stream::read_all(self : Stream) -> Bytes raise HttpError

Stream::read_some

source

async fn Stream::read_some(self : Stream) -> Bytes? raise HttpError

get

source

async fn get(url : String, headers? : Map[String, String], body? : &@moonbitlang/async/io.Data
Data, proxy? : Client) -> (Response, &@moonbitlang/async/io.Data
Data) raise HttpError

get_stream

source

async fn get_stream(url : String, headers? : Map[String, String], body? : &@moonbitlang/async/io.Data
Data, proxy? : Client) -> (Response, Client) raise HttpError

post

source

async fn post(url : String, body : &@moonbitlang/async/io.Data
Data, headers? : Map[String, String], proxy? : Client) -> (Response, &@moonbitlang/async/io.Data
Data) raise HttpError

post_stream

source

async fn post_stream(url : String, headers? : Map[String, String], proxy? : Client) -> Client raise HttpError

put

source

async fn put(url : String, body : &@moonbitlang/async/io.Data
Data, headers? : Map[String, String], proxy? : Client) -> (Response, &@moonbitlang/async/io.Data
Data) raise HttpError

put_stream

source

async fn put_stream(url : String, headers? : Map[String, String], proxy? : Client) -> Client raise HttpError

Source Files

Site source Report issue Packages Build queue Skills Statistics

#HttpError

#Addr

#Client

#Client::close

#Client::end_request

#Client::enter_passthrough_mode

#Client::flush

#Client::get

#Client::new

#Client::post

#Client::put

#Client::request

#Client::skip_response_body

#Cookie

#Cookie::Cookie

#Request

#RequestMethod

#Response

#Server

#Server::accept

#Server::addr

#Server::close

#Server::close_graceful

#Server::new

#Server::port

#Server::run_forever

#ServerConnection

#ServerConnection::client_addr

#ServerConnection::close

#ServerConnection::end_response

#ServerConnection::enter_passthrough_mode

#ServerConnection::flush

#ServerConnection::read_request

#ServerConnection::send_response

#ServerConnection::skip_request_body

#Stream

#Stream::close

#Stream::read_all

#Stream::read_some

#get

#get_stream

#post

#post_stream

#put

#put_stream

Source Files

HttpError

Addr

Client

Client::close

Client::end_request

Client::enter_passthrough_mode

Client::flush

Client::get

Client::new

Client::post

Client::put

Client::request

Client::skip_response_body

Cookie

Cookie::Cookie

Request

RequestMethod

Response

Server

Server::accept

Server::addr

Server::close

Server::close_graceful

Server::new

Server::port

Server::run_forever

ServerConnection

ServerConnection::client_addr

ServerConnection::close

ServerConnection::end_response

ServerConnection::enter_passthrough_mode

ServerConnection::flush

ServerConnection::read_request

ServerConnection::send_response

ServerConnection::skip_request_body

Stream

Stream::close

Stream::read_all

Stream::read_some

get

get_stream

post

post_stream

put

put_stream