typhon

Dec 4, 2023

Changes in this version

type Request

+ func (r Request) RequestMethod() string

+ func (r Request) RequestPathPattern() string

May 5, 2023

Changes in this version

type ServerOption

+ func WithMaxConnectionAge(maxAge time.Duration) ServerOption

May 13, 2022

Changes in this version

+ type ServerOption func(*Server)

+ func WithTimeout(opts TimeoutOptions) ServerOption

+ type TimeoutOptions struct

+ Idle time.Duration

+ Read time.Duration

+ ReadHeader time.Duration

+ Write time.Duration

Mar 31, 2022

Changes in this version

+ var H2cRoundTripper http.RoundTripper = &http2.Transport

+ var HTTPRoundTripper http.RoundTripper = &http.Transport

+ func WithH2C(ctx context.Context) context.Context

Jan 18, 2022

Changes in this version

+ func AppendMetadataToContext(ctx context.Context, md Metadata) context.Context

+ func ErrorStatusCode(err error) int

+ func HttpHandler(svc Service) http.Handler

+ type Filter func(Request, Service) Response

+ type Metadata map[string][]string

+ func MetadataFromContext(ctx context.Context) Metadata

+ func NewMetadata(data map[string]string) Metadata

+ type Request struct

+ func NewRequest(ctx context.Context, method, url string, body interface{}) Request

+ func (r *Request) BodyBytes(consume bool) ([]byte, error)

+ func (r *Request) Encode(v interface{})

+ func (r *Request) EncodeAsJSON(v interface{})

+ func (r *Request) EncodeAsProtobuf(m proto.Message)

+ func (r *Request) Write(b []byte) (n int, err error)

+ func (r Request) Decode(v interface{}) error

+ func (r Request) Response(body interface{}) Response

+ func (r Request) ResponseWithCode(body interface{}, statusCode int) Response

+ func (r Request) Send() *ResponseFuture

+ func (r Request) SendVia(svc Service) *ResponseFuture

+ func (r Request) String() string

+ type Response struct

+ Error error

+ Request *Request

+ func BareClient(req Request) Response

+ func ErrorFilter(req Request, svc Service) Response

+ func ExpirationFilter(req Request, svc Service) Response

+ func H2cFilter(req Request, svc Service) Response

+ func NewResponse(req Request) Response

+ func NewResponseWithCode(req Request, statusCode int) Response

+ func (r *Response) BodyBytes(consume bool) ([]byte, error)

+ func (r *Response) Decode(v interface{}) error

+ func (r *Response) Encode(v interface{})

+ func (r *Response) EncodeAsJSON(v interface{})

+ func (r *Response) EncodeAsLegacyProtobuf(m legacyproto.Message)

+ func (r *Response) EncodeAsProtobuf(m proto.Message)

+ func (r *Response) EncodeAsProtobufJSON(m proto.Message)

+ func (r *Response) Write(b []byte) (n int, err error)

+ func (r *Response) Writer() ResponseWriter

+ func (r Response) String() string

+ type ResponseFuture struct

+ func Send(req Request) *ResponseFuture

+ func SendVia(req Request, svc Service) *ResponseFuture

+ func (f *ResponseFuture) Response() Response

+ func (f *ResponseFuture) WaitC() <-chan struct{}

+ type ResponseWriter interface

+ WriteError func(err error)

+ WriteJSON func(interface{})

+ type Router struct

+ func RouterForRequest(r Request) *Router

+ func (r *Router) CONNECT(pattern string, svc Service)

+ func (r *Router) DELETE(pattern string, svc Service)

+ func (r *Router) GET(pattern string, svc Service)

+ func (r *Router) HEAD(pattern string, svc Service)

+ func (r *Router) OPTIONS(pattern string, svc Service)

+ func (r *Router) PATCH(pattern string, svc Service)

+ func (r *Router) POST(pattern string, svc Service)

+ func (r *Router) PUT(pattern string, svc Service)

+ func (r *Router) Register(method, pattern string, svc Service)

+ func (r *Router) TRACE(pattern string, svc Service)

+ func (r Router) Lookup(method, path string) (Service, string, map[string]string, bool)

+ func (r Router) Params(req Request) map[string]string

+ func (r Router) Pattern(req Request) string

+ func (r Router) Serve() Service

+ type Server struct

+ func Listen(svc Service, addr string) (*Server, error)

+ func Serve(svc Service, l net.Listener) (*Server, error)

+ func (s *Server) Done() <-chan struct{}

+ func (s *Server) Listener() net.Listener

+ func (s *Server) Stop(ctx context.Context)

+ type Service func(req Request) Response

+ var Client Service = BareClient

+ var RoundTripper http.RoundTripper = &http.Transport{ ... }

+ func HttpService(rt http.RoundTripper) Service

+ func (svc Service) Filter(f Filter) Service

+ type StreamerWriter interface

+ CloseWithError func(error) error

+ func Streamer() StreamerWriter

+ type WrapDownstreamErrors struct