master

package

Go to main page

Versions in this module

v1

v1.3.2

Jan 7, 2017

v1.3.1

Sep 22, 2016

v1.3.0

Sep 19, 2016

Changes in this version

+ func DefaultAPIResourceConfigSource() *genericapiserver.ResourceConfig

+ func MetricsWithReset(w http.ResponseWriter, req *http.Request)

+ func NewMasterCountEndpointReconciler(masterCount int, endpointRegistry endpoint.Registry) *masterCountEndpointReconciler

type Controller

+ EndpointReconciler EndpointReconciler

+ SystemNamespaces []string

+ SystemNamespacesInterval time.Duration

+ func (c *Controller) RunKubernetesNamespaces(ch chan struct{})

+ type EndpointReconciler interface

+ ReconcileEndpoints func(serviceName string, ip net.IP, endpointPorts []api.EndpointPort, ...) error

type Master

+ func (m *Master) GetRESTOptionsOrDie(c *Config, resource unversioned.GroupResource) generic.RESTOptions

v1.2.0

Jun 23, 2016

v0

v0.4.0

Jun 23, 2016

Changes in this version

type Config

+ DeleteCollectionWorkers int

type SSHTunneler

+ HealthCheckURL *url.URL

v0.3.0

Mar 16, 2016

Changes in this version

+ type AddressFunc func() (addresses []string, err error)

type Config

+ Tunneler Tunneler

type Controller

+ ExtraEndpointPorts []api.EndpointPort

+ ExtraServicePorts []api.ServicePort

+ func (c *Controller) CreateOrUpdateMasterServiceIfNeeded(serviceName string, serviceIP net.IP, servicePorts []api.ServicePort, ...) error

+ func (c *Controller) ReconcileEndpoints(serviceName string, ip net.IP, endpointPorts []api.EndpointPort, ...) error

type Master

+ func (m *Master) InstallAPIs(c *Config)

+ type SSHTunneler struct

+ InstallSSHKey InstallSSHKey

+ SSHKeyfile string

+ SSHUser string

+ func (c *SSHTunneler) Dial(net, addr string) (net.Conn, error)

+ func (c *SSHTunneler) Run(getAddresses AddressFunc)

+ func (c *SSHTunneler) SecondsSinceSync() int64

+ func (c *SSHTunneler) Stop()

+ type Tunneler interface

+ Dial func(net, addr string) (net.Conn, error)

+ Run func(AddressFunc)

+ SecondsSinceSync func() int64

+ Stop func()

+ func NewSSHTunneler(sshUser string, sshKeyfile string, installSSHKey InstallSSHKey) Tunneler

v0.1.0

Oct 25, 2015

Changes in this version

+ const DefaultEtcdPathPrefix

+ func NewEtcdStorage(client tools.EtcdClient, interfacesFunc meta.VersionInterfacesFunc, ...) (etcdStorage storage.Interface, err error)

+ func NewHandlerContainer(mux *http.ServeMux) *restful.Container

+ type Config struct

+ APIGroupPrefix string

+ APIPrefix string

+ AdmissionControl admission.Interface

+ Authenticator authenticator.Request

+ Authorizer authorizer.Authorizer

+ CacheTimeout time.Duration

+ ClusterName string

+ CorsAllowedOriginList []string

+ DisableV1 bool

+ EnableCoreControllers bool

+ EnableExp bool

+ EnableIndex bool

+ EnableLogsSupport bool

+ EnableProfiling bool

+ EnableSwaggerSupport bool

+ EnableUISupport bool

+ EnableWatchCache bool

+ EventTTL time.Duration

+ ExternalHost string

+ InstallSSHKey InstallSSHKey

+ KubeletClient client.KubeletClient

+ KubernetesServiceNodePort int

+ MasterCount int

+ MasterServiceNamespace string

+ MinRequestTimeout int

+ NodeRegexp string

+ PublicAddress net.IP

+ ReadWritePort int

+ RequestContextMapper api.RequestContextMapper

+ RestfulContainer *restful.Container

+ SSHKeyfile string

+ SSHUser string

+ ServiceClusterIPRange *net.IPNet

+ ServiceNodePortRange util.PortRange

+ ServiceReadWriteIP net.IP

+ StorageDestinations StorageDestinations

+ StorageVersions map[string]string

+ SupportsBasicAuth bool

+ type Controller struct

+ EndpointInterval time.Duration

+ EndpointRegistry endpoint.Registry

+ KubernetesServiceNodePort int

+ MasterCount int

+ NamespaceRegistry namespace.Registry

+ PublicIP net.IP

+ PublicServicePort int

+ ServiceClusterIPInterval time.Duration

+ ServiceClusterIPRange *net.IPNet

+ ServiceClusterIPRegistry service.RangeRegistry

+ ServiceIP net.IP

+ ServiceNodePortInterval time.Duration

+ ServiceNodePortRange util.PortRange

+ ServiceNodePortRegistry service.RangeRegistry

+ ServicePort int

+ ServiceRegistry service.Registry

+ TenantRegistry tenant.Registry

+ func (c *Controller) CreateMasterServiceIfNeeded(serviceName string, serviceIP net.IP, servicePort, nodePort int) error

+ func (c *Controller) CreateNamespaceIfNeeded(ns string) error

+ func (c *Controller) CreateTenantIfNeeded(te string) error

+ func (c *Controller) RunKubernetesService(ch chan struct{})

+ func (c *Controller) SetEndpoints(serviceName string, ip net.IP, port int) error

+ func (c *Controller) Start()

+ func (c *Controller) UpdateKubernetesService() error

+ type InstallSSHKey func(user string, data []byte) error

+ type Master struct

+ Handler http.Handler

+ InsecureHandler http.Handler

+ KubernetesServiceNodePort int

+ func New(c *Config) *Master

+ func (m *Master) Dial(net, addr string) (net.Conn, error)

+ func (m *Master) HandleFuncWithAuth(pattern string, handler func(http.ResponseWriter, *http.Request))

+ func (m *Master) HandleWithAuth(pattern string, handler http.Handler)

+ func (m *Master) HasThirdPartyResource(rsrc *expapi.ThirdPartyResource) (bool, error)

+ func (m *Master) InstallSwaggerAPI()

+ func (m *Master) InstallThirdPartyResource(rsrc *expapi.ThirdPartyResource) error

+ func (m *Master) IsTunnelSyncHealthy(req *http.Request) error

+ func (m *Master) ListThirdPartyResources() []string

+ func (m *Master) NewBootstrapController() *Controller

+ func (m *Master) RemoveThirdPartyResource(path string) error

+ type StorageDestinations struct

+ APIGroups map[string]*StorageDestinationsForAPIGroup

+ func NewStorageDestinations() StorageDestinations

+ func (s *StorageDestinations) AddAPIGroup(group string, defaultStorage storage.Interface)

+ func (s *StorageDestinations) AddStorageOverride(group, resource string, override storage.Interface)

+ type StorageDestinationsForAPIGroup struct

+ Default storage.Interface

+ Overrides map[string]storage.Interface

+ type ThirdPartyController struct

+ func (t *ThirdPartyController) SyncOneResource(rsrc *expapi.ThirdPartyResource) error

+ func (t *ThirdPartyController) SyncResources() error

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