Packages

ferricstore

0.11.0
0.11.4 0.11.3 0.11.2 0.11.1 0.11.0 0.10.3 0.10.2 0.10.1 0.10.0 0.9.1 0.9.0 0.8.0 0.7.5 0.7.4 0.7.3 0.7.2 0.7.1 0.7.0 0.6.0 0.5.7 0.5.6 0.5.5 0.5.4 0.5.3 0.5.2 0.5.1 0.5.0 0.4.3 0.4.2 0.4.1 0.4.0 0.3.7 0.3.6 0.3.5 0.3.4 0.3.3 0.3.2 0.3.1 0.2.0 0.1.0

FerricFlow durable workflows and queues with native-protocol storage, Raft durability, and Bitcask persistence.

HexDocs

Current section

Files

Jump to
Readme
40 Versions
10 Dependencies
Dependants
Files
Activity
ferricstore lib ferricstore flow query memory_budget.ex
Raw

lib/ferricstore/flow/query/memory_budget.ex 

defmodule Ferricstore.Flow.Query.MemoryBudget do

  @moduledoc false



  # FSF5 records are schema-bounded. The smallest valid record is the worst

  # compact-bytes-to-heap ratio; 64x covers it with room for VM layout changes.

  @maximum_record_decode_expansion 64

  @record_storage_copies 1

  @record_reservation_factor @maximum_record_decode_expansion + @record_storage_copies

  @spec term_bytes(term()) :: non_neg_integer()

  defdelegate term_bytes(term), to: Ferricstore.TermMemory, as: :bytes



  @spec decoded_record_reservation(non_neg_integer()) :: non_neg_integer()

  def decoded_record_reservation(encoded_bytes)

      when is_integer(encoded_bytes) and encoded_bytes >= 0,

      do: encoded_bytes * @record_reservation_factor



  @spec encoded_record_input_bytes(integer()) :: non_neg_integer()

  def encoded_record_input_bytes(available_bytes)

      when is_integer(available_bytes) and available_bytes > 0,

      do: div(available_bytes, @record_reservation_factor)



  def encoded_record_input_bytes(_available_bytes), do: 0

end