sink

Documentation

Index

• func UploadAliOSS(conf *livekit.AliOSSUpload, localFilePath, requestedPath string) (location string, err error)
• func UploadAzure(conf *livekit.AzureBlobUpload, localFilepath, storageFilepath string, ...) (location string, err error)
• func UploadGCP(conf *livekit.GCPUpload, localFilepath, storageFilepath string) (location string, err error)
• func UploadS3(conf *livekit.S3Upload, localFilepath, storageFilepath string, ...) (location string, err error)
• type PlaylistWriter
  • func NewPlaylistWriter(p *config.PipelineConfig) (*PlaylistWriter, error)
  • func (w *PlaylistWriter) EOS() error
  • func (w *PlaylistWriter) EndSegment(filepath string, endTime int64) error
  • func (w *PlaylistWriter) StartSegment(filepath string, startTime int64) error

Functions

func UploadAliOSS

func UploadAliOSS(conf *livekit.AliOSSUpload, localFilePath, requestedPath string) (location string, err error)

func UploadAzure

func UploadAzure(conf *livekit.AzureBlobUpload, localFilepath, storageFilepath string, mime types.OutputType) (location string, err error)

func UploadGCP

func UploadGCP(conf *livekit.GCPUpload, localFilepath, storageFilepath string) (location string, err error)

func UploadS3

func UploadS3(conf *livekit.S3Upload, localFilepath, storageFilepath string, mime types.OutputType) (location string, err error)

Types

type PlaylistWriter

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

func NewPlaylistWriter

func NewPlaylistWriter(p *config.PipelineConfig) (*PlaylistWriter, error)

func (*PlaylistWriter) EOS

func (w *PlaylistWriter) EOS() error

func (*PlaylistWriter) EndSegment

func (w *PlaylistWriter) EndSegment(filepath string, endTime int64) error

func (*PlaylistWriter) StartSegment

func (w *PlaylistWriter) StartSegment(filepath string, startTime int64) error