master

Documentation

Overview

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

Index

• Constants
• type Config
• type Master
  • func New(c *Config) *Master
  • func (m *Master) API_v1beta1() (map[string]apiserver.RESTStorage, runtime.Codec)
• type PodCache
  • func NewPodCache(info client.PodInfoGetter, pods pod.Registry) *PodCache
  • func (p *PodCache) GetPodInfo(host, 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
)

Types

type Config

type Config struct {
	Client             *client.Client
	Cloud              cloudprovider.Interface
	EtcdServers        []string
	HealthCheckMinions bool
	Minions            []string
	MinionCacheTTL     time.Duration
	MinionRegexp       string
	PodInfoGetter      client.PodInfoGetter
}

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 etcdServer.

func (*Master) API_v1beta1

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

API_v1beta1 returns the resources and codec for API version v1beta1.

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, 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.