You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by mm...@apache.org on 2019/05/14 16:34:15 UTC
[pulsar-client-go] 38/38: Merge pull request #1 from merlimat/master
This is an automated email from the ASF dual-hosted git repository.
mmerli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar-client-go.git
commit 9c5d5098536baeae117b005fafe5606d4037efa8
Merge: d74beea e058b84
Author: Matteo Merli <mm...@apache.org>
AuthorDate: Tue May 14 09:33:33 2019 -0700
Merge pull request #1 from merlimat/master
Initial client library submission
.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(+)