Documentation
¶
Index ¶
- func Dial(ctx context.Context, opts ...ClientOption) (*grpc.ClientConn, error)
- func DialInsecure(ctx context.Context, opts ...ClientOption) (*grpc.ClientConn, error)
- func NewWrappedStream(ctx context.Context, stream grpc.ServerStream) grpc.ServerStream
- type ClientOption
- 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
- type ServerOption
- 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 TLSConfig(c *tls.Config) ServerOption
- func Timeout(timeout time.Duration) ServerOption
- func UnaryInterceptor(in ...grpc.UnaryServerInterceptor) ServerOption
- type Trailer
- type Transport
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Dial ¶
func Dial(ctx context.Context, opts ...ClientOption) (*grpc.ClientConn, error)
Dial returns a GRPC connection.
func DialInsecure ¶
func DialInsecure(ctx context.Context, opts ...ClientOption) (*grpc.ClientConn, error)
DialInsecure returns an insecure GRPC connection.
func NewWrappedStream ¶ added in v2.1.5
func NewWrappedStream(ctx context.Context, stream grpc.ServerStream) grpc.ServerStream
Types ¶
type ClientOption ¶
type ClientOption func(o *clientOptions)
ClientOption is gRPC client option.
func WithDiscovery ¶
func WithDiscovery(d registry.Discovery) ClientOption
WithDiscovery with client discovery.
func WithEndpoint ¶
func WithEndpoint(endpoint string) ClientOption
WithEndpoint with client endpoint.
func WithHealthCheck ¶ added in v2.7.2
func WithHealthCheck(healthCheck bool) ClientOption
WithHealthCheck with health check
func WithLogger ¶ added in v2.1.3
func WithLogger(_ log.Logger) ClientOption
WithLogger with logger Deprecated: use global logger instead.
func WithMiddleware ¶
func WithMiddleware(m ...middleware.Middleware) ClientOption
WithMiddleware with client middleware.
func WithNodeFilter ¶ added in v2.1.2
func WithNodeFilter(filters ...selector.NodeFilter) ClientOption
WithNodeFilter with select filters
func WithOptions ¶
func WithOptions(opts ...grpc.DialOption) ClientOption
WithOptions with gRPC options.
func WithPrintDiscoveryDebugLog ¶ added in v2.6.2
func WithPrintDiscoveryDebugLog(p bool) ClientOption
func WithStreamInterceptor ¶ added in v2.6.1
func WithStreamInterceptor(in ...grpc.StreamClientInterceptor) ClientOption
WithStreamInterceptor returns a DialOption that specifies the interceptor for streaming RPCs.
func WithSubset ¶ added in v2.6.1
func WithSubset(size int) ClientOption
WithSubset with client discovery subset size. zero value means subset filter disabled
func WithTLSConfig ¶ added in v2.0.5
func WithTLSConfig(c *tls.Config) ClientOption
WithTLSConfig with TLS config.
func WithTimeout ¶
func WithTimeout(timeout time.Duration) ClientOption
WithTimeout with client timeout.
func WithUnaryInterceptor ¶
func WithUnaryInterceptor(in ...grpc.UnaryClientInterceptor) ClientOption
WithUnaryInterceptor returns a DialOption that specifies the interceptor for unary RPCs.
type Server ¶
Server is a gRPC server wrapper.
func NewServer ¶
func NewServer(opts ...ServerOption) *Server
NewServer creates a gRPC server by options.
func (*Server) Endpoint ¶
Endpoint return a real address to registry endpoint. examples:
grpc://127.0.0.1:9000?isSecure=false
func (*Server) Use ¶ added in v2.4.1
func (s *Server) Use(selector string, m ...middleware.Middleware)
Use uses a service middleware with selector. selector:
- '/*'
- '/helloworld.v1.Greeter/*'
- '/helloworld.v1.Greeter/SayHello'
type ServerOption ¶
type ServerOption func(o *Server)
ServerOption is gRPC server option.
func Endpoint ¶ added in v2.7.0
func Endpoint(endpoint *url.URL) ServerOption
Endpoint with server address.
func Listener ¶ added in v2.1.4
func Listener(lis net.Listener) ServerOption
Listener with server lis
func Logger ¶
func Logger(_ log.Logger) ServerOption
Logger with server logger. Deprecated: use global logger instead.
func Middleware ¶
func Middleware(m ...middleware.Middleware) ServerOption
Middleware with server middleware.
func StreamInterceptor ¶ added in v2.1.5
func StreamInterceptor(in ...grpc.StreamServerInterceptor) ServerOption
StreamInterceptor returns a ServerOption that sets the StreamServerInterceptor for the server.
func TLSConfig ¶ added in v2.0.5
func TLSConfig(c *tls.Config) ServerOption
TLSConfig with TLS config.
func UnaryInterceptor ¶
func UnaryInterceptor(in ...grpc.UnaryServerInterceptor) ServerOption
UnaryInterceptor returns a ServerOption that sets the UnaryServerInterceptor for the server.
type Transport ¶
type Transport struct {
// contains filtered or unexported fields
}
Transport is a gRPC transport.
func (*Transport) NodeFilters ¶ added in v2.1.2
func (tr *Transport) NodeFilters() []selector.NodeFilter
NodeFilters returns the client select filters.
func (*Transport) ReplyHeader ¶
ReplyHeader returns the reply header.
func (*Transport) RequestHeader ¶
RequestHeader returns the request header.
Source Files
Directories