controller

package

Go to main page

Versions in this module

v0

v0.5.7

Mar 4, 2024

Changes in this version

type Controller

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

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

v0.5.6

Dec 5, 2023

Changes in this version

+ func NewCollectorTestCaseExecutionTime() prometheus.Collector

+ func NewCollectorTestCaseStatus() prometheus.Collector

type Controller

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

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

v0.5.5

May 22, 2023

Changes in this version

+ 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

type Controller

+ 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)

v0.5.4

Aug 25, 2022

v0.5.3

Feb 11, 2022

Changes in this version

+ func NewInternalCollectorGitLabAPIRequestsLimit() prometheus.Collector

+ func NewInternalCollectorGitLabAPIRequestsRemaining() prometheus.Collector

type Controller

+ UUID uuid.UUID

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

v0.5.2

Aug 25, 2021

v0.5.1

Jul 19, 2021

Changes in this version

+ func NewInternalCollectorCurrentlyQueuedTasksCount() prometheus.Collector

+ func NewInternalCollectorEnvironmentsCount() prometheus.Collector

+ func NewInternalCollectorExecutedTasksCount() prometheus.Collector

+ func NewInternalCollectorGitLabAPIRequestsCount() prometheus.Collector

+ func NewInternalCollectorMetricsCount() prometheus.Collector

+ func NewInternalCollectorProjectsCount() prometheus.Collector

+ func NewInternalCollectorRefsCount() prometheus.Collector

type Registry

+ InternalCollectors struct{ ... }

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

+ func (r *Registry) RegisterInternalCollectors()

type TaskController

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

v0.5.0

Jun 3, 2021

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 NewCollectorTimestamp() prometheus.Collector

+ type Controller struct

+ Config config.Config

+ Gitlab *gitlab.Client

+ Redis *redis.Client

+ Store store.Store

+ TaskController TaskController

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

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

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

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

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

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

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

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

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

+ func (c *Controller) PullEnvironmentMetrics(env schemas.Environment) (err error)

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

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

+ func (c *Controller) PullRefMetrics(ref schemas.Ref) error

+ func (c *Controller) PullRefMostRecentJobsMetrics(ref schemas.Ref) error

+ func (c *Controller) PullRefPipelineJobsMetrics(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) ScheduleTask(ctx context.Context, tt TaskType, args ...interface{})

+ func (c *Controller) ScheduleTaskWithTicker(ctx context.Context, tt 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(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) TaskHandlerPullProjectsFromWildcard(ctx context.Context, w config.Wildcard) error

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

+ func (c *Controller) TaskHandlerPullRefMetrics(ref schemas.Ref)

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

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

+ func (c *Controller) UpdateEnvironment(env *schemas.Environment) error

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

+ type Registry struct

+ Collectors RegistryCollectors

+ func NewRegistry() *Registry

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

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

+ func (r *Registry) RegisterCollectors() error

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

+ type TaskController struct

+ Factory taskq.Factory

+ Queue taskq.Queue

+ TaskMap *taskq.TaskMap

+ func NewTaskController(r *redis.Client) (t TaskController)

+ type TaskType string

+ const TaskTypeGarbageCollectEnvironments

+ const TaskTypeGarbageCollectMetrics

+ const TaskTypeGarbageCollectProjects

+ const TaskTypeGarbageCollectRefs

+ const TaskTypePullEnvironmentMetrics

+ const TaskTypePullEnvironmentsFromProject

+ const TaskTypePullEnvironmentsFromProjects

+ const TaskTypePullMetrics

+ const TaskTypePullProjectsFromWildcard

+ const TaskTypePullProjectsFromWildcards

+ const TaskTypePullRefMetrics

+ const TaskTypePullRefsFromProject

+ const TaskTypePullRefsFromProjects

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