1
- from google .protobuf import struct_pb2 as _struct_pb2
2
1
from google .protobuf import duration_pb2 as _duration_pb2
2
+ from google .protobuf import struct_pb2 as _struct_pb2
3
3
from google .protobuf .internal import containers as _containers
4
4
from google .protobuf .internal import enum_type_wrapper as _enum_type_wrapper
5
5
from google .protobuf import descriptor as _descriptor
6
6
from google .protobuf import message as _message
7
- from typing import ClassVar as _ClassVar , Iterable as _Iterable , Mapping as _Mapping , Optional as _Optional , Union as _Union
7
+ from collections .abc import Iterable as _Iterable , Mapping as _Mapping
8
+ from typing import ClassVar as _ClassVar , Optional as _Optional , Union as _Union
8
9
9
10
DESCRIPTOR : _descriptor .FileDescriptor
10
11
@@ -49,8 +50,8 @@ STATUS_CONDITION_TRUE: Status
49
50
STATUS_CONDITION_FALSE : Status
50
51
51
52
class RunFunctionRequest (_message .Message ):
52
- __slots__ = ("meta" , "observed" , "desired" , "input" , "context" , "extra_resources " , "credentials" )
53
- class ExtraResourcesEntry (_message .Message ):
53
+ __slots__ = ("meta" , "observed" , "desired" , "input" , "context" , "required_resources " , "credentials" )
54
+ class RequiredResourcesEntry (_message .Message ):
54
55
__slots__ = ("key" , "value" )
55
56
KEY_FIELD_NUMBER : _ClassVar [int ]
56
57
VALUE_FIELD_NUMBER : _ClassVar [int ]
@@ -69,16 +70,16 @@ class RunFunctionRequest(_message.Message):
69
70
DESIRED_FIELD_NUMBER : _ClassVar [int ]
70
71
INPUT_FIELD_NUMBER : _ClassVar [int ]
71
72
CONTEXT_FIELD_NUMBER : _ClassVar [int ]
72
- EXTRA_RESOURCES_FIELD_NUMBER : _ClassVar [int ]
73
+ REQUIRED_RESOURCES_FIELD_NUMBER : _ClassVar [int ]
73
74
CREDENTIALS_FIELD_NUMBER : _ClassVar [int ]
74
75
meta : RequestMeta
75
76
observed : State
76
77
desired : State
77
78
input : _struct_pb2 .Struct
78
79
context : _struct_pb2 .Struct
79
- extra_resources : _containers .MessageMap [str , Resources ]
80
+ required_resources : _containers .MessageMap [str , Resources ]
80
81
credentials : _containers .MessageMap [str , Credentials ]
81
- def __init__ (self , meta : _Optional [_Union [RequestMeta , _Mapping ]] = ..., observed : _Optional [_Union [State , _Mapping ]] = ..., desired : _Optional [_Union [State , _Mapping ]] = ..., input : _Optional [_Union [_struct_pb2 .Struct , _Mapping ]] = ..., context : _Optional [_Union [_struct_pb2 .Struct , _Mapping ]] = ..., extra_resources : _Optional [_Mapping [str , Resources ]] = ..., credentials : _Optional [_Mapping [str , Credentials ]] = ...) -> None : ...
82
+ def __init__ (self , meta : _Optional [_Union [RequestMeta , _Mapping ]] = ..., observed : _Optional [_Union [State , _Mapping ]] = ..., desired : _Optional [_Union [State , _Mapping ]] = ..., input : _Optional [_Union [_struct_pb2 .Struct , _Mapping ]] = ..., context : _Optional [_Union [_struct_pb2 .Struct , _Mapping ]] = ..., required_resources : _Optional [_Mapping [str , Resources ]] = ..., credentials : _Optional [_Mapping [str , Credentials ]] = ...) -> None : ...
82
83
83
84
class Credentials (_message .Message ):
84
85
__slots__ = ("credential_data" ,)
@@ -106,20 +107,22 @@ class Resources(_message.Message):
106
107
def __init__ (self , items : _Optional [_Iterable [_Union [Resource , _Mapping ]]] = ...) -> None : ...
107
108
108
109
class RunFunctionResponse (_message .Message ):
109
- __slots__ = ("meta" , "desired" , "results" , "context" , "requirements" , "conditions" )
110
+ __slots__ = ("meta" , "desired" , "results" , "context" , "requirements" , "conditions" , "output" )
110
111
META_FIELD_NUMBER : _ClassVar [int ]
111
112
DESIRED_FIELD_NUMBER : _ClassVar [int ]
112
113
RESULTS_FIELD_NUMBER : _ClassVar [int ]
113
114
CONTEXT_FIELD_NUMBER : _ClassVar [int ]
114
115
REQUIREMENTS_FIELD_NUMBER : _ClassVar [int ]
115
116
CONDITIONS_FIELD_NUMBER : _ClassVar [int ]
117
+ OUTPUT_FIELD_NUMBER : _ClassVar [int ]
116
118
meta : ResponseMeta
117
119
desired : State
118
120
results : _containers .RepeatedCompositeFieldContainer [Result ]
119
121
context : _struct_pb2 .Struct
120
122
requirements : Requirements
121
123
conditions : _containers .RepeatedCompositeFieldContainer [Condition ]
122
- def __init__ (self , meta : _Optional [_Union [ResponseMeta , _Mapping ]] = ..., desired : _Optional [_Union [State , _Mapping ]] = ..., results : _Optional [_Iterable [_Union [Result , _Mapping ]]] = ..., context : _Optional [_Union [_struct_pb2 .Struct , _Mapping ]] = ..., requirements : _Optional [_Union [Requirements , _Mapping ]] = ..., conditions : _Optional [_Iterable [_Union [Condition , _Mapping ]]] = ...) -> None : ...
124
+ output : _struct_pb2 .Struct
125
+ def __init__ (self , meta : _Optional [_Union [ResponseMeta , _Mapping ]] = ..., desired : _Optional [_Union [State , _Mapping ]] = ..., results : _Optional [_Iterable [_Union [Result , _Mapping ]]] = ..., context : _Optional [_Union [_struct_pb2 .Struct , _Mapping ]] = ..., requirements : _Optional [_Union [Requirements , _Mapping ]] = ..., conditions : _Optional [_Iterable [_Union [Condition , _Mapping ]]] = ..., output : _Optional [_Union [_struct_pb2 .Struct , _Mapping ]] = ...) -> None : ...
123
126
124
127
class RequestMeta (_message .Message ):
125
128
__slots__ = ("tag" ,)
@@ -128,29 +131,31 @@ class RequestMeta(_message.Message):
128
131
def __init__ (self , tag : _Optional [str ] = ...) -> None : ...
129
132
130
133
class Requirements (_message .Message ):
131
- __slots__ = ("extra_resources " ,)
132
- class ExtraResourcesEntry (_message .Message ):
134
+ __slots__ = ("resources " ,)
135
+ class ResourcesEntry (_message .Message ):
133
136
__slots__ = ("key" , "value" )
134
137
KEY_FIELD_NUMBER : _ClassVar [int ]
135
138
VALUE_FIELD_NUMBER : _ClassVar [int ]
136
139
key : str
137
140
value : ResourceSelector
138
141
def __init__ (self , key : _Optional [str ] = ..., value : _Optional [_Union [ResourceSelector , _Mapping ]] = ...) -> None : ...
139
- EXTRA_RESOURCES_FIELD_NUMBER : _ClassVar [int ]
140
- extra_resources : _containers .MessageMap [str , ResourceSelector ]
141
- def __init__ (self , extra_resources : _Optional [_Mapping [str , ResourceSelector ]] = ...) -> None : ...
142
+ RESOURCES_FIELD_NUMBER : _ClassVar [int ]
143
+ resources : _containers .MessageMap [str , ResourceSelector ]
144
+ def __init__ (self , resources : _Optional [_Mapping [str , ResourceSelector ]] = ...) -> None : ...
142
145
143
146
class ResourceSelector (_message .Message ):
144
- __slots__ = ("api_version" , "kind" , "match_name" , "match_labels" )
147
+ __slots__ = ("api_version" , "kind" , "match_name" , "match_labels" , "namespace" )
145
148
API_VERSION_FIELD_NUMBER : _ClassVar [int ]
146
149
KIND_FIELD_NUMBER : _ClassVar [int ]
147
150
MATCH_NAME_FIELD_NUMBER : _ClassVar [int ]
148
151
MATCH_LABELS_FIELD_NUMBER : _ClassVar [int ]
152
+ NAMESPACE_FIELD_NUMBER : _ClassVar [int ]
149
153
api_version : str
150
154
kind : str
151
155
match_name : str
152
156
match_labels : MatchLabels
153
- def __init__ (self , api_version : _Optional [str ] = ..., kind : _Optional [str ] = ..., match_name : _Optional [str ] = ..., match_labels : _Optional [_Union [MatchLabels , _Mapping ]] = ...) -> None : ...
157
+ namespace : str
158
+ def __init__ (self , api_version : _Optional [str ] = ..., kind : _Optional [str ] = ..., match_name : _Optional [str ] = ..., match_labels : _Optional [_Union [MatchLabels , _Mapping ]] = ..., namespace : _Optional [str ] = ...) -> None : ...
154
159
155
160
class MatchLabels (_message .Message ):
156
161
__slots__ = ("labels" ,)
@@ -171,7 +176,7 @@ class ResponseMeta(_message.Message):
171
176
TTL_FIELD_NUMBER : _ClassVar [int ]
172
177
tag : str
173
178
ttl : _duration_pb2 .Duration
174
- def __init__ (self , tag : _Optional [str ] = ..., ttl : _Optional [_Union [_duration_pb2 .Duration , _Mapping ]] = ...) -> None : ...
179
+ def __init__ (self , tag : _Optional [str ] = ..., ttl : _Optional [_Union [datetime . timedelta , _duration_pb2 .Duration , _Mapping ]] = ...) -> None : ...
175
180
176
181
class State (_message .Message ):
177
182
__slots__ = ("composite" , "resources" )
0 commit comments