otaindexer

Documentation

Index

• Constants
• Variables
• func GetOTAKeyListMinScannedCoinIndex(keylist map[int][]*OTAkeyInfo) (map[int]uint64, map[int]uint64)
• func GetOTAKeyListMinScannedTxIndex() map[int]string
• func GetUnknownCoinsFromDB(fromPRVIndex, fromTokenIndex map[int]uint64) []shared.CoinData
• func GetWorkerStat(c *gin.Context)
• func ReCheckOTAKey(otaKey, pubKey string, reIndex bool) error
• func StartOTAIndexing()
• func StartWorkerAssigner()
• func WorkerRegisterHandler(c *gin.Context)
• type CoordinatorState
• type OTAAssignRequest
• type OTAkeyInfo
• type WorkerOTACmd

Constants

const (
	REINDEX = "reindex"
	INDEX   = "index"
	RUN     = "run"
)

Variables

var OTAAssignChn chan OTAAssignRequest

var Submitted_OTAKey = struct {
	sync.RWMutex
	Keys        map[string]*OTAkeyInfo
	KeysByShard map[int][]*OTAkeyInfo
	AssignedKey map[string]*worker
	TotalKeys   int
}{}

Functions

func GetOTAKeyListMinScannedCoinIndex

func GetOTAKeyListMinScannedCoinIndex(keylist map[int][]*OTAkeyInfo) (map[int]uint64, map[int]uint64)

func GetOTAKeyListMinScannedTxIndex

func GetOTAKeyListMinScannedTxIndex() map[int]string

func GetUnknownCoinsFromDB

func GetUnknownCoinsFromDB(fromPRVIndex, fromTokenIndex map[int]uint64) []shared.CoinData

func GetWorkerStat

func GetWorkerStat(c *gin.Context)

func ReCheckOTAKey

func ReCheckOTAKey(otaKey, pubKey string, reIndex bool) error

func StartOTAIndexing

func StartOTAIndexing()

func StartWorkerAssigner

func StartWorkerAssigner()

func WorkerRegisterHandler

func WorkerRegisterHandler(c *gin.Context)

Types

type CoordinatorState

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

type OTAAssignRequest

type OTAAssignRequest struct {
	Key     *shared.SubmittedOTAKeyData
	FromNow bool
	Respond chan error
}

type OTAkeyInfo

type OTAkeyInfo struct {
	ShardID int
	Pubkey  string
	OTAKey  string

	KeyInfo *shared.KeyInfoData
	// contains filtered or unexported fields
}

type WorkerOTACmd

type WorkerOTACmd struct {
	Action string
	Key    OTAkeyInfo
}