// @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: { "n1validate.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: { "n1validate.rules": { string: { minLen: "1" } } } },
            { no: 3, name: "Type", kind: "enum", localName: "Type", jsonName: "Type", T: () => ["api.ConnectorType", ConnectorType], options: { "n1validate.rules": { enum: { definedOnly: true } } } },
            { no: 4, name: "Description", kind: "scalar", localName: "Description", jsonName: "Description", T: 9 /*ScalarType.STRING*/, options: { "n1validate.rules": { string: { minLen: "1" } } } },
            { no: 5, name: "Version", kind: "scalar", localName: "Version", jsonName: "Version", T: 9 /*ScalarType.STRING*/, options: { "n1validate.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: { "n1validate.rules": { string: { minLen: "1" } } } },
            { no: 8, name: "JarName", kind: "scalar", localName: "JarName", jsonName: "JarName", T: 9 /*ScalarType.STRING*/, options: { "n1validate.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: { "n1validate.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: { "n1validate.rules": { string: { minLen: "1" } } } },
            { no: 13, name: "Release", kind: "scalar", localName: "Release", jsonName: "Release", T: 9 /*ScalarType.STRING*/, options: { "n1validate.rules": { string: { minLen: "1" } } } },
            { no: 14, name: "ActionsJSONParameters", kind: "scalar", localName: "ActionsJSONParameters", jsonName: "ActionsJSONParameters", T: 9 /*ScalarType.STRING*/, options: { "n1validate.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: { "n1validate.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: { "n1validate.rules": { enum: { definedOnly: true } } } },
            { no: 3, name: "Description", kind: "scalar", localName: "Description", jsonName: "Description", T: 9 /*ScalarType.STRING*/, options: { "n1validate.rules": { string: { minLen: "1" } } } },
            { no: 4, name: "Version", kind: "scalar", localName: "Version", jsonName: "Version", T: 9 /*ScalarType.STRING*/, options: { "n1validate.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: { "n1validate.rules": { string: { minLen: "1" } } } },
            { no: 7, name: "JarName", kind: "scalar", localName: "JarName", jsonName: "JarName", T: 9 /*ScalarType.STRING*/, options: { "n1validate.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: { "n1validate.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: { "n1validate.rules": { string: { minLen: "1" } } } },
            { no: 13, name: "ActionsJSONParameters", kind: "scalar", localName: "ActionsJSONParameters", jsonName: "ActionsJSONParameters", T: 9 /*ScalarType.STRING*/, options: { "n1validate.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: { "n1validate.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: { "n1validate.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: { "n1validate.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: { "n1validate.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: { "n1validate.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 });