rpc

Documentation

Index

• func SetupHeartbeat(ctx context.Context) (*ethRpc.Subscription, error)
• type Client
  • func NewClient(addr string) (*Client, error)
  • func (c *Client) AddOrders(orders []*zeroex.SignedOrder) (*zeroex.ValidationResults, error)
  • func (c *Client) AddPeer(peerInfo peerstore.PeerInfo) error
  • func (c *Client) GetOrders(page, perPage int, snapshotID string) (*GetOrdersResponse, error)
  • func (c *Client) SubscribeToHeartbeat(ctx context.Context, ch chan<- string) (*rpc.ClientSubscription, error)
  • func (c *Client) SubscribeToOrders(ctx context.Context, ch chan<- []*zeroex.OrderEvent) (*rpc.ClientSubscription, error)
• type GetOrdersResponse
• type RPCHandler
• type Server
  • func NewServer(addr string, rpcHandler RPCHandler) (*Server, error)
  • func (s *Server) Addr() net.Addr
  • func (s *Server) Close() error
  • func (s *Server) Listen() error

Functions

func SetupHeartbeat

func SetupHeartbeat(ctx context.Context) (*ethRpc.Subscription, error)

SetupHeartbeat sets up the heartbeat for a subscription

Types

type Client

type Client struct {
	// contains filtered or unexported fields
}

Client is a JSON RPC 2.0 client implementation over WebSockets. It can be used to communicate with a 0x Mesh node and add orders.

func NewClient

func NewClient(addr string) (*Client, error)

NewClient creates and returns a new client. addr is the address of the server (i.e. a 0x Mesh node) to dial.

func (*Client) AddOrders

func (c *Client) AddOrders(orders []*zeroex.SignedOrder) (*zeroex.ValidationResults, error)

AddOrders adds orders to the 0x Mesh node and broadcasts them throughout the 0x Mesh network.

func (*Client) AddPeer

func (c *Client) AddPeer(peerInfo peerstore.PeerInfo) error

AddPeer adds the peer to the node's list of peers. The node will attempt to connect to this new peer and return an error if it cannot.

func (*Client) GetOrders

func (c *Client) GetOrders(page, perPage int, snapshotID string) (*GetOrdersResponse, error)

GetOrders gets all orders stored on the Mesh node at a particular point in time in a paginated fashion

func (*Client) SubscribeToHeartbeat

func (c *Client) SubscribeToHeartbeat(ctx context.Context, ch chan<- string) (*rpc.ClientSubscription, error)

SubscribeToHeartbeat subscribes a stream of heartbeats in order to have certainty that the WS connection is still alive. Note copied from `go-ethereum` codebase: Slow subscribers will be dropped eventually. Client buffers up to 8000 notifications before considering the subscriber dead. The subscription Err channel will receive ErrSubscriptionQueueOverflow. Use a sufficiently large buffer on the channel or ensure that the channel usually has at least one reader to prevent this issue.

func (*Client) SubscribeToOrders

func (c *Client) SubscribeToOrders(ctx context.Context, ch chan<- []*zeroex.OrderEvent) (*rpc.ClientSubscription, error)

SubscribeToOrders subscribes a stream of order events Note copied from `go-ethereum` codebase: Slow subscribers will be dropped eventually. Client buffers up to 8000 notifications before considering the subscriber dead. The subscription Err channel will receive ErrSubscriptionQueueOverflow. Use a sufficiently large buffer on the channel or ensure that the channel usually has at least one reader to prevent this issue.

type GetOrdersResponse

type GetOrdersResponse struct {
	SnapshotID  string                      `json:"snapshotID"`
	OrdersInfos []*zeroex.AcceptedOrderInfo `json:"ordersInfos"`
}

GetOrdersResponse is the response returned for an RPC request to mesh_getOrders

type RPCHandler

type RPCHandler interface {
	// AddOrders is called when the client sends an AddOrders request.
	AddOrders(signedOrdersRaw []*json.RawMessage) (*zeroex.ValidationResults, error)
	// GetOrders is called when the clients sends a GetOrders request
	GetOrders(page, perPage int, snapshotID string) (*GetOrdersResponse, error)
	// AddPeer is called when the client sends an AddPeer request.
	AddPeer(peerInfo peerstore.PeerInfo) error
	// SubscribeToOrders is called when a client sends a Subscribe to `orders` request
	SubscribeToOrders(ctx context.Context) (*rpc.Subscription, error)
}

RPCHandler is used to respond to incoming requests from the client.

type Server

type Server struct {
	// contains filtered or unexported fields
}

Server is a JSON RPC 2.0 server implementation over WebSockets. It accepts requests from a client for adding orders to the 0x Mesh network.

func NewServer

func NewServer(addr string, rpcHandler RPCHandler) (*Server, error)

NewServer creates and returns a new server which will listen for new connections on the given addr and use the rpcHandler to handle incoming requests.

func (*Server) Addr

func (s *Server) Addr() net.Addr

Addr returns the address the server is listening on or nil if it has not yet started listening.

func (*Server) Close

func (s *Server) Close() error

Close closes the listener and stops it from accepting new connections or responding to any new requests.

func (*Server) Listen

func (s *Server) Listen() error

Listen causes the server to listen for new connections. You can call Close to stop listening. Listen blocks until there is an error.