plugins

package
v1.0.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 14, 2019 License: MIT Imports: 24 Imported by: 0

Documentation

Index

Constants

View Source
const LIMIT = 30
View Source
const RewardTableName = "ecosys_reward"

Variables

View Source
var DemoServiceName = "demosrv"
View Source
var FollowServiceName = "followsrv"
View Source
var PostServiceName = "postsrv"
View Source
var TrxMysqlServiceName = "trxsqlservice"
View Source
var TrxServiceName = "trxsrv"

Functions

func FindCreator added in v1.0.2

func FindCreator(operation *prototype.Operation) (name string)

func IsCreateAccountOp added in v1.0.2

func IsCreateAccountOp(operation *prototype.Operation) bool

func IsTransferOp added in v1.0.2

func IsTransferOp(operation *prototype.Operation) bool

func RegisterSQLTableNamePattern added in v1.0.2

func RegisterSQLTableNamePattern(pattern string)

func RemoveSQLTables added in v1.0.2

func RemoveSQLTables(dbConfig *service_configs.DatabaseConfig) error

Types

type BlockLogProcess added in v1.0.2

type BlockLogProcess struct {
	ID          uint64 `gorm:"primary_key;auto_increment"`
	BlockHeight uint64
	FinishAt    time.Time
}

func (BlockLogProcess) TableName added in v1.0.2

func (BlockLogProcess) TableName() string

type BlockLogProcessService added in v1.0.2

type BlockLogProcessService struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewBlockLogProcessService added in v1.0.2

func NewBlockLogProcessService(ctx *node.ServiceContext, config *service_configs.DatabaseConfig, logger *logrus.Logger) (*BlockLogProcessService, error)

func (*BlockLogProcessService) Start added in v1.0.2

func (s *BlockLogProcessService) Start(node *node.Node) error

func (*BlockLogProcessService) Stop added in v1.0.2

func (s *BlockLogProcessService) Stop() error

type BlockLogService added in v1.0.2

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

func NewBlockLogService added in v1.0.2

func NewBlockLogService(ctx *node.ServiceContext, config *service_configs.DatabaseConfig, logger *logrus.Logger) (*BlockLogService, error)

func (*BlockLogService) Start added in v1.0.2

func (s *BlockLogService) Start(node *node.Node) error

func (*BlockLogService) Stop added in v1.0.2

func (s *BlockLogService) Stop() error

type CreateUserProcessor added in v1.0.2

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

func NewCreateUserProcessor added in v1.0.2

func NewCreateUserProcessor() *CreateUserProcessor

func (*CreateUserProcessor) Finalize added in v1.0.2

func (p *CreateUserProcessor) Finalize(db *gorm.DB, blockLog *blocklog.BlockLog) error

func (*CreateUserProcessor) Prepare added in v1.0.2

func (p *CreateUserProcessor) Prepare(db *gorm.DB, blockLog *blocklog.BlockLog) (err error)

func (*CreateUserProcessor) ProcessChange added in v1.0.2

func (p *CreateUserProcessor) ProcessChange(db *gorm.DB, change *blocklog.StateChange, blockLog *blocklog.BlockLog, changeIdx, opIdx, trxIdx int) error

func (*CreateUserProcessor) ProcessOperation added in v1.0.2

func (p *CreateUserProcessor) ProcessOperation(db *gorm.DB, blockLog *blocklog.BlockLog, opIdx, trxIdx int) error

type CreateUserRecord added in v1.0.2

type CreateUserRecord struct {
	ID          uint64 `gorm:"primary_key;auto_increment"`
	BlockHeight uint64 `gorm:"index"`
	BlockTime   time.Time
	Creator     string `gorm:"index"`
	NewAccount  string `gorm:"index"`
	Fee         uint64
}

type DailyStatisticService added in v1.0.2

type DailyStatisticService struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewDailyStatisticService added in v1.0.2

func NewDailyStatisticService(ctx *node.ServiceContext, config *service_configs.DatabaseConfig, log *logrus.Logger) (*DailyStatisticService, error)

func (*DailyStatisticService) DailyStatsSince added in v1.0.2

