AshScylla.Repo behaviour (AshScylla v0.10.0)

Configuration module for AshScylla using direct Xandra connections.

Usage

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

Then configure it in config/config.exs:

config :my_app, MyApp.Repo,
  nodes: ["127.0.0.1:9042"],
  keyspace: "my_app_dev"

children = [
  MyApp.Repo,
  # ...
]

config()

connection()

keyspace()

nodes()

Converts repo config to Xandra connection options.

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

@callback config() :: keyword()

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

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

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

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

@callback nodes() :: [String.t()]

@callback prepare(
  String.t(),
  keyword()
) :: {:ok, Xandra.Prepared.t()} | {:error, term()}

@callback prepare!(
  String.t(),
  keyword()
) :: Xandra.Prepared.t() | no_return()

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

@callback query!(String.t(), list(), keyword()) :: term() | no_return()

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

Converts repo config to Xandra connection options.