pinecone.core.grpc.protos.vector_service_pb2_grpc

Client and server classes corresponding to protobuf-defined services.

View Source

  1# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
  2"""Client and server classes corresponding to protobuf-defined services."""
  3import grpc
  4
  5import pinecone.core.grpc.protos.vector_service_pb2 as vector__service__pb2
  6
  7
  8class VectorServiceStub(object):
  9    """The `VectorService` interface is exposed by Pinecone's vector index services.
 10    This service could also be called a `gRPC` service or a `REST`-like api.
 11    """
 12
 13    def __init__(self, channel):
 14        """Constructor.
 15
 16        Args:
 17            channel: A grpc.Channel.
 18        """
 19        self.Upsert = channel.unary_unary(
 20            "/VectorService/Upsert",
 21            request_serializer=vector__service__pb2.UpsertRequest.SerializeToString,
 22            response_deserializer=vector__service__pb2.UpsertResponse.FromString,
 23        )
 24        self.Delete = channel.unary_unary(
 25            "/VectorService/Delete",
 26            request_serializer=vector__service__pb2.DeleteRequest.SerializeToString,
 27            response_deserializer=vector__service__pb2.DeleteResponse.FromString,
 28        )
 29        self.Fetch = channel.unary_unary(
 30            "/VectorService/Fetch",
 31            request_serializer=vector__service__pb2.FetchRequest.SerializeToString,
 32            response_deserializer=vector__service__pb2.FetchResponse.FromString,
 33        )
 34        self.Query = channel.unary_unary(
 35            "/VectorService/Query",
 36            request_serializer=vector__service__pb2.QueryRequest.SerializeToString,
 37            response_deserializer=vector__service__pb2.QueryResponse.FromString,
 38        )
 39        self.Update = channel.unary_unary(
 40            "/VectorService/Update",
 41            request_serializer=vector__service__pb2.UpdateRequest.SerializeToString,
 42            response_deserializer=vector__service__pb2.UpdateResponse.FromString,
 43        )
 44        self.DescribeIndexStats = channel.unary_unary(
 45            "/VectorService/DescribeIndexStats",
 46            request_serializer=vector__service__pb2.DescribeIndexStatsRequest.SerializeToString,
 47            response_deserializer=vector__service__pb2.DescribeIndexStatsResponse.FromString,
 48        )
 49
 50
 51class VectorServiceServicer(object):
 52    """The `VectorService` interface is exposed by Pinecone's vector index services.
 53    This service could also be called a `gRPC` service or a `REST`-like api.
 54    """
 55
 56    def Upsert(self, request, context):
 57        """Upsert
 58
 59        The `Upsert` operation writes vectors into a namespace.
 60        If a new value is upserted for an existing vector id, it will overwrite the previous value.
 61        """
 62        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
 63        context.set_details("Method not implemented!")
 64        raise NotImplementedError("Method not implemented!")
 65
 66    def Delete(self, request, context):
 67        """Delete
 68
 69        The `Delete` operation deletes vectors, by id, from a single namespace.
 70        You can delete items by their id, from a single namespace.
 71        """
 72        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
 73        context.set_details("Method not implemented!")
 74        raise NotImplementedError("Method not implemented!")
 75
 76    def Fetch(self, request, context):
 77        """Fetch
 78
 79        The `Fetch` operation looks up and returns vectors, by ID, from a single namespace.
 80        The returned vectors include the vector data and/or metadata.
 81        """
 82        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
 83        context.set_details("Method not implemented!")
 84        raise NotImplementedError("Method not implemented!")
 85
 86    def Query(self, request, context):
 87        """Query
 88
 89        The `Query` operation searches a namespace, using a query vector.
 90        It retrieves the ids of the most similar items in a namespace, along with their similarity scores.
 91        """
 92        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
 93        context.set_details("Method not implemented!")
 94        raise NotImplementedError("Method not implemented!")
 95
 96    def Update(self, request, context):
 97        """Update
 98
 99        The `Update` operation updates vector in a namespace.
100        If a value is included, it will overwrite the previous value.
101        If a set_metadata is included, the values of the fields specified in it will be added or overwrite the previous value.
102        """
103        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
104        context.set_details("Method not implemented!")
105        raise NotImplementedError("Method not implemented!")
106
107    def DescribeIndexStats(self, request, context):
108        """DescribeIndexStats
109
110        The `DescribeIndexStats` operation returns statistics about the index's
111        contents, including the vector count per namespace, the number of
112        dimensions, and the index fullness. The index fullness result  may be
113        inaccurate during pod resizing; to get the status of a pod resizing
114        process, use
115        [`describe_index`](https://www.pinecone.io/docs/api/operation/describe_index/).
116        """
117        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
118        context.set_details("Method not implemented!")
119        raise NotImplementedError("Method not implemented!")
120
121
122def add_VectorServiceServicer_to_server(servicer, server):
123    rpc_method_handlers = {
124        "Upsert": grpc.unary_unary_rpc_method_handler(
125            servicer.Upsert,
126            request_deserializer=vector__service__pb2.UpsertRequest.FromString,
127            response_serializer=vector__service__pb2.UpsertResponse.SerializeToString,
128        ),
129        "Delete": grpc.unary_unary_rpc_method_handler(
130            servicer.Delete,
131            request_deserializer=vector__service__pb2.DeleteRequest.FromString,
132            response_serializer=vector__service__pb2.DeleteResponse.SerializeToString,
133        ),
134        "Fetch": grpc.unary_unary_rpc_method_handler(
135            servicer.Fetch,
136            request_deserializer=vector__service__pb2.FetchRequest.FromString,
137            response_serializer=vector__service__pb2.FetchResponse.SerializeToString,
138        ),
139        "Query": grpc.unary_unary_rpc_method_handler(
140            servicer.Query,
141            request_deserializer=vector__service__pb2.QueryRequest.FromString,
142            response_serializer=vector__service__pb2.QueryResponse.SerializeToString,
143        ),
144        "Update": grpc.unary_unary_rpc_method_handler(
145            servicer.Update,
146            request_deserializer=vector__service__pb2.UpdateRequest.FromString,
147            response_serializer=vector__service__pb2.UpdateResponse.SerializeToString,
148        ),
149        "DescribeIndexStats": grpc.unary_unary_rpc_method_handler(
150            servicer.DescribeIndexStats,
151            request_deserializer=vector__service__pb2.DescribeIndexStatsRequest.FromString,
152            response_serializer=vector__service__pb2.DescribeIndexStatsResponse.SerializeToString,
153        ),
154    }
155    generic_handler = grpc.method_handlers_generic_handler("VectorService", rpc_method_handlers)
156    server.add_generic_rpc_handlers((generic_handler,))
157
158
159# This class is part of an EXPERIMENTAL API.
160class VectorService(object):
161    """The `VectorService` interface is exposed by Pinecone's vector index services.
162    This service could also be called a `gRPC` service or a `REST`-like api.
163    """
164
165    @staticmethod
166    def Upsert(
167        request,
168        target,
169        options=(),
170        channel_credentials=None,
171        call_credentials=None,
172        insecure=False,
173        compression=None,
174        wait_for_ready=None,
175        timeout=None,
176        metadata=None,
177    ):
178        return grpc.experimental.unary_unary(
179            request,
180            target,
181            "/VectorService/Upsert",
182            vector__service__pb2.UpsertRequest.SerializeToString,
183            vector__service__pb2.UpsertResponse.FromString,
184            options,
185            channel_credentials,
186            insecure,
187            call_credentials,
188            compression,
189            wait_for_ready,
190            timeout,
191            metadata,
192        )
193
194    @staticmethod
195    def Delete(
196        request,
197        target,
198        options=(),
199        channel_credentials=None,
200        call_credentials=None,
201        insecure=False,
202        compression=None,
203        wait_for_ready=None,
204        timeout=None,
205        metadata=None,
206    ):
207        return grpc.experimental.unary_unary(
208            request,
209            target,
210            "/VectorService/Delete",
211            vector__service__pb2.DeleteRequest.SerializeToString,
212            vector__service__pb2.DeleteResponse.FromString,
213            options,
214            channel_credentials,
215            insecure,
216            call_credentials,
217            compression,
218            wait_for_ready,
219            timeout,
220            metadata,
221        )
222
223    @staticmethod
224    def Fetch(
225        request,
226        target,
227        options=(),
228        channel_credentials=None,
229        call_credentials=None,
230        insecure=False,
231        compression=None,
232        wait_for_ready=None,
233        timeout=None,
234        metadata=None,
235    ):
236        return grpc.experimental.unary_unary(
237            request,
238            target,
239            "/VectorService/Fetch",
240            vector__service__pb2.FetchRequest.SerializeToString,
241            vector__service__pb2.FetchResponse.FromString,
242            options,
243            channel_credentials,
244            insecure,
245            call_credentials,
246            compression,
247            wait_for_ready,
248            timeout,
249            metadata,
250        )
251
252    @staticmethod
253    def Query(
254        request,
255        target,
256        options=(),
257        channel_credentials=None,
258        call_credentials=None,
259        insecure=False,
260        compression=None,
261        wait_for_ready=None,
262        timeout=None,
263        metadata=None,
264    ):
265        return grpc.experimental.unary_unary(
266            request,
267            target,
268            "/VectorService/Query",
269            vector__service__pb2.QueryRequest.SerializeToString,
270            vector__service__pb2.QueryResponse.FromString,
271            options,
272            channel_credentials,
273            insecure,
274            call_credentials,
275            compression,
276            wait_for_ready,
277            timeout,
278            metadata,
279        )
280
281    @staticmethod
282    def Update(
283        request,
284        target,
285        options=(),
286        channel_credentials=None,
287        call_credentials=None,
288        insecure=False,
289        compression=None,
290        wait_for_ready=None,
291        timeout=None,
292        metadata=None,
293    ):
294        return grpc.experimental.unary_unary(
295            request,
296            target,
297            "/VectorService/Update",
298            vector__service__pb2.UpdateRequest.SerializeToString,
299            vector__service__pb2.UpdateResponse.FromString,
300            options,
301            channel_credentials,
302            insecure,
303            call_credentials,
304            compression,
305            wait_for_ready,
306            timeout,
307            metadata,
308        )
309
310    @staticmethod
311    def DescribeIndexStats(
312        request,
313        target,
314        options=(),
315        channel_credentials=None,
316        call_credentials=None,
317        insecure=False,
318        compression=None,
319        wait_for_ready=None,
320        timeout=None,
321        metadata=None,
322    ):
323        return grpc.experimental.unary_unary(
324            request,
325            target,
326            "/VectorService/DescribeIndexStats",
327            vector__service__pb2.DescribeIndexStatsRequest.SerializeToString,
328            vector__service__pb2.DescribeIndexStatsResponse.FromString,
329            options,
330            channel_credentials,
331            insecure,
332            call_credentials,
333            compression,
334            wait_for_ready,
335            timeout,
336            metadata,
337        )

