Packages

ferricstore

0.11.4
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 execution_source.ex
Raw

lib/ferricstore/flow/query/execution_source.ex 

defmodule Ferricstore.Flow.Query.ExecutionSource do

  @moduledoc false



  alias Ferricstore.Flow.Query.{CoveringProjection, IndexDefinition, QueryRowProjection, Request}



  @type t ::

          :covering_index

          | :query_row

          | :authoritative_log

          | :transactional_counter

          | :none



  @scan_paths [:count_scan, :ordered_range, :ordered_range_union, :ordered_filter]



  @spec classify(Request.t(), atom(), IndexDefinition.t() | nil, [term()]) :: t()

  def classify(%Request{}, :counter_lookup, %IndexDefinition{}, _residual_predicates),

    do: :transactional_counter



  def classify(%Request{}, path, _definition, _residual_predicates)

      when path in [:empty, :reject],

      do: :none



  def classify(%Request{}, path, _definition, _residual_predicates)

      when path in [:primary_key, :history, :lineage, :fixed_index],

      do: :authoritative_log



  def classify(

        %Request{} = request,

        path,

        %IndexDefinition{} = definition,

        residual_predicates

      )

      when path in @scan_paths and is_list(residual_predicates) do

    cond do

      CoveringProjection.field_types(request, definition, residual_predicates) != nil ->

        :covering_index



      QueryRowProjection.eligible?(request, path) ->

        :query_row



      true ->

        :authoritative_log

    end

  end



  def classify(%Request{}, _path, _definition, _residual_predicates),

    do: :authoritative_log

end