Documentation ¶
Index ¶
- type Manager
- func (_m *Manager) BroadcastMessage(ctx context.Context, in *core.MessageInOut, waitConfirm bool) (*core.Message, error)
- func (_m *Manager) Name() string
- func (_m *Manager) NewBroadcast(in *core.MessageInOut) syncasync.Sender
- func (_m *Manager) PrepareOperation(ctx context.Context, op *core.Operation) (*core.PreparedOperation, error)
- func (_m *Manager) PublishDataBlob(ctx context.Context, id string, idempotencyKey core.IdempotencyKey) (*core.Data, error)
- func (_m *Manager) PublishDataValue(ctx context.Context, id string, idempotencyKey core.IdempotencyKey) (*core.Data, error)
- func (_m *Manager) RunOperation(ctx context.Context, op *core.PreparedOperation) (fftypes.JSONObject, bool, error)
- func (_m *Manager) Start() error
- func (_m *Manager) WaitStop()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Manager ¶
Manager is an autogenerated mock type for the Manager type
func NewManager ¶ added in v1.1.2
func NewManager(t mockConstructorTestingTNewManager) *Manager
NewManager creates a new instance of Manager. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*Manager) BroadcastMessage ¶
func (_m *Manager) BroadcastMessage(ctx context.Context, in *core.MessageInOut, waitConfirm bool) (*core.Message, error)
BroadcastMessage provides a mock function with given fields: ctx, in, waitConfirm
func (*Manager) NewBroadcast ¶ added in v0.11.0
func (_m *Manager) NewBroadcast(in *core.MessageInOut) syncasync.Sender
NewBroadcast provides a mock function with given fields: in
func (*Manager) PrepareOperation ¶ added in v0.14.0
func (_m *Manager) PrepareOperation(ctx context.Context, op *core.Operation) (*core.PreparedOperation, error)
PrepareOperation provides a mock function with given fields: ctx, op
func (*Manager) PublishDataBlob ¶ added in v1.1.0
func (_m *Manager) PublishDataBlob(ctx context.Context, id string, idempotencyKey core.IdempotencyKey) (*core.Data, error)
PublishDataBlob provides a mock function with given fields: ctx, id, idempotencyKey
func (*Manager) PublishDataValue ¶ added in v1.1.0
func (_m *Manager) PublishDataValue(ctx context.Context, id string, idempotencyKey core.IdempotencyKey) (*core.Data, error)
PublishDataValue provides a mock function with given fields: ctx, id, idempotencyKey
func (*Manager) RunOperation ¶ added in v0.14.0
func (_m *Manager) RunOperation(ctx context.Context, op *core.PreparedOperation) (fftypes.JSONObject, bool, error)
RunOperation provides a mock function with given fields: ctx, op