defmodule Baz.NormalizedSinks.Timescale do
alias Baz.Repo
@behaviour Baz.CollectionPackSink
@behaviour Baz.CollectionSink
@behaviour Baz.CollectionTraitSink
@behaviour Baz.CollectionAssetSink
@behaviour Baz.CollectionAssetTraitSink
@behaviour Baz.CollectionEventSink
@impl true
def receive_collection_pack_import(changeset) do
Repo.insert(changeset, on_conflict: :nothing)
end
@impl true
def receive_collection_pack_stream(changeset) do
Repo.insert(changeset, on_conflict: :nothing)
end
@impl true
def receive_collection_import(changeset) do
Repo.insert(changeset, on_conflict: :nothing)
end
@impl true
def receive_collection_stream(changeset) do
Repo.insert(changeset, on_conflict: :nothing)
end
@impl true
def receive_collection_trait_import(changeset) do
Repo.insert(changeset, on_conflict: :nothing)
end
@impl true
def receive_collection_trait_stream(changeset) do
Repo.insert(changeset, on_conflict: :nothing)
end
@impl true
def receive_collection_asset_import(multi) do
Repo.transaction(multi)
end
@impl true
def receive_collection_asset_stream(changeset) do
Repo.insert(changeset, on_conflict: :nothing)
end
@impl true
def receive_collection_asset_trait_import(changeset) do
Repo.insert(changeset, on_conflict: :nothing)
end
@impl true
def receive_collection_asset_trait_stream(changeset) do
Repo.insert(changeset, on_conflict: :nothing)
end
@impl true
def receive_collection_event_import(multi) do
Repo.transaction(multi)
end
@impl true
def receive_collection_event_stream(changeset) do
Repo.insert(changeset, on_conflict: :nothing)
end
end