import type { TaskDeliveryIdentity as _memoflow_v1_TaskDeliveryIdentity, TaskDeliveryIdentity__Output as _memoflow_v1_TaskDeliveryIdentity__Output } from '../../memoflow/v1/TaskDeliveryIdentity.js'; import type { Long } from '@grpc/proto-loader'; /** * ─── Durable output append (DATA-005) ────────────────────────────────────── * Product output is distinct from best-effort StreamChunk telemetry. Offsets * are contiguous within (namespace, workflow, run, stream_name). A successful * session DurableAck means the chunk and its activity-attempt fence committed. */ export interface AppendOutputChunkRequest { 'task_token'?: (string); 'delivery_identity'?: (_memoflow_v1_TaskDeliveryIdentity | null); 'stream_name'?: (string); 'offset'?: (number | string | Long); 'chunk'?: (Buffer | Uint8Array | string); 'content_type'?: (string); 'idempotency_key'?: (string); 'end_marker'?: (boolean); 'error_type'?: (string); 'error_message'?: (string); } /** * ─── Durable output append (DATA-005) ────────────────────────────────────── * Product output is distinct from best-effort StreamChunk telemetry. Offsets * are contiguous within (namespace, workflow, run, stream_name). A successful * session DurableAck means the chunk and its activity-attempt fence committed. */ export interface AppendOutputChunkRequest__Output { 'task_token': (string); 'delivery_identity': (_memoflow_v1_TaskDeliveryIdentity__Output | null); 'stream_name': (string); 'offset': (string); 'chunk': (Buffer); 'content_type': (string); 'idempotency_key': (string); 'end_marker': (boolean); 'error_type': (string); 'error_message': (string); }