mempool

type AddTransactionEvent struct {
	Hash string
	Body []byte
	Type uint
}

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

type MempoolConfig struct {
	MempoolCapacity int64
	Logger          *slog.Logger
	EventBus        *event.EventBus
	PromRegistry    prometheus.Registerer
	Validator       TxValidator
}

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

type MempoolFullError struct {
	CurrentSize int
	TxSize      int
	Capacity    int64
}

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

type RemoveTransactionEvent struct {
	Hash string
}

type TxValidator interface {
	ValidateTx(tx gledger.Transaction) error
}