Packages

pulsar_elixir

2.2.1
2.11.1 2.11.0 2.10.1 2.10.0 2.9.0 2.8.19 2.8.18 2.8.17 2.8.16 2.8.15 2.8.14 2.8.13 2.8.12 2.8.11 2.8.10 2.8.9 2.8.8 2.8.7 2.8.6 2.8.5 2.8.4 2.8.3 2.8.2 2.8.1 2.8.0 2.7.0 2.6.1 2.6.0 2.5.1 2.5.0 2.4.0 2.3.0 2.2.7 2.2.6 2.2.5 2.2.1

An Elixir client for Apache Pulsar.

HexDocs

Current section

Files

Jump to
Readme
36 Versions
8 Dependencies
Dependants
Files
Activity
pulsar_elixir lib pulsar framing.ex~
Raw

lib/pulsar/framing.ex~ 

defmodule Pulsar.Framing do

  # https://pulsar.apache.org/docs/next/developing-binary-protocol/#framing



  alias Pulsar.Proto

  

  def encode(%Proto.CommandPing{} = ping) do

    encoded =

      %Proto.BaseCommand{type: :PING, ping: ping}

      |> Proto.BaseCommand.encode



    size = byte_size(encoded)

    <<(size + 4)::32, size::32, encoded::binary>>

  end

  def encode(%Proto.CommandPong{} = pong) do

    encoded =

      %Proto.BaseCommand{type: :PONG, ping: pong}

      |> Proto.BaseCommand.encode



    size = byte_size(encoded)

    <<(size + 4)::32, size::32, encoded::binary>>

  end

end