View Source Runbox.Message (runbox v13.0.3)

Altworx message runtime representation.

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(), partition: non_neg_integer()}
  | nil

@type t() :: %Runbox.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()