You've already forked npm-core-sdk
Compare commits
8 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
ac1691e671 | ||
|
|
701abbef8f | ||
|
|
c82bb6bc3a | ||
|
|
4f5050577f | ||
|
|
565fe9f8ba | ||
|
|
3e5995934c | ||
|
|
7d2265dee7 | ||
|
|
6b28d9aedb |
@@ -1,6 +1,6 @@
|
||||
{
|
||||
"name": "@reflex-platform/npm-core-sdk",
|
||||
"version": "1.15.0-SNAPSHOT-260629124922",
|
||||
"version": "1.14.1",
|
||||
"description": "npm libs from core model proto files",
|
||||
"homepage": "",
|
||||
"main": "index.ts",
|
||||
|
||||
12
shared.ts
12
shared.ts
@@ -2493,10 +2493,8 @@ export enum WorkflowTypeEnum {
|
||||
*/
|
||||
CHECK_AND_LAUNCH_RECOVER_DATA = 24,
|
||||
/**
|
||||
* @generated from protobuf enum value: SYNCHRONIZE_RULES_ON_GIT = 25;
|
||||
*/
|
||||
SYNCHRONIZE_RULES_ON_GIT = 25,
|
||||
/**
|
||||
* SYNCHRONIZE_RULES_ON_GIT = 25; deprecated
|
||||
*
|
||||
* @generated from protobuf enum value: ANONYMIZE_DATA = 26;
|
||||
*/
|
||||
ANONYMIZE_DATA = 26,
|
||||
@@ -2555,10 +2553,8 @@ export enum WorkflowSemaphore {
|
||||
*/
|
||||
WS_RECOVER_DATA = 2,
|
||||
/**
|
||||
* @generated from protobuf enum value: WS_SYNCHRONIZE_RULES = 3;
|
||||
*/
|
||||
WS_SYNCHRONIZE_RULES = 3,
|
||||
/**
|
||||
* WS_SYNCHRONIZE_RULES = 3; deprecated
|
||||
*
|
||||
* @generated from protobuf enum value: WS_CHECK_AND_LAUNCH_RECOVER_DATA = 4;
|
||||
*/
|
||||
WS_CHECK_AND_LAUNCH_RECOVER_DATA = 4,
|
||||
|
||||
@@ -18,8 +18,6 @@ import type { StartWorkflowUpgradeModelResult } from "./workflow";
|
||||
import type { StartWorkflowUpgradeModelRequest } from "./workflow";
|
||||
import type { StartWorkflowAnonymizeDataResult } from "./workflow";
|
||||
import type { StartWorkflowAnonymizeDataRequest } from "./workflow";
|
||||
import type { StartWorkflowSynchronizeRulesOnGitResult } from "./workflow";
|
||||
import type { StartWorkflowSynchronizeRulesOnGitRequest } from "./workflow";
|
||||
import type { StartWorkflowPruneDataResult } from "./workflow";
|
||||
import type { StartWorkflowPruneDataRequest } from "./workflow";
|
||||
import type { StartWorkflowExtractKPIResult } from "./workflow";
|
||||
@@ -182,10 +180,6 @@ export interface IWorkflowServiceClient {
|
||||
* @generated from protobuf rpc: StartWorkflowPruneData
|
||||
*/
|
||||
startWorkflowPruneData(input: StartWorkflowPruneDataRequest, options?: RpcOptions): UnaryCall<StartWorkflowPruneDataRequest, StartWorkflowPruneDataResult>;
|
||||
/**
|
||||
* @generated from protobuf rpc: StartWorkflowSynchronizeRulesOnGit
|
||||
*/
|
||||
startWorkflowSynchronizeRulesOnGit(input: StartWorkflowSynchronizeRulesOnGitRequest, options?: RpcOptions): UnaryCall<StartWorkflowSynchronizeRulesOnGitRequest, StartWorkflowSynchronizeRulesOnGitResult>;
|
||||
/**
|
||||
* @generated from protobuf rpc: StartWorkflowAnonymizeData
|
||||
*/
|
||||
@@ -406,60 +400,53 @@ export class WorkflowServiceClient implements IWorkflowServiceClient, ServiceInf
|
||||
const method = this.methods[25], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<StartWorkflowPruneDataRequest, StartWorkflowPruneDataResult>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
* @generated from protobuf rpc: StartWorkflowSynchronizeRulesOnGit
|
||||
*/
|
||||
startWorkflowSynchronizeRulesOnGit(input: StartWorkflowSynchronizeRulesOnGitRequest, options?: RpcOptions): UnaryCall<StartWorkflowSynchronizeRulesOnGitRequest, StartWorkflowSynchronizeRulesOnGitResult> {
|
||||
const method = this.methods[26], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<StartWorkflowSynchronizeRulesOnGitRequest, StartWorkflowSynchronizeRulesOnGitResult>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
* @generated from protobuf rpc: StartWorkflowAnonymizeData
|
||||
*/
|
||||
startWorkflowAnonymizeData(input: StartWorkflowAnonymizeDataRequest, options?: RpcOptions): UnaryCall<StartWorkflowAnonymizeDataRequest, StartWorkflowAnonymizeDataResult> {
|
||||
const method = this.methods[27], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[26], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<StartWorkflowAnonymizeDataRequest, StartWorkflowAnonymizeDataResult>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
* @generated from protobuf rpc: StartWorkflowUpgradeModel
|
||||
*/
|
||||
startWorkflowUpgradeModel(input: StartWorkflowUpgradeModelRequest, options?: RpcOptions): UnaryCall<StartWorkflowUpgradeModelRequest, StartWorkflowUpgradeModelResult> {
|
||||
const method = this.methods[28], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[27], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<StartWorkflowUpgradeModelRequest, StartWorkflowUpgradeModelResult>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
* @generated from protobuf rpc: StartWorkflowSweep
|
||||
*/
|
||||
startWorkflowSweep(input: StartWorkflowSweepRequest, options?: RpcOptions): UnaryCall<StartWorkflowSweepRequest, StartWorkflowSweepResult> {
|
||||
const method = this.methods[29], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[28], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<StartWorkflowSweepRequest, StartWorkflowSweepResult>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
* @generated from protobuf rpc: StartWorkflowCreateClickhouse
|
||||
*/
|
||||
startWorkflowCreateClickhouse(input: StartWorkflowCreateClickhouseRequest, options?: RpcOptions): UnaryCall<StartWorkflowCreateClickhouseRequest, StartWorkflowCreateClickhouseResult> {
|
||||
const method = this.methods[30], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[29], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<StartWorkflowCreateClickhouseRequest, StartWorkflowCreateClickhouseResult>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
* @generated from protobuf rpc: StartWorkflowDeleteClickhouse
|
||||
*/
|
||||
startWorkflowDeleteClickhouse(input: StartWorkflowDeleteClickhouseRequest, options?: RpcOptions): UnaryCall<StartWorkflowDeleteClickhouseRequest, StartWorkflowDeleteClickhouseResult> {
|
||||
const method = this.methods[31], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[30], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<StartWorkflowDeleteClickhouseRequest, StartWorkflowDeleteClickhouseResult>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
* @generated from protobuf rpc: StartWorkflowCleanCassandra
|
||||
*/
|
||||
startWorkflowCleanCassandra(input: StartWorkflowCleanCassandraRequest, options?: RpcOptions): UnaryCall<StartWorkflowCleanCassandraRequest, StartWorkflowCleanCassandraResult> {
|
||||
const method = this.methods[32], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[31], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<StartWorkflowCleanCassandraRequest, StartWorkflowCleanCassandraResult>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
* @generated from protobuf rpc: StartWorkflowSynchronizeUMAStore
|
||||
*/
|
||||
startWorkflowSynchronizeUMAStore(input: StartWorkflowSynchronizeUMAStoreRequest, options?: RpcOptions): UnaryCall<StartWorkflowSynchronizeUMAStoreRequest, StartWorkflowSynchronizeUMAStoreResult> {
|
||||
const method = this.methods[33], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[32], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<StartWorkflowSynchronizeUMAStoreRequest, StartWorkflowSynchronizeUMAStoreResult>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
}
|
||||
|
||||
99
workflow.ts
99
workflow.ts
@@ -841,20 +841,6 @@ export interface StartWorkflowPruneDataResult {
|
||||
*/
|
||||
WorkflowExecution?: WorkflowExecutionResult;
|
||||
}
|
||||
/**
|
||||
* @generated from protobuf message api.StartWorkflowSynchronizeRulesOnGitRequest
|
||||
*/
|
||||
export interface StartWorkflowSynchronizeRulesOnGitRequest {
|
||||
}
|
||||
/**
|
||||
* @generated from protobuf message api.StartWorkflowSynchronizeRulesOnGitResult
|
||||
*/
|
||||
export interface StartWorkflowSynchronizeRulesOnGitResult {
|
||||
/**
|
||||
* @generated from protobuf field: api.WorkflowExecutionResult WorkflowExecution = 1
|
||||
*/
|
||||
WorkflowExecution?: WorkflowExecutionResult;
|
||||
}
|
||||
/**
|
||||
* @generated from protobuf message api.StartWorkflowAnonymizeDataRequest
|
||||
*/
|
||||
@@ -4224,90 +4210,6 @@ class StartWorkflowPruneDataResult$Type extends MessageType<StartWorkflowPruneDa
|
||||
*/
|
||||
export const StartWorkflowPruneDataResult = new StartWorkflowPruneDataResult$Type();
|
||||
// @generated message type with reflection information, may provide speed optimized methods
|
||||
class StartWorkflowSynchronizeRulesOnGitRequest$Type extends MessageType<StartWorkflowSynchronizeRulesOnGitRequest> {
|
||||
constructor() {
|
||||
super("api.StartWorkflowSynchronizeRulesOnGitRequest", [], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: {} } });
|
||||
}
|
||||
create(value?: PartialMessage<StartWorkflowSynchronizeRulesOnGitRequest>): StartWorkflowSynchronizeRulesOnGitRequest {
|
||||
const message = globalThis.Object.create((this.messagePrototype!));
|
||||
if (value !== undefined)
|
||||
reflectionMergePartial<StartWorkflowSynchronizeRulesOnGitRequest>(this, message, value);
|
||||
return message;
|
||||
}
|
||||
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: StartWorkflowSynchronizeRulesOnGitRequest): StartWorkflowSynchronizeRulesOnGitRequest {
|
||||
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: StartWorkflowSynchronizeRulesOnGitRequest, 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.StartWorkflowSynchronizeRulesOnGitRequest
|
||||
*/
|
||||
export const StartWorkflowSynchronizeRulesOnGitRequest = new StartWorkflowSynchronizeRulesOnGitRequest$Type();
|
||||
// @generated message type with reflection information, may provide speed optimized methods
|
||||
class StartWorkflowSynchronizeRulesOnGitResult$Type extends MessageType<StartWorkflowSynchronizeRulesOnGitResult> {
|
||||
constructor() {
|
||||
super("api.StartWorkflowSynchronizeRulesOnGitResult", [
|
||||
{ no: 1, name: "WorkflowExecution", kind: "message", localName: "WorkflowExecution", jsonName: "WorkflowExecution", T: () => WorkflowExecutionResult }
|
||||
]);
|
||||
}
|
||||
create(value?: PartialMessage<StartWorkflowSynchronizeRulesOnGitResult>): StartWorkflowSynchronizeRulesOnGitResult {
|
||||
const message = globalThis.Object.create((this.messagePrototype!));
|
||||
if (value !== undefined)
|
||||
reflectionMergePartial<StartWorkflowSynchronizeRulesOnGitResult>(this, message, value);
|
||||
return message;
|
||||
}
|
||||
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: StartWorkflowSynchronizeRulesOnGitResult): StartWorkflowSynchronizeRulesOnGitResult {
|
||||
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:
|
||||
message.WorkflowExecution = WorkflowExecutionResult.internalBinaryRead(reader, reader.uint32(), options, message.WorkflowExecution);
|
||||
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: StartWorkflowSynchronizeRulesOnGitResult, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
|
||||
/* api.WorkflowExecutionResult WorkflowExecution = 1; */
|
||||
if (message.WorkflowExecution)
|
||||
WorkflowExecutionResult.internalBinaryWrite(message.WorkflowExecution, 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.StartWorkflowSynchronizeRulesOnGitResult
|
||||
*/
|
||||
export const StartWorkflowSynchronizeRulesOnGitResult = new StartWorkflowSynchronizeRulesOnGitResult$Type();
|
||||
// @generated message type with reflection information, may provide speed optimized methods
|
||||
class StartWorkflowAnonymizeDataRequest$Type extends MessageType<StartWorkflowAnonymizeDataRequest> {
|
||||
constructor() {
|
||||
super("api.StartWorkflowAnonymizeDataRequest", [
|
||||
@@ -5020,7 +4922,6 @@ export const WorkflowService = new ServiceType("api.WorkflowService", [
|
||||
{ name: "StartWorkflowHealthCheckWorkflows", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Workflow"], description: "Start a cron workflow to check health of workflows in the last day in all listed domains" }, "api.rscType": "Platform", "api.roles": "Platform.Workflow", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: StartWorkflowHealthCheckWorkflowsRequest, O: StartWorkflowHealthCheckWorkflowsResult },
|
||||
{ name: "StartWorkflowExtractKPI", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Workflow"], description: "Start a workflow to extract kpi" }, "api.rscType": "Platform", "api.roles": "Platform.Workflow", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: StartWorkflowExtractKPIRequest, O: StartWorkflowExtractKPIResult },
|
||||
{ name: "StartWorkflowPruneData", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Workflow"], description: "Start a workflow to prune project entity data." }, "api.rscType": "Platform", "api.roles": "Platform.Workflow", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: StartWorkflowPruneDataRequest, O: StartWorkflowPruneDataResult },
|
||||
{ name: "StartWorkflowSynchronizeRulesOnGit", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Workflow"], description: "Start a workflow to synchronize rules on git" }, "api.rscType": "Platform", "api.roles": "Platform.Workflow", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: StartWorkflowSynchronizeRulesOnGitRequest, O: StartWorkflowSynchronizeRulesOnGitResult },
|
||||
{ name: "StartWorkflowAnonymizeData", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Workflow"], description: "Start a workflow to anonymize project entity data." }, "api.rscType": "Platform", "api.roles": "Platform.Workflow", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: StartWorkflowAnonymizeDataRequest, O: StartWorkflowAnonymizeDataResult },
|
||||
{ name: "StartWorkflowUpgradeModel", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Workflow"], description: "Start a workflow to run upgrade script according to the model version." }, "api.rscType": "Platform", "api.roles": "Platform.Workflow", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: StartWorkflowUpgradeModelRequest, O: StartWorkflowUpgradeModelResult },
|
||||
{ name: "StartWorkflowSweep", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Workflow"], description: "Start a workflow to sweep the platform." }, "api.rscType": "Platform", "api.roles": "Platform.Workflow", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: StartWorkflowSweepRequest, O: StartWorkflowSweepResult },
|
||||
|
||||
Reference in New Issue
Block a user