chainlib

package

Go to main page

Versions in this module

v5

v5.2.0

Feb 12, 2025

v5.1.1

Feb 11, 2025

v5.1.0

Feb 9, 2025

Changes in this version

type ChainFetcher

+ func (cf *ChainFetcher) GetVerificationsStatus() []*pairingtypes.Verification

+ type IChainFetcher interface

+ CustomMessage func(ctx context.Context, path string, data []byte, connectionType string, ...) ([]byte, error)

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

+ FetchEndpoint func() lavasession.RPCProviderEndpoint

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

+ GetVerificationsStatus func() []*pairingtypes.Verification

+ Validate func(ctx context.Context) error

type MockChainFetcherIf

+ func (m *MockChainFetcherIf) GetVerificationsStatus() []*pairingtypes.Verification

type MockChainFetcherIfMockRecorder

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

v5.0.0

Feb 2, 2025

Changes in this version

+ const ChainFetcherHeaderName

+ const ContextUserValueKeyDappID

+ const GRPCStatusCodeOnFailedMessages

+ const INTERNAL_ADDRESS

+ const RPCProviderNodeAddressHash

+ const RPCProviderNodeExtension

+ const RetryListeningInterval

+ const RpcProviderLoadRateHeader

+ const RpcProviderUniqueIdHeader

+ const SEP

+ const SubscriptionTimeoutDuration

+ const TendermintStatusQuery

+ const WebSocketExtension

+ const WebSocketOpenConnectionsLimitHeader

+ const WebSocketRateLimitHeader

+ var AllowMissingApisByDefault = true

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

+ var IgnoreWsEnforcementForTestCommands = false

+ var InvalidResponses = []string

+ var MaxIdleTimeInSeconds = int64(20 * 60)

+ var MaximumNumberOfParallelWebsocketConnectionsPerIp int64 = 0

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

+ var TrailersToAddToHeaderResponse = []string

+ var WebSocketBanDuration = time.Duration(0)

+ var WebSocketRateLimit = -1

+ func CompareRequestedBlockInBatch(currentLatestRequestedBlock, currentEarliestRequestedBlock, parsedBlock 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 GetParseDirective(api *types.Api, apiCollection *types.ApiCollection) *types.ParseDirective

+ 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 IsFunctionTagOfType(chainMessage ChainMessageForSend, functionTag types.FUNCTION_TAG) bool

+ func IsHangingApi(chainMessage ChainMessageForSend) bool

+ func IsUrlWebSocket(urlToParse string) (bool, error)

+ func ListenWithRetry(app *fiber.App, address string, chosenAddrCh *common.SafeChannelSender[string])

+ func ShouldSendToAllProviders(chainMessage ChainMessage) bool

+ func TryRecoverNodeErrorFromClientError(nodeErr error) *rpcclient.JsonrpcMessage

+ func ValidateNilResponse(responseString string) error

+ type ApiContainer struct

+ type ApiKey struct

+ ConnectionType string

+ InternalPath string

+ Name string

+ type BaseChainParser struct

+ func (apip *BaseChainParser) ExtractDataFromRequest(request *http.Request) (url string, data string, connectionType string, ...)

+ func (apip *BaseChainParser) SetResponseFromRelayResult(relayResult *common.RelayResult) (*http.Response, error)

+ 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]InternalPath, ...)

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

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

+ func (bcp *BaseChainParser) GetAllInternalPaths() []string

+ func (bcp *BaseChainParser) GetParsingByTag(tag spectypes.FUNCTION_TAG) (parsing *spectypes.ParseDirective, apiCollection *spectypes.ApiCollection, ...)

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

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

+ func (bcp *BaseChainParser) IsInternalPathEnabled(internalPath string, apiInterface string, addon string) bool

+ func (bcp *BaseChainParser) IsTagInCollection(tag spectypes.FUNCTION_TAG, collectionKey CollectionKey) bool

+ 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 BaseProtocolMessage struct

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

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

+ func (bpm *BaseProtocolMessage) GetUserData() common.UserData

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

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

+ func (bpm *BaseProtocolMessage) UpdateEarliestAndValidateExtensionRules(extensionParser *extensionslib.ExtensionParser, ...) bool

+ type ChainFetcher struct

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

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

+ func (cf *ChainFetcher) CustomMessage(ctx context.Context, path string, data []byte, connectionType string, ...) ([]byte, error)

+ 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

+ CustomMessage func(ctx context.Context, path string, data []byte, connectionType string, ...) ([]byte, error)

+ 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

+ GetListeningAddress func() string

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

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

+ func NewEmptyChainListener() ChainListener

+ 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)

+ GetRequestedBlocksHashes func() []string

