tron

package

v1.1.0 Latest Latest Go to latest Published: Jul 26, 2019 License: Apache-2.0 Imports: 17 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/jdcloud-bds/bds

Documentation ¶

Index ¶

Constants
type CronWorker
- func NewCronWorker(splitter *TRONSplitter) *CronWorker
type SplitterConfig
type TRONBlockData
- func ParseBlock(data string) (*TRONBlockData, error)
type TRONSplitter
- func NewSplitter(cfg *SplitterConfig) (*TRONSplitter, error)
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"
	MetricCronWorkerJobUpdateMetaData = "cron_worker_job_update_meta_data"
	MetricRPCCall                     = "rpc_call"
	MetricRevertBlock                 = "revert_block"
)

View Source

const (
	AccountCreateContract         = "AccountCreateContract"
	TransferContract              = "TransferContract"
	TransferAssetContract         = "TransferAssetContract"
	VoteAssetContract             = "VoteAssetContract"
	VoteWitnessContract           = "VoteWitnessContract"
	WitnessCreateContract         = "WitnessCreateContract"
	AssetIssueContract            = "AssetIssueContract"
	WitnessUpdateContract         = "WitnessUpdateContract"
	ParticipateAssetIssueContract = "ParticipateAssetIssueContract"
	AccountUpdateContract         = "AccountUpdateContract"
	FreezeBalanceContract         = "FreezeBalanceContract"
	UnfreezeBalanceContract       = "UnfreezeBalanceContract"
	WithdrawBalanceContract       = "WithdrawBalanceContract"
	UnfreezeAssetContract         = "UnfreezeAssetContract"
	UpdateAssetContract           = "UpdateAssetContract"
	ProposalCreateContract        = "ProposalCreateContract"
	ProposalApproveContract       = "ProposalApproveContract"
	ProposalDeleteContract        = "ProposalDeleteContract"
	SetAccountIdContract          = "SetAccountIdContract"
	CustomContract                = "CustomContract"
	CreateSmartContract           = "CreateSmartContract"
	TriggerSmartContract          = "TriggerSmartContract"
	GetContract                   = "GetContract"
	UpdateSettingContract         = "UpdateSettingContract"
	ExchangeCreateContract        = "ExchangeCreateContract"
	ExchangeInjectContract        = "ExchangeInjectContract"
	ExchangeWithdrawContract      = "ExchangeWithdrawContract"
	ExchangeTransactionContract   = "ExchangeTransactionContract"
	UpdateEnergyLimitContract     = "UpdateEnergyLimitContract"
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type CronWorker ¶

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

func NewCronWorker ¶

func NewCronWorker(splitter *TRONSplitter) *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 SplitterConfig ¶

type SplitterConfig struct {
	Engine                     *xorm.Engine
	Consumer                   *kafka.ConsumerGroup
	Topic                      string
	DatabaseEnable             bool
	ConcurrentHeight           int
	DatabaseWorkerBuffer       int
	DatabaseWorkerNumber       int
	SkipHeight                 int
	SkipMissBlock              bool
	MaxBatchBlock              int
	Endpoint                   string
	User                       string
	Password                   string
	JSONSchemaFile             string
	JSONSchemaValidationEnable bool
}

type TRONBlockData ¶

type TRONBlockData struct {
	Block        *model.Block
	Transactions []*model.Transaction
}

func ParseBlock ¶

func ParseBlock(data string) (*TRONBlockData, error)

type TRONSplitter ¶

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

func NewSplitter ¶

func NewSplitter(cfg *SplitterConfig) (*TRONSplitter, error)

func (*TRONSplitter) CheckBlock ¶

func (s *TRONSplitter) CheckBlock(curBlock *TRONBlockData) bool

func (*TRONSplitter) CheckMissedBlock ¶

func (s *TRONSplitter) CheckMissedBlock() ([]int64, error)

func (*TRONSplitter) CheckReversal ¶

func (s *TRONSplitter) CheckReversal(curBlock *TRONBlockData) (error, bool)

func (*TRONSplitter) CheckWorkMode ¶

func (s *TRONSplitter) CheckWorkMode() error

func (*TRONSplitter) ConcurrentGetBlock ¶

func (s *TRONSplitter) ConcurrentGetBlock() error

func (*TRONSplitter) ConcurrentRPCWorker ¶

func (s *TRONSplitter) ConcurrentRPCWorker()

func (*TRONSplitter) ConcurrentStop ¶

func (s *TRONSplitter) ConcurrentStop()

func (*TRONSplitter) GetMissBlock ¶

func (s *TRONSplitter) GetMissBlock() error

func (*TRONSplitter) RevertBlock ¶

func (s *TRONSplitter) RevertBlock(num int64, tx *service.Transaction) error

func (*TRONSplitter) SaveBlock ¶

func (s *TRONSplitter) SaveBlock(data *TRONBlockData) error

func (*TRONSplitter) Start ¶

func (s *TRONSplitter) Start()

func (*TRONSplitter) Stop ¶

func (s *TRONSplitter) Stop()

type WorkerJob ¶

type WorkerJob interface {
	Run()
	Name() string
	// contains filtered or unexported methods
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL