server

Documentation

Index

• type SFUServer
  • func NewServer(sfu *sfu.SFU) *SFUServer
  • func (s *SFUServer) Signal(stream pb.SFU_SignalServer) error
• type WrapperedGRPCWebServer
  • func NewWrapperedGRPCWebServer(options WrapperedServerOptions, sfu *sfu.SFU) *WrapperedGRPCWebServer
  • func (s *WrapperedGRPCWebServer) Serve() error
• type WrapperedServerOptions
  • func DefaultWrapperedServerOptions() WrapperedServerOptions

Types

type SFUServer

type SFUServer struct {
	pb.UnimplementedSFUServer
	sync.Mutex
	SFU *sfu.SFU
}

func NewServer

func NewServer(sfu *sfu.SFU) *SFUServer

func (*SFUServer) Signal

func (s *SFUServer) Signal(stream pb.SFU_SignalServer) error

Publish a stream to the sfu. Publish creates a bidirectional streaming rpc connection between the client and sfu.

The sfu will respond with a message containing the stream pid and one of two different payload types: 1. `Connect` containing the session answer description. This message is *always* returned first. 2. `Trickle` containing candidate information for Trickle ICE.

If the webrtc connection is closed, the server will close this stream.

The client should send a message containing the session id and one of two different payload types: 1. `Connect` containing the session offer description. This message must *always* be sent first. 2. `Trickle` containing candidate information for Trickle ICE.

If the client closes this stream, the webrtc stream will be closed.

type WrapperedGRPCWebServer

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

func NewWrapperedGRPCWebServer

func NewWrapperedGRPCWebServer(options WrapperedServerOptions, sfu *sfu.SFU) *WrapperedGRPCWebServer

func (*WrapperedGRPCWebServer) Serve

func (s *WrapperedGRPCWebServer) Serve() error

type WrapperedServerOptions

type WrapperedServerOptions struct {
	Addr                  string
	EnableTLS             bool
	TLSAddr               string
	Cert                  string
	Key                   string
	AllowAllOrigins       bool
	AllowedOrigins        *[]string
	AllowedHeaders        *[]string
	UseWebSocket          bool
	WebsocketPingInterval time.Duration
}

func DefaultWrapperedServerOptions

func DefaultWrapperedServerOptions() WrapperedServerOptions