chainlib

package

Go to main page

Versions in this module

v2

v2.5.3

Aug 26, 2024

Changes in this version

+ type BaseProtocolMessage struct

+ func (bpm *BaseProtocolMessage) GetBlockedProviders() []string

+ func (bpm *BaseProtocolMessage) GetDirectiveHeaders() map[string]string

+ func (bpm *BaseProtocolMessage) HashCacheRequest(chainId string) ([]byte, func([]byte) []byte, error)

+ func (bpm *BaseProtocolMessage) RelayPrivateData() *pairingtypes.RelayPrivateData

+ type MethodRoute struct

type MockChainListener

+ func (m *MockChainListener) GetListeningAddress() string

type MockChainListenerMockRecorder

+ func (mr *MockChainListenerMockRecorder) GetListeningAddress() *gomock.Call

type MockChainMessage

+ func (m *MockChainMessage) GetRawRequestHash() ([]byte, error)

+ func (m *MockChainMessage) SubscriptionIdExtractor(reply *rpcclient.JsonrpcMessage) string

type MockChainMessageForSend

+ func (m *MockChainMessageForSend) CheckResponseError(data []byte, httpStatusCode int) (bool, string)

type MockChainMessageForSendMockRecorder

+ func (mr *MockChainMessageForSendMockRecorder) CheckResponseError(data, httpStatusCode interface{}) *gomock.Call

type MockChainMessageMockRecorder

+ func (mr *MockChainMessageMockRecorder) GetRawRequestHash() *gomock.Call

+ func (mr *MockChainMessageMockRecorder) SubscriptionIdExtractor(reply interface{}) *gomock.Call

+ type ProtocolMessage interface

+ GetBlockedProviders func() []string

+ GetDirectiveHeaders func() map[string]string

+ HashCacheRequest func(chainId string) ([]byte, func([]byte) []byte, error)

+ RelayPrivateData func() *pairingtypes.RelayPrivateData

+ func NewProtocolMessage(chainMessage ChainMessage, directiveHeaders map[string]string, ...) ProtocolMessage

v2.5.2

Aug 19, 2024

v2.5.1

Aug 18, 2024

v2.5.0

Aug 18, 2024

v2.4.0

Aug 14, 2024

Changes in this version

+ const RpcProviderUniqueIdHeader

+ const SubscriptionTimeoutDuration

+ const WebSocketExtension

+ var FailedSendingSubscriptionToClients = sdkerrors.New("failed Sending Subscription To Clients", 1015, ...)

+ var IgnoreSubscriptionNotConfiguredError = true

+ var IgnoreSubscriptionNotConfiguredErrorFlag = "ignore-subscription-not-configured-error"

+ var NoActiveSubscriptionFound = sdkerrors.New("failed finding an active subscription on provider side", 1016, ...)

+ func GetParseDirective(api *types.Api, apiCollection *types.ApiCollection) *types.ParseDirective

+ func IsFunctionTagOfType(chainMessage ChainMessageForSend, functionTag types.FUNCTION_TAG) bool

type ChainListener

+ GetListeningAddress func() string

type ChainMessage

+ SubscriptionIdExtractor func(reply *rpcclient.JsonrpcMessage) string

type ChainMessageForSend

+ GetParseDirective func() *spectypes.ParseDirective

+ type ConsumerWSSubscriptionManager struct

+ func NewConsumerWSSubscriptionManager(consumerSessionManager *lavasession.ConsumerSessionManager, ...) *ConsumerWSSubscriptionManager

+ func (cwsm *ConsumerWSSubscriptionManager) CreateWebSocketConnectionUniqueKey(dappID, consumerIp, webSocketConnectionUniqueId string) string

+ func (cwsm *ConsumerWSSubscriptionManager) StartSubscription(webSocketCtx context.Context, chainMessage ChainMessage, ...) (firstReply *pairingtypes.RelayReply, ...)

+ func (cwsm *ConsumerWSSubscriptionManager) Unsubscribe(webSocketCtx context.Context, chainMessage ChainMessage, ...) error

+ func (cwsm *ConsumerWSSubscriptionManager) UnsubscribeAll(webSocketCtx context.Context, dappID, consumerIp string, ...) error

+ type ConsumerWebsocketManager struct

+ WebsocketConnectionUID string

+ func NewConsumerWebsocketManager(options ConsumerWebsocketManagerOptions) *ConsumerWebsocketManager

+ func (cwm *ConsumerWebsocketManager) GetWebSocketConnectionUniqueId(dappId, userIp string) string

+ func (cwm *ConsumerWebsocketManager) ListenToMessages()

+ type ConsumerWebsocketManagerOptions struct

+ ApiInterface string

+ ChainID string

+ CmdFlags common.ConsumerCmdFlags

+ ConnectionType string

+ ConsumerWsSubscriptionManager *ConsumerWSSubscriptionManager

+ RefererData *RefererData

+ RefererMatchString string

+ RelayMsgLogMaxChars int

+ RelaySender RelaySender

+ RpcConsumerLogs *metrics.RPCConsumerLogs

