handler

package

v6.0.0-beta.6 Latest Latest Go to latest Published: Aug 21, 2026 License: MIT Imports: 9 Imported by: 0

Details

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

Repository

github.com/roadrunner-server/tcp

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
type Handler
- func NewHandler(conn net.Conn, delim []byte, serverName string, ...) *Handler
- func (h *Handler) Release()
- func (h *Handler) Start()
type ServerInfo

Constants ¶

View Source

const (
	EventConnected    string = "CONNECTED"
	EventIncomingData string = "DATA"
	EventClose        string = "CLOSE"
)

Variables ¶

View Source

var (
	CLOSE      = []byte("CLOSE")      //nolint:gochecknoglobals
	CONTINUE   = []byte("CONTINUE")   //nolint:gochecknoglobals
	WRITECLOSE = []byte("WRITECLOSE") //nolint:gochecknoglobals
	WRITE      = []byte("WRITE")      //nolint:gochecknoglobals
)

These byte slices are treated as read-only sentinel values for worker responses. They are package-level vars (not consts) because []byte cannot be const in Go.

Functions ¶

This section is empty.

Types ¶

type Handler ¶

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

func NewHandler ¶

func NewHandler(
	conn net.Conn,
	delim []byte, serverName string,
	wPool func(*payload.Payload) (*payload.Payload, error),
	pldPool *sync.Pool, siPool *sync.Pool, readBufPool *sync.Pool, resBufPool *sync.Pool, connections *sync.Map, log *slog.Logger) *Handler

func (*Handler) Release ¶

func (h *Handler) Release()

Release is a no-op placeholder reserved for future resource cleanup.

func (*Handler) Start ¶

func (h *Handler) Start()

type ServerInfo ¶

type ServerInfo struct {
	RemoteAddr string `json:"remote_addr"`
	Server     string `json:"server"`
	UUID       string `json:"uuid"`
	Event      string `json:"event"`
}

Source Files ¶

View all Source files

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