/// import { ChannelCredentials, ChannelOptions, UntypedServiceImplementation, handleUnaryCall, Client, ClientUnaryCall, Metadata, CallOptions, ServiceError } from '@grpc/grpc-js'; import _m0 from 'protobufjs/minimal'; import { ExecutionInput, Execution, ExecutionPreview } from '../../../../../yandex/cloud/serverless/workflows/v1/execution'; import { HistoryEntry } from '../../../../../yandex/cloud/serverless/workflows/v1/history_entry'; export declare const protobufPackage = "yandex.cloud.serverless.workflows.v1"; export interface StartExecutionRequest { /** ID of the Workflow. */ workflowId: string; /** Input for the Workflow execution */ input?: ExecutionInput; } export interface StartExecutionResponse { /** ID of the Workflow execution. */ executionId: string; } export interface StopExecutionRequest { /** ID of the Workflow execution. */ executionId: string; } export interface StopExecutionResponse { /** ID of the Workflow execution. */ executionId: string; } export interface TerminateExecutionRequest { /** ID of the Workflow execution. */ executionId: string; } export interface TerminateExecutionResponse { /** ID of the Workflow execution. */ executionId: string; } export interface GetExecutionRequest { /** ID of the Workflow execution. */ executionId: string; } export interface GetExecutionResponse { /** Workflow execution details. */ execution?: Execution; } export interface GetExecutionHistoryRequest { /** ID of the Workflow execution. */ executionId: string; } export interface GetExecutionHistoryResponse { /** Workflow execution details. */ execution?: ExecutionPreview; /** Workflow execution detailed history items. */ entries: HistoryEntry[]; } export interface ListExecutionsRequest { /** ID of the Workflow. */ workflowId: string; /** * The maximum number of results per page that should be returned. If the number of available * results is larger than `pageSize`, the service returns a [ListExecutionsResponse.next_page_token] * that can be used to get the next page of results in subsequent list requests. * * Default value: 100. */ pageSize: number; /** * Page token. To get the next page of results, set `pageToken` to the * [ListExecutionsResponse.next_page_token] returned by a previous list request. */ pageToken: string; /** * A filter expression that filters resources listed in the response. * * The expression must specify: * 1. The field name. Currently filtering can be applied to the following fields: status, started_at, finished_at. * 2. Operator: `=`, `<` or `>`. * 3. The value. Must be sting and match the regular expression `[+:\.-a-z0-9]`. * Examples of a filter: `status=ERROR`, `created_by=John.Doe`. */ filter: string; } export interface ListExecutionsResponse { /** List of Workflow executions. */ executions: ExecutionPreview[]; /** * Token for getting the next page of the list. If the number of results is greater than * the specified [ListExecutionsRequest.page_size], use `next_page_token` as the value * for the [ListExecutionsRequest.page_token] parameter in the next list request. * * Each subsequent page will have its own `next_page_token` to continue paging through the results. */ nextPageToken: string; } export declare const StartExecutionRequest: { encode(message: StartExecutionRequest, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): StartExecutionRequest; fromJSON(object: any): StartExecutionRequest; toJSON(message: StartExecutionRequest): unknown; fromPartial, never>) | undefined; } & Record, never>>(object: I): StartExecutionRequest; }; export declare const StartExecutionResponse: { encode(message: StartExecutionResponse, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): StartExecutionResponse; fromJSON(object: any): StartExecutionResponse; toJSON(message: StartExecutionResponse): unknown; fromPartial, never>>(object: I): StartExecutionResponse; }; export declare const StopExecutionRequest: { encode(message: StopExecutionRequest, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): StopExecutionRequest; fromJSON(object: any): StopExecutionRequest; toJSON(message: StopExecutionRequest): unknown; fromPartial, never>>(object: I): StopExecutionRequest; }; export declare const StopExecutionResponse: { encode(message: StopExecutionResponse, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): StopExecutionResponse; fromJSON(object: any): StopExecutionResponse; toJSON(message: StopExecutionResponse): unknown; fromPartial, never>>(object: I): StopExecutionResponse; }; export declare const TerminateExecutionRequest: { encode(message: TerminateExecutionRequest, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): TerminateExecutionRequest; fromJSON(object: any): TerminateExecutionRequest; toJSON(message: TerminateExecutionRequest): unknown; fromPartial, never>>(object: I): TerminateExecutionRequest; }; export declare const TerminateExecutionResponse: { encode(message: TerminateExecutionResponse, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): TerminateExecutionResponse; fromJSON(object: any): TerminateExecutionResponse; toJSON(message: TerminateExecutionResponse): unknown; fromPartial, never>>(object: I): TerminateExecutionResponse; }; export declare const GetExecutionRequest: { encode(message: GetExecutionRequest, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): GetExecutionRequest; fromJSON(object: any): GetExecutionRequest; toJSON(message: GetExecutionRequest): unknown; fromPartial, never>>(object: I): GetExecutionRequest; }; export declare const GetExecutionResponse: { encode(message: GetExecutionResponse, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): GetExecutionResponse; fromJSON(object: any): GetExecutionResponse; toJSON(message: GetExecutionResponse): unknown; fromPartial, never>) | undefined; result?: ({ resultJson?: string | undefined; } & { resultJson?: string | undefined; } & Record, never>) | undefined; error?: ({ message?: string | undefined; errorCode?: string | undefined; } & { message?: string | undefined; errorCode?: string | undefined; } & Record, never>) | undefined; status?: import("../../../../../yandex/cloud/serverless/workflows/v1/execution").Execution_Status | undefined; startedAt?: Date | undefined; duration?: ({ seconds?: number | undefined; nanos?: number | undefined; } & { seconds?: number | undefined; nanos?: number | undefined; } & Record, never>) | undefined; } & Record, never>) | undefined; } & Record, never>>(object: I): GetExecutionResponse; }; export declare const GetExecutionHistoryRequest: { encode(message: GetExecutionHistoryRequest, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): GetExecutionHistoryRequest; fromJSON(object: any): GetExecutionHistoryRequest; toJSON(message: GetExecutionHistoryRequest): unknown; fromPartial, never>>(object: I): GetExecutionHistoryRequest; }; export declare const GetExecutionHistoryResponse: { encode(message: GetExecutionHistoryResponse, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): GetExecutionHistoryResponse; fromJSON(object: any): GetExecutionHistoryResponse; toJSON(message: GetExecutionHistoryResponse): unknown; fromPartial, never>) | undefined; } & Record, never>) | undefined; entries?: ({ id?: string | undefined; title?: string | undefined; description?: string | undefined; startedAt?: Date | undefined; duration?: { seconds?: number | undefined; nanos?: number | undefined; } | undefined; input?: { inputJson?: string | undefined; } | undefined; output?: { outputJson?: string | undefined; } | undefined; error?: { message?: string | undefined; errorCode?: string | undefined; } | undefined; status?: import("../../../../../yandex/cloud/serverless/workflows/v1/history_entry").HistoryEntry_Status | undefined; type?: string | undefined; attempts?: number | undefined; lastError?: { message?: string | undefined; errorCode?: string | undefined; } | undefined; }[] & ({ id?: string | undefined; title?: string | undefined; description?: string | undefined; startedAt?: Date | undefined; duration?: { seconds?: number | undefined; nanos?: number | undefined; } | undefined; input?: { inputJson?: string | undefined; } | undefined; output?: { outputJson?: string | undefined; } | undefined; error?: { message?: string | undefined; errorCode?: string | undefined; } | undefined; status?: import("../../../../../yandex/cloud/serverless/workflows/v1/history_entry").HistoryEntry_Status | undefined; type?: string | undefined; attempts?: number | undefined; lastError?: { message?: string | undefined; errorCode?: string | undefined; } | undefined; } & { id?: string | undefined; title?: string | undefined; description?: string | undefined; startedAt?: Date | undefined; duration?: ({ seconds?: number | undefined; nanos?: number | undefined; } & { seconds?: number | undefined; nanos?: number | undefined; } & Record, never>) | undefined; input?: ({ inputJson?: string | undefined; } & { inputJson?: string | undefined; } & Record, never>) | undefined; output?: ({ outputJson?: string | undefined; } & { outputJson?: string | undefined; } & Record, never>) | undefined; error?: ({ message?: string | undefined; errorCode?: string | undefined; } & { message?: string | undefined; errorCode?: string | undefined; } & Record, never>) | undefined; status?: import("../../../../../yandex/cloud/serverless/workflows/v1/history_entry").HistoryEntry_Status | undefined; type?: string | undefined; attempts?: number | undefined; lastError?: ({ message?: string | undefined; errorCode?: string | undefined; } & { message?: string | undefined; errorCode?: string | undefined; } & Record, never>) | undefined; } & Record, never>)[] & Record, never>) | undefined; } & Record, never>>(object: I): GetExecutionHistoryResponse; }; export declare const ListExecutionsRequest: { encode(message: ListExecutionsRequest, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): ListExecutionsRequest; fromJSON(object: any): ListExecutionsRequest; toJSON(message: ListExecutionsRequest): unknown; fromPartial, never>>(object: I): ListExecutionsRequest; }; export declare const ListExecutionsResponse: { encode(message: ListExecutionsResponse, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): ListExecutionsResponse; fromJSON(object: any): ListExecutionsResponse; toJSON(message: ListExecutionsResponse): unknown; fromPartial, never>) | undefined; } & Record, never>)[] & Record, never>) | undefined; nextPageToken?: string | undefined; } & Record, never>>(object: I): ListExecutionsResponse; }; /** Set of methods for managing Workflows Executions. */ export declare const ExecutionServiceService: { /** Starts new Workflow execution. */ readonly start: { readonly path: "/yandex.cloud.serverless.workflows.v1.ExecutionService/Start"; readonly requestStream: false; readonly responseStream: false; readonly requestSerialize: (value: StartExecutionRequest) => Buffer; readonly requestDeserialize: (value: Buffer) => StartExecutionRequest; readonly responseSerialize: (value: StartExecutionResponse) => Buffer; readonly responseDeserialize: (value: Buffer) => StartExecutionResponse; }; /** Stops specified Workflow execution. */ readonly stop: { readonly path: "/yandex.cloud.serverless.workflows.v1.ExecutionService/Stop"; readonly requestStream: false; readonly responseStream: false; readonly requestSerialize: (value: StopExecutionRequest) => Buffer; readonly requestDeserialize: (value: Buffer) => StopExecutionRequest; readonly responseSerialize: (value: StopExecutionResponse) => Buffer; readonly responseDeserialize: (value: Buffer) => StopExecutionResponse; }; /** Terminates specified Workflow execution. */ readonly terminate: { readonly path: "/yandex.cloud.serverless.workflows.v1.ExecutionService/Terminate"; readonly requestStream: false; readonly responseStream: false; readonly requestSerialize: (value: TerminateExecutionRequest) => Buffer; readonly requestDeserialize: (value: Buffer) => TerminateExecutionRequest; readonly responseSerialize: (value: TerminateExecutionResponse) => Buffer; readonly responseDeserialize: (value: Buffer) => TerminateExecutionResponse; }; /** Retrieves specified Workflow execution. */ readonly get: { readonly path: "/yandex.cloud.serverless.workflows.v1.ExecutionService/Get"; readonly requestStream: false; readonly responseStream: false; readonly requestSerialize: (value: GetExecutionRequest) => Buffer; readonly requestDeserialize: (value: Buffer) => GetExecutionRequest; readonly responseSerialize: (value: GetExecutionResponse) => Buffer; readonly responseDeserialize: (value: Buffer) => GetExecutionResponse; }; /** Retrieves detailed history of specified Workflow execution. */ readonly getHistory: { readonly path: "/yandex.cloud.serverless.workflows.v1.ExecutionService/GetHistory"; readonly requestStream: false; readonly responseStream: false; readonly requestSerialize: (value: GetExecutionHistoryRequest) => Buffer; readonly requestDeserialize: (value: Buffer) => GetExecutionHistoryRequest; readonly responseSerialize: (value: GetExecutionHistoryResponse) => Buffer; readonly responseDeserialize: (value: Buffer) => GetExecutionHistoryResponse; }; /** Retrieves list of Workflow executions. */ readonly list: { readonly path: "/yandex.cloud.serverless.workflows.v1.ExecutionService/List"; readonly requestStream: false; readonly responseStream: false; readonly requestSerialize: (value: ListExecutionsRequest) => Buffer; readonly requestDeserialize: (value: Buffer) => ListExecutionsRequest; readonly responseSerialize: (value: ListExecutionsResponse) => Buffer; readonly responseDeserialize: (value: Buffer) => ListExecutionsResponse; }; }; export interface ExecutionServiceServer extends UntypedServiceImplementation { /** Starts new Workflow execution. */ start: handleUnaryCall; /** Stops specified Workflow execution. */ stop: handleUnaryCall; /** Terminates specified Workflow execution. */ terminate: handleUnaryCall; /** Retrieves specified Workflow execution. */ get: handleUnaryCall; /** Retrieves detailed history of specified Workflow execution. */ getHistory: handleUnaryCall; /** Retrieves list of Workflow executions. */ list: handleUnaryCall; } export interface ExecutionServiceClient extends Client { /** Starts new Workflow execution. */ start(request: StartExecutionRequest, callback: (error: ServiceError | null, response: StartExecutionResponse) => void): ClientUnaryCall; start(request: StartExecutionRequest, metadata: Metadata, callback: (error: ServiceError | null, response: StartExecutionResponse) => void): ClientUnaryCall; start(request: StartExecutionRequest, metadata: Metadata, options: Partial, callback: (error: ServiceError | null, response: StartExecutionResponse) => void): ClientUnaryCall; /** Stops specified Workflow execution. */ stop(request: StopExecutionRequest, callback: (error: ServiceError | null, response: StopExecutionResponse) => void): ClientUnaryCall; stop(request: StopExecutionRequest, metadata: Metadata, callback: (error: ServiceError | null, response: StopExecutionResponse) => void): ClientUnaryCall; stop(request: StopExecutionRequest, metadata: Metadata, options: Partial, callback: (error: ServiceError | null, response: StopExecutionResponse) => void): ClientUnaryCall; /** Terminates specified Workflow execution. */ terminate(request: TerminateExecutionRequest, callback: (error: ServiceError | null, response: TerminateExecutionResponse) => void): ClientUnaryCall; terminate(request: TerminateExecutionRequest, metadata: Metadata, callback: (error: ServiceError | null, response: TerminateExecutionResponse) => void): ClientUnaryCall; terminate(request: TerminateExecutionRequest, metadata: Metadata, options: Partial, callback: (error: ServiceError | null, response: TerminateExecutionResponse) => void): ClientUnaryCall; /** Retrieves specified Workflow execution. */ get(request: GetExecutionRequest, callback: (error: ServiceError | null, response: GetExecutionResponse) => void): ClientUnaryCall; get(request: GetExecutionRequest, metadata: Metadata, callback: (error: ServiceError | null, response: GetExecutionResponse) => void): ClientUnaryCall; get(request: GetExecutionRequest, metadata: Metadata, options: Partial, callback: (error: ServiceError | null, response: GetExecutionResponse) => void): ClientUnaryCall; /** Retrieves detailed history of specified Workflow execution. */ getHistory(request: GetExecutionHistoryRequest, callback: (error: ServiceError | null, response: GetExecutionHistoryResponse) => void): ClientUnaryCall; getHistory(request: GetExecutionHistoryRequest, metadata: Metadata, callback: (error: ServiceError | null, response: GetExecutionHistoryResponse) => void): ClientUnaryCall; getHistory(request: GetExecutionHistoryRequest, metadata: Metadata, options: Partial, callback: (error: ServiceError | null, response: GetExecutionHistoryResponse) => void): ClientUnaryCall; /** Retrieves list of Workflow executions. */ list(request: ListExecutionsRequest, callback: (error: ServiceError | null, response: ListExecutionsResponse) => void): ClientUnaryCall; list(request: ListExecutionsRequest, metadata: Metadata, callback: (error: ServiceError | null, response: ListExecutionsResponse) => void): ClientUnaryCall; list(request: ListExecutionsRequest, metadata: Metadata, options: Partial, callback: (error: ServiceError | null, response: ListExecutionsResponse) => void): ClientUnaryCall; } export declare const ExecutionServiceClient: { new (address: string, credentials: ChannelCredentials, options?: Partial): ExecutionServiceClient; service: typeof ExecutionServiceService; }; type Builtin = Date | Function | Uint8Array | string | number | boolean | undefined; export type DeepPartial = T extends Builtin ? T : T extends Array ? Array> : T extends ReadonlyArray ? ReadonlyArray> : T extends {} ? { [K in keyof T]?: DeepPartial; } : Partial; type KeysOfUnion = T extends T ? keyof T : never; export type Exact = P extends Builtin ? P : P & { [K in keyof P]: Exact; } & Record>, never>; export {};