Documentation
¶
Index ¶
- Constants
- Variables
- func FindCreator(operation *prototype.Operation) (name string)
- func IsCreateAccountOp(operation *prototype.Operation) bool
- func IsTransferOp(operation *prototype.Operation) bool
- func RegisterSQLTableNamePattern(pattern string)
- func RemoveSQLTables(dbConfig *service_configs.DatabaseConfig) error
- type BlockLogProcess
- type BlockLogProcessService
- type BlockLogService
- type CreateUserProcessor
- func (p *CreateUserProcessor) Finalize(db *gorm.DB, blockLog *blocklog.BlockLog) error
- func (p *CreateUserProcessor) Prepare(db *gorm.DB, blockLog *blocklog.BlockLog) (err error)
- func (p *CreateUserProcessor) ProcessChange(db *gorm.DB, change *blocklog.StateChange, blockLog *blocklog.BlockLog, ...) error
- func (p *CreateUserProcessor) ProcessOperation(db *gorm.DB, blockLog *blocklog.BlockLog, opIdx, trxIdx int) error
- type CreateUserRecord
- type DailyStatisticService
- type DemoService
- type EcosysProcessor
- func (p *EcosysProcessor) Finalize(db *gorm.DB, blockLog *blocklog.BlockLog) error
- func (p *EcosysProcessor) Prepare(db *gorm.DB, blockLog *blocklog.BlockLog) (err error)
- func (p *EcosysProcessor) ProcessChange(db *gorm.DB, change *blocklog.StateChange, blockLog *blocklog.BlockLog, ...) error
- func (p *EcosysProcessor) ProcessOperation(db *gorm.DB, blockLog *blocklog.BlockLog, opIdx, trxIdx int) error
- type EcosysReward
- type FollowService
- type Holder
- type HolderProcessor
- func (p *HolderProcessor) Finalize(db *gorm.DB, blockLog *blocklog.BlockLog) error
- func (p *HolderProcessor) Prepare(db *gorm.DB, blockLog *blocklog.BlockLog) (err error)
- func (p *HolderProcessor) ProcessChange(db *gorm.DB, change *blocklog.StateChange, blockLog *blocklog.BlockLog, ...) (err error)
- func (p *HolderProcessor) ProcessOperation(db *gorm.DB, blockLog *blocklog.BlockLog, opIdx, trxIdx int) error
- type IBlockLogProcessor
- type Op
- type PluginMgt
- type PostService
- type PowerUpDownProcessor
- func (p *PowerUpDownProcessor) Finalize(db *gorm.DB, blockLog *blocklog.BlockLog) error
- func (p *PowerUpDownProcessor) Prepare(db *gorm.DB, blockLog *blocklog.BlockLog) (err error)
- func (p *PowerUpDownProcessor) ProcessChange(db *gorm.DB, change *blocklog.StateChange, blockLog *blocklog.BlockLog, ...) error
- func (p *PowerUpDownProcessor) ProcessOperation(db *gorm.DB, blockLog *blocklog.BlockLog, opIdx, trxIdx int) error
- type PowerUpDownRecord
- type ProducerVoteProcessor
- func (p *ProducerVoteProcessor) Finalize(db *gorm.DB, blockLog *blocklog.BlockLog) error
- func (p *ProducerVoteProcessor) Prepare(db *gorm.DB, blockLog *blocklog.BlockLog) (err error)
- func (p *ProducerVoteProcessor) ProcessChange(db *gorm.DB, change *blocklog.StateChange, blockLog *blocklog.BlockLog, ...) error
- func (p *ProducerVoteProcessor) ProcessOperation(db *gorm.DB, blockLog *blocklog.BlockLog, opIdx, trxIdx int) error
- type ProducerVoteRecord
- type ProducerVoteState
- type Stake
- type StakeProcessor
- func (p *StakeProcessor) Finalize(db *gorm.DB, blockLog *blocklog.BlockLog) error
- func (p *StakeProcessor) Prepare(db *gorm.DB, blockLog *blocklog.BlockLog) (err error)
- func (p *StakeProcessor) ProcessChange(db *gorm.DB, change *blocklog.StateChange, blockLog *blocklog.BlockLog, ...) error
- func (p *StakeProcessor) ProcessOperation(db *gorm.DB, blockLog *blocklog.BlockLog, opIdx, trxIdx int) error
- type TransferProcessor
- func (p *TransferProcessor) Finalize(db *gorm.DB, blockLog *blocklog.BlockLog) error
- func (p *TransferProcessor) Prepare(db *gorm.DB, blockLog *blocklog.BlockLog) (err error)
- func (p *TransferProcessor) ProcessChange(db *gorm.DB, change *blocklog.StateChange, blockLog *blocklog.BlockLog, ...) error
- func (p *TransferProcessor) ProcessOperation(db *gorm.DB, blockLog *blocklog.BlockLog, opIdx, trxIdx int) error
- type TransferRecord
- type TrxMysqlService
- type TrxService
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 IsCreateAccountOp ¶ added in v1.0.2
func IsTransferOp ¶ added in v1.0.2
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
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) 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
type CreateUserRecord ¶ added in v1.0.2
type DailyStatisticService ¶ added in v1.0.2
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 ¶
func NewDemoService ¶
func NewDemoService(ctx *node.ServiceContext) (*DemoService, error)
service constructor
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) 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
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 ¶
func NewFollowService ¶
func NewFollowService(ctx *node.ServiceContext, lg *logrus.Logger) (*FollowService, error)
service constructor
func (*FollowService) Stop ¶
func (p *FollowService) Stop() error
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) 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
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 PluginMgt ¶ added in v1.0.2
type PluginMgt struct {
// contains filtered or unexported fields
}
func NewPluginMgt ¶ added in v1.0.2
func (*PluginMgt) RegisterSQLServices ¶ added in v1.0.2
type PostService ¶
func NewPostService ¶
func NewPostService(ctx *node.ServiceContext) (*PostService, error)
service constructor
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) 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
type PowerUpDownRecord ¶ added in v1.0.2
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) 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
type ProducerVoteRecord ¶ added in v1.0.2
type ProducerVoteState ¶ added in v1.0.2
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) 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
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) 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
type TransferRecord ¶ added in v1.0.2
type TrxMysqlService ¶ added in v1.0.2
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
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) Stop ¶ added in v1.0.2
func (t *TrxService) Stop() error
Source Files
¶
- blocklog_process_service.go
- blocklog_processor_create_user.go
- blocklog_processor_ecosys_reward.go
- blocklog_processor_holder.go
- blocklog_processor_power_updown.go
- blocklog_processor_producer_vote.go
- blocklog_processor_stake.go
- blocklog_processor_transfer.go
- blocklog_service.go
- daily_statistic_service.go
- demo_service.go
- follow_service.go
- plugin_mgt.go
- post_service.go
- sql_tables.go
- token_log_service.go
- trx_service.go
- trxs_to_mysql_service.go
Click to show internal directories.
Click to hide internal directories.