127
}
128
129
>
func NewImmutableForUpdateNextEventID(lastVersionHistoryItem *historyspb.VersionHistoryItem) *HistoryBuilder {
history_builder.go
130
>
return &HistoryBuilder{
131
>
EventStore: EventStore{
132
>
state: HistoryBuilderStateImmutable,
133
>
timeSource: nil,
134
>
taskIDGenerator: nil,
135
>
136
>
version: lastVersionHistoryItem.GetVersion(),
137
>
nextEventID: lastVersionHistoryItem.GetEventId() + 1,
138
>
139
>
workflowFinished: false,
140
>
141
>
dbBufferBatch: nil,
142
>
dbClearBuffer: false,
143
>
memEventsBatches: nil,
144
>
memLatestBatch: nil,
145
>
memBufferBatch: nil,
146
>
scheduledIDToStartedID: nil,
147
>
requestIDToEventID: nil,
148
>
149
>
metricsHandler: nil,
150
>
},
151
>
EventFactory: EventFactory{},
152
>
}
153
>
}
154
155
func (b *HistoryBuilder) IsDirty() bool {