server

Documentation

Index

• Constants
• func GetConfig(kubeConfig string) (clientcmd.ClientConfig, error)
• func WaitingWebhooks(ctx context.Context, clientSet *kubernetes.Clientset, releaseName string) error
• type APIServer
  • func NewServer(opts sconfig.Options) (*APIServer, error)
  • func (s *APIServer) ListenAndServe(opts sconfig.Options, listenOpts *dlserver.ListenOpts) error
• type PostStartHook
• type Router
  • func NewRouter(mgmt *config.Scaled) *Router
  • func (r *Router) Routes() http.Handler
• type StartHook

Constants

const (
	PollingInterval = 5 * time.Second
	PollingTimeout  = 2 * time.Minute
)

Functions

func GetConfig

func GetConfig(kubeConfig string) (clientcmd.ClientConfig, error)

func WaitingWebhooks

func WaitingWebhooks(ctx context.Context, clientSet *kubernetes.Clientset, releaseName string) error

WaitingWebhooks waits for the admission webhook server to registered successfully.

Types

type APIServer

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

func NewServer

func NewServer(opts sconfig.Options) (*APIServer, error)

func (*APIServer) ListenAndServe

func (s *APIServer) ListenAndServe(opts sconfig.Options, listenOpts *dlserver.ListenOpts) error

type PostStartHook

type PostStartHook func(int) error

type Router

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

func NewRouter

func NewRouter(mgmt *config.Scaled) *Router

func (*Router) Routes

func (r *Router) Routes() http.Handler

Routes adds additional customize routes to the default router

type StartHook

type StartHook func(context.Context, *steve.Controllers, sconfig.Options) error