reflex-platform/npm-core-sdk
0
Fork 0
Code Pull Requests Projects Releases Wiki Activity
Files
513c7e00a7ae0cd263324a5cfd48574baf5c45af
npm-core-sdk/connector.ts
ci core model 35023738c7 Latest generation
2025-12-09 11:20:34 +00:00

1407 lines
67 KiB
TypeScript
Raw Blame History

// @generated by protobuf-ts 2.11.1 with parameter use_proto_field_name,keep_enum_prefix
// @generated from protobuf file "connector.proto" (package "api", syntax proto3)
// tslint:disable
import { ServiceType } from "@protobuf-ts/runtime-rpc";
import type { BinaryWriteOptions } from "@protobuf-ts/runtime";
import type { IBinaryWriter } from "@protobuf-ts/runtime";
import { WireType } from "@protobuf-ts/runtime";
import type { BinaryReadOptions } from "@protobuf-ts/runtime";
import type { IBinaryReader } from "@protobuf-ts/runtime";
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 { RequestProjectHeader } from "./shared";
import { Paging } from "./base";
import { Permission } from "./shared";
/**
* @generated from protobuf message api.Connector
*/
export interface Connector {
/**
* @generated from protobuf field: string ID = 1
*/
ID: string;
/**
* @generated from protobuf field: string Name = 2
*/
Name: string;
/**
* @generated from protobuf field: api.ConnectorType Type = 3
*/
Type: ConnectorType;
/**
* @generated from protobuf field: string Description = 4
*/
Description: string;
/**
* @generated from protobuf field: string Version = 5
*/
Version: string;
/**
* @generated from protobuf field: string RepoUrl = 6
*/
RepoUrl: string;
/**
* @generated from protobuf field: string MainClassName = 7
*/
MainClassName: string;
/**
* @generated from protobuf field: string JarName = 8
*/
JarName: string;
/**
* @generated from protobuf field: string SetupJson = 9
*/
SetupJson: string;
/**
* @generated from protobuf field: string MetadataJSONParameters = 10
*/
MetadataJSONParameters: string;
/**
* @generated from protobuf field: int32 NbSlots = 11
*/
NbSlots: number;
/**
* @generated from protobuf field: string DistributionName = 12
*/
DistributionName: string;
/**
* @generated from protobuf field: string Release = 13
*/
Release: string;
/**
* @generated from protobuf field: string ActionsJSONParameters = 14
*/
ActionsJSONParameters: string;
}
/**
* @generated from protobuf message api.ParameterMetadata
*/
export interface ParameterMetadata {
/**
* @generated from protobuf field: string name = 1
*/
name: string;
/**
* @generated from protobuf field: string label = 2
*/
label: string;
/**
* @generated from protobuf field: string help_text = 3
*/
help_text: string;
/**
* @generated from protobuf field: bool mandatory = 4
*/
mandatory: boolean;
/**
* @generated from protobuf field: string group_id = 5
*/
group_id: string;
/**
* @generated from protobuf field: int32 order_id = 6
*/
order_id: number;
/**
* @generated from protobuf field: string type = 7
*/
type: string;
/**
* @generated from protobuf field: map<string, string> custom_info = 8
*/
custom_info: {
[key: string]: string;
};
}
/**
* @generated from protobuf message api.CreateConnectorRequest
*/
export interface CreateConnectorRequest {
/**
* @generated from protobuf field: string Name = 1
*/
Name: string;
/**
* @generated from protobuf field: api.ConnectorType Type = 2
*/
Type: ConnectorType;
/**
* @generated from protobuf field: string Description = 3
*/
Description: string;
/**
* @generated from protobuf field: string Version = 4
*/
Version: string;
/**
* @generated from protobuf field: string RepoUrl = 5
*/
RepoUrl: string;
/**
* @generated from protobuf field: string MainClassName = 6
*/
MainClassName: string;
/**
* @generated from protobuf field: string JarName = 7
*/
JarName: string;
/**
* @generated from protobuf field: string SetupJson = 8
*/
SetupJson: string;
/**
* @generated from protobuf field: string MetadataJSONParameters = 9
*/
MetadataJSONParameters: string;
/**
* @generated from protobuf field: int32 NbSlots = 10
*/
NbSlots: number;
/**
* @generated from protobuf field: repeated api.Permission Permissions = 11
*/
Permissions: Permission[];
/**
* @generated from protobuf field: string DistributionName = 12
*/
DistributionName: string;
/**
* @generated from protobuf field: string ActionsJSONParameters = 13
*/
ActionsJSONParameters: string;
}
/**
* @generated from protobuf message api.CreateConnectorResult
*/
export interface CreateConnectorResult {
/**
* @generated from protobuf field: api.Connector Result = 1
*/
Result?: Connector;
}
/**
* @generated from protobuf message api.UpdateConnectorRequest
*/
export interface UpdateConnectorRequest {
/**
* @generated from protobuf field: string ConnectorID = 1
*/
ConnectorID: string;
/**
* @generated from protobuf field: string Description = 2
*/
Description: string;
/**
* @generated from protobuf field: string Version = 3
*/
Version: string;
/**
* @generated from protobuf field: string RepoUrl = 4
*/
RepoUrl: string;
/**
* @generated from protobuf field: string MainClassName = 5
*/
MainClassName: string;
/**
* @generated from protobuf field: string JarName = 6
*/
JarName: string;
/**
* @generated from protobuf field: string SetupJson = 7
*/
SetupJson: string;
/**
* @generated from protobuf field: string MetadataJSONParameters = 8
*/
MetadataJSONParameters: string;
/**
* @generated from protobuf field: int32 NbSlots = 9
*/
NbSlots: number;
/**
* @generated from protobuf field: repeated api.Permission Permissions = 10
*/
Permissions: Permission[];
/**
* @generated from protobuf field: string ActionsJSONParameters = 11
*/
ActionsJSONParameters: string;
}
/**
* @generated from protobuf message api.UpdateConnectorResult
*/
export interface UpdateConnectorResult {
/**
* @generated from protobuf field: api.Connector Result = 1
*/
Result?: Connector;
}
/**
* @generated from protobuf message api.GetConnectorRequest
*/
export interface GetConnectorRequest {
/**
* @generated from protobuf field: string ConnectorID = 1
*/
ConnectorID: string;
}
/**
* @generated from protobuf message api.GetConnectorResult
*/
export interface GetConnectorResult {
/**
* @generated from protobuf field: api.Connector Result = 1
*/
Result?: Connector;
}
/**
* @generated from protobuf message api.ListConnectorsRequest
*/
export interface ListConnectorsRequest {
/**
* @generated from protobuf field: api.Paging Paging = 1
*/
Paging?: Paging;
}
/**
* @generated from protobuf message api.ListConnectorsResult
*/
export interface ListConnectorsResult {
/**
* @generated from protobuf field: repeated api.Connector Results = 1
*/
Results: Connector[];
}
/**
* @generated from protobuf message api.ListAvailableConnectorsRequest
*/
export interface ListAvailableConnectorsRequest {
/**
* @generated from protobuf field: api.RequestProjectHeader Header = 1
*/
Header?: RequestProjectHeader;
}
/**
* @generated from protobuf message api.ListAvailableConnectorsResult
*/
export interface ListAvailableConnectorsResult {
/**
* @generated from protobuf field: repeated api.Connector Results = 1
*/
Results: Connector[];
}
/**
* @generated from protobuf message api.DeleteConnectorRequest
*/
export interface DeleteConnectorRequest {
/**
* @generated from protobuf field: string ConnectorID = 1
*/
ConnectorID: string;
}
/**
* @generated from protobuf message api.DeleteConnectorResult
*/
export interface DeleteConnectorResult {
}
/**
* @generated from protobuf enum api.ConnectorType
*/
export enum ConnectorType {
/**
* @generated from protobuf enum value: CUSTOM = 0;
*/
CUSTOM = 0,
/**
* @generated from protobuf enum value: RFX = 10;
*/
RFX = 10,
/**
* @generated from protobuf enum value: TDI = 20;
*/
TDI = 20
}
/**
* @generated from protobuf enum api.ParameterMetadataType
*/
export enum ParameterMetadataType {
/**
* @generated from protobuf enum value: STRING = 0;
*/
STRING = 0,
/**
* @generated from protobuf enum value: INTEGER = 10;
*/
INTEGER = 10,
/**
* @generated from protobuf enum value: BOOLEAN = 20;
*/
BOOLEAN = 20,
/**
* @generated from protobuf enum value: FILE = 30;
*/
FILE = 30,
/**
* @generated from protobuf enum value: URL = 40;
*/
URL = 40,
/**
* @generated from protobuf enum value: SET = 50;
*/
SET = 50
}
/**
* @generated from protobuf enum api.Keyword
*/
export enum Keyword {
/**
* @generated from protobuf enum value: UNKNOWN = 0;
*/
UNKNOWN = 0,
/**
* @generated from protobuf enum value: ORGANISATION_ID = 10;
*/
ORGANISATION_ID = 10,
/**
* @generated from protobuf enum value: PROJECT_ID = 20;
*/
PROJECT_ID = 20,
/**
* @generated from protobuf enum value: PARTNER_APP_ID = 30;
*/
PARTNER_APP_ID = 30,
/**
* @generated from protobuf enum value: AUTHZ_ENDPOINT = 40;
*/
AUTHZ_ENDPOINT = 40,
/**
* @generated from protobuf enum value: BUCKET_ROOT = 50;
*/
BUCKET_ROOT = 50,
/**
* @generated from protobuf enum value: GRPC_API_CORE_ENDPOINT = 60;
*/
GRPC_API_CORE_ENDPOINT = 60,
/**
* @generated from protobuf enum value: GRPC_API_GCS_ENDPOINT = 70;
*/
GRPC_API_GCS_ENDPOINT = 70,
/**
* @generated from protobuf enum value: NATS_ENDPOINT = 80;
*/
NATS_ENDPOINT = 80,
/**
* @generated from protobuf enum value: NATS_ROOT_SUBJECT = 90;
*/
NATS_ROOT_SUBJECT = 90
}
// @generated message type with reflection information, may provide speed optimized methods
class Connector$Type extends MessageType<Connector> {
constructor() {
super("api.Connector", [
{ no: 1, name: "ID", kind: "scalar", localName: "ID", jsonName: "ID", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1", pattern: "^([a-z0-9-])+$" } }, "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { pattern: "^([a-z0-9-])+$" } } },
{ no: 2, name: "Name", kind: "scalar", localName: "Name", jsonName: "Name", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } },
{ no: 3, name: "Type", kind: "enum", localName: "Type", jsonName: "Type", T: () => ["api.ConnectorType", ConnectorType], options: { "validate.rules": { enum: { definedOnly: true } } } },
{ no: 4, name: "Description", kind: "scalar", localName: "Description", jsonName: "Description", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } },
{ no: 5, name: "Version", kind: "scalar", localName: "Version", jsonName: "Version", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } },
{ no: 6, name: "RepoUrl", kind: "scalar", localName: "RepoUrl", jsonName: "RepoUrl", T: 9 /*ScalarType.STRING*/ },
{ no: 7, name: "MainClassName", kind: "scalar", localName: "MainClassName", jsonName: "MainClassName", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } },
{ no: 8, name: "JarName", kind: "scalar", localName: "JarName", jsonName: "JarName", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } },
{ no: 9, name: "SetupJson", kind: "scalar", localName: "SetupJson", jsonName: "SetupJson", T: 9 /*ScalarType.STRING*/ },
{ no: 10, name: "MetadataJSONParameters", kind: "scalar", localName: "MetadataJSONParameters", jsonName: "MetadataJSONParameters", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } },
{ no: 11, name: "NbSlots", kind: "scalar", localName: "NbSlots", jsonName: "NbSlots", T: 5 /*ScalarType.INT32*/ },
{ no: 12, name: "DistributionName", kind: "scalar", localName: "DistributionName", jsonName: "DistributionName", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } },
{ no: 13, name: "Release", kind: "scalar", localName: "Release", jsonName: "Release", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } },
{ no: 14, name: "ActionsJSONParameters", kind: "scalar", localName: "ActionsJSONParameters", jsonName: "ActionsJSONParameters", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } }
], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["ID", "Name", "Description", "Version", "MainClassName", "JarName", "MetadataJSONParameters", "DistributionName", "Release", "ActionsJSONParameters"] } } });
}
create(value?: PartialMessage<Connector>): Connector {
const message = globalThis.Object.create((this.messagePrototype!));
message.ID = "";
message.Name = "";
message.Type = 0;
message.Description = "";
message.Version = "";
message.RepoUrl = "";
message.MainClassName = "";
message.JarName = "";
message.SetupJson = "";
message.MetadataJSONParameters = "";
message.NbSlots = 0;
message.DistributionName = "";
message.Release = "";
message.ActionsJSONParameters = "";
if (value !== undefined)
reflectionMergePartial<Connector>(this, message, value);
return message;
}
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: Connector): Connector {
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;
case /* string Name */ 2:
message.Name = reader.string();
break;
case /* api.ConnectorType Type */ 3:
message.Type = reader.int32();
break;
case /* string Description */ 4:
message.Description = reader.string();
break;
case /* string Version */ 5:
message.Version = reader.string();
break;
case /* string RepoUrl */ 6:
message.RepoUrl = reader.string();
break;
case /* string MainClassName */ 7:
message.MainClassName = reader.string();
break;
case /* string JarName */ 8:
message.JarName = reader.string();
break;
case /* string SetupJson */ 9:
message.SetupJson = reader.string();
break;
case /* string MetadataJSONParameters */ 10:
message.MetadataJSONParameters = reader.string();
break;
case /* int32 NbSlots */ 11:
message.NbSlots = reader.int32();
break;
case /* string DistributionName */ 12:
message.DistributionName = reader.string();
break;
case /* string Release */ 13:
message.Release = reader.string();
break;
case /* string ActionsJSONParameters */ 14:
message.ActionsJSONParameters = 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: Connector, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
/* string ID = 1; */
if (message.ID !== "")
writer.tag(1, WireType.LengthDelimited).string(message.ID);
/* string Name = 2; */
if (message.Name !== "")
writer.tag(2, WireType.LengthDelimited).string(message.Name);
/* api.ConnectorType Type = 3; */
if (message.Type !== 0)
writer.tag(3, WireType.Varint).int32(message.Type);
/* string Description = 4; */
if (message.Description !== "")
writer.tag(4, WireType.LengthDelimited).string(message.Description);
/* string Version = 5; */
if (message.Version !== "")
writer.tag(5, WireType.LengthDelimited).string(message.Version);
/* string RepoUrl = 6; */
if (message.RepoUrl !== "")
writer.tag(6, WireType.LengthDelimited).string(message.RepoUrl);
/* string MainClassName = 7; */
if (message.MainClassName !== "")
writer.tag(7, WireType.LengthDelimited).string(message.MainClassName);
/* string JarName = 8; */
if (message.JarName !== "")
writer.tag(8, WireType.LengthDelimited).string(message.JarName);
/* string SetupJson = 9; */
if (message.SetupJson !== "")
writer.tag(9, WireType.LengthDelimited).string(message.SetupJson);
/* string MetadataJSONParameters = 10; */
if (message.MetadataJSONParameters !== "")
writer.tag(10, WireType.LengthDelimited).string(message.MetadataJSONParameters);
/* int32 NbSlots = 11; */
if (message.NbSlots !== 0)
writer.tag(11, WireType.Varint).int32(message.NbSlots);
/* string DistributionName = 12; */
if (message.DistributionName !== "")
writer.tag(12, WireType.LengthDelimited).string(message.DistributionName);
/* string Release = 13; */
if (message.Release !== "")
writer.tag(13, WireType.LengthDelimited).string(message.Release);
/* string ActionsJSONParameters = 14; */
if (message.ActionsJSONParameters !== "")
writer.tag(14, WireType.LengthDelimited).string(message.ActionsJSONParameters);
let u = options.writeUnknownFields;
if (u !== false)
(u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
return writer;
}
}
/**
* @generated MessageType for protobuf message api.Connector
*/
export const Connector = new Connector$Type();
// @generated message type with reflection information, may provide speed optimized methods
class ParameterMetadata$Type extends MessageType<ParameterMetadata> {
constructor() {
super("api.ParameterMetadata", [
{ no: 1, name: "name", kind: "scalar", T: 9 /*ScalarType.STRING*/ },
{ no: 2, name: "label", kind: "scalar", T: 9 /*ScalarType.STRING*/ },
{ no: 3, name: "help_text", kind: "scalar", localName: "help_text", T: 9 /*ScalarType.STRING*/ },
{ no: 4, name: "mandatory", kind: "scalar", T: 8 /*ScalarType.BOOL*/ },
{ no: 5, name: "group_id", kind: "scalar", localName: "group_id", T: 9 /*ScalarType.STRING*/ },
{ no: 6, name: "order_id", kind: "scalar", localName: "order_id", T: 5 /*ScalarType.INT32*/ },
{ no: 7, name: "type", kind: "scalar", T: 9 /*ScalarType.STRING*/ },
{ no: 8, name: "custom_info", kind: "map", localName: "custom_info", K: 9 /*ScalarType.STRING*/, V: { kind: "scalar", T: 9 /*ScalarType.STRING*/ } }
]);
}
create(value?: PartialMessage<ParameterMetadata>): ParameterMetadata {
const message = globalThis.Object.create((this.messagePrototype!));
message.name = "";
message.label = "";
message.help_text = "";
message.mandatory = false;
message.group_id = "";
message.order_id = 0;
message.type = "";
message.custom_info = {};
if (value !== undefined)
reflectionMergePartial<ParameterMetadata>(this, message, value);
return message;
}
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ParameterMetadata): ParameterMetadata {
let message = target ?? this.create(), end = reader.pos + length;
while (reader.pos < end) {
let [fieldNo, wireType] = reader.tag();
switch (fieldNo) {
case /* string name */ 1:
message.name = reader.string();
break;
case /* string label */ 2:
message.label = reader.string();
break;
case /* string help_text */ 3:
message.help_text = reader.string();
break;
case /* bool mandatory */ 4:
message.mandatory = reader.bool();
break;
case /* string group_id */ 5:
message.group_id = reader.string();
break;
case /* int32 order_id */ 6:
message.order_id = reader.int32();
break;
case /* string type */ 7:
message.type = reader.string();
break;
case /* map<string, string> custom_info */ 8:
this.binaryReadMap8(message.custom_info, reader, options);
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 binaryReadMap8(map: ParameterMetadata["custom_info"], reader: IBinaryReader, options: BinaryReadOptions): void {
let len = reader.uint32(), end = reader.pos + len, key: keyof ParameterMetadata["custom_info"] | undefined, val: ParameterMetadata["custom_info"][any] | undefined;
while (reader.pos < end) {
let [fieldNo, wireType] = reader.tag();
switch (fieldNo) {
case 1:
key = reader.string();
break;
case 2:
val = reader.string();
break;
default: throw new globalThis.Error("unknown map entry field for api.ParameterMetadata.custom_info");
}
}
map[key ?? ""] = val ?? "";
}
internalBinaryWrite(message: ParameterMetadata, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
/* string name = 1; */
if (message.name !== "")
writer.tag(1, WireType.LengthDelimited).string(message.name);
/* string label = 2; */
if (message.label !== "")
writer.tag(2, WireType.LengthDelimited).string(message.label);
/* string help_text = 3; */
if (message.help_text !== "")
writer.tag(3, WireType.LengthDelimited).string(message.help_text);
/* bool mandatory = 4; */
if (message.mandatory !== false)
writer.tag(4, WireType.Varint).bool(message.mandatory);
/* string group_id = 5; */
if (message.group_id !== "")
writer.tag(5, WireType.LengthDelimited).string(message.group_id);
/* int32 order_id = 6; */
if (message.order_id !== 0)
writer.tag(6, WireType.Varint).int32(message.order_id);
/* string type = 7; */
if (message.type !== "")
writer.tag(7, WireType.LengthDelimited).string(message.type);
/* map<string, string> custom_info = 8; */
for (let k of globalThis.Object.keys(message.custom_info))
writer.tag(8, WireType.LengthDelimited).fork().tag(1, WireType.LengthDelimited).string(k).tag(2, WireType.LengthDelimited).string(message.custom_info[k]).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.ParameterMetadata
*/
export const ParameterMetadata = new ParameterMetadata$Type();
// @generated message type with reflection information, may provide speed optimized methods
class CreateConnectorRequest$Type extends MessageType<CreateConnectorRequest> {
constructor() {
super("api.CreateConnectorRequest", [
{ no: 1, name: "Name", kind: "scalar", localName: "Name", jsonName: "Name", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1", pattern: "^([A-Za-z0-9-])+$" } }, "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { pattern: "^([A-Za-z0-9-])+$" } } },
{ no: 2, name: "Type", kind: "enum", localName: "Type", jsonName: "Type", T: () => ["api.ConnectorType", ConnectorType], options: { "validate.rules": { enum: { definedOnly: true } } } },
{ no: 3, name: "Description", kind: "scalar", localName: "Description", jsonName: "Description", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } },
{ no: 4, name: "Version", kind: "scalar", localName: "Version", jsonName: "Version", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1", pattern: "^([A-Za-z0-9-.])+$" } }, "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { pattern: "^([A-Za-z0-9-.])+$" } } },
{ no: 5, name: "RepoUrl", kind: "scalar", localName: "RepoUrl", jsonName: "RepoUrl", T: 9 /*ScalarType.STRING*/ },
{ no: 6, name: "MainClassName", kind: "scalar", localName: "MainClassName", jsonName: "MainClassName", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } },
{ no: 7, name: "JarName", kind: "scalar", localName: "JarName", jsonName: "JarName", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } },
{ no: 8, name: "SetupJson", kind: "scalar", localName: "SetupJson", jsonName: "SetupJson", T: 9 /*ScalarType.STRING*/ },
{ no: 9, name: "MetadataJSONParameters", kind: "scalar", localName: "MetadataJSONParameters", jsonName: "MetadataJSONParameters", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } },
{ no: 10, name: "NbSlots", kind: "scalar", localName: "NbSlots", jsonName: "NbSlots", T: 5 /*ScalarType.INT32*/ },
{ no: 11, name: "Permissions", kind: "message", localName: "Permissions", jsonName: "Permissions", repeat: 2 /*RepeatType.UNPACKED*/, T: () => Permission },
{ no: 12, name: "DistributionName", kind: "scalar", localName: "DistributionName", jsonName: "DistributionName", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } },
{ no: 13, name: "ActionsJSONParameters", kind: "scalar", localName: "ActionsJSONParameters", jsonName: "ActionsJSONParameters", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } }
], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["Name", "Description", "Version", "MainClassName", "JarName", "MetadataJSONParameters", "DistributionName", "ActionsJSONParameters"] } } });
}
create(value?: PartialMessage<CreateConnectorRequest>): CreateConnectorRequest {
const message = globalThis.Object.create((this.messagePrototype!));
message.Name = "";
message.Type = 0;
message.Description = "";
message.Version = "";
message.RepoUrl = "";
message.MainClassName = "";
message.JarName = "";
message.SetupJson = "";
message.MetadataJSONParameters = "";
message.NbSlots = 0;
message.Permissions = [];
message.DistributionName = "";
message.ActionsJSONParameters = "";
if (value !== undefined)
reflectionMergePartial<CreateConnectorRequest>(this, message, value);
return message;
}
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: CreateConnectorRequest): CreateConnectorRequest {
let message = target ?? this.create(), end = reader.pos + length;
while (reader.pos < end) {
let [fieldNo, wireType] = reader.tag();
switch (fieldNo) {
case /* string Name */ 1:
message.Name = reader.string();
break;
case /* api.ConnectorType Type */ 2:
message.Type = reader.int32();
break;
case /* string Description */ 3:
message.Description = reader.string();
break;
case /* string Version */ 4:
message.Version = reader.string();
break;
case /* string RepoUrl */ 5:
message.RepoUrl = reader.string();
break;
case /* string MainClassName */ 6:
message.MainClassName = reader.string();
break;
case /* string JarName */ 7:
message.JarName = reader.string();
break;
case /* string SetupJson */ 8:
message.SetupJson = reader.string();
break;
case /* string MetadataJSONParameters */ 9:
message.MetadataJSONParameters = reader.string();
break;
case /* int32 NbSlots */ 10:
message.NbSlots = reader.int32();
break;
case /* repeated api.Permission Permissions */ 11:
message.Permissions.push(Permission.internalBinaryRead(reader, reader.uint32(), options));
break;
case /* string DistributionName */ 12:
message.DistributionName = reader.string();
break;
case /* string ActionsJSONParameters */ 13:
message.ActionsJSONParameters = 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: CreateConnectorRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
/* string Name = 1; */
if (message.Name !== "")
writer.tag(1, WireType.LengthDelimited).string(message.Name);
/* api.ConnectorType Type = 2; */
if (message.Type !== 0)
writer.tag(2, WireType.Varint).int32(message.Type);
/* string Description = 3; */
if (message.Description !== "")
writer.tag(3, WireType.LengthDelimited).string(message.Description);
/* string Version = 4; */
if (message.Version !== "")
writer.tag(4, WireType.LengthDelimited).string(message.Version);
/* string RepoUrl = 5; */
if (message.RepoUrl !== "")
writer.tag(5, WireType.LengthDelimited).string(message.RepoUrl);
/* string MainClassName = 6; */
if (message.MainClassName !== "")
writer.tag(6, WireType.LengthDelimited).string(message.MainClassName);
/* string JarName = 7; */
if (message.JarName !== "")
writer.tag(7, WireType.LengthDelimited).string(message.JarName);
/* string SetupJson = 8; */
if (message.SetupJson !== "")
writer.tag(8, WireType.LengthDelimited).string(message.SetupJson);
/* string MetadataJSONParameters = 9; */
if (message.MetadataJSONParameters !== "")
writer.tag(9, WireType.LengthDelimited).string(message.MetadataJSONParameters);
/* int32 NbSlots = 10; */
if (message.NbSlots !== 0)
writer.tag(10, WireType.Varint).int32(message.NbSlots);
/* repeated api.Permission Permissions = 11; */
for (let i = 0; i < message.Permissions.length; i++)
Permission.internalBinaryWrite(message.Permissions[i], writer.tag(11, WireType.LengthDelimited).fork(), options).join();
/* string DistributionName = 12; */
if (message.DistributionName !== "")
writer.tag(12, WireType.LengthDelimited).string(message.DistributionName);
/* string ActionsJSONParameters = 13; */
if (message.ActionsJSONParameters !== "")
writer.tag(13, WireType.LengthDelimited).string(message.ActionsJSONParameters);
let u = options.writeUnknownFields;
if (u !== false)
(u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
return writer;
}
}
/**
* @generated MessageType for protobuf message api.CreateConnectorRequest
*/
export const CreateConnectorRequest = new CreateConnectorRequest$Type();
// @generated message type with reflection information, may provide speed optimized methods
class CreateConnectorResult$Type extends MessageType<CreateConnectorResult> {
constructor() {
super("api.CreateConnectorResult", [
{ no: 1, name: "Result", kind: "message", localName: "Result", jsonName: "Result", T: () => Connector }
]);
}
create(value?: PartialMessage<CreateConnectorResult>): CreateConnectorResult {
const message = globalThis.Object.create((this.messagePrototype!));
if (value !== undefined)
reflectionMergePartial<CreateConnectorResult>(this, message, value);
return message;
}
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: CreateConnectorResult): CreateConnectorResult {
let message = target ?? this.create(), end = reader.pos + length;
while (reader.pos < end) {
let [fieldNo, wireType] = reader.tag();
switch (fieldNo) {
case /* api.Connector Result */ 1:
message.Result = Connector.internalBinaryRead(reader, reader.uint32(), options, message.Result);
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: CreateConnectorResult, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
/* api.Connector Result = 1; */
if (message.Result)
Connector.internalBinaryWrite(message.Result, 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.CreateConnectorResult
*/
export const CreateConnectorResult = new CreateConnectorResult$Type();
// @generated message type with reflection information, may provide speed optimized methods
class UpdateConnectorRequest$Type extends MessageType<UpdateConnectorRequest> {
constructor() {
super("api.UpdateConnectorRequest", [
{ no: 1, name: "ConnectorID", kind: "scalar", localName: "ConnectorID", jsonName: "ConnectorID", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } },
{ no: 2, name: "Description", kind: "scalar", localName: "Description", jsonName: "Description", T: 9 /*ScalarType.STRING*/ },
{ no: 3, name: "Version", kind: "scalar", localName: "Version", jsonName: "Version", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1", pattern: "^([A-Za-z0-9-.])+$" } }, "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_field": { pattern: "^([A-Za-z0-9-.])+$" } } },
{ no: 4, name: "RepoUrl", kind: "scalar", localName: "RepoUrl", jsonName: "RepoUrl", T: 9 /*ScalarType.STRING*/ },
{ no: 5, name: "MainClassName", kind: "scalar", localName: "MainClassName", jsonName: "MainClassName", T: 9 /*ScalarType.STRING*/ },
{ no: 6, name: "JarName", kind: "scalar", localName: "JarName", jsonName: "JarName", T: 9 /*ScalarType.STRING*/ },
{ no: 7, name: "SetupJson", kind: "scalar", localName: "SetupJson", jsonName: "SetupJson", T: 9 /*ScalarType.STRING*/ },
{ no: 8, name: "MetadataJSONParameters", kind: "scalar", localName: "MetadataJSONParameters", jsonName: "MetadataJSONParameters", T: 9 /*ScalarType.STRING*/ },
{ no: 9, name: "NbSlots", kind: "scalar", localName: "NbSlots", jsonName: "NbSlots", T: 5 /*ScalarType.INT32*/ },
{ no: 10, name: "Permissions", kind: "message", localName: "Permissions", jsonName: "Permissions", repeat: 2 /*RepeatType.UNPACKED*/, T: () => Permission },
{ no: 11, name: "ActionsJSONParameters", kind: "scalar", localName: "ActionsJSONParameters", jsonName: "ActionsJSONParameters", T: 9 /*ScalarType.STRING*/ }
], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["ConnectorID", "Version"] } } });
}
create(value?: PartialMessage<UpdateConnectorRequest>): UpdateConnectorRequest {
const message = globalThis.Object.create((this.messagePrototype!));
message.ConnectorID = "";
message.Description = "";
message.Version = "";
message.RepoUrl = "";
message.MainClassName = "";
message.JarName = "";
message.SetupJson = "";
message.MetadataJSONParameters = "";
message.NbSlots = 0;
message.Permissions = [];
message.ActionsJSONParameters = "";
if (value !== undefined)
reflectionMergePartial<UpdateConnectorRequest>(this, message, value);
return message;
}
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: UpdateConnectorRequest): UpdateConnectorRequest {
let message = target ?? this.create(), end = reader.pos + length;
while (reader.pos < end) {
let [fieldNo, wireType] = reader.tag();
switch (fieldNo) {
case /* string ConnectorID */ 1:
message.ConnectorID = reader.string();
break;
case /* string Description */ 2:
message.Description = reader.string();
break;
case /* string Version */ 3:
message.Version = reader.string();
break;
case /* string RepoUrl */ 4:
message.RepoUrl = reader.string();
break;
case /* string MainClassName */ 5:
message.MainClassName = reader.string();
break;
case /* string JarName */ 6:
message.JarName = reader.string();
break;
case /* string SetupJson */ 7:
message.SetupJson = reader.string();
break;
case /* string MetadataJSONParameters */ 8:
message.MetadataJSONParameters = reader.string();
break;
case /* int32 NbSlots */ 9:
message.NbSlots = reader.int32();
break;
case /* repeated api.Permission Permissions */ 10:
message.Permissions.push(Permission.internalBinaryRead(reader, reader.uint32(), options));
break;
case /* string ActionsJSONParameters */ 11:
message.ActionsJSONParameters = 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: UpdateConnectorRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
/* string ConnectorID = 1; */
if (message.ConnectorID !== "")
writer.tag(1, WireType.LengthDelimited).string(message.ConnectorID);
/* string Description = 2; */
if (message.Description !== "")
writer.tag(2, WireType.LengthDelimited).string(message.Description);
/* string Version = 3; */
if (message.Version !== "")
writer.tag(3, WireType.LengthDelimited).string(message.Version);
/* string RepoUrl = 4; */
if (message.RepoUrl !== "")
writer.tag(4, WireType.LengthDelimited).string(message.RepoUrl);
/* string MainClassName = 5; */
if (message.MainClassName !== "")
writer.tag(5, WireType.LengthDelimited).string(message.MainClassName);
/* string JarName = 6; */
if (message.JarName !== "")
writer.tag(6, WireType.LengthDelimited).string(message.JarName);
/* string SetupJson = 7; */
if (message.SetupJson !== "")
writer.tag(7, WireType.LengthDelimited).string(message.SetupJson);
/* string MetadataJSONParameters = 8; */
if (message.MetadataJSONParameters !== "")
writer.tag(8, WireType.LengthDelimited).string(message.MetadataJSONParameters);
/* int32 NbSlots = 9; */
if (message.NbSlots !== 0)
writer.tag(9, WireType.Varint).int32(message.NbSlots);
/* repeated api.Permission Permissions = 10; */
for (let i = 0; i < message.Permissions.length; i++)
Permission.internalBinaryWrite(message.Permissions[i], writer.tag(10, WireType.LengthDelimited).fork(), options).join();
/* string ActionsJSONParameters = 11; */
if (message.ActionsJSONParameters !== "")
writer.tag(11, WireType.LengthDelimited).string(message.ActionsJSONParameters);
let u = options.writeUnknownFields;
if (u !== false)
(u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
return writer;
}
}
/**
* @generated MessageType for protobuf message api.UpdateConnectorRequest
*/
export const UpdateConnectorRequest = new UpdateConnectorRequest$Type();
// @generated message type with reflection information, may provide speed optimized methods
class UpdateConnectorResult$Type extends MessageType<UpdateConnectorResult> {
constructor() {
super("api.UpdateConnectorResult", [
{ no: 1, name: "Result", kind: "message", localName: "Result", jsonName: "Result", T: () => Connector }
]);
}
create(value?: PartialMessage<UpdateConnectorResult>): UpdateConnectorResult {
const message = globalThis.Object.create((this.messagePrototype!));
if (value !== undefined)
reflectionMergePartial<UpdateConnectorResult>(this, message, value);
return message;
}
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: UpdateConnectorResult): UpdateConnectorResult {
let message = target ?? this.create(), end = reader.pos + length;
while (reader.pos < end) {
let [fieldNo, wireType] = reader.tag();
switch (fieldNo) {
case /* api.Connector Result */ 1:
message.Result = Connector.internalBinaryRead(reader, reader.uint32(), options, message.Result);
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: UpdateConnectorResult, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
/* api.Connector Result = 1; */
if (message.Result)
Connector.internalBinaryWrite(message.Result, 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.UpdateConnectorResult
*/
export const UpdateConnectorResult = new UpdateConnectorResult$Type();
// @generated message type with reflection information, may provide speed optimized methods
class GetConnectorRequest$Type extends MessageType<GetConnectorRequest> {
constructor() {
super("api.GetConnectorRequest", [
{ no: 1, name: "ConnectorID", kind: "scalar", localName: "ConnectorID", jsonName: "ConnectorID", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } }
], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["ConnectorID"] } } });
}
create(value?: PartialMessage<GetConnectorRequest>): GetConnectorRequest {
const message = globalThis.Object.create((this.messagePrototype!));
message.ConnectorID = "";
if (value !== undefined)
reflectionMergePartial<GetConnectorRequest>(this, message, value);
return message;
}
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: GetConnectorRequest): GetConnectorRequest {
let message = target ?? this.create(), end = reader.pos + length;
while (reader.pos < end) {
let [fieldNo, wireType] = reader.tag();
switch (fieldNo) {
case /* string ConnectorID */ 1:
message.ConnectorID = 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: GetConnectorRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
/* string ConnectorID = 1; */
if (message.ConnectorID !== "")
writer.tag(1, WireType.LengthDelimited).string(message.ConnectorID);
let u = options.writeUnknownFields;
if (u !== false)
(u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
return writer;
}
}
/**
* @generated MessageType for protobuf message api.GetConnectorRequest
*/
export const GetConnectorRequest = new GetConnectorRequest$Type();
// @generated message type with reflection information, may provide speed optimized methods
class GetConnectorResult$Type extends MessageType<GetConnectorResult> {
constructor() {
super("api.GetConnectorResult", [
{ no: 1, name: "Result", kind: "message", localName: "Result", jsonName: "Result", T: () => Connector }
]);
}
create(value?: PartialMessage<GetConnectorResult>): GetConnectorResult {
const message = globalThis.Object.create((this.messagePrototype!));
if (value !== undefined)
reflectionMergePartial<GetConnectorResult>(this, message, value);
return message;
}
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: GetConnectorResult): GetConnectorResult {
let message = target ?? this.create(), end = reader.pos + length;
while (reader.pos < end) {
let [fieldNo, wireType] = reader.tag();
switch (fieldNo) {
case /* api.Connector Result */ 1:
message.Result = Connector.internalBinaryRead(reader, reader.uint32(), options, message.Result);
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: GetConnectorResult, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
/* api.Connector Result = 1; */
if (message.Result)
Connector.internalBinaryWrite(message.Result, 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.GetConnectorResult
*/
export const GetConnectorResult = new GetConnectorResult$Type();
// @generated message type with reflection information, may provide speed optimized methods
class ListConnectorsRequest$Type extends MessageType<ListConnectorsRequest> {
constructor() {
super("api.ListConnectorsRequest", [
{ no: 1, name: "Paging", kind: "message", localName: "Paging", jsonName: "Paging", T: () => Paging }
]);
}
create(value?: PartialMessage<ListConnectorsRequest>): ListConnectorsRequest {
const message = globalThis.Object.create((this.messagePrototype!));
if (value !== undefined)
reflectionMergePartial<ListConnectorsRequest>(this, message, value);
return message;
}
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ListConnectorsRequest): ListConnectorsRequest {
let message = target ?? this.create(), end = reader.pos + length;
while (reader.pos < end) {
let [fieldNo, wireType] = reader.tag();
switch (fieldNo) {
case /* api.Paging Paging */ 1:
message.Paging = Paging.internalBinaryRead(reader, reader.uint32(), options, message.Paging);
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: ListConnectorsRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
/* api.Paging Paging = 1; */
if (message.Paging)
Paging.internalBinaryWrite(message.Paging, 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.ListConnectorsRequest
*/
export const ListConnectorsRequest = new ListConnectorsRequest$Type();
// @generated message type with reflection information, may provide speed optimized methods
class ListConnectorsResult$Type extends MessageType<ListConnectorsResult> {
constructor() {
super("api.ListConnectorsResult", [
{ no: 1, name: "Results", kind: "message", localName: "Results", jsonName: "Results", repeat: 2 /*RepeatType.UNPACKED*/, T: () => Connector }
]);
}
create(value?: PartialMessage<ListConnectorsResult>): ListConnectorsResult {
const message = globalThis.Object.create((this.messagePrototype!));
message.Results = [];
if (value !== undefined)
reflectionMergePartial<ListConnectorsResult>(this, message, value);
return message;
}
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ListConnectorsResult): ListConnectorsResult {
let message = target ?? this.create(), end = reader.pos + length;
while (reader.pos < end) {
let [fieldNo, wireType] = reader.tag();
switch (fieldNo) {
case /* repeated api.Connector Results */ 1:
message.Results.push(Connector.internalBinaryRead(reader, reader.uint32(), options));
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: ListConnectorsResult, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
/* repeated api.Connector Results = 1; */
for (let i = 0; i < message.Results.length; i++)
Connector.internalBinaryWrite(message.Results[i], 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.ListConnectorsResult
*/
export const ListConnectorsResult = new ListConnectorsResult$Type();
// @generated message type with reflection information, may provide speed optimized methods
class ListAvailableConnectorsRequest$Type extends MessageType<ListAvailableConnectorsRequest> {
constructor() {
super("api.ListAvailableConnectorsRequest", [
{ no: 1, name: "Header", kind: "message", localName: "Header", jsonName: "Header", T: () => RequestProjectHeader, options: { "validate.rules": { message: { required: true } } } }
], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["Header"] } } });
}
create(value?: PartialMessage<ListAvailableConnectorsRequest>): ListAvailableConnectorsRequest {
const message = globalThis.Object.create((this.messagePrototype!));
if (value !== undefined)
reflectionMergePartial<ListAvailableConnectorsRequest>(this, message, value);
return message;
}
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ListAvailableConnectorsRequest): ListAvailableConnectorsRequest {
let message = target ?? this.create(), end = reader.pos + length;
while (reader.pos < end) {
let [fieldNo, wireType] = reader.tag();
switch (fieldNo) {
case /* api.RequestProjectHeader Header */ 1:
message.Header = RequestProjectHeader.internalBinaryRead(reader, reader.uint32(), options, message.Header);
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: ListAvailableConnectorsRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
/* api.RequestProjectHeader Header = 1; */
if (message.Header)
RequestProjectHeader.internalBinaryWrite(message.Header, 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.ListAvailableConnectorsRequest
*/
export const ListAvailableConnectorsRequest = new ListAvailableConnectorsRequest$Type();
// @generated message type with reflection information, may provide speed optimized methods
class ListAvailableConnectorsResult$Type extends MessageType<ListAvailableConnectorsResult> {
constructor() {
super("api.ListAvailableConnectorsResult", [
{ no: 1, name: "Results", kind: "message", localName: "Results", jsonName: "Results", repeat: 2 /*RepeatType.UNPACKED*/, T: () => Connector }
]);
}
create(value?: PartialMessage<ListAvailableConnectorsResult>): ListAvailableConnectorsResult {
const message = globalThis.Object.create((this.messagePrototype!));
message.Results = [];
if (value !== undefined)
reflectionMergePartial<ListAvailableConnectorsResult>(this, message, value);
return message;
}
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ListAvailableConnectorsResult): ListAvailableConnectorsResult {
let message = target ?? this.create(), end = reader.pos + length;
while (reader.pos < end) {
let [fieldNo, wireType] = reader.tag();
switch (fieldNo) {
case /* repeated api.Connector Results */ 1:
message.Results.push(Connector.internalBinaryRead(reader, reader.uint32(), options));
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: ListAvailableConnectorsResult, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
/* repeated api.Connector Results = 1; */
for (let i = 0; i < message.Results.length; i++)
Connector.internalBinaryWrite(message.Results[i], 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.ListAvailableConnectorsResult
*/
export const ListAvailableConnectorsResult = new ListAvailableConnectorsResult$Type();
// @generated message type with reflection information, may provide speed optimized methods
class DeleteConnectorRequest$Type extends MessageType<DeleteConnectorRequest> {
constructor() {
super("api.DeleteConnectorRequest", [
{ no: 1, name: "ConnectorID", kind: "scalar", localName: "ConnectorID", jsonName: "ConnectorID", T: 9 /*ScalarType.STRING*/, options: { "validate.rules": { string: { minLen: "1" } } } }
], { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_schema": { jsonSchema: { required: ["ConnectorID"] } } });
}
create(value?: PartialMessage<DeleteConnectorRequest>): DeleteConnectorRequest {
const message = globalThis.Object.create((this.messagePrototype!));
message.ConnectorID = "";
if (value !== undefined)
reflectionMergePartial<DeleteConnectorRequest>(this, message, value);
return message;
}
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: DeleteConnectorRequest): DeleteConnectorRequest {
let message = target ?? this.create(), end = reader.pos + length;
while (reader.pos < end) {
let [fieldNo, wireType] = reader.tag();
switch (fieldNo) {
case /* string ConnectorID */ 1:
message.ConnectorID = 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: DeleteConnectorRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
/* string ConnectorID = 1; */
if (message.ConnectorID !== "")
writer.tag(1, WireType.LengthDelimited).string(message.ConnectorID);
let u = options.writeUnknownFields;
if (u !== false)
(u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
return writer;
}
}
/**
* @generated MessageType for protobuf message api.DeleteConnectorRequest
*/
export const DeleteConnectorRequest = new DeleteConnectorRequest$Type();
// @generated message type with reflection information, may provide speed optimized methods
class DeleteConnectorResult$Type extends MessageType<DeleteConnectorResult> {
constructor() {
super("api.DeleteConnectorResult", []);
}
create(value?: PartialMessage<DeleteConnectorResult>): DeleteConnectorResult {
const message = globalThis.Object.create((this.messagePrototype!));
if (value !== undefined)
reflectionMergePartial<DeleteConnectorResult>(this, message, value);
return message;
}
internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: DeleteConnectorResult): DeleteConnectorResult {
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: DeleteConnectorResult, 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.DeleteConnectorResult
*/
export const DeleteConnectorResult = new DeleteConnectorResult$Type();
/**
* @generated ServiceType for protobuf service api.ConnectorService
*/
export const ConnectorService = new ServiceType("api.ConnectorService", [
{ name: "Create", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Connector"], description: "Create a Platform Connector" }, "api.rscType": "Platform", "api.roles": "", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: CreateConnectorRequest, O: CreateConnectorResult },
{ name: "Update", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Connector"], description: "Update a Platform Connector" }, "api.rscType": "Platform", "api.roles": "", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: UpdateConnectorRequest, O: UpdateConnectorResult },
{ name: "Delete", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Connector"], description: "Delete a Platform Connector" }, "api.rscType": "Platform", "api.roles": "", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: DeleteConnectorRequest, O: DeleteConnectorResult },
{ name: "Get", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Connector"], description: "Get a Platform Connector" }, "api.rscType": "Platform", "api.roles": "Platform.Connector", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: GetConnectorRequest, O: GetConnectorResult },
{ name: "List", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Connector"], description: "List Platform Connectors" }, "api.rscType": "Platform", "api.roles": "", "google.api.method_visibility": { restriction: "INTERNAL" } }, I: ListConnectorsRequest, O: ListConnectorsResult },
{ name: "ListAvailable", options: { "grpc.gateway.protoc_gen_openapiv2.options.openapiv2_operation": { tags: ["Admin Connector"], description: "List Available Platform Connectors on a Project" }, "api.rscType": "Project", "api.roles": "", "google.api.method_visibility": { restriction: "SDK" } }, I: ListAvailableConnectorsRequest, O: ListAvailableConnectorsResult }
], { "api.k8sService": "organisation-server", "api.roleManager": true, "api.resourceManager": true });
View Git Blame Copy Permalink