transports

Jan 15, 2024

Changes in this version

type ResponseWriter

+ ResetBody func()

type ResultResponseWriter

+ func (w *ResultResponseWriter) ResetBody()

Jan 14, 2024

Changes in this version

+ var DeprecatedHeaderName = []byte("X-Fns-Deprecated")

Jan 8, 2024

Changes in this version

+ func AddXU(header Header, name []byte, value []byte)

+ func GetXU(header Header, name []byte) (value []byte)

+ func SetXU(header Header, name []byte, value []byte)

+ func ValuesXU(header Header, name []byte) (value [][]byte)

Dec 23, 2023

Changes in this version

+ var ContentTypeTextHeaderValue = []byte("text/plain")

type AcceptEncodings

+ func (encodings AcceptEncodings) Add(name []byte, quality float64) AcceptEncodings

+ func (encodings AcceptEncodings) WriteTo(header Header)

type Marshal

+ func GetMarshaler(accepts AcceptEncodings) (v Marshal, contentType []byte)

Dec 22, 2023

Changes in this version

+ var ContentTypeAvroHeaderValue = []byte("application/avro")

+ type AcceptEncoding struct

+ Name []byte

+ Quality float64

+ type AcceptEncodings []AcceptEncoding

+ func GetAcceptEncodings(header Header) (encodings AcceptEncodings)

+ func (encodings AcceptEncodings) Get(name []byte) (quality float64, has bool)

+ func (encodings AcceptEncodings) Len() int

+ func (encodings AcceptEncodings) Less(i, j int) bool

+ func (encodings AcceptEncodings) Swap(i, j int)

+ type Marshal func(v any) (p []byte, err error)

type ResultResponseWriter

+ func (w *ResultResponseWriter) GetMarshal() (v Marshal)

Dec 17, 2023

Changes in this version

+ func ObjectParams(params Params) objects.Object

type Header

+ func NewHeader() Header

type ResultResponseWriter

+ func (w *ResultResponseWriter) Header() (h Header)

Nov 23, 2023

Changes in this version

+ func ConvertRequest(ctx Request, r *http.Request, forServer bool) error

+ func WithRequestHeader(ctx context.Context, header Header) context.Context

type Handler

+ func ConvertHttpHandler(h http.Handler) Handler

+ func ConvertHttpHandlerFunc(h http.HandlerFunc) Handler

type Request

+ RequestURI func() []byte

type TLSConfig

+ func FixedTLSConfig(conf ssl.Config) *TLSConfig

Nov 22, 2023

Changes in this version

type Request

+ FormValue func(name []byte) (value []byte)

type ResponseWriter

+ WriteDeadline func() time.Time

+ WriteTimeout func() time.Duration

type ResultResponseWriter

+ func (w *ResultResponseWriter) WriteDeadline() time.Time

+ func (w *ResultResponseWriter) WriteTimeout() time.Duration

Nov 22, 2023

Changes in this version

+ var AcceptEncodingHeaderName = []byte("Accept-Encoding")

+ var AcceptHeaderName = []byte("Accept")

+ var AccessControlAllowCredentialsHeaderName = []byte("Access-Control-Allow-Credentials")

+ var AccessControlAllowHeadersHeaderName = []byte("Access-Control-Allow-Headers")

+ var AccessControlAllowMethodsHeaderName = []byte("Access-Control-Allow-Methods")

+ var AccessControlAllowOriginHeaderName = []byte("Access-Control-Allow-Origin")

+ var AccessControlAllowPrivateNetworkHeaderName = []byte("Access-Control-Allow-Private-Network")

+ var AccessControlExposeHeadersHeaderName = []byte("Access-Control-Expose-Headers")

+ var AccessControlMaxAgeHeaderName = []byte("Access-Control-Max-Age")

+ var AccessControlRequestHeadersHeaderName = []byte("Access-Control-Request-Headers")

+ var AccessControlRequestMethodHeaderName = []byte("Access-Control-Request-Method")

+ var AccessControlRequestPrivateNetworkHeaderName = []byte("Access-Control-Request-Private-Network")

+ var AgeHeaderName = []byte("Age")

+ var AuthorizationHeaderName = []byte("Authorization")

+ var CacheControlHeaderIfNonMatch = []byte("If-None-Match")

+ var CacheControlHeaderName = []byte("Cache-Control")

+ var CacheControlHeaderNoCache = []byte("no-cache")

+ var CacheControlHeaderNoStore = []byte("no-store")

+ var ClearSiteDataHeaderName = []byte("Clear-Site-Data")

+ var CloseHeaderValue = []byte("close")

+ var ConnectionHeaderName = []byte("Connection")

