grapiserver

Aug 24, 2019

Changes in this version

type Config

+ SignalHanding bool

type Option

+ func WithSignalHandling(enabled bool) Option

Mar 31, 2019

Changes in this version

type Engine

+ func (e *Engine) ServeContext(ctx context.Context) error

Nov 15, 2018

Changes in this version

type Config

+ GatewayServerConfig *HTTPServerConfig

+ type HTTPServerConfig struct

+ ConnState func(net.Conn, http.ConnState)

+ IdleTimeout time.Duration

+ MaxHeaderBytes int

+ ReadHeaderTimeout time.Duration

+ ReadTimeout time.Duration

+ TLSConfig *tls.Config

+ TLSNextProto map[string]func(*http.Server, *tls.Conn, http.Handler)

+ WriteTimeout time.Duration

type Option

+ func WithGatewayServerConfig(cfg *HTTPServerConfig) Option

Mar 25, 2018

Changes in this version

+ func NewMuxServer(mux cmux.CMux, lis net.Listener) internal.Server

type Config

+ GrpcAddr *Address

+ Servers []Server

type Engine

+ func (e *Engine) Shutdown()

+ type MuxServer struct

+ func (s *MuxServer) Serve(lis net.Listener, wg *sync.WaitGroup)

+ func (s *MuxServer) Shutdown()

+ type Option func(*Config)

+ func WithAddr(network, addr string) Option

+ func WithDefaultLogger() Option

+ func WithGatewayAddr(network, addr string) Option

+ func WithGatewayDialOptions(opts ...grpc.DialOption) Option

+ func WithGatewayMuxOptions(opts ...runtime.ServeMuxOption) Option

+ func WithGatewayServerMiddlewares(middlewares ...HTTPServerMiddleware) Option

+ func WithGatewayServerStreamInterceptors(interceptors ...grpc.StreamClientInterceptor) Option

+ func WithGatewayServerUnaryInterceptors(interceptors ...grpc.UnaryClientInterceptor) Option

+ func WithGrpcAddr(network, addr string) Option

+ func WithGrpcInternalAddr(network, addr string) Option

+ func WithGrpcServerOptions(opts ...grpc.ServerOption) Option

+ func WithGrpcServerStreamInterceptors(interceptors ...grpc.StreamServerInterceptor) Option

+ func WithGrpcServerUnaryInterceptors(interceptors ...grpc.UnaryServerInterceptor) Option

+ func WithPassedHeader(decider PassedHeaderDeciderFunc) Option

+ func WithServers(svrs ...Server) Option

type Server

+ RegisterWithHandler func(context.Context, *runtime.ServeMux, *grpc.ClientConn) error

+ RegisterWithServer func(*grpc.Server)

Mar 19, 2018

Changes in this version

type Builder

+ AddGatewayDialOptions func(opts ...grpc.DialOption) Builder

+ AddGrpcServerOptions func(opts ...grpc.ServerOption) Builder

type Config

+ GatewayDialOption []grpc.DialOption

+ GrpcServerOption []grpc.ServerOption

Mar 15, 2018

Changes in this version

type Builder

+ AddGatewayServerMiddleware func(middlewares ...HTTPServerMiddleware) Builder

+ AddPassedHeader func(decider PassedHeaderDeciderFunc) Builder

type Config

+ GatewayServerMiddlewares []HTTPServerMiddleware

+ type HTTPServerMiddleware func(http.Handler) http.Handler

+ type PassedHeaderDeciderFunc func(string) bool

Mar 7, 2018

Changes in this version

+ var DefaultConfig = &Config

+ type Address struct

+ Addr string

+ Network string

+ type Builder interface

+ AddGatewayMuxOptions func(opts ...runtime.ServeMuxOption) Builder

+ AddGatewayServerStreamInterceptors func(interceptors ...grpc.StreamClientInterceptor) Builder

+ AddGatewayServerUnaryInterceptors func(interceptors ...grpc.UnaryClientInterceptor) Builder

+ AddGrpcServerStreamInterceptors func(interceptors ...grpc.StreamServerInterceptor) Builder

+ AddGrpcServerUnaryInterceptors func(interceptors ...grpc.UnaryServerInterceptor) Builder

+ AddRegisterGatewayHandlerFuncs func(registerFuncs ...RegisterGatewayHandlerFunc) Builder

+ AddRegisterGrpcServerImplFuncs func(registerFuncs ...RegisterGrpcServerImplFunc) Builder

+ Build func() (*Engine, error)

+ Serve func() error

+ SetGatewayAddr func(network, addr string) Builder

+ SetGrpcInternalAddr func(network, addr string) Builder

+ SetHTTPHeaderMapping func(deciderFunc func(string) bool, mappingFunc func(string) string) Builder

+ SetLogger func(l Logger) Builder

+ Validate func() error

+ func New() Builder

+ type Config struct

+ GatewayAddr *Address

+ GatewayMuxOptions []runtime.ServeMuxOption

+ GatewayServerStreamInterceptors []grpc.StreamClientInterceptor

+ GatewayServerUnaryInterceptors []grpc.UnaryClientInterceptor

+ GrpcInternalAddr *Address

+ GrpcServerStreamInterceptors []grpc.StreamServerInterceptor

+ GrpcServerUnaryInterceptors []grpc.UnaryServerInterceptor

+ HTTPHeaderMappingConfig *HTTPHeaderMappingConfig

+ Logger Logger

+ MaxConcurrentStreams uint32

+ RegisterGatewayHandlerFuncs []RegisterGatewayHandlerFunc

+ RegisterGrpcServerImplFuncs []RegisterGrpcServerImplFunc

+ type Engine struct

+ func (e *Engine) Serve() error

+ type GatewayServer struct

+ func (s *GatewayServer) Serve(l net.Listener, wg *sync.WaitGroup)

+ func (s *GatewayServer) Shutdown()

+ type GrpcServer struct

+ func (s *GrpcServer) Serve(l net.Listener, wg *sync.WaitGroup)

+ func (s *GrpcServer) Shutdown()

+ type HTTPHeaderMappingConfig struct

+ DeciderFunc func(string) bool

+ MapperFunc func(string) string

+ type LogFields map[string]interface

+ type Logger interface

+ Error func(msg string, fields LogFields)

+ Info func(msg string, fields LogFields)

+ var DefaultLogger Logger = &defaultLogger{ ... }

+ type RegisterGatewayHandlerFunc func(context.Context, *runtime.ServeMux, *grpc.ClientConn) error

+ type RegisterGrpcServerImplFunc func(s *grpc.Server)

+ type Server interface

+ Serve func(l net.Listener, wg *sync.WaitGroup)

+ Shutdown func()

+ func NewGatewayServer(c *Config) Server

+ func NewGrpcServer(c *Config) Server