class VectorServiceStub: View Source

 9class VectorServiceStub(object):
10    """The `VectorService` interface is exposed by Pinecone's vector index services.
11    This service could also be called a `gRPC` service or a `REST`-like api.
12    """
13
14    def __init__(self, channel):
15        """Constructor.
16
17        Args:
18            channel: A grpc.Channel.
19        """
20        self.Upsert = channel.unary_unary(
21            "/VectorService/Upsert",
22            request_serializer=vector__service__pb2.UpsertRequest.SerializeToString,
23            response_deserializer=vector__service__pb2.UpsertResponse.FromString,
24        )
25        self.Delete = channel.unary_unary(
26            "/VectorService/Delete",
27            request_serializer=vector__service__pb2.DeleteRequest.SerializeToString,
28            response_deserializer=vector__service__pb2.DeleteResponse.FromString,
29        )
30        self.Fetch = channel.unary_unary(
31            "/VectorService/Fetch",
32            request_serializer=vector__service__pb2.FetchRequest.SerializeToString,
33            response_deserializer=vector__service__pb2.FetchResponse.FromString,
34        )
35        self.Query = channel.unary_unary(
36            "/VectorService/Query",
37            request_serializer=vector__service__pb2.QueryRequest.SerializeToString,
38            response_deserializer=vector__service__pb2.QueryResponse.FromString,
39        )
40        self.Update = channel.unary_unary(
41            "/VectorService/Update",
42            request_serializer=vector__service__pb2.UpdateRequest.SerializeToString,
43            response_deserializer=vector__service__pb2.UpdateResponse.FromString,
44        )
45        self.DescribeIndexStats = channel.unary_unary(
46            "/VectorService/DescribeIndexStats",
47            request_serializer=vector__service__pb2.DescribeIndexStatsRequest.SerializeToString,
48            response_deserializer=vector__service__pb2.DescribeIndexStatsResponse.FromString,
49        )

