lavasession

package

Go to main page

Versions in this module

v3

v3.1.8

Sep 15, 2024

v3.1.7

Sep 15, 2024

Changes in this version

+ const WeightMultiplierForStaticProviders

+ func CalcWeightsByStake(providers map[uint64]*ConsumerSessionsWithProvider) (weights map[string]int64)

type ProviderOptimizer

+ UpdateWeights func(map[string]int64)

v3.1.7-near-hf

Sep 15, 2024

v3.1.6

Sep 11, 2024

v3.1.5

Sep 11, 2024

Changes in this version

type UsedProviders

+ func (up *UsedProviders) BatchNumber() int

v3.1.4

Sep 4, 2024

v3.1.3

Sep 3, 2024

v3.1.2

Sep 3, 2024

v3.1.1

Sep 3, 2024

v3.1.0

Sep 1, 2024

Changes in this version

+ const AllowGRPCCompressionFlag

+ const AllowInsecureConnectionToProvidersFlag

+ const BACKOFF_TIME_ON_FAILURE

+ const BLOCKING_PROBE_SLEEP_TIME

+ const BLOCKING_PROBE_TIMEOUT

+ const BlockedProviderSessionUnusedStatus

+ const BlockedProviderSessionUsedStatus

+ const DataReliabilityCuSum

+ const DataReliabilityRelayNumber

+ const DataReliabilitySessionId

+ const GeolocationFlag

+ const IndexNotFound

+ const LatencyThresholdSlope

+ const LatencyThresholdStatic

+ const MaxAllowedBlockListedSessionPerProvider

+ const MaxConsecutiveConnectionAttempts

+ const MaxSessionsAllowedPerProvider

+ const MaximumNumberOfFailuresAllowedPerConsumerSession

+ const MaximumNumberOfSelectionLockAttempts

+ const MinProvidersForSync

+ const MinValidAddressesForBlockingProbing

+ const OptimizerPerturbation

+ const PercentileToCalculateLatency

+ const ReconnectCandidateTime

+ const RelayNumberIncrement

+ const StaleEpochDistance

+ const TRY_LOCK_ATTEMPTS

+ const TendermintUnsubscribeAll

+ const TimeoutForEstablishingAConnection

+ var AddressIndexWasNotFoundError = sdkerrors.New("AddressIndexWasNotFound Error", 671, "address index was not found in list")

+ var AllProviderEndpointsDisabledError = sdkerrors.New("AllProviderEndpointsDisabled Error", 667, "All endpoints are not available.")

+ var AllowGRPCCompressionForConsumerProviderCommunication = false

+ var AllowInsecureConnectionToProviders = false

+ var AvailabilityPercentage sdk.Dec = sdk.NewDecWithPrec(1, 1)

+ var BlockEndpointError = sdkerrors.New("BlockEndpoint Error", 688, "Block the endpoint")

+ var BlockProviderError = sdkerrors.New("BlockProvider Error", 676, "Block the provider")

+ var ConsumerIsBlockListed = sdkerrors.New("ConsumerIsBlockListed Error", 883, "This Consumer Is Blocked.")

+ var ConsumerIsNotRegisteredError = sdkerrors.New("ConsumerIsNotRegisteredError Error", 891, ...)

+ var ConsumerNotRegisteredYet = sdkerrors.New("ConsumerNotActive Error", 884, "This Consumer Is Not Currently In The Pool.")

+ var ContextDoneNoNeedToLockSelectionError = sdkerrors.New("ContextDoneNoNeedToLockSelection Error", 687, ...)

+ var CouldNotFindIndexAsConsumerNotYetRegisteredError = sdkerrors.New("CouldNotFindIndexAsConsumerNotYetRegistered Error", 897, ...)

+ var DataReliabilityAlreadySentThisEpochError = sdkerrors.New("DataReliabilityAlreadySentThisEpoch Error", 682, ...)

+ var DataReliabilityCuSumMisMatchError = sdkerrors.New("DataReliabilityCuSumMisMatch Error", 894, ...)

