db

package
v0.75.0-no-limit Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 22, 2016 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ContainerStageCheck = "check"
	ContainerStageGet   = "get"
	ContainerStageRun   = "run"
)
View Source 
const BuildPreparationColumns string = "build_id, paused_pipeline, paused_job, max_running_builds, inputs, inputs_satisfied"

Variables

View Source 
var ErrBuildEventStreamClosed = errors.New("build event stream closed")
View Source 
var ErrConfigComparisonFailed = errors.New("comparison with existing config failed during save")
View Source 
var ErrEndOfBuildEventStream = errors.New("end of build event stream")
View Source 
var ErrInvalidIdentifier = errors.New("invalid container identifier")
View Source 
var ErrLockNotAvailable = errors.New("lock is currently held and cannot be immediately acquired")
View Source 
var ErrLockRowNotPresentOrAlreadyDeleted = errors.New("lock could not be acquired because it didn't exist or was already cleaned up")
View Source 
var ErrMultipleContainersFound = errors.New("multiple containers found for given identifier")
View Source 
var ErrNoBuild = errors.New("no build found")
View Source 
var ErrNoContainer = errors.New("no container found")
View Source 
var ErrNoVersions = errors.New("no versions found")
View Source 
var ErrPipelineNotFound = errors.New("pipeline not found")

Functions

func HashResourceConfig 

func HashResourceConfig(checkType string, source atc.Source) string

func NewNotificationsBus 

func NewNotificationsBus(listener *pq.Listener, conn Conn) *notificationsBus

func NewPipelineDBFactory 

func NewPipelineDBFactory(
	logger lager.Logger,
	sqldbConnection Conn,
	bus *notificationsBus,
	pipelinesDB PipelinesDB,
) *pipelineDBFactory

Types

type BasicAuth 

type BasicAuth struct {
	BasicAuthUsername string `json:"basic_auth_username"`
	BasicAuthPassword string `json:"basic_auth_password"`
}

type Build 

type Build struct {
	ID               int
	Name             string
	Status           Status
	Scheduled        bool
	InputsDetermined bool

	JobID        int
	JobName      string
	PipelineName string
	PipelineID   int

	Engine         string
	EngineMetadata string

	StartTime time.Time
	EndTime   time.Time
}

func (Build) Abortable 

func (b Build) Abortable() bool

func (Build) IsRunning 

func (b Build) IsRunning() bool

func (Build) OneOff 

func (b Build) OneOff() bool

type BuildInput 

type BuildInput struct {
	Name string

	VersionedResource

	FirstOccurrence bool
}

type BuildOutput 

type BuildOutput struct {
	VersionedResource
}

type BuildPreparation 

type BuildPreparation struct {
	BuildID          int
	PausedPipeline   BuildPreparationStatus
	PausedJob        BuildPreparationStatus
	MaxRunningBuilds BuildPreparationStatus
	Inputs           map[string]BuildPreparationStatus
	InputsSatisfied  BuildPreparationStatus
}

func NewBuildPreparation 

func NewBuildPreparation(buildID int) BuildPreparation

type BuildPreparationStatus 

type BuildPreparationStatus string
const (
	BuildPreparationStatusUnknown     BuildPreparationStatus = "unknown"
	BuildPreparationStatusBlocking    BuildPreparationStatus = "blocking"
	BuildPreparationStatusNotBlocking BuildPreparationStatus = "not_blocking"
)

type ConfigDB 

type ConfigDB interface {
	GetConfig(teamName, pipelineName string) (atc.Config, ConfigVersion, error)
	SaveConfig(string, string, atc.Config, ConfigVersion, PipelinePausedState) (SavedPipeline, bool, error)
}

type ConfigVersion 

type ConfigVersion int

ConfigVersion is a sequence identifier used for compare-and-swap

type Conn 

type Conn interface {
	Begin() (Tx, error)
	Close() error
	Driver() driver.Driver
	Exec(query string, args ...interface{}) (sql.Result, error)
	Ping() error
	Prepare(query string) (*sql.Stmt, error)
	Query(query string, args ...interface{}) (*sql.Rows, error)
	QueryRow(query string, args ...interface{}) *sql.Row
	SetMaxIdleConns(n int)
	SetMaxOpenConns(n int)
}

func Explain 

func Explain(logger lager.Logger, conn Conn, clock clock.Clock, timeout time.Duration) Conn

func Wrap 

func Wrap(sqlDB *sql.DB) Conn

func WrapWithError 

