eventmocks

Documentation

Index

• type EventManager
  • func NewEventManager(t mockConstructorTestingTNewEventManager) *EventManager
  • func (_m *EventManager) AddSystemEventListener(ns string, el system.EventListener) error
  • func (_m *EventManager) BatchPinComplete(namespace string, batch *blockchain.BatchPin, signingKey *core.VerifierRef) error
  • func (_m *EventManager) BlockchainEvent(event *blockchain.EventWithSubscription) error
  • func (_m *EventManager) BlockchainNetworkAction(action string, location *fftypes.JSONAny, event *blockchain.Event, ...) error
  • func (_m *EventManager) CreateUpdateDurableSubscription(ctx context.Context, subDef *core.Subscription, mustNew bool) error
  • func (_m *EventManager) DXEvent(plugin dataexchange.Plugin, event dataexchange.DXEvent)
  • func (_m *EventManager) DeleteDurableSubscription(ctx context.Context, subDef *core.Subscription) error
  • func (_m *EventManager) DeletedSubscriptions() chan<- *fftypes.UUID
  • func (_m *EventManager) EnrichEvent(ctx context.Context, event *core.Event) (*core.EnrichedEvent, error)
  • func (_m *EventManager) GetPlugins() []*core.NamespaceStatusPlugin
  • func (_m *EventManager) NewEvents() chan<- int64
  • func (_m *EventManager) NewPins() chan<- int64
  • func (_m *EventManager) NewSubscriptions() chan<- *fftypes.UUID
  • func (_m *EventManager) QueueBatchRewind(batchID *fftypes.UUID)
  • func (_m *EventManager) SharedStorageBatchDownloaded(ss sharedstorage.Plugin, payloadRef string, data []byte) (*fftypes.UUID, error)
  • func (_m *EventManager) SharedStorageBlobDownloaded(ss sharedstorage.Plugin, hash fftypes.Bytes32, size int64, payloadRef string)
  • func (_m *EventManager) Start() error
  • func (_m *EventManager) SubscriptionUpdates() chan<- *fftypes.UUID
  • func (_m *EventManager) TokenPoolCreated(ti tokens.Plugin, pool *tokens.TokenPool) error
  • func (_m *EventManager) TokensApproved(ti tokens.Plugin, approval *tokens.TokenApproval) error
  • func (_m *EventManager) TokensTransferred(ti tokens.Plugin, transfer *tokens.TokenTransfer) error
  • func (_m *EventManager) WaitStop()

Types

type EventManager

type EventManager struct {
	mock.Mock
}

EventManager is an autogenerated mock type for the EventManager type

func NewEventManager

func NewEventManager(t mockConstructorTestingTNewEventManager) *EventManager

NewEventManager creates a new instance of EventManager. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*EventManager) AddSystemEventListener

func (_m *EventManager) AddSystemEventListener(ns string, el system.EventListener) error

AddSystemEventListener provides a mock function with given fields: ns, el

func (*EventManager) BatchPinComplete

func (_m *EventManager) BatchPinComplete(namespace string, batch *blockchain.BatchPin, signingKey *core.VerifierRef) error

BatchPinComplete provides a mock function with given fields: namespace, batch, signingKey

func (*EventManager) BlockchainEvent

func (_m *EventManager) BlockchainEvent(event *blockchain.EventWithSubscription) error

BlockchainEvent provides a mock function with given fields: event

func (*EventManager) BlockchainNetworkAction

func (_m *EventManager) BlockchainNetworkAction(action string, location *fftypes.JSONAny, event *blockchain.Event, signingKey *core.VerifierRef) error

BlockchainNetworkAction provides a mock function with given fields: action, location, event, signingKey

func (*EventManager) CreateUpdateDurableSubscription

func (_m *EventManager) CreateUpdateDurableSubscription(ctx context.Context, subDef *core.Subscription, mustNew bool) error

CreateUpdateDurableSubscription provides a mock function with given fields: ctx, subDef, mustNew

func (*EventManager) DXEvent

func (_m *EventManager) DXEvent(plugin dataexchange.Plugin, event dataexchange.DXEvent)

DXEvent provides a mock function with given fields: plugin, event

func (*EventManager) DeleteDurableSubscription

func (_m *EventManager) DeleteDurableSubscription(ctx context.Context, subDef *core.Subscription) error

DeleteDurableSubscription provides a mock function with given fields: ctx, subDef

func (*EventManager) DeletedSubscriptions

func (_m *EventManager) DeletedSubscriptions() chan<- *fftypes.UUID

DeletedSubscriptions provides a mock function with given fields:

func (*EventManager) EnrichEvent

func (_m *EventManager) EnrichEvent(ctx context.Context, event *core.Event) (*core.EnrichedEvent, error)

EnrichEvent provides a mock function with given fields: ctx, event

func (*EventManager) GetPlugins

func (_m *EventManager) GetPlugins() []*core.NamespaceStatusPlugin

GetPlugins provides a mock function with given fields:

func (*EventManager) NewEvents

func (_m *EventManager) NewEvents() chan<- int64

NewEvents provides a mock function with given fields:

func (*EventManager) NewPins

func (_m *EventManager) NewPins() chan<- int64

NewPins provides a mock function with given fields:

func (*EventManager) NewSubscriptions

func (_m *EventManager) NewSubscriptions() chan<- *fftypes.UUID

NewSubscriptions provides a mock function with given fields:

func (*EventManager) QueueBatchRewind

func (_m *EventManager) QueueBatchRewind(batchID *fftypes.UUID)

QueueBatchRewind provides a mock function with given fields: batchID

func (*EventManager) SharedStorageBatchDownloaded

func (_m *EventManager) SharedStorageBatchDownloaded(ss sharedstorage.Plugin, payloadRef string, data []byte) (*fftypes.UUID, error)

SharedStorageBatchDownloaded provides a mock function with given fields: ss, payloadRef, data

func (*EventManager) SharedStorageBlobDownloaded

func (_m *EventManager) SharedStorageBlobDownloaded(ss sharedstorage.Plugin, hash fftypes.Bytes32, size int64, payloadRef string)

SharedStorageBlobDownloaded provides a mock function with given fields: ss, hash, size, payloadRef

func (*EventManager) Start

func (_m *EventManager) Start() error

Start provides a mock function with given fields:

func (*EventManager) SubscriptionUpdates

func (_m *EventManager) SubscriptionUpdates() chan<- *fftypes.UUID

SubscriptionUpdates provides a mock function with given fields:

func (*EventManager) TokenPoolCreated

func (_m *EventManager) TokenPoolCreated(ti tokens.Plugin, pool *tokens.TokenPool) error

TokenPoolCreated provides a mock function with given fields: ti, pool

func (*EventManager) TokensApproved

func (_m *EventManager) TokensApproved(ti tokens.Plugin, approval *tokens.TokenApproval) error

TokensApproved provides a mock function with given fields: ti, approval

func (*EventManager) TokensTransferred

func (_m *EventManager) TokensTransferred(ti tokens.Plugin, transfer *tokens.TokenTransfer) error

TokensTransferred provides a mock function with given fields: ti, transfer

func (*EventManager) WaitStop

func (_m *EventManager) WaitStop()

WaitStop provides a mock function with given fields: