import type { Payload, Schema, WithHashMeta } from '@xyo-network/sdk'; import type { DataLakeData, DataLakePublishRunner } from '@xyo-network/xl1-protocol/protocol-lib'; import { z } from 'zod'; import { AbstractS3Provider } from './AbstractS3Provider.ts'; /** Schema filtering and concurrency options for S3 payload publication (`config.options`). */ export declare const S3DataLakePublishRunnerOptionsZod: z.ZodObject<{ allowedSchemas: z.ZodOptional>; concurrency: z.ZodDefault>; disallowedSchemas: z.ZodOptional>; }, z.core.$strip>; /** Schema filtering and concurrency options for S3 payload publication. */ export type S3DataLakePublishRunnerOptions = z.infer; /** * Publishes datalake payloads as content-addressed files in the finalized static REST * layout (`payload/.json`, see `@xyo-network/xl1-network-model`) — the same * namespace `S3BlockPublishRunner` writes block payloads into and `RestBlockViewer` * reads payloads from. * * Publishing is idempotent: keys are content-addressed and contents immutable, so * re-inserting any payload is safe. Hash meta is computed client-side at insert time. * `ArrayBuffer` datalake items are not yet supported and are silently omitted. */ export declare class S3DataLakePublishRunner extends AbstractS3Provider implements DataLakePublishRunner { /** Connection kinds supported by this provider. */ static readonly connectionTypes: readonly ["s3"]; /** Primary moniker used to resolve this provider. */ static readonly defaultMoniker: "DataLakePublishRunner"; /** Provider monikers that must resolve before this provider can be created. */ static readonly dependencies: never[]; /** Provider monikers implemented by this provider class. */ static readonly monikers: "DataLakePublishRunner"[]; /** Read, write, or mixed capability surface exposed by the provider. */ static readonly surface: "node"; /** Moniker implemented by this provider instance. */ moniker: "DataLakePublishRunner"; private _options?; /** Optional allowlist restricting which payload schemas are published. */ get allowedSchemas(): Schema[] | undefined; /** Maximum concurrent payload publications; defaults to eight. */ get concurrency(): number; /** Payload schemas excluded even when an allowlist is configured. */ get disallowedSchemas(): Schema[] | undefined; /** Options parsed once from the materialized provider options. */ private get options(); /** Hashes and publishes allowed payloads, omitting unsupported binary items. */ insert(items: DataLakeData[]): Promise[]>; } //# sourceMappingURL=S3DataLakePublishRunner.d.ts.map