core

Jan 24, 2024

Changes in this version

type NodeAssociation

+ FailedHeartbeats uint32

+ HeartbeatChannel chan uint32

+ HeartbeatsActive bool

+ func (association *NodeAssociation) HandleHeartbeat(sequence uint32)

+ func (association *NodeAssociation) HandleHeartbeatTimeout() bool

+ func (association *NodeAssociation) ResetFailedHeartbeats()

+ func (association *NodeAssociation) ScheduleHeartbeat(conn *PfcpConnection)

Dec 4, 2023

Changes in this version

+ type GtpPathManager struct

+ func NewGtpPathManager(localAddress string, interval time.Duration) *GtpPathManager

+ func (gtpPathManager *GtpPathManager) AddGtpPath(gtpPeerAddress string)

+ func (gtpPathManager *GtpPathManager) Run()

+ func (gtpPathManager *GtpPathManager) Stop()

+ type PDRCreationContext struct

+ ResourceManager *service.ResourceManager

+ Session *Session

+ TEIDCache map[uint8]uint32

+ func NewPDRCreationContext(session *Session, resourceManager *service.ResourceManager) *PDRCreationContext

type PfcpConnection

+ ResourceManager *service.ResourceManager

+ func (connection *PfcpConnection) ReleaseResources(seID uint64)

type SPDRInfo

+ Allocated bool

+ PdrID uint32

Oct 13, 2023

Changes in this version

+ func EditConfig(c *gin.Context)

+ func GetFarValue(bpfObjects *ebpf.BpfObjects) func(c *gin.Context)

+ func GetQerValue(bpfObjects *ebpf.BpfObjects) func(c *gin.Context)

+ func GetUplinkPdrValue(bpfObjects *ebpf.BpfObjects) func(c *gin.Context)

+ func InitLogger()

+ func ParseCidrIp(ipStr, maskStr string) (ebpf.IpWMask, error)

+ func ParsePort(str string) (uint16, error)

+ func ParsePortRange(str string) (ebpf.PortRange, error)

+ func ParseProtocol(protocol string) (uint8, error)

+ func ParseSdfFilter(flowDescription string) (ebpf.SdfFilter, error)

+ func SetConfig(conf config.UpfConfig) error

+ func SetFarValue(bpfObjects *ebpf.BpfObjects) func(c *gin.Context)

+ func SetLoggerLevel(loggingLevel string) error

+ func SetQerValue(bpfObjects *ebpf.BpfObjects) func(c *gin.Context)

+ func SetUplinkPdrValue(bpfObjects *ebpf.BpfObjects) func(c *gin.Context)

+ type FarMapElement struct

+ Action uint8

+ Id uint32

+ LocalIP uint32

+ OuterHeaderCreation uint8

+ RemoteIP uint32

+ Teid uint32

+ TransportLevelMarking uint16

+ type PdrElement struct

+ FarId uint32

+ Id uint32

+ OuterHeaderRemoval uint8

+ QerId uint32

Sep 21, 2023

Changes in this version

+ func DisplayPacketStats(forwardPlaneStats ebpf.UpfXdpActionStatistic) func(c *gin.Context)

+ type PacketStats struct

+ RxArp uint64

+ RxGtpEcho uint64

+ RxGtpOther uint64

+ RxGtpPdu uint64

+ RxGtpUnexp uint64

+ RxIcmp uint64

+ RxIcmp6 uint64

+ RxIp4 uint64

+ RxIp6 uint64

+ RxOther uint64

+ RxTcp uint64

+ RxUdp uint64

Aug 24, 2023

Changes in this version

type Session

+ PDRs map[uint32]SPDRInfo

+ func (s *Session) GetPDR(id uint16) SPDRInfo

+ func (s *Session) PutPDR(id uint32, info SPDRInfo)

+ func (s *Session) RemovePDR(id uint32) SPDRInfo

Jul 26, 2023

Changes in this version

+ var UpfPfcpAssociations prometheus.GaugeFunc

+ var UpfPfcpSessions prometheus.GaugeFunc

type PfcpConnection

