tree: d0aa8198d538697e9a54c0a74829391d90a63b9b [path history] [tgz]
  1. credentials/
  2. example/
  3. metadata/
  4. pkg/
  5. protocol/
  6. utils/
  7. client.go
  8. client_manager.go
  9. client_options.go
  10. config.go
  11. conn.go
  12. conn_options.go
  13. consumer.go
  14. consumer_options.go
  15. go.mod
  16. go.sum
  17. message.go
  18. producer.go
  19. producer_options.go
  20. publishing_loadBalancer.go
  21. publishing_message.go
  22. README.md
  23. rpc_client.go
  24. rpc_client_options.go
golang/README.md

Introduction

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.

How to use

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:

```console
$ go get -u github.com/apache/rocketmq-clients/golang

How to contribute

Similar to other Apache RocketMQ projects, we welcome contributions in various ways, from filing a bug report, correcting type error, document writing to complete feature implementation. Any attempt to make this project better is welcome.

If this project catches your attention, do not hesitate to make a pull request.