1 defmodule Pleroma.Elasticsearch do
3 alias Pleroma.Elasticsearch.DocumentMappings
6 Pleroma.Config.get([:elasticsearch, :url])
9 def put(%Activity{} = activity) do
10 Elastix.Document.index(
14 DocumentMappings.Activity.id(activity),
15 DocumentMappings.Activity.encode(activity)
19 def bulk_post(data, :activities) do
23 %{index: %{_id: DocumentMappings.Activity.id(d)}},
24 DocumentMappings.Activity.encode(d)
29 IO.inspect Elastix.Bulk.post(