kubelatte-ce
Форк от sbertech/kubelatte-ce
143 строки · 4.1 Кб
1// Code generated by mockery v2.43.1. DO NOT EDIT.
2
3package grpc4
5import (6context "context"7base "gitverse.ru/ktrntrsv/kubelatte-ce/pkg/sideeffect"8
9clientset "gitverse.ru/ktrntrsv/kubelatte-ce/pkg/operator/controllers/clientset"10
11kubernetes "k8s.io/client-go/kubernetes"12
13mock "github.com/stretchr/testify/mock"14
15time "time"16
17v1alpha1 "gitverse.ru/ktrntrsv/kubelatte-ce/pkg/api/v1alpha1"18)
19
20// ExecutorI is an autogenerated mock type for the ExecutorI type
21type ExecutorI struct {22mock.Mock23}
24
25// ApplySideEffect provides a mock function with given fields: ctx, info
26func (_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
31func (_m *ExecutorI) ApplySideEffectCreate(ctx context.Context, info *base.SE) error {32ret := _m.Called(ctx, info)33
34if len(ret) == 0 {35panic("no return value specified for ApplySideEffectCreate")36}37
38var r0 error39if rf, ok := ret.Get(0).(func(context.Context, *base.SE) error); ok {40r0 = rf(ctx, info)41} else {42r0 = ret.Error(0)43}44
45return r046}
47
48// ApplySideEffectRecreate provides a mock function with given fields: ctx, info
49func (_m *ExecutorI) ApplySideEffectRecreate(ctx context.Context, info *base.SE) error {50ret := _m.Called(ctx, info)51
52if len(ret) == 0 {53panic("no return value specified for ApplySideEffectRecreate")54}55
56var r0 error57if rf, ok := ret.Get(0).(func(context.Context, *base.SE) error); ok {58r0 = rf(ctx, info)59} else {60r0 = ret.Error(0)61}62
63return r064}
65
66// PublishTI provides a mock function with given fields: ctx, ti, info
67func (_m *ExecutorI) PublishTI(ctx context.Context, ti *v1alpha1.TriggerInstance, info *base.SE) error {68ret := _m.Called(ctx, ti, info)69
70if len(ret) == 0 {71panic("no return value specified for PublishTI")72}73
74var r0 error75if rf, ok := ret.Get(0).(func(context.Context, *v1alpha1.TriggerInstance, *base.SE) error); ok {76r0 = rf(ctx, ti, info)77} else {78r0 = ret.Error(0)79}80
81return r082}
83
84// SetKbltCli provides a mock function with given fields: kbltCli
85func (_m *ExecutorI) SetKbltCli(kbltCli clientset.V1Alpha1Interface) {86_m.Called(kbltCli)87}
88
89// SetKubeCli provides a mock function with given fields: kubeCli
90func (_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
95func (_m *ExecutorI) WaitForParentPublication(ctx context.Context, timeout time.Duration, info *base.SE, checkParentUpdate func([]byte, int64) base.ParentStatus) ([]byte, base.ParentStatus, error) {96ret := _m.Called(ctx, timeout, info, checkParentUpdate)97
98if len(ret) == 0 {99panic("no return value specified for WaitForParentPublication")100}101
102var r0 []byte103var r1 base.ParentStatus104var r2 error105if rf, ok := ret.Get(0).(func(context.Context, time.Duration, *base.SE, func([]byte, int64) base.ParentStatus) ([]byte, base.ParentStatus, error)); ok {106return rf(ctx, timeout, info, checkParentUpdate)107}108if rf, ok := ret.Get(0).(func(context.Context, time.Duration, *base.SE, func([]byte, int64) base.ParentStatus) []byte); ok {109r0 = rf(ctx, timeout, info, checkParentUpdate)110} else {111if ret.Get(0) != nil {112r0 = ret.Get(0).([]byte)113}114}115
116if rf, ok := ret.Get(1).(func(context.Context, time.Duration, *base.SE, func([]byte, int64) base.ParentStatus) base.ParentStatus); ok {117r1 = rf(ctx, timeout, info, checkParentUpdate)118} else {119r1 = ret.Get(1).(base.ParentStatus)120}121
122if rf, ok := ret.Get(2).(func(context.Context, time.Duration, *base.SE, func([]byte, int64) base.ParentStatus) error); ok {123r2 = rf(ctx, timeout, info, checkParentUpdate)124} else {125r2 = ret.Error(2)126}127
128return r0, r1, r2129}
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.
133func NewExecutorI(t interface {134mock.TestingT135Cleanup(func())136}) *ExecutorI {137mock := &ExecutorI{}138mock.Mock.Test(t)139
140t.Cleanup(func() { mock.AssertExpectations(t) })141
142return mock143}
144