Versions in this module Expand all Collapse all v2 v2.8.2 Nov 1, 2024 v2.8.1 Nov 1, 2024 Changes in this version + func Dial(ctx context.Context, opts ...ClientOption) (*grpc.ClientConn, error) + func DialInsecure(ctx context.Context, opts ...ClientOption) (*grpc.ClientConn, error) + func GetStream(ctx context.Context) grpc.ServerStream + func NewWrappedStream(ctx context.Context, stream grpc.ServerStream, m matcher.Matcher) grpc.ServerStream + type ClientOption func(o *clientOptions) + func WithDiscovery(d registry.Discovery) ClientOption + func WithEndpoint(endpoint string) ClientOption + func WithHealthCheck(healthCheck bool) ClientOption + func WithLogger(log.Logger) ClientOption + func WithMiddleware(m ...middleware.Middleware) ClientOption + func WithNodeFilter(filters ...selector.NodeFilter) ClientOption + func WithOptions(opts ...grpc.DialOption) ClientOption + func WithPrintDiscoveryDebugLog(p bool) ClientOption + func WithStreamInterceptor(in ...grpc.StreamClientInterceptor) ClientOption + func WithSubset(size int) ClientOption + func WithTLSConfig(c *tls.Config) ClientOption + func WithTimeout(timeout time.Duration) ClientOption + func WithUnaryInterceptor(in ...grpc.UnaryClientInterceptor) ClientOption + type Server struct + func NewServer(opts ...ServerOption) *Server + func (s *Server) Endpoint() (*url.URL, error) + func (s *Server) Start(ctx context.Context) error + func (s *Server) Stop(_ context.Context) error + func (s *Server) Use(selector string, m ...middleware.Middleware) + type ServerOption func(o *Server) + func Address(addr string) ServerOption + func CustomHealth() ServerOption + func Endpoint(endpoint *url.URL) ServerOption + func Listener(lis net.Listener) ServerOption + func Logger(log.Logger) ServerOption + func Middleware(m ...middleware.Middleware) ServerOption + func Network(network string) ServerOption + func Options(opts ...grpc.ServerOption) ServerOption + func StreamInterceptor(in ...grpc.StreamServerInterceptor) ServerOption + func StreamMiddleware(m ...middleware.Middleware) ServerOption + func TLSConfig(c *tls.Config) ServerOption + func Timeout(timeout time.Duration) ServerOption + func UnaryInterceptor(in ...grpc.UnaryServerInterceptor) ServerOption + type Trailer metadata.MD + func (t Trailer) Get(k string) string + type Transport struct + func (tr *Transport) Endpoint() string + func (tr *Transport) Kind() transport.Kind + func (tr *Transport) NodeFilters() []selector.NodeFilter + func (tr *Transport) Operation() string + func (tr *Transport) ReplyHeader() transport.Header + func (tr *Transport) RequestHeader() transport.Header
Go to main page