mocks

Documentation

Index

• type AbigenContract
  • func (_m *AbigenContract) Address() common.Address
  • func (_m *AbigenContract) ParseLog(_a0 types.Log) (generated.AbigenLog, error)
• type Broadcast
  • func (_m *Broadcast) DecodedLog() interface{}
  • func (_m *Broadcast) JobID() log.JobIdSelect
  • func (_m *Broadcast) LatestBlockHash() common.Hash
  • func (_m *Broadcast) LatestBlockNumber() uint64
  • func (_m *Broadcast) RawLog() types.Log
  • func (_m *Broadcast) String() string
• type Broadcaster
  • func (_m *Broadcaster) AddDependents(n int)
  • func (_m *Broadcaster) AwaitDependents() <-chan struct{}
  • func (_m *Broadcaster) BackfillBlockNumber() null.Int64
  • func (_m *Broadcaster) Close() error
  • func (_m *Broadcaster) Connect(head *models.Head) error
  • func (_m *Broadcaster) DependentReady()
  • func (_m *Broadcaster) Healthy() error
  • func (_m *Broadcaster) IsConnected() bool
  • func (_m *Broadcaster) MarkConsumed(db *gorm.DB, lb log.Broadcast) error
  • func (_m *Broadcaster) OnNewLongestChain(ctx context.Context, head models.Head)
  • func (_m *Broadcaster) Ready() error
  • func (_m *Broadcaster) Register(listener log.Listener, opts log.ListenerOpts) func()
  • func (_m *Broadcaster) ReplayFromBlock(number int64)
  • func (_m *Broadcaster) Start() error
  • func (_m *Broadcaster) TrackedAddressesCount() uint32
  • func (_m *Broadcaster) WasAlreadyConsumed(db *gorm.DB, lb log.Broadcast) (bool, error)
• type Listener
  • func (_m *Listener) HandleLog(b log.Broadcast)
  • func (_m *Listener) IsV2Job() bool
  • func (_m *Listener) JobID() models.JobID
  • func (_m *Listener) JobIDV2() int32
• type ORM
  • func (_m *ORM) FindConsumedLogs(fromBlockNum int64, toBlockNum int64) ([]log.LogBroadcast, error)
  • func (_m *ORM) MarkBroadcastConsumed(tx *gorm.DB, blockHash common.Hash, blockNumber uint64, logIndex uint, ...) error
  • func (_m *ORM) WasBroadcastConsumed(tx *gorm.DB, blockHash common.Hash, logIndex uint, jobID log.JobIdSelect) (bool, error)

Types

type AbigenContract

type AbigenContract struct {
	mock.Mock
}

AbigenContract is an autogenerated mock type for the AbigenContract type

func (*AbigenContract) Address

func (_m *AbigenContract) Address() common.Address

Address provides a mock function with given fields:

func (*AbigenContract) ParseLog

func (_m *AbigenContract) ParseLog(_a0 types.Log) (generated.AbigenLog, error)

ParseLog provides a mock function with given fields: _a0

type Broadcast

type Broadcast struct {
	mock.Mock
}

Broadcast is an autogenerated mock type for the Broadcast type

func (*Broadcast) DecodedLog

func (_m *Broadcast) DecodedLog() interface{}

DecodedLog provides a mock function with given fields:

func (*Broadcast) JobID

func (_m *Broadcast) JobID() log.JobIdSelect

JobID provides a mock function with given fields:

func (*Broadcast) LatestBlockHash

func (_m *Broadcast) LatestBlockHash() common.Hash

LatestBlockHash provides a mock function with given fields:

func (*Broadcast) LatestBlockNumber

func (_m *Broadcast) LatestBlockNumber() uint64

LatestBlockNumber provides a mock function with given fields:

func (*Broadcast) RawLog

func (_m *Broadcast) RawLog() types.Log

RawLog provides a mock function with given fields:

func (*Broadcast) String

func (_m *Broadcast) String() string

String provides a mock function with given fields:

type Broadcaster

type Broadcaster struct {
	mock.Mock
}

Broadcaster is an autogenerated mock type for the Broadcaster type

func (*Broadcaster) AddDependents

