producer

Documentation

Index

• func AddPDUSessionAnchorAndULCL(smContext *context.SMContext, nodeID pfcpType.NodeID)
• func ApplySmPolicyFromDecision(smContext *smf_context.SMContext, decision *models.SmPolicyDecision) error
• func EstablishPSA2(smContext *context.SMContext)
• func EstablishRANTunnelInfo(smContext *context.SMContext)
• func EstablishULCL(smContext *context.SMContext)
• func HandleOAMGetUEPDUSessionInfo(smContextRef string) *http_wrapper.Response
• func HandlePDUSessionSMContextCreate(request models.PostSmContextsRequest) *http_wrapper.Response
• func HandlePDUSessionSMContextRelease(smContextRef string, body models.ReleaseSmContextRequest) *http_wrapper.Response
• func HandlePDUSessionSMContextUpdate(smContextRef string, body models.UpdateSmContextRequest) *http_wrapper.Response
• func HandleSMPolicyUpdateNotify(smContextRef string, request models.SmPolicyNotification) *http_wrapper.Response
• func SendPFCPRule(smContext *smf_context.SMContext, dataPath *smf_context.DataPath)
• func SendPFCPRules(smContext *smf_context.SMContext)
• func UpdateDataPathToUPF(smContext *smf_context.SMContext, ...)
• func UpdatePSA2DownLink(smContext *context.SMContext)
• func UpdateRANAndIUPFUpLink(smContext *context.SMContext)
• type PDUSessionInfo
• type PFCPState

Functions

func AddPDUSessionAnchorAndULCL

func AddPDUSessionAnchorAndULCL(smContext *context.SMContext, nodeID pfcpType.NodeID)

func ApplySmPolicyFromDecision

func ApplySmPolicyFromDecision(smContext *smf_context.SMContext, decision *models.SmPolicyDecision) error

func EstablishPSA2

func EstablishPSA2(smContext *context.SMContext)

func EstablishRANTunnelInfo

func EstablishRANTunnelInfo(smContext *context.SMContext)

func EstablishULCL

func EstablishULCL(smContext *context.SMContext)

func HandleOAMGetUEPDUSessionInfo

func HandleOAMGetUEPDUSessionInfo(smContextRef string) *http_wrapper.Response

func HandlePDUSessionSMContextCreate

func HandlePDUSessionSMContextCreate(request models.PostSmContextsRequest) *http_wrapper.Response

func HandlePDUSessionSMContextRelease

func HandlePDUSessionSMContextRelease(smContextRef string, body models.ReleaseSmContextRequest) *http_wrapper.Response

func HandlePDUSessionSMContextUpdate

func HandlePDUSessionSMContextUpdate(smContextRef string, body models.UpdateSmContextRequest) *http_wrapper.Response

func HandleSMPolicyUpdateNotify

func HandleSMPolicyUpdateNotify(smContextRef string, request models.SmPolicyNotification) *http_wrapper.Response

func SendPFCPRule

func SendPFCPRule(smContext *smf_context.SMContext, dataPath *smf_context.DataPath)

SendPFCPRule send one datapath to UPF

func SendPFCPRules

func SendPFCPRules(smContext *smf_context.SMContext)

SendPFCPRules send all datapaths to UPFs

func UpdateDataPathToUPF

func UpdateDataPathToUPF(smContext *smf_context.SMContext, oldDataPath, updateDataPath *smf_context.DataPath)

UpdateDataPathToUPF update the datapath of the UPF

func UpdatePSA2DownLink

func UpdatePSA2DownLink(smContext *context.SMContext)

func UpdateRANAndIUPFUpLink

func UpdateRANAndIUPFUpLink(smContext *context.SMContext)

Types

type PDUSessionInfo

type PDUSessionInfo struct {
	Supi         string
	PDUSessionID string
	Dnn          string
	Sst          string
	Sd           string
	AnType       models.AccessType
	PDUAddress   string
	SessionRule  models.SessionRule
	UpCnxState   models.UpCnxState
	Tunnel       context.UPTunnel
}

type PFCPState

type PFCPState struct {
	// contains filtered or unexported fields
}