conformance

package
v1.13.8 Latest Latest
Warning

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

Go to latest
Published: Oct 6, 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