index

Documentation

Index

• type Indexer
  • func NewIndexer(store IndexerStore, l1url string, l1ConfirmBlocks int, taskInterval string, ...) (Indexer, error)
  • func (o Indexer) ObserveMessageHashAppended(scannedHeight uint64)
  • func (o Indexer) Start()
  • func (o Indexer) Stop()
• type IndexerStore
• type MessageHashInfo
• type MessageHashStore
• type ScanHeightStore

Types

type Indexer

type Indexer struct {
	// contains filtered or unexported fields
}

func NewIndexer

func NewIndexer(store IndexerStore, l1url string, l1ConfirmBlocks int, taskInterval string, l1StartBlockNumber uint64) (Indexer, error)

func (Indexer) ObserveMessageHashAppended

func (o Indexer) ObserveMessageHashAppended(scannedHeight uint64)

func (Indexer) Start

func (o Indexer) Start()

func (Indexer) Stop

func (o Indexer) Stop()

type IndexerStore

type IndexerStore interface {
	MessageHashStore
	ScanHeightStore
}

type MessageHashInfo

type MessageHashInfo struct {
	MessageHash  string   `json:"message_hash"`
	ElectionId   uint64   `json:"election_id"`
	AbsentNodes  []string `json:"absent_nodes"`
	WorkingNodes []string `json:"working_nodes"`
	BatchIndex   uint64   `json:"batch_index"`
}

type MessageHashStore

type MessageHashStore interface {
	SetMessageHash(MessageHashInfo) error
	GetMessageHash([32]byte) (bool, MessageHashInfo)
	IndexMessageHash(uint64, [32]byte) error
	GetIndexMessageHash(index uint64) (bool, [32]byte)
}

type ScanHeightStore

type ScanHeightStore interface {
	UpdateHeight(uint64) error
	GetScannedHeight() (uint64, error)
}