add metricstore send support

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) {

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 {