server

Documentation

Index

• func GetConfig(kubeConfig string) (clientcmd.ClientConfig, error)
• func SetupLocalHandler(server *EdgeServer) http.Handler
• func Wait(ctx context.Context, config rest.Config) error
• type Config
• type EdgeServer
  • func New(ctx context.Context, clientConfig clientcmd.ClientConfig, cfg *Config) (*EdgeServer, error)
  • func (s *EdgeServer) ListenAndServe(ctx context.Context) error

Functions

func GetConfig

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

func SetupLocalHandler

func SetupLocalHandler(server *EdgeServer) http.Handler

func Wait

func Wait(ctx context.Context, config rest.Config) error

Types

type Config

type Config struct {
	Namespace       string
	Threadiness     int
	HTTPListenPort  int
	HTTPSListenPort int
}

type EdgeServer

type EdgeServer struct {
	*server.Controllers

	Config        Config
	RestConfig    *restclient.Config
	DynamicClient dynamic.Interface
	ClientSet     *kubernetes.Clientset
	Context       context.Context
	Handler       http.Handler
	ASL           accesscontrol.AccessSetLookup
}

func New

func New(ctx context.Context, clientConfig clientcmd.ClientConfig, cfg *Config) (*EdgeServer, error)

func (*EdgeServer) ListenAndServe

func (s *EdgeServer) ListenAndServe(ctx context.Context) error