chainproxy

Nov 26, 2024

Changes in this version

type DefaultRPCInput

+ func (dri DefaultRPCInput) GetError() *rpcclient.JsonError

Oct 20, 2024

Changes in this version

+ const GRPCAllowInsecureConnection

+ const GRPCUseTls

+ const InternalErrorString

+ const LavaErrorCode

+ const MaxCallRecvMsgSize

+ const MaximumNumberOfParallelConnectionsAttempts

+ const ParallelConnectionsFlag

+ var NumberOfParallelConnections uint = 10

+ func DefaultParsableRPCInput(input json.RawMessage) parser.RPCInput

+ func HashURL(url string) string

+ type BaseMessage struct

+ Headers []pairingtypes.Metadata

+ LatestBlockHeaderSetter *spectypes.ParseDirective

+ func (bm *BaseMessage) AppendHeader(metadata []pairingtypes.Metadata)

+ func (bm *BaseMessage) DisableErrorHandling()

+ func (bm *BaseMessage) GetDisableErrorHandling() bool

+ func (bm *BaseMessage) SetLatestBlockWithHeader(latestBlock uint64, modifyContent bool) (done bool)

+ func (bm BaseMessage) GetHeaders() []pairingtypes.Metadata

+ type Connector struct

+ func NewConnector(ctx context.Context, nConns uint, nodeUrl common.NodeUrl) (*Connector, error)

+ func (connector *Connector) Close()

+ func (connector *Connector) GetRpc(ctx context.Context, block bool) (*rpcclient.Client, error)

+ func (connector *Connector) GetUrlHash() string

+ func (connector *Connector) ReturnRpc(rpc *rpcclient.Client)

+ type CustomParsingMessage interface

+ NewParsableRPCInput func(input json.RawMessage) (parser.RPCInput, error)

+ type DefaultRPCInput struct

+ Result json.RawMessage

+ func (dri DefaultRPCInput) GetID() json.RawMessage

+ func (dri DefaultRPCInput) GetMethod() string

+ func (dri DefaultRPCInput) GetParams() interface{}

+ func (dri DefaultRPCInput) GetResult() json.RawMessage

+ func (dri DefaultRPCInput) ParseBlock(inp string) (int64, error)

+ type GRPCConnector struct

+ func NewGRPCConnector(ctx context.Context, nConns uint, nodeUrl common.NodeUrl) (*GRPCConnector, error)

+ func (connector *GRPCConnector) Close()

+ func (connector *GRPCConnector) GetRpc(ctx context.Context, block bool) (*grpc.ClientConn, error)

+ func (connector *GRPCConnector) ReturnRpc(rpc *grpc.ClientConn)