You've already forked npm-core-sdk
Latest generation
This commit is contained in:
ci core model
@@ -1,6 +1,6 @@
|
||||
{
|
||||
"name": "@reflex-platform/npm-core-sdk",
|
||||
"version": "1.13.0-SNAPSHOT-260415091643",
|
||||
"version": "1.13.0-SNAPSHOT-260415094908",
|
||||
"description": "npm libs from core model proto files",
|
||||
"homepage": "",
|
||||
"main": "index.ts",
|
||||
|
||||
@@ -52,6 +52,7 @@ import type { DeregisterModuleWorkflowsResult } from "./workflow";
|
||||
import type { DeregisterModuleWorkflowsRequest } from "./workflow";
|
||||
import type { RegisterModuleWorkflowsResult } from "./workflow";
|
||||
import type { RegisterModuleWorkflowsRequest } from "./workflow";
|
||||
import type { StartWorkflowCrossExtractDataFromDBRequest } from "./workflow";
|
||||
import type { StartWorkflowExtractDataFromDBResult } from "./workflow";
|
||||
import type { StartWorkflowExtractDataFromDBRequest } from "./workflow";
|
||||
import type { StopWorkflowBillingResult } from "./workflow";
|
||||
@@ -113,6 +114,10 @@ export interface IWorkflowServiceClient {
|
||||
* @generated from protobuf rpc: StartWorkflowExtractDataFromDB
|
||||
*/
|
||||
startWorkflowExtractDataFromDB(input: StartWorkflowExtractDataFromDBRequest, options?: RpcOptions): UnaryCall<StartWorkflowExtractDataFromDBRequest, StartWorkflowExtractDataFromDBResult>;
|
||||
/**
|
||||
* @generated from protobuf rpc: StartWorkflowCrossExtractDataFromDB
|
||||
*/
|
||||
startWorkflowCrossExtractDataFromDB(input: StartWorkflowCrossExtractDataFromDBRequest, options?: RpcOptions): UnaryCall<StartWorkflowCrossExtractDataFromDBRequest, StartWorkflowExtractDataFromDBResult>;
|
||||
/**
|
||||
* @generated from protobuf rpc: RegisterModuleWorkflows
|
||||
*/
|
||||
@@ -282,172 +287,179 @@ export class WorkflowServiceClient implements IWorkflowServiceClient, ServiceInf
|
||||
const method = this.methods[8], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<StartWorkflowExtractDataFromDBRequest, StartWorkflowExtractDataFromDBResult>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
* @generated from protobuf rpc: StartWorkflowCrossExtractDataFromDB
|
||||
*/
|
||||
startWorkflowCrossExtractDataFromDB(input: StartWorkflowCrossExtractDataFromDBRequest, options?: RpcOptions): UnaryCall<StartWorkflowCrossExtractDataFromDBRequest, StartWorkflowExtractDataFromDBResult> {
|
||||
const method = this.methods[9], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<StartWorkflowCrossExtractDataFromDBRequest, StartWorkflowExtractDataFromDBResult>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
* @generated from protobuf rpc: RegisterModuleWorkflows
|
||||
*/
|
||||
registerModuleWorkflows(input: RegisterModuleWorkflowsRequest, options?: RpcOptions): UnaryCall<RegisterModuleWorkflowsRequest, RegisterModuleWorkflowsResult> {
|
||||
const method = this.methods[9], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[10], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<RegisterModuleWorkflowsRequest, RegisterModuleWorkflowsResult>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
* @generated from protobuf rpc: DeregisterModuleWorkflows
|
||||
*/
|
||||
deregisterModuleWorkflows(input: DeregisterModuleWorkflowsRequest, options?: RpcOptions): UnaryCall<DeregisterModuleWorkflowsRequest, DeregisterModuleWorkflowsResult> {
|
||||
const method = this.methods[10], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[11], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<DeregisterModuleWorkflowsRequest, DeregisterModuleWorkflowsResult>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
* @generated from protobuf rpc: GetModuleWorkflows
|
||||
*/
|
||||
getModuleWorkflows(input: GetModuleWorkflowsRequest, options?: RpcOptions): UnaryCall<GetModuleWorkflowsRequest, GetModuleWorkflowsResult> {
|
||||
const method = this.methods[11], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[12], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<GetModuleWorkflowsRequest, GetModuleWorkflowsResult>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
* @generated from protobuf rpc: StopWorkflow
|
||||
*/
|
||||
stopWorkflow(input: StopWorkflowRequest, options?: RpcOptions): UnaryCall<StopWorkflowRequest, StopWorkflowResult> {
|
||||
const method = this.methods[12], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[13], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<StopWorkflowRequest, StopWorkflowResult>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
* @generated from protobuf rpc: StartWorkflowOptimizeClickhouse
|
||||
*/
|
||||
startWorkflowOptimizeClickhouse(input: StartWorkflowOptimizeClickhouseRequest, options?: RpcOptions): UnaryCall<StartWorkflowOptimizeClickhouseRequest, StartWorkflowOptimizeClickhouseResult> {
|
||||
const method = this.methods[13], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[14], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<StartWorkflowOptimizeClickhouseRequest, StartWorkflowOptimizeClickhouseResult>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
* @generated from protobuf rpc: StartWorkflowCreateOrganisation
|
||||
*/
|
||||
startWorkflowCreateOrganisation(input: StartWorkflowCreateOrganisationRequest, options?: RpcOptions): UnaryCall<StartWorkflowCreateOrganisationRequest, StartWorkflowCreateOrganisationResult> {
|
||||
const method = this.methods[14], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[15], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<StartWorkflowCreateOrganisationRequest, StartWorkflowCreateOrganisationResult>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
* @generated from protobuf rpc: StartWorkflowDeleteOrganisation
|
||||
*/
|
||||
startWorkflowDeleteOrganisation(input: StartWorkflowDeleteOrganisationRequest, options?: RpcOptions): UnaryCall<StartWorkflowDeleteOrganisationRequest, StartWorkflowDeleteOrganisationResult> {
|
||||
const method = this.methods[15], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[16], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<StartWorkflowDeleteOrganisationRequest, StartWorkflowDeleteOrganisationResult>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
* @generated from protobuf rpc: StartWorkflowRecoverData
|
||||
*/
|
||||
startWorkflowRecoverData(input: StartWorkflowRecoverDataRequest, options?: RpcOptions): UnaryCall<StartWorkflowRecoverDataRequest, StartWorkflowRecoverDataResult> {
|
||||
const method = this.methods[16], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[17], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<StartWorkflowRecoverDataRequest, StartWorkflowRecoverDataResult>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
* @generated from protobuf rpc: StartWorkflowCheckAndLaunchRecoverData
|
||||
*/
|
||||
startWorkflowCheckAndLaunchRecoverData(input: StartWorkflowCheckAndLaunchRecoverDataRequest, options?: RpcOptions): UnaryCall<StartWorkflowCheckAndLaunchRecoverDataRequest, StartWorkflowCheckAndLaunchRecoverDataResult> {
|
||||
const method = this.methods[17], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[18], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<StartWorkflowCheckAndLaunchRecoverDataRequest, StartWorkflowCheckAndLaunchRecoverDataResult>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
* @generated from protobuf rpc: StartWorkflowUpdateMaterializedView
|
||||
*/
|
||||
startWorkflowUpdateMaterializedView(input: StartWorkflowUpdateMaterializedViewRequest, options?: RpcOptions): UnaryCall<StartWorkflowUpdateMaterializedViewRequest, StartWorkflowUpdateMaterializedViewResult> {
|
||||
const method = this.methods[18], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[19], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<StartWorkflowUpdateMaterializedViewRequest, StartWorkflowUpdateMaterializedViewResult>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
* @generated from protobuf rpc: GetWorkflowState
|
||||
*/
|
||||
getWorkflowState(input: GetWorkflowStateRequest, options?: RpcOptions): UnaryCall<GetWorkflowStateRequest, GetWorkflowStateResult> {
|
||||
const method = this.methods[19], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[20], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<GetWorkflowStateRequest, GetWorkflowStateResult>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
* @generated from protobuf rpc: GetWorkflowExecutionInformations
|
||||
*/
|
||||
getWorkflowExecutionInformations(input: GetWorkflowExecutionInformationsRequest, options?: RpcOptions): UnaryCall<GetWorkflowExecutionInformationsRequest, GetWorkflowExecutionInformationsResult> {
|
||||
const method = this.methods[20], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[21], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<GetWorkflowExecutionInformationsRequest, GetWorkflowExecutionInformationsResult>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
* @generated from protobuf rpc: StartWorkflowDailyProjectsOperations
|
||||
*/
|
||||
startWorkflowDailyProjectsOperations(input: StartWorkflowDailyProjectsOperationsRequest, options?: RpcOptions): UnaryCall<StartWorkflowDailyProjectsOperationsRequest, StartWorkflowDailyProjectsOperationsResult> {
|
||||
const method = this.methods[21], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[22], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<StartWorkflowDailyProjectsOperationsRequest, StartWorkflowDailyProjectsOperationsResult>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
* @generated from protobuf rpc: StartWorkflowHealthCheckWorkflows
|
||||
*/
|
||||
startWorkflowHealthCheckWorkflows(input: StartWorkflowHealthCheckWorkflowsRequest, options?: RpcOptions): UnaryCall<StartWorkflowHealthCheckWorkflowsRequest, StartWorkflowHealthCheckWorkflowsResult> {
|
||||
const method = this.methods[22], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[23], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<StartWorkflowHealthCheckWorkflowsRequest, StartWorkflowHealthCheckWorkflowsResult>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
* @generated from protobuf rpc: StartWorkflowExtractKPI
|
||||
*/
|
||||
startWorkflowExtractKPI(input: StartWorkflowExtractKPIRequest, options?: RpcOptions): UnaryCall<StartWorkflowExtractKPIRequest, StartWorkflowExtractKPIResult> {
|
||||
const method = this.methods[23], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[24], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<StartWorkflowExtractKPIRequest, StartWorkflowExtractKPIResult>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
/**
|
||||
* @generated from protobuf rpc: StartWorkflowPruneData
|
||||
*/
|
||||
startWorkflowPruneData(input: StartWorkflowPruneDataRequest, options?: RpcOptions): UnaryCall<StartWorkflowPruneDataRequest, StartWorkflowPruneDataResult> {
|
||||
const method = this.methods[24], opt = this._transport.mergeOptions(options);
|
||||
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[25], opt = this._transport.mergeOptions(options);
|
||||
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[26], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[27], 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[27], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[28], 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[28], opt = this._transport.mergeOptions(options);
|
||||
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[29], opt = this._transport.mergeOptions(options);
|
||||
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[30], opt = this._transport.mergeOptions(options);
|
||||
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[31], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[32], 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[32], opt = this._transport.mergeOptions(options);
|
||||
const method = this.methods[33], opt = this._transport.mergeOptions(options);
|
||||
return stackIntercept<StartWorkflowSynchronizeUMAStoreRequest, StartWorkflowSynchronizeUMAStoreResult>("unary", this._transport, method, opt, input);
|
||||
}
|
||||
}
|
||||
|
||||
281
workflow.ts
281
workflow.ts
@@ -310,6 +310,79 @@ export interface StartWorkflowExtractDataFromDBRequest {
|
||||
*/
|
||||
TimeFormat: TimeFormat;
|
||||
}
|
||||
/**
|
||||
* @generated from protobuf message api.StartWorkflowCrossExtractDataFromDBRequest
|
||||
*/
|
||||
export interface StartWorkflowCrossExtractDataFromDBRequest {
|
||||
/**
|
||||
* @generated from protobuf field: string UserId = 1
|
||||
*/
|
||||
UserId: string;
|
||||
/**
|
||||
* @generated from protobuf field: repeated api.BlockFilter BlockFilters = 2
|
||||
*/
|
||||
BlockFilters: BlockFilter[];
|
||||
/**
|
||||
* @generated from protobuf field: string TargetDomain = 3
|
||||
*/
|
||||
TargetDomain: string;
|
||||
/**
|
||||
* @generated from protobuf field: string TargetType = 4
|
||||
*/
|
||||
TargetType: string;
|
||||
/**
|
||||
* @generated from protobuf field: repeated string Fields = 5
|
||||
*/
|
||||
Fields: string[];
|
||||
/**
|
||||
* @generated from protobuf field: string ListSeparator = 6
|
||||
*/
|
||||
ListSeparator: string;
|
||||
/**
|
||||
* @generated from protobuf field: string DecimalSeparator = 7
|
||||
*/
|
||||
DecimalSeparator: string;
|
||||
/**
|
||||
* @generated from protobuf field: repeated string ColumnNames = 8
|
||||
*/
|
||||
ColumnNames: string[];
|
||||
/**
|
||||
* @generated from protobuf field: map<string, api.TranslationMap> ColumnTranslationMaps = 9
|
||||
*/
|
||||
ColumnTranslationMaps: {
|
||||
[key: string]: TranslationMap;
|
||||
};
|
||||
/**
|
||||
* @generated from protobuf field: map<int32, api.ExtractColumnFormat> ColumnFormats = 10
|
||||
*/
|
||||
ColumnFormats: {
|
||||
[key: number]: ExtractColumnFormat;
|
||||
};
|
||||
/**
|
||||
* @generated from protobuf field: string TargetTimeZone = 11
|
||||
*/
|
||||
TargetTimeZone: string;
|
||||
/**
|
||||
* @generated from protobuf field: string DateFormat = 12
|
||||
*/
|
||||
DateFormat: string;
|
||||
/**
|
||||
* @generated from protobuf field: string NumberFormat = 13
|
||||
*/
|
||||
NumberFormat: string;
|
||||
/**
|
||||
* @generated from protobuf field: api.TimeFormat TimeFormat = 14
|
||||
*/
|
||||
TimeFormat: TimeFormat;
|
||||
/**
|
||||
* @generated from protobuf field: repeated string SearchTagProjects = 15
|
||||
*/
|
||||
SearchTagProjects: string[];
|
||||
/**
|
||||
* @generated from protobuf field: repeated string SearchTagUsers = 16
|
||||
*/
|
||||
SearchTagUsers: string[];
|
||||
}
|
||||
/**
|
||||
* @generated from protobuf message api.StartWorkflowExtractDataFromDBResult
|
||||
*/
|
||||
@@ -2021,6 +2094,213 @@ class StartWorkflowExtractDataFromDBRequest$Type extends MessageType<StartWorkfl
|
||||
*/
|
||||
export const StartWorkflowExtractDataFromDBRequest = new StartWorkflowExtractDataFromDBRequest$Type();
|
||||
// @generated message type with reflection information, may provide speed optimized methods
|
||||
class StartWorkflowCrossExtractDataFromDBRequest$Type extends MessageType<StartWorkflowCrossExtractDataFromDBRequest> {
|
||||
constructor() {
|
||||
super("api.StartWorkflowCrossExtractDataFromDBRequest", [
|
||||
{ no: 1, name: "UserId", kind: "scalar", localName: "UserId", jsonName: "UserId", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } },
|
||||
{ no: 2, name: "BlockFilters", kind: "message", localName: "BlockFilters", jsonName: "BlockFilters", repeat: 2 /*RepeatType.UNPACKED*/, T: () => BlockFilter },
|
||||
{ no: 3, name: "TargetDomain", kind: "scalar", localName: "TargetDomain", jsonName: "TargetDomain", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } },
|
||||
{ no: 4, name: "TargetType", kind: "scalar", localName: "TargetType", jsonName: "TargetType", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } },
|
||||
{ no: 5, name: "Fields", kind: "scalar", localName: "Fields", jsonName: "Fields", repeat: 2 /*RepeatType.UNPACKED*/, T: 9 /*ScalarType.STRING*/ },
|
||||
{ no: 6, name: "ListSeparator", kind: "scalar", localName: "ListSeparator", jsonName: "ListSeparator", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } },
|
||||
{ no: 7, name: "DecimalSeparator", kind: "scalar", localName: "DecimalSeparator", jsonName: "DecimalSeparator", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } },
|
||||
{ no: 8, name: "ColumnNames", kind: "scalar", localName: "ColumnNames", jsonName: "ColumnNames", repeat: 2 /*RepeatType.UNPACKED*/, T: 9 /*ScalarType.STRING*/ },
|
||||
{ no: 9, name: "ColumnTranslationMaps", kind: "map", localName: "ColumnTranslationMaps", jsonName: "ColumnTranslationMaps", K: 9 /*ScalarType.STRING*/, V: { kind: "message", T: () => TranslationMap } },
|
||||
{ no: 10, name: "ColumnFormats", kind: "map", localName: "ColumnFormats", jsonName: "ColumnFormats", K: 5 /*ScalarType.INT32*/, V: { kind: "message", T: () => ExtractColumnFormat } },
|
||||
{ no: 11, name: "TargetTimeZone", kind: "scalar", localName: "TargetTimeZone", jsonName: "TargetTimeZone", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1", tzData: true } }, "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Target user time zone <a href='https://en.wikipedia.org/wiki/List_of_tz_database_time_zones'>format</a>", example: "\"Europe/Paris\"" } } },
|
||||
{ no: 12, name: "DateFormat", kind: "scalar", localName: "DateFormat", jsonName: "DateFormat", T: 9 /*ScalarType.STRING*/, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Language code to format dates <a href='https://en.wikipedia.org/wiki/ISO_639'>format</a>", example: "\"en-US\"" } } },
|
||||
{ no: 13, name: "NumberFormat", kind: "scalar", localName: "NumberFormat", jsonName: "NumberFormat", T: 9 /*ScalarType.STRING*/, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Language code to format numbers <a href='https://en.wikipedia.org/wiki/ISO_639'>format</a>", example: "\"en-US\"" } } },
|
||||
{ no: 14, name: "TimeFormat", kind: "enum", localName: "TimeFormat", jsonName: "TimeFormat", T: () => ["api.TimeFormat", TimeFormat], options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "Hour clock time format" } } },
|
||||
{ no: 15, name: "SearchTagProjects", kind: "scalar", localName: "SearchTagProjects", jsonName: "SearchTagProjects", repeat: 2 /*RepeatType.UNPACKED*/, T: 9 /*ScalarType.STRING*/, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "List of projectID to search into", example: "[\"project1\", \"project2\"]" } } },
|
||||
{ no: 16, name: "SearchTagUsers", kind: "scalar", localName: "SearchTagUsers", jsonName: "SearchTagUsers", repeat: 2 /*RepeatType.UNPACKED*/, T: 9 /*ScalarType.STRING*/, options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { description: "List of userID to search into", example: "[\"userID1\", \"userID2\"]" } } }
|
||||
], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["UserId", "TargetDomain", "TargetType", "Fields", "ListSeparator", "DecimalSeparator"] } } });
|
||||
}
|
||||
create(value?: PartialMessage<StartWorkflowCrossExtractDataFromDBRequest>): StartWorkflowCrossExtractDataFromDBRequest {
|
||||
const message = globalThis.Object.create((this.messagePrototype!));
|
||||
message.UserId = "";
|
||||
message.BlockFilters = [];
|
||||
message.TargetDomain = "";
|
||||
message.TargetType = "";
|
||||
message.Fields = [];
|
||||
message.ListSeparator = "";
|
||||
message.DecimalSeparator = "";
|
||||
message.ColumnNames = [];
|
||||
message.ColumnTranslationMaps = {};
|
||||
message.ColumnFormats = {};
|
||||
message.TargetTimeZone = "";
|
||||
message.DateFormat = "";
|
||||
message.NumberFormat = "";
|
||||
message.TimeFormat = 0;
|
||||
message.SearchTagProjects = [];
|
||||
message.SearchTagUsers = [];
|
||||
if (value !== undefined)
|
||||
reflectionMergePartial<StartWorkflowCrossExtractDataFromDBRequest>(this, message, value);
|
||||
return message;
|
||||
}
|
||||
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: StartWorkflowCrossExtractDataFromDBRequest): StartWorkflowCrossExtractDataFromDBRequest {
|
||||
let message = target ?? this.create(), end = reader.pos + length;
|
||||
while (reader.pos < end) {
|
||||
let [fieldNo, wireType] = reader.tag();
|
||||
switch (fieldNo) {
|
||||
case /* string UserId */ 1:
|
||||
message.UserId = reader.string();
|
||||
break;
|
||||
case /* repeated api.BlockFilter BlockFilters */ 2:
|
||||
message.BlockFilters.push(BlockFilter.internalBinaryRead(reader, reader.uint32(), options));
|
||||
break;
|
||||
case /* string TargetDomain */ 3:
|
||||
message.TargetDomain = reader.string();
|
||||
break;
|
||||
case /* string TargetType */ 4:
|
||||
message.TargetType = reader.string();
|
||||
break;
|
||||
case /* repeated string Fields */ 5:
|
||||
message.Fields.push(reader.string());
|
||||
break;
|
||||
case /* string ListSeparator */ 6:
|
||||
message.ListSeparator = reader.string();
|
||||
break;
|
||||
case /* string DecimalSeparator */ 7:
|
||||
message.DecimalSeparator = reader.string();
|
||||
break;
|
||||
case /* repeated string ColumnNames */ 8:
|
||||
message.ColumnNames.push(reader.string());
|
||||
break;
|
||||
case /* map<string, api.TranslationMap> ColumnTranslationMaps */ 9:
|
||||
this.binaryReadMap9(message.ColumnTranslationMaps, reader, options);
|
||||
break;
|
||||
case /* map<int32, api.ExtractColumnFormat> ColumnFormats */ 10:
|
||||
this.binaryReadMap10(message.ColumnFormats, reader, options);
|
||||
break;
|
||||
case /* string TargetTimeZone */ 11:
|
||||
message.TargetTimeZone = reader.string();
|
||||
break;
|
||||
case /* string DateFormat */ 12:
|
||||
message.DateFormat = reader.string();
|
||||
break;
|
||||
case /* string NumberFormat */ 13:
|
||||
message.NumberFormat = reader.string();
|
||||
break;
|
||||
case /* api.TimeFormat TimeFormat */ 14:
|
||||
message.TimeFormat = reader.int32();
|
||||
break;
|
||||
case /* repeated string SearchTagProjects */ 15:
|
||||
message.SearchTagProjects.push(reader.string());
|
||||
break;
|
||||
case /* repeated string SearchTagUsers */ 16:
|
||||
message.SearchTagUsers.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;
|
||||
}
|
||||
private binaryReadMap9(map: StartWorkflowCrossExtractDataFromDBRequest["ColumnTranslationMaps"], reader: IBinaryReader, options: BinaryReadOptions): void {
|
||||
let len = reader.uint32(), end = reader.pos + len, key: keyof StartWorkflowCrossExtractDataFromDBRequest["ColumnTranslationMaps"] | undefined, val: StartWorkflowCrossExtractDataFromDBRequest["ColumnTranslationMaps"][any] | undefined;
|
||||
while (reader.pos < end) {
|
||||
let [fieldNo, wireType] = reader.tag();
|
||||
switch (fieldNo) {
|
||||
case 1:
|
||||
key = reader.string();
|
||||
break;
|
||||
case 2:
|
||||
val = TranslationMap.internalBinaryRead(reader, reader.uint32(), options);
|
||||
break;
|
||||
default: throw new globalThis.Error("unknown map entry field for api.StartWorkflowCrossExtractDataFromDBRequest.ColumnTranslationMaps");
|
||||
}
|
||||
}
|
||||
map[key ?? ""] = val ?? TranslationMap.create();
|
||||
}
|
||||
private binaryReadMap10(map: StartWorkflowCrossExtractDataFromDBRequest["ColumnFormats"], reader: IBinaryReader, options: BinaryReadOptions): void {
|
||||
let len = reader.uint32(), end = reader.pos + len, key: keyof StartWorkflowCrossExtractDataFromDBRequest["ColumnFormats"] | undefined, val: StartWorkflowCrossExtractDataFromDBRequest["ColumnFormats"][any] | undefined;
|
||||
while (reader.pos < end) {
|
||||
let [fieldNo, wireType] = reader.tag();
|
||||
switch (fieldNo) {
|
||||
case 1:
|
||||
key = reader.int32();
|
||||
break;
|
||||
case 2:
|
||||
val = ExtractColumnFormat.internalBinaryRead(reader, reader.uint32(), options);
|
||||
break;
|
||||
default: throw new globalThis.Error("unknown map entry field for api.StartWorkflowCrossExtractDataFromDBRequest.ColumnFormats");
|
||||
}
|
||||
}
|
||||
map[key ?? 0] = val ?? ExtractColumnFormat.create();
|
||||
}
|
||||
internalBinaryWrite(message: StartWorkflowCrossExtractDataFromDBRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
|
||||
/* string UserId = 1; */
|
||||
if (message.UserId !== "")
|
||||
writer.tag(1, WireType.LengthDelimited).string(message.UserId);
|
||||
/* repeated api.BlockFilter BlockFilters = 2; */
|
||||
for (let i = 0; i < message.BlockFilters.length; i++)
|
||||
BlockFilter.internalBinaryWrite(message.BlockFilters[i], writer.tag(2, WireType.LengthDelimited).fork(), options).join();
|
||||
/* string TargetDomain = 3; */
|
||||
if (message.TargetDomain !== "")
|
||||
writer.tag(3, WireType.LengthDelimited).string(message.TargetDomain);
|
||||
/* string TargetType = 4; */
|
||||
if (message.TargetType !== "")
|
||||
writer.tag(4, WireType.LengthDelimited).string(message.TargetType);
|
||||
/* repeated string Fields = 5; */
|
||||
for (let i = 0; i < message.Fields.length; i++)
|
||||
writer.tag(5, WireType.LengthDelimited).string(message.Fields[i]);
|
||||
/* string ListSeparator = 6; */
|
||||
if (message.ListSeparator !== "")
|
||||
writer.tag(6, WireType.LengthDelimited).string(message.ListSeparator);
|
||||
/* string DecimalSeparator = 7; */
|
||||
if (message.DecimalSeparator !== "")
|
||||
writer.tag(7, WireType.LengthDelimited).string(message.DecimalSeparator);
|
||||
/* repeated string ColumnNames = 8; */
|
||||
for (let i = 0; i < message.ColumnNames.length; i++)
|
||||
writer.tag(8, WireType.LengthDelimited).string(message.ColumnNames[i]);
|
||||
/* map<string, api.TranslationMap> ColumnTranslationMaps = 9; */
|
||||
for (let k of globalThis.Object.keys(message.ColumnTranslationMaps)) {
|
||||
writer.tag(9, WireType.LengthDelimited).fork().tag(1, WireType.LengthDelimited).string(k);
|
||||
writer.tag(2, WireType.LengthDelimited).fork();
|
||||
TranslationMap.internalBinaryWrite(message.ColumnTranslationMaps[k], writer, options);
|
||||
writer.join().join();
|
||||
}
|
||||
/* map<int32, api.ExtractColumnFormat> ColumnFormats = 10; */
|
||||
for (let k of globalThis.Object.keys(message.ColumnFormats)) {
|
||||
writer.tag(10, WireType.LengthDelimited).fork().tag(1, WireType.Varint).int32(parseInt(k));
|
||||
writer.tag(2, WireType.LengthDelimited).fork();
|
||||
ExtractColumnFormat.internalBinaryWrite(message.ColumnFormats[k as any], writer, options);
|
||||
writer.join().join();
|
||||
}
|
||||
/* string TargetTimeZone = 11; */
|
||||
if (message.TargetTimeZone !== "")
|
||||
writer.tag(11, WireType.LengthDelimited).string(message.TargetTimeZone);
|
||||
/* string DateFormat = 12; */
|
||||
if (message.DateFormat !== "")
|
||||
writer.tag(12, WireType.LengthDelimited).string(message.DateFormat);
|
||||
/* string NumberFormat = 13; */
|
||||
if (message.NumberFormat !== "")
|
||||
writer.tag(13, WireType.LengthDelimited).string(message.NumberFormat);
|
||||
/* api.TimeFormat TimeFormat = 14; */
|
||||
if (message.TimeFormat !== 0)
|
||||
writer.tag(14, WireType.Varint).int32(message.TimeFormat);
|
||||
/* repeated string SearchTagProjects = 15; */
|
||||
for (let i = 0; i < message.SearchTagProjects.length; i++)
|
||||
writer.tag(15, WireType.LengthDelimited).string(message.SearchTagProjects[i]);
|
||||
/* repeated string SearchTagUsers = 16; */
|
||||
for (let i = 0; i < message.SearchTagUsers.length; i++)
|
||||
writer.tag(16, WireType.LengthDelimited).string(message.SearchTagUsers[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.StartWorkflowCrossExtractDataFromDBRequest
|
||||
*/
|
||||
export const StartWorkflowCrossExtractDataFromDBRequest = new StartWorkflowCrossExtractDataFromDBRequest$Type();
|
||||
// @generated message type with reflection information, may provide speed optimized methods
|
||||
class StartWorkflowExtractDataFromDBResult$Type extends MessageType<StartWorkflowExtractDataFromDBResult> {
|
||||
constructor() {
|
||||
super("api.StartWorkflowExtractDataFromDBResult", [
|
||||
@@ -4723,6 +5003,7 @@ export const WorkflowService = new ServiceType("api.WorkflowService", [
|
||||
{ name: "StartWorkflowBilling", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Workflow"], description: "Start a workflow Billing" }, "api.rscType": "Platform", "api.roles": "Platform.Workflow", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: StartWorkflowBillingRequest, O: StartWorkflowBillingResult },
|
||||
{ name: "StopWorkflowBilling", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Workflow"], description: "Stop the Billing workflow" }, "api.rscType": "Platform", "api.roles": "Platform.Workflow", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: StopWorkflowBillingRequest, O: StopWorkflowBillingResult },
|
||||
{ name: "StartWorkflowExtractDataFromDB", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Workflow"], description: "Start a workflow ExtractDataFromDB" }, "api.rscType": "Platform", "api.roles": "Platform.Workflow", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: StartWorkflowExtractDataFromDBRequest, O: StartWorkflowExtractDataFromDBResult },
|
||||
{ name: "StartWorkflowCrossExtractDataFromDB", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Workflow"], description: "Start a workflow CrossExtractDataFromDB" }, "api.rscType": "Platform", "api.roles": "Platform.Workflow", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: StartWorkflowCrossExtractDataFromDBRequest, O: StartWorkflowExtractDataFromDBResult },
|
||||
{ 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 },
|
||||
|
||||
Reference in New Issue
Block a user