kubernetes

Documentation

Overview

Package kubernetes provides objects for starting the Kubernetes master and node code.

Index

• Constants
• type MasterConfig
  • func (c *MasterConfig) EnsurePortalFlags()
  • func (c *MasterConfig) InstallAPI(container *restful.Container) []string
  • func (c *MasterConfig) RunEndpointController()
  • func (c *MasterConfig) RunMinionController()
  • func (c *MasterConfig) RunReplicationController()
  • func (c *MasterConfig) RunScheduler()
• type NodeConfig
  • func (c *NodeConfig) EnsureDocker(docker *dockerutil.Helper)
  • func (c *NodeConfig) EnsureVolumeDir()
  • func (c *NodeConfig) RunKubelet()
  • func (c *NodeConfig) RunProxy()
• type ProxyConfig
  • func (c *ProxyConfig) InstallAPI(container *restful.Container) []string

Constants

const (
	KubeAPIPrefix        = "/api"
	KubeAPIPrefixV1Beta1 = "/api/v1beta1"
	KubeAPIPrefixV1Beta2 = "/api/v1beta2"
	KubeAPIPrefixV1Beta3 = "/api/v1beta3"
)

const NodePort = 10250

NodePort is the default Kubelet port for serving information about the node.

const NodeScheme = "http"

NodeScheme is the default scheme for serving information about the node.

Types

type MasterConfig

type MasterConfig struct {
	MasterIP   net.IP
	MasterPort int
	NodeHosts  []string
	PortalNet  *net.IPNet

	EtcdHelper tools.EtcdHelper
	KubeClient *kclient.Client

	Authorizer       authorizer.Authorizer
	AdmissionControl admission.Interface
}

MasterConfig defines the required values to start a Kubernetes master

func (*MasterConfig) EnsurePortalFlags

func (c *MasterConfig) EnsurePortalFlags()

TODO: Longer term we should read this from some config store, rather than a flag.

func (*MasterConfig) InstallAPI

func (c *MasterConfig) InstallAPI(container *restful.Container) []string

InstallAPI starts a Kubernetes master and registers the supported REST APIs into the provided mux, then returns an array of strings indicating what endpoints were started (these are format strings that will expect to be sent a single string value).

func (*MasterConfig) RunEndpointController

func (c *MasterConfig) RunEndpointController()

RunEndpointController starts the Kubernetes replication controller sync loop

func (*MasterConfig) RunMinionController

func (c *MasterConfig) RunMinionController()

func (*MasterConfig) RunReplicationController

func (c *MasterConfig) RunReplicationController()

RunReplicationController starts the Kubernetes replication controller sync loop

func (*MasterConfig) RunScheduler

func (c *MasterConfig) RunScheduler()

RunScheduler starts the Kubernetes scheduler

type NodeConfig

type NodeConfig struct {
	// The address to bind to
	BindHost string
	// The name of this node that will be used to identify the node in the master.
	// This value must match the value provided to the master on startup.
	NodeHost string
	// The host that the master can be reached at (not in use yet)
	MasterHost string
	// The directory that volumes will be stored under
	VolumeDir string

	// The image used as the Kubelet network namespace and volume container.
	NetworkContainerImage string

	// Whether to enable TLS serving
	TLS bool

	KubeletCertFile string
	KubeletKeyFile  string

	// ClientCAs will be used to request client certificates in connections to the node.
	// This CertPool should contain all the CAs that will be used for client certificate verification.
	ClientCAs *x509.CertPool

	// A client to connect to the master.
	Client *client.Client
	// A client to connect to Docker
	DockerClient *docker.Client
}

NodeConfig represents the required parameters to start the OpenShift node through Kubernetes. All fields are required.

func (*NodeConfig) EnsureDocker

func (c *NodeConfig) EnsureDocker(docker *dockerutil.Helper)

EnsureDocker attempts to connect to the Docker daemon defined by the helper, and if it is unable to it will print a warning.

func (*NodeConfig) EnsureVolumeDir

func (c *NodeConfig) EnsureVolumeDir()

EnsureVolumeDir attempts to convert the provided volume directory argument to an absolute path and create the directory if it does not exist. Will exit if an error is encountered.

func (*NodeConfig) RunKubelet

func (c *NodeConfig) RunKubelet()

RunKubelet starts the Kubelet.

func (*NodeConfig) RunProxy

func (c *NodeConfig) RunProxy()

RunProxy starts the proxy

type ProxyConfig

type ProxyConfig struct {
	KubernetesAddr *url.URL
	ClientConfig   *kclient.Config
}

func (*ProxyConfig) InstallAPI

func (c *ProxyConfig) InstallAPI(container *restful.Container) []string