Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

pfcp

package

Go to main page

Versions in this module

v1

v1.2.2

Mar 27, 2024

v1.2.1

Dec 19, 2023

v1.2.0

Jun 8, 2023

Changes in this version

+ type PDRInfo struct

+ RelatedURRIDs map[uint32]struct{}

v1.1.0

Nov 18, 2022

Changes in this version

type Sess

+ func (s *Sess) QueryURR(req *ie.IE) ([]report.USAReport, error)

+ func (s *Sess) URRSeq(urrid uint32) uint32

+ type URRInfo struct

+ SEQN uint32

v1.0.1

Nov 18, 2022

v1.0.0

Jun 29, 2022

Changes in this version

+ const BUFFQ_LEN

+ const MAX_PFCP_MSG_LEN

+ const RECEIVE_CHANNEL_LEN

+ const REPORT_CHANNEL_LEN

+ const TRANS_TIMEOUT_CHANNEL_LEN

+ type LocalNode struct

+ func (n *LocalNode) DeleteSess(lSeid uint64) error

+ func (n *LocalNode) NewSess(rSeid uint64, qlen int) *Sess

+ func (n *LocalNode) RemoteSess(rSeid uint64, addr net.Addr) (*Sess, error)

+ func (n *LocalNode) Reset()

+ func (n *LocalNode) Sess(lSeid uint64) (*Sess, error)

+ type PfcpServer struct

+ func NewPfcpServer(cfg *factory.Config, driver forwarder.Driver) *PfcpServer

+ func (s *PfcpServer) NewNode(id string, addr net.Addr, driver forwarder.Driver) *RemoteNode

+ func (s *PfcpServer) NotifySessReport(sr report.SessReport)

+ func (s *PfcpServer) NotifyTransTimeout(trType TransType, trID string)

+ func (s *PfcpServer) PopBufPkt(seid uint64, pdrid uint16) ([]byte, bool)

+ func (s *PfcpServer) ServeDLDReport(addr net.Addr, lSeid uint64, pdrid uint16) error

+ func (s *PfcpServer) ServeReport(rp *report.SessReport)

+ func (s *PfcpServer) ServeUSAReport(addr net.Addr, lSeid uint64, usar *report.USAReport) error

+ func (s *PfcpServer) Start(wg *sync.WaitGroup)

+ func (s *PfcpServer) Stop()

+ func (s *PfcpServer) UpdateNodeID(n *RemoteNode, newId string)

+ type ReceivePacket struct

+ Buf []byte

+ RemoteAddr net.Addr

+ type RemoteNode struct

+ ID string

+ func NewRemoteNode(id string, addr net.Addr, local *LocalNode, driver forwarder.Driver, ...) *RemoteNode

+ func (n *RemoteNode) DeleteSess(lSeid uint64)

+ func (n *RemoteNode) NewSess(rSeid uint64) *Sess

+ func (n *RemoteNode) Reset()

+ func (n *RemoteNode) Sess(lSeid uint64) (*Sess, error)

+ type RxTransaction struct

+ func NewRxTransaction(server *PfcpServer, raddr net.Addr, seq uint32) *RxTransaction

+ type Sess struct

+ BARIDs map[uint8]struct{}

+ FARIDs map[uint32]struct{}

+ LocalID uint64

+ PDRIDs map[uint16]struct{}

+ QERIDs map[uint32]struct{}

+ RemoteID uint64

+ URRIDs map[uint32]struct{}

+ func (s *Sess) Close()

+ func (s *Sess) CreateBAR(req *ie.IE) error

+ func (s *Sess) CreateFAR(req *ie.IE) error

+ func (s *Sess) CreatePDR(req *ie.IE) error

+ func (s *Sess) CreateQER(req *ie.IE) error

+ func (s *Sess) CreateURR(req *ie.IE) error

+ func (s *Sess) Len(pdrid uint16) int

+ func (s *Sess) Pop(pdrid uint16) ([]byte, bool)

+ func (s *Sess) Push(pdrid uint16, p []byte)

+ func (s *Sess) RemoveBAR(req *ie.IE) error

+ func (s *Sess) RemoveFAR(req *ie.IE) error

+ func (s *Sess) RemovePDR(req *ie.IE) error

+ func (s *Sess) RemoveQER(req *ie.IE) error

+ func (s *Sess) RemoveURR(req *ie.IE) error

+ func (s *Sess) UpdateBAR(req *ie.IE) error

+ func (s *Sess) UpdateFAR(req *ie.IE) error

+ func (s *Sess) UpdatePDR(req *ie.IE) error

+ func (s *Sess) UpdateQER(req *ie.IE) error

+ func (s *Sess) UpdateURR(req *ie.IE) error

+ type TransType int

+ const RX

+ const TX

+ type TransactionTimeout struct

+ TrID string

+ TrType TransType

+ type TxTransaction struct

+ func NewTxTransaction(server *PfcpServer, raddr net.Addr, seq uint32) *TxTransaction