package app

import "k8s.io/kubernetes/cmd/controller-manager/app"

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{}) 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.

Source Files ¶

config.go helper.go insecure_serving.go serve.go

Directories ¶