...
1
16
17
18
19 package versioned
20
21 import (
22 "fmt"
23
24 discovery "k8s.io/client-go/discovery"
25 rest "k8s.io/client-go/rest"
26 flowcontrol "k8s.io/client-go/util/flowcontrol"
27 cdiv1beta1 "kubevirt.io/client-go/generated/containerized-data-importer/clientset/versioned/typed/core/v1beta1"
28 uploadv1beta1 "kubevirt.io/client-go/generated/containerized-data-importer/clientset/versioned/typed/upload/v1beta1"
29 )
30
31 type Interface interface {
32 Discovery() discovery.DiscoveryInterface
33 CdiV1beta1() cdiv1beta1.CdiV1beta1Interface
34 UploadV1beta1() uploadv1beta1.UploadV1beta1Interface
35 }
36
37
38
39 type Clientset struct {
40 *discovery.DiscoveryClient
41 cdiV1beta1 *cdiv1beta1.CdiV1beta1Client
42 uploadV1beta1 *uploadv1beta1.UploadV1beta1Client
43 }
44
45
46 func (c *Clientset) CdiV1beta1() cdiv1beta1.CdiV1beta1Interface {
47 return c.cdiV1beta1
48 }
49
50
51 func (c *Clientset) UploadV1beta1() uploadv1beta1.UploadV1beta1Interface {
52 return c.uploadV1beta1
53 }
54
55
56 func (c *Clientset) Discovery() discovery.DiscoveryInterface {
57 if c == nil {
58 return nil
59 }
60 return c.DiscoveryClient
61 }
62
63
64
65
66 func NewForConfig(c *rest.Config) (*Clientset, error) {
67 configShallowCopy := *c
68 if configShallowCopy.RateLimiter == nil && configShallowCopy.QPS > 0 {
69 if configShallowCopy.Burst <= 0 {
70 return nil, fmt.Errorf("burst is required to be greater than 0 when RateLimiter is not set and QPS is set to greater than 0")
71 }
72 configShallowCopy.RateLimiter = flowcontrol.NewTokenBucketRateLimiter(configShallowCopy.QPS, configShallowCopy.Burst)
73 }
74 var cs Clientset
75 var err error
76 cs.cdiV1beta1, err = cdiv1beta1.NewForConfig(&configShallowCopy)
77 if err != nil {
78 return nil, err
79 }
80 cs.uploadV1beta1, err = uploadv1beta1.NewForConfig(&configShallowCopy)
81 if err != nil {
82 return nil, err
83 }
84
85 cs.DiscoveryClient, err = discovery.NewDiscoveryClientForConfig(&configShallowCopy)
86 if err != nil {
87 return nil, err
88 }
89 return &cs, nil
90 }
91
92
93
94 func NewForConfigOrDie(c *rest.Config) *Clientset {
95 var cs Clientset
96 cs.cdiV1beta1 = cdiv1beta1.NewForConfigOrDie(c)
97 cs.uploadV1beta1 = uploadv1beta1.NewForConfigOrDie(c)
98
99 cs.DiscoveryClient = discovery.NewDiscoveryClientForConfigOrDie(c)
100 return &cs
101 }
102
103
104 func New(c rest.Interface) *Clientset {
105 var cs Clientset
106 cs.cdiV1beta1 = cdiv1beta1.New(c)
107 cs.uploadV1beta1 = uploadv1beta1.New(c)
108
109 cs.DiscoveryClient = discovery.NewDiscoveryClient(c)
110 return &cs
111 }
112
View as plain text