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 for package 'tech.pubsub'
17
18require 'grpc'
19require 'google/protobuf/empty'
20require 'tech/pubsub/proto/pubsub'
21
22module Tech
23  module Pubsub
24    module PublisherService
25
26      # TODO: add proto service documentation here
27      class Service
28
29        include GRPC::GenericService
30
31        self.marshal_class_method = :encode
32        self.unmarshal_class_method = :decode
33        self.service_name = 'tech.pubsub.PublisherService'
34
35        rpc :CreateTopic, Topic, Topic
36        rpc :Publish, PublishRequest, Google::Protobuf::Empty
37        rpc :PublishBatch, PublishBatchRequest, PublishBatchResponse
38        rpc :GetTopic, GetTopicRequest, Topic
39        rpc :ListTopics, ListTopicsRequest, ListTopicsResponse
40        rpc :DeleteTopic, DeleteTopicRequest, Google::Protobuf::Empty
41      end
42
43      Stub = Service.rpc_stub_class
44    end
45    module SubscriberService
46
47      # TODO: add proto service documentation here
48      class Service
49
50        include GRPC::GenericService
51
52        self.marshal_class_method = :encode
53        self.unmarshal_class_method = :decode
54        self.service_name = 'tech.pubsub.SubscriberService'
55
56        rpc :CreateSubscription, Subscription, Subscription
57        rpc :GetSubscription, GetSubscriptionRequest, Subscription
58        rpc :ListSubscriptions, ListSubscriptionsRequest, ListSubscriptionsResponse
59        rpc :DeleteSubscription, DeleteSubscriptionRequest, Google::Protobuf::Empty
60        rpc :TruncateSubscription, TruncateSubscriptionRequest, Google::Protobuf::Empty
61        rpc :ModifyPushConfig, ModifyPushConfigRequest, Google::Protobuf::Empty
62        rpc :Pull, PullRequest, PullResponse
63        rpc :PullBatch, PullBatchRequest, PullBatchResponse
64        rpc :ModifyAckDeadline, ModifyAckDeadlineRequest, Google::Protobuf::Empty
65        rpc :Acknowledge, AcknowledgeRequest, Google::Protobuf::Empty
66        rpc :Nack, NackRequest, Google::Protobuf::Empty
67      end
68
69      Stub = Service.rpc_stub_class
70    end
71    module PushEndpointService
72
73      # TODO: add proto service documentation here
74      class Service
75
76        include GRPC::GenericService
77
78        self.marshal_class_method = :encode
79        self.unmarshal_class_method = :decode
80        self.service_name = 'tech.pubsub.PushEndpointService'
81
82        rpc :HandlePubsubEvent, PubsubEvent, Google::Protobuf::Empty
83      end
84
85      Stub = Service.rpc_stub_class
86    end
87  end
88end
89