@cloudquery/plugin-pb-javascript - npm Package Compare versions

Comparing version 0.0.21 to 0.0.22

dist/protos/plugin/v3/plugin.d.ts

@@ -767,2 +767,53 @@ /**
     }
+    export class Transform extends pb_1.Message {
+        #private;
+        constructor(data?: any[] | {});
+        static fromObject(data: {}): Transform;
+        toObject(): {};
+        serialize(): Uint8Array;
+        serialize(w: pb_1.BinaryWriter): void;
+        static deserialize(bytes: Uint8Array | pb_1.BinaryReader): Transform;
+        serializeBinary(): Uint8Array;
+        static deserializeBinary(bytes: Uint8Array): Transform;
+    }
+    export namespace Transform {
+        class Request extends pb_1.Message {
+            #private;
+            constructor(data?: any[] | {
+                record?: Uint8Array;
+            });
+            get record(): Uint8Array;
+            set record(value: Uint8Array);
+            static fromObject(data: {
+                record?: Uint8Array;
+            }): Request;
+            toObject(): {
+                record?: Uint8Array;
+            };
+            serialize(): Uint8Array;
+            serialize(w: pb_1.BinaryWriter): void;
+            static deserialize(bytes: Uint8Array | pb_1.BinaryReader): Request;
+            serializeBinary(): Uint8Array;
+            static deserializeBinary(bytes: Uint8Array): Request;
+        }
+        class Response extends pb_1.Message {
+            #private;
+            constructor(data?: any[] | {
+                record?: Uint8Array;
+            });
+            get record(): Uint8Array;
+            set record(value: Uint8Array);
+            static fromObject(data: {
+                record?: Uint8Array;
+            }): Response;
+            toObject(): {
+                record?: Uint8Array;
+            };
+            serialize(): Uint8Array;
+            serialize(w: pb_1.BinaryWriter): void;
+            static deserialize(bytes: Uint8Array | pb_1.BinaryReader): Response;
+            serializeBinary(): Uint8Array;
+            static deserializeBinary(bytes: Uint8Array): Response;
+        }
+    }
     export class Close extends pb_1.Message {
@@ -880,2 +931,6 @@ #private;
     }
+    interface GrpcChunkServiceInterface<P, R> {
+        (metadata: grpc_1.Metadata, options?: grpc_1.CallOptions): grpc_1.ClientDuplexStream<P, R>;
+        (options?: grpc_1.CallOptions): grpc_1.ClientDuplexStream<P, R>;
+    }
     export abstract class UnimplementedPluginService {
@@ -955,2 +1010,11 @@ static definition: {
             };
+            Transform: {
+                path: string;
+                requestStream: boolean;
+                responseStream: boolean;
+                requestSerialize: (message: Transform.Request) => Buffer;
+                requestDeserialize: (bytes: Buffer) => Transform.Request;
+                responseSerialize: (message: Transform.Response) => Buffer;
+                responseDeserialize: (bytes: Buffer) => Transform.Response;
+            };
             Close: {
@@ -984,2 +1048,3 @@ path: string;
         abstract Write(call: grpc_1.ServerReadableStream<Write.Request, Write.Response>, callback: grpc_1.sendUnaryData<Write.Response>): void;
+        abstract Transform(call: grpc_1.ServerDuplexStream<Transform.Request, Transform.Response>): void;
         abstract Close(call: grpc_1.ServerUnaryCall<Close.Request, Close.Response>, callback: grpc_1.sendUnaryData<Close.Response>): void;
@@ -999,2 +1064,3 @@ abstract TestConnection(call: grpc_1.ServerUnaryCall<TestConnection.Request, TestConnection.Response>, callback: grpc_1.sendUnaryData<TestConnection.Response>): void;
         Write: GrpWritableServiceInterface<Write.Request, Write.Response>;
+        Transform: GrpcChunkServiceInterface<Transform.Request, Transform.Response>;
         Close: GrpcUnaryServiceInterface<Close.Request, Close.Response>;
@@ -1001,0 +1067,0 @@ TestConnection: GrpcUnaryServiceInterface<TestConnection.Request, TestConnection.Response>;

package.json

 {
   "name": "@cloudquery/plugin-pb-javascript",
-  "version": "0.0.21",
+  "version": "0.0.22",
   "files": [
@@ -5,0 +5,0 @@ "dist"

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

244364

increased by4.85%

Lines of code

4689

increased by5.47%

No dependency changes