| # |
| # 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 mypy-protobuf. Do not edit manually! |
| isort:skip_file |
| |
| 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. |
| """ |
| import builtins |
| import collections.abc |
| import google.protobuf.descriptor |
| import google.protobuf.internal.containers |
| import google.protobuf.internal.enum_type_wrapper |
| import google.protobuf.message |
| import sys |
| import typing |
| |
| if sys.version_info >= (3, 10): |
| import typing as typing_extensions |
| else: |
| import typing_extensions |
| |
| DESCRIPTOR: google.protobuf.descriptor.FileDescriptor |
| |
| class _HandleState: |
| ValueType = typing.NewType("ValueType", builtins.int) |
| V: typing_extensions.TypeAlias = ValueType |
| |
| class _HandleStateEnumTypeWrapper( |
| google.protobuf.internal.enum_type_wrapper._EnumTypeWrapper[_HandleState.ValueType], |
| builtins.type, |
| ): # noqa: F821 |
| DESCRIPTOR: google.protobuf.descriptor.EnumDescriptor |
| PRE_INIT: _HandleState.ValueType # 0 |
| CREATED: _HandleState.ValueType # 1 |
| INITIALIZED: _HandleState.ValueType # 2 |
| DATA_PROCESSED: _HandleState.ValueType # 3 |
| TIMER_PROCESSED: _HandleState.ValueType # 4 |
| CLOSED: _HandleState.ValueType # 5 |
| |
| class HandleState(_HandleState, metaclass=_HandleStateEnumTypeWrapper): ... |
| |
| PRE_INIT: HandleState.ValueType # 0 |
| CREATED: HandleState.ValueType # 1 |
| INITIALIZED: HandleState.ValueType # 2 |
| DATA_PROCESSED: HandleState.ValueType # 3 |
| TIMER_PROCESSED: HandleState.ValueType # 4 |
| CLOSED: HandleState.ValueType # 5 |
| global___HandleState = HandleState |
| |
| class StateRequest(google.protobuf.message.Message): |
| DESCRIPTOR: google.protobuf.descriptor.Descriptor |
| |
| VERSION_FIELD_NUMBER: builtins.int |
| STATEFULPROCESSORCALL_FIELD_NUMBER: builtins.int |
| STATEVARIABLEREQUEST_FIELD_NUMBER: builtins.int |
| IMPLICITGROUPINGKEYREQUEST_FIELD_NUMBER: builtins.int |
| TIMERREQUEST_FIELD_NUMBER: builtins.int |
| UTILSREQUEST_FIELD_NUMBER: builtins.int |
| version: builtins.int |
| @property |
| def statefulProcessorCall(self) -> global___StatefulProcessorCall: ... |
| @property |
| def stateVariableRequest(self) -> global___StateVariableRequest: ... |
| @property |
| def implicitGroupingKeyRequest(self) -> global___ImplicitGroupingKeyRequest: ... |
| @property |
| def timerRequest(self) -> global___TimerRequest: ... |
| @property |
| def utilsRequest(self) -> global___UtilsRequest: ... |
| def __init__( |
| self, |
| *, |
| version: builtins.int = ..., |
| statefulProcessorCall: global___StatefulProcessorCall | None = ..., |
| stateVariableRequest: global___StateVariableRequest | None = ..., |
| implicitGroupingKeyRequest: global___ImplicitGroupingKeyRequest | None = ..., |
| timerRequest: global___TimerRequest | None = ..., |
| utilsRequest: global___UtilsRequest | None = ..., |
| ) -> None: ... |
| def HasField( |
| self, |
| field_name: typing_extensions.Literal[ |
| "implicitGroupingKeyRequest", |
| b"implicitGroupingKeyRequest", |
| "method", |
| b"method", |
| "stateVariableRequest", |
| b"stateVariableRequest", |
| "statefulProcessorCall", |
| b"statefulProcessorCall", |
| "timerRequest", |
| b"timerRequest", |
| "utilsRequest", |
| b"utilsRequest", |
| ], |
| ) -> builtins.bool: ... |
| def ClearField( |
| self, |
| field_name: typing_extensions.Literal[ |
| "implicitGroupingKeyRequest", |
| b"implicitGroupingKeyRequest", |
| "method", |
| b"method", |
| "stateVariableRequest", |
| b"stateVariableRequest", |
| "statefulProcessorCall", |
| b"statefulProcessorCall", |
| "timerRequest", |
| b"timerRequest", |
| "utilsRequest", |
| b"utilsRequest", |
| "version", |
| b"version", |
| ], |
| ) -> None: ... |
| def WhichOneof( |
| self, oneof_group: typing_extensions.Literal["method", b"method"] |
| ) -> ( |
| typing_extensions.Literal[ |
| "statefulProcessorCall", |
| "stateVariableRequest", |
| "implicitGroupingKeyRequest", |
| "timerRequest", |
| "utilsRequest", |
| ] |
| | None |
| ): ... |
| |
| global___StateRequest = StateRequest |
| |
| class StateResponse(google.protobuf.message.Message): |
| DESCRIPTOR: google.protobuf.descriptor.Descriptor |
| |
| STATUSCODE_FIELD_NUMBER: builtins.int |
| ERRORMESSAGE_FIELD_NUMBER: builtins.int |
| VALUE_FIELD_NUMBER: builtins.int |
| statusCode: builtins.int |
| errorMessage: builtins.str |
| value: builtins.bytes |
| def __init__( |
| self, |
| *, |
| statusCode: builtins.int = ..., |
| errorMessage: builtins.str = ..., |
| value: builtins.bytes = ..., |
| ) -> None: ... |
| def ClearField( |
| self, |
| field_name: typing_extensions.Literal[ |
| "errorMessage", b"errorMessage", "statusCode", b"statusCode", "value", b"value" |
| ], |
| ) -> None: ... |
| |
| global___StateResponse = StateResponse |
| |
| class StateResponseWithLongTypeVal(google.protobuf.message.Message): |
| DESCRIPTOR: google.protobuf.descriptor.Descriptor |
| |
| STATUSCODE_FIELD_NUMBER: builtins.int |
| ERRORMESSAGE_FIELD_NUMBER: builtins.int |
| VALUE_FIELD_NUMBER: builtins.int |
| statusCode: builtins.int |
| errorMessage: builtins.str |
| value: builtins.int |
| def __init__( |
| self, |
| *, |
| statusCode: builtins.int = ..., |
| errorMessage: builtins.str = ..., |
| value: builtins.int = ..., |
| ) -> None: ... |
| def ClearField( |
| self, |
| field_name: typing_extensions.Literal[ |
| "errorMessage", b"errorMessage", "statusCode", b"statusCode", "value", b"value" |
| ], |
| ) -> None: ... |
| |
| global___StateResponseWithLongTypeVal = StateResponseWithLongTypeVal |
| |
| class StateResponseWithStringTypeVal(google.protobuf.message.Message): |
| DESCRIPTOR: google.protobuf.descriptor.Descriptor |
| |
| STATUSCODE_FIELD_NUMBER: builtins.int |
| ERRORMESSAGE_FIELD_NUMBER: builtins.int |
| VALUE_FIELD_NUMBER: builtins.int |
| statusCode: builtins.int |
| errorMessage: builtins.str |
| value: builtins.str |
| def __init__( |
| self, |
| *, |
| statusCode: builtins.int = ..., |
| errorMessage: builtins.str = ..., |
| value: builtins.str = ..., |
| ) -> None: ... |
| def ClearField( |
| self, |
| field_name: typing_extensions.Literal[ |
| "errorMessage", b"errorMessage", "statusCode", b"statusCode", "value", b"value" |
| ], |
| ) -> None: ... |
| |
| global___StateResponseWithStringTypeVal = StateResponseWithStringTypeVal |
| |
| class StateResponseWithListGet(google.protobuf.message.Message): |
| DESCRIPTOR: google.protobuf.descriptor.Descriptor |
| |
| STATUSCODE_FIELD_NUMBER: builtins.int |
| ERRORMESSAGE_FIELD_NUMBER: builtins.int |
| VALUE_FIELD_NUMBER: builtins.int |
| REQUIRENEXTFETCH_FIELD_NUMBER: builtins.int |
| statusCode: builtins.int |
| errorMessage: builtins.str |
| @property |
| def value( |
| self, |
| ) -> google.protobuf.internal.containers.RepeatedScalarFieldContainer[builtins.bytes]: ... |
| requireNextFetch: builtins.bool |
| def __init__( |
| self, |
| *, |
| statusCode: builtins.int = ..., |
| errorMessage: builtins.str = ..., |
| value: collections.abc.Iterable[builtins.bytes] | None = ..., |
| requireNextFetch: builtins.bool = ..., |
| ) -> None: ... |
| def ClearField( |
| self, |
| field_name: typing_extensions.Literal[ |
| "errorMessage", |
| b"errorMessage", |
| "requireNextFetch", |
| b"requireNextFetch", |
| "statusCode", |
| b"statusCode", |
| "value", |
| b"value", |
| ], |
| ) -> None: ... |
| |
| global___StateResponseWithListGet = StateResponseWithListGet |
| |
| class StateResponseWithMapKeysOrValues(google.protobuf.message.Message): |
| DESCRIPTOR: google.protobuf.descriptor.Descriptor |
| |
| STATUSCODE_FIELD_NUMBER: builtins.int |
| ERRORMESSAGE_FIELD_NUMBER: builtins.int |
| VALUE_FIELD_NUMBER: builtins.int |
| REQUIRENEXTFETCH_FIELD_NUMBER: builtins.int |
| statusCode: builtins.int |
| errorMessage: builtins.str |
| @property |
| def value( |
| self, |
| ) -> google.protobuf.internal.containers.RepeatedScalarFieldContainer[builtins.bytes]: ... |
| requireNextFetch: builtins.bool |
| def __init__( |
| self, |
| *, |
| statusCode: builtins.int = ..., |
| errorMessage: builtins.str = ..., |
| value: collections.abc.Iterable[builtins.bytes] | None = ..., |
| requireNextFetch: builtins.bool = ..., |
| ) -> None: ... |
| def ClearField( |
| self, |
| field_name: typing_extensions.Literal[ |
| "errorMessage", |
| b"errorMessage", |
| "requireNextFetch", |
| b"requireNextFetch", |
| "statusCode", |
| b"statusCode", |
| "value", |
| b"value", |
| ], |
| ) -> None: ... |
| |
| global___StateResponseWithMapKeysOrValues = StateResponseWithMapKeysOrValues |
| |
| class KeyAndValuePair(google.protobuf.message.Message): |
| DESCRIPTOR: google.protobuf.descriptor.Descriptor |
| |
| KEY_FIELD_NUMBER: builtins.int |
| VALUE_FIELD_NUMBER: builtins.int |
| key: builtins.bytes |
| value: builtins.bytes |
| def __init__( |
| self, |
| *, |
| key: builtins.bytes = ..., |
| value: builtins.bytes = ..., |
| ) -> None: ... |
| def ClearField( |
| self, field_name: typing_extensions.Literal["key", b"key", "value", b"value"] |
| ) -> None: ... |
| |
| global___KeyAndValuePair = KeyAndValuePair |
| |
| class StateResponseWithMapIterator(google.protobuf.message.Message): |
| DESCRIPTOR: google.protobuf.descriptor.Descriptor |
| |
| STATUSCODE_FIELD_NUMBER: builtins.int |
| ERRORMESSAGE_FIELD_NUMBER: builtins.int |
| KVPAIR_FIELD_NUMBER: builtins.int |
| REQUIRENEXTFETCH_FIELD_NUMBER: builtins.int |
| statusCode: builtins.int |
| errorMessage: builtins.str |
| @property |
| def kvPair( |
| self, |
| ) -> google.protobuf.internal.containers.RepeatedCompositeFieldContainer[ |
| global___KeyAndValuePair |
| ]: ... |
| requireNextFetch: builtins.bool |
| def __init__( |
| self, |
| *, |
| statusCode: builtins.int = ..., |
| errorMessage: builtins.str = ..., |
| kvPair: collections.abc.Iterable[global___KeyAndValuePair] | None = ..., |
| requireNextFetch: builtins.bool = ..., |
| ) -> None: ... |
| def ClearField( |
| self, |
| field_name: typing_extensions.Literal[ |
| "errorMessage", |
| b"errorMessage", |
| "kvPair", |
| b"kvPair", |
| "requireNextFetch", |
| b"requireNextFetch", |
| "statusCode", |
| b"statusCode", |
| ], |
| ) -> None: ... |
| |
| global___StateResponseWithMapIterator = StateResponseWithMapIterator |
| |
| class TimerInfo(google.protobuf.message.Message): |
| DESCRIPTOR: google.protobuf.descriptor.Descriptor |
| |
| KEY_FIELD_NUMBER: builtins.int |
| TIMESTAMPMS_FIELD_NUMBER: builtins.int |
| key: builtins.bytes |
| timestampMs: builtins.int |
| def __init__( |
| self, |
| *, |
| key: builtins.bytes | None = ..., |
| timestampMs: builtins.int = ..., |
| ) -> None: ... |
| def HasField( |
| self, field_name: typing_extensions.Literal["_key", b"_key", "key", b"key"] |
| ) -> builtins.bool: ... |
| def ClearField( |
| self, |
| field_name: typing_extensions.Literal[ |
| "_key", b"_key", "key", b"key", "timestampMs", b"timestampMs" |
| ], |
| ) -> None: ... |
| def WhichOneof( |
| self, oneof_group: typing_extensions.Literal["_key", b"_key"] |
| ) -> typing_extensions.Literal["key"] | None: ... |
| |
| global___TimerInfo = TimerInfo |
| |
| class StateResponseWithTimer(google.protobuf.message.Message): |
| DESCRIPTOR: google.protobuf.descriptor.Descriptor |
| |
| STATUSCODE_FIELD_NUMBER: builtins.int |
| ERRORMESSAGE_FIELD_NUMBER: builtins.int |
| TIMER_FIELD_NUMBER: builtins.int |
| REQUIRENEXTFETCH_FIELD_NUMBER: builtins.int |
| statusCode: builtins.int |
| errorMessage: builtins.str |
| @property |
| def timer( |
| self, |
| ) -> google.protobuf.internal.containers.RepeatedCompositeFieldContainer[ |
| global___TimerInfo |
| ]: ... |
| requireNextFetch: builtins.bool |
| def __init__( |
| self, |
| *, |
| statusCode: builtins.int = ..., |
| errorMessage: builtins.str = ..., |
| timer: collections.abc.Iterable[global___TimerInfo] | None = ..., |
| requireNextFetch: builtins.bool = ..., |
| ) -> None: ... |
| def ClearField( |
| self, |
| field_name: typing_extensions.Literal[ |
| "errorMessage", |
| b"errorMessage", |
| "requireNextFetch", |
| b"requireNextFetch", |
| "statusCode", |
| b"statusCode", |
| "timer", |
| b"timer", |
| ], |
| ) -> None: ... |
| |
| global___StateResponseWithTimer = StateResponseWithTimer |
| |
| class StatefulProcessorCall(google.protobuf.message.Message): |
| DESCRIPTOR: google.protobuf.descriptor.Descriptor |
| |
| SETHANDLESTATE_FIELD_NUMBER: builtins.int |
| GETVALUESTATE_FIELD_NUMBER: builtins.int |
| GETLISTSTATE_FIELD_NUMBER: builtins.int |
| GETMAPSTATE_FIELD_NUMBER: builtins.int |
| TIMERSTATECALL_FIELD_NUMBER: builtins.int |
| DELETEIFEXISTS_FIELD_NUMBER: builtins.int |
| @property |
| def setHandleState(self) -> global___SetHandleState: ... |
| @property |
| def getValueState(self) -> global___StateCallCommand: ... |
| @property |
| def getListState(self) -> global___StateCallCommand: ... |
| @property |
| def getMapState(self) -> global___StateCallCommand: ... |
| @property |
| def timerStateCall(self) -> global___TimerStateCallCommand: ... |
| @property |
| def deleteIfExists(self) -> global___StateCallCommand: ... |
| def __init__( |
| self, |
| *, |
| setHandleState: global___SetHandleState | None = ..., |
| getValueState: global___StateCallCommand | None = ..., |
| getListState: global___StateCallCommand | None = ..., |
| getMapState: global___StateCallCommand | None = ..., |
| timerStateCall: global___TimerStateCallCommand | None = ..., |
| deleteIfExists: global___StateCallCommand | None = ..., |
| ) -> None: ... |
| def HasField( |
| self, |
| field_name: typing_extensions.Literal[ |
| "deleteIfExists", |
| b"deleteIfExists", |
| "getListState", |
| b"getListState", |
| "getMapState", |
| b"getMapState", |
| "getValueState", |
| b"getValueState", |
| "method", |
| b"method", |
| "setHandleState", |
| b"setHandleState", |
| "timerStateCall", |
| b"timerStateCall", |
| ], |
| ) -> builtins.bool: ... |
| def ClearField( |
| self, |
| field_name: typing_extensions.Literal[ |
| "deleteIfExists", |
| b"deleteIfExists", |
| "getListState", |
| b"getListState", |
| "getMapState", |
| b"getMapState", |
| "getValueState", |
| b"getValueState", |
| "method", |
| b"method", |
| "setHandleState", |
| b"setHandleState", |
| "timerStateCall", |
| b"timerStateCall", |
| ], |
| ) -> None: ... |
| def WhichOneof( |
| self, oneof_group: typing_extensions.Literal["method", b"method"] |
| ) -> ( |
| typing_extensions.Literal[ |
| "setHandleState", |
| "getValueState", |
| "getListState", |
| "getMapState", |
| "timerStateCall", |
| "deleteIfExists", |
| ] |
| | None |
| ): ... |
| |
| global___StatefulProcessorCall = StatefulProcessorCall |
| |
| class StateVariableRequest(google.protobuf.message.Message): |
| DESCRIPTOR: google.protobuf.descriptor.Descriptor |
| |
| VALUESTATECALL_FIELD_NUMBER: builtins.int |
| LISTSTATECALL_FIELD_NUMBER: builtins.int |
| MAPSTATECALL_FIELD_NUMBER: builtins.int |
| @property |
| def valueStateCall(self) -> global___ValueStateCall: ... |
| @property |
| def listStateCall(self) -> global___ListStateCall: ... |
| @property |
| def mapStateCall(self) -> global___MapStateCall: ... |
| def __init__( |
| self, |
| *, |
| valueStateCall: global___ValueStateCall | None = ..., |
| listStateCall: global___ListStateCall | None = ..., |
| mapStateCall: global___MapStateCall | None = ..., |
| ) -> None: ... |
| def HasField( |
| self, |
| field_name: typing_extensions.Literal[ |
| "listStateCall", |
| b"listStateCall", |
| "mapStateCall", |
| b"mapStateCall", |
| "method", |
| b"method", |
| "valueStateCall", |
| b"valueStateCall", |
| ], |
| ) -> builtins.bool: ... |
| def ClearField( |
| self, |
| field_name: typing_extensions.Literal[ |
| "listStateCall", |
| b"listStateCall", |
| "mapStateCall", |
| b"mapStateCall", |
| "method", |
| b"method", |
| "valueStateCall", |
| b"valueStateCall", |
| ], |
| ) -> None: ... |
| def WhichOneof( |
| self, oneof_group: typing_extensions.Literal["method", b"method"] |
| ) -> typing_extensions.Literal["valueStateCall", "listStateCall", "mapStateCall"] | None: ... |
| |
| global___StateVariableRequest = StateVariableRequest |
| |
| class ImplicitGroupingKeyRequest(google.protobuf.message.Message): |
| DESCRIPTOR: google.protobuf.descriptor.Descriptor |
| |
| SETIMPLICITKEY_FIELD_NUMBER: builtins.int |
| REMOVEIMPLICITKEY_FIELD_NUMBER: builtins.int |
| @property |
| def setImplicitKey(self) -> global___SetImplicitKey: ... |
| @property |
| def removeImplicitKey(self) -> global___RemoveImplicitKey: ... |
| def __init__( |
| self, |
| *, |
| setImplicitKey: global___SetImplicitKey | None = ..., |
| removeImplicitKey: global___RemoveImplicitKey | None = ..., |
| ) -> None: ... |
| def HasField( |
| self, |
| field_name: typing_extensions.Literal[ |
| "method", |
| b"method", |
| "removeImplicitKey", |
| b"removeImplicitKey", |
| "setImplicitKey", |
| b"setImplicitKey", |
| ], |
| ) -> builtins.bool: ... |
| def ClearField( |
| self, |
| field_name: typing_extensions.Literal[ |
| "method", |
| b"method", |
| "removeImplicitKey", |
| b"removeImplicitKey", |
| "setImplicitKey", |
| b"setImplicitKey", |
| ], |
| ) -> None: ... |
| def WhichOneof( |
| self, oneof_group: typing_extensions.Literal["method", b"method"] |
| ) -> typing_extensions.Literal["setImplicitKey", "removeImplicitKey"] | None: ... |
| |
| global___ImplicitGroupingKeyRequest = ImplicitGroupingKeyRequest |
| |
| class TimerRequest(google.protobuf.message.Message): |
| DESCRIPTOR: google.protobuf.descriptor.Descriptor |
| |
| TIMERVALUEREQUEST_FIELD_NUMBER: builtins.int |
| EXPIRYTIMERREQUEST_FIELD_NUMBER: builtins.int |
| @property |
| def timerValueRequest(self) -> global___TimerValueRequest: ... |
| @property |
| def expiryTimerRequest(self) -> global___ExpiryTimerRequest: ... |
| def __init__( |
| self, |
| *, |
| timerValueRequest: global___TimerValueRequest | None = ..., |
| expiryTimerRequest: global___ExpiryTimerRequest | None = ..., |
| ) -> None: ... |
| def HasField( |
| self, |
| field_name: typing_extensions.Literal[ |
| "expiryTimerRequest", |
| b"expiryTimerRequest", |
| "method", |
| b"method", |
| "timerValueRequest", |
| b"timerValueRequest", |
| ], |
| ) -> builtins.bool: ... |
| def ClearField( |
| self, |
| field_name: typing_extensions.Literal[ |
| "expiryTimerRequest", |
| b"expiryTimerRequest", |
| "method", |
| b"method", |
| "timerValueRequest", |
| b"timerValueRequest", |
| ], |
| ) -> None: ... |
| def WhichOneof( |
| self, oneof_group: typing_extensions.Literal["method", b"method"] |
| ) -> typing_extensions.Literal["timerValueRequest", "expiryTimerRequest"] | None: ... |
| |
| global___TimerRequest = TimerRequest |
| |
| class TimerValueRequest(google.protobuf.message.Message): |
| DESCRIPTOR: google.protobuf.descriptor.Descriptor |
| |
| GETPROCESSINGTIMER_FIELD_NUMBER: builtins.int |
| GETWATERMARK_FIELD_NUMBER: builtins.int |
| @property |
| def getProcessingTimer(self) -> global___GetProcessingTime: ... |
| @property |
| def getWatermark(self) -> global___GetWatermark: ... |
| def __init__( |
| self, |
| *, |
| getProcessingTimer: global___GetProcessingTime | None = ..., |
| getWatermark: global___GetWatermark | None = ..., |
| ) -> None: ... |
| def HasField( |
| self, |
| field_name: typing_extensions.Literal[ |
| "getProcessingTimer", |
| b"getProcessingTimer", |
| "getWatermark", |
| b"getWatermark", |
| "method", |
| b"method", |
| ], |
| ) -> builtins.bool: ... |
| def ClearField( |
| self, |
| field_name: typing_extensions.Literal[ |
| "getProcessingTimer", |
| b"getProcessingTimer", |
| "getWatermark", |
| b"getWatermark", |
| "method", |
| b"method", |
| ], |
| ) -> None: ... |
| def WhichOneof( |
| self, oneof_group: typing_extensions.Literal["method", b"method"] |
| ) -> typing_extensions.Literal["getProcessingTimer", "getWatermark"] | None: ... |
| |
| global___TimerValueRequest = TimerValueRequest |
| |
| class ExpiryTimerRequest(google.protobuf.message.Message): |
| DESCRIPTOR: google.protobuf.descriptor.Descriptor |
| |
| ITERATORID_FIELD_NUMBER: builtins.int |
| EXPIRYTIMESTAMPMS_FIELD_NUMBER: builtins.int |
| iteratorId: builtins.str |
| expiryTimestampMs: builtins.int |
| def __init__( |
| self, |
| *, |
| iteratorId: builtins.str = ..., |
| expiryTimestampMs: builtins.int = ..., |
| ) -> None: ... |
| def ClearField( |
| self, |
| field_name: typing_extensions.Literal[ |
| "expiryTimestampMs", b"expiryTimestampMs", "iteratorId", b"iteratorId" |
| ], |
| ) -> None: ... |
| |
| global___ExpiryTimerRequest = ExpiryTimerRequest |
| |
| class GetProcessingTime(google.protobuf.message.Message): |
| DESCRIPTOR: google.protobuf.descriptor.Descriptor |
| |
| def __init__( |
| self, |
| ) -> None: ... |
| |
| global___GetProcessingTime = GetProcessingTime |
| |
| class GetWatermark(google.protobuf.message.Message): |
| DESCRIPTOR: google.protobuf.descriptor.Descriptor |
| |
| def __init__( |
| self, |
| ) -> None: ... |
| |
| global___GetWatermark = GetWatermark |
| |
| class UtilsRequest(google.protobuf.message.Message): |
| DESCRIPTOR: google.protobuf.descriptor.Descriptor |
| |
| PARSESTRINGSCHEMA_FIELD_NUMBER: builtins.int |
| @property |
| def parseStringSchema(self) -> global___ParseStringSchema: ... |
| def __init__( |
| self, |
| *, |
| parseStringSchema: global___ParseStringSchema | None = ..., |
| ) -> None: ... |
| def HasField( |
| self, |
| field_name: typing_extensions.Literal[ |
| "method", b"method", "parseStringSchema", b"parseStringSchema" |
| ], |
| ) -> builtins.bool: ... |
| def ClearField( |
| self, |
| field_name: typing_extensions.Literal[ |
| "method", b"method", "parseStringSchema", b"parseStringSchema" |
| ], |
| ) -> None: ... |
| def WhichOneof( |
| self, oneof_group: typing_extensions.Literal["method", b"method"] |
| ) -> typing_extensions.Literal["parseStringSchema"] | None: ... |
| |
| global___UtilsRequest = UtilsRequest |
| |
| class ParseStringSchema(google.protobuf.message.Message): |
| DESCRIPTOR: google.protobuf.descriptor.Descriptor |
| |
| SCHEMA_FIELD_NUMBER: builtins.int |
| schema: builtins.str |
| def __init__( |
| self, |
| *, |
| schema: builtins.str = ..., |
| ) -> None: ... |
| def ClearField(self, field_name: typing_extensions.Literal["schema", b"schema"]) -> None: ... |
| |
| global___ParseStringSchema = ParseStringSchema |
| |
| class StateCallCommand(google.protobuf.message.Message): |
| DESCRIPTOR: google.protobuf.descriptor.Descriptor |
| |
| STATENAME_FIELD_NUMBER: builtins.int |
| SCHEMA_FIELD_NUMBER: builtins.int |
| MAPSTATEVALUESCHEMA_FIELD_NUMBER: builtins.int |
| TTL_FIELD_NUMBER: builtins.int |
| stateName: builtins.str |
| schema: builtins.str |
| mapStateValueSchema: builtins.str |
| @property |
| def ttl(self) -> global___TTLConfig: ... |
| def __init__( |
| self, |
| *, |
| stateName: builtins.str = ..., |
| schema: builtins.str = ..., |
| mapStateValueSchema: builtins.str = ..., |
| ttl: global___TTLConfig | None = ..., |
| ) -> None: ... |
| def HasField(self, field_name: typing_extensions.Literal["ttl", b"ttl"]) -> builtins.bool: ... |
| def ClearField( |
| self, |
| field_name: typing_extensions.Literal[ |
| "mapStateValueSchema", |
| b"mapStateValueSchema", |
| "schema", |
| b"schema", |
| "stateName", |
| b"stateName", |
| "ttl", |
| b"ttl", |
| ], |
| ) -> None: ... |
| |
| global___StateCallCommand = StateCallCommand |
| |
| class TimerStateCallCommand(google.protobuf.message.Message): |
| DESCRIPTOR: google.protobuf.descriptor.Descriptor |
| |
| REGISTER_FIELD_NUMBER: builtins.int |
| DELETE_FIELD_NUMBER: builtins.int |
| LIST_FIELD_NUMBER: builtins.int |
| @property |
| def register(self) -> global___RegisterTimer: ... |
| @property |
| def delete(self) -> global___DeleteTimer: ... |
| @property |
| def list(self) -> global___ListTimers: ... |
| def __init__( |
| self, |
| *, |
| register: global___RegisterTimer | None = ..., |
| delete: global___DeleteTimer | None = ..., |
| list: global___ListTimers | None = ..., |
| ) -> None: ... |
| def HasField( |
| self, |
| field_name: typing_extensions.Literal[ |
| "delete", b"delete", "list", b"list", "method", b"method", "register", b"register" |
| ], |
| ) -> builtins.bool: ... |
| def ClearField( |
| self, |
| field_name: typing_extensions.Literal[ |
| "delete", b"delete", "list", b"list", "method", b"method", "register", b"register" |
| ], |
| ) -> None: ... |
| def WhichOneof( |
| self, oneof_group: typing_extensions.Literal["method", b"method"] |
| ) -> typing_extensions.Literal["register", "delete", "list"] | None: ... |
| |
| global___TimerStateCallCommand = TimerStateCallCommand |
| |
| class ValueStateCall(google.protobuf.message.Message): |
| DESCRIPTOR: google.protobuf.descriptor.Descriptor |
| |
| STATENAME_FIELD_NUMBER: builtins.int |
| EXISTS_FIELD_NUMBER: builtins.int |
| GET_FIELD_NUMBER: builtins.int |
| VALUESTATEUPDATE_FIELD_NUMBER: builtins.int |
| CLEAR_FIELD_NUMBER: builtins.int |
| stateName: builtins.str |
| @property |
| def exists(self) -> global___Exists: ... |
| @property |
| def get(self) -> global___Get: ... |
| @property |
| def valueStateUpdate(self) -> global___ValueStateUpdate: ... |
| @property |
| def clear(self) -> global___Clear: ... |
| def __init__( |
| self, |
| *, |
| stateName: builtins.str = ..., |
| exists: global___Exists | None = ..., |
| get: global___Get | None = ..., |
| valueStateUpdate: global___ValueStateUpdate | None = ..., |
| clear: global___Clear | None = ..., |
| ) -> None: ... |
| def HasField( |
| self, |
| field_name: typing_extensions.Literal[ |
| "clear", |
| b"clear", |
| "exists", |
| b"exists", |
| "get", |
| b"get", |
| "method", |
| b"method", |
| "valueStateUpdate", |
| b"valueStateUpdate", |
| ], |
| ) -> builtins.bool: ... |
| def ClearField( |
| self, |
| field_name: typing_extensions.Literal[ |
| "clear", |
| b"clear", |
| "exists", |
| b"exists", |
| "get", |
| b"get", |
| "method", |
| b"method", |
| "stateName", |
| b"stateName", |
| "valueStateUpdate", |
| b"valueStateUpdate", |
| ], |
| ) -> None: ... |
| def WhichOneof( |
| self, oneof_group: typing_extensions.Literal["method", b"method"] |
| ) -> typing_extensions.Literal["exists", "get", "valueStateUpdate", "clear"] | None: ... |
| |
| global___ValueStateCall = ValueStateCall |
| |
| class ListStateCall(google.protobuf.message.Message): |
| DESCRIPTOR: google.protobuf.descriptor.Descriptor |
| |
| STATENAME_FIELD_NUMBER: builtins.int |
| EXISTS_FIELD_NUMBER: builtins.int |
| LISTSTATEGET_FIELD_NUMBER: builtins.int |
| LISTSTATEPUT_FIELD_NUMBER: builtins.int |
| APPENDVALUE_FIELD_NUMBER: builtins.int |
| APPENDLIST_FIELD_NUMBER: builtins.int |
| CLEAR_FIELD_NUMBER: builtins.int |
| stateName: builtins.str |
| @property |
| def exists(self) -> global___Exists: ... |
| @property |
| def listStateGet(self) -> global___ListStateGet: ... |
| @property |
| def listStatePut(self) -> global___ListStatePut: ... |
| @property |
| def appendValue(self) -> global___AppendValue: ... |
| @property |
| def appendList(self) -> global___AppendList: ... |
| @property |
| def clear(self) -> global___Clear: ... |
| def __init__( |
| self, |
| *, |
| stateName: builtins.str = ..., |
| exists: global___Exists | None = ..., |
| listStateGet: global___ListStateGet | None = ..., |
| listStatePut: global___ListStatePut | None = ..., |
| appendValue: global___AppendValue | None = ..., |
| appendList: global___AppendList | None = ..., |
| clear: global___Clear | None = ..., |
| ) -> None: ... |
| def HasField( |
| self, |
| field_name: typing_extensions.Literal[ |
| "appendList", |
| b"appendList", |
| "appendValue", |
| b"appendValue", |
| "clear", |
| b"clear", |
| "exists", |
| b"exists", |
| "listStateGet", |
| b"listStateGet", |
| "listStatePut", |
| b"listStatePut", |
| "method", |
| b"method", |
| ], |
| ) -> builtins.bool: ... |
| def ClearField( |
| self, |
| field_name: typing_extensions.Literal[ |
| "appendList", |
| b"appendList", |
| "appendValue", |
| b"appendValue", |
| "clear", |
| b"clear", |
| "exists", |
| b"exists", |
| "listStateGet", |
| b"listStateGet", |
| "listStatePut", |
| b"listStatePut", |
| "method", |
| b"method", |
| "stateName", |
| b"stateName", |
| ], |
| ) -> None: ... |
| def WhichOneof( |
| self, oneof_group: typing_extensions.Literal["method", b"method"] |
| ) -> ( |
| typing_extensions.Literal[ |
| "exists", "listStateGet", "listStatePut", "appendValue", "appendList", "clear" |
| ] |
| | None |
| ): ... |
| |
| global___ListStateCall = ListStateCall |
| |
| class MapStateCall(google.protobuf.message.Message): |
| DESCRIPTOR: google.protobuf.descriptor.Descriptor |
| |
| STATENAME_FIELD_NUMBER: builtins.int |
| EXISTS_FIELD_NUMBER: builtins.int |
| GETVALUE_FIELD_NUMBER: builtins.int |
| CONTAINSKEY_FIELD_NUMBER: builtins.int |
| UPDATEVALUE_FIELD_NUMBER: builtins.int |
| ITERATOR_FIELD_NUMBER: builtins.int |
| KEYS_FIELD_NUMBER: builtins.int |
| VALUES_FIELD_NUMBER: builtins.int |
| REMOVEKEY_FIELD_NUMBER: builtins.int |
| CLEAR_FIELD_NUMBER: builtins.int |
| stateName: builtins.str |
| @property |
| def exists(self) -> global___Exists: ... |
| @property |
| def getValue(self) -> global___GetValue: ... |
| @property |
| def containsKey(self) -> global___ContainsKey: ... |
| @property |
| def updateValue(self) -> global___UpdateValue: ... |
| @property |
| def iterator(self) -> global___Iterator: ... |
| @property |
| def keys(self) -> global___Keys: ... |
| @property |
| def values(self) -> global___Values: ... |
| @property |
| def removeKey(self) -> global___RemoveKey: ... |
| @property |
| def clear(self) -> global___Clear: ... |
| def __init__( |
| self, |
| *, |
| stateName: builtins.str = ..., |
| exists: global___Exists | None = ..., |
| getValue: global___GetValue | None = ..., |
| containsKey: global___ContainsKey | None = ..., |
| updateValue: global___UpdateValue | None = ..., |
| iterator: global___Iterator | None = ..., |
| keys: global___Keys | None = ..., |
| values: global___Values | None = ..., |
| removeKey: global___RemoveKey | None = ..., |
| clear: global___Clear | None = ..., |
| ) -> None: ... |
| def HasField( |
| self, |
| field_name: typing_extensions.Literal[ |
| "clear", |
| b"clear", |
| "containsKey", |
| b"containsKey", |
| "exists", |
| b"exists", |
| "getValue", |
| b"getValue", |
| "iterator", |
| b"iterator", |
| "keys", |
| b"keys", |
| "method", |
| b"method", |
| "removeKey", |
| b"removeKey", |
| "updateValue", |
| b"updateValue", |
| "values", |
| b"values", |
| ], |
| ) -> builtins.bool: ... |
| def ClearField( |
| self, |
| field_name: typing_extensions.Literal[ |
| "clear", |
| b"clear", |
| "containsKey", |
| b"containsKey", |
| "exists", |
| b"exists", |
| "getValue", |
| b"getValue", |
| "iterator", |
| b"iterator", |
| "keys", |
| b"keys", |
| "method", |
| b"method", |
| "removeKey", |
| b"removeKey", |
| "stateName", |
| b"stateName", |
| "updateValue", |
| b"updateValue", |
| "values", |
| b"values", |
| ], |
| ) -> None: ... |
| def WhichOneof( |
| self, oneof_group: typing_extensions.Literal["method", b"method"] |
| ) -> ( |
| typing_extensions.Literal[ |
| "exists", |
| "getValue", |
| "containsKey", |
| "updateValue", |
| "iterator", |
| "keys", |
| "values", |
| "removeKey", |
| "clear", |
| ] |
| | None |
| ): ... |
| |
| global___MapStateCall = MapStateCall |
| |
| class SetImplicitKey(google.protobuf.message.Message): |
| DESCRIPTOR: google.protobuf.descriptor.Descriptor |
| |
| KEY_FIELD_NUMBER: builtins.int |
| key: builtins.bytes |
| def __init__( |
| self, |
| *, |
| key: builtins.bytes = ..., |
| ) -> None: ... |
| def ClearField(self, field_name: typing_extensions.Literal["key", b"key"]) -> None: ... |
| |
| global___SetImplicitKey = SetImplicitKey |
| |
| class RemoveImplicitKey(google.protobuf.message.Message): |
| DESCRIPTOR: google.protobuf.descriptor.Descriptor |
| |
| def __init__( |
| self, |
| ) -> None: ... |
| |
| global___RemoveImplicitKey = RemoveImplicitKey |
| |
| class Exists(google.protobuf.message.Message): |
| DESCRIPTOR: google.protobuf.descriptor.Descriptor |
| |
| def __init__( |
| self, |
| ) -> None: ... |
| |
| global___Exists = Exists |
| |
| class Get(google.protobuf.message.Message): |
| DESCRIPTOR: google.protobuf.descriptor.Descriptor |
| |
| def __init__( |
| self, |
| ) -> None: ... |
| |
| global___Get = Get |
| |
| class RegisterTimer(google.protobuf.message.Message): |
| DESCRIPTOR: google.protobuf.descriptor.Descriptor |
| |
| EXPIRYTIMESTAMPMS_FIELD_NUMBER: builtins.int |
| expiryTimestampMs: builtins.int |
| def __init__( |
| self, |
| *, |
| expiryTimestampMs: builtins.int = ..., |
| ) -> None: ... |
| def ClearField( |
| self, field_name: typing_extensions.Literal["expiryTimestampMs", b"expiryTimestampMs"] |
| ) -> None: ... |
| |
| global___RegisterTimer = RegisterTimer |
| |
| class DeleteTimer(google.protobuf.message.Message): |
| DESCRIPTOR: google.protobuf.descriptor.Descriptor |
| |
| EXPIRYTIMESTAMPMS_FIELD_NUMBER: builtins.int |
| expiryTimestampMs: builtins.int |
| def __init__( |
| self, |
| *, |
| expiryTimestampMs: builtins.int = ..., |
| ) -> None: ... |
| def ClearField( |
| self, field_name: typing_extensions.Literal["expiryTimestampMs", b"expiryTimestampMs"] |
| ) -> None: ... |
| |
| global___DeleteTimer = DeleteTimer |
| |
| class ListTimers(google.protobuf.message.Message): |
| DESCRIPTOR: google.protobuf.descriptor.Descriptor |
| |
| ITERATORID_FIELD_NUMBER: builtins.int |
| iteratorId: builtins.str |
| def __init__( |
| self, |
| *, |
| iteratorId: builtins.str = ..., |
| ) -> None: ... |
| def ClearField( |
| self, field_name: typing_extensions.Literal["iteratorId", b"iteratorId"] |
| ) -> None: ... |
| |
| global___ListTimers = ListTimers |
| |
| class ValueStateUpdate(google.protobuf.message.Message): |
| DESCRIPTOR: google.protobuf.descriptor.Descriptor |
| |
| VALUE_FIELD_NUMBER: builtins.int |
| value: builtins.bytes |
| def __init__( |
| self, |
| *, |
| value: builtins.bytes = ..., |
| ) -> None: ... |
| def ClearField(self, field_name: typing_extensions.Literal["value", b"value"]) -> None: ... |
| |
| global___ValueStateUpdate = ValueStateUpdate |
| |
| class Clear(google.protobuf.message.Message): |
| DESCRIPTOR: google.protobuf.descriptor.Descriptor |
| |
| def __init__( |
| self, |
| ) -> None: ... |
| |
| global___Clear = Clear |
| |
| class ListStateGet(google.protobuf.message.Message): |
| DESCRIPTOR: google.protobuf.descriptor.Descriptor |
| |
| ITERATORID_FIELD_NUMBER: builtins.int |
| iteratorId: builtins.str |
| def __init__( |
| self, |
| *, |
| iteratorId: builtins.str = ..., |
| ) -> None: ... |
| def ClearField( |
| self, field_name: typing_extensions.Literal["iteratorId", b"iteratorId"] |
| ) -> None: ... |
| |
| global___ListStateGet = ListStateGet |
| |
| class ListStatePut(google.protobuf.message.Message): |
| DESCRIPTOR: google.protobuf.descriptor.Descriptor |
| |
| VALUE_FIELD_NUMBER: builtins.int |
| FETCHWITHARROW_FIELD_NUMBER: builtins.int |
| @property |
| def value( |
| self, |
| ) -> google.protobuf.internal.containers.RepeatedScalarFieldContainer[builtins.bytes]: ... |
| fetchWithArrow: builtins.bool |
| def __init__( |
| self, |
| *, |
| value: collections.abc.Iterable[builtins.bytes] | None = ..., |
| fetchWithArrow: builtins.bool = ..., |
| ) -> None: ... |
| def ClearField( |
| self, |
| field_name: typing_extensions.Literal[ |
| "fetchWithArrow", b"fetchWithArrow", "value", b"value" |
| ], |
| ) -> None: ... |
| |
| global___ListStatePut = ListStatePut |
| |
| class AppendValue(google.protobuf.message.Message): |
| DESCRIPTOR: google.protobuf.descriptor.Descriptor |
| |
| VALUE_FIELD_NUMBER: builtins.int |
| value: builtins.bytes |
| def __init__( |
| self, |
| *, |
| value: builtins.bytes = ..., |
| ) -> None: ... |
| def ClearField(self, field_name: typing_extensions.Literal["value", b"value"]) -> None: ... |
| |
| global___AppendValue = AppendValue |
| |
| class AppendList(google.protobuf.message.Message): |
| DESCRIPTOR: google.protobuf.descriptor.Descriptor |
| |
| VALUE_FIELD_NUMBER: builtins.int |
| FETCHWITHARROW_FIELD_NUMBER: builtins.int |
| @property |
| def value( |
| self, |
| ) -> google.protobuf.internal.containers.RepeatedScalarFieldContainer[builtins.bytes]: ... |
| fetchWithArrow: builtins.bool |
| def __init__( |
| self, |
| *, |
| value: collections.abc.Iterable[builtins.bytes] | None = ..., |
| fetchWithArrow: builtins.bool = ..., |
| ) -> None: ... |
| def ClearField( |
| self, |
| field_name: typing_extensions.Literal[ |
| "fetchWithArrow", b"fetchWithArrow", "value", b"value" |
| ], |
| ) -> None: ... |
| |
| global___AppendList = AppendList |
| |
| class GetValue(google.protobuf.message.Message): |
| DESCRIPTOR: google.protobuf.descriptor.Descriptor |
| |
| USERKEY_FIELD_NUMBER: builtins.int |
| userKey: builtins.bytes |
| def __init__( |
| self, |
| *, |
| userKey: builtins.bytes = ..., |
| ) -> None: ... |
| def ClearField(self, field_name: typing_extensions.Literal["userKey", b"userKey"]) -> None: ... |
| |
| global___GetValue = GetValue |
| |
| class ContainsKey(google.protobuf.message.Message): |
| DESCRIPTOR: google.protobuf.descriptor.Descriptor |
| |
| USERKEY_FIELD_NUMBER: builtins.int |
| userKey: builtins.bytes |
| def __init__( |
| self, |
| *, |
| userKey: builtins.bytes = ..., |
| ) -> None: ... |
| def ClearField(self, field_name: typing_extensions.Literal["userKey", b"userKey"]) -> None: ... |
| |
| global___ContainsKey = ContainsKey |
| |
| class UpdateValue(google.protobuf.message.Message): |
| DESCRIPTOR: google.protobuf.descriptor.Descriptor |
| |
| USERKEY_FIELD_NUMBER: builtins.int |
| VALUE_FIELD_NUMBER: builtins.int |
| userKey: builtins.bytes |
| value: builtins.bytes |
| def __init__( |
| self, |
| *, |
| userKey: builtins.bytes = ..., |
| value: builtins.bytes = ..., |
| ) -> None: ... |
| def ClearField( |
| self, field_name: typing_extensions.Literal["userKey", b"userKey", "value", b"value"] |
| ) -> None: ... |
| |
| global___UpdateValue = UpdateValue |
| |
| class Iterator(google.protobuf.message.Message): |
| DESCRIPTOR: google.protobuf.descriptor.Descriptor |
| |
| ITERATORID_FIELD_NUMBER: builtins.int |
| iteratorId: builtins.str |
| def __init__( |
| self, |
| *, |
| iteratorId: builtins.str = ..., |
| ) -> None: ... |
| def ClearField( |
| self, field_name: typing_extensions.Literal["iteratorId", b"iteratorId"] |
| ) -> None: ... |
| |
| global___Iterator = Iterator |
| |
| class Keys(google.protobuf.message.Message): |
| DESCRIPTOR: google.protobuf.descriptor.Descriptor |
| |
| ITERATORID_FIELD_NUMBER: builtins.int |
| iteratorId: builtins.str |
| def __init__( |
| self, |
| *, |
| iteratorId: builtins.str = ..., |
| ) -> None: ... |
| def ClearField( |
| self, field_name: typing_extensions.Literal["iteratorId", b"iteratorId"] |
| ) -> None: ... |
| |
| global___Keys = Keys |
| |
| class Values(google.protobuf.message.Message): |
| DESCRIPTOR: google.protobuf.descriptor.Descriptor |
| |
| ITERATORID_FIELD_NUMBER: builtins.int |
| iteratorId: builtins.str |
| def __init__( |
| self, |
| *, |
| iteratorId: builtins.str = ..., |
| ) -> None: ... |
| def ClearField( |
| self, field_name: typing_extensions.Literal["iteratorId", b"iteratorId"] |
| ) -> None: ... |
| |
| global___Values = Values |
| |
| class RemoveKey(google.protobuf.message.Message): |
| DESCRIPTOR: google.protobuf.descriptor.Descriptor |
| |
| USERKEY_FIELD_NUMBER: builtins.int |
| userKey: builtins.bytes |
| def __init__( |
| self, |
| *, |
| userKey: builtins.bytes = ..., |
| ) -> None: ... |
| def ClearField(self, field_name: typing_extensions.Literal["userKey", b"userKey"]) -> None: ... |
| |
| global___RemoveKey = RemoveKey |
| |
| class SetHandleState(google.protobuf.message.Message): |
| DESCRIPTOR: google.protobuf.descriptor.Descriptor |
| |
| STATE_FIELD_NUMBER: builtins.int |
| state: global___HandleState.ValueType |
| def __init__( |
| self, |
| *, |
| state: global___HandleState.ValueType = ..., |
| ) -> None: ... |
| def ClearField(self, field_name: typing_extensions.Literal["state", b"state"]) -> None: ... |
| |
| global___SetHandleState = SetHandleState |
| |
| class TTLConfig(google.protobuf.message.Message): |
| DESCRIPTOR: google.protobuf.descriptor.Descriptor |
| |
| DURATIONMS_FIELD_NUMBER: builtins.int |
| durationMs: builtins.int |
| def __init__( |
| self, |
| *, |
| durationMs: builtins.int = ..., |
| ) -> None: ... |
| def ClearField( |
| self, field_name: typing_extensions.Literal["durationMs", b"durationMs"] |
| ) -> None: ... |
| |
| global___TTLConfig = TTLConfig |
