147
logger log.Logger,
148
registry namespace.Registry,
150
>
m := &userDataManagerImpl{
151
>
onFatalErr: onFatalErr,
152
>
onUserDataChanged: onUserDataChanged,
153
>
onEphemeralDataChanged: onEphemeralDataChanged,
154
>
partition: partition,
155
>
userDataChanged: make(chan struct{}),
156
>
config: config,
157
>
namespaceRegistry: registry,
158
>
logger: logger,
159
>
matchingClient: matchingClient,
160
>
userDataReady: future.NewFuture[struct{}](),
161
>
ephemeralDataChanged: make(chan struct{}),
162
>
}
163
>
164
>
if partition.IsRoot() && partition.TaskType() == enumspb.TASK_QUEUE_TYPE_WORKFLOW {
165
m.store = store
166
}
167
169
}
170