mempool

Documentation

Index

• type Mempool
  • func NewMempool(logger *slog.Logger) *Mempool
  • func (m *Mempool) AddConsumer(connId ouroboros.ConnectionId) *MempoolConsumer
  • func (m *Mempool) AddTransaction(tx MempoolTransaction) error
  • func (m *Mempool) Consumer(connId ouroboros.ConnectionId) *MempoolConsumer
  • func (m *Mempool) GetTransaction(txHash string) (MempoolTransaction, bool)
  • func (m *Mempool) RemoveConsumer(connId ouroboros.ConnectionId)
  • func (m *Mempool) RemoveTransaction(hash string)
• type MempoolConsumer
  • func (m *MempoolConsumer) ClearCache()
  • func (m *MempoolConsumer) GetTxFromCache(hash string) *MempoolTransaction
  • func (m *MempoolConsumer) NextTx(blocking bool) *MempoolTransaction
  • func (m *MempoolConsumer) RemoveTxFromCache(hash string)
• type MempoolTransaction

Types

type Mempool

type Mempool struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewMempool

func NewMempool(logger *slog.Logger) *Mempool

func (*Mempool) AddConsumer

func (m *Mempool) AddConsumer(connId ouroboros.ConnectionId) *MempoolConsumer

func (*Mempool) AddTransaction

func (m *Mempool) AddTransaction(tx MempoolTransaction) error

func (*Mempool) Consumer

func (m *Mempool) Consumer(connId ouroboros.ConnectionId) *MempoolConsumer

func (*Mempool) GetTransaction

func (m *Mempool) GetTransaction(txHash string) (MempoolTransaction, bool)

func (*Mempool) RemoveConsumer

func (m *Mempool) RemoveConsumer(connId ouroboros.ConnectionId)

func (*Mempool) RemoveTransaction

func (m *Mempool) RemoveTransaction(hash string)

type MempoolConsumer

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

func (*MempoolConsumer) ClearCache

func (m *MempoolConsumer) ClearCache()

func (*MempoolConsumer) GetTxFromCache

func (m *MempoolConsumer) GetTxFromCache(hash string) *MempoolTransaction

func (*MempoolConsumer) NextTx

func (m *MempoolConsumer) NextTx(blocking bool) *MempoolTransaction

func (*MempoolConsumer) RemoveTxFromCache

func (m *MempoolConsumer) RemoveTxFromCache(hash string)

type MempoolTransaction

type MempoolTransaction struct {
	Hash     string
	Type     uint
	Cbor     []byte
	LastSeen time.Time
}