reflex-platform/npm-core-sdk
0
Fork 0
Code Pull Requests Projects Releases Wiki Activity

Latest generation

Browse Source
This commit is contained in:
ci core model
2025-03-20 10:05:56 +00:00
parent d14c71c05a
commit a484f7bf7c
187 changed files with 199 additions and 801 deletions
Download Patch File Download Diff File Expand all files Collapse all files

165
proj.ts
View File

@@ -1,4 +1,4 @@
// @generated by protobuf-ts 2.9.5
// @generated by protobuf-ts 2.9.6
// @generated from protobuf file "proj.proto" (package "api", syntax proto3)
// tslint:disable
import { ServiceType } from "@protobuf-ts/runtime-rpc";
@@ -11,8 +11,6 @@ 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 { RecoverType } from "./shared";
import { ModelDataSetEnum } from "./shared";
import { WorkflowExecutionResult } from "./shared";
import { User } from "./user";
import { Organisation } from "./org";
@@ -348,40 +346,6 @@ export interface DeleteProjectInDBRequest {
*/
export interface DeleteProjectInDBResult {
}
/**
* @generated from protobuf message api.StartRecoverDataStreamingJobRequest
*/
export interface StartRecoverDataStreamingJobRequest {
/**
* @generated from protobuf field: string ProjectID = 1 [json_name = "ProjectID"];
*/
projectID: string;
/**
* @generated from protobuf field: api.ModelDataSetEnum Entity = 2 [json_name = "Entity"];
*/
entity: ModelDataSetEnum;
/**
* @generated from protobuf field: api.RecoverType RecoveryType = 3 [json_name = "RecoveryType"];
*/
recoveryType: RecoverType;
/**
* @generated from protobuf field: int32 PartitionStart = 4 [json_name = "PartitionStart"];
*/
partitionStart: number;
/**
* @generated from protobuf field: int32 PartitionEnd = 5 [json_name = "PartitionEnd"];
*/
partitionEnd: number;
}
/**
* @generated from protobuf message api.StartRecoverDataStreamingJobResult
*/
export interface StartRecoverDataStreamingJobResult {
/**
* @generated from protobuf field: string ID = 1 [json_name = "ID"];
*/
iD: string;
}
/**
* @generated from protobuf message api.IDName
*/
@@ -1969,132 +1933,6 @@ class DeleteProjectInDBResult$Type extends MessageType<DeleteProjectInDBResult>
*/
export const DeleteProjectInDBResult = new DeleteProjectInDBResult$Type();
// @generated message type with reflection information, may provide speed optimized methods
class StartRecoverDataStreamingJobRequest$Type extends MessageType<StartRecoverDataStreamingJobRequest> {
constructor() {
super("api.StartRecoverDataStreamingJobRequest", [
{ no: 1, name: "ProjectID", kind: "scalar", jsonName: "ProjectID", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } },
{ no: 2, name: "Entity", kind: "enum", jsonName: "Entity", T: () => ["api.ModelDataSetEnum", ModelDataSetEnum] },
{ no: 3, name: "RecoveryType", kind: "enum", jsonName: "RecoveryType", T: () => ["api.RecoverType", RecoverType] },
{ no: 4, name: "PartitionStart", kind: "scalar", jsonName: "PartitionStart", T: 5 /*ScalarType.INT32*/ },
{ no: 5, name: "PartitionEnd", kind: "scalar", jsonName: "PartitionEnd", T: 5 /*ScalarType.INT32*/ }
], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["ProjectID", "Entity"] } } });
}
create(value?: PartialMessage<StartRecoverDataStreamingJobRequest>): StartRecoverDataStreamingJobRequest {
const message = globalThis.Object.create((this.messagePrototype!));
message.projectID = "";
message.entity = 0;
message.recoveryType = 0;
message.partitionStart = 0;
message.partitionEnd = 0;
if (value !== undefined)
reflectionMergePartial<StartRecoverDataStreamingJobRequest>(this, message, value);
return message;
}
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: StartRecoverDataStreamingJobRequest): StartRecoverDataStreamingJobRequest {
let message = target ?? this.create(), end = reader.pos + length;
while (reader.pos < end) {
let [fieldNo, wireType] = reader.tag();
switch (fieldNo) {
case /* string ProjectID = 1 [json_name = "ProjectID"];*/ 1:
message.projectID = reader.string();
break;
case /* api.ModelDataSetEnum Entity = 2 [json_name = "Entity"];*/ 2:
message.entity = reader.int32();
break;
case /* api.RecoverType RecoveryType = 3 [json_name = "RecoveryType"];*/ 3:
message.recoveryType = reader.int32();
break;
case /* int32 PartitionStart = 4 [json_name = "PartitionStart"];*/ 4:
message.partitionStart = reader.int32();
break;
case /* int32 PartitionEnd = 5 [json_name = "PartitionEnd"];*/ 5:
message.partitionEnd = 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: StartRecoverDataStreamingJobRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
/* string ProjectID = 1 [json_name = "ProjectID"]; */
if (message.projectID !== "")
writer.tag(1, WireType.LengthDelimited).string(message.projectID);
/* api.ModelDataSetEnum Entity = 2 [json_name = "Entity"]; */
if (message.entity !== 0)
writer.tag(2, WireType.Varint).int32(message.entity);
/* api.RecoverType RecoveryType = 3 [json_name = "RecoveryType"]; */
if (message.recoveryType !== 0)
writer.tag(3, WireType.Varint).int32(message.recoveryType);
/* int32 PartitionStart = 4 [json_name = "PartitionStart"]; */
if (message.partitionStart !== 0)
writer.tag(4, WireType.Varint).int32(message.partitionStart);
/* int32 PartitionEnd = 5 [json_name = "PartitionEnd"]; */
if (message.partitionEnd !== 0)
writer.tag(5, WireType.Varint).int32(message.partitionEnd);
let u = options.writeUnknownFields;
if (u !== false)
(u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
return writer;
}
}
/**
* @generated MessageType for protobuf message api.StartRecoverDataStreamingJobRequest
*/
export const StartRecoverDataStreamingJobRequest = new StartRecoverDataStreamingJobRequest$Type();
// @generated message type with reflection information, may provide speed optimized methods
class StartRecoverDataStreamingJobResult$Type extends MessageType<StartRecoverDataStreamingJobResult> {
constructor() {
super("api.StartRecoverDataStreamingJobResult", [
{ no: 1, name: "ID", kind: "scalar", jsonName: "ID", T: 9 /*ScalarType.STRING*/ }
]);
}
create(value?: PartialMessage<StartRecoverDataStreamingJobResult>): StartRecoverDataStreamingJobResult {
const message = globalThis.Object.create((this.messagePrototype!));
message.iD = "";
if (value !== undefined)
reflectionMergePartial<StartRecoverDataStreamingJobResult>(this, message, value);
return message;
}
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: StartRecoverDataStreamingJobResult): StartRecoverDataStreamingJobResult {
let message = target ?? this.create(), end = reader.pos + length;
while (reader.pos < end) {
let [fieldNo, wireType] = reader.tag();
switch (fieldNo) {
case /* string ID = 1 [json_name = "ID"];*/ 1:
message.iD = 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: StartRecoverDataStreamingJobResult, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
/* string ID = 1 [json_name = "ID"]; */
if (message.iD !== "")
writer.tag(1, WireType.LengthDelimited).string(message.iD);
let u = options.writeUnknownFields;
if (u !== false)
(u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
return writer;
}
}
/**
* @generated MessageType for protobuf message api.StartRecoverDataStreamingJobResult
*/
export const StartRecoverDataStreamingJobResult = new StartRecoverDataStreamingJobResult$Type();
// @generated message type with reflection information, may provide speed optimized methods
class IDName$Type extends MessageType<IDName> {
constructor() {
super("api.IDName", [
@@ -2587,6 +2425,5 @@ export const ProjectService = new ServiceType("api.ProjectService", [
{ name: "DeleteProjectInDB", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Project"], description: "Delete the project in database" }, "api.rscType": "Platform", "api.roles": "Platform.Project-Deletion", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: DeleteProjectInDBRequest, O: DeleteProjectInDBResult },
{ name: "DeleteCassandra", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Project"], description: "Delete Cassandra resources in connection with the project" }, "api.rscType": "Platform", "api.roles": "", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: DeleteCassandraRequest, O: DeleteCassandraResult },
{ name: "OptimizeClickhouse", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Project"], description: "Initiate an unscheduled merge of data parts for Clickhouse tables in connection with the project" }, "api.rscType": "Platform", "api.roles": "Platform.Project-Admin", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: OptimizeClickhouseRequest, O: OptimizeClickhouseResult },
{ name: "StartRecoverDataStreamingJob", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Streaming"], description: "Start recover data streaming job for the project" }, "api.rscType": "Platform", "api.roles": "Platform.Project-Admin", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: StartRecoverDataStreamingJobRequest, O: StartRecoverDataStreamingJobResult },
{ name: "CleanDeletedProjects", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Project"], description: "Clear deleted projects in database" }, "api.rscType": "Platform", "api.roles": "Platform.Project", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: CleanDeletedProjectsRequest, O: CleanDeletedProjectsResult }
], { "api.k8sService": "organisation-server", "api.roleManager": true, "api.resourceManager": true });