/** * Generated by the protoc-gen-ts. DO NOT EDIT! * compiler version: 3.19.1 * source: testsystem/v1/observer/observer.proto * git: https://github.com/thesayyn/protoc-gen-ts */ import * as dependency_1 from "./../events/events"; import * as pb_1 from "google-protobuf"; import * as grpc_1 from "@grpc/grpc-js"; export namespace testsystem.v1.observer { export class AckResponse extends pb_1.Message { #one_of_decls: number[][] = [[3]]; constructor(data?: any[] | ({ success?: boolean; message?: string; } & (({ error_code?: number; })))) { super(); pb_1.Message.initialize(this, Array.isArray(data) ? data : [], 0, -1, [], this.#one_of_decls); if (!Array.isArray(data) && typeof data == "object") { if ("success" in data && data.success != undefined) { this.success = data.success; } if ("message" in data && data.message != undefined) { this.message = data.message; } if ("error_code" in data && data.error_code != undefined) { this.error_code = data.error_code; } } } get success() { return pb_1.Message.getFieldWithDefault(this, 1, false) as boolean; } set success(value: boolean) { pb_1.Message.setField(this, 1, value); } get message() { return pb_1.Message.getFieldWithDefault(this, 2, "") as string; } set message(value: string) { pb_1.Message.setField(this, 2, value); } get error_code() { return pb_1.Message.getFieldWithDefault(this, 3, 0) as number; } set error_code(value: number) { pb_1.Message.setOneofField(this, 3, this.#one_of_decls[0], value); } get has_error_code() { return pb_1.Message.getField(this, 3) != null; } get _error_code() { const cases: { [index: number]: "none" | "error_code"; } = { 0: "none", 3: "error_code" }; return cases[pb_1.Message.computeOneofCase(this, [3])]; } static fromObject(data: { success?: boolean; message?: string; error_code?: number; }): AckResponse { const message = new AckResponse({}); if (data.success != null) { message.success = data.success; } if (data.message != null) { message.message = data.message; } if (data.error_code != null) { message.error_code = data.error_code; } return message; } toObject() { const data: { success?: boolean; message?: string; error_code?: number; } = {}; if (this.success != null) { data.success = this.success; } if (this.message != null) { data.message = this.message; } if (this.error_code != null) { data.error_code = this.error_code; } return data; } serialize(): Uint8Array; serialize(w: pb_1.BinaryWriter): void; serialize(w?: pb_1.BinaryWriter): Uint8Array | void { const writer = w || new pb_1.BinaryWriter(); if (this.success != false) writer.writeBool(1, this.success); if (this.message.length) writer.writeString(2, this.message); if (this.has_error_code) writer.writeInt32(3, this.error_code); if (!w) return writer.getResultBuffer(); } static deserialize(bytes: Uint8Array | pb_1.BinaryReader): AckResponse { const reader = bytes instanceof pb_1.BinaryReader ? bytes : new pb_1.BinaryReader(bytes), message = new AckResponse(); while (reader.nextField()) { if (reader.isEndGroup()) break; switch (reader.getFieldNumber()) { case 1: message.success = reader.readBool(); break; case 2: message.message = reader.readString(); break; case 3: message.error_code = reader.readInt32(); break; default: reader.skipField(); } } return message; } serializeBinary(): Uint8Array { return this.serialize(); } static deserializeBinary(bytes: Uint8Array): AckResponse { return AckResponse.deserialize(bytes); } } interface GrpcUnaryServiceInterface { (message: P, metadata: grpc_1.Metadata, options: grpc_1.CallOptions, callback: grpc_1.requestCallback): grpc_1.ClientUnaryCall; (message: P, metadata: grpc_1.Metadata, callback: grpc_1.requestCallback): grpc_1.ClientUnaryCall; (message: P, options: grpc_1.CallOptions, callback: grpc_1.requestCallback): grpc_1.ClientUnaryCall; (message: P, callback: grpc_1.requestCallback): grpc_1.ClientUnaryCall; } interface GrpcStreamServiceInterface { (message: P, metadata: grpc_1.Metadata, options?: grpc_1.CallOptions): grpc_1.ClientReadableStream; (message: P, options?: grpc_1.CallOptions): grpc_1.ClientReadableStream; } interface GrpWritableServiceInterface { (metadata: grpc_1.Metadata, options: grpc_1.CallOptions, callback: grpc_1.requestCallback): grpc_1.ClientWritableStream

; (metadata: grpc_1.Metadata, callback: grpc_1.requestCallback): grpc_1.ClientWritableStream

; (options: grpc_1.CallOptions, callback: grpc_1.requestCallback): grpc_1.ClientWritableStream

; (callback: grpc_1.requestCallback): grpc_1.ClientWritableStream

; } interface GrpcChunkServiceInterface { (metadata: grpc_1.Metadata, options?: grpc_1.CallOptions): grpc_1.ClientDuplexStream; (options?: grpc_1.CallOptions): grpc_1.ClientDuplexStream; } interface GrpcPromiseServiceInterface { (message: P, metadata: grpc_1.Metadata, options?: grpc_1.CallOptions): Promise; (message: P, options?: grpc_1.CallOptions): Promise; } export abstract class UnimplementedTestEventCollectorService { static definition = { ReportRunStart: { path: "/testsystem.v1.observer.TestEventCollector/ReportRunStart", requestStream: false, responseStream: false, requestSerialize: (message: dependency_1.testsystem.v1.events.ReportRunStartEventRequest) => Buffer.from(message.serialize()), requestDeserialize: (bytes: Buffer) => dependency_1.testsystem.v1.events.ReportRunStartEventRequest.deserialize(new Uint8Array(bytes)), responseSerialize: (message: AckResponse) => Buffer.from(message.serialize()), responseDeserialize: (bytes: Buffer) => AckResponse.deserialize(new Uint8Array(bytes)) }, ReportSuiteBegin: { path: "/testsystem.v1.observer.TestEventCollector/ReportSuiteBegin", requestStream: false, responseStream: false, requestSerialize: (message: dependency_1.testsystem.v1.events.SuiteBeginEventRequest) => Buffer.from(message.serialize()), requestDeserialize: (bytes: Buffer) => dependency_1.testsystem.v1.events.SuiteBeginEventRequest.deserialize(new Uint8Array(bytes)), responseSerialize: (message: AckResponse) => Buffer.from(message.serialize()), responseDeserialize: (bytes: Buffer) => AckResponse.deserialize(new Uint8Array(bytes)) }, ReportSuiteEnd: { path: "/testsystem.v1.observer.TestEventCollector/ReportSuiteEnd", requestStream: false, responseStream: false, requestSerialize: (message: dependency_1.testsystem.v1.events.SuiteEndEventRequest) => Buffer.from(message.serialize()), requestDeserialize: (bytes: Buffer) => dependency_1.testsystem.v1.events.SuiteEndEventRequest.deserialize(new Uint8Array(bytes)), responseSerialize: (message: AckResponse) => Buffer.from(message.serialize()), responseDeserialize: (bytes: Buffer) => AckResponse.deserialize(new Uint8Array(bytes)) }, ReportTestBegin: { path: "/testsystem.v1.observer.TestEventCollector/ReportTestBegin", requestStream: false, responseStream: false, requestSerialize: (message: dependency_1.testsystem.v1.events.TestBeginEventRequest) => Buffer.from(message.serialize()), requestDeserialize: (bytes: Buffer) => dependency_1.testsystem.v1.events.TestBeginEventRequest.deserialize(new Uint8Array(bytes)), responseSerialize: (message: AckResponse) => Buffer.from(message.serialize()), responseDeserialize: (bytes: Buffer) => AckResponse.deserialize(new Uint8Array(bytes)) }, ReportTestEnd: { path: "/testsystem.v1.observer.TestEventCollector/ReportTestEnd", requestStream: false, responseStream: false, requestSerialize: (message: dependency_1.testsystem.v1.events.TestEndEventRequest) => Buffer.from(message.serialize()), requestDeserialize: (bytes: Buffer) => dependency_1.testsystem.v1.events.TestEndEventRequest.deserialize(new Uint8Array(bytes)), responseSerialize: (message: AckResponse) => Buffer.from(message.serialize()), responseDeserialize: (bytes: Buffer) => AckResponse.deserialize(new Uint8Array(bytes)) }, ReportStepBegin: { path: "/testsystem.v1.observer.TestEventCollector/ReportStepBegin", requestStream: false, responseStream: false, requestSerialize: (message: dependency_1.testsystem.v1.events.StepBeginEventRequest) => Buffer.from(message.serialize()), requestDeserialize: (bytes: Buffer) => dependency_1.testsystem.v1.events.StepBeginEventRequest.deserialize(new Uint8Array(bytes)), responseSerialize: (message: AckResponse) => Buffer.from(message.serialize()), responseDeserialize: (bytes: Buffer) => AckResponse.deserialize(new Uint8Array(bytes)) }, ReportStepEnd: { path: "/testsystem.v1.observer.TestEventCollector/ReportStepEnd", requestStream: false, responseStream: false, requestSerialize: (message: dependency_1.testsystem.v1.events.StepEndEventRequest) => Buffer.from(message.serialize()), requestDeserialize: (bytes: Buffer) => dependency_1.testsystem.v1.events.StepEndEventRequest.deserialize(new Uint8Array(bytes)), responseSerialize: (message: AckResponse) => Buffer.from(message.serialize()), responseDeserialize: (bytes: Buffer) => AckResponse.deserialize(new Uint8Array(bytes)) }, ReportTestFailure: { path: "/testsystem.v1.observer.TestEventCollector/ReportTestFailure", requestStream: false, responseStream: false, requestSerialize: (message: dependency_1.testsystem.v1.events.TestFailureEventRequest) => Buffer.from(message.serialize()), requestDeserialize: (bytes: Buffer) => dependency_1.testsystem.v1.events.TestFailureEventRequest.deserialize(new Uint8Array(bytes)), responseSerialize: (message: AckResponse) => Buffer.from(message.serialize()), responseDeserialize: (bytes: Buffer) => AckResponse.deserialize(new Uint8Array(bytes)) }, ReportTestError: { path: "/testsystem.v1.observer.TestEventCollector/ReportTestError", requestStream: false, responseStream: false, requestSerialize: (message: dependency_1.testsystem.v1.events.TestErrorEventRequest) => Buffer.from(message.serialize()), requestDeserialize: (bytes: Buffer) => dependency_1.testsystem.v1.events.TestErrorEventRequest.deserialize(new Uint8Array(bytes)), responseSerialize: (message: AckResponse) => Buffer.from(message.serialize()), responseDeserialize: (bytes: Buffer) => AckResponse.deserialize(new Uint8Array(bytes)) }, ReportStdError: { path: "/testsystem.v1.observer.TestEventCollector/ReportStdError", requestStream: false, responseStream: false, requestSerialize: (message: dependency_1.testsystem.v1.events.StdErrorEventRequest) => Buffer.from(message.serialize()), requestDeserialize: (bytes: Buffer) => dependency_1.testsystem.v1.events.StdErrorEventRequest.deserialize(new Uint8Array(bytes)), responseSerialize: (message: AckResponse) => Buffer.from(message.serialize()), responseDeserialize: (bytes: Buffer) => AckResponse.deserialize(new Uint8Array(bytes)) }, ReportStdOutput: { path: "/testsystem.v1.observer.TestEventCollector/ReportStdOutput", requestStream: false, responseStream: false, requestSerialize: (message: dependency_1.testsystem.v1.events.StdOutputEventRequest) => Buffer.from(message.serialize()), requestDeserialize: (bytes: Buffer) => dependency_1.testsystem.v1.events.StdOutputEventRequest.deserialize(new Uint8Array(bytes)), responseSerialize: (message: AckResponse) => Buffer.from(message.serialize()), responseDeserialize: (bytes: Buffer) => AckResponse.deserialize(new Uint8Array(bytes)) }, ReportRunEnd: { path: "/testsystem.v1.observer.TestEventCollector/ReportRunEnd", requestStream: false, responseStream: false, requestSerialize: (message: dependency_1.testsystem.v1.events.TestRunEndEventRequest) => Buffer.from(message.serialize()), requestDeserialize: (bytes: Buffer) => dependency_1.testsystem.v1.events.TestRunEndEventRequest.deserialize(new Uint8Array(bytes)), responseSerialize: (message: AckResponse) => Buffer.from(message.serialize()), responseDeserialize: (bytes: Buffer) => AckResponse.deserialize(new Uint8Array(bytes)) }, Heartbeat: { path: "/testsystem.v1.observer.TestEventCollector/Heartbeat", requestStream: false, responseStream: false, requestSerialize: (message: dependency_1.testsystem.v1.events.HeartbeatEventRequest) => Buffer.from(message.serialize()), requestDeserialize: (bytes: Buffer) => dependency_1.testsystem.v1.events.HeartbeatEventRequest.deserialize(new Uint8Array(bytes)), responseSerialize: (message: AckResponse) => Buffer.from(message.serialize()), responseDeserialize: (bytes: Buffer) => AckResponse.deserialize(new Uint8Array(bytes)) } }; [method: string]: grpc_1.UntypedHandleCall; abstract ReportRunStart(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; abstract ReportSuiteBegin(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; abstract ReportSuiteEnd(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; abstract ReportTestBegin(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; abstract ReportTestEnd(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; abstract ReportStepBegin(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; abstract ReportStepEnd(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; abstract ReportTestFailure(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; abstract ReportTestError(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; abstract ReportStdError(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; abstract ReportStdOutput(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; abstract ReportRunEnd(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; abstract Heartbeat(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; } export class TestEventCollectorClient extends grpc_1.makeGenericClientConstructor(UnimplementedTestEventCollectorService.definition, "TestEventCollector", {}) { constructor(address: string, credentials: grpc_1.ChannelCredentials, options?: Partial) { super(address, credentials, options); } ReportRunStart: GrpcUnaryServiceInterface = (message: dependency_1.testsystem.v1.events.ReportRunStartEventRequest, metadata: grpc_1.Metadata | grpc_1.CallOptions | grpc_1.requestCallback, options?: grpc_1.CallOptions | grpc_1.requestCallback, callback?: grpc_1.requestCallback): grpc_1.ClientUnaryCall => { return super.ReportRunStart(message, metadata, options, callback); }; ReportSuiteBegin: GrpcUnaryServiceInterface = (message: dependency_1.testsystem.v1.events.SuiteBeginEventRequest, metadata: grpc_1.Metadata | grpc_1.CallOptions | grpc_1.requestCallback, options?: grpc_1.CallOptions | grpc_1.requestCallback, callback?: grpc_1.requestCallback): grpc_1.ClientUnaryCall => { return super.ReportSuiteBegin(message, metadata, options, callback); }; ReportSuiteEnd: GrpcUnaryServiceInterface = (message: dependency_1.testsystem.v1.events.SuiteEndEventRequest, metadata: grpc_1.Metadata | grpc_1.CallOptions | grpc_1.requestCallback, options?: grpc_1.CallOptions | grpc_1.requestCallback, callback?: grpc_1.requestCallback): grpc_1.ClientUnaryCall => { return super.ReportSuiteEnd(message, metadata, options, callback); }; ReportTestBegin: GrpcUnaryServiceInterface = (message: dependency_1.testsystem.v1.events.TestBeginEventRequest, metadata: grpc_1.Metadata | grpc_1.CallOptions | grpc_1.requestCallback, options?: grpc_1.CallOptions | grpc_1.requestCallback, callback?: grpc_1.requestCallback): grpc_1.ClientUnaryCall => { return super.ReportTestBegin(message, metadata, options, callback); }; ReportTestEnd: GrpcUnaryServiceInterface = (message: dependency_1.testsystem.v1.events.TestEndEventRequest, metadata: grpc_1.Metadata | grpc_1.CallOptions | grpc_1.requestCallback, options?: grpc_1.CallOptions | grpc_1.requestCallback, callback?: grpc_1.requestCallback): grpc_1.ClientUnaryCall => { return super.ReportTestEnd(message, metadata, options, callback); }; ReportStepBegin: GrpcUnaryServiceInterface = (message: dependency_1.testsystem.v1.events.StepBeginEventRequest, metadata: grpc_1.Metadata | grpc_1.CallOptions | grpc_1.requestCallback, options?: grpc_1.CallOptions | grpc_1.requestCallback, callback?: grpc_1.requestCallback): grpc_1.ClientUnaryCall => { return super.ReportStepBegin(message, metadata, options, callback); }; ReportStepEnd: GrpcUnaryServiceInterface = (message: dependency_1.testsystem.v1.events.StepEndEventRequest, metadata: grpc_1.Metadata | grpc_1.CallOptions | grpc_1.requestCallback, options?: grpc_1.CallOptions | grpc_1.requestCallback, callback?: grpc_1.requestCallback): grpc_1.ClientUnaryCall => { return super.ReportStepEnd(message, metadata, options, callback); }; ReportTestFailure: GrpcUnaryServiceInterface = (message: dependency_1.testsystem.v1.events.TestFailureEventRequest, metadata: grpc_1.Metadata | grpc_1.CallOptions | grpc_1.requestCallback, options?: grpc_1.CallOptions | grpc_1.requestCallback, callback?: grpc_1.requestCallback): grpc_1.ClientUnaryCall => { return super.ReportTestFailure(message, metadata, options, callback); }; ReportTestError: GrpcUnaryServiceInterface = (message: dependency_1.testsystem.v1.events.TestErrorEventRequest, metadata: grpc_1.Metadata | grpc_1.CallOptions | grpc_1.requestCallback, options?: grpc_1.CallOptions | grpc_1.requestCallback, callback?: grpc_1.requestCallback): grpc_1.ClientUnaryCall => { return super.ReportTestError(message, metadata, options, callback); }; ReportStdError: GrpcUnaryServiceInterface = (message: dependency_1.testsystem.v1.events.StdErrorEventRequest, metadata: grpc_1.Metadata | grpc_1.CallOptions | grpc_1.requestCallback, options?: grpc_1.CallOptions | grpc_1.requestCallback, callback?: grpc_1.requestCallback): grpc_1.ClientUnaryCall => { return super.ReportStdError(message, metadata, options, callback); }; ReportStdOutput: GrpcUnaryServiceInterface = (message: dependency_1.testsystem.v1.events.StdOutputEventRequest, metadata: grpc_1.Metadata | grpc_1.CallOptions | grpc_1.requestCallback, options?: grpc_1.CallOptions | grpc_1.requestCallback, callback?: grpc_1.requestCallback): grpc_1.ClientUnaryCall => { return super.ReportStdOutput(message, metadata, options, callback); }; ReportRunEnd: GrpcUnaryServiceInterface = (message: dependency_1.testsystem.v1.events.TestRunEndEventRequest, metadata: grpc_1.Metadata | grpc_1.CallOptions | grpc_1.requestCallback, options?: grpc_1.CallOptions | grpc_1.requestCallback, callback?: grpc_1.requestCallback): grpc_1.ClientUnaryCall => { return super.ReportRunEnd(message, metadata, options, callback); }; Heartbeat: GrpcUnaryServiceInterface = (message: dependency_1.testsystem.v1.events.HeartbeatEventRequest, metadata: grpc_1.Metadata | grpc_1.CallOptions | grpc_1.requestCallback, options?: grpc_1.CallOptions | grpc_1.requestCallback, callback?: grpc_1.requestCallback): grpc_1.ClientUnaryCall => { return super.Heartbeat(message, metadata, options, callback); }; } }