Documentation ¶
Overview ¶
Code generated by MockGen. DO NOT EDIT. Source: ../../../module/modserver/api.go
Generated by this command:
mockgen -typed -source ../../../module/modserver/api.go -destination api.go -package mock_modserver
Package mock_modserver is a generated GoMock package.
Code generated by MockGen. DO NOT EDIT. Source: gitlab.com/gitlab-org/cluster-integration/gitlab-agent/v16/internal/module/modserver (interfaces: RpcApi,AgentRpcApi)
Generated by this command:
mockgen -typed -destination rpc_api.go -package mock_modserver gitlab.com/gitlab-org/cluster-integration/gitlab-agent/v16/internal/module/modserver RpcApi,AgentRpcApi
Package mock_modserver is a generated GoMock package.
Index ¶
- func AgentMeta() *entity.AgentMeta
- func IncomingAgentCtx(t *testing.T, rpcApi *MockAgentRpcApi) context.Context
- type AgentRpcApiAgentInfoCall
- func (c *AgentRpcApiAgentInfoCall) Do(f func(context.Context, *zap.Logger) (*api.AgentInfo, error)) *AgentRpcApiAgentInfoCall
- func (c *AgentRpcApiAgentInfoCall) DoAndReturn(f func(context.Context, *zap.Logger) (*api.AgentInfo, error)) *AgentRpcApiAgentInfoCall
- func (c *AgentRpcApiAgentInfoCall) Return(arg0 *api.AgentInfo, arg1 error) *AgentRpcApiAgentInfoCall
- type AgentRpcApiAgentTokenCall
- type AgentRpcApiHandleIoErrorCall
- func (c *AgentRpcApiHandleIoErrorCall) Do(f func(*zap.Logger, string, error) error) *AgentRpcApiHandleIoErrorCall
- func (c *AgentRpcApiHandleIoErrorCall) DoAndReturn(f func(*zap.Logger, string, error) error) *AgentRpcApiHandleIoErrorCall
- func (c *AgentRpcApiHandleIoErrorCall) Return(arg0 error) *AgentRpcApiHandleIoErrorCall
- type AgentRpcApiHandleProcessingErrorCall
- func (c *AgentRpcApiHandleProcessingErrorCall) Do(f func(*zap.Logger, int64, string, error)) *AgentRpcApiHandleProcessingErrorCall
- func (c *AgentRpcApiHandleProcessingErrorCall) DoAndReturn(f func(*zap.Logger, int64, string, error)) *AgentRpcApiHandleProcessingErrorCall
- func (c *AgentRpcApiHandleProcessingErrorCall) Return() *AgentRpcApiHandleProcessingErrorCall
- type AgentRpcApiLogCall
- type AgentRpcApiPollWithBackoffCall
- func (c *AgentRpcApiPollWithBackoffCall) Do(f func(retry.PollConfig, retry.PollWithBackoffFunc) error) *AgentRpcApiPollWithBackoffCall
- func (c *AgentRpcApiPollWithBackoffCall) DoAndReturn(f func(retry.PollConfig, retry.PollWithBackoffFunc) error) *AgentRpcApiPollWithBackoffCall
- func (c *AgentRpcApiPollWithBackoffCall) Return(arg0 error) *AgentRpcApiPollWithBackoffCall
- type ApiHandleProcessingErrorCall
- func (c *ApiHandleProcessingErrorCall) Do(f func(context.Context, *zap.Logger, int64, string, error)) *ApiHandleProcessingErrorCall
- func (c *ApiHandleProcessingErrorCall) DoAndReturn(f func(context.Context, *zap.Logger, int64, string, error)) *ApiHandleProcessingErrorCall
- func (c *ApiHandleProcessingErrorCall) Return() *ApiHandleProcessingErrorCall
- type ApiOnGitPushEventCall
- func (c *ApiOnGitPushEventCall) Do(f func(context.Context, syncz.EventCallback[*event.GitPushEvent])) *ApiOnGitPushEventCall
- func (c *ApiOnGitPushEventCall) DoAndReturn(f func(context.Context, syncz.EventCallback[*event.GitPushEvent])) *ApiOnGitPushEventCall
- func (c *ApiOnGitPushEventCall) Return() *ApiOnGitPushEventCall
- type FactoryNameCall
- type FactoryNewCall
- type FactoryStartStopPhaseCall
- func (c *FactoryStartStopPhaseCall) Do(f func() modshared.ModuleStartStopPhase) *FactoryStartStopPhaseCall
- func (c *FactoryStartStopPhaseCall) DoAndReturn(f func() modshared.ModuleStartStopPhase) *FactoryStartStopPhaseCall
- func (c *FactoryStartStopPhaseCall) Return(arg0 modshared.ModuleStartStopPhase) *FactoryStartStopPhaseCall
- 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 MockAgentRpcApiMockRecorder
- func (mr *MockAgentRpcApiMockRecorder) AgentInfo(arg0, arg1 any) *AgentRpcApiAgentInfoCall
- func (mr *MockAgentRpcApiMockRecorder) AgentToken() *AgentRpcApiAgentTokenCall
- func (mr *MockAgentRpcApiMockRecorder) HandleIoError(arg0, arg1, arg2 any) *AgentRpcApiHandleIoErrorCall
- func (mr *MockAgentRpcApiMockRecorder) HandleProcessingError(arg0, arg1, arg2, arg3 any) *AgentRpcApiHandleProcessingErrorCall
- func (mr *MockAgentRpcApiMockRecorder) Log() *AgentRpcApiLogCall
- func (mr *MockAgentRpcApiMockRecorder) PollWithBackoff(arg0, arg1 any) *AgentRpcApiPollWithBackoffCall
- type MockApi
- type MockApiMockRecorder
- type MockFactory
- type MockFactoryMockRecorder
- type MockModule
- type MockModuleMockRecorder
- 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 MockRpcApiMockRecorder
- func (mr *MockRpcApiMockRecorder) HandleIoError(arg0, arg1, arg2 any) *RpcApiHandleIoErrorCall
- func (mr *MockRpcApiMockRecorder) HandleProcessingError(arg0, arg1, arg2, arg3 any) *RpcApiHandleProcessingErrorCall
- func (mr *MockRpcApiMockRecorder) Log() *RpcApiLogCall
- func (mr *MockRpcApiMockRecorder) PollWithBackoff(arg0, arg1 any) *RpcApiPollWithBackoffCall
- type ModuleNameCall
- type ModuleRunCall
- type RpcApiHandleIoErrorCall
- type RpcApiHandleProcessingErrorCall
- func (c *RpcApiHandleProcessingErrorCall) Do(f func(*zap.Logger, int64, string, error)) *RpcApiHandleProcessingErrorCall
- func (c *RpcApiHandleProcessingErrorCall) DoAndReturn(f func(*zap.Logger, int64, string, error)) *RpcApiHandleProcessingErrorCall
- func (c *RpcApiHandleProcessingErrorCall) Return() *RpcApiHandleProcessingErrorCall
- type RpcApiLogCall
- type RpcApiPollWithBackoffCall
- func (c *RpcApiPollWithBackoffCall) Do(f func(retry.PollConfig, retry.PollWithBackoffFunc) error) *RpcApiPollWithBackoffCall
- func (c *RpcApiPollWithBackoffCall) DoAndReturn(f func(retry.PollConfig, retry.PollWithBackoffFunc) error) *RpcApiPollWithBackoffCall
- func (c *RpcApiPollWithBackoffCall) Return(arg0 error) *RpcApiPollWithBackoffCall
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func IncomingAgentCtx ¶
func IncomingAgentCtx(t *testing.T, rpcApi *MockAgentRpcApi) context.Context
Types ¶
type AgentRpcApiAgentInfoCall ¶ added in v16.5.0
AgentRpcApiAgentInfoCall wrap *gomock.Call
func (*AgentRpcApiAgentInfoCall) Do ¶ added in v16.5.0
func (c *AgentRpcApiAgentInfoCall) Do(f func(context.Context, *zap.Logger) (*api.AgentInfo, error)) *AgentRpcApiAgentInfoCall
Do rewrite *gomock.Call.Do
func (*AgentRpcApiAgentInfoCall) DoAndReturn ¶ added in v16.5.0
func (c *AgentRpcApiAgentInfoCall) DoAndReturn(f func(context.Context, *zap.Logger) (*api.AgentInfo, error)) *AgentRpcApiAgentInfoCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*AgentRpcApiAgentInfoCall) Return ¶ added in v16.5.0
func (c *AgentRpcApiAgentInfoCall) Return(arg0 *api.AgentInfo, arg1 error) *AgentRpcApiAgentInfoCall
Return rewrite *gomock.Call.Return
type AgentRpcApiAgentTokenCall ¶ added in v16.5.0
AgentRpcApiAgentTokenCall wrap *gomock.Call
func (*AgentRpcApiAgentTokenCall) Do ¶ added in v16.5.0
func (c *AgentRpcApiAgentTokenCall) Do(f func() api.AgentToken) *AgentRpcApiAgentTokenCall
Do rewrite *gomock.Call.Do
func (*AgentRpcApiAgentTokenCall) DoAndReturn ¶ added in v16.5.0
func (c *AgentRpcApiAgentTokenCall) DoAndReturn(f func() api.AgentToken) *AgentRpcApiAgentTokenCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*AgentRpcApiAgentTokenCall) Return ¶ added in v16.5.0
func (c *AgentRpcApiAgentTokenCall) Return(arg0 api.AgentToken) *AgentRpcApiAgentTokenCall
Return rewrite *gomock.Call.Return
type AgentRpcApiHandleIoErrorCall ¶ added in v16.5.0
AgentRpcApiHandleIoErrorCall wrap *gomock.Call
func (*AgentRpcApiHandleIoErrorCall) Do ¶ added in v16.5.0
func (c *AgentRpcApiHandleIoErrorCall) Do(f func(*zap.Logger, string, error) error) *AgentRpcApiHandleIoErrorCall
Do rewrite *gomock.Call.Do
func (*AgentRpcApiHandleIoErrorCall) DoAndReturn ¶ added in v16.5.0
func (c *AgentRpcApiHandleIoErrorCall) DoAndReturn(f func(*zap.Logger, string, error) error) *AgentRpcApiHandleIoErrorCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*AgentRpcApiHandleIoErrorCall) Return ¶ added in v16.5.0
func (c *AgentRpcApiHandleIoErrorCall) Return(arg0 error) *AgentRpcApiHandleIoErrorCall
Return rewrite *gomock.Call.Return
type AgentRpcApiHandleProcessingErrorCall ¶ added in v16.5.0
AgentRpcApiHandleProcessingErrorCall wrap *gomock.Call
func (*AgentRpcApiHandleProcessingErrorCall) Do ¶ added in v16.5.0
func (c *AgentRpcApiHandleProcessingErrorCall) Do(f func(*zap.Logger, int64, string, error)) *AgentRpcApiHandleProcessingErrorCall
Do rewrite *gomock.Call.Do
func (*AgentRpcApiHandleProcessingErrorCall) DoAndReturn ¶ added in v16.5.0
func (c *AgentRpcApiHandleProcessingErrorCall) DoAndReturn(f func(*zap.Logger, int64, string, error)) *AgentRpcApiHandleProcessingErrorCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*AgentRpcApiHandleProcessingErrorCall) Return ¶ added in v16.5.0
func (c *AgentRpcApiHandleProcessingErrorCall) Return() *AgentRpcApiHandleProcessingErrorCall
Return rewrite *gomock.Call.Return
type AgentRpcApiLogCall ¶ added in v16.5.0
AgentRpcApiLogCall wrap *gomock.Call
func (*AgentRpcApiLogCall) Do ¶ added in v16.5.0
func (c *AgentRpcApiLogCall) Do(f func() *zap.Logger) *AgentRpcApiLogCall
Do rewrite *gomock.Call.Do
func (*AgentRpcApiLogCall) DoAndReturn ¶ added in v16.5.0
func (c *AgentRpcApiLogCall) DoAndReturn(f func() *zap.Logger) *AgentRpcApiLogCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*AgentRpcApiLogCall) Return ¶ added in v16.5.0
func (c *AgentRpcApiLogCall) Return(arg0 *zap.Logger) *AgentRpcApiLogCall
Return rewrite *gomock.Call.Return
type AgentRpcApiPollWithBackoffCall ¶ added in v16.5.0
AgentRpcApiPollWithBackoffCall wrap *gomock.Call
func (*AgentRpcApiPollWithBackoffCall) Do ¶ added in v16.5.0
func (c *AgentRpcApiPollWithBackoffCall) Do(f func(retry.PollConfig, retry.PollWithBackoffFunc) error) *AgentRpcApiPollWithBackoffCall
Do rewrite *gomock.Call.Do
func (*AgentRpcApiPollWithBackoffCall) DoAndReturn ¶ added in v16.5.0
func (c *AgentRpcApiPollWithBackoffCall) DoAndReturn(f func(retry.PollConfig, retry.PollWithBackoffFunc) error) *AgentRpcApiPollWithBackoffCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*AgentRpcApiPollWithBackoffCall) Return ¶ added in v16.5.0
func (c *AgentRpcApiPollWithBackoffCall) Return(arg0 error) *AgentRpcApiPollWithBackoffCall
Return rewrite *gomock.Call.Return
type ApiHandleProcessingErrorCall ¶ added in v16.5.0
ApiHandleProcessingErrorCall wrap *gomock.Call
func (*ApiHandleProcessingErrorCall) Do ¶ added in v16.5.0
func (c *ApiHandleProcessingErrorCall) Do(f func(context.Context, *zap.Logger, int64, string, error)) *ApiHandleProcessingErrorCall
Do rewrite *gomock.Call.Do
func (*ApiHandleProcessingErrorCall) DoAndReturn ¶ added in v16.5.0
func (c *ApiHandleProcessingErrorCall) DoAndReturn(f func(context.Context, *zap.Logger, int64, string, error)) *ApiHandleProcessingErrorCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*ApiHandleProcessingErrorCall) Return ¶ added in v16.5.0
func (c *ApiHandleProcessingErrorCall) Return() *ApiHandleProcessingErrorCall
Return rewrite *gomock.Call.Return
type ApiOnGitPushEventCall ¶ added in v16.5.0
ApiOnGitPushEventCall wrap *gomock.Call
func (*ApiOnGitPushEventCall) Do ¶ added in v16.5.0
func (c *ApiOnGitPushEventCall) Do(f func(context.Context, syncz.EventCallback[*event.GitPushEvent])) *ApiOnGitPushEventCall
Do rewrite *gomock.Call.Do
func (*ApiOnGitPushEventCall) DoAndReturn ¶ added in v16.5.0
func (c *ApiOnGitPushEventCall) DoAndReturn(f func(context.Context, syncz.EventCallback[*event.GitPushEvent])) *ApiOnGitPushEventCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*ApiOnGitPushEventCall) Return ¶ added in v16.5.0
func (c *ApiOnGitPushEventCall) Return() *ApiOnGitPushEventCall
Return rewrite *gomock.Call.Return
type FactoryNameCall ¶ added in v16.5.0
FactoryNameCall wrap *gomock.Call
func (*FactoryNameCall) Do ¶ added in v16.5.0
func (c *FactoryNameCall) Do(f func() string) *FactoryNameCall
Do rewrite *gomock.Call.Do
func (*FactoryNameCall) DoAndReturn ¶ added in v16.5.0
func (c *FactoryNameCall) DoAndReturn(f func() string) *FactoryNameCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*FactoryNameCall) Return ¶ added in v16.5.0
func (c *FactoryNameCall) Return(arg0 string) *FactoryNameCall
Return rewrite *gomock.Call.Return
type FactoryNewCall ¶ added in v16.5.0
FactoryNewCall wrap *gomock.Call
func (*FactoryNewCall) Do ¶ added in v16.5.0
func (c *FactoryNewCall) Do(f func(*modserver.Config) (modserver.Module, error)) *FactoryNewCall
Do rewrite *gomock.Call.Do
func (*FactoryNewCall) DoAndReturn ¶ added in v16.5.0
func (c *FactoryNewCall) DoAndReturn(f func(*modserver.Config) (modserver.Module, error)) *FactoryNewCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*FactoryNewCall) Return ¶ added in v16.5.0
func (c *FactoryNewCall) Return(arg0 modserver.Module, arg1 error) *FactoryNewCall
Return rewrite *gomock.Call.Return
type FactoryStartStopPhaseCall ¶ added in v16.5.0
FactoryStartStopPhaseCall wrap *gomock.Call
func (*FactoryStartStopPhaseCall) Do ¶ added in v16.5.0
func (c *FactoryStartStopPhaseCall) Do(f func() modshared.ModuleStartStopPhase) *FactoryStartStopPhaseCall
Do rewrite *gomock.Call.Do
func (*FactoryStartStopPhaseCall) DoAndReturn ¶ added in v16.5.0
func (c *FactoryStartStopPhaseCall) DoAndReturn(f func() modshared.ModuleStartStopPhase) *FactoryStartStopPhaseCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*FactoryStartStopPhaseCall) Return ¶ added in v16.5.0
func (c *FactoryStartStopPhaseCall) Return(arg0 modshared.ModuleStartStopPhase) *FactoryStartStopPhaseCall
Return rewrite *gomock.Call.Return
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 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) *AgentRpcApiAgentInfoCall
AgentInfo indicates an expected call of AgentInfo.
func (*MockAgentRpcApiMockRecorder) AgentToken ¶
func (mr *MockAgentRpcApiMockRecorder) AgentToken() *AgentRpcApiAgentTokenCall
AgentToken indicates an expected call of AgentToken.
func (*MockAgentRpcApiMockRecorder) HandleIoError ¶
func (mr *MockAgentRpcApiMockRecorder) HandleIoError(arg0, arg1, arg2 any) *AgentRpcApiHandleIoErrorCall
HandleIoError indicates an expected call of HandleIoError.
func (*MockAgentRpcApiMockRecorder) HandleProcessingError ¶
func (mr *MockAgentRpcApiMockRecorder) HandleProcessingError(arg0, arg1, arg2, arg3 any) *AgentRpcApiHandleProcessingErrorCall
HandleProcessingError indicates an expected call of HandleProcessingError.
func (*MockAgentRpcApiMockRecorder) Log ¶
func (mr *MockAgentRpcApiMockRecorder) Log() *AgentRpcApiLogCall
Log indicates an expected call of Log.
func (*MockAgentRpcApiMockRecorder) PollWithBackoff ¶
func (mr *MockAgentRpcApiMockRecorder) PollWithBackoff(arg0, arg1 any) *AgentRpcApiPollWithBackoffCall
PollWithBackoff indicates an expected call of PollWithBackoff.
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 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) *ApiHandleProcessingErrorCall
HandleProcessingError indicates an expected call of HandleProcessingError.
func (*MockApiMockRecorder) OnGitPushEvent ¶
func (mr *MockApiMockRecorder) OnGitPushEvent(ctx, cb any) *ApiOnGitPushEventCall
OnGitPushEvent indicates an expected call of OnGitPushEvent.
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() *FactoryNameCall
Name indicates an expected call of Name.
func (*MockFactoryMockRecorder) New ¶ added in v16.2.0
func (mr *MockFactoryMockRecorder) New(arg0 any) *FactoryNewCall
New indicates an expected call of New.
func (*MockFactoryMockRecorder) StartStopPhase ¶ added in v16.2.0
func (mr *MockFactoryMockRecorder) StartStopPhase() *FactoryStartStopPhaseCall
StartStopPhase indicates an expected call of StartStopPhase.
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() *ModuleNameCall
Name indicates an expected call of Name.
func (*MockModuleMockRecorder) Run ¶ added in v16.2.0
func (mr *MockModuleMockRecorder) Run(arg0 any) *ModuleRunCall
Run indicates an expected call of Run.
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 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) *RpcApiHandleIoErrorCall
HandleIoError indicates an expected call of HandleIoError.
func (*MockRpcApiMockRecorder) HandleProcessingError ¶
func (mr *MockRpcApiMockRecorder) HandleProcessingError(arg0, arg1, arg2, arg3 any) *RpcApiHandleProcessingErrorCall
HandleProcessingError indicates an expected call of HandleProcessingError.
func (*MockRpcApiMockRecorder) Log ¶
func (mr *MockRpcApiMockRecorder) Log() *RpcApiLogCall
Log indicates an expected call of Log.
func (*MockRpcApiMockRecorder) PollWithBackoff ¶
func (mr *MockRpcApiMockRecorder) PollWithBackoff(arg0, arg1 any) *RpcApiPollWithBackoffCall
PollWithBackoff indicates an expected call of PollWithBackoff.
type ModuleNameCall ¶ added in v16.5.0
ModuleNameCall wrap *gomock.Call
func (*ModuleNameCall) Do ¶ added in v16.5.0
func (c *ModuleNameCall) Do(f func() string) *ModuleNameCall
Do rewrite *gomock.Call.Do
func (*ModuleNameCall) DoAndReturn ¶ added in v16.5.0
func (c *ModuleNameCall) DoAndReturn(f func() string) *ModuleNameCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*ModuleNameCall) Return ¶ added in v16.5.0
func (c *ModuleNameCall) Return(arg0 string) *ModuleNameCall
Return rewrite *gomock.Call.Return
type ModuleRunCall ¶ added in v16.5.0
ModuleRunCall wrap *gomock.Call
func (*ModuleRunCall) Do ¶ added in v16.5.0
func (c *ModuleRunCall) Do(f func(context.Context) error) *ModuleRunCall
Do rewrite *gomock.Call.Do
func (*ModuleRunCall) DoAndReturn ¶ added in v16.5.0
func (c *ModuleRunCall) DoAndReturn(f func(context.Context) error) *ModuleRunCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*ModuleRunCall) Return ¶ added in v16.5.0
func (c *ModuleRunCall) Return(arg0 error) *ModuleRunCall
Return rewrite *gomock.Call.Return
type RpcApiHandleIoErrorCall ¶ added in v16.5.0
RpcApiHandleIoErrorCall wrap *gomock.Call
func (*RpcApiHandleIoErrorCall) Do ¶ added in v16.5.0
func (c *RpcApiHandleIoErrorCall) Do(f func(*zap.Logger, string, error) error) *RpcApiHandleIoErrorCall
Do rewrite *gomock.Call.Do
func (*RpcApiHandleIoErrorCall) DoAndReturn ¶ added in v16.5.0
func (c *RpcApiHandleIoErrorCall) DoAndReturn(f func(*zap.Logger, string, error) error) *RpcApiHandleIoErrorCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*RpcApiHandleIoErrorCall) Return ¶ added in v16.5.0
func (c *RpcApiHandleIoErrorCall) Return(arg0 error) *RpcApiHandleIoErrorCall
Return rewrite *gomock.Call.Return
type RpcApiHandleProcessingErrorCall ¶ added in v16.5.0
RpcApiHandleProcessingErrorCall wrap *gomock.Call
func (*RpcApiHandleProcessingErrorCall) Do ¶ added in v16.5.0
func (c *RpcApiHandleProcessingErrorCall) Do(f func(*zap.Logger, int64, string, error)) *RpcApiHandleProcessingErrorCall
Do rewrite *gomock.Call.Do
func (*RpcApiHandleProcessingErrorCall) DoAndReturn ¶ added in v16.5.0
func (c *RpcApiHandleProcessingErrorCall) DoAndReturn(f func(*zap.Logger, int64, string, error)) *RpcApiHandleProcessingErrorCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*RpcApiHandleProcessingErrorCall) Return ¶ added in v16.5.0
func (c *RpcApiHandleProcessingErrorCall) Return() *RpcApiHandleProcessingErrorCall
Return rewrite *gomock.Call.Return
type RpcApiLogCall ¶ added in v16.5.0
RpcApiLogCall wrap *gomock.Call
func (*RpcApiLogCall) Do ¶ added in v16.5.0
func (c *RpcApiLogCall) Do(f func() *zap.Logger) *RpcApiLogCall
Do rewrite *gomock.Call.Do
func (*RpcApiLogCall) DoAndReturn ¶ added in v16.5.0
func (c *RpcApiLogCall) DoAndReturn(f func() *zap.Logger) *RpcApiLogCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*RpcApiLogCall) Return ¶ added in v16.5.0
func (c *RpcApiLogCall) Return(arg0 *zap.Logger) *RpcApiLogCall
Return rewrite *gomock.Call.Return
type RpcApiPollWithBackoffCall ¶ added in v16.5.0
RpcApiPollWithBackoffCall wrap *gomock.Call
func (*RpcApiPollWithBackoffCall) Do ¶ added in v16.5.0
func (c *RpcApiPollWithBackoffCall) Do(f func(retry.PollConfig, retry.PollWithBackoffFunc) error) *RpcApiPollWithBackoffCall
Do rewrite *gomock.Call.Do
func (*RpcApiPollWithBackoffCall) DoAndReturn ¶ added in v16.5.0
func (c *RpcApiPollWithBackoffCall) DoAndReturn(f func(retry.PollConfig, retry.PollWithBackoffFunc) error) *RpcApiPollWithBackoffCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*RpcApiPollWithBackoffCall) Return ¶ added in v16.5.0
func (c *RpcApiPollWithBackoffCall) Return(arg0 error) *RpcApiPollWithBackoffCall
Return rewrite *gomock.Call.Return