mock

Documentation

Index

• func NewWatcherRunnable(msgC chan<- *common.MessagePublication, ...) supervisor.Runnable
• type MockL1Finalizer
  • func (f MockL1Finalizer) GetLatestFinalizedBlockNumber() uint64
• type ObservationDb
• type WatcherConfig
  • func (wc *WatcherConfig) Create(msgC chan<- *common.MessagePublication, ...) (interfaces.L1Finalizer, supervisor.Runnable, error)
  • func (wc *WatcherConfig) GetChainID() vaa.ChainID
  • func (wc *WatcherConfig) GetNetworkID() watchers.NetworkID
  • func (wc *WatcherConfig) RequiredL1Finalizer() watchers.NetworkID
  • func (wc *WatcherConfig) SetL1Finalizer(l1finalizer interfaces.L1Finalizer)

Functions

func NewWatcherRunnable

func NewWatcherRunnable(
	msgC chan<- *common.MessagePublication,
	obsvReqC <-chan *gossipv1.ObservationRequest,
	setC chan<- *common.GuardianSet,
	c *WatcherConfig,
) supervisor.Runnable

Types

type MockL1Finalizer

type MockL1Finalizer struct{}

func (MockL1Finalizer) GetLatestFinalizedBlockNumber

func (f MockL1Finalizer) GetLatestFinalizedBlockNumber() uint64

type ObservationDb

type ObservationDb map[eth_common.Hash]*common.MessagePublication

type WatcherConfig

type WatcherConfig struct {
	NetworkID           watchers.NetworkID              // human readable name
	ChainID             vaa.ChainID                     // ChainID
	MockObservationC    chan *common.MessagePublication // Channel to feed this watcher mock observations that it will then make
	ObservationDb       ObservationDb                   // If the watcher receives a re-observation request with a TxHash in this map, it will make the corresponding observation in this map.
	MockSetC            <-chan *common.GuardianSet
	L1FinalizerRequired watchers.NetworkID // (optional)
	// contains filtered or unexported fields
}

The Mock Watcher is a watcher that will make a new observation

func (*WatcherConfig) Create

func (wc *WatcherConfig) Create(
	msgC chan<- *common.MessagePublication,
	obsvReqC <-chan *gossipv1.ObservationRequest,
	_ <-chan *query.PerChainQueryInternal,
	_ chan<- *query.PerChainQueryResponseInternal,
	setC chan<- *common.GuardianSet,
	env common.Environment,
) (interfaces.L1Finalizer, supervisor.Runnable, error)

func (*WatcherConfig) GetChainID

func (wc *WatcherConfig) GetChainID() vaa.ChainID

func (*WatcherConfig) GetNetworkID

func (wc *WatcherConfig) GetNetworkID() watchers.NetworkID

func (*WatcherConfig) RequiredL1Finalizer

func (wc *WatcherConfig) RequiredL1Finalizer() watchers.NetworkID

func (*WatcherConfig) SetL1Finalizer

func (wc *WatcherConfig) SetL1Finalizer(l1finalizer interfaces.L1Finalizer)