MCPcopy Create free account

hub / github.com/CodeForBreakfast/eventsourcing / functions

Functions1,511 in github.com/CodeForBreakfast/eventsourcing

⨍ Functions 1,511◇ Types & classes 208
↓ 1 callersFunctionisKnownLibraryFunction
(node)
packages/eslint-effect/src/rules/suggest-currying-opportunity.js:77
↓ 1 callersFunctionisLogDebugCall
(node)
packages/eslint-effect/src/rules/prefer-ignore-logged.js:85
↓ 1 callersFunctionisMatchCauseEffectCall
(node)
packages/eslint-effect/src/rules/prefer-ignore-logged.js:22
↓ 1 callersFunctionisMatchValueCall
(node)
packages/eslint-effect/src/rules/prefer-effect-if-over-match-boolean.js:105
↓ 1 callersFunctionisMatchValueIdentifier
(node)
packages/eslint-effect/src/rules/prefer-effect-if-over-match-boolean.js:22
↓ 1 callersFunctionisNullReturn
(arrowFunc)
packages/eslint-effect/src/rules/utils.js:35
↓ 1 callersFunctionisOptionCheck
(node)
packages/eslint-effect/src/rules/no-effect-if-option-check.js:30
↓ 1 callersFunctionisOptionNone
(node)
packages/eslint-effect/src/rules/prefer-succeed-none.js:27
↓ 1 callersFunctionisOptionNoneCall
(node)
packages/eslint-effect/src/rules/prefer-from-nullable.js:31
↓ 1 callersFunctionisOptionSomeCall
(node)
packages/eslint-effect/src/rules/prefer-from-nullable.js:19
↓ 1 callersFunctionisPipeCall
(node)
packages/eslint-effect/src/rules/prefer-effect-if-over-match-boolean.js:96
↓ 1 callersFunctionisRelevantTernary
(node)
packages/eslint-effect/src/rules/prefer-match-over-ternary.js:106
↓ 1 callersFunctionisSchemaComposition
(node)
packages/eslint-effect/src/rules/no-intermediate-effect-variables.js:95
↓ 1 callersFunctionisSucceedCall
(node)
packages/eslint-effect/src/rules/prefer-succeed-none.js:17
↓ 1 callersFunctionisUndefinedReturn
(arrowFunc)
packages/eslint-effect/src/rules/utils.js:53
↓ 1 callersFunctionisValueAccess
(node, expectedOption)
packages/eslint-effect/src/rules/prefer-get-or-else.js:37
↓ 1 callersFunctionisVoidEffect
(node)
packages/eslint-effect/src/rules/prefer-ignore-logged.js:32
↓ 1 callersFunctionisWorkspaceDependency
(depVersion: string)
scripts/check-package-dependencies.ts:103
↓ 1 callersFunctionisZipLeftPattern
(arrowFunc, effectType)
packages/eslint-effect/src/rules/prefer-zip-left.js:25
↓ 1 callersFunctionisZipRightPattern
(arrowFunc)
packages/eslint-effect/src/rules/prefer-zip-right.js:25
↓ 1 callersFunctionjoinBothFibers
( perStreamFiber: Fiber.Fiber<Chunk.Chunk<string>, unknown>, allEventsFiber: Fiber.Fiber< Chunk.Chunk<
packages/eventsourcing-store-postgres/src/bridge.integration.test.ts:75
↓ 1 callersFunctionjoinBothFibers
(sub2: Stream.Stream<{ readonly event: TodoEvent }>)
packages/eventsourcing-server/src/lib/eventBus.test.ts:223
↓ 1 callersFunctionlayer
( layer_: Layer.Layer<R, E>, options?: { readonly memoMap?: Layer.MemoMap; readonly timeou
packages/bun-test-effect/src/internal/internal.ts:182
↓ 1 callersFunctionlistenAllEvents
( activeChannels: Ref.Ref<HashSet.HashSet<string>>, client: PgClient.PgClient, notificationQueue: Queue.
packages/eventsourcing-store-postgres/src/notificationListener.ts:372
↓ 1 callersFunctionlistenForWireCommand
( serverProtocol: Context.Tag.Service<ServerProtocol> )
packages/eventsourcing-protocol/src/lib/protocol.test.ts:1453
↓ 1 callersFunctionloadAggregateState
( id: TId, apply: ( state: Readonly<Option.Option<TState>> ) => (event: Readonly<TEvent>) =>
packages/eventsourcing-aggregates/src/lib/aggregateRootEventStream.ts:233
↓ 1 callersFunctionloadAndFormatTodo
(todoId: TodoId)
examples/todo-app/src/cli.ts:188
↓ 1 callersFunctionloadAndProcessEvents
( id: string, apply: ( data: ReadonlyDeep<Option.Option<TData>> ) => ( event: Readonly
packages/eventsourcing-projections/src/lib/projection.ts:86
↓ 1 callersFunctionloadStreamEvents
(eventStore: EventStore<TEvent>, id: TId)
packages/eventsourcing-aggregates/src/lib/aggregateRootEventStream.ts:229
↓ 1 callersFunctionloadTodoListProjection
()
examples/todo-app/src/projections/todoListProjection.ts:69
↓ 1 callersFunctionlogAppendedEvents
(newEvents: Chunk.Chunk<unknown>, streamEnd: EventStreamPosition)
packages/eventsourcing-store-inmemory/src/lib/InMemoryStore.ts:50
↓ 1 callersFunctionlogErrorWrongOrder
(error: unknown, message: string)
packages/eslint-effect/test/currying-examples.ts:23
↓ 1 callersFunctionlogFailure
(result: CommandFailure)
packages/eventsourcing-aggregates/src/lib/command-processing-example.ts:95
↓ 1 callersFunctionlogHandlerError
(error: unknown, message: ReadonlyDeep<TransportMessage>)
packages/eventsourcing-protocol/src/lib/protocol.test.ts:200
↓ 1 callersFunctionlogHandlerErrorWrongOrder
(error: unknown, message: string)
packages/eslint-effect/test/suggest-currying-opportunity.test.ts:7
↓ 1 callersFunctionlogMalformedCodeBlock
(filePath: string, lineIndex: number, state: ParserState)
scripts/validate-markdown-examples.ts:37
↓ 1 callersFunctionlogParseError
(error: unknown, payload: unknown)
packages/eventsourcing-protocol/src/lib/protocol.test.ts:178
↓ 1 callersFunctionlogSuccess
(result: CommandSuccess)
packages/eventsourcing-aggregates/src/lib/command-processing-example.ts:91
↓ 1 callersFunctionlogTodo
(todoId: TodoId, todo: Readonly<TodoState>)
examples/todo-app/src/cli.ts:164
↓ 1 callersFunctionlogUnclosedBlock
(filePath: string, state: ParserState)
scripts/validate-markdown-examples.ts:88
↓ 1 callersFunctionmakeEncodedEventStore
(todoSchema: typeof TodoEvent)
packages/eventsourcing-server/src/lib/eventBus.test.ts:35
↓ 1 callersFunctionmakeEventBus
()
examples/todo-app/src/infrastructure/eventBus.ts:42
↓ 1 callersFunctionmakeFilesystemLayer
(baseDir: string)
examples/todo-app/tests/todoAggregateWithFilesystem.test.ts:17
↓ 1 callersFunctionmakeFooEventStoreLayer
()
packages/eventsourcing-store-inmemory/src/lib/inMemory.spec.ts:22
↓ 1 callersFunctionmakeFooEventStoreLayer
()
packages/eventsourcing-store-filesystem/src/lib/fileSystem.spec.ts:25
↓ 1 callersFunctionmakeInMemorySubscriptionManager
()
packages/eventsourcing-store-inmemory/src/lib/subscriptionManager.ts:219
↓ 1 callersFunctionmakeInitialState
()
packages/eventsourcing-testing-contracts/src/lib/test-utilities.ts:166
↓ 1 callersFunctionmakeSqlEventStoreWithSubscriptionManager
( subscriptionManager: SubscriptionManagerService, notificationListener: Readonly<{ readonly listen:
packages/eventsourcing-store-postgres/src/sqlEventStore.ts:341
↓ 1 callersFunctionmakeStringEventStoreLayer
()
packages/eventsourcing-store-filesystem/src/lib/fileSystem.spec.ts:54
↓ 1 callersFunctionmakeTestLayer
()
packages/eventsourcing-aggregates/src/lib/aggregate-load.test.ts:71
↓ 1 callersFunctionmakeTodoEventStore
()
examples/todo-app/src/cli.ts:23
↓ 1 callersFunctionmakeTodoListEventStore
()
examples/todo-app/src/cli.ts:28
↓ 1 callersFunctionmakeWebSocketProtocolLayer
( url: string )
packages/eventsourcing-websocket/src/lib/index.ts:39
↓ 1 callersFunctionmapNamesToEntries
(currentDir: string)
scripts/validate-markdown-examples.ts:224
↓ 1 callersFunctionmapServerConnections
(transport: InMemoryServer)
packages/eventsourcing-transport-inmemory/src/tests/integration/client-server.test.ts:91
↓ 1 callersFunctionmatchFailureError
(expectedErrorTag: string, expectedErrors?: readonly string[])
packages/eventsourcing-protocol/src/lib/protocol.test.ts:350
↓ 1 callersFunctionmatchParsedError
(expectedErrorTag: string, expectedErrors?: readonly string[])
packages/eventsourcing-protocol/src/lib/protocol.test.ts:300
↓ 1 callersFunctionmatchPendingCommand
(stateRef: Ref.Ref<ProtocolState>, message: ReadonlyDeep<ProtocolCommandResult>)
packages/eventsourcing-protocol/src/lib/protocol.ts:257
↓ 1 callersFunctionmatchStatusOption
(url: string)
packages/eventsourcing-store/src/lib/streaming/connectionManager.ts:253
↓ 1 callersFunctionmatchSubscribedConnections
( server: ReadonlyDeep<Server.Transport>, event: ReadonlyDeep<Event & { readonly streamId: EventStream
packages/eventsourcing-protocol/src/lib/server-protocol.ts:285
↓ 1 callersFunctionmissingArgError
(msg: string)
packages/eslint-effect/test/prefer-match-over-ternary.test.ts:112
↓ 1 callersFunctionmockConnect
( _url: string, _options?: Readonly<Record<string, unknown>> )
packages/eventsourcing-store/src/lib/streaming/connectionManager.ts:190
↓ 1 callersFunctionmodifyEventStreamsByIdWithEmptyStream
( streamId: EventStreamId, emptyStream: EventStream<V>, eventStreamsById: HashMap.HashMap<EventStreamId,
packages/eventsourcing-store-inmemory/src/lib/InMemoryStore.ts:163
↓ 1 callersFunctionmodifyEventStreamsWithEmptyIfMissing
(streamId: EventStreamId, emptyStream: EventStream<V>)
packages/eventsourcing-store-inmemory/src/lib/InMemoryStore.ts:152
↓ 1 callersFunctionmonitorSocketFiber
(stateRef: Readonly<Ref.Ref<WebSocketInternalState>>)
packages/eventsourcing-transport-websocket/src/lib/websocket-transport.ts:331
↓ 1 callersFunctionnoGen
()
packages/eslint-effect/src/configs.js:176
↓ 1 callersFunctionnotifyDisconnection
(stateRef: Ref.Ref<MockTransportState>)
packages/eventsourcing-testing-contracts/src/lib/test-utilities.ts:96
↓ 1 callersFunctionnotifySubscribersOfMessage
(message: TransportMessage, updatedState: MockTransportState)
packages/eventsourcing-testing-contracts/src/lib/test-utilities.ts:57
↓ 1 callersFunctionofferEventToQueue
(message: ReadonlyDeep<ProtocolEvent>)
packages/eventsourcing-protocol/src/lib/protocol.ts:272
↓ 1 callersFunctionofferMessageToClientQueue
(message: TransportMessage)
packages/eventsourcing-transport-websocket/src/lib/websocket-server.ts:182
↓ 1 callersFunctionofferMessageToQueue
(message: TransportMessage)
packages/eventsourcing-transport-websocket/src/lib/websocket-transport.ts:201
↓ 1 callersFunctionofferNewConnection
(clientState: ClientState)
packages/eventsourcing-transport-websocket/src/lib/websocket-server.ts:284
↓ 1 callersFunctionofferToClientConnectionStateQueue
( clientState: ReadonlyDeep<ClientState>, newState: ReadonlyDeep<ConnectionState> )
packages/eventsourcing-transport-websocket/src/lib/websocket-server.ts:167
↓ 1 callersMethodonTestFinished
(callback: () => void | Promise<void>)
packages/bun-test-effect/src/internal/internal.ts:28
↓ 1 callersFunctionparseAndHandleMessage
( server: ReadonlyDeep<InMemoryServer>, commandHandler: (cmd: ReadonlyDeep<WireCommand>) => CommandResult,
packages/eventsourcing-protocol/src/lib/protocol.test.ts:184
↓ 1 callersFunctionparseAndQueue
( notificationQueue: Queue.Queue<{ readonly streamId: EventStreamId; readonly payload: Notific
packages/eventsourcing-store-postgres/src/notificationListener.ts:306
↓ 1 callersFunctionparseAndQueueStreamNotification
( rawPayload: string, notificationQueue: Queue.Queue<{ readonly streamId: EventStreamId; readonly
packages/eventsourcing-store-postgres/src/notificationListener.ts:134
↓ 1 callersFunctionparseChangesetContent
(file: string)
scripts/validate-changesets.ts:196
↓ 1 callersFunctionparseChangesetFile
(fs: FileSystem.FileSystem, path: Path.Path, changesetsDir: string)
scripts/validate-changesets.ts:210
↓ 1 callersFunctionparseChangesetFiles
(fs: FileSystem.FileSystem, path: Path.Path, changesetsDir: string)
scripts/validate-changesets.ts:221
↓ 1 callersFunctionparseErrorMessage
( error: { readonly message: string }, expectedErrorTag: string, expectedErrors?: readonly string[] )
packages/eventsourcing-protocol/src/lib/protocol.test.ts:330
↓ 1 callersFunctionparseEventNumber
(filename: string)
packages/eventsourcing-store-filesystem/src/lib/FileSystemStore.ts:340
↓ 1 callersFunctionparseFrontmatter
(content: string)
scripts/validate-changesets.ts:134
↓ 1 callersFunctionparsePackageInfo
(packageJsonPath: string)
scripts/auto-generate-dependency-changeset.ts:56
↓ 1 callersFunctionparsePackageJson
(content: string)
scripts/validate-publish.ts:39
↓ 1 callersFunctionparsePackageJsonContent
(packagePath: string)
scripts/validate-changesets.ts:45
↓ 1 callersFunctionparsePackagesFromFrontmatter
( frontmatterContent: string )
scripts/validate-changesets.ts:163
↓ 1 callersFunctionparseStreamIdAndQueueNotification
( notificationQueue: Queue.Queue<{ readonly streamId: EventStreamId; readonly payload: Notific
packages/eventsourcing-store-postgres/src/notificationListener.ts:110
↓ 1 callersFunctionparseTypeErrors
( stdout: string, blockFiles: readonly BlockFile[] )
scripts/validate-markdown-examples.ts:433
↓ 1 callersFunctionperformSubscriptionCycle
(cycleNumber: number)
packages/eventsourcing-protocol/src/lib/protocol.test.ts:1954
↓ 1 callersFunctionpipeStrict
()
packages/eslint-effect/src/configs.js:186
↓ 1 callersFunctionpluginRules
()
packages/eslint-effect/src/configs.js:161
↓ 1 callersFunctionpreferMatch
()
packages/eslint-effect/src/configs.js:181
↓ 1 callersFunctionprocessAfterContent
(beforeContent: unknown)
scripts/validate-changesets.ts:391
↓ 1 callersFunctionprocessAllBlocks
(tempDir: string, _packageDir: string)
scripts/validate-markdown-examples.ts:566
↓ 1 callersFunctionprocessAllEventsNotification
( notificationQueue: Queue.Queue<{ readonly streamId: EventStreamId; readonly payload: Notific
packages/eventsourcing-store-postgres/src/notificationListener.ts:324
↓ 1 callersFunctionprocessChangedFiles
( changedFiles: readonly string[], changesets: readonly ChangesetInfoInternal[], packages: readonly Pack
scripts/validate-changesets.ts:902
↓ 1 callersFunctionprocessChanges
(changes: readonly DependencyChange[])
scripts/auto-generate-dependency-changeset.ts:283
↓ 1 callersFunctionprocessClientMessage
( state: ServerState, clientId: Server.ClientId, message: ReadonlyDeep<string> )
packages/eventsourcing-transport-websocket/src/lib/websocket-server.ts:324
↓ 1 callersFunctionprocessCommand
( todoState: Readonly<Option.Option<TodoState>>, command: ( state: Readonly<Option.Option<TodoState>>
examples/todo-app/src/cli.ts:90
← previousnext →601–700 of 1,511, ranked by callers