class StatelyDB::Transaction::Transaction

def initialize(stub:, store_id:, schema:)

Parameters:
  • schema (Module) -- the generated Schema module to use for mapping StatelyDB Items.
  • store_id (Integer) -- the StatelyDB Store to transact against
  • stub (::Stately::Db::DatabaseService::Stub) -- a StatelyDB gRPC stub
def initialize(stub:, store_id:, schema:)
  @stub = stub
  @store_id = store_id
  @schema = schema
  @is_transaction_open = false
  # A queue of outbound requests
  @outgoing_requests = StatelyDB::Transaction::Queue.new
end