+ RecoveryTimestamp time.Time

+ func (connection *PfcpConnection) GetAssiciationCount() int

+ func (connection *PfcpConnection) GetSessionCount() int

Jul 19, 2023

Changes in this version

type NodeAssociation

+ NextSequenceID uint32

+ func (association *NodeAssociation) NewSequenceID() uint32

Jul 12, 2023

Changes in this version

+ func GetTransportLevelMarking(far *ie.IE) (uint16, error)

Jul 6, 2023

Changes in this version

+ func HandlePfcpHeartbeatResponse(conn *PfcpConnection, msg message.Message, addr string) (message.Message, error)

+ func SendHeartbeatRequest(conn *PfcpConnection, addr string)

type NodeAssociation

+ HeartbeatRetries uint32

+ func NewNodeAssociation(remoteNodeID string, addr string) *NodeAssociation

+ func (association *NodeAssociation) IsExpired() bool

+ func (association *NodeAssociation) IsHeartbeatScheduled() bool

+ func (association *NodeAssociation) RefreshRetries()

+ func (association *NodeAssociation) ScheduleHeartbeatRequest(duration time.Duration, conn *PfcpConnection) context.CancelFunc

type PfcpConnection

+ func (connection *PfcpConnection) DeleteAssociation(assocAddr string)

+ func (connection *PfcpConnection) DeleteSession(session *Session)

+ func (connection *PfcpConnection) GetAssociation(assocAddr string) *NodeAssociation

+ func (connection *PfcpConnection) RefreshAssociations()

type Session

+ func NewSession(localSEID uint64, remoteSEID uint64) *Session

Jun 28, 2023

Changes in this version

+ var PfcpMessageRx = promauto.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... })

+ var PfcpMessageRxErrors = promauto.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... })

+ var PfcpMessageTx = promauto.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... })

+ var UpfMessageRxLatency = promauto.NewSummaryVec(prometheus.SummaryOpts{ ... }, []string{ ... })

+ var UpfRx = promauto.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... })

+ var UpfXdpAborted prometheus.CounterFunc

+ var UpfXdpDrop prometheus.CounterFunc

+ var UpfXdpPass prometheus.CounterFunc

+ var UpfXdpRedirect prometheus.CounterFunc

+ var UpfXdpTx prometheus.CounterFunc

+ func DisplayConfig() func(c *gin.Context)

+ func DisplayXdpStatistics(forwardPlaneStats ebpf.UpfXdpActionStatistic) func(c *gin.Context)

+ func GetQerContent(bpfObjects *ebpf.BpfObjects) func(c *gin.Context)

+ func HandlePfcpAssociationSetupRequest(conn *PfcpConnection, msg message.Message, addr *net.UDPAddr) (message.Message, error)

+ func HandlePfcpHeartbeatRequest(_ *PfcpConnection, msg message.Message, addr *net.UDPAddr) (message.Message, error)

+ func HandlePfcpSessionDeletionRequest(conn *PfcpConnection, msg message.Message, addr *net.UDPAddr) (message.Message, error)

+ func HandlePfcpSessionEstablishmentRequest(conn *PfcpConnection, msg message.Message, addr *net.UDPAddr) (message.Message, error)

+ func HandlePfcpSessionModificationRequest(conn *PfcpConnection, msg message.Message, addr *net.UDPAddr) (message.Message, error)

+ func ListPfcpAssociations(pfcpSrv *PfcpConnection) func(c *gin.Context)

+ func ListPfcpAssociationsFull(pfcpSrv *PfcpConnection) func(c *gin.Context)

+ func ListPfcpSessionsFiltered(pfcpSrv *PfcpConnection) func(c *gin.Context)

+ func ListQerMapContent(bpfObjects *ebpf.BpfObjects) func(c *gin.Context)

+ func ListUpfPipeline(bpfObjects *ebpf.BpfObjects) func(c *gin.Context)

+ func RegisterMetrics(stats ebpf.UpfXdpActionStatistic)

+ func StartMetrics(addr string) error

+ type ApiServer struct

