http

package
v0.0.0-...-a2b917b Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 30, 2024 License: MIT Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Agent 

type Agent interface {
	Http() Http
	CreateConnection(ctx context.Context, options net.ConnectOptions, connectListener *isolates.Value) (net.Socket, error)
	GetName(ctx context.Context, options AgentRequestOptions) (string, error)
}

type AgentBase 

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

func (*AgentBase) CreateConnection 

func (a *AgentBase) CreateConnection(ctx context.Context, options net.ConnectOptions, connectListener *isolates.Value) (net.Socket, error)

func (*AgentBase) GetName 

func (a *AgentBase) GetName(ctx context.Context, options AgentRequestOptions) (string, error)

func (*AgentBase) Http 

func (a *AgentBase) Http() Http

func (*AgentBase) V8FuncCreateConnection 

func (a *AgentBase) V8FuncCreateConnection(in isolates.FunctionArgs) (*isolates.Value, error)

func (*AgentBase) V8FuncGetName 

func (a *AgentBase) V8FuncGetName(in isolates.FunctionArgs) (*isolates.Value, error)

type AgentRequestOptions 

type AgentRequestOptions struct {
	Host         string    `v8:"host"`
	Port         int       `v8:"port"`
	LocalAddress string    `v8:"localAddress"`
	Family       *IPFamily `v8:"family"`
}

type ClientRequest 

type ClientRequest interface {
	OutgoingMessage

	MaxHeadersCount() int
	SetMaxHeadersCount(int)
	Path() string
	SetPath(string)
	Method() string
	SetMethod(string)
	Host() string
	SetHost(string)
	Protocol() string
	SetProtocol(string)
	ReusedSocket() bool
	SetNoDelay(bool)
	SetSocketKeepAlive(bool, time.Duration)

	Wait() error
}

type ClientRequestBase 

type ClientRequestBase struct {
	*OutgoingMessageBase
	// contains filtered or unexported fields
}

func NewClientRequest 

func NewClientRequest(in isolates.FunctionArgs) (*ClientRequestBase, error)

func (*ClientRequestBase) FlushHeaders 

func (r *ClientRequestBase) FlushHeaders() error

func (*ClientRequestBase) Host 

func (r *ClientRequestBase) Host() string

func (*ClientRequestBase) MaxHeadersCount 

func (r *ClientRequestBase) MaxHeadersCount() int

func (*ClientRequestBase) Method 

func (r *ClientRequestBase) Method() string

func (*ClientRequestBase) Path 

func (r *ClientRequestBase) Path() string

func (*ClientRequestBase) Protocol 

func (r *ClientRequestBase) Protocol() string

func (*ClientRequestBase) ReusedSocket 

func (r *ClientRequestBase) ReusedSocket() bool

func (*ClientRequestBase) SetHost 

func (r *ClientRequestBase) SetHost(host string)

func (*ClientRequestBase) SetMaxHeadersCount 

func (r *ClientRequestBase) SetMaxHeadersCount(int)

func (*ClientRequestBase) SetMethod 

func (r *ClientRequestBase) SetMethod(method string)

func (*ClientRequestBase) SetNoDelay 

func (r *ClientRequestBase) SetNoDelay(bool)

func (*ClientRequestBase) SetPath 

func (r *ClientRequestBase) SetPath(path string)

func (*ClientRequestBase) SetProtocol 

func (r *ClientRequestBase) SetProtocol(string)

func (*ClientRequestBase) SetSocketKeepAlive 

func (r *ClientRequestBase) SetSocketKeepAlive(bool, time.Duration)

func (*ClientRequestBase) Socket 

func (r *ClientRequestBase) Socket() net.Socket

func (*ClientRequestBase) V8FuncFlushHeaders 

func (r *ClientRequestBase) V8FuncFlushHeaders(in isolates.FunctionArgs) (*isolates.Value, error)

func (*ClientRequestBase) V8FuncSetNoDelay 

func (r *ClientRequestBase) V8FuncSetNoDelay(in isolates.FunctionArgs) (*isolates.Value, error)

func (*ClientRequestBase) V8FuncSetSocketKeepAlive 

func (r *ClientRequestBase) V8FuncSetSocketKeepAlive(in isolates.FunctionArgs) (*isolates.Value, error)

