323
logger log.Logger,
324
metricsHandler metrics.Handler,
326
>
base := &nodeBase{
327
>
registry: registry,
328
>
timeSource: timeSource,
329
>
backend: backend,
330
>
pathEncoder: pathEncoder,
331
>
logger: logger,
332
>
metricsHandler: metricsHandler,
333
>
334
>
mutation: NodesMutation{
335
>
UpdatedNodes: make(map[string]*persistencespb.ChasmNode),
336
>
DeletedNodes: make(map[string]struct{}),
337
>
},
338
>
systemMutation: NodesMutation{
339
>
UpdatedNodes: make(map[string]*persistencespb.ChasmNode),
340
>
DeletedNodes: make(map[string]struct{}),
341
>
},
342
>
newTasks: make(map[any][]taskWithAttributes),
343
>
immediatePureTasks: make(map[any][]taskWithAttributes),
344
>
pendingRequestLinks: make(map[any]map[string][]*commonpb.Link),
345
>
pendingUserMetadata: make(map[any]*sdkpb.UserMetadata),
346
>
valueToNode: make(map[any]*Node),
347
>
taskValueCache: make(map[*commonpb.DataBlob]reflect.Value),
348
>
needsPointerResolution: false,
349
>
}
350
>
351
>
return newNode(base, nil, "")
352
>
}
353
354
func newTreeInitSearchAttributesAndMemo(