+ func CreateApiServer(bpfObjects *ebpf.BpfObjects, pfcpSrv *PfcpConnection, ...) *ApiServer

+ func (server *ApiServer) Run(addr string) error

+ type NodeAssociation struct

+ Addr string

+ ID string

+ NextSessionID uint64

+ Sessions SessionMap

+ func (association *NodeAssociation) NewLocalSEID() uint64

+ type NodeAssociationMap map[string]NodeAssociation

+ type NodeAssociationMapNoSession map[string]NodeAssociationNoSession

+ type NodeAssociationNoSession struct

+ Addr string

+ ID string

+ NextSessionID uint64

+ type PfcpConnection struct

+ NodeAssociations NodeAssociationMap

+ func CreatePfcpConnection(addr string, pfcpHandlerMap PfcpHandlerMap, nodeId string, n3Ip string, ...) (*PfcpConnection, error)

+ func (connection *PfcpConnection) Close()

+ func (connection *PfcpConnection) Handle(b []byte, addr *net.UDPAddr)

+ func (connection *PfcpConnection) Receive(b []byte) (n int, addr *net.UDPAddr, err error)

+ func (connection *PfcpConnection) Run()

+ func (connection *PfcpConnection) Send(b []byte, addr *net.UDPAddr) (int, error)

+ func (connection *PfcpConnection) SendMessage(msg message.Message, addr *net.UDPAddr) error

+ type PfcpFunc func(conn *PfcpConnection, msg message.Message, addr *net.UDPAddr) (message.Message, error)

+ type PfcpHandlerMap map[uint8]PfcpFunc

+ func (handlerMap PfcpHandlerMap) Handle(conn *PfcpConnection, buf []byte, addr *net.UDPAddr) error

+ type SFarInfo struct

+ FarInfo ebpf.FarInfo

+ GlobalId uint32

+ type SPDRInfo struct

+ Ipv4 net.IP

+ Ipv6 net.IP

+ PdrInfo ebpf.PdrInfo

+ Teid uint32

+ type SQerInfo struct

+ GlobalId uint32

+ QerInfo ebpf.QerInfo

+ type Session struct

+ DownlinkPDRs map[uint32]SPDRInfo

+ FARs map[uint32]SFarInfo

+ LocalSEID uint64

+ QERs map[uint32]SQerInfo

+ RemoteSEID uint64

+ UplinkPDRs map[uint32]SPDRInfo

+ func FilterSessionsByIP(nodeMap *NodeAssociationMap, filterByIP net.IP) *Session

+ func FilterSessionsByTeid(nodeMap *NodeAssociationMap, filterByTeid uint32) *Session

+ func GetAllSessions(nodeMap *NodeAssociationMap) (sessions []Session)

+ func (s *Session) GetDownlinkPDR(id uint16) SPDRInfo

+ func (s *Session) GetFar(id uint32) SFarInfo

+ func (s *Session) GetQer(id uint32) SQerInfo

+ func (s *Session) GetUplinkPDR(id uint16) SPDRInfo

+ func (s *Session) NewFar(id uint32, internalId uint32, farInfo ebpf.FarInfo)

+ func (s *Session) NewQer(id uint32, internalId uint32, qerInfo ebpf.QerInfo)

+ func (s *Session) PutDownlinkPDR(id uint32, info SPDRInfo)

+ func (s *Session) PutUplinkPDR(id uint32, info SPDRInfo)

+ func (s *Session) RemoveDownlinkPDR(id uint32) SPDRInfo

+ func (s *Session) RemoveFar(id uint32) SFarInfo

+ func (s *Session) RemoveQer(id uint32) SQerInfo

+ func (s *Session) RemoveUplinkPDR(id uint32) SPDRInfo

+ func (s *Session) UpdateFar(id uint32, farInfo ebpf.FarInfo)

+ func (s *Session) UpdateQer(id uint32, qerInfo ebpf.QerInfo)

+ type SessionMap map[uint64]Session

+ type XdpStats struct

+ Aborted uint64

+ Drop uint64

+ Pass uint64

+ Redirect uint64

+ Tx uint64