Packages

kvasir_agent

0.0.1-proto2
0.0.3 0.0.2 0.0.1 0.0.1-proto7 0.0.1-proto6 0.0.1-proto5c 0.0.1-proto5b 0.0.1-proto5 0.0.1-proto4c 0.0.1-proto4b 0.0.1-proto4 0.0.1-proto3b 0.0.1-proto3 0.0.1-proto2 0.0.1-proto1 0.0.1-proto0

Kvasir agent extension to allow for aggregated state processes.

HexDocs

Current section

Files

Jump to
Readme
16 Versions
1 Dependency
Dependants
Files
Activity
kvasir_agent lib kvasir command encoder.ex
Raw

lib/kvasir/command/encoder.ex 

defmodule Kvasir.Command.Encoder do

  def encode(command, opts \\ []), do: encoding(opts).encode(command, opts)



  @base_encoders %{

    brod: Kvasir.Command.Encodings.Brod,

    json: Kvasir.Command.Encodings.JSON,

    raw: Kvasir.Command.Encodings.Raw

  }



  @spec encoding(Keyword.t()) :: module

  defp encoding(opts) do

    encoding = opts[:encoding]



    cond do

      is_nil(encoding) -> Kvasir.Command.Encodings.JSON

      :erlang.function_exported(encoding, :encode, 2) -> encoding

      encoding = @base_encoders[encoding] -> encoding

      :no_valid_given -> {:error, :invalid_encoding}

    end

  end

end