+ WebsocketConn *websocket.Conn

+ WebsocketConnectionUID string

type GrpcChainListener

+ func (apil *GrpcChainListener) GetListeningAddress() string

type JsonRPCChainListener

+ func (apil *JsonRPCChainListener) GetListeningAddress() string

+ type MockChainListener struct

+ func NewMockChainListener(ctrl *gomock.Controller) *MockChainListener

+ func (m *MockChainListener) EXPECT() *MockChainListenerMockRecorder

+ func (m *MockChainListener) Serve(ctx context.Context, cmdFlags common.ConsumerCmdFlags)

+ type MockChainListenerMockRecorder struct

+ func (mr *MockChainListenerMockRecorder) Serve(ctx, cmdFlags any) *gomock.Call

+ type MockChainMessage struct

+ func NewMockChainMessage(ctrl *gomock.Controller) *MockChainMessage

+ func (m *MockChainMessage) AppendHeader(metadata []types.Metadata)

+ func (m *MockChainMessage) CheckResponseError(data []byte, httpStatusCode int) (bool, string)

+ func (m *MockChainMessage) DisableErrorHandling()

+ func (m *MockChainMessage) EXPECT() *MockChainMessageMockRecorder

+ func (m *MockChainMessage) GetApi() *types0.Api

+ func (m *MockChainMessage) GetApiCollection() *types0.ApiCollection

+ func (m *MockChainMessage) GetExtensions() []*types0.Extension

+ func (m *MockChainMessage) GetForceCacheRefresh() bool

+ func (m *MockChainMessage) GetParseDirective() *types0.ParseDirective

+ func (m *MockChainMessage) GetRPCMessage() rpcInterfaceMessages.GenericMessage

+ func (m *MockChainMessage) OverrideExtensions(extensionNames []string, extensionParser *extensionslib.ExtensionParser)

+ func (m *MockChainMessage) RequestedBlock() (int64, int64)

+ func (m *MockChainMessage) SetForceCacheRefresh(force bool) bool

+ func (m *MockChainMessage) TimeoutOverride(arg0 ...time.Duration) time.Duration

+ func (m *MockChainMessage) UpdateLatestBlockInMessage(latestBlock int64, modifyContent bool) bool

+ type MockChainMessageForSend struct

+ func NewMockChainMessageForSend(ctrl *gomock.Controller) *MockChainMessageForSend

+ func (m *MockChainMessageForSend) EXPECT() *MockChainMessageForSendMockRecorder

+ func (m *MockChainMessageForSend) GetApi() *types0.Api

+ func (m *MockChainMessageForSend) GetApiCollection() *types0.ApiCollection

+ func (m *MockChainMessageForSend) GetParseDirective() *types0.ParseDirective

+ func (m *MockChainMessageForSend) GetRPCMessage() rpcInterfaceMessages.GenericMessage

+ func (m *MockChainMessageForSend) TimeoutOverride(arg0 ...time.Duration) time.Duration

+ type MockChainMessageForSendMockRecorder struct

+ func (mr *MockChainMessageForSendMockRecorder) GetApi() *gomock.Call

+ func (mr *MockChainMessageForSendMockRecorder) GetApiCollection() *gomock.Call

+ func (mr *MockChainMessageForSendMockRecorder) GetParseDirective() *gomock.Call

+ func (mr *MockChainMessageForSendMockRecorder) GetRPCMessage() *gomock.Call

+ func (mr *MockChainMessageForSendMockRecorder) TimeoutOverride(arg0 ...any) *gomock.Call

+ type MockChainMessageMockRecorder struct

+ func (mr *MockChainMessageMockRecorder) AppendHeader(metadata any) *gomock.Call

+ func (mr *MockChainMessageMockRecorder) CheckResponseError(data, httpStatusCode any) *gomock.Call

+ func (mr *MockChainMessageMockRecorder) DisableErrorHandling() *gomock.Call

+ func (mr *MockChainMessageMockRecorder) GetApi() *gomock.Call

+ func (mr *MockChainMessageMockRecorder) GetApiCollection() *gomock.Call

+ func (mr *MockChainMessageMockRecorder) GetExtensions() *gomock.Call

+ func (mr *MockChainMessageMockRecorder) GetForceCacheRefresh() *gomock.Call

+ func (mr *MockChainMessageMockRecorder) GetParseDirective() *gomock.Call

+ func (mr *MockChainMessageMockRecorder) GetRPCMessage() *gomock.Call

+ func (mr *MockChainMessageMockRecorder) OverrideExtensions(extensionNames, extensionParser any) *gomock.Call

+ func (mr *MockChainMessageMockRecorder) RequestedBlock() *gomock.Call

+ func (mr *MockChainMessageMockRecorder) SetForceCacheRefresh(force any) *gomock.Call

+ func (mr *MockChainMessageMockRecorder) TimeoutOverride(arg0 ...any) *gomock.Call

+ func (mr *MockChainMessageMockRecorder) UpdateLatestBlockInMessage(latestBlock, modifyContent any) *gomock.Call

+ type MockChainParser struct

