Revert "Added processor for pg_stat_statements"

This reverts commit 48d3538.
ankane · Apr 18, 2023 · cfdf1ec · cfdf1ec
1 parent 48d3538
commit cfdf1ec
Show file tree

Hide file tree

Showing 4 changed files with 2 additions and 11 deletions.
diff --git a/lib/dexter.rb b/lib/dexter.rb
@@ -23,7 +23,6 @@
 require_relative "dexter/csv_log_parser"
 require_relative "dexter/json_log_parser"
 require_relative "dexter/pg_stat_activity_parser"
-require_relative "dexter/pg_stat_statements_parser"
 require_relative "dexter/sql_log_parser"
 require_relative "dexter/stderr_log_parser"
 

diff --git a/lib/dexter/client.rb b/lib/dexter/client.rb
@@ -23,7 +23,8 @@ def perform
  query = Query.new(options[:statement])
  Indexer.new(options).process_queries([query])
  elsif options[:pg_stat_statements]
- Processor.new(:pg_stat_statements, options).perform
+ # TODO support streaming option
+ Indexer.new(options).process_stat_statements
  elsif options[:pg_stat_activity]
  Processor.new(:pg_stat_activity, options).perform
  elsif arguments.any?

diff --git a/lib/dexter/pg_stat_statements_parser.rb b/lib/dexter/pg_stat_statements_parser.rb
diff --git a/lib/dexter/processor.rb b/lib/dexter/processor.rb
@@ -11,8 +11,6 @@ def initialize(logfile, options)
  @log_parser =
  if @logfile == :pg_stat_activity
  PgStatActivityParser.new(@indexer, @collector)
- elsif @logfile == :pg_stat_statements
- PgStatStatementsParser.new(@indexer, @collector)
  elsif options[:input_format] == "csv"
  CsvLogParser.new(logfile, @collector)
  elsif options[:input_format] == "json"