appcallback_pb.rb in dapr-ruby-1.14.4

- old
+ new
@@ -1,141 +1,45 @@
 # frozen_string_literal: true
-
 # Generated by the protocol buffer compiler.  DO NOT EDIT!
 # source: dapr/proto/runtime/v1/appcallback.proto
 
 require 'google/protobuf'
 
+require 'google/protobuf/any_pb'
 require 'google/protobuf/empty_pb'
 require 'dapr/proto/common/v1/common_pb'
 require 'google/protobuf/struct_pb'
 
-Google::Protobuf::DescriptorPool.generated_pool.build do
-  add_file('dapr/proto/runtime/v1/appcallback.proto', syntax: :proto3) do
-    add_message 'dapr.proto.runtime.v1.TopicEventRequest' do
-      optional :id, :string, 1
-      optional :source, :string, 2
-      optional :type, :string, 3
-      optional :spec_version, :string, 4
-      optional :data_content_type, :string, 5
-      optional :data, :bytes, 7
-      optional :topic, :string, 6
-      optional :pubsub_name, :string, 8
-      optional :path, :string, 9
-      optional :extensions, :message, 10, 'google.protobuf.Struct'
-    end
-    add_message 'dapr.proto.runtime.v1.TopicEventResponse' do
-      optional :status, :enum, 1, 'dapr.proto.runtime.v1.TopicEventResponse.TopicEventResponseStatus'
-    end
-    add_enum 'dapr.proto.runtime.v1.TopicEventResponse.TopicEventResponseStatus' do
-      value :SUCCESS, 0
-      value :RETRY, 1
-      value :DROP, 2
-    end
-    add_message 'dapr.proto.runtime.v1.TopicEventCERequest' do
-      optional :id, :string, 1
-      optional :source, :string, 2
-      optional :type, :string, 3
-      optional :spec_version, :string, 4
-      optional :data_content_type, :string, 5
-      optional :data, :bytes, 6
-      optional :extensions, :message, 7, 'google.protobuf.Struct'
-    end
-    add_message 'dapr.proto.runtime.v1.TopicEventBulkRequestEntry' do
-      optional :entry_id, :string, 1
-      optional :content_type, :string, 4
-      map :metadata, :string, :string, 5
-      oneof :event do
-        optional :bytes, :bytes, 2
-        optional :cloud_event, :message, 3, 'dapr.proto.runtime.v1.TopicEventCERequest'
-      end
-    end
-    add_message 'dapr.proto.runtime.v1.TopicEventBulkRequest' do
-      optional :id, :string, 1
-      repeated :entries, :message, 2, 'dapr.proto.runtime.v1.TopicEventBulkRequestEntry'
-      map :metadata, :string, :string, 3
-      optional :topic, :string, 4
-      optional :pubsub_name, :string, 5
-      optional :type, :string, 6
-      optional :path, :string, 7
-    end
-    add_message 'dapr.proto.runtime.v1.TopicEventBulkResponseEntry' do
-      optional :entry_id, :string, 1
-      optional :status, :enum, 2, 'dapr.proto.runtime.v1.TopicEventResponse.TopicEventResponseStatus'
-    end
-    add_message 'dapr.proto.runtime.v1.TopicEventBulkResponse' do
-      repeated :statuses, :message, 1, 'dapr.proto.runtime.v1.TopicEventBulkResponseEntry'
-    end
-    add_message 'dapr.proto.runtime.v1.BindingEventRequest' do
-      optional :name, :string, 1
-      optional :data, :bytes, 2
-      map :metadata, :string, :string, 3
-    end
-    add_message 'dapr.proto.runtime.v1.BindingEventResponse' do
-      optional :store_name, :string, 1
-      repeated :states, :message, 2, 'dapr.proto.common.v1.StateItem'
-      repeated :to, :string, 3
-      optional :data, :bytes, 4
-      optional :concurrency, :enum, 5, 'dapr.proto.runtime.v1.BindingEventResponse.BindingEventConcurrency'
-    end
-    add_enum 'dapr.proto.runtime.v1.BindingEventResponse.BindingEventConcurrency' do
-      value :SEQUENTIAL, 0
-      value :PARALLEL, 1
-    end
-    add_message 'dapr.proto.runtime.v1.ListTopicSubscriptionsResponse' do
-      repeated :subscriptions, :message, 1, 'dapr.proto.runtime.v1.TopicSubscription'
-    end
-    add_message 'dapr.proto.runtime.v1.TopicSubscription' do
-      optional :pubsub_name, :string, 1
-      optional :topic, :string, 2
-      map :metadata, :string, :string, 3
-      optional :routes, :message, 5, 'dapr.proto.runtime.v1.TopicRoutes'
-      optional :dead_letter_topic, :string, 6
-      optional :bulk_subscribe, :message, 7, 'dapr.proto.runtime.v1.BulkSubscribeConfig'
-    end
-    add_message 'dapr.proto.runtime.v1.TopicRoutes' do
-      repeated :rules, :message, 1, 'dapr.proto.runtime.v1.TopicRule'
-      optional :default, :string, 2
-    end
-    add_message 'dapr.proto.runtime.v1.TopicRule' do
-      optional :match, :string, 1
-      optional :path, :string, 2
-    end
-    add_message 'dapr.proto.runtime.v1.BulkSubscribeConfig' do
-      optional :enabled, :bool, 1
-      optional :max_messages_count, :int32, 2
-      optional :max_await_duration_ms, :int32, 3
-    end
-    add_message 'dapr.proto.runtime.v1.ListInputBindingsResponse' do
-      repeated :bindings, :string, 1
-    end
-    add_message 'dapr.proto.runtime.v1.HealthCheckResponse' do
-    end
-  end
-end
 
