github/client-go
1
0
Fork 0
mirror of https://github.com/kubernetes/client-go.git synced 2025-07-11 14:15:37 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #112774 from stevekuznetsov/skuznets/dynamic-client-similar

Browse Source 
client-go: factor the dynamic client similarly to others

Kubernetes-commit: bb2101bac12748aa77adfa15b07b5b8d8dcd0672
This commit is contained in:
Kubernetes Publisher 2022-10-10 10:23:21 -07:00
commit f515a4cb9f
1 changed files with 15 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
dynamic/simple.go
View File

@ -31,11 +31,11 @@ import (
"k8s.io/client-go/rest" "k8s.io/client-go/rest"
) )
type dynamicClient struct { type DynamicClient struct {
client *rest.RESTClient client rest.Interface
} }
var _ Interface = &dynamicClient{} var _ Interface = &DynamicClient{}
// ConfigFor returns a copy of the provided config with the // ConfigFor returns a copy of the provided config with the
// appropriate dynamic client defaults set. // appropriate dynamic client defaults set.
@ -50,9 +50,14 @@ func ConfigFor(inConfig *rest.Config) *rest.Config {
return config return config
} }
// NewForConfigOrDie creates a new Interface for the given config and // New creates a new DynamicClient for the given RESTClient.
func New(c rest.Interface) *DynamicClient {
return &DynamicClient{client: c}
}
// NewForConfigOrDie creates a new DynamicClient for the given config and
// panics if there is an error in the config. // panics if there is an error in the config.
func NewForConfigOrDie(c *rest.Config) Interface { func NewForConfigOrDie(c *rest.Config) *DynamicClient {
ret, err := NewForConfig(c) ret, err := NewForConfig(c)
if err != nil { if err != nil {
panic(err) panic(err)
@ -63,7 +68,7 @@ func NewForConfigOrDie(c *rest.Config) Interface {
// NewForConfig creates a new dynamic client or returns an error. // NewForConfig creates a new dynamic client or returns an error.
// NewForConfig is equivalent to NewForConfigAndClient(c, httpClient), // NewForConfig is equivalent to NewForConfigAndClient(c, httpClient),
// where httpClient was generated with rest.HTTPClientFor(c). // where httpClient was generated with rest.HTTPClientFor(c).
func NewForConfig(inConfig *rest.Config) (Interface, error) { func NewForConfig(inConfig *rest.Config) (*DynamicClient, error) {
config := ConfigFor(inConfig) config := ConfigFor(inConfig)
httpClient, err := rest.HTTPClientFor(config) httpClient, err := rest.HTTPClientFor(config)
@ -75,7 +80,7 @@ func NewForConfig(inConfig *rest.Config) (Interface, error) {
// NewForConfigAndClient creates a new dynamic client for the given config and http client. // NewForConfigAndClient creates a new dynamic client for the given config and http client.
// Note the http client provided takes precedence over the configured transport values. // Note the http client provided takes precedence over the configured transport values.
func NewForConfigAndClient(inConfig *rest.Config, h *http.Client) (Interface, error) { func NewForConfigAndClient(inConfig *rest.Config, h *http.Client) (*DynamicClient, error) {
config := ConfigFor(inConfig) config := ConfigFor(inConfig)
// for serializing the options // for serializing the options
config.GroupVersion = &schema.GroupVersion{} config.GroupVersion = &schema.GroupVersion{}
@ -85,16 +90,16 @@ func NewForConfigAndClient(inConfig *rest.Config, h *http.Client) (Interface, er
if err != nil { if err != nil {
return nil, err return nil, err
} }
return &dynamicClient{client: restClient}, nil return &DynamicClient{client: restClient}, nil
} }
type dynamicResourceClient struct { type dynamicResourceClient struct {
client *dynamicClient client *DynamicClient
namespace string namespace string
resource schema.GroupVersionResource resource schema.GroupVersionResource
} }
func (c *dynamicClient) Resource(resource schema.GroupVersionResource) NamespaceableResourceInterface { func (c *DynamicClient) Resource(resource schema.GroupVersionResource) NamespaceableResourceInterface {
return &dynamicResourceClient{client: c, resource: resource} return &dynamicResourceClient{client: c, resource: resource}
} }