pub fn log_query(
  db_state: state.DbState,
  ctx: state.QueryContext,
  reply: process.Subject(Nil),
) -> actor.Next(state.DbState, msg)

pub fn register_composite(
  db_state: state.DbState,
  attrs: List(String),
  has_violations: Bool,
  reply_to: process.Subject(Result(Nil, String)),
) -> actor.Next(state.DbState, msg)

pub fn register_function(
  db_state: state.DbState,
  name: String,
  func: fn(state.DbState, Int, Int, List(fact.Value)) -> List(
    #(fact.Eid, String, fact.Value),
  ),
  reply_to: process.Subject(Nil),
) -> actor.Next(state.DbState, msg)

pub fn register_predicate(
  db_state: state.DbState,
  name: String,
  pred: fn(fact.Value) -> Bool,
  reply_to: process.Subject(Nil),
) -> actor.Next(state.DbState, msg)

pub fn set_config(
  db_state: state.DbState,
  config: state.Config,
  reply_to: process.Subject(Nil),
) -> actor.Next(state.DbState, msg)

pub fn set_schema(
  db_state: state.DbState,
  attr: String,
  config: fact.AttributeConfig,
  error: option.Option(String),
  reply_to: process.Subject(Result(Nil, String)),
) -> actor.Next(state.DbState, msg)

pub fn store_rule(
  db_state: state.DbState,
  rule: ast.Rule,
  reply_to: process.Subject(Result(Nil, String)),
  compute_next_state: fn(
    state.DbState,
    List(#(fact.Eid, String, fact.Value)),
    option.Option(Int),
    fact.Operation,
  ) -> Result(#(state.DbState, List(fact.Datom)), String),
) -> actor.Next(state.DbState, msg)

pub fn subscribe(
  db_state: state.DbState,
  reply_to: process.Subject(List(fact.Datom)),
) -> actor.Next(state.DbState, msg)