ctx := context.TODO() upNode := NewPFCPEntityUP(UPF_NODE_ID, UPF_IP_ADDR) // node id can be an IP Address or a FQDN go upNode.ListenAndServeContext(ctx) upnode.WaitReady(ctx) // Access list of associations associations := upNode.GetPFCPAssociations() // Access list of sessions sessions := upNode.GetPFCPSessions()

ctx := context.TODO() cpNode := NewPFCPEntityCP(SMF_NODE_ID, SMF_IP_ADDR) // node id can be an IP Address or a FQDN go cpNode.ListenAndServeContext(ctx) cpNode.WaitReady(ctx) association, _ := cpNode.NewEstablishedPFCPAssociation(ie.NewNodeIDHeuristic(UPFADDR)) session, _ := a.CreateSession(pdrs, fars)