smf_message

package
Version: v3.0.0+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 3, 2020 License: Apache-2.0 Imports: 2 Imported by: 0

Documentation

Index

Constants

View Source
const (
	MaxChannel int = 1000
)

Variables

View Source
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
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
t or T : Toggle theme light dark auto
y or Y : Canonical URL