66
metricsHandler metrics.Handler,
67
maxEventBatchSizeInBytes dynamicconfig.IntPropertyFn,
69
>
return &HistoryBuilder{
70
>
EventStore: EventStore{
71
>
state: HistoryBuilderStateMutable,
72
>
timeSource: timeSource,
73
>
taskIDGenerator: taskIDGenerator,
74
>
75
>
version: version,
76
>
nextEventID: nextEventID,
77
>
78
>
workflowFinished: false,
79
>
80
>
dbBufferBatch: dbBufferBatch,
81
>
dbClearBuffer: false,
82
>
memEventsBatches: nil,
83
>
memLatestBatch: nil,
84
>
memBufferBatch: nil,
85
>
scheduledIDToStartedID: make(map[int64]int64),
86
>
requestIDToEventID: make(map[string]int64),
87
>
88
>
maxEventBatchSizeInBytes: maxEventBatchSizeInBytes,
89
>
90
>
metricsHandler: metricsHandler,
91
>
},
92
>
EventFactory: EventFactory{timeSource: timeSource, version: version},
93
>
}
94
>
}
95
96
func (b *HistoryBuilder) SetTimeSource(timeSource clock.TimeSource) {