pcf_message

Documentation

Index

• Constants
• Variables
• func SendHttpResponseMessage(channel chan HttpResponseMessage, header http.Header, status int, ...)
• func SendMessage(msg ChannelMessage)
• type ChannelMessage
  • func NewHttpChannelMessage(event string, httpRequest *http_wrapper.Request) (msg ChannelMessage)
• type EventCreateAMPolicyCreateValue
• type EventCreateSMPolicyCreateValue
• type EventDeleteAMPolicyCreateValue
• type EventDeleteAppSessionCreateValue
• type EventDeleteEventsSubscCreateValue
• type EventDeleteSMPolicyCreateValue
• type EventGetAMPolicyCreateValue
• type EventGetAppSessionCreateValue
• type EventGetSMPolicyCreateValue
• type EventModAppSessionCreateValue
• type EventNotifySMPolicyCreateValue
• type EventUpdateAMPolicyCreateValue
• type EventUpdateEventsSubscCreateValue
• type EventUpdateSMPolicyCreateValue
• type HttpResponseMessage
• type HttpResponseMessageType

Constants

const (
	EventBDTPolicyCreate       = "BDTPolicyCreate Message"
	EventBDTPolicyGet          = "BDTPolicyGet Message"
	EventBDTPolicyUpdate       = "BDTPolicyUpdate Message"
	EventPostAppSessions       = "PolicyAuthorizationPostAppSessions Message"
	EventGetAppSession         = "PolicyAuthorizationGetAppSession Message"
	EventDeleteAppSession      = "PolicyAuthorizationDeleteAppSession Message"
	EventModAppSession         = "PolicyAuthorizationModAppSession Message"
	EventDeleteEventsSubsc     = "PolicyAuthorizationDeleteEventsSubsc Message"
	EventUpdateEventsSubsc     = "PolicyAuthorizationUpdateEventsSubsc Message"
	EventAMPolicyCreate        = "AMPolicyCreate Message"
	EventAMPolicyGet           = "AMPolicyGet Message"
	EventAMPolicyUpdate        = "AMPolicyUpdate Message"
	EventAMPolicyDelete        = "AMPolicyDelete Message"
	EventSMPolicyCreate        = "EventSMPolicyCreate Message"
	EventSMPolicyGet           = "EventSMPolicyGet Message"
	EventSMPolicyUpdate        = "EventSMPolicyUpdate Message"
	EventSMPolicyDelete        = "EventSMPolicyDelete Message"
	EventSMPolicyNotify        = "EventSMPolicyNotify Message"
	EventAMFStatusChangeNotify = "EventAMFStatusChangeNotify Message"
)

const (
	MaxChannel int = 100000
)

Variables

var PCFChannel chan ChannelMessage

Functions

func SendHttpResponseMessage

func SendHttpResponseMessage(channel chan HttpResponseMessage, header http.Header, status int, body interface{})

Send HTTP Response to HTTP handler thread through HTTP channel, args[0] is response payload and args[1:] is Additional Value

func SendMessage

func SendMessage(msg ChannelMessage)

Types

type ChannelMessage

type ChannelMessage struct {
	Event       string
	HTTPRequest *http_wrapper.Request
	HttpChannel chan HttpResponseMessage // return Http response
	Value       interface{}              // input/request value
}

func NewHttpChannelMessage

func NewHttpChannelMessage(event string, httpRequest *http_wrapper.Request) (msg ChannelMessage)

type EventCreateAMPolicyCreateValue

type EventCreateAMPolicyCreateValue struct {
	Request    models.PolicyAssociationRequest
	RequestUri string
}

type EventCreateSMPolicyCreateValue

type EventCreateSMPolicyCreateValue struct {
	Request    models.SmPolicyContextData
	RequestUri string
}

type EventDeleteAMPolicyCreateValue

type EventDeleteAMPolicyCreateValue struct {
	RequestUri string
}

type EventDeleteAppSessionCreateValue

type EventDeleteAppSessionCreateValue struct {
	RequestUri string
}

type EventDeleteEventsSubscCreateValue

type EventDeleteEventsSubscCreateValue struct {
	RequestUri string
}

type EventDeleteSMPolicyCreateValue

type EventDeleteSMPolicyCreateValue struct {
	RequestUri string
}

type EventGetAMPolicyCreateValue

type EventGetAMPolicyCreateValue struct {
	RequestUri string
}

type EventGetAppSessionCreateValue

type EventGetAppSessionCreateValue struct {
	RequestUri string
}

type EventCreateBDTPolicyCreateValue struct {
	Request    models.BdtReqData
	RequestUri string
}

type EventGetBDTPolicyCreateValue struct {
	RequestUri string
}

type EventUpdateBDTPolicyCreateValue struct {
	Request    models.BdtPolicyDataPatch
	RequestUri string
}

type EventPostAppSessionsCreateValue struct {
	Request    models.AppSessionContext
	RequestUri string
}

type EventGetSMPolicyCreateValue

type EventGetSMPolicyCreateValue struct {
	RequestUri string
}

type EventModAppSessionCreateValue

type EventModAppSessionCreateValue struct {
	Request    models.AppSessionContextUpdateData
	RequestUri string
}

type EventNotifySMPolicyCreateValue

type EventNotifySMPolicyCreateValue struct {
	Request    models.PolicyDataChangeNotification
	RequestUri string
}

type EventUpdateAMPolicyCreateValue

type EventUpdateAMPolicyCreateValue struct {
	Request    models.PolicyAssociationUpdateRequest
	RequestUri string
}

type EventUpdateEventsSubscCreateValue

type EventUpdateEventsSubscCreateValue struct {
	Request    models.EventsSubscReqData
	RequestUri string
}

type EventUpdateSMPolicyCreateValue

type EventUpdateSMPolicyCreateValue struct {
	Request    models.SmPolicyUpdateContextData
	RequestUri string
}

type HttpResponseMessage

type HttpResponseMessage struct {
	HTTPResponse *http_wrapper.Response
}

type HttpResponseMessageType

type HttpResponseMessageType string

const (
	HttpResponseMessageResponse       HttpResponseMessageType = "HTTP Response"
	HttpResponseMessageAddition       HttpResponseMessageType = "HTTP Response Addition"
	HttpResponseMessageResponseError  HttpResponseMessageType = "HTTP Response Error"
	HttpResponseMessageProblemDetails HttpResponseMessageType = "Problem Details"
)