middleware

Documentation

Index

• func ActivityStreamServerInterceptor(activityClient activity.Client) grpc.StreamServerInterceptor
• func ActivityUnaryServerInterceptor(activityClient activity.Client) grpc.UnaryServerInterceptor
• func RequestHTTPHandler(route string, fn func(route string, req *http.Request) error, ...) http.Handler
• func TimeoutStreamServerInterceptor(fn func(method string) time.Duration) grpc.StreamServerInterceptor
• func TimeoutUnaryServerInterceptor(fn func(method string) time.Duration) grpc.UnaryServerInterceptor
• type HTTPError
  • func NewHTTPError(code int, msg string) *HTTPError
  • func (e *HTTPError) Error() string

Functions

func ActivityStreamServerInterceptor

func ActivityStreamServerInterceptor(activityClient activity.Client) grpc.StreamServerInterceptor

func ActivityUnaryServerInterceptor

func ActivityUnaryServerInterceptor(activityClient activity.Client) grpc.UnaryServerInterceptor

func RequestHTTPHandler

func RequestHTTPHandler(route string, fn func(route string, req *http.Request) error, next http.Handler) http.Handler

RequestHTTPHandler calls fn on each request.

func TimeoutStreamServerInterceptor

func TimeoutStreamServerInterceptor(fn func(method string) time.Duration) grpc.StreamServerInterceptor

func TimeoutUnaryServerInterceptor

func TimeoutUnaryServerInterceptor(fn func(method string) time.Duration) grpc.UnaryServerInterceptor

Types

type HTTPError

type HTTPError struct {
	Code    int
	Message string
}

func NewHTTPError

func NewHTTPError(code int, msg string) *HTTPError

func (*HTTPError) Error

func (e *HTTPError) Error() string