MCPcopy Create free account

hub / github.com/CodeForBreakfast/eventsourcing / functions

Functions1,511 in github.com/CodeForBreakfast/eventsourcing

⨍ Functions 1,511◇ Types & classes 208
↓ 1 callersFunctiongetAllEventsLiveOnlyStream
( value: SynchronizedRef.SynchronizedRef<Value<V>> )
packages/eventsourcing-store-inmemory/src/lib/InMemoryStore.ts:295
↓ 1 callersFunctiongetAllEventsLiveOnlyStream
( state: SynchronizedRef.SynchronizedRef<FileSystemStoreState<V>> )
packages/eventsourcing-store-filesystem/src/lib/FileSystemStore.ts:604
↓ 1 callersFunctiongetAllEventsStream
( value: SynchronizedRef.SynchronizedRef<Value<V>> )
packages/eventsourcing-store-inmemory/src/lib/InMemoryStore.ts:286
↓ 1 callersFunctiongetAllStreams
( config: FileSystemStoreConfig )
packages/eventsourcing-store-filesystem/src/lib/FileSystemStore.ts:501
↓ 1 callersFunctiongetAllStreamsWithFs
(config: FileSystemStoreConfig)
packages/eventsourcing-store-filesystem/src/lib/FileSystemStore.ts:491
↓ 1 callersFunctiongetBothPackageJsons
(relativePath: string, pkgPath: string)
scripts/auto-generate-dependency-changeset.ts:140
↓ 1 callersFunctiongetCallExpressionFromBody
(body)
packages/eslint-effect/src/rules/suggest-currying-opportunity.js:87
↓ 1 callersFunctiongetCallbackBody
(callback)
packages/eslint-effect/src/rules/prefer-match-over-conditionals.js:49
↓ 1 callersFunctiongetCalleeName
(node)
packages/eslint-effect/src/rules/no-curried-calls.js:40
↓ 1 callersFunctiongetConnectionAndCommunicate
(server: ServerTransport, client: ClientTransport)
packages/eventsourcing-testing-contracts/src/lib/transport/client-server-contract-tests.ts:445
↓ 1 callersFunctiongetConnectionAndDisconnect
( server: ServerTransport, clientScope: Scope.CloseableScope )
packages/eventsourcing-testing-contracts/src/lib/transport/client-server-contract-tests.ts:588
↓ 1 callersFunctiongetConnectionAndPublish
(server: ServerTransport, client: ClientTransport)
packages/eventsourcing-testing-contracts/src/lib/transport/client-server-contract-tests.ts:787
↓ 1 callersFunctiongetCurrentLastEvent
( lastEvents: HashMap.HashMap<EventStreamId, number>, streamId: EventStreamId )
packages/eventsourcing-store-postgres/src/eventStreamTracker.ts:26
↓ 1 callersFunctiongetDependentNames
(packageName: string)
scripts/check-package-dependencies.ts:107
↓ 1 callersFunctiongetDependentsForPackage
( packageName: string, allPackages: readonly PackageInfo[] )
scripts/check-package-dependencies.ts:115
↓ 1 callersFunctiongetEnvVar
(key: string)
scripts/validate-release.ts:25
↓ 1 callersFunctiongetEventStoreAndCommit
( eventstoreTag: Readonly<Context.Tag<TTag, EventStore<EventRecord<TEvent, TOrigin>>>>, id: TId, eventNu
packages/eventsourcing-aggregates/src/lib/aggregateRootEventStream.ts:125
↓ 1 callersFunctiongetEventStreamAndCreateHistorical
( eventStreamsById: HashMap.HashMap<EventStreamId, EventStream<V>>, streamId: EventStreamId )
packages/eventsourcing-store-inmemory/src/lib/InMemoryStore.ts:246
↓ 1 callersFunctiongetEventStreamAndCreateLive
( eventStreamsById: HashMap.HashMap<EventStreamId, EventStream<V>>, streamId: EventStreamId )
packages/eventsourcing-store-inmemory/src/lib/InMemoryStore.ts:240
↓ 1 callersFunctiongetEventsForStream
( config: FileSystemStoreConfig, state: SynchronizedRef.SynchronizedRef<FileSystemStoreState<V>> )
packages/eventsourcing-store-filesystem/src/lib/FileSystemStore.ts:469
↓ 1 callersFunctiongetFilteredPackages
(changedDirectories: ReadonlySet<string>)
scripts/validate-publish.ts:117
↓ 1 callersFunctiongetForStore
(value: SynchronizedRef.SynchronizedRef<Value<V>>)
packages/eventsourcing-store-inmemory/src/lib/InMemoryStore.ts:311
↓ 1 callersFunctiongetFunctionName
(callee)
packages/eslint-effect/src/rules/suggest-currying-opportunity.js:102
↓ 1 callersFunctiongetHistoricalEventsAndConcatWithLive
(eventRows: EventRowServiceInterface, from: EventStreamPosition)
packages/eventsourcing-store-postgres/src/sqlEventStore.ts:130
↓ 1 callersFunctiongetHistoricalEventsForStream
(config: FileSystemStoreConfig)
packages/eventsourcing-store-filesystem/src/lib/FileSystemStore.ts:580
↓ 1 callersFunctiongetHistoricalForStore
(value: SynchronizedRef.SynchronizedRef<Value<V>>)
packages/eventsourcing-store-inmemory/src/lib/InMemoryStore.ts:316
↓ 1 callersFunctiongetHistoricalStreamForId
(streamId: EventStreamId)
packages/eventsourcing-store-inmemory/src/lib/InMemoryStore.ts:276
↓ 1 callersFunctiongetInitiator
(currentTime: number)
packages/eventsourcing-aggregates/src/lib/aggregateRootEventStream.ts:368
↓ 1 callersFunctiongetLiveStreamForId
(streamId: EventStreamId)
packages/eventsourcing-store-inmemory/src/lib/InMemoryStore.ts:265
↓ 1 callersFunctiongetMetricsEffect
( ref: SynchronizedRef.SynchronizedRef<HashMap.HashMap<EventStreamId, SubscriptionData<T>>> )
packages/eventsourcing-store-inmemory/src/lib/subscriptionManager.ts:196
↓ 1 callersFunctiongetOrCreateDefaultStatus
(url: string)
packages/eventsourcing-store/src/lib/streaming/connectionManager.ts:160
↓ 1 callersFunctiongetOrCreatePubSub
( ref: ReadonlyDeep<SynchronizedRef.SynchronizedRef<SubscriptionManagerState>>, streamId: EventStreamId )
packages/eventsourcing-store-postgres/src/subscriptionManager.ts:138
↓ 1 callersFunctiongetOrCreatePubSub
(streamId: EventStreamId)
packages/eventsourcing-store-filesystem/src/lib/FileSystemStore.ts:207
↓ 1 callersFunctiongetOrCreateSubscription
(streamId: EventStreamId)
packages/eventsourcing-store-postgres/src/subscriptionManager.ts:100
↓ 1 callersFunctiongetOrCreateSubscription
( ref: SynchronizedRef.SynchronizedRef<HashMap.HashMap<EventStreamId, SubscriptionData<T>>>, streamId: Eve
packages/eventsourcing-store-inmemory/src/lib/subscriptionManager.ts:97
↓ 1 callersFunctiongetOriginalName
(node)
packages/eslint-effect/src/rules/no-unnecessary-function-alias.js:31
↓ 1 callersFunctiongetPackageJsonDiff
(filePath: string, baseBranch: string)
scripts/validate-changesets.ts:407
↓ 1 callersFunctiongetPackageJsonFromGit
(packagePath: string, ref: string)
scripts/auto-generate-dependency-changeset.ts:121
↓ 1 callersFunctiongetRelativePath
(from: string, to: string)
scripts/validate-markdown-examples.ts:489
↓ 1 callersFunctiongetStateAndWriter
( stateRef: Readonly<Ref.Ref<WebSocketInternalState>>, writerRef: Readonly<Ref.Ref<((data: string) => Effe
packages/eventsourcing-transport-websocket/src/lib/websocket-transport.ts:96
↓ 1 callersFunctiongetStatusFromRef
(url: string)
packages/eventsourcing-store/src/lib/streaming/connectionManager.ts:260
↓ 1 callersFunctiongetStreamEventsWithServices
(config: FileSystemStoreConfig, streamId: EventStreamId)
packages/eventsourcing-store-filesystem/src/lib/FileSystemStore.ts:506
↓ 1 callersFunctiongetVoidReturnValue
(arrowFunc)
packages/eslint-effect/src/rules/prefer-as-void.js:20
↓ 1 callersFunctionhandleChangedFiles
( changedFiles: readonly string[], changesets: readonly ChangesetInfoInternal[], packages: readonly Pack
scripts/validate-changesets.ts:918
↓ 1 callersFunctionhandleClientDisconnection
( serverStateRef: ReadonlyDeep<Ref.Ref<ServerState>>, state: ServerState, clientId: Server.ClientId )
packages/eventsourcing-transport-websocket/src/lib/websocket-server.ts:356
↓ 1 callersFunctionhandleClientMessage
(clientState: ReadonlyDeep<ClientState>)
packages/eventsourcing-transport-websocket/src/lib/websocket-server.ts:206
↓ 1 callersFunctionhandleCommandMessage
( server: ReadonlyDeep<InMemoryServer>, commandHandler: (cmd: ReadonlyDeep<WireCommand>) => CommandResult,
packages/eventsourcing-protocol/src/lib/protocol.test.ts:92
↓ 1 callersFunctionhandleCommandResult
(stateRef: Ref.Ref<ProtocolState>)
packages/eventsourcing-protocol/src/lib/protocol.ts:269
↓ 1 callersFunctionhandleDependencyCheckFailure
(terminal: Terminal.Terminal)
scripts/validate-changesets.ts:276
↓ 1 callersFunctionhandleEvent
(stateRef: Ref.Ref<ProtocolState>)
packages/eventsourcing-protocol/src/lib/protocol.ts:287
↓ 1 callersFunctionhandleGitDiffFailure
(terminal: Terminal.Terminal)
scripts/validate-changesets.ts:304
↓ 1 callersFunctionhandleIncomingMessage
(stateRef: Readonly<Ref.Ref<WebSocketInternalState>>)
packages/eventsourcing-transport-websocket/src/lib/websocket-transport.ts:228
↓ 1 callersFunctionhandleMatcherExit
( matcherResult: Readonly<Exit.Exit<CommandResult, unknown>>, wireCommand: ReadonlyDeep<WireCommand>
packages/eventsourcing-commands/src/lib/command-registry.ts:72
↓ 1 callersFunctionhandleMessage
(stateRef: Ref.Ref<ProtocolState>)
packages/eventsourcing-protocol/src/lib/protocol.ts:301
↓ 1 callersFunctionhandleMessageForClient
(message: ReadonlyDeep<string>)
packages/eventsourcing-transport-websocket/src/lib/websocket-server.ts:320
↓ 1 callersFunctionhandleMessageForSubscriber
( clientState: ReadonlyDeep<InMemoryClientState>, subscriberQueue: ReadonlyDeep<Queue.Queue<TransportM
packages/eventsourcing-transport-inmemory/src/lib/inmemory-transport.ts:199
↓ 1 callersFunctionhandleMessageWithErrorLogging
( server: ReadonlyDeep<InMemoryServer>, commandHandler: (cmd: ReadonlyDeep<WireCommand>) => CommandResult,
packages/eventsourcing-protocol/src/lib/protocol.test.ts:206
↓ 1 callersFunctionhandleNoData
()
packages/eslint-effect/test/prefer-match-over-ternary.test.ts:108
↓ 1 callersFunctionhandleNonCreatedEvent
( state: Readonly<Option.Option<TodoState>>, event: Readonly<TodoEvent> )
examples/todo-app/src/domain/todoAggregate.ts:58
↓ 1 callersFunctionhandleOnOpen
( stateRef: Readonly<Ref.Ref<WebSocketInternalState>>, connectedDeferred: Deferred.Deferred<void, Connecti
packages/eventsourcing-transport-websocket/src/lib/websocket-transport.ts:340
↓ 1 callersFunctionhandleParsedMessage
( server: ReadonlyDeep<InMemoryServer>, commandHandler: (cmd: ReadonlyDeep<WireCommand>) => CommandResult,
packages/eventsourcing-protocol/src/lib/protocol.test.ts:166
↓ 1 callersFunctionhandleProtocolCommand
(commandQueue: Queue.Queue<WireCommand>)
packages/eventsourcing-protocol/src/lib/server-protocol.ts:103
↓ 1 callersFunctionhandleProtocolSubscribe
(stateRef: Ref.Ref<ServerState>, connectionId: string)
packages/eventsourcing-protocol/src/lib/server-protocol.ts:121
↓ 1 callersFunctionhandleReleasesFound
(status: ChangesetStatus)
scripts/validate-release.ts:117
↓ 1 callersFunctionhandleServerCommand
( serverProtocol: Effect.Effect.Success<typeof ServerProtocol>, clientTransport: ReadonlyDeep<Clie
packages/eventsourcing-protocol/src/lib/protocol.test.ts:2131
↓ 1 callersFunctionhandleSocketError
( connectedDeferred: Readonly<Deferred.Deferred<void, ConnectionError>>, stateRef: Readonly<Ref.Ref<We
packages/eventsourcing-transport-websocket/src/lib/websocket-transport.ts:305
↓ 1 callersFunctionhandleSubscriptionMessage
( server: ReadonlyDeep<InMemoryServer>, subscriptionHandler: (streamId: string) => readonly Event[], par
packages/eventsourcing-protocol/src/lib/protocol.test.ts:132
↓ 1 callersFunctionhandleTodoCreated
(streamId: string, event: Readonly<EventRecord<TodoCreated, UserId>>)
examples/todo-app/src/infrastructure/processManager.ts:76
↓ 1 callersFunctionhandleTodoDeleted
(streamId: string, event: Readonly<EventRecord<TodoDeleted, UserId>>)
examples/todo-app/src/infrastructure/processManager.ts:84
↓ 1 callersFunctionhandleValidationErrors
(allBlocks: readonly CodeBlock[])
scripts/validate-markdown-examples.ts:542
↓ 1 callersFunctionhasCodeChanges
( changedFiles: readonly string[], packages: readonly PackageInternal[], rootDir: string )
scripts/validate-changesets.ts:438
↓ 1 callersFunctionhasExpectOrAssertCall
(node)
packages/bun-test-effect/src/eslint/prefer-effect-assertions.js:31
↓ 1 callersFunctionhasExplicitBooleanType
(identifier, sourceCode)
packages/eslint-effect/src/rules/prefer-effect-if-over-match-boolean.js:33
↓ 1 callersFunctionhasReturnStatements
(statements)
packages/eslint-effect/src/rules/prefer-match-over-conditionals.js:100
↓ 1 callersFunctionincrementSubscribers
( ref: SynchronizedRef.SynchronizedRef<HashMap.HashMap<EventStreamId, SubscriptionData<T>>>, streamId: Eve
packages/eventsourcing-store-inmemory/src/lib/subscriptionManager.ts:114
↓ 1 callersFunctioninitializeProtocol
(transport: ReadonlyDeep<Client.Transport>)
packages/eventsourcing-protocol/src/lib/protocol.ts:524
↓ 1 callersFunctioninitializeServerStateAndStart
(config: ReadonlyDeep<WebSocketServerConfig>)
packages/eventsourcing-transport-websocket/src/lib/websocket-server.ts:593
↓ 1 callersFunctionisAllowedPattern
(node)
packages/eslint-effect/src/rules/no-curried-calls.js:28
↓ 1 callersFunctionisBooleanCondition
(condition)
packages/eslint-effect/src/rules/prefer-match-over-ternary.js:82
↓ 1 callersFunctionisConstAssertion
(node)
packages/eslint-effect/src/rules/prefer-schema-validation-over-assertions.js:70
↓ 1 callersFunctionisConstantReturn
(arrowFunc)
packages/eslint-effect/src/rules/prefer-as.js:42
↓ 1 callersFunctionisDependencyOnlyPackageJsonChange
(file: string, baseBranch: string)
scripts/validate-changesets.ts:416
↓ 1 callersFunctionisDiscardingParameter
(arrowFunc)
packages/eslint-effect/src/rules/prefer-andThen.js:31
↓ 1 callersFunctionisDiscriminatorCheck
(condition, paramName)
packages/eslint-effect/src/rules/prefer-match-over-conditionals.js:56
↓ 1 callersFunctionisEffectIfCall
(node)
packages/eslint-effect/src/rules/no-effect-if-option-check.js:19
↓ 1 callersFunctionisEffectMapCall
(node)
packages/eslint-effect/src/rules/prefer-as-void.js:44
↓ 1 callersFunctionisEffectMethodCall
(node)
packages/eslint-effect/src/rules/prefer-match-over-conditionals.js:32
↓ 1 callersFunctionisEffectMethodCall
(node)
packages/eslint-effect/src/rules/prefer-schema-validation-over-assertions.js:31
↓ 1 callersFunctionisEffectModuleCall
(node)
packages/eslint-effect/src/rules/no-intermediate-effect-variables.js:114
↓ 1 callersFunctionisEffectSync
(node)
packages/bun-test-effect/src/eslint/prefer-effect-assertions.js:21
↓ 1 callersFunctionisExecutionCall
(node)
packages/eslint-effect/src/rules/no-intermediate-effect-variables.js:75
↓ 1 callersFunctionisExported
(node)
packages/eslint-effect/src/rules/no-unnecessary-function-alias.js:43
↓ 1 callersFunctionisFactoryCall
(node)
packages/eslint-effect/src/rules/no-intermediate-effect-variables.js:84
↓ 1 callersFunctionisFlatMapCall
(node)
packages/eslint-effect/src/rules/prefer-flatten.js:21
↓ 1 callersFunctionisFunctionLike
(node)
packages/eslint-effect/src/rules/prefer-match-over-conditionals.js:41
↓ 1 callersFunctionisFunctionLike
(node)
packages/eslint-effect/src/rules/prefer-schema-validation-over-assertions.js:40
↓ 1 callersFunctionisIdentityFunction
(arrowFunc)
packages/eslint-effect/src/rules/prefer-flatten.js:31
↓ 1 callersFunctionisIdentityFunctionReference
(node)
packages/eslint-effect/src/rules/prefer-flatten.js:53
↓ 1 callersFunctionisInReturnOrAssignment
(node)
packages/eslint-effect/src/rules/prefer-match-over-ternary.js:155
↓ 1 callersFunctionisInsideEffectCallback
(node)
packages/eslint-effect/src/rules/prefer-schema-validation-over-assertions.js:48
← previousnext →501–600 of 1,511, ranked by callers