func (_m *Broadcaster) AddDependents(n int)

AddDependents provides a mock function with given fields: n

func (*Broadcaster) AwaitDependents

func (_m *Broadcaster) AwaitDependents() <-chan struct{}

AwaitDependents provides a mock function with given fields:

func (*Broadcaster) BackfillBlockNumber

func (_m *Broadcaster) BackfillBlockNumber() null.Int64

BackfillBlockNumber provides a mock function with given fields:

func (*Broadcaster) Close

func (_m *Broadcaster) Close() error

Close provides a mock function with given fields:

func (*Broadcaster) Connect

func (_m *Broadcaster) Connect(head *models.Head) error

Connect provides a mock function with given fields: head

func (*Broadcaster) DependentReady

func (_m *Broadcaster) DependentReady()

DependentReady provides a mock function with given fields:

func (*Broadcaster) Healthy

func (_m *Broadcaster) Healthy() error

Healthy provides a mock function with given fields:

func (*Broadcaster) IsConnected

func (_m *Broadcaster) IsConnected() bool

IsConnected provides a mock function with given fields:

func (*Broadcaster) MarkConsumed

func (_m *Broadcaster) MarkConsumed(db *gorm.DB, lb log.Broadcast) error

MarkConsumed provides a mock function with given fields: db, lb

func (*Broadcaster) OnNewLongestChain

func (_m *Broadcaster) OnNewLongestChain(ctx context.Context, head models.Head)

OnNewLongestChain provides a mock function with given fields: ctx, head

func (*Broadcaster) Ready

func (_m *Broadcaster) Ready() error

Ready provides a mock function with given fields:

func (*Broadcaster) Register

func (_m *Broadcaster) Register(listener log.Listener, opts log.ListenerOpts) func()

Register provides a mock function with given fields: listener, opts

func (*Broadcaster) ReplayFromBlock

func (_m *Broadcaster) ReplayFromBlock(number int64)

ReplayFromBlock provides a mock function with given fields: number

func (*Broadcaster) Start

func (_m *Broadcaster) Start() error

Start provides a mock function with given fields:

func (*Broadcaster) TrackedAddressesCount

func (_m *Broadcaster) TrackedAddressesCount() uint32

TrackedAddressesCount provides a mock function with given fields:

func (*Broadcaster) WasAlreadyConsumed

func (_m *Broadcaster) WasAlreadyConsumed(db *gorm.DB, lb log.Broadcast) (bool, error)

WasAlreadyConsumed provides a mock function with given fields: db, lb

type Listener

type Listener struct {
	mock.Mock
}

Listener is an autogenerated mock type for the Listener type

func (*Listener) HandleLog

func (_m *Listener) HandleLog(b log.Broadcast)

HandleLog provides a mock function with given fields: b

func (*Listener) IsV2Job

func (_m *Listener) IsV2Job() bool

IsV2Job provides a mock function with given fields:

func (*Listener) JobID

func (_m *Listener) JobID() models.JobID

JobID provides a mock function with given fields:

func (*Listener) JobIDV2

func (_m *Listener) JobIDV2() int32

JobIDV2 provides a mock function with given fields:

type ORM

type ORM struct {
	mock.Mock
}

ORM is an autogenerated mock type for the ORM type

func (*ORM) FindConsumedLogs

func (_m *ORM) FindConsumedLogs(fromBlockNum int64, toBlockNum int64) ([]log.LogBroadcast, error)

FindConsumedLogs provides a mock function with given fields: fromBlockNum, toBlockNum

func (*ORM) MarkBroadcastConsumed

func (_m *ORM) MarkBroadcastConsumed(tx *gorm.DB, blockHash common.Hash, blockNumber uint64, logIndex uint, jobID log.JobIdSelect) error

MarkBroadcastConsumed provides a mock function with given fields: tx, blockHash, blockNumber, logIndex, jobID

func (*ORM) WasBroadcastConsumed

func (_m *ORM) WasBroadcastConsumed(tx *gorm.DB, blockHash common.Hash, logIndex uint, jobID log.JobIdSelect) (bool, error)

WasBroadcastConsumed provides a mock function with given fields: tx, blockHash, logIndex, jobID