events

Documentation

Index

• type EventManager
  • func NewEventManager(ctx context.Context, ni sysmessaging.LocalNodeInfo, si sharedstorage.Plugin, ...) (EventManager, error)

Types

type EventManager

type EventManager interface {
	NewPins() chan<- int64
	NewEvents() chan<- int64
	NewSubscriptions() chan<- *fftypes.UUID
	SubscriptionUpdates() chan<- *fftypes.UUID
	DeletedSubscriptions() chan<- *fftypes.UUID
	ChangeEvents() chan<- *fftypes.ChangeEvent
	DeleteDurableSubscription(ctx context.Context, subDef *fftypes.Subscription) (err error)
	CreateUpdateDurableSubscription(ctx context.Context, subDef *fftypes.Subscription, mustNew bool) (err error)
	Start() error
	WaitStop()

	// Bound blockchain callbacks
	OperationUpdate(plugin fftypes.Named, operationID *fftypes.UUID, txState blockchain.TransactionStatus, blockchainTXID, errorMessage string, opOutput fftypes.JSONObject) error
	BatchPinComplete(bi blockchain.Plugin, batch *blockchain.BatchPin, signingKey *fftypes.VerifierRef) error
	BlockchainEvent(event *blockchain.EventWithSubscription) error

	// Bound dataexchange callbacks
	TransferResult(dx dataexchange.Plugin, trackingID string, status fftypes.OpStatus, update fftypes.TransportStatusUpdate) error
	PrivateBLOBReceived(dx dataexchange.Plugin, peerID string, hash fftypes.Bytes32, size int64, payloadRef string) error
	MessageReceived(dx dataexchange.Plugin, peerID string, data []byte) (manifest string, err error)

	// Bound sharedstorage callbacks
	SharedStorageBatchDownloaded(ss sharedstorage.Plugin, ns, payloadRef string, data []byte) (*fftypes.UUID, error)
	SharedStorageBLOBDownloaded(ss sharedstorage.Plugin, hash fftypes.Bytes32, size int64, payloadRef string) error

	// Bound token callbacks
	TokenPoolCreated(ti tokens.Plugin, pool *tokens.TokenPool) error
	TokensTransferred(ti tokens.Plugin, transfer *tokens.TokenTransfer) error
	TokensApproved(ti tokens.Plugin, approval *tokens.TokenApproval) error

	// Internal events
	sysmessaging.SystemEvents
}

func NewEventManager

func NewEventManager(ctx context.Context, ni sysmessaging.LocalNodeInfo, si sharedstorage.Plugin, di database.Plugin, bi blockchain.Plugin, im identity.Manager, dh definitions.DefinitionHandlers, dm data.Manager, bm broadcast.Manager, pm privatemessaging.Manager, am assets.Manager, sd shareddownload.Manager, mm metrics.Manager, txHelper txcommon.Helper) (EventManager, error)