/** * Docker engine callbacks api * * @since 1.0.0 */ import type * as Exit from "effect/Exit"; import type * as Layer from "effect/Layer"; import type * as MobySchemas from "./MobySchemas.ts"; import * as Effect from "effect/Effect"; import * as Function from "effect/Function"; import * as Runtime from "effect/Runtime"; import * as Stream from "effect/Stream"; import * as DockerEngine from "./DockerEngine.ts"; /** * @since 1.0.0 * @category Callbacks */ export declare const runCallbackForEffect: (runtime: Runtime.Runtime) => (effect: Effect.Effect) => (callback: (exit: Exit.Exit) => void) => (fiberId?: import("effect/FiberId").FiberId, options?: Runtime.RunCallbackOptions | undefined) => void; /** * @since 1.0.0 * @category Callbacks */ export declare function runCallback(runtime: Runtime.Runtime, arity: 0): (function_: () => Effect.Effect) => (callback: (exit: Exit.Exit) => void) => void; export declare function runCallback(runtime: Runtime.Runtime, arity: 1): (function_: (z: Z) => Effect.Effect) => (z: Z, callback: (exit: Exit.Exit) => void) => void; export declare function runCallback(runtime: Runtime.Runtime, arity: 2): (function_: (y: Y, z: Z) => Effect.Effect) => (y: Y, z: Z, callback: (exit: Exit.Exit) => void) => void; export declare function runCallback(runtime: Runtime.Runtime, arity: 3): (function_: (x: X, y: Y, z: Z) => Effect.Effect) => (x: X, y: Y, z: Z, callback: (exit: Exit.Exit) => void) => void; export declare function runCallback(runtime: Runtime.Runtime, arity: 4): (function_: (w: W, x: X, y: Y, z: Z) => Effect.Effect) => (w: W, x: X, y: Y, z: Z, callback: (exit: Exit.Exit) => void) => void; export declare function runCallback(runtime: Runtime.Runtime, arity: 5): (function_: (v: V, w: W, x: X, y: Y, z: Z) => Effect.Effect) => (v: V, w: W, x: X, y: Y, z: Z, callback: (exit: Exit.Exit) => void) => void; /** * Create a callback client for the docker engine * * @since 1.0.0 * @category Callbacks */ export declare const callbackClient: (layer: Layer.Layer, Layer.Layer.Error | E, Layer.Layer.Context>) => Promise<{ pull: (a: { image: string; platform?: string | undefined; }) => ReadableStream; build: (a: { tag: string; platform?: string | undefined; dockerfile?: string | undefined; context: Stream.Stream; buildargs?: Record | undefined; }) => ReadableStream; stop: (z: string, callback: (exit: Exit.Exit) => void) => void; start: (z: string, callback: (exit: Exit.Exit) => void) => void; run: (z: Omit<{ readonly Image: string; readonly Hostname?: string; readonly Domainname?: string; readonly User?: string; readonly AttachStdin?: boolean; readonly AttachStdout?: boolean; readonly AttachStderr?: boolean; readonly ExposedPorts?: { readonly [x: `${number}`]: object; readonly [x: `${number}/tcp`]: object; readonly [x: `${number}/udp`]: object; } | undefined; readonly Tty?: boolean; readonly OpenStdin?: boolean; readonly StdinOnce?: boolean; readonly Env?: readonly string[] | null; readonly Cmd?: readonly string[] | null; readonly Healthcheck?: MobySchemas.V1HealthcheckConfig | undefined; readonly ArgsEscaped?: boolean | undefined; readonly Volumes?: { readonly [x: string]: object; } | null; readonly WorkingDir?: string; readonly Entrypoint?: readonly string[] | null; readonly NetworkDisabled?: boolean | undefined; readonly MacAddress?: string | undefined; readonly OnBuild?: readonly string[] | null | undefined; readonly Labels?: { readonly [x: string]: string; } | null; readonly StopSignal?: string | undefined; readonly StopTimeout?: number | undefined; readonly Shell?: readonly string[] | undefined; readonly HostConfig?: MobySchemas.ContainerHostConfig | undefined; readonly NetworkingConfig?: MobySchemas.NetworkNetworkingConfig | undefined; }, "HostConfig"> & { readonly name?: string | undefined; readonly platform?: string | undefined; readonly HostConfig?: ConstructorParameters[0] | undefined; }, callback: (exit: Exit.Exit) => void) => void; exec: (z: { command: string | Array; containerId: MobySchemas.ContainerIdentifier; }, callback: (exit: Exit.Exit<[exitCode: unknown, output: string], import("@effect/platform/Socket").SocketError | import("effect/ParseResult").ParseError | import("./internal/endpoints/circular.ts").DockerError>) => void) => void; execNonBlocking: (z: { detach: T; command: string | Array; containerId: MobySchemas.ContainerIdentifier; }, callback: (exit: Exit.Exit<[[T] extends [false] ? import("./MobyDemux.ts").MultiplexedSocket | import("./MobyDemux.ts").RawSocket : void, string], import("@effect/platform/Socket").SocketError | import("effect/ParseResult").ParseError | import("./internal/endpoints/circular.ts").DockerError>) => void) => void; execWebsockets: (z: { command: string | Array; containerId: MobySchemas.ContainerIdentifier; }, callback: (exit: Exit.Exit) => void) => void; execWebsocketsNonBlocking: (a: { command: string | Array; containerId: MobySchemas.ContainerIdentifier; cwd?: string | undefined; }) => ReadableStream>; ps: (z: { readonly size?: boolean | undefined; readonly limit?: number | undefined; readonly all?: boolean | undefined; readonly filters?: { readonly identifier?: readonly string[] | undefined; readonly volume?: string | undefined; readonly exited?: readonly number[] | undefined; readonly name?: readonly string[] | undefined; readonly status?: readonly ("created" | "restarting" | "running" | "removing" | "paused" | "exited" | "dead")[] | undefined; readonly network?: readonly string[] | undefined; readonly label?: readonly string[] | undefined; readonly ancestor?: readonly string[] | undefined; readonly before?: readonly string[] | undefined; readonly expose?: readonly string[] | undefined; readonly health?: readonly ("none" | "starting" | "healthy" | "unhealthy")[] | undefined; readonly "is-task"?: boolean | undefined; readonly publish?: readonly string[] | undefined; readonly since?: readonly string[] | undefined; } | undefined; } | undefined, callback: (exit: Exit.Exit) => void) => void; push: (name: string, options: { readonly platform?: string | undefined; readonly tag?: string | undefined; } | undefined) => ReadableStream; images: (z: { readonly all?: boolean | undefined; readonly filters?: { readonly label?: readonly string[] | undefined; readonly before?: readonly string[] | undefined; readonly since?: readonly string[] | undefined; readonly until?: string | undefined; readonly dangling?: boolean | undefined; readonly reference?: readonly string[] | undefined; } | undefined; readonly digests?: boolean | undefined; readonly "shared-size"?: boolean | undefined; } | undefined, callback: (exit: Exit.Exit) => void) => void; search: (z: { readonly limit?: number | undefined; readonly filters?: { readonly "is-official"?: boolean | undefined; readonly "is-automated"?: boolean | undefined; readonly stars?: number | undefined; } | undefined; readonly term: string; }, callback: (exit: Exit.Exit) => void) => void; version: (callback: (exit: Exit.Exit) => void) => void; info: (callback: (exit: Exit.Exit) => void) => void; ping: (callback: (exit: Exit.Exit) => void) => void; pingHead: (callback: (exit: Exit.Exit) => void) => void; followProgressInConsole: (y: Function.LazyArg>, z: (error: unknown) => unknown, callback: (exit: Exit.Exit) => void) => void; waitForProgressToComplete: (y: Function.LazyArg>, z: (error: unknown) => unknown, callback: (exit: Exit.Exit) => void) => void; }>;