preview

package

v0.0.0-...-1d32ed5 Latest Latest Go to latest Published: May 8, 2026 License: MIT Imports: 13 Imported by: 0

Details

View Source

const (
	DefaultChunkBytes       = 196608
	DefaultMaxFrameBytes    = 1048576
	DefaultMaxActiveStreams = 32
)

This section is empty.

This section is empty.

type HTTPHandler struct {
	Registry *Registry
	Sender   Sender
	Client   *http.Client
}

func (h *HTTPHandler) Handle(ctx context.Context, msg *protocol.PreviewHTTPRequest) error

type OpenRequest struct {
	PreviewID string
	SessionID string
	ChannelID string
	MachineID string
	Target    Target
	ExpiresAt time.Time
}

type Preview struct {
	OpenRequest
	// contains filtered or unexported fields
}

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

func NewRegistry() *Registry

func (r *Registry) CancelStream(streamID string)

func (r *Registry) Close(previewID string)

func (r *Registry) Get(previewID string) (Preview, bool)

func (r *Registry) Open(_ context.Context, req OpenRequest) error

func (r *Registry) RegisterStream(previewID, streamID string) (context.Context, context.CancelFunc, bool)

func (r *Registry) UnregisterStream(previewID, streamID string)

type Sender interface {
	Send(ctx context.Context, msg any) error
}

type Target struct {
	Host string
	Port int
}

func NormalizeTarget(host string, port int) (Target, error)

func (t Target) Addr() string

func (t Target) Addrs() []string

type WebSocketBridge struct {
	Registry *Registry
	Sender   Sender
	// contains filtered or unexported fields
}

func NewWebSocketBridge(registry *Registry, sender Sender) *WebSocketBridge

func (b *WebSocketBridge) Close(ctx context.Context, msg *protocol.PreviewWebSocketClose) error

func (b *WebSocketBridge) Data(ctx context.Context, msg *protocol.PreviewWebSocketData) error

func (b *WebSocketBridge) Open(ctx context.Context, msg *protocol.PreviewWebSocketOpen) error