atc/db/volume.go

85 func (volume *creatingVolume) ID() int { return volume.id }
87 func (volume *creatingVolume) Handle() string { return volume.handle }
89 func (volume *creatingVolume) Created() (CreatedVolume, error) {
91 		volume.id,
92 		volume.conn,
98 			return nil, ErrVolumeMarkCreatedFailed{Handle: volume.handle}
104 		id:                       volume.id,
105 		workerName:               volume.workerName,
106 		typ:                      volume.typ,
107 		handle:                   volume.handle,
108 		path:                     volume.path,
109 		teamID:                   volume.teamID,
110 		conn:                     volume.conn,
111 		containerHandle:          volume.containerHandle,
112 		parentHandle:             volume.parentHandle,
113 		resourceCacheID:          volume.resourceCacheID,
114 		workerBaseResourceTypeID: volume.workerBaseResourceTypeID,
115 		workerTaskCacheID:        volume.workerTaskCacheID,
116 		workerResourceCertsID:    volume.workerResourceCertsID,
120 func (volume *creatingVolume) Failed() (FailedVolume, error) {
122 		volume.id,
123 		volume.conn,
135 		id:         volume.id,
136 		workerName: volume.workerName,
137 		handle:     volume.handle,
138 		conn:       volume.conn,
189 func (volume *createdVolume) Handle() string          { return volume.handle }
190 func (volume *createdVolume) Path() string            { return volume.path }
191 func (volume *createdVolume) WorkerName() string      { return volume.workerName }
192 func (volume *createdVolume) Type() VolumeType        { return volume.typ }
193 func (volume *createdVolume) TeamID() int             { return volume.teamID }
194 func (volume *createdVolume) ContainerHandle() string { return volume.containerHandle }
195 func (volume *createdVolume) ParentHandle() string    { return volume.parentHandle }
196 func (volume *createdVolume) WorkerArtifactID() int   { return volume.workerArtifactID }
198 func (volume *createdVolume) ResourceType() (*VolumeResourceType, error) {
199 	if volume.resourceCacheID == 0 {
203 	return volume.findVolumeResourceTypeByCacheID(volume.resourceCacheID)
206 func (volume *createdVolume) BaseResourceType() (*UsedWorkerBaseResourceType, error) {
207 	if volume.workerBaseResourceTypeID == 0 {
211 	return volume.findWorkerBaseResourceTypeByID(volume.workerBaseResourceTypeID)
214 func (volume *createdVolume) TaskIdentifier() (string, string, string, error) {
215 	if volume.workerTaskCacheID == 0 {
229 			"wtc.id": volume.workerTaskCacheID,
231 		RunWith(volume.conn).
241 func (volume *createdVolume) findVolumeResourceTypeByCacheID(resourceCacheID int) (*VolumeResourceT…
252 		RunWith(volume.conn).
266 …workerBaseResourceType, err := volume.findWorkerBaseResourceTypeByBaseResourceTypeID(int(sqBaseRes…
278 		resourceType, err := volume.findVolumeResourceTypeByCacheID(int(sqResourceCacheID.Int64))
292 func (volume *createdVolume) findWorkerBaseResourceTypeByID(workerBaseResourceTypeID int) (*UsedWor…
301 			"wbrt.worker_name": volume.workerName,
303 		RunWith(volume.conn).
314 		WorkerName: volume.workerName,
318 func (volume *createdVolume) findWorkerBaseResourceTypeByBaseResourceTypeID(baseResourceTypeID int)…
328 			"wbrt.worker_name": volume.workerName,
330 		RunWith(volume.conn).
341 		WorkerName: volume.workerName,
345 func (volume *createdVolume) InitializeResourceCache(resourceCache UsedResourceCache) error {
346 	tx, err := volume.conn.Begin()
354 		WorkerName:    volume.WorkerName(),
364 		Where(sq.Eq{"id": volume.id}).
391 	volume.resourceCacheID = resourceCache.ID()
392 	volume.typ = VolumeTypeResource
397 func (volume *createdVolume) GetResourceCacheID() int {
398 	return volume.resourceCacheID
401 func (volume *createdVolume) InitializeArtifact(name string, buildID int) (WorkerArtifact, error) {
402 	tx, err := volume.conn.Begin()
414 	workerArtifact, err := saveWorkerArtifact(tx, volume.conn, atcWorkerArtifact)
421 		Where(sq.Eq{"id": volume.id}).
445 func (volume *createdVolume) InitializeTaskCache(jobID int, stepName string, path string) error {
446 	tx, err := volume.conn.Begin()
463 		WorkerName: volume.WorkerName(),
482 		Where(sq.Eq{"id": volume.id}).
512 func (volume *createdVolume) CreateChildForContainer(container CreatingContainer, mountPath string)…
513 	tx, err := volume.conn.Begin()
534 		volume.workerName,
535 		volume.id,
542 	if volume.teamID != 0 {
544 		columnValues = append(columnValues, volume.teamID)
566 		workerName:      volume.workerName,
569 		teamID:          volume.teamID,
572 		parentHandle:    volume.Handle(),
573 		conn:            volume.conn,
577 func (volume *createdVolume) Destroying() (DestroyingVolume, error) {
579 		volume.id,
580 		volume.conn,
600 		id:         volume.id,
601 		workerName: volume.workerName,
602 		handle:     volume.handle,
603 		conn:       volume.conn,
621 func (volume *destroyingVolume) Handle() string     { return volume.handle }
622 func (volume *destroyingVolume) WorkerName() string { return volume.workerName }
624 func (volume *destroyingVolume) Destroy() (bool, error) {
627 			"id":    volume.id,
630 		RunWith(volume.conn).
661 func (volume *failedVolume) Handle() string     { return volume.handle }
662 func (volume *failedVolume) WorkerName() string { return volume.workerName }
664 func (volume *failedVolume) Destroy() (bool, error) {
667 			"id":    volume.id,
670 		RunWith(volume.conn).