controller.go 592 B

123456789101112131415
  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(clusterId string, store storage.Storage, service diagnostics.DiagnosticService) *exporter.EventExportController[diagnostics.DiagnosticsRunReport] {
  9. return exporter.NewEventExportController(
  10. NewDiagnosticSource(service),
  11. NewDiagnosticExporter(clusterId, store),
  12. )
  13. }