finality

package
v0.5.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 17, 2025 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation

Index

Constants

View Source
const (
	NumberPastBlocks = 10
	FirstBlock       = 1
)

Variables

This section is empty.

Functions

func NewCommitterBasedFLMProvider added in v0.5.0

func NewCommitterBasedFLMProvider(fnsp *fabric.NetworkServiceProvider, tracerProvider trace.TracerProvider, keyTranslator translator.KeyTranslator, config CommitterListenerManagerConfig) *committerBasedFLMProvider

func NewDeliveryBasedFLMProvider added in v0.5.0

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

Types

type CommitterListenerManagerConfig added in v0.5.0

type CommitterListenerManagerConfig struct {
	MaxRetries        int
	RetryWaitDuration time.Duration
}

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 FinalityListener

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

func (*FinalityListener) OnStatus

func (t *FinalityListener) OnStatus(ctx context.Context, txID string, status int, message string)

type ListenerManager

type ListenerManager = driver.FinalityListenerManager

type ListenerManagerProvider

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

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

Jump to

Keyboard shortcuts

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