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
24 %{index: %{_id: DocumentMappings.Activity.id(d)}},
25 DocumentMappings.Activity.encode(d)
38 def search_activities(q) do
39 Elastix.Search.search(