worker

package

Go to main page

Versions in this module

v0

v0.0.7

Apr 24, 2026

v0.0.6

Apr 23, 2026

Changes in this version

type AgentServer

+ func (s *AgentServer) CurrentCPULoad() float64

+ func (s *AgentServer) NumActiveJobs() int

type WorkerOptions

+ LoadFn func(*AgentServer) float64

v0.0.5

Apr 22, 2026

Changes in this version

type AgentServer

+ func (s *AgentServer) Drain(ctx context.Context) error

+ func (s *AgentServer) GetEntrypointFunc() func(*JobContext) error

type AudioEncoder

+ Channels func() int

+ SampleRate func() int

+ type AudioInputOptions struct

+ Enabled bool

+ FrameSizeMs int

+ NumChannels int

+ PreConnectAudio bool

+ PreConnectAudioTimeout time.Duration

+ SampleRate int

+ type AudioOutputOptions struct

+ Enabled bool

+ NumChannels int

+ SampleRate int

+ TrackName string

+ TrackPublishOptions *lksdk.TrackPublicationOptions

type JobContext

+ APIKey string

+ APISecret string

+ URL string

type PreConnectAudioHandler

+ func (h *PreConnectAudioHandler) Close()

+ type RecorderAudioInput struct

+ func NewRecorderAudioInput(recordingIO *RecorderIO, source agent.AudioInput) *RecorderAudioInput

+ func (r *RecorderAudioInput) Label() string

+ func (r *RecorderAudioInput) OnAttached()

+ func (r *RecorderAudioInput) OnDetached()

+ func (r *RecorderAudioInput) Stream() <-chan *model.AudioFrame

+ type RecorderAudioOutput struct

+ func NewRecorderAudioOutput(recordingIO *RecorderIO, nextInChain agent.AudioOutput, ...) *RecorderAudioOutput

+ func (r *RecorderAudioOutput) CaptureFrame(frame *model.AudioFrame) error

+ func (r *RecorderAudioOutput) ClearBuffer()

+ func (r *RecorderAudioOutput) Flush()

+ func (r *RecorderAudioOutput) Label() string

+ func (r *RecorderAudioOutput) OnAttached()

+ func (r *RecorderAudioOutput) OnDetached()

+ func (r *RecorderAudioOutput) OnPlaybackFinished(cb func(ev agent.PlaybackFinishedEvent))

+ func (r *RecorderAudioOutput) OnPlaybackStarted(cb func(ev agent.PlaybackStartedEvent))

+ func (r *RecorderAudioOutput) Pause()

+ func (r *RecorderAudioOutput) Resume()

+ func (r *RecorderAudioOutput) WaitForPlayout(ctx context.Context) error

type RoomIO

+ func (rio *RoomIO) CaptureFrame(frame *model.AudioFrame) error

+ func (rio *RoomIO) CaptureVideoFrame(frame *model.VideoFrame) error

+ func (rio *RoomIO) ClearBuffer()

+ func (rio *RoomIO) Flush()

+ func (rio *RoomIO) Identity() string

+ func (rio *RoomIO) Label() string

+ func (rio *RoomIO) OnAttached()

+ func (rio *RoomIO) OnDetached()

+ func (rio *RoomIO) OnPlaybackFinished(f func(ev agent.PlaybackFinishedEvent))

+ func (rio *RoomIO) OnPlaybackStarted(f func(ev agent.PlaybackStartedEvent))

+ func (rio *RoomIO) Pause()

+ func (rio *RoomIO) PublishData(data []byte, topic string, destinationSIDs []string) error

+ func (rio *RoomIO) Resume()

+ func (rio *RoomIO) SetAttributes(attrs map[string]string) error

+ func (rio *RoomIO) SetParticipant(identity string)

+ func (rio *RoomIO) Stream() <-chan *model.AudioFrame

+ func (rio *RoomIO) UnsetParticipant()

+ func (rio *RoomIO) WaitForPlayout(ctx context.Context) error

type RoomOptions

+ AudioInput *AudioInputOptions

+ AudioOutput *AudioOutputOptions

+ CloseOnDisconnect bool

+ DeleteRoomOnClose bool

+ JobContext *JobContext

+ ParticipantIdentity string

+ ParticipantKinds []lksdk.ParticipantKind

+ TextInput *TextInputOptions

+ TextOutput *TextOutputOptions

+ VideoInput *VideoInputOptions

+ VideoOutput *VideoOutputOptions

+ type RoomTextOutput struct

+ func NewRoomTextOutput(room *lksdk.Room, participantIdentity string, url, apiKey, apiSecret string) *RoomTextOutput

+ func (t *RoomTextOutput) CaptureText(text string) error

+ func (t *RoomTextOutput) Close()

+ func (t *RoomTextOutput) Flush()

+ func (t *RoomTextOutput) Label() string

+ func (t *RoomTextOutput) OnAttached()

+ func (t *RoomTextOutput) OnDetached()

+ func (t *RoomTextOutput) SetSegmentID(id string)

