eventmocks

package
v1.3.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 3, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type EventManager 

type EventManager struct {
	mock.Mock
}

EventManager is an autogenerated mock type for the EventManager type

func NewEventManager added in v1.1.2 

func NewEventManager(t interface {
	mock.TestingT
	Cleanup(func())
}) *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. The first argument is typically a *testing.T value.

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) BlockchainEventBatch added in v1.3.0 

func (_m *EventManager) BlockchainEventBatch(batch []*blockchain.EventToDispatch) error

BlockchainEventBatch provides a mock function with given fields: batch

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 added in v1.0.0 

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

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 added in v1.1.0 

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) EnrichEvents added in v1.3.0 

func (_m *EventManager) EnrichEvents(ctx context.Context, _a1 []*core.Event) ([]*core.EnrichedEvent, error)

EnrichEvents provides a mock function with given fields: ctx, _a1

func (*EventManager) FilterHistoricalEventsOnSubscription added in v1.3.0 

func (_m *EventManager) FilterHistoricalEventsOnSubscription(ctx context.Context, _a1 []*core.EnrichedEvent, sub *core.Subscription) ([]*core.EnrichedEvent, error)

FilterHistoricalEventsOnSubscription provides a mock function with given fields: ctx, _a1, sub

func (*EventManager) GetPlugins added in v1.0.0 

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 added in v1.1.0 

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

QueueBatchRewind provides a mock function with given fields: batchID

func (*EventManager) ResolveTransportAndCapabilities added in v1.3.0 

func (_m *EventManager) ResolveTransportAndCapabilities(ctx context.Context, transportName string) (string, *pkgevents.Capabilities, error)

ResolveTransportAndCapabilities provides a mock function with given fields: ctx, transportName

func (*EventManager) SharedStorageBatchDownloaded added in v0.14.0 

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 added in v1.0.0 

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

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

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 added in v0.11.0 

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

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

func (*EventManager) TokensApproved added in v0.13.1 

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

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

func (*EventManager) TokensTransferred added in v0.10.1 

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:

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.