proxy

Documentation

Overview

Package proxy proxies rpc request to the best rpc node

Index

• type BodyReader
• type Forwarder
• type RPCProxy
  • func NewProxy(config config.Config) *RPCProxy
  • func (r *RPCProxy) Forward(c *gin.Context, chainID uint32)
  • func (r *RPCProxy) Run(ctx context.Context)
• type RPCRequest

Types

type BodyReader

type BodyReader interface {
	io.ReadCloser
}

BodyReader is used for generating a mock of the request body that returns an error

type Forwarder

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

Forwarder creates a request forwarder.

type RPCProxy

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

RPCProxy proxies rpc request to the fastest endpoint. Requests fallback in cases where data is not available.

func NewProxy

func NewProxy(config config.Config) *RPCProxy

NewProxy creates a new rpc proxy.

func (*RPCProxy) Forward

func (r *RPCProxy) Forward(c *gin.Context, chainID uint32)

Forward forwards the rpc request to the servers and makes assertions around confirmation thresholds.

func (*RPCProxy) Run

func (r *RPCProxy) Run(ctx context.Context)

Run runs the rpc server until context cancellation.

type RPCRequest

type RPCRequest struct {
	ID     json.RawMessage   `json:"id"`
	Method string            `json:"method"`
	Params []json.RawMessage `json:"params"`
}

RPCRequest is a raw rpc request format.