Documentation ¶
Index ¶
- Constants
- func GetBlockMiner(data *DOGEBlockData, tx *service.Transaction) error
- func UpdateBlock(data *DOGEBlockData, tx *service.Transaction) error
- type CronWorker
- type DOGEBlockData
- type DOGESplitter
- func (s *DOGESplitter) CheckBlock(curBlock *DOGEBlockData) (bool, int64)
- func (s *DOGESplitter) CheckMissedBlock() ([]int64, error)
- func (s *DOGESplitter) RevertBlock(height int64, tx *service.Transaction) error
- func (s *DOGESplitter) SaveBlock(data *DOGEBlockData) error
- func (s *DOGESplitter) Start()
- func (s *DOGESplitter) Stop()
- type SplitterConfig
- type WorkerJob
Constants ¶
View Source
const ( MetricReceiveMessages = "receive_messages" MetricParseDataError = "parse_data_error" MetricVaildationSuccess = "validation_success" MetricVaildationError = "validation_error" MetricDatabaseRollback = "database_rollback" MetricDatabaseCommit = "database_commit" MetricCronWorkerJob = "cron_worker_job" MetricCronWorkerJobGetBatchBlock = "cron_worker_job_get_batch_block" MetricCronWorkerJobUpdateMetaData = "cron_worker_job_update_meta_data" MetricRPCCall = "rpc_call" MetricRevertBlock = "revert_block" )
Variables ¶
This section is empty.
Functions ¶
func GetBlockMiner ¶
func GetBlockMiner(data *DOGEBlockData, tx *service.Transaction) error
更新标记block所属矿池
func UpdateBlock ¶
func UpdateBlock(data *DOGEBlockData, tx *service.Transaction) error
Types ¶
type CronWorker ¶
type CronWorker struct {
// contains filtered or unexported fields
}
func NewCronWorker ¶
func NewCronWorker(splitter *DOGESplitter) *CronWorker
func (*CronWorker) Prepare ¶
func (w *CronWorker) Prepare() error
func (*CronWorker) Start ¶
func (w *CronWorker) Start() error
func (*CronWorker) Stop ¶
func (w *CronWorker) Stop()
type DOGEBlockData ¶
type DOGEBlockData struct { Block *model.Block Transactions []*model.Transaction VIns []*model.VIn VOuts []*model.VOut }
func ParseBlock ¶
func ParseBlock(data string) (*DOGEBlockData, error)
type DOGESplitter ¶
type DOGESplitter struct {
// contains filtered or unexported fields
}
func NewSplitter ¶
func NewSplitter(cfg *SplitterConfig) (*DOGESplitter, error)
func (*DOGESplitter) CheckBlock ¶
func (s *DOGESplitter) CheckBlock(curBlock *DOGEBlockData) (bool, int64)
func (*DOGESplitter) CheckMissedBlock ¶
func (s *DOGESplitter) CheckMissedBlock() ([]int64, error)
check json schema
func (*DOGESplitter) RevertBlock ¶
func (s *DOGESplitter) RevertBlock(height int64, tx *service.Transaction) error
revert block by height
func (*DOGESplitter) SaveBlock ¶
func (s *DOGESplitter) SaveBlock(data *DOGEBlockData) error
func (*DOGESplitter) Start ¶
func (s *DOGESplitter) Start()
func (*DOGESplitter) Stop ¶
func (s *DOGESplitter) Stop()
type SplitterConfig ¶
Click to show internal directories.
Click to hide internal directories.