The C based gRPC (C++, Python, Ruby, Objective-C, PHP, C#)
https://grpc.io/
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
159 lines
7.6 KiB
159 lines
7.6 KiB
# Copyright 2015 gRPC authors. |
|
# |
|
# Licensed under the Apache License, Version 2.0 (the "License"); |
|
# you may not use this file except in compliance with the License. |
|
# You may obtain a copy of the License at |
|
# |
|
# http://www.apache.org/licenses/LICENSE-2.0 |
|
# |
|
# Unless required by applicable law or agreed to in writing, software |
|
# distributed under the License is distributed on an "AS IS" BASIS, |
|
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
|
# See the License for the specific language governing permissions and |
|
# limitations under the License. |
|
|
|
# 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
|
|
|