clientset.go

Documentation: github.com/openshift/client-go/operator/clientset/versioned

     1  // Code generated by client-gen. DO NOT EDIT.
     2  
     3  package versioned
     4  
     5  import (
     6  	"fmt"
     7  
     8  	operatorv1 "github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1"
     9  	operatorv1alpha1 "github.com/openshift/client-go/operator/clientset/versioned/typed/operator/v1alpha1"
    10  	discovery "k8s.io/client-go/discovery"
    11  	rest "k8s.io/client-go/rest"
    12  	flowcontrol "k8s.io/client-go/util/flowcontrol"
    13  )
    14  
    15  type Interface interface {
    16  	Discovery() discovery.DiscoveryInterface
    17  	OperatorV1() operatorv1.OperatorV1Interface
    18  	OperatorV1alpha1() operatorv1alpha1.OperatorV1alpha1Interface
    19  }
    20  
    21  // Clientset contains the clients for groups. Each group has exactly one
    22  // version included in a Clientset.
    23  type Clientset struct {
    24  	*discovery.DiscoveryClient
    25  	operatorV1       *operatorv1.OperatorV1Client
    26  	operatorV1alpha1 *operatorv1alpha1.OperatorV1alpha1Client
    27  }
    28  
    29  // OperatorV1 retrieves the OperatorV1Client
    30  func (c *Clientset) OperatorV1() operatorv1.OperatorV1Interface {
    31  	return c.operatorV1
    32  }
    33  
    34  // OperatorV1alpha1 retrieves the OperatorV1alpha1Client
    35  func (c *Clientset) OperatorV1alpha1() operatorv1alpha1.OperatorV1alpha1Interface {
    36  	return c.operatorV1alpha1
    37  }
    38  
    39  // Discovery retrieves the DiscoveryClient
    40  func (c *Clientset) Discovery() discovery.DiscoveryInterface {
    41  	if c == nil {
    42  		return nil
    43  	}
    44  	return c.DiscoveryClient
    45  }
    46  
    47  // NewForConfig creates a new Clientset for the given config.
    48  // If config's RateLimiter is not set and QPS and Burst are acceptable,
    49  // NewForConfig will generate a rate-limiter in configShallowCopy.
    50  func NewForConfig(c *rest.Config) (*Clientset, error) {
    51  	configShallowCopy := *c
    52  	if configShallowCopy.RateLimiter == nil && configShallowCopy.QPS > 0 {
    53  		if configShallowCopy.Burst <= 0 {
    54  			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")
    55  		}
    56  		configShallowCopy.RateLimiter = flowcontrol.NewTokenBucketRateLimiter(configShallowCopy.QPS, configShallowCopy.Burst)
    57  	}
    58  	var cs Clientset
    59  	var err error
    60  	cs.operatorV1, err = operatorv1.NewForConfig(&configShallowCopy)
    61  	if err != nil {
    62  		return nil, err
    63  	}
    64  	cs.operatorV1alpha1, err = operatorv1alpha1.NewForConfig(&configShallowCopy)
    65  	if err != nil {
    66  		return nil, err
    67  	}
    68  
    69  	cs.DiscoveryClient, err = discovery.NewDiscoveryClientForConfig(&configShallowCopy)
    70  	if err != nil {
    71  		return nil, err
    72  	}
    73  	return &cs, nil
    74  }
    75  
    76  // NewForConfigOrDie creates a new Clientset for the given config and
    77  // panics if there is an error in the config.
    78  func NewForConfigOrDie(c *rest.Config) *Clientset {
    79  	var cs Clientset
    80  	cs.operatorV1 = operatorv1.NewForConfigOrDie(c)
    81  	cs.operatorV1alpha1 = operatorv1alpha1.NewForConfigOrDie(c)
    82  
    83  	cs.DiscoveryClient = discovery.NewDiscoveryClientForConfigOrDie(c)
    84  	return &cs
    85  }
    86  
    87  // New creates a new Clientset for the given RESTClient.
    88  func New(c rest.Interface) *Clientset {
    89  	var cs Clientset
    90  	cs.operatorV1 = operatorv1.New(c)
    91  	cs.operatorV1alpha1 = operatorv1alpha1.New(c)
    92  
    93  	cs.DiscoveryClient = discovery.NewDiscoveryClient(c)
    94  	return &cs
    95  }
    96
View as plain text