openshiftkubeapiserver

Documentation

Index

• func BuildHandlerChain(genericConfig *genericapiserver.Config, ...) (func(apiHandler http.Handler, kc *genericapiserver.Config) http.Handler, ...)
• func ConfigToFlags(kubeAPIServerConfig *configapi.KubeAPIServerConfig) ([]string, error)
• func NewAuthenticator(servingInfo configapi.ServingInfo, serviceAccountPublicKeyFiles []string, ...) (authenticator.Request, map[string]genericapiserver.PostStartHookFunc, error)
• func NewAuthorizer(internalInformers internalinformers.SharedInformerFactory, ...) authorizer.Authorizer
• func NewOAuthServerConfigFromMasterConfig(genericConfig *genericapiserver.Config, oauthConfig *configapi.OAuthConfig) (*oauthserver.OAuthServerConfig, error)
• func NewOAuthServerHandler(genericConfig *genericapiserver.Config, oauthConfig *configapi.OAuthConfig) (http.Handler, map[string]genericapiserver.PostStartHookFunc, error)
• func WithPatternPrefixHandler(handler http.Handler, patternHandler http.Handler, prefixes ...string) http.Handler
• type CompletedOpenshiftNonAPIConfig
  • func (c CompletedOpenshiftNonAPIConfig) New(delegationTarget genericapiserver.DelegationTarget) (*OpenshiftNonAPIServer, error)
• type KubeAPIServerInformers
  • func NewInformers(internalInformers internalinformers.SharedInformerFactory, ...) (*KubeAPIServerInformers, error)
  • func (i *KubeAPIServerInformers) GetInternalKubernetesInformers() kinternalinformers.SharedInformerFactory
  • func (i *KubeAPIServerInformers) GetInternalOpenshiftImageInformers() imageinformer.SharedInformerFactory
  • func (i *KubeAPIServerInformers) GetInternalOpenshiftQuotaInformers() quotainformer.SharedInformerFactory
  • func (i *KubeAPIServerInformers) GetInternalOpenshiftSecurityInformers() securityinformer.SharedInformerFactory
  • func (i *KubeAPIServerInformers) GetKubernetesInformers() kexternalinformers.SharedInformerFactory
  • func (i *KubeAPIServerInformers) GetOpenshiftUserInformers() userinformer.SharedInformerFactory
  • func (i *KubeAPIServerInformers) Start(stopCh <-chan struct{})
• type KubeAPIServerServerPatchContext
  • func NewOpenShiftKubeAPIServerConfigPatch(delegateAPIServer genericapiserver.DelegationTarget, ...) (app.KubeAPIServerConfigFunc, *KubeAPIServerServerPatchContext)
  • func (c *KubeAPIServerServerPatchContext) PatchServer(server *master.Master) error
• type NonAPIExtraConfig
• type OpenshiftNonAPIConfig
  • func NewOpenshiftNonAPIConfig(generiConfig *genericapiserver.Config, ...) (*OpenshiftNonAPIConfig, error)
  • func (c *OpenshiftNonAPIConfig) Complete() completedOpenshiftNonAPIConfig
• type OpenshiftNonAPIServer
• type ServiceResolver

Functions

func BuildHandlerChain

func BuildHandlerChain(genericConfig *genericapiserver.Config, kubeInformers informers.SharedInformerFactory, legacyServiceServingCertSignerCABundle string, oauthConfig *configapi.OAuthConfig, userAgentMatchingConfig configapi.UserAgentMatchingConfig) (func(apiHandler http.Handler, kc *genericapiserver.Config) http.Handler, map[string]genericapiserver.PostStartHookFunc, error)

TODO switch back to taking a kubeapiserver config. For now make it obviously safe for 3.11

func ConfigToFlags

func ConfigToFlags(kubeAPIServerConfig *configapi.KubeAPIServerConfig) ([]string, error)

func NewAuthenticator

func NewAuthenticator(
	servingInfo configapi.ServingInfo,
	serviceAccountPublicKeyFiles []string, oauthConfig *configapi.OAuthConfig, authConfig configapi.MasterAuthConfig,
	privilegedLoopbackConfig *rest.Config,
	oauthClientLister oauthclientlister.OAuthClientLister,
	groupInformer userinformer.GroupInformer,
) (authenticator.Request, map[string]genericapiserver.PostStartHookFunc, error)

TODO we can re-trim these args to the the kubeapiserver config again if we feel like it, but for now we need it to be TODO obviously safe for 3.11

func NewAuthorizer

func NewAuthorizer(internalInformers internalinformers.SharedInformerFactory, versionedInformers informers.SharedInformerFactory) authorizer.Authorizer

func NewOAuthServerConfigFromMasterConfig

func NewOAuthServerConfigFromMasterConfig(genericConfig *genericapiserver.Config, oauthConfig *configapi.OAuthConfig) (*oauthserver.OAuthServerConfig, error)

