Versions in this module Expand all Collapse all v2 v2.4.0 Nov 13, 2024 v2.3.0 Nov 13, 2024 v2.1.1 Nov 13, 2024 v2.1.0 Nov 11, 2024 Changes in this version + type Listener struct + BlockNumberToReqID *pairing.PairHeap + Cfg vrfcommon.Config + ChStop services.StopChan + Chain legacyevm.Chain + Coordinator *solidity_vrf_coordinator_interface.VRFCoordinator + Deduper *vrfcommon.LogDeduper + FeeCfg vrfcommon.FeeConfig + GethKs vrfcommon.GethKeyStore + Job job.Job + L logger.SugaredLogger + LatestHead uint64 + LatestHeadMu sync.RWMutex + MailMon *mailbox.Monitor + NewHead chan struct{} + PipelineRunner pipeline.Runner + Q pg.Q + ReqAdded func() + ReqLogs *mailbox.Mailbox[log.Broadcast] + Reqs []request + ReqsMu sync.Mutex + RespCountMu sync.Mutex + ResponseCount map[[32]byte]uint64 + WaitOnStop chan struct{} + func (lsn *Listener) Close() error + func (lsn *Listener) GetStartingResponseCountsV1(ctx context.Context) (respCount map[[32]byte]uint64, err error) + func (lsn *Listener) HandleLog(lb log.Broadcast) + func (lsn *Listener) JobID() int32 + func (lsn *Listener) OnNewLongestChain(_ context.Context, head *evmtypes.Head) + func (lsn *Listener) ProcessRequest(ctx context.Context, req request) bool + func (lsn *Listener) ReplayStartedCallback() + func (lsn *Listener) ReqsConfirmedAt() (us []uint64) + func (lsn *Listener) RespCount(reqIDBytes [32]byte) uint64 + func (lsn *Listener) RunHeadListener(unsubscribe func()) + func (lsn *Listener) RunLogListener(unsubscribes []func(), minConfs uint32) + func (lsn *Listener) SetReqAdded(fn func()) + func (lsn *Listener) SetRespCount(reqIDBytes [32]byte, c uint64) + func (lsn *Listener) Start(ctx context.Context) error + func (lsn *Listener) Stop(t *testing.T)
Go to main page