func (*ClientRequestBase) V8GetHost 

func (r *ClientRequestBase) V8GetHost(in isolates.GetterArgs) (*isolates.Value, error)

func (*ClientRequestBase) V8GetMaxHeadersCount 

func (r *ClientRequestBase) V8GetMaxHeadersCount(in isolates.GetterArgs) (*isolates.Value, error)

func (*ClientRequestBase) V8GetMethod 

func (r *ClientRequestBase) V8GetMethod(in isolates.GetterArgs) (*isolates.Value, error)

func (*ClientRequestBase) V8GetPath 

func (r *ClientRequestBase) V8GetPath(in isolates.GetterArgs) (*isolates.Value, error)

func (*ClientRequestBase) V8GetProtocol 

func (r *ClientRequestBase) V8GetProtocol(in isolates.GetterArgs) (*isolates.Value, error)

func (*ClientRequestBase) V8GetReusedSocket 

func (r *ClientRequestBase) V8GetReusedSocket(in isolates.GetterArgs) (*isolates.Value, error)

func (*ClientRequestBase) V8GetSocket 

func (r *ClientRequestBase) V8GetSocket(in isolates.GetterArgs) (*isolates.Value, error)

type ClientResponse 

type ClientResponse interface {
	IncomingMessage

	StatusCode() int
	StatusMessage() string
}

type ClientResponseBase 

type ClientResponseBase struct {
	*IncomingMessageBase
	// contains filtered or unexported fields
}

func NewClientResponse 

func NewClientResponse(in isolates.FunctionArgs) (*ClientResponseBase, error)

func (*ClientResponseBase) StatusCode 

func (r *ClientResponseBase) StatusCode() int

func (*ClientResponseBase) StatusMessage 

func (r *ClientResponseBase) StatusMessage() string

func (*ClientResponseBase) V8GetStatusCode 

func (r *ClientResponseBase) V8GetStatusCode(in isolates.GetterArgs) (*isolates.Value, error)

func (*ClientResponseBase) V8GetStatusMessage 

func (r *ClientResponseBase) V8GetStatusMessage(in isolates.GetterArgs) (*isolates.Value, error)

type Http 

type Http interface {
	Net() net.Net
	Server() *isolates.Value
	Agent() *isolates.Value
}

func NewDefaultHttp 

func NewDefaultHttp(in isolates.RuntimeFunctionArgs) (Http, error)

type HttpBase 

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

func NewHttp 

func NewHttp(in isolates.FunctionArgs) (*HttpBase, error)

func (*HttpBase) Agent 

func (h *HttpBase) Agent() *isolates.Value

func (*HttpBase) GlobalAgent 

func (h *HttpBase) GlobalAgent() Agent

func (*HttpBase) Net 

func (h *HttpBase) Net() net.Net

func (*HttpBase) Request 

func (h *HttpBase) Request(ctx context.Context, args ...any) (ClientRequest, error)

func (*HttpBase) Server 

func (h *HttpBase) Server() *isolates.Value

func (*HttpBase) V8FuncRequest 

func (h *HttpBase) V8FuncRequest(in isolates.FunctionArgs) (*isolates.Value, error)

func (*HttpBase) V8GetAgent 

func (h *HttpBase) V8GetAgent(in isolates.GetterArgs) (*isolates.Value, error)

func (*HttpBase) V8GetGlobalAgent 

func (h *HttpBase) V8GetGlobalAgent(in isolates.GetterArgs) (*isolates.Value, error)

func (*HttpBase) V8GetNet 

func (h *HttpBase) V8GetNet(in isolates.GetterArgs) (*isolates.Value, error)

func (*HttpBase) V8GetServer 

func (h *HttpBase) V8GetServer(in isolates.GetterArgs) (*isolates.Value, error)

type HttpInformation 

type HttpInformation interface {
	HttpVersion() string
	HttpVersionMajor() int
	HttpVersionMinor() int
	StatusCode() int
	StatusMessage() string
	Headers() http.Header
	RawHeaders() []string
}

type HttpServerOptions 

