stream

Documentation

Index

• Variables
• type WSStreamReverseProxy
  • func (p *WSStreamReverseProxy) ProxyStream(ctx *fiber.Ctx) error

Variables

var DefaultWebSocketUpgrader = &websocket.FastHTTPUpgrader{
	ReadBufferSize:  1024,
	WriteBufferSize: 1024,
}

Default web socket upgrader to upgrade the incoming connections

Types

type WSStreamReverseProxy

type WSStreamReverseProxy struct {
	// This method should not be nul
	// It prepares the stream which should be send to client
	// As an example streaming kubernetes Pod logs somewhere, for example, using selenoid-ui
	// Error will be thrown if this field will be set to nil or not used
	// Mandatory
	PrepareStream func() (io.ReadCloser, error)
	// Upgrader is used to upgrade regular http connection into WenSocket one
	Upgrader *websocket.FastHTTPUpgrader
}

func (*WSStreamReverseProxy) ProxyStream

func (p *WSStreamReverseProxy) ProxyStream(ctx *fiber.Ctx) error