Documentation
¶
Index ¶
- Variables
- func NewCSRInitializer(kubeClient clientset.Interface) (initializer.Initializer, error)
- func NewPrivateIPInitializer(kubeClient clientset.Interface, cloud cloudprovider.Interface, ...) (initializer.Initializer, error)
- func NewPublicIPInitializer(kubeClient clientset.Interface, cloud cloudprovider.Interface, ...) (initializer.Initializer, error)
- type CSRInitializer
- type IPInitializer
- type InstanceController
Constants ¶
This section is empty.
Variables ¶
View Source
var ( PublicIPToken = cluster.AnnotationPrefix + "public-ip" PrivateIPToken = cluster.AnnotationPrefix + "private-ip" )
View Source
var (
CSRToken = cluster.AnnotationPrefix + "csr"
)
Functions ¶
func NewCSRInitializer ¶
func NewCSRInitializer(kubeClient clientset.Interface) (initializer.Initializer, error)
func NewPrivateIPInitializer ¶
func NewPrivateIPInitializer(kubeClient clientset.Interface, cloud cloudprovider.Interface, clusterName string) (initializer.Initializer, error)
func NewPublicIPInitializer ¶
func NewPublicIPInitializer(kubeClient clientset.Interface, cloud cloudprovider.Interface, clusterName string) (initializer.Initializer, error)
Types ¶
type CSRInitializer ¶
type CSRInitializer struct {
// contains filtered or unexported fields
}
func (*CSRInitializer) Finalize ¶
func (ci *CSRInitializer) Finalize(obj initializer.Object) (updatedObj initializer.Object, err error, retryable bool)
func (*CSRInitializer) Initialize ¶
func (ci *CSRInitializer) Initialize(obj initializer.Object) (updatedObj initializer.Object, err error, retryable bool)
func (*CSRInitializer) Token ¶
func (ci *CSRInitializer) Token() string
type IPInitializer ¶
type IPInitializer struct {
// contains filtered or unexported fields
}
func (*IPInitializer) Finalize ¶
func (ec *IPInitializer) Finalize(obj initializer.Object) (updatedObj initializer.Object, err error, retryable bool)
func (*IPInitializer) Initialize ¶
func (ec *IPInitializer) Initialize(obj initializer.Object) (updatedObj initializer.Object, err error, retryable bool)
func (*IPInitializer) Token ¶
func (ec *IPInitializer) Token() string
type InstanceController ¶
type InstanceController struct {
// contains filtered or unexported fields
}
func New ¶
func New(cloud cloudprovider.Interface, kubeClient clientset.Interface, clusterName, namespace string) (*InstanceController, error)
New returns a new instance controller to keep cloud provider instance resources in sync with the registry.
func (*InstanceController) Run ¶
func (s *InstanceController) Run(workers int)
Run starts a watcher who watches changes of instances in registry, serveral workers who process instance updates, and a cloud instance syncer who syncs instance statuses from cloud back to registry
Source Files
Click to show internal directories.
Click to hide internal directories.