rpcprovider

package

Versions in this module

v2

v2.5.3

Aug 26, 2024

Changes in this version

+ func ParseEndpointsCustomName(viper_endpoints *viper.Viper, endpointsConfigName string, geolocation uint64) (endpoints []*lavasession.RPCProviderEndpoint, err error)

type RPCProviderServer

+ StaticProvider bool

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

type RPCProviderServer

+ func (rpcps *RPCProviderServer) BuildRelayFinalizedBlockHashes(ctx context.Context, request *pairingtypes.RelayRequest, ...) (err error)

+ func (rpcps *RPCProviderServer) GetParametersForRelayDataReliability(ctx context.Context, request *pairingtypes.RelayRequest, ...) (latestBlock int64, requestedBlockHash []byte, ...)

+ func (rpcps *RPCProviderServer) SetProviderUniqueId(uniqueId string)

+ func (rpcps *RPCProviderServer) TryRelayUnsubscribe(ctx context.Context, request *pairingtypes.RelayRequest, ...) (*pairingtypes.RelayReply, error)

v2.2.7

Aug 6, 2024

v2.2.6

Aug 4, 2024

Changes in this version

+ const ChainTrackerDefaultMemory

+ const DEFAULT_ALLOWED_MISSING_CU

+ const DefaultShardID

+ const HealthCheckURLPathFlagDefault

+ const HealthCheckURLPathFlagName

+ const RPCProviderAddressHeader

+ const ShardIDFlagName

+ const SpecValidationIntervalDisabledChainsFlagName

+ const SpecValidationIntervalFlagName

+ const StickinessHeaderName

+ var DefaultRPCProviderFileName = "rpcprovider.yml"

+ var RPCProviderStickinessHeaderName = "X-Node-Sticky"

+ var RelayHealthIntervalFlagDefault = 5 * time.Minute

+ var RelaysHealthEnableFlagDefault = true

+ var SpecValidationInterval = 3 * time.Hour

+ var SpecValidationIntervalDisabledChains = 3 * time.Minute

+ var Yaml_config_properties = []string

+ func CreateRPCProviderCobraCommand() *cobra.Command

+ func CreateTestRPCProviderCobraCommand() *cobra.Command

+ func ParseEndpoints(viper_endpoints *viper.Viper, geolocation uint64) (endpoints []*lavasession.RPCProviderEndpoint, err error)

+ func PerformCORSCheck(endpoint epochstoragetypes.Endpoint) error

+ type ChainTrackers struct

+ func (ct *ChainTrackers) GetLatestBlockNumForSpec(specID string) int64

+ func (ct *ChainTrackers) GetTrackerPerChain(specID string) (chainTracker *chaintracker.ChainTracker, found bool)

+ func (ct *ChainTrackers) SetTrackerForChain(specId string, chainTracker *chaintracker.ChainTracker)

+ type MockRelayReceiver struct

+ func NewMockRelayReceiver(ctrl *gomock.Controller) *MockRelayReceiver

+ func (m *MockRelayReceiver) EXPECT() *MockRelayReceiverMockRecorder

+ func (m *MockRelayReceiver) Probe(ctx context.Context, probeReq *types.ProbeRequest) (*types.ProbeReply, error)

+ func (m *MockRelayReceiver) Relay(ctx context.Context, request *types.RelayRequest) (*types.RelayReply, error)

+ func (m *MockRelayReceiver) RelaySubscribe(request *types.RelayRequest, srv types.Relayer_RelaySubscribeServer) error

+ type MockRelayReceiverMockRecorder struct

+ func (mr *MockRelayReceiverMockRecorder) Probe(ctx, probeReq any) *gomock.Call

+ func (mr *MockRelayReceiverMockRecorder) Relay(ctx, request any) *gomock.Call

+ func (mr *MockRelayReceiverMockRecorder) RelaySubscribe(request, srv any) *gomock.Call

+ type ProviderListener struct

