Merge branch 'main' of github.com:rudderlabs/rudder-cp-sdk into chore…

….poc

internal/clients/namespace/client.go

@@ -2,7 +2,6 @@ package namespace
 
 import (
 	"context"
-	"errors"
 	"net/http"
 	"time"
 
@@ -48,5 +47,5 @@ func (c *Client) GetWorkspaceConfigs(ctx context.Context) (*modelv2.WorkspaceCon
 }
 
 func (c *Client) GetUpdatedWorkspaceConfigs(ctx context.Context, updatedAfter time.Time) (*modelv2.WorkspaceConfigs, error) {
-	return nil, errors.New("not implemented")
+	return c.GetWorkspaceConfigs(ctx)
 }

internal/clients/workspace/client.go

@@ -2,7 +2,6 @@ package workspace
 
 import (
 	"context"
-	"errors"
 	"net/http"
 	"time"
 
@@ -48,5 +47,5 @@ func (c *Client) GetWorkspaceConfigs(ctx context.Context) (*modelv2.WorkspaceCon
 }
 
 func (c *Client) GetUpdatedWorkspaceConfigs(ctx context.Context, updatedAfter time.Time) (*modelv2.WorkspaceConfigs, error) {
-	return nil, errors.New("not implemented")
+	return c.GetWorkspaceConfigs(ctx)
 }

internal/poller/poller.go

@@ -6,6 +6,8 @@ import (
 	"fmt"
 	"time"
 
+	"github.com/rudderlabs/rudder-cp-sdk/profiler"
+
 	"github.com/rudderlabs/rudder-cp-sdk/modelv2"
 	"github.com/rudderlabs/rudder-go-kit/logger"
 )
@@ -66,6 +68,9 @@ func (p *Poller) Start(ctx context.Context) {
 }
 
 func (p *Poller) poll(ctx context.Context) error {
+	p.log.Info("After processing config")
+	profiler.MemProfile(p.log)
+
 	var response *modelv2.WorkspaceConfigs
 	if p.updatedAt.IsZero() {
 		p.log.Debug("polling for workspace configs")
@@ -89,6 +94,9 @@ func (p *Poller) poll(ctx context.Context) error {
 		return fmt.Errorf("failed to handle workspace configs: %w", err)
 	}
 
+	p.log.Info("After processing config")
+	profiler.MemProfile(p.log)
+
 	// only update updatedAt if we managed to handle the response
 	// so that we don't miss any updates in case of an error
 	p.updatedAt = response.UpdatedAt()

profiler/profiler.go

@@ -0,0 +1,21 @@
+package profiler
+
+import (
+	"fmt"
+	"math/rand"
+	"os"
+	"runtime/pprof"
+	"time"
+
+	"github.com/rudderlabs/rudder-go-kit/logger"
+)
+
+var r = rand.New(rand.NewSource(time.Now().UnixNano()))
+
+func MemProfile(log logger.Logger) {
+	f, _ := os.Create(fmt.Sprintf("heap-%d.pprof", r.Int()))
+	_ = pprof.WriteHeapProfile(f)
+	_ = f.Close()
+
+	log.Infof("heap profile written to %s", f.Name())
+}