func WrapWithError(sqlDB *sql.DB, err error) (Conn, error)

type Container 

type Container struct {
	ContainerIdentifier
	ContainerMetadata
}

type ContainerIdentifier 

type ContainerIdentifier struct {
	// if it's a resource check container
	ResourceID  int
	CheckType   string
	CheckSource atc.Source

	// if it's a step container
	BuildID int
	PlanID  atc.PlanID

	// for the check + get stages of a container with a resource backed image
	ImageResourceType   string
	ImageResourceSource atc.Source

	Stage ContainerStage
}

type ContainerMetadata 

type ContainerMetadata struct {
	Handle               string
	WorkerName           string
	BuildName            string
	ResourceName         string
	PipelineID           int
	PipelineName         string
	JobName              string
	StepName             string
	Type                 ContainerType
	WorkingDirectory     string
	EnvironmentVariables []string
	Attempts             []int
	User                 string
}

type ContainerStage 

type ContainerStage string

ContainerStage is used to distinguish between the 3 potential containers in use by a step, as we'll need to run a 'check' and 'get' for the image used by the container, which themselves correspond to containers.

type ContainerType 

type ContainerType string
const (
	ContainerTypeCheck ContainerType = "check"
	ContainerTypeGet   ContainerType = "get"
	ContainerTypePut   ContainerType = "put"
	ContainerTypeTask  ContainerType = "task"
)

func ContainerTypeFromString 

func ContainerTypeFromString(containerType string) (ContainerType, error)

func (ContainerType) String 

func (containerType ContainerType) String() string

type DB 

type DB interface {
	SaveTeam(team Team) (SavedTeam, error)
	GetTeamByName(teamName string) (SavedTeam, bool, error)
	UpdateTeamBasicAuth(team Team) (SavedTeam, error)
	UpdateTeamGitHubAuth(team Team) (SavedTeam, error)
	CreateDefaultTeamIfNotExists() error
	DeleteTeamByName(teamName string) error

	GetBuild(buildID int) (Build, bool, error)
	GetBuildVersionedResources(buildID int) (SavedVersionedResources, error)
	GetBuildResources(buildID int) ([]BuildInput, []BuildOutput, error)
	GetBuilds(Page) ([]Build, Pagination, error)
	GetAllStartedBuilds() ([]Build, error)

	CreatePipe(pipeGUID string, url string) error
	GetPipe(pipeGUID string) (Pipe, error)

	CreateOneOffBuild() (Build, error)
	GetBuildPreparation(buildID int) (BuildPreparation, bool, error)
	UpdateBuildPreparation(buildPreparation BuildPreparation) error
	ResetBuildPreparationsWithPipelinePaused(pipelineID int) error

	LeaseBuildTracking(buildID int, interval time.Duration) (Lease, bool, error)
	LeaseBuildScheduling(buildID int, interval time.Duration) (Lease, bool, error)
	LeaseCacheInvalidation(interval time.Duration) (Lease, bool, error)

	StartBuild(buildID int, engineName, engineMetadata string) (bool, error)
	FinishBuild(buildID int, status Status) error
	ErrorBuild(buildID int, cause error) error

	SaveBuildInput(teamName string, buildID int, input BuildInput) (SavedVersionedResource, error)
	SaveBuildOutput(teamName string, buildID int, vr VersionedResource, explicit bool) (SavedVersionedResource, error)

	GetBuildEvents(buildID int, from uint) (EventSource, error)
	SaveBuildEvent(buildID int, event atc.Event) error

	SaveBuildEngineMetadata(buildID int, engineMetadata string) error

	AbortBuild(buildID int) error
	AbortNotifier(buildID int) (Notifier, error)

	Workers() ([]SavedWorker, error) // auto-expires workers based on ttl
	GetWorker(workerName string) (SavedWorker, bool, error)
	SaveWorker(WorkerInfo, time.Duration) (SavedWorker, error)

	FindContainersByDescriptors(Container) ([]SavedContainer, error)
	GetContainer(string) (SavedContainer, bool, error)
	CreateContainer(Container, time.Duration) (SavedContainer, error)
	FindContainerByIdentifier(ContainerIdentifier) (SavedContainer, bool, error)
	UpdateExpiresAtOnContainer(handle string, ttl time.Duration) error
	ReapContainer(handle string) error

	DeleteContainer(string) error

	GetConfigByBuildID(buildID int) (atc.Config, ConfigVersion, error)

	InsertVolume(data Volume) error
	GetVolumes() ([]SavedVolume, error)
	ReapVolume(string) error
	SetVolumeTTL(string, time.Duration) error
	GetVolumeTTL(volumeHandle string) (time.Duration, error)
	GetVolumesForOneOffBuildImageResources() ([]SavedVolume, error)

	SaveImageResourceVersion(buildID int, planID atc.PlanID, identifier VolumeIdentifier) error
	GetImageVolumeIdentifiersByBuildID(buildID int) ([]VolumeIdentifier, error)
}

