Skip to content

Commit

Permalink
Update [vald sha: c39130028731aefeb84d03c885e50791b92a8ff3]
Browse files Browse the repository at this point in the history 
Signed-off-by: Vdaas CI <[email protected]>
  • Loading branch information
@vdaas-ci
vdaas-ci committed May 7, 2024
1 parent 9836844 commit dde3899
Show file tree
Hide file tree
Showing 28 changed files with 963 additions and 463 deletions.
2 changes: 1 addition & 1 deletion VALD_SHA
View file
Original file line number Diff line number Diff line change
@@ -1 +1 @@
18786bf03a1a47d7c24afae496ad1c839c1aca1e
c39130028731aefeb84d03c885e50791b92a8ff3
6 changes: 3 additions & 3 deletions src/buf/validate/expression_pb2.py
View file

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

6 changes: 3 additions & 3 deletions src/buf/validate/priv/private_pb2.py
View file

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

312 changes: 156 additions & 156 deletions src/buf/validate/validate_pb2.py
View file

Large diffs are not rendered by default.

6 changes: 3 additions & 3 deletions src/google/api/annotations_pb2.py
View file

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

6 changes: 3 additions & 3 deletions src/google/api/http_pb2.py
View file

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

6 changes: 3 additions & 3 deletions src/google/rpc/status_pb2.py
View file

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

16 changes: 8 additions & 8 deletions src/vald/v1/agent/core/agent_pb2.py
View file

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

90 changes: 70 additions & 20 deletions src/vald/v1/agent/core/agent_pb2_grpc.py
View file
Original file line number Diff line number Diff line change
Expand Up @@ -19,27 +19,27 @@ def __init__(self, channel):
'/core.v1.Agent/CreateIndex',
request_serializer=vald_dot_v1_dot_payload_dot_payload__pb2.Control.CreateIndexRequest.SerializeToString,
response_deserializer=vald_dot_v1_dot_payload_dot_payload__pb2.Empty.FromString,
)
_registered_method=True)
self.SaveIndex = channel.unary_unary(
'/core.v1.Agent/SaveIndex',
request_serializer=vald_dot_v1_dot_payload_dot_payload__pb2.Empty.SerializeToString,
response_deserializer=vald_dot_v1_dot_payload_dot_payload__pb2.Empty.FromString,
)
_registered_method=True)
self.CreateAndSaveIndex = channel.unary_unary(
'/core.v1.Agent/CreateAndSaveIndex',
request_serializer=vald_dot_v1_dot_payload_dot_payload__pb2.Control.CreateIndexRequest.SerializeToString,
response_deserializer=vald_dot_v1_dot_payload_dot_payload__pb2.Empty.FromString,
)
_registered_method=True)
self.IndexInfo = channel.unary_unary(
'/core.v1.Agent/IndexInfo',
request_serializer=vald_dot_v1_dot_payload_dot_payload__pb2.Empty.SerializeToString,
response_deserializer=vald_dot_v1_dot_payload_dot_payload__pb2.Info.Index.Count.FromString,
)
_registered_method=True)
self.GetTimestamp = channel.unary_unary(
'/core.v1.Agent/GetTimestamp',
request_serializer=vald_dot_v1_dot_payload_dot_payload__pb2.Object.GetTimestampRequest.SerializeToString,
response_deserializer=vald_dot_v1_dot_payload_dot_payload__pb2.Object.Timestamp.FromString,
)
_registered_method=True)


