import type { GenFile, GenMessage, GenService } from "@bufbuild/protobuf/codegenv2"; import type { SignalData, SignalDataJson } from "../../graph/v1/signal_data_pb.js"; import type { Transmitter_Mode, Transmitter_ModeJson } from "../../graph/v1/transmitter_pb.js"; import type { ExchangeOperation, ExchangeOperationJson } from "./executor_service_pb.js"; import type { Message } from "@bufbuild/protobuf"; /** * Describes the file mochabugapis/adapt/runtime/v1/executor_incoming.proto. */ export declare const file_mochabugapis_adapt_runtime_v1_executor_incoming: GenFile; /** * Some information about the host environment * Can for example be used to automatically register hooks for external triggers * * @generated from message mochabugapis.adapt.runtime.v1.HostingDetails */ export type HostingDetails = Message<"mochabugapis.adapt.runtime.v1.HostingDetails"> & { /** * The public host (i.e. domain without protocol) of the host environment * Only set for public vertices like external triggers and browsers * * @generated from field: optional string public_host = 1; */ publicHost?: string | undefined; }; /** * Some information about the host environment * Can for example be used to automatically register hooks for external triggers * * @generated from message mochabugapis.adapt.runtime.v1.HostingDetails */ export type HostingDetailsJson = { /** * The public host (i.e. domain without protocol) of the host environment * Only set for public vertices like external triggers and browsers * * @generated from field: optional string public_host = 1; */ publicHost?: string; }; /** * Describes the message mochabugapis.adapt.runtime.v1.HostingDetails. * Use `create(HostingDetailsSchema)` to create a new message. */ export declare const HostingDetailsSchema: GenMessage; /** * The request object used to initiate an execution on a specific receiver. * * @generated from message mochabugapis.adapt.runtime.v1.StartExecutionRequest */ export type StartExecutionRequest = Message<"mochabugapis.adapt.runtime.v1.StartExecutionRequest"> & { /** * The name of the receiver to start the execution on. * * @generated from field: string receiver = 1; */ receiver: string; /** * General information about the host environment * * @generated from field: mochabugapis.adapt.runtime.v1.HostingDetails host = 2; */ host?: HostingDetails | undefined; }; /** * The request object used to initiate an execution on a specific receiver. * * @generated from message mochabugapis.adapt.runtime.v1.StartExecutionRequest */ export type StartExecutionRequestJson = { /** * The name of the receiver to start the execution on. * * @generated from field: string receiver = 1; */ receiver?: string; /** * General information about the host environment * * @generated from field: mochabugapis.adapt.runtime.v1.HostingDetails host = 2; */ host?: HostingDetailsJson; }; /** * Describes the message mochabugapis.adapt.runtime.v1.StartExecutionRequest. * Use `create(StartExecutionRequestSchema)` to create a new message. */ export declare const StartExecutionRequestSchema: GenMessage; /** * The response of the start execution * * @generated from message mochabugapis.adapt.runtime.v1.StartExecutionResponse */ export type StartExecutionResponse = Message<"mochabugapis.adapt.runtime.v1.StartExecutionResponse"> & {}; /** * The response of the start execution * * @generated from message mochabugapis.adapt.runtime.v1.StartExecutionResponse */ export type StartExecutionResponseJson = {}; /** * Describes the message mochabugapis.adapt.runtime.v1.StartExecutionResponse. * Use `create(StartExecutionResponseSchema)` to create a new message. */ export declare const StartExecutionResponseSchema: GenMessage; /** * The request object used to stop a currently running execution. * * @generated from message mochabugapis.adapt.runtime.v1.StopExecutionRequest */ export type StopExecutionRequest = Message<"mochabugapis.adapt.runtime.v1.StopExecutionRequest"> & { /** * General information about the host environment * * @generated from field: mochabugapis.adapt.runtime.v1.HostingDetails host = 1; */ host?: HostingDetails | undefined; }; /** * The request object used to stop a currently running execution. * * @generated from message mochabugapis.adapt.runtime.v1.StopExecutionRequest */ export type StopExecutionRequestJson = { /** * General information about the host environment * * @generated from field: mochabugapis.adapt.runtime.v1.HostingDetails host = 1; */ host?: HostingDetailsJson; }; /** * Describes the message mochabugapis.adapt.runtime.v1.StopExecutionRequest. * Use `create(StopExecutionRequestSchema)` to create a new message. */ export declare const StopExecutionRequestSchema: GenMessage; /** * The response of the start execution * * @generated from message mochabugapis.adapt.runtime.v1.StopExecutionResponse */ export type StopExecutionResponse = Message<"mochabugapis.adapt.runtime.v1.StopExecutionResponse"> & {}; /** * The response of the start execution * * @generated from message mochabugapis.adapt.runtime.v1.StopExecutionResponse */ export type StopExecutionResponseJson = {}; /** * Describes the message mochabugapis.adapt.runtime.v1.StopExecutionResponse. * Use `create(StopExecutionResponseSchema)` to create a new message. */ export declare const StopExecutionResponseSchema: GenMessage; /** * The request object used to manage cron-trigger related operations. * * @generated from message mochabugapis.adapt.runtime.v1.CronTriggerRequest */ export type CronTriggerRequest = Message<"mochabugapis.adapt.runtime.v1.CronTriggerRequest"> & { /** * General information about the host environment * * @generated from field: mochabugapis.adapt.runtime.v1.HostingDetails host = 1; */ host?: HostingDetails | undefined; }; /** * The request object used to manage cron-trigger related operations. * * @generated from message mochabugapis.adapt.runtime.v1.CronTriggerRequest */ export type CronTriggerRequestJson = { /** * General information about the host environment * * @generated from field: mochabugapis.adapt.runtime.v1.HostingDetails host = 1; */ host?: HostingDetailsJson; }; /** * Describes the message mochabugapis.adapt.runtime.v1.CronTriggerRequest. * Use `create(CronTriggerRequestSchema)` to create a new message. */ export declare const CronTriggerRequestSchema: GenMessage; /** * The response of the cron-trigger operation * * @generated from message mochabugapis.adapt.runtime.v1.CronTriggerResponse */ export type CronTriggerResponse = Message<"mochabugapis.adapt.runtime.v1.CronTriggerResponse"> & {}; /** * The response of the cron-trigger operation * * @generated from message mochabugapis.adapt.runtime.v1.CronTriggerResponse */ export type CronTriggerResponseJson = {}; /** * Describes the message mochabugapis.adapt.runtime.v1.CronTriggerResponse. * Use `create(CronTriggerResponseSchema)` to create a new message. */ export declare const CronTriggerResponseSchema: GenMessage; /** * The result of executing a exchange * * @generated from message mochabugapis.adapt.runtime.v1.ExchangeResult */ export type ExchangeResult = Message<"mochabugapis.adapt.runtime.v1.ExchangeResult"> & { /** * The name of the transmitter pushing the resulting signals * * @generated from field: string transmitter = 1; */ transmitter: string; /** * The signals to send over the transmitter * * @generated from field: map signals = 2; */ signals: { [key: string]: SignalData; }; /** * Mode of the transmitter that fired. STANDARD/STREAM = success path; * FAILURE = explicit fail path (signals are user-defined failure payload, * not a runtime error). UNSPECIFIED on payloads from older runtimes — * consumers must treat as STANDARD. * * @generated from field: mochabugapis.adapt.graph.v1.Transmitter.Mode transmitter_mode = 3; */ transmitterMode: Transmitter_Mode; }; /** * The result of executing a exchange * * @generated from message mochabugapis.adapt.runtime.v1.ExchangeResult */ export type ExchangeResultJson = { /** * The name of the transmitter pushing the resulting signals * * @generated from field: string transmitter = 1; */ transmitter?: string; /** * The signals to send over the transmitter * * @generated from field: map signals = 2; */ signals?: { [key: string]: SignalDataJson; }; /** * Mode of the transmitter that fired. STANDARD/STREAM = success path; * FAILURE = explicit fail path (signals are user-defined failure payload, * not a runtime error). UNSPECIFIED on payloads from older runtimes — * consumers must treat as STANDARD. * * @generated from field: mochabugapis.adapt.graph.v1.Transmitter.Mode transmitter_mode = 3; */ transmitterMode?: Transmitter_ModeJson; }; /** * Describes the message mochabugapis.adapt.runtime.v1.ExchangeResult. * Use `create(ExchangeResultSchema)` to create a new message. */ export declare const ExchangeResultSchema: GenMessage; /** * Represents the result object providing detailed information about the exchange operation * * @generated from message mochabugapis.adapt.runtime.v1.ExchangeResultRequest */ export type ExchangeResultRequest = Message<"mochabugapis.adapt.runtime.v1.ExchangeResultRequest"> & { /** * The exchange operation * * @generated from field: mochabugapis.adapt.runtime.v1.ExchangeOperation operation = 1; */ operation?: ExchangeOperation | undefined; /** * The result of the exchange. Unset (nil) when the exchange graph completed * or stopped without any ExchangeOut node being reached — the consumer * should treat this as outcome "not reached". When set, the consumer should * switch on result.transmitter_mode to distinguish normal completion from * failure-path completion. * * @generated from field: mochabugapis.adapt.runtime.v1.ExchangeResult result = 2; */ result?: ExchangeResult | undefined; /** * General information about the host environment * * @generated from field: mochabugapis.adapt.runtime.v1.HostingDetails host = 3; */ host?: HostingDetails | undefined; }; /** * Represents the result object providing detailed information about the exchange operation * * @generated from message mochabugapis.adapt.runtime.v1.ExchangeResultRequest */ export type ExchangeResultRequestJson = { /** * The exchange operation * * @generated from field: mochabugapis.adapt.runtime.v1.ExchangeOperation operation = 1; */ operation?: ExchangeOperationJson; /** * The result of the exchange. Unset (nil) when the exchange graph completed * or stopped without any ExchangeOut node being reached — the consumer * should treat this as outcome "not reached". When set, the consumer should * switch on result.transmitter_mode to distinguish normal completion from * failure-path completion. * * @generated from field: mochabugapis.adapt.runtime.v1.ExchangeResult result = 2; */ result?: ExchangeResultJson; /** * General information about the host environment * * @generated from field: mochabugapis.adapt.runtime.v1.HostingDetails host = 3; */ host?: HostingDetailsJson; }; /** * Describes the message mochabugapis.adapt.runtime.v1.ExchangeResultRequest. * Use `create(ExchangeResultRequestSchema)` to create a new message. */ export declare const ExchangeResultRequestSchema: GenMessage; /** * The response of the procedure result * * @generated from message mochabugapis.adapt.runtime.v1.ExchangeResultResponse */ export type ExchangeResultResponse = Message<"mochabugapis.adapt.runtime.v1.ExchangeResultResponse"> & {}; /** * The response of the procedure result * * @generated from message mochabugapis.adapt.runtime.v1.ExchangeResultResponse */ export type ExchangeResultResponseJson = {}; /** * Describes the message mochabugapis.adapt.runtime.v1.ExchangeResultResponse. * Use `create(ExchangeResultResponseSchema)` to create a new message. */ export declare const ExchangeResultResponseSchema: GenMessage; /** * ExecutorIncomingService is the ADAPT executor ingress exposed by a plugin * program through the runtime proxy. * * @generated from service mochabugapis.adapt.runtime.v1.ExecutorIncomingService */ export declare const ExecutorIncomingService: GenService<{ /** * Starts an execution on a receiver. * * @generated from rpc mochabugapis.adapt.runtime.v1.ExecutorIncomingService.StartExecution */ startExecution: { methodKind: "unary"; input: typeof StartExecutionRequestSchema; output: typeof StartExecutionResponseSchema; }; /** * Stops the current execution. * * @generated from rpc mochabugapis.adapt.runtime.v1.ExecutorIncomingService.StopExecution */ stopExecution: { methodKind: "unary"; input: typeof StopExecutionRequestSchema; output: typeof StopExecutionResponseSchema; }; /** * Delivers the result of an exchange execution. * * @generated from rpc mochabugapis.adapt.runtime.v1.ExecutorIncomingService.ExchangeResult */ exchangeResult: { methodKind: "unary"; input: typeof ExchangeResultRequestSchema; output: typeof ExchangeResultResponseSchema; }; /** * Triggers the program's cron handler. * * @generated from rpc mochabugapis.adapt.runtime.v1.ExecutorIncomingService.CronTrigger */ cronTrigger: { methodKind: "unary"; input: typeof CronTriggerRequestSchema; output: typeof CronTriggerResponseSchema; }; }>; //# sourceMappingURL=executor_incoming_pb.d.ts.map