events

type Delivery interface {
	ScanBlock(background context.Context, callback fabric.BlockCallback) error
}

type DeliveryListenerManagerConfig struct {
	MapperParallelism       int
	BlockProcessParallelism int
	ListenerTimeout         time.Duration
	LRUSize                 int
	LRUBuffer               int
}

type EventID = string

type EventInfo interface {
	ID() EventID
}

type EventInfoCallback[T EventInfo] func(T) error

type EventInfoMapper[T EventInfo] interface {
	MapTxData(ctx context.Context, tx []byte, block *common.BlockMetadata, blockNum driver.BlockNum, txNum driver.TxNum) (map[driver.Namespace]T, error)
	MapProcessedTx(tx *fabric.ProcessedTransaction) ([]T, error)
}

type ListenerEntry[T EventInfo] interface {
	// Namespace returns the namespace this entry refers to. It can be empty.
	Namespace() driver.Namespace
	// OnStatus is the callback for the transaction
	OnStatus(ctx context.Context, info T)
	// Equals compares a listener entry for the delition
	Equals(other ListenerEntry[T]) bool
}

type ListenerManager[T EventInfo] struct {
	// contains filtered or unexported fields
}

type QueryByIDService[T EventInfo] interface {
	QueryByID(ctx context.Context, startingBlock driver.BlockNum, evicted map[EventID][]ListenerEntry[T]) (<-chan []T, error)
}