remove the default resource list limit

Signed-off-by: Wei Liu <[email protected]>
openshift-online · Jun 14, 2024 · bc356d3 · bc356d3
1 parent df9a3ac
commit bc356d3
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/pkg/client/cloudevents/grpcsource/watcherstore.go b/pkg/client/cloudevents/grpcsource/watcherstore.go
@@ -107,8 +107,15 @@ func (m *RESTFulAPIWatcherStore) Get(namespace, name string) (*workv1.ManifestWo
 func (m *RESTFulAPIWatcherStore) List(opts metav1.ListOptions) ([]*workv1.ManifestWork, error) {
 	works := []*workv1.ManifestWork{}
 
+	var size int32 = -1
+	if opts.Limit > 0 {
+		size = int32(opts.Limit)
+	}
+
 	apiRequest := m.apiClient.DefaultApi.ApiMaestroV1ResourceBundlesGet(context.Background()).
-		Search(fmt.Sprintf("source = '%s'", m.sourceID))
+		Search(fmt.Sprintf("source = '%s'", m.sourceID)).
+		Page(1). // TODO consider how to support this
+		Size(size)
 
 	// TODO filter works by labels