The VectorService interface is exposed by Pinecone's vector index services. This service could also be called a gRPC service or a REST-like api.

VectorServiceStub(channel) View Source

14    def __init__(self, channel):
15        """Constructor.
16
17        Args:
18            channel: A grpc.Channel.
19        """
20        self.Upsert = channel.unary_unary(
21            "/VectorService/Upsert",
22            request_serializer=vector__service__pb2.UpsertRequest.SerializeToString,
23            response_deserializer=vector__service__pb2.UpsertResponse.FromString,
24        )
25        self.Delete = channel.unary_unary(
26            "/VectorService/Delete",
27            request_serializer=vector__service__pb2.DeleteRequest.SerializeToString,
28            response_deserializer=vector__service__pb2.DeleteResponse.FromString,
29        )
30        self.Fetch = channel.unary_unary(
31            "/VectorService/Fetch",
32            request_serializer=vector__service__pb2.FetchRequest.SerializeToString,
33            response_deserializer=vector__service__pb2.FetchResponse.FromString,
34        )
35        self.Query = channel.unary_unary(
36            "/VectorService/Query",
37            request_serializer=vector__service__pb2.QueryRequest.SerializeToString,
38            response_deserializer=vector__service__pb2.QueryResponse.FromString,
39        )
40        self.Update = channel.unary_unary(
41            "/VectorService/Update",
42            request_serializer=vector__service__pb2.UpdateRequest.SerializeToString,
43            response_deserializer=vector__service__pb2.UpdateResponse.FromString,
44        )
45        self.DescribeIndexStats = channel.unary_unary(
46            "/VectorService/DescribeIndexStats",
47            request_serializer=vector__service__pb2.DescribeIndexStatsRequest.SerializeToString,
48            response_deserializer=vector__service__pb2.DescribeIndexStatsResponse.FromString,
49        )

