stellar

Documentation

Index

• func New(appConfigStore app.ConfigStore, appMapper app.Mapper, ...) (transactionpb.TransactionServer, error)
• func StreamTransactions(ctx context.Context, hClient horizonclient.ClientInterface, ...)
• type Notifier
• type XDRData

Functions

func New

func New(
	appConfigStore app.ConfigStore,
	appMapper app.Mapper,
	invoiceStore invoice.Store,
	reader history.Reader,
	committer ingestion.Committer,
	authorizer transaction.Authorizer,
	client horizon.ClientInterface,
	kin2Client horizon.ClientInterface,
) (transactionpb.TransactionServer, error)

New returns a new transactionpb.TransactionServer.

func StreamTransactions

func StreamTransactions(ctx context.Context, hClient horizonclient.ClientInterface, notifiers ...Notifier)

StreamTransactions streams transactions from horizon, notifying the provided notifiers with received transactions.

Types

type Notifier

type Notifier interface {
	OnTransaction(XDRData)
}

Notifier notifies that a new transaction has been confirmed on the blockchain.

type XDRData

type XDRData struct {
	Envelope xdr.TransactionEnvelope
	Result   xdr.TransactionResult
	Meta     xdr.TransactionMeta
}