+ func NewProviderListener(ctx context.Context, networkAddress lavasession.NetworkAddressData, ...) *ProviderListener

+ func (pl *ProviderListener) Key() string

+ func (pl *ProviderListener) RegisterReceiver(existingReceiver RelayReceiver, endpoint *lavasession.RPCProviderEndpoint) error

+ func (pl *ProviderListener) Shutdown(shutdownCtx context.Context) error

+ type ProviderPolicy struct

+ func GetAllAddonsAndExtensionsFromNodeUrlSlice(nodeUrls []common.NodeUrl) *ProviderPolicy

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

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

+ type ProviderStateTrackerInf interface

+ EarliestBlockInMemory func(ctx context.Context) (uint64, error)

+ GetAverageBlockTime func() time.Duration

+ GetEpochSize func(ctx context.Context) (uint64, error)

+ GetEpochSizeMultipliedByRecommendedEpochNumToCollectPayment func(ctx context.Context) (uint64, error)

+ GetMaxCuForUser func(ctx context.Context, consumerAddress, chainID string, epocu uint64) (maxCu uint64, err error)

+ GetProtocolVersion func(ctx context.Context) (*updaters.ProtocolVersionResponse, error)

+ GetRecommendedEpochNumToCollectPayment func(ctx context.Context) (uint64, error)

+ GetVirtualEpoch func(epoch uint64) uint64

+ LatestBlock func() int64

+ RegisterForDowntimeParamsUpdates func(ctx context.Context, downtimeParamsUpdatable updaters.DowntimeParamsUpdatable) error

+ RegisterForEpochUpdates func(ctx context.Context, epochUpdatable updaters.EpochUpdatable)

+ RegisterForSpecUpdates func(ctx context.Context, specUpdatable updaters.SpecUpdatable, ...) error

+ RegisterForSpecVerifications func(ctx context.Context, specVerifier updaters.SpecVerifier, chainId string) error

+ RegisterForVersionUpdates func(ctx context.Context, version *protocoltypes.Version, ...)

+ RegisterPaymentUpdatableForPayments func(ctx context.Context, paymentUpdatable updaters.PaymentUpdatable)

+ RegisterReliabilityManagerForVoteUpdates func(ctx context.Context, voteUpdatable updaters.VoteUpdatable, ...)

+ SendVoteCommitment func(voteID string, vote *reliabilitymanager.VoteData, specID string) error

+ SendVoteReveal func(voteID string, vote *reliabilitymanager.VoteData, specID string) error

+ TxRelayPayment func(ctx context.Context, relayRequests []*pairingtypes.RelaySession, ...) error

+ VerifyPairing func(ctx context.Context, consumerAddress, providerAddress string, epoch uint64, ...) (valid bool, total int64, projectId string, err error)

+ type RPCProvider struct

+ func (rpcp *RPCProvider) RetryDisabledEndpoints(disabledEndpoints []*lavasession.RPCProviderEndpoint, ...)

+ func (rpcp *RPCProvider) SetupEndpoint(ctx context.Context, rpcProviderEndpoint *lavasession.RPCProviderEndpoint, ...) error

+ func (rpcp *RPCProvider) SetupProviderEndpoints(rpcProviderEndpoints []*lavasession.RPCProviderEndpoint, ...) (disabledEndpointsRet []*lavasession.RPCProviderEndpoint)

+ func (rpcp *RPCProvider) Start(options *rpcProviderStartOptions) (err error)

+ type RPCProviderServer struct

+ func (rpcps *RPCProviderServer) ExtractConsumerAddress(ctx context.Context, relaySession *pairingtypes.RelaySession) (extractedConsumerAddress sdk.AccAddress, err error)

+ func (rpcps *RPCProviderServer) GetBlockDataForOptimisticFetch(ctx context.Context, relayBaseTimeout time.Duration, requiredProofBlock int64, ...) (latestBlock int64, requestedHashes []*chaintracker.BlockStore, err error)

