xrp

package

v1.1.0 Latest Latest Go to latest Published: Jul 26, 2019 License: Apache-2.0 Imports: 21 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
func FormatAmount(transaction *model.Transaction, input string) *model.Amount
type CompleteLedgers
type CronWorker
- func NewCronWorker(splitter *XRPSplitter) *CronWorker
type SplitterConfig
type WorkerJob
type XRPBlockData
- func ParseBlock(data string) (*XRPBlockData, error)
type XRPSplitter
- func NewSplitter(cfg *SplitterConfig) (*XRPSplitter, error)

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"
	MetricCronWorkerJobGetBatchBlock            = "cron_worker_job_get_batch_block"
	MetricCronWorkerJobRefreshContractAddresses = "cron_worker_job_refresh_contract_addresses"
	MetricCronWorkerJobRefreshPoolName          = "cron_worker_job_refresh_pool_name"
	MetricRPCCall                               = "rpc_call"
	MetricRevertBlock                           = "revert_block"

	AccountTypeNormal   = 0
	AccountTypeContract = 1
	AccountTypeMiner    = 2

	TransactionTypeNormal   = 0
	TransactionTypeContract = 1
)

Variables ¶

This section is empty.

Functions ¶

func FormatAmount ¶

func FormatAmount(transaction *model.Transaction, input string) *model.Amount

Types ¶

type CompleteLedgers ¶

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

type CronWorker ¶

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

func NewCronWorker ¶

func NewCronWorker(splitter *XRPSplitter) *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
	MaxBatchBlock              int
	Endpoint                   string
	User                       string
	Password                   string
	JSONSchemaFile             string
	JSONSchemaValidationEnable bool
	DatabaseWorkerNumber       int
	DatabaseWorkerBuffer       int
}

type WorkerJob ¶

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

type XRPBlockData ¶

type XRPBlockData struct {
	Block         *model.Block
	Transactions  []*model.Transaction
	Accounts      []*model.Account
	AffectedNodes []*model.AffectedNodes
	Paths         []*model.Path
	Amounts       []*model.Amount
}

func ParseBlock ¶

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

type XRPSplitter ¶

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

func NewSplitter ¶

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

func (*XRPSplitter) CheckBlock ¶

func (s *XRPSplitter) CheckBlock(curBlock *XRPBlockData) (bool, int64)

func (*XRPSplitter) CheckMissedBlock ¶

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

func (*XRPSplitter) SaveBlock ¶

func (s *XRPSplitter) SaveBlock(data *XRPBlockData) error

func (*XRPSplitter) Start ¶

func (s *XRPSplitter) Start()

func (*XRPSplitter) Stop ¶

func (s *XRPSplitter) Stop()

Source Files ¶

View all Source files

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