feat: libgse 支持 monitoring 定制化方案 --story=120460837 (#600)

.gtmproject.yaml

@@ -26,4 +26,5 @@ project:
     - sliwebhook
     - influxdbproxy
     - influxdb
+    - libgse
   reviewers: [ ]

pkg/libgse/output/bkpush/bkpush.go

@@ -22,7 +22,9 @@ import (
 	"github.com/elastic/beats/libbeat/publisher"
 	"github.com/spf13/cast"
 
+	gseinfo "github.com/TencentBlueKing/bkmonitor-datalink/pkg/libgse/gse"
 	"github.com/TencentBlueKing/bkmonitor-datalink/pkg/libgse/logp"
+	"github.com/TencentBlueKing/bkmonitor-datalink/pkg/libgse/monitoring/report/bkpipe"
 	"github.com/TencentBlueKing/bkmonitor-datalink/pkg/libgse/output/gse"
 )
 
@@ -120,6 +122,7 @@ func New(cfg *common.Config) (*Output, error) {
 		go o.loopHandle()
 	}
 
+	bkpipe.InitSender(o, gseinfo.AgentInfo{}) // TODO(mando): 兼容 bkpipe 自定义指标上报 ┓(=´∀`=)┏
 	return o, nil
 }
 
@@ -128,6 +131,21 @@ func (o *Output) Close() error {
 	return nil
 }
 
+func (o *Output) Report(dataid int32, data common.MapStr) error {
+	r := &Record{
+		DataID: dataid,
+		Data:   data,
+	}
+
+	select {
+	case o.ch <- r:
+	case <-o.stop:
+		return nil
+	}
+
+	return nil
+}
+
 func (o *Output) String() string { return outputType }
 
 func (o *Output) Publish(batch publisher.Batch) error {