type Dashboard 

type Dashboard []DashboardJob

type DashboardJob 

type DashboardJob struct {
	Job       SavedJob
	JobConfig atc.JobConfig

	FinishedBuild *Build
	NextBuild     *Build
}

type EventSource 

type EventSource interface {
	Next() (atc.Event, error)
	Close() error
}

type GitHubAuth 

type GitHubAuth struct {
	ClientID      string       `json:"client_id"`
	ClientSecret  string       `json:"client_secret"`
	Organizations []string     `json:"organizations"`
	Teams         []GitHubTeam `json:"teams"`
	Users         []string     `json:"users"`
}

type GitHubTeam 

type GitHubTeam struct {
	OrganizationName string `json:"organization_name"`
	TeamName         string `json:"team_name"`
}

type Job 

type Job struct {
	Name string
}

type JobHistory 

type JobHistory struct {
	JobName string
	Builds  []Build
}

type Lease 

type Lease interface {
	Break()
}

type Lock 

type Lock interface {
	Release() error
}

type MetadataField 

type MetadataField struct {
	Name  string
	Value string
}

type Notifier 

type Notifier interface {
	Notify() <-chan struct{}
	Close() error
}

type Page 

type Page struct {
	Since int
	Until int
	Limit int
}

type Pagination 

type Pagination struct {
	Previous *Page
	Next     *Page
}

type Pipe 

type Pipe struct {
	ID  string
	URL string
}

type Pipeline 

type Pipeline struct {
	Name    string
	Config  atc.Config
	Version ConfigVersion
}

type PipelineDB 

type PipelineDB interface {
	GetPipelineName() string
	ScopedName(string) string

	Pause() error
	Unpause() error
	IsPaused() (bool, error)

	Destroy() error

	GetConfig() (atc.Config, ConfigVersion, bool, error)

	LeaseScheduling(time.Duration) (Lease, bool, error)

	GetResource(resourceName string) (SavedResource, error)
	GetResourceVersions(resourceName string, page Page) ([]SavedVersionedResource, Pagination, bool, error)

	PauseResource(resourceName string) error
	UnpauseResource(resourceName string) error

	SaveResourceVersions(atc.ResourceConfig, []atc.Version) error
	GetLatestVersionedResource(resource SavedResource) (SavedVersionedResource, bool, error)
	GetLatestEnabledVersionedResource(resourceName string) (SavedVersionedResource, bool, error)
	EnableVersionedResource(versionedResourceID int) error
	DisableVersionedResource(versionedResourceID int) error
	SetResourceCheckError(resource SavedResource, err error) error
	LeaseResourceChecking(resource string, length time.Duration, immediate bool) (Lease, bool, error)

	GetJob(job string) (SavedJob, error)
	PauseJob(job string) error
	UnpauseJob(job string) error

	GetJobFinishedAndNextBuild(job string) (*Build, *Build, error)

	GetJobBuilds(job string, page Page) ([]Build, Pagination, error)
	GetAllJobBuilds(job string) ([]Build, error)

	GetJobBuild(job string, build string) (Build, bool, error)
	CreateJobBuild(job string) (Build, error)
	CreateJobBuildForCandidateInputs(job string) (Build, bool, error)

	UseInputsForBuild(buildID int, inputs []BuildInput) error

	LoadVersionsDB() (*algorithm.VersionsDB, error)
	GetLatestInputVersions(versions *algorithm.VersionsDB, job string, inputs []config.JobInput) ([]BuildInput, bool, error)
	GetJobBuildForInputs(job string, inputs []BuildInput) (Build, bool, error)
	GetNextPendingBuild(job string) (Build, bool, error)

	GetBuild(buildID int) (Build, bool, error)
	GetCurrentBuild(job string) (Build, bool, error)
	GetRunningBuildsBySerialGroup(jobName string, serialGroups []string) ([]Build, error)
	GetNextPendingBuildBySerialGroup(jobName string, serialGroups []string) (Build, bool, error)

	UpdateBuildToScheduled(buildID int) (bool, error)
	SaveBuildInput(buildID int, input BuildInput) (SavedVersionedResource, error)
	SaveBuildOutput(buildID int, vr VersionedResource, explicit bool) (SavedVersionedResource, error)
	GetBuildsWithVersionAsInput(versionedResourceID int) ([]Build, error)
	GetBuildsWithVersionAsOutput(versionedResourceID int) ([]Build, error)

	UpdateBuildPreparation(prep BuildPreparation) error

	GetDashboard() (Dashboard, atc.GroupConfigs, error)
}

