httptrigger

Documentation

Index

• Constants
• type Operator
  • func NewOperator(ctx context.Context, cfg *rest.Config, rclient rfcli.Interface, ...) (*Operator, error)
  • func (r *Operator) Run(stopC <-chan struct{})
• type RequestContext
• type RequestContextHTTP
• type RequestPayload
• type ResponsePayload

Constants

const DefaultRequestReadTimeout = 9 * time.Second

DefaultRequestReadTimeout for http server

const Type = "httptrigger"

Type name for http trigger

Types

type Operator

type Operator struct {
	*operators.BaseOperator

	// Config cors for http endpoints
	CORS struct {
		AllowedMethods []string
		AllowedHeaders []string
		AllowedOrigins []string
		ExposedHeaders []string

		MaxAge           int
		AllowCredentials bool
	}
	// contains filtered or unexported fields
}

Operator creates http based http trigger automatically for every funcs

func NewOperator

func NewOperator(
	ctx context.Context,
	cfg *rest.Config,
	rclient rfcli.Interface,
	rfInformers informers.SharedInformerFactory,
) (*Operator, error)

NewOperator creates a new http trigger operator

func (*Operator) Run

func (r *Operator) Run(stopC <-chan struct{})

Run will not return until stopC is closed.

type RequestContext

type RequestContext struct {
	DomainName string             `json:"domainName"`
	HTTP       RequestContextHTTP `json:"http"`
	RequestID  string             `json:"requestId"`
}

type RequestContextHTTP

type RequestContextHTTP struct {
	Method    string `json:"method"`
	Path      string `json:"path"`
	Protocol  string `json:"protocol"`
	SourceIP  string `json:"sourceIp"`
	UserAgent string `json:"userAgent"`
}

type RequestPayload

type RequestPayload struct {
	Version               string            `json:"version"`
	RawPath               string            `json:"rawPath"`
	RawQueryString        string            `json:"rawQueryString"`
	Cookies               []string          `json:"cookies"`
	Headers               map[string]string `json:"headers"`
	QueryStringParameters map[string]string `json:"queryStringParameters"`
	PathParameters        map[string]string `json:"pathParameters"`
	IsBase64Encoded       bool              `json:"isBase64Encoded"`
	Body                  string            `json:"body"`
	Context               RequestContext    `json:"requestContext"`
}

type ResponsePayload

type ResponsePayload struct {
	StatusCode      int               `json:"statusCode"`
	Headers         map[string]string `json:"headers"`
	Body            string            `json:"body"`
	Cookies         []string          `json:"cookies"`
	IsBase64Encoded bool              `json:"isBase64Encoded"`
}