instance

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
  • func (ci *CSRInitializer) Finalize(obj initializer.Object) (updatedObj initializer.Object, err error, retryable bool)
  • func (ci *CSRInitializer) Initialize(obj initializer.Object) (updatedObj initializer.Object, err error, retryable bool)
  • func (ci *CSRInitializer) Token() string
• type IPInitializer
  • func (ec *IPInitializer) Finalize(obj initializer.Object) (updatedObj initializer.Object, err error, retryable bool)
  • func (ec *IPInitializer) Initialize(obj initializer.Object) (updatedObj initializer.Object, err error, retryable bool)
  • func (ec *IPInitializer) Token() string
• type InstanceController
  • func New(cloud cloudprovider.Interface, kubeClient clientset.Interface, ...) (*InstanceController, error)
  • func (s *InstanceController) Run(workers int)

Variables

var (
	PublicIPToken  = cluster.AnnotationPrefix + "public-ip"
	PrivateIPToken = cluster.AnnotationPrefix + "private-ip"
)

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