Documentation ¶
Index ¶
- Constants
- Variables
- func FindCreator(operation *prototype.Operation) (name string)
- func IsCreateAccountOp(operation *prototype.Operation) bool
- func IsTransferOp(operation *prototype.Operation) bool
- func ProcessAccountCreateOperation(baseOp prototype.BaseOperation, baseRecord interface{}) ([]interface{}, error)
- func ProcessAccountUpdateOperation(baseOp prototype.BaseOperation, baseRecord interface{}) ([]interface{}, error)
- func ProcessAcquireTicketOperation(baseOp prototype.BaseOperation, baseRecord interface{}) ([]interface{}, error)
- func ProcessBpEnableOperation(baseOp prototype.BaseOperation, baseRecord interface{}) ([]interface{}, error)
- func ProcessBpRegisterOperation(baseOp prototype.BaseOperation, baseRecord interface{}) ([]interface{}, error)
- func ProcessBpUpdateOperation(baseOp prototype.BaseOperation, baseRecord interface{}) ([]interface{}, error)
- func ProcessBpVoteOperation(baseOp prototype.BaseOperation, baseRecord interface{}) ([]interface{}, error)
- func ProcessContractApplyOperation(baseOp prototype.BaseOperation, baseRecord interface{}) ([]interface{}, error)
- func ProcessContractDeployOperation(baseOp prototype.BaseOperation, baseRecord interface{}) ([]interface{}, error)
- func ProcessContractTransferToContractChangeProcessor(opType string, operation prototype.BaseOperation, change *blocklog.StateChange, ...) ([]interface{}, error)
- func ProcessContractTransferToUserChangeProcessor(opType string, operation prototype.BaseOperation, change *blocklog.StateChange, ...) ([]interface{}, error)
- func ProcessContractTransferToUserVestChangeProcessor(opType string, operation prototype.BaseOperation, change *blocklog.StateChange, ...) ([]interface{}, error)
- func ProcessConvertVestOperation(baseOp prototype.BaseOperation, baseRecord interface{}) ([]interface{}, error)
- func ProcessDelegateVestOperation(baseOp prototype.BaseOperation, baseRecord interface{}) ([]interface{}, error)
- func ProcessPostOperation(baseOp prototype.BaseOperation, baseRecord interface{}) ([]interface{}, error)
- func ProcessReplyOperation(baseOp prototype.BaseOperation, baseRecord interface{}) ([]interface{}, error)
- func ProcessStakeOperation(baseOp prototype.BaseOperation, baseRecord interface{}) ([]interface{}, error)
- func ProcessTransferOperation(baseOp prototype.BaseOperation, baseRecord interface{}) ([]interface{}, error)
- func ProcessTransferVestOperation(baseOp prototype.BaseOperation, baseRecord interface{}) ([]interface{}, error)
- func ProcessUnDelegateVestChangeProcessor(opType string, operation prototype.BaseOperation, change *blocklog.StateChange, ...) ([]interface{}, error)
- func ProcessUnStakeOperation(baseOp prototype.BaseOperation, baseRecord interface{}) ([]interface{}, error)
- func ProcessUserToContractChangeProcessor(opType string, operation prototype.BaseOperation, change *blocklog.StateChange, ...) ([]interface{}, error)
- func ProcessVoteByTicketOperation(baseOp prototype.BaseOperation, baseRecord interface{}) ([]interface{}, error)
- func ProcessVoteOperation(baseOp prototype.BaseOperation, baseRecord interface{}) ([]interface{}, error)
- func RegisterSQLTableNamePattern(pattern string)
- func RemoveSQLTables(dbConfig *service_configs.DatabaseConfig) error
- type BlockLogProcessService
- type BlockLogProcessor
- func (p *BlockLogProcessor) Finalize(db *gorm.DB, blockLog *blocklog.BlockLog) error
- func (p *BlockLogProcessor) Prepare(db *gorm.DB, blockLog *blocklog.BlockLog) error
- func (p *BlockLogProcessor) ProcessChange(db *gorm.DB, change *blocklog.StateChange, blockLog *blocklog.BlockLog, ...) error
- func (p *BlockLogProcessor) ProcessOperation(db *gorm.DB, blockLog *blocklog.BlockLog, opIdx, trxIdx int) error
- type BlockLogService
- type ChangeProcessor
- 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 EcosysPowerDown
- type EcosysPowerDownProcessor
- func (p *EcosysPowerDownProcessor) Finalize(db *gorm.DB, blockLog *blocklog.BlockLog) error
- func (p *EcosysPowerDownProcessor) Prepare(db *gorm.DB, blockLog *blocklog.BlockLog) (err error)
- func (p *EcosysPowerDownProcessor) ProcessChange(db *gorm.DB, change *blocklog.StateChange, blockLog *blocklog.BlockLog, ...) error
- func (p *EcosysPowerDownProcessor) ProcessOperation(db *gorm.DB, blockLog *blocklog.BlockLog, opIdx, trxIdx int) error
- 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 FastForwardManagerService
- type FollowService
- type ForwardManagerService
- 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 IOTrxProcessor
- func (p *IOTrxProcessor) Finalize(db *gorm.DB, blockLog *blocklog.BlockLog) error
- func (p *IOTrxProcessor) Prepare(db *gorm.DB, blockLog *blocklog.BlockLog) (err error)
- func (p *IOTrxProcessor) ProcessChange(db *gorm.DB, change *blocklog.StateChange, blockLog *blocklog.BlockLog, ...) error
- func (p *IOTrxProcessor) ProcessOperation(db *gorm.DB, blockLog *blocklog.BlockLog, opIdx, trxIdx int) error
- type Op
- type OpProcessor
- type OpProcessorManager
- 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 SyncForwardManagerService
- 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
- type VestDelegationProcessor
- func (p *VestDelegationProcessor) Finalize(db *gorm.DB, blockLog *blocklog.BlockLog) error
- func (p *VestDelegationProcessor) Prepare(db *gorm.DB, blockLog *blocklog.BlockLog) (err error)
- func (p *VestDelegationProcessor) ProcessChange(db *gorm.DB, change *blocklog.StateChange, blockLog *blocklog.BlockLog, ...) error
- func (p *VestDelegationProcessor) ProcessOperation(db *gorm.DB, blockLog *blocklog.BlockLog, opIdx, trxIdx int) error
- type VestDelegationRecord
Constants ¶
View Source
const ( VestDelegationCreated = "created" VestDelegationDelivering = "delivering" VestDelegationDone = "done" )
View Source
const LIMIT = 30
View Source
const PowerDownTableName = "ecosys_powerdown"
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 ProcessAccountCreateOperation ¶ added in v1.0.4
func ProcessAccountCreateOperation(baseOp prototype.BaseOperation, baseRecord interface{}) ([]interface{}, error)
func ProcessAccountUpdateOperation ¶ added in v1.0.4
func ProcessAccountUpdateOperation(baseOp prototype.BaseOperation, baseRecord interface{}) ([]interface{}, error)
func ProcessAcquireTicketOperation ¶ added in v1.0.4
func ProcessAcquireTicketOperation(baseOp prototype.BaseOperation, baseRecord interface{}) ([]interface{}, error)
func ProcessBpEnableOperation ¶ added in v1.0.4
func ProcessBpEnableOperation(baseOp prototype.BaseOperation, baseRecord interface{}) ([]interface{}, error)
func ProcessBpRegisterOperation ¶ added in v1.0.4
func ProcessBpRegisterOperation(baseOp prototype.BaseOperation, baseRecord interface{}) ([]interface{}, error)
func ProcessBpUpdateOperation ¶ added in v1.0.4
func ProcessBpUpdateOperation(baseOp prototype.BaseOperation, baseRecord interface{}) ([]interface{}, error)
func ProcessBpVoteOperation ¶ added in v1.0.4
func ProcessBpVoteOperation(baseOp prototype.BaseOperation, baseRecord interface{}) ([]interface{}, error)
func ProcessContractApplyOperation ¶ added in v1.0.4
func ProcessContractApplyOperation(baseOp prototype.BaseOperation, baseRecord interface{}) ([]interface{}, error)
func ProcessContractDeployOperation ¶ added in v1.0.4
func ProcessContractDeployOperation(baseOp prototype.BaseOperation, baseRecord interface{}) ([]interface{}, error)
func ProcessContractTransferToContractChangeProcessor ¶ added in v1.0.4
func ProcessContractTransferToContractChangeProcessor(opType string, operation prototype.BaseOperation, change *blocklog.StateChange, baseRecord interface{}) ([]interface{}, error)
func ProcessContractTransferToUserChangeProcessor ¶ added in v1.0.4
func ProcessContractTransferToUserChangeProcessor(opType string, operation prototype.BaseOperation, change *blocklog.StateChange, baseRecord interface{}) ([]interface{}, error)
func ProcessContractTransferToUserVestChangeProcessor ¶ added in v1.0.6
func ProcessContractTransferToUserVestChangeProcessor(opType string, operation prototype.BaseOperation, change *blocklog.StateChange, baseRecord interface{}) ([]interface{}, error)
func ProcessConvertVestOperation ¶ added in v1.0.4
func ProcessConvertVestOperation(baseOp prototype.BaseOperation, baseRecord interface{}) ([]interface{}, error)
func ProcessDelegateVestOperation ¶ added in v1.0.8
func ProcessDelegateVestOperation(baseOp prototype.BaseOperation, baseRecord interface{}) ([]interface{}, error)
func ProcessPostOperation ¶ added in v1.0.4
func ProcessPostOperation(baseOp prototype.BaseOperation, baseRecord interface{}) ([]interface{}, error)
func ProcessReplyOperation ¶ added in v1.0.4
func ProcessReplyOperation(baseOp prototype.BaseOperation, baseRecord interface{}) ([]interface{}, error)
func ProcessStakeOperation ¶ added in v1.0.4
func ProcessStakeOperation(baseOp prototype.BaseOperation, baseRecord interface{}) ([]interface{}, error)
func ProcessTransferOperation ¶ added in v1.0.4
func ProcessTransferOperation(baseOp prototype.BaseOperation, baseRecord interface{}) ([]interface{}, error)
func ProcessTransferVestOperation ¶ added in v1.0.4
func ProcessTransferVestOperation(baseOp prototype.BaseOperation, baseRecord interface{}) ([]interface{}, error)
func ProcessUnDelegateVestChangeProcessor ¶ added in v1.0.8
func ProcessUnDelegateVestChangeProcessor(opType string, operation prototype.BaseOperation, change *blocklog.StateChange, baseRecord interface{}) ([]interface{}, error)
func ProcessUnStakeOperation ¶ added in v1.0.4
func ProcessUnStakeOperation(baseOp prototype.BaseOperation, baseRecord interface{}) ([]interface{}, error)
func ProcessUserToContractChangeProcessor ¶ added in v1.0.4
func ProcessUserToContractChangeProcessor(opType string, operation prototype.BaseOperation, change *blocklog.StateChange, baseRecord interface{}) ([]interface{}, error)
func ProcessVoteByTicketOperation ¶ added in v1.0.4
func ProcessVoteByTicketOperation(baseOp prototype.BaseOperation, baseRecord interface{}) ([]interface{}, error)
func ProcessVoteOperation ¶ added in v1.0.4
func ProcessVoteOperation(baseOp prototype.BaseOperation, baseRecord interface{}) ([]interface{}, error)
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 BlockLogProcessService ¶ added in v1.0.2
func NewBlockLogProcessService ¶ added in v1.0.2
func NewBlockLogProcessService(ctx *node.ServiceContext, config *service_configs.DatabaseConfig, log *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 BlockLogProcessor ¶ added in v1.0.4
type BlockLogProcessor struct {
// contains filtered or unexported fields
}
func NewBlockLogProcessor ¶ added in v1.0.4
func NewBlockLogProcessor() *BlockLogProcessor
func (*BlockLogProcessor) ProcessChange ¶ added in v1.0.4
func (p *BlockLogProcessor) ProcessChange(db *gorm.DB, change *blocklog.StateChange, blockLog *blocklog.BlockLog, changeIdx, opIdx, trxIdx int) error
func (*BlockLogProcessor) ProcessOperation ¶ added in v1.0.4
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 ChangeProcessor ¶ added in v1.0.4
type ChangeProcessor func(opType string, operation prototype.BaseOperation, change *blocklog.StateChange, baseRecord interface{}) ([]interface{}, 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 EcosysPowerDown ¶ added in v1.0.4
type EcosysPowerDown struct { ID uint64 `gorm:"primary_key;auto_increment"` BlockHeight uint64 `gorm:"index"` BlockTime time.Time Name string `gorm:"index"` VestOld uint64 VestNew uint64 }
func (*EcosysPowerDown) TableName ¶ added in v1.0.4
func (rec *EcosysPowerDown) TableName() string
type EcosysPowerDownProcessor ¶ added in v1.0.4
type EcosysPowerDownProcessor struct {
// contains filtered or unexported fields
}
func NewEcosysPowerDownProcessor ¶ added in v1.0.4
func NewEcosysPowerDownProcessor() *EcosysPowerDownProcessor
func (*EcosysPowerDownProcessor) ProcessChange ¶ added in v1.0.4
func (p *EcosysPowerDownProcessor) ProcessChange(db *gorm.DB, change *blocklog.StateChange, blockLog *blocklog.BlockLog, changeIdx, opIdx, trxIdx int) error
func (*EcosysPowerDownProcessor) ProcessOperation ¶ added in v1.0.4
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 FastForwardManagerService ¶ added in v1.0.4
type FastForwardManagerService struct {
*ForwardManagerService
}
func NewFastForwardManagerService ¶ added in v1.0.4
func NewFastForwardManagerService(logger *logrus.Logger, db *gorm.DB, processors map[string]IBlockLogProcessor) *FastForwardManagerService
func (*FastForwardManagerService) Start ¶ added in v1.0.4
func (s *FastForwardManagerService) Start(node *node.Node) error
func (*FastForwardManagerService) Stop ¶ added in v1.0.4
func (s *FastForwardManagerService) Stop() error
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 ForwardManagerService ¶ added in v1.0.4
func NewForwardManagerService ¶ added in v1.0.4
func NewForwardManagerService(logger *logrus.Logger, db *gorm.DB, processors map[string]IBlockLogProcessor) *ForwardManagerService
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 IOTrxProcessor ¶ added in v1.0.4
type IOTrxProcessor struct {
// contains filtered or unexported fields
}
func NewIOTrxProcessor ¶ added in v1.0.4
func NewIOTrxProcessor() *IOTrxProcessor
func (*IOTrxProcessor) ProcessChange ¶ added in v1.0.4
func (p *IOTrxProcessor) ProcessChange(db *gorm.DB, change *blocklog.StateChange, blockLog *blocklog.BlockLog, changeIdx, opIdx, trxIdx int) error
func (*IOTrxProcessor) ProcessOperation ¶ added in v1.0.4
type OpProcessor ¶ added in v1.0.4
type OpProcessor func(operation prototype.BaseOperation, baseRecord interface{}) ([]interface{}, error)
type OpProcessorManager ¶ added in v1.0.4
type OpProcessorManager struct {
// contains filtered or unexported fields
}
func NewOpProcessorManager ¶ added in v1.0.4
func NewOpProcessorManager() *OpProcessorManager
func (*OpProcessorManager) Find ¶ added in v1.0.4
func (m *OpProcessorManager) Find(opType string) (OpProcessor, bool)
func (*OpProcessorManager) Register ¶ added in v1.0.4
func (m *OpProcessorManager) Register(opType string, processor OpProcessor)
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 SyncForwardManagerService ¶ added in v1.0.4
type SyncForwardManagerService struct {
*ForwardManagerService
}
func NewSyncForwardManagerService ¶ added in v1.0.4
func NewSyncForwardManagerService(logger *logrus.Logger, db *gorm.DB, processors map[string]IBlockLogProcessor) *SyncForwardManagerService
func (*SyncForwardManagerService) Start ¶ added in v1.0.4
func (s *SyncForwardManagerService) Start(node *node.Node) error
func (*SyncForwardManagerService) Stop ¶ added in v1.0.4
func (s *SyncForwardManagerService) Stop() 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) 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
type VestDelegationProcessor ¶ added in v1.0.8
type VestDelegationProcessor struct {
// contains filtered or unexported fields
}
func NewVestDelegationProcessor ¶ added in v1.0.8
func NewVestDelegationProcessor() *VestDelegationProcessor
func (*VestDelegationProcessor) ProcessChange ¶ added in v1.0.8
func (p *VestDelegationProcessor) ProcessChange(db *gorm.DB, change *blocklog.StateChange, blockLog *blocklog.BlockLog, changeIdx, opIdx, trxIdx int) error
func (*VestDelegationProcessor) ProcessOperation ¶ added in v1.0.8
type VestDelegationRecord ¶ added in v1.0.8
type VestDelegationRecord struct { ID uint64 `gorm:"primary_key;auto_increment"` OrderID uint64 `gorm:"not null;unique_index"` From string `gorm:"index"` To string `gorm:"index"` Amount uint64 `gorm:"index"` CreatedAtBlock uint64 `gorm:"not null;index"` CreatedAtTime time.Time MaturityBlock uint64 `gorm:"not null;index"` ClaimedAtBlock uint64 `gorm:"index"` ClaimedAtTime time.Time DeliveryBlock uint64 `gorm:"index"` DeliveredAtTime time.Time Status string `gorm:"index"` }
Source Files ¶
- blocklog_fast_foward_manager_service.go
- blocklog_process_service.go
- blocklog_processor.go
- blocklog_processor_create_user.go
- blocklog_processor_ecosys_reward.go
- blocklog_processor_holder.go
- blocklog_processor_iotrx.go
- blocklog_processor_iotrx_changes.go
- blocklog_processor_iotrx_ops.go
- blocklog_processor_power_down_step.go
- blocklog_processor_power_updown.go
- blocklog_processor_producer_vote.go
- blocklog_processor_stake.go
- blocklog_processor_transfer.go
- blocklog_processor_vest_delegation.go
- blocklog_service.go
- blocklog_sync_forward_manager_service.go
- daily_statistic_service.go
- demo_service.go
- follow_service.go
- forward_manager_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.