controller

package

Go to main page

Versions in this module

v0

v0.1.9

Feb 2, 2026

v0.1.8

Oct 6, 2025

v0.1.7-rc1

Aug 19, 2025

v0.1.6

Aug 8, 2025

Changes in this version

+ func NewCollectorRunners() prometheus.Collector

+ func NewInternalCollectorRunnersCount() prometheus.Collector

type Controller

+ func (c *Controller) GarbageCollectRunners(ctx context.Context) error

+ func (c *Controller) ProcessRunnerMetrics(ctx context.Context, runner schemas.Runner) (err error)

+ func (c *Controller) PullRunnersFromProject(ctx context.Context, p schemas.Project) (err error)

+ func (c *Controller) TaskHandlerGarbageCollectRunners(ctx context.Context) error

+ func (c *Controller) TaskHandlerPullRunnerMetrics(ctx context.Context, runner schemas.Runner)

+ func (c *Controller) TaskHandlerPullRunnersFromProject(ctx context.Context, p schemas.Project)

+ func (c *Controller) TaskHandlerPullRunnersFromProjects(ctx context.Context)

+ func (c *Controller) UpdateRunner(ctx context.Context, runner *schemas.Runner) error

v0.1.5

Jun 16, 2025

v0.1.4

Jun 16, 2025

Changes in this version

type Controller

+ func (c *Controller) ProcessPipelinesMetrics(ctx context.Context, ref schemas.Ref, apiPipeline *goGitlab.PipelineInfo) error

v0.1.3

Jun 6, 2025

v0.1.2

Jun 5, 2025

v0.1.1

Jun 3, 2025

v0.1.0

Jun 3, 2025

Changes in this version

+ func NewCollectorCoverage() prometheus.Collector

+ func NewCollectorDurationSeconds() prometheus.Collector

+ func NewCollectorEnvironmentBehindCommitsCount() prometheus.Collector

+ func NewCollectorEnvironmentBehindDurationSeconds() prometheus.Collector

+ func NewCollectorEnvironmentDeploymentCount() prometheus.Collector

+ func NewCollectorEnvironmentDeploymentDurationSeconds() prometheus.Collector

+ func NewCollectorEnvironmentDeploymentJobID() prometheus.Collector

+ func NewCollectorEnvironmentDeploymentStatus() prometheus.Collector

+ func NewCollectorEnvironmentDeploymentTimestamp() prometheus.Collector

+ func NewCollectorEnvironmentInformation() prometheus.Collector

+ func NewCollectorID() prometheus.Collector

+ func NewCollectorJobArtifactSizeBytes() prometheus.Collector

+ func NewCollectorJobDurationSeconds() prometheus.Collector

+ func NewCollectorJobID() prometheus.Collector

+ func NewCollectorJobQueuedDurationSeconds() prometheus.Collector

+ func NewCollectorJobRunCount() prometheus.Collector

+ func NewCollectorJobStatus() prometheus.Collector

+ func NewCollectorJobTimestamp() prometheus.Collector

+ func NewCollectorQueuedDurationSeconds() prometheus.Collector

+ func NewCollectorRunCount() prometheus.Collector

+ func NewCollectorStatus() prometheus.Collector

+ func NewCollectorTestCaseExecutionTime() prometheus.Collector

+ func NewCollectorTestCaseStatus() prometheus.Collector

+ func NewCollectorTestReportErrorCount() prometheus.Collector

+ func NewCollectorTestReportFailedCount() prometheus.Collector

+ func NewCollectorTestReportSkippedCount() prometheus.Collector

+ func NewCollectorTestReportSuccessCount() prometheus.Collector

+ func NewCollectorTestReportTotalCount() prometheus.Collector

+ func NewCollectorTestReportTotalTime() prometheus.Collector

+ func NewCollectorTestSuiteErrorCount() prometheus.Collector

+ func NewCollectorTestSuiteFailedCount() prometheus.Collector

+ func NewCollectorTestSuiteSkippedCount() prometheus.Collector

+ func NewCollectorTestSuiteSuccessCount() prometheus.Collector

+ func NewCollectorTestSuiteTotalCount() prometheus.Collector

+ func NewCollectorTestSuiteTotalTime() prometheus.Collector

+ func NewCollectorTimestamp() prometheus.Collector

+ func NewInternalCollectorCurrentlyQueuedTasksCount() prometheus.Collector

+ func NewInternalCollectorEnvironmentsCount() prometheus.Collector

+ func NewInternalCollectorExecutedTasksCount() prometheus.Collector

+ func NewInternalCollectorGitLabAPIRequestsCount() prometheus.Collector

+ func NewInternalCollectorGitLabAPIRequestsLimit() prometheus.Collector

+ func NewInternalCollectorGitLabAPIRequestsRemaining() prometheus.Collector

+ func NewInternalCollectorMetricsCount() prometheus.Collector

+ func NewInternalCollectorProjectsCount() prometheus.Collector

+ func NewInternalCollectorRefsCount() prometheus.Collector

+ type Controller struct

+ Config config.Config

+ Gitlab *gitlab.Client

+ Redis *redis.Client

+ Store store.Store

+ TaskController TaskController

+ UUID uuid.UUID

+ func New(ctx context.Context, cfg config.Config, version string) (c Controller, err error)

