chain

Jul 30, 2024

Changes in this version

type ClientWithFallback

+ func (c *ClientWithFallback) Copy() interface{}

+ func (c *ClientWithFallback) GetCircuitBreaker() *circuitbreaker.CircuitBreaker

+ func (c *ClientWithFallback) SetCircuitBreaker(cb *circuitbreaker.CircuitBreaker)

+ type Copyable interface

+ Copy func() interface{}

+ type HealthMonitor interface

+ GetCircuitBreaker func() *circuitbreaker.CircuitBreaker

+ SetCircuitBreaker func(cb *circuitbreaker.CircuitBreaker)

Jul 9, 2024

Changes in this version

+ type EthClient struct

+ func NewEthClient(ethClient *ethclient.Client, limiter *RPCRpsLimiter, rpcClient *rpc.Client, ...) *EthClient

Jun 24, 2024

Changes in this version

type InMemRequestsMapStorage

+ func (s *InMemRequestsMapStorage) Delete(tag string) error

type LimitsDBStorage

+ func (s *LimitsDBStorage) Delete(tag string) error

type LimitsStorage

+ Delete func(tag string) error

type RPCRequestLimiter

+ func (rl *RPCRequestLimiter) DeleteLimit(tag string) error

type RequestLimiter

+ DeleteLimit func(tag string) error

May 29, 2024

Changes in this version

+ const LimitInfinitely

+ type ChainInterface interface

+ BalanceAt func(ctx context.Context, account common.Address, blockNumber *big.Int) (*big.Int, error)

+ BatchCallContext func(ctx context.Context, b []rpc.BatchElem) error

+ BlockByHash func(ctx context.Context, hash common.Hash) (*types.Block, error)

+ BlockByNumber func(ctx context.Context, number *big.Int) (*types.Block, error)

+ BlockNumber func(ctx context.Context) (uint64, error)

+ CallBlockHashByTransaction func(ctx context.Context, blockNumber *big.Int, index uint) (common.Hash, error)

+ CallContext func(ctx context.Context, result interface{}, method string, args ...interface{}) error

+ CallContract func(ctx context.Context, call ethereum.CallMsg, blockNumber *big.Int) ([]byte, error)

+ CodeAt func(ctx context.Context, contract common.Address, blockNumber *big.Int) ([]byte, error)

+ FilterLogs func(ctx context.Context, q ethereum.FilterQuery) ([]types.Log, error)

+ GetBaseFeeFromBlock func(ctx context.Context, blockNumber *big.Int) (string, error)

+ HeaderByHash func(ctx context.Context, hash common.Hash) (*types.Header, error)

+ HeaderByNumber func(ctx context.Context, number *big.Int) (*types.Header, error)

+ NetworkID func() uint64

+ NonceAt func(ctx context.Context, account common.Address, blockNumber *big.Int) (uint64, error)

+ ToBigInt func() *big.Int

+ TransactionByHash func(ctx context.Context, hash common.Hash) (*types.Transaction, bool, error)

+ TransactionReceipt func(ctx context.Context, txHash common.Hash) (*types.Receipt, error)

type ClientInterface

+ func ClientWithTag(chainClient ClientInterface, tag, groupTag string) ClientInterface

+ GetLimiter func() RequestLimiter

+ SetLimiter func(RequestLimiter)

type ClientWithFallback

+ func (c *ClientWithFallback) DeepCopyTag() Tagger

+ func (c *ClientWithFallback) GetLimiter() RequestLimiter

+ func (c *ClientWithFallback) GroupTag() string

+ func (c *ClientWithFallback) SetGroupTag(tag string)

+ func (c *ClientWithFallback) SetLimiter(limiter RequestLimiter)

+ func (c *ClientWithFallback) SetTag(tag string)

+ func (c *ClientWithFallback) Tag() string

+ type InMemRequestsMapStorage struct

+ func NewInMemRequestsMapStorage() *InMemRequestsMapStorage

