pinecone.core.grpc.protos.vector_column_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_column_service_pb2 as vector__column__service__pb2
  6
  7
  8class VectorColumnServiceStub(object):
  9    """The `VectorColumnService` interface is exposed by Pinecone vector index services.
 10    The `Upsert` operation is for uploading the data (the vector ids and values) to be indexed.
 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            "/pinecone_columnar.VectorColumnService/Upsert",
 21            request_serializer=vector__column__service__pb2.UpsertRequest.SerializeToString,
 22            response_deserializer=vector__column__service__pb2.UpsertResponse.FromString,
 23        )
 24        self.Delete = channel.unary_unary(
 25            "/pinecone_columnar.VectorColumnService/Delete",
 26            request_serializer=vector__column__service__pb2.DeleteRequest.SerializeToString,
 27            response_deserializer=vector__column__service__pb2.DeleteResponse.FromString,
 28        )
 29        self.Fetch = channel.unary_unary(
 30            "/pinecone_columnar.VectorColumnService/Fetch",
 31            request_serializer=vector__column__service__pb2.FetchRequest.SerializeToString,
 32            response_deserializer=vector__column__service__pb2.FetchResponse.FromString,
 33        )
 34        self.Query = channel.unary_unary(
 35            "/pinecone_columnar.VectorColumnService/Query",
 36            request_serializer=vector__column__service__pb2.QueryRequest.SerializeToString,
 37            response_deserializer=vector__column__service__pb2.QueryResponse.FromString,
 38        )
 39        self.DescribeIndexStats = channel.unary_unary(
 40            "/pinecone_columnar.VectorColumnService/DescribeIndexStats",
 41            request_serializer=vector__column__service__pb2.DescribeIndexStatsRequest.SerializeToString,
 42            response_deserializer=vector__column__service__pb2.DescribeIndexStatsResponse.FromString,
 43        )
 44
 45
 46class VectorColumnServiceServicer(object):
 47    """The `VectorColumnService` interface is exposed by Pinecone vector index services.
 48    The `Upsert` operation is for uploading the data (the vector ids and values) to be indexed.
 49    """
 50
 51    def Upsert(self, request, context):
 52        """If a user upserts a new value for an existing vector id, it overwrites the previous value."""
 53        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
 54        context.set_details("Method not implemented!")
 55        raise NotImplementedError("Method not implemented!")
 56
 57    def Delete(self, request, context):
 58        """The `Delete` operation deletes multiple vectors ids from a single namespace.
 59        Specifying `delete_all` will delete all vectors from the default namespace.
 60        """
 61        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
 62        context.set_details("Method not implemented!")
 63        raise NotImplementedError("Method not implemented!")
 64
 65    def Fetch(self, request, context):
 66        """The `Fetch` operation returns a vector value by id."""
 67        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
 68        context.set_details("Method not implemented!")
 69        raise NotImplementedError("Method not implemented!")
 70
 71    def Query(self, request, context):
 72        """The `Query` operation queries the index for the nearest stored vectors to one
 73        or more query vectors, and returns their ids and/or values.
 74        """
 75        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
 76        context.set_details("Method not implemented!")
 77        raise NotImplementedError("Method not implemented!")
 78
 79    def DescribeIndexStats(self, request, context):
 80        """The `DescribeIndexStats` operation returns summary statistics about the index contents."""
 81        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
 82        context.set_details("Method not implemented!")
 83        raise NotImplementedError("Method not implemented!")
 84
 85
 86def add_VectorColumnServiceServicer_to_server(servicer, server):
 87    rpc_method_handlers = {
 88        "Upsert": grpc.unary_unary_rpc_method_handler(
 89            servicer.Upsert,
 90            request_deserializer=vector__column__service__pb2.UpsertRequest.FromString,
 91            response_serializer=vector__column__service__pb2.UpsertResponse.SerializeToString,
 92        ),
 93        "Delete": grpc.unary_unary_rpc_method_handler(
 94            servicer.Delete,
 95            request_deserializer=vector__column__service__pb2.DeleteRequest.FromString,
 96            response_serializer=vector__column__service__pb2.DeleteResponse.SerializeToString,
 97        ),
 98        "Fetch": grpc.unary_unary_rpc_method_handler(
 99            servicer.Fetch,
100            request_deserializer=vector__column__service__pb2.FetchRequest.FromString,
101            response_serializer=vector__column__service__pb2.FetchResponse.SerializeToString,
102        ),
103        "Query": grpc.unary_unary_rpc_method_handler(
104            servicer.Query,
105            request_deserializer=vector__column__service__pb2.QueryRequest.FromString,
106            response_serializer=vector__column__service__pb2.QueryResponse.SerializeToString,
107        ),
108        "DescribeIndexStats": grpc.unary_unary_rpc_method_handler(
109            servicer.DescribeIndexStats,
110            request_deserializer=vector__column__service__pb2.DescribeIndexStatsRequest.FromString,
111            response_serializer=vector__column__service__pb2.DescribeIndexStatsResponse.SerializeToString,
112        ),
113    }
114    generic_handler = grpc.method_handlers_generic_handler("pinecone_columnar.VectorColumnService", rpc_method_handlers)
115    server.add_generic_rpc_handlers((generic_handler,))
116
117
118# This class is part of an EXPERIMENTAL API.
119class VectorColumnService(object):
120    """The `VectorColumnService` interface is exposed by Pinecone vector index services.
121    The `Upsert` operation is for uploading the data (the vector ids and values) to be indexed.
122    """
123
124    @staticmethod
125    def Upsert(
126        request,
127        target,
128        options=(),
129        channel_credentials=None,
130        call_credentials=None,
131        insecure=False,
132        compression=None,
133        wait_for_ready=None,
134        timeout=None,
135        metadata=None,
136    ):
137        return grpc.experimental.unary_unary(
138            request,
139            target,
140            "/pinecone_columnar.VectorColumnService/Upsert",
141            vector__column__service__pb2.UpsertRequest.SerializeToString,
142            vector__column__service__pb2.UpsertResponse.FromString,
143            options,
144            channel_credentials,
145            insecure,
146            call_credentials,
147            compression,
148            wait_for_ready,
149            timeout,
150            metadata,
151        )
152
153    @staticmethod
154    def Delete(
155        request,
156        target,
157        options=(),
158        channel_credentials=None,
159        call_credentials=None,
160        insecure=False,
161        compression=None,
162        wait_for_ready=None,
163        timeout=None,
164        metadata=None,
165    ):
166        return grpc.experimental.unary_unary(
167            request,
168            target,
169            "/pinecone_columnar.VectorColumnService/Delete",
170            vector__column__service__pb2.DeleteRequest.SerializeToString,
171            vector__column__service__pb2.DeleteResponse.FromString,
172            options,
173            channel_credentials,
174            insecure,
175            call_credentials,
176            compression,
177            wait_for_ready,
178            timeout,
179            metadata,
180        )
181
182    @staticmethod
183    def Fetch(
184        request,
185        target,
186        options=(),
187        channel_credentials=None,
188        call_credentials=None,
189        insecure=False,
190        compression=None,
191        wait_for_ready=None,
192        timeout=None,
193        metadata=None,
194    ):
195        return grpc.experimental.unary_unary(
196            request,
197            target,
198            "/pinecone_columnar.VectorColumnService/Fetch",
199            vector__column__service__pb2.FetchRequest.SerializeToString,
200            vector__column__service__pb2.FetchResponse.FromString,
201            options,
202            channel_credentials,
203            insecure,
204            call_credentials,
205            compression,
206            wait_for_ready,
207            timeout,
208            metadata,
209        )
210
211    @staticmethod
212    def Query(
213        request,
214        target,
215        options=(),
216        channel_credentials=None,
217        call_credentials=None,
218        insecure=False,
219        compression=None,
220        wait_for_ready=None,
221        timeout=None,
222        metadata=None,
223    ):
224        return grpc.experimental.unary_unary(
225            request,
226            target,
227            "/pinecone_columnar.VectorColumnService/Query",
228            vector__column__service__pb2.QueryRequest.SerializeToString,
229            vector__column__service__pb2.QueryResponse.FromString,
230            options,
231            channel_credentials,
232            insecure,
233            call_credentials,
234            compression,
235            wait_for_ready,
236            timeout,
237            metadata,
238        )
239
240    @staticmethod
241    def DescribeIndexStats(
242        request,
243        target,
244        options=(),
245        channel_credentials=None,
246        call_credentials=None,
247        insecure=False,
248        compression=None,
249        wait_for_ready=None,
250        timeout=None,
251        metadata=None,
252    ):
253        return grpc.experimental.unary_unary(
254            request,
255            target,
256            "/pinecone_columnar.VectorColumnService/DescribeIndexStats",
257            vector__column__service__pb2.DescribeIndexStatsRequest.SerializeToString,
258            vector__column__service__pb2.DescribeIndexStatsResponse.FromString,
259            options,
260            channel_credentials,
261            insecure,
262            call_credentials,
263            compression,
264            wait_for_ready,
265            timeout,
266            metadata,
267        )

class VectorColumnServiceStub: View Source

 9class VectorColumnServiceStub(object):
10    """The `VectorColumnService` interface is exposed by Pinecone vector index services.
11    The `Upsert` operation is for uploading the data (the vector ids and values) to be indexed.
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            "/pinecone_columnar.VectorColumnService/Upsert",
22            request_serializer=vector__column__service__pb2.UpsertRequest.SerializeToString,
23            response_deserializer=vector__column__service__pb2.UpsertResponse.FromString,
24        )
25        self.Delete = channel.unary_unary(
26            "/pinecone_columnar.VectorColumnService/Delete",
27            request_serializer=vector__column__service__pb2.DeleteRequest.SerializeToString,
28            response_deserializer=vector__column__service__pb2.DeleteResponse.FromString,
29        )
30        self.Fetch = channel.unary_unary(
31            "/pinecone_columnar.VectorColumnService/Fetch",
32            request_serializer=vector__column__service__pb2.FetchRequest.SerializeToString,
33            response_deserializer=vector__column__service__pb2.FetchResponse.FromString,
34        )
35        self.Query = channel.unary_unary(
36            "/pinecone_columnar.VectorColumnService/Query",
37            request_serializer=vector__column__service__pb2.QueryRequest.SerializeToString,
38            response_deserializer=vector__column__service__pb2.QueryResponse.FromString,
39        )
40        self.DescribeIndexStats = channel.unary_unary(
41            "/pinecone_columnar.VectorColumnService/DescribeIndexStats",
42            request_serializer=vector__column__service__pb2.DescribeIndexStatsRequest.SerializeToString,
43            response_deserializer=vector__column__service__pb2.DescribeIndexStatsResponse.FromString,
44        )

