l4

type EventHandler struct {
	// OnFlowCreated is called after a flow has been admitted, wired, and registered.
	OnFlowCreated func(ev FlowEvent)
	// OnFlowDeleted is called when a flow is being torn down, before its legs close.
	OnFlowDeleted func(ev FlowEvent)
	// OnFlowError is called when a pump exits on a write error.
	OnFlowError func(srcAddr net.Addr, protocol stnrv2.Protocol, message string)
}

type Flow struct {
	flow.Entry
	Event FlowEvent
}

type FlowEvent struct {
	// SrcAddr and DstAddr are the client's source address and the listener-side address
	// serving it.
	SrcAddr, DstAddr net.Addr
	// Protocol is the client-side transport, the listener protocol.
	Protocol stnrv2.Protocol
	// Peer is the endpoint the flow was forwarded to and PeerProtocol the protocol of the leg
	// towards it, its tag's.
	Peer         net.Addr
	PeerProtocol stnrv2.Protocol
	// Cluster is the cluster the flow was forwarded through.
	Cluster string
	// Username and Realm are the flow's quota identity, as minted by the quota gate.
	Username, Realm string
}

type Server struct {
	server.Base
	// contains filtered or unexported fields
}