+ func (s *InMemRequestsMapStorage) Get(tag string) (*LimitData, error)

+ func (s *InMemRequestsMapStorage) Set(data *LimitData) error

+ type LimitData struct

+ CreatedAt time.Time

+ MaxReqs int

+ NumReqs int

+ Period time.Duration

+ Tag string

+ type LimitsDBStorage struct

+ func NewLimitsDBStorage(db *sql.DB) *LimitsDBStorage

+ func (s *LimitsDBStorage) Get(tag string) (*LimitData, error)

+ func (s *LimitsDBStorage) Set(data *LimitData) error

+ type LimitsStorage interface

+ Get func(tag string) (*LimitData, error)

+ Set func(data *LimitData) error

+ type RPCLimiterDB struct

+ func NewRPCLimiterDB(db *sql.DB) *RPCLimiterDB

+ func (r *RPCLimiterDB) CreateRPCLimit(limit LimitData) error

+ func (r *RPCLimiterDB) DeleteRPCLimit(tag string) error

+ func (r *RPCLimiterDB) GetRPCLimit(tag string) (*LimitData, error)

+ func (r *RPCLimiterDB) UpdateRPCLimit(limit LimitData) error

+ type RPCRequestLimiter struct

+ func NewRequestLimiter(storage LimitsStorage) *RPCRequestLimiter

+ func (rl *RPCRequestLimiter) Allow(tag string) (bool, error)

+ func (rl *RPCRequestLimiter) GetLimit(tag string) (*LimitData, error)

+ func (rl *RPCRequestLimiter) SetLimit(tag string, maxRequests int, interval time.Duration) error

+ type RPCRpsLimiter struct

+ func NewRPCRpsLimiter() *RPCRpsLimiter

+ func (rl *RPCRpsLimiter) ReduceLimit()

+ func (rl *RPCRpsLimiter) Stop()

+ func (rl *RPCRpsLimiter) WaitForRequestsAvailability(requests int) error

+ type RequestLimiter interface

+ Allow func(tag string) (bool, error)

+ GetLimit func(tag string) (*LimitData, error)

+ SetLimit func(tag string, maxRequests int, interval time.Duration) error

+ type Tagger interface

+ DeepCopyTag func() Tagger

+ GroupTag func() string

+ SetGroupTag func(tag string)

+ SetTag func(tag string)

+ Tag func() string

+ func DeepCopyTagger(t Tagger) Tagger

Mar 5, 2024

Changes in this version

+ var ErrRequestsOverLimit = fmt.Errorf("number of requests over limit")

+ type RPCLimiter struct

+ func NewRPCLimiter() *RPCLimiter

+ func (rl *RPCLimiter) ReduceLimit()

+ func (rl *RPCLimiter) Stop()

+ func (rl *RPCLimiter) WaitForRequestsAvailability(requests int) error

Feb 23, 2024

Changes in this version

type ClientInterface

+ CallBlockHashByTransaction func(ctx context.Context, blockNumber *big.Int, index uint) (common.Hash, error)

type ClientWithFallback

+ func (c *ClientWithFallback) CallBlockHashByTransaction(ctx context.Context, blockNumber *big.Int, index uint) (common.Hash, error)

Oct 3, 2023

Changes in this version

type ClientInterface

+ BlockNumber func(ctx context.Context) (uint64, error)

+ CallContext func(ctx context.Context, result interface{}, method string, args ...interface{}) error

+ CallContract func(ctx context.Context, call ethereum.CallMsg, blockNumber *big.Int) ([]byte, error)

+ CodeAt func(ctx context.Context, contract common.Address, blockNumber *big.Int) ([]byte, error)

+ GetIsConnected func() bool

+ GetWalletNotifier func() func(chainId uint64, message string)

+ SetIsConnected func(value bool)

+ SetWalletNotifier func(notifier func(chainId uint64, message string))

