@parca/client - npm Package Compare versions

Comparing version 0.16.118 to 0.16.119

CHANGELOG.md

@@ -6,2 +6,6 @@ # Change Log
 
+## 0.16.119 (2024-07-02)
+
+**Note:** Version bump only for package @parca/client
+
 ## 0.16.118 (2024-06-27)
@@ -8,0 +12,0 @@

dist/parca/profilestore/v1alpha1/profilestore.client.d.ts

@@ -5,2 +5,5 @@ import type { AgentsResponse } from "./profilestore";
 import type { ServiceInfo } from "@protobuf-ts/runtime-rpc";
+import type { WriteResponse } from "./profilestore";
+import type { WriteRequest } from "./profilestore";
+import type { DuplexStreamingCall } from "@protobuf-ts/runtime-rpc";
 import type { WriteRawResponse } from "./profilestore";
@@ -22,2 +25,12 @@ import type { WriteRawRequest } from "./profilestore";
     writeRaw(input: WriteRawRequest, options?: RpcOptions): UnaryCall<WriteRawRequest, WriteRawResponse>;
+    /**
+     * Write accepts profiling data encoded as an arrow record. It's a
+     * bi-directional streaming RPC, because the first message can contain only
+     * samples without the stacktraces, and only reference stacktrace IDs. The
+     * backend can then request the full stacktrace from the client should it not
+     * know the stacktrace yet.
+     *
+     * @generated from protobuf rpc: Write(stream parca.profilestore.v1alpha1.WriteRequest) returns (stream parca.profilestore.v1alpha1.WriteResponse);
+     */
+    write(options?: RpcOptions): DuplexStreamingCall<WriteRequest, WriteResponse>;
 }
@@ -43,2 +56,12 @@ /**
     writeRaw(input: WriteRawRequest, options?: RpcOptions): UnaryCall<WriteRawRequest, WriteRawResponse>;
+    /**
+     * Write accepts profiling data encoded as an arrow record. It's a
+     * bi-directional streaming RPC, because the first message can contain only
+     * samples without the stacktraces, and only reference stacktrace IDs. The
+     * backend can then request the full stacktrace from the client should it not
+     * know the stacktrace yet.
+     *
+     * @generated from protobuf rpc: Write(stream parca.profilestore.v1alpha1.WriteRequest) returns (stream parca.profilestore.v1alpha1.WriteResponse);
+     */
+    write(options?: RpcOptions): DuplexStreamingCall<WriteRequest, WriteResponse>;
 }
@@ -45,0 +68,0 @@ /**

dist/parca/profilestore/v1alpha1/profilestore.client.js

@@ -28,2 +28,15 @@ // @generated by protobuf-ts 2.9.4 with parameter generate_dependencies
     }
+    /**
+     * Write accepts profiling data encoded as an arrow record. It's a
+     * bi-directional streaming RPC, because the first message can contain only
+     * samples without the stacktraces, and only reference stacktrace IDs. The
+     * backend can then request the full stacktrace from the client should it not
+     * know the stacktrace yet.
+     *
+     * @generated from protobuf rpc: Write(stream parca.profilestore.v1alpha1.WriteRequest) returns (stream parca.profilestore.v1alpha1.WriteResponse);
+     */
+    write(options) {
+        const method = this.methods[1], opt = this._transport.mergeOptions(options);
+        return stackIntercept("duplex", this._transport, method, opt);
+    }
 }
