Documentation ¶
Index ¶
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 *LTCBlockData, tx *service.Transaction) error
更新标记block所属矿池
func UpdateBlock ¶
func UpdateBlock(data *LTCBlockData, tx *service.Transaction) error
Types ¶
type CronWorker ¶
type CronWorker struct {
// contains filtered or unexported fields
}
func NewCronWorker ¶
func NewCronWorker(splitter *LTCSplitter) *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 LTCBlockData ¶
type LTCBlockData struct { Block *model.Block Transactions []*model.Transaction VIns []*model.VIn VOuts []*model.VOut }
func ParseBlock ¶
func ParseBlock(data string) (*LTCBlockData, error)
type LTCSplitter ¶
type LTCSplitter struct {
// contains filtered or unexported fields
}
func NewSplitter ¶
func NewSplitter(cfg *SplitterConfig) (*LTCSplitter, error)
func (*LTCSplitter) CheckBlock ¶
func (s *LTCSplitter) CheckBlock(curBlock *LTCBlockData) (bool, int64)
func (*LTCSplitter) RevertBlock ¶
func (s *LTCSplitter) RevertBlock(height int64, tx *service.Transaction) error
revert block by height
func (*LTCSplitter) SaveBlock ¶
func (s *LTCSplitter) SaveBlock(data *LTCBlockData) error
func (*LTCSplitter) Start ¶
func (s *LTCSplitter) Start()
func (*LTCSplitter) Stop ¶
func (s *LTCSplitter) Stop()
type SplitterConfig ¶
Click to show internal directories.
Click to hide internal directories.