Pulsar 2.0 (#10)

* Update protobuf files using `v2.0.1-incubating`
* Modifications to support latests api changes
* Modify CLI to allow producing from STDIN

.gitignore

@@ -1,3 +1,5 @@
+.DS_Store
+
 # Test binary, build with `go test -c`
 *.test
 

Makefile

@@ -13,11 +13,6 @@
 
 pulsarSrc := ${GOPATH}/src/github.com/apache/incubator-pulsar
 
-protoPkgName := api
-protoOutput := ${protoPkgName}/PulsarApi.pb.go
-protoDefinitions := ${pulsarSrc}/pulsar-common/src/main/proto
-protoTargets = $(wildcard ${protoDefinitions}/*.proto)
-
 certDir := certs
 certDirAbs := $(shell pwd)/${certDir}
 certAppRole := app
@@ -30,32 +25,26 @@ certAdminRole := admin
 # Requirements:
 #  * protoc and protoc-gen-go are installed. See: https://github.com/golang/protobuf
 #  * The Pulsar project checked out at $GOPATH/src/github.com/apache/incubator-pulsar
-$(protoOutput): $(protoTargets)
-	@echo Generating $@ from definitions: $<
-	mkdir -p ${protoPkgName}
-	protoc --go_out=import_path=${protoPkgName}:${protoPkgName} --proto_path=${protoDefinitions} ${protoTargets}
-
+api/PulsarApi.pb.go:
+	cd api && ./generate.bash ${pulsarSrc}
 
 # When running the standalone server using TLS, the sample
 # topics aren't created properly. This target performs the
 # necessary admin commands to create the topic and permissions.
 .PHONY: standalone-tls-ns
 standalone-tls-ns:
 	${pulsarSrc}/bin/pulsar-admin \
-		--admin-url https://localhost:8081 \
-		properties create sample \
+		tenants create sample \
 		--admin-roles admin \
-		--allowed-clusters standalone
+		--allowed-clusters standalone || true
 	@sleep 1
 	${pulsarSrc}/bin/pulsar-admin \
-		--admin-url https://localhost:8081 \
-		namespaces create sample/standalone/ns1
+		namespaces create sample/standalone/ns1 || true
 	@sleep 1
 	${pulsarSrc}/bin/pulsar-admin \
-		--admin-url https://localhost:8081 \
 		namespaces grant-permission sample/standalone/ns1 \
 		--actions produce,consume \
-		--role ${certAppRole}
+		--role ${certAppRole} || true
 
 .PHONY: pulsar-tls-conf
 pulsar-tls-conf: pulsar-conf/client.tls.conf pulsar-conf/standalone.tls.conf

README.md

@@ -15,7 +15,7 @@ In comparison, this library is 100% Go (no cgo required). Outside the Go standar
 
 **Status**
 
-This client is a work-in-progress and as such does not support all Pulsar features. It supports `v1.22` of Pulsar.
+This client is a work-in-progress and as such does not support all Pulsar features. It supports Pulsar 2.0 along with 1.22.
 
 The following is an incomplete list of features that are not yet implemented:
 
@@ -24,7 +24,6 @@ The following is an incomplete list of features that are not yet implemented:
 * Partitioned topics support
 * Athenz authentication support
 * Encryption support
-* Pulsar `2.x` support
 
 **Goals**