type HttpServerOptions struct {
	ConnectionsCheckingInterval time.Duration `json:"connectionsCheckingInterval"`
	HeadersTimeout              time.Duration `json:"headersTimeout"`
	HighWaterMark               int           `json:"highWaterMark"`
	JoinDuplicateHeaders        bool          `json:"joinDuplicateHeaders"`
	KeepAlive                   bool          `json:"keepAlive"`
	KeepAliveInitialDelay       time.Duration `json:"keepAliveInitialDelay"`
	KeepAliveTimeout            time.Duration `json:"keepAliveTimeout"`
	MaxHeaderSize               int           `json:"maxHeaderSize"`
	NoDelay                     bool          `json:"noDelay"`
	RequestTimeout              time.Duration `json:"requestTimeout"`
	RequireHostHeader           bool          `json:"requireHostHeader"`
	UniqueHeaders               []string      `json:"uniqueHeaders"`
}

type IPFamily 

type IPFamily int
const (
	IPv4 IPFamily = 4
	IPv6 IPFamily = 6
)

type IncomingMessage 

type IncomingMessage interface {
	stream.Readable

	Complete() bool
	Headers() map[string]any
	HeadersDistinct() http.Header
	HttpVersion() string

	RawHeaders() []string
	RawTrailers() []string
	SetTimeout(context.Context, time.Duration, *isolates.Value) error
	Trailers() http.Header
	TrailersDistinct() http.Header
}

type IncomingMessageBase 

type IncomingMessageBase struct {
	*stream.ReadableBase
	// contains filtered or unexported fields
}

func NewIncomingMessage 

func NewIncomingMessage(in isolates.FunctionArgs) (*IncomingMessageBase, error)

func (*IncomingMessageBase) Complete 

func (r *IncomingMessageBase) Complete() bool

func (*IncomingMessageBase) Headers 

func (r *IncomingMessageBase) Headers() map[string]any

func (*IncomingMessageBase) HeadersDistinct 

func (r *IncomingMessageBase) HeadersDistinct() http.Header

func (*IncomingMessageBase) HttpVersion 

func (r *IncomingMessageBase) HttpVersion() string

func (*IncomingMessageBase) RawHeaders 

func (r *IncomingMessageBase) RawHeaders() []string

func (*IncomingMessageBase) RawTrailers 

func (r *IncomingMessageBase) RawTrailers() []string

func (*IncomingMessageBase) SetTimeout 

func (r *IncomingMessageBase) SetTimeout(ctx context.Context, timeout time.Duration, listener *isolates.Value) error

func (*IncomingMessageBase) Trailers 

func (r *IncomingMessageBase) Trailers() http.Header

func (*IncomingMessageBase) TrailersDistinct 

func (r *IncomingMessageBase) TrailersDistinct() http.Header

func (*IncomingMessageBase) V8FuncSetTimeout 

func (r *IncomingMessageBase) V8FuncSetTimeout(in isolates.FunctionArgs) (*isolates.Value, error)

func (*IncomingMessageBase) V8GetComplete 

func (r *IncomingMessageBase) V8GetComplete(in isolates.GetterArgs) (*isolates.Value, error)

func (*IncomingMessageBase) V8GetHeaders 

func (r *IncomingMessageBase) V8GetHeaders(in isolates.GetterArgs) (*isolates.Value, error)

func (*IncomingMessageBase) V8GetHeadersDistinct 

func (r *IncomingMessageBase) V8GetHeadersDistinct(in isolates.GetterArgs) (*isolates.Value, error)

func (*IncomingMessageBase) V8GetHttpVersion 

func (r *IncomingMessageBase) V8GetHttpVersion(in isolates.GetterArgs) (*isolates.Value, error)

func (*IncomingMessageBase) V8GetRawHeaders 

func (r *IncomingMessageBase) V8GetRawHeaders(in isolates.GetterArgs) (*isolates.Value, error)

func (*IncomingMessageBase) V8GetRawTrailers 

func (r *IncomingMessageBase) V8GetRawTrailers(in isolates.GetterArgs) (*isolates.Value, error)

func (*IncomingMessageBase) V8GetTrailers 

func (r *IncomingMessageBase) V8GetTrailers(in isolates.GetterArgs) (*isolates.Value, error)

func (*IncomingMessageBase) V8GetTrailersDistinct 

func (r *IncomingMessageBase) V8GetTrailersDistinct(in isolates.GetterArgs) (*isolates.Value, error)

