occuredtxs

Documentation

Index

• type Buffer
  • func New(size int, txSigner types.Signer) *Buffer
  • func (s *Buffer) Clear()
  • func (s *Buffer) CollectConfirmedTxs(txs types.Transactions)
  • func (s *Buffer) CollectNotConfirmedTxs(txs types.Transactions) error
  • func (s *Buffer) Len() int
  • func (s *Buffer) MayBeConflicted(sender common.Address, txHash common.Hash) bool

Types

type Buffer

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

func New

func New(size int, txSigner types.Signer) *Buffer

func (*Buffer) Clear

func (s *Buffer) Clear()

Clear is not safe for concurrent use

func (*Buffer) CollectConfirmedTxs

func (s *Buffer) CollectConfirmedTxs(txs types.Transactions)

CollectConfirmedTxs is called when txs are included into a block not safe for concurrent use

func (*Buffer) CollectNotConfirmedTxs

func (s *Buffer) CollectNotConfirmedTxs(txs types.Transactions) error

CollectNotConfirmedTxs is called when txs are included into an event, but not included into a block not safe for concurrent use

func (*Buffer) Len

func (s *Buffer) Len() int

Len is safe for concurrent use

func (*Buffer) MayBeConflicted

func (s *Buffer) MayBeConflicted(sender common.Address, txHash common.Hash) bool

MayBeConflicted is not safe for concurrent use