TODO this is taking a very large config for a small piece of it. The information must be broken up at some point so that we can run this in a pod. This is an indication of leaky abstraction because it spent too much time in openshift start

func NewOAuthServerHandler

func NewOAuthServerHandler(genericConfig *genericapiserver.Config, oauthConfig *configapi.OAuthConfig) (http.Handler, map[string]genericapiserver.PostStartHookFunc, error)

func WithPatternPrefixHandler

func WithPatternPrefixHandler(handler http.Handler, patternHandler http.Handler, prefixes ...string) http.Handler

Types

type CompletedOpenshiftNonAPIConfig

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

func (CompletedOpenshiftNonAPIConfig) New

func (c CompletedOpenshiftNonAPIConfig) New(delegationTarget genericapiserver.DelegationTarget) (*OpenshiftNonAPIServer, error)

type KubeAPIServerInformers

type KubeAPIServerInformers struct {
	InternalKubernetesInformers        kinternalinformers.SharedInformerFactory
	KubernetesInformers                kexternalinformers.SharedInformerFactory
	OpenshiftOAuthInformers            oauthinformer.SharedInformerFactory
	InternalOpenshiftImageInformers    imageinformer.SharedInformerFactory
	InternalOpenshiftQuotaInformers    quotainformer.SharedInformerFactory
	InternalOpenshiftSecurityInformers securityinformer.SharedInformerFactory
	OpenshiftUserInformers             userinformer.SharedInformerFactory
}

func NewInformers

func NewInformers(internalInformers internalinformers.SharedInformerFactory, versionedInformers clientgoinformers.SharedInformerFactory, loopbackClientConfig *rest.Config) (*KubeAPIServerInformers, error)

NewInformers is only exposed for the build's integration testing until it can be fixed more appropriately.

func (*KubeAPIServerInformers) GetInternalKubernetesInformers

func (i *KubeAPIServerInformers) GetInternalKubernetesInformers() kinternalinformers.SharedInformerFactory

func (*KubeAPIServerInformers) GetInternalOpenshiftImageInformers

func (i *KubeAPIServerInformers) GetInternalOpenshiftImageInformers() imageinformer.SharedInformerFactory

func (*KubeAPIServerInformers) GetInternalOpenshiftQuotaInformers

func (i *KubeAPIServerInformers) GetInternalOpenshiftQuotaInformers() quotainformer.SharedInformerFactory

func (*KubeAPIServerInformers) GetInternalOpenshiftSecurityInformers

func (i *KubeAPIServerInformers) GetInternalOpenshiftSecurityInformers() securityinformer.SharedInformerFactory

func (*KubeAPIServerInformers) GetKubernetesInformers

func (i *KubeAPIServerInformers) GetKubernetesInformers() kexternalinformers.SharedInformerFactory

func (*KubeAPIServerInformers) GetOpenshiftUserInformers

func (i *KubeAPIServerInformers) GetOpenshiftUserInformers() userinformer.SharedInformerFactory

func (*KubeAPIServerInformers) Start

func (i *KubeAPIServerInformers) Start(stopCh <-chan struct{})

type KubeAPIServerServerPatchContext

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

func NewOpenShiftKubeAPIServerConfigPatch

func NewOpenShiftKubeAPIServerConfigPatch(delegateAPIServer genericapiserver.DelegationTarget, kubeAPIServerConfig *configapi.KubeAPIServerConfig) (app.KubeAPIServerConfigFunc, *KubeAPIServerServerPatchContext)

func (*KubeAPIServerServerPatchContext) PatchServer

func (c *KubeAPIServerServerPatchContext) PatchServer(server *master.Master) error

type NonAPIExtraConfig

type NonAPIExtraConfig struct {
	OAuthMetadata []byte
}

type OpenshiftNonAPIConfig

type OpenshiftNonAPIConfig struct {
	GenericConfig *genericapiserver.RecommendedConfig
	ExtraConfig   NonAPIExtraConfig
}

func NewOpenshiftNonAPIConfig

func NewOpenshiftNonAPIConfig(generiConfig *genericapiserver.Config, kubeInformers informers.SharedInformerFactory, oauthConfig *configapi.OAuthConfig, authConfig configapi.MasterAuthConfig) (*OpenshiftNonAPIConfig, error)

func (*OpenshiftNonAPIConfig) Complete

func (c *OpenshiftNonAPIConfig) Complete() completedOpenshiftNonAPIConfig

Complete fills in any fields not set that are required to have valid data. It's mutating the receiver.

type OpenshiftNonAPIServer

type OpenshiftNonAPIServer struct {
	GenericAPIServer *genericapiserver.GenericAPIServer
}

OpenshiftNonAPIServer serves non-API endpoints for openshift.

type ServiceResolver

type ServiceResolver interface {
	ResolveEndpoint(namespace, name string) (*url.URL, error)
}

A ServiceResolver knows how to get a URL given a service.