+ var DataReliabilityEpochMismatchError = sdkerrors.New("DataReliabilityEpochMismatch Error", 684, ...)

+ var DataReliabilityIndexOutOfRangeError = sdkerrors.New("DataReliabilityIndexOutOfRange Error", 681, ...)

+ var DataReliabilityIndexRequestedIsOriginalProviderError = sdkerrors.New("DataReliabilityIndexRequestedIsOriginalProvider Error", 680, ...)

+ var DataReliabilityRelayNumberMisMatchError = sdkerrors.New("DataReliabilityRelayNumberMisMatch Error", 895, ...)

+ var DataReliabilitySessionAlreadyUsedError = sdkerrors.New("DataReliabilitySessionAlreadyUsed Error", 893, ...)

+ var DebugProbes = false

+ var EpochIsNotRegisteredError = sdkerrors.New("EpochIsNotRegisteredError Error", 890, ...)

+ var EpochMismatchError = sdkerrors.New("ReportingAnOldEpoch Error", 670, "Tried to Report to an older epoch")

+ var FailedToConnectToEndPointForDataReliabilityError = sdkerrors.New("FailedToConnectToEndPointForDataReliability Error", 683, ...)

+ var InvalidEpochError = sdkerrors.New("InvalidEpoch Error", 881, "Requested Epoch Is Too Old")

+ var LockMisUseDetectedError = sdkerrors.New("LockMisUseDetected Error", 672, "Faulty use of locks detected")

+ var MaxComputeUnitsExceededError = sdkerrors.New("MaxComputeUnitsExceeded Error", 669, ...)

+ var MaximumCULimitReachedByConsumer = sdkerrors.New("MaximumCULimitReachedByConsumer Error", 886, ...)

+ var MaximumNumberOfBlockListedSessionsError = sdkerrors.New("MaximumNumberOfBlockListedSessions Error", 678, ...)

+ var MaximumNumberOfSessionsExceededError = sdkerrors.New("MaximumNumberOfSessionsExceeded Error", 668, ...)

+ var NegativeComputeUnitsAmountError = sdkerrors.New("NegativeComputeUnitsAmount", 674, ...)

+ var NewSessionWithRelayNumError = sdkerrors.New("NewSessionWithRelayNum Error", 882, ...)

+ var NoDataReliabilitySessionWasCreatedError = sdkerrors.New("NoDataReliabilitySessionWasCreated Error", 685, ...)

+ var PairingListEmptyError = sdkerrors.New("pairingListEmpty Error", 665, "No pairings available.")

+ var ProviderConsumerCuMisMatch = sdkerrors.New("ProviderConsumerCuMisMatch Error", 887, ...)

+ var ProviderIndexMisMatchError = sdkerrors.New("ProviderIndexMisMatch Error", 898, "provider index mismatch")

+ var RelayNumberMismatch = sdkerrors.New("RelayNumberMismatch Error", 888, ...)

+ var ReportAndBlockProviderError = sdkerrors.New("ReportAndBlockProvider Error", 675, "Report and block the provider")

+ var SendRelayError = sdkerrors.New("SendRelay Error", 679, "Failed To Send Relay")

+ var SessionDoesNotExist = sdkerrors.New("SessionDoesNotExist Error", 885, "This Session Id Does Not Exist.")

+ var SessionIdNotFoundError = sdkerrors.New("SessionIdNotFound Error", 899, "Session Id not found")

+ var SessionIsAlreadyBlockListedError = sdkerrors.New("SessionIsAlreadyBlockListed Error", 673, "Session is already in block list")

+ var SessionOutOfSyncError = sdkerrors.New("SessionOutOfSync Error", 677, "Session went out of sync with the provider")

+ var SubscriptionAlreadyExistsError = sdkerrors.New("SubscriptionAlreadyExists Error", 892, ...)

+ var SubscriptionInitiationError = sdkerrors.New("SubscriptionInitiationError Error", 889, ...)

+ var SubscriptionPointerIsNilError = sdkerrors.New("SubscriptionPointerIsNil Error", 896, "Trying to unsubscribe a nil pointer.")

