 Documentation
      ¶
      Documentation
      ¶
    
    
  
    
  
    Index ¶
- Constants
- func GetDefaultRateLimiter() flowcontrol.RateLimiter
- func GetRateLimiter(name string) flowcontrol.RateLimiter
- func GetUnattachedRateLimiter() flowcontrol.RateLimiter
- func SetDefaultBurst(q int)
- func SetDefaultQPS(q float32)
- type Client
- type ConfigGetter
- type Factory
- type FakeClientBuilder
- type FakeDataInput
- type ModInterface
Constants ¶
      View Source
      
  
const ( DefaultQPS float32 = 32 DefaultBurst int = 256 )
Variables ¶
This section is empty.
Functions ¶
func GetDefaultRateLimiter ¶
func GetDefaultRateLimiter() flowcontrol.RateLimiter
func GetRateLimiter ¶
func GetRateLimiter(name string) flowcontrol.RateLimiter
func GetUnattachedRateLimiter ¶
func GetUnattachedRateLimiter() flowcontrol.RateLimiter
func SetDefaultBurst ¶
func SetDefaultBurst(q int)
func SetDefaultQPS ¶
func SetDefaultQPS(q float32)
Types ¶
type Client ¶
type Client interface {
	Kubernetes() kubernetes.Interface
	KubernetesExtensions() apiextensionsclient.Interface
	Arango() versioned.Interface
	Monitoring() monitoring.Interface
	Name() string
	Config() *rest.Config
}
    func NewFakeClient ¶
func NewFakeClient() Client
func NewStaticClient ¶
func NewStaticClient(config *rest.Config, kubernetes kubernetes.Interface, kubernetesExtensions apiextensionsclient.Interface, arango versioned.Interface, monitoring monitoring.Interface) Client
type ConfigGetter ¶
func NewStaticConfigGetter ¶
func NewStaticConfigGetter(f func() (*rest.Config, error)) ConfigGetter
type Factory ¶
type Factory interface {
	SetKubeConfigGetter(getter ConfigGetter)
	Refresh() error
	SetClient(c Client)
	Name() string
	Client() (Client, bool)
}
    func GetDefaultFactory ¶
func GetDefaultFactory() Factory
func GetFactory ¶
func GetUnattachedFactory ¶
func GetUnattachedFactory() Factory
type FakeClientBuilder ¶
type FakeClientBuilder interface {
	Add(objects ...runtime.Object) FakeClientBuilder
	Version(version *version.Info) FakeClientBuilder
	Client() Client
}
    func NewFakeClientBuilder ¶
func NewFakeClientBuilder() FakeClientBuilder
type FakeDataInput ¶
type FakeDataInput struct {
	Namespace string
	Pods            map[string]*core.Pod
	Secrets         map[string]*core.Secret
	Services        map[string]*core.Service
	PVCS            map[string]*core.PersistentVolumeClaim
	ServiceAccounts map[string]*core.ServiceAccount
	PDBSV1          map[string]*policy.PodDisruptionBudget
	ServiceMonitors map[string]*monitoringApi.ServiceMonitor
	ArangoMembers   map[string]*api.ArangoMember
	Nodes           map[string]*core.Node
	ACS             map[string]*api.ArangoClusterSynchronization
	AT              map[string]*api.ArangoTask
}
    func (FakeDataInput) Client ¶
func (f FakeDataInput) Client() Client
type ModInterface ¶
type ModInterface interface {
	Secrets() generic.ModClient[*core.Secret]
	Pods() generic.ModClient[*core.Pod]
	Services() generic.ModClient[*core.Service]
	ServiceAccounts() generic.ModClient[*core.ServiceAccount]
	PersistentVolumeClaims() generic.ModClient[*core.PersistentVolumeClaim]
	PodDisruptionBudgets() generic.ModClient[*policy.PodDisruptionBudget]
	ServiceMonitors() generic.ModClient[*monitoringApi.ServiceMonitor]
	ArangoMembers() generic.ModStatusClient[*api.ArangoMember]
}
    func NewModInterface ¶
func NewModInterface(client Client, namespace string) ModInterface
       Source Files
      ¶
      Source Files
      ¶
    
   Click to show internal directories. 
   Click to hide internal directories.