KubeMQ (kubemq v1.0.1)

Copy Markdown View Source

KubeMQ Elixir SDK — Kubernetes-native messaging client.

Provides a full-featured Elixir client for KubeMQ, supporting four messaging patterns over gRPC: events (pub/sub), events store (persistent pub/sub), commands/queries (RPC), and queues (pull-based messaging).

Quick Start

{:ok, client} = KubeMQ.Client.start_link(address: "localhost:50000", client_id: "my-app")
:ok = KubeMQ.Client.send_event(client, %KubeMQ.Event{channel: "test", body: "hello"})
KubeMQ.Client.close(client)

Core Modules

  • KubeMQ.Client — Primary API surface for all messaging operations
  • KubeMQ.Config — NimbleOptions-based configuration schema
  • KubeMQ.Error — Typed error struct with error codes and retryability

Messaging Patterns

Integration