+ func NewMockChainParser(ctrl *gomock.Controller) *MockChainParser

+ func (m *MockChainParser) Activate()

+ func (m *MockChainParser) Active() bool

+ func (m *MockChainParser) ChainBlockStats() (int64, time.Duration, uint32, uint32)

+ func (m *MockChainParser) CraftMessage(parser *types0.ParseDirective, connectionType string, craftData *CraftData, ...) (ChainMessageForSend, error)

+ func (m *MockChainParser) DataReliabilityParams() (bool, uint32)

+ func (m *MockChainParser) EXPECT() *MockChainParserMockRecorder

+ func (m *MockChainParser) ExtensionsParser() *extensionslib.ExtensionParser

+ func (m *MockChainParser) GetParsingByTag(tag types0.FUNCTION_TAG) (*types0.ParseDirective, *types0.ApiCollection, bool)

+ func (m *MockChainParser) GetUniqueName() string

+ func (m *MockChainParser) GetVerifications(supported []string) ([]VerificationContainer, error)

+ func (m *MockChainParser) HandleHeaders(metadata []types.Metadata, apiCollection *types0.ApiCollection, ...) ([]types.Metadata, string, []types.Metadata)

+ func (m *MockChainParser) ParseMsg(url string, data []byte, connectionType string, metadata []types.Metadata, ...) (ChainMessage, error)

+ func (m *MockChainParser) SeparateAddonsExtensions(supported []string) ([]string, []string, error)

+ func (m *MockChainParser) SetPolicy(policy PolicyInf, chainId, apiInterface string) error

+ func (m *MockChainParser) SetSpec(spec types0.Spec)

+ func (m *MockChainParser) UpdateBlockTime(newBlockTime time.Duration)

+ type MockChainParserMockRecorder struct

+ func (mr *MockChainParserMockRecorder) Activate() *gomock.Call

+ func (mr *MockChainParserMockRecorder) Active() *gomock.Call

+ func (mr *MockChainParserMockRecorder) ChainBlockStats() *gomock.Call

+ func (mr *MockChainParserMockRecorder) CraftMessage(parser, connectionType, craftData, metadata any) *gomock.Call

+ func (mr *MockChainParserMockRecorder) DataReliabilityParams() *gomock.Call

+ func (mr *MockChainParserMockRecorder) ExtensionsParser() *gomock.Call

+ func (mr *MockChainParserMockRecorder) GetParsingByTag(tag any) *gomock.Call

+ func (mr *MockChainParserMockRecorder) GetUniqueName() *gomock.Call

+ func (mr *MockChainParserMockRecorder) GetVerifications(supported any) *gomock.Call

+ func (mr *MockChainParserMockRecorder) HandleHeaders(metadata, apiCollection, headersDirection any) *gomock.Call

+ func (mr *MockChainParserMockRecorder) ParseMsg(url, data, connectionType, metadata, extensionInfo any) *gomock.Call

+ func (mr *MockChainParserMockRecorder) SeparateAddonsExtensions(supported any) *gomock.Call

+ func (mr *MockChainParserMockRecorder) SetPolicy(policy, chainId, apiInterface any) *gomock.Call

+ func (mr *MockChainParserMockRecorder) SetSpec(spec any) *gomock.Call

+ func (mr *MockChainParserMockRecorder) UpdateBlockTime(newBlockTime any) *gomock.Call

+ type MockChainProxy struct

+ func NewMockChainProxy(ctrl *gomock.Controller) *MockChainProxy

+ func (m *MockChainProxy) EXPECT() *MockChainProxyMockRecorder

+ func (m *MockChainProxy) GetChainProxyInformation() (common.NodeUrl, string)

+ func (m *MockChainProxy) SendNodeMsg(ctx context.Context, ch chan any, chainMessage ChainMessageForSend) (*RelayReplyWrapper, string, *rpcclient.ClientSubscription, error)

+ type MockChainProxyMockRecorder struct

+ func (mr *MockChainProxyMockRecorder) GetChainProxyInformation() *gomock.Call

+ func (mr *MockChainProxyMockRecorder) SendNodeMsg(ctx, ch, chainMessage any) *gomock.Call

+ type MockChainRouter struct

+ func NewMockChainRouter(ctrl *gomock.Controller) *MockChainRouter

+ func (m *MockChainRouter) EXPECT() *MockChainRouterMockRecorder

+ func (m *MockChainRouter) ExtensionsSupported(arg0 []string) bool

+ func (m *MockChainRouter) SendNodeMsg(ctx context.Context, ch chan any, chainMessage ChainMessageForSend, ...) (*RelayReplyWrapper, string, *rpcclient.ClientSubscription, common.NodeUrl, ...)

+ type MockChainRouterMockRecorder struct

+ func (mr *MockChainRouterMockRecorder) ExtensionsSupported(arg0 any) *gomock.Call

+ func (mr *MockChainRouterMockRecorder) SendNodeMsg(ctx, ch, chainMessage, extensions any) *gomock.Call

+ type MockHealthReporter struct

+ func NewMockHealthReporter(ctrl *gomock.Controller) *MockHealthReporter

