eventmocks

Documentation

Index

• type EventManager
  • func (_m *EventManager) AddSystemEventListener(ns string, el system.EventListener) error
  • func (_m *EventManager) BLOBReceived(dx dataexchange.Plugin, peerID string, hash fftypes.Bytes32, payloadRef string) error
  • func (_m *EventManager) BatchPinComplete(bi blockchain.Plugin, batch *blockchain.BatchPin, author string, ...) error
  • func (_m *EventManager) ChangeEvents() chan<- *fftypes.ChangeEvent
  • func (_m *EventManager) CreateUpdateDurableSubscription(ctx context.Context, subDef *fftypes.Subscription, mustNew bool) error
  • func (_m *EventManager) DeleteDurableSubscription(ctx context.Context, subDef *fftypes.Subscription) error
  • func (_m *EventManager) DeletedSubscriptions() chan<- *fftypes.UUID
  • func (_m *EventManager) MessageReceived(dx dataexchange.Plugin, peerID string, data []byte) error
  • func (_m *EventManager) NewEvents() chan<- int64
  • func (_m *EventManager) NewPins() chan<- int64
  • func (_m *EventManager) NewSubscriptions() chan<- *fftypes.UUID
  • func (_m *EventManager) OperationUpdate(plugin fftypes.Named, operationID *fftypes.UUID, txState fftypes.OpStatus, ...) error
  • func (_m *EventManager) Start() error
  • func (_m *EventManager) SubscriptionUpdates() chan<- *fftypes.UUID
  • func (_m *EventManager) TokenPoolCreated(ti tokens.Plugin, pool *tokens.TokenPool, protocolTxID string, ...) error
  • func (_m *EventManager) TokensTransferred(ti tokens.Plugin, poolProtocolID string, transfer *fftypes.TokenTransfer, ...) error
  • func (_m *EventManager) TransferResult(dx dataexchange.Plugin, trackingID string, status fftypes.OpStatus, ...) error
  • func (_m *EventManager) WaitStop()

Types

type EventManager

type EventManager struct {
	mock.Mock
}

EventManager is an autogenerated mock type for the EventManager type

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) BLOBReceived

func (_m *EventManager) BLOBReceived(dx dataexchange.Plugin, peerID string, hash fftypes.Bytes32, payloadRef string) error

BLOBReceived provides a mock function with given fields: dx, peerID, hash, payloadRef

func (*EventManager) BatchPinComplete

func (_m *EventManager) BatchPinComplete(bi blockchain.Plugin, batch *blockchain.BatchPin, author string, protocolTxID string, additionalInfo fftypes.JSONObject) error

BatchPinComplete provides a mock function with given fields: bi, batch, author, protocolTxID, additionalInfo

func (*EventManager) ChangeEvents

func (_m *EventManager) ChangeEvents() chan<- *fftypes.ChangeEvent

ChangeEvents provides a mock function with given fields:

func (*EventManager) CreateUpdateDurableSubscription

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

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

func (*EventManager) DeleteDurableSubscription

func (_m *EventManager) DeleteDurableSubscription(ctx context.Context, subDef *fftypes.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) MessageReceived

func (_m *EventManager) MessageReceived(dx dataexchange.Plugin, peerID string, data []byte) error

MessageReceived provides a mock function with given fields: dx, peerID, data

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) OperationUpdate

func (_m *EventManager) OperationUpdate(plugin fftypes.Named, operationID *fftypes.UUID, txState fftypes.OpStatus, errorMessage string, opOutput fftypes.JSONObject) error

OperationUpdate provides a mock function with given fields: plugin, operationID, txState, errorMessage, opOutput

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, protocolTxID string, additionalInfo fftypes.JSONObject) error

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

func (*EventManager) TokensTransferred

func (_m *EventManager) TokensTransferred(ti tokens.Plugin, poolProtocolID string, transfer *fftypes.TokenTransfer, protocolTxID string, additionalInfo fftypes.JSONObject) error

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

func (*EventManager) TransferResult

func (_m *EventManager) TransferResult(dx dataexchange.Plugin, trackingID string, status fftypes.OpStatus, info string, opOutput fftypes.JSONObject) error

TransferResult provides a mock function with given fields: dx, trackingID, status, info, opOutput

func (*EventManager) WaitStop

func (_m *EventManager) WaitStop()

WaitStop provides a mock function with given fields: