Skip to content

Commit

Permalink
fix: fixed exporter not return as result
Browse files Browse the repository at this point in the history
  • Loading branch information
jiekun authored and Nick-0314 committed Aug 22, 2023
1 parent 457c6e5 commit c5bfb29
Showing 1 changed file with 5 additions and 1 deletion.
6 changes: 5 additions & 1 deletion server/ingester/flow_log/exporter/exporter.go
Expand Up @@ -3,8 +3,11 @@ package exporter
import (
"github.com/deepflowio/deepflow/server/ingester/config"
otlp_exporter "github.com/deepflowio/deepflow/server/ingester/flow_log/exporter/otlp_exporter"
"github.com/op/go-logging"
)

var log = logging.MustGetLogger("exporter")

type Exporter interface {
// Start starts an exporter worker
Start()
Expand All @@ -19,11 +22,12 @@ type Exporter interface {
}

func NewExporters(exportersCfg []ExporterCfg, baseCfg *config.Config) []Exporter {
log.Infof("Init Exporters: %v", exportersCfg)
exporters := make([]Exporter, 0, len(exportersCfg))
for i := range exportersCfg {
switch exportersCfg[i].Type {
case OtlpExporter:
otlp_exporter.NewOtlpExporter(&exportersCfg[i].OtlpExporter, baseCfg)
exporters = append(exporters, otlp_exporter.NewOtlpExporter(&exportersCfg[i].OtlpExporter, baseCfg))
default:

}
Expand Down

0 comments on commit c5bfb29

Please sign in to comment.