type PipelineDBFactory 

type PipelineDBFactory interface {
	Build(pipeline SavedPipeline) PipelineDB
	BuildWithTeamNameAndName(teamName, pipelineName string) (PipelineDB, error)
	BuildDefault() (PipelineDB, bool, error)
}

type PipelinePausedState 

type PipelinePausedState string
const (
	PipelinePaused   PipelinePausedState = "paused"
	PipelineUnpaused PipelinePausedState = "unpaused"
	PipelineNoChange PipelinePausedState = "nochange"
)

func (PipelinePausedState) Bool 

func (state PipelinePausedState) Bool() *bool

type PipelinesDB 

type PipelinesDB interface {
	GetAllPipelines() ([]SavedPipeline, error)
	GetPipelineByTeamNameAndName(teamName string, pipelineName string) (SavedPipeline, error)

	OrderPipelines([]string) error
}

type Resource 

type Resource struct {
	Name string
}

type SQLDB 

type SQLDB struct {
	// contains filtered or unexported fields
}

func NewSQL 

func NewSQL(
	logger lager.Logger,
	sqldbConnection Conn,
	bus *notificationsBus,
) *SQLDB

func (*SQLDB) AbortBuild 

func (db *SQLDB) AbortBuild(buildID int) error

func (*SQLDB) AbortNotifier 

func (db *SQLDB) AbortNotifier(buildID int) (Notifier, error)

func (*SQLDB) CreateContainer 

func (db *SQLDB) CreateContainer(container Container, ttl time.Duration) (SavedContainer, error)

func (*SQLDB) CreateDefaultTeamIfNotExists 

func (db *SQLDB) CreateDefaultTeamIfNotExists() error

func (*SQLDB) CreateOneOffBuild 

func (db *SQLDB) CreateOneOffBuild() (Build, error)

func (*SQLDB) CreatePipe 

func (db *SQLDB) CreatePipe(pipeGUID string, url string) error

func (*SQLDB) DeleteContainer 

func (db *SQLDB) DeleteContainer(handle string) error

func (*SQLDB) DeleteTeamByName 

func (db *SQLDB) DeleteTeamByName(teamName string) error

func (*SQLDB) ErrorBuild 

func (db *SQLDB) ErrorBuild(buildID int, cause error) error

func (*SQLDB) FindContainerByIdentifier 

func (db *SQLDB) FindContainerByIdentifier(id ContainerIdentifier) (SavedContainer, bool, error)

func (*SQLDB) FindContainersByDescriptors 

func (db *SQLDB) FindContainersByDescriptors(id Container) ([]SavedContainer, error)

func (*SQLDB) FinishBuild 

func (db *SQLDB) FinishBuild(buildID int, status Status) error

func (*SQLDB) GetAllPipelines 

func (db *SQLDB) GetAllPipelines() ([]SavedPipeline, error)

func (*SQLDB) GetAllStartedBuilds 

func (db *SQLDB) GetAllStartedBuilds() ([]Build, error)

func (*SQLDB) GetBuild 

func (db *SQLDB) GetBuild(buildID int) (Build, bool, error)

func (*SQLDB) GetBuildEvents 

func (db *SQLDB) GetBuildEvents(buildID int, from uint) (EventSource, error)

func (*SQLDB) GetBuildPreparation 

func (db *SQLDB) GetBuildPreparation(passedBuildID int) (BuildPreparation, bool, error)

func (*SQLDB) GetBuildResources 

func (db *SQLDB) GetBuildResources(buildID int) ([]BuildInput, []BuildOutput, error)

func (*SQLDB) GetBuildVersionedResources 

func (db *SQLDB) GetBuildVersionedResources(buildID int) (SavedVersionedResources, error)

func (*SQLDB) GetBuilds 

func (db *SQLDB) GetBuilds(page Page) ([]Build, Pagination, error)

func (*SQLDB) GetConfig 

func (db *SQLDB) GetConfig(teamName, pipelineName string) (atc.Config, ConfigVersion, error)

