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// ResolveActions provides a mock function for the type RunnerService
421func (_mock *RunnerService) ResolveActions(ctx context.Context, secret string, jobID string, uses []string) ([]ports.ResolvedAction, error) {
422 ret := _mock.Called(ctx, secret, jobID, uses)
423
424 if len(ret) == 0 {
425 panic("no return value specified for ResolveActions")
426 }
427
428 var r0 []ports.ResolvedAction
429 var r1 error
430 if returnFunc, ok := ret.Get(0).(func(context.Context, string, string, []string) ([]ports.ResolvedAction, error)); ok {
431 return returnFunc(ctx, secret, jobID, uses)
432 }
433 if returnFunc, ok := ret.Get(0).(func(context.Context, string, string, []string) []ports.ResolvedAction); ok {
434 r0 = returnFunc(ctx, secret, jobID, uses)
435 } else {
436 if ret.Get(0) != nil {
437 r0 = ret.Get(0).([]ports.ResolvedAction)
438 }
439 }
440 if returnFunc, ok := ret.Get(1).(func(context.Context, string, string, []string) error); ok {
441 r1 = returnFunc(ctx, secret, jobID, uses)
442 } else {
443 r1 = ret.Error(1)
444 }
445 return r0, r1
446}
447
448// RunnerService_ResolveActions_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ResolveActions'
449type RunnerService_ResolveActions_Call struct {
450 *mock.Call
451}
452
453// ResolveActions is a helper method to define mock.On call
454// - ctx context.Context
455// - secret string
456// - jobID string
457// - uses []string
458func (_e *RunnerService_Expecter) ResolveActions(ctx any, secret any, jobID any, uses any) *RunnerService_ResolveActions_Call {
459 return &RunnerService_ResolveActions_Call{Call: _e.mock.On("ResolveActions", ctx, secret, jobID, uses)}
460}
461
462func (_c *RunnerService_ResolveActions_Call) Run(run func(ctx context.Context, secret string, jobID string, uses []string)) *RunnerService_ResolveActions_Call {
463 _c.Call.Run(func(args mock.Arguments) {
464 var arg0 context.Context
465 if args[0] != nil {
466 arg0 = args[0].(context.Context)
467 }
468 var arg1 string
469 if args[1] != nil {
470 arg1 = args[1].(string)
471 }
472 var arg2 string
473 if args[2] != nil {
474 arg2 = args[2].(string)
475 }
476 var arg3 []string
477 if args[3] != nil {
478 arg3 = args[3].([]string)
479 }
480 run(
481 arg0,
482 arg1,
483 arg2,
484 arg3,
485 )
486 })
487 return _c
488}
489
490func (_c *RunnerService_ResolveActions_Call) Return(resolvedActions []ports.ResolvedAction, err error) *RunnerService_ResolveActions_Call {
491 _c.Call.Return(resolvedActions, err)
492 return _c
493}
494
495func (_c *RunnerService_ResolveActions_Call) RunAndReturn(run func(ctx context.Context, secret string, jobID string, uses []string) ([]ports.ResolvedAction, error)) *RunnerService_ResolveActions_Call {
496 _c.Call.Return(run)
497 return _c
498}
499
500// UpdateJob provides a mock function for the type RunnerService
501func (_mock *RunnerService) UpdateJob(ctx context.Context, secret string, jobID string, steps []ports.StepUpdate, annotations []domain.CIAnnotation) error {
502 ret := _mock.Called(ctx, secret, jobID, steps, annotations)
503
504 if len(ret) == 0 {
505 panic("no return value specified for UpdateJob")
506 }
507
508 var r0 error
509 if returnFunc, ok := ret.Get(0).(func(context.Context, string, string, []ports.StepUpdate, []domain.CIAnnotation) error); ok {
510 r0 = returnFunc(ctx, secret, jobID, steps, annotations)
511 } else {
512 r0 = ret.Error(0)
513 }
514 return r0
515}
516
517// RunnerService_UpdateJob_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateJob'
518type RunnerService_UpdateJob_Call struct {
519 *mock.Call
520}
521
522// UpdateJob is a helper method to define mock.On call
523// - ctx context.Context
524// - secret string
525// - jobID string
526// - steps []ports.StepUpdate
527// - annotations []domain.CIAnnotation
528func (_e *RunnerService_Expecter) UpdateJob(ctx any, secret any, jobID any, steps any, annotations any) *RunnerService_UpdateJob_Call {
529 return &RunnerService_UpdateJob_Call{Call: _e.mock.On("UpdateJob", ctx, secret, jobID, steps, annotations)}
530}
531
532func (_c *RunnerService_UpdateJob_Call) Run(run func(ctx context.Context, secret string, jobID string, steps []ports.StepUpdate, annotations []domain.CIAnnotation)) *RunnerService_UpdateJob_Call {
533 _c.Call.Run(func(args mock.Arguments) {
534 var arg0 context.Context
535 if args[0] != nil {
536 arg0 = args[0].(context.Context)
537 }
538 var arg1 string
539 if args[1] != nil {
540 arg1 = args[1].(string)
541 }
542 var arg2 string
543 if args[2] != nil {
544 arg2 = args[2].(string)
545 }
546 var arg3 []ports.StepUpdate
547 if args[3] != nil {
548 arg3 = args[3].([]ports.StepUpdate)
549 }
550 var arg4 []domain.CIAnnotation
551 if args[4] != nil {
552 arg4 = args[4].([]domain.CIAnnotation)
553 }
554 run(
555 arg0,
556 arg1,
557 arg2,
558 arg3,
559 arg4,
560 )
561 })
562 return _c
563}
564
565func (_c *RunnerService_UpdateJob_Call) Return(err error) *RunnerService_UpdateJob_Call {
566 _c.Call.Return(err)
567 return _c
568}
569
570func (_c *RunnerService_UpdateJob_Call) RunAndReturn(run func(ctx context.Context, secret string, jobID string, steps []ports.StepUpdate, annotations []domain.CIAnnotation) error) *RunnerService_UpdateJob_Call {
571 _c.Call.Return(run)
572 return _c
573}
574
575// UploadSummary provides a mock function for the type RunnerService
576func (_mock *RunnerService) UploadSummary(ctx context.Context, secret string, jobID string, step int32, markdown string) error {
577 ret := _mock.Called(ctx, secret, jobID, step, markdown)
578
579 if len(ret) == 0 {
580 panic("no return value specified for UploadSummary")
581 }
582
583 var r0 error
584 if returnFunc, ok := ret.Get(0).(func(context.Context, string, string, int32, string) error); ok {
585 r0 = returnFunc(ctx, secret, jobID, step, markdown)
586 } else {
587 r0 = ret.Error(0)
588 }
589 return r0
590}
591
592// RunnerService_UploadSummary_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UploadSummary'
593type RunnerService_UploadSummary_Call struct {
594 *mock.Call
595}
596
597// UploadSummary is a helper method to define mock.On call
598// - ctx context.Context
599// - secret string
600// - jobID string
601// - step int32
602// - markdown string
603func (_e *RunnerService_Expecter) UploadSummary(ctx any, secret any, jobID any, step any, markdown any) *RunnerService_UploadSummary_Call {
604 return &RunnerService_UploadSummary_Call{Call: _e.mock.On("UploadSummary", ctx, secret, jobID, step, markdown)}
605}
606
607func (_c *RunnerService_UploadSummary_Call) Run(run func(ctx context.Context, secret string, jobID string, step int32, markdown string)) *RunnerService_UploadSummary_Call {
608 _c.Call.Run(func(args mock.Arguments) {
609 var arg0 context.Context
610 if args[0] != nil {
611 arg0 = args[0].(context.Context)
612 }
613 var arg1 string
614 if args[1] != nil {
615 arg1 = args[1].(string)
616 }
617 var arg2 string
618 if args[2] != nil {
619 arg2 = args[2].(string)
620 }
621 var arg3 int32
622 if args[3] != nil {
623 arg3 = args[3].(int32)
624 }
625 var arg4 string
626 if args[4] != nil {
627 arg4 = args[4].(string)
628 }
629 run(
630 arg0,
631 arg1,
632 arg2,
633 arg3,
634 arg4,
635 )
636 })
637 return _c
638}
639
640func (_c *RunnerService_UploadSummary_Call) Return(err error) *RunnerService_UploadSummary_Call {
641 _c.Call.Return(err)
642 return _c
643}
644
645func (_c *RunnerService_UploadSummary_Call) RunAndReturn(run func(ctx context.Context, secret string, jobID string, step int32, markdown string) error) *RunnerService_UploadSummary_Call {
646 _c.Call.Return(run)
647 return _c
648}
649
650// WatchJob provides a mock function for the type RunnerService
651func (_mock *RunnerService) WatchJob(ctx context.Context, secret string, jobID string, ready func(), send func(ports.JobSignal) error) error {
652 ret := _mock.Called(ctx, secret, jobID, ready, send)
653
654 if len(ret) == 0 {
655 panic("no return value specified for WatchJob")
656 }
657
658 var r0 error
659 if returnFunc, ok := ret.Get(0).(func(context.Context, string, string, func(), func(ports.JobSignal) error) error); ok {
660 r0 = returnFunc(ctx, secret, jobID, ready, send)
661 } else {
662 r0 = ret.Error(0)
663 }
664 return r0
665}
666
667// RunnerService_WatchJob_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'WatchJob'
668type RunnerService_WatchJob_Call struct {
669 *mock.Call
670}
671
672// WatchJob is a helper method to define mock.On call
673// - ctx context.Context
674// - secret string
675// - jobID string
676// - ready func()
677// - send func(ports.JobSignal) error
678func (_e *RunnerService_Expecter) WatchJob(ctx any, secret any, jobID any, ready any, send any) *RunnerService_WatchJob_Call {
679 return &RunnerService_WatchJob_Call{Call: _e.mock.On("WatchJob", ctx, secret, jobID, ready, send)}
680}
681
682func (_c *RunnerService_WatchJob_Call) Run(run func(ctx context.Context, secret string, jobID string, ready func(), send func(ports.JobSignal) error)) *RunnerService_WatchJob_Call {
683 _c.Call.Run(func(args mock.Arguments) {
684 var arg0 context.Context
685 if args[0] != nil {
686 arg0 = args[0].(context.Context)
687 }
688 var arg1 string
689 if args[1] != nil {
690 arg1 = args[1].(string)
691 }
692 var arg2 string
693 if args[2] != nil {
694 arg2 = args[2].(string)
695 }
696 var arg3 func()
697 if args[3] != nil {
698 arg3 = args[3].(func())
699 }
700 var arg4 func(ports.JobSignal) error
701 if args[4] != nil {
702 arg4 = args[4].(func(ports.JobSignal) error)
703 }
704 run(
705 arg0,
706 arg1,
707 arg2,
708 arg3,
709 arg4,
710 )
711 })
712 return _c
713}
714
715func (_c *RunnerService_WatchJob_Call) Return(err error) *RunnerService_WatchJob_Call {
716 _c.Call.Return(err)
717 return _c
718}
719
720func (_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 {
721 _c.Call.Return(run)
722 return _c
723}