mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-09-14 05:36:12 +00:00
Support subresource match
Signed-off-by: Shiming Zhang <wzshiming@foxmail.com>
This commit is contained in:
@@ -20,6 +20,7 @@ import (
|
|||||||
"fmt"
|
"fmt"
|
||||||
"reflect"
|
"reflect"
|
||||||
"sort"
|
"sort"
|
||||||
|
"strings"
|
||||||
"sync"
|
"sync"
|
||||||
|
|
||||||
jsonpatch "github.com/evanphx/json-patch"
|
jsonpatch "github.com/evanphx/json-patch"
|
||||||
@@ -509,12 +510,8 @@ func (r *SimpleReactor) Handles(action Action) bool {
|
|||||||
if !verbCovers {
|
if !verbCovers {
|
||||||
return false
|
return false
|
||||||
}
|
}
|
||||||
resourceCovers := r.Resource == "*" || r.Resource == action.GetResource().Resource
|
|
||||||
if !resourceCovers {
|
|
||||||
return false
|
|
||||||
}
|
|
||||||
|
|
||||||
return true
|
return resourceCovers(r.Resource, action)
|
||||||
}
|
}
|
||||||
|
|
||||||
func (r *SimpleReactor) React(action Action) (bool, runtime.Object, error) {
|
func (r *SimpleReactor) React(action Action) (bool, runtime.Object, error) {
|
||||||
@@ -530,12 +527,7 @@ type SimpleWatchReactor struct {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (r *SimpleWatchReactor) Handles(action Action) bool {
|
func (r *SimpleWatchReactor) Handles(action Action) bool {
|
||||||
resourceCovers := r.Resource == "*" || r.Resource == action.GetResource().Resource
|
return resourceCovers(r.Resource, action)
|
||||||
if !resourceCovers {
|
|
||||||
return false
|
|
||||||
}
|
|
||||||
|
|
||||||
return true
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func (r *SimpleWatchReactor) React(action Action) (bool, watch.Interface, error) {
|
func (r *SimpleWatchReactor) React(action Action) (bool, watch.Interface, error) {
|
||||||
@@ -551,14 +543,27 @@ type SimpleProxyReactor struct {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (r *SimpleProxyReactor) Handles(action Action) bool {
|
func (r *SimpleProxyReactor) Handles(action Action) bool {
|
||||||
resourceCovers := r.Resource == "*" || r.Resource == action.GetResource().Resource
|
return resourceCovers(r.Resource, action)
|
||||||
if !resourceCovers {
|
|
||||||
return false
|
|
||||||
}
|
|
||||||
|
|
||||||
return true
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func (r *SimpleProxyReactor) React(action Action) (bool, restclient.ResponseWrapper, error) {
|
func (r *SimpleProxyReactor) React(action Action) (bool, restclient.ResponseWrapper, error) {
|
||||||
return r.Reaction(action)
|
return r.Reaction(action)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func resourceCovers(resource string, action Action) bool {
|
||||||
|
if resource == "*" {
|
||||||
|
return true
|
||||||
|
}
|
||||||
|
|
||||||
|
if resource == action.GetResource().Resource {
|
||||||
|
return true
|
||||||
|
}
|
||||||
|
|
||||||
|
if index := strings.Index(resource, "/"); index != -1 &&
|
||||||
|
resource[:index] == action.GetResource().Resource &&
|
||||||
|
resource[index+1:] == action.GetSubresource() {
|
||||||
|
return true
|
||||||
|
}
|
||||||
|
|
||||||
|
return false
|
||||||
|
}
|
||||||
|
Reference in New Issue
Block a user