MCPcopy Create free account

hub / github.com/CodeForBreakfast/eventsourcing / functions

Functions1,511 in github.com/CodeForBreakfast/eventsourcing

⨍ Functions 1,511◇ Types & classes 208
↓ 1 callersFunctionconnectAndUpdateStatus
( url: string, options: Readonly<Record<string, unknown>> | undefined, retryPolicy: Schedule.Sched
packages/eventsourcing-store/src/lib/streaming/connectionManager.ts:206
↓ 1 callersFunctionconnectAndVerify
(host: string, port: number)
packages/eventsourcing-transport-websocket/src/tests/integration/client-server.test.ts:157
↓ 1 callersFunctionconnectClientToServer
( serverState: ReadonlyDeep<InMemoryServerState>, connectionStatePubSub: ReadonlyDeep<PubSub.PubSub<Co
packages/eventsourcing-transport-inmemory/src/lib/inmemory-transport.ts:432
↓ 1 callersFunctionconnectNewClientAndVerify
(server: ReadonlyDeep<InMemoryServer>)
packages/eventsourcing-protocol/src/lib/protocol.test.ts:1425
↓ 1 callersFunctionconsumeNotifications
( notificationListener: Readonly<{ readonly notifications: Stream.Stream< { readonly strea
packages/eventsourcing-store-postgres/src/sqlEventStore.ts:200
↓ 1 callersFunctioncountEventsAndCreatePosition
(streamId: EventStreamId)
packages/eventsourcing-store/src/lib/eventstore.ts:7
↓ 1 callersFunctioncountExistingEvents
( streamDir: string, fs: FileSystem.FileSystem )
packages/eventsourcing-store-filesystem/src/lib/FileSystemStore.ts:80
↓ 1 callersFunctioncountReferences
(scope, variableName)
packages/eslint-effect/src/rules/no-unnecessary-function-alias.js:53
↓ 1 callersFunctioncreateActiveUser
()
packages/eslint-effect/test/prefer-match-over-ternary.test.ts:115
↓ 1 callersFunctioncreateAddClientToServerStateUpdater
(clientState: ClientState)
packages/eventsourcing-transport-websocket/src/lib/websocket-server.ts:272
↓ 1 callersFunctioncreateAllEventsStream
()
packages/eventsourcing-store-filesystem/src/lib/FileSystemStore.ts:594
↓ 1 callersFunctioncreateAllEventsStreamFromPubSub
( pubsub: PubSub.PubSub<StreamEvent<string>> )
packages/eventsourcing-store-postgres/src/subscriptionManager.ts:248
↓ 1 callersFunctioncreateAppendSink
(store: FileSystemStore<T>, fs: FileSystem.FileSystem, path: Path.Path)
packages/eventsourcing-store-filesystem/src/lib/fileSystemEventStore.ts:34
↓ 1 callersFunctioncreateBoundedPubSub
()
packages/eventsourcing-store-filesystem/src/lib/FileSystemStore.ts:592
↓ 1 callersFunctioncreateClientAndCommunicate
(server: ServerTransport, pair: TransportPair)
packages/eventsourcing-testing-contracts/src/lib/transport/client-server-contract-tests.ts:459
↓ 1 callersFunctioncreateClientAndDisconnect
( clientScope: Scope.CloseableScope, server: ServerTransport, pair: TransportPai
packages/eventsourcing-testing-contracts/src/lib/transport/client-server-contract-tests.ts:609
↓ 1 callersFunctioncreateClientAndPublish
(server: ServerTransport, pair: TransportPair)
packages/eventsourcing-testing-contracts/src/lib/transport/client-server-contract-tests.ts:801
↓ 1 callersFunctioncreateClientConnection
( clientId: ReadonlyDeep<string>, clientToServerQueue: ReadonlyDeep<Queue.Queue<TransportMessage>>, serv
packages/eventsourcing-transport-inmemory/src/lib/inmemory-transport.ts:313
↓ 1 callersFunctioncreateClientConnectionStateStream
( clientState: ReadonlyDeep<ClientState> )
packages/eventsourcing-transport-websocket/src/lib/websocket-server.ts:71
↓ 1 callersFunctioncreateClientIdAndTimestamp
()
packages/eventsourcing-transport-websocket/src/lib/websocket-server.ts:380
↓ 1 callersFunctioncreateClientResources
()
packages/eventsourcing-transport-websocket/src/lib/websocket-server.ts:225
↓ 1 callersFunctioncreateClientState
( clientToServerQueue: ReadonlyDeep<Queue.Queue<TransportMessage>>, serverToClientQueue: ReadonlyDeep<Queu
packages/eventsourcing-transport-inmemory/src/lib/inmemory-transport.ts:261
↓ 1 callersFunctioncreateClientStateResources
( clientId: Server.ClientId, connectedAt: ReadonlyDeep<Date>, ws: ReadonlyDeep<ServerWebSocket<WebSocket
packages/eventsourcing-transport-websocket/src/lib/websocket-server.ts:261
↓ 1 callersFunctioncreateClientTransport
( clientState: ReadonlyDeep<InMemoryClientState> )
packages/eventsourcing-transport-inmemory/src/lib/inmemory-transport.ts:238
↓ 1 callersFunctioncreateClientTransport
(clientState: ReadonlyDeep<ClientState>)
packages/eventsourcing-transport-websocket/src/lib/websocket-server.ts:152
↓ 1 callersFunctioncreateClientsAndBroadcast
(server: ServerTransport, pair: TransportPair)
packages/eventsourcing-testing-contracts/src/lib/transport/client-server-contract-tests.ts:363
↓ 1 callersFunctioncreateClientsAndVerify
(server: ServerTransport, pair: TransportPair)
packages/eventsourcing-testing-contracts/src/lib/transport/client-server-contract-tests.ts:727
↓ 1 callersFunctioncreateConnectedTransport
( stateRef: Readonly<Ref.Ref<WebSocketInternalState>>, writerRef: Readonly<Ref.Ref<((data: string) => Effe
packages/eventsourcing-transport-websocket/src/lib/websocket-transport.ts:165
↓ 1 callersFunctioncreateConnectionQueues
()
packages/eventsourcing-transport-inmemory/src/lib/inmemory-transport.ts:288
↓ 1 callersFunctioncreateConnectionResources
()
packages/eventsourcing-transport-websocket/src/lib/websocket-transport.ts:448
↓ 1 callersFunctioncreateConnectionStateStream
( stateRef: Readonly<Ref.Ref<WebSocketInternalState>> )
packages/eventsourcing-transport-websocket/src/lib/websocket-transport.ts:61
↓ 1 callersFunctioncreateConnectorForServer
(serverState: ReadonlyDeep<InMemoryServerState>)
packages/eventsourcing-transport-inmemory/src/lib/inmemory-transport.ts:478
↓ 1 callersFunctioncreateDataEffect
()
packages/eslint-effect/test/prefer-match-over-ternary.test.ts:107
↓ 1 callersFunctioncreateDependencyChange
( packageName: string, depName: string, beforeVersion: string | undefined, afterVersion: string | unde
scripts/auto-generate-dependency-changeset.ts:88
↓ 1 callersFunctioncreateEmptySubscribersRef
()
packages/eventsourcing-transport-websocket/src/lib/websocket-server.ts:219
↓ 1 callersFunctioncreateEncodingSink
( schema: Schema.Schema<A, I>, originalSink: Sink.Sink< EventStreamPosition, I, I, Concurr
packages/eventsourcing-store/src/lib/eventstore.ts:87
↓ 1 callersFunctioncreateEntryWithChecks
(currentDir: string)
scripts/validate-markdown-examples.ts:221
↓ 1 callersFunctioncreateEntryWithTypes
(name: string)
scripts/validate-markdown-examples.ts:208
↓ 1 callersFunctioncreateEventPublisher
(server: ReadonlyDeep<Server.Transport>, stateRef: Ref.Ref<ServerState>)
packages/eventsourcing-protocol/src/lib/server-protocol.ts:299
↓ 1 callersFunctioncreateEventStoreWithServices
(store: FileSystemStore<T>)
packages/eventsourcing-store-filesystem/src/lib/fileSystemEventStore.ts:49
↓ 1 callersFunctioncreateFileWithDependencyOnlyFlag
(file: string, baseBranch: string)
scripts/validate-changesets.ts:424
↓ 1 callersFunctioncreateFilteredStream
(pubsub: PubSub.PubSub<StreamEvent<TEvent>>)
packages/eventsourcing-server/src/lib/eventBus.ts:96
↓ 1 callersFunctioncreateInactiveUser
()
packages/eslint-effect/test/prefer-match-over-ternary.test.ts:116
↓ 1 callersFunctioncreateInitialState
()
packages/eventsourcing-transport-websocket/src/lib/websocket-transport.ts:262
↓ 1 callersFunctioncreateLiveEventStream
(eventStream: EventStream<V>)
packages/eventsourcing-store-inmemory/src/lib/InMemoryStore.ts:217
↓ 1 callersFunctioncreateLiveStreamFromHistoricalAndPubSub
(historical: Stream.Stream<V, never, never>)
packages/eventsourcing-store-filesystem/src/lib/FileSystemStore.ts:443
↓ 1 callersFunctioncreateMetadataFromInitiator
(currentTime: number)
packages/eventsourcing-aggregates/src/lib/aggregateRootEventStream.ts:361
↓ 1 callersFunctioncreateMockWebSocket
(url: string, _protocols?: string | readonly string[])
packages/eventsourcing-transport-websocket/src/lib/websocket-transport.test.ts:37
↓ 1 callersFunctioncreateNotificationsStream
( notificationQueue: Queue.Queue<{ readonly streamId: EventStreamId; readonly payload: NotificationP
packages/eventsourcing-store-postgres/src/notificationListener.ts:252
↓ 1 callersFunctioncreateOrAppendToStream
(streamEnd: EventStreamPosition, newEvents: Chunk.Chunk<V>)
packages/eventsourcing-store-inmemory/src/lib/InMemoryStore.ts:47
↓ 1 callersFunctioncreateProtocolService
( transport: ReadonlyDeep<Client.Transport> )
packages/eventsourcing-protocol/src/lib/protocol.ts:527
↓ 1 callersFunctioncreatePubSubAndAddToMap
( subs: HashMap.HashMap<EventStreamId, SubscriptionData<T>>, streamId: EventStreamId )
packages/eventsourcing-store-inmemory/src/lib/subscriptionManager.ts:61
↓ 1 callersFunctioncreatePubSubAndUpdateHashMap
( streamId: EventStreamId, subs: HashMap.HashMap<EventStreamId, SubscriptionData<T>> )
packages/eventsourcing-store-postgres/src/subscriptionManager.ts:93
↓ 1 callersFunctioncreatePubSubForStream
()
packages/eventsourcing-store-filesystem/src/lib/FileSystemStore.ts:185
↓ 1 callersFunctioncreatePubSubWithState
( currentState: FileSystemStoreState<V>, streamId: EventStreamId )
packages/eventsourcing-store-filesystem/src/lib/FileSystemStore.ts:188
↓ 1 callersFunctioncreateQueueStream
(filter: (event: TEvent) => event is TFiltered)
packages/eventsourcing-server/src/lib/eventBus.ts:91
↓ 1 callersFunctioncreateReadError
(streamId: string | undefined)
packages/eventsourcing-store/src/lib/services.test.ts:75
↓ 1 callersFunctioncreateRemoveClientFromServerStateUpdater
(clientId: Server.ClientId)
packages/eventsourcing-transport-websocket/src/lib/websocket-server.ts:337
↓ 1 callersFunctioncreateResultMessageWithContext
( commandId: string, result: ReadonlyDeep<CommandResult>, context: { readonly traceId: string; readonly
packages/eventsourcing-protocol/src/lib/server-protocol.ts:162
↓ 1 callersFunctioncreateResultSender
(server: ReadonlyDeep<Server.Transport>)
packages/eventsourcing-protocol/src/lib/server-protocol.ts:215
↓ 1 callersFunctioncreateRetryPolicy
(config: Readonly<ConnectionConfig>)
packages/eventsourcing-store/src/lib/streaming/connectionManager.ts:199
↓ 1 callersFunctioncreateRetrySchedule
()
packages/eventsourcing-store-postgres/src/connectionManager.ts:71
↓ 1 callersFunctioncreateRetrySchedule
()
packages/eventsourcing-store-inmemory/src/lib/subscriptionManager.ts:135
↓ 1 callersFunctioncreateRouter
()
packages/eventsourcing-aggregates/src/lib/command-processing-example.ts:59
↓ 1 callersFunctioncreateScopeAndTest
(server: ServerTransport, pair: TransportPair)
packages/eventsourcing-testing-contracts/src/lib/transport/client-server-contract-tests.ts:619
↓ 1 callersFunctioncreateScopedWireCommandSender
(stateRef: Ref.Ref<ProtocolState>, transport: ReadonlyDeep<Client.Transport>)
packages/eventsourcing-protocol/src/lib/protocol.ts:506
↓ 1 callersFunctioncreateSeparateTempFiles
( blocks: readonly CodeBlock[], tempDir: string )
scripts/validate-markdown-examples.ts:354
↓ 1 callersFunctioncreateServerProtocolService
( server: ReadonlyDeep<Server.Transport> )
packages/eventsourcing-protocol/src/lib/server-protocol.ts:344
↓ 1 callersFunctioncreateServerSideClientTransport
( clientToServerQueue: ReadonlyDeep<Queue.Queue<TransportMessage>>, serverToClientQueue: ReadonlyDeep<Queu
packages/eventsourcing-transport-inmemory/src/lib/inmemory-transport.ts:228
↓ 1 callersFunctioncreateServerTransport
( serverStateRef: ReadonlyDeep<Ref.Ref<ServerState>>, connectionsQueue: ReadonlyDeep<Queue.Queue<Server.Cl
packages/eventsourcing-transport-websocket/src/lib/websocket-server.ts:497
↓ 1 callersFunctioncreateService
(pubsub: PubSub.PubSub<StreamEvent<TEvent>>)
packages/eventsourcing-server/src/lib/eventBus.ts:120
↓ 1 callersFunctioncreateSimpleSubscription
(sourceQueue: ReadonlyDeep<Queue.Queue<TransportMessage>>)
packages/eventsourcing-transport-inmemory/src/lib/inmemory-transport.ts:165
↓ 1 callersFunctioncreateStoreFromState
(config: FileSystemStoreConfig)
packages/eventsourcing-store-filesystem/src/lib/FileSystemStore.ts:614
↓ 1 callersFunctioncreateStoreWithAllEventsStream
(config: FileSystemStoreConfig)
packages/eventsourcing-store-filesystem/src/lib/FileSystemStore.ts:624
↓ 1 callersFunctioncreateStreamWithCleanup
( ref: SynchronizedRef.SynchronizedRef<HashMap.HashMap<EventStreamId, SubscriptionData<T>>>, streamId:
packages/eventsourcing-store-inmemory/src/lib/subscriptionManager.ts:161
↓ 1 callersFunctioncreateSubscribeError
(streamId: EventStreamPosition['streamId'])
packages/eventsourcing-store-inmemory/src/lib/inMemoryEventStore.ts:31
↓ 1 callersFunctioncreateSubscribeError
(streamId: EventStreamId)
packages/eventsourcing-store-inmemory/src/lib/subscriptionManager.ts:168
↓ 1 callersFunctioncreateSubscriber
(stateRef: Ref.Ref<ProtocolState>, transport: ReadonlyDeep<Client.Transport>)
packages/eventsourcing-protocol/src/lib/protocol.ts:498
↓ 1 callersFunctioncreateSubscriptionStream
(ref: ReadonlyDeep<SynchronizedRef.SynchronizedRef<SubscriptionManagerState>>)
packages/eventsourcing-store-postgres/src/subscriptionManager.ts:224
↓ 1 callersFunctioncreateSubscriptionStream
( stateRef: Ref.Ref<ProtocolState>, streamId: string, queue: Queue.Queue<Event> )
packages/eventsourcing-protocol/src/lib/protocol.ts:475
↓ 1 callersFunctioncreateTempDirectory
(tempDir: string)
scripts/validate-markdown-examples.ts:482
↓ 1 callersFunctioncreateTestWebSocketConstructor
(config: TestSocketConfig)
packages/eventsourcing-transport-websocket/src/lib/websocket-transport.test.ts:156
↓ 1 callersFunctioncreateTodo
(title: string)
packages/eslint-effect/test/prefer-match-over-ternary.test.ts:110
↓ 1 callersFunctioncreateTodo
(title: string)
examples/todo-app/src/cli.ts:79
↓ 1 callersFunctioncreateUndefinedReadError
()
packages/eventsourcing-store/src/lib/services.test.ts:217
↓ 1 callersFunctioncreateUnknownErrorFailure
(commandId: string, message: string)
packages/eventsourcing-commands/src/lib/command-registry.ts:61
↓ 1 callersFunctioncreateUnsubscribeError
(streamId: EventStreamId)
packages/eventsourcing-store-inmemory/src/lib/subscriptionManager.ts:171
↓ 1 callersFunctioncreateUpdatedEventStream
( eventStream: EventStream<V>, newEvents: Chunk.Chunk<V> )
packages/eventsourcing-store-inmemory/src/lib/InMemoryStore.ts:24
↓ 1 callersFunctioncreateUpdatedValue
( allEventsStream: EventStream<StreamEvent<V>>, newEvents: Chunk.Chunk<V>, streamEnd: EventStreamP
packages/eventsourcing-store-inmemory/src/lib/InMemoryStore.ts:93
↓ 1 callersFunctioncreateValidationError
( blockFile: BlockFile, lineInFile: number, index: number, errorCode: string, errorMessage: string )
scripts/validate-markdown-examples.ts:378
↓ 1 callersFunctioncreateValidationErrorFailure
( commandId: string, commandName: string, validationErrors: ReadonlyArray<string> )
packages/eventsourcing-commands/src/lib/command-registry.ts:97
↓ 1 callersFunctioncreateWebSocketConnection
( url: Readonly<string>, stateRef: Readonly<Ref.Ref<WebSocketInternalState>> )
packages/eventsourcing-transport-websocket/src/lib/websocket-transport.ts:237
↓ 1 callersFunctioncreateWebSocketConnectionWithProvider
( url: Readonly<string>, stateRef: Readonly<Ref.Ref<WebSocketInternalState>> )
packages/eventsourcing-transport-websocket/src/lib/websocket-transport.ts:426
↓ 1 callersFunctioncreateWebSocketServer
( config: ReadonlyDeep<WebSocketServerConfig>, serverStateRef: ReadonlyDeep<Ref.Ref<ServerState>> )
packages/eventsourcing-transport-websocket/src/lib/websocket-server.ts:369
↓ 1 callersFunctioncreateWebSocketServerTransport
( config: ReadonlyDeep<WebSocketServerConfig> )
packages/eventsourcing-transport-websocket/src/lib/websocket-server.ts:603
↓ 1 callersFunctioncreateWireCommandSender
(stateRef: Ref.Ref<ProtocolState>, transport: ReadonlyDeep<Client.Transport>)
packages/eventsourcing-protocol/src/lib/protocol.ts:421
↓ 1 callersFunctioncreateWriteError
(streamId: string, error: unknown)
packages/eventsourcing-store-postgres/src/sqlEventStore.ts:291
↓ 1 callersFunctiondecodeEventNumber
( nextEventNumber: Readonly<number>, data: Readonly<Option.Option<TState>> )
packages/eventsourcing-aggregates/src/lib/aggregateRootEventStream.ts:211
↓ 1 callersFunctiondecodeProjectionEventNumber
( nextEventNumber: number, data: Readonly<Option.Option<TData>> )
packages/eventsourcing-projections/src/lib/projection.ts:65
↓ 1 callersFunctiondecodeStreamPositionFromEventNumber
(eventNumber: EventNumber)
packages/eventsourcing-aggregates/src/lib/aggregateRootEventStream.ts:92
← previousnext →301–400 of 1,511, ranked by callers