syncer

Documentation

Index

• type ChainEventReceiver
• type ChainOperator
• type OgChainSyncer
  • func (o *OgChainSyncer) Name() string
  • func (o *OgChainSyncer) QueryHeight() (int64, error)
  • func (o *OgChainSyncer) Start()
  • func (o *OgChainSyncer) Stop()
• type WebsocketInfoReceiver
  • func (w WebsocketInfoReceiver) Name() string
  • func (w WebsocketInfoReceiver) Start()
  • func (w WebsocketInfoReceiver) Stop()

Types

type ChainEventReceiver

type ChainEventReceiver interface {
	Connect()
	EventChannel() chan int64 // Maybe you will pass a more complicate object in the channel

}

ChainEventReceiver is the pushing way to receive the latest sequencer

type ChainOperator

type ChainOperator interface {
	QueryHeight() (int64, error)
}

ChainOperator is the pulling way to query the latest sequencer and txs.

type OgChainSyncer

type OgChainSyncer struct {

	// table: op
	MaxSyncedHeight int64
	ChainOperator   ChainOperator
	InfoReceiver    ChainEventReceiver
	// contains filtered or unexported fields
}

func (*OgChainSyncer) Name

func (o *OgChainSyncer) Name() string

func (*OgChainSyncer) QueryHeight

func (o *OgChainSyncer) QueryHeight() (int64, error)

func (*OgChainSyncer) Start

func (o *OgChainSyncer) Start()

func (*OgChainSyncer) Stop

func (o *OgChainSyncer) Stop()

type WebsocketInfoReceiver

type WebsocketInfoReceiver struct {
}

func (WebsocketInfoReceiver) Name

func (w WebsocketInfoReceiver) Name() string

func (WebsocketInfoReceiver) Start

func (w WebsocketInfoReceiver) Start()

func (WebsocketInfoReceiver) Stop

func (w WebsocketInfoReceiver) Stop()