mocks

Documentation

Index

• type Broadcast
  • func (_m *Broadcast) DecodedLog() interface{}
  • func (_m *Broadcast) MarkConsumed() error
  • func (_m *Broadcast) RawLog() types.Log
  • func (_m *Broadcast) SetDecodedLog(_a0 interface{})
  • func (_m *Broadcast) WasAlreadyConsumed() (bool, error)
• type Broadcaster
  • func (_m *Broadcaster) AddDependents(n int)
  • func (_m *Broadcaster) AwaitDependents() <-chan struct{}
  • func (_m *Broadcaster) DependentReady()
  • func (_m *Broadcaster) Register(address common.Address, listener log.Listener) bool
  • func (_m *Broadcaster) Start() error
  • func (_m *Broadcaster) Stop() error
  • func (_m *Broadcaster) Unregister(address common.Address, listener log.Listener)
• type Listener
  • func (_m *Listener) HandleLog(lb log.Broadcast, err error)
  • func (_m *Listener) IsV2Job() bool
  • func (_m *Listener) JobID() models.JobID
  • func (_m *Listener) JobIDV2() int32
  • func (_m *Listener) OnConnect()
  • func (_m *Listener) OnDisconnect()
• type ORM
  • func (_m *ORM) DeleteLogAndBroadcasts(blockHash common.Hash, logIndex uint) error
  • func (_m *ORM) DeleteUnconsumedBroadcastsForListener(jobID interface{}) error
  • func (_m *ORM) MarkBroadcastConsumed(blockHash common.Hash, logIndex uint, jobID interface{}) error
  • func (_m *ORM) UnconsumedLogsPriorToBlock(blockNumber uint64) ([]types.Log, error)
  • func (_m *ORM) UpsertBroadcastForListener(_a0 types.Log, jobID interface{}) error
  • func (_m *ORM) UpsertBroadcastsForListenerSinceBlock(blockNumber uint64, address common.Address, jobID interface{}) error
  • func (_m *ORM) UpsertLog(_a0 types.Log) error
  • func (_m *ORM) WasBroadcastConsumed(blockHash common.Hash, logIndex uint, jobID interface{}) (bool, error)

Types

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) MarkConsumed

func (_m *Broadcast) MarkConsumed() error

MarkConsumed 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) SetDecodedLog

func (_m *Broadcast) SetDecodedLog(_a0 interface{})

SetDecodedLog provides a mock function with given fields: _a0

func (*Broadcast) WasAlreadyConsumed

func (_m *Broadcast) WasAlreadyConsumed() (bool, error)

WasAlreadyConsumed 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) DependentReady

func (_m *Broadcaster) DependentReady()

DependentReady provides a mock function with given fields:

func (*Broadcaster) Register

func (_m *Broadcaster) Register(address common.Address, listener log.Listener) bool

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

func (*Broadcaster) Start

func (_m *Broadcaster) Start() error

Start provides a mock function with given fields:

func (*Broadcaster) Stop

func (_m *Broadcaster) Stop() error

Stop provides a mock function with given fields:

func (*Broadcaster) Unregister

func (_m *Broadcaster) Unregister(address common.Address, listener log.Listener)

Unregister provides a mock function with given fields: address, listener

type Listener

type Listener struct {
	mock.Mock
}

Listener is an autogenerated mock type for the Listener type

func (*Listener) HandleLog

func (_m *Listener) HandleLog(lb log.Broadcast, err error)

HandleLog provides a mock function with given fields: lb, err

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:

func (*Listener) OnConnect

func (_m *Listener) OnConnect()

OnConnect provides a mock function with given fields:

func (*Listener) OnDisconnect

func (_m *Listener) OnDisconnect()

OnDisconnect 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) DeleteLogAndBroadcasts

func (_m *ORM) DeleteLogAndBroadcasts(blockHash common.Hash, logIndex uint) error

DeleteLogAndBroadcasts provides a mock function with given fields: blockHash, logIndex

func (*ORM) DeleteUnconsumedBroadcastsForListener

func (_m *ORM) DeleteUnconsumedBroadcastsForListener(jobID interface{}) error

DeleteUnconsumedBroadcastsForListener provides a mock function with given fields: jobID

func (*ORM) MarkBroadcastConsumed

func (_m *ORM) MarkBroadcastConsumed(blockHash common.Hash, logIndex uint, jobID interface{}) error

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

func (*ORM) UnconsumedLogsPriorToBlock

func (_m *ORM) UnconsumedLogsPriorToBlock(blockNumber uint64) ([]types.Log, error)

UnconsumedLogsPriorToBlock provides a mock function with given fields: blockNumber

func (*ORM) UpsertBroadcastForListener

func (_m *ORM) UpsertBroadcastForListener(_a0 types.Log, jobID interface{}) error

UpsertBroadcastForListener provides a mock function with given fields: _a0, jobID

func (*ORM) UpsertBroadcastsForListenerSinceBlock

func (_m *ORM) UpsertBroadcastsForListenerSinceBlock(blockNumber uint64, address common.Address, jobID interface{}) error

UpsertBroadcastsForListenerSinceBlock provides a mock function with given fields: blockNumber, address, jobID

func (*ORM) UpsertLog

func (_m *ORM) UpsertLog(_a0 types.Log) error

UpsertLog provides a mock function with given fields: _a0

func (*ORM) WasBroadcastConsumed

func (_m *ORM) WasBroadcastConsumed(blockHash common.Hash, logIndex uint, jobID interface{}) (bool, error)

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