191
if !c.namespace.ActiveInCluster(c.clusterMetadata.GetCurrentClusterName()) {
192
if c.shouldForwardRequest(ctx, header) {
193
>
// Handler methods should have special logic to forward requests if this method returns
nexus_handler.go
194
>
// a serviceerror.NamespaceNotActive error.
195
>
c.metricsHandler = c.metricsHandler.WithTags(metrics.OutcomeTag("request_forwarded"))
196
>
handler, forwardStartTime := c.redirectionInterceptor.BeforeCall(c.apiName)
197
>
c.cleanupFunctions = append(c.cleanupFunctions, func(_ map[string]string, retErr error) {
198
c.redirectionInterceptor.AfterCall(handler, forwardStartTime, c.namespace.ActiveClusterName(namespace.RoutingKey{}), c.namespace.Name().String(), retErr)
199
})
201
>
c.namespaceName,
202
>
c.clusterMetadata.GetCurrentClusterName(),
203
>
c.namespace.ActiveClusterName(namespace.RoutingKey{}),
204
>
)
205
}
206
c.metricsHandler = c.metricsHandler.WithTags(metrics.OutcomeTag("namespace_inactive_forwarding_disabled"))