- cb24d11 fix a little by xiaolong.ran · 4 years, 9 months ago
- 69adade add some depend for openjdk-8 by xiaolong.ran · 4 years, 9 months ago
- d72134f fix java install errr in dokcer image by xiaolong.ran · 4 years, 9 months ago
- a430e71 comments openjdk-8-jre-headless by xiaolong.ran · 4 years, 9 months ago
- 66ffac1 fix ci error by xiaolong.ran · 4 years, 9 months ago
- 836438a remove openjdk-8-jre-headless by xiaolong.ran · 4 years, 9 months ago
- 1c148de fix comments by xiaolong.ran · 4 years, 9 months ago
- 0db5c44 Fix gofmt and add some comments by xiaolong.ran · 4 years, 9 months ago
- 0a9a70b Merge master code and fix conflict by xiaolong.ran · 4 years, 9 months ago
- 7a9aa2b Merge pull request #25 from wolfstudy/xiaolong/golint-code-format by Jia Zhai · 4 years, 9 months ago
- 4512b67 Fix gofmt and golint issues by xiaolong.ran · 4 years, 9 months ago
- ad1e9be code format by xiaolong.ran · 4 years, 9 months ago
- 059e15d code format for consumer by xiaolong.ran · 4 years, 9 months ago
- 1a7fda0 Merge master and fix conflict by xiaolong.ran · 4 years, 9 months ago
- 2c5503b Merge pull request #24 from wolfstudy/xiaolong/code_format_producer by Jia Zhai · 4 years, 9 months ago
- aec466d fix a little by xiaolong.ran · 4 years, 9 months ago
- 3c960ce add gofmt check by xiaolong.ran · 4 years, 9 months ago
- cddfc7f Use golangci-lint to format the code for the master branch by xiaolong.ran · 4 years, 9 months ago
- 7148b47 add ack timeout test case for consumer by xiaolong.ran · 4 years, 9 months ago
- f77a470 add partition topic test case for consumer by xiaolong.ran · 4 years, 9 months ago
- 54f8ee2 add key_shared test case for consumer by xiaolong.ran · 4 years, 9 months ago
- 003037c Add some unit test for consumer and add IsNil func by xiaolong.ran · 4 years, 9 months ago
- c53f30d Add golangci-lint for formatting code (#21) by 冉小龙 · 4 years, 9 months ago
- a042223 support consumer listener logic by xiaolong.ran · 4 years, 9 months ago
- a5d1d98 remove godoc and add in other pull request by xiaolong.ran · 4 years, 9 months ago
- 090b251 add go report to checking code format (#19) by 冉小龙 · 4 years, 9 months ago
- 6e743dc Merge pull request #1 from wty4427300/master by 冉小龙 · 4 years, 9 months ago
- 9c64136 Update README.md by GameOver · 4 years, 9 months ago
- 7f80cc7 add unack messages tracker uint test by xiaolong.ran · 4 years, 10 months ago
- 9da5a04 support ack timeout logic by xiaolong.ran · 4 years, 10 months ago
- a56277e fix conflict by xiaolong.ran · 4 years, 10 months ago
- 7f0eba1 add unsubscribe test and handler channel logic of closing by xiaolong.ran · 4 years, 10 months ago
- 81540a2 support unsubscribe logic in consumer by xiaolong.ran · 4 years, 10 months ago
- f04ca7b Support multi partition receive logic by xiaolong.ran · 4 years, 10 months ago
- b6982c5 Fix an issue where partition topic could not be created correctly by xiaolong.ran · 4 years, 10 months ago
- faa0e18 Fix unsubscribe logic by xiaolong.ran · 4 years, 10 months ago
- 26b421e fix dead lock of UnackedMessageTracker by xiaolong.ran · 4 years, 10 months ago
- 3a1e41c fix a little by xiaolong.ran · 4 years, 10 months ago
- b26016e Add test case for consumer by xiaolong.ran · 4 years, 10 months ago
- b2e59ef fix messageID and Seek logic by xiaolong.ran · 4 years, 10 months ago
- a5bde62 Impl consumer logic for go client by xiaolong.ran · 4 years, 10 months ago
- 3c5b583 support unsubscribe logic in consumer by xiaolong.ran · 4 years, 10 months ago
- e9f77e8 Fix runtime error: integer divide by zero (#20) by 冉小龙 · 4 years, 10 months ago
- 9aced0f Support multi partition receive logic by xiaolong.ran · 4 years, 10 months ago
- 76430c8 Add github issues template (#18) by 冉小龙 · 4 years, 10 months ago
- bbfffce Fix an issue where partition topic could not be created correctly by xiaolong.ran · 4 years, 10 months ago
- 6edeab9 Fix unsubscribe logic by xiaolong.ran · 4 years, 10 months ago
- b1ac841 fix dead lock of UnackedMessageTracker by xiaolong.ran · 4 years, 10 months ago
- 96cd5c4 fix a little by xiaolong.ran · 4 years, 10 months ago
- fee4fd1 Add test case for consumer by xiaolong.ran · 4 years, 10 months ago
- c577157 fix messageID and Seek logic by xiaolong.ran · 4 years, 10 months ago
- f172fb2 Impl consumer logic for go client by xiaolong.ran · 4 years, 10 months ago
- ebd7667 [issues 13] Fix go func(){} usage question (#14) by 冉小龙 · 5 years ago
- 12f444a Run tests on all the subdirectories (#10) by Matteo Merli · 5 years ago
- 02a57e3 Added producer example in README (#9) by Matteo Merli · 5 years ago
- b30adb8 Fixed flaky TestConvertStringMap (#11) by Matteo Merli · 5 years ago
- 94edfbf Added scripts to run unit tests (#6) by Matteo Merli · 5 years ago
- fd50e0e Removed non-needed section in LICENSE (#8) by Matteo Merli · 5 years ago
- f562db9 Use pure ZStd decompression is CGo is disabled (#3) by Matteo Merli · 5 years ago
- d6a6187 Fixed producer.Flush() (#5) by Matteo Merli · 5 years ago
- 9e3736a refactor the project's directory structure (#7) by 冉小龙 · 5 years ago
- b4c60c0 add go mod for pulsar-client-go (#4) by 冉小龙 · 5 years ago
- b7700c0 Merge pull request #2 from merlimat/lz4-go by Matteo Merli · 5 years ago
- a913fc6 Use pure Go LZ4 compression by Matteo Merli · 5 years ago
- 9c5d509 Merge pull request #1 from merlimat/master by Matteo Merli · 5 years ago
- e058b84 Added token auth provider by Matteo Merli · 5 years ago
- 1a6dfaa TLS Auth provider by Matteo Merli · 5 years ago
- ddc789e Added TLS connection support by Matteo Merli · 5 years ago
- fe3258b Added scripts to start test service by Matteo Merli · 5 years ago
- d6dbcfa Renamed `impl` package to `internal` by Matteo Merli · 5 years ago
- 617f0d5 Addressed comments by Matteo Merli · 5 years ago
- b212407 Added README by Matteo Merli · 5 years ago
- 1ead55b Added license headers by Matteo Merli · 5 years ago
- dfd7550 Renamed to pulsar-client-go by Matteo Merli · 5 years ago
- 05bc67f Added MessageID implementation by Matteo Merli · 5 years ago
- b329bbf Fixed releasing of semaphore for each send request by Matteo Merli · 5 years ago
- e077250 Use logrus in perf producer/consumer by Matteo Merli · 5 years ago
- 9c6d52f Added auto-resize when writing to buffer by Matteo Merli · 5 years ago
- 585500e Added perf producer/consumer by Matteo Merli · 5 years ago
- e7a4aef Completed default message router and tests by Matteo Merli · 5 years ago
- 0ac7868 Added hash functions and tests by Matteo Merli · 5 years ago
- b2c9d8c Producer last sequence id by Matteo Merli · 5 years ago
- b924b78 Completed lookup service with tests by Matteo Merli · 5 years ago
- 0eb04d5 Support compression in producer by Matteo Merli · 5 years ago
- f9fa727 Added compression codecs and tests by Matteo Merli · 5 years ago
- ea44ac9 Implemented producer flush by Matteo Merli · 5 years ago
- 98552f3 Producer close by Matteo Merli · 5 years ago
- 9522dd5 Handle cases with no-batching by Matteo Merli · 5 years ago
- 427fe05 Resend pending messages after reconnection by Matteo Merli · 5 years ago
- ecab9cf Added blocking queue iterator by Matteo Merli · 5 years ago
- 7851714 Queue sending requests and trigger callbacks by Matteo Merli · 5 years ago
- b95a971 Added blocking queue implementation by Matteo Merli · 5 years ago
- 2e74112 Reconnection logic by Matteo Merli · 5 years ago
- f7cac7a Basic publishing works by Matteo Merli · 5 years ago
- 0fe868a Added serialize method for string map by Matteo Merli · 5 years ago
- d8a1dcc Removed internalClose method by Matteo Merli · 5 years ago
- d31030e Set right level for logs by Matteo Merli · 5 years ago
- 1bdf19f Implemented keep-alive logic by Matteo Merli · 5 years ago
- ccc596a Create producer session by Matteo Merli · 5 years ago
- 0c2da14 Use string for result errors by Matteo Merli · 5 years ago
