This is an automated email from the ASF dual-hosted git repository.
mmerli pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar-client-go.git.
from d74beea Initial commit
new 84cb32e Initial import
new 0c2da14 Use string for result errors
new ccc596a Create producer session
new 1bdf19f Implemented keep-alive logic
new d31030e Set right level for logs
new d8a1dcc Removed internalClose method
new 0fe868a Added serialize method for string map
new f7cac7a Basic publishing works
new 2e74112 Reconnection logic
new b95a971 Added blocking queue implementation
new 7851714 Queue sending requests and trigger callbacks
new ecab9cf Added blocking queue iterator
new 427fe05 Resend pending messages after reconnection
new 9522dd5 Handle cases with no-batching
new 98552f3 Producer close
new ea44ac9 Implemented producer flush
new f9fa727 Added compression codecs and tests
new 0eb04d5 Support compression in producer
new b924b78 Completed lookup service with tests
new b2c9d8c Producer last sequence id
new 0ac7868 Added hash functions and tests
new e7a4aef Completed default message router and tests
new 585500e Added perf producer/consumer
new 9c6d52f Added auto-resize when writing to buffer
new e077250 Use logrus in perf producer/consumer
new b329bbf Fixed releasing of semaphore for each send request
new 05bc67f Added MessageID implementation
new dfd7550 Renamed to pulsar-client-go
new 1ead55b Added license headers
new b212407 Added README
new 617f0d5 Addressed comments
new d6dbcfa Renamed `impl` package to `internal`
new fe3258b Added scripts to start test service
new ddc789e Added TLS connection support
new 1a6dfaa TLS Auth provider
new e058b84 Added token auth provider
new 9c5d509 Merge pull request #1 from merlimat/master
The 38 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.gitignore | 1 +
Dockerfile | 34 +
LICENSE | 305 ++
NOTICE | 6 +
README.md | 60 +
integration-tests/certs/broker-cert.pem | 73 +
integration-tests/certs/broker-key.pem | 28 +
integration-tests/certs/cacert.pem | 62 +
integration-tests/certs/client-cert.pem | 73 +
integration-tests/certs/client-key.pem | 28 +
integration-tests/client.conf | 27 +
integration-tests/standalone.conf | 280 ++
integration-tests/tokens/secret.key | 1 +
integration-tests/tokens/token.txt | 1 +
perf/perf-consumer.go | 113 +
perf/perf-producer.go | 147 +
perf/pulsar-perf-go.go | 49 +
pulsar-test-service-start.sh | 79 +
pulsar-test-service-stop.sh | 35 +
pulsar/client.go | 113 +
pulsar/consumer.go | 179 +
pulsar/error.go | 103 +
pulsar/impl_client.go | 152 +
pulsar/impl_client_test.go | 203 ++
pulsar/impl_message.go | 78 +
pulsar/impl_message_test.go | 48 +
pulsar/impl_partition_producer.go | 427 +++
pulsar/impl_producer.go | 156 +
pulsar/internal/auth/disabled.go | 49 +
pulsar/internal/auth/provider.go | 63 +
pulsar/internal/auth/tls.go | 64 +
pulsar/internal/auth/token.go | 98 +
pulsar/internal/backoff.go | 45 +
pulsar/internal/batch_builder.go | 166 +
pulsar/internal/buffer.go | 193 ++
pulsar/internal/buffer_test.go | 38 +
pulsar/internal/checksum.go | 28 +
pulsar/internal/closable.go | 24 +
pulsar/internal/commands.go | 141 +
pulsar/internal/commands_test.go | 45 +
pulsar/internal/compression/compression.go | 33 +
pulsar/internal/compression/compression_test.go | 71 +
pulsar/internal/compression/lz4.go | 47 +
pulsar/internal/compression/noop.go | 35 +
pulsar/internal/compression/zlib.go | 54 +
pulsar/internal/compression/zstd.go | 39 +
pulsar/internal/connection.go | 484 +++
pulsar/internal/connection_pool.go | 85 +
pulsar/internal/connection_reader.go | 136 +
pulsar/internal/default_router.go | 69 +
pulsar/internal/default_router_test.go | 85 +
pulsar/internal/hash.go | 38 +
pulsar/internal/hash_test.go | 59 +
pulsar/internal/lookup_service.go | 132 +
pulsar/internal/lookup_service_test.go | 268 ++
pulsar/internal/pulsar_proto/PulsarApi.pb.go | 4043 +++++++++++++++++++++++
pulsar/internal/rpc_client.go | 124 +
pulsar/internal/topic_name.go | 107 +
pulsar/internal/topic_name_test.go | 87 +
pulsar/internal/util/blocking_queue.go | 203 ++
pulsar/internal/util/blocking_queue_test.go | 137 +
pulsar/internal/util/semaphore.go | 30 +
pulsar/internal/utils.go | 39 +
pulsar/message.go | 88 +
pulsar/producer.go | 167 +
pulsar/producer_test.go | 181 +
pulsar/reader.go | 84 +
pulsar/test_helper.go | 43 +
68 files changed, 10783 insertions(+)
create mode 100644 .gitignore
create mode 100644 Dockerfile
create mode 100644 LICENSE
create mode 100644 NOTICE
create mode 100644 integration-tests/certs/broker-cert.pem
create mode 100644 integration-tests/certs/broker-key.pem
create mode 100644 integration-tests/certs/cacert.pem
create mode 100644 integration-tests/certs/client-cert.pem
create mode 100644 integration-tests/certs/client-key.pem
create mode 100644 integration-tests/client.conf
create mode 100644 integration-tests/standalone.conf
create mode 100644 integration-tests/tokens/secret.key
create mode 100644 integration-tests/tokens/token.txt
create mode 100644 perf/perf-consumer.go
create mode 100644 perf/perf-producer.go
create mode 100644 perf/pulsar-perf-go.go
create mode 100755 pulsar-test-service-start.sh
create mode 100755 pulsar-test-service-stop.sh
create mode 100644 pulsar/client.go
create mode 100644 pulsar/consumer.go
create mode 100644 pulsar/error.go
create mode 100644 pulsar/impl_client.go
create mode 100644 pulsar/impl_client_test.go
create mode 100644 pulsar/impl_message.go
create mode 100644 pulsar/impl_message_test.go
create mode 100644 pulsar/impl_partition_producer.go
create mode 100644 pulsar/impl_producer.go
create mode 100644 pulsar/internal/auth/disabled.go
create mode 100644 pulsar/internal/auth/provider.go
create mode 100644 pulsar/internal/auth/tls.go
create mode 100644 pulsar/internal/auth/token.go
create mode 100644 pulsar/internal/backoff.go
create mode 100644 pulsar/internal/batch_builder.go
create mode 100644 pulsar/internal/buffer.go
create mode 100644 pulsar/internal/buffer_test.go
create mode 100644 pulsar/internal/checksum.go
create mode 100644 pulsar/internal/closable.go
create mode 100644 pulsar/internal/commands.go
create mode 100644 pulsar/internal/commands_test.go
create mode 100644 pulsar/internal/compression/compression.go
create mode 100644 pulsar/internal/compression/compression_test.go
create mode 100644 pulsar/internal/compression/lz4.go
create mode 100644 pulsar/internal/compression/noop.go
create mode 100644 pulsar/internal/compression/zlib.go
create mode 100644 pulsar/internal/compression/zstd.go
create mode 100644 pulsar/internal/connection.go
create mode 100644 pulsar/internal/connection_pool.go
create mode 100644 pulsar/internal/connection_reader.go
create mode 100644 pulsar/internal/default_router.go
create mode 100644 pulsar/internal/default_router_test.go
create mode 100644 pulsar/internal/hash.go
create mode 100644 pulsar/internal/hash_test.go
create mode 100644 pulsar/internal/lookup_service.go
create mode 100644 pulsar/internal/lookup_service_test.go
create mode 100644 pulsar/internal/pulsar_proto/PulsarApi.pb.go
create mode 100644 pulsar/internal/rpc_client.go
create mode 100644 pulsar/internal/topic_name.go
create mode 100644 pulsar/internal/topic_name_test.go
create mode 100644 pulsar/internal/util/blocking_queue.go
create mode 100644 pulsar/internal/util/blocking_queue_test.go
create mode 100644 pulsar/internal/util/semaphore.go
create mode 100644 pulsar/internal/utils.go
create mode 100644 pulsar/message.go
create mode 100644 pulsar/producer.go
create mode 100644 pulsar/producer_test.go
create mode 100644 pulsar/reader.go
create mode 100644 pulsar/test_helper.go