The VectorColumnService interface is exposed by Pinecone vector index services. The Upsert operation is for uploading the data (the vector ids and values) to be indexed.

VectorColumnServiceStub(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            "/pinecone_columnar.VectorColumnService/Upsert",
22            request_serializer=vector__column__service__pb2.UpsertRequest.SerializeToString,
23            response_deserializer=vector__column__service__pb2.UpsertResponse.FromString,
24        )
25        self.Delete = channel.unary_unary(
26            "/pinecone_columnar.VectorColumnService/Delete",
27            request_serializer=vector__column__service__pb2.DeleteRequest.SerializeToString,
28            response_deserializer=vector__column__service__pb2.DeleteResponse.FromString,
29        )
30        self.Fetch = channel.unary_unary(
31            "/pinecone_columnar.VectorColumnService/Fetch",
32            request_serializer=vector__column__service__pb2.FetchRequest.SerializeToString,
33            response_deserializer=vector__column__service__pb2.FetchResponse.FromString,
34        )
35        self.Query = channel.unary_unary(
36            "/pinecone_columnar.VectorColumnService/Query",
37            request_serializer=vector__column__service__pb2.QueryRequest.SerializeToString,
38            response_deserializer=vector__column__service__pb2.QueryResponse.FromString,
39        )
40        self.DescribeIndexStats = channel.unary_unary(
41            "/pinecone_columnar.VectorColumnService/DescribeIndexStats",
42            request_serializer=vector__column__service__pb2.DescribeIndexStatsRequest.SerializeToString,
43            response_deserializer=vector__column__service__pb2.DescribeIndexStatsResponse.FromString,
44        )

