Versions in this module Expand all Collapse all v0 v0.1.0 Aug 30, 2026 Changes in this version + const IPCTypeDone + const IPCTypeHello + const IPCTypeInferenceCancel + const IPCTypeInferenceRequest + const IPCTypeInferenceResponse + const IPCTypeInitialize + const IPCTypeReady + const IPCTypeStart + const IPCTypeStatus + const IPCTypeStop + const MaxIPCFrameSize + var ErrClosed = errors.New("worker protocol: transport is closed") + var ErrUnexpectedMessageType = errors.New("worker protocol: expected a binary WebSocket message") + func AgentEndpoint(rawURL, workerToken string) (*url.URL, error) + type Dialer interface + Dial func(context.Context, *url.URL, http.Header) (Transport, error) + type FramedConn struct + func NewFramedConn(conn net.Conn) *FramedConn + func (c *FramedConn) Close() error + func (c *FramedConn) Read(ctx context.Context) (IPCMessage, error) + func (c *FramedConn) Write(ctx context.Context, msg IPCMessage) error + type GorillaDialer struct + HandshakeTimeout time.Duration + Proxy func(*http.Request) (*url.URL, error) + ReadLimit int64 + WriteTimeout time.Duration + func (d GorillaDialer) Dial(ctx context.Context, endpoint *url.URL, header http.Header) (Transport, error) + type IPCMessage struct + APIKey string + APISecret string + Data json.RawMessage + DeadlineUnixNano int64 + Error string + ErrorCode string + FakeJob bool + Job []byte + Method string + Methods []string + ParticipantAttributes map[string]string + ParticipantIdentity string + ParticipantMetadata string + ParticipantName string + Reason string + RequestID string + RoomToken string + Status int32 + Success bool + Token string + Type string + URL string + WorkerID string + type Transport interface + Close func() error + Read func(context.Context) (*livekit.ServerMessage, error) + Write func(context.Context, *livekit.WorkerMessage) error
Go to main page