Google Git
Sign in
apache / rocketmq-clients / refs/tags/rocketmq-client-golang-5.0.0-rc1 / . / golang
tree: 87bfef2910ae64e5d2dfede84bd26d79eac28bcb [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. error.go
  18. go.mod
  19. go.sum
  20. loadBalancer.go
  21. log.go
  22. message.go
  23. message_id.go
  24. message_id_codec.go
  25. message_id_codec_test.go
  26. metric.go
  27. producer.go
  28. producer_options.go
  29. producer_test.go
  30. publishing_message.go
  31. README.md
  32. rpc_client.go
  33. rpc_client_mock.go
  34. rpc_client_options.go
  35. simple_consumer.go
  36. simple_consumer_options.go
  37. trace.go
  38. transaction.go
  39. user_agent.go
golang/README.md

The Golang Implementation of Apache RocketMQ Client

Project github.com/apache/rocketmq-clients/golang is targeted to implement with golang. At the current moment, it is still a work-in-progress project. Do not use it in production till it grows mature enough.

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