// @generated by protobuf-ts 2.11.1 with parameter use_proto_field_name,keep_enum_prefix // @generated from protobuf file "executionflowQuery.proto" (package "api", syntax proto3) // tslint:disable import { CountLinesResult } from "./shared"; import { CountLinesQuery } from "./shared"; import { GetKPIDataResult } from "./clickhouse"; import { GetKPIDataQuery } from "./clickhouse"; import { ServiceType } from "@protobuf-ts/runtime-rpc"; import type { BinaryWriteOptions } from "@protobuf-ts/runtime"; import type { IBinaryWriter } from "@protobuf-ts/runtime"; import { WireType } from "@protobuf-ts/runtime"; import type { BinaryReadOptions } from "@protobuf-ts/runtime"; import type { IBinaryReader } from "@protobuf-ts/runtime"; import { UnknownFieldHandler } from "@protobuf-ts/runtime"; import type { PartialMessage } from "@protobuf-ts/runtime"; import { reflectionMergePartial } from "@protobuf-ts/runtime"; import { MessageType } from "@protobuf-ts/runtime"; import { EntityType } from "./shared"; import { BlockFilter } from "./shared"; import { Executionflow } from "./executionflow"; import { ResultHeader } from "./shared"; import { QueryEntityID } from "./shared"; import { QueryProjectHeader } from "./shared"; // // Query-server services /** * @generated from protobuf message api.ExecutionflowByIdQuery */ export interface ExecutionflowByIdQuery { /** * @generated from protobuf field: api.QueryProjectHeader Header = 1 */ Header?: QueryProjectHeader; /** * @generated from protobuf field: repeated api.QueryEntityID IDs = 2 */ IDs: QueryEntityID[]; /** * @generated from protobuf field: api.ExecutionflowQueryOptions Options = 3 */ Options?: ExecutionflowQueryOptions; } /** * @generated from protobuf message api.ExecutionflowByIdResult */ export interface ExecutionflowByIdResult { /** * @generated from protobuf field: api.ResultHeader Header = 1 */ Header?: ResultHeader; /** * @generated from protobuf field: repeated api.Executionflow Objects = 2 */ Objects: Executionflow[]; } /** * @generated from protobuf message api.ExecutionflowByFilterQuery */ export interface ExecutionflowByFilterQuery { /** * @generated from protobuf field: api.QueryProjectHeader Header = 1 */ Header?: QueryProjectHeader; /** * Number of maximum result * * @generated from protobuf field: string limitFilter = 4 */ limitFilter: string; /** * @generated from protobuf field: string queryContext = 5 */ queryContext: string; /** * list of blockFilters structure for Find query, each element (BlockFilter) in the list is an "OR" part of the query * * @generated from protobuf field: repeated api.BlockFilter BlockFilters = 6 */ BlockFilters: BlockFilter[]; /** * @generated from protobuf field: api.ExecutionflowQueryOptions Options = 7 */ Options?: ExecutionflowQueryOptions; /** * @generated from protobuf field: api.EntityType UsageContextEntity = 8 */ UsageContextEntity: EntityType; /** * @generated from protobuf field: string UsageContextPath = 9 */ UsageContextPath: string; } /** * @generated from protobuf message api.ExecutionflowByFilterResult */ export interface ExecutionflowByFilterResult { /** * @generated from protobuf field: api.ResultHeader Header = 1 */ Header?: ResultHeader; /** * @generated from protobuf field: repeated api.Executionflow Objects = 2 */ Objects: Executionflow[]; /** * @generated from protobuf field: string queryContext = 3 */ queryContext: string; } /** * @generated from protobuf message api.ExecutionflowQueryOptions */ export interface ExecutionflowQueryOptions { /** * @generated from protobuf field: bool TruncateLines = 1 */ TruncateLines: boolean; // If true, the executionflow lines will be truncated. /** * @generated from protobuf field: repeated string Only = 2 */ Only: string[]; } // @generated message type with reflection information, may provide speed optimized methods class ExecutionflowByIdQuery$Type extends MessageType { constructor() { super("api.ExecutionflowByIdQuery", [ { no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => QueryProjectHeader, options: { "validate.rules": { message: { required: true } } } }, { no: 2, name: "IDs", kind: "message", localName: "IDs", jsonName: "IDs", repeat: 2 /*RepeatType.UNPACKED*/, T: () => QueryEntityID, options: { "validate.rules": { repeated: { minItems: "1" } } } }, { no: 3, name: "Options", kind: "message", localName: "Options", jsonName: "Options", T: () => ExecutionflowQueryOptions } ], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["Header", "IDs"] } }, "api.messageType": "Query" }); } create(value?: PartialMessage): ExecutionflowByIdQuery { const message = globalThis.Object.create((this.messagePrototype!)); message.IDs = []; if (value !== undefined) reflectionMergePartial(this, message, value); return message; } internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ExecutionflowByIdQuery): ExecutionflowByIdQuery { let message = target ?? this.create(), end = reader.pos + length; while (reader.pos < end) { let [fieldNo, wireType] = reader.tag(); switch (fieldNo) { case /* api.QueryProjectHeader Header */ 1: message.Header = QueryProjectHeader.internalBinaryRead(reader, reader.uint32(), options, message.Header); break; case /* repeated api.QueryEntityID IDs */ 2: message.IDs.push(QueryEntityID.internalBinaryRead(reader, reader.uint32(), options)); break; case /* api.ExecutionflowQueryOptions Options */ 3: message.Options = ExecutionflowQueryOptions.internalBinaryRead(reader, reader.uint32(), options, message.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: ExecutionflowByIdQuery, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { /* api.QueryProjectHeader Header = 1; */ if (message.Header) QueryProjectHeader.internalBinaryWrite(message.Header, writer.tag(1, WireType.LengthDelimited).fork(), options).join(); /* repeated api.QueryEntityID IDs = 2; */ for (let i = 0; i < message.IDs.length; i++) QueryEntityID.internalBinaryWrite(message.IDs[i], writer.tag(2, WireType.LengthDelimited).fork(), options).join(); /* api.ExecutionflowQueryOptions Options = 3; */ if (message.Options) ExecutionflowQueryOptions.internalBinaryWrite(message.Options, writer.tag(3, 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 api.ExecutionflowByIdQuery */ export const ExecutionflowByIdQuery = new ExecutionflowByIdQuery$Type(); // @generated message type with reflection information, may provide speed optimized methods class ExecutionflowByIdResult$Type extends MessageType { constructor() { super("api.ExecutionflowByIdResult", [ { no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => ResultHeader }, { no: 2, name: "Objects", kind: "message", localName: "Objects", jsonName: "Objects", repeat: 2 /*RepeatType.UNPACKED*/, T: () => Executionflow } ], { "api.messageType": "Result" }); } create(value?: PartialMessage): ExecutionflowByIdResult { const message = globalThis.Object.create((this.messagePrototype!)); message.Objects = []; if (value !== undefined) reflectionMergePartial(this, message, value); return message; } internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ExecutionflowByIdResult): ExecutionflowByIdResult { let message = target ?? this.create(), end = reader.pos + length; while (reader.pos < end) { let [fieldNo, wireType] = reader.tag(); switch (fieldNo) { case /* api.ResultHeader Header */ 1: message.Header = ResultHeader.internalBinaryRead(reader, reader.uint32(), options, message.Header); break; case /* repeated api.Executionflow Objects */ 2: message.Objects.push(Executionflow.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: ExecutionflowByIdResult, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { /* api.ResultHeader Header = 1; */ if (message.Header) ResultHeader.internalBinaryWrite(message.Header, writer.tag(1, WireType.LengthDelimited).fork(), options).join(); /* repeated api.Executionflow Objects = 2; */ for (let i = 0; i < message.Objects.length; i++) Executionflow.internalBinaryWrite(message.Objects[i], writer.tag(2, 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 api.ExecutionflowByIdResult */ export const ExecutionflowByIdResult = new ExecutionflowByIdResult$Type(); // @generated message type with reflection information, may provide speed optimized methods class ExecutionflowByFilterQuery$Type extends MessageType { constructor() { super("api.ExecutionflowByFilterQuery", [ { no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => QueryProjectHeader, options: { "validate.rules": { message: { required: true } } } }, { no: 4, name: "limitFilter", kind: "scalar", T: 9 /*ScalarType.STRING*/, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Number of maximum result", example: "\"500\"" } } }, { no: 5, name: "queryContext", kind: "scalar", T: 9 /*ScalarType.STRING*/ }, { no: 6, name: "BlockFilters", kind: "message", localName: "BlockFilters", jsonName: "BlockFilters", repeat: 2 /*RepeatType.UNPACKED*/, T: () => BlockFilter }, { no: 7, name: "Options", kind: "message", localName: "Options", jsonName: "Options", T: () => ExecutionflowQueryOptions }, { no: 8, name: "UsageContextEntity", kind: "enum", localName: "UsageContextEntity", jsonName: "UsageContextEntity", T: () => ["api.EntityType", EntityType], options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Optional : Entity to apply the restriction rules (on the path defined with UsageContextPath)", example: "\"For Actor, to limit the results according to Order ShipFrom restriction rules, define UsageContextEntity to Order and UsageContextPath to Payload.ShipFrom\"" } } }, { no: 9, name: "UsageContextPath", kind: "scalar", localName: "UsageContextPath", jsonName: "UsageContextPath", T: 9 /*ScalarType.STRING*/, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Optional : Path of restriction rule to apply (UsageContextEntity should be defined)" } } } ], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["Header"] } } }); } create(value?: PartialMessage): ExecutionflowByFilterQuery { const message = globalThis.Object.create((this.messagePrototype!)); message.limitFilter = ""; message.queryContext = ""; message.BlockFilters = []; message.UsageContextEntity = 0; message.UsageContextPath = ""; if (value !== undefined) reflectionMergePartial(this, message, value); return message; } internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ExecutionflowByFilterQuery): ExecutionflowByFilterQuery { let message = target ?? this.create(), end = reader.pos + length; while (reader.pos < end) { let [fieldNo, wireType] = reader.tag(); switch (fieldNo) { case /* api.QueryProjectHeader Header */ 1: message.Header = QueryProjectHeader.internalBinaryRead(reader, reader.uint32(), options, message.Header); break; case /* string limitFilter */ 4: message.limitFilter = reader.string(); break; case /* string queryContext */ 5: message.queryContext = reader.string(); break; case /* repeated api.BlockFilter BlockFilters */ 6: message.BlockFilters.push(BlockFilter.internalBinaryRead(reader, reader.uint32(), options)); break; case /* api.ExecutionflowQueryOptions Options */ 7: message.Options = ExecutionflowQueryOptions.internalBinaryRead(reader, reader.uint32(), options, message.Options); break; case /* api.EntityType UsageContextEntity */ 8: message.UsageContextEntity = reader.int32(); break; case /* string UsageContextPath */ 9: message.UsageContextPath = reader.string(); 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: ExecutionflowByFilterQuery, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { /* api.QueryProjectHeader Header = 1; */ if (message.Header) QueryProjectHeader.internalBinaryWrite(message.Header, writer.tag(1, WireType.LengthDelimited).fork(), options).join(); /* string limitFilter = 4; */ if (message.limitFilter !== "") writer.tag(4, WireType.LengthDelimited).string(message.limitFilter); /* string queryContext = 5; */ if (message.queryContext !== "") writer.tag(5, WireType.LengthDelimited).string(message.queryContext); /* repeated api.BlockFilter BlockFilters = 6; */ for (let i = 0; i < message.BlockFilters.length; i++) BlockFilter.internalBinaryWrite(message.BlockFilters[i], writer.tag(6, WireType.LengthDelimited).fork(), options).join(); /* api.ExecutionflowQueryOptions Options = 7; */ if (message.Options) ExecutionflowQueryOptions.internalBinaryWrite(message.Options, writer.tag(7, WireType.LengthDelimited).fork(), options).join(); /* api.EntityType UsageContextEntity = 8; */ if (message.UsageContextEntity !== 0) writer.tag(8, WireType.Varint).int32(message.UsageContextEntity); /* string UsageContextPath = 9; */ if (message.UsageContextPath !== "") writer.tag(9, WireType.LengthDelimited).string(message.UsageContextPath); let u = options.writeUnknownFields; if (u !== false) (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); return writer; } } /** * @generated MessageType for protobuf message api.ExecutionflowByFilterQuery */ export const ExecutionflowByFilterQuery = new ExecutionflowByFilterQuery$Type(); // @generated message type with reflection information, may provide speed optimized methods class ExecutionflowByFilterResult$Type extends MessageType { constructor() { super("api.ExecutionflowByFilterResult", [ { no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => ResultHeader }, { no: 2, name: "Objects", kind: "message", localName: "Objects", jsonName: "Objects", repeat: 2 /*RepeatType.UNPACKED*/, T: () => Executionflow }, { no: 3, name: "queryContext", kind: "scalar", T: 9 /*ScalarType.STRING*/ } ]); } create(value?: PartialMessage): ExecutionflowByFilterResult { const message = globalThis.Object.create((this.messagePrototype!)); message.Objects = []; message.queryContext = ""; if (value !== undefined) reflectionMergePartial(this, message, value); return message; } internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ExecutionflowByFilterResult): ExecutionflowByFilterResult { let message = target ?? this.create(), end = reader.pos + length; while (reader.pos < end) { let [fieldNo, wireType] = reader.tag(); switch (fieldNo) { case /* api.ResultHeader Header */ 1: message.Header = ResultHeader.internalBinaryRead(reader, reader.uint32(), options, message.Header); break; case /* repeated api.Executionflow Objects */ 2: message.Objects.push(Executionflow.internalBinaryRead(reader, reader.uint32(), options)); break; case /* string queryContext */ 3: message.queryContext = reader.string(); 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: ExecutionflowByFilterResult, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { /* api.ResultHeader Header = 1; */ if (message.Header) ResultHeader.internalBinaryWrite(message.Header, writer.tag(1, WireType.LengthDelimited).fork(), options).join(); /* repeated api.Executionflow Objects = 2; */ for (let i = 0; i < message.Objects.length; i++) Executionflow.internalBinaryWrite(message.Objects[i], writer.tag(2, WireType.LengthDelimited).fork(), options).join(); /* string queryContext = 3; */ if (message.queryContext !== "") writer.tag(3, WireType.LengthDelimited).string(message.queryContext); let u = options.writeUnknownFields; if (u !== false) (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); return writer; } } /** * @generated MessageType for protobuf message api.ExecutionflowByFilterResult */ export const ExecutionflowByFilterResult = new ExecutionflowByFilterResult$Type(); // @generated message type with reflection information, may provide speed optimized methods class ExecutionflowQueryOptions$Type extends MessageType { constructor() { super("api.ExecutionflowQueryOptions", [ { no: 1, name: "TruncateLines", kind: "scalar", localName: "TruncateLines", jsonName: "TruncateLines", T: 8 /*ScalarType.BOOL*/ }, { no: 2, name: "Only", kind: "scalar", localName: "Only", jsonName: "Only", repeat: 2 /*RepeatType.UNPACKED*/, T: 9 /*ScalarType.STRING*/, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Optional : List of fields to include in the response for each returned Executionflow", example: "[\"ID.RefID\", \"Payload.Name\", \"Payload.Lines.ID\"]" } } } ]); } create(value?: PartialMessage): ExecutionflowQueryOptions { const message = globalThis.Object.create((this.messagePrototype!)); message.TruncateLines = false; message.Only = []; if (value !== undefined) reflectionMergePartial(this, message, value); return message; } internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ExecutionflowQueryOptions): ExecutionflowQueryOptions { let message = target ?? this.create(), end = reader.pos + length; while (reader.pos < end) { let [fieldNo, wireType] = reader.tag(); switch (fieldNo) { case /* bool TruncateLines */ 1: message.TruncateLines = reader.bool(); break; case /* repeated string Only */ 2: message.Only.push(reader.string()); 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: ExecutionflowQueryOptions, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter { /* bool TruncateLines = 1; */ if (message.TruncateLines !== false) writer.tag(1, WireType.Varint).bool(message.TruncateLines); /* repeated string Only = 2; */ for (let i = 0; i < message.Only.length; i++) writer.tag(2, WireType.LengthDelimited).string(message.Only[i]); let u = options.writeUnknownFields; if (u !== false) (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer); return writer; } } /** * @generated MessageType for protobuf message api.ExecutionflowQueryOptions */ export const ExecutionflowQueryOptions = new ExecutionflowQueryOptions$Type(); /** * @generated ServiceType for protobuf service api.ExecutionflowQuery */ export const ExecutionflowQuery = new ServiceType("api.ExecutionflowQuery", [ { name: "GetByIds", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["ExecutionFlow Query"], description: "Get Execution Flows from RefIDs" }, "api.rscType": "Project", "api.roles": "Platform.Project-Query", "api.moduleID": "order-tracking", "api.tableName": "executionflowById", "api.tags": "PROJECT_ACTIVITY", "google.api.method_visibility": { restriction: "PUBLIC" } }, I: ExecutionflowByIdQuery, O: ExecutionflowByIdResult }, { name: "GetKPIData", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["ExecutionFlow Query"], description: "Get Execution Flows KPI data" }, "api.rscType": "Project", "api.roles": "", "api.moduleID": "order-tracking", "api.tags": "PROJECT_ACTIVITY", "google.api.method_visibility": { restriction: "PUBLIC" } }, I: GetKPIDataQuery, O: GetKPIDataResult }, { name: "CountLines", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["ExecutionFlow Query"], description: "Count lines in database for project" }, "api.rscType": "Platform", "api.roles": "Platform.Project-Query", "api.moduleID": "order-tracking", "api.tags": "PROJECT_ACTIVITY", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: CountLinesQuery, O: CountLinesResult }, { name: "Find", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["ExecutionFlow Query"], description: "Find Execution flows using search criterias" }, "api.rscType": "Project", "api.roles": "Platform.Project-Query", "api.moduleID": "order-tracking", "api.tags": "PROJECT_ACTIVITY", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: ExecutionflowByFilterQuery, O: ExecutionflowByFilterResult } ], { "api.serviceType": "Query", "api.k8sService": "query-server" });