server

Documentation

Index

• func ListNamespaces(defaultNamespace string, clientset kubernetes.Interface) []string
• func MakeNamespacesLister(defaultNamespace string, clusterRole bool, clientset kubernetes.Interface) http.HandlerFunc
• func NewHandlerFunc(config types.FaaSConfig, resolver *k8s.FunctionLookup, ...) http.HandlerFunc
• func NewProxyClient(timeout time.Duration, maxIdleConns int, maxIdleConnsPerHost int) *http.Client
• func NewProxyClientFromConfig(config types.FaaSConfig) *http.Client
• type NamespaceResolver
  • func NewNamsespaceResolver(defaultNamespace string, kube kubernetes.Interface) NamespaceResolver
• type Server
  • func New(client clientset.Interface, kube kubernetes.Interface, ...) *Server
  • func (s *Server) Start()

Functions

func ListNamespaces

func ListNamespaces(defaultNamespace string, clientset kubernetes.Interface) []string

func MakeNamespacesLister

func MakeNamespacesLister(defaultNamespace string, clusterRole bool, clientset kubernetes.Interface) http.HandlerFunc

func NewHandlerFunc

func NewHandlerFunc(config types.FaaSConfig, resolver *k8s.FunctionLookup, kube clientset.Interface) http.HandlerFunc

func NewProxyClient

func NewProxyClient(timeout time.Duration, maxIdleConns int, maxIdleConnsPerHost int) *http.Client

NewProxyClient creates a new http.Client designed for proxying requests, this is exposed as a convenience method for internal or advanced uses. Most people should use NewProxyClientFromConfig.

func NewProxyClientFromConfig

func NewProxyClientFromConfig(config types.FaaSConfig) *http.Client

NewProxyClientFromConfig creates a new http.Client designed for proxying requests and enforcing certain minimum configuration values.

Types

type NamespaceResolver

type NamespaceResolver func(r *http.Request) (namspace string, err error)

func NewNamsespaceResolver

func NewNamsespaceResolver(defaultNamespace string, kube kubernetes.Interface) NamespaceResolver

type Server

type Server struct {
	BootstrapHandlers *types.FaaSHandlers
	BootstrapConfig   *types.FaaSConfig
}

func New

func New(client clientset.Interface,
	kube kubernetes.Interface,
	podInformer coreinformer.PodInformer,
	sharepodLister lister.SharePodLister,
	clusterRole bool,
	sharepodLookup *k8s.FunctionLookup,
	cfg config.BootstrapConfig) *Server

New created HTTP server struct

func (*Server) Start

func (s *Server) Start()