singleton

Documentation

Index

• Variables
• func InitGenericAPIServer(server *builder.GenericAPIServer) *builder.GenericAPIServer
• func InitServerConfig(config *server.RecommendedConfig) *server.RecommendedConfig
• func ReloadClients()
• type Singleton
  • func NewSingleton[T any](loader func() T) *Singleton[T]
  • func NewSingletonE[T any](loaderE func() (T, error)) *Singleton[T]
  • func (in *Singleton[T]) Get() T
  • func (in *Singleton[T]) Reload()
  • func (in *Singleton[T]) Set(data T)

Variables

var APIServerConfig = NewSingleton[*server.Config](nil)

APIServerConfig the global server.Config for APIServer to use

var DynamicClient = NewSingletonE[dynamic.Interface](func() (dynamic.Interface, error) {
	return dynamic.NewForConfig(KubeConfig.Get())
})

DynamicClient .

var GenericAPIServer = NewSingleton[*builder.GenericAPIServer](nil)

GenericAPIServer .

var KubeClient = NewSingletonE[client.Client](func() (client.Client, error) {
	return client.New(KubeConfig.Get(), client.Options{
		Scheme: scheme.Scheme,
		Mapper: RESTMapper.Get(),
	})
})

KubeClient .

var KubeConfig = NewSingleton[*rest.Config](func() *rest.Config {
	cfg := config.GetConfigOrDie()
	cfg.UserAgent = UserAgent.Get()
	return cfg
})

KubeConfig .

var RESTMapper = NewSingletonE[meta.RESTMapper](func() (meta.RESTMapper, error) {
	return apiutil.NewDiscoveryRESTMapper(KubeConfig.Get())
})

RESTMapper .

var StaticClient = NewSingletonE[kubernetes.Interface](func() (kubernetes.Interface, error) {
	return kubernetes.NewForConfig(KubeConfig.Get())
})

StaticClient .

var UserAgent = NewSingleton[string](nil)

UserAgent .

Functions

func InitGenericAPIServer

func InitGenericAPIServer(server *builder.GenericAPIServer) *builder.GenericAPIServer

InitGenericAPIServer load the global unique GenericAPIServer

func InitServerConfig

func InitServerConfig(config *server.RecommendedConfig) *server.RecommendedConfig

InitServerConfig initialize APIServerConfig

func ReloadClients

func ReloadClients()

ReloadClients should be called when KubeConfig is called to update related clients

Types

type Singleton

type Singleton[T any] struct {
	// contains filtered or unexported fields
}

Singleton global unique data struct

func NewSingleton

func NewSingleton[T any](loader func() T) *Singleton[T]

NewSingleton create a new singleton with loader

func NewSingletonE

func NewSingletonE[T any](loaderE func() (T, error)) *Singleton[T]

NewSingletonE create a new singleton with error-returned loader

func (*Singleton[T]) Get

func (in *Singleton[T]) Get() T

Get retrieve underlying data, if not initialized, will trigger initialization

func (*Singleton[T]) Reload

func (in *Singleton[T]) Reload()

Reload trigger loader

func (*Singleton[T]) Set

func (in *Singleton[T]) Set(data T)

Set write the underlying data