Modules
KubeMQ Elixir SDK — Kubernetes-native messaging client.
Broadway producer for KubeMQ Events (Pub/Sub).
Broadway producer for KubeMQ Events Store (Persistent Pub/Sub).
Broadway producer for KubeMQ Queues.
Information about a KubeMQ channel returned from list operations.
Main KubeMQ client GenServer — primary API surface for all messaging patterns.
Command message for the KubeMQ RPC pattern.
Received command from a KubeMQ command subscription.
Reply constructed by a command subscriber to respond to a received command.
Response received after sending a command via KubeMQ.Client.send_command/2.
Configuration for KubeMQ client connections via NimbleOptions.
Behaviour for providing authentication credentials to KubeMQ.
KubeMQ error type with error codes, retryability, and gRPC status mapping.
Event message for the KubeMQ Pub/Sub pattern.
Received event from a KubeMQ Pub/Sub subscription.
Persistent event message for the KubeMQ Events Store pattern.
Received event from a KubeMQ Events Store subscription.
Result of sending a persistent event to KubeMQ Events Store.
Handle for streaming persistent events with awaitable confirmation.
Handle for streaming events via a bidirectional gRPC stream.
Request parameters for polling queue messages via the Stream API.
Response from polling queue messages, with transaction management methods.
Query message for the KubeMQ RPC pattern with optional response caching.
Received query from a KubeMQ query subscription.
Reply constructed by a query subscriber to respond to a received query.
Response received after sending a query via KubeMQ.Client.send_query/2.
Result of acknowledging all messages in a queue.
Server-populated attributes attached to received queue messages.
Result of sending a batch of queue messages.
Message for the KubeMQ Queues pattern.
Delivery policy for queue messages.
Result of receiving messages from a queue via the Simple API.
Result of sending a queue message.
Handle for sending queue messages via a bidirectional upstream stream.
Reconnection policy for the KubeMQ connection GenServer.
Retry policy for transient gRPC errors.
Server information returned from a Ping request.
Static token credential provider for KubeMQ authentication.
Handle for an active subscription. Provides cancellation and status checking.
TLS configuration for KubeMQ gRPC connections.