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:29:28 +00:00
parent a484f7bf7c
commit 7f435dfb28
3 changed files with 16 additions and 289 deletions
Download Patch File Download Diff File Expand all files Collapse all files

247
workflow.ts
View File

@@ -462,50 +462,6 @@ export interface GetModuleWorkflowsResult {
*/
moduleWorkflows: ModuleWorkflow[];
}
/**
* @generated from protobuf message api.StartWorkflowStopIdleFlinkRequest
*/
export interface StartWorkflowStopIdleFlinkRequest {
/**
* @generated from protobuf field: string OrganisationId = 1 [json_name = "OrganisationId"];
*/
organisationId: string;
/**
* @generated from protobuf field: bool RunWakeUpFlink = 2 [json_name = "RunWakeUpFlink"];
*/
runWakeUpFlink: boolean;
}
/**
* @generated from protobuf message api.StartWorkflowStopIdleFlinkResult
*/
export interface StartWorkflowStopIdleFlinkResult {
/**
* @generated from protobuf field: api.WorkflowExecutionResult WorkflowExecution = 1 [json_name = "WorkflowExecution"];
*/
workflowExecution?: WorkflowExecutionResult;
/**
* @generated from protobuf field: api.WorkflowExecutionResult WakeUpFlinkWorkflowExecution = 2 [json_name = "WakeUpFlinkWorkflowExecution"];
*/
wakeUpFlinkWorkflowExecution?: WorkflowExecutionResult;
}
/**
* @generated from protobuf message api.StopWorkflowStopIdleFlinkRequest
*/
export interface StopWorkflowStopIdleFlinkRequest {
/**
* @generated from protobuf field: string OrganisationId = 1 [json_name = "OrganisationId"];
*/
organisationId: string;
/**
* @generated from protobuf field: bool RunWakeUpFlink = 2 [json_name = "RunWakeUpFlink"];
*/
runWakeUpFlink: boolean;
}
/**
* @generated from protobuf message api.StopWorkflowStopIdleFlinkResult
*/
export interface StopWorkflowStopIdleFlinkResult {
}
/**
* @generated from protobuf message api.StopWorkflowRequest
*/
@@ -2544,207 +2500,6 @@ class GetModuleWorkflowsResult$Type extends MessageType<GetModuleWorkflowsResult
*/
export const GetModuleWorkflowsResult = new GetModuleWorkflowsResult$Type();
// @generated message type with reflection information, may provide speed optimized methods
class StartWorkflowStopIdleFlinkRequest$Type extends MessageType<StartWorkflowStopIdleFlinkRequest> {
constructor() {
super("api.StartWorkflowStopIdleFlinkRequest", [
{ no: 1, name: "OrganisationId", kind: "scalar", jsonName: "OrganisationId", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } },
{ no: 2, name: "RunWakeUpFlink", kind: "scalar", jsonName: "RunWakeUpFlink", T: 8 /*ScalarType.BOOL*/ }
], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["OrganisationId"] } } });
}
create(value?: PartialMessage<StartWorkflowStopIdleFlinkRequest>): StartWorkflowStopIdleFlinkRequest {
const message = globalThis.Object.create((this.messagePrototype!));
message.organisationId = "";
message.runWakeUpFlink = false;
if (value !== undefined)
reflectionMergePartial<StartWorkflowStopIdleFlinkRequest>(this, message, value);
return message;
}
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: StartWorkflowStopIdleFlinkRequest): StartWorkflowStopIdleFlinkRequest {
let message = target ?? this.create(), end = reader.pos + length;
while (reader.pos < end) {
let [fieldNo, wireType] = reader.tag();
switch (fieldNo) {
case /* string OrganisationId = 1 [json_name = "OrganisationId"];*/ 1:
message.organisationId = reader.string();
break;
case /* bool RunWakeUpFlink = 2 [json_name = "RunWakeUpFlink"];*/ 2:
message.runWakeUpFlink = 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: StartWorkflowStopIdleFlinkRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
/* string OrganisationId = 1 [json_name = "OrganisationId"]; */
if (message.organisationId !== "")
writer.tag(1, WireType.LengthDelimited).string(message.organisationId);
/* bool RunWakeUpFlink = 2 [json_name = "RunWakeUpFlink"]; */
if (message.runWakeUpFlink !== false)
writer.tag(2, WireType.Varint).bool(message.runWakeUpFlink);
let u = options.writeUnknownFields;
if (u !== false)
(u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
return writer;
}
}
/**
* @generated MessageType for protobuf message api.StartWorkflowStopIdleFlinkRequest
*/
export const StartWorkflowStopIdleFlinkRequest = new StartWorkflowStopIdleFlinkRequest$Type();
// @generated message type with reflection information, may provide speed optimized methods
class StartWorkflowStopIdleFlinkResult$Type extends MessageType<StartWorkflowStopIdleFlinkResult> {
constructor() {
super("api.StartWorkflowStopIdleFlinkResult", [
{ no: 1, name: "WorkflowExecution", kind: "message", jsonName: "WorkflowExecution", T: () => WorkflowExecutionResult },
{ no: 2, name: "WakeUpFlinkWorkflowExecution", kind: "message", jsonName: "WakeUpFlinkWorkflowExecution", T: () => WorkflowExecutionResult }
]);
}
create(value?: PartialMessage<StartWorkflowStopIdleFlinkResult>): StartWorkflowStopIdleFlinkResult {
const message = globalThis.Object.create((this.messagePrototype!));
if (value !== undefined)
reflectionMergePartial<StartWorkflowStopIdleFlinkResult>(this, message, value);
return message;
}
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: StartWorkflowStopIdleFlinkResult): StartWorkflowStopIdleFlinkResult {
let message = target ?? this.create(), end = reader.pos + length;
while (reader.pos < end) {
let [fieldNo, wireType] = reader.tag();
switch (fieldNo) {
case /* api.WorkflowExecutionResult WorkflowExecution = 1 [json_name = "WorkflowExecution"];*/ 1:
message.workflowExecution = WorkflowExecutionResult.internalBinaryRead(reader, reader.uint32(), options, message.workflowExecution);
break;
case /* api.WorkflowExecutionResult WakeUpFlinkWorkflowExecution = 2 [json_name = "WakeUpFlinkWorkflowExecution"];*/ 2:
message.wakeUpFlinkWorkflowExecution = WorkflowExecutionResult.internalBinaryRead(reader, reader.uint32(), options, message.wakeUpFlinkWorkflowExecution);
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: StartWorkflowStopIdleFlinkResult, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
/* api.WorkflowExecutionResult WorkflowExecution = 1 [json_name = "WorkflowExecution"]; */
if (message.workflowExecution)
WorkflowExecutionResult.internalBinaryWrite(message.workflowExecution, writer.tag(1, WireType.LengthDelimited).fork(), options).join();
/* api.WorkflowExecutionResult WakeUpFlinkWorkflowExecution = 2 [json_name = "WakeUpFlinkWorkflowExecution"]; */
if (message.wakeUpFlinkWorkflowExecution)
WorkflowExecutionResult.internalBinaryWrite(message.wakeUpFlinkWorkflowExecution, writer.tag(2, WireType.LengthDelimited).fork(), options).join();
let u = options.writeUnknownFields;
if (u !== false)
(u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
return writer;
}
}
/**
* @generated MessageType for protobuf message api.StartWorkflowStopIdleFlinkResult
*/
export const StartWorkflowStopIdleFlinkResult = new StartWorkflowStopIdleFlinkResult$Type();
// @generated message type with reflection information, may provide speed optimized methods
class StopWorkflowStopIdleFlinkRequest$Type extends MessageType<StopWorkflowStopIdleFlinkRequest> {
constructor() {
super("api.StopWorkflowStopIdleFlinkRequest", [
{ no: 1, name: "OrganisationId", kind: "scalar", jsonName: "OrganisationId", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } },
{ no: 2, name: "RunWakeUpFlink", kind: "scalar", jsonName: "RunWakeUpFlink", T: 8 /*ScalarType.BOOL*/ }
], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["OrganisationId"] } } });
}
create(value?: PartialMessage<StopWorkflowStopIdleFlinkRequest>): StopWorkflowStopIdleFlinkRequest {
const message = globalThis.Object.create((this.messagePrototype!));
message.organisationId = "";
message.runWakeUpFlink = false;
if (value !== undefined)
reflectionMergePartial<StopWorkflowStopIdleFlinkRequest>(this, message, value);
return message;
}
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: StopWorkflowStopIdleFlinkRequest): StopWorkflowStopIdleFlinkRequest {
let message = target ?? this.create(), end = reader.pos + length;
while (reader.pos < end) {
let [fieldNo, wireType] = reader.tag();
switch (fieldNo) {
case /* string OrganisationId = 1 [json_name = "OrganisationId"];*/ 1:
message.organisationId = reader.string();
break;
case /* bool RunWakeUpFlink = 2 [json_name = "RunWakeUpFlink"];*/ 2:
message.runWakeUpFlink = 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: StopWorkflowStopIdleFlinkRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
/* string OrganisationId = 1 [json_name = "OrganisationId"]; */
if (message.organisationId !== "")
writer.tag(1, WireType.LengthDelimited).string(message.organisationId);
/* bool RunWakeUpFlink = 2 [json_name = "RunWakeUpFlink"]; */
if (message.runWakeUpFlink !== false)
writer.tag(2, WireType.Varint).bool(message.runWakeUpFlink);
let u = options.writeUnknownFields;
if (u !== false)
(u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
return writer;
}
}
/**
* @generated MessageType for protobuf message api.StopWorkflowStopIdleFlinkRequest
*/
export const StopWorkflowStopIdleFlinkRequest = new StopWorkflowStopIdleFlinkRequest$Type();
// @generated message type with reflection information, may provide speed optimized methods
class StopWorkflowStopIdleFlinkResult$Type extends MessageType<StopWorkflowStopIdleFlinkResult> {
constructor() {
super("api.StopWorkflowStopIdleFlinkResult", []);
}
create(value?: PartialMessage<StopWorkflowStopIdleFlinkResult>): StopWorkflowStopIdleFlinkResult {
const message = globalThis.Object.create((this.messagePrototype!));
if (value !== undefined)
reflectionMergePartial<StopWorkflowStopIdleFlinkResult>(this, message, value);
return message;
}
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: StopWorkflowStopIdleFlinkResult): StopWorkflowStopIdleFlinkResult {
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: StopWorkflowStopIdleFlinkResult, 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.StopWorkflowStopIdleFlinkResult
*/
export const StopWorkflowStopIdleFlinkResult = new StopWorkflowStopIdleFlinkResult$Type();
// @generated message type with reflection information, may provide speed optimized methods
class StopWorkflowRequest$Type extends MessageType<StopWorkflowRequest> {
constructor() {
super("api.StopWorkflowRequest", [
@@ -4171,8 +3926,6 @@ export const WorkflowService = new ServiceType("api.WorkflowService", [
{ name: "RegisterModuleWorkflows", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Workflow"], description: "Register module child workflows to be executed after or before a core workflow" }, "api.rscType": "Platform", "api.roles": "Platform.Workflow", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: RegisterModuleWorkflowsRequest, O: RegisterModuleWorkflowsResult },
{ name: "DeregisterModuleWorkflows", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Workflow"], description: "Deregister module child workflow" }, "api.rscType": "Platform", "api.roles": "Platform.Workflow", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: DeregisterModuleWorkflowsRequest, O: DeregisterModuleWorkflowsResult },
{ name: "GetModuleWorkflows", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Workflow"], description: "Get module child workflow for a workflow type" }, "api.rscType": "Platform", "api.roles": "Platform.Workflow", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: GetModuleWorkflowsRequest, O: GetModuleWorkflowsResult },
{ name: "StartWorkflowStopIdleFlink", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Workflow"], description: "Start a workflow which will periodically stop idle flink jobs for an organization" }, "api.rscType": "Platform", "api.roles": "Platform.Workflow", "google.api.method_visibility": { restriction: "HIDDEN" } }, I: StartWorkflowStopIdleFlinkRequest, O: StartWorkflowStopIdleFlinkResult },
{ name: "StopWorkflowStopIdleFlink", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Workflow"], description: "Stop the workflow wich will periodically stop idle flink jobs for an organization" }, "api.rscType": "Platform", "api.roles": "Platform.Workflow", "google.api.method_visibility": { restriction: "HIDDEN" } }, I: StopWorkflowStopIdleFlinkRequest, O: StopWorkflowStopIdleFlinkResult },
{ name: "StopWorkflow", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Workflow"], description: "Terminates a workflow execution" }, "api.rscType": "Platform", "api.roles": "Platform.Workflow", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: StopWorkflowRequest, O: StopWorkflowResult },
{ name: "StartWorkflowOptimizeClickhouse", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Workflow"], description: "Start a workflow which will periodically launch optimize clikhouse operation for all projects in the platform" }, "api.rscType": "Platform", "api.roles": "Platform.Workflow", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: StartWorkflowOptimizeClickhouseRequest, O: StartWorkflowOptimizeClickhouseResult },
{ name: "StartWorkflowCreateOrganisation", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Workflow"], description: "Start a workflow which will create an organisation" }, "api.rscType": "Platform", "api.roles": "Platform.Workflow", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: StartWorkflowCreateOrganisationRequest, O: StartWorkflowCreateOrganisationResult },