router

Documentation

Index

• Constants
• func HeadersToMetadata(prefix string, headers http.Header) *metav1.ObjectMeta
• func MetadataToHeaders(prefix string, meta *metav1.ObjectMeta, request *http.Request)
• func NewMutableRouter(handler *mux.Router) *mutableRouter
• func Start(port int, executorUrl string)
• type HTTPTriggerSet
  • func (mr HTTPTriggerSet) ServeHTTP(responseWriter http.ResponseWriter, request *http.Request)
• type RetryingRoundTripper
  • func (rrt RetryingRoundTripper) RoundTrip(req *http.Request) (*http.Response, error)

Constants

const (
	HEADERS_FISSION_FUNCTION_PREFIX = "Fission-Function"
)

Functions

func HeadersToMetadata

func HeadersToMetadata(prefix string, headers http.Header) *metav1.ObjectMeta

func MetadataToHeaders

func MetadataToHeaders(prefix string, meta *metav1.ObjectMeta, request *http.Request)

func NewMutableRouter

func NewMutableRouter(handler *mux.Router) *mutableRouter

func Start

func Start(port int, executorUrl string)

Types

type HTTPTriggerSet

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

func (HTTPTriggerSet) ServeHTTP

func (mr HTTPTriggerSet) ServeHTTP(responseWriter http.ResponseWriter, request *http.Request)

type RetryingRoundTripper

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

A layer on top of http.DefaultTransport, with retries.

func (RetryingRoundTripper) RoundTrip

func (rrt RetryingRoundTripper) RoundTrip(req *http.Request) (*http.Response, error)