http

Documentation

Index

• Variables
• func NewLogRoundTripper() func(http.RoundTripper) http.RoundTripper
• func NewRequest(method string, path string) *request
• func OmitAuthorization(u *url.URL) string
• func RegisterCheckerBy(vs ...interface{})
• func RegisterEnvRouters(r *kit.Router)
• func ResetRegistered()
• func TraceLogHandler(tr trace.Tracer) func(http.Handler) http.Handler
• func WithContextCompose(contexts ...contextx.WithContext) contextx.WithContext
• func WithMiddlewares(ms ...httptransport.HttpMiddleware)
• type ClientEndpoint
  • func (c *ClientEndpoint) Do(ctx context.Context, req interface{}, metas ...kit.Metadata) kit.Result
  • func (c *ClientEndpoint) Init()
  • func (c *ClientEndpoint) LivenessCheck() map[string]string
  • func (c *ClientEndpoint) SetDefault()
• type EnvQuery
  • func (r *EnvQuery) Output(ctx context.Context) (interface{}, error)
  • func (r *EnvQuery) Path() string
• type EnvSet
  • func (r *EnvSet) Output(ctx context.Context) (interface{}, error)
  • func (r *EnvSet) Path() string
• type Liveness
  • func (Liveness) Output(ctx context.Context) (interface{}, error)
  • func (Liveness) Path() string
• type LivenessChecker
• type LivenessCheckers
  • func (cs LivenessCheckers) Statuses() map[string]string
• type LogRoundTripper
  • func (rt *LogRoundTripper) RoundTrip(req *http.Request) (*http.Response, error)
• type LoggerResponseWriter
  • func NewLoggerResponseWriter(rw http.ResponseWriter) *LoggerResponseWriter
  • func (rw *LoggerResponseWriter) Header() http.Header
  • func (rw *LoggerResponseWriter) Write(data []byte) (int, error)
  • func (rw *LoggerResponseWriter) WriteHeader(sc int)
• type Middleware
  • func NewContextInjectorMw(ctx contextx.WithContext) Middleware
• type Server
  • func (s *Server) LivenessCheck() map[string]string
  • func (s *Server) Serve(router *kit.Router) error
  • func (s *Server) SetDefault()
  • func (s *Server) Shutdown()
  • func (s Server) WithContextInjector(injector contextx.WithContext) *Server
  • func (s Server) WithName(name string) *Server

Variables

var (
	EnvQueryRouter = kit.NewRouter(&EnvQuery{})
	EnvSetRouter   = kit.NewRouter(&EnvSet{})
)

var LivenessRouter = kit.NewRouter(&Liveness{})

var (
	RTypeLivenessChecker = reflect.TypeOf((*LivenessChecker)(nil)).Elem()
)

Functions

func NewLogRoundTripper

func NewLogRoundTripper() func(http.RoundTripper) http.RoundTripper

func NewRequest

func NewRequest(method string, path string) *request

func OmitAuthorization

func OmitAuthorization(u *url.URL) string

func RegisterCheckerBy

func RegisterCheckerBy(vs ...interface{})

func RegisterEnvRouters

func RegisterEnvRouters(r *kit.Router)

func ResetRegistered

func ResetRegistered()

func TraceLogHandler

func TraceLogHandler(tr trace.Tracer) func(http.Handler) http.Handler

func WithContextCompose

func WithContextCompose(contexts ...contextx.WithContext) contextx.WithContext

func WithMiddlewares

func WithMiddlewares(ms ...httptransport.HttpMiddleware)

WithMiddlewares for custom

Types

type ClientEndpoint

type ClientEndpoint struct {
	Endpoint types.Endpoint `env:""`
	Timeout  time.Duration

	client.Client `env:"-"`
}

func (*ClientEndpoint) Do

func (c *ClientEndpoint) Do(ctx context.Context, req interface{}, metas ...kit.Metadata) kit.Result

func (*ClientEndpoint) Init

func (c *ClientEndpoint) Init()

func (*ClientEndpoint) LivenessCheck

func (c *ClientEndpoint) LivenessCheck() map[string]string

func (*ClientEndpoint) SetDefault

func (c *ClientEndpoint) SetDefault()

type EnvQuery

type EnvQuery struct {
	httpx.MethodGet
	K string `in:"query" name:"k,omitempty"`
}

func (*EnvQuery) Output

func (r *EnvQuery) Output(ctx context.Context) (interface{}, error)

func (*EnvQuery) Path

func (r *EnvQuery) Path() string

type EnvSet

type EnvSet struct {
	httpx.MethodPost
	K string `in:"query"           name:"key"`
	V string `in:"query,omitempty" name:"key"`
}

func (*EnvSet) Output

func (r *EnvSet) Output(ctx context.Context) (interface{}, error)

func (*EnvSet) Path

func (r *EnvSet) Path() string

type Liveness

type Liveness struct{ httpx.MethodGet }

func (Liveness) Output

func (Liveness) Output(ctx context.Context) (interface{}, error)

func (Liveness) Path

func (Liveness) Path() string

type LivenessChecker

type LivenessChecker interface {
	LivenessCheck() map[string]string
}

type LivenessCheckers

type LivenessCheckers map[string]LivenessChecker

func (LivenessCheckers) Statuses

func (cs LivenessCheckers) Statuses() map[string]string

type LogRoundTripper

type LogRoundTripper struct {
	// contains filtered or unexported fields
}

func (*LogRoundTripper) RoundTrip

func (rt *LogRoundTripper) RoundTrip(req *http.Request) (*http.Response, error)

type LoggerResponseWriter

type LoggerResponseWriter struct {
	http.ResponseWriter
	http.Hijacker
	http.Flusher
	// contains filtered or unexported fields
}

func NewLoggerResponseWriter

func NewLoggerResponseWriter(rw http.ResponseWriter) *LoggerResponseWriter

func (*LoggerResponseWriter) Header

func (rw *LoggerResponseWriter) Header() http.Header

func (*LoggerResponseWriter) Write

func (rw *LoggerResponseWriter) Write(data []byte) (int, error)

func (*LoggerResponseWriter) WriteHeader

func (rw *LoggerResponseWriter) WriteHeader(sc int)

type Middleware

type Middleware = func(http.Handler) http.Handler

func NewContextInjectorMw

func NewContextInjectorMw(ctx contextx.WithContext) Middleware

type Server

type Server struct {
	Port        int    `env:",opt,expose"`
	Spec        string `env:",opt,copy"`
	HealthCheck string `env:",opt,healthCheck"`
	Debug       *bool  `env:""`
	// contains filtered or unexported fields
}

func (*Server) LivenessCheck

func (s *Server) LivenessCheck() map[string]string

func (*Server) Serve

func (s *Server) Serve(router *kit.Router) error

func (*Server) SetDefault

func (s *Server) SetDefault()

func (*Server) Shutdown

func (s *Server) Shutdown()

func (Server) WithContextInjector

func (s Server) WithContextInjector(injector contextx.WithContext) *Server

func (Server) WithName

func (s Server) WithName(name string) *Server