1// Code generated by mockery; DO NOT EDIT.
2// github.com/vektra/mockery
3// template: testify
4
5package mocks
6
7import (
8 "context"
9
10 "bnema.dev/ermite/internal/domain"
11 "bnema.dev/ermite/internal/ports"
12 mock "github.com/stretchr/testify/mock"
13)
14
15// NewRunnerService creates a new instance of RunnerService. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
16// The first argument is typically a *testing.T value.
17func NewRunnerService(t interface {
18 mock.TestingT
19 Cleanup(func())
20}) *RunnerService {
21 if helper, ok := t.(interface{ Helper() }); ok {
22 helper.Helper()
23 }
24
25 mock := &RunnerService{}
26 mock.Mock.Test(t)
27
28 t.Cleanup(func() {
29 if helper, ok := t.(interface{ Helper() }); ok {
30 helper.Helper()
31 }
32 mock.AssertExpectations(t)
33 })
34
35 return mock
36}
37
38// RunnerService is an autogenerated mock type for the RunnerService type
39type RunnerService struct {
40 mock.Mock
41}
42
43type RunnerService_Expecter struct {
44 mock *mock.Mock
45}
46
47func (_m *RunnerService) EXPECT() *RunnerService_Expecter {
48 return &RunnerService_Expecter{mock: &_m.Mock}
49}
50
51// AppendLog provides a mock function for the type RunnerService
52func (_mock *RunnerService) AppendLog(ctx context.Context, secret string, jobID string, step int32, offset int64, lines []domain.CILogLine) (int64, error) {
53 ret := _mock.Called(ctx, secret, jobID, step, offset, lines)
54
55 if len(ret) == 0 {
56 panic("no return value specified for AppendLog")
57 }
58
59 var r0 int64
60 var r1 error
61 if returnFunc, ok := ret.Get(0).(func(context.Context, string, string, int32, int64, []domain.CILogLine) (int64, error)); ok {
62 return returnFunc(ctx, secret, jobID, step, offset, lines)
63 }
64 if returnFunc, ok := ret.Get(0).(func(context.Context, string, string, int32, int64, []domain.CILogLine) int64); ok {
65 r0 = returnFunc(ctx, secret, jobID, step, offset, lines)
66 } else {
67 r0 = ret.Get(0).(int64)
68 }
69 if returnFunc, ok := ret.Get(1).(func(context.Context, string, string, int32, int64, []domain.CILogLine) error); ok {
70 r1 = returnFunc(ctx, secret, jobID, step, offset, lines)
71 } else {
72 r1 = ret.Error(1)
73 }
74 return r0, r1
75}
76
77// RunnerService_AppendLog_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AppendLog'
78type RunnerService_AppendLog_Call struct {
79 *mock.Call
80}
81
82// AppendLog is a helper method to define mock.On call
83// - ctx context.Context
84// - secret string
85// - jobID string
86// - step int32
87// - offset int64
88// - lines []domain.CILogLine
89func (_e *RunnerService_Expecter) AppendLog(ctx any, secret any, jobID any, step any, offset any, lines any) *RunnerService_AppendLog_Call {
90 return &RunnerService_AppendLog_Call{Call: _e.mock.On("AppendLog", ctx, secret, jobID, step, offset, lines)}
91}
92
93func (_c *RunnerService_AppendLog_Call) Run(run func(ctx context.Context, secret string, jobID string, step int32, offset int64, lines []domain.CILogLine)) *RunnerService_AppendLog_Call {
94 _c.Call.Run(func(args mock.Arguments) {
95 var arg0 context.Context
96 if args[0] != nil {
97 arg0 = args[0].(context.Context)
98 }
99 var arg1 string
100 if args[1] != nil {
101 arg1 = args[1].(string)
102 }
103 var arg2 string
104 if args[2] != nil {
105 arg2 = args[2].(string)
106 }
107 var arg3 int32
108 if args[3] != nil {
109 arg3 = args[3].(int32)
110 }
111 var arg4 int64
112 if args[4] != nil {
113 arg4 = args[4].(int64)
114 }
115 var arg5 []domain.CILogLine
116 if args[5] != nil {
117 arg5 = args[5].([]domain.CILogLine)
118 }
119 run(
120 arg0,
121 arg1,
122 arg2,
123 arg3,
124 arg4,
125 arg5,
126 )
127 })
128 return _c
129}
130
131func (_c *RunnerService_AppendLog_Call) Return(next int64, err error) *RunnerService_AppendLog_Call {
132 _c.Call.Return(next, err)
133 return _c
134}
135
136func (_c *RunnerService_AppendLog_Call) RunAndReturn(run func(ctx context.Context, secret string, jobID string, step int32, offset int64, lines []domain.CILogLine) (int64, error)) *RunnerService_AppendLog_Call {
137 _c.Call.Return(run)
138 return _c
139}
140
141// CompleteJob provides a mock function for the type RunnerService
142func (_mock *RunnerService) CompleteJob(ctx context.Context, secret string, params ports.CompleteJobParams) (ports.CompleteJobResult, error) {
143 ret := _mock.Called(ctx, secret, params)
144
145 if len(ret) == 0 {
146 panic("no return value specified for CompleteJob")
147 }
148
149 var r0 ports.CompleteJobResult
150 var r1 error
151 if returnFunc, ok := ret.Get(0).(func(context.Context, string, ports.CompleteJobParams) (ports.CompleteJobResult, error)); ok {
152 return returnFunc(ctx, secret, params)
153 }
154 if returnFunc, ok := ret.Get(0).(func(context.Context, string, ports.CompleteJobParams) ports.CompleteJobResult); ok {
155 r0 = returnFunc(ctx, secret, params)
156 } else {
157 r0 = ret.Get(0).(ports.CompleteJobResult)
158 }
159 if returnFunc, ok := ret.Get(1).(func(context.Context, string, ports.CompleteJobParams) error); ok {
160 r1 = returnFunc(ctx, secret, params)
161 } else {
162 r1 = ret.Error(1)
163 }
164 return r0, r1
165}
166
167// RunnerService_CompleteJob_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CompleteJob'
168type RunnerService_CompleteJob_Call struct {
169 *mock.Call
170}
171
172// CompleteJob is a helper method to define mock.On call
173// - ctx context.Context
174// - secret string
175// - params ports.CompleteJobParams
176func (_e *RunnerService_Expecter) CompleteJob(ctx any, secret any, params any) *RunnerService_CompleteJob_Call {
177 return &RunnerService_CompleteJob_Call{Call: _e.mock.On("CompleteJob", ctx, secret, params)}
178}
179
180func (_c *RunnerService_CompleteJob_Call) Run(run func(ctx context.Context, secret string, params ports.CompleteJobParams)) *RunnerService_CompleteJob_Call {
181 _c.Call.Run(func(args mock.Arguments) {
182 var arg0 context.Context
183 if args[0] != nil {
184 arg0 = args[0].(context.Context)
185 }
186 var arg1 string
187 if args[1] != nil {
188 arg1 = args[1].(string)
189 }
190 var arg2 ports.CompleteJobParams
191 if args[2] != nil {
192 arg2 = args[2].(ports.CompleteJobParams)
193 }
194 run(
195 arg0,
196 arg1,
197 arg2,
198 )
199 })
200 return _c
201}
202
203func (_c *RunnerService_CompleteJob_Call) Return(completeJobResult ports.CompleteJobResult, err error) *RunnerService_CompleteJob_Call {
204 _c.Call.Return(completeJobResult, err)
205 return _c
206}
207
208func (_c *RunnerService_CompleteJob_Call) RunAndReturn(run func(ctx context.Context, secret string, params ports.CompleteJobParams) (ports.CompleteJobResult, error)) *RunnerService_CompleteJob_Call {
209 _c.Call.Return(run)
210 return _c
211}
212
213// FetchJob provides a mock function for the type RunnerService
214func (_mock *RunnerService) FetchJob(ctx context.Context, secret string, params ports.FetchJobParams) (ports.FetchJobResult, error) {
215 ret := _mock.Called(ctx, secret, params)
216
217 if len(ret) == 0 {
218 panic("no return value specified for FetchJob")
219 }
220
221 var r0 ports.FetchJobResult
222 var r1 error
223 if returnFunc, ok := ret.Get(0).(func(context.Context, string, ports.FetchJobParams) (ports.FetchJobResult, error)); ok {
224 return returnFunc(ctx, secret, params)
225 }
226 if returnFunc, ok := ret.Get(0).(func(context.Context, string, ports.FetchJobParams) ports.FetchJobResult); ok {
227 r0 = returnFunc(ctx, secret, params)
228 } else {
229 r0 = ret.Get(0).(ports.FetchJobResult)
230 }
231 if returnFunc, ok := ret.Get(1).(func(context.Context, string, ports.FetchJobParams) error); ok {
232 r1 = returnFunc(ctx, secret, params)
233 } else {
234 r1 = ret.Error(1)
235 }
236 return r0, r1
237}
238
239// RunnerService_FetchJob_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FetchJob'
240type RunnerService_FetchJob_Call struct {
241 *mock.Call
242}
243
244// FetchJob is a helper method to define mock.On call
245// - ctx context.Context
246// - secret string
247// - params ports.FetchJobParams
248func (_e *RunnerService_Expecter) FetchJob(ctx any, secret any, params any) *RunnerService_FetchJob_Call {
249 return &RunnerService_FetchJob_Call{Call: _e.mock.On("FetchJob", ctx, secret, params)}
250}
251
252func (_c *RunnerService_FetchJob_Call) Run(run func(ctx context.Context, secret string, params ports.FetchJobParams)) *RunnerService_FetchJob_Call {
253 _c.Call.Run(func(args mock.Arguments) {
254 var arg0 context.Context
255 if args[0] != nil {
256 arg0 = args[0].(context.Context)
257 }
258 var arg1 string
259 if args[1] != nil {
260 arg1 = args[1].(string)
261 }
262 var arg2 ports.FetchJobParams
263 if args[2] != nil {
264 arg2 = args[2].(ports.FetchJobParams)
265 }
266 run(
267 arg0,
268 arg1,
269 arg2,
270 )
271 })
272 return _c
273}
274
275func (_c *RunnerService_FetchJob_Call) Return(fetchJobResult ports.FetchJobResult, err error) *RunnerService_FetchJob_Call {
276 _c.Call.Return(fetchJobResult, err)
277 return _c
278}
279
280func (_c *RunnerService_FetchJob_Call) RunAndReturn(run func(ctx context.Context, secret string, params ports.FetchJobParams) (ports.FetchJobResult, error)) *RunnerService_FetchJob_Call {
281 _c.Call.Return(run)
282 return _c
283}
284
285// Heartbeat provides a mock function for the type RunnerService
286func (_mock *RunnerService) Heartbeat(ctx context.Context, secret string, jobID string) error {
287 ret := _mock.Called(ctx, secret, jobID)
288
289 if len(ret) == 0 {
290 panic("no return value specified for Heartbeat")
291 }
292
293 var r0 error
294 if returnFunc, ok := ret.Get(0).(func(context.Context, string, string) error); ok {
295 r0 = returnFunc(ctx, secret, jobID)
296 } else {
297 r0 = ret.Error(0)
298 }
299 return r0
300}
301
302// RunnerService_Heartbeat_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Heartbeat'
303type RunnerService_Heartbeat_Call struct {
304 *mock.Call
305}
306
307// Heartbeat is a helper method to define mock.On call
308// - ctx context.Context
309// - secret string
310// - jobID string
311func (_e *RunnerService_Expecter) Heartbeat(ctx any, secret any, jobID any) *RunnerService_Heartbeat_Call {
312 return &RunnerService_Heartbeat_Call{Call: _e.mock.On("Heartbeat", ctx, secret, jobID)}
313}
314
315func (_c *RunnerService_Heartbeat_Call) Run(run func(ctx context.Context, secret string, jobID string)) *RunnerService_Heartbeat_Call {
316 _c.Call.Run(func(args mock.Arguments) {
317 var arg0 context.Context
318 if args[0] != nil {
319 arg0 = args[0].(context.Context)
320 }
321 var arg1 string
322 if args[1] != nil {
323 arg1 = args[1].(string)
324 }
325 var arg2 string
326 if args[2] != nil {
327 arg2 = args[2].(string)
328 }
329 run(
330 arg0,
331 arg1,
332 arg2,
333 )
334 })
335 return _c
336}
337
338func (_c *RunnerService_Heartbeat_Call) Return(err error) *RunnerService_Heartbeat_Call {
339 _c.Call.Return(err)
340 return _c
341}
342
343func (_c *RunnerService_Heartbeat_Call) RunAndReturn(run func(ctx context.Context, secret string, jobID string) error) *RunnerService_Heartbeat_Call {
344 _c.Call.Return(run)
345 return _c
346}
347
348// Register provides a mock function for the type RunnerService
349func (_mock *RunnerService) Register(ctx context.Context, p domain.Principal, params ports.RegisterRunnerParams) (ports.RegisteredRunner, error) {
350 ret := _mock.Called(ctx, p, params)
351
352 if len(ret) == 0 {
353 panic("no return value specified for Register")
354 }
355
356 var r0 ports.RegisteredRunner
357 var r1 error
358 if returnFunc, ok := ret.Get(0).(func(context.Context, domain.Principal, ports.RegisterRunnerParams) (ports.RegisteredRunner, error)); ok {
359 return returnFunc(ctx, p, params)
360 }
361 if returnFunc, ok := ret.Get(0).(func(context.Context, domain.Principal, ports.RegisterRunnerParams) ports.RegisteredRunner); ok {
362 r0 = returnFunc(ctx, p, params)
363 } else {
364 r0 = ret.Get(0).(ports.RegisteredRunner)
365 }
366 if returnFunc, ok := ret.Get(1).(func(context.Context, domain.Principal, ports.RegisterRunnerParams) error); ok {
367 r1 = returnFunc(ctx, p, params)
368 } else {
369 r1 = ret.Error(1)
370 }
371 return r0, r1
372}
373
374// RunnerService_Register_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Register'
375type RunnerService_Register_Call struct {
376 *mock.Call
377}
378
379// Register is a helper method to define mock.On call
380// - ctx context.Context
381// - p domain.Principal
382// - params ports.RegisterRunnerParams
383func (_e *RunnerService_Expecter) Register(ctx any, p any, params any) *RunnerService_Register_Call {
384 return &RunnerService_Register_Call{Call: _e.mock.On("Register", ctx, p, params)}
385}
386
387func (_c *RunnerService_Register_Call) Run(run func(ctx context.Context, p domain.Principal, params ports.RegisterRunnerParams)) *RunnerService_Register_Call {
388 _c.Call.Run(func(args mock.Arguments) {
389 var arg0 context.Context
390 if args[0] != nil {
391 arg0 = args[0].(context.Context)
392 }
393 var arg1 domain.Principal
394 if args[1] != nil {
395 arg1 = args[1].(domain.Principal)
396 }
397 var arg2 ports.RegisterRunnerParams
398 if args[2] != nil {
399 arg2 = args[2].(ports.RegisterRunnerParams)
400 }
401 run(
402 arg0,
403 arg1,
404 arg2,
405 )
406 })
407 return _c
408}
409
410func (_c *RunnerService_Register_Call) Return(registeredRunner ports.RegisteredRunner, err error) *RunnerService_Register_Call {
411 _c.Call.Return(registeredRunner, err)
412 return _c
413}
414
415func (_c *RunnerService_Register_Call) RunAndReturn(run func(ctx context.Context, p domain.Principal, params ports.RegisterRunnerParams) (ports.RegisteredRunner, error)) *RunnerService_Register_Call {
416 _c.Call.Return(run)
417 return _c
418}
419
420// UpdateJob provides a mock function for the type RunnerService
421func (_mock *RunnerService) UpdateJob(ctx context.Context, secret string, jobID string, steps []ports.StepUpdate) error {
422 ret := _mock.Called(ctx, secret, jobID, steps)
423
424 if len(ret) == 0 {
425 panic("no return value specified for UpdateJob")
426 }
427
428 var r0 error
429 if returnFunc, ok := ret.Get(0).(func(context.Context, string, string, []ports.StepUpdate) error); ok {
430 r0 = returnFunc(ctx, secret, jobID, steps)
431 } else {
432 r0 = ret.Error(0)
433 }
434 return r0
435}
436
437// RunnerService_UpdateJob_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateJob'
438type RunnerService_UpdateJob_Call struct {
439 *mock.Call
440}
441
442// UpdateJob is a helper method to define mock.On call
443// - ctx context.Context
444// - secret string
445// - jobID string
446// - steps []ports.StepUpdate
447func (_e *RunnerService_Expecter) UpdateJob(ctx any, secret any, jobID any, steps any) *RunnerService_UpdateJob_Call {
448 return &RunnerService_UpdateJob_Call{Call: _e.mock.On("UpdateJob", ctx, secret, jobID, steps)}
449}
450
451func (_c *RunnerService_UpdateJob_Call) Run(run func(ctx context.Context, secret string, jobID string, steps []ports.StepUpdate)) *RunnerService_UpdateJob_Call {
452 _c.Call.Run(func(args mock.Arguments) {
453 var arg0 context.Context
454 if args[0] != nil {
455 arg0 = args[0].(context.Context)
456 }
457 var arg1 string
458 if args[1] != nil {
459 arg1 = args[1].(string)
460 }
461 var arg2 string
462 if args[2] != nil {
463 arg2 = args[2].(string)
464 }
465 var arg3 []ports.StepUpdate
466 if args[3] != nil {
467 arg3 = args[3].([]ports.StepUpdate)
468 }
469 run(
470 arg0,
471 arg1,
472 arg2,
473 arg3,
474 )
475 })
476 return _c
477}
478
479func (_c *RunnerService_UpdateJob_Call) Return(err error) *RunnerService_UpdateJob_Call {
480 _c.Call.Return(err)
481 return _c
482}
483
484func (_c *RunnerService_UpdateJob_Call) RunAndReturn(run func(ctx context.Context, secret string, jobID string, steps []ports.StepUpdate) error) *RunnerService_UpdateJob_Call {
485 _c.Call.Return(run)
486 return _c
487}
488
489// WatchJob provides a mock function for the type RunnerService
490func (_mock *RunnerService) WatchJob(ctx context.Context, secret string, jobID string, ready func(), send func(ports.JobSignal) error) error {
491 ret := _mock.Called(ctx, secret, jobID, ready, send)
492
493 if len(ret) == 0 {
494 panic("no return value specified for WatchJob")
495 }
496
497 var r0 error
498 if returnFunc, ok := ret.Get(0).(func(context.Context, string, string, func(), func(ports.JobSignal) error) error); ok {
499 r0 = returnFunc(ctx, secret, jobID, ready, send)
500 } else {
501 r0 = ret.Error(0)
502 }
503 return r0
504}
505
506// RunnerService_WatchJob_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'WatchJob'
507type RunnerService_WatchJob_Call struct {
508 *mock.Call
509}
510
511// WatchJob is a helper method to define mock.On call
512// - ctx context.Context
513// - secret string
514// - jobID string
515// - ready func()
516// - send func(ports.JobSignal) error
517func (_e *RunnerService_Expecter) WatchJob(ctx any, secret any, jobID any, ready any, send any) *RunnerService_WatchJob_Call {
518 return &RunnerService_WatchJob_Call{Call: _e.mock.On("WatchJob", ctx, secret, jobID, ready, send)}
519}
520
521func (_c *RunnerService_WatchJob_Call) Run(run func(ctx context.Context, secret string, jobID string, ready func(), send func(ports.JobSignal) error)) *RunnerService_WatchJob_Call {
522 _c.Call.Run(func(args mock.Arguments) {
523 var arg0 context.Context
524 if args[0] != nil {
525 arg0 = args[0].(context.Context)
526 }
527 var arg1 string
528 if args[1] != nil {
529 arg1 = args[1].(string)
530 }
531 var arg2 string
532 if args[2] != nil {
533 arg2 = args[2].(string)
534 }
535 var arg3 func()
536 if args[3] != nil {
537 arg3 = args[3].(func())
538 }
539 var arg4 func(ports.JobSignal) error
540 if args[4] != nil {
541 arg4 = args[4].(func(ports.JobSignal) error)
542 }
543 run(
544 arg0,
545 arg1,
546 arg2,
547 arg3,
548 arg4,
549 )
550 })
551 return _c
552}
553
554func (_c *RunnerService_WatchJob_Call) Return(err error) *RunnerService_WatchJob_Call {
555 _c.Call.Return(err)
556 return _c
557}
558
559func (_c *RunnerService_WatchJob_Call) RunAndReturn(run func(ctx context.Context, secret string, jobID string, ready func(), send func(ports.JobSignal) error) error) *RunnerService_WatchJob_Call {
560 _c.Call.Return(run)
561 return _c
562}