add metricstore send support

aliyun · Mar 27, 2024 · 95b255f · 95b255f
1 parent cd4fc76
commit 95b255f
Showing 1 changed file with 10 additions and 10 deletions.
diff --git a/producer/producer.go b/producer/producer.go
@@ -134,7 +134,7 @@ func (producer *Producer) HashSendLogWithCallBack(project, logstore, shardHash,
 			return err
 		}
 	}
-	return producer.logAccumulator.addLogToProducerBatch(project, logstore, shardHash, topic, source, log, callback, false)
+	return producer.logAccumulator.addLogToProducerBatch(project, logstore, shardHash, topic, source, log, callback)
 }
 
 func (producer *Producer) HashSendLogListWithCallBack(project, logstore, shardHash, topic, source string, logList []*sls.Log, callback CallBack) (err error) {
@@ -149,15 +149,15 @@ func (producer *Producer) HashSendLogListWithCallBack(project, logstore, shardHa
 			return err
 		}
 	}
-	return producer.logAccumulator.addLogToProducerBatch(project, logstore, shardHash, topic, source, logList, callback, false)
+	return producer.logAccumulator.addLogToProducerBatch(project, logstore, shardHash, topic, source, logList, callback)
 }
 
 func (producer *Producer) SendLog(project, logstore, topic, source string, log *sls.Log) error {
 	err := producer.waitTime()
 	if err != nil {
 		return err
 	}
-	return producer.logAccumulator.addLogToProducerBatch(project, logstore, "", topic, source, log, nil, false)
+	return producer.logAccumulator.addLogToProducerBatch(project, logstore, "", topic, source, log, nil)
 }
 
 func (producer *Producer) SendLogList(project, logstore, topic, source string, logList []*sls.Log) (err error) {
@@ -166,7 +166,7 @@ func (producer *Producer) SendLogList(project, logstore, topic, source string, l
 		return err
 	}
 
-	return producer.logAccumulator.addLogToProducerBatch(project, logstore, "", topic, source, logList, nil, false)
+	return producer.logAccumulator.addLogToProducerBatch(project, logstore, "", topic, source, logList, nil)
 
 }
 
@@ -175,15 +175,15 @@ func (producer *Producer) SendMetricStoreLogWithCallBack(project, logstore, topi
 	if err != nil {
 		return err
 	}
-	return producer.logAccumulator.addLogToProducerBatch(project, logstore, "", topic, source, log, callback, true)
+	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, true)
+	return producer.logAccumulator.addLogToProducerBatch(project, logstore, "", topic, source, logList, callback)
 
 }
 
@@ -198,7 +198,7 @@ func (producer *Producer) HashSendLog(project, logstore, shardHash, topic, sourc
 			return err
 		}
 	}
-	return producer.logAccumulator.addLogToProducerBatch(project, logstore, shardHash, topic, source, log, nil, false)
+	return producer.logAccumulator.addLogToProducerBatch(project, logstore, shardHash, topic, source, log, nil)
 }
 
 func (producer *Producer) HashSendLogList(project, logstore, shardHash, topic, source string, logList []*sls.Log) (err error) {
@@ -212,7 +212,7 @@ func (producer *Producer) HashSendLogList(project, logstore, shardHash, topic, s
 			return err
 		}
 	}
-	return producer.logAccumulator.addLogToProducerBatch(project, logstore, shardHash, topic, source, logList, nil, false)
+	return producer.logAccumulator.addLogToProducerBatch(project, logstore, shardHash, topic, source, logList, nil)
 
 }
 
@@ -221,15 +221,15 @@ func (producer *Producer) SendLogWithCallBack(project, logstore, topic, source s
 	if err != nil {
 		return err
 	}
-	return producer.logAccumulator.addLogToProducerBatch(project, logstore, "", topic, source, log, callback, false)
+	return producer.logAccumulator.addLogToProducerBatch(project, logstore, "", topic, source, log, callback)
 }
 
 func (producer *Producer) SendLogListWithCallBack(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, false)
+	return producer.logAccumulator.addLogToProducerBatch(project, logstore, "", topic, source, logList, callback)
 
 }