+ var UnreachableCodeError = sdkerrors.New("UnreachableCode Error", 666, "Should not get here.")

+ func CalculateAvailabilityScore(qosReport *QoSReport) (downtimePercentageRet, scaledAvailabilityScoreRet sdk.Dec)

+ func ConnectGRPCClient(ctx context.Context, address string, allowInsecure bool, skipTLS bool, ...) (*grpc.ClientConn, error)

+ func GenerateSelfSignedCertificate() (tls.Certificate, error)

+ func GetCaCertificate(serverCertPath, serverKeyPath string) (*tls.Config, error)

+ func GetSelfSignedConfig() (*tls.Config, error)

+ func GetTlsConfig(networkAddress NetworkAddressData) *tls.Config

+ func IsEpochValidForUse(targetEpoch, blockedEpochHeight uint64) bool

+ func IsSessionSyncLoss(err error) bool

+ func SortByGeolocations(pairingEndpoints []*Endpoint, currentGeo planstypes.Geolocation)

+ type ActiveSubscriptionProvidersStorage struct

+ func NewActiveSubscriptionProvidersStorage() *ActiveSubscriptionProvidersStorage

+ func (asps *ActiveSubscriptionProvidersStorage) AddProvider(providerAddress string)

+ func (asps *ActiveSubscriptionProvidersStorage) IsProviderCurrentlyUsed(providerAddress string) bool

+ func (asps *ActiveSubscriptionProvidersStorage) RemoveProvider(providerAddress string)

+ type BadgeSession struct

+ BadgeCuAllocation uint64

+ BadgeUser string

+ type BlockedProvidersInf interface

+ GetBlockedProviders func() []string

+ type ConsumerSessionManager struct

+ func NewConsumerSessionManager(rpcEndpoint *RPCEndpoint, providerOptimizer ProviderOptimizer, ...) *ConsumerSessionManager

+ func (csm *ConsumerSessionManager) CalculateAddonValidAddresses(addon string, extensions []string) (supportingProviderAddresses []string)

+ func (csm *ConsumerSessionManager) GenerateReconnectCallback(consumerSessionsWithProvider *ConsumerSessionsWithProvider) func() error

+ func (csm *ConsumerSessionManager) GetAtomicPairingAddressesLength() uint64

+ func (csm *ConsumerSessionManager) GetNumberOfValidProviders() int

+ func (csm *ConsumerSessionManager) GetReportedProviders(epoch uint64) []*pairingtypes.ReportedProvider

+ func (csm *ConsumerSessionManager) GetSessions(ctx context.Context, cuNeededForSession uint64, usedProviders UsedProvidersInf, ...) (consumerSessionMap ConsumerSessionsMap, errRet error)

+ func (csm *ConsumerSessionManager) Initialized() bool

+ func (csm *ConsumerSessionManager) OnSessionDone(consumerSession *SingleConsumerSession, latestServicedBlock int64, ...) error

+ func (csm *ConsumerSessionManager) OnSessionDoneIncreaseCUOnly(consumerSession *SingleConsumerSession, latestServicedBlock int64) error

+ func (csm *ConsumerSessionManager) OnSessionFailure(consumerSession *SingleConsumerSession, errorReceived error) error

+ func (csm *ConsumerSessionManager) RPCEndpoint() RPCEndpoint

+ func (csm *ConsumerSessionManager) RemoveAddonAddresses(addon string, extensions []string)

+ func (csm *ConsumerSessionManager) UpdateAllProviders(epoch uint64, pairingList map[uint64]*ConsumerSessionsWithProvider) error

+ type ConsumerSessionsMap map[string]*SessionInfo

+ type ConsumerSessionsWithProvider struct

+ Endpoints []*Endpoint

+ Lock sync.RWMutex

+ MaxComputeUnits uint64

+ PairingEpoch uint64

+ PublicLavaAddress string

+ Sessions map[int64]*SingleConsumerSession

+ StaticProvider bool

+ UsedComputeUnits uint64

