View Source vdist_entry (erldist_filter v1.28.5)

Summary

Types

t()

Functions

decode(OldEntry, Input)

encode(Entry, ControlMessage, Options)

encode(Entry, ControlMessage, Payload, Options)

fill_tx_atom_cache(Entry, Options)

is_tx_atom_cache_filled(Entry)

new(DistributionFlags)

Types

t()

-type t() ::
    #vdist_entry{dflags :: vterm:u64(),
                 rx_sequences :: #{vdist:sequence_id() => vdist_external:t()},
                 rx_atom_cache :: undefined | vdist_atom_cache:t(),
                 tx_atom_cache :: undefined | vdist_atom_cache:t()}.

Functions

decode(OldEntry, Input)

-spec decode(OldEntry, Input) -> {ok, ControlMessage, MaybePayload, NewEntry, Rest} | {cont, NewEntry}
          when
              OldEntry :: t(),
              Input :: binary(),
              ControlMessage :: vdist:dop_t(),
              MaybePayload :: vterm:t() | undefined,
              NewEntry :: t(),
              Rest :: binary().

encode(Entry, ControlMessage, Options)

-spec encode(Entry, ControlMessage, Options) -> {ok, Fragments, Entry}
          when
              Entry :: t(),
              ControlMessage :: vdist:dop_without_payload_t(),
              Options :: vdist_entry_encode:options(),
              Fragments :: [binary()].

encode(Entry, ControlMessage, Payload, Options)

-spec encode(Entry, ControlMessage, Payload, Options) -> {ok, Fragments, Entry}
          when
              Entry :: t(),
              ControlMessage :: vdist:dop_with_payload_t(),
              Payload :: vterm:t(),
              Options :: vdist_entry_encode:options(),
              Fragments :: [binary()].

fill_tx_atom_cache(Entry, Options)

-spec fill_tx_atom_cache(Entry, Options) -> {ok, Fragments, Entry}
                      when
                          Entry :: t(),
                          Options :: vdist_entry_encode:options(),
                          Fragments :: [binary()].

is_tx_atom_cache_filled(Entry)

-spec is_tx_atom_cache_filled(Entry) -> boolean() when Entry :: t().

new(DistributionFlags)

-spec new(DistributionFlags) -> T when DistributionFlags :: vterm:u64(), T :: t().