master

Documentation

Overview

Package master contains code for setting up and running a Kubernetes cluster master.

Index

• Constants
• func NewEtcdHelper(client tools.EtcdGetSet, version string) (helper tools.EtcdHelper, err error)
• type Config
• type Master
  • func New(c *Config) *Master
  • func (m *Master) API_v1beta1() (map[string]apiserver.RESTStorage, runtime.Codec, string, runtime.SelfLinker)
  • func (m *Master) API_v1beta2() (map[string]apiserver.RESTStorage, runtime.Codec, string, runtime.SelfLinker)
• type PodCache
  • func NewPodCache(info client.PodInfoGetter, pods pod.Registry) *PodCache
  • func (p *PodCache) GetPodInfo(host, podNamespace, podID string) (api.PodInfo, error)
  • func (p *PodCache) UpdateAllContainers()

Constants

const (
	// KubeletPort is the default port for the kubelet status server on each host machine.
	// May be overridden by a flag at startup.
	KubeletPort = 10250
	// SchedulerPort is the default port for the scheduler status server.
	// May be overridden by a flag at startup.
	SchedulerPort = 10251
	// ControllerManagerPort is the default port for the controller manager status server.
	// May be overridden by a flag at startup.
	ControllerManagerPort = 10252
)

Functions

func NewEtcdHelper

func NewEtcdHelper(client tools.EtcdGetSet, version string) (helper tools.EtcdHelper, err error)

NewEtcdHelper returns an EtcdHelper for the provided arguments or an error if the version is incorrect.

Types

type Config

type Config struct {
	Client             *client.Client
	Cloud              cloudprovider.Interface
	EtcdHelper         tools.EtcdHelper
	HealthCheckMinions bool
	Minions            []string
	MinionCacheTTL     time.Duration
	EventTTL           time.Duration
	MinionRegexp       string
	PodInfoGetter      client.PodInfoGetter
	NodeResources      api.NodeResources
}

Config is a structure used to configure a Master.

type Master

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

Master contains state for a Kubernetes cluster master/api server.

func New

func New(c *Config) *Master

New returns a new instance of Master connected to the given etcd server.

func (*Master) API_v1beta1

func (m *Master) API_v1beta1() (map[string]apiserver.RESTStorage, runtime.Codec, string, runtime.SelfLinker)

API_v1beta1 returns the resources and codec for API version v1beta1.

func (*Master) API_v1beta2

func (m *Master) API_v1beta2() (map[string]apiserver.RESTStorage, runtime.Codec, string, runtime.SelfLinker)

API_v1beta2 returns the resources and codec for API version v1beta2.

type PodCache

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

PodCache contains both a cache of container information, as well as the mechanism for keeping that cache up to date.

func NewPodCache

func NewPodCache(info client.PodInfoGetter, pods pod.Registry) *PodCache

NewPodCache returns a new PodCache which watches container information registered in the given PodRegistry.

func (*PodCache) GetPodInfo

func (p *PodCache) GetPodInfo(host, podNamespace, podID string) (api.PodInfo, error)

GetPodInfo implements the PodInfoGetter.GetPodInfo. The returned value should be treated as read-only. TODO: Remove the host from this call, it's totally unnecessary.

func (*PodCache) UpdateAllContainers

func (p *PodCache) UpdateAllContainers()

UpdateAllContainers updates information about all containers. Either called by Loop() below, or one-off.