sgw

type KernelTunnel struct {
	GTPLink *netlink.GTP
	// contains filtered or unexported fields
}

type NetNS interface {
	Handle() netns.NsHandle
	ListenUDP(ctx context.Context, laddr *net.UDPAddr) (*net.UDPConn, error)
	Do(toCall func() error) error
}

type SGWGTPUTunnel struct {
	Type          SGWGTPUTunnelType `yaml:"type"`
	InterfaceName string            `yaml:"interface_name" default:"gtpu_sgw"`
	MTU           int               `yaml:"mtu" default:"1300"`
}

type SGWGTPUTunnelType string

type Session interface {
	TriggerEvent(ev SessionEvent)
	UNodeAddr() *net.UDPAddr
	TEIDPGWs5u() uint32
	TEIDSGWs5u() uint32
	IPv4() net.IP
	IPv6() net.IP
	TunnelRegistered() bool
	SetTunnelRegistered(r bool)
	Logger() *logrus.Entry
}

type SessionCreateSessionResponseEvent struct{ Error error }

type SessionDeleteSessionResponseEvent struct{ Error error }

type SessionEvent interface{}

type SessionEventHandler = func(s Session, ev SessionEvent)

type SessionIncomingTPDUEvent struct {
	Data    []byte
	PeerSrc *net.UDPAddr
}

type SessionModifyBearerResponseEvent struct{ Error error }

type SessionTunnelStartEvent struct{}

type SessionTunnelStopEvent struct{}

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

type SimpleSessionConfig struct {
	UNodeAddr  *net.UDPAddr
	TEIDPGWs5u uint32
	TEIDSGWs5u uint32
	IPv4       net.IP
	IPv6       net.IP
	Logger     *logrus.Entry
}

type TPDUHook func(tpdu *message.TPDU, fromPGW bool)

type TunTunnel struct {
	TUNNetLink netlink.Link
	// contains filtered or unexported fields
}

type UserPlaneConfig struct {
	S5uIP      net.IP
	GTPUTunnel SGWGTPUTunnel
	GRXNetNS   NetNS
	UENetNS    NetNS
	AddRule    bool
	// Specify a hook function to run on ougtoing and incoming
	// encapsulated T-PDUs. If this hook is non-nil, userspace
	// GTP mode must always be used
	TPDUHook TPDUHook
}

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

type UserPlaneTunnel interface {
	Start(context.Context) error
	Close() error
	RegisterSession(s Session) error
	UnregisterSession(s Session) error
	HandleTPDU(data []byte, src *net.UDPAddr) error
}