@@ -30,0 +43,0 @@ /**

dist/parca/profilestore/v1alpha1/profilestore.d.ts

@@ -11,2 +11,34 @@ import { ServiceType } from "@protobuf-ts/runtime-rpc";
 /**
+ * WriteRequest may contain an apache arrow record that only contains profiling
+ * samples with a reference to a stacktrace ID, or a full stacktrace. If it
+ * only contains samples, the server may request the full stacktrace from the
+ * client should it not already know them.
+ *
+ * @generated from protobuf message parca.profilestore.v1alpha1.WriteRequest
+ */
+export interface WriteRequest {
+    /**
+     * The bytes containing the arrow record.
+     *
+     * @generated from protobuf field: bytes record = 1;
+     */
+    record: Uint8Array;
+}
+/**
+ * WriteResponse may be empty if the server doesn't need any further
+ * information, or contain an arrow record that contains the stacktrace IDs
+ * that are unknown and therefore requested by the client from the server.
+ *
+ * @generated from protobuf message parca.profilestore.v1alpha1.WriteResponse
+ */
+export interface WriteResponse {
+    /**
+     * When record is non-empty it contains the bytes of an arrow record that
+     * contains a column containing the stacktraces that are unknown.
+     *
+     * @generated from protobuf field: bytes record = 1;
+     */
+    record: Uint8Array;
+}
+/**
  * WriteRawRequest writes a pprof profile for a given tenant
@@ -207,2 +239,22 @@ *
 }
+declare class WriteRequest$Type extends MessageType<WriteRequest> {
+    constructor();
+    create(value?: PartialMessage<WriteRequest>): WriteRequest;
+    internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: WriteRequest): WriteRequest;
+    internalBinaryWrite(message: WriteRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter;
+}
+/**
+ * @generated MessageType for protobuf message parca.profilestore.v1alpha1.WriteRequest
+ */
+export declare const WriteRequest: WriteRequest$Type;
+declare class WriteResponse$Type extends MessageType<WriteResponse> {
+    constructor();
+    create(value?: PartialMessage<WriteResponse>): WriteResponse;
+    internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: WriteResponse): WriteResponse;
+    internalBinaryWrite(message: WriteResponse, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter;
+}
+/**
+ * @generated MessageType for protobuf message parca.profilestore.v1alpha1.WriteResponse
+ */
+export declare const WriteResponse: WriteResponse$Type;
 declare class WriteRawRequest$Type extends MessageType<WriteRawRequest> {
@@ -209,0 +261,0 @@ constructor();

dist/parca/profilestore/v1alpha1/profilestore.js

@@ -12,2 +12,96 @@ // @generated by protobuf-ts 2.9.4 with parameter generate_dependencies
 // @generated message type with reflection information, may provide speed optimized methods
+class WriteRequest$Type extends MessageType {
+    constructor() {
+        super("parca.profilestore.v1alpha1.WriteRequest", [
+            { no: 1, name: "record", kind: "scalar", T: 12 /*ScalarType.BYTES*/ }
+        ]);
+    }
+    create(value) {
+        const message = globalThis.Object.create((this.messagePrototype));
+        message.record = new Uint8Array(0);
+        if (value !== undefined)
+            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 /* bytes record */ 1:
+                    message.record = reader.bytes();
+                    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 ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d);
+            }
+        }
+        return message;
+    }
+    internalBinaryWrite(message, writer, options) {
+        /* bytes record = 1; */
+        if (message.record.length)
+            writer.tag(1, WireType.LengthDelimited).bytes(message.record);
+        let u = options.writeUnknownFields;
+        if (u !== false)
+            (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
+        return writer;
+    }
+}
+/**
+ * @generated MessageType for protobuf message parca.profilestore.v1alpha1.WriteRequest
+ */
+export const WriteRequest = new WriteRequest$Type();
+// @generated message type with reflection information, may provide speed optimized methods
+class WriteResponse$Type extends MessageType {
+    constructor() {
+        super("parca.profilestore.v1alpha1.WriteResponse", [
+            { no: 1, name: "record", kind: "scalar", T: 12 /*ScalarType.BYTES*/ }
+        ]);
+    }
+    create(value) {
+        const message = globalThis.Object.create((this.messagePrototype));
+        message.record = new Uint8Array(0);
+        if (value !== undefined)
+            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 /* bytes record */ 1:
+                    message.record = reader.bytes();
+                    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 ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d);
+            }
+        }
+        return message;
+    }
+    internalBinaryWrite(message, writer, options) {
+        /* bytes record = 1; */
+        if (message.record.length)
+            writer.tag(1, WireType.LengthDelimited).bytes(message.record);
+        let u = options.writeUnknownFields;
+        if (u !== false)
+            (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
+        return writer;
+    }
+}
+/**
+ * @generated MessageType for protobuf message parca.profilestore.v1alpha1.WriteResponse
+ */
+export const WriteResponse = new WriteResponse$Type();
+// @generated message type with reflection information, may provide speed optimized methods
 class WriteRawRequest$Type extends MessageType {
@@ -565,3 +659,4 @@ constructor() {
 export const ProfileStoreService = new ServiceType("parca.profilestore.v1alpha1.ProfileStoreService", [
-    { name: "WriteRaw", options: { "google.api.http": { post: "/profiles/writeraw", body: "*" } }, I: WriteRawRequest, O: WriteRawResponse }
+    { name: "WriteRaw", options: { "google.api.http": { post: "/profiles/writeraw", body: "*" } }, I: WriteRawRequest, O: WriteRawResponse },
+    { name: "Write", serverStreaming: true, clientStreaming: true, options: { "google.api.http": { post: "/profiles/write", body: "*" } }, I: WriteRequest, O: WriteResponse }
 ]);
@@ -568,0 +663,0 @@ /**

package.json

 {
   "name": "@parca/client",
-  "version": "0.16.118",
+  "version": "0.16.119",
   "description": "Parca API Client",
@@ -28,3 +28,3 @@ "main": "dist/index.js",
   },
-  "gitHead": "6c04fc4c249509a65e48a0a9273c28c1c1c41b62"
+  "gitHead": "9d13687d6648e70412369d67999b77633d384199"
 }

src/parca/profilestore/v1alpha1/profilestore.client.ts

@@ -10,2 +10,5 @@ // @generated by protobuf-ts 2.9.4 with parameter generate_dependencies
 import { ProfileStoreService } from "./profilestore";
+import type { WriteResponse } from "./profilestore";
+import type { WriteRequest } from "./profilestore";
+import type { DuplexStreamingCall } from "@protobuf-ts/runtime-rpc";
 import { stackIntercept } from "@protobuf-ts/runtime-rpc";
@@ -28,2 +31,12 @@ import type { WriteRawResponse } from "./profilestore";
     writeRaw(input: WriteRawRequest, options?: RpcOptions): UnaryCall<WriteRawRequest, WriteRawResponse>;
+    /**
+     * Write accepts profiling data encoded as an arrow record. It's a
+     * bi-directional streaming RPC, because the first message can contain only
+     * samples without the stacktraces, and only reference stacktrace IDs. The
+     * backend can then request the full stacktrace from the client should it not
+     * know the stacktrace yet.
+     *
+     * @generated from protobuf rpc: Write(stream parca.profilestore.v1alpha1.WriteRequest) returns (stream parca.profilestore.v1alpha1.WriteResponse);
+     */
+    write(options?: RpcOptions): DuplexStreamingCall<WriteRequest, WriteResponse>;
 }
@@ -50,2 +63,15 @@ /**
     }
+    /**
+     * Write accepts profiling data encoded as an arrow record. It's a
+     * bi-directional streaming RPC, because the first message can contain only
+     * samples without the stacktraces, and only reference stacktrace IDs. The
+     * backend can then request the full stacktrace from the client should it not
+     * know the stacktrace yet.
+     *
+     * @generated from protobuf rpc: Write(stream parca.profilestore.v1alpha1.WriteRequest) returns (stream parca.profilestore.v1alpha1.WriteResponse);
+     */
+    write(options?: RpcOptions): DuplexStreamingCall<WriteRequest, WriteResponse> {
+        const method = this.methods[1], opt = this._transport.mergeOptions(options);
+        return stackIntercept<WriteRequest, WriteResponse>("duplex", this._transport, method, opt);
+    }
 }
