| # Copyright 2015, Google Inc. |
| # All rights reserved. |
| # |
| # Redistribution and use in source and binary forms, with or without |
| # modification, are permitted provided that the following conditions are |
| # met: |
| # |
| # * Redistributions of source code must retain the above copyright |
| # notice, this list of conditions and the following disclaimer. |
| # * Redistributions in binary form must reproduce the above |
| # copyright notice, this list of conditions and the following disclaimer |
| # in the documentation and/or other materials provided with the |
| # distribution. |
| # * Neither the name of Google Inc. nor the names of its |
| # contributors may be used to endorse or promote products derived from |
| # this software without specific prior written permission. |
| # |
| # THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS |
| # "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT |
| # LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR |
| # A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT |
| # OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, |
| # SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT |
| # LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, |
| # DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY |
| # THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT |
| # (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE |
| # OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
| |
| # Generated by the protocol buffer compiler. DO NOT EDIT! |
| # source: tech/pubsub/proto/pubsub.proto |
| |
| require 'google/protobuf' |
| |
| require 'google/protobuf/empty' |
| Google::Protobuf::DescriptorPool.generated_pool.build do |
| add_message "tech.pubsub.Topic" do |
| optional :name, :string, 1 |
| end |
| add_message "tech.pubsub.PubsubMessage" do |
| optional :data, :string, 1 |
| optional :message_id, :string, 3 |
| end |
| add_message "tech.pubsub.GetTopicRequest" do |
| optional :topic, :string, 1 |
| end |
| add_message "tech.pubsub.PublishRequest" do |
| optional :topic, :string, 1 |
| optional :message, :message, 2, "tech.pubsub.PubsubMessage" |
| end |
| add_message "tech.pubsub.PublishBatchRequest" do |
| optional :topic, :string, 1 |
| repeated :messages, :message, 2, "tech.pubsub.PubsubMessage" |
| end |
| add_message "tech.pubsub.PublishBatchResponse" do |
| repeated :message_ids, :string, 1 |
| end |
| add_message "tech.pubsub.ListTopicsRequest" do |
| optional :query, :string, 1 |
| optional :max_results, :int32, 2 |
| optional :page_token, :string, 3 |
| end |
| add_message "tech.pubsub.ListTopicsResponse" do |
| repeated :topic, :message, 1, "tech.pubsub.Topic" |
| optional :next_page_token, :string, 2 |
| end |
| add_message "tech.pubsub.DeleteTopicRequest" do |
| optional :topic, :string, 1 |
| end |
| add_message "tech.pubsub.Subscription" do |
| optional :name, :string, 1 |
| optional :topic, :string, 2 |
| optional :query, :string, 3 |
| optional :truncation_policy, :message, 4, "tech.pubsub.Subscription.TruncationPolicy" |
| optional :push_config, :message, 5, "tech.pubsub.PushConfig" |
| optional :ack_deadline_seconds, :int32, 6 |
| optional :garbage_collect_seconds, :int64, 7 |
| end |
| add_message "tech.pubsub.Subscription.TruncationPolicy" do |
| optional :max_bytes, :int64, 1 |
| optional :max_age_seconds, :int64, 2 |
| end |
| add_message "tech.pubsub.PushConfig" do |
| optional :push_endpoint, :string, 1 |
| end |
| add_message "tech.pubsub.PubsubEvent" do |
| optional :subscription, :string, 1 |
| optional :message, :message, 2, "tech.pubsub.PubsubMessage" |
| optional :truncated, :bool, 3 |
| optional :deleted, :bool, 4 |
| end |
| add_message "tech.pubsub.GetSubscriptionRequest" do |
| optional :subscription, :string, 1 |
| end |
| add_message "tech.pubsub.ListSubscriptionsRequest" do |
| optional :query, :string, 1 |
| optional :max_results, :int32, 3 |
| optional :page_token, :string, 4 |
| end |
| add_message "tech.pubsub.ListSubscriptionsResponse" do |
| repeated :subscription, :message, 1, "tech.pubsub.Subscription" |
| optional :next_page_token, :string, 2 |
| end |
| add_message "tech.pubsub.TruncateSubscriptionRequest" do |
| optional :subscription, :string, 1 |
| end |
| add_message "tech.pubsub.DeleteSubscriptionRequest" do |
| optional :subscription, :string, 1 |
| end |
| add_message "tech.pubsub.ModifyPushConfigRequest" do |
| optional :subscription, :string, 1 |
| optional :push_config, :message, 2, "tech.pubsub.PushConfig" |
| end |
| add_message "tech.pubsub.PullRequest" do |
| optional :subscription, :string, 1 |
| optional :return_immediately, :bool, 2 |
| end |
| add_message "tech.pubsub.PullResponse" do |
| optional :ack_id, :string, 1 |
| optional :pubsub_event, :message, 2, "tech.pubsub.PubsubEvent" |
| end |
| add_message "tech.pubsub.PullBatchRequest" do |
| optional :subscription, :string, 1 |
| optional :return_immediately, :bool, 2 |
| optional :max_events, :int32, 3 |
| end |
| add_message "tech.pubsub.PullBatchResponse" do |
| repeated :pull_responses, :message, 2, "tech.pubsub.PullResponse" |
| end |
| add_message "tech.pubsub.ModifyAckDeadlineRequest" do |
| optional :subscription, :string, 1 |
| optional :ack_id, :string, 2 |
| optional :ack_deadline_seconds, :int32, 3 |
| end |
| add_message "tech.pubsub.AcknowledgeRequest" do |
| optional :subscription, :string, 1 |
| repeated :ack_id, :string, 2 |
| end |
| add_message "tech.pubsub.NackRequest" do |
| optional :subscription, :string, 1 |
| repeated :ack_id, :string, 2 |
| end |
| end |
| |
| module Tech |
| module Pubsub |
| Topic = Google::Protobuf::DescriptorPool.generated_pool.lookup("tech.pubsub.Topic").msgclass |
| PubsubMessage = Google::Protobuf::DescriptorPool.generated_pool.lookup("tech.pubsub.PubsubMessage").msgclass |
| GetTopicRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("tech.pubsub.GetTopicRequest").msgclass |
| PublishRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("tech.pubsub.PublishRequest").msgclass |
| PublishBatchRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("tech.pubsub.PublishBatchRequest").msgclass |
| PublishBatchResponse = Google::Protobuf::DescriptorPool.generated_pool.lookup("tech.pubsub.PublishBatchResponse").msgclass |
| ListTopicsRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("tech.pubsub.ListTopicsRequest").msgclass |
| ListTopicsResponse = Google::Protobuf::DescriptorPool.generated_pool.lookup("tech.pubsub.ListTopicsResponse").msgclass |
| DeleteTopicRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("tech.pubsub.DeleteTopicRequest").msgclass |
| Subscription = Google::Protobuf::DescriptorPool.generated_pool.lookup("tech.pubsub.Subscription").msgclass |
| Subscription::TruncationPolicy = Google::Protobuf::DescriptorPool.generated_pool.lookup("tech.pubsub.Subscription.TruncationPolicy").msgclass |
| PushConfig = Google::Protobuf::DescriptorPool.generated_pool.lookup("tech.pubsub.PushConfig").msgclass |
| PubsubEvent = Google::Protobuf::DescriptorPool.generated_pool.lookup("tech.pubsub.PubsubEvent").msgclass |
| GetSubscriptionRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("tech.pubsub.GetSubscriptionRequest").msgclass |
| ListSubscriptionsRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("tech.pubsub.ListSubscriptionsRequest").msgclass |
| ListSubscriptionsResponse = Google::Protobuf::DescriptorPool.generated_pool.lookup("tech.pubsub.ListSubscriptionsResponse").msgclass |
| TruncateSubscriptionRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("tech.pubsub.TruncateSubscriptionRequest").msgclass |
| DeleteSubscriptionRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("tech.pubsub.DeleteSubscriptionRequest").msgclass |
| ModifyPushConfigRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("tech.pubsub.ModifyPushConfigRequest").msgclass |
| PullRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("tech.pubsub.PullRequest").msgclass |
| PullResponse = Google::Protobuf::DescriptorPool.generated_pool.lookup("tech.pubsub.PullResponse").msgclass |
| PullBatchRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("tech.pubsub.PullBatchRequest").msgclass |
| PullBatchResponse = Google::Protobuf::DescriptorPool.generated_pool.lookup("tech.pubsub.PullBatchResponse").msgclass |
| ModifyAckDeadlineRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("tech.pubsub.ModifyAckDeadlineRequest").msgclass |
| AcknowledgeRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("tech.pubsub.AcknowledgeRequest").msgclass |
| NackRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("tech.pubsub.NackRequest").msgclass |
| end |
| end |