You've already forked npm-core-sdk
1336 lines
63 KiB
TypeScript
1336 lines
63 KiB
TypeScript
// @generated by protobuf-ts 2.11.1 with parameter use_proto_field_name,keep_enum_prefix
|
|
// @generated from protobuf file "kpi.proto" (package "api", syntax proto3)
|
|
// tslint:disable
|
|
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 { RequestProjectHeader } from "./shared";
|
|
/**
|
|
* @generated from protobuf message api.Kpi
|
|
*/
|
|
export interface Kpi {
|
|
/**
|
|
* @generated from protobuf field: string Name = 1
|
|
*/
|
|
Name: string;
|
|
/**
|
|
* @generated from protobuf field: string Level = 2
|
|
*/
|
|
Level: string;
|
|
// string Block = 3;
|
|
|
|
/**
|
|
* @generated from protobuf field: string DataType = 4
|
|
*/
|
|
DataType: string;
|
|
/**
|
|
* @generated from protobuf field: string ContentType = 5
|
|
*/
|
|
ContentType: string;
|
|
/**
|
|
* @generated from protobuf field: string EnumValues = 6
|
|
*/
|
|
EnumValues: string;
|
|
/**
|
|
* @generated from protobuf field: repeated api.KpiExpression Expressions = 7
|
|
*/
|
|
Expressions: KpiExpression[];
|
|
/**
|
|
* @generated from protobuf field: string FullName = 8
|
|
*/
|
|
FullName: string;
|
|
/**
|
|
* @generated from protobuf field: bool IsComputed = 9
|
|
*/
|
|
IsComputed: boolean;
|
|
/**
|
|
* repeated EntityCorrespondence EntityCorrespondences = 10;
|
|
*
|
|
* @generated from protobuf field: string GroupToJoin = 11
|
|
*/
|
|
GroupToJoin: string;
|
|
/**
|
|
* @generated from protobuf field: string ColumnType = 12
|
|
*/
|
|
ColumnType: string;
|
|
/**
|
|
* @generated from protobuf field: bool IsQueryable = 13
|
|
*/
|
|
IsQueryable: boolean;
|
|
}
|
|
/**
|
|
* @generated from protobuf message api.KpiExpression
|
|
*/
|
|
export interface KpiExpression {
|
|
/**
|
|
* @generated from protobuf field: string Block = 1
|
|
*/
|
|
Block: string;
|
|
/**
|
|
* @generated from protobuf field: string QueryType = 2
|
|
*/
|
|
QueryType: string;
|
|
/**
|
|
* @generated from protobuf field: string Field = 3
|
|
*/
|
|
Field: string;
|
|
/**
|
|
* @generated from protobuf field: string Query = 4
|
|
*/
|
|
Query: string;
|
|
}
|
|
/**
|
|
* @generated from protobuf message api.GetKpisRequest
|
|
*/
|
|
export interface GetKpisRequest {
|
|
/**
|
|
* @generated from protobuf field: api.RequestProjectHeader Header = 1
|
|
*/
|
|
Header?: RequestProjectHeader;
|
|
/**
|
|
* @generated from protobuf field: string Domain = 2
|
|
*/
|
|
Domain: string;
|
|
/**
|
|
* Widget analysis criterion, executionflow for Order and stock for Stock
|
|
*
|
|
* @generated from protobuf field: string Group = 3
|
|
*/
|
|
Group: string;
|
|
/**
|
|
* @generated from protobuf field: bool isMetric = 4
|
|
*/
|
|
isMetric: boolean;
|
|
/**
|
|
* @generated from protobuf field: bool isDimension = 5
|
|
*/
|
|
isDimension: boolean;
|
|
/**
|
|
* @generated from protobuf field: bool isDate = 6
|
|
*/
|
|
isDate: boolean;
|
|
/**
|
|
* @generated from protobuf field: bool isCount = 7
|
|
*/
|
|
isCount: boolean;
|
|
/**
|
|
* @generated from protobuf field: bool OnlyQueryable = 8
|
|
*/
|
|
OnlyQueryable: boolean;
|
|
}
|
|
/**
|
|
* @generated from protobuf message api.GetKpisResult
|
|
*/
|
|
export interface GetKpisResult {
|
|
/**
|
|
* @generated from protobuf field: repeated api.Kpi Kpis = 1
|
|
*/
|
|
Kpis: Kpi[];
|
|
}
|
|
/**
|
|
* @generated from protobuf message api.GetKpiTableStructureRequest
|
|
*/
|
|
export interface GetKpiTableStructureRequest {
|
|
/**
|
|
* @generated from protobuf field: string RscID = 1
|
|
*/
|
|
RscID: string; // RscID or SiteID
|
|
/**
|
|
* @generated from protobuf field: string Domain = 2
|
|
*/
|
|
Domain: string;
|
|
}
|
|
/**
|
|
* @generated from protobuf message api.GetKpiTableStructureResult
|
|
*/
|
|
export interface GetKpiTableStructureResult {
|
|
/**
|
|
* @generated from protobuf field: repeated string Tables = 1
|
|
*/
|
|
Tables: string[];
|
|
}
|
|
/**
|
|
* @generated from protobuf message api.UpdateKpiTableStructureRequest
|
|
*/
|
|
export interface UpdateKpiTableStructureRequest {
|
|
/**
|
|
* @generated from protobuf field: string RscID = 1
|
|
*/
|
|
RscID: string; // RscID or SiteID
|
|
/**
|
|
* @generated from protobuf field: string Domain = 2
|
|
*/
|
|
Domain: string;
|
|
}
|
|
/**
|
|
* @generated from protobuf message api.UpdateKpiTableStructureResult
|
|
*/
|
|
export interface UpdateKpiTableStructureResult {
|
|
}
|
|
/**
|
|
* @generated from protobuf message api.GetKpiEntitiesRequest
|
|
*/
|
|
export interface GetKpiEntitiesRequest {
|
|
/**
|
|
* @generated from protobuf field: string RscID = 1
|
|
*/
|
|
RscID: string;
|
|
/**
|
|
* @generated from protobuf field: string Domain = 2
|
|
*/
|
|
Domain: string;
|
|
}
|
|
/**
|
|
* @generated from protobuf message api.GetKpiEntitiesResult
|
|
*/
|
|
export interface GetKpiEntitiesResult {
|
|
/**
|
|
* @generated from protobuf field: repeated string Entities = 1
|
|
*/
|
|
Entities: string[];
|
|
}
|
|
/**
|
|
* @generated from protobuf message api.ClearKpiEntityRequest
|
|
*/
|
|
export interface ClearKpiEntityRequest {
|
|
/**
|
|
* @generated from protobuf field: string RscID = 1
|
|
*/
|
|
RscID: string;
|
|
/**
|
|
* @generated from protobuf field: api.EntityType Entity = 2
|
|
*/
|
|
Entity: EntityType;
|
|
}
|
|
/**
|
|
* @generated from protobuf message api.ClearKpiEntityResult
|
|
*/
|
|
export interface ClearKpiEntityResult {
|
|
}
|
|
/**
|
|
* @generated from protobuf message api.CreateMVRequest
|
|
*/
|
|
export interface CreateMVRequest {
|
|
/**
|
|
* @generated from protobuf field: string RscID = 1
|
|
*/
|
|
RscID: string;
|
|
/**
|
|
* @generated from protobuf field: string Domain = 2
|
|
*/
|
|
Domain: string;
|
|
}
|
|
/**
|
|
* @generated from protobuf message api.CreateMVResult
|
|
*/
|
|
export interface CreateMVResult {
|
|
}
|
|
/**
|
|
* @generated from protobuf message api.DropMVRequest
|
|
*/
|
|
export interface DropMVRequest {
|
|
/**
|
|
* @generated from protobuf field: string RscID = 1
|
|
*/
|
|
RscID: string;
|
|
/**
|
|
* @generated from protobuf field: string Domain = 2
|
|
*/
|
|
Domain: string;
|
|
}
|
|
/**
|
|
* @generated from protobuf message api.DropMVResult
|
|
*/
|
|
export interface DropMVResult {
|
|
}
|
|
/**
|
|
* @generated from protobuf message api.PopulateMVRequest
|
|
*/
|
|
export interface PopulateMVRequest {
|
|
/**
|
|
* @generated from protobuf field: string RscID = 1
|
|
*/
|
|
RscID: string;
|
|
/**
|
|
* @generated from protobuf field: string Domain = 2
|
|
*/
|
|
Domain: string;
|
|
}
|
|
/**
|
|
* @generated from protobuf message api.PopulateMVResult
|
|
*/
|
|
export interface PopulateMVResult {
|
|
}
|
|
/**
|
|
* @generated from protobuf enum api.KPIGroupProperty
|
|
*/
|
|
export enum KPIGroupProperty {
|
|
/**
|
|
* Type of kpi group (Sink, Materialized, View)
|
|
*
|
|
* @generated from protobuf enum value: KPIGROUP_TYPE = 0;
|
|
*/
|
|
KPIGROUP_TYPE = 0,
|
|
/**
|
|
* Table Orderby
|
|
*
|
|
* @generated from protobuf enum value: KPIGROUP_ORDERBY = 1;
|
|
*/
|
|
KPIGROUP_ORDERBY = 1,
|
|
/**
|
|
* Table engine
|
|
*
|
|
* @generated from protobuf enum value: KPIGROUP_ENGINE = 2;
|
|
*/
|
|
KPIGROUP_ENGINE = 2,
|
|
/**
|
|
* Table header columns
|
|
*
|
|
* @generated from protobuf enum value: KPIGROUP_HEADER_COLUMNS = 3;
|
|
*/
|
|
KPIGROUP_HEADER_COLUMNS = 3,
|
|
/**
|
|
* Table PartitionBy
|
|
*
|
|
* @generated from protobuf enum value: KPIGROUP_PARTITIONBY = 4;
|
|
*/
|
|
KPIGROUP_PARTITIONBY = 4
|
|
}
|
|
// @generated message type with reflection information, may provide speed optimized methods
|
|
class Kpi$Type extends MessageType<Kpi> {
|
|
constructor() {
|
|
super("api.Kpi", [
|
|
{ no: 1, name: "Name", kind: "scalar", localName: "Name", jsonName: "Name", T: 9 /*ScalarType.STRING*/ },
|
|
{ no: 2, name: "Level", kind: "scalar", localName: "Level", jsonName: "Level", T: 9 /*ScalarType.STRING*/ },
|
|
{ no: 4, name: "DataType", kind: "scalar", localName: "DataType", jsonName: "DataType", T: 9 /*ScalarType.STRING*/ },
|
|
{ no: 5, name: "ContentType", kind: "scalar", localName: "ContentType", jsonName: "ContentType", T: 9 /*ScalarType.STRING*/ },
|
|
{ no: 6, name: "EnumValues", kind: "scalar", localName: "EnumValues", jsonName: "EnumValues", T: 9 /*ScalarType.STRING*/ },
|
|
{ no: 7, name: "Expressions", kind: "message", localName: "Expressions", jsonName: "Expressions", repeat: 2 /*RepeatType.UNPACKED*/, T: () => KpiExpression },
|
|
{ no: 8, name: "FullName", kind: "scalar", localName: "FullName", jsonName: "FullName", T: 9 /*ScalarType.STRING*/ },
|
|
{ no: 9, name: "IsComputed", kind: "scalar", localName: "IsComputed", jsonName: "IsComputed", T: 8 /*ScalarType.BOOL*/ },
|
|
{ no: 11, name: "GroupToJoin", kind: "scalar", localName: "GroupToJoin", jsonName: "GroupToJoin", T: 9 /*ScalarType.STRING*/ },
|
|
{ no: 12, name: "ColumnType", kind: "scalar", localName: "ColumnType", jsonName: "ColumnType", T: 9 /*ScalarType.STRING*/ },
|
|
{ no: 13, name: "IsQueryable", kind: "scalar", localName: "IsQueryable", jsonName: "IsQueryable", T: 8 /*ScalarType.BOOL*/ }
|
|
]);
|
|
}
|
|
create(value?: PartialMessage<Kpi>): Kpi {
|
|
const message = globalThis.Object.create((this.messagePrototype!));
|
|
message.Name = "";
|
|
message.Level = "";
|
|
message.DataType = "";
|
|
message.ContentType = "";
|
|
message.EnumValues = "";
|
|
message.Expressions = [];
|
|
message.FullName = "";
|
|
message.IsComputed = false;
|
|
message.GroupToJoin = "";
|
|
message.ColumnType = "";
|
|
message.IsQueryable = false;
|
|
if (value !== undefined)
|
|
reflectionMergePartial<Kpi>(this, message, value);
|
|
return message;
|
|
}
|
|
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: Kpi): Kpi {
|
|
let message = target ?? this.create(), end = reader.pos + length;
|
|
while (reader.pos < end) {
|
|
let [fieldNo, wireType] = reader.tag();
|
|
switch (fieldNo) {
|
|
case /* string Name */ 1:
|
|
message.Name = reader.string();
|
|
break;
|
|
case /* string Level */ 2:
|
|
message.Level = reader.string();
|
|
break;
|
|
case /* string DataType */ 4:
|
|
message.DataType = reader.string();
|
|
break;
|
|
case /* string ContentType */ 5:
|
|
message.ContentType = reader.string();
|
|
break;
|
|
case /* string EnumValues */ 6:
|
|
message.EnumValues = reader.string();
|
|
break;
|
|
case /* repeated api.KpiExpression Expressions */ 7:
|
|
message.Expressions.push(KpiExpression.internalBinaryRead(reader, reader.uint32(), options));
|
|
break;
|
|
case /* string FullName */ 8:
|
|
message.FullName = reader.string();
|
|
break;
|
|
case /* bool IsComputed */ 9:
|
|
message.IsComputed = reader.bool();
|
|
break;
|
|
case /* string GroupToJoin */ 11:
|
|
message.GroupToJoin = reader.string();
|
|
break;
|
|
case /* string ColumnType */ 12:
|
|
message.ColumnType = reader.string();
|
|
break;
|
|
case /* bool IsQueryable */ 13:
|
|
message.IsQueryable = reader.bool();
|
|
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: Kpi, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
|
|
/* string Name = 1; */
|
|
if (message.Name !== "")
|
|
writer.tag(1, WireType.LengthDelimited).string(message.Name);
|
|
/* string Level = 2; */
|
|
if (message.Level !== "")
|
|
writer.tag(2, WireType.LengthDelimited).string(message.Level);
|
|
/* string DataType = 4; */
|
|
if (message.DataType !== "")
|
|
writer.tag(4, WireType.LengthDelimited).string(message.DataType);
|
|
/* string ContentType = 5; */
|
|
if (message.ContentType !== "")
|
|
writer.tag(5, WireType.LengthDelimited).string(message.ContentType);
|
|
/* string EnumValues = 6; */
|
|
if (message.EnumValues !== "")
|
|
writer.tag(6, WireType.LengthDelimited).string(message.EnumValues);
|
|
/* repeated api.KpiExpression Expressions = 7; */
|
|
for (let i = 0; i < message.Expressions.length; i++)
|
|
KpiExpression.internalBinaryWrite(message.Expressions[i], writer.tag(7, WireType.LengthDelimited).fork(), options).join();
|
|
/* string FullName = 8; */
|
|
if (message.FullName !== "")
|
|
writer.tag(8, WireType.LengthDelimited).string(message.FullName);
|
|
/* bool IsComputed = 9; */
|
|
if (message.IsComputed !== false)
|
|
writer.tag(9, WireType.Varint).bool(message.IsComputed);
|
|
/* string GroupToJoin = 11; */
|
|
if (message.GroupToJoin !== "")
|
|
writer.tag(11, WireType.LengthDelimited).string(message.GroupToJoin);
|
|
/* string ColumnType = 12; */
|
|
if (message.ColumnType !== "")
|
|
writer.tag(12, WireType.LengthDelimited).string(message.ColumnType);
|
|
/* bool IsQueryable = 13; */
|
|
if (message.IsQueryable !== false)
|
|
writer.tag(13, WireType.Varint).bool(message.IsQueryable);
|
|
let u = options.writeUnknownFields;
|
|
if (u !== false)
|
|
(u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
|
|
return writer;
|
|
}
|
|
}
|
|
/**
|
|
* @generated MessageType for protobuf message api.Kpi
|
|
*/
|
|
export const Kpi = new Kpi$Type();
|
|
// @generated message type with reflection information, may provide speed optimized methods
|
|
class KpiExpression$Type extends MessageType<KpiExpression> {
|
|
constructor() {
|
|
super("api.KpiExpression", [
|
|
{ no: 1, name: "Block", kind: "scalar", localName: "Block", jsonName: "Block", T: 9 /*ScalarType.STRING*/ },
|
|
{ no: 2, name: "QueryType", kind: "scalar", localName: "QueryType", jsonName: "QueryType", T: 9 /*ScalarType.STRING*/ },
|
|
{ no: 3, name: "Field", kind: "scalar", localName: "Field", jsonName: "Field", T: 9 /*ScalarType.STRING*/ },
|
|
{ no: 4, name: "Query", kind: "scalar", localName: "Query", jsonName: "Query", T: 9 /*ScalarType.STRING*/ }
|
|
]);
|
|
}
|
|
create(value?: PartialMessage<KpiExpression>): KpiExpression {
|
|
const message = globalThis.Object.create((this.messagePrototype!));
|
|
message.Block = "";
|
|
message.QueryType = "";
|
|
message.Field = "";
|
|
message.Query = "";
|
|
if (value !== undefined)
|
|
reflectionMergePartial<KpiExpression>(this, message, value);
|
|
return message;
|
|
}
|
|
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: KpiExpression): KpiExpression {
|
|
let message = target ?? this.create(), end = reader.pos + length;
|
|
while (reader.pos < end) {
|
|
let [fieldNo, wireType] = reader.tag();
|
|
switch (fieldNo) {
|
|
case /* string Block */ 1:
|
|
message.Block = reader.string();
|
|
break;
|
|
case /* string QueryType */ 2:
|
|
message.QueryType = reader.string();
|
|
break;
|
|
case /* string Field */ 3:
|
|
message.Field = reader.string();
|
|
break;
|
|
case /* string Query */ 4:
|
|
message.Query = 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: KpiExpression, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
|
|
/* string Block = 1; */
|
|
if (message.Block !== "")
|
|
writer.tag(1, WireType.LengthDelimited).string(message.Block);
|
|
/* string QueryType = 2; */
|
|
if (message.QueryType !== "")
|
|
writer.tag(2, WireType.LengthDelimited).string(message.QueryType);
|
|
/* string Field = 3; */
|
|
if (message.Field !== "")
|
|
writer.tag(3, WireType.LengthDelimited).string(message.Field);
|
|
/* string Query = 4; */
|
|
if (message.Query !== "")
|
|
writer.tag(4, WireType.LengthDelimited).string(message.Query);
|
|
let u = options.writeUnknownFields;
|
|
if (u !== false)
|
|
(u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
|
|
return writer;
|
|
}
|
|
}
|
|
/**
|
|
* @generated MessageType for protobuf message api.KpiExpression
|
|
*/
|
|
export const KpiExpression = new KpiExpression$Type();
|
|
// @generated message type with reflection information, may provide speed optimized methods
|
|
class GetKpisRequest$Type extends MessageType<GetKpisRequest> {
|
|
constructor() {
|
|
super("api.GetKpisRequest", [
|
|
{ no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => RequestProjectHeader, options: { "validate.rules": { message: { required: true } } } },
|
|
{ no: 2, name: "Domain", kind: "scalar", localName: "Domain", jsonName: "Domain", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { in: ["trade", "collab"] } }, "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { default: "trade" } } },
|
|
{ no: 3, name: "Group", kind: "scalar", localName: "Group", jsonName: "Group", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { in: ["executionflow", "stock", "movement", "handlingunit", "actor", "item", "stock_extended", "claim"] } }, "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Widget analysis criterion, executionflow, stock, movement or handlingunit", example: "\"executionflow\"" } } },
|
|
{ no: 4, name: "isMetric", kind: "scalar", T: 8 /*ScalarType.BOOL*/ },
|
|
{ no: 5, name: "isDimension", kind: "scalar", T: 8 /*ScalarType.BOOL*/ },
|
|
{ no: 6, name: "isDate", kind: "scalar", T: 8 /*ScalarType.BOOL*/ },
|
|
{ no: 7, name: "isCount", kind: "scalar", T: 8 /*ScalarType.BOOL*/ },
|
|
{ no: 8, name: "OnlyQueryable", kind: "scalar", localName: "OnlyQueryable", jsonName: "OnlyQueryable", T: 8 /*ScalarType.BOOL*/ }
|
|
], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["Header"] } } });
|
|
}
|
|
create(value?: PartialMessage<GetKpisRequest>): GetKpisRequest {
|
|
const message = globalThis.Object.create((this.messagePrototype!));
|
|
message.Domain = "";
|
|
message.Group = "";
|
|
message.isMetric = false;
|
|
message.isDimension = false;
|
|
message.isDate = false;
|
|
message.isCount = false;
|
|
message.OnlyQueryable = false;
|
|
if (value !== undefined)
|
|
reflectionMergePartial<GetKpisRequest>(this, message, value);
|
|
return message;
|
|
}
|
|
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: GetKpisRequest): GetKpisRequest {
|
|
let message = target ?? this.create(), end = reader.pos + length;
|
|
while (reader.pos < end) {
|
|
let [fieldNo, wireType] = reader.tag();
|
|
switch (fieldNo) {
|
|
case /* api.RequestProjectHeader Header */ 1:
|
|
message.Header = RequestProjectHeader.internalBinaryRead(reader, reader.uint32(), options, message.Header);
|
|
break;
|
|
case /* string Domain */ 2:
|
|
message.Domain = reader.string();
|
|
break;
|
|
case /* string Group */ 3:
|
|
message.Group = reader.string();
|
|
break;
|
|
case /* bool isMetric */ 4:
|
|
message.isMetric = reader.bool();
|
|
break;
|
|
case /* bool isDimension */ 5:
|
|
message.isDimension = reader.bool();
|
|
break;
|
|
case /* bool isDate */ 6:
|
|
message.isDate = reader.bool();
|
|
break;
|
|
case /* bool isCount */ 7:
|
|
message.isCount = reader.bool();
|
|
break;
|
|
case /* bool OnlyQueryable */ 8:
|
|
message.OnlyQueryable = reader.bool();
|
|
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: GetKpisRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
|
|
/* api.RequestProjectHeader Header = 1; */
|
|
if (message.Header)
|
|
RequestProjectHeader.internalBinaryWrite(message.Header, writer.tag(1, WireType.LengthDelimited).fork(), options).join();
|
|
/* string Domain = 2; */
|
|
if (message.Domain !== "")
|
|
writer.tag(2, WireType.LengthDelimited).string(message.Domain);
|
|
/* string Group = 3; */
|
|
if (message.Group !== "")
|
|
writer.tag(3, WireType.LengthDelimited).string(message.Group);
|
|
/* bool isMetric = 4; */
|
|
if (message.isMetric !== false)
|
|
writer.tag(4, WireType.Varint).bool(message.isMetric);
|
|
/* bool isDimension = 5; */
|
|
if (message.isDimension !== false)
|
|
writer.tag(5, WireType.Varint).bool(message.isDimension);
|
|
/* bool isDate = 6; */
|
|
if (message.isDate !== false)
|
|
writer.tag(6, WireType.Varint).bool(message.isDate);
|
|
/* bool isCount = 7; */
|
|
if (message.isCount !== false)
|
|
writer.tag(7, WireType.Varint).bool(message.isCount);
|
|
/* bool OnlyQueryable = 8; */
|
|
if (message.OnlyQueryable !== false)
|
|
writer.tag(8, WireType.Varint).bool(message.OnlyQueryable);
|
|
let u = options.writeUnknownFields;
|
|
if (u !== false)
|
|
(u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
|
|
return writer;
|
|
}
|
|
}
|
|
/**
|
|
* @generated MessageType for protobuf message api.GetKpisRequest
|
|
*/
|
|
export const GetKpisRequest = new GetKpisRequest$Type();
|
|
// @generated message type with reflection information, may provide speed optimized methods
|
|
class GetKpisResult$Type extends MessageType<GetKpisResult> {
|
|
constructor() {
|
|
super("api.GetKpisResult", [
|
|
{ no: 1, name: "Kpis", kind: "message", localName: "Kpis", jsonName: "Kpis", repeat: 2 /*RepeatType.UNPACKED*/, T: () => Kpi }
|
|
]);
|
|
}
|
|
create(value?: PartialMessage<GetKpisResult>): GetKpisResult {
|
|
const message = globalThis.Object.create((this.messagePrototype!));
|
|
message.Kpis = [];
|
|
if (value !== undefined)
|
|
reflectionMergePartial<GetKpisResult>(this, message, value);
|
|
return message;
|
|
}
|
|
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: GetKpisResult): GetKpisResult {
|
|
let message = target ?? this.create(), end = reader.pos + length;
|
|
while (reader.pos < end) {
|
|
let [fieldNo, wireType] = reader.tag();
|
|
switch (fieldNo) {
|
|
case /* repeated api.Kpi Kpis */ 1:
|
|
message.Kpis.push(Kpi.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: GetKpisResult, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
|
|
/* repeated api.Kpi Kpis = 1; */
|
|
for (let i = 0; i < message.Kpis.length; i++)
|
|
Kpi.internalBinaryWrite(message.Kpis[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 api.GetKpisResult
|
|
*/
|
|
export const GetKpisResult = new GetKpisResult$Type();
|
|
// @generated message type with reflection information, may provide speed optimized methods
|
|
class GetKpiTableStructureRequest$Type extends MessageType<GetKpiTableStructureRequest> {
|
|
constructor() {
|
|
super("api.GetKpiTableStructureRequest", [
|
|
{ no: 1, name: "RscID", kind: "scalar", localName: "RscID", jsonName: "RscID", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } },
|
|
{ no: 2, name: "Domain", kind: "scalar", localName: "Domain", jsonName: "Domain", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { in: ["trade", "collab", "core"] } }, "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { default: "trade" } } }
|
|
], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["RscID", "Domain"] } } });
|
|
}
|
|
create(value?: PartialMessage<GetKpiTableStructureRequest>): GetKpiTableStructureRequest {
|
|
const message = globalThis.Object.create((this.messagePrototype!));
|
|
message.RscID = "";
|
|
message.Domain = "";
|
|
if (value !== undefined)
|
|
reflectionMergePartial<GetKpiTableStructureRequest>(this, message, value);
|
|
return message;
|
|
}
|
|
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: GetKpiTableStructureRequest): GetKpiTableStructureRequest {
|
|
let message = target ?? this.create(), end = reader.pos + length;
|
|
while (reader.pos < end) {
|
|
let [fieldNo, wireType] = reader.tag();
|
|
switch (fieldNo) {
|
|
case /* string RscID */ 1:
|
|
message.RscID = reader.string();
|
|
break;
|
|
case /* string Domain */ 2:
|
|
message.Domain = 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: GetKpiTableStructureRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
|
|
/* string RscID = 1; */
|
|
if (message.RscID !== "")
|
|
writer.tag(1, WireType.LengthDelimited).string(message.RscID);
|
|
/* string Domain = 2; */
|
|
if (message.Domain !== "")
|
|
writer.tag(2, WireType.LengthDelimited).string(message.Domain);
|
|
let u = options.writeUnknownFields;
|
|
if (u !== false)
|
|
(u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
|
|
return writer;
|
|
}
|
|
}
|
|
/**
|
|
* @generated MessageType for protobuf message api.GetKpiTableStructureRequest
|
|
*/
|
|
export const GetKpiTableStructureRequest = new GetKpiTableStructureRequest$Type();
|
|
// @generated message type with reflection information, may provide speed optimized methods
|
|
class GetKpiTableStructureResult$Type extends MessageType<GetKpiTableStructureResult> {
|
|
constructor() {
|
|
super("api.GetKpiTableStructureResult", [
|
|
{ no: 1, name: "Tables", kind: "scalar", localName: "Tables", jsonName: "Tables", repeat: 2 /*RepeatType.UNPACKED*/, T: 9 /*ScalarType.STRING*/ }
|
|
]);
|
|
}
|
|
create(value?: PartialMessage<GetKpiTableStructureResult>): GetKpiTableStructureResult {
|
|
const message = globalThis.Object.create((this.messagePrototype!));
|
|
message.Tables = [];
|
|
if (value !== undefined)
|
|
reflectionMergePartial<GetKpiTableStructureResult>(this, message, value);
|
|
return message;
|
|
}
|
|
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: GetKpiTableStructureResult): GetKpiTableStructureResult {
|
|
let message = target ?? this.create(), end = reader.pos + length;
|
|
while (reader.pos < end) {
|
|
let [fieldNo, wireType] = reader.tag();
|
|
switch (fieldNo) {
|
|
case /* repeated string Tables */ 1:
|
|
message.Tables.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: GetKpiTableStructureResult, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
|
|
/* repeated string Tables = 1; */
|
|
for (let i = 0; i < message.Tables.length; i++)
|
|
writer.tag(1, WireType.LengthDelimited).string(message.Tables[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.GetKpiTableStructureResult
|
|
*/
|
|
export const GetKpiTableStructureResult = new GetKpiTableStructureResult$Type();
|
|
// @generated message type with reflection information, may provide speed optimized methods
|
|
class UpdateKpiTableStructureRequest$Type extends MessageType<UpdateKpiTableStructureRequest> {
|
|
constructor() {
|
|
super("api.UpdateKpiTableStructureRequest", [
|
|
{ no: 1, name: "RscID", kind: "scalar", localName: "RscID", jsonName: "RscID", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } },
|
|
{ no: 2, name: "Domain", kind: "scalar", localName: "Domain", jsonName: "Domain", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { in: ["trade", "collab", "core"] } }, "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { default: "trade" } } }
|
|
], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["RscID", "RscType", "Domain"] } } });
|
|
}
|
|
create(value?: PartialMessage<UpdateKpiTableStructureRequest>): UpdateKpiTableStructureRequest {
|
|
const message = globalThis.Object.create((this.messagePrototype!));
|
|
message.RscID = "";
|
|
message.Domain = "";
|
|
if (value !== undefined)
|
|
reflectionMergePartial<UpdateKpiTableStructureRequest>(this, message, value);
|
|
return message;
|
|
}
|
|
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: UpdateKpiTableStructureRequest): UpdateKpiTableStructureRequest {
|
|
let message = target ?? this.create(), end = reader.pos + length;
|
|
while (reader.pos < end) {
|
|
let [fieldNo, wireType] = reader.tag();
|
|
switch (fieldNo) {
|
|
case /* string RscID */ 1:
|
|
message.RscID = reader.string();
|
|
break;
|
|
case /* string Domain */ 2:
|
|
message.Domain = 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: UpdateKpiTableStructureRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
|
|
/* string RscID = 1; */
|
|
if (message.RscID !== "")
|
|
writer.tag(1, WireType.LengthDelimited).string(message.RscID);
|
|
/* string Domain = 2; */
|
|
if (message.Domain !== "")
|
|
writer.tag(2, WireType.LengthDelimited).string(message.Domain);
|
|
let u = options.writeUnknownFields;
|
|
if (u !== false)
|
|
(u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
|
|
return writer;
|
|
}
|
|
}
|
|
/**
|
|
* @generated MessageType for protobuf message api.UpdateKpiTableStructureRequest
|
|
*/
|
|
export const UpdateKpiTableStructureRequest = new UpdateKpiTableStructureRequest$Type();
|
|
// @generated message type with reflection information, may provide speed optimized methods
|
|
class UpdateKpiTableStructureResult$Type extends MessageType<UpdateKpiTableStructureResult> {
|
|
constructor() {
|
|
super("api.UpdateKpiTableStructureResult", []);
|
|
}
|
|
create(value?: PartialMessage<UpdateKpiTableStructureResult>): UpdateKpiTableStructureResult {
|
|
const message = globalThis.Object.create((this.messagePrototype!));
|
|
if (value !== undefined)
|
|
reflectionMergePartial<UpdateKpiTableStructureResult>(this, message, value);
|
|
return message;
|
|
}
|
|
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: UpdateKpiTableStructureResult): UpdateKpiTableStructureResult {
|
|
let message = target ?? this.create(), end = reader.pos + length;
|
|
while (reader.pos < end) {
|
|
let [fieldNo, wireType] = reader.tag();
|
|
switch (fieldNo) {
|
|
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: UpdateKpiTableStructureResult, 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 api.UpdateKpiTableStructureResult
|
|
*/
|
|
export const UpdateKpiTableStructureResult = new UpdateKpiTableStructureResult$Type();
|
|
// @generated message type with reflection information, may provide speed optimized methods
|
|
class GetKpiEntitiesRequest$Type extends MessageType<GetKpiEntitiesRequest> {
|
|
constructor() {
|
|
super("api.GetKpiEntitiesRequest", [
|
|
{ no: 1, name: "RscID", kind: "scalar", localName: "RscID", jsonName: "RscID", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } },
|
|
{ no: 2, name: "Domain", kind: "scalar", localName: "Domain", jsonName: "Domain", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { in: ["trade", "collab"] } }, "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { default: "trade" } } }
|
|
], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["RscID", "RscType", "Domain"] } } });
|
|
}
|
|
create(value?: PartialMessage<GetKpiEntitiesRequest>): GetKpiEntitiesRequest {
|
|
const message = globalThis.Object.create((this.messagePrototype!));
|
|
message.RscID = "";
|
|
message.Domain = "";
|
|
if (value !== undefined)
|
|
reflectionMergePartial<GetKpiEntitiesRequest>(this, message, value);
|
|
return message;
|
|
}
|
|
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: GetKpiEntitiesRequest): GetKpiEntitiesRequest {
|
|
let message = target ?? this.create(), end = reader.pos + length;
|
|
while (reader.pos < end) {
|
|
let [fieldNo, wireType] = reader.tag();
|
|
switch (fieldNo) {
|
|
case /* string RscID */ 1:
|
|
message.RscID = reader.string();
|
|
break;
|
|
case /* string Domain */ 2:
|
|
message.Domain = 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: GetKpiEntitiesRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
|
|
/* string RscID = 1; */
|
|
if (message.RscID !== "")
|
|
writer.tag(1, WireType.LengthDelimited).string(message.RscID);
|
|
/* string Domain = 2; */
|
|
if (message.Domain !== "")
|
|
writer.tag(2, WireType.LengthDelimited).string(message.Domain);
|
|
let u = options.writeUnknownFields;
|
|
if (u !== false)
|
|
(u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
|
|
return writer;
|
|
}
|
|
}
|
|
/**
|
|
* @generated MessageType for protobuf message api.GetKpiEntitiesRequest
|
|
*/
|
|
export const GetKpiEntitiesRequest = new GetKpiEntitiesRequest$Type();
|
|
// @generated message type with reflection information, may provide speed optimized methods
|
|
class GetKpiEntitiesResult$Type extends MessageType<GetKpiEntitiesResult> {
|
|
constructor() {
|
|
super("api.GetKpiEntitiesResult", [
|
|
{ no: 1, name: "Entities", kind: "scalar", localName: "Entities", jsonName: "Entities", repeat: 2 /*RepeatType.UNPACKED*/, T: 9 /*ScalarType.STRING*/ }
|
|
]);
|
|
}
|
|
create(value?: PartialMessage<GetKpiEntitiesResult>): GetKpiEntitiesResult {
|
|
const message = globalThis.Object.create((this.messagePrototype!));
|
|
message.Entities = [];
|
|
if (value !== undefined)
|
|
reflectionMergePartial<GetKpiEntitiesResult>(this, message, value);
|
|
return message;
|
|
}
|
|
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: GetKpiEntitiesResult): GetKpiEntitiesResult {
|
|
let message = target ?? this.create(), end = reader.pos + length;
|
|
while (reader.pos < end) {
|
|
let [fieldNo, wireType] = reader.tag();
|
|
switch (fieldNo) {
|
|
case /* repeated string Entities */ 1:
|
|
message.Entities.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: GetKpiEntitiesResult, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
|
|
/* repeated string Entities = 1; */
|
|
for (let i = 0; i < message.Entities.length; i++)
|
|
writer.tag(1, WireType.LengthDelimited).string(message.Entities[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.GetKpiEntitiesResult
|
|
*/
|
|
export const GetKpiEntitiesResult = new GetKpiEntitiesResult$Type();
|
|
// @generated message type with reflection information, may provide speed optimized methods
|
|
class ClearKpiEntityRequest$Type extends MessageType<ClearKpiEntityRequest> {
|
|
constructor() {
|
|
super("api.ClearKpiEntityRequest", [
|
|
{ no: 1, name: "RscID", kind: "scalar", localName: "RscID", jsonName: "RscID", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } },
|
|
{ no: 2, name: "Entity", kind: "enum", localName: "Entity", jsonName: "Entity", T: () => ["api.EntityType", EntityType], options: { "validate.rules": { enum: { definedOnly: true } } } }
|
|
], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["RscID", "RscType", "Domain"] } } });
|
|
}
|
|
create(value?: PartialMessage<ClearKpiEntityRequest>): ClearKpiEntityRequest {
|
|
const message = globalThis.Object.create((this.messagePrototype!));
|
|
message.RscID = "";
|
|
message.Entity = 0;
|
|
if (value !== undefined)
|
|
reflectionMergePartial<ClearKpiEntityRequest>(this, message, value);
|
|
return message;
|
|
}
|
|
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ClearKpiEntityRequest): ClearKpiEntityRequest {
|
|
let message = target ?? this.create(), end = reader.pos + length;
|
|
while (reader.pos < end) {
|
|
let [fieldNo, wireType] = reader.tag();
|
|
switch (fieldNo) {
|
|
case /* string RscID */ 1:
|
|
message.RscID = reader.string();
|
|
break;
|
|
case /* api.EntityType Entity */ 2:
|
|
message.Entity = reader.int32();
|
|
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: ClearKpiEntityRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
|
|
/* string RscID = 1; */
|
|
if (message.RscID !== "")
|
|
writer.tag(1, WireType.LengthDelimited).string(message.RscID);
|
|
/* api.EntityType Entity = 2; */
|
|
if (message.Entity !== 0)
|
|
writer.tag(2, WireType.Varint).int32(message.Entity);
|
|
let u = options.writeUnknownFields;
|
|
if (u !== false)
|
|
(u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
|
|
return writer;
|
|
}
|
|
}
|
|
/**
|
|
* @generated MessageType for protobuf message api.ClearKpiEntityRequest
|
|
*/
|
|
export const ClearKpiEntityRequest = new ClearKpiEntityRequest$Type();
|
|
// @generated message type with reflection information, may provide speed optimized methods
|
|
class ClearKpiEntityResult$Type extends MessageType<ClearKpiEntityResult> {
|
|
constructor() {
|
|
super("api.ClearKpiEntityResult", []);
|
|
}
|
|
create(value?: PartialMessage<ClearKpiEntityResult>): ClearKpiEntityResult {
|
|
const message = globalThis.Object.create((this.messagePrototype!));
|
|
if (value !== undefined)
|
|
reflectionMergePartial<ClearKpiEntityResult>(this, message, value);
|
|
return message;
|
|
}
|
|
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ClearKpiEntityResult): ClearKpiEntityResult {
|
|
let message = target ?? this.create(), end = reader.pos + length;
|
|
while (reader.pos < end) {
|
|
let [fieldNo, wireType] = reader.tag();
|
|
switch (fieldNo) {
|
|
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: ClearKpiEntityResult, 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 api.ClearKpiEntityResult
|
|
*/
|
|
export const ClearKpiEntityResult = new ClearKpiEntityResult$Type();
|
|
// @generated message type with reflection information, may provide speed optimized methods
|
|
class CreateMVRequest$Type extends MessageType<CreateMVRequest> {
|
|
constructor() {
|
|
super("api.CreateMVRequest", [
|
|
{ no: 1, name: "RscID", kind: "scalar", localName: "RscID", jsonName: "RscID", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } },
|
|
{ no: 2, name: "Domain", kind: "scalar", localName: "Domain", jsonName: "Domain", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { in: ["trade", "collab", "core"] } }, "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { default: "trade" } } }
|
|
], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["RscID", "Domain"] } } });
|
|
}
|
|
create(value?: PartialMessage<CreateMVRequest>): CreateMVRequest {
|
|
const message = globalThis.Object.create((this.messagePrototype!));
|
|
message.RscID = "";
|
|
message.Domain = "";
|
|
if (value !== undefined)
|
|
reflectionMergePartial<CreateMVRequest>(this, message, value);
|
|
return message;
|
|
}
|
|
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: CreateMVRequest): CreateMVRequest {
|
|
let message = target ?? this.create(), end = reader.pos + length;
|
|
while (reader.pos < end) {
|
|
let [fieldNo, wireType] = reader.tag();
|
|
switch (fieldNo) {
|
|
case /* string RscID */ 1:
|
|
message.RscID = reader.string();
|
|
break;
|
|
case /* string Domain */ 2:
|
|
message.Domain = 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: CreateMVRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
|
|
/* string RscID = 1; */
|
|
if (message.RscID !== "")
|
|
writer.tag(1, WireType.LengthDelimited).string(message.RscID);
|
|
/* string Domain = 2; */
|
|
if (message.Domain !== "")
|
|
writer.tag(2, WireType.LengthDelimited).string(message.Domain);
|
|
let u = options.writeUnknownFields;
|
|
if (u !== false)
|
|
(u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
|
|
return writer;
|
|
}
|
|
}
|
|
/**
|
|
* @generated MessageType for protobuf message api.CreateMVRequest
|
|
*/
|
|
export const CreateMVRequest = new CreateMVRequest$Type();
|
|
// @generated message type with reflection information, may provide speed optimized methods
|
|
class CreateMVResult$Type extends MessageType<CreateMVResult> {
|
|
constructor() {
|
|
super("api.CreateMVResult", []);
|
|
}
|
|
create(value?: PartialMessage<CreateMVResult>): CreateMVResult {
|
|
const message = globalThis.Object.create((this.messagePrototype!));
|
|
if (value !== undefined)
|
|
reflectionMergePartial<CreateMVResult>(this, message, value);
|
|
return message;
|
|
}
|
|
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: CreateMVResult): CreateMVResult {
|
|
let message = target ?? this.create(), end = reader.pos + length;
|
|
while (reader.pos < end) {
|
|
let [fieldNo, wireType] = reader.tag();
|
|
switch (fieldNo) {
|
|
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: CreateMVResult, 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 api.CreateMVResult
|
|
*/
|
|
export const CreateMVResult = new CreateMVResult$Type();
|
|
// @generated message type with reflection information, may provide speed optimized methods
|
|
class DropMVRequest$Type extends MessageType<DropMVRequest> {
|
|
constructor() {
|
|
super("api.DropMVRequest", [
|
|
{ no: 1, name: "RscID", kind: "scalar", localName: "RscID", jsonName: "RscID", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } },
|
|
{ no: 2, name: "Domain", kind: "scalar", localName: "Domain", jsonName: "Domain", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { in: ["trade", "collab", "core"] } }, "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { default: "trade" } } }
|
|
], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["RscID", "Domain"] } } });
|
|
}
|
|
create(value?: PartialMessage<DropMVRequest>): DropMVRequest {
|
|
const message = globalThis.Object.create((this.messagePrototype!));
|
|
message.RscID = "";
|
|
message.Domain = "";
|
|
if (value !== undefined)
|
|
reflectionMergePartial<DropMVRequest>(this, message, value);
|
|
return message;
|
|
}
|
|
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: DropMVRequest): DropMVRequest {
|
|
let message = target ?? this.create(), end = reader.pos + length;
|
|
while (reader.pos < end) {
|
|
let [fieldNo, wireType] = reader.tag();
|
|
switch (fieldNo) {
|
|
case /* string RscID */ 1:
|
|
message.RscID = reader.string();
|
|
break;
|
|
case /* string Domain */ 2:
|
|
message.Domain = 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: DropMVRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
|
|
/* string RscID = 1; */
|
|
if (message.RscID !== "")
|
|
writer.tag(1, WireType.LengthDelimited).string(message.RscID);
|
|
/* string Domain = 2; */
|
|
if (message.Domain !== "")
|
|
writer.tag(2, WireType.LengthDelimited).string(message.Domain);
|
|
let u = options.writeUnknownFields;
|
|
if (u !== false)
|
|
(u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
|
|
return writer;
|
|
}
|
|
}
|
|
/**
|
|
* @generated MessageType for protobuf message api.DropMVRequest
|
|
*/
|
|
export const DropMVRequest = new DropMVRequest$Type();
|
|
// @generated message type with reflection information, may provide speed optimized methods
|
|
class DropMVResult$Type extends MessageType<DropMVResult> {
|
|
constructor() {
|
|
super("api.DropMVResult", []);
|
|
}
|
|
create(value?: PartialMessage<DropMVResult>): DropMVResult {
|
|
const message = globalThis.Object.create((this.messagePrototype!));
|
|
if (value !== undefined)
|
|
reflectionMergePartial<DropMVResult>(this, message, value);
|
|
return message;
|
|
}
|
|
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: DropMVResult): DropMVResult {
|
|
let message = target ?? this.create(), end = reader.pos + length;
|
|
while (reader.pos < end) {
|
|
let [fieldNo, wireType] = reader.tag();
|
|
switch (fieldNo) {
|
|
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: DropMVResult, 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 api.DropMVResult
|
|
*/
|
|
export const DropMVResult = new DropMVResult$Type();
|
|
// @generated message type with reflection information, may provide speed optimized methods
|
|
class PopulateMVRequest$Type extends MessageType<PopulateMVRequest> {
|
|
constructor() {
|
|
super("api.PopulateMVRequest", [
|
|
{ no: 1, name: "RscID", kind: "scalar", localName: "RscID", jsonName: "RscID", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } },
|
|
{ no: 2, name: "Domain", kind: "scalar", localName: "Domain", jsonName: "Domain", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { in: ["trade", "collab", "core"] } }, "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { default: "trade" } } }
|
|
], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["RscID", "Domain"] } } });
|
|
}
|
|
create(value?: PartialMessage<PopulateMVRequest>): PopulateMVRequest {
|
|
const message = globalThis.Object.create((this.messagePrototype!));
|
|
message.RscID = "";
|
|
message.Domain = "";
|
|
if (value !== undefined)
|
|
reflectionMergePartial<PopulateMVRequest>(this, message, value);
|
|
return message;
|
|
}
|
|
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: PopulateMVRequest): PopulateMVRequest {
|
|
let message = target ?? this.create(), end = reader.pos + length;
|
|
while (reader.pos < end) {
|
|
let [fieldNo, wireType] = reader.tag();
|
|
switch (fieldNo) {
|
|
case /* string RscID */ 1:
|
|
message.RscID = reader.string();
|
|
break;
|
|
case /* string Domain */ 2:
|
|
message.Domain = 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: PopulateMVRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
|
|
/* string RscID = 1; */
|
|
if (message.RscID !== "")
|
|
writer.tag(1, WireType.LengthDelimited).string(message.RscID);
|
|
/* string Domain = 2; */
|
|
if (message.Domain !== "")
|
|
writer.tag(2, WireType.LengthDelimited).string(message.Domain);
|
|
let u = options.writeUnknownFields;
|
|
if (u !== false)
|
|
(u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
|
|
return writer;
|
|
}
|
|
}
|
|
/**
|
|
* @generated MessageType for protobuf message api.PopulateMVRequest
|
|
*/
|
|
export const PopulateMVRequest = new PopulateMVRequest$Type();
|
|
// @generated message type with reflection information, may provide speed optimized methods
|
|
class PopulateMVResult$Type extends MessageType<PopulateMVResult> {
|
|
constructor() {
|
|
super("api.PopulateMVResult", []);
|
|
}
|
|
create(value?: PartialMessage<PopulateMVResult>): PopulateMVResult {
|
|
const message = globalThis.Object.create((this.messagePrototype!));
|
|
if (value !== undefined)
|
|
reflectionMergePartial<PopulateMVResult>(this, message, value);
|
|
return message;
|
|
}
|
|
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: PopulateMVResult): PopulateMVResult {
|
|
let message = target ?? this.create(), end = reader.pos + length;
|
|
while (reader.pos < end) {
|
|
let [fieldNo, wireType] = reader.tag();
|
|
switch (fieldNo) {
|
|
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: PopulateMVResult, 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 api.PopulateMVResult
|
|
*/
|
|
export const PopulateMVResult = new PopulateMVResult$Type();
|
|
/**
|
|
* @generated ServiceType for protobuf service api.KpiService
|
|
*/
|
|
export const KpiService = new ServiceType("api.KpiService", [
|
|
{ name: "GetKpis", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["KPIs"], description: "Get the KPIs analysis possibilities" }, "api.rscType": "Project", "api.roles": "Platform.Project-KPI", "google.api.method_visibility": { restriction: "SDK" } }, I: GetKpisRequest, O: GetKpisResult },
|
|
{ name: "GetKpiTableStructure", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["KPIs"], description: "Get KPI Table structure" }, "api.rscType": "Platform", "api.roles": "Platform.Project-KPI", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: GetKpiTableStructureRequest, O: GetKpiTableStructureResult },
|
|
{ name: "UpdateKpiTableStructure", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["KPIs"], description: "Update KPI Table structure" }, "api.rscType": "Platform", "api.roles": "Platform.Project-KPI", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: UpdateKpiTableStructureRequest, O: UpdateKpiTableStructureResult },
|
|
{ name: "GetKpiEntities", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["KPIs"], description: "Get the entities with KPIs" }, "api.rscType": "Platform", "api.roles": "", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: GetKpiEntitiesRequest, O: GetKpiEntitiesResult },
|
|
{ name: "ClearKpiEntity", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["KPIs"], description: "Clear KPI data for a specific entity" }, "api.rscType": "Platform", "api.roles": "Platform.Project-KPI", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: ClearKpiEntityRequest, O: ClearKpiEntityResult },
|
|
{ name: "CreateMV", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["KPIs"], description: "Build materialized view for all kpi groups" }, "api.rscType": "Platform", "api.roles": "Platform.Project-KPI", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: CreateMVRequest, O: CreateMVResult },
|
|
{ name: "DropMV", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["KPIs"], description: "Clear materialized view for all kpi groups" }, "api.rscType": "Platform", "api.roles": "Platform.Project-KPI", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: DropMVRequest, O: DropMVResult },
|
|
{ name: "PopulateMV", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["KPIs"], description: "Insert data in materialized view for all kpi groups" }, "api.rscType": "Platform", "api.roles": "Platform.Project-KPI", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: PopulateMVRequest, O: PopulateMVResult }
|
|
], { "api.k8sService": "project-model-server" });
|