+descriptor_data = "\n\'dapr/proto/runtime/v1/appcallback.proto\x12\x15\x64\x61pr.proto.runtime.v1\x1a\x19google/protobuf/any.proto\x1a\x1bgoogle/protobuf/empty.proto\x1a!dapr/proto/common/v1/common.proto\x1a\x1cgoogle/protobuf/struct.proto\"\xa6\x01\n\x0fJobEventRequest\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\"\n\x04\x64\x61ta\x18\x02 \x01(\x0b\x32\x14.google.protobuf.Any\x12\x0e\n\x06method\x18\x03 \x01(\t\x12\x14\n\x0c\x63ontent_type\x18\x04 \x01(\t\x12;\n\x0ehttp_extension\x18\x05 \x01(\x0b\x32#.dapr.proto.common.v1.HTTPExtension\"\x12\n\x10JobEventResponse\"\xdb\x01\n\x11TopicEventRequest\x12\n\n\x02id\x18\x01 \x01(\t\x12\x0e\n\x06source\x18\x02 \x01(\t\x12\x0c\n\x04type\x18\x03 \x01(\t\x12\x14\n\x0cspec_version\x18\x04 \x01(\t\x12\x19\n\x11\x64\x61ta_content_type\x18\x05 \x01(\t\x12\x0c\n\x04\x64\x61ta\x18\x07 \x01(\x0c\x12\r\n\x05topic\x18\x06 \x01(\t\x12\x13\n\x0bpubsub_name\x18\x08 \x01(\t\x12\x0c\n\x04path\x18\t \x01(\t\x12+\n\nextensions\x18\n \x01(\x0b\x32\x17.google.protobuf.Struct\"\xa6\x01\n\x12TopicEventResponse\x12R\n\x06status\x18\x01 \x01(\x0e\x32\x42.dapr.proto.runtime.v1.TopicEventResponse.TopicEventResponseStatus\"<\n\x18TopicEventResponseStatus\x12\x0b\n\x07SUCCESS\x10\x00\x12\t\n\x05RETRY\x10\x01\x12\x08\n\x04\x44ROP\x10\x02\"\xab\x01\n\x13TopicEventCERequest\x12\n\n\x02id\x18\x01 \x01(\t\x12\x0e\n\x06source\x18\x02 \x01(\t\x12\x0c\n\x04type\x18\x03 \x01(\t\x12\x14\n\x0cspec_version\x18\x04 \x01(\t\x12\x19\n\x11\x64\x61ta_content_type\x18\x05 \x01(\t\x12\x0c\n\x04\x64\x61ta\x18\x06 \x01(\x0c\x12+\n\nextensions\x18\x07 \x01(\x0b\x32\x17.google.protobuf.Struct\"\xa5\x02\n\x1aTopicEventBulkRequestEntry\x12\x10\n\x08\x65ntry_id\x18\x01 \x01(\t\x12\x0f\n\x05\x62ytes\x18\x02 \x01(\x0cH\x00\x12\x41\n\x0b\x63loud_event\x18\x03 \x01(\x0b\x32*.dapr.proto.runtime.v1.TopicEventCERequestH\x00\x12\x14\n\x0c\x63ontent_type\x18\x04 \x01(\t\x12Q\n\x08metadata\x18\x05 \x03(\x0b\x32?.dapr.proto.runtime.v1.TopicEventBulkRequestEntry.MetadataEntry\x1a/\n\rMetadataEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\x42\x07\n\x05\x65vent\"\xa6\x02\n\x15TopicEventBulkRequest\x12\n\n\x02id\x18\x01 \x01(\t\x12\x42\n\x07\x65ntries\x18\x02 \x03(\x0b\x32\x31.dapr.proto.runtime.v1.TopicEventBulkRequestEntry\x12L\n\x08metadata\x18\x03 \x03(\x0b\x32:.dapr.proto.runtime.v1.TopicEventBulkRequest.MetadataEntry\x12\r\n\x05topic\x18\x04 \x01(\t\x12\x13\n\x0bpubsub_name\x18\x05 \x01(\t\x12\x0c\n\x04type\x18\x06 \x01(\t\x12\x0c\n\x04path\x18\x07 \x01(\t\x1a/\n\rMetadataEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"\x83\x01\n\x1bTopicEventBulkResponseEntry\x12\x10\n\x08\x65ntry_id\x18\x01 \x01(\t\x12R\n\x06status\x18\x02 \x01(\x0e\x32\x42.dapr.proto.runtime.v1.TopicEventResponse.TopicEventResponseStatus\"^\n\x16TopicEventBulkResponse\x12\x44\n\x08statuses\x18\x01 \x03(\x0b\x32\x32.dapr.proto.runtime.v1.TopicEventBulkResponseEntry\"\xae\x01\n\x13\x42indingEventRequest\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x0c\n\x04\x64\x61ta\x18\x02 \x01(\x0c\x12J\n\x08metadata\x18\x03 \x03(\x0b\x32\x38.dapr.proto.runtime.v1.BindingEventRequest.MetadataEntry\x1a/\n\rMetadataEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"\x88\x02\n\x14\x42indingEventResponse\x12\x12\n\nstore_name\x18\x01 \x01(\t\x12/\n\x06states\x18\x02 \x03(\x0b\x32\x1f.dapr.proto.common.v1.StateItem\x12\n\n\x02to\x18\x03 \x03(\t\x12\x0c\n\x04\x64\x61ta\x18\x04 \x01(\x0c\x12X\n\x0b\x63oncurrency\x18\x05 \x01(\x0e\x32\x43.dapr.proto.runtime.v1.BindingEventResponse.BindingEventConcurrency\"7\n\x17\x42indingEventConcurrency\x12\x0e\n\nSEQUENTIAL\x10\x00\x12\x0c\n\x08PARALLEL\x10\x01\"a\n\x1eListTopicSubscriptionsResponse\x12?\n\rsubscriptions\x18\x01 \x03(\x0b\x32(.dapr.proto.runtime.v1.TopicSubscription\"\xc5\x02\n\x11TopicSubscription\x12\x13\n\x0bpubsub_name\x18\x01 \x01(\t\x12\r\n\x05topic\x18\x02 \x01(\t\x12H\n\x08metadata\x18\x03 \x03(\x0b\x32\x36.dapr.proto.runtime.v1.TopicSubscription.MetadataEntry\x12\x32\n\x06routes\x18\x05 \x01(\x0b\x32\".dapr.proto.runtime.v1.TopicRoutes\x12\x19\n\x11\x64\x65\x61\x64_letter_topic\x18\x06 \x01(\t\x12\x42\n\x0e\x62ulk_subscribe\x18\x07 \x01(\x0b\x32*.dapr.proto.runtime.v1.BulkSubscribeConfig\x1a/\n\rMetadataEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"O\n\x0bTopicRoutes\x12/\n\x05rules\x18\x01 \x03(\x0b\x32 .dapr.proto.runtime.v1.TopicRule\x12\x0f\n\x07\x64\x65\x66\x61ult\x18\x02 \x01(\t\"(\n\tTopicRule\x12\r\n\x05match\x18\x01 \x01(\t\x12\x0c\n\x04path\x18\x02 \x01(\t\"a\n\x13\x42ulkSubscribeConfig\x12\x0f\n\x07\x65nabled\x18\x01 \x01(\x08\x12\x1a\n\x12max_messages_count\x18\x02 \x01(\x05\x12\x1d\n\x15max_await_duration_ms\x18\x03 \x01(\x05\"-\n\x19ListInputBindingsResponse\x12\x10\n\x08\x62indings\x18\x01 \x03(\t\"\x15\n\x13HealthCheckResponse2\x86\x04\n\x0b\x41ppCallback\x12W\n\x08OnInvoke\x12#.dapr.proto.common.v1.InvokeRequest\x1a$.dapr.proto.common.v1.InvokeResponse\"\x00\x12i\n\x16ListTopicSubscriptions\x12\x16.google.protobuf.Empty\x1a\x35.dapr.proto.runtime.v1.ListTopicSubscriptionsResponse\"\x00\x12\x65\n\x0cOnTopicEvent\x12(.dapr.proto.runtime.v1.TopicEventRequest\x1a).dapr.proto.runtime.v1.TopicEventResponse\"\x00\x12_\n\x11ListInputBindings\x12\x16.google.protobuf.Empty\x1a\x30.dapr.proto.runtime.v1.ListInputBindingsResponse\"\x00\x12k\n\x0eOnBindingEvent\x12*.dapr.proto.runtime.v1.BindingEventRequest\x1a+.dapr.proto.runtime.v1.BindingEventResponse\"\x00\x32m\n\x16\x41ppCallbackHealthCheck\x12S\n\x0bHealthCheck\x12\x16.google.protobuf.Empty\x1a*.dapr.proto.runtime.v1.HealthCheckResponse\"\x00\x32\xf0\x01\n\x10\x41ppCallbackAlpha\x12w\n\x16OnBulkTopicEventAlpha1\x12,.dapr.proto.runtime.v1.TopicEventBulkRequest\x1a-.dapr.proto.runtime.v1.TopicEventBulkResponse\"\x00\x12\x63\n\x10OnJobEventAlpha1\x12&.dapr.proto.runtime.v1.JobEventRequest\x1a\'.dapr.proto.runtime.v1.JobEventResponseBy\n\nio.dapr.v1B\x15\x44\x61prAppCallbackProtosZ1github.com/dapr/dapr/pkg/proto/runtime/v1;runtime\xaa\x02 Dapr.AppCallback.Autogen.Grpc.v1b\x06proto3"
+
+pool = Google::Protobuf::DescriptorPool.generated_pool
+pool.add_serialized_file(descriptor_data)
+
 module Dapr
   module Proto
     module Runtime
       module V1
-        TopicEventRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup('dapr.proto.runtime.v1.TopicEventRequest').msgclass
-        TopicEventResponse = ::Google::Protobuf::DescriptorPool.generated_pool.lookup('dapr.proto.runtime.v1.TopicEventResponse').msgclass
-        TopicEventResponse::TopicEventResponseStatus = ::Google::Protobuf::DescriptorPool.generated_pool.lookup('dapr.proto.runtime.v1.TopicEventResponse.TopicEventResponseStatus').enummodule
-        TopicEventCERequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup('dapr.proto.runtime.v1.TopicEventCERequest').msgclass
-        TopicEventBulkRequestEntry = ::Google::Protobuf::DescriptorPool.generated_pool.lookup('dapr.proto.runtime.v1.TopicEventBulkRequestEntry').msgclass
-        TopicEventBulkRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup('dapr.proto.runtime.v1.TopicEventBulkRequest').msgclass
-        TopicEventBulkResponseEntry = ::Google::Protobuf::DescriptorPool.generated_pool.lookup('dapr.proto.runtime.v1.TopicEventBulkResponseEntry').msgclass
-        TopicEventBulkResponse = ::Google::Protobuf::DescriptorPool.generated_pool.lookup('dapr.proto.runtime.v1.TopicEventBulkResponse').msgclass
-        BindingEventRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup('dapr.proto.runtime.v1.BindingEventRequest').msgclass
-        BindingEventResponse = ::Google::Protobuf::DescriptorPool.generated_pool.lookup('dapr.proto.runtime.v1.BindingEventResponse').msgclass
-        BindingEventResponse::BindingEventConcurrency = ::Google::Protobuf::DescriptorPool.generated_pool.lookup('dapr.proto.runtime.v1.BindingEventResponse.BindingEventConcurrency').enummodule
-        ListTopicSubscriptionsResponse = ::Google::Protobuf::DescriptorPool.generated_pool.lookup('dapr.proto.runtime.v1.ListTopicSubscriptionsResponse').msgclass
-        TopicSubscription = ::Google::Protobuf::DescriptorPool.generated_pool.lookup('dapr.proto.runtime.v1.TopicSubscription').msgclass
-        TopicRoutes = ::Google::Protobuf::DescriptorPool.generated_pool.lookup('dapr.proto.runtime.v1.TopicRoutes').msgclass
-        TopicRule = ::Google::Protobuf::DescriptorPool.generated_pool.lookup('dapr.proto.runtime.v1.TopicRule').msgclass
-        BulkSubscribeConfig = ::Google::Protobuf::DescriptorPool.generated_pool.lookup('dapr.proto.runtime.v1.BulkSubscribeConfig').msgclass
-        ListInputBindingsResponse = ::Google::Protobuf::DescriptorPool.generated_pool.lookup('dapr.proto.runtime.v1.ListInputBindingsResponse').msgclass
-        HealthCheckResponse = ::Google::Protobuf::DescriptorPool.generated_pool.lookup('dapr.proto.runtime.v1.HealthCheckResponse').msgclass
+        JobEventRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("dapr.proto.runtime.v1.JobEventRequest").msgclass
+        JobEventResponse = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("dapr.proto.runtime.v1.JobEventResponse").msgclass
+        TopicEventRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("dapr.proto.runtime.v1.TopicEventRequest").msgclass
+        TopicEventResponse = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("dapr.proto.runtime.v1.TopicEventResponse").msgclass
+        TopicEventResponse::TopicEventResponseStatus = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("dapr.proto.runtime.v1.TopicEventResponse.TopicEventResponseStatus").enummodule
+        TopicEventCERequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("dapr.proto.runtime.v1.TopicEventCERequest").msgclass
+        TopicEventBulkRequestEntry = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("dapr.proto.runtime.v1.TopicEventBulkRequestEntry").msgclass
+        TopicEventBulkRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("dapr.proto.runtime.v1.TopicEventBulkRequest").msgclass
+        TopicEventBulkResponseEntry = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("dapr.proto.runtime.v1.TopicEventBulkResponseEntry").msgclass
+        TopicEventBulkResponse = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("dapr.proto.runtime.v1.TopicEventBulkResponse").msgclass
+        BindingEventRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("dapr.proto.runtime.v1.BindingEventRequest").msgclass
+        BindingEventResponse = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("dapr.proto.runtime.v1.BindingEventResponse").msgclass
+        BindingEventResponse::BindingEventConcurrency = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("dapr.proto.runtime.v1.BindingEventResponse.BindingEventConcurrency").enummodule
+        ListTopicSubscriptionsResponse = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("dapr.proto.runtime.v1.ListTopicSubscriptionsResponse").msgclass
+        TopicSubscription = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("dapr.proto.runtime.v1.TopicSubscription").msgclass
+        TopicRoutes = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("dapr.proto.runtime.v1.TopicRoutes").msgclass
+        TopicRule = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("dapr.proto.runtime.v1.TopicRule").msgclass
+        BulkSubscribeConfig = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("dapr.proto.runtime.v1.BulkSubscribeConfig").msgclass
+        ListInputBindingsResponse = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("dapr.proto.runtime.v1.ListInputBindingsResponse").msgclass
+        HealthCheckResponse = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("dapr.proto.runtime.v1.HealthCheckResponse").msgclass
       end
     end
   end
 end