DirectoryUpserted | DirectoryRemovedMembership-push event from Directory.changes.
wire schemasDirectory.changes
Source src/Lookup.ts:15412 lines
export const const DirectoryChange: Schema.Union<
readonly [
typeof DirectoryUpserted,
typeof DirectoryRemoved
]
>
const DirectoryChange: {
Type: { [K in keyof Members]: Members[K]["Type"]; }[number];
Encoded: { [K in keyof Members]: Members[K]["Encoded"]; }[number];
DecodingServices: { [K in keyof Members]: Members[K]["DecodingServices"]; }[number];
EncodingServices: { [K in keyof Members]: Members[K]["EncodingServices"]; }[number];
Iso: { [K in keyof Members]: Members[K]["Iso"]; }[number];
members: Members;
mapMembers: (f: (members: readonly [typeof DirectoryUpserted, typeof DirectoryRemoved]) => To, options?: { readonly unsafePreserveChecks?: boolean | undefined } | undefined) => Schema.Union<{ [K in keyof Readonly<To>]: Readonly<To>[K]; }>;
Rebuild: Rebuild;
ast: Ast;
annotate: (annotations: Schema.Annotations.Bottom<DirectoryUpserted | DirectoryRemoved, readonly []>) => Schema.Union<readonly [typeof DirectoryUpserted, typeof DirectoryRemoved]>;
annotateKey: (annotations: Schema.Annotations.Key<DirectoryUpserted | DirectoryRemoved>) => Schema.Union<readonly [typeof DirectoryUpserted, typeof DirectoryRemoved]>;
check: (checks_0: Check<DirectoryUpserted | DirectoryRemoved>, ...checks: Array<Check<DirectoryUpserted | DirectoryRemoved>>) => Schema.Union<readonly [typeof DirectoryUpserted, typeof DirectoryRemoved]>;
rebuild: (ast: Union<Declaration>) => Schema.Union<readonly [typeof DirectoryUpserted, typeof DirectoryRemoved]>;
make: (input: DirectoryUpserted | DirectoryRemoved, options?: MakeOptions) => DirectoryUpserted | DirectoryRemoved;
makeOption: (input: DirectoryUpserted | DirectoryRemoved, options?: MakeOptions) => Option_.Option<DirectoryUpserted | DirectoryRemoved>;
makeEffect: (input: DirectoryUpserted | DirectoryRemoved, options?: MakeOptions) => Effect.Effect<DirectoryUpserted | DirectoryRemoved, SchemaError, never>;
pipe: { <A>(this: A): A; <A, B = never>(this: A, ab: (_: A) => B): B; <A, B = never, C = never>(this: A, ab: (_: A) => B, bc: (_: B) => C): C; <A, B = never, C = never, D = never>(this: A, ab: (_: A) => B, bc: (_: B) => C, cd: (_: C) => D): D; <…;
}
Membership-push event from
Directory.changes
.
Membership-push event type.
DirectoryChange = import SchemaSchema.function Union<
Members extends ReadonlyArray<Constraint>
>(
members: Members,
options?: { mode?: "anyOf" | "oneOf" }
): Union<Members>
Creates a union schema from an array of member schemas. Members are tested in
order; the first match is returned.
Details
Optionally, specify mode:
"anyOf" (default) — matches if any member matches."oneOf" — matches if exactly one member matches.
Example (Defining a string or number union)
import { Schema } from "effect"
const schema = Schema.Union([Schema.String, Schema.Number])
Schema.decodeUnknownSync(schema)("hello") // "hello"
Schema.decodeUnknownSync(schema)(42) // 42
Union([
class DirectoryUpsertedclass DirectoryUpserted {
Type: Self;
Encoded: S["Encoded"];
DecodingServices: S["DecodingServices"];
EncodingServices: S["EncodingServices"];
Iso: S["Iso"];
identifier: string;
fields: S["fields"];
mapFields: (f: (fields: { readonly _tag: Schema.tag<'DirectoryUpserted'>; readonly entry: typeof DirectoryEntry; readonly previous: Schema.optionalKey<typeof DirectoryEntry>; readonly dialChanged: Schema.Boolean }) => To, options?: { readonly unsafeP…;
extend: (identifier: string) => { (fields: NewFields, annotations?: Schema.Annotations.Declaration<Extended, readonly [Schema.Struct<{ [K in keyof { [K in keyof (('previous' | 'entry' | 'dialChanged' | '_tag') & keyof NewFields extends never ? { r…;
Rebuild: Rebuild;
ast: Ast;
annotate: (annotations: Schema.Annotations.Bottom<DirectoryUpserted, readonly [Schema.TaggedStruct<'DirectoryUpserted', { readonly entry: typeof DirectoryEntry; readonly previous: Schema.optionalKey<typeof DirectoryEntry>; readonly dialChanged: Sche…;
annotateKey: (annotations: Schema.Annotations.Key<DirectoryUpserted>) => Schema.decodeTo<Schema.declareConstructor<DirectoryUpserted, { readonly entry: { readonly kind: 'Http' | 'WebSocket' | 'IpcSocket'; readonly serves: ReadonlyArray<string>; readonl…;
check: (checks_0: Check<DirectoryUpserted>, ...checks: Array<Check<DirectoryUpserted>>) => Schema.decodeTo<Schema.declareConstructor<DirectoryUpserted, { readonly entry: { readonly kind: 'Http' | 'WebSocket' | 'IpcSocket'; readonly serves: Readon…;
rebuild: (ast: Declaration) => Schema.decodeTo<Schema.declareConstructor<DirectoryUpserted, { readonly entry: { readonly kind: 'Http' | 'WebSocket' | 'IpcSocket'; readonly serves: ReadonlyArray<string>; readonly nodeKey: string; readonly url?: stri…;
make: (input: { readonly entry: DirectoryEntry; readonly dialChanged: boolean; readonly previous?: DirectoryEntry | undefined; readonly _tag?: 'DirectoryUpserted' | undefined }, options?: MakeOptions) => DirectoryUpserted;
makeOption: (input: { readonly entry: DirectoryEntry; readonly dialChanged: boolean; readonly previous?: DirectoryEntry | undefined; readonly _tag?: 'DirectoryUpserted' | undefined }, options?: MakeOptions) => Option_.Option<DirectoryUpserted>;
makeEffect: (input: { readonly entry: DirectoryEntry; readonly dialChanged: boolean; readonly previous?: DirectoryEntry | undefined; readonly _tag?: 'DirectoryUpserted' | undefined }, options?: MakeOptions) => Effect.Effect<DirectoryUpserted, SchemaEr…;
pipe: { <A>(this: A): A; <A, B = never>(this: A, ab: (_: A) => B): B; <A, B = never, C = never>(this: A, ab: (_: A) => B, bc: (_: B) => C): C; <A, B = never, C = never, D = never>(this: A, ab: (_: A) => B, bc: (_: B) => C, cd: (_: C) => D): D; <…;
}
Directory row upserted (first advertise, serves refresh, or A→B dial replace).
dialChanged is true when the dial target moved (membership push for peer rebind).
DirectoryUpserted,
class DirectoryRemovedclass DirectoryRemoved {
Type: Self;
Encoded: S["Encoded"];
DecodingServices: S["DecodingServices"];
EncodingServices: S["EncodingServices"];
Iso: S["Iso"];
identifier: string;
fields: S["fields"];
mapFields: (f: (fields: { readonly _tag: Schema.tag<'DirectoryRemoved'>; readonly nodeKey: Schema.String; readonly previous: typeof DirectoryEntry }) => To, options?: { readonly unsafePreserveChecks?: boolean | undefined } | undefined) => Schema.Stru…;
extend: (identifier: string) => { (fields: NewFields, annotations?: Schema.Annotations.Declaration<Extended, readonly [Schema.Struct<{ [K in keyof { [K in keyof (('nodeKey' | 'previous' | '_tag') & keyof NewFields extends never ? { readonly _tag: …;
Rebuild: Rebuild;
ast: Ast;
annotate: (annotations: Schema.Annotations.Bottom<DirectoryRemoved, readonly [Schema.TaggedStruct<'DirectoryRemoved', { readonly nodeKey: Schema.String; readonly previous: typeof DirectoryEntry }>]>) => Schema.decodeTo<Schema.declareConstructor<Dire…;
annotateKey: (annotations: Schema.Annotations.Key<DirectoryRemoved>) => Schema.decodeTo<Schema.declareConstructor<DirectoryRemoved, Schema.Struct.ReadonlySide<{ readonly _tag: Schema.tag<'DirectoryRemoved'>; readonly nodeKey: Schema.String; readonly pr…;
check: (checks_0: Check<DirectoryRemoved>, ...checks: Array<Check<DirectoryRemoved>>) => Schema.decodeTo<Schema.declareConstructor<DirectoryRemoved, Schema.Struct.ReadonlySide<{ readonly _tag: Schema.tag<'DirectoryRemoved'>; readonly nodeKey: Sch…;
rebuild: (ast: Declaration) => Schema.decodeTo<Schema.declareConstructor<DirectoryRemoved, Schema.Struct.ReadonlySide<{ readonly _tag: Schema.tag<'DirectoryRemoved'>; readonly nodeKey: Schema.String; readonly previous: typeof DirectoryEntry }, 'Enc…;
make: (input: { readonly nodeKey: string; readonly previous: DirectoryEntry; readonly _tag?: 'DirectoryRemoved' | undefined }, options?: MakeOptions) => DirectoryRemoved;
makeOption: (input: { readonly nodeKey: string; readonly previous: DirectoryEntry; readonly _tag?: 'DirectoryRemoved' | undefined }, options?: MakeOptions) => Option_.Option<DirectoryRemoved>;
makeEffect: (input: { readonly nodeKey: string; readonly previous: DirectoryEntry; readonly _tag?: 'DirectoryRemoved' | undefined }, options?: MakeOptions) => Effect.Effect<DirectoryRemoved, SchemaError, never>;
pipe: { <A>(this: A): A; <A, B = never>(this: A, ab: (_: A) => B): B; <A, B = never, C = never>(this: A, ab: (_: A) => B, bc: (_: B) => C): C; <A, B = never, C = never, D = never>(this: A, ab: (_: A) => B, bc: (_: B) => C, cd: (_: C) => D): D; <…;
}
Directory row removed (unregister / dial-matched remove).
DirectoryRemoved,
]);
/**
* Membership-push event type.
*
* @category models
* @public
*/
export type type DirectoryChange =
| DirectoryUpserted
| DirectoryRemoved
Membership-push event from
Directory.changes
.
Membership-push event type.
DirectoryChange = typeof const DirectoryChange: Schema.Union<
readonly [
typeof DirectoryUpserted,
typeof DirectoryRemoved
]
>
const DirectoryChange: {
Type: { [K in keyof Members]: Members[K]["Type"]; }[number];
Encoded: { [K in keyof Members]: Members[K]["Encoded"]; }[number];
DecodingServices: { [K in keyof Members]: Members[K]["DecodingServices"]; }[number];
EncodingServices: { [K in keyof Members]: Members[K]["EncodingServices"]; }[number];
Iso: { [K in keyof Members]: Members[K]["Iso"]; }[number];
members: Members;
mapMembers: (f: (members: readonly [typeof DirectoryUpserted, typeof DirectoryRemoved]) => To, options?: { readonly unsafePreserveChecks?: boolean | undefined } | undefined) => Schema.Union<{ [K in keyof Readonly<To>]: Readonly<To>[K]; }>;
Rebuild: Rebuild;
ast: Ast;
annotate: (annotations: Schema.Annotations.Bottom<DirectoryUpserted | DirectoryRemoved, readonly []>) => Schema.Union<readonly [typeof DirectoryUpserted, typeof DirectoryRemoved]>;
annotateKey: (annotations: Schema.Annotations.Key<DirectoryUpserted | DirectoryRemoved>) => Schema.Union<readonly [typeof DirectoryUpserted, typeof DirectoryRemoved]>;
check: (checks_0: Check<DirectoryUpserted | DirectoryRemoved>, ...checks: Array<Check<DirectoryUpserted | DirectoryRemoved>>) => Schema.Union<readonly [typeof DirectoryUpserted, typeof DirectoryRemoved]>;
rebuild: (ast: Union<Declaration>) => Schema.Union<readonly [typeof DirectoryUpserted, typeof DirectoryRemoved]>;
make: (input: DirectoryUpserted | DirectoryRemoved, options?: MakeOptions) => DirectoryUpserted | DirectoryRemoved;
makeOption: (input: DirectoryUpserted | DirectoryRemoved, options?: MakeOptions) => Option_.Option<DirectoryUpserted | DirectoryRemoved>;
makeEffect: (input: DirectoryUpserted | DirectoryRemoved, options?: MakeOptions) => Effect.Effect<DirectoryUpserted | DirectoryRemoved, SchemaError, never>;
pipe: { <A>(this: A): A; <A, B = never>(this: A, ab: (_: A) => B): B; <A, B = never, C = never>(this: A, ab: (_: A) => B, bc: (_: B) => C): C; <A, B = never, C = never, D = never>(this: A, ab: (_: A) => B, bc: (_: B) => C, cd: (_: C) => D): D; <…;
}
Membership-push event from
Directory.changes
.
Membership-push event type.
DirectoryChange.Union<readonly [typeof DirectoryUpserted, typeof DirectoryRemoved]>["Type"]: DirectoryUpserted | DirectoryRemovedType;
Referenced by 1 symbols