Constructor.

Arguments:

channel: A grpc.Channel.

Upsert

Delete

Fetch

Query

DescribeIndexStats

class VectorColumnServiceServicer: View Source

47class VectorColumnServiceServicer(object):
48    """The `VectorColumnService` interface is exposed by Pinecone vector index services.
49    The `Upsert` operation is for uploading the data (the vector ids and values) to be indexed.
50    """
51
52    def Upsert(self, request, context):
53        """If a user upserts a new value for an existing vector id, it overwrites the previous value."""
54        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
55        context.set_details("Method not implemented!")
56        raise NotImplementedError("Method not implemented!")
57
58    def Delete(self, request, context):
59        """The `Delete` operation deletes multiple vectors ids from a single namespace.
60        Specifying `delete_all` will delete all vectors from the default namespace.
61        """
62        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
63        context.set_details("Method not implemented!")
64        raise NotImplementedError("Method not implemented!")
65
66    def Fetch(self, request, context):
67        """The `Fetch` operation returns a vector value by id."""
68        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
69        context.set_details("Method not implemented!")
70        raise NotImplementedError("Method not implemented!")
71
72    def Query(self, request, context):
73        """The `Query` operation queries the index for the nearest stored vectors to one
74        or more query vectors, and returns their ids and/or values.
75        """
76        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
77        context.set_details("Method not implemented!")
78        raise NotImplementedError("Method not implemented!")
79
80    def DescribeIndexStats(self, request, context):
81        """The `DescribeIndexStats` operation returns summary statistics about the index contents."""
82        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
83        context.set_details("Method not implemented!")
84        raise NotImplementedError("Method not implemented!")

