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 ¶
View Source
const ( REINDEX = "reindex" INDEX = "index" RUN = "run" )
Variables ¶
View Source
var OTAAssignChn chan OTAAssignRequest
View Source
var Submitted_OTAKey = struct { sync.RWMutex Keys map[string]*OTAkeyInfo KeysByShard map[int][]*OTAkeyInfo AssignedKey map[string]*worker TotalKeys int }{}
Functions ¶
func GetOTAKeyListMinScannedTxIndex ¶ added in v1.8.0
func GetUnknownCoinsFromDB ¶
func GetWorkerStat ¶ added in v1.1.0
func ReCheckOTAKey ¶ added in v1.8.0
func StartOTAIndexing ¶
func StartOTAIndexing()
func StartWorkerAssigner ¶
func StartWorkerAssigner()
func WorkerRegisterHandler ¶
Types ¶
type CoordinatorState ¶ added in v1.8.0
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
}
Source Files
Click to show internal directories.
Click to hide internal directories.