import { type HandlerContext } from "@connectrpc/connect";
import { InvokeRequest, InvokeResponse } from "../../../proto/dapr/proto/common/v1/common_pb";
import { BindingEventRequest, BindingEventResponse, HealthCheckResponse, JobEventRequest, JobEventResponse, ListInputBindingsResponse, ListTopicSubscriptionsResponse, TopicEventBulkRequest, TopicEventBulkResponse, TopicEventRequest, TopicEventResponse } from "../../../proto/dapr/proto/runtime/v1/appcallback_pb";
import { Empty } from "@bufbuild/protobuf/wkt";
import { TypeDaprBindingCallback } from "../../../types/DaprBindingCallback.type";
import { TypeDaprPubSubCallback } from "../../../types/DaprPubSubCallback.type";
import { LoggerOptions } from "../../../types/logger/LoggerOptions";
import { PubSubSubscriptionOptionsType } from "../../../types/pubsub/PubSubSubscriptionOptions.type";
import { IServerType } from "./GRPCServer";
import { DaprInvokerCallbackFunction } from "../../../types/DaprInvokerCallback.type";
import { PubSubSubscriptionTopicRouteType } from "../../../types/pubsub/PubSubSubscriptionTopicRoute.type";
import DaprPubSubStatusEnum from "../../../enum/DaprPubSubStatus.enum";
import { PubSubSubscriptionsType } from "../../../types/pubsub/PubSubSubscriptions.type";
export default class GRPCServerImpl {
    private readonly logger;
    private readonly subscriptionManager;
    handlersInvoke: {
        [key: string]: DaprInvokerCallbackFunction;
    };
    handlersBindings: {
        [key: string]: TypeDaprBindingCallback;
    };
    constructor(_server: IServerType, loggerOptions?: LoggerOptions);
    createInputBindingHandlerKey(bindingName: string): string;
    createOnInvokeHandlerKey(httpMethod: string, methodName: string): string;
    registerOnInvokeHandler(httpMethod: string, methodName: string, cb: DaprInvokerCallbackFunction): void;
    registerPubsubSubscription(pubsubName: string, topic: string, options?: PubSubSubscriptionOptionsType): void;
    registerPubSubSubscriptionEventHandler(pubsubName: string, topic: string, route: string | undefined, cb: TypeDaprPubSubCallback): void;
    registerInputBindingHandler(bindingName: string, cb: DaprInvokerCallbackFunction): void;
    getSubscriptions(): PubSubSubscriptionsType;
    onInvoke(request: InvokeRequest, _context: HandlerContext): Promise<InvokeResponse>;
    onBindingEvent(request: BindingEventRequest, _context: HandlerContext): Promise<BindingEventResponse>;
    onTopicEvent(request: TopicEventRequest, context: HandlerContext): Promise<TopicEventResponse>;
    onBulkTopicEventAlpha1(request: TopicEventBulkRequest, context: HandlerContext): Promise<TopicEventBulkResponse>;
    processPubSubCallbacks(routeObj: PubSubSubscriptionTopicRouteType, data: any, headers: {
        [key: string]: string;
    }): Promise<DaprPubSubStatusEnum>;
    listTopicSubscriptions(_request: Empty, _context: HandlerContext): Promise<ListTopicSubscriptionsResponse>;
    listInputBindings(_request: Empty, _context: HandlerContext): Promise<ListInputBindingsResponse>;
    healthCheck(_request: Empty, _context: HandlerContext): Promise<HealthCheckResponse>;
    onJobEventAlpha1(_request: JobEventRequest, _context: HandlerContext): Promise<JobEventResponse>;
}