github/steve
1
0
Fork 0
mirror of https://github.com/niusmallnan/steve.git synced 2025-06-26 22:46:56 +00:00
Code Issues Projects Releases Wiki Activity

feat: support k8s version less than 1.16

Browse Source
This commit is contained in:
CMC 2021-11-04 13:36:13 +08:00
parent 7224dc2101
commit fea67065db
No known key found for this signature in database
GPG Key ID: 04D2B02F51DC67BF
3 changed files with 8 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
pkg/client/factory.go
View File

@ -35,7 +35,7 @@ func (a *addQuery) RoundTrip(req *http.Request) (*http.Response, error) {
for k, v := range a.values { for k, v := range a.values {
q.Set(k, v) q.Set(k, v)
} }
req.Header.Set("Accept", "application/json;as=Table;v=v1;g=meta.k8s.io") req.Header.Set("Accept", "application/json;as=Table;v=v1;g=meta.k8s.io,application/json;as=Table;v=v1beta1;g=meta.k8s.io")
req.URL.RawQuery = q.Encode() req.URL.RawQuery = q.Encode()
return a.next.RoundTrip(req) return a.next.RoundTrip(req)
} }
@ -59,10 +59,10 @@ func NewFactory(cfg *rest.Config, impersonate bool) (*Factory, error) {
tableClientCfg := rest.CopyConfig(clientCfg) tableClientCfg := rest.CopyConfig(clientCfg)
tableClientCfg.Wrap(setTable) tableClientCfg.Wrap(setTable)
tableClientCfg.AcceptContentTypes = "application/json;as=Table;v=v1;g=meta.k8s.io" tableClientCfg.AcceptContentTypes = "application/json;as=Table;v=v1;g=meta.k8s.io,application/json;as=Table;v=v1beta1;g=meta.k8s.io"
tableWatchClientCfg := rest.CopyConfig(watchClientCfg) tableWatchClientCfg := rest.CopyConfig(watchClientCfg)
tableWatchClientCfg.Wrap(setTable) tableWatchClientCfg.Wrap(setTable)
tableWatchClientCfg.AcceptContentTypes = "application/json;as=Table;v=v1;g=meta.k8s.io" tableWatchClientCfg.AcceptContentTypes = "application/json;as=Table;v=v1;g=meta.k8s.io,application/json;as=Table;v=v1beta1;g=meta.k8s.io"
md, err := metadata.NewForConfig(cfg) md, err := metadata.NewForConfig(cfg)
if err != nil { if err != nil {

2
pkg/resources/common/dynamiccolumns.go
View File

@ -96,7 +96,7 @@ func newClient(config *rest.Config) (*rest.RESTClient, error) {
config = rest.CopyConfig(config) config = rest.CopyConfig(config)
config.RateLimiter = ratelimit.None config.RateLimiter = ratelimit.None
config.UserAgent = rest.DefaultKubernetesUserAgent() config.UserAgent = rest.DefaultKubernetesUserAgent()
config.AcceptContentTypes = "application/json;as=Table;v=v1;g=meta.k8s.io" config.AcceptContentTypes = "application/json;as=Table;v=v1;g=meta.k8s.io,application/json;as=Table;v=v1beta1;g=meta.k8s.io"
config.GroupVersion = &schema.GroupVersion{} config.GroupVersion = &schema.GroupVersion{}
config.NegotiatedSerializer = serializer.NewCodecFactory(scheme) config.NegotiatedSerializer = serializer.NewCodecFactory(scheme)
config.APIPath = "/" config.APIPath = "/"

6
pkg/stores/proxy/proxy_store.go
View File

@ -169,7 +169,8 @@ func rowToObject(obj *unstructured.Unstructured) {
return return
} }
if obj.Object["kind"] != "Table" || if obj.Object["kind"] != "Table" ||
obj.Object["apiVersion"] != "meta.k8s.io/v1" { (obj.Object["apiVersion"] != "meta.k8s.io/v1" &&
obj.Object["apiVersion"] != "meta.k8s.io/v1beta1") {
return return
} }
@ -181,7 +182,8 @@ func rowToObject(obj *unstructured.Unstructured) {
func tableToList(obj *unstructured.UnstructuredList) { func tableToList(obj *unstructured.UnstructuredList) {
if obj.Object["kind"] != "Table" || if obj.Object["kind"] != "Table" ||
obj.Object["apiVersion"] != "meta.k8s.io/v1" { (obj.Object["apiVersion"] != "meta.k8s.io/v1" &&
obj.Object["apiVersion"] != "meta.k8s.io/v1beta1") {
return return
} }