mirror of
https://github.com/hanzoai/tasks.git
synced 2026-11-03 03:56:04 +00:00
zeekay
40351cce6f
Goes from 135 MB binary with 1153 files importing go.temporal.io and 224
importing google.golang.org/grpc to a 10 MB native binary with ZERO of
either.
Deleted:
- tasks/, tasktests/, service/, chasm/, client/, api/, proto/, tools/
- cmd/tools/, components/, docker/
- schema/{cassandra,elasticsearch,mysql,postgresql,sqlite}/
- 40 tainted common/ subdirs + 7 top-level common files
- tests/testutils (no longer referenced after surviving deps drop common)
New cmd/tasksd (~100 lines) boots tasks.Embed (zap.Node) + http.Server.
New pkg/tasks/embed.go registers ZAP handlers for the SDK opcode surface
(0x0060-0x00A5). Workflow handlers return a 501 "not yet implemented"
envelope; native engine lands behind this contract.
Build: go build ./cmd/tasksd → 10 MB
Vet: go vet ./... → clean
Boot: tasksd --zap-port 9999 --http :7243
Probes: /healthz, /v1/tasks/health → 200
UI: /_/tasks/, / → 200 (embedded Vite bundle)
ZAP: _tasks._tcp on :9999 (mDNS disabled; direct connect)
go.mod: tidy. No go.temporal.io. No google.golang.org/grpc.
73 lines
1.7 KiB
Go
73 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,
|
|
NewDefaultHandoverTrackerFactory,
|
|
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))
|
|
}
|