rtpconn

Documentation

Index

• Variables
• func StartClient(conn *websocket.Conn, addr net.Addr) (err error)
• type WhipClient
  • func NewWhipClient(g *group.Group, id string, token string, addr net.Addr) *WhipClient
  • func (c *WhipClient) Addr() net.Addr
  • func (c *WhipClient) Close() error
  • func (c *WhipClient) Data() map[string]interface{}
  • func (c *WhipClient) GotICECandidate(init webrtc.ICECandidateInit) error
  • func (c *WhipClient) GotOffer(ctx context.Context, offer []byte) ([]byte, error)
  • func (c *WhipClient) Group() *group.Group
  • func (c *WhipClient) Id() string
  • func (c *WhipClient) Joined(group, kind string) error
  • func (c *WhipClient) Kick(id string, user *string, message string) error
  • func (c *WhipClient) NewConnection(ctx context.Context, offer []byte) ([]byte, error)
  • func (c *WhipClient) Permissions() []string
  • func (c *WhipClient) PushClient(group, kind, id, username string, permissions []string, ...) error
  • func (c *WhipClient) PushConn(g *group.Group, id string, conn conn.Up, tracks []conn.UpTrack, replace string) error
  • func (c *WhipClient) RequestConns(target group.Client, g *group.Group, id string) error
  • func (c *WhipClient) SetPermissions(perms []string)
  • func (c *WhipClient) SetUsername(username string)
  • func (c *WhipClient) Token() string
  • func (c *WhipClient) Username() string

Variables

var ErrClientDead = errors.New("client is dead")

var ErrRateLimited = errors.New("rate limited")

var ErrUnknownId = errors.New("unknown id")

var ErrUnknownTrack = errors.New("unknown track")

var ErrUnsupportedFeedback = errors.New("unsupported feedback type")

var ErrUserMismatch = errors.New("user id mismatch")

var ErrWriterBusy = errors.New("writer is busy")

var ErrWriterDead = errors.New("writer is dead")

Functions

func StartClient

func StartClient(conn *websocket.Conn, addr net.Addr) (err error)

Types

type WhipClient

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

func NewWhipClient

func NewWhipClient(g *group.Group, id string, token string, addr net.Addr) *WhipClient

func (*WhipClient) Addr

func (c *WhipClient) Addr() net.Addr

func (*WhipClient) Close

func (c *WhipClient) Close() error

func (*WhipClient) Data

func (c *WhipClient) Data() map[string]interface{}

func (*WhipClient) GotICECandidate

func (c *WhipClient) GotICECandidate(init webrtc.ICECandidateInit) error

func (*WhipClient) GotOffer

func (c *WhipClient) GotOffer(ctx context.Context, offer []byte) ([]byte, error)

func (*WhipClient) Group

func (c *WhipClient) Group() *group.Group

func (*WhipClient) Id

func (c *WhipClient) Id() string

func (*WhipClient) Joined

func (c *WhipClient) Joined(group, kind string) error

func (*WhipClient) Kick

func (c *WhipClient) Kick(id string, user *string, message string) error

func (*WhipClient) NewConnection

func (c *WhipClient) NewConnection(ctx context.Context, offer []byte) ([]byte, error)

func (*WhipClient) Permissions

func (c *WhipClient) Permissions() []string

func (*WhipClient) PushClient

func (c *WhipClient) PushClient(group, kind, id, username string, permissions []string, status map[string]interface{}) error

func (*WhipClient) PushConn

func (c *WhipClient) PushConn(g *group.Group, id string, conn conn.Up, tracks []conn.UpTrack, replace string) error

func (*WhipClient) RequestConns

func (c *WhipClient) RequestConns(target group.Client, g *group.Group, id string) error

func (*WhipClient) SetPermissions

func (c *WhipClient) SetPermissions(perms []string)

func (*WhipClient) SetUsername

func (c *WhipClient) SetUsername(username string)

func (*WhipClient) Token

func (c *WhipClient) Token() string

func (*WhipClient) Username

func (c *WhipClient) Username() string