+ var ContentEncodingHeaderName = []byte("Content-Encoding")

+ var ContentLengthHeaderName = []byte("Content-Length")

+ var ContentTypeHeaderName = []byte("Content-Type")

+ var ContentTypeJsonHeaderValue = []byte("application/json")

+ var CookieHeaderName = []byte("Cookie")

+ var DeviceIdHeaderName = []byte("X-Fns-Device-Id")

+ var DeviceIpHeaderName = []byte("X-Fns-Device-Ip")

+ var ETagHeaderName = []byte("ETag")

+ var EndpointIdHeaderName = []byte("X-Fns-Endpoint-Id")

+ var EndpointVersionHeaderName = []byte("X-Fns-Endpoint-Version")

+ var ErrTooBigRequestBody = errors.New(http.StatusRequestEntityTooLarge, "***TOO LARGE BODY***", ...)

+ var HandleLatencyHeaderName = []byte("X-Fns-Handle-Latency")

+ var MethodGet = []byte(http.MethodGet)

+ var MethodPost = []byte(http.MethodPost)

+ var OriginHeaderName = []byte("Origin")

+ var RequestIdHeaderName = []byte("X-Fns-Request-Id")

+ var RequestTimeoutHeaderName = []byte("X-Fns-Request-Timeout")

+ var RequestVersionsHeaderName = []byte("X-Fns-Request-Version")

+ var ResponseRetryAfterHeaderName = []byte("Retry-After")

+ var ResponseTimingAllowOriginHeaderName = []byte("Timing-Allow-Origin")

+ var ResponseXFrameOptionsSameOriginHeaderName = []byte("SAMEORIGIN")

+ var SignatureHeaderName = []byte("X-Fns-Signature")

+ var TrueClientIpHeaderName = []byte("True-Client-Ip")

+ var UpgradeHeaderName = []byte("Upgrade")

+ var UserHeaderNamePrefix = []byte("XU-")

+ var VaryHeaderName = []byte("Vary")

+ var XForwardedForHeaderName = []byte("X-Forwarded-For")

+ var XRealIpHeaderName = []byte("X-Real-IP")

+ var XRequestedWithHeaderName = []byte("X-Requested-With")

+ func DecodeParams(params Params, dst interface{}) (err error)

+ func DeviceIp(ctx context.Context) (ip []byte)

+ func ParamsScanner(params Params) scanner.Scanner

+ func ReleaseCookie(c *Cookie)

+ func ReleaseHeader(h Header)

+ func ReleaseResultResponseWriter(w *ResultResponseWriter)

+ func WithRequest(ctx context.Context, r Request) context.Context

+ func WithResponse(ctx context.Context, w ResponseWriter) context.Context

+ type Client interface

+ Close func()

+ Do func(ctx context.Context, method []byte, path []byte, header Header, body []byte) (status int, responseHeader Header, responseBody []byte, err error)

+ type Config struct

+ Handlers json.RawMessage

+ Middlewares json.RawMessage

+ Options json.RawMessage

+ Port int

+ TLS *TLSConfig

+ func (config *Config) GetPort() (port int, err error)

+ func (config *Config) GetTLS() (tls ssl.Config, err error)

+ func (config *Config) HandlerConfig(name string) (handler configures.Config, err error)

+ func (config *Config) MiddlewareConfig(name string) (middleware configures.Config, err error)

+ func (config *Config) OptionsConfig() (options configures.Config, err error)

+ type Cookie struct

+ func AcquireCookie() *Cookie

+ func (c *Cookie) Domain() []byte

+ func (c *Cookie) Expire() time.Time

+ func (c *Cookie) HTTPOnly() bool

+ func (c *Cookie) Key() []byte

+ func (c *Cookie) MaxAge() int

+ func (c *Cookie) Path() []byte

+ func (c *Cookie) Reset()

+ func (c *Cookie) SameSite() CookieSameSite

+ func (c *Cookie) Secure() bool

+ func (c *Cookie) SetDomain(domain []byte)

+ func (c *Cookie) SetExpire(expire time.Time)

+ func (c *Cookie) SetHTTPOnly(httpOnly bool)

+ func (c *Cookie) SetKey(key []byte)

+ func (c *Cookie) SetMaxAge(seconds int)

+ func (c *Cookie) SetPath(path []byte)

+ func (c *Cookie) SetSameSite(mode CookieSameSite)

+ func (c *Cookie) SetSecure(secure bool)

+ func (c *Cookie) SetValue(value []byte)

+ func (c *Cookie) Value() []byte

+ type CookieSameSite int

+ const CookieSameSiteDefaultMode

