|
|
@ -157,9 +157,7 @@ package tech.pubsub; |
|
|
|
// |
|
|
|
// |
|
|
|
// Consuming messages via push: |
|
|
|
// Consuming messages via push: |
|
|
|
// |
|
|
|
// |
|
|
|
// TODO(eschapira): Add HTTP push example. |
|
|
|
// The port 'machinename:8888' must be bound to a server that implements |
|
|
|
// |
|
|
|
|
|
|
|
// The port 'machinename:8888' must be bound to a stubby server that implements |
|
|
|
|
|
|
|
// the PushEndpointService with the following method: |
|
|
|
// the PushEndpointService with the following method: |
|
|
|
// |
|
|
|
// |
|
|
|
// int HandlePubsubEvent(PubsubEvent event) { |
|
|
|
// int HandlePubsubEvent(PubsubEvent event) { |
|
|
@ -252,8 +250,6 @@ service PublisherService { |
|
|
|
|
|
|
|
|
|
|
|
// Adds a message to the topic. Returns NOT_FOUND if the topic does not |
|
|
|
// Adds a message to the topic. Returns NOT_FOUND if the topic does not |
|
|
|
// exist. |
|
|
|
// exist. |
|
|
|
// (-- For different error code values returned via Stubby, see |
|
|
|
|
|
|
|
// util/task/codes.proto. --) |
|
|
|
|
|
|
|
rpc Publish(PublishRequest) returns (proto2.Empty) { |
|
|
|
rpc Publish(PublishRequest) returns (proto2.Empty) { |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
@ -292,7 +288,6 @@ message PubsubMessage { |
|
|
|
|
|
|
|
|
|
|
|
// Optional list of labels for this message. Keys in this collection must |
|
|
|
// Optional list of labels for this message. Keys in this collection must |
|
|
|
// be unique. |
|
|
|
// be unique. |
|
|
|
//(-- TODO(eschapira): Define how key namespace may be scoped to the topic.--) |
|
|
|
|
|
|
|
repeated tech.label.Label label = 2; |
|
|
|
repeated tech.label.Label label = 2; |
|
|
|
|
|
|
|
|
|
|
|
// ID of this message assigned by the server at publication time. Guaranteed |
|
|
|
// ID of this message assigned by the server at publication time. Guaranteed |
|
|
@ -467,7 +462,7 @@ message Subscription { |
|
|
|
// If <code>query</code> is non-empty, only messages on the subscriber's |
|
|
|
// If <code>query</code> is non-empty, only messages on the subscriber's |
|
|
|
// topic whose labels match the query will be returned. Otherwise all |
|
|
|
// topic whose labels match the query will be returned. Otherwise all |
|
|
|
// messages on the topic will be returned. |
|
|
|
// messages on the topic will be returned. |
|
|
|
// (-- The query syntax is described in tech/label/proto/label_query.proto --) |
|
|
|
// (-- The query syntax is described in label_query.proto --) |
|
|
|
optional string query = 3; |
|
|
|
optional string query = 3; |
|
|
|
|
|
|
|
|
|
|
|
// The subscriber may specify requirements for truncating unacknowledged |
|
|
|
// The subscriber may specify requirements for truncating unacknowledged |
|
|
|