controller.go 640 B

1234567891011121314151617181920
  1. package exporter
  2. import (
  3. "github.com/opencost/opencost/core/pkg/diagnostics"
  4. "github.com/opencost/opencost/core/pkg/exporter"
  5. "github.com/opencost/opencost/core/pkg/storage"
  6. )
  7. // NewDiagnosticsExportController creates a new EventExportController for DiagnosticsRunReport events.
  8. func NewDiagnosticsExportController(
  9. clusterId string,
  10. applicationName string,
  11. store storage.Storage,
  12. service diagnostics.DiagnosticService,
  13. ) *exporter.EventExportController[diagnostics.DiagnosticsRunReport] {
  14. return exporter.NewEventExportController(
  15. NewDiagnosticSource(service),
  16. NewDiagnosticExporter(clusterId, applicationName, store),
  17. )
  18. }