Lookup node directory — advertise / unregister / list by served HyperService key / directorySpec.changes membership push.
servicesdirectorySpec.changes
Source src/Lookup.ts:3705 lines
export class class Directoryclass Directory {
key: Identifier;
Service: {
advertise: (payload: { kind: 'Http' | 'WebSocket' | 'IpcSocket'; serves: ReadonlyArray<string>; nodeKey: string; url?: string | undefined; path?: string | undefined; onConflict?: 'livenessReplace' | 'askIncumbent' | 'reject' | 'inherit' | undefined }…;
unregister: (payload: { nodeKey: string; kind?: 'Http' | 'WebSocket' | 'IpcSocket' | undefined; url?: string | undefined; path?: string | undefined }) => Effect.Effect<boolean, never, never>;
nodesServing: (payload: { serviceKey: string }) => Effect.Effect<ReadonlyArray<DirectoryEntry>, never, never>;
changes: Stream.Stream<DirectoryUpserted | DirectoryRemoved, never, never>;
};
}
Lookup node directory — advertise / unregister / list by served HyperService key /
directorySpec.changes
membership push.
Directory extends import HyperlinkHyperlink.Tag<Directory>(): SchemaTagBuilder<Directory> (+2 overloads)
export Tag
Schema-driven solo: infer the service from spec; bare
local
is a compile error.
Tag<class Directoryclass Directory {
key: Identifier;
Service: {
advertise: (payload: { kind: 'Http' | 'WebSocket' | 'IpcSocket'; serves: ReadonlyArray<string>; nodeKey: string; url?: string | undefined; path?: string | undefined; onConflict?: 'livenessReplace' | 'askIncumbent' | 'reject' | 'inherit' | undefined }…;
unregister: (payload: { nodeKey: string; kind?: 'Http' | 'WebSocket' | 'IpcSocket' | undefined; url?: string | undefined; path?: string | undefined }) => Effect.Effect<boolean, never, never>;
nodesServing: (payload: { serviceKey: string }) => Effect.Effect<ReadonlyArray<DirectoryEntry>, never, never>;
changes: Stream.Stream<DirectoryUpserted | DirectoryRemoved, never, never>;
};
}
Lookup node directory — advertise / unregister / list by served HyperService key /
directorySpec.changes
membership push.
Directory>()(
"hyperlink-ts/Lookup/Directory",
const directorySpec: {
advertise: Hyperlink.Method<typeof AdvertiseRequest, typeof DirectoryEntry, typeof IncumbentAlive, false, Hyperlink.MethodAnnotations & {
description: string;
}, Hyperlink.Derive>;
unregister: Hyperlink.Method<typeof UnregisterRequest, Schema.Boolean, Schema.Never, false, Hyperlink.MethodAnnotations & {
description: string;
}, Hyperlink.Derive>;
nodesServing: Hyperlink.Method<typeof NodesServingRequest, ... 4 more ..., Hyperlink.Derive>;
changes: Hyperlink.Method<...>;
}
kind?: string | undefinedkind },
) {}
Referenced by 8 symbols