tree: 3e8d4df863d1f1e6bb662cf429275879212b4d30 [path history] [tgz]
  1. credentials/
  2. example/
  3. metadata/
  4. pkg/
  5. protocol/
  6. client.go
  7. client_manager.go
  8. client_manager_mock.go
  9. client_manager_test.go
  10. client_mock.go
  11. client_options.go
  12. client_test.go
  13. config.go
  14. conn.go
  15. conn_options.go
  16. consumer.go
  17. consumer_options.go
  18. consumer_service.go
  19. error.go
  20. go.mod
  21. go.sum
  22. loadBalancer.go
  23. log.go
  24. message.go
  25. message_id.go
  26. message_id_codec.go
  27. message_id_codec_test.go
  28. metric.go
  29. metric_test.go
  30. name_resolver.go
  31. process_queue.go
  32. producer.go
  33. producer_options.go
  34. producer_test.go
  35. publishing_message.go
  36. publishing_message_test.go
  37. push_consumer.go
  38. push_consumer_options.go
  39. README.md
  40. rpc_client.go
  41. rpc_client_mock.go
  42. rpc_client_options.go
  43. simple_consumer.go
  44. simple_consumer_options.go
  45. simple_thread_pool.go
  46. trace.go
  47. transaction.go
  48. user_agent.go
golang/README.md

The Golang Implementation of Apache RocketMQ Client

Codecov-golang

Here is the golang implementation of the client for Apache RocketMQ.

Architecture

We build the following protocols described in rocketmq-apis on top of gRPC-go, utilizing Protocol buffers to serialize and deserialize data in transmission.

Quick Start

Installation

With Go modules(Go 1.11+), simply add the following import to your code, and then go [build|run|test] will automatically fetch the necessary dependencies.

import "github.com/apache/rocketmq-clients/golang"

Otherwise, to install the golang package, run the following command:

go get -u github.com/apache/rocketmq-clients/golang/v5