plugins

package
v1.0.8 Latest Latest
Warning

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

 Go to latest Published: Mar 26, 2020 License: MIT Imports: 25 Imported by: 0

Documentation

Index

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 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 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 

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, 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) Finalize added in v1.0.4 

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

func (*BlockLogProcessor) Prepare added in v1.0.4 

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

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 

func (p *BlockLogProcessor) ProcessOperation(db *gorm.DB, blockLog *blocklog.BlockLog, opIdx, trxIdx int) 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 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) 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 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) Finalize added in v1.0.4 

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

func (*EcosysPowerDownProcessor) Prepare added in v1.0.4 

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

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 

func (p *EcosysPowerDownProcessor) ProcessOperation(db *gorm.DB, blockLog *blocklog.BlockLog, opIdx, trxIdx int) 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 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 

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 ForwardManagerService added in v1.0.4 

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

func NewForwardManagerService added in v1.0.4 

func NewForwardManagerService(logger *logrus.Logger, db *gorm.DB, processors map[string]IBlockLogProcessor) *ForwardManagerService

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"`
	BorrowedVest    uint64 `gorm:"index"`
	LentVest        uint64 `gorm:"index"`
	DeliveringVest  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 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) Finalize added in v1.0.4 

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

func (*IOTrxProcessor) Prepare added in v1.0.4 

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

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 

func (p *IOTrxProcessor) ProcessOperation(db *gorm.DB, blockLog *blocklog.BlockLog, opIdx, trxIdx int) 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 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 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 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) 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

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) Finalize added in v1.0.8 

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

func (*VestDelegationProcessor) Prepare added in v1.0.8 

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

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 

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

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

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.