Method Export

engine/server/telemetry.go:450–476

(ctx context.Context, logs []sdklog.Record)

var _ sdklog.Exporter = clientLogs{}

func (ps clientLogs) Export(ctx context.Context, logs []sdklog.Record) error {
	slog.ExtraDebug("pubsub exporting logs", "client", ps.client.clientID, "count", len(logs))

	var inserts []*clientdb.InsertLogParams
	for _, rec := range logs {
		insert, err := insertLogRecordParam(&rec)
		if err != nil {
			return fmt.Errorf("prepare log record %v: %w", rec, err)
		}
		inserts = append(inserts, insert)
	}

	db, err := ps.client.TelemetryDB(ctx)
	if err != nil {
		return fmt.Errorf("get telemetry db: %w", err)
	}
	defer db.Close()

	for _, insert := range inserts {
		if _, err := db.InsertLog(ctx, *insert); err != nil {
			slog.Warn("failed to insert log record", "error", err)
			continue
		}
	}

	return nil
}

func (ps clientLogs) Enabled(context.Context, sdklog.EnabledParameters) bool { return true }
func (ps clientLogs) ForceFlush(ctx context.Context) error                   { return nil }