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-08-22 13:50:54 +00:00
parent 67193ce0b4
commit 9dd9b7f364
5 changed files with 407 additions and 359 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
package.json
View File

@@ -1,6 +1,6 @@
{
"name": "@reflex-platform/npm-core-sdk",
"version": "1.11.0-SNAPSHOT-250822131607",
"version": "1.11.0-SNAPSHOT-250822135038",
"description": "npm libs from core model proto files",
"homepage": "",
"main": "index.ts",

49
proj.client.ts
View File

@@ -6,18 +6,12 @@ import type { ServiceInfo } from "@protobuf-ts/runtime-rpc";
import { ProjectService } from "./proj";
import type { CleanDeletedProjectsResult } from "./proj";
import type { CleanDeletedProjectsRequest } from "./proj";
import type { DeleteCassandraResult } from "./proj";
import type { DeleteCassandraRequest } from "./proj";
import type { DeleteProjectInDBResult } from "./proj";
import type { DeleteProjectInDBRequest } from "./proj";
import type { GetMyContextResult } from "./proj";
import type { GetMyContextRequest } from "./proj";
import type { SuggestProjectIDResult } from "./proj";
import type { SuggestProjectIDRequest } from "./proj";
import type { DeleteClickhouseResult } from "./proj";
import type { DeleteClickhouseRequest } from "./proj";
import type { CreateClickhouseResult } from "./proj";
import type { CreateClickhouseRequest } from "./proj";
import type { DeleteProjectResult } from "./proj";
import type { DeleteProjectRequest } from "./proj";
import type { UpdateProjectStatusResult } from "./proj";
@@ -73,14 +67,6 @@ export interface IProjectServiceClient {
* @generated from protobuf rpc: Delete
*/
delete(input: DeleteProjectRequest, options?: RpcOptions): UnaryCall<DeleteProjectRequest, DeleteProjectResult>;
/**
* @generated from protobuf rpc: CreateClickhouse
*/
createClickhouse(input: CreateClickhouseRequest, options?: RpcOptions): UnaryCall<CreateClickhouseRequest, CreateClickhouseResult>;
/**
* @generated from protobuf rpc: DeleteClickhouse
*/
deleteClickhouse(input: DeleteClickhouseRequest, options?: RpcOptions): UnaryCall<DeleteClickhouseRequest, DeleteClickhouseResult>;
/**
* @generated from protobuf rpc: SuggestID
*/
@@ -97,10 +83,6 @@ export interface IProjectServiceClient {
* @generated from protobuf rpc: DeleteProjectInDB
*/
deleteProjectInDB(input: DeleteProjectInDBRequest, options?: RpcOptions): UnaryCall<DeleteProjectInDBRequest, DeleteProjectInDBResult>;
/**
* @generated from protobuf rpc: DeleteCassandra
*/
deleteCassandra(input: DeleteCassandraRequest, options?: RpcOptions): UnaryCall<DeleteCassandraRequest, DeleteCassandraResult>;
/**
* @generated from protobuf rpc: CleanDeletedProjects
*/
@@ -171,60 +153,39 @@ export class ProjectServiceClient implements IProjectServiceClient, ServiceInfo
const method = this.methods[7], opt = this._transport.mergeOptions(options);
return stackIntercept<DeleteProjectRequest, DeleteProjectResult>("unary", this._transport, method, opt, input);
}
/**
* @generated from protobuf rpc: CreateClickhouse
*/
createClickhouse(input: CreateClickhouseRequest, options?: RpcOptions): UnaryCall<CreateClickhouseRequest, CreateClickhouseResult> {
const method = this.methods[8], opt = this._transport.mergeOptions(options);
return stackIntercept<CreateClickhouseRequest, CreateClickhouseResult>("unary", this._transport, method, opt, input);
}
/**
* @generated from protobuf rpc: DeleteClickhouse
*/
deleteClickhouse(input: DeleteClickhouseRequest, options?: RpcOptions): UnaryCall<DeleteClickhouseRequest, DeleteClickhouseResult> {
const method = this.methods[9], opt = this._transport.mergeOptions(options);
return stackIntercept<DeleteClickhouseRequest, DeleteClickhouseResult>("unary", this._transport, method, opt, input);
}
/**
* @generated from protobuf rpc: SuggestID
*/
suggestID(input: SuggestProjectIDRequest, options?: RpcOptions): UnaryCall<SuggestProjectIDRequest, SuggestProjectIDResult> {
const method = this.methods[10], opt = this._transport.mergeOptions(options);
const method = this.methods[8], opt = this._transport.mergeOptions(options);
return stackIntercept<SuggestProjectIDRequest, SuggestProjectIDResult>("unary", this._transport, method, opt, input);
}
/**
* @generated from protobuf rpc: GetMyUIContext
*/
getMyUIContext(input: GetMyContextRequest, options?: RpcOptions): UnaryCall<GetMyContextRequest, GetMyContextResult> {
const method = this.methods[11], opt = this._transport.mergeOptions(options);
const method = this.methods[9], opt = this._transport.mergeOptions(options);
return stackIntercept<GetMyContextRequest, GetMyContextResult>("unary", this._transport, method, opt, input);
}
/**
* @generated from protobuf rpc: GetMyContext
*/
getMyContext(input: GetMyContextRequest, options?: RpcOptions): UnaryCall<GetMyContextRequest, GetMyContextResult> {
const method = this.methods[12], opt = this._transport.mergeOptions(options);
const method = this.methods[10], opt = this._transport.mergeOptions(options);
return stackIntercept<GetMyContextRequest, GetMyContextResult>("unary", this._transport, method, opt, input);
}
/**
* @generated from protobuf rpc: DeleteProjectInDB
*/
deleteProjectInDB(input: DeleteProjectInDBRequest, options?: RpcOptions): UnaryCall<DeleteProjectInDBRequest, DeleteProjectInDBResult> {
const method = this.methods[13], opt = this._transport.mergeOptions(options);
const method = this.methods[11], opt = this._transport.mergeOptions(options);
return stackIntercept<DeleteProjectInDBRequest, DeleteProjectInDBResult>("unary", this._transport, method, opt, input);
}
/**
* @generated from protobuf rpc: DeleteCassandra
*/
deleteCassandra(input: DeleteCassandraRequest, options?: RpcOptions): UnaryCall<DeleteCassandraRequest, DeleteCassandraResult> {
const method = this.methods[14], opt = this._transport.mergeOptions(options);
return stackIntercept<DeleteCassandraRequest, DeleteCassandraResult>("unary", this._transport, method, opt, input);
}
/**
* @generated from protobuf rpc: CleanDeletedProjects
*/
cleanDeletedProjects(input: CleanDeletedProjectsRequest, options?: RpcOptions): UnaryCall<CleanDeletedProjectsRequest, CleanDeletedProjectsResult> {
const method = this.methods[15], opt = this._transport.mergeOptions(options);
const method = this.methods[12], opt = this._transport.mergeOptions(options);
return stackIntercept<CleanDeletedProjectsRequest, CleanDeletedProjectsResult>("unary", this._transport, method, opt, input);
}
}

313
proj.ts
View File

@@ -246,52 +246,6 @@ export interface SetModulesProjectResult {
*/
Result?: Project;
}
/**
* @generated from protobuf message api.CreateClickhouseRequest
*/
export interface CreateClickhouseRequest {
/**
* @generated from protobuf field: string ProjectID = 1
*/
ProjectID: string;
}
/**
* @generated from protobuf message api.CreateClickhouseResult
*/
export interface CreateClickhouseResult {
/**
* @generated from protobuf field: string ID = 1
*/
ID: string;
}
/**
* @generated from protobuf message api.DeleteCassandraRequest
*/
export interface DeleteCassandraRequest {
/**
* @generated from protobuf field: string ProjectID = 1
*/
ProjectID: string;
}
/**
* @generated from protobuf message api.DeleteClickhouseRequest
*/
export interface DeleteClickhouseRequest {
/**
* @generated from protobuf field: string ProjectID = 1
*/
ProjectID: string;
}
/**
* @generated from protobuf message api.DeleteCassandraResult
*/
export interface DeleteCassandraResult {
}
/**
* @generated from protobuf message api.DeleteClickhouseResult
*/
export interface DeleteClickhouseResult {
}
/**
* @generated from protobuf message api.SuggestProjectIDRequest
*/
@@ -1376,270 +1330,6 @@ class SetModulesProjectResult$Type extends MessageType<SetModulesProjectResult>
*/
export const SetModulesProjectResult = new SetModulesProjectResult$Type();
// @generated message type with reflection information, may provide speed optimized methods
class CreateClickhouseRequest$Type extends MessageType<CreateClickhouseRequest> {
constructor() {
super("api.CreateClickhouseRequest", [
{ no: 1, name: "ProjectID", kind: "scalar", localName: "ProjectID", jsonName: "ProjectID", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } }
], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["ProjectID"] } } });
}
create(value?: PartialMessage<CreateClickhouseRequest>): CreateClickhouseRequest {
const message = globalThis.Object.create((this.messagePrototype!));
message.ProjectID = "";
if (value !== undefined)
reflectionMergePartial<CreateClickhouseRequest>(this, message, value);
return message;
}
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: CreateClickhouseRequest): CreateClickhouseRequest {
let message = target ?? this.create(), end = reader.pos + length;
while (reader.pos < end) {
let [fieldNo, wireType] = reader.tag();
switch (fieldNo) {
case /* string ProjectID */ 1:
message.ProjectID = 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: CreateClickhouseRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
/* string ProjectID = 1; */
if (message.ProjectID !== "")
writer.tag(1, WireType.LengthDelimited).string(message.ProjectID);
let u = options.writeUnknownFields;
if (u !== false)
(u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
return writer;
}
}
/**
* @generated MessageType for protobuf message api.CreateClickhouseRequest
*/
export const CreateClickhouseRequest = new CreateClickhouseRequest$Type();
// @generated message type with reflection information, may provide speed optimized methods
class CreateClickhouseResult$Type extends MessageType<CreateClickhouseResult> {
constructor() {
super("api.CreateClickhouseResult", [
{ no: 1, name: "ID", kind: "scalar", localName: "ID", jsonName: "ID", T: 9 /*ScalarType.STRING*/ }
]);
}
create(value?: PartialMessage<CreateClickhouseResult>): CreateClickhouseResult {
const message = globalThis.Object.create((this.messagePrototype!));
message.ID = "";
if (value !== undefined)
reflectionMergePartial<CreateClickhouseResult>(this, message, value);
return message;
}
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: CreateClickhouseResult): CreateClickhouseResult {
let message = target ?? this.create(), end = reader.pos + length;
while (reader.pos < end) {
let [fieldNo, wireType] = reader.tag();
switch (fieldNo) {
case /* string 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: CreateClickhouseResult, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
/* string ID = 1; */
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.CreateClickhouseResult
*/
export const CreateClickhouseResult = new CreateClickhouseResult$Type();
// @generated message type with reflection information, may provide speed optimized methods
class DeleteCassandraRequest$Type extends MessageType<DeleteCassandraRequest> {
constructor() {
super("api.DeleteCassandraRequest", [
{ no: 1, name: "ProjectID", kind: "scalar", localName: "ProjectID", jsonName: "ProjectID", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } }
]);
}
create(value?: PartialMessage<DeleteCassandraRequest>): DeleteCassandraRequest {
const message = globalThis.Object.create((this.messagePrototype!));
message.ProjectID = "";
if (value !== undefined)
reflectionMergePartial<DeleteCassandraRequest>(this, message, value);
return message;
}
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: DeleteCassandraRequest): DeleteCassandraRequest {
let message = target ?? this.create(), end = reader.pos + length;
while (reader.pos < end) {
let [fieldNo, wireType] = reader.tag();
switch (fieldNo) {
case /* string ProjectID */ 1:
message.ProjectID = 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: DeleteCassandraRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
/* string ProjectID = 1; */
if (message.ProjectID !== "")
writer.tag(1, WireType.LengthDelimited).string(message.ProjectID);
let u = options.writeUnknownFields;
if (u !== false)
(u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
return writer;
}
}
/**
* @generated MessageType for protobuf message api.DeleteCassandraRequest
*/
export const DeleteCassandraRequest = new DeleteCassandraRequest$Type();
// @generated message type with reflection information, may provide speed optimized methods
class DeleteClickhouseRequest$Type extends MessageType<DeleteClickhouseRequest> {
constructor() {
super("api.DeleteClickhouseRequest", [
{ no: 1, name: "ProjectID", kind: "scalar", localName: "ProjectID", jsonName: "ProjectID", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } }
], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["ProjectID"] } } });
}
create(value?: PartialMessage<DeleteClickhouseRequest>): DeleteClickhouseRequest {
const message = globalThis.Object.create((this.messagePrototype!));
message.ProjectID = "";
if (value !== undefined)
reflectionMergePartial<DeleteClickhouseRequest>(this, message, value);
return message;
}
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: DeleteClickhouseRequest): DeleteClickhouseRequest {
let message = target ?? this.create(), end = reader.pos + length;
while (reader.pos < end) {
let [fieldNo, wireType] = reader.tag();
switch (fieldNo) {
case /* string ProjectID */ 1:
message.ProjectID = 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: DeleteClickhouseRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
/* string ProjectID = 1; */
if (message.ProjectID !== "")
writer.tag(1, WireType.LengthDelimited).string(message.ProjectID);
let u = options.writeUnknownFields;
if (u !== false)
(u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
return writer;
}
}
/**
* @generated MessageType for protobuf message api.DeleteClickhouseRequest
*/
export const DeleteClickhouseRequest = new DeleteClickhouseRequest$Type();
// @generated message type with reflection information, may provide speed optimized methods
class DeleteCassandraResult$Type extends MessageType<DeleteCassandraResult> {
constructor() {
super("api.DeleteCassandraResult", []);
}
create(value?: PartialMessage<DeleteCassandraResult>): DeleteCassandraResult {
const message = globalThis.Object.create((this.messagePrototype!));
if (value !== undefined)
reflectionMergePartial<DeleteCassandraResult>(this, message, value);
return message;
}
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: DeleteCassandraResult): DeleteCassandraResult {
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: DeleteCassandraResult, 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.DeleteCassandraResult
*/
export const DeleteCassandraResult = new DeleteCassandraResult$Type();
// @generated message type with reflection information, may provide speed optimized methods
class DeleteClickhouseResult$Type extends MessageType<DeleteClickhouseResult> {
constructor() {
super("api.DeleteClickhouseResult", []);
}
create(value?: PartialMessage<DeleteClickhouseResult>): DeleteClickhouseResult {
const message = globalThis.Object.create((this.messagePrototype!));
if (value !== undefined)
reflectionMergePartial<DeleteClickhouseResult>(this, message, value);
return message;
}
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: DeleteClickhouseResult): DeleteClickhouseResult {
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: DeleteClickhouseResult, 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.DeleteClickhouseResult
*/
export const DeleteClickhouseResult = new DeleteClickhouseResult$Type();
// @generated message type with reflection information, may provide speed optimized methods
class SuggestProjectIDRequest$Type extends MessageType<SuggestProjectIDRequest> {
constructor() {
super("api.SuggestProjectIDRequest", [
@@ -2318,12 +2008,9 @@ export const ProjectService = new ServiceType("api.ProjectService", [
{ name: "Update", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Project"], description: "Update project" }, "api.rscType": "Project", "api.roles": "", "google.api.method_visibility": { restriction: "SDK" } }, I: UpdateProjectRequest, O: UpdateProjectResult },
{ name: "UpdateStatus", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Project"], description: "Update project status" }, "api.rscType": "Platform", "api.roles": "Platform.Project", "google.api.method_visibility": { restriction: "SDK" } }, I: UpdateProjectStatusRequest, O: UpdateProjectStatusResult },
{ name: "Delete", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Project"], description: "Delete resources in connection with the project" }, "api.rscType": "Organisation", "api.roles": "Platform.Project-Deletion", "google.api.method_visibility": { restriction: "SDK" } }, I: DeleteProjectRequest, O: DeleteProjectResult },
{ name: "CreateClickhouse", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Project"], description: "Create Clickhouse resources in connection with the project" }, "api.rscType": "Platform", "api.roles": "", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: CreateClickhouseRequest, O: CreateClickhouseResult },
{ name: "DeleteClickhouse", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Project"], description: "Delete Clickhouse resources in connection with the project" }, "api.rscType": "Platform", "api.roles": "", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: DeleteClickhouseRequest, O: DeleteClickhouseResult },
{ name: "SuggestID", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Project"], description: "Suggest a project ID" }, "api.rscType": "Organisation", "api.roles": "", "google.api.method_visibility": { restriction: "SDK" } }, I: SuggestProjectIDRequest, O: SuggestProjectIDResult },
{ name: "GetMyUIContext", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Project"], description: "List all user accessible projects for non-SA users" }, "api.rscType": "Platform", "api.roles": "", "google.api.method_visibility": { restriction: "SDK" } }, I: GetMyContextRequest, O: GetMyContextResult },
{ name: "GetMyContext", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Project"], description: "List all user accessible projects. For non-SA users, it is advised to use GetMyUIContext instead." }, "api.rscType": "Platform", "api.roles": "", "google.api.method_visibility": { restriction: "SDK" } }, I: GetMyContextRequest, O: GetMyContextResult },
{ 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: "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 });

39
workflow.client.ts
View File

@@ -4,6 +4,12 @@
import type { RpcTransport } from "@protobuf-ts/runtime-rpc";
import type { ServiceInfo } from "@protobuf-ts/runtime-rpc";
import { WorkflowService } from "./workflow";
import type { StartWorkflowCleanCassandraResult } from "./workflow";
import type { StartWorkflowCleanCassandraRequest } from "./workflow";
import type { StartWorkflowDeleteClickhouseResult } from "./workflow";
import type { StartWorkflowDeleteClickhouseRequest } from "./workflow";
import type { StartWorkflowCreateClickhouseResult } from "./workflow";
import type { StartWorkflowCreateClickhouseRequest } from "./workflow";
import type { StartWorkflowSweepResult } from "./workflow";
import type { StartWorkflowSweepRequest } from "./workflow";
import type { StartWorkflowUpgradeModelResult } from "./workflow";
@@ -191,6 +197,18 @@ export interface IWorkflowServiceClient {
* @generated from protobuf rpc: StartWorkflowSweep
*/
startWorkflowSweep(input: StartWorkflowSweepRequest, options?: RpcOptions): UnaryCall<StartWorkflowSweepRequest, StartWorkflowSweepResult>;
/**
* @generated from protobuf rpc: StartWorkflowCreateClickhouse
*/
startWorkflowCreateClickhouse(input: StartWorkflowCreateClickhouseRequest, options?: RpcOptions): UnaryCall<StartWorkflowCreateClickhouseRequest, StartWorkflowCreateClickhouseResult>;
/**
* @generated from protobuf rpc: StartWorkflowDeleteClickhouse
*/
startWorkflowDeleteClickhouse(input: StartWorkflowDeleteClickhouseRequest, options?: RpcOptions): UnaryCall<StartWorkflowDeleteClickhouseRequest, StartWorkflowDeleteClickhouseResult>;
/**
* @generated from protobuf rpc: StartWorkflowCleanCassandra
*/
startWorkflowCleanCassandra(input: StartWorkflowCleanCassandraRequest, options?: RpcOptions): UnaryCall<StartWorkflowCleanCassandraRequest, StartWorkflowCleanCassandraResult>;
}
/**
* @generated from protobuf service api.WorkflowService
@@ -411,4 +429,25 @@ export class WorkflowServiceClient implements IWorkflowServiceClient, ServiceInf
const method = this.methods[29], 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);
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);
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);
return stackIntercept<StartWorkflowCleanCassandraRequest, StartWorkflowCleanCassandraResult>("unary", this._transport, method, opt, input);
}
}

363
workflow.ts
View File

@@ -11,6 +11,7 @@ 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 { ResourceType } from "./shared";
import { EntityType } from "./shared";
import { RecoverType } from "./shared";
import { ModelDataSetEnum } from "./shared";
@@ -850,6 +851,68 @@ export interface StartWorkflowSweepResult {
*/
WorkflowExecution?: WorkflowExecutionResult;
}
/**
* @generated from protobuf message api.StartWorkflowCreateClickhouseRequest
*/
export interface StartWorkflowCreateClickhouseRequest {
/**
* @generated from protobuf field: string ProjectID = 1
*/
ProjectID: string;
/**
* @generated from protobuf field: api.ResourceType ResourceType = 2
*/
ResourceType: ResourceType;
}
/**
* @generated from protobuf message api.StartWorkflowCreateClickhouseResult
*/
export interface StartWorkflowCreateClickhouseResult {
/**
* @generated from protobuf field: api.WorkflowExecutionResult WorkflowExecution = 1
*/
WorkflowExecution?: WorkflowExecutionResult;
}
/**
* @generated from protobuf message api.StartWorkflowDeleteClickhouseRequest
*/
export interface StartWorkflowDeleteClickhouseRequest {
/**
* @generated from protobuf field: string ProjectID = 1
*/
ProjectID: string;
}
/**
* @generated from protobuf message api.StartWorkflowDeleteClickhouseResult
*/
export interface StartWorkflowDeleteClickhouseResult {
/**
* @generated from protobuf field: api.WorkflowExecutionResult WorkflowExecution = 1
*/
WorkflowExecution?: WorkflowExecutionResult;
}
/**
* @generated from protobuf message api.StartWorkflowCleanCassandraRequest
*/
export interface StartWorkflowCleanCassandraRequest {
/**
* @generated from protobuf field: string ProjectID = 1
*/
ProjectID: string;
/**
* @generated from protobuf field: api.ResourceType ResourceType = 2
*/
ResourceType: ResourceType;
}
/**
* @generated from protobuf message api.StartWorkflowCleanCassandraResult
*/
export interface StartWorkflowCleanCassandraResult {
/**
* @generated from protobuf field: api.WorkflowExecutionResult WorkflowExecution = 1
*/
WorkflowExecution?: WorkflowExecutionResult;
}
/**
* @generated from protobuf enum api.WorkflowStatusEnum
*/
@@ -4317,6 +4380,301 @@ class StartWorkflowSweepResult$Type extends MessageType<StartWorkflowSweepResult
* @generated MessageType for protobuf message api.StartWorkflowSweepResult
*/
export const StartWorkflowSweepResult = new StartWorkflowSweepResult$Type();
// @generated message type with reflection information, may provide speed optimized methods
class StartWorkflowCreateClickhouseRequest$Type extends MessageType<StartWorkflowCreateClickhouseRequest> {
constructor() {
super("api.StartWorkflowCreateClickhouseRequest", [
{ no: 1, name: "ProjectID", kind: "scalar", localName: "ProjectID", jsonName: "ProjectID", T: 9 /*ScalarType.STRING*/ },
{ no: 2, name: "ResourceType", kind: "enum", localName: "ResourceType", jsonName: "ResourceType", T: () => ["api.ResourceType", ResourceType] }
], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["ProjectID", "ResourceType"] } } });
}
create(value?: PartialMessage<StartWorkflowCreateClickhouseRequest>): StartWorkflowCreateClickhouseRequest {
const message = globalThis.Object.create((this.messagePrototype!));
message.ProjectID = "";
message.ResourceType = 0;
if (value !== undefined)
reflectionMergePartial<StartWorkflowCreateClickhouseRequest>(this, message, value);
return message;
}
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: StartWorkflowCreateClickhouseRequest): StartWorkflowCreateClickhouseRequest {
let message = target ?? this.create(), end = reader.pos + length;
while (reader.pos < end) {
let [fieldNo, wireType] = reader.tag();
switch (fieldNo) {
case /* string ProjectID */ 1:
message.ProjectID = reader.string();
break;
case /* api.ResourceType ResourceType */ 2:
message.ResourceType = 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: StartWorkflowCreateClickhouseRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
/* string ProjectID = 1; */
if (message.ProjectID !== "")
writer.tag(1, WireType.LengthDelimited).string(message.ProjectID);
/* api.ResourceType ResourceType = 2; */
if (message.ResourceType !== 0)
writer.tag(2, WireType.Varint).int32(message.ResourceType);
let u = options.writeUnknownFields;
if (u !== false)
(u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
return writer;
}
}
/**
* @generated MessageType for protobuf message api.StartWorkflowCreateClickhouseRequest
*/
export const StartWorkflowCreateClickhouseRequest = new StartWorkflowCreateClickhouseRequest$Type();
// @generated message type with reflection information, may provide speed optimized methods
class StartWorkflowCreateClickhouseResult$Type extends MessageType<StartWorkflowCreateClickhouseResult> {
constructor() {
super("api.StartWorkflowCreateClickhouseResult", [
{ no: 1, name: "WorkflowExecution", kind: "message", localName: "WorkflowExecution", jsonName: "WorkflowExecution", T: () => WorkflowExecutionResult }
]);
}
create(value?: PartialMessage<StartWorkflowCreateClickhouseResult>): StartWorkflowCreateClickhouseResult {
const message = globalThis.Object.create((this.messagePrototype!));
if (value !== undefined)
reflectionMergePartial<StartWorkflowCreateClickhouseResult>(this, message, value);
return message;
}
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: StartWorkflowCreateClickhouseResult): StartWorkflowCreateClickhouseResult {
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: StartWorkflowCreateClickhouseResult, 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.StartWorkflowCreateClickhouseResult
*/
export const StartWorkflowCreateClickhouseResult = new StartWorkflowCreateClickhouseResult$Type();
// @generated message type with reflection information, may provide speed optimized methods
class StartWorkflowDeleteClickhouseRequest$Type extends MessageType<StartWorkflowDeleteClickhouseRequest> {
constructor() {
super("api.StartWorkflowDeleteClickhouseRequest", [
{ no: 1, name: "ProjectID", kind: "scalar", localName: "ProjectID", jsonName: "ProjectID", T: 9 /*ScalarType.STRING*/ }
], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["ProjectID"] } } });
}
create(value?: PartialMessage<StartWorkflowDeleteClickhouseRequest>): StartWorkflowDeleteClickhouseRequest {
const message = globalThis.Object.create((this.messagePrototype!));
message.ProjectID = "";
if (value !== undefined)
reflectionMergePartial<StartWorkflowDeleteClickhouseRequest>(this, message, value);
return message;
}
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: StartWorkflowDeleteClickhouseRequest): StartWorkflowDeleteClickhouseRequest {
let message = target ?? this.create(), end = reader.pos + length;
while (reader.pos < end) {
let [fieldNo, wireType] = reader.tag();
switch (fieldNo) {
case /* string ProjectID */ 1:
message.ProjectID = 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: StartWorkflowDeleteClickhouseRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
/* string ProjectID = 1; */
if (message.ProjectID !== "")
writer.tag(1, WireType.LengthDelimited).string(message.ProjectID);
let u = options.writeUnknownFields;
if (u !== false)
(u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
return writer;
}
}
/**
* @generated MessageType for protobuf message api.StartWorkflowDeleteClickhouseRequest
*/
export const StartWorkflowDeleteClickhouseRequest = new StartWorkflowDeleteClickhouseRequest$Type();
// @generated message type with reflection information, may provide speed optimized methods
class StartWorkflowDeleteClickhouseResult$Type extends MessageType<StartWorkflowDeleteClickhouseResult> {
constructor() {
super("api.StartWorkflowDeleteClickhouseResult", [
{ no: 1, name: "WorkflowExecution", kind: "message", localName: "WorkflowExecution", jsonName: "WorkflowExecution", T: () => WorkflowExecutionResult }
]);
}
create(value?: PartialMessage<StartWorkflowDeleteClickhouseResult>): StartWorkflowDeleteClickhouseResult {
const message = globalThis.Object.create((this.messagePrototype!));
if (value !== undefined)
reflectionMergePartial<StartWorkflowDeleteClickhouseResult>(this, message, value);
return message;
}
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: StartWorkflowDeleteClickhouseResult): StartWorkflowDeleteClickhouseResult {
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: StartWorkflowDeleteClickhouseResult, 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.StartWorkflowDeleteClickhouseResult
*/
export const StartWorkflowDeleteClickhouseResult = new StartWorkflowDeleteClickhouseResult$Type();
// @generated message type with reflection information, may provide speed optimized methods
class StartWorkflowCleanCassandraRequest$Type extends MessageType<StartWorkflowCleanCassandraRequest> {
constructor() {
super("api.StartWorkflowCleanCassandraRequest", [
{ no: 1, name: "ProjectID", kind: "scalar", localName: "ProjectID", jsonName: "ProjectID", T: 9 /*ScalarType.STRING*/ },
{ no: 2, name: "ResourceType", kind: "enum", localName: "ResourceType", jsonName: "ResourceType", T: () => ["api.ResourceType", ResourceType] }
], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["ProjectID", "ResourceType"] } } });
}
create(value?: PartialMessage<StartWorkflowCleanCassandraRequest>): StartWorkflowCleanCassandraRequest {
const message = globalThis.Object.create((this.messagePrototype!));
message.ProjectID = "";
message.ResourceType = 0;
if (value !== undefined)
reflectionMergePartial<StartWorkflowCleanCassandraRequest>(this, message, value);
return message;
}
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: StartWorkflowCleanCassandraRequest): StartWorkflowCleanCassandraRequest {
let message = target ?? this.create(), end = reader.pos + length;
while (reader.pos < end) {
let [fieldNo, wireType] = reader.tag();
switch (fieldNo) {
case /* string ProjectID */ 1:
message.ProjectID = reader.string();
break;
case /* api.ResourceType ResourceType */ 2:
message.ResourceType = 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: StartWorkflowCleanCassandraRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
/* string ProjectID = 1; */
if (message.ProjectID !== "")
writer.tag(1, WireType.LengthDelimited).string(message.ProjectID);
/* api.ResourceType ResourceType = 2; */
if (message.ResourceType !== 0)
writer.tag(2, WireType.Varint).int32(message.ResourceType);
let u = options.writeUnknownFields;
if (u !== false)
(u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
return writer;
}
}
/**
* @generated MessageType for protobuf message api.StartWorkflowCleanCassandraRequest
*/
export const StartWorkflowCleanCassandraRequest = new StartWorkflowCleanCassandraRequest$Type();
// @generated message type with reflection information, may provide speed optimized methods
class StartWorkflowCleanCassandraResult$Type extends MessageType<StartWorkflowCleanCassandraResult> {
constructor() {
super("api.StartWorkflowCleanCassandraResult", [
{ no: 1, name: "WorkflowExecution", kind: "message", localName: "WorkflowExecution", jsonName: "WorkflowExecution", T: () => WorkflowExecutionResult }
]);
}
create(value?: PartialMessage<StartWorkflowCleanCassandraResult>): StartWorkflowCleanCassandraResult {
const message = globalThis.Object.create((this.messagePrototype!));
if (value !== undefined)
reflectionMergePartial<StartWorkflowCleanCassandraResult>(this, message, value);
return message;
}
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: StartWorkflowCleanCassandraResult): StartWorkflowCleanCassandraResult {
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: StartWorkflowCleanCassandraResult, 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.StartWorkflowCleanCassandraResult
*/
export const StartWorkflowCleanCassandraResult = new StartWorkflowCleanCassandraResult$Type();
/**
* @generated ServiceType for protobuf service api.WorkflowService
*/
@@ -4350,5 +4708,8 @@ export const WorkflowService = new ServiceType("api.WorkflowService", [
{ 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 }
{ 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 },
{ name: "StartWorkflowCreateClickhouse", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Workflow"], description: "Start a workflow which will create clickhouse database for the project and the resource" }, "api.rscType": "Platform", "api.roles": "Platform.Workflow", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: StartWorkflowCreateClickhouseRequest, O: StartWorkflowCreateClickhouseResult },
{ name: "StartWorkflowDeleteClickhouse", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Workflow"], description: "Start a workflow which will delete clickhouse database for the project and the resource" }, "api.rscType": "Platform", "api.roles": "Platform.Workflow", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: StartWorkflowDeleteClickhouseRequest, O: StartWorkflowDeleteClickhouseResult },
{ name: "StartWorkflowCleanCassandra", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Workflow"], description: "Start a workflow which will clean data in cassandra tables for the project and the resource" }, "api.rscType": "Platform", "api.roles": "Platform.Workflow", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: StartWorkflowCleanCassandraRequest, O: StartWorkflowCleanCassandraResult }
], { "api.k8sService": "organisation-server", "api.roleManager": true, "api.resourceManager": true });