85
shard historyi.ShardContext,
86
logger log.Logger,
88
>
89
>
return &StateRebuilderImpl{
90
>
shard: shard,
91
>
namespaceRegistry: shard.GetNamespaceRegistry(),
92
>
eventsCache: shard.GetEventsCache(),
93
>
clusterMetadata: shard.GetClusterMetadata(),
94
>
executionMgr: shard.GetExecutionManager(),
95
>
taskRefresher: workflow.NewTaskRefresher(shard),
96
>
rebuiltHistorySize: 0,
97
>
rebuiltExternalPayloadSize: 0,
98
>
rebuiltExternalPayloadCount: 0,
99
>
logger: logger,
100
>
}
101
>
}
102
103
func (r *StateRebuilderImpl) Rebuild(