txinput_queue

Documentation

Index

• Constants
• type Input
• type TxInputQueue
  • func New(env environment) *TxInputQueue
  • func (q *TxInputQueue) AddWantedTransaction(txid *ledger.TransactionID)
  • func (q *TxInputQueue) EvidenceNonSequencerTx()

Constants

const (
	CmdFromPeer = byte(iota)
	CmdFromAPI
)

const (
	Name = "txInputQueue"
)

Types

type Input

type Input struct {
	Cmd        byte
	TxBytes    []byte
	TxMetaData *txmetadata.TransactionMetadata
	FromPeer   peer.ID
	TraceFlag  bool
}

type TxInputQueue

type TxInputQueue struct {
	*work_process.WorkProcess[Input]
	// contains filtered or unexported fields
}

func New

func New(env environment) *TxInputQueue

func (*TxInputQueue) AddWantedTransaction

func (q *TxInputQueue) AddWantedTransaction(txid *ledger.TransactionID)

AddWantedTransaction adds transaction short id to the wanted filter. It makes the transaction go directly for attachment without checking other filters and without gossiping

func (*TxInputQueue) EvidenceNonSequencerTx

func (q *TxInputQueue) EvidenceNonSequencerTx()