+ func (c *Controller) GarbageCollectEnvironments(ctx context.Context) error

+ func (c *Controller) GarbageCollectMetrics(ctx context.Context) error

+ func (c *Controller) GarbageCollectProjects(ctx context.Context) error

+ func (c *Controller) GarbageCollectRefs(ctx context.Context) error

+ func (c *Controller) GetGitLabMetadata(ctx context.Context) error

+ func (c *Controller) GetRefs(ctx context.Context, p schemas.Project) (refs schemas.Refs, err error)

+ func (c *Controller) HealthCheckHandler(ctx context.Context) (h healthcheck.Handler)

+ func (c *Controller) MetricsHandler(w http.ResponseWriter, r *http.Request)

+ func (c *Controller) ProcessJobMetrics(ctx context.Context, ref schemas.Ref, job schemas.Job)

+ func (c *Controller) ProcessTestCaseMetrics(ctx context.Context, ref schemas.Ref, ts schemas.TestSuite, ...)

+ func (c *Controller) ProcessTestReportMetrics(ctx context.Context, ref schemas.Ref, tr schemas.TestReport)

+ func (c *Controller) ProcessTestSuiteMetrics(ctx context.Context, ref schemas.Ref, ts schemas.TestSuite)

+ func (c *Controller) PullEnvironmentMetrics(ctx context.Context, env schemas.Environment) (err error)

+ func (c *Controller) PullEnvironmentsFromProject(ctx context.Context, p schemas.Project) (err error)

+ func (c *Controller) PullProject(ctx context.Context, name string, pull config.ProjectPull) error

+ func (c *Controller) PullProjectsFromWildcard(ctx context.Context, w config.Wildcard) error

+ func (c *Controller) PullRefMetrics(ctx context.Context, ref schemas.Ref) error

+ func (c *Controller) PullRefMostRecentJobsMetrics(ctx context.Context, ref schemas.Ref) error

+ func (c *Controller) PullRefPipelineJobsMetrics(ctx context.Context, ref schemas.Ref) error

+ func (c *Controller) PullRefsFromProject(ctx context.Context, p schemas.Project) error

+ func (c *Controller) Schedule(ctx context.Context, pull config.Pull, gc config.GarbageCollect)

+ func (c *Controller) ScheduleRedisSetKeepalive(ctx context.Context)

+ func (c *Controller) ScheduleTask(ctx context.Context, tt schemas.TaskType, uniqueID string, args ...interface{})

+ func (c *Controller) ScheduleTaskWithTicker(ctx context.Context, tt schemas.TaskType, intervalSeconds int)

+ func (c *Controller) TaskHandlerGarbageCollectEnvironments(ctx context.Context) error

+ func (c *Controller) TaskHandlerGarbageCollectMetrics(ctx context.Context) error

+ func (c *Controller) TaskHandlerGarbageCollectProjects(ctx context.Context) error

+ func (c *Controller) TaskHandlerGarbageCollectRefs(ctx context.Context) error

+ func (c *Controller) TaskHandlerPullEnvironmentMetrics(ctx context.Context, env schemas.Environment)

+ func (c *Controller) TaskHandlerPullEnvironmentsFromProject(ctx context.Context, p schemas.Project)

+ func (c *Controller) TaskHandlerPullEnvironmentsFromProjects(ctx context.Context)

+ func (c *Controller) TaskHandlerPullMetrics(ctx context.Context)

+ func (c *Controller) TaskHandlerPullProject(ctx context.Context, name string, pull config.ProjectPull) error

+ func (c *Controller) TaskHandlerPullProjectsFromWildcard(ctx context.Context, id string, w config.Wildcard) error

+ func (c *Controller) TaskHandlerPullProjectsFromWildcards(ctx context.Context)

+ func (c *Controller) TaskHandlerPullRefMetrics(ctx context.Context, ref schemas.Ref)

+ func (c *Controller) TaskHandlerPullRefsFromProject(ctx context.Context, p schemas.Project)

+ func (c *Controller) TaskHandlerPullRefsFromProjects(ctx context.Context)

+ func (c *Controller) UpdateEnvironment(ctx context.Context, env *schemas.Environment) error

+ func (c *Controller) WebhookHandler(w http.ResponseWriter, r *http.Request)

+ type Registry struct

+ Collectors RegistryCollectors

+ InternalCollectors struct{ ... }

+ func NewRegistry(ctx context.Context) *Registry

+ func (r *Registry) ExportInternalMetrics(ctx context.Context, g *gitlab.Client, s store.Store) (err error)

+ func (r *Registry) ExportMetrics(metrics schemas.Metrics)

+ func (r *Registry) GetCollector(kind schemas.MetricKind) prometheus.Collector

+ func (r *Registry) RegisterCollectors() error

+ func (r *Registry) RegisterInternalCollectors()

+ type RegistryCollectors map[schemas.MetricKind]prometheus.Collector

+ type TaskController struct

+ Factory taskq.Factory

+ Queue taskq.Queue

+ TaskMap *taskq.TaskMap

+ TaskSchedulingMonitoring map[schemas.TaskType]*monitor.TaskSchedulingStatus

+ func NewTaskController(ctx context.Context, r *redis.Client, maximumJobsQueueSize int) (t TaskController)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL