Documentation ¶
Index ¶
Constants ¶
View Source
const ( LavaErrorCode = 555 InternalErrorString = "Internal Error" )
View Source
const ( ParallelConnectionsFlag = "parallel-connections" MaximumNumberOfParallelConnectionsAttempts = 10 )
Variables ¶
View Source
var NumberOfParallelConnections uint = 10
Functions ¶
func DefaultParsableRPCInput ¶
func DefaultParsableRPCInput(input json.RawMessage) parser.RPCInput
Types ¶
type Connector ¶
type Connector struct {
// contains filtered or unexported fields
}
func NewConnector ¶
type CustomParsingMessage ¶
type CustomParsingMessage interface {
NewParsableRPCInput(input json.RawMessage) (parser.RPCInput, error)
}
type DefaultRPCInput ¶
type DefaultRPCInput struct {
Result json.RawMessage
}
func (DefaultRPCInput) GetParams ¶
func (dri DefaultRPCInput) GetParams() interface{}
func (DefaultRPCInput) GetResult ¶
func (dri DefaultRPCInput) GetResult() json.RawMessage
func (DefaultRPCInput) ParseBlock ¶
func (dri DefaultRPCInput) ParseBlock(inp string) (int64, error)
type GRPCConnector ¶
type GRPCConnector struct {
// contains filtered or unexported fields
}
func NewGRPCConnector ¶
func (*GRPCConnector) Close ¶
func (connector *GRPCConnector) Close()
func (*GRPCConnector) GetRpc ¶
func (connector *GRPCConnector) GetRpc(ctx context.Context, block bool) (*grpc.ClientConn, error)
func (*GRPCConnector) ReturnRpc ¶
func (connector *GRPCConnector) ReturnRpc(rpc *grpc.ClientConn)
Directories ¶
Path | Synopsis |
---|---|
package rpcclient implements bi-directional JSON-RPC 2.0 on multiple transports.
|
package rpcclient implements bi-directional JSON-RPC 2.0 on multiple transports. |
Click to show internal directories.
Click to hide internal directories.