mirror of
https://github.com/kubernetes/client-go.git
synced 2026-01-20 00:46:27 +00:00
8101e94f49
The main purpose is to replace context.TODO with a context provided by the caller. A secondary purpose is to enable contextual logging. Modifying the existing interfaces and APIs would have a big impact on the ecosystem. This is a no-go. Instead, the following approach was taken: - All interfaces get duplicated in a *WithContext variant where the methods also have a *WithContext suffix and the ctx parameter. All methods are treated this way except for obvious local get methods (like RESTClient) because it cannot be ruled out entirely that some implementation may need a context. - Implementations of these interfaces implement both method variants which is possible because the method names are different. The old methods are implemented as thin wrappers around the updated code which is now the body of the new methods or shared helpers. In some cases there is additional overhead (type checks, potentially additional allocations) when using the old methods. - To*WithContext helpers bridge from the old to the new interfaces. They try a type cast first. Because the in-tree implementations implement both, they can be used directly. For other implementations wrappers are used. - All old APIs and interfaces are marked as deprecated. There is no intent to ever remove them, but consumers should be made aware that there are now better alternatives. Implementations also get marked this way even if nothing ever calls them directly because it shows which code, at least theoretically, could get removed. - Existing unit tests do not get updated to the new APIs. This gives us unit test coverage of the old and new API because the old APIs call the new ones. - In-tree consumers will be updated in follow-up PRs. This is likely to be a longer process. Because of the deprecation comment, `hack/golangci-lint.sh -n` can be used to find code which needs to be updated. Kubernetes-commit: 025b844bcabe0212c4dd56395ee18481602d7c65
74 lines
1.7 KiB
Go
74 lines
1.7 KiB
Go
/*
|
|
Copyright 2017 The Kubernetes Authors.
|
|
|
|
Licensed under the Apache License, Version 2.0 (the "License");
|
|
you may not use this file except in compliance with the License.
|
|
You may obtain a copy of the License at
|
|
|
|
http://www.apache.org/licenses/LICENSE-2.0
|
|
|
|
Unless required by applicable law or agreed to in writing, software
|
|
distributed under the License is distributed on an "AS IS" BASIS,
|
|
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
See the License for the specific language governing permissions and
|
|
limitations under the License.
|
|
*/
|
|
|
|
package cached
|
|
|
|
import (
|
|
"context"
|
|
"sync"
|
|
|
|
"k8s.io/client-go/openapi"
|
|
)
|
|
|
|
type groupversion struct {
|
|
delegate openapi.GroupVersionWithContext
|
|
|
|
lock sync.Mutex
|
|
docs map[string]docInfo
|
|
}
|
|
|
|
var (
|
|
_ openapi.GroupVersion = &groupversion{}
|
|
_ openapi.GroupVersionWithContext = &groupversion{}
|
|
)
|
|
|
|
type docInfo struct {
|
|
data []byte
|
|
err error
|
|
}
|
|
|
|
func newGroupVersion(delegate openapi.GroupVersionWithContext) *groupversion {
|
|
return &groupversion{
|
|
delegate: delegate,
|
|
}
|
|
}
|
|
|
|
// Deprecated: use SchemaWithContext instead.
|
|
func (g *groupversion) Schema(contentType string) ([]byte, error) {
|
|
return g.SchemaWithContext(context.Background(), contentType)
|
|
}
|
|
|
|
func (g *groupversion) SchemaWithContext(ctx context.Context, contentType string) ([]byte, error) {
|
|
g.lock.Lock()
|
|
defer g.lock.Unlock()
|
|
|
|
cachedInfo, ok := g.docs[contentType]
|
|
if !ok {
|
|
if g.docs == nil {
|
|
g.docs = make(map[string]docInfo)
|
|
}
|
|
|
|
cachedInfo.data, cachedInfo.err = g.delegate.SchemaWithContext(ctx, contentType)
|
|
g.docs[contentType] = cachedInfo
|
|
}
|
|
|
|
return cachedInfo.data, cachedInfo.err
|
|
}
|
|
|
|
func (c *groupversion) ServerRelativeURL() string {
|
|
return c.delegate.ServerRelativeURL()
|
|
}
|