...
1
2
3
4
5 package mocks
6
7 import (
8 context "context"
9 reflect "reflect"
10
11 events "github.com/containerd/containerd/events"
12 gomock "github.com/golang/mock/gomock"
13 )
14
15
16 type MockEventService struct {
17 ctrl *gomock.Controller
18 recorder *MockEventServiceMockRecorder
19 }
20
21
22 type MockEventServiceMockRecorder struct {
23 mock *MockEventService
24 }
25
26
27 func NewMockEventService(ctrl *gomock.Controller) *MockEventService {
28 mock := &MockEventService{ctrl: ctrl}
29 mock.recorder = &MockEventServiceMockRecorder{mock}
30 return mock
31 }
32
33
34 func (m *MockEventService) EXPECT() *MockEventServiceMockRecorder {
35 return m.recorder
36 }
37
38
39 func (m *MockEventService) Forward(arg0 context.Context, arg1 *events.Envelope) error {
40 m.ctrl.T.Helper()
41 ret := m.ctrl.Call(m, "Forward", arg0, arg1)
42 ret0, _ := ret[0].(error)
43 return ret0
44 }
45
46
47 func (mr *MockEventServiceMockRecorder) Forward(arg0, arg1 interface{}) *gomock.Call {
48 mr.mock.ctrl.T.Helper()
49 return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Forward", reflect.TypeOf((*MockEventService)(nil).Forward), arg0, arg1)
50 }
51
52
53 func (m *MockEventService) Publish(arg0 context.Context, arg1 string, arg2 events.Event) error {
54 m.ctrl.T.Helper()
55 ret := m.ctrl.Call(m, "Publish", arg0, arg1, arg2)
56 ret0, _ := ret[0].(error)
57 return ret0
58 }
59
60
61 func (mr *MockEventServiceMockRecorder) Publish(arg0, arg1, arg2 interface{}) *gomock.Call {
62 mr.mock.ctrl.T.Helper()
63 return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Publish", reflect.TypeOf((*MockEventService)(nil).Publish), arg0, arg1, arg2)
64 }
65
66
67 func (m *MockEventService) Subscribe(arg0 context.Context, arg1 ...string) (<-chan *events.Envelope, <-chan error) {
68 m.ctrl.T.Helper()
69 varargs := []interface{}{arg0}
70 for _, a := range arg1 {
71 varargs = append(varargs, a)
72 }
73 ret := m.ctrl.Call(m, "Subscribe", varargs...)
74 ret0, _ := ret[0].(<-chan *events.Envelope)
75 ret1, _ := ret[1].(<-chan error)
76 return ret0, ret1
77 }
78
79
80 func (mr *MockEventServiceMockRecorder) Subscribe(arg0 interface{}, arg1 ...interface{}) *gomock.Call {
81 mr.mock.ctrl.T.Helper()
82 varargs := append([]interface{}{arg0}, arg1...)
83 return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Subscribe", reflect.TypeOf((*MockEventService)(nil).Subscribe), varargs...)
84 }
85
View as plain text