Files
npm-core-sdk/kpi.ts
2026-02-27 16:01:42 +00:00

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", "appointment"] } }, "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" });