common

package

Go to main page

Versions in this module

v4

v4.2.4

Dec 23, 2024

v4.2.3

Dec 23, 2024

v4.2.2

Dec 19, 2024

Changes in this version

+ const AllowMissingApisByDefaultFlagName

v4.2.1

Dec 8, 2024

Changes in this version

+ const LimitParallelWebsocketConnectionsPerIpFlag

+ const LimitWebsocketIdleTimeFlag

v4.2.0

Dec 4, 2024

v4.1.6

Dec 3, 2024

v4.1.5

Dec 3, 2024

v4.1.4

Dec 2, 2024

v4.1.3

Nov 26, 2024

Changes in this version

+ const OptimizerQosListenFlag

+ const REQUESTED_BLOCK_HEADER_NAME

+ var JsonRpcParseError = JsonRPCErrorMessage

v4.1.2

Nov 7, 2024

v4.1.2-near-experimental

Nov 10, 2024

v4.1.1

Nov 7, 2024

v4.1.0

Nov 5, 2024

Changes in this version

+ const LavaChainIdMetadataKey

+ const RateLimitRequestPerSecondFlag

v4.0.0

Oct 20, 2024

Changes in this version

+ const AverageWorldLatency

+ const BLOCK_PROVIDERS_ADDRESSES_HEADER_NAME

+ const BanDurationForWebsocketRateLimitExceededFlag

+ const CDNCacheDurationFlag

+ const CONSISTENCY_SELECT_ALL_PROVIDERS

+ const CacheTimeout

+ const CommunicateWithLocalLavaNodeTimeout

+ const CorsCredentialsFlag

+ const CorsHeadersFlag

+ const CorsMethodsFlag

+ const CorsOriginFlag

+ const DEFAULT_HEALTH_PATH

+ const DataReliabilityTimeoutIncrease

+ const DefaultTimeout

+ const DefaultTimeoutLong

+ const DefaultTimeoutLongIsh

+ const DisableConflictTransactionsFlag

+ const ERRORED_PROVIDERS_HEADER_NAME

+ const EXTENSION_OVERRIDE_HEADER_NAME

+ const EndpointsConfigName

+ const FORCE_CACHE_REFRESH_HEADER_NAME

+ const GUID_HEADER_NAME

+ const GeolocationFlag

+ const IP_FORWARDING_HEADER_NAME

+ const LAVAP_VERSION_HEADER_NAME

+ const LAVA_CONSUMER_PROCESS_GUID

+ const LAVA_DEBUG_RELAY

+ const LAVA_IDENTIFIED_NODE_ERROR_HEADER

+ const LAVA_LB_UNIQUE_ID_HEADER

+ const MAXIMUM_ALLOWED_TIMEOUT_EXTEND_MULTIPLIER_BY_THE_CONSUMER

+ const MaximumConcurrentProvidersFlagName

+ const MinimumTimePerRelayDelay

+ const NODE_ERRORS_PROVIDERS_HEADER_NAME

+ const NO_STATE

+ const OptimizerQosServerAddressFlag

+ const OptimizerQosServerPushIntervalFlag

+ const OptimizerQosServerSamplingIntervalFlag

+ const PROVIDER_ADDRESS_HEADER_NAME

+ const PROVIDER_LATEST_BLOCK_HEADER_NAME

+ const PlainTextConnection

+ const ProcessStartLogText

+ const RELAY_TIMEOUT_HEADER_NAME

+ const REPORTED_PROVIDERS_HEADER_NAME

+ const RETRY_COUNT_HEADER_NAME

+ const RateLimitWebSocketFlag

+ const RelayHealthIntervalFlag

+ const RelaysHealthEnableFlag

+ const RollingLogBackupsFlag

+ const RollingLogFileLocationFlag

+ const RollingLogFormat

+ const RollingLogLevelFlag

+ const RollingLogMaxAgeFlag

+ const RollingLogMaxSizeFlag

+ const STATEFUL_API_HEADER

+ const SaveConfigFlagName

+ const SetProviderOptimizerBestTierPickChance

+ const SetProviderOptimizerNumberOfTiersToCreate

+ const SetProviderOptimizerWorstTierPickChance

