1# Copyright 2015 gRPC authors.
2#
3# Licensed under the Apache License, Version 2.0 (the "License");
4# you may not use this file except in compliance with the License.
5# You may obtain a copy of the License at
6#
7#     http://www.apache.org/licenses/LICENSE-2.0
8#
9# Unless required by applicable law or agreed to in writing, software
10# distributed under the License is distributed on an "AS IS" BASIS,
11# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12# See the License for the specific language governing permissions and
13# limitations under the License.
14
15# Generated by the protocol buffer compiler.  DO NOT EDIT!
16# source: tech/pubsub/proto/pubsub.proto
17
18require 'google/protobuf'
19
20require 'google/protobuf/empty'
21Google::Protobuf::DescriptorPool.generated_pool.build do
22  add_message "tech.pubsub.Topic" do
23    optional :name, :string, 1
24  end
25  add_message "tech.pubsub.PubsubMessage" do
26    optional :data, :string, 1
27    optional :message_id, :string, 3
28  end
29  add_message "tech.pubsub.GetTopicRequest" do
30    optional :topic, :string, 1
31  end
32  add_message "tech.pubsub.PublishRequest" do
33    optional :topic, :string, 1
34    optional :message, :message, 2, "tech.pubsub.PubsubMessage"
35  end
36  add_message "tech.pubsub.PublishBatchRequest" do
37    optional :topic, :string, 1
38    repeated :messages, :message, 2, "tech.pubsub.PubsubMessage"
39  end
40  add_message "tech.pubsub.PublishBatchResponse" do
41    repeated :message_ids, :string, 1
42  end
43  add_message "tech.pubsub.ListTopicsRequest" do
44    optional :query, :string, 1
45    optional :max_results, :int32, 2
46    optional :page_token, :string, 3
47  end
48  add_message "tech.pubsub.ListTopicsResponse" do
49    repeated :topic, :message, 1, "tech.pubsub.Topic"
50    optional :next_page_token, :string, 2
51  end
52  add_message "tech.pubsub.DeleteTopicRequest" do
53    optional :topic, :string, 1
54  end
55  add_message "tech.pubsub.Subscription" do
56    optional :name, :string, 1
57    optional :topic, :string, 2
58    optional :query, :string, 3
59    optional :truncation_policy, :message, 4, "tech.pubsub.Subscription.TruncationPolicy"
60    optional :push_config, :message, 5, "tech.pubsub.PushConfig"
61    optional :ack_deadline_seconds, :int32, 6
62    optional :garbage_collect_seconds, :int64, 7
63  end
64  add_message "tech.pubsub.Subscription.TruncationPolicy" do
65    optional :max_bytes, :int64, 1
66    optional :max_age_seconds, :int64, 2
67  end
68  add_message "tech.pubsub.PushConfig" do
69    optional :push_endpoint, :string, 1
70  end
71  add_message "tech.pubsub.PubsubEvent" do
72    optional :subscription, :string, 1
73    optional :message, :message, 2, "tech.pubsub.PubsubMessage"
74    optional :truncated, :bool, 3
75    optional :deleted, :bool, 4
76  end
77  add_message "tech.pubsub.GetSubscriptionRequest" do
78    optional :subscription, :string, 1
79  end
80  add_message "tech.pubsub.ListSubscriptionsRequest" do
81    optional :query, :string, 1
82    optional :max_results, :int32, 3
83    optional :page_token, :string, 4
84  end
85  add_message "tech.pubsub.ListSubscriptionsResponse" do
86    repeated :subscription, :message, 1, "tech.pubsub.Subscription"
87    optional :next_page_token, :string, 2
88  end
89  add_message "tech.pubsub.TruncateSubscriptionRequest" do
90    optional :subscription, :string, 1
91  end
92  add_message "tech.pubsub.DeleteSubscriptionRequest" do
93    optional :subscription, :string, 1
94  end
95  add_message "tech.pubsub.ModifyPushConfigRequest" do
96    optional :subscription, :string, 1
97    optional :push_config, :message, 2, "tech.pubsub.PushConfig"
98  end
99  add_message "tech.pubsub.PullRequest" do
100    optional :subscription, :string, 1
101    optional :return_immediately, :bool, 2
102  end
103  add_message "tech.pubsub.PullResponse" do
104    optional :ack_id, :string, 1
105    optional :pubsub_event, :message, 2, "tech.pubsub.PubsubEvent"
106  end
107  add_message "tech.pubsub.PullBatchRequest" do
108    optional :subscription, :string, 1
109    optional :return_immediately, :bool, 2
110    optional :max_events, :int32, 3
111  end
112  add_message "tech.pubsub.PullBatchResponse" do
113    repeated :pull_responses, :message, 2, "tech.pubsub.PullResponse"
114  end
115  add_message "tech.pubsub.ModifyAckDeadlineRequest" do
116    optional :subscription, :string, 1
117    optional :ack_id, :string, 2
118    optional :ack_deadline_seconds, :int32, 3
119  end
120  add_message "tech.pubsub.AcknowledgeRequest" do
121    optional :subscription, :string, 1
122    repeated :ack_id, :string, 2
123  end
124  add_message "tech.pubsub.NackRequest" do
125    optional :subscription, :string, 1
126    repeated :ack_id, :string, 2
127  end
128end
129
130module Tech
131  module Pubsub
132    Topic = Google::Protobuf::DescriptorPool.generated_pool.lookup("tech.pubsub.Topic").msgclass
133    PubsubMessage = Google::Protobuf::DescriptorPool.generated_pool.lookup("tech.pubsub.PubsubMessage").msgclass
134    GetTopicRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("tech.pubsub.GetTopicRequest").msgclass
135    PublishRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("tech.pubsub.PublishRequest").msgclass
136    PublishBatchRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("tech.pubsub.PublishBatchRequest").msgclass
137    PublishBatchResponse = Google::Protobuf::DescriptorPool.generated_pool.lookup("tech.pubsub.PublishBatchResponse").msgclass
138    ListTopicsRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("tech.pubsub.ListTopicsRequest").msgclass
139    ListTopicsResponse = Google::Protobuf::DescriptorPool.generated_pool.lookup("tech.pubsub.ListTopicsResponse").msgclass
140    DeleteTopicRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("tech.pubsub.DeleteTopicRequest").msgclass
141    Subscription = Google::Protobuf::DescriptorPool.generated_pool.lookup("tech.pubsub.Subscription").msgclass
142    Subscription::TruncationPolicy = Google::Protobuf::DescriptorPool.generated_pool.lookup("tech.pubsub.Subscription.TruncationPolicy").msgclass
143    PushConfig = Google::Protobuf::DescriptorPool.generated_pool.lookup("tech.pubsub.PushConfig").msgclass
144    PubsubEvent = Google::Protobuf::DescriptorPool.generated_pool.lookup("tech.pubsub.PubsubEvent").msgclass
145    GetSubscriptionRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("tech.pubsub.GetSubscriptionRequest").msgclass
146    ListSubscriptionsRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("tech.pubsub.ListSubscriptionsRequest").msgclass
147    ListSubscriptionsResponse = Google::Protobuf::DescriptorPool.generated_pool.lookup("tech.pubsub.ListSubscriptionsResponse").msgclass
148    TruncateSubscriptionRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("tech.pubsub.TruncateSubscriptionRequest").msgclass
149    DeleteSubscriptionRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("tech.pubsub.DeleteSubscriptionRequest").msgclass
150    ModifyPushConfigRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("tech.pubsub.ModifyPushConfigRequest").msgclass
151    PullRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("tech.pubsub.PullRequest").msgclass
152    PullResponse = Google::Protobuf::DescriptorPool.generated_pool.lookup("tech.pubsub.PullResponse").msgclass
153    PullBatchRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("tech.pubsub.PullBatchRequest").msgclass
154    PullBatchResponse = Google::Protobuf::DescriptorPool.generated_pool.lookup("tech.pubsub.PullBatchResponse").msgclass
155    ModifyAckDeadlineRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("tech.pubsub.ModifyAckDeadlineRequest").msgclass
156    AcknowledgeRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("tech.pubsub.AcknowledgeRequest").msgclass
157    NackRequest = Google::Protobuf::DescriptorPool.generated_pool.lookup("tech.pubsub.NackRequest").msgclass
158  end
159end
160