+ func (m *MockHealthReporter) EXPECT() *MockHealthReporterMockRecorder

+ func (m *MockHealthReporter) IsHealthy() bool

+ type MockHealthReporterMockRecorder struct

+ func (mr *MockHealthReporterMockRecorder) IsHealthy() *gomock.Call

+ type MockRelaySender struct

+ func NewMockRelaySender(ctrl *gomock.Controller) *MockRelaySender

+ func (m *MockRelaySender) CancelSubscriptionContext(subscriptionKey string)

+ func (m *MockRelaySender) CreateDappKey(dappID, consumerIp string) string

+ func (m *MockRelaySender) EXPECT() *MockRelaySenderMockRecorder

+ func (m *MockRelaySender) ParseRelay(ctx context.Context, url, req, connectionType, dappID, consumerIp string, ...) (ChainMessage, map[string]string, *types.RelayPrivateData, error)

+ func (m *MockRelaySender) SendParsedRelay(ctx context.Context, dappID, consumerIp string, ...) (*common.RelayResult, error)

+ func (m *MockRelaySender) SendRelay(ctx context.Context, url, req, connectionType, dappID, consumerIp string, ...) (*common.RelayResult, error)

+ func (m *MockRelaySender) SetConsistencySeenBlock(blockSeen int64, key string)

+ type MockRelaySenderMockRecorder struct

+ func (mr *MockRelaySenderMockRecorder) CancelSubscriptionContext(subscriptionKey any) *gomock.Call

+ func (mr *MockRelaySenderMockRecorder) CreateDappKey(dappID, consumerIp any) *gomock.Call

+ func (mr *MockRelaySenderMockRecorder) ParseRelay(ctx, url, req, connectionType, dappID, consumerIp, analytics, metadata any) *gomock.Call

+ func (mr *MockRelaySenderMockRecorder) SendParsedRelay(ctx, dappID, consumerIp, analytics, chainMessage, directiveHeaders, ... any) *gomock.Call

+ func (mr *MockRelaySenderMockRecorder) SendRelay(...) *gomock.Call

+ func (mr *MockRelaySenderMockRecorder) SetConsistencySeenBlock(blockSeen, key any) *gomock.Call

+ type ProviderNodeSubscriptionManager struct

+ func NewProviderNodeSubscriptionManager(chainRouter ChainRouter, chainParser ChainParser, ...) *ProviderNodeSubscriptionManager

+ func (pnsm *ProviderNodeSubscriptionManager) AddConsumer(ctx context.Context, request *pairingtypes.RelayRequest, ...) (subscriptionId string, err error)

+ func (pnsm *ProviderNodeSubscriptionManager) RemoveConsumer(ctx context.Context, chainMessage ChainMessageForSend, ...) error

type RelaySender

+ CancelSubscriptionContext func(subscriptionKey string)

+ CreateDappKey func(dappID, consumerIp string) string

+ ParseRelay func(ctx context.Context, url string, req string, connectionType string, ...) (ChainMessage, map[string]string, *pairingtypes.RelayPrivateData, error)

+ SendParsedRelay func(ctx context.Context, dappID string, consumerIp string, ...) (relayResult *common.RelayResult, errRet error)

+ SetConsistencySeenBlock func(blockSeen int64, key string)

type RestChainListener

+ func (apil *RestChainListener) GetListeningAddress() string

type TendermintRpcChainListener

+ func (apil *TendermintRpcChainListener) GetListeningAddress() string

v2.2.7

Aug 6, 2024

v2.2.6

Aug 4, 2024

Changes in this version

+ const ChainFetcherHeaderName

+ const ContextUserValueKeyDappID

+ const GRPCStatusCodeOnFailedMessages

+ const RPCProviderNodeAddressHash

+ const RPCProviderNodeExtension

+ const RetryListeningInterval

+ const SEP

+ const TendermintStatusQuery

+ var InvalidResponses = []string

+ func CompareRequestedBlockInBatch(firstRequestedBlock int64, second int64) (latestCombinedBlock int64, earliestCombinedBlock int64)

+ func CreateChainLibMocks(ctx context.Context, specIndex string, apiInterface string, ...) (cpar ChainParser, crout ChainRouter, cfetc chaintracker.ChainFetcher, ...)

+ func FormatResponseForParsing(reply *pairingtypes.RelayReply, chainMessage ChainMessageForSend) (parsable parser.RPCInput, err error)

+ func GetAddon(chainMessage ChainMessageForSend) string

+ func GetComputeUnits(chainMessage ChainMessageForSend) uint64

+ func GetListenerWithRetryGrpc(protocol, addr string) net.Listener

+ func GetRelayTimeout(chainMessage ChainMessageForSend, averageBlockTime time.Duration) time.Duration

+ func GetStateful(chainMessage ChainMessageForSend) uint32

+ func GetTimeoutInfo(chainMessage ChainMessageForSend) common.TimeoutInfo

+ func HashCacheRequest(relayData *pairingtypes.RelayPrivateData, chainId string) ([]byte, func([]byte) []byte, error)

