108
// If we got here, we assume that the endpoint in the original call was a worker target, and we should route
109
// internally, either to a local frontend, or one of the other connected clusters' frontends.
110
>
var frontendClient *common.FrontendHTTPClient
request.go
111
>
callbackSource := r.Header.Get(callbackSourceHeader)
112
>
for clusterName, clusterInfo := range clusterMetadata.GetAllClusterInfo() {
113
>
if callbackSource == clusterInfo.ClusterID {
114
if clusterMetadata.GetCurrentClusterName() == clusterName {
115
frontendClient = localClient