handler

package

v0.0.5 Latest Latest Go to latest Published: Jun 11, 2024 License: Apache-2.0 Imports: 18 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewProxy(l *logrus.Logger) *Proxy

func (p *Proxy) Connect(r *http.Request) (*websocket.Conn, string, error)

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

func (p *Proxy) RPCHandler() *RPCHandler

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

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

func (h *RPCHandler) GetOrCreateWSUpstreamConnection(w http.ResponseWriter, r *http.Request) (*Upstream, error)

func (h *RPCHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

type RunningRequestPayloads struct {
	Request   []byte
	ResposeCh chan []byte
}

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

func (ws *Upstream) IsRecoverable(err error) bool

func (ws *Upstream) WriteAndGetResponse(ctx context.Context, id int, req []byte) ([]byte, error)