events

Documentation

Index

• Constants
• type Event
• type Processor
  • func NewProcessor(eventsQueueCtor taskqueue.ProcessorCtor, invoiceStore invoice.Store, ...) (p *Processor, err error)
  • func (p *Processor) Submit(ctx context.Context, entry *model.Entry) error
  • func (p *Processor) Write(ctx context.Context, entry *model.Entry) error
• type SolanaEvent
• type StellarEvent
• type Submitter
• type TransactionEvent

Constants

const (
	// IngestionQueueName is the events ingestion queue name
	IngestionQueueName = "events-ingestion-queue"
)

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,
	appMapper app.Mapper,
	webhookClient *webhook.Client,
) (p *Processor, err error)

func (*Processor) Submit

func (p *Processor) Submit(ctx context.Context, entry *model.Entry) error

Submit implements Submitter.Submit.

func (*Processor) Write

func (p *Processor) Write(ctx context.Context, entry *model.Entry) error

Write implements history.Writer.Write.

Write forwards model.Entry's to a taskqueue, where other processors will attempt to notify any webhooks that might be interested in the transaction.

type SolanaEvent

type SolanaEvent struct {
	Transaction         []byte `json:"transaction"`
	TransactionError    string `json:"transaction_error"`
	TransactionErrorRaw []byte `json:"transaction_error_raw"`
}

SolanaEvent is stellar specific data related to a transaction.

type StellarEvent

type StellarEvent struct {
	EnvelopeXDR []byte `json:"envelope_xdr"`
	ResultXDR   []byte `json:"result_xdr"`
}

StellarEvent is stellar specific data related to a transaction.

type Submitter

type Submitter interface {
	Submit(context.Context, *model.Entry) error
}

type TransactionEvent

type TransactionEvent struct {
	KinVersion  int                   `json:"kin_version"`
	TxHash      []byte                `json:"tx_hash"`
	TxID        []byte                `json:"tx_id"`
	InvoiceList *commonpb.InvoiceList `json:"invoice_list"`

	StellarEvent *StellarEvent `json:"stellar_event"`
	SolanaEvent  *SolanaEvent  `json:"solana_event"`
}

TransactionEvent is an event containing transaction details.