mirror of
https://github.com/hanzoai/tasks.git
synced 2026-11-03 03:56:04 +00:00
Alex ShtinandGitHub
8e8f1b0f7c
## 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`.
72 lines
1.7 KiB
Go
72 lines
1.7 KiB
Go
package shard
|
|
|
|
import (
|
|
"context"
|
|
"sync/atomic"
|
|
|
|
"go.temporal.io/server/common/log"
|
|
"go.temporal.io/server/common/log/tag"
|
|
"go.temporal.io/server/common/pingable"
|
|
"go.temporal.io/server/common/primitives"
|
|
"go.temporal.io/server/service/history/configs"
|
|
"go.uber.org/fx"
|
|
)
|
|
|
|
var Module = fx.Options(
|
|
fx.Provide(
|
|
ControllerProvider,
|
|
func(impl *ControllerImpl) Controller { return impl },
|
|
ContextFactoryProvider,
|
|
fx.Annotate(
|
|
func(p Controller) pingable.Pingable { return p },
|
|
fx.ResultTags(`group:"deadlockDetectorRoots"`),
|
|
),
|
|
),
|
|
ownershipBasedQuotaScalerModule,
|
|
)
|
|
|
|
var ownershipBasedQuotaScalerModule = fx.Options(
|
|
fx.Provide(func(
|
|
impl *ControllerImpl,
|
|
cfg *configs.Config,
|
|
) (*OwnershipBasedQuotaScalerImpl, error) {
|
|
return NewOwnershipBasedQuotaScaler(
|
|
impl,
|
|
int(cfg.NumberOfShards),
|
|
nil,
|
|
)
|
|
}),
|
|
fx.Provide(func(
|
|
impl *OwnershipBasedQuotaScalerImpl,
|
|
) OwnershipBasedQuotaScaler {
|
|
return impl
|
|
}),
|
|
fx.Provide(func() LazyLoadedOwnershipBasedQuotaScaler {
|
|
return LazyLoadedOwnershipBasedQuotaScaler{
|
|
Value: &atomic.Value{},
|
|
}
|
|
}),
|
|
fx.Invoke(initLazyLoadedOwnershipBasedQuotaScaler),
|
|
fx.Invoke(func(
|
|
lc fx.Lifecycle,
|
|
impl *OwnershipBasedQuotaScalerImpl,
|
|
) {
|
|
lc.Append(fx.Hook{
|
|
OnStop: func(_ context.Context) error {
|
|
impl.Close()
|
|
return nil
|
|
},
|
|
})
|
|
}),
|
|
)
|
|
|
|
func initLazyLoadedOwnershipBasedQuotaScaler(
|
|
serviceName primitives.ServiceName,
|
|
logger log.SnTaggedLogger,
|
|
ownershipBasedQuotaScaler OwnershipBasedQuotaScaler,
|
|
lazyLoadedOwnershipBasedQuotaScaler LazyLoadedOwnershipBasedQuotaScaler,
|
|
) {
|
|
lazyLoadedOwnershipBasedQuotaScaler.Store(ownershipBasedQuotaScaler)
|
|
logger.Info("Initialized lazy loaded OwnershipBasedQuotaScaler", tag.Service(serviceName))
|
|
}
|