Documentation
¶
Index ¶
- func GetAnnotation(m meta.ObjectMeta, name string) (string, bool)
- func IgnoreAlreadyExists(err error) error
- func IgnoreError(err error, handler func(error) bool) error
- func IgnoreNotFound(err error) error
- func IgnoreTimeout(err error) error
- func NewForConfig(cfg *rest.Config) (*client, error)
- func SetAnnotation(m meta.ObjectMeta, name, val string)
- type Config
- type FactoryGroup
- type Interface
- type ListerGroup
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetAnnotation ¶
func GetAnnotation(m meta.ObjectMeta, name string) (string, bool)
func IgnoreAlreadyExists ¶
func IgnoreNotFound ¶
func IgnoreTimeout ¶
func NewForConfig ¶
func SetAnnotation ¶
func SetAnnotation(m meta.ObjectMeta, name, val string)
Types ¶
type Config ¶
type Config struct {
AccessType string `env-required:"true" json:"access_type" env:"KUBE_ACCESS_TYPE"`
}
type FactoryGroup ¶
type FactoryGroup struct {
Core core.SharedInformerFactory
Stands stands.SharedInformerFactory
}
func NewFactoryGroup ¶
func NewFactoryGroup(k Interface, coreRI, standsRI time.Duration) *FactoryGroup
func (*FactoryGroup) Start ¶
func (fg *FactoryGroup) Start(interrupt <-chan struct{})
func (*FactoryGroup) WaitForCacheSync ¶
func (fg *FactoryGroup) WaitForCacheSync(interrupt <-chan struct{}) map[reflect.Type]bool
type Interface ¶
type Interface interface {
CoreClient() corecs.Interface
StandSchedulesClient() standscs.Interface
}
func NewForAccessType ¶
func NewForExternalCluster ¶
func NewForInternalCluster ¶
func NewForTest ¶
func NewPluginClient ¶
func NewPluginClient(clientGetter genericclioptions.RESTClientGetter) (Interface, error)
type ListerGroup ¶
type ListerGroup struct {
Namespaces core.NamespaceLister
Deployments apps.DeploymentLister
StatefulSets apps.StatefulSetLister
Stands stands.StandSchedulePolicyLister
}
func NewListerGroup ¶
func NewListerGroup(f *FactoryGroup) *ListerGroup
Source Files
Click to show internal directories.
Click to hide internal directories.