You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
72 lines
1.7 KiB
72 lines
1.7 KiB
// Copyright 2023 William Perron. All rights reserved. MIT License.
|
|
package sqliteexporter
|
|
|
|
import (
|
|
"context"
|
|
"database/sql"
|
|
_ "embed"
|
|
"fmt"
|
|
|
|
"go.opentelemetry.io/collector/component"
|
|
"go.opentelemetry.io/collector/consumer"
|
|
"go.opentelemetry.io/collector/exporter"
|
|
"go.opentelemetry.io/collector/exporter/exporterhelper"
|
|
"go.wperron.io/sqliteexporter/internal/metadata"
|
|
)
|
|
|
|
//go:embed migrations/20240120195122_init.up.sql
|
|
var initScript string
|
|
|
|
func NewFactory() exporter.Factory {
|
|
return exporter.NewFactory(
|
|
metadata.Type,
|
|
createDefaultConfig,
|
|
exporter.WithTraces(createTracesExporter, metadata.TracesStability),
|
|
exporter.WithMetrics(nil, metadata.MetricsStability),
|
|
exporter.WithLogs(nil, metadata.LogsStability),
|
|
)
|
|
}
|
|
|
|
func createDefaultConfig() component.Config {
|
|
return &Config{}
|
|
}
|
|
|
|
func createTracesExporter(
|
|
ctx context.Context,
|
|
set exporter.CreateSettings,
|
|
cfg component.Config,
|
|
) (exporter.Traces, error) {
|
|
conf := cfg.(*Config)
|
|
|
|
se, err := newSqliteExporter(conf)
|
|
if err != nil {
|
|
return nil, fmt.Errorf("failed to create sqlite exporter: %w", err)
|
|
}
|
|
|
|
return exporterhelper.NewTracesExporter(
|
|
ctx, set, cfg,
|
|
se.ConsumeTraces,
|
|
exporterhelper.WithStart(se.Start),
|
|
exporterhelper.WithShutdown(se.Shutdown),
|
|
exporterhelper.WithCapabilities(consumer.Capabilities{MutatesData: false}),
|
|
)
|
|
}
|
|
|
|
func newSqliteExporter(cfg *Config) (*sqliteExporter, error) {
|
|
db, err := sql.Open("sqlite3", cfg.Path)
|
|
if err != nil {
|
|
return nil, fmt.Errorf("couldn't open sqlite3 database: %w", err)
|
|
}
|
|
|
|
tx, _ := db.Begin()
|
|
defer tx.Commit()
|
|
|
|
if _, err := tx.Exec(initScript); err != nil {
|
|
return nil, fmt.Errorf("failed to run migrations: %w", err)
|
|
}
|
|
|
|
return &sqliteExporter{
|
|
db: db,
|
|
}, nil
|
|
}
|