Documentation ¶
Index ¶
- Constants
- type LocalNode
- type PDRInfo
- type 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) ServeReport(sr *report.SessReport)
- func (s *PfcpServer) Start(wg *sync.WaitGroup)
- func (s *PfcpServer) Stop()
- func (s *PfcpServer) UpdateNodeID(n *RemoteNode, newId string)
- type ReceivePacket
- type RemoteNode
- type RxTransaction
- type Sess
- func (s *Sess) Close() []report.USAReport
- 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) QueryURR(req *ie.IE) ([]report.USAReport, error)
- func (s *Sess) RemoveBAR(req *ie.IE) error
- func (s *Sess) RemoveFAR(req *ie.IE) error
- func (s *Sess) RemovePDR(req *ie.IE) ([]report.USAReport, error)
- func (s *Sess) RemoveQER(req *ie.IE) error
- func (s *Sess) RemoveURR(req *ie.IE) ([]report.USAReport, error)
- func (s *Sess) URRSeq(urrid uint32) uint32
- func (s *Sess) UpdateBAR(req *ie.IE) error
- func (s *Sess) UpdateFAR(req *ie.IE) error
- func (s *Sess) UpdatePDR(req *ie.IE) ([]report.USAReport, error)
- func (s *Sess) UpdateQER(req *ie.IE) error
- func (s *Sess) UpdateURR(req *ie.IE) ([]report.USAReport, error)
- type TransType
- type TransactionTimeout
- type TxTransaction
- type URRInfo
Constants ¶
View Source
const ( RECEIVE_CHANNEL_LEN = 512 REPORT_CHANNEL_LEN = 128 TRANS_TIMEOUT_CHANNEL_LEN = 64 MAX_PFCP_MSG_LEN = 65536 )
View Source
const (
BUFFQ_LEN = 512
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type LocalNode ¶
type LocalNode struct {
// contains filtered or unexported fields
}
func (*LocalNode) DeleteSess ¶
func (*LocalNode) RemoteSess ¶
type PfcpServer ¶
type PfcpServer struct {
// contains filtered or unexported fields
}
func NewPfcpServer ¶
func NewPfcpServer(cfg *factory.Config, driver forwarder.Driver) *PfcpServer
func (*PfcpServer) NewNode ¶
func (s *PfcpServer) NewNode(id string, addr net.Addr, driver forwarder.Driver) *RemoteNode
func (*PfcpServer) NotifySessReport ¶
func (s *PfcpServer) NotifySessReport(sr report.SessReport)
func (*PfcpServer) NotifyTransTimeout ¶
func (s *PfcpServer) NotifyTransTimeout(trType TransType, trID string)
func (*PfcpServer) PopBufPkt ¶
func (s *PfcpServer) PopBufPkt(seid uint64, pdrid uint16) ([]byte, bool)
func (*PfcpServer) ServeReport ¶
func (s *PfcpServer) ServeReport(sr *report.SessReport)
func (*PfcpServer) Start ¶
func (s *PfcpServer) Start(wg *sync.WaitGroup)
func (*PfcpServer) Stop ¶
func (s *PfcpServer) Stop()
func (*PfcpServer) UpdateNodeID ¶
func (s *PfcpServer) UpdateNodeID(n *RemoteNode, newId string)
type ReceivePacket ¶
type RemoteNode ¶
type RemoteNode struct { ID string // contains filtered or unexported fields }
func NewRemoteNode ¶
func (*RemoteNode) DeleteSess ¶
func (n *RemoteNode) DeleteSess(lSeid uint64) []report.USAReport
func (*RemoteNode) NewSess ¶
func (n *RemoteNode) NewSess(rSeid uint64) *Sess
func (*RemoteNode) Reset ¶
func (n *RemoteNode) Reset()
type RxTransaction ¶
type RxTransaction struct {
// contains filtered or unexported fields
}
func NewRxTransaction ¶
func NewRxTransaction( server *PfcpServer, raddr net.Addr, seq uint32, ) *RxTransaction
type Sess ¶
type Sess struct { LocalID uint64 RemoteID uint64 PDRIDs map[uint16]*PDRInfo // key: PDR_ID FARIDs map[uint32]struct{} // key: FAR_ID QERIDs map[uint32]struct{} // key: QER_ID URRIDs map[uint32]*URRInfo // key: URR_ID BARIDs map[uint8]struct{} // key: BAR_ID // contains filtered or unexported fields }
type TransactionTimeout ¶
type TxTransaction ¶
type TxTransaction struct {
// contains filtered or unexported fields
}
func NewTxTransaction ¶
func NewTxTransaction( server *PfcpServer, raddr net.Addr, seq uint32, ) *TxTransaction
type URRInfo ¶ added in v1.1.0
type URRInfo struct { SEQN uint32 report.MeasureMethod report.MeasureInformation // contains filtered or unexported fields }
Click to show internal directories.
Click to hide internal directories.