...
1
16
17
18
19 package versioned
20
21 import (
22 "fmt"
23
24 snapshotv1 "github.com/kubernetes-csi/external-snapshotter/client/v4/clientset/versioned/typed/volumesnapshot/v1"
25 snapshotv1beta1 "github.com/kubernetes-csi/external-snapshotter/client/v4/clientset/versioned/typed/volumesnapshot/v1beta1"
26 discovery "k8s.io/client-go/discovery"
27 rest "k8s.io/client-go/rest"
28 flowcontrol "k8s.io/client-go/util/flowcontrol"
29 )
30
31 type Interface interface {
32 Discovery() discovery.DiscoveryInterface
33 SnapshotV1beta1() snapshotv1beta1.SnapshotV1beta1Interface
34 SnapshotV1() snapshotv1.SnapshotV1Interface
35 }
36
37
38
39 type Clientset struct {
40 *discovery.DiscoveryClient
41 snapshotV1beta1 *snapshotv1beta1.SnapshotV1beta1Client
42 snapshotV1 *snapshotv1.SnapshotV1Client
43 }
44
45
46 func (c *Clientset) SnapshotV1beta1() snapshotv1beta1.SnapshotV1beta1Interface {
47 return c.snapshotV1beta1
48 }
49
50
51 func (c *Clientset) SnapshotV1() snapshotv1.SnapshotV1Interface {
52 return c.snapshotV1
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.snapshotV1beta1, err = snapshotv1beta1.NewForConfig(&configShallowCopy)
77 if err != nil {
78 return nil, err
79 }
80 cs.snapshotV1, err = snapshotv1.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.snapshotV1beta1 = snapshotv1beta1.NewForConfigOrDie(c)
97 cs.snapshotV1 = snapshotv1.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.snapshotV1beta1 = snapshotv1beta1.New(c)
107 cs.snapshotV1 = snapshotv1.New(c)
108
109 cs.DiscoveryClient = discovery.NewDiscoveryClient(c)
110 return &cs
111 }
112
View as plain text