/dports/net/concourse-fly/concourse-6.7.1/atc/gc/ |
H A D | volume_collector.go | 15 volumeRepository db.VolumeRepository member 20 volumeRepository db.VolumeRepository, 24 volumeRepository: volumeRepository, 56 _, err = vc.volumeRepository.RemoveMissingVolumes(vc.missingVolumeGracePeriod) 66 failedVolumesLen, err := vc.volumeRepository.DestroyFailedVolumes() 86 orphanedVolumesHandles, err := vc.volumeRepository.GetOrphanedVolumes()
|
H A D | volume_collector_test.go | 21 volumeRepository db.VolumeRepository 33 volumeRepository = db.NewVolumeRepository(dbConn) 39 volumeRepository, 90 …creatingVolume1, err := volumeRepository.CreateContainerVolume(team.ID(), worker.Name(), creatingC… 98 failedVolumesLen, err := volumeRepository.DestroyFailedVolumes() 105 failedVolumesLen, err = volumeRepository.DestroyFailedVolumes() 121 …creatingVolume1, err := volumeRepository.CreateContainerVolume(team.ID(), worker.Name(), creatingC… 128 …creatingVolume2, err := volumeRepository.CreateContainerVolume(team.ID(), worker.Name(), creatingC… 152 destroyingVolumes, err := volumeRepository.GetDestroyingVolumes(worker.Name())
|
H A D | destroyer.go | 27 volumeRepository db.VolumeRepository member 34 volumeRepository db.VolumeRepository, 39 volumeRepository: volumeRepository, 77 deleted, err := d.volumeRepository.RemoveDestroyingVolumes(workerName, currentHandles) 90 destroyingVolumesHandles, err := d.volumeRepository.GetDestroyingVolumes(workerName)
|
/dports/misc/concourse/concourse-6.7.2/atc/gc/ |
H A D | volume_collector.go | 15 volumeRepository db.VolumeRepository member 20 volumeRepository db.VolumeRepository, 24 volumeRepository: volumeRepository, 56 _, err = vc.volumeRepository.RemoveMissingVolumes(vc.missingVolumeGracePeriod) 66 failedVolumesLen, err := vc.volumeRepository.DestroyFailedVolumes() 86 orphanedVolumesHandles, err := vc.volumeRepository.GetOrphanedVolumes()
|
H A D | volume_collector_test.go | 21 volumeRepository db.VolumeRepository 33 volumeRepository = db.NewVolumeRepository(dbConn) 39 volumeRepository, 90 …creatingVolume1, err := volumeRepository.CreateContainerVolume(team.ID(), worker.Name(), creatingC… 98 failedVolumesLen, err := volumeRepository.DestroyFailedVolumes() 105 failedVolumesLen, err = volumeRepository.DestroyFailedVolumes() 121 …creatingVolume1, err := volumeRepository.CreateContainerVolume(team.ID(), worker.Name(), creatingC… 128 …creatingVolume2, err := volumeRepository.CreateContainerVolume(team.ID(), worker.Name(), creatingC… 152 destroyingVolumes, err := volumeRepository.GetDestroyingVolumes(worker.Name())
|
H A D | destroyer.go | 27 volumeRepository db.VolumeRepository member 34 volumeRepository db.VolumeRepository, 39 volumeRepository: volumeRepository, 77 deleted, err := d.volumeRepository.RemoveDestroyingVolumes(workerName, currentHandles) 90 destroyingVolumesHandles, err := d.volumeRepository.GetDestroyingVolumes(workerName)
|
/dports/net/concourse-fly/concourse-6.7.1/atc/db/ |
H A D | volume_repository.go | 51 type volumeRepository struct { struct 56 return &volumeRepository{ 61 func (repository *volumeRepository) queryVolumeHandles(tx Tx, cond sq.Eq) ([]string, error) { argument 147 func (repository *volumeRepository) RemoveMissingVolumes(gracePeriod time.Duration) (int, error) { argument 188 func (repository *volumeRepository) RemoveDestroyingVolumes(workerName string, handles []string) (i… argument 217 func (repository *volumeRepository) GetTeamVolumes(teamID int) ([]CreatedVolume, error) { argument 455 func (repository *volumeRepository) FindCreatedVolume(handle string) (CreatedVolume, bool, error) { argument 470 func (repository *volumeRepository) GetOrphanedVolumes() ([]CreatedVolume, error) { argument 522 func (repository *volumeRepository) DestroyFailedVolumes() (int, error) { argument 553 func (repository *volumeRepository) GetDestroyingVolumes(workerName string) ([]string, error) { argument [all …]
|
H A D | volume_repository_test.go | 72 volumes, err := volumeRepository.GetTeamVolumes(defaultTeam.ID()) 114 createdVolumes, err := volumeRepository.GetTeamVolumes(defaultTeam.ID()) 122 createdVolumes2, err := volumeRepository.GetTeamVolumes(team2.ID()) 142 createdVolumes, err := volumeRepository.GetTeamVolumes(defaultTeam.ID()) 150 createdVolumes2, err := volumeRepository.GetTeamVolumes(team2.ID()) 277 createdVolumes, err := volumeRepository.GetOrphanedVolumes() 299 createdVolumes, err := volumeRepository.GetOrphanedVolumes() 318 createdVolumes, err := volumeRepository.GetOrphanedVolumes() 343 failedVolumes, err := volumeRepository.DestroyFailedVolumes() 687 rowsAffected, err = volumeRepository.RemoveMissingVolumes(gracePeriod) [all …]
|
H A D | volume_test.go | 161 foundVolumes, err := volumeRepository.FindVolumesForContainer(defaultCreatedContainer) 235 …foundVolume, found, err := volumeRepository.FindResourceCacheVolume(defaultWorker.Name(), resource… 272 …creatingVolume, err = volumeRepository.CreateVolume(defaultTeam.ID(), defaultWorker.Name(), db.Vol… 292 created, found, err := volumeRepository.FindCreatedVolume(createdVolume.Handle()) 313 …v, err := volumeRepository.CreateContainerVolume(defaultTeam.ID(), defaultWorker.Name(), creatingC… 333 …createdVolume, found, err := volumeRepository.FindTaskCacheVolume(defaultTeam.ID(), defaultWorker.… 342 …createdVolume, found, err = volumeRepository.FindTaskCacheVolume(defaultTeam.ID(), defaultWorker.N… 481 …createdVolume, found, err := volumeRepository.FindResourceCacheVolume(defaultWorker.Name(), resour… 499 creatingVolume, err := volumeRepository.CreateBaseResourceTypeVolume(usedWorkerBaseResourceType) 510 _, createdVolume, err = volumeRepository.FindBaseResourceTypeVolume(usedWorkerBaseResourceType) [all …]
|
H A D | container_test.go | 61 …creatingVolume1, err := volumeRepository.CreateContainerVolume(defaultTeam.ID(), defaultWorker.Nam… 67 …creatingVolume2, err := volumeRepository.CreateContainerVolume(defaultTeam.ID(), defaultWorker.Nam… 78 volumes, err := volumeRepository.FindVolumesForContainer(createdContainer)
|
H A D | db_suite_test.go | 38 volumeRepository db.VolumeRepository var 110 volumeRepository = db.NewVolumeRepository(dbConn)
|
/dports/misc/concourse/concourse-6.7.2/atc/db/ |
H A D | volume_repository.go | 51 type volumeRepository struct { struct 56 return &volumeRepository{ 61 func (repository *volumeRepository) queryVolumeHandles(tx Tx, cond sq.Eq) ([]string, error) { argument 147 func (repository *volumeRepository) RemoveMissingVolumes(gracePeriod time.Duration) (int, error) { argument 188 func (repository *volumeRepository) RemoveDestroyingVolumes(workerName string, handles []string) (i… argument 217 func (repository *volumeRepository) GetTeamVolumes(teamID int) ([]CreatedVolume, error) { argument 455 func (repository *volumeRepository) FindCreatedVolume(handle string) (CreatedVolume, bool, error) { argument 470 func (repository *volumeRepository) GetOrphanedVolumes() ([]CreatedVolume, error) { argument 522 func (repository *volumeRepository) DestroyFailedVolumes() (int, error) { argument 553 func (repository *volumeRepository) GetDestroyingVolumes(workerName string) ([]string, error) { argument [all …]
|
H A D | volume_repository_test.go | 72 volumes, err := volumeRepository.GetTeamVolumes(defaultTeam.ID()) 114 createdVolumes, err := volumeRepository.GetTeamVolumes(defaultTeam.ID()) 122 createdVolumes2, err := volumeRepository.GetTeamVolumes(team2.ID()) 142 createdVolumes, err := volumeRepository.GetTeamVolumes(defaultTeam.ID()) 150 createdVolumes2, err := volumeRepository.GetTeamVolumes(team2.ID()) 277 createdVolumes, err := volumeRepository.GetOrphanedVolumes() 299 createdVolumes, err := volumeRepository.GetOrphanedVolumes() 318 createdVolumes, err := volumeRepository.GetOrphanedVolumes() 343 failedVolumes, err := volumeRepository.DestroyFailedVolumes() 687 rowsAffected, err = volumeRepository.RemoveMissingVolumes(gracePeriod) [all …]
|
H A D | volume_test.go | 161 foundVolumes, err := volumeRepository.FindVolumesForContainer(defaultCreatedContainer) 235 …foundVolume, found, err := volumeRepository.FindResourceCacheVolume(defaultWorker.Name(), resource… 272 …creatingVolume, err = volumeRepository.CreateVolume(defaultTeam.ID(), defaultWorker.Name(), db.Vol… 292 created, found, err := volumeRepository.FindCreatedVolume(createdVolume.Handle()) 313 …v, err := volumeRepository.CreateContainerVolume(defaultTeam.ID(), defaultWorker.Name(), creatingC… 333 …createdVolume, found, err := volumeRepository.FindTaskCacheVolume(defaultTeam.ID(), defaultWorker.… 342 …createdVolume, found, err = volumeRepository.FindTaskCacheVolume(defaultTeam.ID(), defaultWorker.N… 481 …createdVolume, found, err := volumeRepository.FindResourceCacheVolume(defaultWorker.Name(), resour… 499 creatingVolume, err := volumeRepository.CreateBaseResourceTypeVolume(usedWorkerBaseResourceType) 510 _, createdVolume, err = volumeRepository.FindBaseResourceTypeVolume(usedWorkerBaseResourceType) [all …]
|
H A D | container_test.go | 61 …creatingVolume1, err := volumeRepository.CreateContainerVolume(defaultTeam.ID(), defaultWorker.Nam… 67 …creatingVolume2, err := volumeRepository.CreateContainerVolume(defaultTeam.ID(), defaultWorker.Nam… 78 volumes, err := volumeRepository.FindVolumesForContainer(createdContainer)
|
H A D | db_suite_test.go | 38 volumeRepository db.VolumeRepository var 110 volumeRepository = db.NewVolumeRepository(dbConn)
|
/dports/net/concourse-fly/concourse-6.7.1/atc/api/volumeserver/ |
H A D | server.go | 17 volumeRepository db.VolumeRepository, 22 repository: volumeRepository,
|
/dports/misc/concourse/concourse-6.7.2/atc/api/volumeserver/ |
H A D | server.go | 17 volumeRepository db.VolumeRepository, 22 repository: volumeRepository,
|
/dports/net/concourse-fly/concourse-6.7.1/atc/api/ |
H A D | handler.go | 51 volumeRepository db.VolumeRepository, 101 volumesServer := volumeserver.NewServer(logger, volumeRepository, destroyer)
|
/dports/misc/concourse/concourse-6.7.2/atc/api/ |
H A D | handler.go | 51 volumeRepository db.VolumeRepository, 101 volumesServer := volumeserver.NewServer(logger, volumeRepository, destroyer)
|
/dports/net/concourse-fly/concourse-6.7.1/atc/worker/ |
H A D | worker.go | 106 volumeRepository db.VolumeRepository, 122 volumeRepo: volumeRepository,
|
/dports/misc/concourse/concourse-6.7.2/atc/worker/ |
H A D | worker.go | 106 volumeRepository db.VolumeRepository, 122 volumeRepo: volumeRepository,
|