apiserver

Documentation

Overview

package kubeapiserver does all of the work necessary to create a Kubernetes APIServer by binding together the API, master and APIServer infrastructure. It can be configured and called directly or via the hyperkube framework.

package kubeapiserver does all of the work necessary to create a Kubernetes APIServer by binding together the API, master and APIServer infrastructure. It can be configured and called directly or via the hyperkube framework.

Index

• func APIResourceConfigSource() *serverstorage.ResourceConfig
• func BuildAuthorizer(s *options.ServerRunOptions, EgressSelector *egressselector.EgressSelector, ...) (authorizer.Authorizer, authorizer.RuleResolver, error)
• func BuildPriorityAndFairness(s *options.ServerRunOptions, extclient clientgoclientset.Interface, ...) (utilflowcontrol.Interface, error)
• func CreateKubeAPIServer(kubeAPIServerConfig *controlplane.Config, ...) (*controlplane.Instance, error)
• func CreateKubeAPIServerConfig(s CompletedServerRunOptions) (*controlplane.Config, aggregatorapiserver.ServiceResolver, ...)
• func CreateProxyTransport() *http.Transport
• func CreateServerChain(completedOptions CompletedServerRunOptions) (*aggregatorapiserver.APIAggregator, error)
• func ParseWatchCacheSizes(cacheSizes []string) (map[schema.GroupResource]int, error)
• func WriteWatchCacheSizes(watchCacheSizes map[schema.GroupResource]int) ([]string, error)
• type CompletedServerRunOptions
  • func Complete(s *options.ServerRunOptions) (CompletedServerRunOptions, error)
  • func (c *CompletedServerRunOptions) Run(ctx context.Context) error

Functions

func APIResourceConfigSource

func APIResourceConfigSource() *serverstorage.ResourceConfig

func BuildAuthorizer

func BuildAuthorizer(s *options.ServerRunOptions, EgressSelector *egressselector.EgressSelector, versionedInformers clientgoinformers.SharedInformerFactory) (authorizer.Authorizer, authorizer.RuleResolver, error)

BuildAuthorizer constructs the authorizer

func BuildPriorityAndFairness

func BuildPriorityAndFairness(s *options.ServerRunOptions, extclient clientgoclientset.Interface, versionedInformer clientgoinformers.SharedInformerFactory) (utilflowcontrol.Interface, error)

BuildPriorityAndFairness constructs the guts of the API Priority and Fairness filter

func CreateKubeAPIServer

func CreateKubeAPIServer(kubeAPIServerConfig *controlplane.Config, delegateAPIServer genericapiserver.DelegationTarget) (*controlplane.Instance, error)

CreateKubeAPIServer creates and wires a workable kube-apiserver

func CreateKubeAPIServerConfig

func CreateKubeAPIServerConfig(s CompletedServerRunOptions) (
	*controlplane.Config,
	aggregatorapiserver.ServiceResolver,
	[]admission.PluginInitializer,
	error,
)

CreateKubeAPIServerConfig creates all the resources for running the API server, but runs none of them

func CreateProxyTransport

func CreateProxyTransport() *http.Transport

CreateProxyTransport creates the dialer infrastructure to connect to the nodes.

func CreateServerChain

func CreateServerChain(completedOptions CompletedServerRunOptions) (*aggregatorapiserver.APIAggregator, error)

CreateServerChain creates the apiservers connected via delegation.

func ParseWatchCacheSizes

func ParseWatchCacheSizes(cacheSizes []string) (map[schema.GroupResource]int, error)

ParseWatchCacheSizes turns a list of cache size values into a map of group resources to requested sizes.

func WriteWatchCacheSizes

func WriteWatchCacheSizes(watchCacheSizes map[schema.GroupResource]int) ([]string, error)

WriteWatchCacheSizes turns a map of cache size values into a list of string specifications.

Types

type CompletedServerRunOptions

type CompletedServerRunOptions struct {
	*options.ServerRunOptions
}

CompletedServerRunOptions is a private wrapper that enforces a call of Complete() before Run can be invoked.

func Complete

func Complete(s *options.ServerRunOptions) (CompletedServerRunOptions, error)

Complete set default ServerRunOptions. Should be called after kube-apiserver flags parsed.

func (*CompletedServerRunOptions) Run

func (c *CompletedServerRunOptions) Run(ctx context.Context) error