p2p_node

Documentation

Index

• func NewP2PSyncClient(apiUrl, p2pAddr string) (*p2pSyncClient, error)
• type DataHandlerInterface

Functions

func NewP2PSyncClient

func NewP2PSyncClient(apiUrl, p2pAddr string) (*p2pSyncClient, error)

NewP2PSyncClient create a sync client to eosforce

Types

type DataHandlerInterface

type DataHandlerInterface interface {
	OnBlock(blockID string, block *eos.SignedBlock)
	OnTrx(blockID string, blk *eos.SignedBlock, trx *eos.SignedTransaction)
	OnAction(blockID string, trx *eos.SignedTransaction, act *eos.Action)

	OnNewAccount(blockID string, trx *eos.SignedTransaction, act *eos.Action, data *system.NewAccount)
	OnTransfer(blockID string, trx *eos.SignedTransaction, act *eos.Action, data *eosforce.Transfer)

	OnTokenIssue(blockID string, trx *eos.SignedTransaction, act *eos.Action, data *token.Issue)
	OnTokenCreate(blockID string, trx *eos.SignedTransaction, act *eos.Action, data *token.Create)
	OnTokenTransfer(blockID string, trx *eos.SignedTransaction, act *eos.Action, data *token.Transfer)

	OnVote(blockID string, trx *eos.SignedTransaction, act *eos.Action, data *eosforce.Vote)
	OnClaim(blockID string, trx *eos.SignedTransaction, act *eos.Action, data *eosforce.Claim)
	OnUnfreeze(blockID string, trx *eos.SignedTransaction, act *eos.Action, data *eosforce.Unfreeze)
	OnUpdateBP(blockID string, trx *eos.SignedTransaction, act *eos.Action, data *eosforce.UpdateBP)
}

DataHandlerInterface data handler interface, when sync data will call it