Sha256: 0273492cc2930262822de08a9b342196204d7e16e0164607845f3b788a8e14d0
Contents?: true
Size: 1.74 KB
Versions: 2
Compression:
Stored size: 1.74 KB
Contents
class CreateEventStore < ActiveRecord::Migration<%= migration_version %> def change create_table "event_records", :force => :cascade do |t| t.string "aggregate_id", null: false t.integer "sequence_number", null: false t.string "event_type", null: false t.text "event_json", null: false t.integer "command_record_id", null: false t.integer "stream_record_id", null: false t.datetime "created_at", null: false unless ActiveRecord::Base.connection.instance_of? ActiveRecord::ConnectionAdapters::SQLite3Adapter t.index "aggregate_id, sequence_number, (\nCASE event_type\n WHEN \"Sequent::Core::SnapshotEvent\"::text THEN 0\n ELSE 1\nEND)", name: "unique_event_per_aggregate", unique: true t.index ["aggregate_id", "sequence_number"], name: "snapshot_events", order: { sequence_number: :desc }, where: "((event_type)::text = \"Sequent::Core::SnapshotEvent\"::text)" end t.index ["command_record_id"], name: "index_event_records_on_command_record_id" t.index ["created_at"], name: "index_event_records_on_created_at" t.index ["event_type"], name: "index_event_records_on_event_type" end create_table "command_records", force: :cascade do |t| t.string "user_id" t.string "aggregate_id" t.string "command_type", null: false t.text "command_json", null: false t.datetime "created_at", null: false end create_table "stream_records", force: :cascade do |t| t.string "aggregate_type", null: false t.string "aggregate_id", null: false t.integer "snapshot_threshold" t.datetime "created_at", null: false t.index ["aggregate_id"], name: "index_stream_records_on_aggregate_id", unique: true end end end
Version data entries
2 entries across 2 versions & 1 rubygems
Version | Path |
---|---|
sequent-rails-0.1.1 | lib/generators/templates/db/create_event_store.rb |
sequent-rails-0.1.0 | lib/generators/templates/db/create_event_store.rb |