subscriber

package

Go to main page

Versions in this module

v0

v0.1.43

Mar 18, 2026

Changes in this version

+ const DefaultConsecutiveZeroLogThreshold

type ChainSubscriber

+ func (cs *ChainSubscriber) SetConsecutiveZeroLogThreshold(n int)

v0.1.42

Mar 13, 2026

v0.1.41

Feb 27, 2026

Changes in this version

type Subscriber

+ SetRetryInterval func(retryInterval time.Duration)

v0.1.40

Feb 26, 2026

Changes in this version

+ func TopicLayoutKey(q ethereum.FilterQuery) string

v0.1.39

Feb 26, 2026

Changes in this version

type ChainSubscriber

+ func (cs *ChainSubscriber) SetMaxQueriesPerMerge(n int)

v0.1.38

Feb 25, 2026

Changes in this version

+ func GetPartitionKey(q ethereum.FilterQuery, fallbackFrom, fallbackTo *big.Int) string

+ func LogMatchesQuery(log *etypes.Log, q ethereum.FilterQuery) bool

+ func MergeFilterQueries(queries []ethereum.FilterQuery, fromBlock, toBlock *big.Int) (ethereum.FilterQuery, error)

+ func MergeFilterQueriesByBlockHash(queries []ethereum.FilterQuery, blockHash common.Hash) (ethereum.FilterQuery, error)

+ func PartitionQueriesByMergeKey(queries []ethereum.FilterQuery, fallbackFrom, fallbackTo *big.Int) [][]ethereum.FilterQuery

v0.1.37

Feb 24, 2026

Changes in this version

+ type LogFiltererBatch interface

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

+ FilterLogsBatch func(ctx context.Context, queries []ethereum.FilterQuery) ([][]etypes.Log, error)

+ func NewBatchLogFilterer(c *ethclient.Client, rpcCli *rpc.Client) LogFiltererBatch

v0.1.36

Jan 23, 2026

v0.1.35

Aug 24, 2025

v0.1.34

Aug 24, 2025

v0.1.33

Aug 24, 2025

v0.1.32

Aug 24, 2025

v0.1.31

Aug 22, 2025

v0.1.30

Aug 20, 2025

v0.1.29

Aug 19, 2025

v0.1.28

Aug 19, 2025

Changes in this version

type Subscriber

+ FilterLogsBatch func(ctx context.Context, queries []ethereum.FilterQuery) (logs [][]etypes.Log, err error)

v0.1.27

Aug 19, 2025

Changes in this version

type ChainSubscriber

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

+ func (cs *ChainSubscriber) FilterLogsBatch(ctx context.Context, queries []ethereum.FilterQuery) (logs [][]etypes.Log, err error)

+ type FilterLogsFunc func(ctx context.Context, q ethereum.FilterQuery) (logs []etypes.Log, err error)

type MemoryStorage

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

type QueryStateReader

+ FilterLogsBatch func(ctx context.Context, queries []ethereum.FilterQuery) (logs [][]etypes.Log, err error)

+ type QueryWithChannel struct

type RedisStorage

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

type Subscriber

+ DeleteQuery func(query ethereum.FilterQuery) error

v0.1.26

Jul 3, 2025

v0.1.25

Jul 3, 2025

v0.1.24

Apr 11, 2025

v0.1.23

Feb 23, 2025

v0.1.22

Feb 23, 2025

v0.1.21

Feb 18, 2025

v0.1.20

Feb 17, 2025

v0.1.19

Feb 17, 2025

v0.1.18

Dec 19, 2024

Changes in this version

type ChainSubscriber

+ func (cs *ChainSubscriber) SubscribeFilterFullPendingTransactions(ctx context.Context, filter FilterTransaction, ch chan<- *etypes.Transaction) (*rpc.ClientSubscription, error)

+ func (cs *ChainSubscriber) SubscribeFilterFullTransactions(ctx context.Context, filter FilterTransaction, ch chan<- *etypes.Transaction) (ethereum.Subscription, error)

+ func (cs *ChainSubscriber) SubscribeFullPendingTransactions(ctx context.Context, ch chan<- *etypes.Transaction) (*rpc.ClientSubscription, error)

+ func (cs *ChainSubscriber) SubscribePendingTransactions(ctx context.Context, ch chan<- common.Hash) (*rpc.ClientSubscription, error)

+ type FilterTransaction struct

+ From []common.Address

+ FromBlock *big.Int

+ MethodSelector []types.MethodSelector

+ To []common.Address

+ ToBlock *big.Int

type Subscriber

+ SubscribeFilterFullPendingTransactions func(ctx context.Context, filter FilterTransaction, ch chan<- *etypes.Transaction) (*rpc.ClientSubscription, error)

+ SubscribeFilterFullTransactions func(ctx context.Context, filter FilterTransaction, ch chan<- *etypes.Transaction) (ethereum.Subscription, error)

+ SubscribeFullPendingTransactions func(ctx context.Context, ch chan<- *etypes.Transaction) (*rpc.ClientSubscription, error)

+ SubscribePendingTransactions func(ctx context.Context, ch chan<- common.Hash) (*rpc.ClientSubscription, error)

v0.1.17

Dec 9, 2024

v0.1.16

Dec 5, 2024

v0.1.15

Nov 17, 2024

v0.1.14

Nov 17, 2024

v0.1.13

Nov 17, 2024

v0.1.12

Nov 17, 2024

v0.1.11

Nov 16, 2024

Changes in this version

type ChainSubscriber

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

type Subscriber

+ SetFetchMissingHeaders func(enable bool)

v0.1.10

Nov 4, 2024

v0.1.9

Nov 4, 2024

v0.1.8

Nov 4, 2024

v0.1.7

Nov 1, 2024

v0.1.6

Nov 1, 2024

v0.1.5

Nov 1, 2024

v0.1.4

Oct 29, 2024

Changes in this version

type ChainSubscriber

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

v0.1.3

Oct 22, 2024

v0.1.2

Oct 22, 2024

v0.1.1

Oct 22, 2024

v0.1.0

Oct 14, 2024

v0.0.11

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)

v0.0.10

Sep 21, 2024

Changes in this version

type ChainSubscriber

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

type Subscriber

+ SetBuffer func(buffer int)

v0.0.9

Sep 21, 2024

Changes in this version

type ChainSubscriber

+ func (cs *ChainSubscriber) GetQueryHandler() QueryHandler

type Subscriber

+ GetQueryHandler func() QueryHandler

v0.0.8

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

v0.0.7

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

v0.0.6

Sep 19, 2024

Changes in this version

type ChainSubscriber

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

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

v0.0.5

Sep 19, 2024

v0.0.4

Sep 19, 2024

v0.0.3

Sep 17, 2024

v0.0.2

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)

v0.0.1

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

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