http

Documentation

Index

• type Server
• type Splitter
  • func (c *Splitter) Handler(next http.Handler) http.Handler
• type Transport
  • func NewTransport(listener interfaces.Listener) *Transport
  • func (c *Transport) Add(cw int64)
  • func (c *Transport) Close()
  • func (c *Transport) Count() int
  • func (c *Transport) GetRouter() *mux.Router
  • func (c *Transport) NewServer(handle http.Handler, add string, disableHttp2 bool) *Server
  • func (c *Transport) OnStateChange(_ net.Conn, state http.ConnState)
  • func (c *Transport) Run()
  • func (c *Transport) ServerHttp(w http.ResponseWriter, r *http.Request)
  • func (c *Transport) SetGrpcServer(server *grpc.Server)
  • func (c *Transport) SetWebsocket(server *websocket.Transport)
  • 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 Transport

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

func NewTransport

func NewTransport(listener interfaces.Listener) *Transport

func (*Transport) Add

func (c *Transport) Add(cw int64)

Add adds c to the number of active connections.

func (*Transport) Close

func (c *Transport) Close()

func (*Transport) Count

func (c *Transport) Count() int

Count returns the number of connections at the time the call.

func (*Transport) GetRouter

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

func (*Transport) NewServer

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

func (*Transport) OnStateChange

func (c *Transport) OnStateChange(_ net.Conn, state http.ConnState)

OnStateChange records open connections in response to connection state changes. Set net/http Server.ConnState to this method as value.

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

func (c *Transport) SetWebsocket(server *websocket.Transport)

func (*Transport) Start

func (c *Transport) Start()