ddhttp

Documentation

Index

• func BasicAuth(inner http.Handler) http.Handler
• func Logger(inner http.Handler) http.Handler
• func Metrics(inner http.Handler) http.Handler
• func NewClient() *resty.Client
• func Rest(inner http.Handler) http.Handler
• type DdClient
• type DdClientOption
  • func WithClient(client *resty.Client) DdClientOption
  • func WithProvider(provider IServiceProvider) DdClientOption
• type DefaultHttpSrv
  • func (srv *DefaultHttpSrv) AddMiddleware(mwf ...func(http.Handler) http.Handler)
  • func (srv *DefaultHttpSrv) AddRoute(route ...model.Route)
  • func (srv *DefaultHttpSrv) Run()
• type HttpLog
• type IServiceProvider
  • func NewMemberlistServiceProvider(name string, registry registry.IRegistry, opts ...MemberlistProviderOption) IServiceProvider
  • func NewServiceProvider(env string, opts ...ServiceProviderOption) IServiceProvider
• type MemberlistProviderOption
• type MemberlistServiceProvider
  • func (m *MemberlistServiceProvider) SelectServer() (string, error)
• type ServiceProvider
  • func (s *ServiceProvider) SelectServer() (string, error)
• type ServiceProviderOption
• type Srv
  • func NewDefaultHttpSrv() Srv

Functions

func BasicAuth

func BasicAuth(inner http.Handler) http.Handler

func Logger

func Logger(inner http.Handler) http.Handler

func Metrics

func Metrics(inner http.Handler) http.Handler

func NewClient

func NewClient() *resty.Client

func Rest

func Rest(inner http.Handler) http.Handler

Types

type DdClient

type DdClient interface {
	SetProvider(provider IServiceProvider)
	SetClient(client *resty.Client)
}

type DdClientOption

type DdClientOption func(DdClient)

func WithClient

func WithClient(client *resty.Client) DdClientOption

func WithProvider

func WithProvider(provider IServiceProvider) DdClientOption

type DefaultHttpSrv

type DefaultHttpSrv struct {
	*mux.Router
	// contains filtered or unexported fields
}

gorilla

func (*DefaultHttpSrv) AddMiddleware

func (srv *DefaultHttpSrv) AddMiddleware(mwf ...func(http.Handler) http.Handler)

func (*DefaultHttpSrv) AddRoute

func (srv *DefaultHttpSrv) AddRoute(route ...model.Route)

func (*DefaultHttpSrv) Run

func (srv *DefaultHttpSrv) Run()

type HttpLog

type HttpLog struct {
	ClientIp          string      `json:"clientIp,omitempty"`
	HttpMethod        string      `json:"httpMethod,omitempty"`
	Uri               string      `json:"uri,omitempty"`
	Proto             string      `json:"proto,omitempty"`
	Host              string      `json:"host,omitempty"`
	ReqContentLength  int64       `json:"reqContentLength,omitempty"`
	ReqHeader         http.Header `json:"reqHeader,omitempty"`
	RequestId         string      `json:"requestId,omitempty"`
	RawReq            string      `json:"rawReq,omitempty"`
	RespBody          string      `json:"respBody,omitempty"`
	StatusCode        int         `json:"statusCode,omitempty"`
	RespHeader        http.Header `json:"respHeader,omitempty"`
	RespContentLength int         `json:"respContentLength,omitempty"`
	ElapsedTime       string      `json:"elapsedTime,omitempty"`
	// in ms
	Elapsed int64 `json:"elapsed,omitempty"`
}

POST /usersvc/pageusers HTTP/1.1 Host: localhost:6060 Content-Length: 80 Content-Type: application/json User-Agent: go-resty/2.6.0 (https://github.com/go-resty/resty) X-Request-Id: d1e4dc83-18be-493e-be5b-2e0faaca90ec

{"filter":{"dept":99,"name":"Jack"},"page":{"orders":null,"pageNo":2,"size":10}}

type IServiceProvider

type IServiceProvider interface {
	SelectServer() (string, error)
}

func NewMemberlistServiceProvider

func NewMemberlistServiceProvider(name string, registry registry.IRegistry, opts ...MemberlistProviderOption) IServiceProvider

func NewServiceProvider

func NewServiceProvider(env string, opts ...ServiceProviderOption) IServiceProvider

type MemberlistProviderOption

type MemberlistProviderOption func(IServiceProvider)

type MemberlistServiceProvider

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

func (*MemberlistServiceProvider) SelectServer

func (m *MemberlistServiceProvider) SelectServer() (string, error)

type ServiceProvider

type ServiceProvider struct {
	Env string
}

func (*ServiceProvider) SelectServer

func (s *ServiceProvider) SelectServer() (string, error)

type ServiceProviderOption

type ServiceProviderOption func(IServiceProvider)

type Srv

type Srv interface {
	// Run the service
	Run()
	// Register routes
	AddRoute(route ...model.Route)
	// Use middleware
	AddMiddleware(mwf ...func(http.Handler) http.Handler)
}

func NewDefaultHttpSrv

func NewDefaultHttpSrv() Srv