Home
last modified time | relevance | path

Searched refs:volumeRepository (Results 1 – 22 of 22) sorted by relevance

/dports/net/concourse-fly/concourse-6.7.1/atc/gc/
H A Dvolume_collector.go15 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 Dvolume_collector_test.go21 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 Ddestroyer.go27 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 Dvolume_collector.go15 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 Dvolume_collector_test.go21 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 Ddestroyer.go27 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 Dvolume_repository.go51 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 Dvolume_repository_test.go72 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 Dvolume_test.go161 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 Dcontainer_test.go61 …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 Ddb_suite_test.go38 volumeRepository db.VolumeRepository var
110 volumeRepository = db.NewVolumeRepository(dbConn)
/dports/misc/concourse/concourse-6.7.2/atc/db/
H A Dvolume_repository.go51 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 Dvolume_repository_test.go72 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 Dvolume_test.go161 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 Dcontainer_test.go61 …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 Ddb_suite_test.go38 volumeRepository db.VolumeRepository var
110 volumeRepository = db.NewVolumeRepository(dbConn)
/dports/net/concourse-fly/concourse-6.7.1/atc/api/volumeserver/
H A Dserver.go17 volumeRepository db.VolumeRepository,
22 repository: volumeRepository,
/dports/misc/concourse/concourse-6.7.2/atc/api/volumeserver/
H A Dserver.go17 volumeRepository db.VolumeRepository,
22 repository: volumeRepository,
/dports/net/concourse-fly/concourse-6.7.1/atc/api/
H A Dhandler.go51 volumeRepository db.VolumeRepository,
101 volumesServer := volumeserver.NewServer(logger, volumeRepository, destroyer)
/dports/misc/concourse/concourse-6.7.2/atc/api/
H A Dhandler.go51 volumeRepository db.VolumeRepository,
101 volumesServer := volumeserver.NewServer(logger, volumeRepository, destroyer)
/dports/net/concourse-fly/concourse-6.7.1/atc/worker/
H A Dworker.go106 volumeRepository db.VolumeRepository,
122 volumeRepo: volumeRepository,
/dports/misc/concourse/concourse-6.7.2/atc/worker/
H A Dworker.go106 volumeRepository db.VolumeRepository,
122 volumeRepo: volumeRepository,