func (*SQLDB) GetConfigByBuildID 

func (db *SQLDB) GetConfigByBuildID(buildID int) (atc.Config, ConfigVersion, error)

func (*SQLDB) GetContainer 

func (db *SQLDB) GetContainer(handle string) (SavedContainer, bool, error)

func (*SQLDB) GetImageVolumeIdentifiersByBuildID 

func (db *SQLDB) GetImageVolumeIdentifiersByBuildID(buildID int) ([]VolumeIdentifier, error)

func (*SQLDB) GetPipe 

func (db *SQLDB) GetPipe(pipeGUID string) (Pipe, error)

func (*SQLDB) GetPipelineByTeamNameAndName 

func (db *SQLDB) GetPipelineByTeamNameAndName(teamName string, pipelineName string) (SavedPipeline, error)

func (*SQLDB) GetTeamByName 

func (db *SQLDB) GetTeamByName(teamName string) (SavedTeam, bool, error)

func (*SQLDB) GetVolumeTTL 

func (db *SQLDB) GetVolumeTTL(handle string) (time.Duration, error)

func (*SQLDB) GetVolumes 

func (db *SQLDB) GetVolumes() ([]SavedVolume, error)

func (*SQLDB) GetVolumesForOneOffBuildImageResources 

func (db *SQLDB) GetVolumesForOneOffBuildImageResources() ([]SavedVolume, error)

func (*SQLDB) GetWorker 

func (db *SQLDB) GetWorker(name string) (SavedWorker, bool, error)

func (*SQLDB) InsertVolume 

func (db *SQLDB) InsertVolume(data Volume) error

func (*SQLDB) LeaseBuildScheduling 

func (db *SQLDB) LeaseBuildScheduling(buildID int, interval time.Duration) (Lease, bool, error)

func (*SQLDB) LeaseBuildTracking 

func (db *SQLDB) LeaseBuildTracking(buildID int, interval time.Duration) (Lease, bool, error)

func (*SQLDB) LeaseCacheInvalidation 

func (db *SQLDB) LeaseCacheInvalidation(interval time.Duration) (Lease, bool, error)

func (*SQLDB) OrderPipelines 

func (db *SQLDB) OrderPipelines(pipelineNames []string) error

func (*SQLDB) ReapContainer 

func (db *SQLDB) ReapContainer(handle string) error

func (*SQLDB) ReapVolume 

func (db *SQLDB) ReapVolume(handle string) error

func (*SQLDB) ResetBuildPreparationsWithPipelinePaused 

func (db *SQLDB) ResetBuildPreparationsWithPipelinePaused(pipelineID int) error

func (*SQLDB) SaveBuildEngineMetadata 

func (db *SQLDB) SaveBuildEngineMetadata(buildID int, engineMetadata string) error

func (*SQLDB) SaveBuildEvent 

func (db *SQLDB) SaveBuildEvent(buildID int, event atc.Event) error

func (*SQLDB) SaveBuildInput 

func (db *SQLDB) SaveBuildInput(teamName string, buildID int, input BuildInput) (SavedVersionedResource, error)

func (*SQLDB) SaveBuildOutput 

func (db *SQLDB) SaveBuildOutput(teamName string, buildID int, vr VersionedResource, explicit bool) (SavedVersionedResource, error)

func (*SQLDB) SaveConfig 

func (db *SQLDB) SaveConfig(
	teamName string, pipelineName string, config atc.Config, from ConfigVersion, pausedState PipelinePausedState,
) (SavedPipeline, bool, error)

func (*SQLDB) SaveImageResourceVersion 

func (db *SQLDB) SaveImageResourceVersion(buildID int, planID atc.PlanID, identifier VolumeIdentifier) error

func (*SQLDB) SaveTeam 

func (db *SQLDB) SaveTeam(data Team) (SavedTeam, error)

func (*SQLDB) SaveWorker 

func (db *SQLDB) SaveWorker(info WorkerInfo, ttl time.Duration) (SavedWorker, error)

func (*SQLDB) SetVolumeTTL 

func (db *SQLDB) SetVolumeTTL(handle string, ttl time.Duration) error

func (*SQLDB) StartBuild 

func (db *SQLDB) StartBuild(buildID int, engine, metadata string) (bool, error)

func (*SQLDB) UpdateBuildPreparation 

func (db *SQLDB) UpdateBuildPreparation(buildPrep BuildPreparation) error

func (*SQLDB) UpdateExpiresAtOnContainer 

