Documentation ¶
Index ¶
- type Manager
- func (_m *Manager) AddOrReuseOperation(ctx context.Context, op *core.Operation, hooks ...database.PostCompletionHook) error
- func (_m *Manager) BulkInsertOperations(ctx context.Context, ops ...*core.Operation) error
- func (_m *Manager) GetOperationByIDCached(ctx context.Context, opID *fftypes.UUID) (*core.Operation, error)
- func (_m *Manager) PrepareOperation(ctx context.Context, op *core.Operation) (*core.PreparedOperation, error)
- func (_m *Manager) RegisterHandler(ctx context.Context, handler operations.OperationHandler, ops []fftypes.FFEnum)
- func (_m *Manager) ResolveOperationByID(ctx context.Context, opID *fftypes.UUID, op *core.OperationUpdateDTO) error
- func (_m *Manager) ResubmitOperations(ctx context.Context, txID *fftypes.UUID) (int, []*core.Operation, error)
- func (_m *Manager) RetryOperation(ctx context.Context, opID *fftypes.UUID) (*core.Operation, error)
- func (_m *Manager) RunOperation(ctx context.Context, op *core.PreparedOperation, idempotentSubmit bool) (fftypes.JSONObject, error)
- func (_m *Manager) Start() error
- func (_m *Manager) SubmitOperationUpdate(update *core.OperationUpdate)
- 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
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. The first argument is typically a *testing.T value.
func (*Manager) AddOrReuseOperation ¶
func (_m *Manager) AddOrReuseOperation(ctx context.Context, op *core.Operation, hooks ...database.PostCompletionHook) error
AddOrReuseOperation provides a mock function with given fields: ctx, op, hooks
func (*Manager) BulkInsertOperations ¶ added in v1.3.0
BulkInsertOperations provides a mock function with given fields: ctx, ops
func (*Manager) GetOperationByIDCached ¶ added in v1.1.0
func (_m *Manager) GetOperationByIDCached(ctx context.Context, opID *fftypes.UUID) (*core.Operation, error)
GetOperationByIDCached provides a mock function with given fields: ctx, opID
func (*Manager) PrepareOperation ¶
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) RegisterHandler ¶
func (_m *Manager) RegisterHandler(ctx context.Context, handler operations.OperationHandler, ops []fftypes.FFEnum)
RegisterHandler provides a mock function with given fields: ctx, handler, ops
func (*Manager) ResolveOperationByID ¶ added in v1.0.0
func (_m *Manager) ResolveOperationByID(ctx context.Context, opID *fftypes.UUID, op *core.OperationUpdateDTO) error
ResolveOperationByID provides a mock function with given fields: ctx, opID, op
func (*Manager) ResubmitOperations ¶ added in v1.3.0
func (_m *Manager) ResubmitOperations(ctx context.Context, txID *fftypes.UUID) (int, []*core.Operation, error)
ResubmitOperations provides a mock function with given fields: ctx, txID
func (*Manager) RetryOperation ¶
RetryOperation provides a mock function with given fields: ctx, opID
func (*Manager) RunOperation ¶
func (_m *Manager) RunOperation(ctx context.Context, op *core.PreparedOperation, idempotentSubmit bool) (fftypes.JSONObject, error)
RunOperation provides a mock function with given fields: ctx, op, idempotentSubmit
func (*Manager) SubmitOperationUpdate ¶ added in v1.0.0
func (_m *Manager) SubmitOperationUpdate(update *core.OperationUpdate)
SubmitOperationUpdate provides a mock function with given fields: update