KubeMQ.EventStoreReceive (kubemq v1.0.1)

Received event from a KubeMQ Events Store subscription.

Delivered to the :on_event callback or :notify PID registered via KubeMQ.Client.subscribe_to_events_store/3.

Fields

id (String.t()) — Unique event identifier assigned by the server.
channel (String.t()) — Channel the event was published to.
metadata (String.t()) — Metadata string set by the publisher.
body (binary()) — Message payload.
timestamp (integer()) — Unix timestamp (nanoseconds) when the event was received by the server.
sequence (non_neg_integer()) — Monotonic sequence number within the channel.
tags (%{String.t() => String.t()}) — Key-value tags set by the publisher.

Summary

Types

t()

Functions

from_proto(event)

Types

t()

@type t() :: %KubeMQ.EventStoreReceive{
  body: binary(),
  channel: String.t(),
  id: String.t(),
  metadata: String.t(),
  sequence: non_neg_integer(),
  tags: %{required(String.t()) => String.t()},
  timestamp: integer()
}

Functions

from_proto(event)

@spec from_proto(map()) :: t()