Versions in this module Expand all Collapse all v18 v18.0.0 May 14, 2025 Changes in this version + func AgentMeta() *entity.AgentMeta + func IncomingAgentCtx(t *testing.T, rpcAPI *MockAgentRPCAPI) context.Context + type MockAPI struct + func NewMockAPI(ctrl *gomock.Controller) *MockAPI + func (m *MockAPI) EXPECT() *MockAPIMockRecorder + func (m *MockAPI) HandleProcessingError(ctx context.Context, log *slog.Logger, msg string, err error, ...) + func (m *MockAPI) OnGitPushEvent(ctx context.Context, cb syncz.EventCallback[*event.GitPushEvent]) + type MockAPIHandleProcessingErrorCall struct + 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 struct + func (mr *MockAPIMockRecorder) HandleProcessingError(ctx, log, msg, err any, fields ...any) *MockAPIHandleProcessingErrorCall + func (mr *MockAPIMockRecorder) OnGitPushEvent(ctx, cb any) *MockAPIOnGitPushEventCall + type MockAPIOnGitPushEventCall struct + 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 MockAgentInfoResolver struct + func NewMockAgentInfoResolver(ctrl *gomock.Controller) *MockAgentInfoResolver + func (m *MockAgentInfoResolver) EXPECT() *MockAgentInfoResolverMockRecorder + func (m *MockAgentInfoResolver) Get(ctx context.Context, agentID int64) (map[string]any, error) + type MockAgentInfoResolverGetCall struct + func (c *MockAgentInfoResolverGetCall) Do(f func(context.Context, int64) (map[string]any, error)) *MockAgentInfoResolverGetCall + func (c *MockAgentInfoResolverGetCall) DoAndReturn(f func(context.Context, int64) (map[string]any, error)) *MockAgentInfoResolverGetCall + func (c *MockAgentInfoResolverGetCall) Return(arg0 map[string]any, arg1 error) *MockAgentInfoResolverGetCall + type MockAgentInfoResolverMockRecorder struct + func (mr *MockAgentInfoResolverMockRecorder) Get(ctx, agentID any) *MockAgentInfoResolverGetCall + type MockAgentRPCAPI struct + func NewMockAgentRPCAPI(ctrl *gomock.Controller) *MockAgentRPCAPI + func NewMockAgentRPCAPIWithMockPoller(ctrl *gomock.Controller, pollTimes int) *MockAgentRPCAPI + func (m *MockAgentRPCAPI) AgentInfo(ctx context.Context, log *slog.Logger) (*api.AgentInfo, error) + func (m *MockAgentRPCAPI) AgentToken() api.AgentToken + 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 struct + 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 MockAgentRPCAPIAgentTokenCall struct + 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 struct + 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 struct + 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 struct + func (c *MockAgentRPCAPILogCall) Do(f func() *slog.Logger) *MockAgentRPCAPILogCall + func (c *MockAgentRPCAPILogCall) DoAndReturn(f func() *slog.Logger) *MockAgentRPCAPILogCall + func (c *MockAgentRPCAPILogCall) Return(arg0 *slog.Logger) *MockAgentRPCAPILogCall + type MockAgentRPCAPIMockRecorder struct + func (mr *MockAgentRPCAPIMockRecorder) AgentInfo(ctx, log any) *MockAgentRPCAPIAgentInfoCall + func (mr *MockAgentRPCAPIMockRecorder) AgentToken() *MockAgentRPCAPIAgentTokenCall + 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 struct + 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 struct + func NewMockFactory(ctrl *gomock.Controller) *MockFactory + func (m *MockFactory) EXPECT() *MockFactoryMockRecorder + func (m *MockFactory) Name() string + func (m *MockFactory) New(arg0 *modserver.Config) (modserver.Module, error) + type MockFactoryMockRecorder struct + func (mr *MockFactoryMockRecorder) Name() *MockFactoryNameCall + func (mr *MockFactoryMockRecorder) New(arg0 any) *MockFactoryNewCall + type MockFactoryNameCall struct + func (c *MockFactoryNameCall) Do(f func() string) *MockFactoryNameCall + func (c *MockFactoryNameCall) DoAndReturn(f func() string) *MockFactoryNameCall + func (c *MockFactoryNameCall) Return(arg0 string) *MockFactoryNameCall + type MockFactoryNewCall struct + 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 struct + func NewMockModule(ctrl *gomock.Controller) *MockModule + func (m *MockModule) EXPECT() *MockModuleMockRecorder + func (m *MockModule) Name() string + func (m *MockModule) Run(arg0 context.Context) error + type MockModuleMockRecorder struct + func (mr *MockModuleMockRecorder) Name() *MockModuleNameCall + func (mr *MockModuleMockRecorder) Run(arg0 any) *MockModuleRunCall + type MockModuleNameCall struct + func (c *MockModuleNameCall) Do(f func() string) *MockModuleNameCall + func (c *MockModuleNameCall) DoAndReturn(f func() string) *MockModuleNameCall + func (c *MockModuleNameCall) Return(arg0 string) *MockModuleNameCall + type MockModuleRunCall struct + func (c *MockModuleRunCall) Do(f func(context.Context) error) *MockModuleRunCall + func (c *MockModuleRunCall) DoAndReturn(f func(context.Context) error) *MockModuleRunCall + func (c *MockModuleRunCall) Return(arg0 error) *MockModuleRunCall v18.0.0-rc42 May 13, 2025 Other modules containing this package gitlab.com/gitlab-org/cluster-integration/gitlab-agent/v14 gitlab.com/gitlab-org/cluster-integration/gitlab-agent/v15 gitlab.com/gitlab-org/cluster-integration/gitlab-agent/v16 gitlab.com/gitlab-org/cluster-integration/gitlab-agent/v17