Update [vald sha: f82407e]

VALD_CLIENT_NODE_VERSION

@@ -1 +1 @@
-1.7.8
+1.7.9

VALD_SHA

@@ -1 +1 @@
-6dcee657bb12ab999f63231ebc4acbcf52850962
+f82407ef8ee93ec28354caafcfd36c81f6c7bc42

index.d.ts

@@ -1,9 +1,9 @@
 import v1_agent_core = require("./src/vald/v1/agent/core");
-import v1_vald = require("./src/vald/v1/vald");
 import v1_payload = require("./src/vald/v1/payload");
+import v1_vald = require("./src/vald/v1/vald");
 declare const _default: {
     v1_agent_core: typeof v1_agent_core,
-    v1_vald: typeof v1_vald,
     v1_payload: typeof v1_payload,
+    v1_vald: typeof v1_vald,
 };
 export = _default;

index.js

@@ -1,3 +1,3 @@
 module.exports.v1_agent_core = require("./src/vald/v1/agent/core");
-module.exports.v1_vald = require("./src/vald/v1/vald");
 module.exports.v1_payload = require("./src/vald/v1/payload");
+module.exports.v1_vald = require("./src/vald/v1/vald");

package.json

@@ -1,6 +1,6 @@
 {
   "name": "vald-client-node",
-  "version": "1.7.8",
+  "version": "1.7.9",
   "description": "A gRPC client library for Vald",
   "main": "index.js",
   "types": "index.d.ts",

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

@@ -12,6 +12,7 @@ interface IAgentService extends grpc.ServiceDefinition<grpc.UntypedServiceImplem
   saveIndex: grpc.MethodDefinition<vald_v1_payload_payload_pb.Empty, vald_v1_payload_payload_pb.Empty>;
   createAndSaveIndex: grpc.MethodDefinition<vald_v1_payload_payload_pb.Control.CreateIndexRequest, vald_v1_payload_payload_pb.Empty>;
   indexInfo: grpc.MethodDefinition<vald_v1_payload_payload_pb.Empty, vald_v1_payload_payload_pb.Info.Index.Count>;
+  getTimestamp: grpc.MethodDefinition<vald_v1_payload_payload_pb.Object.GetTimestampRequest, vald_v1_payload_payload_pb.Object.Timestamp>;
 }
 
 export const AgentService: IAgentService;
@@ -30,4 +31,7 @@ export class AgentClient extends grpc.Client {
   indexInfo(argument: vald_v1_payload_payload_pb.Empty, callback: grpc.requestCallback<vald_v1_payload_payload_pb.Info.Index.Count>): grpc.ClientUnaryCall;
   indexInfo(argument: vald_v1_payload_payload_pb.Empty, metadataOrOptions: grpc.Metadata | grpc.CallOptions | null, callback: grpc.requestCallback<vald_v1_payload_payload_pb.Info.Index.Count>): grpc.ClientUnaryCall;
   indexInfo(argument: vald_v1_payload_payload_pb.Empty, metadata: grpc.Metadata | null, options: grpc.CallOptions | null, callback: grpc.requestCallback<vald_v1_payload_payload_pb.Info.Index.Count>): grpc.ClientUnaryCall;
+  getTimestamp(argument: vald_v1_payload_payload_pb.Object.GetTimestampRequest, callback: grpc.requestCallback<vald_v1_payload_payload_pb.Object.Timestamp>): grpc.ClientUnaryCall;
+  getTimestamp(argument: vald_v1_payload_payload_pb.Object.GetTimestampRequest, metadataOrOptions: grpc.Metadata | grpc.CallOptions | null, callback: grpc.requestCallback<vald_v1_payload_payload_pb.Object.Timestamp>): grpc.ClientUnaryCall;
+  getTimestamp(argument: vald_v1_payload_payload_pb.Object.GetTimestampRequest, metadata: grpc.Metadata | null, options: grpc.CallOptions | null, callback: grpc.requestCallback<vald_v1_payload_payload_pb.Object.Timestamp>): grpc.ClientUnaryCall;
 }

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

@@ -55,6 +55,28 @@ function deserialize_payload_v1_Info_Index_Count(buffer_arg) {
   return vald_v1_payload_payload_pb.Info.Index.Count.deserializeBinary(new Uint8Array(buffer_arg));
 }
 
