Packages

taskafka

0.0.8
0.1.1 0.1.0 0.0.13 0.0.12 0.0.11 0.0.10 0.0.9 0.0.8 0.0.7 0.0.6 0.0.5 0.0.4 0.0.3 0.0.2 0.0.1

TasKafka is a background processing application written in Elixir and uses Kafka as a messaging backend.

HexDocs

Current section

Files

Jump to
Readme
15 Versions
6 Dependencies
Dependants
Files
Activity
taskafka lib taskafka mix tasks drop.ex
Raw

lib/taskafka/mix/tasks/drop.ex 

defmodule Mix.Tasks.Drop do

  @moduledoc false



  use Mix.Task

  alias TasKafka.Mongo

  require Logger



  def run(_) do

    {:ok, _} = Application.ensure_all_started(:mongodb)



    {:ok, pid} =

      Mongo.start_link(

        name: :taskafka_mongo,

        url: Application.get_env(:taskafka, :mongo)[:url],

        pool: DBConnection.Poolboy

      )



    Mongo.command!(dropDatabase: 1)

    Logger.info(IO.ANSI.green() <> "Database dropped" <> IO.ANSI.default_color())



    GenServer.stop(pid)

  end

end