gonvoy

package module

Go to main page

Versions in this module

v0

v0.4.0

Sep 16, 2024

Changes in this version

+ const MIMEApplicationGRPC

+ var ErrAccessDenied = errors.New("Access Denied")

+ var ErrBadRequest = errors.New("Bad Request")

+ var ErrClientClosedRequest = errors.New("Client Closed Request")

+ var ErrIncompatibleReceiver = errors.New("receiver and value has an incompatible type")

+ var ErrInternalServer = errors.New("Internal Server Error")

+ var ErrNilReceiver = errors.New("receiver shouldn't be nil")

+ var ErrOperationNotPermitted = errors.New("operation not permitted")

+ var ErrRuntime = errors.New("an unexpected runtime error occurred")

+ var ErrUnauthorized = errors.New("Unauthorized")

type ConfigOptions

+ AutoReloadRoute bool

+ DisableChunkedEncodingRequest bool

+ DisableChunkedEncodingResponse bool

+ MetricsPrefix string

type HttpFilterAction

+ const ActionWait

type HttpFilterContext

+ IsRequestBodyAccessible func() bool

+ IsRequestBodyWritable func() bool

+ IsResponseBodyAccessible func() bool

+ IsResponseBodyWritable func() bool

+ LoadRequestBody func(buffer api.BufferInstance, endStream bool)

+ LoadRequestHeaders func(api.RequestHeaderMap)

+ LoadResponseBody func(buffer api.BufferInstance, endStream bool)

+ LoadResponseHeaders func(api.ResponseHeaderMap)

+ ReloadRoute func()

+ SendResponse func(code int, bodyText string, opts ...LocalReplyOption) error

+ SetRequestHost func(host string)

+ SetRequestMethod func(method string)

+ SetRequestPath func(path string)

+ type HttpFilterFactory func() HttpFilter

type HttpFilterServer

+ Complete func()

+ type LocalReplyOption func(o *LocalReplyOptions)

+ func LocalReplyWithGRPCStatus(status int64) LocalReplyOption

+ func LocalReplyWithHTTPHeaders(headers http.Header) LocalReplyOption

+ func LocalReplyWithRCDetails(detail string) LocalReplyOption

+ func LocalReplyWithStatusType(status api.StatusType) LocalReplyOption

+ type LocalReplyOptions struct

+ func NewLocalReplyOptions(opts ...LocalReplyOption) *LocalReplyOptions

v0.3.5

Aug 5, 2024

v0.3.4

Aug 3, 2024

v0.3.3

May 28, 2024

Changes in this version

type Header

+ Export func() http.Header

+ Import func(headers http.Header)

v0.3.2

May 27, 2024

retracted

Changes in this version

type Header

+ Replace func(headers http.Header)

+ ToHeaders func() http.Header

v0.3.1

May 27, 2024

Changes in this version

+ const MIMEApplicationForm

+ const MIMEApplicationJSON

+ const MIMEApplicationJSONCharsetUTF8

+ const MIMEApplicationMsgpack

+ const MIMEApplicationProtobuf

+ const MIMEApplicationXML

+ const MIMEApplicationXMLCharsetUTF8

+ const MIMEMultipartForm

+ const MIMEOctetStream

+ const MIMETextHTML

+ const MIMETextHTMLCharsetUTF8

+ const MIMETextPlain

+ const MIMETextPlainCharsetUTF8

+ const MIMETextXML

+ const MIMETextXMLCharsetUTF8

+ const XRequestBodyAccessOff

+ const XResponseBodyAccessOff

type ConfigOptions

+ FilterConfig interface{}

type Context

+ func NewContext(cb api.FilterCallbacks, opts ...ContextOption) (Context, error)

type RuntimeContext

+ GetCache func() Cache

v0.3.0

May 17, 2024

Changes in this version

+ const ContentOperationRO

+ const ContentOperationRW

+ const ContentOperationReadOnly

+ const ContentOperationReadWrite

+ const HeaderContentLength

+ const HeaderContentType

+ const HeaderXContentOperation

+ const HeaderXRequestBodyAccess

+ const HeaderXResponseBodyAccess

+ const ValueXRequestBodyAccessOff

+ const ValueXResponseBodyAccessOff

+ var DefaultResponseCodeDetailAccessDenied = ResponseCodeDetailPrefix("goext_access_denied")

+ var DefaultResponseCodeDetailError = ResponseCodeDetailPrefix("goext_error")

+ var DefaultResponseCodeDetailInfo = ResponseCodeDetailPrefix("goext_info")

+ var DefaultResponseCodeDetailUnauthorized = ResponseCodeDetailPrefix("goext_unauthorized")

+ var DefaultResponseCodeDetails = DefaultResponseCodeDetailInfo.Wrap("via_Go_extension")

+ var NoOpHttpFilter = &api.PassThroughStreamFilter

+ var ResponseForbidden = NewMinimalJSONResponse("FORBIDDEN", "FORBIDDEN")

+ var ResponseInternalServerError = NewMinimalJSONResponse("RUNTIME_ERROR", "RUNTIME_ERROR")

+ var ResponseServiceUnavailable = NewMinimalJSONResponse("SERVICE_UNAVAILABLE", "SERVICE_UNAVAILABLE")

+ var ResponseTooManyRequest = NewMinimalJSONResponse("TOO_MANY_REQUEST", "TOO_MANY_REQUEST")

+ var ResponseUnauthorized = NewMinimalJSONResponse("UNAUTHORIZED", "UNAUTHORIZED")

+ func DefaultErrorHandler(c Context, err error) api.StatusType

+ func DefaultRender(keysAndValues []interface{}) []interface

