Class: Pgbus::Generators::AddStreamQueuesGenerator

Inherits:
Rails::Generators::Base
  • Object
show all
Includes:
ActiveRecord::Generators::Migration, MigrationPath
Defined in:
lib/generators/pgbus/add_stream_queues_generator.rb

Instance Method Summary collapse

Instance Method Details

#create_migration_file ⇒ Object 



23
24
25
26
 
# File 'lib/generators/pgbus/add_stream_queues_generator.rb', line 23

def create_migration_file
  migration_template "add_stream_queues.rb.erb",
                     File.join(pgbus_migrate_path, "add_pgbus_stream_queues.rb")
end

#display_post_install ⇒ Object 



28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
 
# File 'lib/generators/pgbus/add_stream_queues_generator.rb', line 28

def display_post_install
  say ""
  say "Pgbus stream queue registry installed!", :green
  say ""
  say "Without this table, stream queues are indistinguishable from job"
  say "queues: per-stream archive retention and the orphan sweep skip them,"
  say "and wildcard ('*') workers can claim durable broadcasts. Active"
  say "streams register themselves on their next broadcast after migrating."
  say "Dormant durable streams (completed checkout flows, ended chats) never"
  say "broadcast again, but doctor / orphan sweep / wildcard workers already"
  say "see them via the archive-index fingerprint (known_names). Backfill"
  say "persists those names in the registry and clears the doctor DEGRADED"
  say "hint (issue #366)."
  say ""
  say "Next steps:"
  say "  1. Run: rails db:migrate#{migrate_command_suffix}"
  say "  2. Backfill dormant streams: rake pgbus:streams:backfill_registry"
  say "  3. Restart pgbus: bin/pgbus start"
  say ""
end