pool

type PoolEntry ¶

type PoolEntry struct {
	// Info on where this tx originated from.
	Src TxSource `json:"src"`
	// Timestamp of when this tx was originally added to the pool.
	TxAt string `json:"tx_at"`
	// The transaction itself.
	Tx core.Transaction `json:"tx"`
}

PoolEntry represents a single entry in the pool. A single (possibly aggregated) transaction.

type TxSource ¶

type TxSource int

TxSource is used to make decisions based on transaction acceptance priority from various sources. For example, a node may want to bypass pool size restrictions when accepting a transaction from a local wallet.

Most likely this will evolve to contain some sort of network identifier, once we get a better sense of what transaction building might look like.

const (
	// PushAPITxSource when the tx is pushed via API
	PushAPITxSource TxSource = iota
	// BroadcastTxSource when the source is a broadcats
	BroadcastTxSource
	// FluffTxSource zhen the source is our own fluff
	FluffTxSource
	// EmbargoExpiredTxSource when the source is an expired embargo
	EmbargoExpiredTxSource
	// DeaggregateTxSource when the source is the deaggregation
	DeaggregateTxSource
)

func (s TxSource) MarshalJSON() ([]byte, error)

func (s *TxSource) UnmarshalJSON(b []byte) error