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 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 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