+ func NewConsumerSessionWithProvider(publicLavaAddress string, pairingEndpoints []*Endpoint, maxCu uint64, ...) *ConsumerSessionsWithProvider

+ func (cswp *ConsumerSessionsWithProvider) ConflictAlreadyReported() bool

+ func (cswp *ConsumerSessionsWithProvider) ConnectRawClientWithTimeout(ctx context.Context, addr string) (pairingtypes.RelayerClient, *grpc.ClientConn, error)

+ func (cswp *ConsumerSessionsWithProvider) GetConsumerSessionInstanceFromEndpoint(endpointConnection *EndpointConnection, numberOfResets uint64) (singleConsumerSession *SingleConsumerSession, pairingEpoch uint64, err error)

+ func (cswp *ConsumerSessionsWithProvider) GetPairingEpoch() uint64

+ func (cswp *ConsumerSessionsWithProvider) IsSupportingAddon(addon string) bool

+ func (cswp *ConsumerSessionsWithProvider) IsSupportingExtensions(extensions []string) bool

+ func (cswp *ConsumerSessionsWithProvider) StoreConflictReported()

+ type DataReliabilitySession struct

+ Epoch uint64

+ ProviderPublicAddress string

+ SingleConsumerSession *SingleConsumerSession

+ UniqueIdentifier bool

+ type Endpoint struct

+ Addons map[string]struct{}

+ ConnectionRefusals uint64

+ Connections []*EndpointConnection

+ Enabled bool

+ Extensions map[string]struct{}

+ Geolocation planstypes.Geolocation

+ NetworkAddress string

+ func (e *Endpoint) CheckSupportForServices(addon string, extensions []string) (supported bool)

+ type EndpointAndChosenConnection struct

+ type EndpointConnection struct

+ Client pairingtypes.RelayerClient

+ func (ec *EndpointConnection) GetLbUniqueId() string

+ type EndpointInfo struct

+ Endpoint *Endpoint

+ Latency time.Duration

+ type EndpointInfoList []EndpointInfo

+ func (list EndpointInfoList) Len() int

+ func (list EndpointInfoList) Less(i, j int) bool

+ func (list EndpointInfoList) Swap(i, j int)

+ type NetworkAddressData struct

+ Address string

+ CertPem string

+ DisableTLS bool

+ KeyPem string

+ type NumberOfActiveSubscriptions int64

+ type ProviderOptimizer interface

+ AppendProbeRelayData func(providerAddress string, latency time.Duration, success bool)

+ AppendRelayData func(providerAddress string, latency time.Duration, isHangingApi bool, ...)

+ AppendRelayFailure func(providerAddress string)

+ ChooseProvider func(allAddresses []string, ignoredProviders map[string]struct{}, cu uint64, ...) (addresses []string)

+ GetExcellenceQoSReportForProvider func(string) (*pairingtypes.QualityOfServiceReport, *pairingtypes.QualityOfServiceReport)

+ Strategy func() provideroptimizer.Strategy

+ type ProviderSessionManager struct

+ func NewProviderSessionManager(rpcProviderEndpoint *RPCProviderEndpoint, numberOfBlocksKeptInMemory uint64) *ProviderSessionManager

+ func (psm *ProviderSessionManager) GetBlockedEpochHeight() uint64

+ func (psm *ProviderSessionManager) GetCurrentEpochAtomic() uint64

+ func (psm *ProviderSessionManager) GetSession(ctx context.Context, consumerAddress string, ...) (*SingleProviderSession, error)

+ func (psm *ProviderSessionManager) IsActiveProject(epoch uint64, projectId string) (providerSessionWithConsumer *ProviderSessionsWithConsumerProject, err error)

+ func (psm *ProviderSessionManager) IsValidEpoch(epoch uint64) (valid bool)

+ func (psm *ProviderSessionManager) OnSessionDone(singleProviderSession *SingleProviderSession, relayNumber uint64) (err error)

+ func (psm *ProviderSessionManager) OnSessionFailure(singleProviderSession *SingleProviderSession, relayNumber uint64) (err error)

