69
visibilityManager manager.VisibilityManager,
70
chasmEngine chasm.Engine,
72
>
return &transferQueueTaskExecutorBase{
73
>
currentClusterName: shardContext.GetClusterMetadata().GetCurrentClusterName(),
74
>
shardContext: shardContext,
75
>
registry: shardContext.GetNamespaceRegistry(),
76
>
cache: workflowCache,
77
>
logger: logger,
78
>
metricHandler: metricHandler,
79
>
historyRawClient: historyRawClient,
80
>
matchingRawClient: matchingRawClient,
81
>
config: shardContext.GetConfig(),
82
>
searchAttributesProvider: shardContext.GetSearchAttributesProvider(),
83
>
visibilityManager: visibilityManager,
84
>
workflowDeleteManager: deletemanager.NewDeleteManager(
85
>
shardContext,
86
>
workflowCache,
87
>
shardContext.GetConfig(),
88
>
shardContext.GetTimeSource(),
89
>
visibilityManager,
90
>
),
91
>
chasmEngine: chasmEngine,
92
>
}
93
>
}
94
95
func (t *transferQueueTaskExecutorBase) pushActivity(