class AgentServicer(object):
Expand Down Expand Up @@ -131,11 +131,21 @@ def CreateIndex(request,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/core.v1.Agent/CreateIndex',
return grpc.experimental.unary_unary(
request,
target,
'/core.v1.Agent/CreateIndex',
vald_dot_v1_dot_payload_dot_payload__pb2.Control.CreateIndexRequest.SerializeToString,
vald_dot_v1_dot_payload_dot_payload__pb2.Empty.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)

@staticmethod
def SaveIndex(request,
Expand All @@ -148,11 +158,21 @@ def SaveIndex(request,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/core.v1.Agent/SaveIndex',
return grpc.experimental.unary_unary(
request,
target,
'/core.v1.Agent/SaveIndex',
vald_dot_v1_dot_payload_dot_payload__pb2.Empty.SerializeToString,
vald_dot_v1_dot_payload_dot_payload__pb2.Empty.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)

@staticmethod
def CreateAndSaveIndex(request,
Expand All @@ -165,11 +185,21 @@ def CreateAndSaveIndex(request,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/core.v1.Agent/CreateAndSaveIndex',
return grpc.experimental.unary_unary(
request,
target,
'/core.v1.Agent/CreateAndSaveIndex',
vald_dot_v1_dot_payload_dot_payload__pb2.Control.CreateIndexRequest.SerializeToString,
vald_dot_v1_dot_payload_dot_payload__pb2.Empty.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)

@staticmethod
def IndexInfo(request,
Expand All @@ -182,11 +212,21 @@ def IndexInfo(request,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/core.v1.Agent/IndexInfo',
return grpc.experimental.unary_unary(
request,
target,
'/core.v1.Agent/IndexInfo',
vald_dot_v1_dot_payload_dot_payload__pb2.Empty.SerializeToString,
vald_dot_v1_dot_payload_dot_payload__pb2.Info.Index.Count.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)

@staticmethod
def GetTimestamp(request,
Expand All @@ -199,8 +239,18 @@ def GetTimestamp(request,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/core.v1.Agent/GetTimestamp',
return grpc.experimental.unary_unary(
request,
target,
'/core.v1.Agent/GetTimestamp',
vald_dot_v1_dot_payload_dot_payload__pb2.Object.GetTimestampRequest.SerializeToString,
vald_dot_v1_dot_payload_dot_payload__pb2.Object.Timestamp.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
10 changes: 5 additions & 5 deletions src/vald/v1/filter/egress/egress_filter_pb2.py
View file

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

36 changes: 28 additions & 8 deletions src/vald/v1/filter/egress/egress_filter_pb2_grpc.py
View file
Original file line number Diff line number Diff line change
Expand Up @@ -19,12 +19,12 @@ def __init__(self, channel):
'/filter.egress.v1.Filter/FilterDistance',
request_serializer=vald_dot_v1_dot_payload_dot_payload__pb2.Object.Distance.SerializeToString,
response_deserializer=vald_dot_v1_dot_payload_dot_payload__pb2.Object.Distance.FromString,
)
_registered_method=True)
self.FilterVector = channel.unary_unary(
'/filter.egress.v1.Filter/FilterVector',
request_serializer=vald_dot_v1_dot_payload_dot_payload__pb2.Object.Vector.SerializeToString,
response_deserializer=vald_dot_v1_dot_payload_dot_payload__pb2.Object.Vector.FromString,
)
_registered_method=True)


class FilterServicer(object):
Expand Down Expand Up @@ -80,11 +80,21 @@ def FilterDistance(request,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/filter.egress.v1.Filter/FilterDistance',
return grpc.experimental.unary_unary(
request,
target,
'/filter.egress.v1.Filter/FilterDistance',
vald_dot_v1_dot_payload_dot_payload__pb2.Object.Distance.SerializeToString,
vald_dot_v1_dot_payload_dot_payload__pb2.Object.Distance.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)

@staticmethod
def FilterVector(request,
Expand All @@ -97,8 +107,18 @@ def FilterVector(request,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/filter.egress.v1.Filter/FilterVector',
return grpc.experimental.unary_unary(
request,
target,
'/filter.egress.v1.Filter/FilterVector',
vald_dot_v1_dot_payload_dot_payload__pb2.Object.Vector.SerializeToString,
vald_dot_v1_dot_payload_dot_payload__pb2.Object.Vector.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
Loading

0 comments on commit dde3899

Please sign in to comment.