Add introspecting summary to minimize the output for pods (#276)

pkg/pool/pool.go

@@ -104,6 +104,12 @@ type IntrospectResponse struct {
 	CoolingResources []CoolDownResource
 }
 
+type IntrospectSummaryResponse struct {
+	UsedResourcesCount    int
+	WarmResourcesCount    int
+	CoolingResourcesCount int
+}
+
 func NewResourcePool(log logr.Logger, poolConfig *config.WarmPoolConfig, usedResources map[string]Resource,
 	warmResources map[string][]Resource, nodeName string, capacity int, isPDPool bool) Pool {
 	pool := &pool{

pkg/provider/branch/provider.go

@@ -496,6 +496,28 @@ func (b *branchENIProvider) Introspect() interface{} {
 	return allResponse
 }
 
+func (b *branchENIProvider) IntrospectSummary() interface{} {
+	b.lock.RLock()
+	defer b.lock.RUnlock()
+
+	allResponse := make(map[string]trunk.IntrospectSummaryResponse)
+
+	for nodeName, trunkENI := range b.trunkENICache {
+		response := trunkENI.Introspect()
+		allResponse[nodeName] = changeToIntrospectSummary(response)
+	}
+	return allResponse
+}
+
+func changeToIntrospectSummary(details trunk.IntrospectResponse) trunk.IntrospectSummaryResponse {
+	return trunk.IntrospectSummaryResponse{
+		TrunkENIID:     details.TrunkENIID,
+		InstanceID:     details.InstanceID,
+		BranchENICount: len(details.PodToBranchENI),
+		DeleteQueueLen: len(details.DeleteQueue),
+	}
+}
+
 func (b *branchENIProvider) IntrospectNode(nodeName string) interface{} {
 	b.lock.RLock()
 	defer b.lock.RUnlock()

pkg/provider/branch/trunk/trunk.go

@@ -130,6 +130,13 @@ type IntrospectResponse struct {
 	DeleteQueue    []ENIDetails
 }
 
+type IntrospectSummaryResponse struct {
+	TrunkENIID     string
+	InstanceID     string
+	BranchENICount int
+	DeleteQueueLen int
+}
+
 // NewTrunkENI returns a new Trunk ENI interface.
 func NewTrunkENI(logger logr.Logger, instance ec2.EC2Instance, helper api.EC2APIHelper) TrunkENI {
 

pkg/provider/ip/provider.go

@@ -460,6 +460,26 @@ func (p *ipv4Provider) Introspect() interface{} {
 	return response
 }
 
+func (p *ipv4Provider) IntrospectSummary() interface{} {
+	p.lock.RLock()
+	defer p.lock.RUnlock()
+
+	response := make(map[string]pool.IntrospectSummaryResponse)
+	for nodeName, resource := range p.instanceProviderAndPool {
+		response[nodeName] = ChangeToIntrospectSummary(resource.resourcePool.Introspect())
+
+	}
+	return response
+}
+
+func ChangeToIntrospectSummary(details pool.IntrospectResponse) pool.IntrospectSummaryResponse {
+	return pool.IntrospectSummaryResponse{
+		WarmResourcesCount:    len(details.WarmResources),
+		CoolingResourcesCount: len(details.CoolingResources),
+		UsedResourcesCount:    len(details.UsedResources),
+	}
+}
+
 func (p *ipv4Provider) IntrospectNode(nodeName string) interface{} {
 	p.lock.RLock()
 	defer p.lock.RUnlock()

pkg/provider/prefix/provider.go

@@ -28,6 +28,7 @@ import (
 	rcHealthz "github.com/aws/amazon-vpc-resource-controller-k8s/pkg/healthz"
 	"github.com/aws/amazon-vpc-resource-controller-k8s/pkg/pool"
 	"github.com/aws/amazon-vpc-resource-controller-k8s/pkg/provider"
+	"github.com/aws/amazon-vpc-resource-controller-k8s/pkg/provider/ip"
 	"github.com/aws/amazon-vpc-resource-controller-k8s/pkg/provider/ip/eni"
 	"github.com/aws/amazon-vpc-resource-controller-k8s/pkg/utils"
 	"github.com/aws/amazon-vpc-resource-controller-k8s/pkg/worker"
@@ -435,6 +436,17 @@ func (p *ipv4PrefixProvider) Introspect() interface{} {
 	return response
 }
 
+func (p *ipv4PrefixProvider) IntrospectSummary() interface{} {
+	p.lock.RLock()
+	defer p.lock.RUnlock()
+
+	response := make(map[string]pool.IntrospectSummaryResponse)
+	for nodeName, resource := range p.instanceProviderAndPool {
+		response[nodeName] = ip.ChangeToIntrospectSummary(resource.resourcePool.Introspect())
+	}
+	return response
+}
+
 func (p *ipv4PrefixProvider) IntrospectNode(node string) interface{} {
 	p.lock.RLock()
 	defer p.lock.RUnlock()

pkg/provider/provider.go

@@ -42,4 +42,6 @@ type ResourceProvider interface {
 	IntrospectNode(node string) interface{}
 	// GetHealthChecker provider a health check subpath for pinging provider
 	GetHealthChecker() healthz.Checker
+	// IntrospectSummary allows introspection of resources summary per node
+	IntrospectSummary() interface{}
 }

pkg/resource/introspect.go

@@ -25,8 +25,9 @@ import (
 )
 
 const (
-	GetNodeResourcesPath = "/node/"
-	GetAllResourcesPath  = "/resources"
+	GetNodeResourcesPath    = "/node/"
+	GetAllResourcesPath     = "/resources/all"
+	GetResourcesSummaryPath = "/resources/summary"
 )
 
 type IntrospectHandler struct {
@@ -42,6 +43,7 @@ func (i *IntrospectHandler) Start(_ context.Context) error {
 	mux := http.NewServeMux()
 	mux.HandleFunc(GetAllResourcesPath, i.ResourceHandler)
 	mux.HandleFunc(GetNodeResourcesPath, i.NodeResourceHandler)
+	mux.HandleFunc(GetResourcesSummaryPath, i.ResourceSummaryHandler)
 
 	// Should this be a fatal error?
 	err := http.ListenAndServe(i.BindAddress, mux)
@@ -95,6 +97,26 @@ func (i *IntrospectHandler) NodeResourceHandler(w http.ResponseWriter, r *http.R
 	w.Write(jsonData)
 }
 
+// ResourceSummaryHandler returns all the resources associated with the Node
+func (i *IntrospectHandler) ResourceSummaryHandler(w http.ResponseWriter, r *http.Request) {
+	response := make(map[string]interface{})
+	for resourceName, provider := range i.ResourceManager.GetResourceProviders() {
+		data := provider.IntrospectSummary()
+		response[resourceName] = data
+	}
+
+	jsonData, err := json.MarshalIndent(response, "", "\t")
+	if err != nil {
+		w.WriteHeader(http.StatusInternalServerError)
+		w.Write([]byte(err.Error()))
+		return
+	}
+
+	w.Header().Set("content-type", "application/json")
+	w.WriteHeader(http.StatusOK)
+	w.Write(jsonData)
+}
+
 func (i *IntrospectHandler) SetupWithManager(mgr ctrl.Manager, healthzHanlder *rcHealthz.HealthzHandler) error {
 	// add health check on subpath for introspect controller
 	healthzHanlder.AddControllersHealthCheckers(

pkg/resource/introspect_test.go

@@ -19,8 +19,8 @@ import (
 	"net/http/httptest"
 	"testing"
 
-	"github.com/aws/amazon-vpc-resource-controller-k8s/mocks/amazon-vcp-resource-controller-k8s/pkg/provider"
-	"github.com/aws/amazon-vpc-resource-controller-k8s/mocks/amazon-vcp-resource-controller-k8s/pkg/resource"
+	mock_provider "github.com/aws/amazon-vpc-resource-controller-k8s/mocks/amazon-vcp-resource-controller-k8s/pkg/provider"
+	mock_resource "github.com/aws/amazon-vpc-resource-controller-k8s/mocks/amazon-vcp-resource-controller-k8s/pkg/resource"
 	"github.com/aws/amazon-vpc-resource-controller-k8s/pkg/config"
 	"github.com/aws/amazon-vpc-resource-controller-k8s/pkg/provider"
 
@@ -90,6 +90,24 @@ func TestIntrospectHandler_ResourceHandler(t *testing.T) {
 	VerifyResponse(t, rr, mock.response)
 }
 
+func TestIntrospectHandler_SummaryHandler(t *testing.T) {
+	ctrl := gomock.NewController(t)
+	defer ctrl.Finish()
+
+	mock := NewMockIntrospectHandler(ctrl)
+
+	req, err := http.NewRequest("GET", GetAllResourcesPath+nodeName, nil)
+	assert.NoError(t, err)
+	rr := httptest.NewRecorder()
+
+	mock.mockManager.EXPECT().GetResourceProviders().
+		Return(map[string]provider.ResourceProvider{resourceName: mock.mockProvider})
+	mock.mockProvider.EXPECT().IntrospectSummary().Return(response)
+
+	mock.handler.ResourceSummaryHandler(rr, req)
+	VerifyResponse(t, rr, mock.response)
+}
+
 func VerifyResponse(t *testing.T, rr *httptest.ResponseRecorder, response map[string]string) {
 	got := &map[string]string{}
 	err := json.Unmarshal(rr.Body.Bytes(), got)