servercore

Documentation

Index

• func Listen(ctx context.Context, opts ListenOpts, registerServices func(Server)) error
• func MakeTCPListener(address string, port int) func(context.Context) (net.Listener, error)
• func NewHTTPMux(middleware ...mux.MiddlewareFunc) *mux.Router
• func Run(ctx context.Context, opts RunOpts, listenOpts ListenOpts)
• type ListenOpts
• type Registrar
• type RunOpts
• type Server
• type ServerImpl
  • func (s *ServerImpl) Handle(path string, p http.Handler) *mux.Route
  • func (s *ServerImpl) HandleFunc(path string, f func(http.ResponseWriter, *http.Request)) *mux.Route
  • func (s *ServerImpl) InternalRegisterGrpcGateway(reg func(context.Context, *runtime.ServeMux, *grpc.ClientConn) error)
  • func (s *ServerImpl) PathPrefix(path string) *mux.Route
  • func (g *ServerImpl) RegisterGrpcGateway(reg func(context.Context, *runtime.ServeMux, *grpc.ClientConn) error)
  • func (s *ServerImpl) RegisterService(desc *grpc.ServiceDesc, impl interface{})
  • func (s *ServerImpl) Scope(pkg *core.Package) Registrar

Functions

func Listen

func Listen(ctx context.Context, opts ListenOpts, registerServices func(Server)) error

func MakeTCPListener

func MakeTCPListener(address string, port int) func(context.Context) (net.Listener, error)

func NewHTTPMux

func NewHTTPMux(middleware ...mux.MiddlewareFunc) *mux.Router

func Run

func Run(ctx context.Context, opts RunOpts, listenOpts ListenOpts)

Types

type ListenOpts

type ListenOpts struct {
	CreateListener     func(context.Context) (net.Listener, error)
	CreateHttpListener func(context.Context) (net.Listener, error)

	DontHandleSigTerm bool
}

type Registrar

type Registrar interface {
	grpc.ServiceRegistrar

	Handle(path string, p http.Handler) *mux.Route
	PathPrefix(path string) *mux.Route
}

type RunOpts

type RunOpts struct {
	PackageName          string
	RegisterInitializers func(*core.DependencyGraph)
	WireServices         func(context.Context, Server, core.Dependencies) []error
}

type Server

type Server interface {
	InternalRegisterGrpcGateway(reg func(context.Context, *runtime.ServeMux, *grpc.ClientConn) error)
	Scope(*core.Package) Registrar
}

type ServerImpl

type ServerImpl struct {
	// contains filtered or unexported fields
}

Implements the grpc.ServiceRegistrar interface.

func (*ServerImpl) Handle

func (s *ServerImpl) Handle(path string, p http.Handler) *mux.Route

func (*ServerImpl) HandleFunc

func (s *ServerImpl) HandleFunc(path string, f func(http.ResponseWriter, *http.Request)) *mux.Route

func (*ServerImpl) InternalRegisterGrpcGateway

func (s *ServerImpl) InternalRegisterGrpcGateway(reg func(context.Context, *runtime.ServeMux, *grpc.ClientConn) error)

func (*ServerImpl) PathPrefix

func (s *ServerImpl) PathPrefix(path string) *mux.Route

func (*ServerImpl) RegisterGrpcGateway

func (g *ServerImpl) RegisterGrpcGateway(reg func(context.Context, *runtime.ServeMux, *grpc.ClientConn) error)

Deprecated; should use InternalRegisterGrpcGateway.

func (*ServerImpl) RegisterService

func (s *ServerImpl) RegisterService(desc *grpc.ServiceDesc, impl interface{})

func (*ServerImpl) Scope

func (s *ServerImpl) Scope(pkg *core.Package) Registrar