| # -*- coding: utf-8 -*- |
| ################################################################################ |
| # Licensed to the Apache Software Foundation (ASF) under one |
| # or more contributor license agreements. See the NOTICE file |
| # distributed with this work for additional information |
| # regarding copyright ownership. The ASF licenses this file |
| # to you 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: request-reply.proto |
| |
| from google.protobuf import descriptor as _descriptor |
| from google.protobuf import message as _message |
| from google.protobuf import reflection as _reflection |
| from google.protobuf import symbol_database as _symbol_database |
| # @@protoc_insertion_point(imports) |
| |
| _sym_db = _symbol_database.Default() |
| |
| |
| from google.protobuf import any_pb2 as google_dot_protobuf_dot_any__pb2 |
| |
| |
| DESCRIPTOR = _descriptor.FileDescriptor( |
| name='request-reply.proto', |
| package='org.apache.flink.statefun.flink.core.polyglot', |
| syntax='proto3', |
| serialized_options=b'\n7org.apache.flink.statefun.flink.core.polyglot.generatedP\001', |
| serialized_pb=b'\n\x13request-reply.proto\x12-org.apache.flink.statefun.flink.core.polyglot\x1a\x19google/protobuf/any.proto\"6\n\x07\x41\x64\x64ress\x12\x11\n\tnamespace\x18\x01 \x01(\t\x12\x0c\n\x04type\x18\x02 \x01(\t\x12\n\n\x02id\x18\x03 \x01(\t\"\xcf\x04\n\nToFunction\x12\x66\n\ninvocation\x18\x64 \x01(\x0b\x32P.org.apache.flink.statefun.flink.core.polyglot.ToFunction.InvocationBatchRequestH\x00\x1a\x39\n\x0ePersistedValue\x12\x12\n\nstate_name\x18\x01 \x01(\t\x12\x13\n\x0bstate_value\x18\x02 \x01(\x0c\x1a|\n\nInvocation\x12\x46\n\x06\x63\x61ller\x18\x01 \x01(\x0b\x32\x36.org.apache.flink.statefun.flink.core.polyglot.Address\x12&\n\x08\x61rgument\x18\x02 \x01(\x0b\x32\x14.google.protobuf.Any\x1a\x94\x02\n\x16InvocationBatchRequest\x12\x46\n\x06target\x18\x01 \x01(\x0b\x32\x36.org.apache.flink.statefun.flink.core.polyglot.Address\x12W\n\x05state\x18\x02 \x03(\x0b\x32H.org.apache.flink.statefun.flink.core.polyglot.ToFunction.PersistedValue\x12Y\n\x0binvocations\x18\x03 \x03(\x0b\x32\x44.org.apache.flink.statefun.flink.core.polyglot.ToFunction.InvocationB\t\n\x07request\"\xa5\t\n\x0c\x46romFunction\x12k\n\x11invocation_result\x18\x64 \x01(\x0b\x32N.org.apache.flink.statefun.flink.core.polyglot.FromFunction.InvocationResponseH\x00\x1a\xe1\x01\n\x16PersistedValueMutation\x12v\n\rmutation_type\x18\x01 \x01(\x0e\x32_.org.apache.flink.statefun.flink.core.polyglot.FromFunction.PersistedValueMutation.MutationType\x12\x12\n\nstate_name\x18\x02 \x01(\t\x12\x13\n\x0bstate_value\x18\x03 \x01(\x0c\"&\n\x0cMutationType\x12\n\n\x06\x44\x45LETE\x10\x00\x12\n\n\x06MODIFY\x10\x01\x1a|\n\nInvocation\x12\x46\n\x06target\x18\x01 \x01(\x0b\x32\x36.org.apache.flink.statefun.flink.core.polyglot.Address\x12&\n\x08\x61rgument\x18\x02 \x01(\x0b\x32\x14.google.protobuf.Any\x1a\x98\x01\n\x11\x44\x65layedInvocation\x12\x13\n\x0b\x64\x65lay_in_ms\x18\x01 \x01(\x03\x12\x46\n\x06target\x18\x02 \x01(\x0b\x32\x36.org.apache.flink.statefun.flink.core.polyglot.Address\x12&\n\x08\x61rgument\x18\x03 \x01(\x0b\x32\x14.google.protobuf.Any\x1a\x66\n\rEgressMessage\x12\x18\n\x10\x65gress_namespace\x18\x01 \x01(\t\x12\x13\n\x0b\x65gress_type\x18\x02 \x01(\t\x12&\n\x08\x61rgument\x18\x03 \x01(\x0b\x32\x14.google.protobuf.Any\x1a\xb6\x03\n\x12InvocationResponse\x12k\n\x0fstate_mutations\x18\x01 \x03(\x0b\x32R.org.apache.flink.statefun.flink.core.polyglot.FromFunction.PersistedValueMutation\x12\x61\n\x11outgoing_messages\x18\x02 \x03(\x0b\x32\x46.org.apache.flink.statefun.flink.core.polyglot.FromFunction.Invocation\x12j\n\x13\x64\x65layed_invocations\x18\x03 \x03(\x0b\x32M.org.apache.flink.statefun.flink.core.polyglot.FromFunction.DelayedInvocation\x12\x64\n\x11outgoing_egresses\x18\x04 \x03(\x0b\x32I.org.apache.flink.statefun.flink.core.polyglot.FromFunction.EgressMessageB\n\n\x08responseB;\n7org.apache.flink.statefun.flink.core.polyglot.generatedP\x01\x62\x06proto3' |
| , |
| dependencies=[google_dot_protobuf_dot_any__pb2.DESCRIPTOR,]) |
| |
| |
| |
| _FROMFUNCTION_PERSISTEDVALUEMUTATION_MUTATIONTYPE = _descriptor.EnumDescriptor( |
| name='MutationType', |
| full_name='org.apache.flink.statefun.flink.core.polyglot.FromFunction.PersistedValueMutation.MutationType', |
| filename=None, |
| file=DESCRIPTOR, |
| values=[ |
| _descriptor.EnumValueDescriptor( |
| name='DELETE', index=0, number=0, |
| serialized_options=None, |
| type=None), |
| _descriptor.EnumValueDescriptor( |
| name='MODIFY', index=1, number=1, |
| serialized_options=None, |
| type=None), |
| ], |
| containing_type=None, |
| serialized_options=None, |
| serialized_start=1061, |
| serialized_end=1099, |
| ) |
| _sym_db.RegisterEnumDescriptor(_FROMFUNCTION_PERSISTEDVALUEMUTATION_MUTATIONTYPE) |
| |
| |
| _ADDRESS = _descriptor.Descriptor( |
| name='Address', |
| full_name='org.apache.flink.statefun.flink.core.polyglot.Address', |
| filename=None, |
| file=DESCRIPTOR, |
| containing_type=None, |
| fields=[ |
| _descriptor.FieldDescriptor( |
| name='namespace', full_name='org.apache.flink.statefun.flink.core.polyglot.Address.namespace', index=0, |
| number=1, type=9, cpp_type=9, label=1, |
| has_default_value=False, default_value=b"".decode('utf-8'), |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| serialized_options=None, file=DESCRIPTOR), |
| _descriptor.FieldDescriptor( |
| name='type', full_name='org.apache.flink.statefun.flink.core.polyglot.Address.type', index=1, |
| number=2, type=9, cpp_type=9, label=1, |
| has_default_value=False, default_value=b"".decode('utf-8'), |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| serialized_options=None, file=DESCRIPTOR), |
| _descriptor.FieldDescriptor( |
| name='id', full_name='org.apache.flink.statefun.flink.core.polyglot.Address.id', index=2, |
| number=3, type=9, cpp_type=9, label=1, |
| has_default_value=False, default_value=b"".decode('utf-8'), |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| serialized_options=None, file=DESCRIPTOR), |
| ], |
| extensions=[ |
| ], |
| nested_types=[], |
| enum_types=[ |
| ], |
| serialized_options=None, |
| is_extendable=False, |
| syntax='proto3', |
| extension_ranges=[], |
| oneofs=[ |
| ], |
| serialized_start=97, |
| serialized_end=151, |
| ) |
| |
| |
| _TOFUNCTION_PERSISTEDVALUE = _descriptor.Descriptor( |
| name='PersistedValue', |
| full_name='org.apache.flink.statefun.flink.core.polyglot.ToFunction.PersistedValue', |
| filename=None, |
| file=DESCRIPTOR, |
| containing_type=None, |
| fields=[ |
| _descriptor.FieldDescriptor( |
| name='state_name', full_name='org.apache.flink.statefun.flink.core.polyglot.ToFunction.PersistedValue.state_name', index=0, |
| number=1, type=9, cpp_type=9, label=1, |
| has_default_value=False, default_value=b"".decode('utf-8'), |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| serialized_options=None, file=DESCRIPTOR), |
| _descriptor.FieldDescriptor( |
| name='state_value', full_name='org.apache.flink.statefun.flink.core.polyglot.ToFunction.PersistedValue.state_value', index=1, |
| number=2, type=12, cpp_type=9, label=1, |
| has_default_value=False, default_value=b"", |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| serialized_options=None, file=DESCRIPTOR), |
| ], |
| extensions=[ |
| ], |
| nested_types=[], |
| enum_types=[ |
| ], |
| serialized_options=None, |
| is_extendable=False, |
| syntax='proto3', |
| extension_ranges=[], |
| oneofs=[ |
| ], |
| serialized_start=272, |
| serialized_end=329, |
| ) |
| |
| _TOFUNCTION_INVOCATION = _descriptor.Descriptor( |
| name='Invocation', |
| full_name='org.apache.flink.statefun.flink.core.polyglot.ToFunction.Invocation', |
| filename=None, |
| file=DESCRIPTOR, |
| containing_type=None, |
| fields=[ |
| _descriptor.FieldDescriptor( |
| name='caller', full_name='org.apache.flink.statefun.flink.core.polyglot.ToFunction.Invocation.caller', index=0, |
| number=1, type=11, cpp_type=10, label=1, |
| has_default_value=False, default_value=None, |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| serialized_options=None, file=DESCRIPTOR), |
| _descriptor.FieldDescriptor( |
| name='argument', full_name='org.apache.flink.statefun.flink.core.polyglot.ToFunction.Invocation.argument', index=1, |
| number=2, type=11, cpp_type=10, label=1, |
| has_default_value=False, default_value=None, |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| serialized_options=None, file=DESCRIPTOR), |
| ], |
| extensions=[ |
| ], |
| nested_types=[], |
| enum_types=[ |
| ], |
| serialized_options=None, |
| is_extendable=False, |
| syntax='proto3', |
| extension_ranges=[], |
| oneofs=[ |
| ], |
| serialized_start=331, |
| serialized_end=455, |
| ) |
| |
| _TOFUNCTION_INVOCATIONBATCHREQUEST = _descriptor.Descriptor( |
| name='InvocationBatchRequest', |
| full_name='org.apache.flink.statefun.flink.core.polyglot.ToFunction.InvocationBatchRequest', |
| filename=None, |
| file=DESCRIPTOR, |
| containing_type=None, |
| fields=[ |
| _descriptor.FieldDescriptor( |
| name='target', full_name='org.apache.flink.statefun.flink.core.polyglot.ToFunction.InvocationBatchRequest.target', index=0, |
| number=1, type=11, cpp_type=10, label=1, |
| has_default_value=False, default_value=None, |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| serialized_options=None, file=DESCRIPTOR), |
| _descriptor.FieldDescriptor( |
| name='state', full_name='org.apache.flink.statefun.flink.core.polyglot.ToFunction.InvocationBatchRequest.state', index=1, |
| number=2, type=11, cpp_type=10, label=3, |
| has_default_value=False, default_value=[], |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| serialized_options=None, file=DESCRIPTOR), |
| _descriptor.FieldDescriptor( |
| name='invocations', full_name='org.apache.flink.statefun.flink.core.polyglot.ToFunction.InvocationBatchRequest.invocations', index=2, |
| number=3, type=11, cpp_type=10, label=3, |
| has_default_value=False, default_value=[], |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| serialized_options=None, file=DESCRIPTOR), |
| ], |
| extensions=[ |
| ], |
| nested_types=[], |
| enum_types=[ |
| ], |
| serialized_options=None, |
| is_extendable=False, |
| syntax='proto3', |
| extension_ranges=[], |
| oneofs=[ |
| ], |
| serialized_start=458, |
| serialized_end=734, |
| ) |
| |
| _TOFUNCTION = _descriptor.Descriptor( |
| name='ToFunction', |
| full_name='org.apache.flink.statefun.flink.core.polyglot.ToFunction', |
| filename=None, |
| file=DESCRIPTOR, |
| containing_type=None, |
| fields=[ |
| _descriptor.FieldDescriptor( |
| name='invocation', full_name='org.apache.flink.statefun.flink.core.polyglot.ToFunction.invocation', index=0, |
| number=100, type=11, cpp_type=10, label=1, |
| has_default_value=False, default_value=None, |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| serialized_options=None, file=DESCRIPTOR), |
| ], |
| extensions=[ |
| ], |
| nested_types=[_TOFUNCTION_PERSISTEDVALUE, _TOFUNCTION_INVOCATION, _TOFUNCTION_INVOCATIONBATCHREQUEST, ], |
| enum_types=[ |
| ], |
| serialized_options=None, |
| is_extendable=False, |
| syntax='proto3', |
| extension_ranges=[], |
| oneofs=[ |
| _descriptor.OneofDescriptor( |
| name='request', full_name='org.apache.flink.statefun.flink.core.polyglot.ToFunction.request', |
| index=0, containing_type=None, fields=[]), |
| ], |
| serialized_start=154, |
| serialized_end=745, |
| ) |
| |
| |
| _FROMFUNCTION_PERSISTEDVALUEMUTATION = _descriptor.Descriptor( |
| name='PersistedValueMutation', |
| full_name='org.apache.flink.statefun.flink.core.polyglot.FromFunction.PersistedValueMutation', |
| filename=None, |
| file=DESCRIPTOR, |
| containing_type=None, |
| fields=[ |
| _descriptor.FieldDescriptor( |
| name='mutation_type', full_name='org.apache.flink.statefun.flink.core.polyglot.FromFunction.PersistedValueMutation.mutation_type', index=0, |
| number=1, type=14, cpp_type=8, label=1, |
| has_default_value=False, default_value=0, |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| serialized_options=None, file=DESCRIPTOR), |
| _descriptor.FieldDescriptor( |
| name='state_name', full_name='org.apache.flink.statefun.flink.core.polyglot.FromFunction.PersistedValueMutation.state_name', index=1, |
| number=2, type=9, cpp_type=9, label=1, |
| has_default_value=False, default_value=b"".decode('utf-8'), |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| serialized_options=None, file=DESCRIPTOR), |
| _descriptor.FieldDescriptor( |
| name='state_value', full_name='org.apache.flink.statefun.flink.core.polyglot.FromFunction.PersistedValueMutation.state_value', index=2, |
| number=3, type=12, cpp_type=9, label=1, |
| has_default_value=False, default_value=b"", |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| serialized_options=None, file=DESCRIPTOR), |
| ], |
| extensions=[ |
| ], |
| nested_types=[], |
| enum_types=[ |
| _FROMFUNCTION_PERSISTEDVALUEMUTATION_MUTATIONTYPE, |
| ], |
| serialized_options=None, |
| is_extendable=False, |
| syntax='proto3', |
| extension_ranges=[], |
| oneofs=[ |
| ], |
| serialized_start=874, |
| serialized_end=1099, |
| ) |
| |
| _FROMFUNCTION_INVOCATION = _descriptor.Descriptor( |
| name='Invocation', |
| full_name='org.apache.flink.statefun.flink.core.polyglot.FromFunction.Invocation', |
| filename=None, |
| file=DESCRIPTOR, |
| containing_type=None, |
| fields=[ |
| _descriptor.FieldDescriptor( |
| name='target', full_name='org.apache.flink.statefun.flink.core.polyglot.FromFunction.Invocation.target', index=0, |
| number=1, type=11, cpp_type=10, label=1, |
| has_default_value=False, default_value=None, |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| serialized_options=None, file=DESCRIPTOR), |
| _descriptor.FieldDescriptor( |
| name='argument', full_name='org.apache.flink.statefun.flink.core.polyglot.FromFunction.Invocation.argument', index=1, |
| number=2, type=11, cpp_type=10, label=1, |
| has_default_value=False, default_value=None, |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| serialized_options=None, file=DESCRIPTOR), |
| ], |
| extensions=[ |
| ], |
| nested_types=[], |
| enum_types=[ |
| ], |
| serialized_options=None, |
| is_extendable=False, |
| syntax='proto3', |
| extension_ranges=[], |
| oneofs=[ |
| ], |
| serialized_start=1101, |
| serialized_end=1225, |
| ) |
| |
| _FROMFUNCTION_DELAYEDINVOCATION = _descriptor.Descriptor( |
| name='DelayedInvocation', |
| full_name='org.apache.flink.statefun.flink.core.polyglot.FromFunction.DelayedInvocation', |
| filename=None, |
| file=DESCRIPTOR, |
| containing_type=None, |
| fields=[ |
| _descriptor.FieldDescriptor( |
| name='delay_in_ms', full_name='org.apache.flink.statefun.flink.core.polyglot.FromFunction.DelayedInvocation.delay_in_ms', index=0, |
| number=1, type=3, cpp_type=2, label=1, |
| has_default_value=False, default_value=0, |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| serialized_options=None, file=DESCRIPTOR), |
| _descriptor.FieldDescriptor( |
| name='target', full_name='org.apache.flink.statefun.flink.core.polyglot.FromFunction.DelayedInvocation.target', index=1, |
| number=2, type=11, cpp_type=10, label=1, |
| has_default_value=False, default_value=None, |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| serialized_options=None, file=DESCRIPTOR), |
| _descriptor.FieldDescriptor( |
| name='argument', full_name='org.apache.flink.statefun.flink.core.polyglot.FromFunction.DelayedInvocation.argument', index=2, |
| number=3, type=11, cpp_type=10, label=1, |
| has_default_value=False, default_value=None, |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| serialized_options=None, file=DESCRIPTOR), |
| ], |
| extensions=[ |
| ], |
| nested_types=[], |
| enum_types=[ |
| ], |
| serialized_options=None, |
| is_extendable=False, |
| syntax='proto3', |
| extension_ranges=[], |
| oneofs=[ |
| ], |
| serialized_start=1228, |
| serialized_end=1380, |
| ) |
| |
| _FROMFUNCTION_EGRESSMESSAGE = _descriptor.Descriptor( |
| name='EgressMessage', |
| full_name='org.apache.flink.statefun.flink.core.polyglot.FromFunction.EgressMessage', |
| filename=None, |
| file=DESCRIPTOR, |
| containing_type=None, |
| fields=[ |
| _descriptor.FieldDescriptor( |
| name='egress_namespace', full_name='org.apache.flink.statefun.flink.core.polyglot.FromFunction.EgressMessage.egress_namespace', index=0, |
| number=1, type=9, cpp_type=9, label=1, |
| has_default_value=False, default_value=b"".decode('utf-8'), |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| serialized_options=None, file=DESCRIPTOR), |
| _descriptor.FieldDescriptor( |
| name='egress_type', full_name='org.apache.flink.statefun.flink.core.polyglot.FromFunction.EgressMessage.egress_type', index=1, |
| number=2, type=9, cpp_type=9, label=1, |
| has_default_value=False, default_value=b"".decode('utf-8'), |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| serialized_options=None, file=DESCRIPTOR), |
| _descriptor.FieldDescriptor( |
| name='argument', full_name='org.apache.flink.statefun.flink.core.polyglot.FromFunction.EgressMessage.argument', index=2, |
| number=3, type=11, cpp_type=10, label=1, |
| has_default_value=False, default_value=None, |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| serialized_options=None, file=DESCRIPTOR), |
| ], |
| extensions=[ |
| ], |
| nested_types=[], |
| enum_types=[ |
| ], |
| serialized_options=None, |
| is_extendable=False, |
| syntax='proto3', |
| extension_ranges=[], |
| oneofs=[ |
| ], |
| serialized_start=1382, |
| serialized_end=1484, |
| ) |
| |
| _FROMFUNCTION_INVOCATIONRESPONSE = _descriptor.Descriptor( |
| name='InvocationResponse', |
| full_name='org.apache.flink.statefun.flink.core.polyglot.FromFunction.InvocationResponse', |
| filename=None, |
| file=DESCRIPTOR, |
| containing_type=None, |
| fields=[ |
| _descriptor.FieldDescriptor( |
| name='state_mutations', full_name='org.apache.flink.statefun.flink.core.polyglot.FromFunction.InvocationResponse.state_mutations', index=0, |
| number=1, type=11, cpp_type=10, label=3, |
| has_default_value=False, default_value=[], |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| serialized_options=None, file=DESCRIPTOR), |
| _descriptor.FieldDescriptor( |
| name='outgoing_messages', full_name='org.apache.flink.statefun.flink.core.polyglot.FromFunction.InvocationResponse.outgoing_messages', index=1, |
| number=2, type=11, cpp_type=10, label=3, |
| has_default_value=False, default_value=[], |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| serialized_options=None, file=DESCRIPTOR), |
| _descriptor.FieldDescriptor( |
| name='delayed_invocations', full_name='org.apache.flink.statefun.flink.core.polyglot.FromFunction.InvocationResponse.delayed_invocations', index=2, |
| number=3, type=11, cpp_type=10, label=3, |
| has_default_value=False, default_value=[], |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| serialized_options=None, file=DESCRIPTOR), |
| _descriptor.FieldDescriptor( |
| name='outgoing_egresses', full_name='org.apache.flink.statefun.flink.core.polyglot.FromFunction.InvocationResponse.outgoing_egresses', index=3, |
| number=4, type=11, cpp_type=10, label=3, |
| has_default_value=False, default_value=[], |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| serialized_options=None, file=DESCRIPTOR), |
| ], |
| extensions=[ |
| ], |
| nested_types=[], |
| enum_types=[ |
| ], |
| serialized_options=None, |
| is_extendable=False, |
| syntax='proto3', |
| extension_ranges=[], |
| oneofs=[ |
| ], |
| serialized_start=1487, |
| serialized_end=1925, |
| ) |
| |
| _FROMFUNCTION = _descriptor.Descriptor( |
| name='FromFunction', |
| full_name='org.apache.flink.statefun.flink.core.polyglot.FromFunction', |
| filename=None, |
| file=DESCRIPTOR, |
| containing_type=None, |
| fields=[ |
| _descriptor.FieldDescriptor( |
| name='invocation_result', full_name='org.apache.flink.statefun.flink.core.polyglot.FromFunction.invocation_result', index=0, |
| number=100, type=11, cpp_type=10, label=1, |
| has_default_value=False, default_value=None, |
| message_type=None, enum_type=None, containing_type=None, |
| is_extension=False, extension_scope=None, |
| serialized_options=None, file=DESCRIPTOR), |
| ], |
| extensions=[ |
| ], |
| nested_types=[_FROMFUNCTION_PERSISTEDVALUEMUTATION, _FROMFUNCTION_INVOCATION, _FROMFUNCTION_DELAYEDINVOCATION, _FROMFUNCTION_EGRESSMESSAGE, _FROMFUNCTION_INVOCATIONRESPONSE, ], |
| enum_types=[ |
| ], |
| serialized_options=None, |
| is_extendable=False, |
| syntax='proto3', |
| extension_ranges=[], |
| oneofs=[ |
| _descriptor.OneofDescriptor( |
| name='response', full_name='org.apache.flink.statefun.flink.core.polyglot.FromFunction.response', |
| index=0, containing_type=None, fields=[]), |
| ], |
| serialized_start=748, |
| serialized_end=1937, |
| ) |
| |
| _TOFUNCTION_PERSISTEDVALUE.containing_type = _TOFUNCTION |
| _TOFUNCTION_INVOCATION.fields_by_name['caller'].message_type = _ADDRESS |
| _TOFUNCTION_INVOCATION.fields_by_name['argument'].message_type = google_dot_protobuf_dot_any__pb2._ANY |
| _TOFUNCTION_INVOCATION.containing_type = _TOFUNCTION |
| _TOFUNCTION_INVOCATIONBATCHREQUEST.fields_by_name['target'].message_type = _ADDRESS |
| _TOFUNCTION_INVOCATIONBATCHREQUEST.fields_by_name['state'].message_type = _TOFUNCTION_PERSISTEDVALUE |
| _TOFUNCTION_INVOCATIONBATCHREQUEST.fields_by_name['invocations'].message_type = _TOFUNCTION_INVOCATION |
| _TOFUNCTION_INVOCATIONBATCHREQUEST.containing_type = _TOFUNCTION |
| _TOFUNCTION.fields_by_name['invocation'].message_type = _TOFUNCTION_INVOCATIONBATCHREQUEST |
| _TOFUNCTION.oneofs_by_name['request'].fields.append( |
| _TOFUNCTION.fields_by_name['invocation']) |
| _TOFUNCTION.fields_by_name['invocation'].containing_oneof = _TOFUNCTION.oneofs_by_name['request'] |
| _FROMFUNCTION_PERSISTEDVALUEMUTATION.fields_by_name['mutation_type'].enum_type = _FROMFUNCTION_PERSISTEDVALUEMUTATION_MUTATIONTYPE |
| _FROMFUNCTION_PERSISTEDVALUEMUTATION.containing_type = _FROMFUNCTION |
| _FROMFUNCTION_PERSISTEDVALUEMUTATION_MUTATIONTYPE.containing_type = _FROMFUNCTION_PERSISTEDVALUEMUTATION |
| _FROMFUNCTION_INVOCATION.fields_by_name['target'].message_type = _ADDRESS |
| _FROMFUNCTION_INVOCATION.fields_by_name['argument'].message_type = google_dot_protobuf_dot_any__pb2._ANY |
| _FROMFUNCTION_INVOCATION.containing_type = _FROMFUNCTION |
| _FROMFUNCTION_DELAYEDINVOCATION.fields_by_name['target'].message_type = _ADDRESS |
| _FROMFUNCTION_DELAYEDINVOCATION.fields_by_name['argument'].message_type = google_dot_protobuf_dot_any__pb2._ANY |
| _FROMFUNCTION_DELAYEDINVOCATION.containing_type = _FROMFUNCTION |
| _FROMFUNCTION_EGRESSMESSAGE.fields_by_name['argument'].message_type = google_dot_protobuf_dot_any__pb2._ANY |
| _FROMFUNCTION_EGRESSMESSAGE.containing_type = _FROMFUNCTION |
| _FROMFUNCTION_INVOCATIONRESPONSE.fields_by_name['state_mutations'].message_type = _FROMFUNCTION_PERSISTEDVALUEMUTATION |
| _FROMFUNCTION_INVOCATIONRESPONSE.fields_by_name['outgoing_messages'].message_type = _FROMFUNCTION_INVOCATION |
| _FROMFUNCTION_INVOCATIONRESPONSE.fields_by_name['delayed_invocations'].message_type = _FROMFUNCTION_DELAYEDINVOCATION |
| _FROMFUNCTION_INVOCATIONRESPONSE.fields_by_name['outgoing_egresses'].message_type = _FROMFUNCTION_EGRESSMESSAGE |
| _FROMFUNCTION_INVOCATIONRESPONSE.containing_type = _FROMFUNCTION |
| _FROMFUNCTION.fields_by_name['invocation_result'].message_type = _FROMFUNCTION_INVOCATIONRESPONSE |
| _FROMFUNCTION.oneofs_by_name['response'].fields.append( |
| _FROMFUNCTION.fields_by_name['invocation_result']) |
| _FROMFUNCTION.fields_by_name['invocation_result'].containing_oneof = _FROMFUNCTION.oneofs_by_name['response'] |
| DESCRIPTOR.message_types_by_name['Address'] = _ADDRESS |
| DESCRIPTOR.message_types_by_name['ToFunction'] = _TOFUNCTION |
| DESCRIPTOR.message_types_by_name['FromFunction'] = _FROMFUNCTION |
| _sym_db.RegisterFileDescriptor(DESCRIPTOR) |
| |
| Address = _reflection.GeneratedProtocolMessageType('Address', (_message.Message,), { |
| 'DESCRIPTOR' : _ADDRESS, |
| '__module__' : 'request_reply_pb2' |
| # @@protoc_insertion_point(class_scope:org.apache.flink.statefun.flink.core.polyglot.Address) |
| }) |
| _sym_db.RegisterMessage(Address) |
| |
| ToFunction = _reflection.GeneratedProtocolMessageType('ToFunction', (_message.Message,), { |
| |
| 'PersistedValue' : _reflection.GeneratedProtocolMessageType('PersistedValue', (_message.Message,), { |
| 'DESCRIPTOR' : _TOFUNCTION_PERSISTEDVALUE, |
| '__module__' : 'request_reply_pb2' |
| # @@protoc_insertion_point(class_scope:org.apache.flink.statefun.flink.core.polyglot.ToFunction.PersistedValue) |
| }) |
| , |
| |
| 'Invocation' : _reflection.GeneratedProtocolMessageType('Invocation', (_message.Message,), { |
| 'DESCRIPTOR' : _TOFUNCTION_INVOCATION, |
| '__module__' : 'request_reply_pb2' |
| # @@protoc_insertion_point(class_scope:org.apache.flink.statefun.flink.core.polyglot.ToFunction.Invocation) |
| }) |
| , |
| |
| 'InvocationBatchRequest' : _reflection.GeneratedProtocolMessageType('InvocationBatchRequest', (_message.Message,), { |
| 'DESCRIPTOR' : _TOFUNCTION_INVOCATIONBATCHREQUEST, |
| '__module__' : 'request_reply_pb2' |
| # @@protoc_insertion_point(class_scope:org.apache.flink.statefun.flink.core.polyglot.ToFunction.InvocationBatchRequest) |
| }) |
| , |
| 'DESCRIPTOR' : _TOFUNCTION, |
| '__module__' : 'request_reply_pb2' |
| # @@protoc_insertion_point(class_scope:org.apache.flink.statefun.flink.core.polyglot.ToFunction) |
| }) |
| _sym_db.RegisterMessage(ToFunction) |
| _sym_db.RegisterMessage(ToFunction.PersistedValue) |
| _sym_db.RegisterMessage(ToFunction.Invocation) |
| _sym_db.RegisterMessage(ToFunction.InvocationBatchRequest) |
| |
| FromFunction = _reflection.GeneratedProtocolMessageType('FromFunction', (_message.Message,), { |
| |
| 'PersistedValueMutation' : _reflection.GeneratedProtocolMessageType('PersistedValueMutation', (_message.Message,), { |
| 'DESCRIPTOR' : _FROMFUNCTION_PERSISTEDVALUEMUTATION, |
| '__module__' : 'request_reply_pb2' |
| # @@protoc_insertion_point(class_scope:org.apache.flink.statefun.flink.core.polyglot.FromFunction.PersistedValueMutation) |
| }) |
| , |
| |
| 'Invocation' : _reflection.GeneratedProtocolMessageType('Invocation', (_message.Message,), { |
| 'DESCRIPTOR' : _FROMFUNCTION_INVOCATION, |
| '__module__' : 'request_reply_pb2' |
| # @@protoc_insertion_point(class_scope:org.apache.flink.statefun.flink.core.polyglot.FromFunction.Invocation) |
| }) |
| , |
| |
| 'DelayedInvocation' : _reflection.GeneratedProtocolMessageType('DelayedInvocation', (_message.Message,), { |
| 'DESCRIPTOR' : _FROMFUNCTION_DELAYEDINVOCATION, |
| '__module__' : 'request_reply_pb2' |
| # @@protoc_insertion_point(class_scope:org.apache.flink.statefun.flink.core.polyglot.FromFunction.DelayedInvocation) |
| }) |
| , |
| |
| 'EgressMessage' : _reflection.GeneratedProtocolMessageType('EgressMessage', (_message.Message,), { |
| 'DESCRIPTOR' : _FROMFUNCTION_EGRESSMESSAGE, |
| '__module__' : 'request_reply_pb2' |
| # @@protoc_insertion_point(class_scope:org.apache.flink.statefun.flink.core.polyglot.FromFunction.EgressMessage) |
| }) |
| , |
| |
| 'InvocationResponse' : _reflection.GeneratedProtocolMessageType('InvocationResponse', (_message.Message,), { |
| 'DESCRIPTOR' : _FROMFUNCTION_INVOCATIONRESPONSE, |
| '__module__' : 'request_reply_pb2' |
| # @@protoc_insertion_point(class_scope:org.apache.flink.statefun.flink.core.polyglot.FromFunction.InvocationResponse) |
| }) |
| , |
| 'DESCRIPTOR' : _FROMFUNCTION, |
| '__module__' : 'request_reply_pb2' |
| # @@protoc_insertion_point(class_scope:org.apache.flink.statefun.flink.core.polyglot.FromFunction) |
| }) |
| _sym_db.RegisterMessage(FromFunction) |
| _sym_db.RegisterMessage(FromFunction.PersistedValueMutation) |
| _sym_db.RegisterMessage(FromFunction.Invocation) |
| _sym_db.RegisterMessage(FromFunction.DelayedInvocation) |
| _sym_db.RegisterMessage(FromFunction.EgressMessage) |
| _sym_db.RegisterMessage(FromFunction.InvocationResponse) |
| |
| |
| DESCRIPTOR._options = None |
| # @@protoc_insertion_point(module_scope) |