servers

Documentation

Index

• func AdminGRPC(m *noir.Manager, grpcAddr string)
• func AdminGRPCWeb(m *noir.Manager, webAddr string)
• func AdminJSONRPC(mgr *noir.Manager, adminJrpcAddr string, key string, cert string)
• func JobRunner(m *noir.Manager)
• func NewAdminJSONRPC(s *noir.NoirSFU, manager *noir.Manager) *adminJSONRPC
• func NewClientJSONRPCBridge(pid string, manager *noir.Manager) *clientJSONRPCBridge
• func NewGRPCServer(manager *noir.Manager) *grpc.Server
• func PublicJSONRPC(mgr *noir.Manager, publicJrpcAddr string, key string, cert string)
• type JSONableSlice
  • func (u JSONableSlice) MarshalJSON() ([]byte, error)
• type RelayMessage
• type SFUServer
  • func (s *SFUServer) Admin(stream pb.Noir_AdminServer) error
  • func (s *SFUServer) AdminBridge(clientID string, stream pb.Noir_AdminServer) error
  • func (s *SFUServer) Handle(message *pb.NoirRequest, clientID string) (*pb.Empty, error)
  • func (s *SFUServer) Send(ctx context.Context, message *pb.NoirRequest) (*pb.Empty, error)
  • func (s *SFUServer) Subscribe(client *pb.AdminClient, stream pb.Noir_SubscribeServer) error
• type Trickle
• type WrapperedGRPCWebServer
  • func NewWrapperedGRPCWebServer(options WrapperedServerOptions, manager *noir.Manager) *WrapperedGRPCWebServer
  • func (s *WrapperedGRPCWebServer) Serve() error
• type WrapperedServerOptions
  • func DefaultWrapperedServerOptions() WrapperedServerOptions

Functions

func AdminGRPC

func AdminGRPC(m *noir.Manager, grpcAddr string)

func AdminGRPCWeb

func AdminGRPCWeb(m *noir.Manager, webAddr string)

func AdminJSONRPC

func AdminJSONRPC(mgr *noir.Manager, adminJrpcAddr string, key string, cert string)

func JobRunner

func JobRunner(m *noir.Manager)

func NewAdminJSONRPC

func NewAdminJSONRPC(s *noir.NoirSFU, manager *noir.Manager) *adminJSONRPC

func NewClientJSONRPCBridge

func NewClientJSONRPCBridge(pid string, manager *noir.Manager) *clientJSONRPCBridge

func NewGRPCServer

func NewGRPCServer(manager *noir.Manager) *grpc.Server

func PublicJSONRPC

func PublicJSONRPC(mgr *noir.Manager, publicJrpcAddr string, key string, cert string)

Types

type JSONableSlice

type JSONableSlice []uint8

func (JSONableSlice) MarshalJSON

func (u JSONableSlice) MarshalJSON() ([]byte, error)

type RelayMessage

type RelayMessage struct {
	Encoded JSONableSlice `json:"encoded"`
}

type SFUServer

type SFUServer struct {
	pb.UnimplementedNoirServer
	// contains filtered or unexported fields
}

func (*SFUServer) Admin

func (s *SFUServer) Admin(stream pb.Noir_AdminServer) error

func (*SFUServer) AdminBridge

func (s *SFUServer) AdminBridge(clientID string, stream pb.Noir_AdminServer) error

func (*SFUServer) Handle

func (s *SFUServer) Handle(message *pb.NoirRequest, clientID string) (*pb.Empty, error)

func (*SFUServer) Send

func (s *SFUServer) Send(ctx context.Context, message *pb.NoirRequest) (*pb.Empty, error)

func (*SFUServer) Subscribe

func (s *SFUServer) Subscribe(client *pb.AdminClient, stream pb.Noir_SubscribeServer) error

type Trickle

type Trickle struct {
	Target    int                     `json:"target"`
	Candidate webrtc.ICECandidateInit `json:"candidate"`
}

Trickle message sent when renegotiating the peer connection

type WrapperedGRPCWebServer

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

func NewWrapperedGRPCWebServer

func NewWrapperedGRPCWebServer(options WrapperedServerOptions, manager *noir.Manager) *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