web3protocol

Dec 13, 2024

Changes in this version

+ type SharedOutput struct

+ FetchedBytes []byte

+ IsEnded bool

+ Mutex sync.Mutex

+ OriginalOutput io.Reader

+ type SharedOutputReader struct

+ Position int

+ SharedOutput *SharedOutput

+ func (r *SharedOutputReader) Read(p []byte) (n int, err error)

Dec 13, 2024

Changes in this version

type ChainConfig

+ SystemRPC string

+ type ChainRPCConfig struct

+ MaxConcurrentRequests int

+ Url string

type Client

+ RequestQueue map[RequestQueueKey][]chan *RequestQueueResponse

+ RequestQueueMutex sync.Mutex

+ Rpcs map[int][]*Rpc

+ RpcsMutex sync.RWMutex

+ func (client *Client) CheckTooManyRequestsStateWorker(rpc *Rpc)

+ func (client *Client) FetchUrlDirect(url string, httpHeaders map[string]string) (fetchedUrl FetchedWeb3URL, err error)

+ func (client *Client) GetSystemRpcUrl(chain int) (rpcUrl string, err error)

+ type JsonError interface

+ Error func() string

+ ErrorCode func() int

+ ErrorData func() interface{}

+ type RequestQueueKey struct

+ HttpHeaderAcceptEncoding string

+ HttpHeaderIfModifiedSince string

+ HttpHeaderIfNoneMatch string

+ URL string

+ type RequestQueueResponse struct

+ type Rpc struct

+ Config ChainRPCConfig

+ RequestSemaphone chan struct{}

+ State RpcState

+ type RpcState string

+ const RpcStateAvailable

+ const RpcStateTooManyRequests

+ const RpcStateUnauthorized

+ type Web3ProtocolError struct

+ Err error

+ HttpCode int

+ JsonErrorCode int

+ JsonErrorData interface{}

+ RpcHttpCode int

+ Type Web3ProtocolErrorType

+ func (e *Web3ProtocolError) Error() string

+ type Web3ProtocolErrorType string

+ const Web3ProtocolErrorTypeOther

+ const Web3ProtocolErrorTypeRPCError

+ const Web3ProtocolErrorTypeRPCJsonError

Dec 9, 2024

Changes in this version

type ResourceRequestChainCachingTracker

+ LastEventsCheck time.Time

Nov 11, 2024

Changes in this version

type ResourceRequestChainCachingTracker

+ func (c *ResourceRequestChainCachingTracker) GetResourceCachingInfosByPattern(contractAddress common.Address, pathQueryPattern string) (resourceCachingInfos map[string]*ResourceCachingInfos, err error)

Oct 27, 2024

Changes in this version

type ResourceRequestChainCachingTracker

+ LastRead time.Time

+ func (c *ResourceRequestChainCachingTracker) ActivateUnsafe()

Oct 17, 2024

Changes in this version

+ type AddressPathQuery struct

+ ContractAddress common.Address

+ PathQuery string

type ResourceCachingInfos

+ CacheClearEventListeners []AddressPathQuery

Oct 3, 2024

Changes in this version

type Client

+ ResolveModeCache *golanglru2.LRU[ResolveModeCacheKey, ResolveMode]

+ type ResolveModeCacheKey struct

+ ChainId int

+ ContractAddress common.Address

Oct 3, 2024

Changes in this version

+ func GetCacheControlHeaderDirectives(headerValue string) (directives map[string]string)

+ func SerializeResourceRequestMethodArgValues(argValues []interface{}) (pathQuery string)

type Client

+ Logger *logrus.Logger

+ ResourceRequestCachingTracker ResourceRequestCachingTracker

+ func (client *Client) AttemptEarlyResourceRequestModeResponse(web3Url *Web3URL) (fetchedWeb3Url FetchedWeb3URL, success bool, err error)

+ func (client *Client) AttemptEarlyResponse(web3Url *Web3URL) (fetchedWeb3Url FetchedWeb3URL, success bool, err error)

+ type ParsedWeb3Url struct

+ ChainId string

+ Fragment string

+ Hostname string

+ Path string

+ PathQuery string

+ Protocol string

+ Query string

+ type ResourceCachingInfos struct

+ ETag string

+ LastModified time.Time

+ type ResourceRequestCachingTracker struct

+ ChainCachingTrackers map[int]*ResourceRequestChainCachingTracker

+ Client *Client

+ Mutex sync.RWMutex

+ func NewResourceRequestCachingTracker(client *Client) ResourceRequestCachingTracker

+ func (c *ResourceRequestCachingTracker) GetChainCachingTracker(chainId int) (chainCachingTracker *ResourceRequestChainCachingTracker, ok bool)

+ func (c *ResourceRequestCachingTracker) GetOrCreateChainCachingTracker(chainId int) (chainCachingTracker *ResourceRequestChainCachingTracker)

+ type ResourceRequestChainCachingTracker struct

+ ChainId int

+ EventsCheckWorkerStopChan chan bool

+ GlobalCachingTracker *ResourceRequestCachingTracker

+ IsActive bool

+ LastBlockNumber uint64

+ Mutex sync.RWMutex