+ TransactionByHash func(ctx context.Context, hash common.Hash) (*types.Transaction, bool, error)

+ TransactionReceipt func(ctx context.Context, txHash common.Hash) (*types.Receipt, error)

type ClientWithFallback

+ func (c *ClientWithFallback) GetIsConnected() bool

+ func (c *ClientWithFallback) GetWalletNotifier() func(chainId uint64, message string)

+ func (c *ClientWithFallback) SetWalletNotifier(notifier func(chainId uint64, message string))

Sep 21, 2023

Changes in this version

+ type BatchCallClient interface

+ BatchCallContext func(ctx context.Context, b []rpc.BatchElem) error

type ClientInterface

+ BalanceAt func(ctx context.Context, account common.Address, blockNumber *big.Int) (*big.Int, error)

+ BlockByHash func(ctx context.Context, hash common.Hash) (*types.Block, error)

+ BlockByNumber func(ctx context.Context, number *big.Int) (*types.Block, error)

+ FilterLogs func(ctx context.Context, q ethereum.FilterQuery) ([]types.Log, error)

+ FullTransactionByBlockNumberAndIndex func(ctx context.Context, blockNumber *big.Int, index uint) (*FullTransaction, error)

+ GetBaseFeeFromBlock func(blockNumber *big.Int) (string, error)

+ HeaderByHash func(ctx context.Context, hash common.Hash) (*types.Header, error)

+ HeaderByNumber func(ctx context.Context, number *big.Int) (*types.Header, error)

+ NetworkID func() uint64

+ NonceAt func(ctx context.Context, account common.Address, blockNumber *big.Int) (uint64, error)

+ ToBigInt func() *big.Int

Aug 29, 2023

Changes in this version

+ type ClientInterface interface

+ BatchCallContext func(ctx context.Context, b []rpc.BatchElem) error

type ClientWithFallback

+ func (c *ClientWithFallback) BatchCallContext(ctx context.Context, b []rpc.BatchElem) error

Jun 8, 2023

Changes in this version

type ClientWithFallback

+ func (c *ClientWithFallback) FullTransactionByBlockNumberAndIndex(ctx context.Context, blockNumber *big.Int, index uint) (*FullTransaction, error)

+ type FullTransaction struct

+ Tx *types.Transaction

+ func (tx *FullTransaction) UnmarshalJSON(msg []byte) error

+ type TxExtraInfo struct

+ BlockHash *common.Hash

+ BlockNumber *hexutil.Big

+ From *common.Address

Apr 5, 2023

Changes in this version

type ClientWithFallback

+ IsConnectedLock sync.RWMutex

+ WalletNotifier func(chainId uint64, message string)

+ func (c *ClientWithFallback) SetIsConnected(value bool)

Mar 30, 2023

Changes in this version

+ type CommandResult struct

Feb 28, 2023

Changes in this version

+ type ClientWithFallback struct

+ ChainID uint64

+ IsConnected bool

+ LastCheckedAt int64

+ func NewClient(main, fallback *rpc.Client, chainID uint64) *ClientWithFallback

+ func NewSimpleClient(main *rpc.Client, chainID uint64) *ClientWithFallback

+ func (c *ClientWithFallback) BalanceAt(ctx context.Context, account common.Address, blockNumber *big.Int) (*big.Int, error)

+ func (c *ClientWithFallback) BlockByHash(ctx context.Context, hash common.Hash) (*types.Block, error)

+ func (c *ClientWithFallback) BlockByNumber(ctx context.Context, number *big.Int) (*types.Block, error)

+ func (c *ClientWithFallback) BlockNumber(ctx context.Context) (uint64, error)

+ func (c *ClientWithFallback) CallContext(ctx context.Context, result interface{}, method string, args ...interface{}) error

+ func (c *ClientWithFallback) CallContract(ctx context.Context, msg ethereum.CallMsg, blockNumber *big.Int) ([]byte, error)

