124
// If we got here, we assume that the endpoint in the original call was a worker target, and we should route
125
// internally, either to a local frontend, or one of the other connected clusters' frontends.
126
>
var frontendClient *common.FrontendHTTPClient
request.go
127
>
callbackSource := r.Header.Get(callbackSourceHeader)
128
>
for clusterName, clusterInfo := range clusterMetadata.GetAllClusterInfo() {
129
>
if callbackSource == clusterInfo.ClusterID {
130
if clusterMetadata.GetCurrentClusterName() == clusterName {
131
frontendClient = localClient