summaryrefslogtreecommitdiff
path: root/benchmarks/load_testing/generator.ex
diff options
context:
space:
mode:
authorMaksim Pechnikov <parallel588@gmail.com>2019-11-19 21:11:15 +0300
committerMaksim Pechnikov <parallel588@gmail.com>2019-11-19 21:11:15 +0300
commit1fcd579b6d8c26557dcc6f9d3c9f247d03e7b5a4 (patch)
tree6c8f6ba88bd4801849f5c639ca942139102eecc4 /benchmarks/load_testing/generator.ex
parentbf89e0bf38d9709f6dd331f5d9b326575994423d (diff)
downloadpleroma-1fcd579b6d8c26557dcc6f9d3c9f247d03e7b5a4.tar.gz
pleroma-1fcd579b6d8c26557dcc6f9d3c9f247d03e7b5a4.zip
benchmarks/ added favourites timeline
Diffstat (limited to 'benchmarks/load_testing/generator.ex')
-rw-r--r--benchmarks/load_testing/generator.ex18
1 files changed, 18 insertions, 0 deletions
diff --git a/benchmarks/load_testing/generator.ex b/benchmarks/load_testing/generator.ex
index b4432bdb7..f42fd363e 100644
--- a/benchmarks/load_testing/generator.ex
+++ b/benchmarks/load_testing/generator.ex
@@ -2,6 +2,24 @@ defmodule Pleroma.LoadTesting.Generator do
use Pleroma.LoadTesting.Helper
alias Pleroma.Web.CommonAPI
+ def generate_like_activities(user, posts) do
+ count_likes = Kernel.trunc(length(posts) / 4)
+ IO.puts("Starting generating #{count_likes} like activities...")
+
+ {time, _} =
+ :timer.tc(fn ->
+ Task.async_stream(
+ Enum.take_random(posts, count_likes),
+ fn post -> {:ok, _, _} = CommonAPI.favorite(post.id, user) end,
+ max_concurrency: 10,
+ timeout: 30_000
+ )
+ |> Stream.run()
+ end)
+
+ IO.puts("Inserting like activities take #{to_sec(time)} sec.\n")
+ end
+
def generate_users(opts) do
IO.puts("Starting generating #{opts[:users_max]} users...")
{time, _} = :timer.tc(fn -> do_generate_users(opts) end)