server

Documentation

Index

• func CreateAggregatorConfig(sharedConfig genericapiserver.Config, ...) (*aggregatorapiserver.Config, error)
• func CreateAggregatorServer(aggregatorConfig *aggregatorapiserver.Config, ...) (*aggregatorapiserver.APIAggregator, error)
• func CreateExtensions(opts *Options, endpointConfig endpoint.ETCDConfig) (genericapiserver.Config, genericoptions.EtcdOptions, ...)
• func RunAggregator(server *aggregatorapiserver.APIAggregator, stopCh <-chan struct{}) error
• type HoHApiServer
  • func NewHoHApiServer(opts *Options, client dynamic.Interface, hostedConfig *rest.Config) *HoHApiServer
  • func (s *HoHApiServer) AddPostStartHook(name string, hook genericapiserver.PostStartHookFunc)
  • func (s *HoHApiServer) AddPreShutdownHook(name string, hook genericapiserver.PreShutdownHookFunc)
  • func (s *HoHApiServer) CreateCache(ctx context.Context) error
  • func (s *HoHApiServer) InstallCRDController(ctx context.Context, config *rest.Config) error
  • func (s *HoHApiServer) InstallPlacementBindingController(ctx context.Context, config *rest.Config) error
  • func (s *HoHApiServer) InstallPlacementRuleController(ctx context.Context, config *rest.Config) error
  • func (s *HoHApiServer) InstallPolicyController(ctx context.Context, config *rest.Config) error
  • func (s *HoHApiServer) RunHoHApiServer(ctx context.Context) error
• type Options
  • func NewOptions() *Options
  • func (o *Options) AddFlags(fs *pflag.FlagSet)

Functions

func CreateAggregatorConfig

func CreateAggregatorConfig(sharedConfig genericapiserver.Config, sharedEtcdOptions genericoptions.EtcdOptions) (*aggregatorapiserver.Config, error)

func CreateAggregatorServer

func CreateAggregatorServer(aggregatorConfig *aggregatorapiserver.Config, delegateAPIServer genericapiserver.DelegationTarget, apiExtensionInformers apiextensionsinformers.SharedInformerFactory) (*aggregatorapiserver.APIAggregator, error)

func CreateExtensions

func CreateExtensions(opts *Options, endpointConfig endpoint.ETCDConfig) (genericapiserver.Config, genericoptions.EtcdOptions, *apiextensionsapiserver.CustomResourceDefinitions, error)

CreateExtensions creates the Exensions Server.

func RunAggregator

func RunAggregator(server *aggregatorapiserver.APIAggregator, stopCh <-chan struct{}) error

RunAggregator runs the API Aggregator.

Types

type HoHApiServer

type HoHApiServer struct {

	// contains caches
	Cache cache.Cache
	// contains filtered or unexported fields
}

func NewHoHApiServer

func NewHoHApiServer(opts *Options, client dynamic.Interface,
	hostedConfig *rest.Config) *HoHApiServer

func (*HoHApiServer) AddPostStartHook

func (s *HoHApiServer) AddPostStartHook(name string, hook genericapiserver.PostStartHookFunc)

AddPostStartHook allows you to add a PostStartHook that gets passed to the underlying genericapiserver implementation.

func (*HoHApiServer) AddPreShutdownHook

func (s *HoHApiServer) AddPreShutdownHook(name string, hook genericapiserver.PreShutdownHookFunc)

AddPreShutdownHook allows you to add a PreShutdownHookFunc that gets passed to the underlying genericapiserver implementation.

func (*HoHApiServer) CreateCache

func (s *HoHApiServer) CreateCache(ctx context.Context) error

func (*HoHApiServer) InstallCRDController

func (s *HoHApiServer) InstallCRDController(ctx context.Context, config *rest.Config) error

func (*HoHApiServer) InstallPlacementBindingController

func (s *HoHApiServer) InstallPlacementBindingController(ctx context.Context, config *rest.Config) error

func (*HoHApiServer) InstallPlacementRuleController

func (s *HoHApiServer) InstallPlacementRuleController(ctx context.Context, config *rest.Config) error

func (*HoHApiServer) InstallPolicyController

func (s *HoHApiServer) InstallPolicyController(ctx context.Context, config *rest.Config) error

func (*HoHApiServer) RunHoHApiServer

func (s *HoHApiServer) RunHoHApiServer(ctx context.Context) error

RunHoHApiServer starts a new HoHApiServer.

type Options

type Options struct {
	KubeConfigFile string
	ServerRun      *genericapiserveroptions.ServerRunOptions
	SecureServing  *genericapiserveroptions.SecureServingOptionsWithLoopback
	Authentication *genericapiserveroptions.DelegatingAuthenticationOptions
	Authorization  *genericapiserveroptions.DelegatingAuthorizationOptions
}

func NewOptions

func NewOptions() *Options

func (*Options) AddFlags

func (o *Options) AddFlags(fs *pflag.FlagSet)