cache manager list access requests (#565)

Axway · Oct 6, 2022 · 33a40f9 · 33a40f9
1 parent 8ba3f30
commit 33a40f9
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 0 deletions.
diff --git a/pkg/agent/cache/accessrequest.go b/pkg/agent/cache/accessrequest.go
@@ -95,3 +95,14 @@ func (c *cacheManager) GetAccessRequest(id string) *v1.ResourceInstance {
 func (c *cacheManager) DeleteAccessRequest(id string) error {
 	return c.accessRequestMap.Delete(id)
 }
+
+func (c *cacheManager) ListAccessRequests() []*v1.ResourceInstance {
+	list := make([]*v1.ResourceInstance, 0)
+	for _, key := range c.accessRequestMap.GetKeys() {
+		item, _ := c.accessRequestMap.Get(key)
+		if v, ok := item.(*v1.ResourceInstance); ok && v != nil {
+			list = append(list, v)
+		}
+	}
+	return list
+}
diff --git a/pkg/agent/cache/manager.go b/pkg/agent/cache/manager.go
@@ -111,6 +111,7 @@ type Manager interface {
 	GetAccessRequest(id string) *v1.ResourceInstance
 	GetAccessRequestsByApp(managedAppName string) []*v1.ResourceInstance
 	DeleteAccessRequest(id string) error
+	ListAccessRequests() []*v1.ResourceInstance
 
 	GetWatchResourceCacheKeys(group, kind string) []string
 	AddWatchResource(resource *v1.ResourceInstance)