Toolbox.Message (runbox v7.0.1)

Altworx message runtime representation.

Link to this section Summary

body()

from()

origin()

t()

timestamp()

type()

body(message)

from(message)

type(message)

@type body() :: term()

@type from() :: atom() | String.t()

@type origin() :: %{offset: non_neg_integer(), topic: String.t()} | nil

@type t() :: %Toolbox.Message{
  body: body(),
  from: from(),
  origin: origin(),
  timestamp: timestamp(),
  type: type()
}

@type timestamp() :: integer()

@type type() :: atom() | String.t()

@spec body(t()) :: body()

@spec from(t()) :: from()

@spec new(from(), type(), timestamp(), body()) :: t()

@spec timestamp(t()) :: timestamp()

@spec type(t()) :: type()