go.temporal.io/server/chasm/engine_mock.go
166 LOC · 33 covered · 133 uncovered · 8 ranges · 554 concepts · 2 introducers · 220 tests
File neighbourhood
The centred file is linked to every concept that introduces one of its ranges, every test that runs code from the file, and the gray connector concepts standing between those tests and the file's own introducer concepts. Undirected links join concepts to every file where they introduce source and concepts to the tests they introduce; arrows show specialization between the displayed concepts and bridge only concepts omitted from this view. Concept colors match the source ranges below; connector concepts have no source color and are shown in gray.
Focused file, its introducer and connector concepts, their introduced files, and tests that run code from the file
In the embedded map, ordinary wheel input scrolls the page; use the visible controls to zoom and drag to pan. Open the full-screen map for canvas navigation: wheel pans, Ctrl/Command plus wheel zooms, and arrow keys pan when this region is focused. On touch screens, open the full-screen map to pan or pinch. If JavaScript or WebGL is unavailable, use the related-file, concept, and source links on this page.
Graph controls are ready.
Interactive rendering requires JavaScript and WebGL. Use the related-file, concept, and source links on this page while the interactive map is unavailable.
1
// Code generated by MockGen. DO NOT EDIT.
2
// Source: engine.go
3
//
4
// Generated by this command:
5
//
6
// mockgen -package chasm -source engine.go -destination engine_mock.go
7
//
8
9
// Package chasm is a generated GoMock package.
10
package chasm
11
12
import (
13
context "context"
14
reflect "reflect"
15
16
gomock "go.uber.org/mock/gomock"
17
)
18
19
// MockEngine is a mock of Engine interface.
20
type MockEngine struct {
21
ctrl *gomock.Controller
22
recorder *MockEngineMockRecorder
23
isgomock struct{}
24
}
25
26
// MockEngineMockRecorder is the mock recorder for MockEngine.
27
type MockEngineMockRecorder struct {
28
mock *MockEngine
29
}
30
31
// NewMockEngine creates a new mock instance.
33
>
mock := &MockEngine{ctrl: ctrl}
34
>
mock.recorder = &MockEngineMockRecorder{mock}
35
>
return mock
36
>
}
37
38
// EXPECT returns an object that allows the caller to indicate expected use.
40
>
return m.recorder
41
>
}
42
43
// DeleteExecution mocks base method.
44
func (m *MockEngine) DeleteExecution(arg0 context.Context, arg1 ComponentRef, arg2 DeleteExecutionRequest) error {
45
m.ctrl.T.Helper()
46
ret := m.ctrl.Call(m, "DeleteExecution", arg0, arg1, arg2)
47
ret0, _ := ret[0].(error)
48
return ret0
49
}
50
51
// DeleteExecution indicates an expected call of DeleteExecution.
52
func (mr *MockEngineMockRecorder) DeleteExecution(arg0, arg1, arg2 any) *gomock.Call {
53
mr.mock.ctrl.T.Helper()
54
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeleteExecution", reflect.TypeOf((*MockEngine)(nil).DeleteExecution), arg0, arg1, arg2)
55
}
56
57
// NotifyExecution mocks base method.
58
func (m *MockEngine) NotifyExecution(arg0 ExecutionKey) {
59
m.ctrl.T.Helper()
60
m.ctrl.Call(m, "NotifyExecution", arg0)
61
}
62
63
// NotifyExecution indicates an expected call of NotifyExecution.
64
func (mr *MockEngineMockRecorder) NotifyExecution(arg0 any) *gomock.Call {
65
mr.mock.ctrl.T.Helper()
66
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "NotifyExecution", reflect.TypeOf((*MockEngine)(nil).NotifyExecution), arg0)
67
}
68
69
// PollComponent mocks base method.
70
func (m *MockEngine) PollComponent(arg0 context.Context, arg1 ComponentRef, arg2 func(Context, Component) (bool, error), arg3 ...TransitionOption) ([]byte, error) {
71
m.ctrl.T.Helper()
72
varargs := []any{arg0, arg1, arg2}
73
for _, a := range arg3 {
74
varargs = append(varargs, a)
75
}
76
ret := m.ctrl.Call(m, "PollComponent", varargs...)
77
ret0, _ := ret[0].([]byte)
78
ret1, _ := ret[1].(error)
79
return ret0, ret1
80
}
81
82
// PollComponent indicates an expected call of PollComponent.
83
func (mr *MockEngineMockRecorder) PollComponent(arg0, arg1, arg2 any, arg3 ...any) *gomock.Call {
84
mr.mock.ctrl.T.Helper()
85
varargs := append([]any{arg0, arg1, arg2}, arg3...)
86
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "PollComponent", reflect.TypeOf((*MockEngine)(nil).PollComponent), varargs...)
87
}
88
89
// ReadComponent mocks base method.
90
>
func (m *MockEngine) ReadComponent(arg0 context.Context, arg1 ComponentRef, arg2 func(Context, Component) error, arg3 ...TransitionOption) error {
engine_mock.go ×7
91
>
m.ctrl.T.Helper()
92
>
varargs := []any{arg0, arg1, arg2}
93
>
for _, a := range arg3 {
94
varargs = append(varargs, a)
95
}
97
>
ret0, _ := ret[0].(error)
98
>
return ret0
99
}
100
101
// ReadComponent indicates an expected call of ReadComponent.
102
>
func (mr *MockEngineMockRecorder) ReadComponent(arg0, arg1, arg2 any, arg3 ...any) *gomock.Call {
engine_mock.go ×7
103
>
mr.mock.ctrl.T.Helper()
104
>
varargs := append([]any{arg0, arg1, arg2}, arg3...)
105
>
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ReadComponent", reflect.TypeOf((*MockEngine)(nil).ReadComponent), varargs...)
106
>
}
107
108
// StartExecution mocks base method.
109
func (m *MockEngine) StartExecution(arg0 context.Context, arg1 ComponentRef, arg2 func(MutableContext) (RootComponent, error), arg3 ...TransitionOption) (StartExecutionResult, error) {
110
m.ctrl.T.Helper()
111
varargs := []any{arg0, arg1, arg2}
112
for _, a := range arg3 {
113
varargs = append(varargs, a)
114
}
115
ret := m.ctrl.Call(m, "StartExecution", varargs...)
116
ret0, _ := ret[0].(StartExecutionResult)
117
ret1, _ := ret[1].(error)
118
return ret0, ret1
119
}
120
121
// StartExecution indicates an expected call of StartExecution.
122
func (mr *MockEngineMockRecorder) StartExecution(arg0, arg1, arg2 any, arg3 ...any) *gomock.Call {
123
mr.mock.ctrl.T.Helper()
124
varargs := append([]any{arg0, arg1, arg2}, arg3...)
125
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "StartExecution", reflect.TypeOf((*MockEngine)(nil).StartExecution), varargs...)
126
}
127
128
// UpdateComponent mocks base method.
129
>
func (m *MockEngine) UpdateComponent(arg0 context.Context, arg1 ComponentRef, arg2 func(MutableContext, Component) error, arg3 ...TransitionOption) ([]byte, error) {
engine_mock.go ×7
130
>
m.ctrl.T.Helper()
131
>
varargs := []any{arg0, arg1, arg2}
132
>
for _, a := range arg3 {
133
varargs = append(varargs, a)
134
}
136
>
ret0, _ := ret[0].([]byte)
137
>
ret1, _ := ret[1].(error)
138
>
return ret0, ret1
139
}
140
141
// UpdateComponent indicates an expected call of UpdateComponent.
142
>
func (mr *MockEngineMockRecorder) UpdateComponent(arg0, arg1, arg2 any, arg3 ...any) *gomock.Call {
engine_mock.go ×7
143
>
mr.mock.ctrl.T.Helper()
144
>
varargs := append([]any{arg0, arg1, arg2}, arg3...)
145
>
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateComponent", reflect.TypeOf((*MockEngine)(nil).UpdateComponent), varargs...)
146
>
}
147
148
// UpdateWithStartExecution mocks base method.
149
func (m *MockEngine) UpdateWithStartExecution(arg0 context.Context, arg1 ComponentRef, arg2 func(MutableContext) (RootComponent, error), arg3 func(MutableContext, Component) error, arg4 ...TransitionOption) (EngineUpdateWithStartExecutionResult, error) {
150
m.ctrl.T.Helper()
151
varargs := []any{arg0, arg1, arg2, arg3}
152
for _, a := range arg4 {
153
varargs = append(varargs, a)
154
}
155
ret := m.ctrl.Call(m, "UpdateWithStartExecution", varargs...)
156
ret0, _ := ret[0].(EngineUpdateWithStartExecutionResult)
157
ret1, _ := ret[1].(error)
158
return ret0, ret1
159
}
160
161
// UpdateWithStartExecution indicates an expected call of UpdateWithStartExecution.
162
func (mr *MockEngineMockRecorder) UpdateWithStartExecution(arg0, arg1, arg2, arg3 any, arg4 ...any) *gomock.Call {
163
mr.mock.ctrl.T.Helper()
164
varargs := append([]any{arg0, arg1, arg2, arg3}, arg4...)
165
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateWithStartExecution", reflect.TypeOf((*MockEngine)(nil).UpdateWithStartExecution), varargs...)
166
}