KubeMQ.CommandReceive (kubemq v1.0.1)

Copy Markdown View Source

Received command from a KubeMQ command subscription.

Delivered to the :on_command callback registered via KubeMQ.Client.subscribe_to_commands/3. The reply_channel field must be copied to KubeMQ.CommandReply.response_to when constructing a reply.

Fields

  • id (String.t()) — Unique command identifier.
  • channel (String.t()) — Channel the command was sent to.
  • metadata (String.t()) — Metadata string set by the sender.
  • body (binary()) — Command payload.
  • reply_channel (String.t()) — Channel for sending the reply back (copy to CommandReply.response_to).
  • tags (%{String.t() => String.t()}) — Key-value tags set by the sender.

  • span (binary() | nil) — Tracing span context (internal).

Summary

Types

t()

Functions

from_proto(request)

Types

t()

@type t() :: %KubeMQ.CommandReceive{
  body: binary(),
  channel: String.t(),
  id: String.t(),
  metadata: String.t(),
  reply_channel: String.t(),
  span: binary() | nil,
  tags: %{required(String.t()) => String.t()}
}

Functions

from_proto(request)

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