Documentation
¶
Overview ¶
Package mock_modserver is a generated GoMock package.
Package mock_modserver is a generated GoMock package.
Index ¶
- func AgentMeta() *entity.AgentMeta
- func IncomingAgentCtx(t *testing.T, rpcApi *MockAgentRpcApi) context.Context
- type MockAgentRpcApi
- func (m *MockAgentRpcApi) AgentInfo(arg0 context.Context, arg1 *zap.Logger) (*api.AgentInfo, error)
- func (m *MockAgentRpcApi) AgentToken() api.AgentToken
- func (m *MockAgentRpcApi) EXPECT() *MockAgentRpcApiMockRecorder
- func (m *MockAgentRpcApi) HandleIoError(arg0 *zap.Logger, arg1 string, arg2 error) error
- func (m *MockAgentRpcApi) HandleProcessingError(arg0 *zap.Logger, arg1 int64, arg2 string, arg3 error)
- func (m *MockAgentRpcApi) Log() *zap.Logger
- func (m *MockAgentRpcApi) PollWithBackoff(arg0 retry.PollConfig, arg1 retry.PollWithBackoffFunc) error
- type MockAgentRpcApiAgentInfoCall
- func (c *MockAgentRpcApiAgentInfoCall) Do(f func(context.Context, *zap.Logger) (*api.AgentInfo, error)) *MockAgentRpcApiAgentInfoCall
- func (c *MockAgentRpcApiAgentInfoCall) DoAndReturn(f func(context.Context, *zap.Logger) (*api.AgentInfo, error)) *MockAgentRpcApiAgentInfoCall
- func (c *MockAgentRpcApiAgentInfoCall) Return(arg0 *api.AgentInfo, arg1 error) *MockAgentRpcApiAgentInfoCall
- type MockAgentRpcApiAgentTokenCall
- func (c *MockAgentRpcApiAgentTokenCall) Do(f func() api.AgentToken) *MockAgentRpcApiAgentTokenCall
- func (c *MockAgentRpcApiAgentTokenCall) DoAndReturn(f func() api.AgentToken) *MockAgentRpcApiAgentTokenCall
- func (c *MockAgentRpcApiAgentTokenCall) Return(arg0 api.AgentToken) *MockAgentRpcApiAgentTokenCall
- type MockAgentRpcApiHandleIoErrorCall
- func (c *MockAgentRpcApiHandleIoErrorCall) Do(f func(*zap.Logger, string, error) error) *MockAgentRpcApiHandleIoErrorCall
- func (c *MockAgentRpcApiHandleIoErrorCall) DoAndReturn(f func(*zap.Logger, string, error) error) *MockAgentRpcApiHandleIoErrorCall
- func (c *MockAgentRpcApiHandleIoErrorCall) Return(arg0 error) *MockAgentRpcApiHandleIoErrorCall
- type MockAgentRpcApiHandleProcessingErrorCall
- func (c *MockAgentRpcApiHandleProcessingErrorCall) Do(f func(*zap.Logger, int64, string, error)) *MockAgentRpcApiHandleProcessingErrorCall
- func (c *MockAgentRpcApiHandleProcessingErrorCall) DoAndReturn(f func(*zap.Logger, int64, string, error)) *MockAgentRpcApiHandleProcessingErrorCall
- func (c *MockAgentRpcApiHandleProcessingErrorCall) Return() *MockAgentRpcApiHandleProcessingErrorCall
- type MockAgentRpcApiLogCall
- type MockAgentRpcApiMockRecorder
- func (mr *MockAgentRpcApiMockRecorder) AgentInfo(arg0, arg1 any) *MockAgentRpcApiAgentInfoCall
- func (mr *MockAgentRpcApiMockRecorder) AgentToken() *MockAgentRpcApiAgentTokenCall
- func (mr *MockAgentRpcApiMockRecorder) HandleIoError(arg0, arg1, arg2 any) *MockAgentRpcApiHandleIoErrorCall
- func (mr *MockAgentRpcApiMockRecorder) HandleProcessingError(arg0, arg1, arg2, arg3 any) *MockAgentRpcApiHandleProcessingErrorCall
- func (mr *MockAgentRpcApiMockRecorder) Log() *MockAgentRpcApiLogCall
- func (mr *MockAgentRpcApiMockRecorder) PollWithBackoff(arg0, arg1 any) *MockAgentRpcApiPollWithBackoffCall
- type MockAgentRpcApiPollWithBackoffCall
- func (c *MockAgentRpcApiPollWithBackoffCall) Do(f func(retry.PollConfig, retry.PollWithBackoffFunc) error) *MockAgentRpcApiPollWithBackoffCall
- func (c *MockAgentRpcApiPollWithBackoffCall) DoAndReturn(f func(retry.PollConfig, retry.PollWithBackoffFunc) error) *MockAgentRpcApiPollWithBackoffCall
- func (c *MockAgentRpcApiPollWithBackoffCall) Return(arg0 error) *MockAgentRpcApiPollWithBackoffCall
- type MockApi
- type MockApiHandleProcessingErrorCall
- func (c *MockApiHandleProcessingErrorCall) Do(f func(context.Context, *zap.Logger, int64, string, error)) *MockApiHandleProcessingErrorCall
- func (c *MockApiHandleProcessingErrorCall) DoAndReturn(f func(context.Context, *zap.Logger, int64, string, error)) *MockApiHandleProcessingErrorCall
- func (c *MockApiHandleProcessingErrorCall) Return() *MockApiHandleProcessingErrorCall
- type MockApiMockRecorder
- type MockApiOnGitPushEventCall
- func (c *MockApiOnGitPushEventCall) Do(f func(context.Context, syncz.EventCallback[*event.GitPushEvent])) *MockApiOnGitPushEventCall
- func (c *MockApiOnGitPushEventCall) DoAndReturn(f func(context.Context, syncz.EventCallback[*event.GitPushEvent])) *MockApiOnGitPushEventCall
- func (c *MockApiOnGitPushEventCall) Return() *MockApiOnGitPushEventCall
- type MockFactory
- type MockFactoryMockRecorder
- type MockFactoryNameCall
- type MockFactoryNewCall
- func (c *MockFactoryNewCall) Do(f func(*modserver.Config) (modserver.Module, error)) *MockFactoryNewCall
- func (c *MockFactoryNewCall) DoAndReturn(f func(*modserver.Config) (modserver.Module, error)) *MockFactoryNewCall
- func (c *MockFactoryNewCall) Return(arg0 modserver.Module, arg1 error) *MockFactoryNewCall
- type MockFactoryStartStopPhaseCall
- func (c *MockFactoryStartStopPhaseCall) Do(f func() modshared.ModuleStartStopPhase) *MockFactoryStartStopPhaseCall
- func (c *MockFactoryStartStopPhaseCall) DoAndReturn(f func() modshared.ModuleStartStopPhase) *MockFactoryStartStopPhaseCall
- func (c *MockFactoryStartStopPhaseCall) Return(arg0 modshared.ModuleStartStopPhase) *MockFactoryStartStopPhaseCall
- type MockModule
- type MockModuleMockRecorder
- type MockModuleNameCall
- type MockModuleRunCall
- type MockRpcApi
- func (m *MockRpcApi) EXPECT() *MockRpcApiMockRecorder
- func (m *MockRpcApi) HandleIoError(arg0 *zap.Logger, arg1 string, arg2 error) error
- func (m *MockRpcApi) HandleProcessingError(arg0 *zap.Logger, arg1 int64, arg2 string, arg3 error)
- func (m *MockRpcApi) Log() *zap.Logger
- func (m *MockRpcApi) PollWithBackoff(arg0 retry.PollConfig, arg1 retry.PollWithBackoffFunc) error
- type MockRpcApiHandleIoErrorCall
- func (c *MockRpcApiHandleIoErrorCall) Do(f func(*zap.Logger, string, error) error) *MockRpcApiHandleIoErrorCall
- func (c *MockRpcApiHandleIoErrorCall) DoAndReturn(f func(*zap.Logger, string, error) error) *MockRpcApiHandleIoErrorCall
- func (c *MockRpcApiHandleIoErrorCall) Return(arg0 error) *MockRpcApiHandleIoErrorCall
- type MockRpcApiHandleProcessingErrorCall
- func (c *MockRpcApiHandleProcessingErrorCall) Do(f func(*zap.Logger, int64, string, error)) *MockRpcApiHandleProcessingErrorCall
- func (c *MockRpcApiHandleProcessingErrorCall) DoAndReturn(f func(*zap.Logger, int64, string, error)) *MockRpcApiHandleProcessingErrorCall
- func (c *MockRpcApiHandleProcessingErrorCall) Return() *MockRpcApiHandleProcessingErrorCall
- type MockRpcApiLogCall
- type MockRpcApiMockRecorder
- func (mr *MockRpcApiMockRecorder) HandleIoError(arg0, arg1, arg2 any) *MockRpcApiHandleIoErrorCall
- func (mr *MockRpcApiMockRecorder) HandleProcessingError(arg0, arg1, arg2, arg3 any) *MockRpcApiHandleProcessingErrorCall
- func (mr *MockRpcApiMockRecorder) Log() *MockRpcApiLogCall
- func (mr *MockRpcApiMockRecorder) PollWithBackoff(arg0, arg1 any) *MockRpcApiPollWithBackoffCall
- type MockRpcApiPollWithBackoffCall
- func (c *MockRpcApiPollWithBackoffCall) Do(f func(retry.PollConfig, retry.PollWithBackoffFunc) error) *MockRpcApiPollWithBackoffCall
- func (c *MockRpcApiPollWithBackoffCall) DoAndReturn(f func(retry.PollConfig, retry.PollWithBackoffFunc) error) *MockRpcApiPollWithBackoffCall
- func (c *MockRpcApiPollWithBackoffCall) Return(arg0 error) *MockRpcApiPollWithBackoffCall
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func IncomingAgentCtx ¶
func IncomingAgentCtx(t *testing.T, rpcApi *MockAgentRpcApi) context.Context
Types ¶
type MockAgentRpcApi ¶
type MockAgentRpcApi struct {
// contains filtered or unexported fields
}
MockAgentRpcApi is a mock of AgentRpcApi interface.
func NewMockAgentRpcApi ¶
func NewMockAgentRpcApi(ctrl *gomock.Controller) *MockAgentRpcApi
NewMockAgentRpcApi creates a new mock instance.
func NewMockAgentRpcApiWithMockPoller ¶
func NewMockAgentRpcApiWithMockPoller(ctrl *gomock.Controller, pollTimes int) *MockAgentRpcApi
func (*MockAgentRpcApi) AgentToken ¶
func (m *MockAgentRpcApi) AgentToken() api.AgentToken
AgentToken mocks base method.
func (*MockAgentRpcApi) EXPECT ¶
func (m *MockAgentRpcApi) EXPECT() *MockAgentRpcApiMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockAgentRpcApi) HandleIoError ¶
HandleIoError mocks base method.
func (*MockAgentRpcApi) HandleProcessingError ¶
func (m *MockAgentRpcApi) HandleProcessingError(arg0 *zap.Logger, arg1 int64, arg2 string, arg3 error)
HandleProcessingError mocks base method.
func (*MockAgentRpcApi) PollWithBackoff ¶
func (m *MockAgentRpcApi) PollWithBackoff(arg0 retry.PollConfig, arg1 retry.PollWithBackoffFunc) error
PollWithBackoff mocks base method.
type MockAgentRpcApiAgentInfoCall ¶ added in v16.8.0
MockAgentRpcApiAgentInfoCall wrap *gomock.Call
func (*MockAgentRpcApiAgentInfoCall) Do ¶ added in v16.8.0
func (c *MockAgentRpcApiAgentInfoCall) Do(f func(context.Context, *zap.Logger) (*api.AgentInfo, error)) *MockAgentRpcApiAgentInfoCall
Do rewrite *gomock.Call.Do
func (*MockAgentRpcApiAgentInfoCall) DoAndReturn ¶ added in v16.8.0
func (c *MockAgentRpcApiAgentInfoCall) DoAndReturn(f func(context.Context, *zap.Logger) (*api.AgentInfo, error)) *MockAgentRpcApiAgentInfoCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockAgentRpcApiAgentInfoCall) Return ¶ added in v16.8.0
func (c *MockAgentRpcApiAgentInfoCall) Return(arg0 *api.AgentInfo, arg1 error) *MockAgentRpcApiAgentInfoCall
Return rewrite *gomock.Call.Return
type MockAgentRpcApiAgentTokenCall ¶ added in v16.8.0
MockAgentRpcApiAgentTokenCall wrap *gomock.Call
func (*MockAgentRpcApiAgentTokenCall) Do ¶ added in v16.8.0
func (c *MockAgentRpcApiAgentTokenCall) Do(f func() api.AgentToken) *MockAgentRpcApiAgentTokenCall
Do rewrite *gomock.Call.Do
func (*MockAgentRpcApiAgentTokenCall) DoAndReturn ¶ added in v16.8.0
func (c *MockAgentRpcApiAgentTokenCall) DoAndReturn(f func() api.AgentToken) *MockAgentRpcApiAgentTokenCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockAgentRpcApiAgentTokenCall) Return ¶ added in v16.8.0
func (c *MockAgentRpcApiAgentTokenCall) Return(arg0 api.AgentToken) *MockAgentRpcApiAgentTokenCall
Return rewrite *gomock.Call.Return
type MockAgentRpcApiHandleIoErrorCall ¶ added in v16.8.0
MockAgentRpcApiHandleIoErrorCall wrap *gomock.Call
func (*MockAgentRpcApiHandleIoErrorCall) Do ¶ added in v16.8.0
func (c *MockAgentRpcApiHandleIoErrorCall) Do(f func(*zap.Logger, string, error) error) *MockAgentRpcApiHandleIoErrorCall
Do rewrite *gomock.Call.Do
func (*MockAgentRpcApiHandleIoErrorCall) DoAndReturn ¶ added in v16.8.0
func (c *MockAgentRpcApiHandleIoErrorCall) DoAndReturn(f func(*zap.Logger, string, error) error) *MockAgentRpcApiHandleIoErrorCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockAgentRpcApiHandleIoErrorCall) Return ¶ added in v16.8.0
func (c *MockAgentRpcApiHandleIoErrorCall) Return(arg0 error) *MockAgentRpcApiHandleIoErrorCall
Return rewrite *gomock.Call.Return
type MockAgentRpcApiHandleProcessingErrorCall ¶ added in v16.8.0
MockAgentRpcApiHandleProcessingErrorCall wrap *gomock.Call
func (*MockAgentRpcApiHandleProcessingErrorCall) Do ¶ added in v16.8.0
func (c *MockAgentRpcApiHandleProcessingErrorCall) Do(f func(*zap.Logger, int64, string, error)) *MockAgentRpcApiHandleProcessingErrorCall
Do rewrite *gomock.Call.Do
func (*MockAgentRpcApiHandleProcessingErrorCall) DoAndReturn ¶ added in v16.8.0
func (c *MockAgentRpcApiHandleProcessingErrorCall) DoAndReturn(f func(*zap.Logger, int64, string, error)) *MockAgentRpcApiHandleProcessingErrorCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockAgentRpcApiHandleProcessingErrorCall) Return ¶ added in v16.8.0
func (c *MockAgentRpcApiHandleProcessingErrorCall) Return() *MockAgentRpcApiHandleProcessingErrorCall
Return rewrite *gomock.Call.Return
type MockAgentRpcApiLogCall ¶ added in v16.8.0
MockAgentRpcApiLogCall wrap *gomock.Call
func (*MockAgentRpcApiLogCall) Do ¶ added in v16.8.0
func (c *MockAgentRpcApiLogCall) Do(f func() *zap.Logger) *MockAgentRpcApiLogCall
Do rewrite *gomock.Call.Do
func (*MockAgentRpcApiLogCall) DoAndReturn ¶ added in v16.8.0
func (c *MockAgentRpcApiLogCall) DoAndReturn(f func() *zap.Logger) *MockAgentRpcApiLogCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockAgentRpcApiLogCall) Return ¶ added in v16.8.0
func (c *MockAgentRpcApiLogCall) Return(arg0 *zap.Logger) *MockAgentRpcApiLogCall
Return rewrite *gomock.Call.Return
type MockAgentRpcApiMockRecorder ¶
type MockAgentRpcApiMockRecorder struct {
// contains filtered or unexported fields
}
MockAgentRpcApiMockRecorder is the mock recorder for MockAgentRpcApi.
func (*MockAgentRpcApiMockRecorder) AgentInfo ¶
func (mr *MockAgentRpcApiMockRecorder) AgentInfo(arg0, arg1 any) *MockAgentRpcApiAgentInfoCall
AgentInfo indicates an expected call of AgentInfo.
func (*MockAgentRpcApiMockRecorder) AgentToken ¶
func (mr *MockAgentRpcApiMockRecorder) AgentToken() *MockAgentRpcApiAgentTokenCall
AgentToken indicates an expected call of AgentToken.
func (*MockAgentRpcApiMockRecorder) HandleIoError ¶
func (mr *MockAgentRpcApiMockRecorder) HandleIoError(arg0, arg1, arg2 any) *MockAgentRpcApiHandleIoErrorCall
HandleIoError indicates an expected call of HandleIoError.
func (*MockAgentRpcApiMockRecorder) HandleProcessingError ¶
func (mr *MockAgentRpcApiMockRecorder) HandleProcessingError(arg0, arg1, arg2, arg3 any) *MockAgentRpcApiHandleProcessingErrorCall
HandleProcessingError indicates an expected call of HandleProcessingError.
func (*MockAgentRpcApiMockRecorder) Log ¶
func (mr *MockAgentRpcApiMockRecorder) Log() *MockAgentRpcApiLogCall
Log indicates an expected call of Log.
func (*MockAgentRpcApiMockRecorder) PollWithBackoff ¶
func (mr *MockAgentRpcApiMockRecorder) PollWithBackoff(arg0, arg1 any) *MockAgentRpcApiPollWithBackoffCall
PollWithBackoff indicates an expected call of PollWithBackoff.
type MockAgentRpcApiPollWithBackoffCall ¶ added in v16.8.0
MockAgentRpcApiPollWithBackoffCall wrap *gomock.Call
func (*MockAgentRpcApiPollWithBackoffCall) Do ¶ added in v16.8.0
func (c *MockAgentRpcApiPollWithBackoffCall) Do(f func(retry.PollConfig, retry.PollWithBackoffFunc) error) *MockAgentRpcApiPollWithBackoffCall
Do rewrite *gomock.Call.Do
func (*MockAgentRpcApiPollWithBackoffCall) DoAndReturn ¶ added in v16.8.0
func (c *MockAgentRpcApiPollWithBackoffCall) DoAndReturn(f func(retry.PollConfig, retry.PollWithBackoffFunc) error) *MockAgentRpcApiPollWithBackoffCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockAgentRpcApiPollWithBackoffCall) Return ¶ added in v16.8.0
func (c *MockAgentRpcApiPollWithBackoffCall) Return(arg0 error) *MockAgentRpcApiPollWithBackoffCall
Return rewrite *gomock.Call.Return
type MockApi ¶
type MockApi struct {
// contains filtered or unexported fields
}
MockApi is a mock of Api interface.
func NewMockApi ¶
func NewMockApi(ctrl *gomock.Controller) *MockApi
NewMockApi creates a new mock instance.
func (*MockApi) EXPECT ¶
func (m *MockApi) EXPECT() *MockApiMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockApi) HandleProcessingError ¶
func (m *MockApi) HandleProcessingError(ctx context.Context, log *zap.Logger, agentId int64, msg string, err error)
HandleProcessingError mocks base method.
func (*MockApi) OnGitPushEvent ¶
func (m *MockApi) OnGitPushEvent(ctx context.Context, cb syncz.EventCallback[*event.GitPushEvent])
OnGitPushEvent mocks base method.
type MockApiHandleProcessingErrorCall ¶ added in v16.8.0
MockApiHandleProcessingErrorCall wrap *gomock.Call
func (*MockApiHandleProcessingErrorCall) Do ¶ added in v16.8.0
func (c *MockApiHandleProcessingErrorCall) Do(f func(context.Context, *zap.Logger, int64, string, error)) *MockApiHandleProcessingErrorCall
Do rewrite *gomock.Call.Do
func (*MockApiHandleProcessingErrorCall) DoAndReturn ¶ added in v16.8.0
func (c *MockApiHandleProcessingErrorCall) DoAndReturn(f func(context.Context, *zap.Logger, int64, string, error)) *MockApiHandleProcessingErrorCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockApiHandleProcessingErrorCall) Return ¶ added in v16.8.0
func (c *MockApiHandleProcessingErrorCall) Return() *MockApiHandleProcessingErrorCall
Return rewrite *gomock.Call.Return
type MockApiMockRecorder ¶
type MockApiMockRecorder struct {
// contains filtered or unexported fields
}
MockApiMockRecorder is the mock recorder for MockApi.
func (*MockApiMockRecorder) HandleProcessingError ¶
func (mr *MockApiMockRecorder) HandleProcessingError(ctx, log, agentId, msg, err any) *MockApiHandleProcessingErrorCall
HandleProcessingError indicates an expected call of HandleProcessingError.
func (*MockApiMockRecorder) OnGitPushEvent ¶
func (mr *MockApiMockRecorder) OnGitPushEvent(ctx, cb any) *MockApiOnGitPushEventCall
OnGitPushEvent indicates an expected call of OnGitPushEvent.
type MockApiOnGitPushEventCall ¶ added in v16.8.0
MockApiOnGitPushEventCall wrap *gomock.Call
func (*MockApiOnGitPushEventCall) Do ¶ added in v16.8.0
func (c *MockApiOnGitPushEventCall) Do(f func(context.Context, syncz.EventCallback[*event.GitPushEvent])) *MockApiOnGitPushEventCall
Do rewrite *gomock.Call.Do
func (*MockApiOnGitPushEventCall) DoAndReturn ¶ added in v16.8.0
func (c *MockApiOnGitPushEventCall) DoAndReturn(f func(context.Context, syncz.EventCallback[*event.GitPushEvent])) *MockApiOnGitPushEventCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockApiOnGitPushEventCall) Return ¶ added in v16.8.0
func (c *MockApiOnGitPushEventCall) Return() *MockApiOnGitPushEventCall
Return rewrite *gomock.Call.Return
type MockFactory ¶ added in v16.2.0
type MockFactory struct {
// contains filtered or unexported fields
}
MockFactory is a mock of Factory interface.
func NewMockFactory ¶ added in v16.2.0
func NewMockFactory(ctrl *gomock.Controller) *MockFactory
NewMockFactory creates a new mock instance.
func (*MockFactory) EXPECT ¶ added in v16.2.0
func (m *MockFactory) EXPECT() *MockFactoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockFactory) Name ¶ added in v16.2.0
func (m *MockFactory) Name() string
Name mocks base method.
func (*MockFactory) StartStopPhase ¶ added in v16.2.0
func (m *MockFactory) StartStopPhase() modshared.ModuleStartStopPhase
StartStopPhase mocks base method.
type MockFactoryMockRecorder ¶ added in v16.2.0
type MockFactoryMockRecorder struct {
// contains filtered or unexported fields
}
MockFactoryMockRecorder is the mock recorder for MockFactory.
func (*MockFactoryMockRecorder) Name ¶ added in v16.2.0
func (mr *MockFactoryMockRecorder) Name() *MockFactoryNameCall
Name indicates an expected call of Name.
func (*MockFactoryMockRecorder) New ¶ added in v16.2.0
func (mr *MockFactoryMockRecorder) New(arg0 any) *MockFactoryNewCall
New indicates an expected call of New.
func (*MockFactoryMockRecorder) StartStopPhase ¶ added in v16.2.0
func (mr *MockFactoryMockRecorder) StartStopPhase() *MockFactoryStartStopPhaseCall
StartStopPhase indicates an expected call of StartStopPhase.
type MockFactoryNameCall ¶ added in v16.8.0
MockFactoryNameCall wrap *gomock.Call
func (*MockFactoryNameCall) Do ¶ added in v16.8.0
func (c *MockFactoryNameCall) Do(f func() string) *MockFactoryNameCall
Do rewrite *gomock.Call.Do
func (*MockFactoryNameCall) DoAndReturn ¶ added in v16.8.0
func (c *MockFactoryNameCall) DoAndReturn(f func() string) *MockFactoryNameCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockFactoryNameCall) Return ¶ added in v16.8.0
func (c *MockFactoryNameCall) Return(arg0 string) *MockFactoryNameCall
Return rewrite *gomock.Call.Return
type MockFactoryNewCall ¶ added in v16.8.0
MockFactoryNewCall wrap *gomock.Call
func (*MockFactoryNewCall) Do ¶ added in v16.8.0
func (c *MockFactoryNewCall) Do(f func(*modserver.Config) (modserver.Module, error)) *MockFactoryNewCall
Do rewrite *gomock.Call.Do
func (*MockFactoryNewCall) DoAndReturn ¶ added in v16.8.0
func (c *MockFactoryNewCall) DoAndReturn(f func(*modserver.Config) (modserver.Module, error)) *MockFactoryNewCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockFactoryNewCall) Return ¶ added in v16.8.0
func (c *MockFactoryNewCall) Return(arg0 modserver.Module, arg1 error) *MockFactoryNewCall
Return rewrite *gomock.Call.Return
type MockFactoryStartStopPhaseCall ¶ added in v16.8.0
MockFactoryStartStopPhaseCall wrap *gomock.Call
func (*MockFactoryStartStopPhaseCall) Do ¶ added in v16.8.0
func (c *MockFactoryStartStopPhaseCall) Do(f func() modshared.ModuleStartStopPhase) *MockFactoryStartStopPhaseCall
Do rewrite *gomock.Call.Do
func (*MockFactoryStartStopPhaseCall) DoAndReturn ¶ added in v16.8.0
func (c *MockFactoryStartStopPhaseCall) DoAndReturn(f func() modshared.ModuleStartStopPhase) *MockFactoryStartStopPhaseCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockFactoryStartStopPhaseCall) Return ¶ added in v16.8.0
func (c *MockFactoryStartStopPhaseCall) Return(arg0 modshared.ModuleStartStopPhase) *MockFactoryStartStopPhaseCall
Return rewrite *gomock.Call.Return
type MockModule ¶ added in v16.2.0
type MockModule struct {
// contains filtered or unexported fields
}
MockModule is a mock of Module interface.
func NewMockModule ¶ added in v16.2.0
func NewMockModule(ctrl *gomock.Controller) *MockModule
NewMockModule creates a new mock instance.
func (*MockModule) EXPECT ¶ added in v16.2.0
func (m *MockModule) EXPECT() *MockModuleMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockModule) Name ¶ added in v16.2.0
func (m *MockModule) Name() string
Name mocks base method.
type MockModuleMockRecorder ¶ added in v16.2.0
type MockModuleMockRecorder struct {
// contains filtered or unexported fields
}
MockModuleMockRecorder is the mock recorder for MockModule.
func (*MockModuleMockRecorder) Name ¶ added in v16.2.0
func (mr *MockModuleMockRecorder) Name() *MockModuleNameCall
Name indicates an expected call of Name.
func (*MockModuleMockRecorder) Run ¶ added in v16.2.0
func (mr *MockModuleMockRecorder) Run(arg0 any) *MockModuleRunCall
Run indicates an expected call of Run.
type MockModuleNameCall ¶ added in v16.8.0
MockModuleNameCall wrap *gomock.Call
func (*MockModuleNameCall) Do ¶ added in v16.8.0
func (c *MockModuleNameCall) Do(f func() string) *MockModuleNameCall
Do rewrite *gomock.Call.Do
func (*MockModuleNameCall) DoAndReturn ¶ added in v16.8.0
func (c *MockModuleNameCall) DoAndReturn(f func() string) *MockModuleNameCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockModuleNameCall) Return ¶ added in v16.8.0
func (c *MockModuleNameCall) Return(arg0 string) *MockModuleNameCall
Return rewrite *gomock.Call.Return
type MockModuleRunCall ¶ added in v16.8.0
MockModuleRunCall wrap *gomock.Call
func (*MockModuleRunCall) Do ¶ added in v16.8.0
func (c *MockModuleRunCall) Do(f func(context.Context) error) *MockModuleRunCall
Do rewrite *gomock.Call.Do
func (*MockModuleRunCall) DoAndReturn ¶ added in v16.8.0
func (c *MockModuleRunCall) DoAndReturn(f func(context.Context) error) *MockModuleRunCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockModuleRunCall) Return ¶ added in v16.8.0
func (c *MockModuleRunCall) Return(arg0 error) *MockModuleRunCall
Return rewrite *gomock.Call.Return
type MockRpcApi ¶
type MockRpcApi struct {
// contains filtered or unexported fields
}
MockRpcApi is a mock of RpcApi interface.
func NewMockRpcApi ¶
func NewMockRpcApi(ctrl *gomock.Controller) *MockRpcApi
NewMockRpcApi creates a new mock instance.
func (*MockRpcApi) EXPECT ¶
func (m *MockRpcApi) EXPECT() *MockRpcApiMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockRpcApi) HandleIoError ¶
HandleIoError mocks base method.
func (*MockRpcApi) HandleProcessingError ¶
HandleProcessingError mocks base method.
func (*MockRpcApi) PollWithBackoff ¶
func (m *MockRpcApi) PollWithBackoff(arg0 retry.PollConfig, arg1 retry.PollWithBackoffFunc) error
PollWithBackoff mocks base method.
type MockRpcApiHandleIoErrorCall ¶ added in v16.8.0
MockRpcApiHandleIoErrorCall wrap *gomock.Call
func (*MockRpcApiHandleIoErrorCall) Do ¶ added in v16.8.0
func (c *MockRpcApiHandleIoErrorCall) Do(f func(*zap.Logger, string, error) error) *MockRpcApiHandleIoErrorCall
Do rewrite *gomock.Call.Do
func (*MockRpcApiHandleIoErrorCall) DoAndReturn ¶ added in v16.8.0
func (c *MockRpcApiHandleIoErrorCall) DoAndReturn(f func(*zap.Logger, string, error) error) *MockRpcApiHandleIoErrorCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockRpcApiHandleIoErrorCall) Return ¶ added in v16.8.0
func (c *MockRpcApiHandleIoErrorCall) Return(arg0 error) *MockRpcApiHandleIoErrorCall
Return rewrite *gomock.Call.Return
type MockRpcApiHandleProcessingErrorCall ¶ added in v16.8.0
MockRpcApiHandleProcessingErrorCall wrap *gomock.Call
func (*MockRpcApiHandleProcessingErrorCall) Do ¶ added in v16.8.0
func (c *MockRpcApiHandleProcessingErrorCall) Do(f func(*zap.Logger, int64, string, error)) *MockRpcApiHandleProcessingErrorCall
Do rewrite *gomock.Call.Do
func (*MockRpcApiHandleProcessingErrorCall) DoAndReturn ¶ added in v16.8.0
func (c *MockRpcApiHandleProcessingErrorCall) DoAndReturn(f func(*zap.Logger, int64, string, error)) *MockRpcApiHandleProcessingErrorCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockRpcApiHandleProcessingErrorCall) Return ¶ added in v16.8.0
func (c *MockRpcApiHandleProcessingErrorCall) Return() *MockRpcApiHandleProcessingErrorCall
Return rewrite *gomock.Call.Return
type MockRpcApiLogCall ¶ added in v16.8.0
MockRpcApiLogCall wrap *gomock.Call
func (*MockRpcApiLogCall) Do ¶ added in v16.8.0
func (c *MockRpcApiLogCall) Do(f func() *zap.Logger) *MockRpcApiLogCall
Do rewrite *gomock.Call.Do
func (*MockRpcApiLogCall) DoAndReturn ¶ added in v16.8.0
func (c *MockRpcApiLogCall) DoAndReturn(f func() *zap.Logger) *MockRpcApiLogCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockRpcApiLogCall) Return ¶ added in v16.8.0
func (c *MockRpcApiLogCall) Return(arg0 *zap.Logger) *MockRpcApiLogCall
Return rewrite *gomock.Call.Return
type MockRpcApiMockRecorder ¶
type MockRpcApiMockRecorder struct {
// contains filtered or unexported fields
}
MockRpcApiMockRecorder is the mock recorder for MockRpcApi.
func (*MockRpcApiMockRecorder) HandleIoError ¶
func (mr *MockRpcApiMockRecorder) HandleIoError(arg0, arg1, arg2 any) *MockRpcApiHandleIoErrorCall
HandleIoError indicates an expected call of HandleIoError.
func (*MockRpcApiMockRecorder) HandleProcessingError ¶
func (mr *MockRpcApiMockRecorder) HandleProcessingError(arg0, arg1, arg2, arg3 any) *MockRpcApiHandleProcessingErrorCall
HandleProcessingError indicates an expected call of HandleProcessingError.
func (*MockRpcApiMockRecorder) Log ¶
func (mr *MockRpcApiMockRecorder) Log() *MockRpcApiLogCall
Log indicates an expected call of Log.
func (*MockRpcApiMockRecorder) PollWithBackoff ¶
func (mr *MockRpcApiMockRecorder) PollWithBackoff(arg0, arg1 any) *MockRpcApiPollWithBackoffCall
PollWithBackoff indicates an expected call of PollWithBackoff.
type MockRpcApiPollWithBackoffCall ¶ added in v16.8.0
MockRpcApiPollWithBackoffCall wrap *gomock.Call
func (*MockRpcApiPollWithBackoffCall) Do ¶ added in v16.8.0
func (c *MockRpcApiPollWithBackoffCall) Do(f func(retry.PollConfig, retry.PollWithBackoffFunc) error) *MockRpcApiPollWithBackoffCall
Do rewrite *gomock.Call.Do
func (*MockRpcApiPollWithBackoffCall) DoAndReturn ¶ added in v16.8.0
func (c *MockRpcApiPollWithBackoffCall) DoAndReturn(f func(retry.PollConfig, retry.PollWithBackoffFunc) error) *MockRpcApiPollWithBackoffCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockRpcApiPollWithBackoffCall) Return ¶ added in v16.8.0
func (c *MockRpcApiPollWithBackoffCall) Return(arg0 error) *MockRpcApiPollWithBackoffCall
Return rewrite *gomock.Call.Return