gc

Documentation

Index

• Constants
• func NewBuildCollector(buildFactory buildFactory) *buildCollector
• type BuildLogRetentionCalculator
  • func NewBuildLogRetentionCalculator(defaultBuildLogsToRetain uint64, maxBuildLogsToRetain uint64) BuildLogRetentionCalculator
• type Collector
  • func NewBuildLogCollector(pipelineFactory db.PipelineFactory, batchSize int, ...) Collector
  • func NewCollector(buildCollector Collector, workers Collector, resourceCacheUses Collector, ...) Collector
  • func NewContainerCollector(containerRepository db.ContainerRepository, jobRunner WorkerJobRunner) Collector
  • func NewResourceCacheCollector(cacheLifecycle db.ResourceCacheLifecycle) Collector
  • func NewResourceCacheUseCollector(cacheLifecycle db.ResourceCacheLifecycle) Collector
  • func NewResourceConfigCheckSessionCollector(configCheckSessionLifecycle db.ResourceConfigCheckSessionLifecycle) Collector
  • func NewResourceConfigCollector(configFactory db.ResourceConfigFactory) Collector
  • func NewVolumeCollector(volumeRepository db.VolumeRepository) Collector
  • func NewWorkerCollector(workerLifecycle db.WorkerLifecycle) Collector
• type Destroyer
  • func NewDestroyer(logger lager.Logger, containerRepository db.ContainerRepository, ...) Destroyer
• type Job
• type JobFunc
  • func (f JobFunc) Name() string
  • func (f JobFunc) Run(workerClient worker.Worker)
• type WorkerJobRunner
  • func NewWorkerJobRunner(logger lager.Logger, workerPool worker.Client, ...) WorkerJobRunner

Constants

const HijackedContainerTimeout = 5 * time.Minute

Functions

func NewBuildCollector

func NewBuildCollector(buildFactory buildFactory) *buildCollector

Types

type BuildLogRetentionCalculator

type BuildLogRetentionCalculator interface {
	BuildLogsToRetain(db.Job) int
}

func NewBuildLogRetentionCalculator

func NewBuildLogRetentionCalculator(
	defaultBuildLogsToRetain uint64,
	maxBuildLogsToRetain uint64,
) BuildLogRetentionCalculator

type Collector

type Collector interface {
	Run(context.Context) error
}

func NewBuildLogCollector

func NewBuildLogCollector(
	pipelineFactory db.PipelineFactory,
	batchSize int,
	buildLogRetentionCalculator BuildLogRetentionCalculator,
) Collector

func NewCollector

func NewCollector(
	buildCollector Collector,
	workers Collector,
	resourceCacheUses Collector,
	resourceConfigs Collector,
	resourceCaches Collector,
	volumes Collector,
	containers Collector,
	resourceConfigCheckSessionCollector Collector,
) Collector

func NewContainerCollector

func NewContainerCollector(
	containerRepository db.ContainerRepository,
	jobRunner WorkerJobRunner,
) Collector

func NewResourceCacheCollector

func NewResourceCacheCollector(cacheLifecycle db.ResourceCacheLifecycle) Collector

func NewResourceCacheUseCollector

func NewResourceCacheUseCollector(cacheLifecycle db.ResourceCacheLifecycle) Collector

func NewResourceConfigCheckSessionCollector

func NewResourceConfigCheckSessionCollector(
	configCheckSessionLifecycle db.ResourceConfigCheckSessionLifecycle,
) Collector

func NewResourceConfigCollector

func NewResourceConfigCollector(configFactory db.ResourceConfigFactory) Collector

func NewVolumeCollector

func NewVolumeCollector(volumeRepository db.VolumeRepository) Collector

func NewWorkerCollector

func NewWorkerCollector(workerLifecycle db.WorkerLifecycle) Collector

type Destroyer

type Destroyer interface {
	FindOrphanedVolumesasDestroying(workerName string) ([]string, error)
	DestroyContainers(workerName string, handles []string) error
	DestroyVolumes(workerName string, handles []string) error
}

Destroyer allows the caller to remove containers and volumes

func NewDestroyer

func NewDestroyer(
	logger lager.Logger,
	containerRepository db.ContainerRepository,
	volumeRepository db.VolumeRepository,
) Destroyer

NewDestroyer provides a constructor for a Destroyer interface implementation

type Job

type Job interface {
	Name() string
	Run(worker.Worker)
}

type JobFunc

type JobFunc func(worker.Worker)

func (JobFunc) Name

func (f JobFunc) Name() string

func (JobFunc) Run

func (f JobFunc) Run(workerClient worker.Worker)

type WorkerJobRunner

type WorkerJobRunner interface {
	Try(lager.Logger, string, Job)
}

func NewWorkerJobRunner

func NewWorkerJobRunner(
	logger lager.Logger,
	workerPool worker.Client,
	workersSyncInterval time.Duration,
	maxJobsPerWorker int,
	dropMetricFunc func(lager.Logger, string),
) WorkerJobRunner