gc

Documentation

Index

• func NewAccessTokensCollector(lifecycle db.AccessTokenLifecycle, leeway time.Duration) *accessTokensCollector
• func NewArtifactCollector(artifactLifecycle db.WorkerArtifactLifecycle) *artifactCollector
• func NewBuildCollector(buildFactory buildFactory) *buildCollector
• func NewBuildLogCollector(pipelineFactory db.PipelineFactory, pipelineLifecycle db.PipelineLifecycle, ...) *buildLogCollector
• func NewContainerCollector(containerRepository db.ContainerRepository, ...) *containerCollector
• func NewPipelineCollector(pipelineLifecyle db.PipelineLifecycle) *pipelineCollector
• func NewResourceCacheCollector(cacheLifecycle db.ResourceCacheLifecycle) *resourceCacheCollector
• func NewResourceCacheUseCollector(cacheLifecycle db.ResourceCacheLifecycle) *resourceCacheUseCollector
• func NewResourceConfigCheckSessionCollector(configCheckSessionLifecycle db.ResourceConfigCheckSessionLifecycle) *resourceConfigCheckSessionCollector
• func NewResourceConfigCollector(configFactory db.ResourceConfigFactory, gracePeriod time.Duration) *resourceConfigCollector
• func NewVolumeCollector(volumeRepository db.VolumeRepository, missingVolumeGracePeriod time.Duration) *volumeCollector
• func NewWorkerCollector(workerLifecycle db.WorkerLifecycle) *workerCollector
• type BuildLogRetentionCalculator
  • func NewBuildLogRetentionCalculator(defaultBuildLogsToRetain uint64, maxBuildLogsToRetain uint64, ...) BuildLogRetentionCalculator
• type Collector
• type Destroyer
  • func NewDestroyer(logger lager.Logger, containerRepository db.ContainerRepository, ...) Destroyer

Functions

func NewAccessTokensCollector

func NewAccessTokensCollector(lifecycle db.AccessTokenLifecycle, leeway time.Duration) *accessTokensCollector

func NewArtifactCollector

func NewArtifactCollector(artifactLifecycle db.WorkerArtifactLifecycle) *artifactCollector

func NewBuildCollector

func NewBuildCollector(buildFactory buildFactory) *buildCollector

func NewBuildLogCollector

func NewBuildLogCollector(
	pipelineFactory db.PipelineFactory,
	pipelineLifecycle db.PipelineLifecycle,
	batchSize int,
	buildLogRetentionCalculator BuildLogRetentionCalculator,
	drainerConfigured bool,
) *buildLogCollector

func NewContainerCollector

func NewContainerCollector(
	containerRepository db.ContainerRepository,
	missingContainerGracePeriod time.Duration,
	hijackContainerGracePeriod time.Duration,
) *containerCollector

func NewPipelineCollector

func NewPipelineCollector(pipelineLifecyle db.PipelineLifecycle) *pipelineCollector

func NewResourceCacheCollector

func NewResourceCacheCollector(cacheLifecycle db.ResourceCacheLifecycle) *resourceCacheCollector

func NewResourceCacheUseCollector

func NewResourceCacheUseCollector(cacheLifecycle db.ResourceCacheLifecycle) *resourceCacheUseCollector

func NewResourceConfigCheckSessionCollector

func NewResourceConfigCheckSessionCollector(
	configCheckSessionLifecycle db.ResourceConfigCheckSessionLifecycle,
) *resourceConfigCheckSessionCollector

func NewResourceConfigCollector

func NewResourceConfigCollector(
	configFactory db.ResourceConfigFactory,
	gracePeriod time.Duration,
) *resourceConfigCollector

func NewVolumeCollector

func NewVolumeCollector(
	volumeRepository db.VolumeRepository,
	missingVolumeGracePeriod time.Duration,
) *volumeCollector

func NewWorkerCollector

func NewWorkerCollector(workerLifecycle db.WorkerLifecycle) *workerCollector

Types

type BuildLogRetentionCalculator

type BuildLogRetentionCalculator interface {
	BuildLogsToRetain(atc.JobConfig) atc.BuildLogRetention
}

func NewBuildLogRetentionCalculator

func NewBuildLogRetentionCalculator(
	defaultBuildLogsToRetain uint64,
	maxBuildLogsToRetain uint64,
	defaultDaysToRetainBuildLogs uint64,
	maxDaysToRetainBuildLogs uint64,
) BuildLogRetentionCalculator

type Collector

type Collector interface {
	Collect(lager.Logger) error
}

type Destroyer

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

Destroyer allows removal of containers and volumes from the database

func NewDestroyer

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

NewDestroyer provides a constructor for a Destroyer interface implementation