lavasession

package

Go to main page

Versions in this module

v0

v0.5.0

Feb 2, 2023

Changes in this version

+ const GeolocationFlag

+ var ConsumerNotActive = sdkerrors.New("ConsumerNotActive Error", 884, "This Consumer Is Not Active.")

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

+ func PrintRPCProviderEndpoint(endpoint *RPCProviderEndpoint) (retStr string)

type ProviderSessionManager

+ func NewProviderSessionManager(rpcProviderEndpoint *RPCProviderEndpoint, stateQuery StateQuery) *ProviderSessionManager

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

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

type ProviderSessionsWithConsumer

+ func (pswc *ProviderSessionsWithConsumer) GetExistingSession(sessionId uint64) (session *SingleProviderSession, err error)

+ type RPCProviderEndpoint struct

+ ApiInterface string

+ ChainID string

+ Geolocation uint64

+ NetworkAddress string

+ NodeUrl string

+ func (rpcpe *RPCProviderEndpoint) Key() string

+ type StateQuery interface

+ QueryVerifyPairing func(ctx context.Context, consumer string, blockHeight uint64)

v0.4.41

Jan 25, 2023

v0.4.31

Jan 9, 2023

v0.4.5

Jan 24, 2023

Changes in this version

type ConsumerSessionManager

+ func NewConsumerSessionManager(rpcEndpoint *RPCEndpoint) *ConsumerSessionManager

+ func (csm *ConsumerSessionManager) RPCEndpoint() RPCEndpoint

type ConsumerSessionsWithProvider

+ PublicLavaAddress string

+ type DataReliabilitySession struct

+ Epoch uint64

+ ProviderPublicAddress string

+ SingleConsumerSession *SingleConsumerSession

+ UniqueIdentifier bool

type Endpoint

+ NetworkAddress string

+ type RPCEndpoint struct

+ ApiInterface string

+ ChainID string

+ Geolocation uint64

+ NetworkAddress string

+ func (rpce *RPCEndpoint) Key() string

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

v0.4.4

Jan 19, 2023

v0.4.3

Jan 9, 2023

Changes in this version

+ const DataReliabilityCuSum

+ const DataReliabilitySessionId

+ const LatencyThresholdSlope

+ const LatencyThresholdStatic

+ const MaxAllowedBlockListedSessionPerProvider

+ const MaxConsecutiveConnectionAttempts

+ const MaxSessionsAllowedPerProvider

+ const MaximumNumberOfFailuresAllowedPerConsumerSession

+ const MinProvidersForSync

+ const PercentileToCalculateLatency

+ const RelayNumberIncrement

+ const StaleEpochDistance

+ 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 AvailabilityPercentage sdk.Dec = sdk.NewDecWithPrec(5, 2)

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

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

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

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

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

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

+ 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 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 PairingListEmptyError = sdkerrors.New("pairingListEmpty Error", 665, "No pairings available.")

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

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

+ 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 UnreachableCodeError = sdkerrors.New("UnreachableCode Error", 666, "Should not get here.")

+ type ConsumerSessionManager struct

+ func (csm *ConsumerSessionManager) GetAtomicPairingAddressesLength() uint64

+ func (csm *ConsumerSessionManager) GetDataReliabilitySession(ctx context.Context, originalProviderAddress string, index int64, ...) (singleConsumerSession *SingleConsumerSession, providerAddress string, ...)

+ func (csm *ConsumerSessionManager) GetReportedProviders(epoch uint64) ([]byte, error)

+ func (csm *ConsumerSessionManager) GetSession(ctx context.Context, cuNeededForSession uint64, ...) (consumerSession *SingleConsumerSession, epoch uint64, ...)

+ func (csm *ConsumerSessionManager) GetSessionFromAllExcept(ctx context.Context, bannedAddresses map[string]struct{}, cuNeeded uint64, ...) (consumerSession *SingleConsumerSession, epoch uint64, ...)

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

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

+ func (csm *ConsumerSessionManager) OnSessionDone(consumerSession *SingleConsumerSession, epoch uint64, ...) error

+ func (csm *ConsumerSessionManager) OnSessionDoneIncreaseRelayAndCu(consumerSession *SingleConsumerSession) error

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

+ func (csm *ConsumerSessionManager) OnSessionUnUsed(consumerSession *SingleConsumerSession) error

+ func (csm *ConsumerSessionManager) UpdateAllProviders(ctx context.Context, epoch uint64, pairingList []*ConsumerSessionsWithProvider) error

+ type ConsumerSessionsWithProvider struct

+ Acc string

+ Endpoints []*Endpoint

+ Lock utils.LavaMutex

+ MaxComputeUnits uint64

+ PairingEpoch uint64

+ ReliabilitySent bool

+ Sessions map[int64]*SingleConsumerSession

+ UsedComputeUnits uint64

+ func (cswp *ConsumerSessionsWithProvider) GetPairingEpoch() uint64

+ type Endpoint struct

+ Addr string

+ Client *pairingtypes.RelayerClient

+ ConnectionRefusals uint64

+ Enabled bool

+ type ProviderSessionManager struct

+ func GetProviderSessionManager() *ProviderSessionManager

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

+ func (psm *ProviderSessionManager) GetSession(address string, id uint64, epoch uint64, relayNum uint64, sessionId uint64) (*SingleProviderSession, error)

+ func (psm *ProviderSessionManager) IsActiveConsumer(epoch uint64, address string) (active bool, err error)

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

+ func (psm *ProviderSessionManager) OnSessionDone(proof string) (epoch uint64, err error)

+ func (psm *ProviderSessionManager) OnSessionFailure() (epoch uint64, err error)

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

+ type ProviderSessionsEpochData struct

+ DataReliability *pairingtypes.VRFData

+ MaxComputeUnits uint64

+ UsedComputeUnits uint64

+ VrfPk utils.VrfPubKey

+ type ProviderSessionsWithConsumer struct

+ Lock sync.RWMutex

+ Sessions map[uint64]*SingleProviderSession

+ type SingleConsumerSession struct

+ BlockListed bool

+ Client *ConsumerSessionsWithProvider

+ ConsecutiveNumberOfFailures uint64

+ CuSum uint64

+ Endpoint *Endpoint

+ LatestBlock int64

+ LatestRelayCu uint64

+ QoSInfo qoSInfo

+ RelayNum uint64

+ SessionId int64

+ func (cs *SingleConsumerSession) CalculateQoS(cu uint64, latency time.Duration, blockHeightDiff int64, numOfProviders int, ...)

+ type SingleProviderSession struct

+ CuSum uint64

+ Lock sync.RWMutex

+ PairingEpoch uint64

+ Proof *pairingtypes.RelayRequest

+ RelayNum uint64

+ UniqueIdentifier uint64

+ func (r *SingleProviderSession) GetPairingEpoch() uint64

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

v0.4.2

Jan 1, 2023

v0.4.1

Dec 28, 2022

v0.4.1-rc3

Dec 28, 2022

v0.4.1-rc2

Dec 28, 2022

v0.4.1-rc1

Dec 28, 2022

v0.4.0

Dec 25, 2022

v0.3.0

Dec 21, 2022

v0.2.0

Dec 12, 2022

v0.1.2

Nov 20, 2022

v0.1.1

Nov 20, 2022

v0.1.0

Nov 14, 2022

v0.1.0-production

Nov 16, 2022

v0.0.6

Nov 9, 2022

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