Method ListVolumes

server-source-code/internal/store/docker.go:563–620

ListVolumes returns volumes with host info.

(ctx context.Context, params VolumeListParams)

// ListVolumes returns volumes with host info.
func (s *DockerStore) ListVolumes(ctx context.Context, params VolumeListParams) ([]VolumeWithHost, int, error) {
	d := s.db.DB(ctx)
	skip, take := validatePagination(params.Page, params.Limit, 10000)

	arg := db.ListVolumesParams{Limit: safeconv.ClampToInt32(take), Offset: safeconv.ClampToInt32(skip)}
	if params.Driver != "" {
		arg.Driver = &params.Driver
	}
	if params.Search != "" {
		arg.Search = &params.Search
	}

	countArg := db.CountVolumesParams{}
	if params.Driver != "" {
		countArg.Driver = &params.Driver
	}
	if params.Search != "" {
		countArg.Search = &params.Search
	}

	total, err := d.Queries.CountVolumes(ctx, countArg)
	if err != nil {
		return nil, 0, err
	}

	volumes, err := d.Queries.ListVolumes(ctx, arg)
	if err != nil {
		return nil, 0, err
	}

	if len(volumes) == 0 {
		return []VolumeWithHost{}, int(total), nil
	}

	hostIDs := make([]string, len(volumes))
	for i := range volumes {
		hostIDs[i] = volumes[i].HostID
	}

	hosts, err := d.Queries.GetDockerHostsMinimalByIDs(ctx, hostIDs)
	if err != nil {
		return nil, 0, err
	}
	hostMap := make(map[string]*HostInfo)
	for i := range hosts {
		h := dockerHostRowToHostInfo(hosts[i])
		hostMap[h.ID] = h
	}

	out := make([]VolumeWithHost, len(volumes))
	for i := range volumes {
		out[i] = VolumeWithHost{
			DockerVolume: dbDockerVolumeToModel(volumes[i]),
			Hosts:        hostMap[volumes[i].HostID],
		}
	}
	return out, int(total), nil
}