committer

package

v0.4.0 Latest Latest Go to latest Published: Jan 6, 2025 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation ¶

Index ¶

Variables
func New(networkName string, pm ProcessorManager, em driver.EnvelopeService, ...) (*committer, error)
type Finality
type FinalityManager
type ProcessorManager
type TxEvent
type Vault

Constants ¶

This section is empty.

Variables ¶

View Source

var (

	// ErrDiscardTX this error can be used to signal that a valid transaction should be discarded anyway
	ErrDiscardTX = errors.New("discard tx")
	// ErrUnknownTX this erro can be used to signal that a transaction is unknown
	ErrUnknownTX = errors.New("unknown tx")
)

Functions ¶

func New ¶

func New(
	networkName string,
	pm ProcessorManager,
	em driver.EnvelopeService,
	vault Vault,
	finality Finality,
	waitForEventTimeout time.Duration,
	quiet bool,
	eventsPublisher events.Publisher,
	eventsSubscriber events.Subscriber,
	tracerProvider trace.TracerProvider,
	networkConfig driver.NetworkConfig,
	listenerManager driver.ListenerManager,
) (*committer, error)

Types ¶

type Finality ¶

type Finality interface {
	IsFinal(txID string, address string) error
}

type FinalityManager ¶ added in v0.4.0

type FinalityManager = committer2.FinalityManager[driver.ValidationCode]

type ProcessorManager ¶

type ProcessorManager interface {
	ProcessByID(txid string) error
}

type TxEvent ¶

type TxEvent = driver2.FinalityEvent[driver.ValidationCode]

type Vault ¶

type Vault interface {
	Status(txID string) (driver.ValidationCode, string, error)
	SetStatus(txID string, code driver.ValidationCode) error
	Statuses(ids ...string) ([]driver.TxValidationStatus, error)
	DiscardTx(txID string, message string) error
	CommitTX(ctx context.Context, txid string, block driver.BlockNum, indexInBloc driver.TxNum) error
}

Source Files ¶

View all Source files

committer.go

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