476
477
// PutReplicationTaskToDLQ mocks base method.
478
>
func (m *MockExecutionManager) PutReplicationTaskToDLQ(ctx context.Context, request *PutReplicationTaskToDLQRequest) error {
data_interfaces_mock.go
479
>
m.ctrl.T.Helper()
480
>
ret := m.ctrl.Call(m, "PutReplicationTaskToDLQ", ctx, request)
481
>
ret0, _ := ret[0].(error)
482
>
return ret0
483
>
}
484
485
// PutReplicationTaskToDLQ indicates an expected call of PutReplicationTaskToDLQ.
486
>
func (mr *MockExecutionManagerMockRecorder) PutReplicationTaskToDLQ(ctx, request any) *gomock.Call {
data_interfaces_mock.go
487
>
mr.mock.ctrl.T.Helper()
488
>
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "PutReplicationTaskToDLQ", reflect.TypeOf((*MockExecutionManager)(nil).PutReplicationTaskToDLQ), ctx, request)
489
>
}
490
491
// RangeCompleteHistoryTasks mocks base method.