The highest tagged major version is
Documentation
¶
Index ¶
Constants ¶
View Source
const (
MaxRelayRetries = 3
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConsumerStateTrackerInf ¶
type ConsumerStateTrackerInf interface {
RegisterConsumerSessionManagerForPairingUpdates(ctx context.Context, consumerSessionManager *lavasession.ConsumerSessionManager)
RegisterApiParserForSpecUpdates(ctx context.Context, chainParser chainlib.ChainParser)
RegisterFinalizationConsensusForUpdates(context.Context, *lavaprotocol.FinalizationConsensus)
TxConflictDetection(ctx context.Context, finalizationConflict *conflicttypes.FinalizationConflict, responseConflict *conflicttypes.ResponseConflict, sameProviderConflict *conflicttypes.FinalizationConflict)
}
type RPCConsumer ¶
type RPCConsumer struct {
// contains filtered or unexported fields
}
func (*RPCConsumer) Start ¶
func (rpcc *RPCConsumer) Start(ctx context.Context, txFactory tx.Factory, clientCtx client.Context, rpcEndpoints []*lavasession.RPCEndpoint, requiredResponses int, vrf_sk vrf.PrivateKey) (err error)
spawns a new RPCConsumer server with all it's processes and internals ready for communications
type RPCConsumerServer ¶
type RPCConsumerServer struct {
VrfSk vrf.PrivateKey
// contains filtered or unexported fields
}
implements Relay Sender interfaced and uses an ChainListener to get it called
func (*RPCConsumerServer) SendRelay ¶
func (rpccs *RPCConsumerServer) SendRelay( ctx context.Context, url string, req string, connectionType string, dappID string, ) (relayReply *pairingtypes.RelayReply, relayServer *pairingtypes.Relayer_RelaySubscribeClient, errRet error)
func (*RPCConsumerServer) ServeRPCRequests ¶
func (rpccs *RPCConsumerServer) ServeRPCRequests(ctx context.Context, listenEndpoint *lavasession.RPCEndpoint, consumerStateTracker ConsumerStateTrackerInf, consumerSessionManager *lavasession.ConsumerSessionManager, requiredResponses int, privKey *btcec.PrivateKey, vrfSk vrf.PrivateKey, cache *performance.Cache, ) (err error)
Source Files
Click to show internal directories.
Click to hide internal directories.