+ func IsHangingApi(chainMessage ChainMessageForSend) bool

+ func IsSubscription(chainMessage ChainMessageForSend) bool

+ func ListenWithRetry(app *fiber.App, address string)

+ func ShouldSendToAllProviders(chainMessage ChainMessage) bool

+ func ValidateNilResponse(responseString string) error

+ type ApiContainer struct

+ type ApiKey struct

+ ConnectionType string

+ InternalPath string

+ Name string

+ type BaseChainParser struct

+ func (bcp *BaseChainParser) Activate()

+ func (bcp *BaseChainParser) Active() bool

+ func (bcp *BaseChainParser) BuildMapFromPolicyQuery(policy PolicyInf, chainId string, apiInterface string) (map[string]struct{}, error)

+ func (bcp *BaseChainParser) Construct(spec spectypes.Spec, internalPaths map[string]struct{}, ...)

+ func (bcp *BaseChainParser) ExtensionParsing(addon string, parsedMessageArg *baseChainMessageContainer, ...)

+ func (bcp *BaseChainParser) ExtensionsParser() *extensionslib.ExtensionParser

+ func (bcp *BaseChainParser) GetParsingByTag(tag spectypes.FUNCTION_TAG) (parsing *spectypes.ParseDirective, collectionData *spectypes.CollectionData, ...)

+ func (bcp *BaseChainParser) GetVerifications(supported []string) (retVerifications []VerificationContainer, err error)

+ func (bcp *BaseChainParser) HandleHeaders(metadata []pairingtypes.Metadata, apiCollection *spectypes.ApiCollection, ...) (filteredHeaders []pairingtypes.Metadata, overwriteRequestedBlock string, ...)

+ func (bcp *BaseChainParser) SeparateAddonsExtensions(supported []string) (addons, extensions []string, err error)

+ func (bcp *BaseChainParser) SetPolicy(policy PolicyInf, chainId string, apiInterface string) error

+ func (bcp *BaseChainParser) SetPolicyFromAddonAndExtensionMap(policyInformation map[string]struct{})

+ func (bcp *BaseChainParser) UpdateBlockTime(newBlockTime time.Duration)

+ func (bcp *BaseChainParser) Validate(nodeMessage *baseChainMessageContainer) error

+ type BaseChainProxy struct

+ ChainID string

+ HashedNodeUrl string

+ NodeUrl common.NodeUrl

+ func (bcp *BaseChainProxy) CapTimeoutForSend(ctx context.Context, chainMessage ChainMessageForSend) (context.Context, context.CancelFunc)

+ func (bcp *BaseChainProxy) GetChainProxyInformation() (common.NodeUrl, string)

+ type ChainFetcher struct

+ func NewChainFetcher(ctx context.Context, options *ChainFetcherOptions) *ChainFetcher

+ func (cf *ChainFetcher) ChainFetcherMetadata() []pairingtypes.Metadata

+ func (cf *ChainFetcher) FetchBlockHashByNum(ctx context.Context, blockNum int64) (string, error)

+ func (cf *ChainFetcher) FetchEndpoint() lavasession.RPCProviderEndpoint

+ func (cf *ChainFetcher) FetchLatestBlockNum(ctx context.Context) (int64, error)

+ func (cf *ChainFetcher) Validate(ctx context.Context) error

+ func (cf *ChainFetcher) Verify(ctx context.Context, verification VerificationContainer, latestBlock uint64) error

+ type ChainFetcherIf interface

+ FetchBlockHashByNum func(ctx context.Context, blockNum int64) (string, error)

+ FetchEndpoint func() lavasession.RPCProviderEndpoint

+ FetchLatestBlockNum func(ctx context.Context) (int64, error)

+ Validate func(ctx context.Context) error

+ type ChainFetcherOptions struct

+ Cache *performance.Cache

+ ChainParser ChainParser

+ ChainRouter ChainRouter

+ Endpoint *lavasession.RPCProviderEndpoint

+ type ChainListener interface

+ Serve func(ctx context.Context, cmdFlags common.ConsumerCmdFlags)

+ func NewChainListener(ctx context.Context, listenEndpoint *lavasession.RPCEndpoint, ...) (ChainListener, error)

+ type ChainMessage interface

+ AppendHeader func(metadata []pairingtypes.Metadata)

+ CheckResponseError func(data []byte, httpStatusCode int) (hasError bool, errorMessage string)

+ DisableErrorHandling func()

+ GetExtensions func() []*spectypes.Extension

+ GetForceCacheRefresh func() bool

+ GetRawRequestHash func() ([]byte, error)

+ OverrideExtensions func(extensionNames []string, extensionParser *extensionslib.ExtensionParser)

+ RequestedBlock func() (latest int64, earliest int64)

+ SetForceCacheRefresh func(force bool) bool

+ TimeoutOverride func(...time.Duration) time.Duration

+ UpdateLatestBlockInMessage func(latestBlock int64, modifyContent bool) (modified bool)

+ type ChainMessageForSend interface

+ CheckResponseError func(data []byte, httpStatusCode int) (hasError bool, errorMessage string)

