kubelatte-ce

1
// Code generated by mockery v2.43.1. DO NOT EDIT.
2

3
package grpc
4

5
import (
6
	context "context"
7
	base "gitverse.ru/synapse/kubelatte/pkg/sideeffect"
8

9
	clientset "gitverse.ru/synapse/kubelatte/pkg/operator/controllers/clientset"
10

11
	kubernetes "k8s.io/client-go/kubernetes"
12

13
	mock "github.com/stretchr/testify/mock"
14

15
	time "time"
16

17
	v1alpha1 "gitverse.ru/synapse/kubelatte/pkg/api/v1alpha1"
18
)
19

20
// ExecutorI is an autogenerated mock type for the ExecutorI type
21
type ExecutorI struct {
22
	mock.Mock
23
}
24

25
// ApplySideEffect provides a mock function with given fields: ctx, info
26
func (_m *ExecutorI) ApplySideEffect(ctx context.Context, info *base.SE) {
27
	_m.Called(ctx, info)
28
}
29

30
// ApplySideEffectCreate provides a mock function with given fields: ctx, info
31
func (_m *ExecutorI) ApplySideEffectCreate(ctx context.Context, info *base.SE) error {
32
	ret := _m.Called(ctx, info)
33

34
	if len(ret) == 0 {
35
		panic("no return value specified for ApplySideEffectCreate")
36
	}
37

38
	var r0 error
39
	if rf, ok := ret.Get(0).(func(context.Context, *base.SE) error); ok {
40
		r0 = rf(ctx, info)
41
	} else {
42
		r0 = ret.Error(0)
43
	}
44

45
	return r0
46
}
47

48
// ApplySideEffectRecreate provides a mock function with given fields: ctx, info
49
func (_m *ExecutorI) ApplySideEffectRecreate(ctx context.Context, info *base.SE) error {
50
	ret := _m.Called(ctx, info)
51

52
	if len(ret) == 0 {
53
		panic("no return value specified for ApplySideEffectRecreate")
54
	}
55

56
	var r0 error
57
	if rf, ok := ret.Get(0).(func(context.Context, *base.SE) error); ok {
58
		r0 = rf(ctx, info)
59
	} else {
60
		r0 = ret.Error(0)
61
	}
62

63
	return r0
64
}
65

66
// PublishTI provides a mock function with given fields: ctx, ti, info
67
func (_m *ExecutorI) PublishTI(ctx context.Context, ti *v1alpha1.TriggerInstance, info *base.SE) error {
68
	ret := _m.Called(ctx, ti, info)
69

70
	if len(ret) == 0 {
71
		panic("no return value specified for PublishTI")
72
	}
73

74
	var r0 error
75
	if rf, ok := ret.Get(0).(func(context.Context, *v1alpha1.TriggerInstance, *base.SE) error); ok {
76
		r0 = rf(ctx, ti, info)
77
	} else {
78
		r0 = ret.Error(0)
79
	}
80

81
	return r0
82
}
83

84
// SetKbltCli provides a mock function with given fields: kbltCli
85
func (_m *ExecutorI) SetKbltCli(kbltCli clientset.V1Alpha1Interface) {
86
	_m.Called(kbltCli)
87
}
88

89
// SetKubeCli provides a mock function with given fields: kubeCli
90
func (_m *ExecutorI) SetKubeCli(kubeCli *kubernetes.Clientset) {
91
	_m.Called(kubeCli)
92
}
93

94
// WaitForParentPublication provides a mock function with given fields: ctx, timeout, info, checkParentUpdate
95
func (_m *ExecutorI) WaitForParentPublication(ctx context.Context, timeout time.Duration, info *base.SE, checkParentUpdate func([]byte, int64) base.ParentStatus) ([]byte, base.ParentStatus, error) {
96
	ret := _m.Called(ctx, timeout, info, checkParentUpdate)
97

98
	if len(ret) == 0 {
99
		panic("no return value specified for WaitForParentPublication")
100
	}
101

102
	var r0 []byte
103
	var r1 base.ParentStatus
104
	var r2 error
105
	if rf, ok := ret.Get(0).(func(context.Context, time.Duration, *base.SE, func([]byte, int64) base.ParentStatus) ([]byte, base.ParentStatus, error)); ok {
106
		return rf(ctx, timeout, info, checkParentUpdate)
107
	}
108
	if rf, ok := ret.Get(0).(func(context.Context, time.Duration, *base.SE, func([]byte, int64) base.ParentStatus) []byte); ok {
109
		r0 = rf(ctx, timeout, info, checkParentUpdate)
110
	} else {
111
		if ret.Get(0) != nil {
112
			r0 = ret.Get(0).([]byte)
113
		}
114
	}
115

116
	if rf, ok := ret.Get(1).(func(context.Context, time.Duration, *base.SE, func([]byte, int64) base.ParentStatus) base.ParentStatus); ok {
117
		r1 = rf(ctx, timeout, info, checkParentUpdate)
118
	} else {
119
		r1 = ret.Get(1).(base.ParentStatus)
120
	}
121

122
	if rf, ok := ret.Get(2).(func(context.Context, time.Duration, *base.SE, func([]byte, int64) base.ParentStatus) error); ok {
123
		r2 = rf(ctx, timeout, info, checkParentUpdate)
124
	} else {
125
		r2 = ret.Error(2)
126
	}
127

128
	return r0, r1, r2
129
}
130

131
// NewExecutorI creates a new instance of ExecutorI. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
132
// The first argument is typically a *testing.T value.
133
func NewExecutorI(t interface {
134
	mock.TestingT
135
	Cleanup(func())
136
}) *ExecutorI {
137
	mock := &ExecutorI{}
138
	mock.Mock.Test(t)
139

140
	t.Cleanup(func() { mock.AssertExpectations(t) })
141

142
	return mock
143
}
144