+ GetUsedDefaultValue func() bool

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

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

+ SetExtension func(extension *spectypes.Extension)

+ SetForceCacheRefresh func(force bool) bool

+ SubscriptionIdExtractor func(reply *rpcclient.JsonrpcMessage) string

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

+ UpdateEarliestInMessage func(incomingEarliest int64) bool

+ 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

+ GetParseDirective func() *spectypes.ParseDirective

+ 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

+ ExtractDataFromRequest func(*http.Request) (url string, data string, connectionType string, ...)

+ GetAllInternalPaths func() []string

+ GetParsingByTag func(tag spectypes.FUNCTION_TAG) (parsing *spectypes.ParseDirective, apiCollection *spectypes.ApiCollection, ...)

+ GetUniqueName func() string

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

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

+ IsInternalPathEnabled func(internalPath string, apiInterface string, addon string) bool

+ IsTagInCollection func(tag spectypes.FUNCTION_TAG, collectionKey CollectionKey) bool

+ 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

+ SetResponseFromRelayResult func(*common.RelayResult) (*http.Response, 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(internalPath string, extensions []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 ConsumerWSSubscriptionManager struct

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

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

+ func (cwsm *ConsumerWSSubscriptionManager) StartSubscription(webSocketCtx context.Context, protocolMessage ProtocolMessage, dappID string, ...) (firstReply *pairingtypes.RelayReply, ...)

+ func (cwsm *ConsumerWSSubscriptionManager) Unsubscribe(webSocketCtx context.Context, protocolMessage ProtocolMessage, ...) 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 CraftData struct

+ ConnectionType string

+ Data []byte

+ InternalPath string

+ 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 EmptyChainListener struct

+ func (*EmptyChainListener) GetListeningAddress() string

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

+ 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) GetListeningAddress() string

+ 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 InternalPath struct

+ Addon string

+ ApiInterface string

+ ConnectionType string

+ Enabled bool

+ Path string

+ 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) GetListeningAddress() string

+ 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) CustomMessage(ctx context.Context, path string, data []byte, connectionType string, ...) ([]byte, error)

+ 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) CustomMessage(ctx context.Context, path string, data []byte, connectionType string, ...) ([]byte, error)

+ 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) CustomMessage(ctx, path, data, connectionType, apiName any) *gomock.Call

+ 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 MockChainListener struct

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

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

+ func (m *MockChainListener) GetListeningAddress() string

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

+ type MockChainListenerMockRecorder struct

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

+ func (mr *MockChainListenerMockRecorder) Serve(ctx, cmdFlags interface{}) *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) GetRawRequestHash() ([]byte, error)

+ func (m *MockChainMessage) GetRequestedBlocksHashes() []string

+ func (m *MockChainMessage) GetUsedDefaultValue() bool

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

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

+ func (m *MockChainMessage) SetExtension(extension *types0.Extension)

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

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

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

+ func (m *MockChainMessage) UpdateEarliestInMessage(incomingEarliest int64) bool

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

+ type MockChainMessageForSend struct

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

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

+ 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) CheckResponseError(data, httpStatusCode interface{}) *gomock.Call

+ 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 ...interface{}) *gomock.Call

+ type MockChainMessageMockRecorder struct

+ func (mr *MockChainMessageMockRecorder) AppendHeader(metadata interface{}) *gomock.Call

+ func (mr *MockChainMessageMockRecorder) CheckResponseError(data, httpStatusCode interface{}) *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) GetRawRequestHash() *gomock.Call

+ func (mr *MockChainMessageMockRecorder) OverrideExtensions(extensionNames, extensionParser interface{}) *gomock.Call

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

+ func (mr *MockChainMessageMockRecorder) SetForceCacheRefresh(force interface{}) *gomock.Call

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

+ func (mr *MockChainMessageMockRecorder) TimeoutOverride(arg0 ...interface{}) *gomock.Call

+ func (mr *MockChainMessageMockRecorder) UpdateLatestBlockInMessage(latestBlock, modifyContent interface{}) *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 interface{}) *gomock.Call

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

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

+ func (mr *MockChainParserMockRecorder) GetParsingByTag(tag interface{}) *gomock.Call

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

+ func (mr *MockChainParserMockRecorder) GetVerifications(supported interface{}) *gomock.Call

+ func (mr *MockChainParserMockRecorder) HandleHeaders(metadata, apiCollection, headersDirection interface{}) *gomock.Call

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

+ func (mr *MockChainParserMockRecorder) SeparateAddonsExtensions(supported interface{}) *gomock.Call

+ func (mr *MockChainParserMockRecorder) SetPolicy(policy, chainId, apiInterface interface{}) *gomock.Call

