service/cache2
Api Code Documentation / Exports / service/cache2
Table of contents#
Type aliases#
Functions#
Type aliases#
Cache2#
Ƭ Cache2: Object
Type declaration#
| Name | Type |
|---|---|
cachedProjects | Map<Id, Project> |
cachedSubprojectLookup | Map<Id, Set<Id>> |
cachedSubprojects | Map<Id, Subproject> |
cachedWorkflowItems | Map<Id, Workflowitem> |
cachedWorkflowitemLookup | Map<Id, Set<Id>> |
eventsByStream | Map<StreamName, BusinessEvent[]> |
isWriteLocked | boolean |
streamState | Map<StreamName, StreamCursor> |
Defined in#
TransactionFn#
Ƭ TransactionFn<T>: (cache: CacheInstance) => Promise<T>
Type parameters#
| Name |
|---|
T |
Type declaration#
â–¸ (cache): Promise<T>
Parameters#
| Name | Type |
|---|---|
cache | CacheInstance |
Returns#
Promise<T>
Defined in#
Functions#
getCacheInstance#
â–¸ getCacheInstance(ctx, cache): CacheInstance
Parameters#
| Name | Type |
|---|---|
ctx | Ctx |
cache | Cache2 |
Returns#
CacheInstance
Defined in#
initCache#
â–¸ initCache(): Cache2
Returns#
Defined in#
invalidateCache#
â–¸ invalidateCache(conn): Promise<void>
Parameters#
| Name | Type |
|---|---|
conn | ConnToken |
Returns#
Promise<void>
Defined in#
parseBusinessEvents#
â–¸ parseBusinessEvents(items, streamName): Type<BusinessEvent>[]
Parameters#
| Name | Type |
|---|---|
items | Item[] |
streamName | string |
Returns#
Defined in#
updateAggregates#
â–¸ updateAggregates(ctx, cache, newEvents): void
Parameters#
| Name | Type |
|---|---|
ctx | Ctx |
cache | Cache2 |
newEvents | BusinessEvent[] |
Returns#
void
Defined in#
withCache#
â–¸ withCache<T>(conn, ctx, transaction, doRefresh?): Promise<T>
Type parameters#
| Name |
|---|
T |
Parameters#
| Name | Type | Default value |
|---|---|---|
conn | ConnToken | undefined |
ctx | Ctx | undefined |
transaction | TransactionFn<T> | undefined |
doRefresh | boolean | true |
Returns#
Promise<T>