pipeline refactor

livekit · Aug 19, 2023 · f7146be · f7146be
1 parent bef981b
commit f7146be
Show file tree

Hide file tree

Showing 16 changed files with 402 additions and 441 deletions.
diff --git a/pkg/config/base.go b/pkg/config/base.go
@@ -105,6 +105,9 @@ func (c *BaseConfig) initLogger(values ...interface{}) error {
 	if err := os.Setenv("GST_DEBUG", gstDebug); err != nil {
 		return err
 	}
+	if err := os.Setenv("GST_DEBUG_DUMP_DOT_DIR", "/out/output"); err != nil {
+		return err
+	}
 
 	zl, err := logger.NewZapLogger(c.Logging)
 	if err != nil {

diff --git a/pkg/config/pipeline.go b/pkg/config/pipeline.go
@@ -98,6 +98,7 @@ type TrackSource struct {
 	MimeType    types.MimeType
 	PayloadType webrtc.PayloadType
 	ClockRate   uint32
+	EOSFunc     func()
 }
 
 type AudioConfig struct {