bindings/elixir/lib/fluss/native.ex

# Licensed to the Apache Software Foundation (ASF) under one
# or more contributor license agreements.  See the NOTICE file
# distributed with this work for additional information
# regarding copyright ownership.  The ASF licenses this file
# to you under the Apache License, Version 2.0 (the
# "License"); you may not use this file except in compliance
# with the License.  You may obtain a copy of the License at
#
#   http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing,
# software distributed under the License is distributed on an
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
# KIND, either express or implied.  See the License for the
# specific language governing permissions and limitations
# under the License.

defmodule Fluss.Native do
  @moduledoc false
  # Release only when packaging for prod; debug keeps dev/test compiles fast.
  use Rustler,
    otp_app: :fluss,
    crate: "fluss_nif",
    mode: if(Mix.env() == :prod, do: :release, else: :debug)

  # Connection
  def connection_new(_config), do: :erlang.nif_error(:nif_not_loaded)

  # Admin
  def admin_new(_conn), do: :erlang.nif_error(:nif_not_loaded)

  def admin_get_server_nodes(_admin), do: :erlang.nif_error(:nif_not_loaded)

  def admin_create_database(_admin, _name, _descriptor, _ignore_if_exists),
    do: :erlang.nif_error(:nif_not_loaded)

  def admin_get_database_info(_admin, _database_name), do: :erlang.nif_error(:nif_not_loaded)

  def admin_drop_database(_admin, _name, _ignore_if_not_exists),
    do: :erlang.nif_error(:nif_not_loaded)

  def admin_list_databases(_admin), do: :erlang.nif_error(:nif_not_loaded)

  def admin_database_exists(_admin, _database_name), do: :erlang.nif_error(:nif_not_loaded)

  def admin_create_table(_admin, _db, _table, _descriptor, _ignore_if_exists),
    do: :erlang.nif_error(:nif_not_loaded)

  def admin_drop_table(_admin, _db, _table, _ignore_if_not_exists),
    do: :erlang.nif_error(:nif_not_loaded)

  def admin_list_tables(_admin, _database), do: :erlang.nif_error(:nif_not_loaded)

  def admin_table_exists(_admin, _database_name, _table_name),
    do: :erlang.nif_error(:nif_not_loaded)

  def admin_get_table_info(_admin, _database_name, _table_name),
    do: :erlang.nif_error(:nif_not_loaded)

  def admin_get_table_schema(_admin, _database_name, _table_name, _schema_id),
    do: :erlang.nif_error(:nif_not_loaded)

  # Schema / TableDescriptor
  def table_descriptor_new(_schema, _options),
    do: :erlang.nif_error(:nif_not_loaded)

  # Table
  def table_get(_conn, _database, _table), do: :erlang.nif_error(:nif_not_loaded)
  def table_has_primary_key(_table), do: :erlang.nif_error(:nif_not_loaded)
  def table_column_names(_table), do: :erlang.nif_error(:nif_not_loaded)

  # AppendWriter
  def append_writer_new(_table), do: :erlang.nif_error(:nif_not_loaded)
  def append_writer_append(_writer, _values), do: :erlang.nif_error(:nif_not_loaded)
  def append_writer_flush(_writer), do: :erlang.nif_error(:nif_not_loaded)

  # LogScanner
  def log_scanner_new(_table), do: :erlang.nif_error(:nif_not_loaded)
  def log_scanner_subscribe(_scanner, _bucket, _offset), do: :erlang.nif_error(:nif_not_loaded)

  def log_scanner_subscribe_buckets(_scanner, _bucket_offsets),
    do: :erlang.nif_error(:nif_not_loaded)

  def log_scanner_unsubscribe(_scanner, _bucket), do: :erlang.nif_error(:nif_not_loaded)
  def log_scanner_poll(_scanner, _timeout_ms), do: :erlang.nif_error(:nif_not_loaded)

  # WriteHandle
  def write_handle_wait(_handle), do: :erlang.nif_error(:nif_not_loaded)

  # Constants
  def earliest_offset, do: :erlang.nif_error(:nif_not_loaded)

  @doc false
  def await_nif(ref) do
    receive do
      {^ref, result} -> result
    end
  end
end