lb

Documentation

Index

• Constants
• type ServerPool
  • func GetInstance() *ServerPool
  • func (s *ServerPool) GetHttpClient() client.HttpClient
  • func (s *ServerPool) GetService(name string) *service
  • func (s *ServerPool) GetUrl(serviceName string, path string) string
  • func (s *ServerPool) Run(req *request.Request, respResult any) (*response.Response, 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://"
)

Types

type ServerPool

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

func GetInstance

func GetInstance() *ServerPool

func (*ServerPool) GetHttpClient

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

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, respResult any) (*response.Response, error)

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

func (*ServerPool) SetHttpClient

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