clusterregistry

Documentation

Overview

Package clusterregistry contains the meat of the implementation for k8s.io/cluster-registry/cmd/clusterregistry consisting of functions to support the cluster registry subcommands and to launch the API server.

Index

• func CreateServer(s options.Options) (*genericapiserver.GenericAPIServer, error)
• func NewClusterRegistryCommand(out io.Writer) *cobra.Command
• func NewCmdAggregated(cmdOut io.Writer, pathOptions *clientcmd.PathOptions) *cobra.Command
• func NewCmdStandalone(cmdOut io.Writer, pathOptions *clientcmd.PathOptions) *cobra.Command
• func NonBlockingRun(s options.Options, stopCh <-chan struct{}) error
• func Run(s options.Options, stopCh <-chan struct{}) error

Functions

func CreateServer

func CreateServer(s options.Options) (*genericapiserver.GenericAPIServer, error)

CreateServer creates a cluster registry API server.

func NewClusterRegistryCommand

func NewClusterRegistryCommand(out io.Writer) *cobra.Command

NewClusterRegistryCommand creates the 'clusterregistry' command.

func NewCmdAggregated

func NewCmdAggregated(cmdOut io.Writer, pathOptions *clientcmd.PathOptions) *cobra.Command

NewCmdAggregated defines the 'aggregated' subcommand that runs the cluster registry as a Kubernetes aggregated API server.

func NewCmdStandalone

func NewCmdStandalone(cmdOut io.Writer, pathOptions *clientcmd.PathOptions) *cobra.Command

NewCmdStandalone defines the 'standalone' subcommand that runs the cluster registry using the Kubernetes aggregator.

func NonBlockingRun

func NonBlockingRun(s options.Options, stopCh <-chan struct{}) error

NonBlockingRun runs the cluster registry API server and configures it to stop with the given channel.

func Run

func Run(s options.Options, stopCh <-chan struct{}) error

Run runs the cluster registry API server. It only returns if stopCh is closed or one of the ports cannot be listened on initially.