common

package

Go to main page

Versions in this module

v2

v2.5.3

Aug 26, 2024

Changes in this version

+ const DisableCacheOnNodeErrorFlag

+ const LAVAP_VERSION_HEADER_NAME

+ const NODE_ERRORS_PROVIDERS_HEADER_NAME

+ const SetRelayCountOnNodeErrorFlag

+ const StaticProvidersConfigName

+ const UseOfflineSpecFlag

type ConsumerCmdFlags

+ DisableCacheOnNodeError bool

+ OfflineSpecPath string

+ SetRelayCountOnNodeError int

type NodeUrl

+ Methods []string

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

+ const LAVA_CONSUMER_PROCESS_GUID

+ const LAVA_LB_UNIQUE_ID_HEADER

+ const SubscriptionFirstReplyTimeout

+ var JsonRpcSubscriptionNotFoundError = JsonRPCErrorMessage

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

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

+ func IsQuoted(s string) bool

+ func IsSquareBracketed(s string) bool

+ func UnSquareBracket(s string) string

type JsonRPCError

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

v2.2.7

Aug 6, 2024

v2.2.6

Aug 4, 2024

Changes in this version

+ const AverageWorldLatency

+ const BLOCK_PROVIDERS_ADDRESSES_HEADER_NAME

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

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

+ const MAXIMUM_ALLOWED_TIMEOUT_EXTEND_MULTIPLIER_BY_THE_CONSUMER

+ const MaximumConcurrentProvidersFlagName

+ const MinimumTimePerRelayDelay

+ const NO_STATE

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

+ const RelaysHealthEnableFlag

+ const RollingLogBackupsFlag

+ const RollingLogFileLocationFlag

+ const RollingLogFormat

+ const RollingLogLevelFlag

+ const RollingLogMaxAgeFlag

+ const RollingLogMaxSizeFlag

+ const SaveConfigFlagName

+ const SharedStateFlag

+ const StatusCodeMetadataKey

+ const TestModeFlagName

+ const TimeOutForFetchingLavaBlocksFlag

+ const TimePerCU

+ const URL_QUERY_PARAMETERS_SEPARATOR_FROM_PATH

+ const URL_QUERY_PARAMETERS_SEPARATOR_OTHER_PARAMETERS

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

+ 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(consumerAddress string, ip string) string

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

+ DisableRetryOnNodeErrors bool

+ HeadersFlag string

+ MethodsFlag string

+ OriginFlag string

+ RelaysHealthEnableFlag bool

+ RelaysHealthIntervalFlag time.Duration

+ type JsonRPCError struct

+ Code int

+ Message string

+ type JsonRPCErrorMessage struct

+ Error JsonRPCError

+ Id int

+ JsonRPC string

+ type NodeUrl struct

+ Addons []string

+ AuthConfig AuthConfig

+ InternalPath string

+ IpForwarding bool

+ 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

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

Other modules containing this package

github.com/lavanet/lava

github.com/lavanet/lava/v3

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