subscriber

Nov 16, 2024

Changes in this version

type ChainSubscriber

+ func (cs *ChainSubscriber) SetFetchMissingHeaders(enable bool)

type Subscriber

+ SetFetchMissingHeaders func(enable bool)

Oct 29, 2024

Changes in this version

type ChainSubscriber

+ func (s *ChainSubscriber) SetMaxBlocksPerScan(maxBlocksPerScan uint64)

Sep 27, 2024

Changes in this version

type MemoryStorage

+ func (s *MemoryStorage) FilterLogs(ctx context.Context, q ethereum.FilterQuery) (logs []types.Log, err error)

+ func (s *MemoryStorage) IsFilterLogsSupported(q ethereum.FilterQuery) bool

+ func (s *MemoryStorage) SaveFilterLogs(q ethereum.FilterQuery, logs []types.Log) (err error)

type QueryStateReader

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

+ IsFilterLogsSupported func(q ethereum.FilterQuery) bool

type QueryStateWriter

+ SaveFilterLogs func(q ethereum.FilterQuery, logs []types.Log) (err error)

type RedisStorage

+ func (s *RedisStorage) FilterLogs(ctx context.Context, q ethereum.FilterQuery) (logs []types.Log, err error)

+ func (s *RedisStorage) IsFilterLogsSupported(q ethereum.FilterQuery) bool

+ func (s *RedisStorage) SaveFilterLogs(q ethereum.FilterQuery, logs []types.Log) (err error)

Sep 21, 2024

Changes in this version

type ChainSubscriber

+ func (cs *ChainSubscriber) SetBuffer(buffer int)

type Subscriber

+ SetBuffer func(buffer int)

Sep 21, 2024

Changes in this version

type ChainSubscriber

+ func (cs *ChainSubscriber) GetQueryHandler() QueryHandler

type Subscriber

+ GetQueryHandler func() QueryHandler

Sep 21, 2024

Changes in this version

+ type Query struct

+ ChainID *big.Int

+ func NewQuery(chainId *big.Int, q ethereum.FilterQuery) Query

+ func (q Query) Hash() common.Hash

Sep 20, 2024

Changes in this version

type ChainSubscriber

+ func (cs *ChainSubscriber) SetQueryHandler(handler QueryHandler)

+ func (cs *ChainSubscriber) SubmitQuery(query ethereum.FilterQuery) error

+ func (s *ChainSubscriber) Close()

+ type QueryHandler interface

+ HandleQuery func(ctx context.Context, query ethereum.FilterQuery, log types.Log) error

+ type QueryStateReader interface

+ LatestBlockForQuery func(ctx context.Context, query ethereum.FilterQuery) (uint64, error)

+ LatestLogForQuery func(ctx context.Context, query ethereum.FilterQuery) (types.Log, error)

+ type QueryStateWriter interface

+ SaveLatestBlockForQuery func(ctx context.Context, query ethereum.FilterQuery, blockNum uint64) error

+ SaveLatestLogForQuery func(ctx context.Context, query ethereum.FilterQuery, log types.Log) error

type Subscriber

+ Close func()

+ SetQueryHandler func(handler QueryHandler)

+ SubmitQuery func(query ethereum.FilterQuery) error

Sep 19, 2024

Changes in this version

type ChainSubscriber

+ func (s *ChainSubscriber) SetBlocksPerScan(blocksPerScan uint64)

+ func (s *ChainSubscriber) SetRetryInterval(retryInterval time.Duration)

Sep 17, 2024

Changes in this version

+ func GetQueryHash(query ethereum.FilterQuery) common.Hash

type ChainSubscriber

+ func (cs *ChainSubscriber) GetBlockConfirmationsOnSubscription() uint64

+ func (cs *ChainSubscriber) SetBlockConfirmationsOnSubscription(confirmations uint64)

type Subscriber

+ GetBlockConfirmationsOnSubscription func() uint64

+ SetBlockConfirmationsOnSubscription func(confirmations uint64)

Sep 14, 2024

Changes in this version

+ func GetQueryKey(query ethereum.FilterQuery) string

+ type ChainSubscriber struct

+ func NewChainSubscriber(c *ethclient.Client, storage SubscriberStorage) (*ChainSubscriber, error)

+ func (cs *ChainSubscriber) FilterLogs(ctx context.Context, q ethereum.FilterQuery) (logs []types.Log, err error)

+ func (cs *ChainSubscriber) FilterLogsWithChannel(ctx context.Context, q ethereum.FilterQuery, logsChan chan<- types.Log, ...) (err error)

+ func (cs *ChainSubscriber) SubscribeFilterLogs(ctx context.Context, q ethereum.FilterQuery, ch chan<- types.Log) (sub ethereum.Subscription, err error)

+ func (cs *ChainSubscriber) SubscribeNewHead(ctx context.Context, ch chan<- *types.Header) error

+ type MemoryStorage struct

+ func NewMemoryStorage() *MemoryStorage

+ func (s *MemoryStorage) LatestBlockForQuery(ctx context.Context, query ethereum.FilterQuery) (uint64, error)

+ func (s *MemoryStorage) LatestLogForQuery(ctx context.Context, query ethereum.FilterQuery) (types.Log, error)

+ func (s *MemoryStorage) SaveLatestBlockForQuery(ctx context.Context, query ethereum.FilterQuery, blockNum uint64) error

+ func (s *MemoryStorage) SaveLatestLogForQuery(ctx context.Context, query ethereum.FilterQuery, log types.Log) error

+ type RedisStorage struct

+ func NewRedisStorage(pool redis.Pool) *RedisStorage

+ func (s *RedisStorage) LatestBlockForQuery(ctx context.Context, query ethereum.FilterQuery) (uint64, error)

+ func (s *RedisStorage) LatestLogForQuery(ctx context.Context, query ethereum.FilterQuery) (types.Log, error)

+ func (s *RedisStorage) QueryLock(q ethereum.FilterQuery) sync.Locker

+ func (s *RedisStorage) SaveLatestBlockForQuery(ctx context.Context, query ethereum.FilterQuery, blockNum uint64) error

+ func (s *RedisStorage) SaveLatestLogForQuery(ctx context.Context, query ethereum.FilterQuery, log types.Log) error

+ type Subscriber interface

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

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

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

+ type SubscriberStorage interface

+ LatestBlockForQuery func(ctx context.Context, query ethereum.FilterQuery) (uint64, error)

+ LatestLogForQuery func(ctx context.Context, query ethereum.FilterQuery) (types.Log, error)

+ SaveLatestBlockForQuery func(ctx context.Context, query ethereum.FilterQuery, blockNum uint64) error

+ SaveLatestLogForQuery func(ctx context.Context, query ethereum.FilterQuery, log types.Log) error