recorder

package

v0.0.1 Latest Latest Go to latest Published: Sep 16, 2024 License: MIT Imports: 13 Imported by: 0

Details

This section is empty.

This section is empty.

func GetRandomQuicClient(clientConfig ClientConfig, config []*QuicConfig) (quic.Connection, error)

func NewQuicClient(ctx context.Context, clientConfig ClientConfig, config *QuicConfig) (quic.Connection, error)

type Channel int

const (
	LeftChannel  Channel = 1
	RightChannel Channel = 2
)

type ChannelConfig map[string]int

type ClientConfig struct {
	ClientId   string
	BucketName string
	FileName   string
	Channel    int // 1 to left channel, 2 to right channel
}

type PacketType byte

const (
	ConfigPacket   PacketType = 0x01
	DataPacket     PacketType = 0x02
	RoomEndPacket  PacketType = 0x03
	TrackEndPacket PacketType = 0x04
)

type QuicConfig struct {
	Host     string
	Port     int
	CertFile string
	KeyFile  string
}

type SplitConfig struct {
	Start    time.Duration
	End      time.Duration
	FileName string
}

type StopConfig struct {
	Splits        []SplitConfig
	ChannelConfig ChannelConfig
}

type Track struct {
	TrackID  string
	ClientID string
	RoomID   string
	// contains filtered or unexported fields
}

func (q *Track) Close() error

func (q *Track) Write(p []byte) (int, error)

func (q *Track) WritePacket(packet *rtp.Packet) (int, error)

type TrackConfig struct {
	TrackID  string
	ClientID string
	RoomID   string
	FileName string
	MimeType string
	Channel  int
}

type TrackRecorder interface {
	Write(data []byte) (int, error)
	WritePacket(packet *rtp.Packet) (int, error)
	Close() error
}

func NewTrackRecorder(conf *TrackConfig, stream quic.SendStream) (TrackRecorder, error)