+ const SetRelayCountOnNodeErrorFlag

+ const SharedStateFlag

+ const StaticProvidersConfigName

+ const StatusCodeMetadataKey

+ const SubscriptionFirstReplyTimeout

+ const TestModeFlagName

+ const TimeOutForFetchingLavaBlocksFlag

+ const TimePerCU

+ const URL_QUERY_PARAMETERS_SEPARATOR_FROM_PATH

+ const URL_QUERY_PARAMETERS_SEPARATOR_OTHER_PARAMETERS

+ const USER_REQUEST_TYPE

+ const UseStaticSpecFlag

+ const VersionMetadataKey

+ var APINotSupportedError = sdkerrors.New("APINotSupported Error", 900, "api not supported")

+ var ContextDeadlineExceededError = sdkerrors.New("ContextDeadlineExceeded Error", 300, "context deadline exceeded")

+ var JsonRpcMethodNotFoundError = JsonRPCErrorMessage

+ var JsonRpcRateLimitError = JsonRPCErrorMessage

+ var JsonRpcSubscriptionNotFoundError = JsonRPCErrorMessage

+ var ProviderFinalizationDataAccountabilityError = sdkerrors.New("ProviderFinalizationDataAccountability Error", 3365, ...)

+ var RestAptosMethodNotFoundError = RestAptosError

+ var RestMethodNotFoundError = RestError

+ var SPECIAL_LAVA_DIRECTIVE_HEADERS = map[string]struct

+ var StatusCodeError429 = sdkerrors.New("Disallowed StatusCode Error", 429, "Disallowed status code error")

+ var StatusCodeError504 = sdkerrors.New("Disallowed StatusCode Error", 504, "Disallowed status code error")

+ var StatusCodeErrorStrict = sdkerrors.New("Disallowed StatusCode Error", 800, "Disallowed status code error")

+ var SubscriptionNotFoundError = sdkerrors.New("SubscriptionNotFoundError Error", 901, "subscription not found")

+ func AddRollingLogConfig(cmd *cobra.Command)

+ func BaseTimePerCU(cu uint64) time.Duration

+ func CapContextTimeout(ctx context.Context, timeout time.Duration) (context.Context, context.CancelFunc)

+ func ContextOutOfTime(ctx context.Context) bool

+ func CreateRestMethodNotFoundError(fiberCtx *fiber.Ctx, chainId string) error

+ func FindSequenceNumber(sequence string) (int, error)

+ func GetExtensionNames(extensionCollection []*spectypes.Extension) (extensions []string)

+ func GetIpFromGrpcContext(ctx context.Context) string

+ func GetRemainingTimeoutFromContext(ctx context.Context) (timeRemaining time.Duration)

+ func GetTimePerCu(cu uint64) time.Duration

+ func GetTimeoutForProcessing(relayTimeout time.Duration, timeoutInfo TimeoutInfo) time.Duration

+ func GetTokenFromGrpcContext(ctx context.Context) string

+ func GetUniqueToken(userData UserData) string

+ func IsQuoted(s string) bool

+ func IsSquareBracketed(s string) bool

+ func IsTestMode(ctx context.Context) bool

+ func IsTimeout(errArg error) bool

+ func LocalNodeTimePerCu(cu uint64) time.Duration

+ func ParseEndpointArgs(endpoint_strings, yaml_config_properties []string, endpointsConfigName string) (viper_endpoints *viper.Viper, err error)

+ func SetupRollingLogger() func()

+ func UnSquareBracket(s string) string

+ func ValidateEndpoint(endpoint, apiInterface string) error

+ func VerifyAndHandleUnsupportedFlags(currentFlags *pflag.FlagSet) error

+ type AuthConfig struct

+ AllowInsecure bool

+ AuthHeaders map[string]string

+ AuthQuery string

+ CaCert string

+ CertPem string

+ KeyPem string

+ UseTLS bool

+ func (ac *AuthConfig) AddAuthPath(url string) string

+ func (ac *AuthConfig) GetCaCertificateParams() string

+ func (ac *AuthConfig) GetLoadingCertificateParams() (string, string)

+ func (ac *AuthConfig) GetUseTls() bool

+ type ChainMessageGetApiInterface interface

+ GetApi func() *spectypes.Api

+ type ConflictHandlerInterface interface

+ ConflictAlreadyReported func() bool

+ StoreConflictReported func()

+ type ConsumerCmdFlags struct

+ CDNCacheDuration string

+ CredentialsFlag string

+ DebugRelays bool

+ DisableConflictTransactions bool

+ HeadersFlag string

+ MethodsFlag string

+ OriginFlag string

+ RelaysHealthEnableFlag bool

+ RelaysHealthIntervalFlag time.Duration

+ StaticSpecPath string

+ type JsonRPCError struct

+ Code int

+ Data string

+ Message string

+ type JsonRPCErrorMessage struct

+ Error JsonRPCError

+ Id int

+ JsonRPC string

+ type NodeUrl struct

+ Addons []string

+ AuthConfig AuthConfig

+ InternalPath string

+ IpForwarding bool

+ Methods []string

+ SkipVerifications []string

+ Timeout time.Duration

+ Url string

+ func (nurl *NodeUrl) UrlStr() string

+ func (nurl NodeUrl) String() string

+ func (url *NodeUrl) LowerContextTimeout(ctx context.Context, processingTimeout time.Duration) (context.Context, context.CancelFunc)

+ func (url *NodeUrl) LowerContextTimeoutWithDuration(ctx context.Context, timeout time.Duration) (context.Context, context.CancelFunc)

+ func (url *NodeUrl) SetAuthHeaders(ctx context.Context, headerSetter func(string, string))

+ func (url *NodeUrl) SetIpForwardingIfNecessary(ctx context.Context, headerSetter func(string, string))

+ type ProviderInfo struct

+ ProviderAddress string

+ ProviderQoSExcellenceSummery sdk.Dec

+ ProviderStake sdk.Coin

+ type RelayResult struct

+ ConflictHandler ConflictHandlerInterface

+ Finalized bool

+ IsNodeError bool

+ ProviderInfo ProviderInfo

+ ProviderTrailer metadata.MD

+ Quorum int

+ Reply *pairingtypes.RelayReply

+ ReplyServer pairingtypes.Relayer_RelaySubscribeClient

+ Request *pairingtypes.RelayRequest

+ StatusCode int

+ func (rr *RelayResult) GetProvider() string

+ func (rr *RelayResult) GetReply() *pairingtypes.RelayReply

+ func (rr *RelayResult) GetReplyServer() pairingtypes.Relayer_RelaySubscribeClient

+ func (rr *RelayResult) GetStatusCode() int

+ type RestAptosError struct

+ ErrorCode string

+ Message string

+ VmErrorCode interface{}

+ type RestError struct

+ Code int

+ Details []interface{}

+ Message string

+ type SafeChannelSender struct

+ func NewSafeChannelSender[T any](ctx context.Context, ch chan<- T) *SafeChannelSender[T]

+ func (scs *SafeChannelSender[T]) Close()

+ func (scs *SafeChannelSender[T]) LockAndSendAsynchronously(msg T)

+ func (scs *SafeChannelSender[T]) ReplaceChannel(ch chan<- T)

+ func (scs *SafeChannelSender[T]) Send(msg T)

+ type SafeSyncMap struct

+ func (ssm *SafeSyncMap[K, V]) Load(key K) (ret V, ok bool, err error)

+ func (ssm *SafeSyncMap[K, V]) LoadOrStore(key K, value V) (ret V, loaded bool, err error)

+ func (ssm *SafeSyncMap[K, V]) Range(f func(key K, value V) bool)

+ func (ssm *SafeSyncMap[K, V]) Store(key K, toSet V)

+ type Test_mode_ctx_key struct

+ type TimeoutInfo struct

+ CU uint64

+ Hanging bool

+ Stateful uint32

+ type TxResultData struct

+ Code int

+ RawLog string

+ Txhash []byte

+ func ParseTransactionResult(parsedValues map[string]any) (retData TxResultData, err error)

+ type UserData struct

+ ConsumerIp string

+ DappId string

Other modules containing this package

github.com/lavanet/lava

github.com/lavanet/lava/v2

github.com/lavanet/lava/v3

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