func (s *DailyStatisticService) DailyStatsSince(days int, dapp string) []*itype.Row

func (*DailyStatisticService) Start added in v1.0.2

func (s *DailyStatisticService) Start(node *node.Node) error

func (*DailyStatisticService) Stop added in v1.0.2

func (s *DailyStatisticService) Stop() error

type DemoService

type DemoService struct {
	node.Service
	// contains filtered or unexported fields
}

func NewDemoService

func NewDemoService(ctx *node.ServiceContext) (*DemoService, error)

service constructor

func (*DemoService) Start

func (p *DemoService) Start(node *node.Node) error

func (*DemoService) Stop

func (p *DemoService) Stop() error

type EcosysProcessor added in v1.0.2

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

func NewEcosysProcessor added in v1.0.2

func NewEcosysProcessor() *EcosysProcessor

func (*EcosysProcessor) Finalize added in v1.0.2

func (p *EcosysProcessor) Finalize(db *gorm.DB, blockLog *blocklog.BlockLog) error

func (*EcosysProcessor) Prepare added in v1.0.2

func (p *EcosysProcessor) Prepare(db *gorm.DB, blockLog *blocklog.BlockLog) (err error)

func (*EcosysProcessor) ProcessChange added in v1.0.2

func (p *EcosysProcessor) ProcessChange(db *gorm.DB, change *blocklog.StateChange, blockLog *blocklog.BlockLog, changeIdx, opIdx, trxIdx int) error

func (*EcosysProcessor) ProcessOperation added in v1.0.2

func (p *EcosysProcessor) ProcessOperation(db *gorm.DB, blockLog *blocklog.BlockLog, opIdx, trxIdx int) error

type EcosysReward added in v1.0.2

type EcosysReward struct {
	ID          uint64 `gorm:"primary_key;auto_increment"`
	BlockHeight uint64 `gorm:"index"`
	BlockTime   time.Time
	Name        string `gorm:"index"`
	Type        string `gorm:"index"`
	PostId      uint64 `gorm:"index"`
	Reward      uint64
	Wvps        string
	TotalWvps   string
	Pool        uint64
}

func (*EcosysReward) TableName added in v1.0.2

func (rec *EcosysReward) TableName() string

type FollowService

type FollowService struct {
	node.Service
	// contains filtered or unexported fields
}

func NewFollowService

func NewFollowService(ctx *node.ServiceContext, lg *logrus.Logger) (*FollowService, error)

service constructor

func (*FollowService) Start

func (p *FollowService) Start(node *node.Node) error

func (*FollowService) Stop

func (p *FollowService) Stop() error

type Holder added in v1.0.2

type Holder struct {
	Name            string `gorm:"primary_key"`
	IsContract      bool   `gorm:"index"`
	Balance         uint64 `gorm:"index"`
	Vest            uint64 `gorm:"index"`
	StakeVestFromMe uint64 `gorm:"index"`
}

type HolderProcessor added in v1.0.2

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

func NewHolderProcessor added in v1.0.2

func NewHolderProcessor() *HolderProcessor

func (*HolderProcessor) Finalize added in v1.0.2

func (p *HolderProcessor) Finalize(db *gorm.DB, blockLog *blocklog.BlockLog) error

func (*HolderProcessor) Prepare added in v1.0.2

func (p *HolderProcessor) Prepare(db *gorm.DB, blockLog *blocklog.BlockLog) (err error)

func (*HolderProcessor) ProcessChange added in v1.0.2

func (p *HolderProcessor) ProcessChange(db *gorm.DB, change *blocklog.StateChange, blockLog *blocklog.BlockLog, changeIdx, opIdx, trxIdx int) (err error)

func (*HolderProcessor) ProcessOperation added in v1.0.2

func (p *HolderProcessor) ProcessOperation(db *gorm.DB, blockLog *blocklog.BlockLog, opIdx, trxIdx int) error

type IBlockLogProcessor added in v1.0.2

