lb

Documentation

Index

• Constants
• func GetClient(timeout time.Duration) *http.Client
• type FastHttpClient
  • func (FastHttpClient) Exec(req *request.Request) (statusCode int, err error)
• type NetHttpClient
  • func (NetHttpClient) Exec(req *request.Request) (statusCode int, err error)
• type ServerPool
  • func GetInstance() *ServerPool
  • func (s *ServerPool) GetService(name string) *service
  • func (s *ServerPool) GetUrl(serviceName string, path string) string
  • func (s *ServerPool) Run(req *request.Request) (int, error)
  • func (s *ServerPool) SetHttpClient(client client.HttpClient)

Constants

const (
	ConnectionTimeout               = "server.http.client.timeout"
	RetryOnConnectionFailure        = "server.http.retry.onConnectionFailure"
	RetryEnabled                    = "server.http.retry.enabled"
	RetryOnAllOperations            = "server.http.retry.allOperations"
	MaxRetriesOnNextServiceInstance = "server.http.retry.maxRetriesOnNextServiceInstance"
	RetryableStatusCodes            = "server.http.retry.retryableStatusCodes"
	ProtocolHttp                    = "http://"
	ProtocolHttps                   = "https://"
)

const (
	DefaultTimeout = 30 * time.Second
)

Functions

func GetClient

func GetClient(timeout time.Duration) *http.Client

Types

type FastHttpClient

type FastHttpClient struct{}

func (FastHttpClient) Exec

func (FastHttpClient) Exec(req *request.Request) (statusCode int, err error)

type NetHttpClient

type NetHttpClient struct{}

func (NetHttpClient) Exec

func (NetHttpClient) Exec(req *request.Request) (statusCode int, err error)

type ServerPool

type ServerPool struct {
	Services sync.Map
	// contains filtered or unexported fields
}

func GetInstance

func GetInstance() *ServerPool

func (*ServerPool) GetService

func (s *ServerPool) GetService(name string) *service

func (*ServerPool) GetUrl

func (s *ServerPool) GetUrl(serviceName string, path string) string

func (*ServerPool) Run

func (s *ServerPool) Run(req *request.Request) (int, error)

lb对接收到的请求 进行负载均衡

func (*ServerPool) SetHttpClient

func (s *ServerPool) SetHttpClient(client client.HttpClient)