params

Documentation

Index

• func CopyRedactedIngressInfo(info *livekit.IngressInfo) *livekit.IngressInfo
• func InitLogger(conf *config.Config, info *livekit.IngressInfo, ...) error
• func UpdateTranscodingEnabled(info *livekit.IngressInfo)
• type Params
  • func GetParams(ctx context.Context, psrpcClient rpc.IOInfoClient, conf *config.Config, ...) (*Params, error)
  • func (p *Params) CopyInfo() *livekit.IngressInfo
  • func (p *Params) GetLogger() logger.Logger
  • func (p *Params) SendStateUpdate(ctx context.Context)
  • func (p *Params) SetExtraParams(ep any)
  • func (p *Params) SetInputAudioState(ctx context.Context, audioState *livekit.InputAudioState, ...)
  • func (p *Params) SetInputAudioStats(st *ipc.TrackStats)
  • func (p *Params) SetInputVideoState(ctx context.Context, videoState *livekit.InputVideoState, ...)
  • func (p *Params) SetInputVideoStats(st *ipc.TrackStats)
  • func (p *Params) SetRoomId(roomId string)
  • func (p *Params) SetStatus(status livekit.IngressState_Status, err error)
• type WhipExtraParams

Functions

func CopyRedactedIngressInfo

func CopyRedactedIngressInfo(info *livekit.IngressInfo) *livekit.IngressInfo

func InitLogger

func InitLogger(conf *config.Config, info *livekit.IngressInfo, loggingFields map[string]string) error

func UpdateTranscodingEnabled

func UpdateTranscodingEnabled(info *livekit.IngressInfo)

Types

type Params

type Params struct {
	*livekit.IngressInfo
	*config.Config

	AudioEncodingOptions *livekit.IngressAudioEncodingOptions
	VideoEncodingOptions *livekit.IngressVideoEncodingOptions

	// connection info
	WsUrl string
	Token string

	// extra logging fields
	LoggingFields map[string]string

	// relay info
	RelayUrl   string
	RelayToken string
	TmpDir     string

	// Input type specific private parameters
	ExtraParams any
	// contains filtered or unexported fields
}

func GetParams

func GetParams(ctx context.Context, psrpcClient rpc.IOInfoClient, conf *config.Config, info *livekit.IngressInfo, wsUrl, token, relayToken string, loggingFields map[string]string, ep any) (*Params, error)

func (*Params) CopyInfo

func (p *Params) CopyInfo() *livekit.IngressInfo

func (*Params) GetLogger

func (p *Params) GetLogger() logger.Logger

func (*Params) SendStateUpdate

func (p *Params) SendStateUpdate(ctx context.Context)

func (*Params) SetExtraParams

func (p *Params) SetExtraParams(ep any)

Useful in some paths where the extanded params are not known at creation time

func (*Params) SetInputAudioState

func (p *Params) SetInputAudioState(ctx context.Context, audioState *livekit.InputAudioState, sendUpdateIfModified bool)

func (*Params) SetInputAudioStats

func (p *Params) SetInputAudioStats(st *ipc.TrackStats)

func (*Params) SetInputVideoState

func (p *Params) SetInputVideoState(ctx context.Context, videoState *livekit.InputVideoState, sendUpdateIfModified bool)

func (*Params) SetInputVideoStats

func (p *Params) SetInputVideoStats(st *ipc.TrackStats)

func (*Params) SetRoomId

func (p *Params) SetRoomId(roomId string)

func (*Params) SetStatus

func (p *Params) SetStatus(status livekit.IngressState_Status, err error)

type WhipExtraParams

type WhipExtraParams struct {
	MimeTypes map[types.StreamKind]string `json:"mime_types"`
}