transport

Documentation

Index

• func NewCalculatorClient(transportFactory CalculatorTransportFactory, instancer sd.Instancer, ...) *cli_endpoint.CalculatorEndpoints
• func NewHealthClient(transportFactory HealthTransportFactory, instancer sd.Instancer, ...) *cli_endpoint.HealthEndpoints
• type CalculatorTransport
• type CalculatorTransportFactory
• type HealthTransport
• type HealthTransportFactory

Functions

func NewCalculatorClient

func NewCalculatorClient(transportFactory CalculatorTransportFactory, instancer sd.Instancer, logger kit_log.Logger) *cli_endpoint.CalculatorEndpoints

NewCalculatorClient 创建计算器客户端 这一步集成服务发现、负载均衡、失败重试

func NewHealthClient

func NewHealthClient(transportFactory HealthTransportFactory, instancer sd.Instancer, logger kit_log.Logger) *cli_endpoint.HealthEndpoints

NewHealthClient 创建健康检查客户端 这一步集成服务发现、负载均衡、失败重试

Types

type CalculatorTransport

type CalculatorTransport interface {
	io.Closer
	NewAddEndpoint() endpoint.Endpoint
	NewSubEndpoint() endpoint.Endpoint
	NewMulEndpoint() endpoint.Endpoint
	NewDivEndpoint() endpoint.Endpoint
}

CalculatorTransport 传输层传输层客户端接口

type CalculatorTransportFactory

type CalculatorTransportFactory func(ctx context.Context, target string) (CalculatorTransport, error)

CalculatorTransportFactory 健康检查传输层客户端factory

type HealthTransport

type HealthTransport interface {
	io.Closer
	NewCheckEndpoint() endpoint.Endpoint
}

HealthTransport 健康检查传输层客户端接口

type HealthTransportFactory

type HealthTransportFactory func(ctx context.Context, target string) (HealthTransport, error)

HealthTransportFactory 健康检查传输层客户端factory