add CreateMetricStore

aliyun · Jun 20, 2022 · 81651ad · 81651ad
1 parent 14bb326
commit 81651ad
Show file tree

Hide file tree

Showing 4 changed files with 10 additions and 10 deletions.
diff --git a/client_interface.go b/client_interface.go
@@ -96,9 +96,9 @@ type ClientInterface interface {
 
 	// #################### MetricStore Operations #####################
 	// CreateMetricStore creates a new metric store in SLS.
-	CreateMetricStore(project string, metricStore LogStore) error
+	CreateMetricStore(project string, metricStore *LogStore) error
 	// UpdateMetricStore updates a metric store.
-	UpdateMetricStore(project string, metricStore LogStore) error
+	UpdateMetricStore(project string, metricStore *LogStore) error
 	// DeleteMetricStore deletes a metric store.
 	DeleteMetricStore(project, name string) error
 	// GetMetricStore return a metric store.

diff --git a/client_metric_store.go b/client_metric_store.go
@@ -3,9 +3,9 @@ package sls
 import "time"
 
 // CreateMetricStore .
-func (c *Client) CreateMetricStore(project string, metricStore LogStore) error {
+func (c *Client) CreateMetricStore(project string, metricStore *LogStore) error {
 	metricStore.TelemetryType = "Metrics"
-	err := c.CreateLogStoreV2(project, &metricStore)
+	err := c.CreateLogStoreV2(project, metricStore)
 	if err != nil {
 		return err
 	}
@@ -35,9 +35,9 @@ func (c *Client) CreateMetricStore(project string, metricStore LogStore) error {
 }
 
 // UpdateMetricStore .
-func (c *Client) UpdateMetricStore(project string, metricStore LogStore) error {
+func (c *Client) UpdateMetricStore(project string, metricStore *LogStore) error {
 	metricStore.TelemetryType = "Metrics"
-	err := c.UpdateLogStoreV2(project, &metricStore)
+	err := c.UpdateLogStoreV2(project, metricStore)
 	if err != nil {
 		return err
 	}

diff --git a/client_metric_store_test.go b/client_metric_store_test.go
@@ -49,7 +49,7 @@ func (m *MetricStoreTestSuite) TearDownSuite() {
 }
 
 func (m *MetricStoreTestSuite) TestClient_CreateAndDeleteMetricStore() {
-	metricStore := LogStore{
+	metricStore := &LogStore{
 		Name:       m.metricStoreName,
 		TTL:        m.ttl,
 		ShardCount: m.shardCnt,
@@ -61,7 +61,7 @@ func (m *MetricStoreTestSuite) TestClient_CreateAndDeleteMetricStore() {
 }
 
 func (m *MetricStoreTestSuite) TestClient_UpdateAndGetMetricStore() {
-	metricStore1 := LogStore{
+	metricStore1 := &LogStore{
 		Name:       m.metricStoreName,
 		TTL:        m.ttl,
 		ShardCount: m.shardCnt,

diff --git a/token_auto_update_client.go b/token_auto_update_client.go
@@ -1549,7 +1549,7 @@ func (c *TokenAutoUpdateClient) DeleteExport(project string, name string) (err e
 	}
 	return
 }
-func (c *TokenAutoUpdateClient) CreateMetricStore(project string, metricStore LogStore) (err error) {
+func (c *TokenAutoUpdateClient) CreateMetricStore(project string, metricStore *LogStore) (err error) {
 	for i := 0; i < c.maxTryTimes; i++ {
 		err = c.logClient.CreateMetricStore(project, metricStore)
 		if !c.processError(err) {
@@ -1558,7 +1558,7 @@ func (c *TokenAutoUpdateClient) CreateMetricStore(project string, metricStore Lo
 	}
 	return
 }
-func (c *TokenAutoUpdateClient) UpdateMetricStore(project string, metricStore LogStore) (err error) {
+func (c *TokenAutoUpdateClient) UpdateMetricStore(project string, metricStore *LogStore) (err error) {
 	for i := 0; i < c.maxTryTimes; i++ {
 		err = c.logClient.UpdateMetricStore(project, metricStore)
 		if !c.processError(err) {