client

Documentation

Index

• func GetIceServers(config *config.Config, logger *slog.Logger, testRunId xid.ID) (map[string]adapters.IceServersConfig, string, error)
• type Client
  • func NewClient(config *config.Config, iceServerInfo *stun.URI, provider string, ...) (c *Client, err error)
  • func (c *Client) Run()
  • func (c *Client) Stop() error
• type ConnectionPair
  • func NewConnectionPair(config *config.Config, iceServerInfo *stun.URI, provider string, ...) (c *ConnectionPair, err error)
• type IceServersConfig
• type PC
  • func (pc *PC) Stop()

Functions

func GetIceServers

func GetIceServers(config *config.Config, logger *slog.Logger, testRunId xid.ID) (map[string]adapters.IceServersConfig, string, error)

Types

type Client

type Client struct {
	ConnectionPair    *ConnectionPair
	OffererConnected  chan bool
	AnswererConnected chan bool

	Logger *slog.Logger

	Stats *stats.Stats
	// contains filtered or unexported fields
}

func NewClient

func NewClient(config *config.Config, iceServerInfo *stun.URI, provider string, testRunId xid.ID, testRunStartedAt time.Time, doThroughputTest bool, close chan struct{}) (c *Client, err error)

func (*Client) Run

func (c *Client) Run()

func (*Client) Stop

func (c *Client) Stop() error

type ConnectionPair

type ConnectionPair struct {
	OfferPC     *webrtc.PeerConnection
	OfferDC     *webrtc.DataChannel
	AnswerPC    *webrtc.PeerConnection
	LogOfferer  *slog.Logger
	LogAnswerer *slog.Logger
	// contains filtered or unexported fields
}

func NewConnectionPair

func NewConnectionPair(config *config.Config, iceServerInfo *stun.URI, provider string, stats *stats.Stats, doThroughputTest bool, closeChan chan struct{}) (c *ConnectionPair, err error)

type IceServersConfig

type IceServersConfig struct {
	IceServers   map[string][]webrtc.ICEServer
	DoThroughput bool
}

type PC

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

func (*PC) Stop

func (pc *PC) Stop()