server

Documentation

Index

• type ResponseWriter
  • func NewResponseWriter(dc *dataChannel) *ResponseWriter
  • func (w *ResponseWriter) Flush() error
  • func (w *ResponseWriter) Header() http.Header
  • func (w *ResponseWriter) TriggersShutdown()
  • func (w *ResponseWriter) Write(b []byte) (int, error)
  • func (w *ResponseWriter) WriteHeader(statusCode int)
• type Server
  • func NewServer(config *webrtc.Configuration, bat string, iceGatherTimeout time.Duration, ...) *Server
  • func (s *Server) HandleRequest(ctx context.Context, id string, conf *webrtc.Configuration, ...) error
  • func (s *Server) Wait()

Types

type ResponseWriter

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

func NewResponseWriter

func NewResponseWriter(dc *dataChannel) *ResponseWriter

func (*ResponseWriter) Flush

func (w *ResponseWriter) Flush() error

func (*ResponseWriter) Header

func (w *ResponseWriter) Header() http.Header

func (*ResponseWriter) TriggersShutdown

func (w *ResponseWriter) TriggersShutdown()

func (*ResponseWriter) Write

func (w *ResponseWriter) Write(b []byte) (int, error)

func (*ResponseWriter) WriteHeader

func (w *ResponseWriter) WriteHeader(statusCode int)

type Server

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

Server satisfies the sdp.RequestHandler interface. Server acts as a factory for new peer connections when a client request comes in.

func NewServer

func NewServer(config *webrtc.Configuration, bat string, iceGatherTimeout time.Duration, handler http.HandlerFunc) *Server

func (*Server) HandleRequest

func (s *Server) HandleRequest(ctx context.Context, id string, conf *webrtc.Configuration, answerOfferFunc signallers.AnswerOffer) error

func (*Server) Wait

func (s *Server) Wait()