Constructor.

Arguments:

channel: A grpc.Channel.

Upsert

Delete

Fetch

Query

Update

DescribeIndexStats

class VectorServiceServicer: View Source

 52class VectorServiceServicer(object):
 53    """The `VectorService` interface is exposed by Pinecone's vector index services.
 54    This service could also be called a `gRPC` service or a `REST`-like api.
 55    """
 56
 57    def Upsert(self, request, context):
 58        """Upsert
 59
 60        The `Upsert` operation writes vectors into a namespace.
 61        If a new value is upserted for an existing vector id, it will overwrite the previous value.
 62        """
 63        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
 64        context.set_details("Method not implemented!")
 65        raise NotImplementedError("Method not implemented!")
 66
 67    def Delete(self, request, context):
 68        """Delete
 69
 70        The `Delete` operation deletes vectors, by id, from a single namespace.
 71        You can delete items by their id, from a single namespace.
 72        """
 73        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
 74        context.set_details("Method not implemented!")
 75        raise NotImplementedError("Method not implemented!")
 76
 77    def Fetch(self, request, context):
 78        """Fetch
 79
 80        The `Fetch` operation looks up and returns vectors, by ID, from a single namespace.
 81        The returned vectors include the vector data and/or metadata.
 82        """
 83        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
 84        context.set_details("Method not implemented!")
 85        raise NotImplementedError("Method not implemented!")
 86
 87    def Query(self, request, context):
 88        """Query
 89
 90        The `Query` operation searches a namespace, using a query vector.
 91        It retrieves the ids of the most similar items in a namespace, along with their similarity scores.
 92        """
 93        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
 94        context.set_details("Method not implemented!")
 95        raise NotImplementedError("Method not implemented!")
 96
 97    def Update(self, request, context):
 98        """Update
 99
100        The `Update` operation updates vector in a namespace.
101        If a value is included, it will overwrite the previous value.
102        If a set_metadata is included, the values of the fields specified in it will be added or overwrite the previous value.
103        """
104        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
105        context.set_details("Method not implemented!")
106        raise NotImplementedError("Method not implemented!")
107
108    def DescribeIndexStats(self, request, context):
109        """DescribeIndexStats
110
111        The `DescribeIndexStats` operation returns statistics about the index's
112        contents, including the vector count per namespace, the number of
113        dimensions, and the index fullness. The index fullness result  may be
114        inaccurate during pod resizing; to get the status of a pod resizing
115        process, use
116        [`describe_index`](https://www.pinecone.io/docs/api/operation/describe_index/).
117        """
118        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
119        context.set_details("Method not implemented!")
120        raise NotImplementedError("Method not implemented!")