type IBlockLogProcessor interface {
	Prepare(db *gorm.DB, blockLog *blocklog.BlockLog) error
	ProcessChange(db *gorm.DB, change *blocklog.StateChange, blockLog *blocklog.BlockLog, changeIdx, opIdx, trxIdx int) error
	ProcessOperation(db *gorm.DB, blockLog *blocklog.BlockLog, opIdx, trxIdx int) error
	Finalize(db *gorm.DB, blockLog *blocklog.BlockLog) error
}

type Op added in v1.0.2

type Op map[string]interface{}

func PurgeOperation added in v1.0.2

func PurgeOperation(operations []*prototype.Operation) []Op

type PluginMgt added in v1.0.2

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

func NewPluginMgt added in v1.0.2

func NewPluginMgt(list []string) *PluginMgt

func (*PluginMgt) RegisterSQLServices added in v1.0.2

func (p *PluginMgt) RegisterSQLServices(app *node.Node, cfg *node.Config)

func (*PluginMgt) RegisterTrxPoolDependents added in v1.0.2

func (p *PluginMgt) RegisterTrxPoolDependents(app *node.Node, cfg *node.Config)

type PostService

type PostService struct {
	node.Service
	// contains filtered or unexported fields
}

func NewPostService

func NewPostService(ctx *node.ServiceContext) (*PostService, error)

service constructor

func (*PostService) Start

func (p *PostService) Start(node *node.Node) error

func (*PostService) Stop

func (p *PostService) Stop() error

type PowerUpDownProcessor added in v1.0.2

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

func NewPowerUpDownProcessor added in v1.0.2

func NewPowerUpDownProcessor() *PowerUpDownProcessor

func (*PowerUpDownProcessor) Finalize added in v1.0.2

func (p *PowerUpDownProcessor) Finalize(db *gorm.DB, blockLog *blocklog.BlockLog) error

func (*PowerUpDownProcessor) Prepare added in v1.0.2

func (p *PowerUpDownProcessor) Prepare(db *gorm.DB, blockLog *blocklog.BlockLog) (err error)

func (*PowerUpDownProcessor) ProcessChange added in v1.0.2

func (p *PowerUpDownProcessor) ProcessChange(db *gorm.DB, change *blocklog.StateChange, blockLog *blocklog.BlockLog, changeIdx, opIdx, trxIdx int) error

func (*PowerUpDownProcessor) ProcessOperation added in v1.0.2

func (p *PowerUpDownProcessor) ProcessOperation(db *gorm.DB, blockLog *blocklog.BlockLog, opIdx, trxIdx int) error

type PowerUpDownRecord added in v1.0.2

type PowerUpDownRecord struct {
	ID          uint64 `gorm:"primary_key;auto_increment"`
	Account     string `gorm:"index"`
	From        string `gorm:"index"`
	PowerUp     bool   `gorm:"index"`
	Amount      uint64 `gorm:"index"`
	BlockHeight uint64 `gorm:"index"`
	BlockTime   time.Time
	OperationId string `gorm:"index"`
	Memo        string
}

type ProducerVoteProcessor added in v1.0.2

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

func NewProducerVoteProcessor added in v1.0.2

func NewProducerVoteProcessor() *ProducerVoteProcessor

func (*ProducerVoteProcessor) Finalize added in v1.0.2

func (p *ProducerVoteProcessor) Finalize(db *gorm.DB, blockLog *blocklog.BlockLog) error

func (*ProducerVoteProcessor) Prepare added in v1.0.2

func (p *ProducerVoteProcessor) Prepare(db *gorm.DB, blockLog *blocklog.BlockLog) (err error)

func (*ProducerVoteProcessor) ProcessChange added in v1.0.2

func (p *ProducerVoteProcessor) ProcessChange(db *gorm.DB, change *blocklog.StateChange, blockLog *blocklog.BlockLog, changeIdx, opIdx, trxIdx int) error

func (*ProducerVoteProcessor) ProcessOperation added in v1.0.2

func (p *ProducerVoteProcessor) ProcessOperation(db *gorm.DB, blockLog *blocklog.BlockLog, opIdx, trxIdx int) error

type ProducerVoteRecord added in v1.0.2

type ProducerVoteRecord struct {
	ID          uint64 `gorm:"primary_key;auto_increment"`
	BlockHeight uint64 `gorm:"index"`
	BlockTime   time.Time
	Voter       string `gorm:"index"`
	Producer    string `gorm:"index"`
	Cancel      bool
}

