pubsub: api redesign

README.md

@@ -19,6 +19,7 @@ This client supports the following Google Cloud Platform services at a [General
 This client supports the following Google Cloud Platform services at a [Beta](#versioning) quality level:
 
 * [Cloud Natural Language](#cloud-natural-language-beta) (Beta)
+* [Cloud Pub/Sub](#cloud-pubsub-alpha) (Beta)
 * [Cloud Spanner](#cloud-spanner-beta) (Beta)
 * [Cloud Vision](#cloud-vision-beta) (Beta)
 * [Google BigQuery](#google-bigquery-beta) (Beta)
@@ -28,7 +29,6 @@ This client supports the following Google Cloud Platform services at an [Alpha](
 
 * [Cloud Bigtable](#cloud-bigtable-alpha) (Alpha)
 * [Cloud DNS](#cloud-dns-alpha) (Alpha)
-* [Cloud Pub/Sub](#cloud-pubsub-alpha) (Alpha)
 * [Cloud Resource Manager](#cloud-resource-manager-alpha) (Alpha)
 * [Cloud Speech](#cloud-speech-alpha) (Alpha)
 * [Google Compute Engine](#google-compute-engine-alpha) (Alpha)
@@ -450,6 +450,57 @@ languageClient.analyzeSentiment({document: document}).then(function(responses) {
 ```
 
 
+## Cloud Pub/Sub (Beta)
+
+- [API Documentation][gcloud-pubsub-docs]
+- [Official Documentation][cloud-pubsub-docs]
+
+#### Using the Cloud Pub/Sub API module
+
+```
+$ npm install --save @google-cloud/pubsub
+```
+
+```js
+var pubsub = require('@google-cloud/pubsub');
+```
+
+#### Authentication
+
+See [Authentication](#authentication).
+
+#### Preview
+
+```js
+var pubsubClient = pubsub({
+  projectId: 'grape-spaceship-123',
+  keyFilename: '/path/to/keyfile.json'
+});
+
+// Reference a topic that has been previously created.
+var topic = pubsubClient.topic('my-topic');
+
+// Publish a message to the topic.
+var publisher = topic.publisher();
+var message = new Buffer('New message!');
+
+publisher.publish(message, function(err, messageId) {});
+
+// Subscribe to the topic.
+topic.createSubscription('subscription-name', function(err, subscription) {
+  // Register listeners to start pulling for messages.
+  function onError(err) {}
+  function onMessage(message) {}
+  subscription.on('error', onError);
+  subscription.on('message', onMessage);
+
+  // Remove listeners to stop pulling for messages.
+  subscription.removeListener('message', onMessage);
+  subscription.removeListener('error', onError);
+});
+```
+
+
 ## Cloud Spanner (Beta)
 
 - [API Documentation][gcloud-spanner-docs]
@@ -816,54 +867,6 @@ zone.export('/zonefile.zone', function(err) {});
 ```
 
 
-## Cloud Pub/Sub (Alpha)
-
-- [API Documentation][gcloud-pubsub-docs]
-- [Official Documentation][cloud-pubsub-docs]
-
-#### Using the Cloud Pub/Sub API module
-
-```
-$ npm install --save @google-cloud/pubsub
-```
-
-```js
-var pubsub = require('@google-cloud/pubsub');
-```
-
-#### Authentication
-
-See [Authentication](#authentication).
-
-#### Preview
-
-```js
-var pubsubClient = pubsub({
-  projectId: 'grape-spaceship-123',
-  keyFilename: '/path/to/keyfile.json'
-});
-
-// Reference a topic that has been previously created.
-var topic = pubsubClient.topic('my-topic');
-
-// Publish a message to the topic.
-topic.publish('New message!', function(err) {});
-
-// Subscribe to the topic.
-topic.subscribe('subscription-name', function(err, subscription) {
-  // Register listeners to start pulling for messages.
-  function onError(err) {}
-  function onMessage(message) {}
-  subscription.on('error', onError);
-  subscription.on('message', onMessage);
-
-  // Remove listeners to stop pulling for messages.
-  subscription.removeListener('message', onMessage);
-  subscription.removeListener('error', onError);
-});
-```
-
-
 ## Cloud Resource Manager (Alpha)
 
 - [API Documentation][gcloud-resource-docs]

packages/pubsub/README.md

@@ -1,4 +1,4 @@
-# @google-cloud/pubsub ([Alpha][versioning])
+# @google-cloud/pubsub ([Beta][versioning])
 > Cloud Pub/Sub Client Library for Node.js
 
 *Looking for more Google APIs than just Pub/Sub? You might want to check out [`google-cloud`][google-cloud].*
@@ -20,10 +20,13 @@ var pubsub = require('@google-cloud/pubsub')({
 var topic = pubsub.topic('my-topic');
 
 // Publish a message to the topic.
-topic.publish('New message!', function(err) {});
+var publisher = topic.publisher();
+var message = new Buffer('New message!');
+
+publisher.publish(message, function(err, messageId) {});
 
 // Subscribe to the topic.
-topic.subscribe('subscription-name', function(err, subscription) {
+topic.createSubscription('subscription-name', function(err, subscription) {
   // Register listeners to start pulling for messages.
   function onError(err) {}
   function onMessage(message) {}
@@ -36,7 +39,7 @@ topic.subscribe('subscription-name', function(err, subscription) {
 });
 
 // Promises are also supported by omitting callbacks.
-topic.publish('New message!').then(function(data) {
+publisher.publish(message).then(function(data) {
   var messageIds = data[0];
 });
 

packages/pubsub/package.json

@@ -54,12 +54,12 @@
     "@google-cloud/common": "^0.13.0",
     "@google-cloud/common-grpc": "^0.4.0",
     "arrify": "^1.0.0",
+    "async-each": "^1.0.1",
     "extend": "^3.0.0",
+    "google-auto-auth": "^0.7.1",
     "google-gax": "^0.13.0",
     "google-proto-files": "^0.12.0",
     "is": "^3.0.1",
-    "modelo": "^4.2.0",
-    "propprop": "^0.3.0",
     "uuid": "^3.0.1"
   },
   "devDependencies": {