The VectorService interface is exposed by Pinecone's vector index services. This service could also be called a gRPC service or a REST-like api.

def Upsert(self, request, context): View Source

57    def Upsert(self, request, context):
58        """Upsert
59
60        The `Upsert` operation writes vectors into a namespace.
61        If a new value is upserted for an existing vector id, it will overwrite the previous value.
62        """
63        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
64        context.set_details("Method not implemented!")
65        raise NotImplementedError("Method not implemented!")

Upsert

The Upsert operation writes vectors into a namespace. If a new value is upserted for an existing vector id, it will overwrite the previous value.

def Delete(self, request, context): View Source

67    def Delete(self, request, context):
68        """Delete
69
70        The `Delete` operation deletes vectors, by id, from a single namespace.
71        You can delete items by their id, from a single namespace.
72        """
73        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
74        context.set_details("Method not implemented!")
75        raise NotImplementedError("Method not implemented!")

Delete

The Delete operation deletes vectors, by id, from a single namespace. You can delete items by their id, from a single namespace.

def Fetch(self, request, context): View Source

77    def Fetch(self, request, context):
78        """Fetch
79
80        The `Fetch` operation looks up and returns vectors, by ID, from a single namespace.
81        The returned vectors include the vector data and/or metadata.
82        """
83        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
84        context.set_details("Method not implemented!")
85        raise NotImplementedError("Method not implemented!")

Fetch

The Fetch operation looks up and returns vectors, by ID, from a single namespace. The returned vectors include the vector data and/or metadata.

def Query(self, request, context): View Source

87    def Query(self, request, context):
88        """Query
89
90        The `Query` operation searches a namespace, using a query vector.
91        It retrieves the ids of the most similar items in a namespace, along with their similarity scores.
92        """
93        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
94        context.set_details("Method not implemented!")
95        raise NotImplementedError("Method not implemented!")

Query

The Query operation searches a namespace, using a query vector. It retrieves the ids of the most similar items in a namespace, along with their similarity scores.

def Update(self, request, context): View Source

 97    def Update(self, request, context):
 98        """Update
 99
100        The `Update` operation updates vector in a namespace.
101        If a value is included, it will overwrite the previous value.
102        If a set_metadata is included, the values of the fields specified in it will be added or overwrite the previous value.
103        """
104        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
105        context.set_details("Method not implemented!")
106        raise NotImplementedError("Method not implemented!")

Update

The Update operation updates vector in a namespace. If a value is included, it will overwrite the previous value. If a set_metadata is included, the values of the fields specified in it will be added or overwrite the previous value.

def DescribeIndexStats(self, request, context): View Source

108    def DescribeIndexStats(self, request, context):
109        """DescribeIndexStats
110
111        The `DescribeIndexStats` operation returns statistics about the index's
112        contents, including the vector count per namespace, the number of
113        dimensions, and the index fullness. The index fullness result  may be
114        inaccurate during pod resizing; to get the status of a pod resizing
115        process, use
116        [`describe_index`](https://www.pinecone.io/docs/api/operation/describe_index/).
117        """
118        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
119        context.set_details("Method not implemented!")
120        raise NotImplementedError("Method not implemented!")

DescribeIndexStats

The DescribeIndexStats operation returns statistics about the index's contents, including the vector count per namespace, the number of dimensions, and the index fullness. The index fullness result may be inaccurate during pod resizing; to get the status of a pod resizing process, use describe_index.

def add_VectorServiceServicer_to_server(servicer, server): View Source

123def add_VectorServiceServicer_to_server(servicer, server):
124    rpc_method_handlers = {
125        "Upsert": grpc.unary_unary_rpc_method_handler(
126            servicer.Upsert,
127            request_deserializer=vector__service__pb2.UpsertRequest.FromString,
128            response_serializer=vector__service__pb2.UpsertResponse.SerializeToString,
129        ),
130        "Delete": grpc.unary_unary_rpc_method_handler(
131            servicer.Delete,
132            request_deserializer=vector__service__pb2.DeleteRequest.FromString,
133            response_serializer=vector__service__pb2.DeleteResponse.SerializeToString,
134        ),
135        "Fetch": grpc.unary_unary_rpc_method_handler(
136            servicer.Fetch,
137            request_deserializer=vector__service__pb2.FetchRequest.FromString,
138            response_serializer=vector__service__pb2.FetchResponse.SerializeToString,
139        ),
140        "Query": grpc.unary_unary_rpc_method_handler(
141            servicer.Query,
142            request_deserializer=vector__service__pb2.QueryRequest.FromString,
143            response_serializer=vector__service__pb2.QueryResponse.SerializeToString,
144        ),
145        "Update": grpc.unary_unary_rpc_method_handler(
146            servicer.Update,
147            request_deserializer=vector__service__pb2.UpdateRequest.FromString,
148            response_serializer=vector__service__pb2.UpdateResponse.SerializeToString,
149        ),
150        "DescribeIndexStats": grpc.unary_unary_rpc_method_handler(
151            servicer.DescribeIndexStats,
152            request_deserializer=vector__service__pb2.DescribeIndexStatsRequest.FromString,
153            response_serializer=vector__service__pb2.DescribeIndexStatsResponse.SerializeToString,
154        ),
155    }
156    generic_handler = grpc.method_handlers_generic_handler("VectorService", rpc_method_handlers)
157    server.add_generic_rpc_handlers((generic_handler,))

class VectorService: View Source

