endpoint

Oct 17, 2026

Changes in this version

type EndpointFactoryOption

+ func WithSelector(sel loadbalance.Selector) EndpointFactoryOption

type GRPCEndpointFactory

+ func (f *GRPCEndpointFactory) ResetSelector(serviceName string)

type HTTPEndpointFactory

+ func (f *HTTPEndpointFactory) ResetSelector(serviceName string)

Oct 15, 2026

Changes in this version

+ var ErrCircuitOpen = httpx.ErrCircuitOpen

+ type Endpoint func(ctx context.Context, request any) (any, error)

+ type EndpointFactoryOption func(*factoryConfig)

+ func WithBreakerSettings(tmpl gobreaker.Settings) EndpointFactoryOption

+ func WithMetrics(reg prom.Registerer, namespace string) EndpointFactoryOption

+ type GRPCEndpointFactory struct

+ func NewGRPCEndpointFactory(c *nnsclient.ServiceClient, opts ...EndpointFactoryOption) *GRPCEndpointFactory

+ func (f *GRPCEndpointFactory) Close()

+ func (f *GRPCEndpointFactory) MakeEndpoint(serviceName string, opts ...grpc.DialOption) (Endpoint, error)

+ func (f *GRPCEndpointFactory) ResetBalancer(serviceName string)

+ type GRPCPool struct

+ func NewGRPCPool() *GRPCPool

+ func NewGRPCPoolWithSize(maxSize int) *GRPCPool

+ func (p *GRPCPool) Close()

+ func (p *GRPCPool) Get(ctx context.Context, addr string, opts ...grpc.DialOption) (*grpc.ClientConn, error)

+ type GRPCRequest struct

+ GrpcServiceName string

+ Method string

+ Request any

+ ServiceName string

+ Timeout time.Duration

+ type HTTPEndpointFactory struct

+ func NewHTTPEndpointFactory(c *nnsclient.ServiceClient, opts ...EndpointFactoryOption) *HTTPEndpointFactory

+ func (f *HTTPEndpointFactory) Close()

+ func (f *HTTPEndpointFactory) MakeEndpoint(serviceName string) (Endpoint, error)

+ func (f *HTTPEndpointFactory) ResetBalancer(serviceName string)

+ type HTTPRequest struct

+ Body any

+ Header map[string]string

+ Method string

+ Path string

+ Query map[string]string

+ Result any

+ Timeout time.Duration