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 Recover(inner http.Handler) http.Handler
• func Rest(inner http.Handler) http.Handler
• func Seed()
• type DdClient
• type DdClientOption
  • func WithClient(client *resty.Client) DdClientOption
  • func WithProvider(provider registry.IServiceProvider) DdClientOption
• type DefaultHttpSrv
  • func NewDefaultHttpSrv() *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 MemberlistServiceProvider
  • func NewMemberlistServiceProvider(name string) *MemberlistServiceProvider
  • func (m *MemberlistServiceProvider) AddNode(node *memberlist.Node)
  • func (m *MemberlistServiceProvider) RemoveNode(node *memberlist.Node)
  • func (m *MemberlistServiceProvider) SelectServer() string
  • func (m *MemberlistServiceProvider) UpdateWeight(node *memberlist.Node)
• type ServiceProvider
  • func NewServiceProvider(env string) *ServiceProvider
  • func (s *ServiceProvider) AddNode(node *memberlist.Node)
  • func (s *ServiceProvider) RemoveNode(node *memberlist.Node)
  • func (s *ServiceProvider) SelectServer() string
  • func (s *ServiceProvider) UpdateWeight(node *memberlist.Node)
• type SmoothWeightedRoundRobinProvider
  • func NewSmoothWeightedRoundRobinProvider(name string) *SmoothWeightedRoundRobinProvider
  • func (m *SmoothWeightedRoundRobinProvider) AddNode(node *memberlist.Node)
  • func (m *SmoothWeightedRoundRobinProvider) RemoveNode(node *memberlist.Node)
  • func (m *SmoothWeightedRoundRobinProvider) SelectServer() string
  • func (m *SmoothWeightedRoundRobinProvider) UpdateWeight(node *memberlist.Node)

Functions

func BasicAuth

func BasicAuth(inner http.Handler) http.Handler

BasicAuth adds http basic auth validation

func Logger

func Logger(inner http.Handler) http.Handler

Logger logs http request body and response body for debugging

func Metrics

func Metrics(inner http.Handler) http.Handler

Metrics logs some metrics for http request

func NewClient

func NewClient() *resty.Client

NewClient creates new resty Client instance

func Recover

func Recover(inner http.Handler) http.Handler

Recover handles panic from processing incoming http request

func Rest

func Rest(inner http.Handler) http.Handler

Rest set Content-Type to application/json

func Seed

func Seed()

Seed starts a seed node

Types

type DdClient

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

DdClient defines service client interface

type DdClientOption

type DdClientOption func(DdClient)

DdClientOption defines configure function type

func WithClient

func WithClient(client *resty.Client) DdClientOption

WithClient sets http client

func WithProvider

func WithProvider(provider registry.IServiceProvider) DdClientOption

WithProvider sets service provider

type DefaultHttpSrv

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

DefaultHttpSrv wraps gorilla mux router

func NewDefaultHttpSrv

func NewDefaultHttpSrv() *DefaultHttpSrv

NewDefaultHttpSrv create a DefaultHttpSrv instance

func (*DefaultHttpSrv) AddMiddleware

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

AddMiddleware adds middlewares to router

func (*DefaultHttpSrv) AddRoute

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

AddRoute adds routes to router

func (*DefaultHttpSrv) Run

func (srv *DefaultHttpSrv) Run()

Run runs http server

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"`
}

HttpLog wraps properties for logging http request and body Example:

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 MemberlistServiceProvider

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

MemberlistServiceProvider defines an implementation for IServiceProvider

func NewMemberlistServiceProvider

func NewMemberlistServiceProvider(name string) *MemberlistServiceProvider

NewMemberlistServiceProvider create an NewMemberlistServiceProvider instance

func (*MemberlistServiceProvider) AddNode

func (m *MemberlistServiceProvider) AddNode(node *memberlist.Node)

AddNode add or update node providing the service

func (*MemberlistServiceProvider) RemoveNode

func (m *MemberlistServiceProvider) RemoveNode(node *memberlist.Node)

func (*MemberlistServiceProvider) SelectServer

func (m *MemberlistServiceProvider) SelectServer() string

SelectServer selects a node which is supplying service specified by name property from cluster

func (*MemberlistServiceProvider) UpdateWeight

func (m *MemberlistServiceProvider) UpdateWeight(node *memberlist.Node)

type ServiceProvider

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

ServiceProvider defines an implementation for IServiceProvider

func NewServiceProvider

func NewServiceProvider(env string) *ServiceProvider

NewServiceProvider creates new ServiceProvider instance

func (*ServiceProvider) AddNode

func (s *ServiceProvider) AddNode(node *memberlist.Node)

func (*ServiceProvider) RemoveNode

func (s *ServiceProvider) RemoveNode(node *memberlist.Node)

func (*ServiceProvider) SelectServer

func (s *ServiceProvider) SelectServer() string

SelectServer return service address from environment variable

func (*ServiceProvider) UpdateWeight

func (s *ServiceProvider) UpdateWeight(node *memberlist.Node)

type SmoothWeightedRoundRobinProvider

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

SmoothWeightedRoundRobinProvider is a smooth weighted round-robin algo implementation for IServiceProvider https://github.com/nginx/nginx/commit/52327e0627f49dbda1e8db695e63a4b0af4448b1

func NewSmoothWeightedRoundRobinProvider

func NewSmoothWeightedRoundRobinProvider(name string) *SmoothWeightedRoundRobinProvider

NewSmoothWeightedRoundRobinProvider create an SmoothWeightedRoundRobinProvider instance

func (*SmoothWeightedRoundRobinProvider) AddNode

func (m *SmoothWeightedRoundRobinProvider) AddNode(node *memberlist.Node)

AddNode add or update node providing the service

func (*SmoothWeightedRoundRobinProvider) RemoveNode

func (m *SmoothWeightedRoundRobinProvider) RemoveNode(node *memberlist.Node)

func (*SmoothWeightedRoundRobinProvider) SelectServer

func (m *SmoothWeightedRoundRobinProvider) SelectServer() string

SelectServer selects a node which is supplying service specified by name property from cluster

func (*SmoothWeightedRoundRobinProvider) UpdateWeight

func (m *SmoothWeightedRoundRobinProvider) UpdateWeight(node *memberlist.Node)