rpc

Mar 16, 2026

Changes in this version

type ServerOption

+ func WithServerOnStatusChange(callback naming.StatusChangeCallback) ServerOption

type ServiceDiscoveryLB

+ const WeightedRoundRobin

Mar 30, 2025

Changes in this version

type ServerOption

+ func WithServerKeepalive(kep keepalive.EnforcementPolicy, kp keepalive.ServerParameters) ServerOption

+ func WithServerLimiter(rateLimiter limiter.RateLimiter) ServerOption

type ServiceDiscoveryOption

+ func WithServiceDiscoveryKeepalive(keepaliveTime, timeout time.Duration, backoffConf backoff.Config) ServiceDiscoveryOption

Mar 30, 2025

Changes in this version

+ type Server interface

+ RegisterService func(serviceMetadata metadata.ServiceRegister, grpcRegister interface{}) error

+ Serve func() error

+ Stop func() error

+ func NewServer(conf *config.ServerConfig, registry naming.Registry, opts ...ServerOption) Server

+ type ServerOption func(s *serverOption)

+ func WithServerGrpcServerOption(opts ...grpc.ServerOption) ServerOption

+ func WithServiceLimiter(rateLimiter limiter.RateLimiter) ServerOption

+ type ServiceDiscovery interface

+ ServiceConn func(serviceName string, opts ...ServiceDiscoveryOption) (*grpc.ClientConn, error)

+ func NewServiceDiscovery(appName string, resolverBuilder resolver.Builder) ServiceDiscovery

+ type ServiceDiscoveryLB string

+ const PickFirst

+ const RoundRobin

+ type ServiceDiscoveryOption func(s *serviceDiscoveryOption)

+ func WithServiceDiscoveryBreaker(cb breaker.CircuitBreaker) ServiceDiscoveryOption

+ func WithServiceDiscoveryGrpcDialOption(opts ...grpc.DialOption) ServiceDiscoveryOption

+ func WithServiceDiscoveryGrpcDialTransportCredentials(credentials *credentials.TransportCredentials) ServiceDiscoveryOption

+ func WithServiceDiscoveryLB(lb ServiceDiscoveryLB) ServiceDiscoveryOption

+ func WithServiceDiscoveryRetry(retryPolicy *retry.Policy) ServiceDiscoveryOption

+ func WithServiceDiscoveryTimeout(timeout time.Duration) ServiceDiscoveryOption