tree 1333d2263ab30870681a90fd10e8eef1b8f0763e
parent f9abf8c5ae278490dd09ee798d3d63672e703d4c
author Zhanhui Li <lizhanhui@apache.org> 1656408362 +0800
committer GitHub <noreply@github.com> 1656408362 +0800
gpgsig -----BEGIN PGP SIGNATURE-----
 
 wsBcBAABCAAQBQJiuskqCRBK7hj4Ov3rIwAAf9kIAG79uGTowETTRLyLb0Cz5iai
 C1TtFF3//vk0IS+OyZOCOmePNt33GQTldJ/NboDk4x8vaxVtBNmkDmyzB3k1MWeC
 Fp+ht13xvnMscRrQM8msIyRt4343Z9f1Si6PvAtbMojC6FiIiwx8579qCA2OjycR
 +husYH5hHvi4oxCa5ja4nydJolHGkCPMihEFv5BTOGYbUF0j/57V+bWzy4TpaXhz
 lvwYzWGjLTUGnNnvSpuwuNxsUTS9eqxIzlhxMEhGSCDtlJzeDzusR1nkAXwg6c3U
 mewTFNfnh6JBTzBebhwD6ouWI/jC0oGr5cUM+yK2ek22oU9t0JXPmyT7DixZCJg=
 =XYi8
 -----END PGP SIGNATURE-----
 

Merge back to master (#21)

* Refactor ClientManager and RpcClient (#9)

* Ensure rpc stub dispose correctly when shutdown (#10)

* Transparent retry when query topic route entries

* Make sure stub shutdown gracefully

* Log when something is wrong (#11)

* Supply the residual RPC request (#12)

* Fix a series of naming issues (#13)

* Implement the first alpha version of PushConsumer, with many TODOs (#14)

Implement an initial version of PushConsumer

* Polish code (#15)

* WIP: Start to adapt to protocol v2

* WIP: debug telemetry bi-direction streaming

* Fix telemetry by adding x-mq-client-id header

* WIP:

* Make producer work

* Polish code (#20)

* Add package OpenTelemetry and Opentelemetry.API

* WIP: write unit tests

* WIP

* Make Shutdown async

* WIP: refactor start procedure

* WIP

* WIP

* WIP: receive messages

* WIP: add change invisible duration

* Minor fix

* Adjust message

* Add unit tests for Producer.Send

* WIP: prepare to add unit test for SimpleConsumer.Receive

* WIP: Unit tests for SimpleConsumer.Receive

* Add unit tests for SimpleConsumer

* Collect metrics for Producer

* Fix minor issue

* Add custom otlp exporter

* add MeterProvider

Co-authored-by: aaron ai <yangkun.ayk@alibaba-inc.com>