eos

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 *EOSSplitter) *CronWorker
type EOSBlockData
- func ParseBlock(data string) (*EOSBlockData, error)
type EOSSplitter
- func NewSplitter(cfg *SplitterConfig) (*EOSSplitter, error)
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"
	MetricCronWorkerJobUpdateMetaData           = "cron_worker_job_update_meta_data"
	MetricCronWorkerJobRefreshContractAddresses = "cron_worker_job_refresh_contract_addresses"
	MetricCronWorkerJobRefreshPoolName          = "cron_worker_job_refresh_pool_name"
	MetricRPCCall                               = "rpc_call"
	MetricRevertBlock                           = "revert_block"
	TimeYmdHmssFormatISO                        = "2006-01-02T15:04:05.000"
)

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 *EOSSplitter) *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 EOSBlockData ¶

type EOSBlockData struct {
	Block        *model.Block
	Transactions []*model.Transaction
	Actions      []*model.Action
}

func ParseBlock ¶

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

type EOSSplitter ¶

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

func NewSplitter ¶

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

func (*EOSSplitter) CheckBlock ¶

func (s *EOSSplitter) CheckBlock(curBlock *EOSBlockData) bool

func (*EOSSplitter) RevertBlock ¶

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

func (*EOSSplitter) Start ¶

func (s *EOSSplitter) Start()

func (*EOSSplitter) Stop ¶

func (s *EOSSplitter) Stop()

type SplitterConfig ¶

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

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