161class VectorService(object):
162    """The `VectorService` interface is exposed by Pinecone's vector index services.
163    This service could also be called a `gRPC` service or a `REST`-like api.
164    """
165
166    @staticmethod
167    def Upsert(
168        request,
169        target,
170        options=(),
171        channel_credentials=None,
172        call_credentials=None,
173        insecure=False,
174        compression=None,
175        wait_for_ready=None,
176        timeout=None,
177        metadata=None,
178    ):
179        return grpc.experimental.unary_unary(
180            request,
181            target,
182            "/VectorService/Upsert",
183            vector__service__pb2.UpsertRequest.SerializeToString,
184            vector__service__pb2.UpsertResponse.FromString,
185            options,
186            channel_credentials,
187            insecure,
188            call_credentials,
189            compression,
190            wait_for_ready,
191            timeout,
192            metadata,
193        )
194
195    @staticmethod
196    def Delete(
197        request,
198        target,
199        options=(),
200        channel_credentials=None,
201        call_credentials=None,
202        insecure=False,
203        compression=None,
204        wait_for_ready=None,
205        timeout=None,
206        metadata=None,
207    ):
208        return grpc.experimental.unary_unary(
209            request,
210            target,
211            "/VectorService/Delete",
212            vector__service__pb2.DeleteRequest.SerializeToString,
213            vector__service__pb2.DeleteResponse.FromString,
214            options,
215            channel_credentials,
216            insecure,
217            call_credentials,
218            compression,
219            wait_for_ready,
220            timeout,
221            metadata,
222        )
223
224    @staticmethod
225    def Fetch(
226        request,
227        target,
228        options=(),
229        channel_credentials=None,
230        call_credentials=None,
231        insecure=False,
232        compression=None,
233        wait_for_ready=None,
234        timeout=None,
235        metadata=None,
236    ):
237        return grpc.experimental.unary_unary(
238            request,
239            target,
240            "/VectorService/Fetch",
241            vector__service__pb2.FetchRequest.SerializeToString,
242            vector__service__pb2.FetchResponse.FromString,
243            options,
244            channel_credentials,
245            insecure,
246            call_credentials,
247            compression,
248            wait_for_ready,
249            timeout,
250            metadata,
251        )
252
253    @staticmethod
254    def Query(
255        request,
256        target,
257        options=(),
258        channel_credentials=None,
259        call_credentials=None,
260        insecure=False,
261        compression=None,
262        wait_for_ready=None,
263        timeout=None,
264        metadata=None,
265    ):
266        return grpc.experimental.unary_unary(
267            request,
268            target,
269            "/VectorService/Query",
270            vector__service__pb2.QueryRequest.SerializeToString,
271            vector__service__pb2.QueryResponse.FromString,
272            options,
273            channel_credentials,
274            insecure,
275            call_credentials,
276            compression,
277            wait_for_ready,
278            timeout,
279            metadata,
280        )
281
282    @staticmethod
283    def Update(
284        request,
285        target,
286        options=(),
287        channel_credentials=None,
288        call_credentials=None,
289        insecure=False,
290        compression=None,
291        wait_for_ready=None,
292        timeout=None,
293        metadata=None,
294    ):
295        return grpc.experimental.unary_unary(
296            request,
297            target,
298            "/VectorService/Update",
299            vector__service__pb2.UpdateRequest.SerializeToString,
300            vector__service__pb2.UpdateResponse.FromString,
301            options,
302            channel_credentials,
303            insecure,
304            call_credentials,
305            compression,
306            wait_for_ready,
307            timeout,
308            metadata,
309        )
310
311    @staticmethod
312    def DescribeIndexStats(
313        request,
314        target,
315        options=(),
316        channel_credentials=None,
317        call_credentials=None,
318        insecure=False,
319        compression=None,
320        wait_for_ready=None,
321        timeout=None,
322        metadata=None,
323    ):
324        return grpc.experimental.unary_unary(
325            request,
326            target,
327            "/VectorService/DescribeIndexStats",
328            vector__service__pb2.DescribeIndexStatsRequest.SerializeToString,
329            vector__service__pb2.DescribeIndexStatsResponse.FromString,
330            options,
331            channel_credentials,
332            insecure,
333            call_credentials,
334            compression,
335            wait_for_ready,
336            timeout,
337            metadata,
338        )

The VectorService interface is exposed by Pinecone's vector index services. This service could also be called a gRPC service or a REST-like api.

@staticmethod

def Upsert( request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None): View Source

166    @staticmethod
167    def Upsert(
168        request,
169        target,
170        options=(),
171        channel_credentials=None,
172        call_credentials=None,
173        insecure=False,
174        compression=None,
175        wait_for_ready=None,
176        timeout=None,
177        metadata=None,
178    ):
179        return grpc.experimental.unary_unary(
180            request,
181            target,
182            "/VectorService/Upsert",
183            vector__service__pb2.UpsertRequest.SerializeToString,
184            vector__service__pb2.UpsertResponse.FromString,
185            options,
186            channel_credentials,
187            insecure,
188            call_credentials,
189            compression,
190            wait_for_ready,
191            timeout,
192            metadata,
193        )