@@ -52,0 +78,0 @@ /**

src/parca/profilestore/v1alpha1/profilestore.ts

@@ -17,2 +17,34 @@ // @generated by protobuf-ts 2.9.4 with parameter generate_dependencies
 /**
+ * WriteRequest may contain an apache arrow record that only contains profiling
+ * samples with a reference to a stacktrace ID, or a full stacktrace. If it
+ * only contains samples, the server may request the full stacktrace from the
+ * client should it not already know them.
+ *
+ * @generated from protobuf message parca.profilestore.v1alpha1.WriteRequest
+ */
+export interface WriteRequest {
+    /**
+     * The bytes containing the arrow record.
+     *
+     * @generated from protobuf field: bytes record = 1;
+     */
+    record: Uint8Array;
+}
+/**
+ * WriteResponse may be empty if the server doesn't need any further
+ * information, or contain an arrow record that contains the stacktrace IDs
+ * that are unknown and therefore requested by the client from the server.
+ *
+ * @generated from protobuf message parca.profilestore.v1alpha1.WriteResponse
+ */
+export interface WriteResponse {
+    /**
+     * When record is non-empty it contains the bytes of an arrow record that
+     * contains a column containing the stacktraces that are unknown.
+     *
+     * @generated from protobuf field: bytes record = 1;
+     */
+    record: Uint8Array;
+}
+/**
  * WriteRawRequest writes a pprof profile for a given tenant
@@ -214,2 +246,96 @@ *
 // @generated message type with reflection information, may provide speed optimized methods
+class WriteRequest$Type extends MessageType<WriteRequest> {
+    constructor() {
+        super("parca.profilestore.v1alpha1.WriteRequest", [
+            { no: 1, name: "record", kind: "scalar", T: 12 /*ScalarType.BYTES*/ }
+        ]);
+    }
+    create(value?: PartialMessage<WriteRequest>): WriteRequest {
+        const message = globalThis.Object.create((this.messagePrototype!));
+        message.record = new Uint8Array(0);
+        if (value !== undefined)
+            reflectionMergePartial<WriteRequest>(this, message, value);
+        return message;
+    }
+    internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: WriteRequest): WriteRequest {
+        let message = target ?? this.create(), end = reader.pos + length;
+        while (reader.pos < end) {
+            let [fieldNo, wireType] = reader.tag();
+            switch (fieldNo) {
+                case /* bytes record */ 1:
+                    message.record = reader.bytes();
+                    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 ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d);
+            }
+        }
+        return message;
+    }
+    internalBinaryWrite(message: WriteRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
+        /* bytes record = 1; */
+        if (message.record.length)
+            writer.tag(1, WireType.LengthDelimited).bytes(message.record);
+        let u = options.writeUnknownFields;
+        if (u !== false)
+            (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
+        return writer;
+    }
+}
+/**
+ * @generated MessageType for protobuf message parca.profilestore.v1alpha1.WriteRequest
+ */
+export const WriteRequest = new WriteRequest$Type();
+// @generated message type with reflection information, may provide speed optimized methods
+class WriteResponse$Type extends MessageType<WriteResponse> {
+    constructor() {
+        super("parca.profilestore.v1alpha1.WriteResponse", [
+            { no: 1, name: "record", kind: "scalar", T: 12 /*ScalarType.BYTES*/ }
+        ]);
+    }
+    create(value?: PartialMessage<WriteResponse>): WriteResponse {
+        const message = globalThis.Object.create((this.messagePrototype!));
+        message.record = new Uint8Array(0);
+        if (value !== undefined)
+            reflectionMergePartial<WriteResponse>(this, message, value);
+        return message;
+    }
+    internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: WriteResponse): WriteResponse {
+        let message = target ?? this.create(), end = reader.pos + length;
+        while (reader.pos < end) {
+            let [fieldNo, wireType] = reader.tag();
+            switch (fieldNo) {
+                case /* bytes record */ 1:
+                    message.record = reader.bytes();
+                    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 ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d);
+            }
+        }
+        return message;
+    }
+    internalBinaryWrite(message: WriteResponse, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
+        /* bytes record = 1; */
+        if (message.record.length)
+            writer.tag(1, WireType.LengthDelimited).bytes(message.record);
+        let u = options.writeUnknownFields;
+        if (u !== false)
+            (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
+        return writer;
+    }
+}
+/**
+ * @generated MessageType for protobuf message parca.profilestore.v1alpha1.WriteResponse
+ */
+export const WriteResponse = new WriteResponse$Type();
+// @generated message type with reflection information, may provide speed optimized methods
 class WriteRawRequest$Type extends MessageType<WriteRawRequest> {
@@ -767,3 +893,4 @@ constructor() {
 export const ProfileStoreService = new ServiceType("parca.profilestore.v1alpha1.ProfileStoreService", [
-    { name: "WriteRaw", options: { "google.api.http": { post: "/profiles/writeraw", body: "*" } }, I: WriteRawRequest, O: WriteRawResponse }
+    { name: "WriteRaw", options: { "google.api.http": { post: "/profiles/writeraw", body: "*" } }, I: WriteRawRequest, O: WriteRawResponse },
+    { name: "Write", serverStreaming: true, clientStreaming: true, options: { "google.api.http": { post: "/profiles/write", body: "*" } }, I: WriteRequest, O: WriteResponse }
 ]);
@@ -770,0 +897,0 @@ /**

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

2032117

increased by0.79%

Lines of code

43556

increased by0.78%

No dependency changes