Documentation
¶
Overview ¶
Package conn provides shared HTTP/1.1 and HTTP/2 connection handling.
Index ¶
- Variables
- func CloseH1(state *H1State)
- func CloseH2(state *H2State)
- func ProcessH1(ctx context.Context, data []byte, state *H1State, handler stream.Handler, ...) error
- func ProcessH2(ctx context.Context, data []byte, state *H2State, _ stream.Handler, ...) error
- type H1State
- type H2Config
- type H2State
Constants ¶
This section is empty.
Variables ¶
var ErrHijacked = errors.New("celeris: connection hijacked")
ErrHijacked is returned by ProcessH1 when the connection was hijacked. The engine must not close or reuse the FD after receiving this error.
Functions ¶
func CloseH1 ¶ added in v1.1.0
func CloseH1(state *H1State)
CloseH1 releases the cached stream and context (if any) back to their pools.
func ProcessH1 ¶
func ProcessH1(ctx context.Context, data []byte, state *H1State, handler stream.Handler, write func([]byte)) error
ProcessH1 processes incoming H1 data, parsing requests and calling the handler. The write callback is used to send response bytes back to the connection.
func ProcessH2 ¶
func ProcessH2(ctx context.Context, data []byte, state *H2State, _ stream.Handler, write func([]byte), _ H2Config) error
ProcessH2 processes incoming H2 data. On first call, validates the client preface and sends server settings. After frame processing, drains the async write queue for handler goroutine responses that completed during parsing.
Types ¶
type H1State ¶
type H1State struct {
RemoteAddr string
HijackFn func() (net.Conn, error) // set by engine; nil if unsupported
// contains filtered or unexported fields
}
H1State holds per-connection H1 parsing state.
func NewH1State ¶
func NewH1State() *H1State
NewH1State creates a new H1 connection state with zero-copy header parsing.
type H2State ¶
type H2State struct {
// contains filtered or unexported fields
}
H2State holds per-connection H2 state.
func NewH2State ¶
NewH2State creates a new H2 connection state. wakeupFD is an eventfd used to signal the event loop when handler goroutines enqueue responses (-1 to disable, falling back to polling).
func (*H2State) DrainWriteQueue ¶ added in v1.1.0
DrainWriteQueue drains async handler responses to the write function. Called from the event loop thread (outside H2State.mu).
func (*H2State) SetRemoteAddr ¶ added in v1.1.0
SetRemoteAddr sets the remote address on the H2 stream manager so that all streams created on this connection inherit the peer address.
func (*H2State) WriteQueuePending ¶ added in v1.1.0
WriteQueuePending returns true if the write queue has pending data.
Source Files