+ GetApi func() *spectypes.Api

+ GetApiCollection func() *spectypes.ApiCollection

+ GetRPCMessage func() rpcInterfaceMessages.GenericMessage

+ TimeoutOverride func(...time.Duration) time.Duration

+ func CraftChainMessage(parsing *spectypes.ParseDirective, connectionType string, ...) (ChainMessageForSend, error)

+ type ChainParser interface

+ Activate func()

+ Active func() bool

+ ChainBlockStats func() (allowedBlockLagForQosSync int64, averageBlockTime time.Duration, ...)

+ CraftMessage func(parser *spectypes.ParseDirective, connectionType string, craftData *CraftData, ...) (ChainMessageForSend, error)

+ DataReliabilityParams func() (enabled bool, dataReliabilityThreshold uint32)

+ ExtensionsParser func() *extensionslib.ExtensionParser

+ GetParsingByTag func(tag spectypes.FUNCTION_TAG) (parsing *spectypes.ParseDirective, collectionData *spectypes.CollectionData, ...)

+ GetUniqueName func() string

+ GetVerifications func(supported []string) ([]VerificationContainer, error)

+ HandleHeaders func(metadata []pairingtypes.Metadata, apiCollection *spectypes.ApiCollection, ...) (filtered []pairingtypes.Metadata, overwriteReqBlock string, ...)

+ ParseMsg func(url string, data []byte, connectionType string, ...) (ChainMessage, error)

+ SeparateAddonsExtensions func(supported []string) (addons, extensions []string, err error)

+ SetPolicy func(policy PolicyInf, chainId string, apiInterface string) error

+ SetSpec func(spec spectypes.Spec)

+ UpdateBlockTime func(newBlockTime time.Duration)

+ func NewChainParser(apiInterface string) (chainParser ChainParser, err error)

+ type ChainProxy interface

+ GetChainProxyInformation func() (common.NodeUrl, string)

+ SendNodeMsg func(ctx context.Context, ch chan interface{}, chainMessage ChainMessageForSend) (relayReply *RelayReplyWrapper, subscriptionID string, ...)

+ func NewGrpcChainProxy(ctx context.Context, nConns uint, ...) (ChainProxy, error)

+ func NewJrpcChainProxy(ctx context.Context, nConns uint, ...) (ChainProxy, error)

+ func NewRestChainProxy(ctx context.Context, nConns uint, ...) (ChainProxy, error)

+ func NewtendermintRpcChainProxy(ctx context.Context, nConns uint, ...) (ChainProxy, error)

+ type ChainRouter interface

+ ExtensionsSupported func([]string) bool

+ SendNodeMsg func(ctx context.Context, ch chan interface{}, chainMessage ChainMessageForSend, ...) (relayReply *RelayReplyWrapper, subscriptionID string, ...)

+ func GetChainRouter(ctx context.Context, nConns uint, ...) (ChainRouter, error)

+ type CollectionKey struct

+ Addon string

+ ConnectionType string

+ InternalPath string

+ type CraftData struct

+ ConnectionType string

+ Data []byte

+ Path string

+ type DummyChainFetcher struct

+ func NewVerificationsOnlyChainFetcher(ctx context.Context, chainRouter ChainRouter, chainParser ChainParser, ...) *DummyChainFetcher

+ func (cf *DummyChainFetcher) FetchBlockHashByNum(ctx context.Context, blockNum int64) (string, error)

+ func (cf *DummyChainFetcher) FetchLatestBlockNum(ctx context.Context) (int64, error)

+ func (cf *DummyChainFetcher) Validate(ctx context.Context) error

+ type ErrorHandler interface

+ HandleJSONFormatError func([]byte) error

+ HandleNodeError func(context.Context, error) error

+ HandleStatusError func(int, bool) error

+ ValidateRequestAndResponseIds func(json.RawMessage, json.RawMessage) error

+ type GRPCErrorHandler struct

+ func (geh *GRPCErrorHandler) HandleJSONFormatError(replyData []byte) error

+ func (geh *GRPCErrorHandler) HandleNodeError(ctx context.Context, nodeError error) error

+ func (geh *GRPCErrorHandler) HandleStatusError(statusCode int, strict bool) error

+ func (geh *GRPCErrorHandler) ValidateRequestAndResponseIds(nodeMessageID json.RawMessage, replyMsgID json.RawMessage) error

+ type GrpcChainListener struct

+ func NewGrpcChainListener(ctx context.Context, listenEndpoint *lavasession.RPCEndpoint, ...) (chainListener *GrpcChainListener)

+ func (apil *GrpcChainListener) Serve(ctx context.Context, cmdFlags common.ConsumerCmdFlags)

+ type GrpcChainParser struct

+ func NewGrpcChainParser() (chainParser *GrpcChainParser, err error)

+ func (apip *GrpcChainParser) ChainBlockStats() (allowedBlockLagForQosSync int64, averageBlockTime time.Duration, ...)

+ func (apip *GrpcChainParser) CraftMessage(parsing *spectypes.ParseDirective, connectionType string, craftData *CraftData, ...) (ChainMessageForSend, error)