+ func (t *RoomTextOutput) SetTrackID(id string)

+ type RoomVideoInput struct

+ func NewRoomVideoInput(rio *RoomIO) *RoomVideoInput

+ func (rvi *RoomVideoInput) Label() string

+ func (rvi *RoomVideoInput) OnAttached()

+ func (rvi *RoomVideoInput) OnDetached()

+ func (rvi *RoomVideoInput) Stream() <-chan *model.VideoFrame

+ type TextInputOptions struct

+ Enabled bool

+ InputHandler func(s *agent.AgentSession, text string) error

+ type TextOutputOptions struct

+ Enabled bool

+ SyncTranscription bool

+ TranscriptionSpeedFactor float64

+ type VideoInputOptions struct

+ Enabled bool

+ type VideoOutputOptions struct

+ Enabled bool

v0.0.4

Apr 17, 2026

v0.0.3

Apr 15, 2026

Changes in this version

type RecorderIO

+ OutPath string

v0.0.2

Apr 14, 2026

v0.0.1

Apr 10, 2026

Changes in this version

+ const PreConnectAudioBufferStream

+ type AgentServer struct

+ Options WorkerOptions

+ func NewAgentServer(opts WorkerOptions) *AgentServer

+ func (s *AgentServer) ExecuteLocalJob(ctx context.Context, roomName string, participantIdentity string) error

+ func (s *AgentServer) GetConsoleSession() any

+ func (s *AgentServer) RTCSession(entrypoint func(*JobContext) error, request func(*JobRequest) error, ...)

+ func (s *AgentServer) Run(ctx context.Context) error

+ func (s *AgentServer) SetConsoleSession(session any)

+ type AudioDecoder interface

+ Close func() error

+ Decode func(data []byte) ([]byte, error)

+ type AudioEncoder interface

+ Close func() error

+ Encode func(pcm []byte) ([]byte, error)

+ type JobAcceptArguments struct

+ Attributes map[string]string

+ Identity string

+ Metadata string

+ Name string

+ type JobContext struct

+ Job *livekit.Job

+ Report *agent.SessionReport

+ Room *lksdk.Room

+ func NewJobContext(job *livekit.Job, url string, apiKey string, apiSecret string) *JobContext

+ func (c *JobContext) AddSIPParticipant(ctx context.Context, callTo string, trunkID string, identity string, ...) (*livekit.SIPParticipantInfo, error)

+ func (c *JobContext) Connect(ctx context.Context, cb *lksdk.RoomCallback) error

+ func (c *JobContext) DeleteRoom(ctx context.Context, roomName string) (*livekit.DeleteRoomResponse, error)

+ func (c *JobContext) Shutdown(reason string)

+ func (c *JobContext) TransferSIPParticipant(ctx context.Context, identity string, transferTo string, playDialtone bool) error

+ type JobRequest struct

+ Job *livekit.Job

+ func (r *JobRequest) Accept(args JobAcceptArguments) error

+ func (r *JobRequest) Reject() error

+ type PreConnectAudioBuffer struct

+ Frames []*model.AudioFrame

+ Timestamp time.Time

+ type PreConnectAudioHandler struct

+ func NewPreConnectAudioHandler(room *lksdk.Room, timeout time.Duration) *PreConnectAudioHandler

+ func (h *PreConnectAudioHandler) Register()

+ func (h *PreConnectAudioHandler) WaitForData(ctx context.Context, trackID string) []*model.AudioFrame

+ type RecorderIO struct

+ InputStartTime *time.Time

+ OutputStartTime *time.Time

+ Session *agent.AgentSession

+ func NewRecorderIO(session *agent.AgentSession) *RecorderIO

+ func (r *RecorderIO) RecordInput(frame *model.AudioFrame)

+ func (r *RecorderIO) RecordOutput(frame *model.AudioFrame)

+ func (r *RecorderIO) Start(outputPath string, sampleRate int) error

+ func (r *RecorderIO) Stop() error

+ type RoomIO struct

+ AgentSession *agent.AgentSession

+ Options RoomOptions

+ Recorder *RecorderIO

+ Room *lksdk.Room

+ func NewRoomIO(room *lksdk.Room, session *agent.AgentSession, opts RoomOptions) *RoomIO

+ func (rio *RoomIO) Close() error

+ func (rio *RoomIO) GetCallback() *lksdk.RoomCallback

+ func (rio *RoomIO) PublishAudio(frame *model.AudioFrame) error

+ func (rio *RoomIO) Start(ctx context.Context) error

+ type RoomOptions struct

+ type WorkerOptions struct

+ APIKey string

+ APISecret string

+ AgentName string

+ DrainTimeoutSeconds int

+ HTTPProxy string

+ JobMemoryLimitMB float64

+ JobMemoryWarnMB float64

+ MaxRetry int

+ NumIdleProcesses int

+ WSRL string

+ WorkerType WorkerType

+ type WorkerType string

+ const WorkerTypePublisher

+ const WorkerTypeRoom

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL