models

Documentation

Index

• Constants
• func BodyToMessageBytesAnyHTTP(bodyType MessageBodyType, aReq anyhttp.Request) []byte
• func BodyToMessageBytesFastHTTP(bodyType MessageBodyType, ctx *fasthttp.RequestCtx) []byte
• func BodyToMessageBytesNetHTTP(bodyType MessageBodyType, req *http.Request) []byte
• func BuildAwsAPIGatewayProxyResponse(hookData HookData, errs ...ErrorInfo) (events.APIGatewayProxyResponse, error)
• func GetMapString2Simple(mapSS map[string]string, key string) string
• func GetMaxStatusCode(errs ...ErrorInfo) int
• type AwsAPIGatewayProxyOutput
• type ErrorInfo
  • func ErrorsInfoToResponseInfoOld(errs ...ErrorInfo) ErrorInfo
• type HookData
  • func HookDataFromAnyHTTPReq(bodyType MessageBodyType, aReq anyhttp.Request) HookData
  • func HookDataFromAwsLambdaEvent(bodyType MessageBodyType, awsReq events.APIGatewayProxyRequest) HookData
  • func HookDataFromEawsyLambdaEvent(bodyType MessageBodyType, eawsyReq *apigatewayproxyevt.Event) HookData
  • func HookDataFromFastHTTPReqCtx(bodyType MessageBodyType, ctx *fasthttp.RequestCtx) HookData
  • func HookDataFromNetHTTPReq(bodyType MessageBodyType, req *http.Request) HookData
• type MessageBodyType
• type RequestParams
• type ResponseInfo
  • func (ri *ResponseInfo) ToAPIGatewayProxyResponse() (events.APIGatewayProxyResponse, error)

Constants

const (
	QueryParamOutputAdapters = "adapters"
	QueryParamInputType      = "inputType"
	QueryParamOutputType     = "outputType"
	QueryParamToken          = "token"
	QueryParamOutputURL      = "url"
)

Functions

func BodyToMessageBytesAnyHTTP

func BodyToMessageBytesAnyHTTP(bodyType MessageBodyType, aReq anyhttp.Request) []byte

func BodyToMessageBytesFastHTTP

func BodyToMessageBytesFastHTTP(bodyType MessageBodyType, ctx *fasthttp.RequestCtx) []byte

func BodyToMessageBytesNetHTTP

func BodyToMessageBytesNetHTTP(bodyType MessageBodyType, req *http.Request) []byte

func BuildAwsAPIGatewayProxyResponse

func BuildAwsAPIGatewayProxyResponse(hookData HookData, errs ...ErrorInfo) (events.APIGatewayProxyResponse, error)

func GetMapString2Simple

func GetMapString2Simple(mapSS map[string]string, key string) string

func GetMaxStatusCode

func GetMaxStatusCode(errs ...ErrorInfo) int

Types

type AwsAPIGatewayProxyOutput

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

type ErrorInfo

type ErrorInfo struct {
	StatusCode int
	Body       []byte
}

func ErrorsInfoToResponseInfoOld

func ErrorsInfoToResponseInfoOld(errs ...ErrorInfo) ErrorInfo

type HookData

type HookData struct {
	InputType        string     `json:"inputType,omitempty"`
	InputBody        []byte     `json:"inputBody,omitempty"`
	OutputType       string     `json:"outputType,omitempty"`
	OutputURL        string     `json:"outputUrl,omitempty"`
	OutputNames      []string   `json:"outputNames,omitempty"`
	Token            string     `json:"token,omitempty"`
	InputMessage     []byte     `json:"inputMessage,omitempty"`
	CanonicalMessage cc.Message `json:"canonicalMessage,omitempty"`
}

func HookDataFromAnyHTTPReq

func HookDataFromAnyHTTPReq(bodyType MessageBodyType, aReq anyhttp.Request) HookData

func HookDataFromAwsLambdaEvent

func HookDataFromAwsLambdaEvent(bodyType MessageBodyType, awsReq events.APIGatewayProxyRequest) HookData

func HookDataFromEawsyLambdaEvent

func HookDataFromEawsyLambdaEvent(bodyType MessageBodyType, eawsyReq *apigatewayproxyevt.Event) HookData

func HookDataFromFastHTTPReqCtx

func HookDataFromFastHTTPReqCtx(bodyType MessageBodyType, ctx *fasthttp.RequestCtx) HookData

func HookDataFromNetHTTPReq

func HookDataFromNetHTTPReq(bodyType MessageBodyType, req *http.Request) HookData

type MessageBodyType

type MessageBodyType int

const (
	JSON MessageBodyType = iota
	URLEncoded
	URLEncodedJSONPayload
	URLEncodedJSONPayloadOrJSON
)

type RequestParams

type RequestParams struct {
	InputType  string `url:"inputType"`
	OutputType string `url:"outputType"`
	Token      string `url:"token"`
	URL        string `url:"url"`
}

type ResponseInfo

type ResponseInfo struct {
	HookData   HookData    `json:"hookData,omitempty"`
	Responses  []ErrorInfo `json:"responses,omitempty"`
	StatusCode int         `json:"statusCode,omitempty"`
}

func (*ResponseInfo) ToAPIGatewayProxyResponse

func (ri *ResponseInfo) ToAPIGatewayProxyResponse() (events.APIGatewayProxyResponse, error)