309
workflowIdentifier definition.WorkflowKey,
310
now time.Time,
312
>
resetMutableState := workflow.NewMutableState(
313
>
r.shard,
314
>
r.shard.GetEventsCache(),
315
>
r.logger,
316
>
namespaceEntry,
317
>
workflowIdentifier.GetWorkflowID(),
318
>
workflowIdentifier.GetRunID(),
319
>
now,
320
>
)
321
>
stateBuilder := workflow.NewMutableStateRebuilder(
322
>
r.shard,
323
>
r.logger,
324
>
resetMutableState,
325
>
)
326
>
return resetMutableState, stateBuilder
327
>
}
328
329
func (r *StateRebuilderImpl) applyEvents(