smf_message

Documentation

Index

• Constants
• Variables
• func SendMessage(msg HandlerMessage)
• type Event
• type HandlerMessage
  • func NewHandlerMessage(event Event, httpRequest *http_wrapper.Request) (msg HandlerMessage)
  • func NewPfcpMessage(pfcpRequest *pfcpUdp.Message) (msg HandlerMessage)
• type HandlerResponseMessage
• type ResponseQueue
  • func NewQueue() *ResponseQueue
  • func (rq ResponseQueue) CheckItemExist(seqNum uint32) (exist bool)
  • func (rq ResponseQueue) DeleteItem(seqNum uint32)
  • func (rq ResponseQueue) GetItem(seqNum uint32) *ResponseQueueItem
  • func (rq ResponseQueue) PutItem(seqNum uint32, rspChan chan HandlerResponseMessage, ...)
• type ResponseQueueItem

Constants

const (
	MaxChannel int = 1000
)

Variables

var SmfChannel chan HandlerMessage

Functions

func SendMessage

func SendMessage(msg HandlerMessage)

Types

type Event

type Event int

const (
	PFCPMessage Event = iota
	PDUSessionSMContextCreate
	PDUSessionSMContextUpdate
	PDUSessionSMContextRelease
	OAMGetUEPDUSessionInfo
)

type HandlerMessage

type HandlerMessage struct {
	Event        Event
	HTTPRequest  *http_wrapper.Request
	PFCPRequest  *pfcpUdp.Message
	ResponseChan chan HandlerResponseMessage
}

func NewHandlerMessage

func NewHandlerMessage(event Event, httpRequest *http_wrapper.Request) (msg HandlerMessage)

func NewPfcpMessage

func NewPfcpMessage(pfcpRequest *pfcpUdp.Message) (msg HandlerMessage)

type HandlerResponseMessage

type HandlerResponseMessage struct {
	HTTPResponse *http_wrapper.Response
	PFCPResponse *pfcpUdp.Message
}

type ResponseQueue

type ResponseQueue struct {
	RspQueue map[uint32]*ResponseQueueItem
}

var RspQueue *ResponseQueue

func NewQueue

func NewQueue() *ResponseQueue

func (ResponseQueue) CheckItemExist

func (rq ResponseQueue) CheckItemExist(seqNum uint32) (exist bool)

func (ResponseQueue) DeleteItem

func (rq ResponseQueue) DeleteItem(seqNum uint32)

func (ResponseQueue) GetItem

func (rq ResponseQueue) GetItem(seqNum uint32) *ResponseQueueItem

func (ResponseQueue) PutItem

func (rq ResponseQueue) PutItem(seqNum uint32, rspChan chan HandlerResponseMessage, response http_wrapper.Response)

type ResponseQueueItem

type ResponseQueueItem struct {
	RspChan  chan HandlerResponseMessage
	Response http_wrapper.Response
}