type OutgoingMessage 

type OutgoingMessage interface {
	stream.Writable

	AddTrailers(headers http.Header)
	AppendHeader(name string, values []string)
	Destroyed() bool
	Finished() bool
	FlushHeaders() error
	GetHeader(name string) []string
	GetHeaderNames() []string
	GetRawHeaderNames() []string
	Headers() map[string]any
	HasHeader(name string) bool
	HeadersSent() bool
	RemoveHeader(name string)
	SetHeader(ctx context.Context, name string, value *isolates.Value) error
	SetHeaders(headers http.Header)
	SetTimeout(time.Duration, func() error) func()
}

type OutgoingMessageBase 

type OutgoingMessageBase struct {
	*stream.WritableBase
	// contains filtered or unexported fields
}

func NewOutgoingMessage 

func NewOutgoingMessage(in isolates.FunctionArgs) (*OutgoingMessageBase, error)

func (*OutgoingMessageBase) AddTrailers 

func (r *OutgoingMessageBase) AddTrailers(headers http.Header)

func (*OutgoingMessageBase) AppendHeader 

func (r *OutgoingMessageBase) AppendHeader(name string, values []string)

func (*OutgoingMessageBase) Destroyed 

func (r *OutgoingMessageBase) Destroyed() bool

func (*OutgoingMessageBase) Finished 

func (r *OutgoingMessageBase) Finished() bool

func (*OutgoingMessageBase) FlushHeaders 

func (r *OutgoingMessageBase) FlushHeaders() error

func (*OutgoingMessageBase) GetHeader 

func (r *OutgoingMessageBase) GetHeader(name string) []string

func (*OutgoingMessageBase) GetHeaderNames 

func (r *OutgoingMessageBase) GetHeaderNames() []string

func (*OutgoingMessageBase) GetRawHeaderNames 

func (r *OutgoingMessageBase) GetRawHeaderNames() []string

func (*OutgoingMessageBase) HasHeader 

func (r *OutgoingMessageBase) HasHeader(name string) bool

func (*OutgoingMessageBase) Headers 

func (r *OutgoingMessageBase) Headers() map[string]any

func (*OutgoingMessageBase) HeadersSent 

func (r *OutgoingMessageBase) HeadersSent() bool

func (*OutgoingMessageBase) RemoveHeader 

func (r *OutgoingMessageBase) RemoveHeader(name string)

func (*OutgoingMessageBase) SendDate 

func (r *OutgoingMessageBase) SendDate() bool

func (*OutgoingMessageBase) SetHeader 

func (r *OutgoingMessageBase) SetHeader(ctx context.Context, name string, value *isolates.Value) error

func (*OutgoingMessageBase) SetHeaders 

func (r *OutgoingMessageBase) SetHeaders(headers http.Header)

func (*OutgoingMessageBase) SetSendDate 

func (r *OutgoingMessageBase) SetSendDate(bool)

func (*OutgoingMessageBase) SetStrictContentLength 

func (r *OutgoingMessageBase) SetStrictContentLength(bool)

func (*OutgoingMessageBase) SetTimeout 

func (r *OutgoingMessageBase) SetTimeout(timeout time.Duration, listener func() error) func()

func (*OutgoingMessageBase) StrictContentLength 

func (r *OutgoingMessageBase) StrictContentLength() bool

func (*OutgoingMessageBase) V8FuncAddTrailers 

func (r *OutgoingMessageBase) V8FuncAddTrailers(in isolates.FunctionArgs) (*isolates.Value, error)

func (*OutgoingMessageBase) V8FuncAppendHeader 

func (r *OutgoingMessageBase) V8FuncAppendHeader(in isolates.FunctionArgs) (*isolates.Value, error)

func (*OutgoingMessageBase) V8FuncGetHeader 

func (r *OutgoingMessageBase) V8FuncGetHeader(in isolates.FunctionArgs) (*isolates.Value, error)

func (*OutgoingMessageBase) V8FuncGetHeaderNames 

func (r *OutgoingMessageBase) V8FuncGetHeaderNames(in isolates.FunctionArgs) (*isolates.Value, error)

func (*OutgoingMessageBase) V8FuncGetRawHeaderNames 