type ProducerVoteState added in v1.0.2

type ProducerVoteState struct {
	Voter    string `gorm:"primary_key"`
	Producer string `gorm:"index"`
}

type Stake added in v1.0.2

type Stake struct {
	StakeFrom   string `gorm:"primary_key"`
	StakeTo     string `gorm:"primary_key"`
	BlockHeight uint64
	BlockTime   time.Time
	Amount      uint64 `gorm:"index"`
}

type StakeProcessor added in v1.0.2

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

func NewStakeProcessor added in v1.0.2

func NewStakeProcessor() *StakeProcessor

func (*StakeProcessor) Finalize added in v1.0.2

func (p *StakeProcessor) Finalize(db *gorm.DB, blockLog *blocklog.BlockLog) error

func (*StakeProcessor) Prepare added in v1.0.2

func (p *StakeProcessor) Prepare(db *gorm.DB, blockLog *blocklog.BlockLog) (err error)

func (*StakeProcessor) ProcessChange added in v1.0.2

func (p *StakeProcessor) ProcessChange(db *gorm.DB, change *blocklog.StateChange, blockLog *blocklog.BlockLog, changeIdx, opIdx, trxIdx int) error

func (*StakeProcessor) ProcessOperation added in v1.0.2

func (p *StakeProcessor) ProcessOperation(db *gorm.DB, blockLog *blocklog.BlockLog, opIdx, trxIdx int) error

type TransferProcessor added in v1.0.2

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

func NewTransferProcessor added in v1.0.2

func NewTransferProcessor() *TransferProcessor

func (*TransferProcessor) Finalize added in v1.0.2

func (p *TransferProcessor) Finalize(db *gorm.DB, blockLog *blocklog.BlockLog) error

func (*TransferProcessor) Prepare added in v1.0.2

func (p *TransferProcessor) Prepare(db *gorm.DB, blockLog *blocklog.BlockLog) (err error)

func (*TransferProcessor) ProcessChange added in v1.0.2

func (p *TransferProcessor) ProcessChange(db *gorm.DB, change *blocklog.StateChange, blockLog *blocklog.BlockLog, changeIdx, opIdx, trxIdx int) error

func (*TransferProcessor) ProcessOperation added in v1.0.2

func (p *TransferProcessor) ProcessOperation(db *gorm.DB, blockLog *blocklog.BlockLog, opIdx, trxIdx int) error

type TransferRecord added in v1.0.2

type TransferRecord struct {
	ID          uint64 `gorm:"primary_key;auto_increment"`
	BlockHeight uint64 `gorm:"index"`
	OperationId string `gorm:"not null;unique_index"`
	BlockTime   time.Time
	From        string `gorm:"index"`
	To          string `gorm:"index"`
	Amount      uint64 `gorm:"index"`
	Memo        string `gorm:"index"`
}

type TrxMysqlService added in v1.0.2

type TrxMysqlService struct {
	node.Service
	// contains filtered or unexported fields
}

func NewTrxMysqlSerVice added in v1.0.2

func NewTrxMysqlSerVice(ctx *node.ServiceContext, config *service_configs.DatabaseConfig, log *logrus.Logger) (*TrxMysqlService, error)

func (*TrxMysqlService) Start added in v1.0.2

func (t *TrxMysqlService) Start(node *node.Node) error

func (*TrxMysqlService) Stop added in v1.0.2

func (t *TrxMysqlService) Stop() error

type TrxService added in v1.0.2

type TrxService struct {
	node.Service
	// contains filtered or unexported fields
}

func NewTrxSerVice added in v1.0.2

func NewTrxSerVice(ctx *node.ServiceContext, log *logrus.Logger) (*TrxService, error)

func (*TrxService) GetTrxCreator added in v1.0.2

func (t *TrxService) GetTrxCreator(usrMap map[string]bool) string

func (*TrxService) Start added in v1.0.2

func (t *TrxService) Start(node *node.Node) error

func (*TrxService) Stop added in v1.0.2

func (t *TrxService) Stop() error

Jump to

Keyboard shortcuts

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