The VectorColumnService interface is exposed by Pinecone vector index services. The Upsert operation is for uploading the data (the vector ids and values) to be indexed.

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

52    def Upsert(self, request, context):
53        """If a user upserts a new value for an existing vector id, it overwrites the previous value."""
54        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
55        context.set_details("Method not implemented!")
56        raise NotImplementedError("Method not implemented!")

If a user upserts a new value for an existing vector id, it overwrites the previous value.

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

58    def Delete(self, request, context):
59        """The `Delete` operation deletes multiple vectors ids from a single namespace.
60        Specifying `delete_all` will delete all vectors from the default namespace.
61        """
62        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
63        context.set_details("Method not implemented!")
64        raise NotImplementedError("Method not implemented!")

The Delete operation deletes multiple vectors ids from a single namespace. Specifying delete_all will delete all vectors from the default namespace.

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

66    def Fetch(self, request, context):
67        """The `Fetch` operation returns a vector value by id."""
68        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
69        context.set_details("Method not implemented!")
70        raise NotImplementedError("Method not implemented!")

The Fetch operation returns a vector value by id.

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

72    def Query(self, request, context):
73        """The `Query` operation queries the index for the nearest stored vectors to one
74        or more query vectors, and returns their ids and/or values.
75        """
76        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
77        context.set_details("Method not implemented!")
78        raise NotImplementedError("Method not implemented!")

The Query operation queries the index for the nearest stored vectors to one or more query vectors, and returns their ids and/or values.

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

80    def DescribeIndexStats(self, request, context):
81        """The `DescribeIndexStats` operation returns summary statistics about the index contents."""
82        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
83        context.set_details("Method not implemented!")
84        raise NotImplementedError("Method not implemented!")

The DescribeIndexStats operation returns summary statistics about the index contents.

def add_VectorColumnServiceServicer_to_server(servicer, server): View Source

 87def add_VectorColumnServiceServicer_to_server(servicer, server):
 88    rpc_method_handlers = {
 89        "Upsert": grpc.unary_unary_rpc_method_handler(
 90            servicer.Upsert,
 91            request_deserializer=vector__column__service__pb2.UpsertRequest.FromString,
 92            response_serializer=vector__column__service__pb2.UpsertResponse.SerializeToString,
 93        ),
 94        "Delete": grpc.unary_unary_rpc_method_handler(
 95            servicer.Delete,
 96            request_deserializer=vector__column__service__pb2.DeleteRequest.FromString,
 97            response_serializer=vector__column__service__pb2.DeleteResponse.SerializeToString,
 98        ),
 99        "Fetch": grpc.unary_unary_rpc_method_handler(
100            servicer.Fetch,
101            request_deserializer=vector__column__service__pb2.FetchRequest.FromString,
102            response_serializer=vector__column__service__pb2.FetchResponse.SerializeToString,
103        ),
104        "Query": grpc.unary_unary_rpc_method_handler(
105            servicer.Query,
106            request_deserializer=vector__column__service__pb2.QueryRequest.FromString,
107            response_serializer=vector__column__service__pb2.QueryResponse.SerializeToString,
108        ),
109        "DescribeIndexStats": grpc.unary_unary_rpc_method_handler(
110            servicer.DescribeIndexStats,
111            request_deserializer=vector__column__service__pb2.DescribeIndexStatsRequest.FromString,
112            response_serializer=vector__column__service__pb2.DescribeIndexStatsResponse.SerializeToString,
113        ),
114    }
115    generic_handler = grpc.method_handlers_generic_handler("pinecone_columnar.VectorColumnService", rpc_method_handlers)
116    server.add_generic_rpc_handlers((generic_handler,))

