Repository URL to install this package:
|
Version:
0.1.0.0 ▾
|
module EntitySnapshot
class Postgres
module Controls
module Write
def self.batch(stream_name: nil, category: nil, count: nil, starting_number: nil)
stream_name ||= Controls::StreamName.example(category: category)
writer = ::Messaging::Postgres::Write.build
batch = Batch.example(count: count, starting_number: starting_number)
writer.write(batch, stream_name)
stream_name
end
end
end
end
end