conn

package

v1.1.0-beta.5 Latest Latest Go to latest Published: Mar 16, 2026 License: Apache-2.0 Imports: 15 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/goceleris/celeris

Links

Open Source Insights

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
- func NewH1State() *H1State
type H2Config
type H2State
- func NewH2State(handler stream.Handler, cfg H2Config, write func([]byte)) *H2State
- func (s *H2State) SetRemoteAddr(addr string)

Constants ¶

This section is empty.

Variables ¶

View Source

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 CloseH2 ¶

func CloseH2(state *H2State)

CloseH2 cleans up H2 state.

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.

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 H2Config ¶

type H2Config struct {
	MaxConcurrentStreams uint32
	InitialWindowSize    uint32
	MaxFrameSize         uint32
}

H2Config holds H2 connection configuration.

type H2State ¶

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

H2State holds per-connection H2 state.

func NewH2State ¶

func NewH2State(handler stream.Handler, cfg H2Config, write func([]byte)) *H2State

NewH2State creates a new H2 connection state.

func (*H2State) SetRemoteAddr ¶ added in v1.1.0

func (s *H2State) SetRemoteAddr(addr string)

SetRemoteAddr sets the remote address on the H2 stream manager so that all streams created on this connection inherit the peer address.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL