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.