@parca/client
Advanced tools
@parca/client - npm Package Compare versions
Comparing version 0.16.22 to 0.16.42
182
CHANGELOG.md
@@ -6,22 +6,30 @@ # Change Log | ||
| ## [0.16.22](https://github.com/parca-dev/parca/compare/ui-v0.16.20...ui-v0.16.22) (2022-09-27) | ||
| ## [0.16.42](https://github.com/parca-dev/parca/compare/ui-v0.16.41...ui-v0.16.42) (2022-10-13) | ||
| **Note:** Version bump only for package @parca/client | ||
| ## [0.16.39](https://github.com/parca-dev/parca/compare/ui-v0.16.38...ui-v0.16.39) (2022-10-10) | ||
| **Note:** Version bump only for package @parca/client | ||
| ## [0.16.38](https://github.com/parca-dev/parca/compare/ui-v0.16.37...ui-v0.16.38) (2022-10-10) | ||
| ## 0.16.27 (2022-09-29) | ||
| ## [0.16.21](https://github.com/parca-dev/parca/compare/ui-v0.16.20...ui-v0.16.21) (2022-09-27) | ||
| **Note:** Version bump only for package @parca/client | ||
| ## [0.16.23](https://github.com/parca-dev/parca/compare/ui-v0.16.20...ui-v0.16.23) (2022-09-27) | ||
| **Note:** Version bump only for package @parca/client | ||
| ## [0.16.22](https://github.com/parca-dev/parca/compare/ui-v0.16.20...ui-v0.16.22) (2022-09-27) | ||
| **Note:** Version bump only for package @parca/client | ||
| ## [0.16.21](https://github.com/parca-dev/parca/compare/ui-v0.16.20...ui-v0.16.21) (2022-09-27) | ||
| **Note:** Version bump only for package @parca/client | ||
| ## [0.16.20](https://github.com/parca-dev/parca/compare/ui-v0.16.19...ui-v0.16.20) (2022-09-27) | ||
| ## [0.16.15](https://github.com/parca-dev/parca/compare/ui-v0.16.6...ui-v0.16.15) (2022-09-22) | ||
@@ -31,6 +39,2 @@ | ||
| ## [0.16.19](https://github.com/parca-dev/parca/compare/ui-v0.16.18...ui-v0.16.19) (2022-09-26) | ||
@@ -40,6 +44,2 @@ | ||
| ## [0.16.16](https://github.com/parca-dev/parca/compare/ui-v0.16.15...ui-v0.16.16) (2022-09-26) | ||
@@ -49,6 +49,2 @@ | ||
| # [0.16.0](https://github.com/parca-dev/parca/compare/ui-v0.15.26...ui-v0.16.0) (2022-09-13) | ||
@@ -58,14 +54,6 @@ | ||
| ## [0.15.11](https://github.com/parca-dev/parca/compare/ui-v0.15.10...ui-v0.15.11) (2022-09-01) | ||
| ## [0.15.8](https://github.com/parca-dev/parca/compare/ui-v0.15.1...ui-v0.15.8) (2022-08-30) | ||
| ## 0.15.1 (2022-08-25) | ||
@@ -75,10 +63,4 @@ | ||
| ## [0.15.9](https://github.com/parca-dev/parca/compare/ui-v0.15.8...ui-v0.15.9) (2022-08-30) | ||
| ## 0.15.1 (2022-08-25) | ||
@@ -88,6 +70,2 @@ | ||
| ## [0.15.2](https://github.com/parca-dev/parca/compare/ui-v0.15.1...ui-v0.15.2) (2022-08-25) | ||
@@ -97,6 +75,2 @@ | ||
| # [0.15.0](https://github.com/parca-dev/parca/compare/ui-v0.14.37...ui-v0.15.0) (2022-08-24) | ||
@@ -106,14 +80,6 @@ | ||
| ## [0.14.37](https://github.com/parca-dev/parca/compare/ui-v0.14.36...ui-v0.14.37) (2022-08-24) | ||
| ## [0.14.16](https://github.com/parca-dev/parca/compare/ui-v0.14.11...ui-v0.14.16) (2022-08-03) | ||
| ## [0.14.7](https://github.com/parca-dev/parca/compare/ui-v0.14.5...ui-v0.14.7) (2022-07-27) | ||
@@ -123,10 +89,4 @@ | ||
| ## [0.14.16](https://github.com/parca-dev/parca/compare/ui-v0.14.15...ui-v0.14.16) (2022-08-03) | ||
| ## [0.14.12](https://github.com/parca-dev/parca/compare/ui-v0.14.11...ui-v0.14.12) (2022-08-02) | ||
@@ -136,6 +96,2 @@ | ||
| ## [0.14.12](https://github.com/parca-dev/parca/compare/ui-v0.14.11...ui-v0.14.12) (2022-08-02) | ||
@@ -145,6 +101,2 @@ | ||
| ## [0.14.1](https://github.com/parca-dev/parca/compare/ui-v0.13.14...ui-v0.14.1) (2022-07-25) | ||
@@ -154,6 +106,2 @@ | ||
| # [0.14.0](https://github.com/parca-dev/parca/compare/ui-v0.13.14...ui-v0.14.0) (2022-07-25) | ||
@@ -163,6 +111,2 @@ | ||
| ## [0.13.15](https://github.com/parca-dev/parca/compare/ui-v0.13.14...ui-v0.13.15) (2022-07-12) | ||
@@ -172,6 +116,2 @@ | ||
| ## [0.13.13](https://github.com/parca-dev/parca/compare/ui-v0.13.12...ui-v0.13.13) (2022-06-29) | ||
@@ -181,10 +121,4 @@ | ||
| ## [0.13.10](https://github.com/parca-dev/parca/compare/ui-v0.13.9...ui-v0.13.10) (2022-06-22) | ||
| ## [0.13.8](https://github.com/parca-dev/parca/compare/ui-v0.13.7...ui-v0.13.8) (2022-06-21) | ||
@@ -194,10 +128,4 @@ | ||
| ## [0.13.6](https://github.com/parca-dev/parca/compare/ui-v0.13.5...ui-v0.13.6) (2022-06-14) | ||
| ## [0.13.4](https://github.com/parca-dev/parca/compare/ui-v0.13.3...ui-v0.13.4) (2022-06-07) | ||
@@ -207,6 +135,2 @@ | ||
| # [0.13.0](https://github.com/parca-dev/parca/compare/ui-v0.12.38...ui-v0.13.0) (2022-05-30) | ||
@@ -216,6 +140,2 @@ | ||
| ## 0.12.35 (2022-05-05) | ||
@@ -225,6 +145,2 @@ | ||
| ## [0.12.30](https://github.com/parca-dev/parca/compare/ui-v0.12.29...ui-v0.12.30) (2022-04-29) | ||
@@ -234,6 +150,2 @@ | ||
| ## [0.12.27](https://github.com/parca-dev/parca/compare/ui-v0.12.26...ui-v0.12.27) (2022-04-29) | ||
@@ -243,10 +155,4 @@ | ||
| ## [0.12.26](https://github.com/parca-dev/parca/compare/ui-v0.12.25...ui-v0.12.26) (2022-04-28) | ||
| ## [0.12.24](https://github.com/parca-dev/parca/compare/ui-v0.12.23...ui-v0.12.24) (2022-04-26) | ||
@@ -256,6 +162,2 @@ | ||
| ## [0.12.20](https://github.com/parca-dev/parca/compare/ui-v0.12.19...ui-v0.12.20) (2022-04-12) | ||
@@ -265,6 +167,2 @@ | ||
| ## [0.12.12](https://github.com/parca-dev/parca/compare/ui-v0.12.11...ui-v0.12.12) (2022-04-05) | ||
@@ -274,10 +172,4 @@ | ||
| ## [0.12.6](https://github.com/parca-dev/parca/compare/ui-v0.12.5...ui-v0.12.6) (2022-03-24) | ||
| ## [0.12.4](https://github.com/parca-dev/parca/compare/ui-v0.12.3...ui-v0.12.4) (2022-03-23) | ||
@@ -287,6 +179,2 @@ | ||
| ## [0.12.5](https://github.com/parca-dev/parca/compare/ui-v0.12.4...ui-v0.12.5) (2022-03-24) | ||
@@ -296,6 +184,2 @@ | ||
| ## [0.12.2](https://github.com/parca-dev/parca/compare/ui-v0.12.1...ui-v0.12.2) (2022-03-14) | ||
@@ -305,6 +189,2 @@ | ||
| # [0.12.0](https://github.com/parca-dev/parca/compare/ui-v0.11.2...ui-v0.12.0) (2022-03-09) | ||
@@ -314,6 +194,2 @@ | ||
| # [0.11.0](https://github.com/parca-dev/parca/compare/ui-v0.10.4...ui-v0.11.0) (2022-03-02) | ||
@@ -323,6 +199,2 @@ | ||
| # [0.10.0](https://github.com/parca-dev/parca/compare/ui-v0.9.3...ui-v0.10.0) (2022-02-28) | ||
@@ -332,6 +204,2 @@ | ||
| ## [0.9.3](https://github.com/parca-dev/parca/compare/ui-v0.8.0...ui-v0.9.3) (2022-02-23) | ||
@@ -341,10 +209,4 @@ | ||
| ## [0.9.1](https://github.com/parca-dev/parca/compare/ui-v0.9.0...ui-v0.9.1) (2022-02-21) | ||
| ## [0.8.2](https://github.com/parca-dev/parca/compare/ui-v0.8.1...ui-v0.8.2) (2022-02-14) | ||
@@ -354,6 +216,2 @@ | ||
| # [0.9.0](https://github.com/parca-dev/parca/compare/ui-v0.8.3...ui-v0.9.0) (2022-02-16) | ||
@@ -363,6 +221,2 @@ | ||
| # [0.8.0](https://github.com/parca-dev/parca/compare/ui-v0.7.13...ui-v0.8.0) (2022-01-31) | ||
@@ -372,6 +226,2 @@ | ||
| ## 0.7.11 (2022-01-20) | ||
@@ -381,6 +231,2 @@ | ||
| ## [0.7.10](https://github.com/yomete/parca/compare/ui-v0.7.9...ui-v0.7.10) (2022-01-19) | ||
@@ -390,6 +236,2 @@ | ||
| ## [0.7.8](https://github.com/yomete/parca/compare/ui-v0.7.7...ui-v0.7.8) (2022-01-19) | ||
@@ -396,0 +238,0 @@ |
@@ -0,1 +1,3 @@ | ||
| import type { AgentsResponse } from "./profilestore"; | ||
| import type { AgentsRequest } from "./profilestore"; | ||
| import type { RpcTransport } from "@protobuf-ts/runtime-rpc"; | ||
@@ -40,1 +42,34 @@ import type { ServiceInfo } from "@protobuf-ts/runtime-rpc"; | ||
| } | ||
| /** | ||
| * AgentsService maintains the agents | ||
| * | ||
| * @generated from protobuf service parca.profilestore.v1alpha1.AgentsService | ||
| */ | ||
| export interface IAgentsServiceClient { | ||
| /** | ||
| * Agents return the agents that pushed data to the server | ||
| * | ||
| * @generated from protobuf rpc: Agents(parca.profilestore.v1alpha1.AgentsRequest) returns (parca.profilestore.v1alpha1.AgentsResponse); | ||
| */ | ||
| agents(input: AgentsRequest, options?: RpcOptions): UnaryCall<AgentsRequest, AgentsResponse>; | ||
| } | ||
| /** | ||
| * AgentsService maintains the agents | ||
| * | ||
| * @generated from protobuf service parca.profilestore.v1alpha1.AgentsService | ||
| */ | ||
| export declare class AgentsServiceClient implements IAgentsServiceClient, ServiceInfo { | ||
| private readonly _transport; | ||
| typeName: string; | ||
| methods: import("@protobuf-ts/runtime-rpc").MethodInfo<any, any>[]; | ||
| options: { | ||
| [extensionName: string]: import("@protobuf-ts/runtime").JsonValue; | ||
| }; | ||
| constructor(_transport: RpcTransport); | ||
| /** | ||
| * Agents return the agents that pushed data to the server | ||
| * | ||
| * @generated from protobuf rpc: Agents(parca.profilestore.v1alpha1.AgentsRequest) returns (parca.profilestore.v1alpha1.AgentsResponse); | ||
| */ | ||
| agents(input: AgentsRequest, options?: RpcOptions): UnaryCall<AgentsRequest, AgentsResponse>; | ||
| } |
@@ -0,1 +1,5 @@ | ||
| // @generated by protobuf-ts 2.8.1 with parameter long_type_string,generate_dependencies | ||
| // @generated from protobuf file "parca/profilestore/v1alpha1/profilestore.proto" (package "parca.profilestore.v1alpha1", syntax proto3) | ||
| // tslint:disable | ||
| import { AgentsService } from "./profilestore"; | ||
| import { ProfileStoreService } from "./profilestore"; | ||
@@ -27,1 +31,25 @@ import { stackIntercept } from "@protobuf-ts/runtime-rpc"; | ||
| export { ProfileStoreServiceClient }; | ||
| /** | ||
| * AgentsService maintains the agents | ||
| * | ||
| * @generated from protobuf service parca.profilestore.v1alpha1.AgentsService | ||
| */ | ||
| var AgentsServiceClient = /** @class */ (function () { | ||
| function AgentsServiceClient(_transport) { | ||
| this._transport = _transport; | ||
| this.typeName = AgentsService.typeName; | ||
| this.methods = AgentsService.methods; | ||
| this.options = AgentsService.options; | ||
| } | ||
| /** | ||
| * Agents return the agents that pushed data to the server | ||
| * | ||
| * @generated from protobuf rpc: Agents(parca.profilestore.v1alpha1.AgentsRequest) returns (parca.profilestore.v1alpha1.AgentsResponse); | ||
| */ | ||
| AgentsServiceClient.prototype.agents = function (input, options) { | ||
| var method = this.methods[0], opt = this._transport.mergeOptions(options); | ||
| return stackIntercept("unary", this._transport, method, opt, input); | ||
| }; | ||
| return AgentsServiceClient; | ||
| }()); | ||
| export { AgentsServiceClient }; |
@@ -8,2 +8,4 @@ import { ServiceType } from "@protobuf-ts/runtime-rpc"; | ||
| import { MessageType } from "@protobuf-ts/runtime"; | ||
| import { Duration } from "../../../google/protobuf/duration"; | ||
| import { Timestamp } from "../../../google/protobuf/timestamp"; | ||
| /** | ||
@@ -106,2 +108,54 @@ * WriteRawRequest writes a pprof profile for a given tenant | ||
| } | ||
| /** | ||
| * AgentsRequest is the request to retrieve a list of agents | ||
| * | ||
| * @generated from protobuf message parca.profilestore.v1alpha1.AgentsRequest | ||
| */ | ||
| export interface AgentsRequest { | ||
| } | ||
| /** | ||
| * AgentsResponse is the request to retrieve a list of agents | ||
| * | ||
| * @generated from protobuf message parca.profilestore.v1alpha1.AgentsResponse | ||
| */ | ||
| export interface AgentsResponse { | ||
| /** | ||
| * agents is a list of agents | ||
| * | ||
| * @generated from protobuf field: repeated parca.profilestore.v1alpha1.Agent agents = 1; | ||
| */ | ||
| agents: Agent[]; | ||
| } | ||
| /** | ||
| * Agent is the agent representation | ||
| * | ||
| * @generated from protobuf message parca.profilestore.v1alpha1.Agent | ||
| */ | ||
| export interface Agent { | ||
| /** | ||
| * id is the agent identity that either represent by the node name or the IP address. | ||
| * When node name is not found, this will fallback to IP address. | ||
| * | ||
| * @generated from protobuf field: string id = 1; | ||
| */ | ||
| id: string; | ||
| /** | ||
| * last_error is the error message most recently received from a push attempt | ||
| * | ||
| * @generated from protobuf field: string last_error = 2; | ||
| */ | ||
| lastError: string; | ||
| /** | ||
| * last_push is the time stamp the last push request was performed | ||
| * | ||
| * @generated from protobuf field: google.protobuf.Timestamp last_push = 3; | ||
| */ | ||
| lastPush?: Timestamp; | ||
| /** | ||
| * last_push_duration is the duration of the last push request | ||
| * | ||
| * @generated from protobuf field: google.protobuf.Duration last_push_duration = 4; | ||
| */ | ||
| lastPushDuration?: Duration; | ||
| } | ||
| declare class WriteRawRequest$Type extends MessageType<WriteRawRequest> { | ||
@@ -167,6 +221,40 @@ constructor(); | ||
| export declare const RawSample: RawSample$Type; | ||
| declare class AgentsRequest$Type extends MessageType<AgentsRequest> { | ||
| constructor(); | ||
| create(value?: PartialMessage<AgentsRequest>): AgentsRequest; | ||
| internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: AgentsRequest): AgentsRequest; | ||
| internalBinaryWrite(message: AgentsRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; | ||
| } | ||
| /** | ||
| * @generated MessageType for protobuf message parca.profilestore.v1alpha1.AgentsRequest | ||
| */ | ||
| export declare const AgentsRequest: AgentsRequest$Type; | ||
| declare class AgentsResponse$Type extends MessageType<AgentsResponse> { | ||
| constructor(); | ||
| create(value?: PartialMessage<AgentsResponse>): AgentsResponse; | ||
| internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: AgentsResponse): AgentsResponse; | ||
| internalBinaryWrite(message: AgentsResponse, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; | ||
| } | ||
| /** | ||
| * @generated MessageType for protobuf message parca.profilestore.v1alpha1.AgentsResponse | ||
| */ | ||
| export declare const AgentsResponse: AgentsResponse$Type; | ||
| declare class Agent$Type extends MessageType<Agent> { | ||
| constructor(); | ||
| create(value?: PartialMessage<Agent>): Agent; | ||
| internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: Agent): Agent; | ||
| internalBinaryWrite(message: Agent, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter; | ||
| } | ||
| /** | ||
| * @generated MessageType for protobuf message parca.profilestore.v1alpha1.Agent | ||
| */ | ||
| export declare const Agent: Agent$Type; | ||
| /** | ||
| * @generated ServiceType for protobuf service parca.profilestore.v1alpha1.ProfileStoreService | ||
| */ | ||
| export declare const ProfileStoreService: ServiceType; | ||
| /** | ||
| * @generated ServiceType for protobuf service parca.profilestore.v1alpha1.AgentsService | ||
| */ | ||
| export declare const AgentsService: ServiceType; | ||
| export {}; |
@@ -25,2 +25,4 @@ var __extends = (this && this.__extends) || (function () { | ||
| import { MessageType } from "@protobuf-ts/runtime"; | ||
| import { Duration } from "../../../google/protobuf/duration"; | ||
| import { Timestamp } from "../../../google/protobuf/timestamp"; | ||
| // @generated message type with reflection information, may provide speed optimized methods | ||
@@ -327,3 +329,150 @@ var WriteRawRequest$Type = /** @class */ (function (_super) { | ||
| export var RawSample = new RawSample$Type(); | ||
| // @generated message type with reflection information, may provide speed optimized methods | ||
| var AgentsRequest$Type = /** @class */ (function (_super) { | ||
| __extends(AgentsRequest$Type, _super); | ||
| function AgentsRequest$Type() { | ||
| return _super.call(this, "parca.profilestore.v1alpha1.AgentsRequest", []) || this; | ||
| } | ||
| AgentsRequest$Type.prototype.create = function (value) { | ||
| var message = {}; | ||
| globalThis.Object.defineProperty(message, MESSAGE_TYPE, { enumerable: false, value: this }); | ||
| if (value !== undefined) | ||
| reflectionMergePartial(this, message, value); | ||
| return message; | ||
| }; | ||
| AgentsRequest$Type.prototype.internalBinaryRead = function (reader, length, options, target) { | ||
| return target !== null && target !== void 0 ? target : this.create(); | ||
| }; | ||
| AgentsRequest$Type.prototype.internalBinaryWrite = function (message, writer, options) { | ||
| var u = options.writeUnknownFields; | ||
| if (u !== false) | ||
| (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); | ||
| return writer; | ||
| }; | ||
| return AgentsRequest$Type; | ||
| }(MessageType)); | ||
| /** | ||
| * @generated MessageType for protobuf message parca.profilestore.v1alpha1.AgentsRequest | ||
| */ | ||
| export var AgentsRequest = new AgentsRequest$Type(); | ||
| // @generated message type with reflection information, may provide speed optimized methods | ||
| var AgentsResponse$Type = /** @class */ (function (_super) { | ||
| __extends(AgentsResponse$Type, _super); | ||
| function AgentsResponse$Type() { | ||
| return _super.call(this, "parca.profilestore.v1alpha1.AgentsResponse", [ | ||
| { no: 1, name: "agents", kind: "message", repeat: 1 /*RepeatType.PACKED*/, T: function () { return Agent; } } | ||
| ]) || this; | ||
| } | ||
| AgentsResponse$Type.prototype.create = function (value) { | ||
| var message = { agents: [] }; | ||
| globalThis.Object.defineProperty(message, MESSAGE_TYPE, { enumerable: false, value: this }); | ||
| if (value !== undefined) | ||
| reflectionMergePartial(this, message, value); | ||
| return message; | ||
| }; | ||
| AgentsResponse$Type.prototype.internalBinaryRead = function (reader, length, options, target) { | ||
| var message = target !== null && target !== void 0 ? target : this.create(), end = reader.pos + length; | ||
| while (reader.pos < end) { | ||
| var _a = reader.tag(), fieldNo = _a[0], wireType = _a[1]; | ||
| switch (fieldNo) { | ||
| case /* repeated parca.profilestore.v1alpha1.Agent agents */ 1: | ||
| message.agents.push(Agent.internalBinaryRead(reader, reader.uint32(), options)); | ||
| break; | ||
| default: | ||
| var u = options.readUnknownField; | ||
| if (u === "throw") | ||
| throw new globalThis.Error("Unknown field ".concat(fieldNo, " (wire type ").concat(wireType, ") for ").concat(this.typeName)); | ||
| var d = reader.skip(wireType); | ||
| if (u !== false) | ||
| (u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d); | ||
| } | ||
| } | ||
| return message; | ||
| }; | ||
| AgentsResponse$Type.prototype.internalBinaryWrite = function (message, writer, options) { | ||
| /* repeated parca.profilestore.v1alpha1.Agent agents = 1; */ | ||
| for (var i = 0; i < message.agents.length; i++) | ||
| Agent.internalBinaryWrite(message.agents[i], writer.tag(1, WireType.LengthDelimited).fork(), options).join(); | ||
| var u = options.writeUnknownFields; | ||
| if (u !== false) | ||
| (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); | ||
| return writer; | ||
| }; | ||
| return AgentsResponse$Type; | ||
| }(MessageType)); | ||
| /** | ||
| * @generated MessageType for protobuf message parca.profilestore.v1alpha1.AgentsResponse | ||
| */ | ||
| export var AgentsResponse = new AgentsResponse$Type(); | ||
| // @generated message type with reflection information, may provide speed optimized methods | ||
| var Agent$Type = /** @class */ (function (_super) { | ||
| __extends(Agent$Type, _super); | ||
| function Agent$Type() { | ||
| return _super.call(this, "parca.profilestore.v1alpha1.Agent", [ | ||
| { no: 1, name: "id", kind: "scalar", T: 9 /*ScalarType.STRING*/ }, | ||
| { no: 2, name: "last_error", kind: "scalar", T: 9 /*ScalarType.STRING*/ }, | ||
| { no: 3, name: "last_push", kind: "message", T: function () { return Timestamp; } }, | ||
| { no: 4, name: "last_push_duration", kind: "message", T: function () { return Duration; } } | ||
| ]) || this; | ||
| } | ||
| Agent$Type.prototype.create = function (value) { | ||
| var message = { id: "", lastError: "" }; | ||
| globalThis.Object.defineProperty(message, MESSAGE_TYPE, { enumerable: false, value: this }); | ||
| if (value !== undefined) | ||
| reflectionMergePartial(this, message, value); | ||
| return message; | ||
| }; | ||
| Agent$Type.prototype.internalBinaryRead = function (reader, length, options, target) { | ||
| var message = target !== null && target !== void 0 ? target : this.create(), end = reader.pos + length; | ||
| while (reader.pos < end) { | ||
| var _a = reader.tag(), fieldNo = _a[0], wireType = _a[1]; | ||
| switch (fieldNo) { | ||
| case /* string id */ 1: | ||
| message.id = reader.string(); | ||
| break; | ||
| case /* string last_error */ 2: | ||
| message.lastError = reader.string(); | ||
| break; | ||
| case /* google.protobuf.Timestamp last_push */ 3: | ||
| message.lastPush = Timestamp.internalBinaryRead(reader, reader.uint32(), options, message.lastPush); | ||
| break; | ||
| case /* google.protobuf.Duration last_push_duration */ 4: | ||
| message.lastPushDuration = Duration.internalBinaryRead(reader, reader.uint32(), options, message.lastPushDuration); | ||
| break; | ||
| default: | ||
| var u = options.readUnknownField; | ||
| if (u === "throw") | ||
| throw new globalThis.Error("Unknown field ".concat(fieldNo, " (wire type ").concat(wireType, ") for ").concat(this.typeName)); | ||
| var d = reader.skip(wireType); | ||
| if (u !== false) | ||
| (u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d); | ||
| } | ||
| } | ||
| return message; | ||
| }; | ||
| Agent$Type.prototype.internalBinaryWrite = function (message, writer, options) { | ||
| /* string id = 1; */ | ||
| if (message.id !== "") | ||
| writer.tag(1, WireType.LengthDelimited).string(message.id); | ||
| /* string last_error = 2; */ | ||
| if (message.lastError !== "") | ||
| writer.tag(2, WireType.LengthDelimited).string(message.lastError); | ||
| /* google.protobuf.Timestamp last_push = 3; */ | ||
| if (message.lastPush) | ||
| Timestamp.internalBinaryWrite(message.lastPush, writer.tag(3, WireType.LengthDelimited).fork(), options).join(); | ||
| /* google.protobuf.Duration last_push_duration = 4; */ | ||
| if (message.lastPushDuration) | ||
| Duration.internalBinaryWrite(message.lastPushDuration, writer.tag(4, WireType.LengthDelimited).fork(), options).join(); | ||
| var u = options.writeUnknownFields; | ||
| if (u !== false) | ||
| (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); | ||
| return writer; | ||
| }; | ||
| return Agent$Type; | ||
| }(MessageType)); | ||
| /** | ||
| * @generated MessageType for protobuf message parca.profilestore.v1alpha1.Agent | ||
| */ | ||
| export var Agent = new Agent$Type(); | ||
| /** | ||
| * @generated ServiceType for protobuf service parca.profilestore.v1alpha1.ProfileStoreService | ||
@@ -334,1 +483,7 @@ */ | ||
| ]); | ||
| /** | ||
| * @generated ServiceType for protobuf service parca.profilestore.v1alpha1.AgentsService | ||
| */ | ||
| export var AgentsService = new ServiceType("parca.profilestore.v1alpha1.AgentsService", [ | ||
| { name: "Agents", options: { "google.api.http": { get: "/agents" } }, I: AgentsRequest, O: AgentsResponse } | ||
| ]); |
@@ -96,3 +96,3 @@ import { ServiceType } from "@protobuf-ts/runtime-rpc"; | ||
| /** | ||
| * lase_error is the error message most recently received from a scrape attempt | ||
| * last_error is the error message most recently received from a scrape attempt | ||
| * | ||
@@ -99,0 +99,0 @@ * @generated from protobuf field: string last_error = 3; |
| { | ||
| "name": "@parca/client", | ||
| "version": "0.16.22", | ||
| "version": "0.16.42", | ||
| "description": "Parca API Client", | ||
@@ -9,3 +9,4 @@ "main": "src/index.ts", | ||
| "prepublish": "yarn build", | ||
| "build": "tsc" | ||
| "build": "tsc", | ||
| "watch": "tsc-watch" | ||
| }, | ||
@@ -26,3 +27,3 @@ "dependencies": { | ||
| }, | ||
| "gitHead": "b7dc2d8947b27f8fd5e62e1473c1cb41272c7850" | ||
| "gitHead": "6abe2900480e4d043611fb7587b898c12f4f1518" | ||
| } |
| // @generated by protobuf-ts 2.8.1 with parameter long_type_string,generate_dependencies | ||
| // @generated from protobuf file "parca/profilestore/v1alpha1/profilestore.proto" (package "parca.profilestore.v1alpha1", syntax proto3) | ||
| // tslint:disable | ||
| import { AgentsService } from "./profilestore"; | ||
| import type { AgentsResponse } from "./profilestore"; | ||
| import type { AgentsRequest } from "./profilestore"; | ||
| import type { RpcTransport } from "@protobuf-ts/runtime-rpc"; | ||
@@ -46,1 +49,35 @@ import type { ServiceInfo } from "@protobuf-ts/runtime-rpc"; | ||
| } | ||
| /** | ||
| * AgentsService maintains the agents | ||
| * | ||
| * @generated from protobuf service parca.profilestore.v1alpha1.AgentsService | ||
| */ | ||
| export interface IAgentsServiceClient { | ||
| /** | ||
| * Agents return the agents that pushed data to the server | ||
| * | ||
| * @generated from protobuf rpc: Agents(parca.profilestore.v1alpha1.AgentsRequest) returns (parca.profilestore.v1alpha1.AgentsResponse); | ||
| */ | ||
| agents(input: AgentsRequest, options?: RpcOptions): UnaryCall<AgentsRequest, AgentsResponse>; | ||
| } | ||
| /** | ||
| * AgentsService maintains the agents | ||
| * | ||
| * @generated from protobuf service parca.profilestore.v1alpha1.AgentsService | ||
| */ | ||
| export class AgentsServiceClient implements IAgentsServiceClient, ServiceInfo { | ||
| typeName = AgentsService.typeName; | ||
| methods = AgentsService.methods; | ||
| options = AgentsService.options; | ||
| constructor(private readonly _transport: RpcTransport) { | ||
| } | ||
| /** | ||
| * Agents return the agents that pushed data to the server | ||
| * | ||
| * @generated from protobuf rpc: Agents(parca.profilestore.v1alpha1.AgentsRequest) returns (parca.profilestore.v1alpha1.AgentsResponse); | ||
| */ | ||
| agents(input: AgentsRequest, options?: RpcOptions): UnaryCall<AgentsRequest, AgentsResponse> { | ||
| const method = this.methods[0], opt = this._transport.mergeOptions(options); | ||
| return stackIntercept<AgentsRequest, AgentsResponse>("unary", this._transport, method, opt, input); | ||
| } | ||
| } |
@@ -15,2 +15,4 @@ // @generated by protobuf-ts 2.8.1 with parameter long_type_string,generate_dependencies | ||
| import { MessageType } from "@protobuf-ts/runtime"; | ||
| import { Duration } from "../../../google/protobuf/duration"; | ||
| import { Timestamp } from "../../../google/protobuf/timestamp"; | ||
| /** | ||
@@ -113,2 +115,54 @@ * WriteRawRequest writes a pprof profile for a given tenant | ||
| } | ||
| /** | ||
| * AgentsRequest is the request to retrieve a list of agents | ||
| * | ||
| * @generated from protobuf message parca.profilestore.v1alpha1.AgentsRequest | ||
| */ | ||
| export interface AgentsRequest { | ||
| } | ||
| /** | ||
| * AgentsResponse is the request to retrieve a list of agents | ||
| * | ||
| * @generated from protobuf message parca.profilestore.v1alpha1.AgentsResponse | ||
| */ | ||
| export interface AgentsResponse { | ||
| /** | ||
| * agents is a list of agents | ||
| * | ||
| * @generated from protobuf field: repeated parca.profilestore.v1alpha1.Agent agents = 1; | ||
| */ | ||
| agents: Agent[]; | ||
| } | ||
| /** | ||
| * Agent is the agent representation | ||
| * | ||
| * @generated from protobuf message parca.profilestore.v1alpha1.Agent | ||
| */ | ||
| export interface Agent { | ||
| /** | ||
| * id is the agent identity that either represent by the node name or the IP address. | ||
| * When node name is not found, this will fallback to IP address. | ||
| * | ||
| * @generated from protobuf field: string id = 1; | ||
| */ | ||
| id: string; | ||
| /** | ||
| * last_error is the error message most recently received from a push attempt | ||
| * | ||
| * @generated from protobuf field: string last_error = 2; | ||
| */ | ||
| lastError: string; | ||
| /** | ||
| * last_push is the time stamp the last push request was performed | ||
| * | ||
| * @generated from protobuf field: google.protobuf.Timestamp last_push = 3; | ||
| */ | ||
| lastPush?: Timestamp; | ||
| /** | ||
| * last_push_duration is the duration of the last push request | ||
| * | ||
| * @generated from protobuf field: google.protobuf.Duration last_push_duration = 4; | ||
| */ | ||
| lastPushDuration?: Duration; | ||
| } | ||
| // @generated message type with reflection information, may provide speed optimized methods | ||
@@ -403,3 +457,144 @@ class WriteRawRequest$Type extends MessageType<WriteRawRequest> { | ||
| export const RawSample = new RawSample$Type(); | ||
| // @generated message type with reflection information, may provide speed optimized methods | ||
| class AgentsRequest$Type extends MessageType<AgentsRequest> { | ||
| constructor() { | ||
| super("parca.profilestore.v1alpha1.AgentsRequest", []); | ||
| } | ||
| create(value?: PartialMessage<AgentsRequest>): AgentsRequest { | ||
| const message = {}; | ||
| globalThis.Object.defineProperty(message, MESSAGE_TYPE, { enumerable: false, value: this }); | ||
| if (value !== undefined) | ||
| reflectionMergePartial<AgentsRequest>(this, message, value); | ||
| return message; | ||
| } | ||
| internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: AgentsRequest): AgentsRequest { | ||
| return target ?? this.create(); | ||
| } | ||
| internalBinaryWrite(message: AgentsRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { | ||
| 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.AgentsRequest | ||
| */ | ||
| export const AgentsRequest = new AgentsRequest$Type(); | ||
| // @generated message type with reflection information, may provide speed optimized methods | ||
| class AgentsResponse$Type extends MessageType<AgentsResponse> { | ||
| constructor() { | ||
| super("parca.profilestore.v1alpha1.AgentsResponse", [ | ||
| { no: 1, name: "agents", kind: "message", repeat: 1 /*RepeatType.PACKED*/, T: () => Agent } | ||
| ]); | ||
| } | ||
| create(value?: PartialMessage<AgentsResponse>): AgentsResponse { | ||
| const message = { agents: [] }; | ||
| globalThis.Object.defineProperty(message, MESSAGE_TYPE, { enumerable: false, value: this }); | ||
| if (value !== undefined) | ||
| reflectionMergePartial<AgentsResponse>(this, message, value); | ||
| return message; | ||
| } | ||
| internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: AgentsResponse): AgentsResponse { | ||
| let message = target ?? this.create(), end = reader.pos + length; | ||
| while (reader.pos < end) { | ||
| let [fieldNo, wireType] = reader.tag(); | ||
| switch (fieldNo) { | ||
| case /* repeated parca.profilestore.v1alpha1.Agent agents */ 1: | ||
| message.agents.push(Agent.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 ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d); | ||
| } | ||
| } | ||
| return message; | ||
| } | ||
| internalBinaryWrite(message: AgentsResponse, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { | ||
| /* repeated parca.profilestore.v1alpha1.Agent agents = 1; */ | ||
| for (let i = 0; i < message.agents.length; i++) | ||
| Agent.internalBinaryWrite(message.agents[i], writer.tag(1, WireType.LengthDelimited).fork(), options).join(); | ||
| 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.AgentsResponse | ||
| */ | ||
| export const AgentsResponse = new AgentsResponse$Type(); | ||
| // @generated message type with reflection information, may provide speed optimized methods | ||
| class Agent$Type extends MessageType<Agent> { | ||
| constructor() { | ||
| super("parca.profilestore.v1alpha1.Agent", [ | ||
| { no: 1, name: "id", kind: "scalar", T: 9 /*ScalarType.STRING*/ }, | ||
| { no: 2, name: "last_error", kind: "scalar", T: 9 /*ScalarType.STRING*/ }, | ||
| { no: 3, name: "last_push", kind: "message", T: () => Timestamp }, | ||
| { no: 4, name: "last_push_duration", kind: "message", T: () => Duration } | ||
| ]); | ||
| } | ||
| create(value?: PartialMessage<Agent>): Agent { | ||
| const message = { id: "", lastError: "" }; | ||
| globalThis.Object.defineProperty(message, MESSAGE_TYPE, { enumerable: false, value: this }); | ||
| if (value !== undefined) | ||
| reflectionMergePartial<Agent>(this, message, value); | ||
| return message; | ||
| } | ||
| internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: Agent): Agent { | ||
| let message = target ?? this.create(), end = reader.pos + length; | ||
| while (reader.pos < end) { | ||
| let [fieldNo, wireType] = reader.tag(); | ||
| switch (fieldNo) { | ||
| case /* string id */ 1: | ||
| message.id = reader.string(); | ||
| break; | ||
| case /* string last_error */ 2: | ||
| message.lastError = reader.string(); | ||
| break; | ||
| case /* google.protobuf.Timestamp last_push */ 3: | ||
| message.lastPush = Timestamp.internalBinaryRead(reader, reader.uint32(), options, message.lastPush); | ||
| break; | ||
| case /* google.protobuf.Duration last_push_duration */ 4: | ||
| message.lastPushDuration = Duration.internalBinaryRead(reader, reader.uint32(), options, message.lastPushDuration); | ||
| 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: Agent, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { | ||
| /* string id = 1; */ | ||
| if (message.id !== "") | ||
| writer.tag(1, WireType.LengthDelimited).string(message.id); | ||
| /* string last_error = 2; */ | ||
| if (message.lastError !== "") | ||
| writer.tag(2, WireType.LengthDelimited).string(message.lastError); | ||
| /* google.protobuf.Timestamp last_push = 3; */ | ||
| if (message.lastPush) | ||
| Timestamp.internalBinaryWrite(message.lastPush, writer.tag(3, WireType.LengthDelimited).fork(), options).join(); | ||
| /* google.protobuf.Duration last_push_duration = 4; */ | ||
| if (message.lastPushDuration) | ||
| Duration.internalBinaryWrite(message.lastPushDuration, writer.tag(4, WireType.LengthDelimited).fork(), options).join(); | ||
| 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.Agent | ||
| */ | ||
| export const Agent = new Agent$Type(); | ||
| /** | ||
| * @generated ServiceType for protobuf service parca.profilestore.v1alpha1.ProfileStoreService | ||
@@ -410,1 +605,7 @@ */ | ||
| ]); | ||
| /** | ||
| * @generated ServiceType for protobuf service parca.profilestore.v1alpha1.AgentsService | ||
| */ | ||
| export const AgentsService = new ServiceType("parca.profilestore.v1alpha1.AgentsService", [ | ||
| { name: "Agents", options: { "google.api.http": { get: "/agents" } }, I: AgentsRequest, O: AgentsResponse } | ||
| ]); |
@@ -103,3 +103,3 @@ // @generated by protobuf-ts 2.8.1 with parameter long_type_string,generate_dependencies | ||
| /** | ||
| * lase_error is the error message most recently received from a scrape attempt | ||
| * last_error is the error message most recently received from a scrape attempt | ||
| * | ||
@@ -106,0 +106,0 @@ * @generated from protobuf field: string last_error = 3; |
New alerts
License Policy Violation
LicenseThis 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
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
Worsened metrics
- Total package byte prevSize
- decreased by-7.01%
1355031
- Number of package files
- decreased by-10.14%
62
- Lines of code
- decreased by-7.36%
28212
No dependency changes