Update [vald sha: d1e546f]

VALD_SHA

@@ -1 +1 @@
-1e1cd862427cb5cab4e7b627e55cc34f7f1741b7
+d1e546f2ffbbdf6f7908f3631a7ff6959098744c

package.json

@@ -5,8 +5,8 @@
   "main": "index.js",
   "types": "index.d.ts",
   "devDependencies": {
-    "@bufbuild/buf": "^1.28.1",
-    "@bufbuild/protobuf": "^1.6.0",
+    "@bufbuild/buf": "^1.29.0",
+    "@bufbuild/protobuf": "^1.7.2",
     "@types/jest": "^27.5.2",
     "jest": "^27.5.1",
     "ts-jest": "^27.1.5",

src/vald/v1/agent/core/agent_pb.d.ts

@@ -5,7 +5,7 @@
 // @ts-nocheck
 //
 //
-// Copyright (C) 2019-2023 vdaas.org vald team <[email protected]>
+// Copyright (C) 2019-2024 vdaas.org vald team <[email protected]>
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // You may not use this file except in compliance with the License.

src/vald/v1/agent/core/agent_pb.grpc-client.d.ts

@@ -5,7 +5,7 @@
 // @ts-nocheck
 //
 //
-// Copyright (C) 2019-2023 vdaas.org vald team <[email protected]>
+// Copyright (C) 2019-2024 vdaas.org vald team <[email protected]>
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // You may not use this file except in compliance with the License.

src/vald/v1/agent/core/agent_pb.grpc-client.js

@@ -5,7 +5,7 @@
 // @ts-nocheck
 //
 //
-// Copyright (C) 2019-2023 vdaas.org vald team <[email protected]>
+// Copyright (C) 2019-2024 vdaas.org vald team <[email protected]>
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // You may not use this file except in compliance with the License.
@@ -30,7 +30,7 @@ exports.AgentClient = void 0;
 // @ts-nocheck
 //
 //
-// Copyright (C) 2019-2023 vdaas.org vald team <[email protected]>
+// Copyright (C) 2019-2024 vdaas.org vald team <[email protected]>
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // You may not use this file except in compliance with the License.

src/vald/v1/agent/core/agent_pb.js

@@ -5,7 +5,7 @@
 // @ts-nocheck
 //
 //
-// Copyright (C) 2019-2023 vdaas.org vald team <[email protected]>
+// Copyright (C) 2019-2024 vdaas.org vald team <[email protected]>
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // You may not use this file except in compliance with the License.
@@ -30,7 +30,7 @@ exports.Agent = void 0;
 // @ts-nocheck
 //
 //
-// Copyright (C) 2019-2023 vdaas.org vald team <[email protected]>
+// Copyright (C) 2019-2024 vdaas.org vald team <[email protected]>
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // You may not use this file except in compliance with the License.

src/vald/v1/payload/payload_pb.d.ts

@@ -5,7 +5,7 @@
 // @ts-nocheck
 //
 //
-// Copyright (C) 2019-2023 vdaas.org vald team <[email protected]>
+// Copyright (C) 2019-2024 vdaas.org vald team <[email protected]>
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // You may not use this file except in compliance with the License.
@@ -1547,6 +1547,45 @@ export interface Info_IPs {
      */
     ip: string[];
 }
+/**
+ * Mirror related messages.
+ *
+ * @generated from protobuf message payload.v1.Mirror
+ */
+export interface Mirror {
+}
+/**
+ * Represent server information.
+ *
+ * @generated from protobuf message payload.v1.Mirror.Target
+ */
+export interface Mirror_Target {
+    /**
+     * The target hostname.
+     *
+     * @generated from protobuf field: string host = 1;
+     */
+    host: string;
+    /**
+     * The target port.
+     *
+     * @generated from protobuf field: uint32 port = 2;
+     */
+    port: number;
+}
+/**
+ * Represent the multiple Target message.
+ *
+ * @generated from protobuf message payload.v1.Mirror.Targets
+ */
+export interface Mirror_Targets {
+    /**
+     * The multiple target information.
+     *
+     * @generated from protobuf field: repeated payload.v1.Mirror.Target targets = 1;
+     */
+    targets: Mirror_Target[];
+}
 /**
  * Represent an empty message.
  *
@@ -2356,6 +2395,36 @@ declare class Info_IPs$Type extends MessageType<Info_IPs> {
  * @generated MessageType for protobuf message payload.v1.Info.IPs
  */
 export declare const Info_IPs: Info_IPs$Type;
+declare class Mirror$Type extends MessageType<Mirror> {
+    constructor();
+    create(value?: PartialMessage<Mirror>): Mirror;
+    internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: Mirror): Mirror;
+    internalBinaryWrite(message: Mirror, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter;
+}
+/**
+ * @generated MessageType for protobuf message payload.v1.Mirror
+ */
+export declare const Mirror: Mirror$Type;
+declare class Mirror_Target$Type extends MessageType<Mirror_Target> {
+    constructor();
+    create(value?: PartialMessage<Mirror_Target>): Mirror_Target;
+    internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: Mirror_Target): Mirror_Target;
+    internalBinaryWrite(message: Mirror_Target, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter;
+}
+/**
+ * @generated MessageType for protobuf message payload.v1.Mirror.Target
+ */
+export declare const Mirror_Target: Mirror_Target$Type;
+declare class Mirror_Targets$Type extends MessageType<Mirror_Targets> {
+    constructor();
+    create(value?: PartialMessage<Mirror_Targets>): Mirror_Targets;
+    internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: Mirror_Targets): Mirror_Targets;
+    internalBinaryWrite(message: Mirror_Targets, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter;
+}
+/**
+ * @generated MessageType for protobuf message payload.v1.Mirror.Targets
+ */
+export declare const Mirror_Targets: Mirror_Targets$Type;
 declare class Empty$Type extends MessageType<Empty> {
     constructor();
     create(value?: PartialMessage<Empty>): Empty;

src/vald/v1/payload/payload_pb.js

@@ -5,7 +5,7 @@
 // @ts-nocheck
 //
 //
-// Copyright (C) 2019-2023 vdaas.org vald team <[email protected]>
+// Copyright (C) 2019-2024 vdaas.org vald team <[email protected]>
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // You may not use this file except in compliance with the License.
@@ -22,15 +22,15 @@
 //
 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.Empty = exports.Info_IPs = exports.Info_Services = exports.Info_Nodes = exports.Info_Pods = exports.Info_Memory = exports.Info_CPU = exports.Info_Annotations = exports.Info_Labels = exports.Info_ServicePort = exports.Info_Service = exports.Info_Node = exports.Info_Pod = exports.Info_Index_UUID_Uncommitted = exports.Info_Index_UUID_Committed = exports.Info_Index_UUID = exports.Info_Index_Count = exports.Info_Index = exports.Info = exports.Discoverer_Request = exports.Discoverer = exports.Control_CreateIndexRequest = exports.Control = exports.Object_List_Response = exports.Object_List_Request = exports.Object_List = exports.Object_Locations = exports.Object_StreamLocation = exports.Object_Location = exports.Object_StreamBlob = exports.Object_Blob = exports.Object_ReshapeVector = exports.Object_StreamVector = exports.Object_Vectors = exports.Object_Timestamp = exports.Object_GetTimestampRequest = exports.Object_Vector = exports.Object_IDs = exports.Object_ID = exports.Object_StreamDistance = exports.Object_Distance = exports.Object_VectorRequest = exports.Object = exports.Remove_Config = exports.Remove_Timestamp = exports.Remove_TimestampRequest = exports.Remove_MultiRequest = exports.Remove_Request = exports.Remove = exports.Upsert_Config = exports.Upsert_MultiObjectRequest = exports.Upsert_ObjectRequest = exports.Upsert_MultiRequest = exports.Upsert_Request = exports.Upsert = exports.Update_Config = exports.Update_MultiObjectRequest = exports.Update_ObjectRequest = exports.Update_MultiRequest = exports.Update_Request = exports.Update = exports.Insert_Config = exports.Insert_MultiObjectRequest = exports.Insert_ObjectRequest = exports.Insert_MultiRequest = exports.Insert_Request = exports.Insert = exports.Filter_Config = exports.Filter_Target = exports.Filter = exports.Search_StreamResponse = exports.Search_Responses = exports.Search_Response = exports.Search_Config = exports.Search_MultiObjectRequest = exports.Search_ObjectRequest = exports.Search_MultiIDRequest = exports.Search_IDRequest = exports.Search_MultiRequest = exports.Search_Request = exports.Search = exports.Remove_Timestamp_Operator = exports.Search_AggregationAlgorithm = void 0;
+exports.Empty = exports.Mirror_Targets = exports.Mirror_Target = exports.Mirror = exports.Info_IPs = exports.Info_Services = exports.Info_Nodes = exports.Info_Pods = exports.Info_Memory = exports.Info_CPU = exports.Info_Annotations = exports.Info_Labels = exports.Info_ServicePort = exports.Info_Service = exports.Info_Node = exports.Info_Pod = exports.Info_Index_UUID_Uncommitted = exports.Info_Index_UUID_Committed = exports.Info_Index_UUID = exports.Info_Index_Count = exports.Info_Index = exports.Info = exports.Discoverer_Request = exports.Discoverer = exports.Control_CreateIndexRequest = exports.Control = exports.Object_List_Response = exports.Object_List_Request = exports.Object_List = exports.Object_Locations = exports.Object_StreamLocation = exports.Object_Location = exports.Object_StreamBlob = exports.Object_Blob = exports.Object_ReshapeVector = exports.Object_StreamVector = exports.Object_Vectors = exports.Object_Timestamp = exports.Object_GetTimestampRequest = exports.Object_Vector = exports.Object_IDs = exports.Object_ID = exports.Object_StreamDistance = exports.Object_Distance = exports.Object_VectorRequest = exports.Object = exports.Remove_Config = exports.Remove_Timestamp = exports.Remove_TimestampRequest = exports.Remove_MultiRequest = exports.Remove_Request = exports.Remove = exports.Upsert_Config = exports.Upsert_MultiObjectRequest = exports.Upsert_ObjectRequest = exports.Upsert_MultiRequest = exports.Upsert_Request = exports.Upsert = exports.Update_Config = exports.Update_MultiObjectRequest = exports.Update_ObjectRequest = exports.Update_MultiRequest = exports.Update_Request = exports.Update = exports.Insert_Config = exports.Insert_MultiObjectRequest = exports.Insert_ObjectRequest = exports.Insert_MultiRequest = exports.Insert_Request = exports.Insert = exports.Filter_Config = exports.Filter_Target = exports.Filter = exports.Search_StreamResponse = exports.Search_Responses = exports.Search_Response = exports.Search_Config = exports.Search_MultiObjectRequest = exports.Search_ObjectRequest = exports.Search_MultiIDRequest = exports.Search_IDRequest = exports.Search_MultiRequest = exports.Search_Request = exports.Search = exports.Remove_Timestamp_Operator = exports.Search_AggregationAlgorithm = void 0;
 /* eslint-disable */
 // @generated by protobuf-ts 2.9.3 with parameter add_pb_suffix,client_grpc1,generate_dependencies,keep_enum_prefix,ts_nocheck,use_proto_field_name,output_javascript,output_legacy_commonjs,eslint_disable
 // @generated from protobuf file "vald/v1/payload/payload.proto" (package "payload.v1", syntax proto3)
 // tslint:disable
 // @ts-nocheck
 //
 //
-// Copyright (C) 2019-2023 vdaas.org vald team <[email protected]>
+// Copyright (C) 2019-2024 vdaas.org vald team <[email protected]>
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // You may not use this file except in compliance with the License.
@@ -4224,6 +4224,133 @@ class Info_IPs$Type extends runtime_4.MessageType {
  */
 exports.Info_IPs = new Info_IPs$Type();
 // @generated message type with reflection information, may provide speed optimized methods
+class Mirror$Type extends runtime_4.MessageType {
+    constructor() {
+        super("payload.v1.Mirror", []);
+    }
+    create(value) {
+        const message = globalThis.Object.create((this.messagePrototype));
+        if (value !== undefined)
+            runtime_3.reflectionMergePartial(this, message, value);
+        return message;
+    }
+    internalBinaryRead(reader, length, options, target) {
+        return target ?? this.create();
+    }
+    internalBinaryWrite(message, writer, options) {
+        let u = options.writeUnknownFields;
+        if (u !== false)
+            (u == true ? runtime_2.UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
+        return writer;
+    }
+}
+/**
+ * @generated MessageType for protobuf message payload.v1.Mirror
+ */
+exports.Mirror = new Mirror$Type();
+// @generated message type with reflection information, may provide speed optimized methods
+class Mirror_Target$Type extends runtime_4.MessageType {
+    constructor() {
+        super("payload.v1.Mirror.Target", [
+            { no: 1, name: "host", kind: "scalar", T: 9 /*ScalarType.STRING*/ },
+            { no: 2, name: "port", kind: "scalar", T: 13 /*ScalarType.UINT32*/ }
+        ]);
+    }
+    create(value) {
+        const message = globalThis.Object.create((this.messagePrototype));
+        message.host = "";
+        message.port = 0;
+        if (value !== undefined)
+            runtime_3.reflectionMergePartial(this, message, value);
+        return message;
+    }
+    internalBinaryRead(reader, length, options, target) {
+        let message = target ?? this.create(), end = reader.pos + length;
+        while (reader.pos < end) {
+            let [fieldNo, wireType] = reader.tag();
+            switch (fieldNo) {
+                case /* string host */ 1:
+                    message.host = reader.string();
+                    break;
+                case /* uint32 port */ 2:
+                    message.port = reader.uint32();
+                    break;
+                default:
+                    let u = options.readUnknownField;
+                    if (u === "throw")
+                        throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`);
+                    let d = reader.skip(wireType);
+                    if (u !== false)
+                        (u === true ? runtime_2.UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d);
+            }
+        }
+        return message;
+    }
+    internalBinaryWrite(message, writer, options) {
+        /* string host = 1; */
+        if (message.host !== "")
+            writer.tag(1, runtime_1.WireType.LengthDelimited).string(message.host);
+        /* uint32 port = 2; */
+        if (message.port !== 0)
+            writer.tag(2, runtime_1.WireType.Varint).uint32(message.port);
+        let u = options.writeUnknownFields;
+        if (u !== false)
+            (u == true ? runtime_2.UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
+        return writer;
+    }
+}
+/**
+ * @generated MessageType for protobuf message payload.v1.Mirror.Target
+ */
+exports.Mirror_Target = new Mirror_Target$Type();
+// @generated message type with reflection information, may provide speed optimized methods
+class Mirror_Targets$Type extends runtime_4.MessageType {
+    constructor() {
+        super("payload.v1.Mirror.Targets", [
+            { no: 1, name: "targets", kind: "message", repeat: 1 /*RepeatType.PACKED*/, T: () => exports.Mirror_Target }
+        ]);
+    }
+    create(value) {
+        const message = globalThis.Object.create((this.messagePrototype));
+        message.targets = [];
+        if (value !== undefined)
+            runtime_3.reflectionMergePartial(this, message, value);
+        return message;
+    }
+    internalBinaryRead(reader, length, options, target) {
+        let message = target ?? this.create(), end = reader.pos + length;
+        while (reader.pos < end) {
+            let [fieldNo, wireType] = reader.tag();
+            switch (fieldNo) {
+                case /* repeated payload.v1.Mirror.Target targets */ 1:
+                    message.targets.push(exports.Mirror_Target.internalBinaryRead(reader, reader.uint32(), options));
+                    break;
+                default:
+                    let u = options.readUnknownField;
+                    if (u === "throw")
+                        throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`);
+                    let d = reader.skip(wireType);
+                    if (u !== false)
+                        (u === true ? runtime_2.UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d);
+            }
+        }
+        return message;
+    }
+    internalBinaryWrite(message, writer, options) {
+        /* repeated payload.v1.Mirror.Target targets = 1; */
+        for (let i = 0; i < message.targets.length; i++)
+            exports.Mirror_Target.internalBinaryWrite(message.targets[i], writer.tag(1, runtime_1.WireType.LengthDelimited).fork(), options).join();
+        let u = options.writeUnknownFields;
+        if (u !== false)
+            (u == true ? runtime_2.UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
+        return writer;
+    }
+}
+/**
+ * @generated MessageType for protobuf message payload.v1.Mirror.Targets
+ */
+exports.Mirror_Targets = new Mirror_Targets$Type();
+// @generated message type with reflection information, may provide speed optimized methods
 class Empty$Type extends runtime_4.MessageType {
     constructor() {
         super("payload.v1.Empty", []);

src/vald/v1/vald/filter_pb.d.ts

@@ -5,7 +5,7 @@
 // @ts-nocheck
 //
 //
-// Copyright (C) 2019-2023 vdaas.org vald team <[email protected]>
+// Copyright (C) 2019-2024 vdaas.org vald team <[email protected]>
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // You may not use this file except in compliance with the License.

src/vald/v1/vald/filter_pb.grpc-client.d.ts

@@ -5,7 +5,7 @@
 // @ts-nocheck
 //
 //
-// Copyright (C) 2019-2023 vdaas.org vald team <[email protected]>
+// Copyright (C) 2019-2024 vdaas.org vald team <[email protected]>
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // You may not use this file except in compliance with the License.

src/vald/v1/vald/filter_pb.grpc-client.js

@@ -5,7 +5,7 @@
 // @ts-nocheck
 //
 //
-// Copyright (C) 2019-2023 vdaas.org vald team <[email protected]>
+// Copyright (C) 2019-2024 vdaas.org vald team <[email protected]>
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // You may not use this file except in compliance with the License.
@@ -30,7 +30,7 @@ exports.FilterClient = void 0;
 // @ts-nocheck
 //
 //
-// Copyright (C) 2019-2023 vdaas.org vald team <[email protected]>
+// Copyright (C) 2019-2024 vdaas.org vald team <[email protected]>
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // You may not use this file except in compliance with the License.

src/vald/v1/vald/filter_pb.js

@@ -5,7 +5,7 @@
 // @ts-nocheck
 //
 //
-// Copyright (C) 2019-2023 vdaas.org vald team <[email protected]>
+// Copyright (C) 2019-2024 vdaas.org vald team <[email protected]>
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // You may not use this file except in compliance with the License.
@@ -30,7 +30,7 @@ exports.Filter = void 0;
 // @ts-nocheck
 //
 //
-// Copyright (C) 2019-2023 vdaas.org vald team <[email protected]>
+// Copyright (C) 2019-2024 vdaas.org vald team <[email protected]>
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // You may not use this file except in compliance with the License.

src/vald/v1/vald/insert_pb.d.ts

@@ -5,7 +5,7 @@
 // @ts-nocheck
 //
 //
-// Copyright (C) 2019-2023 vdaas.org vald team <[email protected]>
+// Copyright (C) 2019-2024 vdaas.org vald team <[email protected]>
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // You may not use this file except in compliance with the License.

src/vald/v1/vald/insert_pb.grpc-client.d.ts

@@ -5,7 +5,7 @@
 // @ts-nocheck
 //
 //
-// Copyright (C) 2019-2023 vdaas.org vald team <[email protected]>
+// Copyright (C) 2019-2024 vdaas.org vald team <[email protected]>
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // You may not use this file except in compliance with the License.