import _m0 from 'protobufjs/minimal';
import { Duration } from '../../../../../google/protobuf/duration';
export declare const protobufPackage = "yandex.cloud.serverless.eventrouter.v1";
export interface Connector {
    /** ID of the connector. */
    id: string;
    /** ID of the bus that the connector belongs to. */
    busId: string;
    /** ID of the folder that the connector resides in. */
    folderId: string;
    /** ID of the cloud that the connector resides in. */
    cloudId: string;
    /** Creation timestamp. */
    createdAt?: Date;
    /** Name of the connector. */
    name: string;
    /** Description of the connector. */
    description: string;
    /** Resource labels as `key:value` pairs. */
    labels: {
        [key: string]: string;
    };
    /** Source of the connector. */
    source?: Source;
    /** Deletion protection. */
    deletionProtection: boolean;
    /** Status of the connector. */
    status: Connector_Status;
}
/** Status of the connector. */
export declare enum Connector_Status {
    STATUS_UNSPECIFIED = 0,
    RUNNING = 1,
    /** STOPPED - disabled by user */
    STOPPED = 2,
    /** RESOURCE_NOT_FOUND - source does not exist */
    RESOURCE_NOT_FOUND = 3,
    /** PERMISSION_DENIED - service account does not have read permission on source */
    PERMISSION_DENIED = 4,
    /** SUBJECT_NOT_FOUND - service account not found */
    SUBJECT_NOT_FOUND = 5,
    /** DELETING - deletion in progress */
    DELETING = 7,
    /** CREATING - creation in progress */
    CREATING = 8,
    UNRECOGNIZED = -1
}
export declare function connector_StatusFromJSON(object: any): Connector_Status;
export declare function connector_StatusToJSON(object: Connector_Status): string;
export interface Connector_LabelsEntry {
    key: string;
    value: string;
}
export interface Source {
    dataStream?: DataStream | undefined;
    messageQueue?: MessageQueue | undefined;
    timer?: Timer | undefined;
    eventServiceSource?: EventServiceSource | undefined;
}
export interface DataStream {
    /**
     * Stream database.
     * example: /ru-central1/aoegtvhtp8ob******** /cc8004q4lbo6********
     */
    database: string;
    /** Stream name, absolute or relative. */
    streamName: string;
    /** Consumer name. */
    consumer: string;
    /** Service account which has read permission on the stream. */
    serviceAccountId: string;
}
export interface MessageQueue {
    /**
     * Queue ARN.
     * Example: yrn:yc:ymq:ru-central1:aoe***:test
     */
    queueArn: string;
    /** Service account which has read access to the queue. */
    serviceAccountId: string;
    /** Queue visibility timeout override. */
    visibilityTimeout?: Duration;
    /** Batch size for polling. */
    batchSize: number;
    /** Queue polling timeout. */
    pollingTimeout?: Duration;
}
export interface EventServiceSource {
}
export interface Timer {
    /** cron expression, with second precision */
    cronExpression: string;
    /** time zone, e.g. Europe/Moscow */
    timeZone: string;
    /** payload to send to target */
    payload: string;
}
export declare const Connector: {
    encode(message: Connector, writer?: _m0.Writer): _m0.Writer;
    decode(input: _m0.Reader | Uint8Array, length?: number): Connector;
    fromJSON(object: any): Connector;
    toJSON(message: Connector): unknown;
    fromPartial<I extends {
        id?: string | undefined;
        busId?: string | undefined;
        folderId?: string | undefined;
        cloudId?: string | undefined;
        createdAt?: Date | undefined;
        name?: string | undefined;
        description?: string | undefined;
        labels?: {
            [x: string]: string | undefined;
        } | undefined;
        source?: {
            dataStream?: {
                database?: string | undefined;
                streamName?: string | undefined;
                consumer?: string | undefined;
                serviceAccountId?: string | undefined;
            } | undefined;
            messageQueue?: {
                queueArn?: string | undefined;
                serviceAccountId?: string | undefined;
                visibilityTimeout?: {
                    seconds?: number | undefined;
                    nanos?: number | undefined;
                } | undefined;
                batchSize?: number | undefined;
                pollingTimeout?: {
                    seconds?: number | undefined;
                    nanos?: number | undefined;
                } | undefined;
            } | undefined;
            timer?: {
                cronExpression?: string | undefined;
                timeZone?: string | undefined;
                payload?: string | undefined;
            } | undefined;
            eventServiceSource?: {} | undefined;
        } | undefined;
        deletionProtection?: boolean | undefined;
        status?: Connector_Status | undefined;
    } & {
        id?: string | undefined;
        busId?: string | undefined;
        folderId?: string | undefined;
        cloudId?: string | undefined;
        createdAt?: Date | undefined;
        name?: string | undefined;
        description?: string | undefined;
        labels?: ({
            [x: string]: string | undefined;
        } & {
            [x: string]: string | undefined;
        } & Record<Exclude<keyof I["labels"], string | number>, never>) | undefined;
        source?: ({
            dataStream?: {
                database?: string | undefined;
                streamName?: string | undefined;
                consumer?: string | undefined;
                serviceAccountId?: string | undefined;
            } | undefined;
            messageQueue?: {
                queueArn?: string | undefined;
                serviceAccountId?: string | undefined;
                visibilityTimeout?: {
                    seconds?: number | undefined;
                    nanos?: number | undefined;
                } | undefined;
                batchSize?: number | undefined;
                pollingTimeout?: {
                    seconds?: number | undefined;
                    nanos?: number | undefined;
                } | undefined;
            } | undefined;
            timer?: {
                cronExpression?: string | undefined;
                timeZone?: string | undefined;
                payload?: string | undefined;
            } | undefined;
            eventServiceSource?: {} | undefined;
        } & {
            dataStream?: ({
                database?: string | undefined;
                streamName?: string | undefined;
                consumer?: string | undefined;
                serviceAccountId?: string | undefined;
            } & {
                database?: string | undefined;
                streamName?: string | undefined;
                consumer?: string | undefined;
                serviceAccountId?: string | undefined;
            } & Record<Exclude<keyof I["source"]["dataStream"], keyof DataStream>, never>) | undefined;
            messageQueue?: ({
                queueArn?: string | undefined;
                serviceAccountId?: string | undefined;
                visibilityTimeout?: {
                    seconds?: number | undefined;
                    nanos?: number | undefined;
                } | undefined;
                batchSize?: number | undefined;
                pollingTimeout?: {
                    seconds?: number | undefined;
                    nanos?: number | undefined;
                } | undefined;
            } & {
                queueArn?: string | undefined;
                serviceAccountId?: string | undefined;
                visibilityTimeout?: ({
                    seconds?: number | undefined;
                    nanos?: number | undefined;
                } & {
                    seconds?: number | undefined;
                    nanos?: number | undefined;
                } & Record<Exclude<keyof I["source"]["messageQueue"]["visibilityTimeout"], keyof Duration>, never>) | undefined;
                batchSize?: number | undefined;
                pollingTimeout?: ({
                    seconds?: number | undefined;
                    nanos?: number | undefined;
                } & {
                    seconds?: number | undefined;
                    nanos?: number | undefined;
                } & Record<Exclude<keyof I["source"]["messageQueue"]["pollingTimeout"], keyof Duration>, never>) | undefined;
            } & Record<Exclude<keyof I["source"]["messageQueue"], keyof MessageQueue>, never>) | undefined;
            timer?: ({
                cronExpression?: string | undefined;
                timeZone?: string | undefined;
                payload?: string | undefined;
            } & {
                cronExpression?: string | undefined;
                timeZone?: string | undefined;
                payload?: string | undefined;
            } & Record<Exclude<keyof I["source"]["timer"], keyof Timer>, never>) | undefined;
            eventServiceSource?: ({} & {} & Record<Exclude<keyof I["source"]["eventServiceSource"], never>, never>) | undefined;
        } & Record<Exclude<keyof I["source"], keyof Source>, never>) | undefined;
        deletionProtection?: boolean | undefined;
        status?: Connector_Status | undefined;
    } & Record<Exclude<keyof I, keyof Connector>, never>>(object: I): Connector;
};
export declare const Connector_LabelsEntry: {
    encode(message: Connector_LabelsEntry, writer?: _m0.Writer): _m0.Writer;
    decode(input: _m0.Reader | Uint8Array, length?: number): Connector_LabelsEntry;
    fromJSON(object: any): Connector_LabelsEntry;
    toJSON(message: Connector_LabelsEntry): unknown;
    fromPartial<I extends {
        key?: string | undefined;
        value?: string | undefined;
    } & {
        key?: string | undefined;
        value?: string | undefined;
    } & Record<Exclude<keyof I, keyof Connector_LabelsEntry>, never>>(object: I): Connector_LabelsEntry;
};
export declare const Source: {
    encode(message: Source, writer?: _m0.Writer): _m0.Writer;
    decode(input: _m0.Reader | Uint8Array, length?: number): Source;
    fromJSON(object: any): Source;
    toJSON(message: Source): unknown;
    fromPartial<I extends {
        dataStream?: {
            database?: string | undefined;
            streamName?: string | undefined;
            consumer?: string | undefined;
            serviceAccountId?: string | undefined;
        } | undefined;
        messageQueue?: {
            queueArn?: string | undefined;
            serviceAccountId?: string | undefined;
            visibilityTimeout?: {
                seconds?: number | undefined;
                nanos?: number | undefined;
            } | undefined;
            batchSize?: number | undefined;
            pollingTimeout?: {
                seconds?: number | undefined;
                nanos?: number | undefined;
            } | undefined;
        } | undefined;
        timer?: {
            cronExpression?: string | undefined;
            timeZone?: string | undefined;
            payload?: string | undefined;
        } | undefined;
        eventServiceSource?: {} | undefined;
    } & {
        dataStream?: ({
            database?: string | undefined;
            streamName?: string | undefined;
            consumer?: string | undefined;
            serviceAccountId?: string | undefined;
        } & {
            database?: string | undefined;
            streamName?: string | undefined;
            consumer?: string | undefined;
            serviceAccountId?: string | undefined;
        } & Record<Exclude<keyof I["dataStream"], keyof DataStream>, never>) | undefined;
        messageQueue?: ({
            queueArn?: string | undefined;
            serviceAccountId?: string | undefined;
            visibilityTimeout?: {
                seconds?: number | undefined;
                nanos?: number | undefined;
            } | undefined;
            batchSize?: number | undefined;
            pollingTimeout?: {
                seconds?: number | undefined;
                nanos?: number | undefined;
            } | undefined;
        } & {
            queueArn?: string | undefined;
            serviceAccountId?: string | undefined;
            visibilityTimeout?: ({
                seconds?: number | undefined;
                nanos?: number | undefined;
            } & {
                seconds?: number | undefined;
                nanos?: number | undefined;
            } & Record<Exclude<keyof I["messageQueue"]["visibilityTimeout"], keyof Duration>, never>) | undefined;
            batchSize?: number | undefined;
            pollingTimeout?: ({
                seconds?: number | undefined;
                nanos?: number | undefined;
            } & {
                seconds?: number | undefined;
                nanos?: number | undefined;
            } & Record<Exclude<keyof I["messageQueue"]["pollingTimeout"], keyof Duration>, never>) | undefined;
        } & Record<Exclude<keyof I["messageQueue"], keyof MessageQueue>, never>) | undefined;
        timer?: ({
            cronExpression?: string | undefined;
            timeZone?: string | undefined;
            payload?: string | undefined;
        } & {
            cronExpression?: string | undefined;
            timeZone?: string | undefined;
            payload?: string | undefined;
        } & Record<Exclude<keyof I["timer"], keyof Timer>, never>) | undefined;
        eventServiceSource?: ({} & {} & Record<Exclude<keyof I["eventServiceSource"], never>, never>) | undefined;
    } & Record<Exclude<keyof I, keyof Source>, never>>(object: I): Source;
};
export declare const DataStream: {
    encode(message: DataStream, writer?: _m0.Writer): _m0.Writer;
    decode(input: _m0.Reader | Uint8Array, length?: number): DataStream;
    fromJSON(object: any): DataStream;
    toJSON(message: DataStream): unknown;
    fromPartial<I extends {
        database?: string | undefined;
        streamName?: string | undefined;
        consumer?: string | undefined;
        serviceAccountId?: string | undefined;
    } & {
        database?: string | undefined;
        streamName?: string | undefined;
        consumer?: string | undefined;
        serviceAccountId?: string | undefined;
    } & Record<Exclude<keyof I, keyof DataStream>, never>>(object: I): DataStream;
};
export declare const MessageQueue: {
    encode(message: MessageQueue, writer?: _m0.Writer): _m0.Writer;
    decode(input: _m0.Reader | Uint8Array, length?: number): MessageQueue;
    fromJSON(object: any): MessageQueue;
    toJSON(message: MessageQueue): unknown;
    fromPartial<I extends {
        queueArn?: string | undefined;
        serviceAccountId?: string | undefined;
        visibilityTimeout?: {
            seconds?: number | undefined;
            nanos?: number | undefined;
        } | undefined;
        batchSize?: number | undefined;
        pollingTimeout?: {
            seconds?: number | undefined;
            nanos?: number | undefined;
        } | undefined;
    } & {
        queueArn?: string | undefined;
        serviceAccountId?: string | undefined;
        visibilityTimeout?: ({
            seconds?: number | undefined;
            nanos?: number | undefined;
        } & {
            seconds?: number | undefined;
            nanos?: number | undefined;
        } & Record<Exclude<keyof I["visibilityTimeout"], keyof Duration>, never>) | undefined;
        batchSize?: number | undefined;
        pollingTimeout?: ({
            seconds?: number | undefined;
            nanos?: number | undefined;
        } & {
            seconds?: number | undefined;
            nanos?: number | undefined;
        } & Record<Exclude<keyof I["pollingTimeout"], keyof Duration>, never>) | undefined;
    } & Record<Exclude<keyof I, keyof MessageQueue>, never>>(object: I): MessageQueue;
};
export declare const EventServiceSource: {
    encode(_: EventServiceSource, writer?: _m0.Writer): _m0.Writer;
    decode(input: _m0.Reader | Uint8Array, length?: number): EventServiceSource;
    fromJSON(_: any): EventServiceSource;
    toJSON(_: EventServiceSource): unknown;
    fromPartial<I extends {} & {} & Record<Exclude<keyof I, never>, never>>(_: I): EventServiceSource;
};
export declare const Timer: {
    encode(message: Timer, writer?: _m0.Writer): _m0.Writer;
    decode(input: _m0.Reader | Uint8Array, length?: number): Timer;
    fromJSON(object: any): Timer;
    toJSON(message: Timer): unknown;
    fromPartial<I extends {
        cronExpression?: string | undefined;
        timeZone?: string | undefined;
        payload?: string | undefined;
    } & {
        cronExpression?: string | undefined;
        timeZone?: string | undefined;
        payload?: string | undefined;
    } & Record<Exclude<keyof I, keyof Timer>, never>>(object: I): Timer;
};
type Builtin = Date | Function | Uint8Array | string | number | boolean | undefined;
export type DeepPartial<T> = T extends Builtin ? T : T extends Array<infer U> ? Array<DeepPartial<U>> : T extends ReadonlyArray<infer U> ? ReadonlyArray<DeepPartial<U>> : T extends {} ? {
    [K in keyof T]?: DeepPartial<T[K]>;
} : Partial<T>;
type KeysOfUnion<T> = T extends T ? keyof T : never;
export type Exact<P, I extends P> = P extends Builtin ? P : P & {
    [K in keyof P]: Exact<P[K], I[K]>;
} & Record<Exclude<keyof I, KeysOfUnion<P>>, never>;
export {};