mirror of
https://github.com/cloudflare/cloudflared.git
synced 2025-05-22 19:56:34 +00:00
86476e6248
Before this commit the commands that listed tunnels and tunnel routes would be limited to 1000 results by the server. Now, the commands will call the endpoints until the result set is exhausted. This can take a long time if there are thousands of pages available, since each request is executed synchronously. From a user's perspective, nothing changes.
60 lines
1.1 KiB
Go
60 lines
1.1 KiB
Go
package cfapi
|
|
|
|
import (
|
|
"net/url"
|
|
"strconv"
|
|
"time"
|
|
|
|
"github.com/google/uuid"
|
|
)
|
|
|
|
const (
|
|
TimeLayout = time.RFC3339
|
|
)
|
|
|
|
type TunnelFilter struct {
|
|
queryParams url.Values
|
|
}
|
|
|
|
func NewTunnelFilter() *TunnelFilter {
|
|
return &TunnelFilter{
|
|
queryParams: url.Values{},
|
|
}
|
|
}
|
|
|
|
func (f *TunnelFilter) ByName(name string) {
|
|
f.queryParams.Set("name", name)
|
|
}
|
|
|
|
func (f *TunnelFilter) ByNamePrefix(namePrefix string) {
|
|
f.queryParams.Set("name_prefix", namePrefix)
|
|
}
|
|
|
|
func (f *TunnelFilter) ExcludeNameWithPrefix(excludePrefix string) {
|
|
f.queryParams.Set("exclude_prefix", excludePrefix)
|
|
}
|
|
|
|
func (f *TunnelFilter) NoDeleted() {
|
|
f.queryParams.Set("is_deleted", "false")
|
|
}
|
|
|
|
func (f *TunnelFilter) ByExistedAt(existedAt time.Time) {
|
|
f.queryParams.Set("existed_at", existedAt.Format(TimeLayout))
|
|
}
|
|
|
|
func (f *TunnelFilter) ByTunnelID(tunnelID uuid.UUID) {
|
|
f.queryParams.Set("uuid", tunnelID.String())
|
|
}
|
|
|
|
func (f *TunnelFilter) MaxFetchSize(max uint) {
|
|
f.queryParams.Set("per_page", strconv.Itoa(int(max)))
|
|
}
|
|
|
|
func (f *TunnelFilter) Page(page int) {
|
|
f.queryParams.Set("page", strconv.Itoa(page))
|
|
}
|
|
|
|
func (f TunnelFilter) encode() string {
|
|
return f.queryParams.Encode()
|
|
}
|