txpool

Documentation

Index

• Variables
• type ChainTxPool
  • func NewChainTxPool() *ChainTxPool
  • func (c *ChainTxPool) FindOneTx(targetTxHash string) bool
  • func (c *ChainTxPool) Print() string
  • func (c *ChainTxPool) StartLoopGetRawTxPool(ctx context.Context, rpcClient rpc.Client, duration time.Duration)
• type RecentUsedTxInfoObj
• type RecentUsedTxManager
  • func NewRecentUsedTxManager(retryTime int, retryDelay time.Duration, overdueSec int64) *RecentUsedTxManager
  • func (r *RecentUsedTxManager) AddRecentUsedTx(accountId celltype.DasAccountId, tx RecentUsedTxInfoObj)
  • func (r *RecentUsedTxManager) AddRecentUsedTx2(tx RecentUsedTxInfoObj)
  • func (r *RecentUsedTxManager) PopOneLocalRecentUsedTx(key interface{}) *RecentUsedTxInfoObj
  • func (r *RecentUsedTxManager) PopOneRecentUsedTx(chainTxPool *ChainTxPool, key interface{}) *RecentUsedTxInfoObj
  • func (r *RecentUsedTxManager) RemoveOneRecentUsedTx(accountId celltype.DasAccountId, newTxHash types.Hash)
  • func (r *RecentUsedTxManager) RemoveOneRecentUsedTxByHash(txHash types.Hash)

Variables

var (
	ChainTxPoolManager             *ChainTxPool
	RecentAccountCellUsedTxManager *RecentUsedTxManager
	RecentManagerCellUsedTxManager *RecentUsedTxManager
	RecentIncomeCellUsedTxManager  *RecentUsedTxManager
)

Types

type ChainTxPool

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

func NewChainTxPool

func NewChainTxPool() *ChainTxPool

func (*ChainTxPool) FindOneTx

func (c *ChainTxPool) FindOneTx(targetTxHash string) bool

func (*ChainTxPool) Print

func (c *ChainTxPool) Print() string

func (*ChainTxPool) StartLoopGetRawTxPool

func (c *ChainTxPool) StartLoopGetRawTxPool(ctx context.Context, rpcClient rpc.Client, duration time.Duration)

type RecentUsedTxInfoObj

type RecentUsedTxInfoObj struct {
	TimeUnixAdd int64          `json:"time_unix_add"`
	OutPoint    types.OutPoint `json:"out_point"`
	DetailObj   interface{}    `json:"detail_obj"`
}

type RecentUsedTxManager

type RecentUsedTxManager struct {
	UsedTx     sync.Map
	RetryTime  int
	RetryDelay time.Duration
	// contains filtered or unexported fields
}

func NewRecentUsedTxManager

func NewRecentUsedTxManager(retryTime int, retryDelay time.Duration, overdueSec int64) *RecentUsedTxManager

func (*RecentUsedTxManager) AddRecentUsedTx

func (r *RecentUsedTxManager) AddRecentUsedTx(accountId celltype.DasAccountId, tx RecentUsedTxInfoObj)

func (*RecentUsedTxManager) AddRecentUsedTx2

func (r *RecentUsedTxManager) AddRecentUsedTx2(tx RecentUsedTxInfoObj)

func (*RecentUsedTxManager) PopOneLocalRecentUsedTx

func (r *RecentUsedTxManager) PopOneLocalRecentUsedTx(key interface{}) *RecentUsedTxInfoObj

func (*RecentUsedTxManager) PopOneRecentUsedTx

func (r *RecentUsedTxManager) PopOneRecentUsedTx(chainTxPool *ChainTxPool, key interface{}) *RecentUsedTxInfoObj

func (*RecentUsedTxManager) RemoveOneRecentUsedTx

func (r *RecentUsedTxManager) RemoveOneRecentUsedTx(accountId celltype.DasAccountId, newTxHash types.Hash)

func (*RecentUsedTxManager) RemoveOneRecentUsedTxByHash

func (r *RecentUsedTxManager) RemoveOneRecentUsedTxByHash(txHash types.Hash)