Documentation
¶
Overview ¶
Package mock_modserver is a generated GoMock package.
Package mock_modserver is a generated GoMock package.
Index ¶
- func AgentkMeta() *entity.AgentkMeta
- func AgentwMeta() *entity.AgentwMeta
- func IncomingAgentCtx(t *testing.T, rpcAPI *MockAgentRPCAPI) context.Context
- type MockAPI
- type MockAPIHandleProcessingErrorCall
- func (c *MockAPIHandleProcessingErrorCall) Do(f func(context.Context, *slog.Logger, string, error, ...fieldz.Field)) *MockAPIHandleProcessingErrorCall
- func (c *MockAPIHandleProcessingErrorCall) DoAndReturn(f func(context.Context, *slog.Logger, string, error, ...fieldz.Field)) *MockAPIHandleProcessingErrorCall
- func (c *MockAPIHandleProcessingErrorCall) Return() *MockAPIHandleProcessingErrorCall
- type MockAPIMockRecorder
- type MockAPIOnGitPushEventCall
- func (c *MockAPIOnGitPushEventCall) Do(f func(func(*event.GitPushEvent)) func()) *MockAPIOnGitPushEventCall
- func (c *MockAPIOnGitPushEventCall) DoAndReturn(f func(func(*event.GitPushEvent)) func()) *MockAPIOnGitPushEventCall
- func (c *MockAPIOnGitPushEventCall) Return(arg0 func()) *MockAPIOnGitPushEventCall
- type MockAgentInfoResolver
- type MockAgentInfoResolverGetCall
- func (c *MockAgentInfoResolverGetCall) Do(f func(context.Context, api.AgentKey) (map[string]any, error)) *MockAgentInfoResolverGetCall
- func (c *MockAgentInfoResolverGetCall) DoAndReturn(f func(context.Context, api.AgentKey) (map[string]any, error)) *MockAgentInfoResolverGetCall
- func (c *MockAgentInfoResolverGetCall) Return(arg0 map[string]any, arg1 error) *MockAgentInfoResolverGetCall
- type MockAgentInfoResolverMockRecorder
- type MockAgentRPCAPI
- func (m *MockAgentRPCAPI) AgentInfo(ctx context.Context, log *slog.Logger) (api.AgentInfo, error)
- func (m *MockAgentRPCAPI) AgentTokenWithType() api.AgentTokenWithType
- func (m *MockAgentRPCAPI) EXPECT() *MockAgentRPCAPIMockRecorder
- func (m *MockAgentRPCAPI) HandleIOError(log *slog.Logger, msg string, err error) error
- func (m *MockAgentRPCAPI) HandleProcessingError(log *slog.Logger, msg string, err error, fields ...fieldz.Field)
- func (m *MockAgentRPCAPI) Log() *slog.Logger
- func (m *MockAgentRPCAPI) PollWithBackoff(cfg retry.PollConfig, f retry.PollWithBackoffFunc) error
- type MockAgentRPCAPIAgentInfoCall
- func (c *MockAgentRPCAPIAgentInfoCall) Do(f func(context.Context, *slog.Logger) (api.AgentInfo, error)) *MockAgentRPCAPIAgentInfoCall
- func (c *MockAgentRPCAPIAgentInfoCall) DoAndReturn(f func(context.Context, *slog.Logger) (api.AgentInfo, error)) *MockAgentRPCAPIAgentInfoCall
- func (c *MockAgentRPCAPIAgentInfoCall) Return(arg0 api.AgentInfo, arg1 error) *MockAgentRPCAPIAgentInfoCall
- type MockAgentRPCAPIAgentTokenWithTypeCall
- func (c *MockAgentRPCAPIAgentTokenWithTypeCall) Do(f func() api.AgentTokenWithType) *MockAgentRPCAPIAgentTokenWithTypeCall
- func (c *MockAgentRPCAPIAgentTokenWithTypeCall) DoAndReturn(f func() api.AgentTokenWithType) *MockAgentRPCAPIAgentTokenWithTypeCall
- func (c *MockAgentRPCAPIAgentTokenWithTypeCall) Return(arg0 api.AgentTokenWithType) *MockAgentRPCAPIAgentTokenWithTypeCall
- type MockAgentRPCAPIHandleIOErrorCall
- func (c *MockAgentRPCAPIHandleIOErrorCall) Do(f func(*slog.Logger, string, error) error) *MockAgentRPCAPIHandleIOErrorCall
- func (c *MockAgentRPCAPIHandleIOErrorCall) DoAndReturn(f func(*slog.Logger, string, error) error) *MockAgentRPCAPIHandleIOErrorCall
- func (c *MockAgentRPCAPIHandleIOErrorCall) Return(arg0 error) *MockAgentRPCAPIHandleIOErrorCall
- type MockAgentRPCAPIHandleProcessingErrorCall
- func (c *MockAgentRPCAPIHandleProcessingErrorCall) Do(f func(*slog.Logger, string, error, ...fieldz.Field)) *MockAgentRPCAPIHandleProcessingErrorCall
- func (c *MockAgentRPCAPIHandleProcessingErrorCall) DoAndReturn(f func(*slog.Logger, string, error, ...fieldz.Field)) *MockAgentRPCAPIHandleProcessingErrorCall
- func (c *MockAgentRPCAPIHandleProcessingErrorCall) Return() *MockAgentRPCAPIHandleProcessingErrorCall
- type MockAgentRPCAPILogCall
- type MockAgentRPCAPIMockRecorder
- func (mr *MockAgentRPCAPIMockRecorder) AgentInfo(ctx, log any) *MockAgentRPCAPIAgentInfoCall
- func (mr *MockAgentRPCAPIMockRecorder) AgentTokenWithType() *MockAgentRPCAPIAgentTokenWithTypeCall
- func (mr *MockAgentRPCAPIMockRecorder) HandleIOError(log, msg, err any) *MockAgentRPCAPIHandleIOErrorCall
- func (mr *MockAgentRPCAPIMockRecorder) HandleProcessingError(log, msg, err any, fields ...any) *MockAgentRPCAPIHandleProcessingErrorCall
- func (mr *MockAgentRPCAPIMockRecorder) Log() *MockAgentRPCAPILogCall
- func (mr *MockAgentRPCAPIMockRecorder) PollWithBackoff(cfg, f 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 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 MockModule
- type MockModuleMockRecorder
- type MockModuleNameCall
- type MockModuleRunCall
- type MockRPCAPI
- func (m *MockRPCAPI) EXPECT() *MockRPCAPIMockRecorder
- func (m *MockRPCAPI) HandleIOError(log *slog.Logger, msg string, err error) error
- func (m *MockRPCAPI) HandleProcessingError(log *slog.Logger, msg string, err error, fields ...fieldz.Field)
- func (m *MockRPCAPI) IsDisabled(ff *featureflag.FeatureFlag) bool
- func (m *MockRPCAPI) IsEnabled(ff *featureflag.FeatureFlag) bool
- func (m *MockRPCAPI) Log() *slog.Logger
- func (m *MockRPCAPI) PollWithBackoff(cfg retry.PollConfig, f retry.PollWithBackoffFunc) error
- type MockRPCAPIHandleIOErrorCall
- func (c *MockRPCAPIHandleIOErrorCall) Do(f func(*slog.Logger, string, error) error) *MockRPCAPIHandleIOErrorCall
- func (c *MockRPCAPIHandleIOErrorCall) DoAndReturn(f func(*slog.Logger, string, error) error) *MockRPCAPIHandleIOErrorCall
- func (c *MockRPCAPIHandleIOErrorCall) Return(arg0 error) *MockRPCAPIHandleIOErrorCall
- type MockRPCAPIHandleProcessingErrorCall
- func (c *MockRPCAPIHandleProcessingErrorCall) Do(f func(*slog.Logger, string, error, ...fieldz.Field)) *MockRPCAPIHandleProcessingErrorCall
- func (c *MockRPCAPIHandleProcessingErrorCall) DoAndReturn(f func(*slog.Logger, string, error, ...fieldz.Field)) *MockRPCAPIHandleProcessingErrorCall
- func (c *MockRPCAPIHandleProcessingErrorCall) Return() *MockRPCAPIHandleProcessingErrorCall
- type MockRPCAPIIsDisabledCall
- type MockRPCAPIIsEnabledCall
- type MockRPCAPILogCall
- type MockRPCAPIMockRecorder
- func (mr *MockRPCAPIMockRecorder) HandleIOError(log, msg, err any) *MockRPCAPIHandleIOErrorCall
- func (mr *MockRPCAPIMockRecorder) HandleProcessingError(log, msg, err any, fields ...any) *MockRPCAPIHandleProcessingErrorCall
- func (mr *MockRPCAPIMockRecorder) IsDisabled(ff any) *MockRPCAPIIsDisabledCall
- func (mr *MockRPCAPIMockRecorder) IsEnabled(ff any) *MockRPCAPIIsEnabledCall
- func (mr *MockRPCAPIMockRecorder) Log() *MockRPCAPILogCall
- func (mr *MockRPCAPIMockRecorder) PollWithBackoff(cfg, f 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 AgentkMeta ¶ added in v18.2.0
func AgentkMeta() *entity.AgentkMeta
func AgentwMeta ¶ added in v18.2.0
func AgentwMeta() *entity.AgentwMeta
func IncomingAgentCtx ¶
func IncomingAgentCtx(t *testing.T, rpcAPI *MockAgentRPCAPI) context.Context
Types ¶
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 *slog.Logger, msg string, err error, fields ...fieldz.Field)
HandleProcessingError mocks base method.
func (*MockAPI) OnGitPushEvent ¶
func (m *MockAPI) OnGitPushEvent(arg0 func(*event.GitPushEvent)) func()
OnGitPushEvent mocks base method.
type MockAPIHandleProcessingErrorCall ¶
MockAPIHandleProcessingErrorCall wrap *gomock.Call
func (*MockAPIHandleProcessingErrorCall) Do ¶
func (c *MockAPIHandleProcessingErrorCall) Do(f func(context.Context, *slog.Logger, string, error, ...fieldz.Field)) *MockAPIHandleProcessingErrorCall
Do rewrite *gomock.Call.Do
func (*MockAPIHandleProcessingErrorCall) DoAndReturn ¶
func (c *MockAPIHandleProcessingErrorCall) DoAndReturn(f func(context.Context, *slog.Logger, string, error, ...fieldz.Field)) *MockAPIHandleProcessingErrorCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockAPIHandleProcessingErrorCall) Return ¶
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, msg, err any, fields ...any) *MockAPIHandleProcessingErrorCall
HandleProcessingError indicates an expected call of HandleProcessingError.
func (*MockAPIMockRecorder) OnGitPushEvent ¶
func (mr *MockAPIMockRecorder) OnGitPushEvent(arg0 any) *MockAPIOnGitPushEventCall
OnGitPushEvent indicates an expected call of OnGitPushEvent.
type MockAPIOnGitPushEventCall ¶
MockAPIOnGitPushEventCall wrap *gomock.Call
func (*MockAPIOnGitPushEventCall) Do ¶
func (c *MockAPIOnGitPushEventCall) Do(f func(func(*event.GitPushEvent)) func()) *MockAPIOnGitPushEventCall
Do rewrite *gomock.Call.Do
func (*MockAPIOnGitPushEventCall) DoAndReturn ¶
func (c *MockAPIOnGitPushEventCall) DoAndReturn(f func(func(*event.GitPushEvent)) func()) *MockAPIOnGitPushEventCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockAPIOnGitPushEventCall) Return ¶
func (c *MockAPIOnGitPushEventCall) Return(arg0 func()) *MockAPIOnGitPushEventCall
Return rewrite *gomock.Call.Return
type MockAgentInfoResolver ¶
type MockAgentInfoResolver struct {
// contains filtered or unexported fields
}
MockAgentInfoResolver is a mock of AgentInfoResolver interface.
func NewMockAgentInfoResolver ¶
func NewMockAgentInfoResolver(ctrl *gomock.Controller) *MockAgentInfoResolver
NewMockAgentInfoResolver creates a new mock instance.
func (*MockAgentInfoResolver) EXPECT ¶
func (m *MockAgentInfoResolver) EXPECT() *MockAgentInfoResolverMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockAgentInfoResolverGetCall ¶
MockAgentInfoResolverGetCall wrap *gomock.Call
func (*MockAgentInfoResolverGetCall) Do ¶
func (c *MockAgentInfoResolverGetCall) Do(f func(context.Context, api.AgentKey) (map[string]any, error)) *MockAgentInfoResolverGetCall
Do rewrite *gomock.Call.Do
func (*MockAgentInfoResolverGetCall) DoAndReturn ¶
func (c *MockAgentInfoResolverGetCall) DoAndReturn(f func(context.Context, api.AgentKey) (map[string]any, error)) *MockAgentInfoResolverGetCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockAgentInfoResolverGetCall) Return ¶
func (c *MockAgentInfoResolverGetCall) Return(arg0 map[string]any, arg1 error) *MockAgentInfoResolverGetCall
Return rewrite *gomock.Call.Return
type MockAgentInfoResolverMockRecorder ¶
type MockAgentInfoResolverMockRecorder struct {
// contains filtered or unexported fields
}
MockAgentInfoResolverMockRecorder is the mock recorder for MockAgentInfoResolver.
func (*MockAgentInfoResolverMockRecorder) Get ¶
func (mr *MockAgentInfoResolverMockRecorder) Get(ctx, agentKey any) *MockAgentInfoResolverGetCall
Get indicates an expected call of Get.
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) AgentTokenWithType ¶ added in v18.2.0
func (m *MockAgentRPCAPI) AgentTokenWithType() api.AgentTokenWithType
AgentTokenWithType 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(log *slog.Logger, msg string, err error, fields ...fieldz.Field)
HandleProcessingError mocks base method.
func (*MockAgentRPCAPI) PollWithBackoff ¶
func (m *MockAgentRPCAPI) PollWithBackoff(cfg retry.PollConfig, f retry.PollWithBackoffFunc) error
PollWithBackoff mocks base method.
type MockAgentRPCAPIAgentInfoCall ¶
MockAgentRPCAPIAgentInfoCall wrap *gomock.Call
func (*MockAgentRPCAPIAgentInfoCall) Do ¶
func (c *MockAgentRPCAPIAgentInfoCall) Do(f func(context.Context, *slog.Logger) (api.AgentInfo, error)) *MockAgentRPCAPIAgentInfoCall
Do rewrite *gomock.Call.Do
func (*MockAgentRPCAPIAgentInfoCall) DoAndReturn ¶
func (c *MockAgentRPCAPIAgentInfoCall) DoAndReturn(f func(context.Context, *slog.Logger) (api.AgentInfo, error)) *MockAgentRPCAPIAgentInfoCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockAgentRPCAPIAgentInfoCall) Return ¶
func (c *MockAgentRPCAPIAgentInfoCall) Return(arg0 api.AgentInfo, arg1 error) *MockAgentRPCAPIAgentInfoCall
Return rewrite *gomock.Call.Return
type MockAgentRPCAPIAgentTokenWithTypeCall ¶ added in v18.2.0
MockAgentRPCAPIAgentTokenWithTypeCall wrap *gomock.Call
func (*MockAgentRPCAPIAgentTokenWithTypeCall) Do ¶ added in v18.2.0
func (c *MockAgentRPCAPIAgentTokenWithTypeCall) Do(f func() api.AgentTokenWithType) *MockAgentRPCAPIAgentTokenWithTypeCall
Do rewrite *gomock.Call.Do
func (*MockAgentRPCAPIAgentTokenWithTypeCall) DoAndReturn ¶ added in v18.2.0
func (c *MockAgentRPCAPIAgentTokenWithTypeCall) DoAndReturn(f func() api.AgentTokenWithType) *MockAgentRPCAPIAgentTokenWithTypeCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockAgentRPCAPIAgentTokenWithTypeCall) Return ¶ added in v18.2.0
func (c *MockAgentRPCAPIAgentTokenWithTypeCall) Return(arg0 api.AgentTokenWithType) *MockAgentRPCAPIAgentTokenWithTypeCall
Return rewrite *gomock.Call.Return
type MockAgentRPCAPIHandleIOErrorCall ¶
MockAgentRPCAPIHandleIOErrorCall wrap *gomock.Call
func (*MockAgentRPCAPIHandleIOErrorCall) Do ¶
func (c *MockAgentRPCAPIHandleIOErrorCall) Do(f func(*slog.Logger, string, error) error) *MockAgentRPCAPIHandleIOErrorCall
Do rewrite *gomock.Call.Do
func (*MockAgentRPCAPIHandleIOErrorCall) DoAndReturn ¶
func (c *MockAgentRPCAPIHandleIOErrorCall) DoAndReturn(f func(*slog.Logger, string, error) error) *MockAgentRPCAPIHandleIOErrorCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockAgentRPCAPIHandleIOErrorCall) Return ¶
func (c *MockAgentRPCAPIHandleIOErrorCall) Return(arg0 error) *MockAgentRPCAPIHandleIOErrorCall
Return rewrite *gomock.Call.Return
type MockAgentRPCAPIHandleProcessingErrorCall ¶
MockAgentRPCAPIHandleProcessingErrorCall wrap *gomock.Call
func (*MockAgentRPCAPIHandleProcessingErrorCall) Do ¶
func (c *MockAgentRPCAPIHandleProcessingErrorCall) Do(f func(*slog.Logger, string, error, ...fieldz.Field)) *MockAgentRPCAPIHandleProcessingErrorCall
Do rewrite *gomock.Call.Do
func (*MockAgentRPCAPIHandleProcessingErrorCall) DoAndReturn ¶
func (c *MockAgentRPCAPIHandleProcessingErrorCall) DoAndReturn(f func(*slog.Logger, string, error, ...fieldz.Field)) *MockAgentRPCAPIHandleProcessingErrorCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockAgentRPCAPIHandleProcessingErrorCall) Return ¶
func (c *MockAgentRPCAPIHandleProcessingErrorCall) Return() *MockAgentRPCAPIHandleProcessingErrorCall
Return rewrite *gomock.Call.Return
type MockAgentRPCAPILogCall ¶
MockAgentRPCAPILogCall wrap *gomock.Call
func (*MockAgentRPCAPILogCall) Do ¶
func (c *MockAgentRPCAPILogCall) Do(f func() *slog.Logger) *MockAgentRPCAPILogCall
Do rewrite *gomock.Call.Do
func (*MockAgentRPCAPILogCall) DoAndReturn ¶
func (c *MockAgentRPCAPILogCall) DoAndReturn(f func() *slog.Logger) *MockAgentRPCAPILogCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockAgentRPCAPILogCall) Return ¶
func (c *MockAgentRPCAPILogCall) Return(arg0 *slog.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(ctx, log any) *MockAgentRPCAPIAgentInfoCall
AgentInfo indicates an expected call of AgentInfo.
func (*MockAgentRPCAPIMockRecorder) AgentTokenWithType ¶ added in v18.2.0
func (mr *MockAgentRPCAPIMockRecorder) AgentTokenWithType() *MockAgentRPCAPIAgentTokenWithTypeCall
AgentTokenWithType indicates an expected call of AgentTokenWithType.
func (*MockAgentRPCAPIMockRecorder) HandleIOError ¶
func (mr *MockAgentRPCAPIMockRecorder) HandleIOError(log, msg, err any) *MockAgentRPCAPIHandleIOErrorCall
HandleIOError indicates an expected call of HandleIOError.
func (*MockAgentRPCAPIMockRecorder) HandleProcessingError ¶
func (mr *MockAgentRPCAPIMockRecorder) HandleProcessingError(log, msg, err any, fields ...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(cfg, f any) *MockAgentRPCAPIPollWithBackoffCall
PollWithBackoff indicates an expected call of PollWithBackoff.
type MockAgentRPCAPIPollWithBackoffCall ¶
MockAgentRPCAPIPollWithBackoffCall wrap *gomock.Call
func (*MockAgentRPCAPIPollWithBackoffCall) Do ¶
func (c *MockAgentRPCAPIPollWithBackoffCall) Do(f func(retry.PollConfig, retry.PollWithBackoffFunc) error) *MockAgentRPCAPIPollWithBackoffCall
Do rewrite *gomock.Call.Do
func (*MockAgentRPCAPIPollWithBackoffCall) DoAndReturn ¶
func (c *MockAgentRPCAPIPollWithBackoffCall) DoAndReturn(f func(retry.PollConfig, retry.PollWithBackoffFunc) error) *MockAgentRPCAPIPollWithBackoffCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockAgentRPCAPIPollWithBackoffCall) Return ¶
func (c *MockAgentRPCAPIPollWithBackoffCall) Return(arg0 error) *MockAgentRPCAPIPollWithBackoffCall
Return rewrite *gomock.Call.Return
type MockFactory ¶
type MockFactory struct {
// contains filtered or unexported fields
}
MockFactory is a mock of Factory interface.
func NewMockFactory ¶
func NewMockFactory(ctrl *gomock.Controller) *MockFactory
NewMockFactory creates a new mock instance.
func (*MockFactory) EXPECT ¶
func (m *MockFactory) EXPECT() *MockFactoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockFactoryMockRecorder ¶
type MockFactoryMockRecorder struct {
// contains filtered or unexported fields
}
MockFactoryMockRecorder is the mock recorder for MockFactory.
func (*MockFactoryMockRecorder) Name ¶
func (mr *MockFactoryMockRecorder) Name() *MockFactoryNameCall
Name indicates an expected call of Name.
func (*MockFactoryMockRecorder) New ¶
func (mr *MockFactoryMockRecorder) New(arg0 any) *MockFactoryNewCall
New indicates an expected call of New.
type MockFactoryNameCall ¶
MockFactoryNameCall wrap *gomock.Call
func (*MockFactoryNameCall) Do ¶
func (c *MockFactoryNameCall) Do(f func() string) *MockFactoryNameCall
Do rewrite *gomock.Call.Do
func (*MockFactoryNameCall) DoAndReturn ¶
func (c *MockFactoryNameCall) DoAndReturn(f func() string) *MockFactoryNameCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockFactoryNameCall) Return ¶
func (c *MockFactoryNameCall) Return(arg0 string) *MockFactoryNameCall
Return rewrite *gomock.Call.Return
type MockFactoryNewCall ¶
MockFactoryNewCall wrap *gomock.Call
func (*MockFactoryNewCall) Do ¶
func (c *MockFactoryNewCall) Do(f func(*modserver.Config) (modserver.Module, error)) *MockFactoryNewCall
Do rewrite *gomock.Call.Do
func (*MockFactoryNewCall) DoAndReturn ¶
func (c *MockFactoryNewCall) DoAndReturn(f func(*modserver.Config) (modserver.Module, error)) *MockFactoryNewCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockFactoryNewCall) Return ¶
func (c *MockFactoryNewCall) Return(arg0 modserver.Module, arg1 error) *MockFactoryNewCall
Return rewrite *gomock.Call.Return
type MockModule ¶
type MockModule struct {
// contains filtered or unexported fields
}
MockModule is a mock of Module interface.
func NewMockModule ¶
func NewMockModule(ctrl *gomock.Controller) *MockModule
NewMockModule creates a new mock instance.
func (*MockModule) EXPECT ¶
func (m *MockModule) EXPECT() *MockModuleMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockModuleMockRecorder ¶
type MockModuleMockRecorder struct {
// contains filtered or unexported fields
}
MockModuleMockRecorder is the mock recorder for MockModule.
func (*MockModuleMockRecorder) Name ¶
func (mr *MockModuleMockRecorder) Name() *MockModuleNameCall
Name indicates an expected call of Name.
func (*MockModuleMockRecorder) Run ¶
func (mr *MockModuleMockRecorder) Run(arg0 any) *MockModuleRunCall
Run indicates an expected call of Run.
type MockModuleNameCall ¶
MockModuleNameCall wrap *gomock.Call
func (*MockModuleNameCall) Do ¶
func (c *MockModuleNameCall) Do(f func() string) *MockModuleNameCall
Do rewrite *gomock.Call.Do
func (*MockModuleNameCall) DoAndReturn ¶
func (c *MockModuleNameCall) DoAndReturn(f func() string) *MockModuleNameCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockModuleNameCall) Return ¶
func (c *MockModuleNameCall) Return(arg0 string) *MockModuleNameCall
Return rewrite *gomock.Call.Return
type MockModuleRunCall ¶
MockModuleRunCall wrap *gomock.Call
func (*MockModuleRunCall) Do ¶
func (c *MockModuleRunCall) Do(f func(context.Context) error) *MockModuleRunCall
Do rewrite *gomock.Call.Do
func (*MockModuleRunCall) DoAndReturn ¶
func (c *MockModuleRunCall) DoAndReturn(f func(context.Context) error) *MockModuleRunCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockModuleRunCall) Return ¶
func (c *MockModuleRunCall) Return(arg0 error) *MockModuleRunCall
Return rewrite *gomock.Call.Return
type MockRPCAPI ¶ added in v18.3.0
type MockRPCAPI struct {
// contains filtered or unexported fields
}
MockRPCAPI is a mock of RPCAPI interface.
func NewMockRPCAPI ¶ added in v18.3.0
func NewMockRPCAPI(ctrl *gomock.Controller) *MockRPCAPI
NewMockRPCAPI creates a new mock instance.
func (*MockRPCAPI) EXPECT ¶ added in v18.3.0
func (m *MockRPCAPI) EXPECT() *MockRPCAPIMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockRPCAPI) HandleIOError ¶ added in v18.3.0
HandleIOError mocks base method.
func (*MockRPCAPI) HandleProcessingError ¶ added in v18.3.0
func (m *MockRPCAPI) HandleProcessingError(log *slog.Logger, msg string, err error, fields ...fieldz.Field)
HandleProcessingError mocks base method.
func (*MockRPCAPI) IsDisabled ¶ added in v18.3.0
func (m *MockRPCAPI) IsDisabled(ff *featureflag.FeatureFlag) bool
IsDisabled mocks base method.
func (*MockRPCAPI) IsEnabled ¶ added in v18.3.0
func (m *MockRPCAPI) IsEnabled(ff *featureflag.FeatureFlag) bool
IsEnabled mocks base method.
func (*MockRPCAPI) Log ¶ added in v18.3.0
func (m *MockRPCAPI) Log() *slog.Logger
Log mocks base method.
func (*MockRPCAPI) PollWithBackoff ¶ added in v18.3.0
func (m *MockRPCAPI) PollWithBackoff(cfg retry.PollConfig, f retry.PollWithBackoffFunc) error
PollWithBackoff mocks base method.
type MockRPCAPIHandleIOErrorCall ¶ added in v18.3.0
MockRPCAPIHandleIOErrorCall wrap *gomock.Call
func (*MockRPCAPIHandleIOErrorCall) Do ¶ added in v18.3.0
func (c *MockRPCAPIHandleIOErrorCall) Do(f func(*slog.Logger, string, error) error) *MockRPCAPIHandleIOErrorCall
Do rewrite *gomock.Call.Do
func (*MockRPCAPIHandleIOErrorCall) DoAndReturn ¶ added in v18.3.0
func (c *MockRPCAPIHandleIOErrorCall) DoAndReturn(f func(*slog.Logger, string, error) error) *MockRPCAPIHandleIOErrorCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockRPCAPIHandleIOErrorCall) Return ¶ added in v18.3.0
func (c *MockRPCAPIHandleIOErrorCall) Return(arg0 error) *MockRPCAPIHandleIOErrorCall
Return rewrite *gomock.Call.Return
type MockRPCAPIHandleProcessingErrorCall ¶ added in v18.3.0
MockRPCAPIHandleProcessingErrorCall wrap *gomock.Call
func (*MockRPCAPIHandleProcessingErrorCall) Do ¶ added in v18.3.0
func (c *MockRPCAPIHandleProcessingErrorCall) Do(f func(*slog.Logger, string, error, ...fieldz.Field)) *MockRPCAPIHandleProcessingErrorCall
Do rewrite *gomock.Call.Do
func (*MockRPCAPIHandleProcessingErrorCall) DoAndReturn ¶ added in v18.3.0
func (c *MockRPCAPIHandleProcessingErrorCall) DoAndReturn(f func(*slog.Logger, string, error, ...fieldz.Field)) *MockRPCAPIHandleProcessingErrorCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockRPCAPIHandleProcessingErrorCall) Return ¶ added in v18.3.0
func (c *MockRPCAPIHandleProcessingErrorCall) Return() *MockRPCAPIHandleProcessingErrorCall
Return rewrite *gomock.Call.Return
type MockRPCAPIIsDisabledCall ¶ added in v18.3.0
MockRPCAPIIsDisabledCall wrap *gomock.Call
func (*MockRPCAPIIsDisabledCall) Do ¶ added in v18.3.0
func (c *MockRPCAPIIsDisabledCall) Do(f func(*featureflag.FeatureFlag) bool) *MockRPCAPIIsDisabledCall
Do rewrite *gomock.Call.Do
func (*MockRPCAPIIsDisabledCall) DoAndReturn ¶ added in v18.3.0
func (c *MockRPCAPIIsDisabledCall) DoAndReturn(f func(*featureflag.FeatureFlag) bool) *MockRPCAPIIsDisabledCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockRPCAPIIsDisabledCall) Return ¶ added in v18.3.0
func (c *MockRPCAPIIsDisabledCall) Return(arg0 bool) *MockRPCAPIIsDisabledCall
Return rewrite *gomock.Call.Return
type MockRPCAPIIsEnabledCall ¶ added in v18.3.0
MockRPCAPIIsEnabledCall wrap *gomock.Call
func (*MockRPCAPIIsEnabledCall) Do ¶ added in v18.3.0
func (c *MockRPCAPIIsEnabledCall) Do(f func(*featureflag.FeatureFlag) bool) *MockRPCAPIIsEnabledCall
Do rewrite *gomock.Call.Do
func (*MockRPCAPIIsEnabledCall) DoAndReturn ¶ added in v18.3.0
func (c *MockRPCAPIIsEnabledCall) DoAndReturn(f func(*featureflag.FeatureFlag) bool) *MockRPCAPIIsEnabledCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockRPCAPIIsEnabledCall) Return ¶ added in v18.3.0
func (c *MockRPCAPIIsEnabledCall) Return(arg0 bool) *MockRPCAPIIsEnabledCall
Return rewrite *gomock.Call.Return
type MockRPCAPILogCall ¶ added in v18.3.0
MockRPCAPILogCall wrap *gomock.Call
func (*MockRPCAPILogCall) Do ¶ added in v18.3.0
func (c *MockRPCAPILogCall) Do(f func() *slog.Logger) *MockRPCAPILogCall
Do rewrite *gomock.Call.Do
func (*MockRPCAPILogCall) DoAndReturn ¶ added in v18.3.0
func (c *MockRPCAPILogCall) DoAndReturn(f func() *slog.Logger) *MockRPCAPILogCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockRPCAPILogCall) Return ¶ added in v18.3.0
func (c *MockRPCAPILogCall) Return(arg0 *slog.Logger) *MockRPCAPILogCall
Return rewrite *gomock.Call.Return
type MockRPCAPIMockRecorder ¶ added in v18.3.0
type MockRPCAPIMockRecorder struct {
// contains filtered or unexported fields
}
MockRPCAPIMockRecorder is the mock recorder for MockRPCAPI.
func (*MockRPCAPIMockRecorder) HandleIOError ¶ added in v18.3.0
func (mr *MockRPCAPIMockRecorder) HandleIOError(log, msg, err any) *MockRPCAPIHandleIOErrorCall
HandleIOError indicates an expected call of HandleIOError.
func (*MockRPCAPIMockRecorder) HandleProcessingError ¶ added in v18.3.0
func (mr *MockRPCAPIMockRecorder) HandleProcessingError(log, msg, err any, fields ...any) *MockRPCAPIHandleProcessingErrorCall
HandleProcessingError indicates an expected call of HandleProcessingError.
func (*MockRPCAPIMockRecorder) IsDisabled ¶ added in v18.3.0
func (mr *MockRPCAPIMockRecorder) IsDisabled(ff any) *MockRPCAPIIsDisabledCall
IsDisabled indicates an expected call of IsDisabled.
func (*MockRPCAPIMockRecorder) IsEnabled ¶ added in v18.3.0
func (mr *MockRPCAPIMockRecorder) IsEnabled(ff any) *MockRPCAPIIsEnabledCall
IsEnabled indicates an expected call of IsEnabled.
func (*MockRPCAPIMockRecorder) Log ¶ added in v18.3.0
func (mr *MockRPCAPIMockRecorder) Log() *MockRPCAPILogCall
Log indicates an expected call of Log.
func (*MockRPCAPIMockRecorder) PollWithBackoff ¶ added in v18.3.0
func (mr *MockRPCAPIMockRecorder) PollWithBackoff(cfg, f any) *MockRPCAPIPollWithBackoffCall
PollWithBackoff indicates an expected call of PollWithBackoff.
type MockRPCAPIPollWithBackoffCall ¶ added in v18.3.0
MockRPCAPIPollWithBackoffCall wrap *gomock.Call
func (*MockRPCAPIPollWithBackoffCall) Do ¶ added in v18.3.0
func (c *MockRPCAPIPollWithBackoffCall) Do(f func(retry.PollConfig, retry.PollWithBackoffFunc) error) *MockRPCAPIPollWithBackoffCall
Do rewrite *gomock.Call.Do
func (*MockRPCAPIPollWithBackoffCall) DoAndReturn ¶ added in v18.3.0
func (c *MockRPCAPIPollWithBackoffCall) DoAndReturn(f func(retry.PollConfig, retry.PollWithBackoffFunc) error) *MockRPCAPIPollWithBackoffCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockRPCAPIPollWithBackoffCall) Return ¶ added in v18.3.0
func (c *MockRPCAPIPollWithBackoffCall) Return(arg0 error) *MockRPCAPIPollWithBackoffCall
Return rewrite *gomock.Call.Return