app

Documentation

Index

• func Serve(c *CompletedConfig, serveFunc serveFunc, stopCh <-chan struct{}, ...) error
• func WaitForAPIServer(client clientset.Interface, timeout time.Duration) error
• type CompletedConfig
• type Config
  • func (c *Config) Complete() CompletedConfig
• type InsecureServingInfo
  • func (s *InsecureServingInfo) Serve(handler http.Handler, shutdownTimeout time.Duration, stopCh <-chan struct{}) error

Functions

func Serve

func Serve(c *CompletedConfig, serveFunc serveFunc, stopCh <-chan struct{}, checks ...healthz.HealthzChecker) error

Serve creates a base handler chain for a controller manager. It runs the the chain with the given serveFunc.

func WaitForAPIServer

func WaitForAPIServer(client clientset.Interface, timeout time.Duration) error

WaitForAPIServer waits for the API Server's /healthz endpoint to report "ok" with timeout.

Types

type CompletedConfig

type CompletedConfig struct {
	// contains filtered or unexported fields
}

CompletedConfig same as Config, just to swap private object.

type Config

type Config struct {
	// TODO: split up the component config. This is not generic.
	ComponentConfig componentconfig.KubeControllerManagerConfiguration

	SecureServing *apiserver.SecureServingInfo
	// TODO: remove deprecated insecure serving
	InsecureServing *InsecureServingInfo
	Authentication  apiserver.AuthenticationInfo
	Authorization   apiserver.AuthorizationInfo

	// the general kube client
	Client *clientset.Clientset

	// the client only used for leader election
	LeaderElectionClient *clientset.Clientset

	// the rest config for the master
	Kubeconfig *restclient.Config

	// the event sink
	EventRecorder record.EventRecorder
}

Config is the main context object for the controller manager.

func (*Config) Complete

func (c *Config) Complete() CompletedConfig

Complete fills in any fields not set that are required to have valid data. It's mutating the receiver.

type InsecureServingInfo

type InsecureServingInfo struct {
	// Listener is the secure server network listener.
	Listener net.Listener
}

InsecureServingInfo is the main context object for the insecure http server.

func (*InsecureServingInfo) Serve

func (s *InsecureServingInfo) Serve(handler http.Handler, shutdownTimeout time.Duration, stopCh <-chan struct{}) error

Serve starts an insecure http server with the given handler. It fails only if the initial listen call fails. It does not block.