Documentation
¶
Index ¶
Constants ¶
View Source
const (
// IngestionQueueName is the events ingestion queue name
IngestionQueueName = "events-ingestion-queue"
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Event ¶
type Event struct {
TransactionEvent *TransactionEvent `json:"transaction_event"`
}
Event is a top level event container for blockchain events.
type Processor ¶
type Processor struct {
// contains filtered or unexported fields
}
Processor processes transactions as a history.Writer, and notifies webhooks about said transactions via a taskqueue.
func NewProcessor ¶
func NewProcessor( eventsQueueCtor taskqueue.ProcessorCtor, invoiceStore invoice.Store, configStore app.ConfigStore, webhookClient *webhook.Client, ) (p *Processor, err error)
type StellarData ¶
type StellarData struct {
EnvelopeXDR []byte `json:"envelope_xdr"`
ResultXDR []byte `json:"result_xdr"`
}
StellarData is stellar specific data related to a transaction.
type TransactionEvent ¶
type TransactionEvent struct {
KinVersion int `json:"kin_version"`
TxHash []byte `json:"tx_hash"`
InvoiceList *commonpb.InvoiceList `json:"invoice_list"`
StellarEvent *StellarData `json:"stellar_event"`
}
TransactionEvent is an event containing transaction details.
Source Files
Click to show internal directories.
Click to hide internal directories.