txcache

Documentation

Index

• Constants
• type TxCache
  • func NewTxCache(txSliceTimeout time.Duration, txSetSize uint64, logger logrus.FieldLogger) *TxCache
  • func (tc *TxCache) IsFull() bool
  • func (tc *TxCache) ListenEvent()

Constants

const (
	DefaultTxCacheSize = 10000
	DefaultTxSetTick   = 100 * time.Millisecond
	DefaultTxSetSize   = 10
)

Types

type TxCache

type TxCache struct {
	TxSetC  chan []*types.Transaction
	RecvTxC chan *types.Transaction
	TxRespC chan *common.TxWithResp
	CloseC  chan bool
	// contains filtered or unexported fields
}

func NewTxCache

func NewTxCache(txSliceTimeout time.Duration, txSetSize uint64, logger logrus.FieldLogger) *TxCache

func (*TxCache) IsFull

func (tc *TxCache) IsFull() bool

func (*TxCache) ListenEvent

func (tc *TxCache) ListenEvent()