+ const CookieSameSiteDisabled

+ const CookieSameSiteLaxMode

+ const CookieSameSiteNoneMode

+ const CookieSameSiteStrictMode

+ type Dialer interface

+ Dial func(address []byte) (client Client, err error)

+ type Handler interface

+ Handle func(w ResponseWriter, r Request)

+ type HandlerFunc func(ResponseWriter, Request)

+ func (f HandlerFunc) Handle(w ResponseWriter, r Request)

+ type Header interface

+ Add func(key []byte, value []byte)

+ Del func(key []byte)

+ Foreach func(fn func(key []byte, values [][]byte))

+ Get func(key []byte) []byte

+ Len func() int

+ Reset func()

+ Set func(key []byte, value []byte)

+ Values func(key []byte) [][]byte

+ func AcquireHeader() Header

+ func TryLoadRequestHeader(ctx context.Context) (Header, bool)

+ func TryLoadResponseHeader(ctx context.Context) (Header, bool)

+ type Middleware interface

+ Close func()

+ Construct func(options MiddlewareOptions) error

+ Handler func(next Handler) Handler

+ Name func() string

+ type MiddlewareOptions struct

+ Config configures.Config

+ Log logs.Logger

+ type Middlewares []Middleware

+ func WaveMiddlewares(log logs.Logger, config Config, middlewares []Middleware) (v Middlewares, err error)

+ func (middlewares Middlewares) Close()

+ func (middlewares Middlewares) Handler(handler Handler) Handler

+ type Mux struct

+ func NewMux() *Mux

+ func (mux *Mux) Add(handler MuxHandler)

+ func (mux *Mux) Handle(w ResponseWriter, r Request)

+ type MuxHandler interface

+ Construct func(options MuxHandlerOptions) error

+ Match func(ctx context.Context, method []byte, path []byte, header Header) bool

+ Name func() string

+ type MuxHandlerOptions struct

+ Config configures.Config

+ Log logs.Logger

+ type Options struct

+ Config Config

+ Handler Handler

+ Log logs.Logger

+ Middlewares []Middleware

+ type Params interface

+ Add func(name []byte, value []byte)

+ Encode func() (p []byte)

+ Get func(name []byte) []byte

+ Len func() int

+ Remove func(name []byte)

+ Set func(name []byte, value []byte)

+ Values func(name []byte) [][]byte

+ func NewParams() Params

+ type Request interface

+ Body func() ([]byte, error)

+ Cookie func(key []byte) (value []byte)

+ Header func() Header

+ Host func() []byte

+ Method func() []byte

+ Params func() Params

+ Path func() []byte

+ Proto func() []byte

+ RemoteAddr func() []byte

+ SetBody func(body []byte)

+ SetCookie func(key []byte, value []byte)

+ SetMethod func(method []byte)

+ TLS func() bool

+ TLSConnectionState func() *tls.ConnectionState

+ func LoadRequest(ctx context.Context) Request

+ func TryLoadRequest(ctx context.Context) (Request, bool)

+ type ResponseWriter interface

+ Body func() []byte

+ BodyLen func() int

+ Failed func(cause error)

+ Header func() Header

+ Hijack func(func(conn net.Conn, rw *bufio.ReadWriter) (err error)) (async bool, err error)

+ Hijacked func() bool

+ SetCookie func(cookie *Cookie)

+ SetStatus func(status int)

+ Status func() int

+ Succeed func(v interface{})

+ Write func(body []byte) (int, error)

+ func LoadResponseWriter(ctx context.Context) ResponseWriter

+ func TryLoadResponseWriter(ctx context.Context) (ResponseWriter, bool)

+ type ResultResponseWriter struct

+ func AcquireResultResponseWriter() *ResultResponseWriter

+ func (w *ResultResponseWriter) Body() []byte

+ func (w *ResultResponseWriter) BodyLen() int

+ func (w *ResultResponseWriter) Failed(cause error)

+ func (w *ResultResponseWriter) SetStatus(status int)

+ func (w *ResultResponseWriter) Status() int

+ func (w *ResultResponseWriter) Succeed(v interface{})

+ func (w *ResultResponseWriter) Write(body []byte) (int, error)

+ type Server interface

+ ListenAndServe func() (err error)

+ Port func() (port int)

+ Shutdown func(ctx context.Context)

+ type TLSConfig struct

+ Kind string

+ Options json.RawMessage

+ func (config *TLSConfig) Config() (conf ssl.Config, err error)

+ type Transport interface

+ Construct func(options Options) (err error)

+ Name func() (name string)

+ type WriteBuffer interface

+ Bytes func() []byte