app

package
v1.12.0-alpha.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 17, 2018 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func BuildHandlerChain added in v1.11.0

func BuildHandlerChain(apiHandler http.Handler, c *CompletedConfig) http.Handler

BuildHandlerChain builds a handler chain with a base handler and CompletedConfig.

func NewBaseHandler added in v1.11.0

func NewBaseHandler(c *CompletedConfig) http.Handler

NewBaseHandler takes in CompletedConfig and returns a handler.

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 {
	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
	// optional server name for log messages
	Name string
}

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.

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL