Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Manager ¶
type Manager interface {
Notify(n *Notification) error
Start()
Stop()
NewBlockHashes() chan<- *ffcapi.BlockHashEvent
CheckInFlight(listenerID *fftypes.UUID) bool
StartConfirmedBlockListener(ctx context.Context, id *fftypes.UUID, fromBlock string, checkpoint *ffcapi.BlockListenerCheckpoint, eventStream chan<- *ffcapi.ListenerEvent) error
StopConfirmedBlockListener(ctx context.Context, id *fftypes.UUID) error
}
Manager listens to the blocks on the chain, and attributes confirmations to pending events. Once those events meet a threshold they are considered final and dispatched to the relevant listener.
type Notification ¶
type Notification struct {
NotificationType NotificationType
Event *EventInfo // NewEventLog, RemovedEventLog
Transaction *TransactionInfo // NewTransaction, RemovedTransaction
RemovedListener *RemovedListenerInfo // ListenerRemoved
// contains filtered or unexported fields
}
type NotificationType ¶
type NotificationType string
const ( NewEventLog NotificationType = "newEventLog" RemovedEventLog NotificationType = "removedEventLog" NewTransaction NotificationType = "newTransaction" RemovedTransaction NotificationType = "removedTransaction" ListenerRemoved NotificationType = "listenerRemoved" )
type RemovedListenerInfo ¶ added in v0.9.3
type TransactionInfo ¶
type TransactionInfo struct {
TransactionHash string
Receipt func(ctx context.Context, receipt *ffcapi.TransactionReceiptResponse)
Confirmations func(ctx context.Context, notification *apitypes.ConfirmationsNotification)
}
Click to show internal directories.
Click to hide internal directories.