mirror of
https://github.com/hanzoai/tasks.git
synced 2026-10-04 02:04:03 +00:00
## What changed?
<!-- Describe what has changed in this PR -->
Remove license header from every file. Because it is really hard to
follow in this PR here is the summary:
1. License header is removed from all `.go` and `.proto` files
:fireworks::fireworks:🎆.
2. `LICENSE` file in the root directory has only Temporal and Uber
copyrights.
3. 5 other `LICENSE` files added to the packages which have copyrights
different from Temporal and Uber: Datadog, Xargin, "Mat Ryer, Tyler
Bunnell and contributors".
4. `license_file` flag is removed from all code generation tools.
5. `copyright_file` flag is removed from `go:generate mockgen`
directive.
6. All copyright related targets are removed from `Makefile`.
7. Updated Temporal copyright year to 2025 everywhere.
## Why?
<!-- Tell your future self why have you made these changes -->
I double checked with legal department that it is not needed to have
license header in every file. One file per repo is enough. I put all
copyrights to the root `LICENSE` file and removed header from all other
files. Also updated tools and `Makefile`.
80 lines
1.9 KiB
Go
80 lines
1.9 KiB
Go
package matching
|
|
|
|
import (
|
|
"time"
|
|
|
|
"go.temporal.io/server/common/log"
|
|
"go.temporal.io/server/common/metrics"
|
|
)
|
|
|
|
type (
|
|
priMetricHandler struct {
|
|
handler metrics.Handler
|
|
}
|
|
priMetricsTimer struct {
|
|
name string
|
|
handler metrics.Handler
|
|
}
|
|
priMetricsCounter struct {
|
|
name string
|
|
handler metrics.Handler
|
|
}
|
|
priMetricsGauge struct {
|
|
name string
|
|
handler metrics.Handler
|
|
}
|
|
)
|
|
|
|
// TODO(pri): cleanup; delete this
|
|
func newPriMetricsHandler(handler metrics.Handler) priMetricHandler {
|
|
return priMetricHandler{
|
|
handler: handler,
|
|
}
|
|
}
|
|
|
|
func (p priMetricHandler) Stop(logger log.Logger) {
|
|
p.handler.Stop(logger)
|
|
}
|
|
|
|
func (p priMetricHandler) Counter(name string) metrics.CounterIface {
|
|
return priMetricsCounter{name: name, handler: p.handler}
|
|
}
|
|
func (p priMetricHandler) Timer(name string) metrics.TimerIface {
|
|
return priMetricsTimer{name: name, handler: p.handler}
|
|
}
|
|
|
|
func (p priMetricHandler) Gauge(name string) metrics.GaugeIface {
|
|
return priMetricsGauge{name: name, handler: p.handler}
|
|
}
|
|
|
|
func (p priMetricHandler) WithTags(...metrics.Tag) metrics.Handler {
|
|
panic("not implemented")
|
|
}
|
|
|
|
func (p priMetricHandler) Histogram(string, metrics.MetricUnit) metrics.HistogramIface {
|
|
panic("not implemented")
|
|
}
|
|
|
|
func (p priMetricHandler) StartBatch(string) metrics.BatchHandler {
|
|
panic("not implemented")
|
|
}
|
|
|
|
func (c priMetricsCounter) Record(i int64, tag ...metrics.Tag) {
|
|
c.handler.Counter(c.name).Record(i, tag...)
|
|
c.handler.Counter(withPriPrefix(c.name)).Record(i, tag...)
|
|
}
|
|
|
|
func (t priMetricsTimer) Record(duration time.Duration, tag ...metrics.Tag) {
|
|
t.handler.Timer(t.name).Record(duration, tag...)
|
|
t.handler.Timer(withPriPrefix(t.name)).Record(duration, tag...)
|
|
}
|
|
|
|
func (t priMetricsGauge) Record(v float64, tag ...metrics.Tag) {
|
|
t.handler.Gauge(t.name).Record(v, tag...)
|
|
t.handler.Gauge(withPriPrefix(t.name)).Record(v, tag...)
|
|
}
|
|
|
|
func withPriPrefix(name string) string {
|
|
return "pri_" + name
|
|
}
|