From 303336f28c32daa4fd865d7d4d2617117bdd3ca9 Mon Sep 17 00:00:00 2001
From: evanljp <evanljp@outlook.com>
Date: Wed, 27 Mar 2024 15:01:20 +0800
Subject: [PATCH] add metricstore send support

---
 log_store.go         |  6 +-----
 producer/producer.go | 17 -----------------
 2 files changed, 1 insertion(+), 22 deletions(-)

diff --git a/log_store.go b/log_store.go
index 401d69e9..87f90465 100644
--- a/log_store.go
+++ b/log_store.go
@@ -306,7 +306,7 @@ func (s *LogStore) PutLogs(lg *LogGroup) (err error) {
 	}
 	var uri string
 	if s.MetricStore {
-		uri = s.getMetricStoreURL()
+		uri = fmt.Sprintf("/prometheus/%s/%s/api/v1/write", s.project.Name, s.Name)
 	} else {
 		uri = fmt.Sprintf("/logstores/%v", s.Name)
 	}
@@ -326,10 +326,6 @@ func (s *LogStore) PutLogs(lg *LogGroup) (err error) {
 	return nil
 }
 
-func (s *LogStore) getMetricStoreURL() string {
-	return fmt.Sprintf("/prometheus/%s/%s/api/v1/write", s.project.Name, s.Name)
-}
-
 // PostLogStoreLogs put logs into Shard logstore by hashKey.
 // The callers should transform user logs into LogGroup.
 func (s *LogStore) PostLogStoreLogs(lg *LogGroup, hashKey *string) (err error) {
diff --git a/producer/producer.go b/producer/producer.go
index 181dc102..71376acb 100644
--- a/producer/producer.go
+++ b/producer/producer.go
@@ -170,23 +170,6 @@ func (producer *Producer) SendLogList(project, logstore, topic, source string, l
 
 }
 
-func (producer *Producer) SendMetricStoreLogWithCallBack(project, logstore, topic, source string, log *sls.Log, callback CallBack) error {
-	err := producer.waitTime()
-	if err != nil {
-		return err
-	}
-	return producer.logAccumulator.addLogToProducerBatch(project, logstore, "", topic, source, log, callback)
-}
-
-func (producer *Producer) SendMetricStoreLogListWithCallBack(project, logstore, topic, source string, logList []*sls.Log, callback CallBack) (err error) {
-	err = producer.waitTime()
-	if err != nil {
-		return err
-	}
-	return producer.logAccumulator.addLogToProducerBatch(project, logstore, "", topic, source, logList, callback)
-
-}
-
 func (producer *Producer) HashSendLog(project, logstore, shardHash, topic, source string, log *sls.Log) error {
 	err := producer.waitTime()
 	if err != nil {