committer

Documentation

Index

• func New(networkName string, pm ProcessorManager, em driver.EnvelopeService, ...) (*committer, error)
• type Finality
• type ProcessorManager
• type TxEvent
• type TxEventsListener
  • func (l *TxEventsListener) OnReceive(event events.Event)
• type Vault

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,
) (*committer, error)

Types

type Finality

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

type ProcessorManager

type ProcessorManager interface {
	ProcessByID(txid string) error
}

type TxEvent

type TxEvent struct {
	Txid           string
	DependantTxIDs []string
	Committed      bool
	Block          uint64
	IndexInBlock   int
	CommitPeer     string
	Err            error
}

TxEvent contains information for token transaction commit

type TxEventsListener

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

func (*TxEventsListener) OnReceive

func (l *TxEventsListener) OnReceive(event events.Event)

type Vault

type Vault interface {
	Status(txID string) (driver.ValidationCode, error)
	DiscardTx(txid string) error
	CommitTX(txid string, block uint64, indexInBloc int) error
}