Help us shape the future of Go! Take the 2026 Go Developer Survey

conformance

package
v1.13.11 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 25, 2026 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Config

type Config struct {
	// ServerURL is the https:// URL of the /agent endpoint (WebTransport).
	ServerURL string
	APIKey    string
	APISecret string

	AgentName  string
	Deployment string
	Endpoints  []*livekit.AgentHttp_AgentEndpoint

	// TargetAddr is the host:port of the local HTTP server streams bridge into.
	TargetAddr string

	// Insecure skips TLS verification (self-signed certs in tests).
	Insecure bool

	Logger logger.Logger
}

type Worker

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

Worker is one registration epoch: a single WebTransport session carrying the control stream and every HTTP-exchange stream.

func New

func New(cfg Config) *Worker

func (*Worker) Close

func (w *Worker) Close()

Close tears down the session.

func (*Worker) Start

func (w *Worker) Start(ctx context.Context) error

Start dials the WebTransport session, registers on the control stream, and begins serving node-opened streams. It returns once registration completes.

func (*Worker) WaitRegistered

func (w *Worker) WaitRegistered(ctx context.Context) error

WaitRegistered blocks until registration completes or ctx is done.

func (*Worker) WorkerID

func (w *Worker) WorkerID() string

WorkerID returns the id assigned by the server (valid after registration).

Jump to

Keyboard shortcuts

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