Function queryAPI

cmd/kubectl-tree/query.go:62–98

(client dynamic.Interface, api apiResource, allNs bool, labelSelector string)

}

func queryAPI(client dynamic.Interface, api apiResource, allNs bool, labelSelector string) ([]unstructured.Unstructured, error) {
	var out []unstructured.Unstructured

	var next string
	var ns string

	if !allNs {
		ns = getNamespace()
	}
	for {
		var intf dynamic.ResourceInterface
		nintf := client.Resource(api.GroupVersionResource())
		if !allNs {
			intf = nintf.Namespace(ns)
		} else {
			intf = nintf
		}
		listOptions := metav1.ListOptions{
			Limit:    250,
			Continue: next,
		}
		if labelSelector != "" {
			listOptions.LabelSelector = labelSelector
		}
		resp, err := intf.List(context.TODO(), listOptions)
		if err != nil {
			return nil, fmt.Errorf("listing resources failed (%s): %w", api.GroupVersionResource(), err)
		}
		out = append(out, resp.Items...)

		next = resp.GetContinue()
		if next == "" {
			break
		}
	}
	return out, nil
}