AshClickhouse.Repo behaviour (AshClickhouse v0.6.2)

Configuration module for AshClickhouse.

Define a repo in your application and add it to your supervision tree:

defmodule MyApp.Repo do
  use AshClickhouse.Repo, otp_app: :my_app
end

Then configure it in config/config.exs:

config :my_app, MyApp.Repo,
  url: "http://localhost:8123",
  database: "my_app_dev"

Options

:url — ClickHouse HTTP URL (default "http://localhost:8123")
:username / :password — credentials (default "default" / "")
:database — default database name
:pool_size — size of the connection pool (default 10)
:ipv4_only — resolve the URL host to an IPv4 address and connect to that literal IP (default false). Set to true when the DNS server returns NXDOMAIN for AAAA queries, which otherwise surfaces as a ClickHouse.ConnectionError with message "nxdomain".

config()

config()

connection()

database()

otp_app()

Converts repo config to ClickHouse connection options.

@type config() :: keyword()

@callback child_spec(keyword()) :: Supervisor.child_spec()

@callback config() :: keyword()

@callback connection() :: AshClickhouse.Connection.t() | nil

@callback create_database(String.t() | nil) :: {:ok, term()} | {:error, term()}

@callback database() :: String.t() | nil

@callback drop_database(String.t() | nil) :: {:ok, term()} | {:error, term()}

@callback insert_rows(String.t(), String.t(), [list()], keyword()) ::
  {:ok, term()} | {:error, term()}

@callback otp_app() :: atom() | nil

@spec config_to_conn_opts(module()) :: keyword()

Converts repo config to ClickHouse connection options.