+ func (apip *GrpcChainParser) DataReliabilityParams() (enabled bool, dataReliabilityThreshold uint32)

+ func (apip *GrpcChainParser) ParseMsg(url string, data []byte, connectionType string, ...) (ChainMessage, error)

+ func (apip *GrpcChainParser) SetSpec(spec spectypes.Spec)

+ func (bcp *GrpcChainParser) GetUniqueName() string

+ type GrpcChainProxy struct

+ func (cp *GrpcChainProxy) SendNodeMsg(ctx context.Context, ch chan interface{}, chainMessage ChainMessageForSend) (relayReply *RelayReplyWrapper, subscriptionID string, ...)

+ type GrpcNodeErrorResponse struct

+ ErrorCode uint32

+ ErrorMessage string

+ type HealthReporter interface

+ IsHealthy func() bool

+ type JrpcChainProxy struct

+ func (cp *JrpcChainProxy) SendNodeMsg(ctx context.Context, ch chan interface{}, chainMessage ChainMessageForSend) (relayReply *RelayReplyWrapper, subscriptionID string, ...)

+ type JsonRPCChainListener struct

+ func NewJrpcChainListener(ctx context.Context, listenEndpoint *lavasession.RPCEndpoint, ...) (chainListener *JsonRPCChainListener)

+ func (apil *JsonRPCChainListener) Serve(ctx context.Context, cmdFlags common.ConsumerCmdFlags)

+ type JsonRPCChainParser struct

+ func NewJrpcChainParser() (chainParser *JsonRPCChainParser, err error)

+ func (apip *JsonRPCChainParser) ChainBlockStats() (allowedBlockLagForQosSync int64, averageBlockTime time.Duration, ...)

+ func (apip *JsonRPCChainParser) CraftMessage(parsing *spectypes.ParseDirective, connectionType string, craftData *CraftData, ...) (ChainMessageForSend, error)

+ func (apip *JsonRPCChainParser) DataReliabilityParams() (enabled bool, dataReliabilityThreshold uint32)

+ func (apip *JsonRPCChainParser) GetInternalPaths() map[string]struct{}

+ func (apip *JsonRPCChainParser) ParseMsg(url string, data []byte, connectionType string, ...) (ChainMessage, error)

+ func (apip *JsonRPCChainParser) SetSpec(spec spectypes.Spec)

+ func (bcp *JsonRPCChainParser) GetUniqueName() string

+ type JsonRPCErrorHandler struct

+ func (geh *JsonRPCErrorHandler) HandleJSONFormatError(replyData []byte) error

+ func (geh *JsonRPCErrorHandler) HandleStatusError(statusCode int, strict bool) error

+ func (geh *JsonRPCErrorHandler) ValidateRequestAndResponseIds(nodeMessageID json.RawMessage, replyMsgID json.RawMessage) error

+ func (jeh *JsonRPCErrorHandler) HandleNodeError(ctx context.Context, nodeError error) error

+ type LavaChainFetcher struct

+ func NewLavaChainFetcher(ctx context.Context, clientCtx client.Context) *LavaChainFetcher

+ func (lcf *LavaChainFetcher) FetchBlockHashByNum(ctx context.Context, blockNum int64) (string, error)

+ func (lcf *LavaChainFetcher) FetchChainID(ctx context.Context) (string, string, error)

+ func (lcf *LavaChainFetcher) FetchEndpoint() lavasession.RPCProviderEndpoint

+ func (lcf *LavaChainFetcher) FetchLatestBlockNum(ctx context.Context) (int64, error)

+ type MockChainFetcherIf struct

+ func NewMockChainFetcherIf(ctrl *gomock.Controller) *MockChainFetcherIf

+ func (m *MockChainFetcherIf) EXPECT() *MockChainFetcherIfMockRecorder

+ func (m *MockChainFetcherIf) FetchBlockHashByNum(ctx context.Context, blockNum int64) (string, error)

+ func (m *MockChainFetcherIf) FetchEndpoint() lavasession.RPCProviderEndpoint

+ func (m *MockChainFetcherIf) FetchLatestBlockNum(ctx context.Context) (int64, error)

+ func (m *MockChainFetcherIf) Validate(ctx context.Context) error

+ type MockChainFetcherIfMockRecorder struct

+ func (mr *MockChainFetcherIfMockRecorder) FetchBlockHashByNum(ctx, blockNum any) *gomock.Call

+ func (mr *MockChainFetcherIfMockRecorder) FetchEndpoint() *gomock.Call

+ func (mr *MockChainFetcherIfMockRecorder) FetchLatestBlockNum(ctx any) *gomock.Call

+ func (mr *MockChainFetcherIfMockRecorder) Validate(ctx any) *gomock.Call

+ type PolicyInf interface

+ GetSupportedAddons func(specID string) (addons []string, err error)

+ GetSupportedExtensions func(specID string) (extensions []epochstorage.EndpointService, err error)

+ type RefererData struct

+ Address string

+ Marker string

+ ReferrerClient *metrics.ConsumerReferrerClient

