go-pfcp-networking

Jun 1, 2022

Changes in this version

type PFCPClientEntity

+ func (e *PFCPClientEntity) GetLocalSessions() PFCPSessionMapSEID

type PFCPEntityInterface

+ GetLocalSessions func() PFCPSessionMapSEID

type PFCPServerEntity

+ func (e *PFCPServerEntity) GetLocalSessions() PFCPSessionMapSEID

type PFCPSession

+ func (s *PFCPSession) LocalFSEID() *ie.IE

+ func (s *PFCPSession) LocalIPAddress() (net.IP, error)

+ func (s *PFCPSession) LocalSEID() (uint64, error)

+ func (s *PFCPSession) RemoteFSEID() *ie.IE

+ func (s *PFCPSession) RemoteIPAddress() (net.IP, error)

+ func (s *PFCPSession) RemoteSEID() (uint64, error)

+ func (s *PFCPSession) SetRemoteFSEID(FSEID *ie.IE)

+ type PFCPSessionMapSEID = map[uint64]*PFCPSession

+ type ReceivedMessage struct

+ Entity PFCPEntityInterface

+ SenderAddr net.Addr

+ func (receivedMessage *ReceivedMessage) ReplyTo(responseMessage message.Message) error

+ type RemotePFCPSessionMapSEID = map[uint64]*RemotePFCPSession

Feb 23, 2022

Changes in this version

+ func NewFSEID(seid uint64, v4, v6 *net.IPAddr) (*ie.IE, error)

+ type PFCPAssociation struct

+ func NewPFCPAssociation(peer *PFCPPeer) PFCPAssociation

+ func (association *PFCPAssociation) CreateSession(seid, rseid uint64, pdrs []*pfcprule.PDR, fars []*pfcprule.FAR) (session *PFCPSession, err error)

+ func (association *PFCPAssociation) GetSessions() map[uint64]*PFCPSession

+ func (association *PFCPAssociation) NewPFCPSession(seid uint64, pdrs []*pfcprule.PDR, fars []*pfcprule.FAR) (session *RemotePFCPSession, err error)

+ type PFCPClientEntity struct

+ func NewPFCPClientEntity(nodeID string) *PFCPClientEntity

+ func (e *PFCPClientEntity) CreatePFCPAssociation(association *PFCPAssociation) error

+ func (e *PFCPClientEntity) GetPFCPAssociation(nid string) (association *PFCPAssociation, err error)

+ func (e *PFCPClientEntity) NewPFCPAssociation(peer *PFCPPeer) (association *PFCPAssociation, err error)

+ func (e *PFCPClientEntity) RemovePFCPAssociation(association *PFCPAssociation) error

+ func (e *PFCPClientEntity) Start() error

+ type PFCPEntity struct

+ func NewPFCPEntity(nodeID string) PFCPEntity

+ func (e *PFCPEntity) AddHandler(t pfcputil.MessageType, h handler) error

+ func (e *PFCPEntity) AddHandlers(funcs map[pfcputil.MessageType]handler) error

+ func (e *PFCPEntity) GetHandler(t pfcputil.MessageType) (h handler, err error)

+ func (e *PFCPEntity) GetNextRemoteSessionID() uint64

+ func (e *PFCPEntity) NodeID() *ie.IE

+ func (e *PFCPEntity) RecoveryTimeStamp() *ie.IE

+ func (entity *PFCPEntity) ReplyTo(ipAddress net.Addr, requestMessage message.Message, ...) error

+ type PFCPEntityInterface interface

+ CreatePFCPAssociation func(association *PFCPAssociation) error

+ GetNextRemoteSessionID func() uint64

+ GetPFCPAssociation func(nid string) (association *PFCPAssociation, err error)

+ NodeID func() *ie.IE

+ RecoveryTimeStamp func() *ie.IE

+ RemovePFCPAssociation func(association *PFCPAssociation) error

+ ReplyTo func(ipAddress net.Addr, requestMessage message.Message, ...) error

+ type PFCPPeer struct

+ NodeID *ie.IE

+ Srv PFCPEntityInterface

+ func NewPFCPPeer(srv PFCPEntityInterface, nodeID *ie.IE) (peer *PFCPPeer, err error)

+ func (peer *PFCPPeer) Close() error

+ func (peer *PFCPPeer) IsAlive() (res bool, err error)

+ func (peer *PFCPPeer) Send(msg message.Message) (m message.Message, err error)

+ type PFCPServerEntity struct

+ func NewPFCPServerEntity(nodeID string) *PFCPServerEntity

+ func (e *PFCPServerEntity) CreatePFCPAssociation(association *PFCPAssociation) error

+ func (e *PFCPServerEntity) GetPFCPAssociation(nid string) (association *PFCPAssociation, err error)

+ func (e *PFCPServerEntity) GetPFCPSessions() []*PFCPSession

+ func (e *PFCPServerEntity) RemovePFCPAssociation(association *PFCPAssociation) error

+ func (e *PFCPServerEntity) Start() error

+ type PFCPSession struct

+ func NewPFCPSession(fseid *ie.IE, rseid uint64) PFCPSession

+ func (s *PFCPSession) AddFARs(fars map[uint32]*pfcprule.FAR)

+ func (s *PFCPSession) AddPDRs(pdrs map[uint16]*pfcprule.PDR)

+ func (s *PFCPSession) FSEID() *ie.IE

+ func (s *PFCPSession) GetFAR(farid uint32) (*pfcprule.FAR, error)

+ func (s *PFCPSession) GetPDRs() pfcprule.PDRs

+ func (s *PFCPSession) RSEID() uint64

+ func (s *PFCPSession) SEID() (uint64, error)

+ type RemotePFCPSession struct

+ func NewRemotePFCPSession(fseid *ie.IE, association *PFCPAssociation) RemotePFCPSession

+ func (s *RemotePFCPSession) Start(pdrs []*pfcprule.PDR, fars []*pfcprule.FAR) error