103
104
// NewTaskPersistenceMetricsClient creates a client to manage tasks
105
>
func NewTaskPersistenceMetricsClient(persistence TaskManager, metricsHandler metrics.Handler, healthSignals HealthSignalAggregator, logger log.Logger, enableDataLossMetrics dynamicconfig.BoolPropertyFn) TaskManager {
persistence_metric_clients.go
106
>
return &taskPersistenceClient{
107
>
metricEmitter: metricEmitter{
108
>
metricsHandler: metricsHandler,
109
>
logger: logger,
110
>
enableDataLossMetrics: enableDataLossMetrics,
111
>
},
112
>
healthSignals: healthSignals,
113
>
persistence: persistence,
114
>
}
115
>
}
116
117
// NewMetadataPersistenceMetricsClient creates a MetadataManager client to manage metadata