@staticmethod

def Delete( request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None): View Source

195    @staticmethod
196    def Delete(
197        request,
198        target,
199        options=(),
200        channel_credentials=None,
201        call_credentials=None,
202        insecure=False,
203        compression=None,
204        wait_for_ready=None,
205        timeout=None,
206        metadata=None,
207    ):
208        return grpc.experimental.unary_unary(
209            request,
210            target,
211            "/VectorService/Delete",
212            vector__service__pb2.DeleteRequest.SerializeToString,
213            vector__service__pb2.DeleteResponse.FromString,
214            options,
215            channel_credentials,
216            insecure,
217            call_credentials,
218            compression,
219            wait_for_ready,
220            timeout,
221            metadata,
222        )

@staticmethod

def Fetch( request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None): View Source

224    @staticmethod
225    def Fetch(
226        request,
227        target,
228        options=(),
229        channel_credentials=None,
230        call_credentials=None,
231        insecure=False,
232        compression=None,
233        wait_for_ready=None,
234        timeout=None,
235        metadata=None,
236    ):
237        return grpc.experimental.unary_unary(
238            request,
239            target,
240            "/VectorService/Fetch",
241            vector__service__pb2.FetchRequest.SerializeToString,
242            vector__service__pb2.FetchResponse.FromString,
243            options,
244            channel_credentials,
245            insecure,
246            call_credentials,
247            compression,
248            wait_for_ready,
249            timeout,
250            metadata,
251        )

@staticmethod

def Query( request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None): View Source

253    @staticmethod
254    def Query(
255        request,
256        target,
257        options=(),
258        channel_credentials=None,
259        call_credentials=None,
260        insecure=False,
261        compression=None,
262        wait_for_ready=None,
263        timeout=None,
264        metadata=None,
265    ):
266        return grpc.experimental.unary_unary(
267            request,
268            target,
269            "/VectorService/Query",
270            vector__service__pb2.QueryRequest.SerializeToString,
271            vector__service__pb2.QueryResponse.FromString,
272            options,
273            channel_credentials,
274            insecure,
275            call_credentials,
276            compression,
277            wait_for_ready,
278            timeout,
279            metadata,
280        )

@staticmethod

def Update( request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None): View Source

282    @staticmethod
283    def Update(
284        request,
285        target,
286        options=(),
287        channel_credentials=None,
288        call_credentials=None,
289        insecure=False,
290        compression=None,
291        wait_for_ready=None,
292        timeout=None,
293        metadata=None,
294    ):
295        return grpc.experimental.unary_unary(
296            request,
297            target,
298            "/VectorService/Update",
299            vector__service__pb2.UpdateRequest.SerializeToString,
300            vector__service__pb2.UpdateResponse.FromString,
301            options,
302            channel_credentials,
303            insecure,
304            call_credentials,
305            compression,
306            wait_for_ready,
307            timeout,
308            metadata,
309        )

@staticmethod

def DescribeIndexStats( request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None): View Source

311    @staticmethod
312    def DescribeIndexStats(
313        request,
314        target,
315        options=(),
316        channel_credentials=None,
317        call_credentials=None,
318        insecure=False,
319        compression=None,
320        wait_for_ready=None,
321        timeout=None,
322        metadata=None,
323    ):
324        return grpc.experimental.unary_unary(
325            request,
326            target,
327            "/VectorService/DescribeIndexStats",
328            vector__service__pb2.DescribeIndexStatsRequest.SerializeToString,
329            vector__service__pb2.DescribeIndexStatsResponse.FromString,
330            options,
331            channel_credentials,
332            insecure,
333            call_credentials,
334            compression,
335            wait_for_ready,
336            timeout,
337            metadata,
338        )