mirror of
https://github.com/etcd-io/etcd.git
synced 2024-09-27 06:25:44 +00:00
v2http: remove deprecated /v2/machines path
This commit is contained in:
parent
7da451640f
commit
2bb33181b6
@ -46,16 +46,15 @@ import (
|
|||||||
)
|
)
|
||||||
|
|
||||||
const (
|
const (
|
||||||
authPrefix = "/v2/auth"
|
authPrefix = "/v2/auth"
|
||||||
keysPrefix = "/v2/keys"
|
keysPrefix = "/v2/keys"
|
||||||
deprecatedMachinesPrefix = "/v2/machines"
|
membersPrefix = "/v2/members"
|
||||||
membersPrefix = "/v2/members"
|
statsPrefix = "/v2/stats"
|
||||||
statsPrefix = "/v2/stats"
|
varsPath = "/debug/vars"
|
||||||
varsPath = "/debug/vars"
|
metricsPath = "/metrics"
|
||||||
metricsPath = "/metrics"
|
healthPath = "/health"
|
||||||
healthPath = "/health"
|
versionPath = "/version"
|
||||||
versionPath = "/version"
|
configPath = "/config"
|
||||||
configPath = "/config"
|
|
||||||
)
|
)
|
||||||
|
|
||||||
// NewClientHandler generates a muxed http.Handler with the given parameters to serve etcd client requests.
|
// NewClientHandler generates a muxed http.Handler with the given parameters to serve etcd client requests.
|
||||||
@ -84,10 +83,6 @@ func NewClientHandler(server *etcdserver.EtcdServer, timeout time.Duration) http
|
|||||||
clientCertAuthEnabled: server.Cfg.ClientCertAuthEnabled,
|
clientCertAuthEnabled: server.Cfg.ClientCertAuthEnabled,
|
||||||
}
|
}
|
||||||
|
|
||||||
dmh := &deprecatedMachinesHandler{
|
|
||||||
cluster: server.Cluster(),
|
|
||||||
}
|
|
||||||
|
|
||||||
sech := &authHandler{
|
sech := &authHandler{
|
||||||
sec: sec,
|
sec: sec,
|
||||||
cluster: server.Cluster(),
|
cluster: server.Cluster(),
|
||||||
@ -108,7 +103,6 @@ func NewClientHandler(server *etcdserver.EtcdServer, timeout time.Duration) http
|
|||||||
mux.Handle(metricsPath, prometheus.Handler())
|
mux.Handle(metricsPath, prometheus.Handler())
|
||||||
mux.Handle(membersPrefix, mh)
|
mux.Handle(membersPrefix, mh)
|
||||||
mux.Handle(membersPrefix+"/", mh)
|
mux.Handle(membersPrefix+"/", mh)
|
||||||
mux.Handle(deprecatedMachinesPrefix, dmh)
|
|
||||||
handleAuth(mux, sech)
|
handleAuth(mux, sech)
|
||||||
|
|
||||||
return requestLogger(mux)
|
return requestLogger(mux)
|
||||||
@ -170,18 +164,6 @@ func (h *keysHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
type deprecatedMachinesHandler struct {
|
|
||||||
cluster api.Cluster
|
|
||||||
}
|
|
||||||
|
|
||||||
func (h *deprecatedMachinesHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
|
|
||||||
if !allowMethod(w, r.Method, "GET", "HEAD") {
|
|
||||||
return
|
|
||||||
}
|
|
||||||
endpoints := h.cluster.ClientURLs()
|
|
||||||
w.Write([]byte(strings.Join(endpoints, ", ")))
|
|
||||||
}
|
|
||||||
|
|
||||||
type membersHandler struct {
|
type membersHandler struct {
|
||||||
sec auth.Store
|
sec auth.Store
|
||||||
server etcdserver.Server
|
server etcdserver.Server
|
||||||
|
@ -1220,56 +1220,6 @@ func TestWriteEvent(t *testing.T) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func TestV2DeprecatedMachinesEndpoint(t *testing.T) {
|
|
||||||
tests := []struct {
|
|
||||||
method string
|
|
||||||
wcode int
|
|
||||||
}{
|
|
||||||
{"GET", http.StatusOK},
|
|
||||||
{"HEAD", http.StatusOK},
|
|
||||||
{"POST", http.StatusMethodNotAllowed},
|
|
||||||
}
|
|
||||||
|
|
||||||
m := &deprecatedMachinesHandler{cluster: &fakeCluster{}}
|
|
||||||
s := httptest.NewServer(m)
|
|
||||||
defer s.Close()
|
|
||||||
|
|
||||||
for _, tt := range tests {
|
|
||||||
req, err := http.NewRequest(tt.method, s.URL+deprecatedMachinesPrefix, nil)
|
|
||||||
if err != nil {
|
|
||||||
t.Fatal(err)
|
|
||||||
}
|
|
||||||
resp, err := http.DefaultClient.Do(req)
|
|
||||||
if err != nil {
|
|
||||||
t.Fatal(err)
|
|
||||||
}
|
|
||||||
|
|
||||||
if resp.StatusCode != tt.wcode {
|
|
||||||
t.Errorf("StatusCode = %d, expected %d", resp.StatusCode, tt.wcode)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestServeMachines(t *testing.T) {
|
|
||||||
cluster := &fakeCluster{
|
|
||||||
clientURLs: []string{"http://localhost:8080", "http://localhost:8081", "http://localhost:8082"},
|
|
||||||
}
|
|
||||||
writer := httptest.NewRecorder()
|
|
||||||
req, err := http.NewRequest("GET", "", nil)
|
|
||||||
if err != nil {
|
|
||||||
t.Fatal(err)
|
|
||||||
}
|
|
||||||
h := &deprecatedMachinesHandler{cluster: cluster}
|
|
||||||
h.ServeHTTP(writer, req)
|
|
||||||
w := "http://localhost:8080, http://localhost:8081, http://localhost:8082"
|
|
||||||
if g := writer.Body.String(); g != w {
|
|
||||||
t.Errorf("body = %s, want %s", g, w)
|
|
||||||
}
|
|
||||||
if writer.Code != http.StatusOK {
|
|
||||||
t.Errorf("code = %d, want %d", writer.Code, http.StatusOK)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestGetID(t *testing.T) {
|
func TestGetID(t *testing.T) {
|
||||||
tests := []struct {
|
tests := []struct {
|
||||||
path string
|
path string
|
||||||
|
Loading…
x
Reference in New Issue
Block a user