Module ocs_diameter_3gpp_ro_application_cb

Description
Data Types
Function Index
Function Details

This diameter_app behaviour callback module handles diameter messages for the 3GPP DIAMETER Ro application in the cse application.

References

3GPP TS 29.299 Diameter charging applications
RFC4006 - DIAMETER Credit-Control Application

Description

This diameter_app behaviour callback module handles diameter messages for the 3GPP DIAMETER Ro application in the cse application.

Data Types

capabilities()

capabilities() = #diameter_caps{}

message()

message() = tuple() | list()

packet()

packet() = #diameter_packet{}

peer()

peer() = {Peer_Ref::term(), Capabilities::capabilities()}

state()

state() = #state{}

Function Index

peer_up/4	Invoked when the peer connection is available.
peer_down/4	Invoked when the peer connection is not available.
pick_peer/5	Invoked as a consequence of a call to diameter:call/4 to select a destination peer for an outgoing request.
prepare_request/4	Invoked to return a request for encoding and transport.
prepare_retransmit/4	Invoked to return a request for encoding and retransmission.
handle_answer/5	Invoked when an answer message is received from a peer.
handle_error/5	Invoked when an error occurs before an answer message is received in response to an outgoing request.
handle_request/4	Invoked when a request message is received from the peer.
errors/4*	Handle errors in requests.
process_request/5*	Process a received DIAMETER Accounting packet.
accounting_event_type/1*	Converts CC-Request-Type integer value to a readable atom.
fui/1*	Parse redirect server address.
subscriber_id/3*	Get filtered subscriber IDs in priority order.

Function Details

peer_up/4

peer_up(ServiceName, Peer, State, Config) -> NewState

ServiceName = diameter:service_name()
Peer = peer()
State = state()
Config = map()
NewState = state()

Invoked when the peer connection is available

peer_down/4

peer_down(ServiceName, Peer, State, Config) -> NewState

ServiceName = diameter:service_name()
Peer = peer()
State = state()
Config = map()
NewState = state()

Invoked when the peer connection is not available

pick_peer/5

pick_peer(LocalCandidates, RemoteCandidates, ServiceName, State, Config) -> Result

LocalCandidates = [peer()]
RemoteCandidates = [peer()]
ServiceName = diameter:service_name()
State = state()
Config = map()
NewState = state()
Selection = {ok, Peer} | {Peer, NewState}
Peer = peer() | false
Result = Selection | false

Invoked as a consequence of a call to diameter:call/4 to select a destination peer for an outgoing request.

prepare_request/4

prepare_request(Packet, ServiceName, Peer, Config) -> Action

Packet = packet()
ServiceName = diameter:service_name()
Peer = peer()
Config = map()
Action = Send | Discard | {eval_packet, Action, PostF}
Send = {send, packet() | message()}
Discard = {discard, Reason} | discard
Reason = term()
PostF = diameter:evaluable()

Invoked to return a request for encoding and transport

prepare_retransmit/4

prepare_retransmit(Packet, ServiceName, Peer, Config) -> Action

Packet = packet()
ServiceName = diameter:service_name()
Peer = peer()
Config = map()
Action = Send | Discard | {eval_packet, Action, PostF}
Send = {send, packet() | message()}
Discard = {discard, Reason} | discard
Reason = term()
PostF = diameter:evaluable()

Invoked to return a request for encoding and retransmission. In case of peer connection is lost alternate peer is selected.

handle_answer/5

handle_answer(Packet, Request, ServiceName, Peer, Config) -> Result

Packet = packet()
Request = message()
ServiceName = diameter:service_name()
Peer = peer()
Config = map()
Result = term()

Invoked when an answer message is received from a peer.

handle_error/5

handle_error(Reason, Request, ServiceName, Peer, Config) -> Result

Reason = timeout | failover | term()
Request = message()
ServiceName = diameter:service_name()
Peer = peer()
Config = map()
Result = term()

Invoked when an error occurs before an answer message is received in response to an outgoing request.

handle_request/4

handle_request(Packet, ServiceName, Peer, Config) -> Action

Packet = packet()
ServiceName = term()
Peer = peer()
Config = map()
Action = Reply | {relay, [Opt]} | discard | {eval | eval_packet, Action, PostF}
Reply = {reply, packet() | message()} | {answer_message, 3000..3999 | 5000..5999} | {protocol_error, 3000..3999}
Opt = diameter:call_opt()
PostF = diameter:evaluable()

Invoked when a request message is received from the peer.

errors/4 *

errors(ServiceName, Capabilities, Request, Errors) -> Action

ServiceName = atom()
Capabilities = capabilities()
Request = message()
Errors = [Error]
Error = {Code, #diameter_avp{}} | Code
Code = 0..4294967295
Action = Reply | {relay, [Opt]} | discard | {eval | eval_packet, Action, PostF}
Reply = {reply, packet() | message()} | {answer_message, 3000..3999 | 5000..5999} | {protocol_error, 3000..3999}
Opt = diameter:call_opt()
PostF = diameter:evaluable()

Handle errors in requests.

process_request/5 *

process_request(IpAddress, Port, Caps, Request, Config) -> Result

IpAddress = inet:ip_address()
Port = inet:port_number()
Request = #'3gpp_ro_CCR'{}
Config = map()
Caps = capabilities()
Result = packet() | message()

Process a received DIAMETER Accounting packet.

accounting_event_type/1 *

accounting_event_type(RequestType) -> EventType

RequestType = 1..4
EventType = start | interim | stop | event

Converts CC-Request-Type integer value to a readable atom.

fui/1 *

fui(RedirectServerAddress) -> Result

RedirectServerAddress = string()
Result = [#'3gpp_ro_Final-Unit-Indication'{}]

Parse redirect server address.

subscriber_id/3 *

subscriber_id(SubscriptionIds, UserName, SubIdTypes) -> SubscriberIDs

SubscriptionIds = [#'3gpp_ro_Subscription-Id'{}]
UserName = [binary()]
SubIdTypes = [SubIdType] | undefined
SubIdType = imsi | msisdn | nai | sip | private
SubscriberIDs = [binary()]

Get filtered subscriber IDs in priority order.

Generated by EDoc