func (db *SQLDB) UpdateExpiresAtOnContainer(handle string, ttl time.Duration) error

func (*SQLDB) UpdateTeamBasicAuth 

func (db *SQLDB) UpdateTeamBasicAuth(team Team) (SavedTeam, error)

func (*SQLDB) UpdateTeamGitHubAuth 

func (db *SQLDB) UpdateTeamGitHubAuth(team Team) (SavedTeam, error)

func (*SQLDB) Workers 

func (db *SQLDB) Workers() ([]SavedWorker, error)

type SavedContainer 

type SavedContainer struct {
	Container

	TTL       time.Duration
	ExpiresIn time.Duration
}

type SavedJob 

type SavedJob struct {
	ID           int
	Paused       bool
	PipelineName string
	Job
}

type SavedPipeline 

type SavedPipeline struct {
	ID     int
	Paused bool
	TeamID int

	Pipeline
}

type SavedResource 

type SavedResource struct {
	ID           int
	CheckError   error
	Paused       bool
	PipelineName string
	Resource
}

func (SavedResource) FailingToCheck 

func (r SavedResource) FailingToCheck() bool

type SavedTeam 

type SavedTeam struct {
	ID int
	Team
}

type SavedVersionedResource 

type SavedVersionedResource struct {
	ID int

	Enabled bool

	ModifiedTime time.Time

	VersionedResource

	CheckOrder int
}

type SavedVersionedResources 

type SavedVersionedResources []SavedVersionedResource

func (SavedVersionedResources) Lookup 

func (vrs SavedVersionedResources) Lookup(name string) (SavedVersionedResource, bool)

type SavedVolume 

type SavedVolume struct {
	Volume

	ID        int
	ExpiresIn time.Duration
}

type SavedWorker 

type SavedWorker struct {
	WorkerInfo

	ExpiresIn time.Duration
}

type Status 

type Status string
const (
	StatusPending   Status = "pending"
	StatusStarted   Status = "started"
	StatusAborted   Status = "aborted"
	StatusSucceeded Status = "succeeded"
	StatusFailed    Status = "failed"
	StatusErrored   Status = "errored"
)

type Team 

type Team struct {
	Name  string
	Admin bool
	BasicAuth
	GitHubAuth
}

type Tx 

type Tx interface {
	Commit() error
	Exec(query string, args ...interface{}) (sql.Result, error)
	Prepare(query string) (*sql.Stmt, error)
	Query(query string, args ...interface{}) (*sql.Rows, error)
	QueryRow(query string, args ...interface{}) *sql.Row
	Rollback() error
	Stmt(stmt *sql.Stmt) *sql.Stmt
}

type Version 

type Version map[string]string

type VersionHistory 

type VersionHistory struct {
	VersionedResource SavedVersionedResource
	InputsTo          []*JobHistory
	OutputsOf         []*JobHistory
}

type VersionedResource 

type VersionedResource struct {
	Resource     string
	Type         string
	Version      Version
	Metadata     []MetadataField
	PipelineName string
}

type VersionedResources 

type VersionedResources []VersionedResource

func (VersionedResources) Lookup 

func (vrs VersionedResources) Lookup(name string) (VersionedResource, bool)

type Volume 

type Volume struct {
	WorkerName string
	TTL        time.Duration
	Handle     string
	VolumeIdentifier
}

type VolumeIdentifier 

type VolumeIdentifier struct {
	ResourceVersion atc.Version
	ResourceHash    string
}

type WorkerInfo 

type WorkerInfo struct {
	GardenAddr      string
	BaggageclaimURL string

	ActiveContainers int
	ResourceTypes    []atc.WorkerResourceType
	Platform         string
	Tags             []string
	Name             string
}

Source Files

View all Source files

Directories

Path Synopsis
This file was generated by counterfeiter This file was generated by counterfeiter This file was generated by counterfeiter This file was generated by counterfeiter This file was generated by counterfeiter This file was generated by counterfeiter This file was generated by counterfeiter This file was generated by counterfeiter This file was generated by counterfeiter This file was generated by counterfeiter
 This file was generated by counterfeiter This file was generated by counterfeiter This file was generated by counterfeiter This file was generated by counterfeiter This file was generated by counterfeiter This file was generated by counterfeiter This file was generated by counterfeiter This file was generated by counterfeiter This file was generated by counterfeiter This file was generated by counterfeiter
fakes
This file was generated by counterfeiter
 This file was generated by counterfeiter

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.