Method forwardToLeader

core/api.go:352–385

forwardToLeader forwards the current request to the core's leader process. It propagates the same credentials used in the current request. For that reason, it cannot be used outside of a request- handling context.

(ctx context.Context, path string, body interface{}, resp interface{})

// request. For that reason, it cannot be used outside of a request-
// handling context.
func (a *API) forwardToLeader(ctx context.Context, path string, body interface{}, resp interface{}) error {
	addr, err := a.leader.Address(ctx)
	if err != nil {
		return errors.Wrap(err)
	}

	// Don't infinite loop if the leader's address is our own address.
	// This is possible if we just became the leader. The client should
	// just retry.
	if addr == a.addr {
		return leader.ErrNoLeader
	}

	l := &rpc.Client{
		BaseURL: "http://" + addr,
		Client:  a.httpClient,
	}
	if a.useTLS {
		l.BaseURL = "https://" + addr
	}

	// Forward the request credentials if we have them.
	// TODO(jackson): Don't use the incoming request's credentials and
	// have an alternative authentication scheme between processes of the
	// same Core. For now, we only call the leader for the purpose of
	// forwarding a request, so this is OK.
	req := httpjson.Request(ctx)
	user, pass, ok := req.BasicAuth()
	if ok {
		l.AccessToken = fmt.Sprintf("%s:%s", user, pass)
	}

	return l.Call(ctx, path, body, resp)
}

func healthHandler(handler http.Handler) http.Handler {
	return http.HandlerFunc(func(w http.ResponseWriter, req *http.Request) {