+ func (rd *RefererData) SendReferer(refererMatchString string, chainId string, msg string, userIp string, ...) error

+ type RelayReplyWrapper struct

+ RelayReply *pairingtypes.RelayReply

+ StatusCode int

+ type RelaySender interface

+ SendRelay func(ctx context.Context, url string, req string, connectionType string, ...) (*common.RelayResult, error)

+ type RestChainListener struct

+ func NewRestChainListener(ctx context.Context, listenEndpoint *lavasession.RPCEndpoint, ...) (chainListener *RestChainListener)

+ func (apil *RestChainListener) Serve(ctx context.Context, cmdFlags common.ConsumerCmdFlags)

+ type RestChainParser struct

+ func NewRestChainParser() (chainParser *RestChainParser, err error)

+ func (apip *RestChainParser) ChainBlockStats() (allowedBlockLagForQosSync int64, averageBlockTime time.Duration, ...)

+ func (apip *RestChainParser) CraftMessage(parsing *spectypes.ParseDirective, connectionType string, craftData *CraftData, ...) (ChainMessageForSend, error)

+ func (apip *RestChainParser) DataReliabilityParams() (enabled bool, dataReliabilityThreshold uint32)

+ func (apip *RestChainParser) ParseMsg(urlPath string, data []byte, connectionType string, ...) (ChainMessage, error)

+ func (apip *RestChainParser) SetSpec(spec spectypes.Spec)

+ func (bcp *RestChainParser) GetUniqueName() string

+ type RestChainProxy struct

+ func (rcp *RestChainProxy) SendNodeMsg(ctx context.Context, ch chan interface{}, chainMessage ChainMessageForSend) (relayReply *RelayReplyWrapper, subscriptionID string, ...)

+ type RestErrorHandler struct

+ func (geh *RestErrorHandler) HandleJSONFormatError(replyData []byte) error

+ func (geh *RestErrorHandler) HandleStatusError(statusCode int, strict bool) error

+ func (geh *RestErrorHandler) ValidateRequestAndResponseIds(nodeMessageID json.RawMessage, replyMsgID json.RawMessage) error

+ func (rne *RestErrorHandler) HandleNodeError(ctx context.Context, nodeError error) error

+ type TaggedContainer struct

+ ApiCollection *spectypes.ApiCollection

+ Parsing *spectypes.ParseDirective

+ type TendermintChainParser struct

+ func NewTendermintRpcChainParser() (chainParser *TendermintChainParser, err error)

+ func (apip *TendermintChainParser) ChainBlockStats() (allowedBlockLagForQosSync int64, averageBlockTime time.Duration, ...)

+ func (apip *TendermintChainParser) CraftMessage(parsing *spectypes.ParseDirective, connectionType string, craftData *CraftData, ...) (ChainMessageForSend, error)

+ func (apip *TendermintChainParser) DataReliabilityParams() (enabled bool, dataReliabilityThreshold uint32)

+ func (apip *TendermintChainParser) ParseMsg(urlPath string, data []byte, connectionType string, ...) (ChainMessage, error)

+ func (apip *TendermintChainParser) SetSpec(spec spectypes.Spec)

+ func (bcp *TendermintChainParser) GetUniqueName() string

+ type TendermintRPCErrorHandler struct

+ func (geh *TendermintRPCErrorHandler) HandleJSONFormatError(replyData []byte) error

+ func (geh *TendermintRPCErrorHandler) HandleStatusError(statusCode int, strict bool) error

+ func (geh *TendermintRPCErrorHandler) ValidateRequestAndResponseIds(nodeMessageID json.RawMessage, replyMsgID json.RawMessage) error

+ func (tendermintErrorHandler *TendermintRPCErrorHandler) HandleNodeError(ctx context.Context, nodeError error) error

+ type TendermintRpcChainListener struct

+ func NewTendermintRpcChainListener(ctx context.Context, listenEndpoint *lavasession.RPCEndpoint, ...) (chainListener *TendermintRpcChainListener)

+ func (apil *TendermintRpcChainListener) Serve(ctx context.Context, cmdFlags common.ConsumerCmdFlags)

+ type TestStruct struct

+ Consumer sigs.Account

+ Ctx context.Context

+ Keepers *keepertest.Keepers

+ Plan plantypes.Plan

+ Providers []sigs.Account

+ Servers *keepertest.Servers

+ Spec spectypes.Spec

+ Validator sigs.Account

+ func SetupForTests(t *testing.T, numOfProviders int, specID string, getToTopMostPath string) TestStruct

+ func (ts *TestStruct) BondDenom() string

+ type VerificationContainer struct

+ ConnectionType string

+ LatestDistance uint64

+ Name string

+ ParseDirective spectypes.ParseDirective

+ Severity spectypes.ParseValue_VerificationSeverity

+ Value string

+ func (vc *VerificationContainer) IsActive() bool

+ type VerificationKey struct

+ Addon string

+ Extension string

Other modules containing this package

github.com/lavanet/lava

github.com/lavanet/lava/v3

github.com/lavanet/lava/v4

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL