import type * as grpc from '@grpc/grpc-js';
import type { MethodDefinition } from '@grpc/proto-loader';
import type { GetCheckpointsRequest as _memoflow_v1_GetCheckpointsRequest, GetCheckpointsRequest__Output as _memoflow_v1_GetCheckpointsRequest__Output } from '../../memoflow/v1/GetCheckpointsRequest.js';
import type { GetCheckpointsResponse as _memoflow_v1_GetCheckpointsResponse, GetCheckpointsResponse__Output as _memoflow_v1_GetCheckpointsResponse__Output } from '../../memoflow/v1/GetCheckpointsResponse.js';
import type { GetSqlContractRequest as _memoflow_v1_GetSqlContractRequest, GetSqlContractRequest__Output as _memoflow_v1_GetSqlContractRequest__Output } from '../../memoflow/v1/GetSqlContractRequest.js';
import type { GetSqlContractResponse as _memoflow_v1_GetSqlContractResponse, GetSqlContractResponse__Output as _memoflow_v1_GetSqlContractResponse__Output } from '../../memoflow/v1/GetSqlContractResponse.js';
import type { ReadActivityOutputRequest as _memoflow_v1_ReadActivityOutputRequest, ReadActivityOutputRequest__Output as _memoflow_v1_ReadActivityOutputRequest__Output } from '../../memoflow/v1/ReadActivityOutputRequest.js';
import type { ReadActivityOutputResponse as _memoflow_v1_ReadActivityOutputResponse, ReadActivityOutputResponse__Output as _memoflow_v1_ReadActivityOutputResponse__Output } from '../../memoflow/v1/ReadActivityOutputResponse.js';
export interface WorkerServiceClient extends grpc.Client {
    /**
     * Batch-fetch checkpoints for a workflow run (used during recovery /
     * lazy hydration). Task flow — pushes, completions, heartbeats, stream
     * chunks — lives on the WorkerSession bidirectional stream (ADR-0002,
     * worker_session.proto); the unary poll/complete/heartbeat/stream-chunk
     * RPCs were deleted at the P9.2 flag day (pre-launch, no users).
     */
    GetCheckpoints(argument: _memoflow_v1_GetCheckpointsRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_GetCheckpointsResponse__Output>): grpc.ClientUnaryCall;
    GetCheckpoints(argument: _memoflow_v1_GetCheckpointsRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_GetCheckpointsResponse__Output>): grpc.ClientUnaryCall;
    GetCheckpoints(argument: _memoflow_v1_GetCheckpointsRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_GetCheckpointsResponse__Output>): grpc.ClientUnaryCall;
    GetCheckpoints(argument: _memoflow_v1_GetCheckpointsRequest, callback: grpc.requestCallback<_memoflow_v1_GetCheckpointsResponse__Output>): grpc.ClientUnaryCall;
    /**
     * Batch-fetch checkpoints for a workflow run (used during recovery /
     * lazy hydration). Task flow — pushes, completions, heartbeats, stream
     * chunks — lives on the WorkerSession bidirectional stream (ADR-0002,
     * worker_session.proto); the unary poll/complete/heartbeat/stream-chunk
     * RPCs were deleted at the P9.2 flag day (pre-launch, no users).
     */
    getCheckpoints(argument: _memoflow_v1_GetCheckpointsRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_GetCheckpointsResponse__Output>): grpc.ClientUnaryCall;
    getCheckpoints(argument: _memoflow_v1_GetCheckpointsRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_GetCheckpointsResponse__Output>): grpc.ClientUnaryCall;
    getCheckpoints(argument: _memoflow_v1_GetCheckpointsRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_GetCheckpointsResponse__Output>): grpc.ClientUnaryCall;
    getCheckpoints(argument: _memoflow_v1_GetCheckpointsRequest, callback: grpc.requestCallback<_memoflow_v1_GetCheckpointsResponse__Output>): grpc.ClientUnaryCall;
    /**
     * P6.3 transactional step (Postgres tier only) — startup handshake,
     * ALSO folded into the session hello_ack (SessionHelloAck.sql_contract).
     * Kept as a standalone RPC for out-of-band tooling; the SDK reads it from
     * the hello_ack. On version skew the worker MUST fail loudly and refuse
     * to start (never silently degrade or guess at a compatible statement).
     */
    GetSqlContract(argument: _memoflow_v1_GetSqlContractRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_GetSqlContractResponse__Output>): grpc.ClientUnaryCall;
    GetSqlContract(argument: _memoflow_v1_GetSqlContractRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_GetSqlContractResponse__Output>): grpc.ClientUnaryCall;
    GetSqlContract(argument: _memoflow_v1_GetSqlContractRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_GetSqlContractResponse__Output>): grpc.ClientUnaryCall;
    GetSqlContract(argument: _memoflow_v1_GetSqlContractRequest, callback: grpc.requestCallback<_memoflow_v1_GetSqlContractResponse__Output>): grpc.ClientUnaryCall;
    /**
     * P6.3 transactional step (Postgres tier only) — startup handshake,
     * ALSO folded into the session hello_ack (SessionHelloAck.sql_contract).
     * Kept as a standalone RPC for out-of-band tooling; the SDK reads it from
     * the hello_ack. On version skew the worker MUST fail loudly and refuse
     * to start (never silently degrade or guess at a compatible statement).
     */
    getSqlContract(argument: _memoflow_v1_GetSqlContractRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_GetSqlContractResponse__Output>): grpc.ClientUnaryCall;
    getSqlContract(argument: _memoflow_v1_GetSqlContractRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_GetSqlContractResponse__Output>): grpc.ClientUnaryCall;
    getSqlContract(argument: _memoflow_v1_GetSqlContractRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_GetSqlContractResponse__Output>): grpc.ClientUnaryCall;
    getSqlContract(argument: _memoflow_v1_GetSqlContractRequest, callback: grpc.requestCallback<_memoflow_v1_GetSqlContractResponse__Output>): grpc.ClientUnaryCall;
    /**
     * Read protected durable output only for the exact workflow run authorized
     * by a currently valid activity task token. Unlike WorkflowService's
     * operator read, this remains inside worker.connect least privilege.
     */
    ReadActivityOutput(argument: _memoflow_v1_ReadActivityOutputRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_ReadActivityOutputResponse__Output>): grpc.ClientUnaryCall;
    ReadActivityOutput(argument: _memoflow_v1_ReadActivityOutputRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_ReadActivityOutputResponse__Output>): grpc.ClientUnaryCall;
    ReadActivityOutput(argument: _memoflow_v1_ReadActivityOutputRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_ReadActivityOutputResponse__Output>): grpc.ClientUnaryCall;
    ReadActivityOutput(argument: _memoflow_v1_ReadActivityOutputRequest, callback: grpc.requestCallback<_memoflow_v1_ReadActivityOutputResponse__Output>): grpc.ClientUnaryCall;
    /**
     * Read protected durable output only for the exact workflow run authorized
     * by a currently valid activity task token. Unlike WorkflowService's
     * operator read, this remains inside worker.connect least privilege.
     */
    readActivityOutput(argument: _memoflow_v1_ReadActivityOutputRequest, metadata: grpc.Metadata, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_ReadActivityOutputResponse__Output>): grpc.ClientUnaryCall;
    readActivityOutput(argument: _memoflow_v1_ReadActivityOutputRequest, metadata: grpc.Metadata, callback: grpc.requestCallback<_memoflow_v1_ReadActivityOutputResponse__Output>): grpc.ClientUnaryCall;
    readActivityOutput(argument: _memoflow_v1_ReadActivityOutputRequest, options: grpc.CallOptions, callback: grpc.requestCallback<_memoflow_v1_ReadActivityOutputResponse__Output>): grpc.ClientUnaryCall;
    readActivityOutput(argument: _memoflow_v1_ReadActivityOutputRequest, callback: grpc.requestCallback<_memoflow_v1_ReadActivityOutputResponse__Output>): grpc.ClientUnaryCall;
}
export interface WorkerServiceHandlers extends grpc.UntypedServiceImplementation {
    /**
     * Batch-fetch checkpoints for a workflow run (used during recovery /
     * lazy hydration). Task flow — pushes, completions, heartbeats, stream
     * chunks — lives on the WorkerSession bidirectional stream (ADR-0002,
     * worker_session.proto); the unary poll/complete/heartbeat/stream-chunk
     * RPCs were deleted at the P9.2 flag day (pre-launch, no users).
     */
    GetCheckpoints: grpc.handleUnaryCall<_memoflow_v1_GetCheckpointsRequest__Output, _memoflow_v1_GetCheckpointsResponse>;
    /**
     * P6.3 transactional step (Postgres tier only) — startup handshake,
     * ALSO folded into the session hello_ack (SessionHelloAck.sql_contract).
     * Kept as a standalone RPC for out-of-band tooling; the SDK reads it from
     * the hello_ack. On version skew the worker MUST fail loudly and refuse
     * to start (never silently degrade or guess at a compatible statement).
     */
    GetSqlContract: grpc.handleUnaryCall<_memoflow_v1_GetSqlContractRequest__Output, _memoflow_v1_GetSqlContractResponse>;
    /**
     * Read protected durable output only for the exact workflow run authorized
     * by a currently valid activity task token. Unlike WorkflowService's
     * operator read, this remains inside worker.connect least privilege.
     */
    ReadActivityOutput: grpc.handleUnaryCall<_memoflow_v1_ReadActivityOutputRequest__Output, _memoflow_v1_ReadActivityOutputResponse>;
}
export interface WorkerServiceDefinition extends grpc.ServiceDefinition {
    GetCheckpoints: MethodDefinition<_memoflow_v1_GetCheckpointsRequest, _memoflow_v1_GetCheckpointsResponse, _memoflow_v1_GetCheckpointsRequest__Output, _memoflow_v1_GetCheckpointsResponse__Output>;
    GetSqlContract: MethodDefinition<_memoflow_v1_GetSqlContractRequest, _memoflow_v1_GetSqlContractResponse, _memoflow_v1_GetSqlContractRequest__Output, _memoflow_v1_GetSqlContractResponse__Output>;
    ReadActivityOutput: MethodDefinition<_memoflow_v1_ReadActivityOutputRequest, _memoflow_v1_ReadActivityOutputResponse, _memoflow_v1_ReadActivityOutputRequest__Output, _memoflow_v1_ReadActivityOutputResponse__Output>;
}