Versions in this module Expand all Collapse all v6 v6.4.2 Aug 17, 2020 Changes in this version + const MissingBuildInput + const NoResourceCheckFinished + const NoVersionsAvailable + const NoVersionsSatisfiedPassedConstraints + const PinnedVersionUnavailable + const WorkerStateLanded + const WorkerStateLanding + const WorkerStateRetiring + const WorkerStateRunning + const WorkerStateStalled + var ErrAdoptRerunBuildHasNoInputs = errors.New("inputs not ready for build to rerun") + var ErrBuildArtifactNotFound = errors.New("build artifact not found") + var ErrBuildDisappeared = errors.New("build disappeared from db") + var ErrBuildEventStreamClosed = errors.New("build event stream closed") + var ErrBuildHasNoPipeline = errors.New("build has no pipeline") + var ErrCannotPruneRunningWorker = errors.New("worker not stalled for pruning") + var ErrConfigComparisonFailed = errors.New("comparison with existing config failed during save") + var ErrContainerDisappeared = errors.New("container disappeared from db") + var ErrEncryptedWithUnknownKey = errors.New("row encrypted with neither old nor new key") + var ErrEndOfBuildEventStream = errors.New("end of build event stream") + var ErrInvalidResourceCache = errors.New("invalid resource cache") + var ErrPinnedThroughConfig = errors.New("resource is pinned through config") + var ErrResourceCacheAlreadyExists = errors.New("resource-cache-already-exists") + var ErrResourceCacheDisappeared = errors.New("resource-cache-disappeared") + var ErrResourceConfigAlreadyExists = errors.New("resource config already exists") + var ErrResourceConfigDisappeared = errors.New("resource config disappeared") + var ErrResourceConfigHasNoType = errors.New("resource config has no type") + var ErrResourceConfigParentDisappeared = errors.New("resource config parent disappeared") + var ErrSetByNewerBuild = errors.New("pipeline set by a newer build") + var ErrVolumeCannotBeDestroyedWithChildrenPresent = errors.New("volume cannot be destroyed as children are present") + var ErrVolumeMissing = errors.New("volume no longer in db") + var ErrVolumeStateTransitionFailed = errors.New("could not transition volume state") + var ErrWorkerBaseResourceTypeDisappeared = errors.New("worker base resource type disappeared") + var ErrWorkerNotPresent = errors.New("worker not present in db") + var GlobalConnectionTracker = NewConnectionTracker() + func Close(c io.Closer) + func NewArtifactLifecycle(conn Conn) *artifactLifecycle + func NewCheckLifecycle(conn Conn) *checkLifecycle + func NewCheckableCounter(conn Conn) *checkableCounter + func NewClock() clock + func NewNotificationsBus(listener Listener, executor Executor) *notificationsBus + func Rollback(tx Tx) + func SetupConnectionRetryingDriver(delegateDriverName string, sqlDataSource string, newDriverName string) + type AccessToken struct + Claims Claims + Token string + type AccessTokenFactory interface + CreateAccessToken func(token string, claims Claims) error + GetAccessToken func(token string) (AccessToken, bool, error) + func NewAccessTokenFactory(conn Conn) AccessTokenFactory + type AccessTokenLifecycle interface + RemoveExpiredAccessTokens func(leeway time.Duration) (int, error) + func NewAccessTokenLifecycle(conn Conn) AccessTokenLifecycle + type AlgorithmInput struct + FirstOccurrence bool + type AlgorithmOutput struct + InputName string + type AlgorithmVersion struct + ResourceID int + Version ResourceVersion + type BaseResourceType struct + Name string + func (brt BaseResourceType) Find(runner sq.Runner) (*UsedBaseResourceType, bool, error) + func (brt BaseResourceType) FindOrCreate(tx Tx, unique bool) (*UsedBaseResourceType, error) + type BaseResourceTypeNotFoundError struct + Name string + func (e BaseResourceTypeNotFoundError) Error() string + type Build interface + AbortNotifier func() (Notifier, error) + AcquireTrackingLock func(logger lager.Logger, interval time.Duration) (lock.Lock, bool, error) + AdoptInputsAndPipes func() ([]BuildInput, bool, error) + AdoptRerunInputsAndPipes func() ([]BuildInput, bool, error) + Artifact func(artifactID int) (WorkerArtifact, error) + Artifacts func() ([]WorkerArtifact, error) + Delete func() (bool, error) + EndTime func() time.Time + Events func(uint) (EventSource, error) + Finish func(BuildStatus) error + HasPlan func() bool + ID func() int + InputsReady func() bool + Interceptible func() (bool, error) + IsAborted func() bool + IsCompleted func() bool + IsDrained func() bool + IsManuallyTriggered func() bool + IsNewerThanLastCheckOf func(input Resource) bool + IsRunning func() bool + IsScheduled func() bool + JobID func() int + JobName func() string + MarkAsAborted func() error + Name func() string + Preparation func() (BuildPreparation, bool, error) + PrivatePlan func() atc.Plan + PublicPlan func() *json.RawMessage + ReapTime func() time.Time + Reload func() (bool, error) + RerunNumber func() int + RerunOf func() int + RerunOfName func() string + Resources func() ([]BuildInput, []BuildOutput, error) + ResourcesChecked func() (bool, error) + SaveEvent func(event atc.Event) error + SaveImageResourceVersion func(UsedResourceCache) error + SaveOutput func(string, atc.Source, atc.VersionedResourceTypes, atc.Version, ...) error + SavePipeline func(pipelineName string, teamId int, config atc.Config, from ConfigVersion, ...) (Pipeline, bool, error) + Schema func() string + SetDrained func(bool) error + SetInterceptible func(bool) error + SpanContext func() propagators.Supplier + Start func(atc.Plan) (bool, error) + StartTime func() time.Time + Status func() BuildStatus + TeamID func() int + TeamName func() string + type BuildCursor struct + ID int + RerunOf sql.NullInt64 + func (cursor BuildCursor) NewerBuilds(idCol string) sq.Sqlizer + func (cursor BuildCursor) OlderBuilds(idCol string) sq.Sqlizer + type BuildFactory interface + AllBuilds func(Page) ([]Build, Pagination, error) + Build func(int) (Build, bool, error) + GetAllStartedBuilds func() ([]Build, error) + GetDrainableBuilds func() ([]Build, error) + MarkNonInterceptibleBuilds func() error + PublicBuilds func(Page) ([]Build, Pagination, error) + VisibleBuilds func([]string, Page) ([]Build, Pagination, error) + func NewBuildFactory(conn Conn, lockFactory lock.LockFactory, oneOffGracePeriod time.Duration, ...) BuildFactory + type BuildInput struct + Context SpanContext + FirstOccurrence bool + Name string + ResolveError string + ResourceID int + Version atc.Version + func (bi BuildInput) SpanContext() propagators.Supplier + type BuildOutput struct + Name string + Version atc.Version + type BuildPreparation struct + BuildID int + Inputs map[string]BuildPreparationStatus + InputsSatisfied BuildPreparationStatus + MaxRunningBuilds BuildPreparationStatus + MissingInputReasons MissingInputReasons + PausedJob BuildPreparationStatus + PausedPipeline BuildPreparationStatus + type BuildPreparationStatus string + const BuildPreparationStatusBlocking + const BuildPreparationStatusNotBlocking + type BuildStatus string + const BuildStatusAborted + const BuildStatusErrored + const BuildStatusFailed + const BuildStatusPending + const BuildStatusStarted + const BuildStatusSucceeded + type Cause struct + BuildID int + ResourceVersionID int + type Check interface + AcquireTrackingLock func(lager.Logger) (lock.Lock, bool, error) + AllCheckables func() ([]Checkable, error) + BaseResourceTypeID func() int + CheckError func() error + CreateTime func() time.Time + EndTime func() time.Time + Finish func() error + FinishWithError func(err error) error + ID func() int + ManuallyTriggered func() bool + Plan func() atc.Plan + Reload func() (bool, error) + ResourceConfigID func() int + ResourceConfigScopeID func() int + SaveVersions func(SpanContext, []atc.Version) error + Schema func() string + SpanContext func() propagators.Supplier + Start func() error + StartTime func() time.Time + Status func() CheckStatus + TeamID func() int + TeamName func() string + type CheckFactory interface + AcquireScanningLock func(lager.Logger) (lock.Lock, bool, error) + Check func(int) (Check, bool, error) + CreateCheck func(int, bool, atc.Plan, CheckMetadata, SpanContext) (Check, bool, error) + NotifyChecker func() error + ResourceTypes func() ([]ResourceType, error) + Resources func() ([]Resource, error) + StartedChecks func() ([]Check, error) + TryCreateCheck func(context.Context, Checkable, ResourceTypes, atc.Version, bool) (Check, bool, error) + func NewCheckFactory(conn Conn, lockFactory lock.LockFactory, secrets creds.Secrets, ...) CheckFactory + type CheckLifecycle interface + RemoveExpiredChecks func(time.Duration) (int, error) + type CheckMetadata struct + BaseResourceTypeID int + PipelineID int + PipelineName string + ResourceConfigID int + TeamID int + TeamName string + type CheckStatus string + const CheckStatusErrored + const CheckStatusStarted + const CheckStatusSucceeded + type Checkable interface + CheckEvery func() string + CheckTimeout func() string + CurrentPinnedVersion func() atc.Version + HasWebhook func() bool + LastCheckEndTime func() time.Time + Name func() string + ResourceConfigScopeID func() int + SetCheckSetupError func(error) error + SetResourceConfig func(atc.Source, atc.VersionedResourceTypes) (ResourceConfigScope, error) + Source func() atc.Source + Tags func() atc.Tags + TeamID func() int + TeamName func() string + Type func() string + type Claims struct + RawClaims map[string]interface{} + func (c *Claims) Scan(value interface{}) error + func (c *Claims) UnmarshalJSON(data []byte) error + func (c Claims) MarshalJSON() ([]byte, error) + func (c Claims) Value() (driver.Value, error) + type Clock interface + Now func() time.Time + Until func(time.Time) time.Duration + type Component interface + ID func() int + Interval func() time.Duration + IntervalElapsed func() bool + LastRan func() time.Time + Name func() string + Paused func() bool + Reload func() (bool, error) + UpdateLastRan func() error + type ComponentFactory interface + CreateOrUpdate func(atc.Component) (Component, error) + Find func(string) (Component, bool, error) + func NewComponentFactory(conn Conn) ComponentFactory + type ConfigVersion int + type Conn interface + Begin func() (Tx, error) + BeginTx func(context.Context, *sql.TxOptions) (Tx, error) + Bus func() NotificationsBus + Close func() error + Driver func() driver.Driver + EncryptionStrategy func() encryption.Strategy + Exec func(string, ...interface{}) (sql.Result, error) + ExecContext func(context.Context, string, ...interface{}) (sql.Result, error) + Name func() string + Ping func() error + Prepare func(string) (*sql.Stmt, error) + PrepareContext func(context.Context, string) (*sql.Stmt, error) + Query func(string, ...interface{}) (*sql.Rows, error) + QueryContext func(context.Context, string, ...interface{}) (*sql.Rows, error) + QueryRow func(string, ...interface{}) squirrel.RowScanner + QueryRowContext func(context.Context, string, ...interface{}) squirrel.RowScanner + SetMaxIdleConns func(int) + SetMaxOpenConns func(int) + Stats func() sql.DBStats + func Log(logger lager.Logger, conn Conn) Conn + func Open(logger lager.Logger, sqlDriver string, sqlDataSource string, ...) (Conn, error) + type ConnectionSession struct + func (session *ConnectionSession) Release() + type ConnectionTracker struct + func NewConnectionTracker() *ConnectionTracker + func (tracker *ConnectionTracker) Current() []string + func (tracker *ConnectionTracker) Track() *ConnectionSession + type Container interface + Handle func() string + ID func() int + Metadata func() ContainerMetadata + State func() string + WorkerName func() string + type ContainerMetadata struct + Attempt string + BuildID int + BuildName string + JobID int + JobName string + PipelineID int + PipelineName string + StepName string + Type ContainerType + User string + WorkingDirectory string + func (metadata *ContainerMetadata) ScanTargets() []interface{} + func (metadata ContainerMetadata) SQLMap() map[string]interface{} + type ContainerOwner interface + Create func(tx Tx, workerName string) (map[string]interface{}, error) + Find func(conn Conn) (sq.Eq, bool, error) + func NewBuildStepContainerOwner(buildID int, planID atc.PlanID, teamID int) ContainerOwner + func NewImageCheckContainerOwner(container CreatingContainer, teamID int) ContainerOwner + func NewImageGetContainerOwner(container CreatingContainer, teamID int) ContainerOwner + func NewResourceConfigCheckSessionContainerOwner(resourceConfigID int, baseResourceTypeID int, expiries ContainerOwnerExpiries) ContainerOwner + type ContainerOwnerDisappearedError struct + func (e ContainerOwnerDisappearedError) Error() string + type ContainerOwnerExpiries struct + Max time.Duration + Min time.Duration + type ContainerRepository interface + DestroyFailedContainers func() (int, error) + DestroyUnknownContainers func(workerName string, reportedHandles []string) (int, error) + FindDestroyingContainers func(workerName string) ([]string, error) + FindOrphanedContainers func() ([]CreatingContainer, []CreatedContainer, []DestroyingContainer, error) + RemoveDestroyingContainers func(workerName string, currentHandles []string) (int, error) + RemoveMissingContainers func(time.Duration) (int, error) + UpdateContainersMissingSince func(workerName string, handles []string) error + func NewContainerRepository(conn Conn) ContainerRepository + type ContainerState string + type ContainerType string + const ContainerTypeCheck + const ContainerTypeGet + const ContainerTypePut + const ContainerTypeTask + func ContainerTypeFromString(containerType string) (ContainerType, error) + type CreatedContainer interface + Destroying func() (DestroyingContainer, error) + LastHijack func() time.Time + UpdateLastHijack func() error + type CreatedVolume interface + BaseResourceType func() (*UsedWorkerBaseResourceType, error) + ContainerHandle func() string + CreateChildForContainer func(CreatingContainer, string) (CreatingVolume, error) + Destroying func() (DestroyingVolume, error) + GetResourceCacheID func() int + Handle func() string + InitializeArtifact func(name string, buildID int) (WorkerArtifact, error) + InitializeResourceCache func(UsedResourceCache) error + InitializeTaskCache func(jobID int, stepName string, path string) error + ParentHandle func() string + Path func() string + ResourceType func() (*VolumeResourceType, error) + TaskIdentifier func() (string, string, string, error) + TeamID func() int + Type func() VolumeType + WorkerArtifactID func() int + WorkerName func() string + type CreatingContainer interface + Created func() (CreatedContainer, error) + Failed func() (FailedContainer, error) + type CreatingVolume interface + Created func() (CreatedVolume, error) + Failed func() (FailedVolume, error) + Handle func() string + ID func() int + type DestroyingContainer interface + Destroy func() (bool, error) + type DestroyingVolume interface + Destroy func() (bool, error) + Handle func() string + WorkerName func() string + type ErrCustomResourceTypeVersionNotFound struct + Name string + func (e ErrCustomResourceTypeVersionNotFound) Error() string + type ErrResourceNotFound struct + Name string + func (e ErrResourceNotFound) Error() string + type ErrVolumeMarkCreatedFailed struct + Handle string + func (e ErrVolumeMarkCreatedFailed) Error() string + type ErrVolumeMarkStateFailed struct + State VolumeState + func (e ErrVolumeMarkStateFailed) Error() string + type EventSource interface + Close func() error + Next func() (event.Envelope, error) + type Executor interface + Exec func(statement string, args ...interface{}) (sql.Result, error) + type FailedContainer interface + Destroy func() (bool, error) + type FailedVolume interface + Destroy func() (bool, error) + Handle func() string + WorkerName func() string + type FederatedClaims struct + Connector string + Username string + type FirstLoggedBuildIDDecreasedError struct + Job string + NewID int + OldID int + func (e FirstLoggedBuildIDDecreasedError) Error() string + type InputConfig struct + JobID int + Name string + Passed JobSet + PinnedVersion atc.Version + ResourceID int + Trigger bool + UseEveryVersion bool + type InputConfigs []InputConfig + func (cfgs InputConfigs) String() string + type InputMapping map[string]InputResult + type InputResult struct + Input *AlgorithmInput + PassedBuildIDs []int + ResolveError ResolutionFailure + type InputVersionEmptyError struct + InputName string + func (e InputVersionEmptyError) Error() string + type Job interface + AcquireSchedulingLock func(lager.Logger) (lock.Lock, bool, error) + AlgorithmInputs func() (InputConfigs, error) + Build func(name string) (Build, bool, error) + Builds func(page Page) ([]Build, Pagination, error) + BuildsWithTime func(page Page) ([]Build, Pagination, error) + ClearTaskCache func(string, string) (int64, error) + Config func() (atc.JobConfig, error) + CreateBuild func() (Build, error) + DisableManualTrigger func() bool + EnsurePendingBuildExists func(context.Context) error + FinishedAndNextBuild func() (Build, Build, error) + FirstLoggedBuildID func() int + GetFullNextBuildInputs func() ([]BuildInput, bool, error) + GetNextBuildInputs func() ([]BuildInput, error) + GetPendingBuilds func() ([]Build, error) + HasNewInputs func() bool + ID func() int + Inputs func() ([]atc.JobInput, error) + MaxInFlight func() int + Name func() string + Outputs func() ([]atc.JobOutput, error) + Pause func() error + Paused func() bool + Public func() bool + Reload func() (bool, error) + RequestSchedule func() error + RerunBuild func(Build) (Build, error) + SaveNextInputMapping func(inputMapping InputMapping, inputsDetermined bool) error + ScheduleBuild func(Build) (bool, error) + ScheduleRequestedTime func() time.Time + SetHasNewInputs func(bool) error + Tags func() []string + TeamID func() int + TeamName func() string + Unpause func() error + UpdateFirstLoggedBuildID func(newFirstLoggedBuildID int) error + UpdateLastScheduled func(time.Time) error + type JobFactory interface + AllActiveJobs func() (atc.Dashboard, error) + JobsToSchedule func() (SchedulerJobs, error) + VisibleJobs func([]string) (atc.Dashboard, error) + func NewJobFactory(conn Conn, lockFactory lock.LockFactory) JobFactory + type JobSet map[int]bool + type Jobs []Job + func (jobs Jobs) Configs() (atc.JobConfigs, error) + type Listener interface + Close func() error + Listen func(channel string) error + NotificationChannel func() <-chan *pq.Notification + Unlisten func(channel string) error + type MissingInputReasons map[string]string + func (m MissingInputReasons) RegisterMissingInput(inputName string) + func (m MissingInputReasons) RegisterNoResourceCheckFinished(inputName string) + func (m MissingInputReasons) RegisterResolveError(inputName string, resolveErr string) + type NonOneRowAffectedError struct + RowsAffected int64 + func (err NonOneRowAffectedError) Error() string + type NotificationsBus interface + Close func() error + Listen func(channel string) (chan bool, error) + Notify func(channel string) error + Unlisten func(channel string, notify chan bool) error + type Notifier interface + Close func() error + Notify func() <-chan struct{} + type Page struct + From int + Limit int + Since int + To int + Until int + UseDate bool + type PaginatedBuilds struct + func (bs *PaginatedBuilds) HasNext() bool + func (bs *PaginatedBuilds) Next(ctx context.Context) (int, bool, error) + type Pagination struct + Next *Page + Previous *Page + type PinnedVersionNotFound struct + PinnedVersion atc.Version + func (p PinnedVersionNotFound) String() ResolutionFailure + type Pipe struct + ID string + TeamName string + URL string + type Pipeline interface + Archive func() error + Archived func() bool + Builds func(page Page) ([]Build, Pagination, error) + BuildsWithTime func(page Page) ([]Build, Pagination, error) + Causality func(versionedResourceID int) ([]Cause, error) + CheckPaused func() (bool, error) + Config func() (atc.Config, error) + ConfigVersion func() ConfigVersion + CreateOneOffBuild func() (Build, error) + CreateStartedBuild func(plan atc.Plan) (Build, error) + Dashboard func() (atc.Dashboard, error) + DeleteBuildEventsByBuildIDs func(buildIDs []int) error + Destroy func() error + Expose func() error + GetBuildsWithVersionAsInput func(int, int) ([]Build, error) + GetBuildsWithVersionAsOutput func(int, int) ([]Build, error) + Groups func() atc.GroupConfigs + Hide func() error + ID func() int + Job func(name string) (Job, bool, error) + Jobs func() (Jobs, error) + LastUpdated func() time.Time + LoadDebugVersionsDB func() (*atc.DebugVersionsDB, error) + Name func() string + ParentBuildID func() int + ParentJobID func() int + Pause func() error + Paused func() bool + Public func() bool + Reload func() (bool, error) + Rename func(string) error + Resource func(name string) (Resource, bool, error) + ResourceByID func(id int) (Resource, bool, error) + ResourceType func(name string) (ResourceType, bool, error) + ResourceTypeByID func(id int) (ResourceType, bool, error) + ResourceTypes func() (ResourceTypes, error) + ResourceVersion func(resourceConfigVersionID int) (atc.ResourceVersion, bool, error) + Resources func() (Resources, error) + SetParentIDs func(jobID, buildID int) error + TeamID func() int + TeamName func() string + Unpause func() error + VarSources func() atc.VarSourceConfigs + Variables func(lager.Logger, creds.Secrets, creds.VarSourcePool) (vars.Variables, error) + type PipelineFactory interface + AllPipelines func() ([]Pipeline, error) + PipelinesToSchedule func() ([]Pipeline, error) + VisiblePipelines func([]string) ([]Pipeline, error) + func NewPipelineFactory(conn Conn, lockFactory lock.LockFactory) PipelineFactory + type PipelineLifecycle interface + ArchiveAbandonedPipelines func() error + func NewPipelineLifecycle(conn Conn, lockFactory lock.LockFactory) PipelineLifecycle + type PipelineRef interface + Pipeline func() (Pipeline, bool, error) + PipelineID func() int + PipelineName func() string + func NewPipelineRef(id int, name string, conn Conn, lockFactory lock.LockFactory) PipelineRef + type ResolutionFailure string + const LatestVersionNotFound + const NoSatisfiableBuilds + const VersionNotFound + type Resource interface + APIPinnedVersion func() atc.Version + CheckError func() error + CheckEvery func() string + CheckSetupError func() error + CheckTimeout func() string + Config func() atc.ResourceConfig + ConfigPinnedVersion func() atc.Version + CurrentPinnedVersion func() atc.Version + DisableVersion func(rcvID int) error + EnableVersion func(rcvID int) error + HasWebhook func() bool + ID func() int + Icon func() string + LastCheckEndTime func() time.Time + LastCheckStartTime func() time.Time + Name func() string + NotifyScan func() error + PinComment func() string + PinVersion func(rcvID int) (bool, error) + Public func() bool + Reload func() (bool, error) + ResourceConfigID func() int + ResourceConfigScopeID func() int + ResourceConfigVersionID func(atc.Version) (int, bool, error) + SaveUncheckedVersion func(atc.Version, ResourceConfigMetadataFields, ResourceConfig, ...) (bool, error) + SetCheckSetupError func(error) error + SetPinComment func(string) error + SetResourceConfig func(atc.Source, atc.VersionedResourceTypes) (ResourceConfigScope, error) + Source func() atc.Source + Tags func() atc.Tags + TeamID func() int + TeamName func() string + Type func() string + UnpinVersion func() error + UpdateMetadata func(atc.Version, ResourceConfigMetadataFields) (bool, error) + Versions func(page Page, versionFilter atc.Version) ([]atc.ResourceVersion, Pagination, bool, error) + WebhookToken func() string + type ResourceCacheDescriptor struct + Params atc.Params + ResourceConfigDescriptor ResourceConfigDescriptor + Version atc.Version + type ResourceCacheFactory interface + FindOrCreateResourceCache func(resourceCacheUser ResourceCacheUser, resourceTypeName string, ...) (UsedResourceCache, error) + FindResourceCacheByID func(id int) (UsedResourceCache, bool, error) + ResourceCacheMetadata func(UsedResourceCache) (ResourceConfigMetadataFields, error) + UpdateResourceCacheMetadata func(UsedResourceCache, []atc.MetadataField) error + func NewResourceCacheFactory(conn Conn, lockFactory lock.LockFactory) ResourceCacheFactory + type ResourceCacheLifecycle interface + CleanBuildImageResourceCaches func(lager.Logger) error + CleanUpInvalidCaches func(lager.Logger) error + CleanUsesForFinishedBuilds func(lager.Logger) error + func NewResourceCacheLifecycle(conn Conn) ResourceCacheLifecycle + type ResourceCacheUser interface + SQLMap func() map[string]interface{} + func ForBuild(id int) ResourceCacheUser + func ForContainer(id int) ResourceCacheUser + type ResourceConfig interface + CreatedByBaseResourceType func() *UsedBaseResourceType + CreatedByResourceCache func() UsedResourceCache + FindResourceConfigScopeByID func(int, Resource) (ResourceConfigScope, bool, error) + ID func() int + OriginBaseResourceType func() *UsedBaseResourceType + type ResourceConfigCheckSessionLifecycle interface + CleanExpiredResourceConfigCheckSessions func() error + CleanInactiveResourceConfigCheckSessions func() error + func NewResourceConfigCheckSessionLifecycle(conn Conn) ResourceConfigCheckSessionLifecycle + type ResourceConfigDescriptor struct + CreatedByBaseResourceType *BaseResourceType + CreatedByResourceCache *ResourceCacheDescriptor + Source atc.Source + type ResourceConfigFactory interface + CleanUnreferencedConfigs func() error + FindOrCreateResourceConfig func(resourceType string, source atc.Source, ...) (ResourceConfig, error) + FindResourceConfigByID func(int) (ResourceConfig, bool, error) + func NewResourceConfigFactory(conn Conn, lockFactory lock.LockFactory) ResourceConfigFactory + type ResourceConfigMetadataField struct + Name string + Value string + type ResourceConfigMetadataFields []ResourceConfigMetadataField + func NewResourceConfigMetadataFields(atcm []atc.MetadataField) ResourceConfigMetadataFields + func (rmf ResourceConfigMetadataFields) ToATCMetadata() []atc.MetadataField + type ResourceConfigScope interface + AcquireResourceCheckingLock func(logger lager.Logger) (lock.Lock, bool, error) + CheckError func() error + FindVersion func(atc.Version) (ResourceConfigVersion, bool, error) + ID func() int + LatestVersion func() (ResourceConfigVersion, bool, error) + Resource func() Resource + ResourceConfig func() ResourceConfig + SaveVersions func(SpanContext, []atc.Version) error + SetCheckError func(error) error + UpdateLastCheckEndTime func() (bool, error) + UpdateLastCheckStartTime func(interval time.Duration, immediate bool) (bool, error) + type ResourceConfigVersion interface + CheckOrder func() int + ID func() int + Metadata func() ResourceConfigMetadataFields + Reload func() (bool, error) + ResourceConfigScope func() ResourceConfigScope + SpanContext func() propagators.Supplier + Version func() Version + type ResourceConfigVersions []ResourceConfigVersion + type ResourceFactory interface + AllResources func() ([]Resource, error) + Resource func(int) (Resource, bool, error) + VisibleResources func([]string) ([]Resource, error) + func NewResourceFactory(conn Conn, lockFactory lock.LockFactory) ResourceFactory + type ResourceNotFoundError struct + ID int + func (e ResourceNotFoundError) Error() string + type ResourceNotFoundInPipeline struct + Pipeline string + Resource string + func (r ResourceNotFoundInPipeline) Error() string + type ResourceType interface + CheckError func() error + CheckEvery func() string + CheckSetupError func() error + CheckTimeout func() string + CurrentPinnedVersion func() atc.Version + HasWebhook func() bool + ID func() int + LastCheckEndTime func() time.Time + LastCheckStartTime func() time.Time + Name func() string + Params func() atc.Params + Privileged func() bool + Reload func() (bool, error) + ResourceConfigScopeID func() int + SetCheckSetupError func(error) error + SetResourceConfig func(atc.Source, atc.VersionedResourceTypes) (ResourceConfigScope, error) + Source func() atc.Source + Tags func() atc.Tags + TeamID func() int + TeamName func() string + Type func() string + UniqueVersionHistory func() bool + Version func() atc.Version + type ResourceTypeNotFoundError struct + ID int + func (e ResourceTypeNotFoundError) Error() string + type ResourceTypes []ResourceType + func (resourceTypes ResourceTypes) Configs() atc.ResourceTypes + func (resourceTypes ResourceTypes) Deserialize() atc.VersionedResourceTypes + func (resourceTypes ResourceTypes) Filter(checkable Checkable) ResourceTypes + func (resourceTypes ResourceTypes) Parent(checkable Checkable) (ResourceType, bool) + type ResourceVersion string + type Resources []Resource + func (resources Resources) Configs() atc.ResourceConfigs + func (resources Resources) Lookup(name string) (Resource, bool) + type SchedulerJob struct + ResourceTypes atc.VersionedResourceTypes + Resources SchedulerResources + type SchedulerJobs []SchedulerJob + type SchedulerResource struct + Name string + Source atc.Source + Type string + type SchedulerResources []SchedulerResource + func (resources SchedulerResources) Lookup(name string) (SchedulerResource, bool) + type SpanContext map[string]string + func NewSpanContext(ctx context.Context) SpanContext + func (sc SpanContext) Get(key string) string + func (sc SpanContext) Set(key, value string) + type TaskCacheFactory interface + Find func(jobID int, stepName string, path string) (UsedTaskCache, bool, error) + FindOrCreate func(jobID int, stepName string, path string) (UsedTaskCache, error) + func NewTaskCacheFactory(conn Conn) TaskCacheFactory + type Team interface + Admin func() bool + Auth func() atc.TeamAuth + Builds func(page Page) ([]Build, Pagination, error) + BuildsWithTime func(page Page) ([]Build, Pagination, error) + Containers func() ([]Container, error) + CreateOneOffBuild func() (Build, error) + CreateStartedBuild func(plan atc.Plan) (Build, error) + Delete func() error + FindCheckContainers func(lager.Logger, string, string, creds.Secrets, creds.VarSourcePool) ([]Container, map[int]time.Time, error) + FindContainerByHandle func(string) (Container, bool, error) + FindContainersByMetadata func(ContainerMetadata) ([]Container, error) + FindCreatedContainerByHandle func(string) (CreatedContainer, bool, error) + FindVolumeForWorkerArtifact func(int) (CreatedVolume, bool, error) + FindWorkerForContainer func(handle string) (Worker, bool, error) + FindWorkerForVolume func(handle string) (Worker, bool, error) + ID func() int + IsCheckContainer func(string) (bool, error) + IsContainerWithinTeam func(string, bool) (bool, error) + Name func() string + OrderPipelines func([]string) error + Pipeline func(pipelineName string) (Pipeline, bool, error) + Pipelines func() ([]Pipeline, error) + PrivateAndPublicBuilds func(Page) ([]Build, Pagination, error) + PublicPipelines func() ([]Pipeline, error) + Rename func(string) error + SavePipeline func(pipelineName string, config atc.Config, from ConfigVersion, ...) (Pipeline, bool, error) + SaveWorker func(atcWorker atc.Worker, ttl time.Duration) (Worker, error) + UpdateProviderAuth func(auth atc.TeamAuth) error + Workers func() ([]Worker, error) + type TeamFactory interface + CreateDefaultTeamIfNotExists func() (Team, error) + CreateTeam func(atc.Team) (Team, error) + FindTeam func(string) (Team, bool, error) + GetByID func(teamID int) Team + GetTeams func() ([]Team, error) + NotifyCacher func() error + NotifyResourceScanner func() error + func NewTeamFactory(conn Conn, lockFactory lock.LockFactory) TeamFactory + type Tx interface + Commit func() error + EncryptionStrategy func() encryption.Strategy + Exec func(string, ...interface{}) (sql.Result, error) + ExecContext func(context.Context, string, ...interface{}) (sql.Result, error) + Prepare func(string) (*sql.Stmt, error) + PrepareContext func(context.Context, string) (*sql.Stmt, error) + Query func(string, ...interface{}) (*sql.Rows, error) + QueryContext func(context.Context, string, ...interface{}) (*sql.Rows, error) + QueryRow func(string, ...interface{}) squirrel.RowScanner + QueryRowContext func(context.Context, string, ...interface{}) squirrel.RowScanner + Rollback func() error + Stmt func(*sql.Stmt) *sql.Stmt + type UpdateName struct + NewName string + OldName string + type UsedBaseResourceType struct + ID int + Name string + UniqueVersionHistory bool + type UsedResourceCache interface + BaseResourceType func() *UsedBaseResourceType + Destroy func(Tx) (bool, error) + ID func() int + ResourceConfig func() ResourceConfig + Version func() atc.Version + type UsedTaskCache interface + ID func() int + JobID func() int + Path func() string + StepName func() string + type UsedWorkerBaseResourceType struct + ID int + Name string + Version string + WorkerName string + type UsedWorkerResourceCache struct + ID int + type UsedWorkerResourceCerts struct + ID int + type UsedWorkerResourceType struct + ID int + UsedBaseResourceType *UsedBaseResourceType + Worker Worker + type UsedWorkerTaskCache struct + ID int + WorkerName string + type User interface + Connector func() string + ID func() int + LastLogin func() time.Time + Name func() string + Sub func() string + type UserFactory interface + CreateOrUpdateUser func(username, connector, sub string) error + GetAllUsers func() ([]User, error) + GetAllUsersByLoginDate func(LastLogin time.Time) ([]User, error) + func NewUserFactory(conn Conn) UserFactory + type Version map[string]string + type VersionsDB struct + func NewVersionsDB(conn Conn, limitRows int, cache *gocache.Cache) VersionsDB + func (versions VersionsDB) FindVersionOfResource(ctx context.Context, resourceID int, v atc.Version) (ResourceVersion, bool, error) + func (versions VersionsDB) IsFirstOccurrence(ctx context.Context, jobID int, inputName string, versionMD5 ResourceVersion, ...) (bool, error) + func (versions VersionsDB) LatestBuildPipes(ctx context.Context, buildID int) (map[int]BuildCursor, error) + func (versions VersionsDB) LatestBuildUsingLatestVersion(ctx context.Context, jobID int, resourceID int) (int, bool, error) + func (versions VersionsDB) LatestVersionOfResource(ctx context.Context, resourceID int) (ResourceVersion, bool, error) + func (versions VersionsDB) NextEveryVersion(ctx context.Context, jobID int, resourceID int) (ResourceVersion, bool, bool, error) + func (versions VersionsDB) SuccessfulBuildOutputs(ctx context.Context, buildID int) ([]AlgorithmVersion, error) + func (versions VersionsDB) SuccessfulBuilds(ctx context.Context, jobID int) PaginatedBuilds + func (versions VersionsDB) SuccessfulBuildsVersionConstrained(ctx context.Context, jobID int, constrainingCandidates map[string][]string) (PaginatedBuilds, error) + func (versions VersionsDB) UnusedBuilds(ctx context.Context, jobID int, lastUsedBuild BuildCursor) (PaginatedBuilds, error) + func (versions VersionsDB) UnusedBuildsVersionConstrained(ctx context.Context, jobID int, lastUsedBuild BuildCursor, ...) (PaginatedBuilds, error) + func (versions VersionsDB) VersionExists(ctx context.Context, resourceID int, versionMD5 ResourceVersion) (bool, error) + func (versions VersionsDB) VersionIsDisabled(ctx context.Context, resourceID int, versionMD5 ResourceVersion) (bool, error) + type VolumeRepository interface + CreateBaseResourceTypeVolume func(*UsedWorkerBaseResourceType) (CreatingVolume, error) + CreateContainerVolume func(teamID int, workerName string, container CreatingContainer, mountPath string) (CreatingVolume, error) + CreateResourceCertsVolume func(workerName string, uwrc *UsedWorkerResourceCerts) (CreatingVolume, error) + CreateTaskCacheVolume func(teamID int, uwtc *UsedWorkerTaskCache) (CreatingVolume, error) + CreateVolume func(int, string, VolumeType) (CreatingVolume, error) + DestroyFailedVolumes func() (count int, err error) + DestroyUnknownVolumes func(workerName string, handles []string) (int, error) + FindBaseResourceTypeVolume func(*UsedWorkerBaseResourceType) (CreatingVolume, CreatedVolume, error) + FindContainerVolume func(teamID int, workerName string, container CreatingContainer, mountPath string) (CreatingVolume, CreatedVolume, error) + FindCreatedVolume func(handle string) (CreatedVolume, bool, error) + FindResourceCacheVolume func(workerName string, resourceCache UsedResourceCache) (CreatedVolume, bool, error) + FindResourceCertsVolume func(workerName string, uwrc *UsedWorkerResourceCerts) (CreatingVolume, CreatedVolume, error) + FindTaskCacheVolume func(teamID int, workerName string, taskCache UsedTaskCache) (CreatedVolume, bool, error) + FindVolumesForContainer func(container CreatedContainer) ([]CreatedVolume, error) + GetDestroyingVolumes func(workerName string) ([]string, error) + GetOrphanedVolumes func() ([]CreatedVolume, error) + GetTeamVolumes func(teamID int) ([]CreatedVolume, error) + RemoveDestroyingVolumes func(workerName string, handles []string) (int, error) + RemoveMissingVolumes func(gracePeriod time.Duration) (removed int, err error) + UpdateVolumesMissingSince func(workerName string, handles []string) error + func NewVolumeRepository(conn Conn) VolumeRepository + type VolumeResourceType struct + ResourceType *VolumeResourceType + Version atc.Version + WorkerBaseResourceType *UsedWorkerBaseResourceType + type VolumeState string + const VolumeStateCreated + const VolumeStateCreating + const VolumeStateDestroying + const VolumeStateFailed + type VolumeType string + const VolumeTypeArtifact + const VolumeTypeContainer + const VolumeTypeResource + const VolumeTypeResourceCerts + const VolumeTypeResourceType + const VolumeTypeTaskCache + const VolumeTypeUknown + type Wall interface + Clear func() error + GetWall func() (atc.Wall, error) + SetWall func(atc.Wall) error + func NewWall(conn Conn, clock Clock) Wall + type Worker interface + ActiveContainers func() int + ActiveTasks func() (int, error) + ActiveVolumes func() int + BaggageclaimURL func() *string + CertsPath func() *string + CreateContainer func(owner ContainerOwner, meta ContainerMetadata) (CreatingContainer, error) + DecreaseActiveTasks func() error + Delete func() error + Ephemeral func() bool + ExpiresAt func() time.Time + FindContainer func(owner ContainerOwner) (CreatingContainer, CreatedContainer, error) + GardenAddr func() *string + HTTPProxyURL func() string + HTTPSProxyURL func() string + IncreaseActiveTasks func() error + Land func() error + Name func() string + NoProxy func() string + Platform func() string + Prune func() error + Reload func() (bool, error) + ResourceCerts func() (*UsedWorkerResourceCerts, bool, error) + ResourceTypes func() []atc.WorkerResourceType + Retire func() error + StartTime func() time.Time + State func() WorkerState + Tags func() []string + TeamID func() int + TeamName func() string + Version func() *string + type WorkerArtifact interface + BuildID func() int + CreatedAt func() time.Time + ID func() int + Name func() string + Volume func(teamID int) (CreatedVolume, bool, error) + type WorkerArtifactLifecycle interface + RemoveExpiredArtifacts func() error + type WorkerBaseResourceType struct + Name string + WorkerName string + func (workerBaseResourceType WorkerBaseResourceType) Find(runner sq.Runner) (*UsedWorkerBaseResourceType, bool, error) + type WorkerBaseResourceTypeFactory interface + Find func(name string, worker Worker) (*UsedWorkerBaseResourceType, bool, error) + func NewWorkerBaseResourceTypeFactory(conn Conn) WorkerBaseResourceTypeFactory + type WorkerFactory interface + BuildContainersCountPerWorker func() (map[string]int, error) + FindWorkersForContainerByOwner func(ContainerOwner) ([]Worker, error) + GetWorker func(name string) (Worker, bool, error) + HeartbeatWorker func(worker atc.Worker, ttl time.Duration) (Worker, error) + SaveWorker func(atcWorker atc.Worker, ttl time.Duration) (Worker, error) + VisibleWorkers func([]string) ([]Worker, error) + Workers func() ([]Worker, error) + func NewWorkerFactory(conn Conn) WorkerFactory + type WorkerLifecycle interface + DeleteFinishedRetiringWorkers func() ([]string, error) + DeleteUnresponsiveEphemeralWorkers func() ([]string, error) + GetWorkerStateByName func() (map[string]WorkerState, error) + LandFinishedLandingWorkers func() ([]string, error) + StallUnresponsiveWorkers func() ([]string, error) + func NewWorkerLifecycle(conn Conn) WorkerLifecycle + type WorkerResourceCache struct + ResourceCache UsedResourceCache + WorkerName string + func (workerResourceCache WorkerResourceCache) Find(runner sq.Runner) (*UsedWorkerResourceCache, bool, error) + func (workerResourceCache WorkerResourceCache) FindOrCreate(tx Tx) (*UsedWorkerResourceCache, error) + type WorkerResourceCerts struct + CertsPath string + WorkerName string + func (workerResourceCerts WorkerResourceCerts) Find(runner sq.BaseRunner) (*UsedWorkerResourceCerts, bool, error) + func (workerResourceCerts WorkerResourceCerts) FindOrCreate(tx Tx) (*UsedWorkerResourceCerts, error) + type WorkerResourceType struct + BaseResourceType *BaseResourceType + Image string + Version string + Worker Worker + func (wrt WorkerResourceType) FindOrCreate(tx Tx, unique bool) (*UsedWorkerResourceType, error) + type WorkerState string + func AllWorkerStates() []WorkerState + type WorkerTaskCache struct + TaskCache UsedTaskCache + WorkerName string + type WorkerTaskCacheFactory interface + Find func(WorkerTaskCache) (*UsedWorkerTaskCache, bool, error) + FindOrCreate func(WorkerTaskCache) (*UsedWorkerTaskCache, error) + func NewWorkerTaskCacheFactory(conn Conn) WorkerTaskCacheFactory