streaming

package

v0.1.1 Latest Latest Go to latest Published: Jul 26, 2026 License: MIT Imports: 13 Imported by: 0

Details

Package streaming exposes authenticated remote media through a temporary loopback-only HTTP endpoint.

This section is empty.

This section is empty.

This section is empty.

type Config struct {
	Username   string
	Password   string
	HTTPClient *http.Client
}

Config configures authenticated upstream media requests.

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

Proxy creates temporary loopback streaming sessions.

func NewProxy(config Config) *Proxy

NewProxy creates a streaming proxy. Credentials remain in memory and are added only to requests sent to the fixed upstream media origin.

func (p *Proxy) Start(ctx context.Context, source *url.URL) (*Session, error)

Start exposes source through a random loopback URL until the context is canceled or the returned session is closed.

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

Session represents one temporary local media endpoint.

func (s *Session) Close() error

Close stops the local streaming server and interrupts active streams.

func (s *Session) Done() <-chan struct{}

Done is closed after the local streaming server stops.

func (s *Session) URL() *url.URL

URL returns a copy of the temporary loopback media URL.