+ func MustGetProperty(c RuntimeContext, name, defaultVal string) string

+ func NewGatewayHeaders(keysAndValues ...string) http.Header

+ func NewGatewayHeadersWithEnvoyHeader(envoyheader Header, keysAndValues ...string) http.Header

+ func NewMinimalJSONResponse(code, message string, errs ...error) []byte

+ func RunHttpFilter(filter HttpFilter, options ConfigOptions)

+ type Body interface

+ Bytes func() []byte

+ String func() string

+ WriteString func(s string) (n int, err error)

+ type Cache interface

+ Load func(key, receiver any) (ok bool, err error)

+ Store func(key, value any)

+ type ConfigOptions struct

+ AlwaysUseChildConfig bool

+ BaseConfig interface{}

+ DisableStrictBodyAccess bool

+ EnableRequestBodyRead bool

+ EnableRequestBodyWrite bool

+ EnableResponseBodyRead bool

+ EnableResponseBodyWrite bool

+ IgnoreMergeError bool

+ MetricPrefix string

+ type Context interface

+ Committed func() bool

+ StatusType func() api.StatusType

+ type ContextOption func(c *context) error

+ func WithContextConfig(cfg *globalConfig) ContextOption

+ func WithContextLogger(logger logr.Logger) ContextOption

+ type ErrorHandler func(Context, error) api.StatusType

+ type Header interface

+ AsMap func() map[string][]string

+ type HttpFilter interface

+ Name func() string

+ OnBegin func(c RuntimeContext, ctrl HttpFilterController) error

+ OnComplete func(c Context) error

+ type HttpFilterAction uint

+ const ActionContinue

+ const ActionPause

+ const ActionSkip

+ type HttpFilterCompletionFunc func()

+ type HttpFilterContext interface

+ IsRequestBodyReadable func() bool

+ IsRequestBodyWriteable func() bool

+ IsResponseBodyReadable func() bool

+ IsResponseBodyWriteable func() bool

+ JSON func(code int, b []byte, header http.Header, opts ...ReplyOption) error

+ Request func() *http.Request

+ RequestBody func() Body

+ RequestHeader func() Header

+ Response func() *http.Response

+ ResponseBody func() Body

+ ResponseHeader func() Header

+ SetRequestBody func(api.BufferInstance)

+ SetRequestHeader func(api.RequestHeaderMap)

+ SetResponseBody func(api.BufferInstance)

+ SetResponseHeader func(api.ResponseHeaderMap)

+ SkipNextPhase func() error

+ String func(code int, s string, header http.Header, opts ...ReplyOption) error

+ type HttpFilterController interface

+ AddHandler func(handler HttpFilterHandler)

+ SetErrorHandler func(handler ErrorHandler)

+ type HttpFilterDecodeProcessor interface

+ HandleOnRequestBody func(Context) error

+ HandleOnRequestHeader func(Context) error

+ type HttpFilterDecoderFunc func(Context, HttpFilterDecodeProcessor) (HttpFilterAction, error)

+ type HttpFilterEncodeProcessor interface

+ HandleOnResponseBody func(Context) error

+ HandleOnResponseHeader func(Context) error

+ type HttpFilterEncoderFunc func(Context, HttpFilterEncodeProcessor) (HttpFilterAction, error)

+ type HttpFilterHandler interface

+ Disable func() bool

+ OnRequestBody func(c Context, body []byte) error

+ OnRequestHeader func(c Context, header http.Header) error

+ OnResponseBody func(c Context, body []byte) error

+ OnResponseHeader func(c Context, header http.Header) error

+ type HttpFilterProcessor interface

+ SetNext func(HttpFilterProcessor)

+ SetPrevious func(HttpFilterProcessor)

+ type HttpFilterResult struct

+ Action HttpFilterAction

+ Err error

+ Status api.StatusType

+ func (res *HttpFilterResult) Finalize(c Context, errorHandler ErrorHandler)

+ type HttpFilterServer interface

+ Finalize func()

+ ServeDecodeFilter func(HttpFilterDecoderFunc) *HttpFilterResult

+ ServeEncodeFilter func(HttpFilterEncoderFunc) *HttpFilterResult

+ type Metrics interface

+ Counter func(name string, labelKeyValues ...string) api.CounterMetric

+ Gauge func(name string, labelKeyValues ...string) api.GaugeMetric

+ Histogram func(name string, labelKeyValues ...string) api.HistogramMetric

+ type PassthroughHttpFilterHandler struct

+ func (PassthroughHttpFilterHandler) Disable() bool

+ func (PassthroughHttpFilterHandler) OnRequestBody(c Context, body []byte) error

+ func (PassthroughHttpFilterHandler) OnRequestHeader(c Context, header http.Header) error

+ func (PassthroughHttpFilterHandler) OnResponseBody(c Context, body []byte) error

+ func (PassthroughHttpFilterHandler) OnResponseHeader(c Context, header http.Header) error

+ type ReplyOption func(o *ReplyOptions)

+ func WithGrpcStatus(status int64) ReplyOption

+ func WithResponseCodeDetails(detail string) ReplyOption

+ func WithStatusType(status api.StatusType) ReplyOption

+ type ReplyOptions struct

+ func NewDefaultReplyOptions() *ReplyOptions

+ type ResponseCodeDetailPrefix string

+ func (prefix ResponseCodeDetailPrefix) Wrap(message string) string

+ type RuntimeContext interface

+ GetFilterConfig func() interface{}

+ GetProperty func(name, defaultVal string) (string, error)

+ GlobalCache func() Cache

+ LocalCache func() Cache

+ Log func() logr.Logger

+ Metrics func() Metrics

+ StreamInfo func() api.StreamInfo

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL