control

type Control struct {
	Hostname       string
	HTTPServerType string `mapstructure:"http_server_type"`
	HTTPAddress    string `mapstructure:"http_address"`
	HTTPS          bool
	HTTPSHostname  string `mapstructure:"https_hostname"`
	HTTPSCert      string `mapstructure:"https_cert"`
	HTTPSKey       string `mapstructure:"https_key"`

	// Flag to enable saving video stream to file
	// Currently it's global flag toggled from the config file
	SaveVideo bool `mapstructure:"save_video"`
	// contains filtered or unexported fields
}

type FileWriter interface {
	SendRTP(p *rtp.Packet)
	Run()
	Done()
}

type Input interface {
	SetControl(ctrl *Control)
	SetLogger(log logrus.FieldLogger)

	Listen(ctx context.Context)
}

type InputConfig[C any] struct {
	ReadConfig func(map[string]interface{}) C
}

type InputOption struct {
	Name     string
	Default  interface{}
	Value    interface{}
	Required bool
}

type InputType struct {
	Name       string
	New        func(*Control, interface{}) (Input, error)
	ReadConfig InputConfig[any]
	Options    []InputOption
	Config     interface{}
}

type Metadata func(*Stream)

type Output interface {
	SetControl(ctrl *Control)
	SetLogger(log logrus.FieldLogger)

	Listen(ctx context.Context)
}

type Pipe struct {
	Input        string
	Output       string
	Orchestrator string
}

type Stream struct {
	ChannelID types.ChannelID
	StreamID  types.StreamID
	StreamKey types.StreamKey
	// contains filtered or unexported fields
}

type StreamTrack struct {
	Type  webrtc.RTPCodecType
	Codec string
	Track webrtc.TrackLocal
}