func (r *OutgoingMessageBase) V8FuncGetRawHeaderNames(in isolates.FunctionArgs) (*isolates.Value, error)

func (*OutgoingMessageBase) V8FuncHasHeader 

func (r *OutgoingMessageBase) V8FuncHasHeader(in isolates.FunctionArgs) (*isolates.Value, error)

func (*OutgoingMessageBase) V8FuncRemoveHeader 

func (r *OutgoingMessageBase) V8FuncRemoveHeader(in isolates.FunctionArgs) (*isolates.Value, error)

func (*OutgoingMessageBase) V8FuncSetHeader 

func (r *OutgoingMessageBase) V8FuncSetHeader(in isolates.FunctionArgs) (*isolates.Value, error)

func (*OutgoingMessageBase) V8FuncSetHeaders 

func (r *OutgoingMessageBase) V8FuncSetHeaders(in isolates.FunctionArgs) (*isolates.Value, error)

func (*OutgoingMessageBase) V8FuncSetTimeout 

func (r *OutgoingMessageBase) V8FuncSetTimeout(in isolates.FunctionArgs) (*isolates.Value, error)

func (*OutgoingMessageBase) V8FuncWait 

func (r *OutgoingMessageBase) V8FuncWait(in isolates.FunctionArgs) (*isolates.Value, error)

func (*OutgoingMessageBase) V8FuncWriteContinue 

func (r *OutgoingMessageBase) V8FuncWriteContinue(in isolates.FunctionArgs) (*isolates.Value, error)

func (*OutgoingMessageBase) V8FuncWriteEarlyHints 

func (r *OutgoingMessageBase) V8FuncWriteEarlyHints(in isolates.FunctionArgs) (*isolates.Value, error)

func (*OutgoingMessageBase) V8FuncWriteProcessing 

func (r *OutgoingMessageBase) V8FuncWriteProcessing(in isolates.FunctionArgs) (*isolates.Value, error)

func (*OutgoingMessageBase) V8GetDestroyed 

func (r *OutgoingMessageBase) V8GetDestroyed(in isolates.GetterArgs) (*isolates.Value, error)

func (*OutgoingMessageBase) V8GetFinished 

func (r *OutgoingMessageBase) V8GetFinished(in isolates.GetterArgs) (*isolates.Value, error)

func (*OutgoingMessageBase) V8GetHeaders 

func (r *OutgoingMessageBase) V8GetHeaders(in isolates.GetterArgs) (*isolates.Value, error)

func (*OutgoingMessageBase) V8GetHeadersSent 

func (r *OutgoingMessageBase) V8GetHeadersSent(in isolates.GetterArgs) (*isolates.Value, error)

func (*OutgoingMessageBase) V8GetSendDate 

func (r *OutgoingMessageBase) V8GetSendDate(in isolates.GetterArgs) (*isolates.Value, error)

func (*OutgoingMessageBase) V8GetStrictContentLength 

func (r *OutgoingMessageBase) V8GetStrictContentLength(in isolates.GetterArgs) (*isolates.Value, error)

func (*OutgoingMessageBase) V8GetWritableEnded 

func (r *OutgoingMessageBase) V8GetWritableEnded(in isolates.GetterArgs) (*isolates.Value, error)

func (*OutgoingMessageBase) V8GetWritableFinished 

func (r *OutgoingMessageBase) V8GetWritableFinished(in isolates.GetterArgs) (*isolates.Value, error)

func (*OutgoingMessageBase) Wait 

func (r *OutgoingMessageBase) Wait() error

func (*OutgoingMessageBase) WritableEnded 

func (r *OutgoingMessageBase) WritableEnded() bool

func (*OutgoingMessageBase) WritableFinished 

func (r *OutgoingMessageBase) WritableFinished() bool

func (*OutgoingMessageBase) WriteContinue 

func (r *OutgoingMessageBase) WriteContinue() error

func (*OutgoingMessageBase) WriteEarlyHints 

func (r *OutgoingMessageBase) WriteEarlyHints(header http.Header) error

func (*OutgoingMessageBase) WriteHead 

func (r *OutgoingMessageBase) WriteHead(statusCode int, statusMessage string, headers http.Header) error

func (*OutgoingMessageBase) WriteProcessing 