class VectorColumnService: View Source

120class VectorColumnService(object):
121    """The `VectorColumnService` interface is exposed by Pinecone vector index services.
122    The `Upsert` operation is for uploading the data (the vector ids and values) to be indexed.
123    """
124
125    @staticmethod
126    def Upsert(
127        request,
128        target,
129        options=(),
130        channel_credentials=None,
131        call_credentials=None,
132        insecure=False,
133        compression=None,
134        wait_for_ready=None,
135        timeout=None,
136        metadata=None,
137    ):
138        return grpc.experimental.unary_unary(
139            request,
140            target,
141            "/pinecone_columnar.VectorColumnService/Upsert",
142            vector__column__service__pb2.UpsertRequest.SerializeToString,
143            vector__column__service__pb2.UpsertResponse.FromString,
144            options,
145            channel_credentials,
146            insecure,
147            call_credentials,
148            compression,
149            wait_for_ready,
150            timeout,
151            metadata,
152        )
153
154    @staticmethod
155    def Delete(
156        request,
157        target,
158        options=(),
159        channel_credentials=None,
160        call_credentials=None,
161        insecure=False,
162        compression=None,
163        wait_for_ready=None,
164        timeout=None,
165        metadata=None,
166    ):
167        return grpc.experimental.unary_unary(
168            request,
169            target,
170            "/pinecone_columnar.VectorColumnService/Delete",
171            vector__column__service__pb2.DeleteRequest.SerializeToString,
172            vector__column__service__pb2.DeleteResponse.FromString,
173            options,
174            channel_credentials,
175            insecure,
176            call_credentials,
177            compression,
178            wait_for_ready,
179            timeout,
180            metadata,
181        )
182
183    @staticmethod
184    def Fetch(
185        request,
186        target,
187        options=(),
188        channel_credentials=None,
189        call_credentials=None,
190        insecure=False,
191        compression=None,
192        wait_for_ready=None,
193        timeout=None,
194        metadata=None,
195    ):
196        return grpc.experimental.unary_unary(
197            request,
198            target,
199            "/pinecone_columnar.VectorColumnService/Fetch",
200            vector__column__service__pb2.FetchRequest.SerializeToString,
201            vector__column__service__pb2.FetchResponse.FromString,
202            options,
203            channel_credentials,
204            insecure,
205            call_credentials,
206            compression,
207            wait_for_ready,
208            timeout,
209            metadata,
210        )
211
212    @staticmethod
213    def Query(
214        request,
215        target,
216        options=(),
217        channel_credentials=None,
218        call_credentials=None,
219        insecure=False,
220        compression=None,
221        wait_for_ready=None,
222        timeout=None,
223        metadata=None,
224    ):
225        return grpc.experimental.unary_unary(
226            request,
227            target,
228            "/pinecone_columnar.VectorColumnService/Query",
229            vector__column__service__pb2.QueryRequest.SerializeToString,
230            vector__column__service__pb2.QueryResponse.FromString,
231            options,
232            channel_credentials,
233            insecure,
234            call_credentials,
235            compression,
236            wait_for_ready,
237            timeout,
238            metadata,
239        )
240
241    @staticmethod
242    def DescribeIndexStats(
243        request,
244        target,
245        options=(),
246        channel_credentials=None,
247        call_credentials=None,
248        insecure=False,
249        compression=None,
250        wait_for_ready=None,
251        timeout=None,
252        metadata=None,
253    ):
254        return grpc.experimental.unary_unary(
255            request,
256            target,
257            "/pinecone_columnar.VectorColumnService/DescribeIndexStats",
258            vector__column__service__pb2.DescribeIndexStatsRequest.SerializeToString,
259            vector__column__service__pb2.DescribeIndexStatsResponse.FromString,
260            options,
261            channel_credentials,
262            insecure,
263            call_credentials,
264            compression,
265            wait_for_ready,
266            timeout,
267            metadata,
268        )