+ func (psm *ProviderSessionManager) RPCProviderEndpoint() *RPCProviderEndpoint

+ func (psm *ProviderSessionManager) RegisterProviderSessionWithConsumer(ctx context.Context, consumerAddress string, ...) (*SingleProviderSession, error)

+ func (psm *ProviderSessionManager) ReportConsumer() (address string, epoch uint64, err error)

+ func (psm *ProviderSessionManager) UpdateEpoch(epoch uint64)

+ func (psm *ProviderSessionManager) UpdateSessionCU(consumerAddress string, epoch, sessionID, newCU uint64) error

+ type ProviderSessionsEpochData struct

+ MaxComputeUnits uint64

+ MissingComputeUnits uint64

+ UsedComputeUnits uint64

+ type ProviderSessionsWithConsumerProject struct

+ Lock sync.RWMutex

+ Sessions map[uint64]*SingleProviderSession

+ func NewProviderSessionsWithConsumer(projectId string, epochData *ProviderSessionsEpochData, ...) *ProviderSessionsWithConsumerProject

+ func (pswc *ProviderSessionsWithConsumerProject) SafeAddMissingComputeUnits(currentMissingCU uint64, allowedThreshold float64) (legitimate bool, totalMissingCu uint64)

+ type QoSReport struct

+ AnsweredRelays uint64

+ LastExcellenceQoSReport *pairingtypes.QualityOfServiceReport

+ LastExcellenceQoSReportRaw *pairingtypes.QualityOfServiceReport

+ LastQoSReport *pairingtypes.QualityOfServiceReport

+ LatencyScoreList []sdk.Dec

+ SyncScoreSum int64

+ TotalRelays uint64

+ TotalSyncScore int64

+ type RPCEndpoint struct

+ ApiInterface string

+ ChainID string

+ Geolocation uint64

+ HealthCheckPath string

+ NetworkAddress string

+ TLSEnabled bool

+ func (endpoint *RPCEndpoint) String() (retStr string)

+ func (rpce *RPCEndpoint) Key() string

+ func (rpce *RPCEndpoint) New(address, chainID, apiInterface string, geolocation uint64) *RPCEndpoint

+ type RPCProviderEndpoint struct

+ ApiInterface string

+ ChainID string

+ Geolocation uint64

+ NetworkAddress NetworkAddressData

+ NodeUrls []common.NodeUrl

+ func (endpoint *RPCProviderEndpoint) AddonsString() string

+ func (endpoint *RPCProviderEndpoint) String() string

+ func (endpoint *RPCProviderEndpoint) UrlsString() string

+ func (endpoint *RPCProviderEndpoint) Validate() error

+ func (rpcpe *RPCProviderEndpoint) Key() string

+ type RPCSubscription struct

+ Id string

+ Sub *rpcclient.ClientSubscription

+ SubscribeRepliesChan chan interface{}

+ type ReportedProviderEntry struct

+ Disconnections uint64

+ Errors uint64

+ type ReportedProviders struct

+ func NewReportedProviders(reporter metrics.Reporter, chainId string) *ReportedProviders

+ func (rp *ReportedProviders) AppendReport(report metrics.ReportsRequest)

+ func (rp *ReportedProviders) GetReportedProviders() []*pairingtypes.ReportedProvider

+ func (rp *ReportedProviders) IsReported(address string) bool

+ func (rp *ReportedProviders) ReconnectCandidates() []reconnectCandidate

+ func (rp *ReportedProviders) ReconnectProviders()

+ func (rp *ReportedProviders) RemoveReport(address string)

+ func (rp *ReportedProviders) ReportProvider(providerAddr string, errors uint64, disconnections uint64, ...)

+ func (rp *ReportedProviders) Reset()

+ type RouterKey string

+ func GetEmptyRouterKey() RouterKey

+ func NewRouterKey(extensions []string) RouterKey

+ func (rk *RouterKey) ApplyMethodsRoute(routeNum int) RouterKey

+ type SessionInfo struct

+ Epoch uint64

