forked from feast-dev/feast
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathCoreService_pb2_grpc.py
More file actions
147 lines (128 loc) · 6.76 KB
/
Copy pathCoreService_pb2_grpc.py
File metadata and controls
147 lines (128 loc) · 6.76 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
import grpc
from feast.core import CoreService_pb2 as feast_dot_core_dot_CoreService__pb2
class CoreServiceStub(object):
# missing associated documentation comment in .proto file
pass
def __init__(self, channel):
"""Constructor.
Args:
channel: A grpc.Channel.
"""
self.GetFeastCoreVersion = channel.unary_unary(
'/feast.core.CoreService/GetFeastCoreVersion',
request_serializer=feast_dot_core_dot_CoreService__pb2.GetFeastCoreVersionRequest.SerializeToString,
response_deserializer=feast_dot_core_dot_CoreService__pb2.GetFeastCoreVersionResponse.FromString,
)
self.GetFeatureSet = channel.unary_unary(
'/feast.core.CoreService/GetFeatureSet',
request_serializer=feast_dot_core_dot_CoreService__pb2.GetFeatureSetRequest.SerializeToString,
response_deserializer=feast_dot_core_dot_CoreService__pb2.GetFeatureSetResponse.FromString,
)
self.ListFeatureSets = channel.unary_unary(
'/feast.core.CoreService/ListFeatureSets',
request_serializer=feast_dot_core_dot_CoreService__pb2.ListFeatureSetsRequest.SerializeToString,
response_deserializer=feast_dot_core_dot_CoreService__pb2.ListFeatureSetsResponse.FromString,
)
self.ListStores = channel.unary_unary(
'/feast.core.CoreService/ListStores',
request_serializer=feast_dot_core_dot_CoreService__pb2.ListStoresRequest.SerializeToString,
response_deserializer=feast_dot_core_dot_CoreService__pb2.ListStoresResponse.FromString,
)
self.ApplyFeatureSet = channel.unary_unary(
'/feast.core.CoreService/ApplyFeatureSet',
request_serializer=feast_dot_core_dot_CoreService__pb2.ApplyFeatureSetRequest.SerializeToString,
response_deserializer=feast_dot_core_dot_CoreService__pb2.ApplyFeatureSetResponse.FromString,
)
self.UpdateStore = channel.unary_unary(
'/feast.core.CoreService/UpdateStore',
request_serializer=feast_dot_core_dot_CoreService__pb2.UpdateStoreRequest.SerializeToString,
response_deserializer=feast_dot_core_dot_CoreService__pb2.UpdateStoreResponse.FromString,
)
class CoreServiceServicer(object):
# missing associated documentation comment in .proto file
pass
def GetFeastCoreVersion(self, request, context):
"""Retrieve version information about this Feast deployment
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def GetFeatureSet(self, request, context):
"""Returns a specific feature set
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def ListFeatureSets(self, request, context):
"""Retrieve feature set details given a filter.
Returns all feature sets matching that filter. If none are found,
an empty list will be returned.
If no filter is provided in the request, the response will contain all the feature
sets currently stored in the registry.
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def ListStores(self, request, context):
"""Retrieve store details given a filter.
Returns all stores matching that filter. If none are found, an empty list will be returned.
If no filter is provided in the request, the response will contain all the stores currently
stored in the registry.
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def ApplyFeatureSet(self, request, context):
"""Create or update and existing feature set.
This function is idempotent - it will not create a new feature set if schema does not change.
If an existing feature set is updated, core will advance the version number, which will be
returned in response.
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def UpdateStore(self, request, context):
"""Updates core with the configuration of the store.
If the changes are valid, core will return the given store configuration in response, and
start or update the necessary feature population jobs for the updated store.
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def add_CoreServiceServicer_to_server(servicer, server):
rpc_method_handlers = {
'GetFeastCoreVersion': grpc.unary_unary_rpc_method_handler(
servicer.GetFeastCoreVersion,
request_deserializer=feast_dot_core_dot_CoreService__pb2.GetFeastCoreVersionRequest.FromString,
response_serializer=feast_dot_core_dot_CoreService__pb2.GetFeastCoreVersionResponse.SerializeToString,
),
'GetFeatureSet': grpc.unary_unary_rpc_method_handler(
servicer.GetFeatureSet,
request_deserializer=feast_dot_core_dot_CoreService__pb2.GetFeatureSetRequest.FromString,
response_serializer=feast_dot_core_dot_CoreService__pb2.GetFeatureSetResponse.SerializeToString,
),
'ListFeatureSets': grpc.unary_unary_rpc_method_handler(
servicer.ListFeatureSets,
request_deserializer=feast_dot_core_dot_CoreService__pb2.ListFeatureSetsRequest.FromString,
response_serializer=feast_dot_core_dot_CoreService__pb2.ListFeatureSetsResponse.SerializeToString,
),
'ListStores': grpc.unary_unary_rpc_method_handler(
servicer.ListStores,
request_deserializer=feast_dot_core_dot_CoreService__pb2.ListStoresRequest.FromString,
response_serializer=feast_dot_core_dot_CoreService__pb2.ListStoresResponse.SerializeToString,
),
'ApplyFeatureSet': grpc.unary_unary_rpc_method_handler(
servicer.ApplyFeatureSet,
request_deserializer=feast_dot_core_dot_CoreService__pb2.ApplyFeatureSetRequest.FromString,
response_serializer=feast_dot_core_dot_CoreService__pb2.ApplyFeatureSetResponse.SerializeToString,
),
'UpdateStore': grpc.unary_unary_rpc_method_handler(
servicer.UpdateStore,
request_deserializer=feast_dot_core_dot_CoreService__pb2.UpdateStoreRequest.FromString,
response_serializer=feast_dot_core_dot_CoreService__pb2.UpdateStoreResponse.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'feast.core.CoreService', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))