func (r *OutgoingMessageBase) WriteProcessing() error

type Server 

type Server interface {
	net.Server

	CloseAllConnections() error
	CloseIdleConnections() error
	HeadersTimeout() time.Duration
	SetHeadersTimeout(time.Duration)
	MaxHeadersCount() int
	SetMaxHeadersCount(int)
	RequestTimeout() time.Duration
	SetRequestTimeout(time.Duration)
	Timeout() time.Duration
	SetTimeout(ctx context.Context, timeout time.Duration, listener *isolates.Value) error
	MaxRequestsPerSocket() int
	SetMaxRequestsPerSocket(int)
	KeepAliveTimeout() time.Duration
	SetKeepAliveTimeout(time.Duration)
}

type ServerBase 

type ServerBase struct {
	*net.ServerBase

	This *isolates.Value
	// contains filtered or unexported fields
}

func (*ServerBase) CloseAllConnections 

func (l *ServerBase) CloseAllConnections() error

func (*ServerBase) CloseIdleConnections 

func (l *ServerBase) CloseIdleConnections() error

func (*ServerBase) HeadersTimeout 

func (l *ServerBase) HeadersTimeout() time.Duration

func (*ServerBase) KeepAliveTimeout 

func (l *ServerBase) KeepAliveTimeout() time.Duration

func (*ServerBase) MaxHeadersCount 

func (l *ServerBase) MaxHeadersCount() int

func (*ServerBase) MaxRequestsPerSocket 

func (l *ServerBase) MaxRequestsPerSocket() int

func (*ServerBase) RequestTimeout 

func (l *ServerBase) RequestTimeout() time.Duration

func (*ServerBase) SetHeadersTimeout 

func (l *ServerBase) SetHeadersTimeout(headersTimeout time.Duration)

func (*ServerBase) SetKeepAliveTimeout 

func (l *ServerBase) SetKeepAliveTimeout(keepAliveTimeout time.Duration)

func (*ServerBase) SetMaxHeadersCount 

func (l *ServerBase) SetMaxHeadersCount(maxHeadersCount int)

func (*ServerBase) SetMaxRequestsPerSocket 

func (l *ServerBase) SetMaxRequestsPerSocket(maxRequestsPerSocket int)

func (*ServerBase) SetRequestTimeout 

func (l *ServerBase) SetRequestTimeout(requestTimeout time.Duration)

func (*ServerBase) SetTimeout 

func (l *ServerBase) SetTimeout(ctx context.Context, timeout time.Duration, listener *isolates.Value) error

func (*ServerBase) Timeout 

func (l *ServerBase) Timeout() time.Duration

func (*ServerBase) V8FuncCloseAllConnections 

func (l *ServerBase) V8FuncCloseAllConnections(in isolates.FunctionArgs) (*isolates.Value, error)

func (*ServerBase) V8FuncCloseIdleConnections 

func (l *ServerBase) V8FuncCloseIdleConnections(in isolates.FunctionArgs) (*isolates.Value, error)

func (*ServerBase) V8FuncSetTimeout 

func (l *ServerBase) V8FuncSetTimeout(in isolates.FunctionArgs) (*isolates.Value, error)

func (*ServerBase) V8GetHeadersTimeout 

func (l *ServerBase) V8GetHeadersTimeout(in isolates.GetterArgs) (*isolates.Value, error)

func (*ServerBase) V8GetKeepAliveTimeout 

func (l *ServerBase) V8GetKeepAliveTimeout(in isolates.GetterArgs) (*isolates.Value, error)

func (*ServerBase) V8GetMaxHeadersCount 

func (l *ServerBase) V8GetMaxHeadersCount(in isolates.GetterArgs) (*isolates.Value, error)

func (*ServerBase) V8GetMaxRequestsPerSocket 

func (l *ServerBase) V8GetMaxRequestsPerSocket(in isolates.GetterArgs) (*isolates.Value, error)

func (*ServerBase) V8GetRequestTimeout 

func (l *ServerBase) V8GetRequestTimeout(in isolates.GetterArgs) (*isolates.Value, error)

func (*ServerBase) V8GetTimeout 

func (l *ServerBase) V8GetTimeout(in isolates.GetterArgs) (*isolates.Value, error)