+ QoSSummeryResult sdk.Dec

+ ReportedProviders []*pairingtypes.ReportedProvider

+ Session *SingleConsumerSession

+ StakeSize sdk.Coin

+ type SessionWithProvider struct

+ CurrentEpoch uint64

+ SessionsWithProvider *ConsumerSessionsWithProvider

+ type SessionWithProviderMap map[string]*SessionWithProvider

+ type SingleConsumerSession struct

+ BlockListed bool

+ ConsecutiveErrors []error

+ CuSum uint64

+ EndpointConnection *EndpointConnection

+ LatestBlock int64

+ LatestRelayCu uint64

+ Parent *ConsumerSessionsWithProvider

+ QoSInfo QoSReport

+ RelayNum uint64

+ SessionId int64

+ StaticProvider bool

+ func (consumerSession *SingleConsumerSession) VerifyLock() error

+ func (cs *SingleConsumerSession) CalculateExpectedLatency(timeoutGivenToRelay time.Duration) time.Duration

+ func (cs *SingleConsumerSession) CalculateQoS(latency, expectedLatency time.Duration, blockHeightDiff int64, ...)

+ func (scs *SingleConsumerSession) Free(err error)

+ func (scs *SingleConsumerSession) GetProviderUniqueId() string

+ func (scs *SingleConsumerSession) SetUsageForSession(cuNeededForSession uint64, ...) error

+ func (scs *SingleConsumerSession) VerifyProviderUniqueIdAndStoreIfFirstTime(providerUniqueId string) bool

+ func (session *SingleConsumerSession) TryUseSession() (blocked bool, ok bool)

+ type SingleProviderSession struct

+ BadgeUserData *ProviderSessionsEpochData

+ CuSum uint64

+ LatestRelayCu uint64

+ PairingEpoch uint64

+ RelayNum uint64

+ SessionID uint64

+ func (sps *SingleProviderSession) DisbandSession() error

+ func (sps *SingleProviderSession) GetOccupyingGuid() uint64

+ func (sps *SingleProviderSession) GetPairingEpoch() uint64

+ func (sps *SingleProviderSession) IsBadgeSession() bool

+ func (sps *SingleProviderSession) IsPayingRelay() bool

+ func (sps *SingleProviderSession) PrepareDataReliabilitySessionForUsage(relayRequestTotalCU uint64) error

+ func (sps *SingleProviderSession) PrepareSessionForUsage(ctx context.Context, cuFromSpec, relayRequestTotalCU uint64, ...) error

+ func (sps *SingleProviderSession) SetPairingEpoch(epoch uint64)

+ func (sps *SingleProviderSession) VerifyLock() error

+ type UsedProviders struct

+ func NewUsedProviders(blockedProviders BlockedProvidersInf) *UsedProviders

+ func (up *UsedProviders) AddUnwantedAddresses(address string)

+ func (up *UsedProviders) AddUsed(sessions ConsumerSessionsMap, err error)

+ func (up *UsedProviders) ClearUnwanted()

+ func (up *UsedProviders) CurrentlyUsed() int

+ func (up *UsedProviders) CurrentlyUsedAddresses() []string

+ func (up *UsedProviders) GetErroredProviders() map[string]struct{}

+ func (up *UsedProviders) GetUnwantedProvidersToSend() map[string]struct{}

+ func (up *UsedProviders) RemoveUsed(provider string, err error)

+ func (up *UsedProviders) SessionsLatestBatch() int

+ func (up *UsedProviders) TryLockSelection(ctx context.Context) error

+ func (up *UsedProviders) UnwantedAddresses() []string

+ type UsedProvidersInf interface

+ AddUnwantedAddresses func(address string)

+ AddUsed func(ConsumerSessionsMap, error)

+ CurrentlyUsed func() int

+ GetUnwantedProvidersToSend func() map[string]struct{}

+ RemoveUsed func(providerAddress string, err error)

+ TryLockSelection func(context.Context) error

Other modules containing this package

github.com/lavanet/lava

github.com/lavanet/lava/v2

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