+ func (rpcps *RPCProviderServer) GetLatestBlockData(ctx context.Context, blockDistanceToFinalization uint32, ...) (latestBlock int64, requestedHashes []*chaintracker.BlockStore, ...)

+ func (rpcps *RPCProviderServer) IsHealthy() bool

+ func (rpcps *RPCProviderServer) Probe(ctx context.Context, probeReq *pairingtypes.ProbeRequest) (*pairingtypes.ProbeReply, error)

+ func (rpcps *RPCProviderServer) Relay(ctx context.Context, request *pairingtypes.RelayRequest) (*pairingtypes.RelayReply, error)

+ func (rpcps *RPCProviderServer) RelaySubscribe(request *pairingtypes.RelayRequest, ...) error

+ func (rpcps *RPCProviderServer) SendProof(ctx context.Context, epoch uint64, request *pairingtypes.RelayRequest, ...) error

+ func (rpcps *RPCProviderServer) ServeRPCRequests(ctx context.Context, rpcProviderEndpoint *lavasession.RPCProviderEndpoint, ...)

+ func (rpcps *RPCProviderServer) SleepUntilTimeOrConditionReached(ctx context.Context, queryTime time.Duration, condition func() bool) (sleepTime time.Duration)

+ func (rpcps *RPCProviderServer) TryRelay(ctx context.Context, request *pairingtypes.RelayRequest, ...) (*pairingtypes.RelayReply, error)

+ func (rpcps *RPCProviderServer) TryRelaySubscribe(ctx context.Context, requestBlockHeight uint64, ...) (subscribed bool, errRet error)

+ func (rpcps *RPCProviderServer) ValidateAddonsExtensions(addon string, extensions []string, chainMessage chainlib.ChainMessage) error

+ func (rpcps *RPCProviderServer) ValidateRequest(chainMessage chainlib.ChainMessage, request *pairingtypes.RelayRequest, ...) error

+ type RelayReceiver interface

+ Probe func(ctx context.Context, probeReq *pairingtypes.ProbeRequest) (*pairingtypes.ProbeReply, error)

+ Relay func(ctx context.Context, request *pairingtypes.RelayRequest) (*pairingtypes.RelayReply, error)

+ RelaySubscribe func(request *pairingtypes.RelayRequest, ...) error

+ type ReliabilityManagerInf interface

+ GetLatestBlockData func(fromBlock, toBlock, specificBlock int64) (latestBlock int64, requestedHashes []*chaintracker.BlockStore, ...)

+ GetLatestBlockNum func() (int64, time.Time)

+ type RewardServerInf interface

+ SendNewProof func(ctx context.Context, proof *pairingtypes.RelaySession, epoch uint64, ...) (existingCU uint64, updatedWithProof bool)

+ SubscribeEnded func(consumer string, epoch uint64, subscribeID string)

+ SubscribeStarted func(consumer string, epoch uint64, subscribeID string)

+ type SpecValidator struct

+ func NewSpecValidator() *SpecValidator

+ func (sv *SpecValidator) Active() bool

+ func (sv *SpecValidator) AddChainFetcher(ctx context.Context, chainFetcher *chainlib.ChainFetcherIf, chainId string) error

+ func (sv *SpecValidator) AddRPCProviderListener(address string, providerListener *ProviderListener)

+ func (sv *SpecValidator) GetUniqueName() string

+ func (sv *SpecValidator) Start(ctx context.Context)

+ func (sv *SpecValidator) VerifySpec(spec spectypes.Spec)

+ type StateTrackerInf interface

+ GetMaxCuForUser func(ctx context.Context, consumerAddress, chainID string, epocu uint64) (maxCu uint64, err error)

+ GetVirtualEpoch func(epoch uint64) uint64

+ LatestBlock func() int64

+ VerifyPairing func(ctx context.Context, consumerAddress, providerAddress string, epoch uint64, ...) (valid bool, total int64, projectId string, err error)

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