The VectorColumnService interface is exposed by Pinecone vector index services. The Upsert operation is for uploading the data (the vector ids and values) to be indexed.

@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

125    @staticmethod
126    def Upsert(
127        request,
128        target,
129        options=(),
130        channel_credentials=None,
131        call_credentials=None,
132        insecure=False,
133        compression=None,
134        wait_for_ready=None,
135        timeout=None,
136        metadata=None,
137    ):
138        return grpc.experimental.unary_unary(
139            request,
140            target,
141            "/pinecone_columnar.VectorColumnService/Upsert",
142            vector__column__service__pb2.UpsertRequest.SerializeToString,
143            vector__column__service__pb2.UpsertResponse.FromString,
144            options,
145            channel_credentials,
146            insecure,
147            call_credentials,
148            compression,
149            wait_for_ready,
150            timeout,
151            metadata,
152        )

@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

154    @staticmethod
155    def Delete(
156        request,
157        target,
158        options=(),
159        channel_credentials=None,
160        call_credentials=None,
161        insecure=False,
162        compression=None,
163        wait_for_ready=None,
164        timeout=None,
165        metadata=None,
166    ):
167        return grpc.experimental.unary_unary(
168            request,
169            target,
170            "/pinecone_columnar.VectorColumnService/Delete",
171            vector__column__service__pb2.DeleteRequest.SerializeToString,
172            vector__column__service__pb2.DeleteResponse.FromString,
173            options,
174            channel_credentials,
175            insecure,
176            call_credentials,
177            compression,
178            wait_for_ready,
179            timeout,
180            metadata,
181        )

@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

183    @staticmethod
184    def Fetch(
185        request,
186        target,
187        options=(),
188        channel_credentials=None,
189        call_credentials=None,
190        insecure=False,
191        compression=None,
192        wait_for_ready=None,
193        timeout=None,
194        metadata=None,
195    ):
196        return grpc.experimental.unary_unary(
197            request,
198            target,
199            "/pinecone_columnar.VectorColumnService/Fetch",
200            vector__column__service__pb2.FetchRequest.SerializeToString,
201            vector__column__service__pb2.FetchResponse.FromString,
202            options,
203            channel_credentials,
204            insecure,
205            call_credentials,
206            compression,
207            wait_for_ready,
208            timeout,
209            metadata,
210        )

@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

212    @staticmethod
213    def Query(
214        request,
215        target,
216        options=(),
217        channel_credentials=None,
218        call_credentials=None,
219        insecure=False,
220        compression=None,
221        wait_for_ready=None,
222        timeout=None,
223        metadata=None,
224    ):
225        return grpc.experimental.unary_unary(
226            request,
227            target,
228            "/pinecone_columnar.VectorColumnService/Query",
229            vector__column__service__pb2.QueryRequest.SerializeToString,
230            vector__column__service__pb2.QueryResponse.FromString,
231            options,
232            channel_credentials,
233            insecure,
234            call_credentials,
235            compression,
236            wait_for_ready,
237            timeout,
238            metadata,
239        )

@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

241    @staticmethod
242    def DescribeIndexStats(
243        request,
244        target,
245        options=(),
246        channel_credentials=None,
247        call_credentials=None,
248        insecure=False,
249        compression=None,
250        wait_for_ready=None,
251        timeout=None,
252        metadata=None,
253    ):
254        return grpc.experimental.unary_unary(
255            request,
256            target,
257            "/pinecone_columnar.VectorColumnService/DescribeIndexStats",
258            vector__column__service__pb2.DescribeIndexStatsRequest.SerializeToString,
259            vector__column__service__pb2.DescribeIndexStatsResponse.FromString,
260            options,
261            channel_credentials,
262            insecure,
263            call_credentials,
264            compression,
265            wait_for_ready,
266            timeout,
267            metadata,
268        )