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)
38 Elastix.Search.search(
42 %{query: %{term: %{content: query}}}