+function serialize_payload_v1_Object_GetTimestampRequest(arg) {
+  if (!(arg instanceof vald_v1_payload_payload_pb.Object.GetTimestampRequest)) {
+    throw new Error('Expected argument of type payload.v1.Object.GetTimestampRequest');
+  }
+  return Buffer.from(arg.serializeBinary());
+}
+
+function deserialize_payload_v1_Object_GetTimestampRequest(buffer_arg) {
+  return vald_v1_payload_payload_pb.Object.GetTimestampRequest.deserializeBinary(new Uint8Array(buffer_arg));
+}
+
+function serialize_payload_v1_Object_Timestamp(arg) {
+  if (!(arg instanceof vald_v1_payload_payload_pb.Object.Timestamp)) {
+    throw new Error('Expected argument of type payload.v1.Object.Timestamp');
+  }
+  return Buffer.from(arg.serializeBinary());
+}
+
+function deserialize_payload_v1_Object_Timestamp(buffer_arg) {
+  return vald_v1_payload_payload_pb.Object.Timestamp.deserializeBinary(new Uint8Array(buffer_arg));
+}
+
 
 // Represent the agent service.
 var AgentService = exports.AgentService = {
@@ -106,6 +128,18 @@ indexInfo: {
     responseSerialize: serialize_payload_v1_Info_Index_Count,
     responseDeserialize: deserialize_payload_v1_Info_Index_Count,
   },
+  // Represent the RPC to get the vector metadata. This RPC is mainly used for index correction process
+getTimestamp: {
+    path: '/core.v1.Agent/GetTimestamp',
+    requestStream: false,
+    responseStream: false,
+    requestType: vald_v1_payload_payload_pb.Object.GetTimestampRequest,
+    responseType: vald_v1_payload_payload_pb.Object.Timestamp,
+    requestSerialize: serialize_payload_v1_Object_GetTimestampRequest,
+    requestDeserialize: deserialize_payload_v1_Object_GetTimestampRequest,
+    responseSerialize: serialize_payload_v1_Object_Timestamp,
+    responseDeserialize: deserialize_payload_v1_Object_Timestamp,
+  },
 };
 
 exports.AgentClient = grpc.makeGenericClientConstructor(AgentService);

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

@@ -4,7 +4,6 @@
 import * as jspb from "google-protobuf";
 import * as validate_validate_pb from "../../../validate/validate_pb";
 import * as google_rpc_status_pb from "../../../google/rpc/status_pb";
-import * as vtproto_ext_pb from "../../../vtproto/ext_pb";
 
 export class Search extends jspb.Message {
   serializeBinary(): Uint8Array;
@@ -1172,6 +1171,52 @@ export namespace Object {
     }
   }
 
+  export class GetTimestampRequest extends jspb.Message {
+    hasId(): boolean;
+    clearId(): void;
+    getId(): Object.ID | undefined;
+    setId(value?: Object.ID): void;
+
+    serializeBinary(): Uint8Array;
+    toObject(includeInstance?: boolean): GetTimestampRequest.AsObject;
+    static toObject(includeInstance: boolean, msg: GetTimestampRequest): GetTimestampRequest.AsObject;
+    static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
+    static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
+    static serializeBinaryToWriter(message: GetTimestampRequest, writer: jspb.BinaryWriter): void;
+    static deserializeBinary(bytes: Uint8Array): GetTimestampRequest;
+    static deserializeBinaryFromReader(message: GetTimestampRequest, reader: jspb.BinaryReader): GetTimestampRequest;
+  }
+
+  export namespace GetTimestampRequest {
+    export type AsObject = {
+      id?: Object.ID.AsObject,
+    }
+  }
+
+  export class Timestamp extends jspb.Message {
+    getId(): string;
+    setId(value: string): void;
+
+    getTimestamp(): number;
+    setTimestamp(value: number): void;
+
+    serializeBinary(): Uint8Array;
+    toObject(includeInstance?: boolean): Timestamp.AsObject;
+    static toObject(includeInstance: boolean, msg: Timestamp): Timestamp.AsObject;
+    static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
+    static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
+    static serializeBinaryToWriter(message: Timestamp, writer: jspb.BinaryWriter): void;
+    static deserializeBinary(bytes: Uint8Array): Timestamp;
+    static deserializeBinaryFromReader(message: Timestamp, reader: jspb.BinaryReader): Timestamp;
+  }
+
+  export namespace Timestamp {
+    export type AsObject = {
+      id: string,
+      timestamp: number,
+    }
+  }
+
   export class Vectors extends jspb.Message {
     clearVectorsList(): void;
     getVectorsList(): Array<Object.Vector>;