This is an automated email from the ASF dual-hosted git repository.
sanjeevrk pushed a commit to branch srkukarni/serverside_validation_endpoints
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit d84aab19c768229d13a0a5faec3917b1c9e7e48b
Merge: 4334d62 7e3203d
Author: Sanjeev Kulkarni <sanj...@streaml.io>
AuthorDate: Mon Oct 8 09:33:16 2018 -0700
Merge branch 'master' into serverside_validation_endpoints
conf/broker.conf | 7 +
.../apache/pulsar/broker/ServiceConfiguration.java | 9 ++
.../apache/pulsar/broker/service/ServerCnx.java | 4 +-
.../apache/pulsar/broker/admin/AdminApiTest.java | 31 ++---
.../pulsar/broker/admin/v1/V1_AdminApiTest.java | 31 ++---
.../broker/auth/MockedPulsarServiceBaseTest.java | 1 +
.../pulsar/client/api/BrokerServiceLookupTest.java | 28 ++--
.../apache/pulsar/client/api/SimpleSchemaTest.java | 40 +++++-
.../java/org/apache/pulsar/client/api/Schema.java | 16 +++
.../client/impl/schema/AutoConsumeSchema.java | 7 +
.../client/impl/schema/AutoProduceBytesSchema.java | 24 +++-
.../pulsar/client/impl/schema/ByteSchema.java | 10 +-
.../pulsar/client/impl/schema/DoubleSchema.java | 11 +-
.../pulsar/client/impl/schema/FloatSchema.java | 11 +-
.../pulsar/client/impl/schema/IntSchema.java | 11 +-
.../pulsar/client/impl/schema/LongSchema.java | 11 +-
.../pulsar/client/impl/schema/ShortSchema.java | 11 +-
.../org/apache/pulsar/client/api/PulsarClient.java | 8 +-
.../instance/src/main/python/python_instance.py | 16 ++-
.../pulsar/functions/worker/SchedulerManager.java | 21 ++-
.../functions/worker/SchedulerManagerTest.java | 144 +++++++++++++++------
.../ProxyAuthenticatedProducerConsumerTest.java | 3 +-
.../proxy/server/ProxyAuthenticationTest.java | 7 +-
.../server/ProxyConnectionThrottlingTest.java | 5 +-
.../proxy/server/ProxyLookupThrottlingTest.java | 7 +-
.../org/apache/pulsar/proxy/server/ProxyTest.java | 9 +-
.../apache/pulsar/proxy/server/ProxyTlsTest.java | 5 +-
.../server/ProxyWithAuthorizationNegTest.java | 5 +-
.../proxy/server/ProxyWithAuthorizationTest.java | 3 +-
.../server/ProxyWithoutServiceDiscoveryTest.java | 3 +-
tests/integration/pom.xml | 6 -
.../integration/compat/kafka/KafkaApiTest.java | 1 +
32 files changed, 363 insertions(+), 143 deletions(-)
