KubeMQ.QueryReceive (kubemq v1.0.1)

Copy Markdown View Source

Received query from a KubeMQ query subscription.

Delivered to the :on_query callback registered via KubeMQ.Client.subscribe_to_queries/3. The reply_channel field must be copied to KubeMQ.QueryReply.response_to when constructing a reply.

Fields

  • id (String.t()) — Unique query identifier.
  • channel (String.t()) — Channel the query was sent to.
  • metadata (String.t()) — Metadata string set by the sender.
  • body (binary()) — Query payload.
  • reply_channel (String.t()) — Channel for sending the reply back (copy to QueryReply.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.QueryReceive{
  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()