+ func (c *ClientWithFallback) CallContractAtHash(ctx context.Context, msg ethereum.CallMsg, blockHash common.Hash) ([]byte, error)

+ func (c *ClientWithFallback) Close()

+ func (c *ClientWithFallback) CodeAt(ctx context.Context, account common.Address, blockNumber *big.Int) ([]byte, error)

+ func (c *ClientWithFallback) EstimateGas(ctx context.Context, msg ethereum.CallMsg) (uint64, error)

+ func (c *ClientWithFallback) FeeHistory(ctx context.Context, blockCount uint64, lastBlock *big.Int, ...) (*ethereum.FeeHistory, error)

+ func (c *ClientWithFallback) FilterLogs(ctx context.Context, q ethereum.FilterQuery) ([]types.Log, error)

+ func (c *ClientWithFallback) GetBaseFeeFromBlock(blockNumber *big.Int) (string, error)

+ func (c *ClientWithFallback) HeaderByHash(ctx context.Context, hash common.Hash) (*types.Header, error)

+ func (c *ClientWithFallback) HeaderByNumber(ctx context.Context, number *big.Int) (*types.Header, error)

+ func (c *ClientWithFallback) NetworkID(ctx context.Context) (*big.Int, error)

+ func (c *ClientWithFallback) NonceAt(ctx context.Context, account common.Address, blockNumber *big.Int) (uint64, error)

+ func (c *ClientWithFallback) PeerCount(ctx context.Context) (uint64, error)

+ func (c *ClientWithFallback) PendingBalanceAt(ctx context.Context, account common.Address) (*big.Int, error)

+ func (c *ClientWithFallback) PendingCallContract(ctx context.Context, msg ethereum.CallMsg) ([]byte, error)

+ func (c *ClientWithFallback) PendingCodeAt(ctx context.Context, account common.Address) ([]byte, error)

+ func (c *ClientWithFallback) PendingNonceAt(ctx context.Context, account common.Address) (uint64, error)

+ func (c *ClientWithFallback) PendingStorageAt(ctx context.Context, account common.Address, key common.Hash) ([]byte, error)

+ func (c *ClientWithFallback) PendingTransactionCount(ctx context.Context) (uint, error)

+ func (c *ClientWithFallback) SendTransaction(ctx context.Context, tx *types.Transaction) error

+ func (c *ClientWithFallback) StorageAt(ctx context.Context, account common.Address, key common.Hash, ...) ([]byte, error)

+ func (c *ClientWithFallback) SubscribeFilterLogs(ctx context.Context, q ethereum.FilterQuery, ch chan<- types.Log) (ethereum.Subscription, error)

+ func (c *ClientWithFallback) SubscribeNewHead(ctx context.Context, ch chan<- *types.Header) (ethereum.Subscription, error)

+ func (c *ClientWithFallback) SuggestGasPrice(ctx context.Context) (*big.Int, error)

+ func (c *ClientWithFallback) SuggestGasTipCap(ctx context.Context) (*big.Int, error)

+ func (c *ClientWithFallback) SyncProgress(ctx context.Context) (*ethereum.SyncProgress, error)

+ func (c *ClientWithFallback) ToBigInt() *big.Int

+ func (c *ClientWithFallback) TransactionByHash(ctx context.Context, hash common.Hash) (*types.Transaction, bool, error)

+ func (c *ClientWithFallback) TransactionCount(ctx context.Context, blockHash common.Hash) (uint, error)

+ func (c *ClientWithFallback) TransactionInBlock(ctx context.Context, blockHash common.Hash, index uint) (*types.Transaction, error)

+ func (c *ClientWithFallback) TransactionReceipt(ctx context.Context, txHash common.Hash) (*types.Receipt, error)

+ func (c *ClientWithFallback) TransactionSender(ctx context.Context, tx *types.Transaction, block common.Hash, index uint) (common.Address, error)

+ type FeeHistory struct

+ BaseFeePerGas []string