+ func (mr *MockChainParserMockRecorder) SetSpec(spec interface{}) *gomock.Call

+ func (mr *MockChainParserMockRecorder) UpdateBlockTime(newBlockTime interface{}) *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 interface{}, chainMessage ChainMessageForSend) (*RelayReplyWrapper, string, *rpcclient.ClientSubscription, error)

+ type MockChainProxyMockRecorder struct

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

+ func (mr *MockChainProxyMockRecorder) SendNodeMsg(ctx, ch, chainMessage interface{}) *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 interface{}, chainMessage ChainMessageForSend, ...) (*RelayReplyWrapper, string, *rpcclient.ClientSubscription, common.NodeUrl, ...)

+ type MockChainRouterMockRecorder struct

+ func (mr *MockChainRouterMockRecorder) ExtensionsSupported(arg0 interface{}) *gomock.Call

+ func (mr *MockChainRouterMockRecorder) SendNodeMsg(ctx, ch, chainMessage, extensions interface{}) *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(userData common.UserData) string

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

+ func (m *MockRelaySender) ParseRelay(ctx context.Context, url, req, connectionType, dappID, consumerIp string, ...) (ProtocolMessage, error)

+ func (m *MockRelaySender) SendParsedRelay(ctx context.Context, analytics *metrics.RelayMetrics, ...) (*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 interface{}) *gomock.Call

+ func (mr *MockRelaySenderMockRecorder) CreateDappKey(userData interface{}) *gomock.Call

+ func (mr *MockRelaySenderMockRecorder) ParseRelay(ctx, url, req, connectionType, dappID, consumerIp, metadata interface{}) *gomock.Call

+ func (mr *MockRelaySenderMockRecorder) SendParsedRelay(ctx, analytics, protocolMessage interface{}) *gomock.Call

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

+ func (mr *MockRelaySenderMockRecorder) SetConsistencySeenBlock(blockSeen, key interface{}) *gomock.Call

+ type MockWebsocketConnection struct

+ func NewMockWebsocketConnection(ctrl *gomock.Controller) *MockWebsocketConnection

+ func (m *MockWebsocketConnection) EXPECT() *MockWebsocketConnectionMockRecorder

+ func (m *MockWebsocketConnection) Locals(key string) interface{}

+ func (m *MockWebsocketConnection) RemoteAddr() net.Addr

+ func (m *MockWebsocketConnection) WriteMessage(messageType int, data []byte) error

+ type MockWebsocketConnectionMockRecorder struct

+ func (mr *MockWebsocketConnectionMockRecorder) Locals(key interface{}) *gomock.Call

+ func (mr *MockWebsocketConnectionMockRecorder) RemoteAddr() *gomock.Call

+ func (mr *MockWebsocketConnectionMockRecorder) WriteMessage(messageType, data interface{}) *gomock.Call

+ type PolicyInf interface

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

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

+ type ProtocolMessage interface

+ GetBlockedProviders func() []string

+ GetDirectiveHeaders func() map[string]string

+ GetUserData func() common.UserData

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

+ RelayPrivateData func() *pairingtypes.RelayPrivateData

+ UpdateEarliestAndValidateExtensionRules func(extensionParser *extensionslib.ExtensionParser, ...) bool

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

+ 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 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

+ CancelSubscriptionContext func(subscriptionKey string)

+ CreateDappKey func(userData common.UserData) string

+ ParseRelay func(ctx context.Context, url string, req string, connectionType string, ...) (ProtocolMessage, error)

+ SendParsedRelay func(ctx context.Context, analytics *metrics.RelayMetrics, ...) (relayResult *common.RelayResult, errRet error)

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

+ SetConsistencySeenBlock func(blockSeen int64, key string)

+ type RestChainListener struct

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

+ func (apil *RestChainListener) GetListeningAddress() string

+ 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) ExtractDataFromRequest(request *http.Request) (url string, data string, connectionType string, ...)

+ 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) GetListeningAddress() string

+ 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 UserData struct

+ ConsumerIp string

+ DappId string

+ type VerificationContainer struct

+ ConnectionType string

+ InternalPath 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

+ type WebsocketConnection interface

+ Locals func(key string) interface{}

+ RemoteAddr func() net.Addr

+ WriteMessage func(messageType int, data []byte) error

+ type WebsocketConnectionLimiter struct

+ func (wcl *WebsocketConnectionLimiter) CanOpenConnection(websocketConn WebsocketConnection) (bool, func())

+ func (wcl *WebsocketConnectionLimiter) HandleFiberRateLimitFlags(c *fiber.Ctx)

Other modules containing this package

github.com/lavanet/lava

github.com/lavanet/lava/v2

github.com/lavanet/lava/v3

github.com/lavanet/lava/v4

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