http

Documentation

Index

• type Server
• type Splitter
  • func (c *Splitter) Handler(next http.Handler) http.Handler
• type TcpKeepAliveListener
  • func (ln TcpKeepAliveListener) Accept() (c net.Conn, err error)
• type Transport
  • func NewTransport(listener interfaces.Listener) *Transport
  • func (c *Transport) GetRpouter() *mux.Router
  • func (c *Transport) NewServer(handle http.Handler, add string) *Server
  • func (c *Transport) Run()
  • func (c *Transport) ServerHttp(w http.ResponseWriter, r *http.Request)
  • func (c *Transport) SetGrpcServer(server *grpc.Server)
  • func (c *Transport) Start()

Types

type Server

type Server struct {
	Server *http.Server
	// contains filtered or unexported fields
}

type Splitter

type Splitter struct {
	*splitter.WrappedGrpcServer
}

func (*Splitter) Handler

func (c *Splitter) Handler(next http.Handler) http.Handler

type TcpKeepAliveListener

type TcpKeepAliveListener struct {
	*net.TCPListener
}

func (TcpKeepAliveListener) Accept

func (ln TcpKeepAliveListener) Accept() (c net.Conn, err error)

type Transport

type Transport struct {
	InsecureServer *Server
	SecureServer   *Server
	// contains filtered or unexported fields
}

func NewTransport

func NewTransport(listener interfaces.Listener) *Transport

func (*Transport) GetRpouter

func (c *Transport) GetRpouter() *mux.Router

func (*Transport) NewServer

func (c *Transport) NewServer(handle http.Handler, add string) *Server

func (*Transport) Run

func (c *Transport) Run()

func (*Transport) ServerHttp

func (c *Transport) ServerHttp(w http.ResponseWriter, r *http.Request)

func (*Transport) SetGrpcServer

func (c *Transport) SetGrpcServer(server *grpc.Server)

func (*Transport) Start

func (c *Transport) Start()