MCPcopy Create free account

hub / github.com/CodeForBreakfast/eventsourcing / functions

Functions1,511 in github.com/CodeForBreakfast/eventsourcing

⨍ Functions 1,511◇ Types & classes 208
↓ 1 callersFunctiondecrementSubscribers
( ref: SynchronizedRef.SynchronizedRef<HashMap.HashMap<EventStreamId, SubscriptionData<T>>>, streamId: Eve
packages/eventsourcing-store-inmemory/src/lib/subscriptionManager.ts:120
↓ 1 callersFunctiondeleteTodo
(todoId: TodoId)
examples/todo-app/src/cli.ts:156
↓ 1 callersFunctiondisconnectAllClients
( serverState: ReadonlyDeep<InMemoryServerState> )
packages/eventsourcing-transport-inmemory/src/lib/inmemory-transport.ts:76
↓ 1 callersFunctiondisconnectAndRemoveClient
( serverState: ReadonlyDeep<InMemoryServerState>, clientId: ReadonlyDeep<string>, clientState: ReadonlyD
packages/eventsourcing-transport-inmemory/src/lib/inmemory-transport.ts:371
↓ 1 callersFunctiondisconnectClient
(clientState: ReadonlyDeep<InMemoryClientState>)
packages/eventsourcing-transport-inmemory/src/lib/inmemory-transport.ts:70
↓ 1 callersFunctiondisconnectClientAndCleanup
(serverStateRef: ReadonlyDeep<Ref.Ref<ServerState>>)
packages/eventsourcing-transport-websocket/src/lib/websocket-server.ts:349
↓ 1 callersFunctiondisplayChangeList
(terminal: Terminal.Terminal, changes: readonly DependencyChange[])
scripts/auto-generate-dependency-changeset.ts:260
↓ 1 callersFunctiondisplayChangeMessages
(terminal: Terminal.Terminal, changes: readonly DependencyChange[])
scripts/auto-generate-dependency-changeset.ts:266
↓ 1 callersFunctiondisplayChangesetMessages
(terminal: Terminal.Terminal, path: string)
scripts/auto-generate-dependency-changeset.ts:244
↓ 1 callersFunctiondisplayDependencyError
(terminal: Terminal.Terminal)
scripts/validate-changesets.ts:710
↓ 1 callersFunctiondisplayDependencyErrors
( terminal: Terminal.Terminal, dependencyErrors: readonly MissingDependentError[] )
scripts/validate-changesets.ts:719
↓ 1 callersFunctiondisplayDocOnlyInfo
(terminal: Terminal.Terminal)
scripts/validate-changesets.ts:636
↓ 1 callersFunctiondisplayErrors
(terminal: Terminal.Terminal, errors: readonly string[])
scripts/validate-changesets.ts:545
↓ 1 callersFunctiondisplayErrorsAndFail
(errors: readonly ValidationError[])
scripts/validate-markdown-examples.ts:527
↓ 1 callersFunctiondisplayFileList
(terminal: Terminal.Terminal, files: readonly string[])
scripts/validate-changesets.ts:578
↓ 1 callersFunctiondisplayFoundMessage
(terminal: Terminal.Terminal, count: number)
scripts/auto-generate-dependency-changeset.ts:263
↓ 1 callersFunctiondisplayPackageList
(changedPackageNames: readonly string[])
scripts/validate-publish.ts:160
↓ 1 callersFunctiondisplayPackageList
(packages: readonly string[])
scripts/orchestrate-publish-validation.ts:46
↓ 1 callersFunctiondisplayPackageList
(terminal: Terminal.Terminal, packages: readonly string[])
scripts/validate-changesets.ts:679
↓ 1 callersFunctiondisplayPackageList
(packageNames: readonly string[])
scripts/validate-release.ts:98
↓ 1 callersFunctiondisplayPackages
(terminal: Terminal.Terminal, packages: readonly PackageInternal[])
scripts/validate-changesets.ts:551
↓ 1 callersFunctiondisplaySingleChange
(terminal: Terminal.Terminal)
scripts/auto-generate-dependency-changeset.ts:257
↓ 1 callersFunctiondisplaySingleError
(terminal: Terminal.Terminal)
scripts/validate-changesets.ts:542
↓ 1 callersFunctiondisplaySingleFile
(terminal: Terminal.Terminal)
scripts/validate-changesets.ts:575
↓ 1 callersFunctiondisplaySingleMissingDependency
(terminal: Terminal.Terminal)
scripts/validate-changesets.ts:699
↓ 1 callersFunctiondisplaySinglePackage
(terminal: Terminal.Terminal)
scripts/validate-changesets.ts:548
↓ 1 callersFunctiondisplaySinglePackageName
(terminal: Terminal.Terminal)
scripts/validate-changesets.ts:676
↓ 1 callersFunctiondisplaySingleUnpublishablePackage
(terminal: Terminal.Terminal)
scripts/validate-changesets.ts:604
↓ 1 callersFunctiondisplaySuccess
(changesets: readonly ChangesetInfoInternal[])
scripts/validate-changesets.ts:797
↓ 1 callersFunctiondisplayUnpublishableError
(unpublishable: readonly string[])
scripts/validate-changesets.ts:633
↓ 1 callersFunctiondisplayUnpublishablePackages
( terminal: Terminal.Terminal, unpublishable: readonly string[] )
scripts/validate-changesets.ts:607
↓ 1 callersFunctiondisplayValidationFailure
( errors: readonly string[], packages: readonly PackageInternal[] )
scripts/validate-changesets.ts:570
↓ 1 callersFunctiondisplayWarningForMissingBlockFile
(filename: string)
scripts/validate-markdown-examples.ts:394
↓ 1 callersFunctiondistributeMessageToSubscribers
(clientState: ReadonlyDeep<ClientState>)
packages/eventsourcing-transport-websocket/src/lib/websocket-server.ts:187
↓ 1 callersFunctiondistributeMessageToSubscribers
(stateRef: Readonly<Ref.Ref<WebSocketInternalState>>)
packages/eventsourcing-transport-websocket/src/lib/websocket-transport.ts:206
↓ 1 callersFunctionencodeAndPublishCommand
( transport: ReadonlyDeep<Client.Transport>, command: ReadonlyDeep<WireCommand>, timestamp: ReadonlyDeep
packages/eventsourcing-protocol/src/lib/protocol.ts:351
↓ 1 callersFunctionencodeAndPublishSubscribe
( transport: ReadonlyDeep<Client.Transport>, streamId: string, timestamp: ReadonlyDeep<Date> )
packages/eventsourcing-protocol/src/lib/protocol.ts:443
↓ 1 callersFunctionencodeProtocolCommand
( command: ReadonlyDeep<WireCommand>, context: { readonly traceId: string; readonly parentId: string } )
packages/eventsourcing-protocol/src/lib/protocol.ts:320
↓ 1 callersFunctionencodeProtocolSubscribe
( streamId: string, context: { readonly traceId: string; readonly parentId: string } )
packages/eventsourcing-protocol/src/lib/protocol.ts:428
↓ 1 callersFunctionenrichEventWithMetadata
( event: TEvent, metadata: EventMetadata<TOrigin> )
packages/eventsourcing-aggregates/src/lib/aggregateRootEventStream.ts:111
↓ 1 callersFunctionensureStreamDirectoryExists
( streamDir: string, fs: FileSystem.FileSystem )
packages/eventsourcing-store-filesystem/src/lib/FileSystemStore.ts:71
↓ 1 callersFunctioneventMetadata
()
packages/eventsourcing-aggregates/src/lib/aggregateRootEventStream.ts:392
↓ 1 callersFunctionexecuteAddTodo
(event: Readonly<EventRecord<TodoCreated, UserId>>)
examples/todo-app/src/infrastructure/processManager.ts:71
↓ 1 callersFunctionexecuteAndCommit
( state: Readonly<AggregateState<TodoListState>>, event: TEvent, command: Effect.Effect<ReadonlyArray<To
examples/todo-app/src/infrastructure/processManager.ts:45
↓ 1 callersFunctionexecuteCommandAndPersistEvents
(router: ReadonlyDeep<CommandRouter<TEvent>>, eventStore: EventStore<TEvent>)
packages/eventsourcing-aggregates/src/lib/commandProcessingFactory.ts:36
↓ 1 callersFunctionexecuteHandlerAndGetPosition
( handler: { readonly execute: ( command: Readonly<WireCommand> ) => Effect.Effect<ReadonlyArr
packages/eventsourcing-aggregates/src/lib/commandProcessingFactory.ts:18
↓ 1 callersFunctionexecuteHealthCheck
(listenConnection: PgClient.PgClient)
packages/eventsourcing-store-postgres/src/connectionManager.ts:34
↓ 1 callersFunctionexecuteMatcherWithErrorHandling
( command: CommandFromDefinitions<T>, wireCommand: ReadonlyDeep<WireCommand> )
packages/eventsourcing-commands/src/lib/command-registry.ts:85
↓ 1 callersFunctionexecutePackageValidation
(root: string, packagesToValidate: readonly string[])
scripts/validate-release.ts:243
↓ 1 callersFunctionexecuteRemoveTodo
(event: Readonly<EventRecord<TodoDeleted, UserId>>)
examples/todo-app/src/infrastructure/processManager.ts:79
↓ 1 callersFunctionexecuteShutdown
(_listenConnection: PgClient.PgClient)
packages/eventsourcing-store-postgres/src/connectionManager.ts:45
↓ 1 callersFunctionexecuteWireCommand
( stateRef: Ref.Ref<ProtocolState>, transport: ReadonlyDeep<Client.Transport>, command: ReadonlyDe
packages/eventsourcing-protocol/src/lib/protocol.ts:406
↓ 1 callersFunctionextractChangesForPath
(pkg: PackageInfo)
scripts/auto-generate-dependency-changeset.ts:143
↓ 1 callersFunctionextractChangesFromPackage
(packageName: string)
scripts/auto-generate-dependency-changeset.ts:133
↓ 1 callersFunctionextractCodeBlocks
(content: string, filePath: string)
scripts/validate-markdown-examples.ts:127
↓ 1 callersFunctionextractDependencyChanges
( packageName: string, before: { readonly dependencies?: Record<string, string> }, after: { readonly dep
scripts/auto-generate-dependency-changeset.ts:106
↓ 1 callersFunctionextractMessageId
(msg: unknown)
packages/eventsourcing-transport-websocket/src/lib/websocket-transport.test.ts:246
↓ 1 callersFunctionextractStatusFromMap
(url: string)
packages/eventsourcing-store/src/lib/streaming/connectionManager.ts:170
↓ 1 callersFunctionextractSubscriptionData
(streamId: EventStreamId)
packages/eventsourcing-store-postgres/src/subscriptionManager.ts:114
↓ 1 callersFunctionextractSubscriptionData
(streamId: EventStreamId)
packages/eventsourcing-store-inmemory/src/lib/subscriptionManager.ts:79
↓ 1 callersFunctionextractUnpublishablePackages
(error: unknown)
scripts/validate-changesets.ts:481
↓ 1 callersFunctionfailDeferredAndUpdateState
( connectedDeferred: Readonly<Deferred.Deferred<void, ConnectionError>>, stateRef: Readonly<Ref.Ref<WebSoc
packages/eventsourcing-transport-websocket/src/lib/websocket-transport.ts:294
↓ 1 callersFunctionfetchAfterPackageJson
(beforeContent: unknown, filePath: string)
scripts/validate-changesets.ts:398
↓ 1 callersFunctionfetchGitOrigin
(root: string, baseBranch: string)
scripts/validate-release.ts:37
↓ 1 callersFunctionfilterEvent
(filter: (event: TEvent) => event is TFiltered)
packages/eventsourcing-server/src/lib/eventBus.ts:74
↓ 1 callersFunctionfilterPackagesByDirectory
(changedDirectories: ReadonlySet<string>)
scripts/validate-publish.ts:113
↓ 1 callersFunctionfilterTakeAndDrain
( expectedState: ConnectionState, timeoutMs: number, connectionStateStream: Stream.Stream<ConnectionStat
packages/eventsourcing-testing-contracts/src/lib/test-utilities.ts:274
↓ 1 callersFunctionfinalizeParserState
(filePath: string)
scripts/validate-markdown-examples.ts:104
↓ 1 callersFunctionfindBlockFileByFilename
(filename: string, blockFiles: readonly BlockFile[])
scripts/validate-markdown-examples.ts:375
↓ 1 callersFunctionfindMarkdownFiles
(dir: string)
scripts/validate-markdown-examples.ts:280
↓ 1 callersFunctionfindNestedPipe
(n, stopAtFunctionBoundary = false)
packages/eslint-effect/src/rules/no-nested-pipes.js:31
↓ 1 callersFunctionfindStatusInMap
(url: string)
packages/eventsourcing-store/src/lib/streaming/connectionManager.ts:250
↓ 1 callersFunctionflatMapEntryProcessor
(currentDir: string)
scripts/validate-markdown-examples.ts:228
↓ 1 callersFunctionflatMapProcessLine
(filePath: string, index: number, line: string)
scripts/validate-markdown-examples.ts:119
↓ 1 callersFunctionflipAndFilterError
( errorPredicate: (error: E) => boolean, effect: Effect.Effect<A, E, never> )
packages/eventsourcing-testing-contracts/src/lib/test-utilities.ts:234
↓ 1 callersFunctionfoldEvents
( apply: ( data: ReadonlyDeep<Option.Option<TData>> ) => ( event: ReadonlyDeep<TEvent>
packages/eventsourcing-projections/src/lib/projection.ts:45
↓ 1 callersFunctionfoldEventsIntoState
( apply: ( state: Readonly<Option.Option<TState>> ) => (event: Readonly<TEvent>) => Effect.Effec
packages/eventsourcing-aggregates/src/lib/aggregateRootEventStream.ts:185
↓ 1 callersFunctionforEachTodoItem
(todos: Readonly<ReadonlyArray<{ readonly todoId: TodoId }>>)
examples/todo-app/src/cli.ts:191
↓ 1 callersFunctionforkAndVerifyFilteredMessages
(transport: ConnectedTransportTestInterface)
packages/eventsourcing-testing-contracts/src/lib/transport/client-transport-contract-tests.ts:290
↓ 1 callersFunctionforkPerStreamSubscription
(store: EventStore<string>, streamId: EventStreamId)
packages/eventsourcing-store-postgres/src/bridge.integration.test.ts:45
↓ 1 callersFunctionforkPumpAndCreateService
(pubsub: PubSub.PubSub<StreamEvent<TEvent>>)
packages/eventsourcing-server/src/lib/eventBus.ts:126
↓ 1 callersFunctionforkStreamCollection
(count: number)
packages/eventsourcing-testing-contracts/src/lib/transport/client-transport-contract-tests.ts:190
↓ 1 callersFunctionformatAddedDependency
(change: DependencyChange)
scripts/auto-generate-dependency-changeset.ts:174
↓ 1 callersFunctionformatAllErrors
(errors: readonly ValidationError[])
scripts/validate-markdown-examples.ts:524
↓ 1 callersFunctionformatAndLogTodo
(todoId: TodoId)
examples/todo-app/src/cli.ts:169
↓ 1 callersFunctionformatDependencyChange
(change: DependencyChange)
scripts/auto-generate-dependency-changeset.ts:180
↓ 1 callersFunctionformatError
(error: ValidationError)
scripts/validate-markdown-examples.ts:464
↓ 1 callersFunctionformatErrorLine
(line: string)
scripts/validate-markdown-examples.ts:449
↓ 1 callersFunctionformatErrorLines
(errorLines: readonly string[])
scripts/validate-markdown-examples.ts:457
↓ 1 callersFunctionformatRemovedDependency
(change: DependencyChange)
scripts/auto-generate-dependency-changeset.ts:171
↓ 1 callersFunctionformatTodoList
(events: readonly unknown[])
packages/eslint-effect/test/prefer-match-over-ternary.test.ts:109
↓ 1 callersFunctionformatTodoList
(todos: Readonly<ReadonlyArray<{ readonly todoId: TodoId }>>)
examples/todo-app/src/cli.ts:194
↓ 1 callersFunctionformatUpdatedDependency
(change: DependencyChange)
scripts/auto-generate-dependency-changeset.ts:177
↓ 1 callersFunctionforwardMessagesToSubscriber
(sourceQueue: ReadonlyDeep<Queue.Queue<TransportMessage>>)
packages/eventsourcing-transport-inmemory/src/lib/inmemory-transport.ts:143
↓ 1 callersFunctionforwardToSubscribers
( clientState: ReadonlyDeep<InMemoryClientState>, message: ReadonlyDeep<TransportMessage>, excludeQueue?
packages/eventsourcing-transport-inmemory/src/lib/inmemory-transport.ts:180
↓ 1 callersFunctiongenerateChangesetContent
(changes: readonly DependencyChange[])
scripts/auto-generate-dependency-changeset.ts:192
↓ 1 callersFunctiongenerateClientId
()
packages/eventsourcing-transport-inmemory/src/lib/inmemory-transport.ts:286
↓ 1 callersFunctiongenerateContent
(changes: readonly DependencyChange[])
scripts/auto-generate-dependency-changeset.ts:280
↓ 1 callersFunctiongetAllEventsFromAllStreams
( config: FileSystemStoreConfig )
packages/eventsourcing-store-filesystem/src/lib/FileSystemStore.ts:558
↓ 1 callersFunctiongetAllEventsFromAllStreamsWithServices
( config: FileSystemStoreConfig, streamIds: readonly EventStreamId[], fs: FileSystem.FileSystem, path:
packages/eventsourcing-store-filesystem/src/lib/FileSystemStore.ts:545
← previousnext →401–500 of 1,511, ranked by callers