mirror of
https://github.com/hanzoai/tasks.git
synced 2026-10-30 14:56:19 +00:00
Stephan BehnkeandGitHub
c4b9e0ae33
## What changed Migrated `tests/xdc/history_replication_signals_and_updates_test.go` to stop relying on `WithFxOptionsForService` to replace fx modules and instead use test hooks. ## Why We want to eliminate `WithFxOptionsForService` as it is blocking us from migrating away from the `onebox.go` approach (which duplicates the fx setup) since we don't want to expose an equivalent method in `temporal/fx.go`.
47 lines
1.8 KiB
Go
47 lines
1.8 KiB
Go
package replication
|
|
|
|
import (
|
|
"go.temporal.io/server/chasm"
|
|
"go.temporal.io/server/client"
|
|
"go.temporal.io/server/common/cluster"
|
|
"go.temporal.io/server/common/log"
|
|
"go.temporal.io/server/common/metrics"
|
|
"go.temporal.io/server/common/namespace"
|
|
"go.temporal.io/server/common/persistence/serialization"
|
|
ctasks "go.temporal.io/server/common/tasks"
|
|
"go.temporal.io/server/common/testing/testhooks"
|
|
"go.temporal.io/server/service/history/configs"
|
|
"go.temporal.io/server/service/history/replication/eventhandler"
|
|
"go.temporal.io/server/service/history/shard"
|
|
wcache "go.temporal.io/server/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
|
|
ChasmEngine chasm.Engine
|
|
ChasmRegistry *chasm.Registry
|
|
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
|
|
TestHooks testhooks.TestHooks
|
|
DLQWriter DLQWriter
|
|
HistoryEventsHandler eventhandler.HistoryEventsHandler
|
|
WorkflowCache wcache.Cache
|
|
RemoteHistoryFetcher eventhandler.HistoryPaginatedFetcher
|
|
}
|
|
)
|