type ServerRequest 

type ServerRequest interface {
	IncomingMessage

	Response(context.Context) (ServerResponse, error)
	Socket() net.Socket

	IsUpgrade() bool

	Method() string
	URL() string
}

type ServerRequestBase 

type ServerRequestBase struct {
	*IncomingMessageBase
	*events.EventEmitterBase
	// contains filtered or unexported fields
}

func NewServerRequest 

func NewServerRequest(in isolates.FunctionArgs) (*ServerRequestBase, error)

func (*ServerRequestBase) IsUpgrade 

func (r *ServerRequestBase) IsUpgrade() bool

func (*ServerRequestBase) Method 

func (r *ServerRequestBase) Method() string

func (*ServerRequestBase) Response 

func (r *ServerRequestBase) Response(ctx context.Context) (ServerResponse, error)

func (*ServerRequestBase) Socket 

func (r *ServerRequestBase) Socket() net.Socket

func (*ServerRequestBase) URL 

func (r *ServerRequestBase) URL() string

func (*ServerRequestBase) V8GetMethod 

func (r *ServerRequestBase) V8GetMethod(in isolates.GetterArgs) (*isolates.Value, error)

func (*ServerRequestBase) V8GetSocket 

func (r *ServerRequestBase) V8GetSocket(in isolates.GetterArgs) (*isolates.Value, error)

func (*ServerRequestBase) V8GetUrl 

func (r *ServerRequestBase) V8GetUrl(in isolates.GetterArgs) (*isolates.Value, error)

type ServerResponse 

type ServerResponse interface {
	OutgoingMessage

	Request(context.Context) (ServerRequest, error)
	Socket() net.Socket
	SendDate() bool
	SetSendDate(bool)
	StatusCode() int
	SetStatusCode(int)
	StatusMessage() string
	SetStatusMessage(string)
	StrictContentLength() bool
	SetStrictContentLength(bool)
	WriteContinue() error
	WriteEarlyHints(http.Header) error
	WriteHead(statusCode int, statusMessage string, headers http.Header) error
	WriteProcessing() error

	Wait() error
}

type ServerResponseBase 

type ServerResponseBase struct {
	*OutgoingMessageBase
	// contains filtered or unexported fields
}

func NewServerResponse 

func NewServerResponse(in isolates.FunctionArgs) (*ServerResponseBase, error)

func (*ServerResponseBase) FlushHeaders 

func (r *ServerResponseBase) FlushHeaders() error

func (*ServerResponseBase) Request 

func (r *ServerResponseBase) Request(context.Context) (ServerRequest, error)

func (*ServerResponseBase) SetStatusCode 

func (r *ServerResponseBase) SetStatusCode(statusCode int)

func (*ServerResponseBase) SetStatusMessage 

func (r *ServerResponseBase) SetStatusMessage(statusMessage string)

func (*ServerResponseBase) Socket 

func (r *ServerResponseBase) Socket() net.Socket

func (*ServerResponseBase) StatusCode 

func (r *ServerResponseBase) StatusCode() int

func (*ServerResponseBase) StatusMessage 

func (r *ServerResponseBase) StatusMessage() string

func (*ServerResponseBase) V8FuncFlushHeaders 

func (r *ServerResponseBase) V8FuncFlushHeaders(in isolates.FunctionArgs) (*isolates.Value, error)

func (*ServerResponseBase) V8FuncWriteHead 

func (r *ServerResponseBase) V8FuncWriteHead(in isolates.FunctionArgs) (*isolates.Value, error)

func (*ServerResponseBase) V8GetSocket 

func (r *ServerResponseBase) V8GetSocket(in isolates.GetterArgs) (*isolates.Value, error)

func (*ServerResponseBase) V8GetStatusCode 

func (r *ServerResponseBase) V8GetStatusCode(in isolates.GetterArgs) (*isolates.Value, error)

func (*ServerResponseBase) V8GetStatusMessage 

func (r *ServerResponseBase) V8GetStatusMessage(in isolates.GetterArgs) (*isolates.Value, error)

func (*ServerResponseBase) WriteHead 

func (r *ServerResponseBase) WriteHead(statusCode int, statusMessage string, headers http.Header) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.
JackTT - Gopher 🇻🇳