envoy

package module

Go to main page

Versions in this module

v0

v0.2.0

May 3, 2024

Changes in this version

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

+ var NoOpFilter = &api.PassThroughStreamFilter

+ var ResponseCodeDetailPrefix_AccessDenied = ResponseCodeDetailPrefix("goext_access_denied")

+ var ResponseCodeDetailPrefix_Error = ResponseCodeDetailPrefix("goext_error")

+ var ResponseCodeDetailPrefix_Info = ResponseCodeDetailPrefix("goext_info")

+ var ResponseCodeDetailPrefix_Unauthorized = ResponseCodeDetailPrefix("goext_unauthorized")

+ 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 Clone(in interface{}) interface

+ func MustGetProperty(c Context, 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 ReplaceAllEmptySpace(s string) string

+ func RunHttpFilter(filter HttpFilter, cfg interface{})

+ type BufferWriter interface

+ Bytes func() []byte

+ String func() string

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

+ type Configuration interface

+ GetConfigCallbacks func() api.ConfigCallbacks

+ GetFilterConfig func() interface{}

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

+ Store func(key any, value any)

type Context

+ Configuration func() Configuration

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

+ Metrics func() Metrics

+ RequestBodyWriter func() BufferWriter

+ ResponseBodyWriter func() BufferWriter

+ SetRequestBody func(api.BufferInstance)

+ SetRequestHeader func(api.RequestHeaderMap)

+ SetResponseBody func(api.BufferInstance)

+ SetResponseHeader func(api.ResponseHeaderMap)

+ type ContextOption func(c *context) error

+ func WithFilterConfiguration(cfg Configuration) ContextOption

+ type HttpFilter interface

+ Handlers func(c Context) []HttpFilterHandler

+ Name func() string

+ OnComplete func(c Context)

+ OnStart func(c Context)

+ 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 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

+ func NewMetrics(config Configuration) Metrics

+ 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 ReplyOptions

+ func NewDefaultReplyOptions() *ReplyOptions

+ type ResponseCodeDetailPrefix string

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

v0.1.1

Nov 8, 2023

Changes in this version

+ func CastTo(target interface{}, value interface{}) bool

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

+ func NewLogger(callback api.FilterCallbacks) logr.Logger

type Context

+ func NewContext(callback api.FilterCallbacks) (Context, error)

+ Committed func() bool

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

+ Request func() *http.Request

+ RequestHeader func() Header

+ Response func() *http.Response

+ ResponseHeader func() Header

+ SetRequest func(api.RequestHeaderMap)

+ SetResponse func(api.ResponseHeaderMap)

+ Store func(key any, value any)

+ StreamInfo func() api.StreamInfo

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

+ type Handler func(next HandlerFunc) HandlerFunc

+ type HandlerFunc func(ctx Context) error

+ func HandlerDecorator(next HandlerFunc) HandlerFunc

+ type HandlerManager interface

+ Handle func(ctx Context) api.StatusType

+ Use func(handler Handler)

+ func NewManager() HandlerManager

+ func NewManagerWithErrorHandler(errHandler ErrorHandler) HandlerManager

type Header

+ AsMap func() map[string]string

+ type ReplyOption func(o *ReplyOptions)

+ func WithResponseCodeDetails(detail string) ReplyOption

+ type ReplyOptions struct

+ func GetDefaultReplyOptions() *ReplyOptions

v0.1.0

Oct 7, 2023

v0.0.2

Oct 7, 2023

v0.0.1

Oct 7, 2023

Changes in this version

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

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

+ func NewRequestHandler(ctx RequestContext) *requestHandler

+ func NewRequestHandlerWithErrorHandler(ctx RequestContext, errHandler ErrorHandler) *requestHandler

+ func NewResponseHandler(ctx ResponseContext) *responseHandler

+ func NewResponseHandlerWithErrorHandler(ctx ResponseContext, errHandler ErrorHandler) *responseHandler

+ func ToFlatHeader(header http.Header) map[string]string

+ type Context interface

+ JSON func(statusCode int, body []byte, headers map[string]string, ...) error

+ Log func(lvl LogLevel, msg string)

+ PlainText func(statusCode int, msg string, opts ...LocalReplyOption) error

+ StatusType func() api.StatusType

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

+ type Header interface

+ type LocalReplyOption func(o *LocalReplyOptions)

+ func WithGrpcStatus(status int64) LocalReplyOption

+ func WithLocalReplyDetail(detail string) LocalReplyOption

+ type LocalReplyOptions struct

+ func GetDefaultLocalReplyOptions() *LocalReplyOptions

+ type LogLevel api.LogType

+ const CriticalLevel

+ const DebugLevel

+ const ErrorLevel

+ const InfoLevel

+ const WarnLevel

+ type RequestContext interface

+ Host func() string

+ Method func() string

+ Path func() string

+ func NewRequestContext(header api.RequestHeaderMap, callback api.FilterCallbacks) (RequestContext, error)

+ type RequestHandler func(next RequestHandlerFunc) RequestHandlerFunc

+ type RequestHandlerFunc func(ctx RequestContext, req *http.Request) error

+ type ResponseContext interface

+ Status func() (int, bool)

+ func NewResponseContext(header api.ResponseHeaderMap, callback api.FilterCallbacks) (ResponseContext, error)

+ type ResponseHandler func(next ResponseHandlerFunc) ResponseHandlerFunc

+ type ResponseHandlerFunc func(ctx ResponseContext, res *http.Response) error

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