Versions in this module Expand all Collapse all v1 v1.0.1 May 28, 2021 v1.0.0 May 13, 2021 Changes in this version + var ErrPipeListenerClosed = errors.New(`pipe listener already closed`) + func StreamServerInterceptor(authFunc AuthFunc) grpc.StreamServerInterceptor + func UnaryServerInterceptor(authFunc AuthFunc) grpc.UnaryServerInterceptor + type AuthFunc func(ctx context.Context, fullMethod string) (context.Context, error) + type PipeListener struct + func ListenPipe() *PipeListener + func (l *PipeListener) Accept() (c net.Conn, e error) + func (l *PipeListener) Addr() net.Addr + func (l *PipeListener) Close() (e error) + func (l *PipeListener) Dial(network, addr string) (net.Conn, error) + func (l *PipeListener) DialContext(ctx context.Context, network, addr string) (conn net.Conn, e error) + type Server struct + func NewServer(addr string, auth *configure.Auth) (s *Server, e error) + func (s *Server) Serve() (e error) + func (s *Server) ServeHTTP(w http.ResponseWriter, r *http.Request) + func (s *Server) ServeTLS(certFile, keyFile string) (e error) + type ServiceAuthFuncOverride interface + AuthFuncOverride func(ctx context.Context, fullMethodName string) (context.Context, error)