config rodan server port in metaserver.metricConfiguration

WangZzzhe · WangZzzhe · commit 62186795a9c4 · 2024-04-15T14:39:28.000+08:00
diff --git a/cmd/katalyst-agent/app/options/metaserver/metaserver.go b/cmd/katalyst-agent/app/options/metaserver/metaserver.go
@@ -56,6 +56,8 @@ const defaultCustomNodeResourceCacheTTL = 15 * time.Second
 
 const defaultCustomNodeConfigCacheTTL = 15 * time.Second
 
+const defaultRodanServerPort = 9102
+
 // MetaServerOptions holds all the configurations for metaserver.
 // we will not try to separate this structure into several individual
 // structures since it will not be used directly by other components; instead,
@@ -79,6 +81,7 @@ type MetaServerOptions struct {
 	// configurations for metric-fetcher
 	MetricInsurancePeriod time.Duration
 	MetricProvisions      []string
+	RodanServerPort       int
 
 	// configurations for pod-cache
 	KubeletPodCacheSyncPeriod    time.Duration
@@ -109,6 +112,7 @@ func NewMetaServerOptions() *MetaServerOptions {
 
 		MetricInsurancePeriod: defaultMetricInsurancePeriod,
 		MetricProvisions:      []string{metaserver.MetricProvisionerMalachite, metaserver.MetricProvisionerKubelet},
+		RodanServerPort:       defaultRodanServerPort,
 
 		KubeletPodCacheSyncPeriod:    defaultKubeletPodCacheSyncPeriod,
 		KubeletPodCacheSyncMaxRate:   defaultKubeletPodCacheSyncMaxRate,
@@ -150,6 +154,8 @@ func (o *MetaServerOptions) AddFlags(fss *cliflag.NamedFlagSets) {
 		"The meta server return metric data and MetricDataExpired if the update time of metric data is earlier than this period.")
 	fs.StringSliceVar(&o.MetricProvisions, "metric-provisioners", o.MetricProvisions,
 		"The provisioners that should be enabled by default")
+	fs.IntVar(&o.RodanServerPort, "rodan-server-port", o.RodanServerPort,
+		"The rodan metric provisioner server port")
 
 	fs.DurationVar(&o.KubeletPodCacheSyncPeriod, "kubelet-pod-cache-sync-period", o.KubeletPodCacheSyncPeriod,
 		"The period of meta server to sync pod from kubelet 10255 port")
@@ -183,6 +189,7 @@ func (o *MetaServerOptions) ApplyTo(c *metaserver.MetaServerConfiguration) error
 
 	c.MetricInsurancePeriod = o.MetricInsurancePeriod
 	c.MetricProvisions = o.MetricProvisions
+	c.RodanServerPort = o.RodanServerPort
 
 	c.KubeletPodCacheSyncPeriod = o.KubeletPodCacheSyncPeriod
 	c.KubeletPodCacheSyncMaxRate = rate.Limit(o.KubeletPodCacheSyncMaxRate)
diff --git a/pkg/config/agent/metaserver/agent.go b/pkg/config/agent/metaserver/agent.go
@@ -32,6 +32,11 @@ const (
 type MetricConfiguration struct {
 	MetricInsurancePeriod time.Duration
 	MetricProvisions      []string
+	*RodanMetricConfiguration
+}
+
+type RodanMetricConfiguration struct {
+	RodanServerPort int
 }
 
 type PodConfiguration struct {
@@ -65,10 +70,12 @@ type AgentConfiguration struct {
 
 func NewAgentConfiguration() *AgentConfiguration {
 	return &AgentConfiguration{
-		MetricConfiguration: &MetricConfiguration{},
-		PodConfiguration:    &PodConfiguration{},
-		NodeConfiguration:   &NodeConfiguration{},
-		CNRConfiguration:    &CNRConfiguration{},
-		CNCConfiguration:    &CNCConfiguration{},
+		MetricConfiguration: &MetricConfiguration{
+			RodanMetricConfiguration: &RodanMetricConfiguration{},
+		},
+		PodConfiguration:  &PodConfiguration{},
+		NodeConfiguration: &NodeConfiguration{},
+		CNRConfiguration:  &CNRConfiguration{},
+		CNCConfiguration:  &CNCConfiguration{},
 	}
 }
diff --git a/pkg/metaserver/agent/metric/metric_impl.go b/pkg/metaserver/agent/metric/metric_impl.go
@@ -233,7 +233,7 @@ func NewMetricsFetcher(baseConf *global.BaseConfiguration, metricConf *metaserve
 	var enabledProvisioners []types.MetricsProvisioner
 	for _, name := range metricConf.MetricProvisions {
 		if f, ok := registeredProvisioners[name]; ok {
-			enabledProvisioners = append(enabledProvisioners, f(baseConf, emitter, podFetcher, metricStore))
+			enabledProvisioners = append(enabledProvisioners, f(baseConf, metricConf, emitter, podFetcher, metricStore))
 		}
 	}
 
diff --git a/pkg/metaserver/agent/metric/metric_provisoner.go b/pkg/metaserver/agent/metric/metric_provisoner.go
@@ -38,7 +38,7 @@ func init() {
 	RegisterProvisioners(metaserver.MetricProvisionerRodan, rodan.NewRodanMetricsProvisioner)
 }
 
-type ProvisionerInitFunc func(baseConf *global.BaseConfiguration,
+type ProvisionerInitFunc func(baseConf *global.BaseConfiguration, metricConf *metaserver.MetricConfiguration,
 	emitter metrics.MetricEmitter, fetcher pod.PodFetcher, metricStore *utilmetric.MetricStore) types.MetricsProvisioner
 
 // provisioners stores the initializing function for each-provisioner
diff --git a/pkg/metaserver/agent/metric/provisioner/cgroup/provisioner.go b/pkg/metaserver/agent/metric/provisioner/cgroup/provisioner.go
@@ -20,14 +20,15 @@ import (
 	"context"
 
 	"github.com/kubewharf/katalyst-core/pkg/config/agent/global"
+	"github.com/kubewharf/katalyst-core/pkg/config/agent/metaserver"
 	"github.com/kubewharf/katalyst-core/pkg/metaserver/agent/metric/types"
 	"github.com/kubewharf/katalyst-core/pkg/metaserver/agent/pod"
 	"github.com/kubewharf/katalyst-core/pkg/metrics"
 	utilmetric "github.com/kubewharf/katalyst-core/pkg/util/metric"
 )
 
 // NewCGroupMetricsProvisioner returns the default implementation of CGroup.
-func NewCGroupMetricsProvisioner(baseConf *global.BaseConfiguration,
+func NewCGroupMetricsProvisioner(baseConf *global.BaseConfiguration, _ *metaserver.MetricConfiguration,
 	emitter metrics.MetricEmitter, _ pod.PodFetcher, metricStore *utilmetric.MetricStore) types.MetricsProvisioner {
 	return &CGroupMetricsProvisioner{
 		metricStore: metricStore,
diff --git a/pkg/metaserver/agent/metric/provisioner/kubelet/provisioner.go b/pkg/metaserver/agent/metric/provisioner/kubelet/provisioner.go
@@ -24,6 +24,7 @@ import (
 	statsapi "k8s.io/kubelet/pkg/apis/stats/v1alpha1"
 
 	"github.com/kubewharf/katalyst-core/pkg/config/agent/global"
+	"github.com/kubewharf/katalyst-core/pkg/config/agent/metaserver"
 	"github.com/kubewharf/katalyst-core/pkg/consts"
 	"github.com/kubewharf/katalyst-core/pkg/metaserver/agent/metric/provisioner/kubelet/client"
 	"github.com/kubewharf/katalyst-core/pkg/metaserver/agent/metric/types"
@@ -36,7 +37,7 @@ const (
 	metricsNamKubeletSummaryUnHealthy = "kubelet_summary_unhealthy"
 )
 
-func NewKubeletSummaryProvisioner(baseConf *global.BaseConfiguration,
+func NewKubeletSummaryProvisioner(baseConf *global.BaseConfiguration, _ *metaserver.MetricConfiguration,
 	emitter metrics.MetricEmitter, _ pod.PodFetcher, metricStore *utilmetric.MetricStore) types.MetricsProvisioner {
 	return &KubeletSummaryProvisioner{
 		metricStore: metricStore,
diff --git a/pkg/metaserver/agent/metric/provisioner/malachite/provisioner.go b/pkg/metaserver/agent/metric/provisioner/malachite/provisioner.go
@@ -27,6 +27,7 @@ import (
 	"k8s.io/klog/v2"
 
 	"github.com/kubewharf/katalyst-core/pkg/config/agent/global"
+	"github.com/kubewharf/katalyst-core/pkg/config/agent/metaserver"
 	"github.com/kubewharf/katalyst-core/pkg/consts"
 	"github.com/kubewharf/katalyst-core/pkg/metaserver/agent/metric/provisioner/malachite/client"
 	malachitetypes "github.com/kubewharf/katalyst-core/pkg/metaserver/agent/metric/provisioner/malachite/types"
@@ -53,7 +54,7 @@ const (
 )
 
 // NewMalachiteMetricsProvisioner returns the default implementation of MetricsFetcher.
-func NewMalachiteMetricsProvisioner(baseConf *global.BaseConfiguration,
+func NewMalachiteMetricsProvisioner(baseConf *global.BaseConfiguration, _ *metaserver.MetricConfiguration,
 	emitter metrics.MetricEmitter, fetcher pod.PodFetcher, metricStore *utilmetric.MetricStore) types.MetricsProvisioner {
 	return &MalachiteMetricsProvisioner{
 		malachiteClient: client.NewMalachiteClient(fetcher),
diff --git a/pkg/metaserver/agent/metric/provisioner/malachite/provisioner_test.go b/pkg/metaserver/agent/metric/provisioner/malachite/provisioner_test.go
@@ -20,6 +20,7 @@ import (
 	"testing"
 
 	"github.com/kubewharf/katalyst-core/pkg/config/agent/global"
+	"github.com/kubewharf/katalyst-core/pkg/config/agent/metaserver"
 	malachitetypes "github.com/kubewharf/katalyst-core/pkg/metaserver/agent/metric/provisioner/malachite/types"
 	"github.com/kubewharf/katalyst-core/pkg/metaserver/agent/pod"
 	"github.com/kubewharf/katalyst-core/pkg/metrics"
@@ -32,7 +33,7 @@ func Test_noneExistMetricsProvisioner(t *testing.T) {
 	store := utilmetric.NewMetricStore()
 
 	var err error
-	implement := NewMalachiteMetricsProvisioner(&global.BaseConfiguration{}, metrics.DummyMetrics{}, &pod.PodFetcherStub{}, store)
+	implement := NewMalachiteMetricsProvisioner(&global.BaseConfiguration{}, &metaserver.MetricConfiguration{}, metrics.DummyMetrics{}, &pod.PodFetcherStub{}, store)
 
 	fakeSystemCompute := &malachitetypes.SystemComputeData{
 		CPU: []malachitetypes.CPU{
diff --git a/pkg/metaserver/agent/metric/provisioner/rodan/client/client.go b/pkg/metaserver/agent/metric/provisioner/rodan/client/client.go
@@ -33,10 +33,10 @@ type RodanClient struct {
 	metricFunc MetricFunc
 }
 
-func NewRodanClient(fetcher pod.PodFetcher, metricFunc MetricFunc) *RodanClient {
+func NewRodanClient(fetcher pod.PodFetcher, metricFunc MetricFunc, port int) *RodanClient {
 	urls := make(map[string]string)
 	for path := range types.MetricsMap {
-		urls[path] = fmt.Sprintf("http://localhost:%d%s", types.RodanServerPort, path)
+		urls[path] = fmt.Sprintf("http://localhost:%d%s", port, path)
 	}
 
 	if metricFunc == nil {
diff --git a/pkg/metaserver/agent/metric/provisioner/rodan/client/client_node_test.go b/pkg/metaserver/agent/metric/provisioner/rodan/client/client_node_test.go
@@ -26,19 +26,21 @@ import (
 )
 
 func TestGetNodeMemoryStats(t *testing.T) {
+	t.Parallel()
 	ic := NewRodanClient(&FakePodFetcher{}, func(url string, params map[string]string) ([]byte, error) {
 		return []byte(`{"data":[{"key":"memory_swaptotal","val":0},{"key":"memory_sreclaimable","val":573520},{"key":"memory_shmem","val":1643536},{"key":"memory_writeback","val":0},{"key":"memory_memavailable","val":19710408},{"key":"memory_pgsteal_kswapd","val":7067178},{"key":"memory_cached","val":16703864},{"key":"memory_memtotal","val":32614152},{"key":"memory_swapfree","val":0},{"key":"memory_buffers","val":360688},{"key":"memory_memfree","val":14053836},{"key":"memory_dirty","val":1124}]}`), nil
-	})
+	}, 9102)
 
 	res, err := ic.GetNodeMemoryStats()
 	require.NoError(t, err)
 	require.Equal(t, 12, len(res))
 }
 
 func TestGetNUMAMemoryStats(t *testing.T) {
+	t.Parallel()
 	ic := NewRodanClient(&FakePodFetcher{}, func(url string, params map[string]string) ([]byte, error) {
 		return []byte(`{"data":[{"key":"numastat_node0_memfree","val":14549598208},{"key":"numastat_node0_memtotal","val":33396891648}]}`), nil
-	})
+	}, 9102)
 
 	res, err := ic.GetNUMAMemoryStats()
 	require.NoError(t, err)
@@ -48,19 +50,21 @@ func TestGetNUMAMemoryStats(t *testing.T) {
 }
 
 func TestGetNodeCgroupMemoryStats(t *testing.T) {
+	t.Parallel()
 	ic := NewRodanClient(&FakePodFetcher{}, func(url string, params map[string]string) ([]byte, error) {
 		return []byte(`{"data":[{"key":"qosgroupmem_besteffort_memory_rss","val":112414720},{"key":"qosgroupmem_besteffort_memory_usage","val":1244418048},{"key":"qosgroupmem_burstable_memory_rss","val":183828480},{"key":"qosgroupmem_burstable_memory_usage","val":377950208}]}`), nil
-	})
+	}, 9102)
 
 	res, err := ic.GetNodeCgroupMemoryStats()
 	require.NoError(t, err)
 	require.Equal(t, 4, len(res))
 }
 
 func TestGetCoreCPUStats(t *testing.T) {
+	t.Parallel()
 	ic := NewRodanClient(&FakePodFetcher{}, func(url string, params map[string]string) ([]byte, error) {
 		return []byte(`{"data":[{"key":"percorecpu_cpu5_sched_wait","val":0},{"key":"percorecpu_cpu0_usage","val":19},{"key":"percorecpu_cpu3_sched_wait","val":0},{"key":"percorecpu_cpu7_usage","val":53},{"key":"percorecpu_cpu0_sched_wait","val":0},{"key":"percorecpu_cpu6_usage","val":31},{"key":"percorecpu_cpu7_sched_wait","val":0},{"key":"percorecpu_cpu2_usage","val":23},{"key":"percorecpu_cpu1_usage","val":28},{"key":"percorecpu_cpu6_sched_wait","val":0},{"key":"percorecpu_cpu3_usage","val":78},{"key":"percorecpu_cpu4_sched_wait","val":0},{"key":"percorecpu_cpu2_sched_wait","val":0},{"key":"percorecpu_cpu1_sched_wait","val":0},{"key":"percorecpu_cpu5_usage","val":64},{"key":"percorecpu_cpu4_usage","val":32}]}`), nil
-	})
+	}, 9102)
 
 	res, err := ic.GetCoreCPUStats()
 	require.NoError(t, err)
@@ -70,9 +74,10 @@ func TestGetCoreCPUStats(t *testing.T) {
 }
 
 func TestGetNodeSysctl(t *testing.T) {
+	t.Parallel()
 	ic := NewRodanClient(&FakePodFetcher{}, func(url string, params map[string]string) ([]byte, error) {
 		return []byte(`{"data":[{"key":"sysctl_vm_watermark_scale_factor","val":1000},{"key":"sysctl_tcp_mem_pressure","val":507145},{"key":"sysctl_tcp_mem_extreme","val":760716},{"key":"sysctl_tcp_mem_original","val":380358}]}`), nil
-	})
+	}, 9102)
 
 	res, err := ic.GetNodeSysctl()
 	require.NoError(t, err)
diff --git a/pkg/metaserver/agent/metric/provisioner/rodan/client/client_pod_test.go b/pkg/metaserver/agent/metric/provisioner/rodan/client/client_pod_test.go
@@ -26,6 +26,7 @@ import (
 )
 
 func TestGetPodContainerCPUStats(t *testing.T) {
+	t.Parallel()
 	testPod := &v1.Pod{
 		ObjectMeta: metav1.ObjectMeta{
 			UID:  "2126079c-8e0a-4cfe-9a0b-583199c14027",
@@ -47,14 +48,15 @@ func TestGetPodContainerCPUStats(t *testing.T) {
 		},
 	}, func(url string, params map[string]string) ([]byte, error) {
 		return []byte(`{"data":{"da2f6c58a278f9966c2951f3297ed2ac6b8c73cc92460e68f6865bc0448137f0":[{"key":"cgcpu_usage","val":99},{"key":"cgcpu_sysusage","val":0},{"key":"cgcpu_user_nsecs","val":2777495188589},{"key":"cgcpu_sys_nsecs","val":337561580},{"key":"cgcpu_userusage","val":99},{"key":"cgcpu_nsecs","val":2777832750169}]}}`), nil
-	})
+	}, 9102)
 
 	res, err := ic.GetPodContainerCPUStats(context.Background(), "2126079c-8e0a-4cfe-9a0b-583199c14027")
 	require.NoError(t, err)
 	require.NotNil(t, res["testcontainer"])
 }
 
 func TestGetPodContainerCgroupMemStats(t *testing.T) {
+	t.Parallel()
 	testPod := &v1.Pod{
 		ObjectMeta: metav1.ObjectMeta{
 			UID:  "2126079c-8e0a-4cfe-9a0b-583199c14027",
@@ -76,14 +78,15 @@ func TestGetPodContainerCgroupMemStats(t *testing.T) {
 		},
 	}, func(url string, params map[string]string) ([]byte, error) {
 		return []byte(`{"data":{"da2f6c58a278f9966c2951f3297ed2ac6b8c73cc92460e68f6865bc0448137f0":[{"key":"cgmem_total_shmem","val":0},{"key":"cgmem_total_rss","val":0},{"key":"cgmem_total_cache","val":0},{"key":"cgmem_total_dirty","val":0}]}}`), nil
-	})
+	}, 9102)
 
 	res, err := ic.GetPodContainerCgroupMemStats(context.Background(), "2126079c-8e0a-4cfe-9a0b-583199c14027")
 	require.NoError(t, err)
 	require.NotNil(t, res["testcontainer"])
 }
 
 func TestGetPodContainerLoadStats(t *testing.T) {
+	t.Parallel()
 	testPod := &v1.Pod{
 		ObjectMeta: metav1.ObjectMeta{
 			UID:  "2126079c-8e0a-4cfe-9a0b-583199c14027",
@@ -105,14 +108,15 @@ func TestGetPodContainerLoadStats(t *testing.T) {
 		},
 	}, func(url string, params map[string]string) ([]byte, error) {
 		return []byte(`{"data":{"da2f6c58a278f9966c2951f3297ed2ac6b8c73cc92460e68f6865bc0448137f0":[{"key":"loadavg_loadavg15","val":48},{"key":"loadavg_loadavg5","val":48},{"key":"loadavg_nrrunning","val":48},{"key":"loadavg_loadavg1","val":48},{"key":"loadavg_nriowait","val":48},{"key":"loadavg_nrsleeping","val":48},{"key":"loadavg_nruninterruptible","val":48}]}}`), nil
-	})
+	}, 9102)
 
 	res, err := ic.GetPodContainerLoadStats(context.Background(), "2126079c-8e0a-4cfe-9a0b-583199c14027")
 	require.NoError(t, err)
 	require.NotNil(t, res["testcontainer"])
 }
 
 func TestGetPodContainerCghardwareStats(t *testing.T) {
+	t.Parallel()
 	testPod := &v1.Pod{
 		ObjectMeta: metav1.ObjectMeta{
 			UID:  "2126079c-8e0a-4cfe-9a0b-583199c14027",
@@ -134,14 +138,15 @@ func TestGetPodContainerCghardwareStats(t *testing.T) {
 		},
 	}, func(url string, params map[string]string) ([]byte, error) {
 		return []byte(`{"data":{"da2f6c58a278f9966c2951f3297ed2ac6b8c73cc92460e68f6865bc0448137f0":[{"key":"cghardware_cycles","val":0},{"key":"cghardware_instructions","val":0}]}}`), nil
-	})
+	}, 9102)
 
 	res, err := ic.GetPodContainerCghardwareStats(context.Background(), "2126079c-8e0a-4cfe-9a0b-583199c14027")
 	require.NoError(t, err)
 	require.NotNil(t, res["testcontainer"])
 }
 
 func TestGetPodContainerCgNumaStats(t *testing.T) {
+	t.Parallel()
 	testPod := &v1.Pod{
 		ObjectMeta: metav1.ObjectMeta{
 			UID:  "2126079c-8e0a-4cfe-9a0b-583199c14027",
@@ -163,7 +168,7 @@ func TestGetPodContainerCgNumaStats(t *testing.T) {
 		},
 	}, func(url string, params map[string]string) ([]byte, error) {
 		return []byte(`{"data":{"da2f6c58a278f9966c2951f3297ed2ac6b8c73cc92460e68f6865bc0448137f0":[{"key":"cgnumastat_filepage","val":5},{"key":"cgnumastat_node0_filepage","val":5}]}}`), nil
-	})
+	}, 9102)
 
 	res, err := ic.GetPodContainerCgNumaStats(context.Background(), "2126079c-8e0a-4cfe-9a0b-583199c14027")
 	require.NoError(t, err)
@@ -173,6 +178,7 @@ func TestGetPodContainerCgNumaStats(t *testing.T) {
 }
 
 func TestGetMetrics(t *testing.T) {
+	t.Parallel()
 	testPod := &v1.Pod{
 		ObjectMeta: metav1.ObjectMeta{
 			UID:  "2126079c-8e0a-4cfe-9a0b-583199c14027",
@@ -192,7 +198,7 @@ func TestGetMetrics(t *testing.T) {
 		GetPodFunc: func(ctx context.Context, podUID string) (*v1.Pod, error) {
 			return testPod, nil
 		},
-	}, nil)
+	}, nil, 9102)
 
 	res, err := ic.GetPodContainerCgNumaStats(context.Background(), "2126079c-8e0a-4cfe-9a0b-583199c14027")
 	require.Error(t, err)
diff --git a/pkg/metaserver/agent/metric/provisioner/rodan/provisioner.go b/pkg/metaserver/agent/metric/provisioner/rodan/provisioner.go
@@ -21,12 +21,12 @@ import (
 	"strconv"
 	"time"
 
-	"github.com/kubewharf/katalyst-core/pkg/config/agent/global"
-
 	v1 "k8s.io/api/core/v1"
 	"k8s.io/apimachinery/pkg/util/wait"
 	"k8s.io/klog/v2"
 
+	"github.com/kubewharf/katalyst-core/pkg/config/agent/global"
+	"github.com/kubewharf/katalyst-core/pkg/config/agent/metaserver"
 	"github.com/kubewharf/katalyst-core/pkg/consts"
 	"github.com/kubewharf/katalyst-core/pkg/metaserver/agent/metric/provisioner/rodan/client"
 	"github.com/kubewharf/katalyst-core/pkg/metaserver/agent/metric/provisioner/rodan/types"
@@ -56,13 +56,14 @@ type RodanMetricsProvisioner struct {
 // NewRodanMetricsProvisioner returns the fetcher that fetch metrics by Inspector client
 func NewRodanMetricsProvisioner(
 	_ *global.BaseConfiguration,
+	metricConf *metaserver.MetricConfiguration,
 	emitter metrics.MetricEmitter,
 	fetcher pod.PodFetcher,
 	metricStore *utilmetric.MetricStore) metrictypes.MetricsProvisioner {
 	return &RodanMetricsProvisioner{
 		metricStore: metricStore,
 		podFetcher:  fetcher,
-		client:      client.NewRodanClient(fetcher, nil),
+		client:      client.NewRodanClient(fetcher, nil, metricConf.RodanServerPort),
 		emitter:     emitter,
 		synced:      false,
 	}
diff --git a/pkg/metaserver/agent/metric/provisioner/rodan/provisioner_test.go b/pkg/metaserver/agent/metric/provisioner/rodan/provisioner_test.go
@@ -33,6 +33,7 @@ import (
 )
 
 func TestSample(t *testing.T) {
+	t.Parallel()
 	testPod := &v1.Pod{
 		ObjectMeta: metav1.ObjectMeta{
 			UID:  "2126079c-8e0a-4cfe-9a0b-583199c14027",
@@ -62,7 +63,7 @@ func TestSample(t *testing.T) {
 	f := &RodanMetricsProvisioner{
 		metricStore: utilmetric.NewMetricStore(),
 		podFetcher:  podFetcher,
-		client:      client.NewRodanClient(podFetcher, makeTestMetricClient()),
+		client:      client.NewRodanClient(podFetcher, makeTestMetricClient(), 9102),
 		emitter:     metrics.DummyMetrics{},
 		synced:      false,
 	}
@@ -199,9 +200,3 @@ func (f *FakePodFetcher) GetPod(ctx context.Context, podUID string) (*v1.Pod, er
 func (f *FakePodFetcher) GetPodList(ctx context.Context, podFilter func(*v1.Pod) bool) ([]*v1.Pod, error) {
 	return f.GetPodListFunc(ctx, podFilter)
 }
-
-func TestT(t *testing.T) {
-	a := 32614152
-	a = a << 10
-	fmt.Println(a)
-}
diff --git a/pkg/metaserver/agent/metric/provisioner/rodan/types/types_test.go b/pkg/metaserver/agent/metric/provisioner/rodan/types/types_test.go

Original file line number	Diff line number	Diff line change
`@@ -233,7 +233,7 @@ func NewMetricsFetcher(baseConf global.BaseConfiguration, metricConf metaserve`
`233`	`233`	`var enabledProvisioners []types.MetricsProvisioner`
`234`	`234`	`for _, name := range metricConf.MetricProvisions {`
`235`	`235`	`if f, ok := registeredProvisioners[name]; ok {`
`236`		`- enabledProvisioners = append(enabledProvisioners, f(baseConf, emitter, podFetcher, metricStore))`
	`236`	`+ enabledProvisioners = append(enabledProvisioners, f(baseConf, metricConf, emitter, podFetcher, metricStore))`
`237`	`237`	`}`
`238`	`238`	`}`
`239`	`239`
Original file line number	Diff line number	Diff line change
`@@ -38,7 +38,7 @@ func init() {`
`38`	`38`	`RegisterProvisioners(metaserver.MetricProvisionerRodan, rodan.NewRodanMetricsProvisioner)`
`39`	`39`	`}`
`40`	`40`
`41`		`-type ProvisionerInitFunc func(baseConf *global.BaseConfiguration,`
	`41`	`+type ProvisionerInitFunc func(baseConf global.BaseConfiguration, metricConf metaserver.MetricConfiguration,`
`42`	`42`	`emitter metrics.MetricEmitter, fetcher pod.PodFetcher, metricStore *utilmetric.MetricStore) types.MetricsProvisioner`
`43`	`43`
`44`	`44`	`// provisioners stores the initializing function for each-provisioner`
Original file line number	Diff line number	Diff line change
`@@ -33,10 +33,10 @@ type RodanClient struct {`
`33`	`33`	`metricFunc MetricFunc`
`34`	`34`	`}`
`35`	`35`
`36`		`-func NewRodanClient(fetcher pod.PodFetcher, metricFunc MetricFunc) *RodanClient {`
	`36`	`+func NewRodanClient(fetcher pod.PodFetcher, metricFunc MetricFunc, port int) *RodanClient {`
`37`	`37`	`urls := make(map[string]string)`
`38`	`38`	`for path := range types.MetricsMap {`
`39`		`- urls[path] = fmt.Sprintf("http://localhost:%d%s", types.RodanServerPort, path)`
	`39`	`+ urls[path] = fmt.Sprintf("http://localhost:%d%s", port, path)`
`40`	`40`	`}`
`41`	`41`
`42`	`42`	`if metricFunc == nil {`