Crate cubist_proxy

rpcmux: framework for muxing TCP connections

Modules

connector

connector: an Pair <-> Pair connector

pipeline

pipeline: take an Offchain and execute on it

transformer

transformer: a (stream/sink) <-> (stream/sink) adapter

Macros

listen_all

Set up one or more listeners and handle all of them in a loop

Structs

JrpcRequest

A rpc call is represented by sending a Request object to a Server.

Enums

FatalErr

Failure of an entire pipeline.

HttpRrErr

An error message for an HTTP Request/Response pipeline. This is either a wrapper around a Result or a fatal error that should kill the pipeline.

JsonRpcErr

An error message for a JSON-RPC processing pipeline. This is either a wrapper around serde_json::Value or a fatal error that should kill the pipeline.

Offchain

Offchains represent a unique tcp connection from an offchain client. They’re emitted by the http function

Traits

Pair

A Sink/Stream pair in an RPC muxing pipeline

Functions

conn_pool

Construct a connection pool for use with http_client(), jrpc_client(), or rr_client()

jrpc_client

Construct a JSON-RPC client from a ws:, wss:, http:, or https: URI

listen_on

Listens on a tcp port and produces Offchains

listen_on_addr

Listens on a tcp port and produces Offchains.

rr_client

Construct an HTTP client that takes Request/Response directly from the pipeline

Type Definitions

ConnPool

A connection pool for making HTTP or HTTPS requests