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
¶
Click to show internal directories.
Click to hide internal directories.