mirror of
https://github.com/hanzoai/tasks.git
synced 2026-10-04 02:04:03 +00:00
Will DuanandGitHub
96bb675eac
## What changed? Deprecate ndc_history_resender code ## Why? It is replaced by Resend Handler which support resend local generated events. ## How did you test it? - [x] built - [x] run locally and tested manually - [x] covered by existing tests - [ ] added new unit test(s) - [ ] added new functional test(s) ## Potential risks no risk. The dynamic config is enabled long time in prod.
41 lines
1.6 KiB
Go
41 lines
1.6 KiB
Go
package replication
|
|
|
|
import (
|
|
"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/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
|
|
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
|
|
EventSerializer serialization.Serializer
|
|
DLQWriter DLQWriter
|
|
HistoryEventsHandler eventhandler.HistoryEventsHandler
|
|
WorkflowCache wcache.Cache
|
|
RemoteHistoryFetcher eventhandler.HistoryPaginatedFetcher
|
|
}
|
|
)
|