90
91
// NewExecutionPersistenceMetricsClient creates a client to manage executions
92
>
func NewExecutionPersistenceMetricsClient(persistence ExecutionManager, metricsHandler metrics.Handler, healthSignals HealthSignalAggregator, logger log.Logger, enableDataLossMetrics dynamicconfig.BoolPropertyFn) ExecutionManager {
persistence_metric_clients.go
93
>
return &executionPersistenceClient{
94
>
metricEmitter: metricEmitter{
95
>
metricsHandler: metricsHandler,
96
>
logger: logger,
97
>
enableDataLossMetrics: enableDataLossMetrics,
98
>
},
99
>
healthSignals: healthSignals,
100
>
persistence: persistence,
101
>
}
102
>
}
103
104
// NewTaskPersistenceMetricsClient creates a client to manage tasks