mirror of
https://github.com/hanzoai/tasks.git
synced 2026-11-03 03:56:04 +00:00
zeekay
5a601d081b
Full module path rebrand from Temporal to Hanzo Tasks: - go.mod module: github.com/hanzoai/tasks - All internal Go imports updated (1906 files) - cmd/server renamed to cmd/tasksd - Binary name: tasksd (was temporal-server) - Docker images: hanzoai/tasks (was temporalio/server) - README rewritten with Hanzo Tasks branding - LLM.md created with integration notes - Makefile, goreleaser, CI workflows updated - go.temporal.io/sdk and go.temporal.io/api imports preserved (separate repos) Fork of Temporal.io (MIT license).
42 lines
1.6 KiB
Go
42 lines
1.6 KiB
Go
package replication
|
|
|
|
import (
|
|
"github.com/hanzoai/tasks/client"
|
|
"github.com/hanzoai/tasks/common/cluster"
|
|
"github.com/hanzoai/tasks/common/log"
|
|
"github.com/hanzoai/tasks/common/metrics"
|
|
"github.com/hanzoai/tasks/common/namespace"
|
|
"github.com/hanzoai/tasks/common/persistence/serialization"
|
|
ctasks "github.com/hanzoai/tasks/common/tasks"
|
|
"github.com/hanzoai/tasks/service/history/configs"
|
|
"github.com/hanzoai/tasks/service/history/replication/eventhandler"
|
|
"github.com/hanzoai/tasks/service/history/shard"
|
|
wcache "github.com/hanzoai/tasks/service/history/workflow/cache"
|
|
"go.uber.org/fx"
|
|
)
|
|
|
|
type (
|
|
ProcessToolBox struct {
|
|
fx.In
|
|
|
|
Config *configs.Config
|
|
ClusterMetadata cluster.Metadata
|
|
ClientBean client.Bean
|
|
ShardController shard.Controller
|
|
NamespaceCache namespace.Registry
|
|
EagerNamespaceRefresher EagerNamespaceRefresher
|
|
ResendHandler eventhandler.ResendHandler
|
|
HighPriorityTaskScheduler ctasks.Scheduler[TrackableExecutableTask] `name:"HighPriorityTaskScheduler"`
|
|
// consider using a single TaskScheduler i.e. InterleavedWeightedRoundRobinScheduler instead of two
|
|
LowPriorityTaskScheduler ctasks.Scheduler[TrackableExecutableTask] `name:"LowPriorityTaskScheduler"`
|
|
MetricsHandler metrics.Handler
|
|
Logger log.Logger
|
|
ThrottledLogger log.ThrottledLogger
|
|
Serializer serialization.Serializer
|
|
DLQWriter DLQWriter
|
|
HistoryEventsHandler eventhandler.HistoryEventsHandler
|
|
WorkflowCache wcache.Cache
|
|
RemoteHistoryFetcher eventhandler.HistoryPaginatedFetcher
|
|
}
|
|
)
|