handler

package

v0.1.0 Latest Latest Go to latest Published: Sep 24, 2024 License: Apache-2.0 Imports: 18 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type ProxiedConnection struct {
	Unrecoverable bool
	// contains filtered or unexported fields
}

func (pc *ProxiedConnection) IsRecoverable(err error) bool

func (pc *ProxiedConnection) UpstreamRead(r *http.Request) ([]byte, error)

func (pc *ProxiedConnection) UpstreamWrite(r *http.Request) error

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

func NewProxy(l *logrus.Logger) *Proxy

func (p *Proxy) GetMonitoringEventTypes() []string

func (p *Proxy) ServeHTTP(w http.ResponseWriter, r *http.Request)

func (p *Proxy) SetObserver(mon monitoring.Observer)

type RequestPayload struct {
	Request []byte
	Ready   chan []byte
}

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

func (h *WSProxyHandler) GetOrCreateUpstreamConnection(w http.ResponseWriter, r *http.Request) (*ProxiedConnection, error)