+ ResourcesCachingInfos map[common.Address]map[string]ResourceCachingInfos

+ func (c *ResourceRequestChainCachingTracker) Activate()

+ func (c *ResourceRequestChainCachingTracker) DeleteResourceCachingInfos(contractAddress common.Address, pathQuery string)

+ func (c *ResourceRequestChainCachingTracker) Desactivate()

+ func (c *ResourceRequestChainCachingTracker) GetResourceCachingInfos(contractAddress common.Address, pathQuery string) (resourceCachingInfos ResourceCachingInfos, ok bool)

+ func (c *ResourceRequestChainCachingTracker) SetResourceCachingInfos(contractAddress common.Address, pathQuery string, ...)

type Web3URL

+ HttpHeaders map[string]string

+ UrlParts ParsedWeb3Url

Feb 15, 2024

Changes in this version

+ type PrefixDecompressionErrorReader struct

+ Reader io.Reader

+ func (r *PrefixDecompressionErrorReader) Read(p []byte) (readBytes int, err error)

Dec 15, 2023

Changes in this version

+ type ResourceRequestReader struct

+ Chunk []byte

+ Client *Client

+ Cursor int

+ FetchedWeb3URL *FetchedWeb3URL

+ NextChunkUrl string

+ func (rrr *ResourceRequestReader) Read(p []byte) (readBytes int, err error)

Nov 9, 2023

Changes in this version

+ const ContractCallModeCalldata

+ const ContractCallModeMethod

+ const ContractReturnProcessingDecodeABIEncodedBytes

+ const ContractReturnProcessingDecodeErc5219Request

+ const ContractReturnProcessingJsonEncodeValues

+ const ContractReturnProcessingRawBytesJsonEncoded

+ const DomainNameServiceENS

+ const DomainNameServiceW3NS

+ const ResolveModeAuto

+ const ResolveModeManual

+ const ResolveModeResourceRequests

+ var EmptyAddress = strings.Repeat("0", 64)

+ var EmptyString = strings.Repeat("0", 62) + "20" + strings.Repeat("0", 64)

+ func JsonEncodeAbiTypeValue(arg abi.Type, value interface{}) (result interface{}, err error)

+ func LabelHash(label string) (hash [32]byte, err error)

+ func NameHash(name string) (hash [32]byte, err error)

+ func Normalize(input string) (output string, err error)

+ type ArgInfo struct

+ type ChainConfig struct

+ ChainId int

+ DomainNameServices map[DomainNameService]DomainNameServiceChainConfig

+ RPC string

+ ShortName string

+ type Client struct

+ Config *Config

+ DomainNameResolutionCache *localCache

+ func NewClient(config *Config) (client *Client)

+ func (client *Client) FetchContractReturn(web3Url *Web3URL) (contractReturn []byte, err error)

+ func (client *Client) FetchUrl(url string) (fetchedUrl FetchedWeb3URL, err error)

+ func (client *Client) ParseUrl(url string) (web3Url Web3URL, err error)

+ func (client *Client) ProcessContractReturn(web3Url *Web3URL, contractReturn []byte) (fetchedWeb3Url FetchedWeb3URL, err error)

+ func (client *Client) ProcessResourceRequestContractReturn(fetchedWeb3Url *FetchedWeb3URL, web3Url *Web3URL, contractReturn []byte) (err error)

+ type Config struct

+ Chains map[int]ChainConfig

+ DomainNameServices map[DomainNameService]DomainNameServiceConfig

+ NameAddrCacheDurationInMinutes int

+ func (config *Config) GetChainIdByShortName(shortName string) (result int)

+ func (config *Config) GetDomainNameServiceBySuffix(suffix string) (result DomainNameService)

+ type ContractCallMode string

+ type ContractReturnProcessing string

+ type DomainNameService string

+ type DomainNameServiceChainConfig struct

+ Id DomainNameService

+ ResolverAddress common.Address

+ type DomainNameServiceConfig struct

+ DefaultChainId int

+ Id DomainNameService

+ Suffix string

+ type ErrorWithHttpCode struct

+ Err string

+ HttpCode int

+ func (e *ErrorWithHttpCode) Error() string

+ type FetchedWeb3URL struct

+ ContractReturn []byte

+ HttpCode int

+ HttpHeaders map[string]string

+ Output []byte

+ ParsedUrl *Web3URL

+ type QueryParameter struct

+ Name string

+ Value string

+ type QueryParameters []QueryParameter

+ func ParseQuery(query string) (params QueryParameters, err error)

+ type ResolveMode string

+ type Web3URL struct

+ Calldata []byte

+ ChainId int

+ ContractAddress common.Address

+ ContractCallMode ContractCallMode

+ ContractReturnProcessing ContractReturnProcessing

+ DecodedABIEncodedBytesMimeType string

+ HostDomainNameResolver DomainNameService

+ HostDomainNameResolverChainId int

+ JsonEncodedValueTypes []abi.Type

+ MethodArgValues []interface{}

+ MethodArgs []abi.Type

+ MethodName string

+ ResolveMode ResolveMode

+ Url string

+ func (web3Url *Web3URL) ComputeCalldata() (calldata []byte, err error)