finality

package

v0.7.0 Latest Latest Go to latest Published: Dec 4, 2025 License: Apache-2.0 Imports: 22 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/hyperledger-labs/fabric-token-sdk

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func NewDeliveryBasedFLMProvider(fnsp *fabric.NetworkServiceProvider, tracerProvider trace.TracerProvider, ...) *deliveryBasedFLMProvider
type Delivery
- func (d *Delivery) ScanBlock(background context.Context, callback fabric.BlockCallback) error
type DeliveryScanQueryByID
- func (q *DeliveryScanQueryByID) QueryByID(ctx context.Context, lastBlock driver.BlockNum, ...) (<-chan []TxInfo, error)
type EventsListenerManager
type ListenerManager
type ListenerManagerProvider
- func NewListenerManagerProvider(fnsp *fabric.NetworkServiceProvider, tracerProvider trace.TracerProvider, ...) ListenerManagerProvider
type TxInfo
- func (i TxInfo) ID() driver2.TxID

Constants ¶

View Source

const (
	NumberPastBlocks = 10
	FirstBlock       = 1
)

Variables ¶

This section is empty.

Functions ¶

func NewDeliveryBasedFLMProvider ¶ added in v0.5.0

func NewDeliveryBasedFLMProvider(fnsp *fabric.NetworkServiceProvider, tracerProvider trace.TracerProvider, config events.DeliveryListenerManagerConfig, newMapper newTxInfoMapper) *deliveryBasedFLMProvider

Types ¶

type Delivery ¶

type Delivery struct {
	*fabric.Delivery
	*fabric.Ledger
	Logger logging.Logger
}

func (*Delivery) ScanBlock ¶ added in v0.5.0

func (d *Delivery) ScanBlock(background context.Context, callback fabric.BlockCallback) error

type DeliveryScanQueryByID ¶ added in v0.5.0

type DeliveryScanQueryByID struct {
	Delivery *fabric.Delivery
	Ledger   *fabric.Ledger
	Mapper   events2.EventInfoMapper[TxInfo]
}

func (*DeliveryScanQueryByID) QueryByID ¶ added in v0.5.0

func (q *DeliveryScanQueryByID) QueryByID(ctx context.Context, lastBlock driver.BlockNum, evicted map[driver.TxID][]events2.ListenerEntry[TxInfo]) (<-chan []TxInfo, error)

type EventsListenerManager ¶ added in v0.5.0

type EventsListenerManager interface {
	AddEventListener(txID string, e events.ListenerEntry[TxInfo]) error
	RemoveEventListener(txID string, e events.ListenerEntry[TxInfo]) error
}

type ListenerManager ¶

type ListenerManager = driver.FinalityListenerManager

type ListenerManagerProvider ¶

type ListenerManagerProvider interface {
	NewManager(network, channel string) (ListenerManager, error)
}

func NewListenerManagerProvider ¶

func NewListenerManagerProvider(fnsp *fabric.NetworkServiceProvider, tracerProvider trace.TracerProvider, keyTranslator translator.KeyTranslator, lmConfig config.ListenerManagerConfig) ListenerManagerProvider

type TxInfo ¶ added in v0.5.0

type TxInfo struct {
	TxId        driver2.TxID
	Namespace   driver2.Namespace
	Status      driver.TxStatus
	Message     string
	RequestHash []byte
}

func (TxInfo) ID ¶ added in v0.5.0

func (i TxInfo) ID() driver2.TxID

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL