finality

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

type FabricFinality struct {
	Channel                string
	ConfigService          driver.ConfigService
	Services               Services
	DefaultSigningIdentity driver.SigningIdentity
	Hasher                 Hasher
	WaitForEventTimeout    time.Duration
	// contains filtered or unexported fields
}

type Hasher interface {
	Hash(msg []byte) (hash []byte, err error)
}

type ListenerEntry[T TxInfo] interface {
	// 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 TxInfo] interface {
	AddFinalityListener(txID string, e ListenerEntry[T]) error
	RemoveFinalityListener(txID string, e ListenerEntry[T]) error
}

type Services interface {
	NewPeerClient(cc grpc.ConnectionConfig) (services.PeerClient, error)
}

type TxInfo interface {
	TxID() driver2.TxID
}

type TxInfoCallback[T TxInfo] func(T) error

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