71
}
72
73
>
func newHistoryArchiver(executionManager persistence.ExecutionManager, logger log.Logger, metricsHandler metrics.Handler, historyIterator archiver.HistoryIterator, storage connector.Client) archiver.HistoryArchiver {
history_archiver.go
74
>
return &historyArchiver{
75
>
executionManager: executionManager,
76
>
logger: logger,
77
>
metricsHandler: metricsHandler,
78
>
gcloudStorage: storage,
79
>
historyIterator: historyIterator,
80
>
}
81
>
}
82
83
// Archive is used to archive a workflow history. When the context expires the method should stop trying to archive.