Versions in this module Expand all Collapse all v1 v1.1.1 Aug 18, 2020 Changes in this version + const DefaultFramedIPv4AddrEnv + const DisableDestHostEnv + const DisableEUIIPv6IfNoIPEnv + const DisableEUIIPv6IfNoIPFlag + const FramedIPv4AddrRequiredEnv + const GxDiamHostEnv + const GxDiamProductEnv + const GxDiamRealmEnv + const GxLocalAddr + const GxNetworkEnv + const GxSupportedVendorIDsEnv + const OverwriteDestHostEnv + const PCRF91CompliantEnv + const PCRF91CompliantFlag + const PCRFAddrEnv + const PCRFHostEnv + const PCRFRealmEnv + func ConvertToProtoTimestamp(unixTime *time.Time) *timestamp.Timestamp + func GetEventTriggersRelatedInfo(eventTriggers []EventTrigger, revalidationTime *time.Time) ([]protos.EventTrigger, *timestamp.Timestamp) + func GetGxClientConfiguration() []*diameter.DiameterClientConfig + func GetIPCANType(pRATType protos.RATType) credit_control.IPCANType + func GetPCRFConfiguration() []*diameter.DiameterServerConfig + func GetRATType(pRATType protos.RATType) credit_control.RATType + func Ipv6PrefixFromMAC(mac net.HardwareAddr) []byte + func ParseRuleInstallAVPs(policyDBClient policydb.PolicyDBClient, ruleInstalls []*RuleInstallAVP) ([]*protos.StaticRuleInstall, []*protos.DynamicRuleInstall) + func ParseRuleRemoveAVPs(policyDBClient policydb.PolicyDBClient, rulesToRemoveAVP []*RuleRemoveAVP) []string + type CCADiameterMessage struct + EventTriggers []EventTrigger + ExperimentalResult struct{ ... } + OriginHost string + RequestNumber uint32 + RequestType uint32 + ResultCode uint32 + RevalidationTime *time.Time + RuleInstalls []*RuleInstallAVP + RuleRemovals []*RuleRemoveAVP + SessionID string + UsageMonitors []*UsageMonitoringInfo + type ChargingRuleReport struct + FailureCode RuleFailureCode + RuleBaseNames []string + RuleNames []string + type CreditControlAnswer struct + EventTriggers []EventTrigger + ExperimentalResultCode uint32 + OriginHost string + RequestNumber uint32 + ResultCode uint32 + RevalidationTime *time.Time + RuleInstallAVP []*RuleInstallAVP + RuleRemoveAVP []*RuleRemoveAVP + SessionID string + UsageMonitors []*UsageMonitoringInfo + func GetAnswer(done <-chan interface{}) *CreditControlAnswer + type CreditControlRequest struct + Apn string + EventTrigger EventTrigger + GcID string + HardwareAddr []byte + IMSI string + IPAddr string + IPCANType credit_control.IPCANType + Imei string + Msisdn []byte + PlmnID string + Qos *QosRequestInfo + RATType credit_control.RATType + RequestNumber uint32 + SessionID string + SpgwIPV4 string + TgppCtx *protos.TgppContext + Type credit_control.CreditRequestType + UsageReports []*UsageReport + UserLocation []byte + func (ccr *CreditControlRequest) FromUsageMonitorUpdate(update *protos.UsageMonitoringUpdateRequest) *CreditControlRequest + type EventTrigger uint32 + const PCRF91UsageReportTrigger + const RevalidationTimeout + const UsageReportTrigger + type FlowInformation struct + FlowDescription string + type GxClient struct + func NewConnectedGxClient(diamClient *diameter.Client, serverCfg *diameter.DiameterServerConfig, ...) *GxClient + func NewGxClient(clientCfg *diameter.DiameterClientConfig, ...) *GxClient + func (gxClient *GxClient) DisableConnections(period time.Duration) + func (gxClient *GxClient) EnableConnections() error + func (gxClient *GxClient) IgnoreAnswer(request *CreditControlRequest) + func (gxClient *GxClient) SendCreditControlRequest(server *diameter.DiameterServerConfig, done chan interface{}, ...) error + type GxGlobalConfig struct + DisableGx bool + PCFROverwriteApn string + func GetGxGlobalConfig() *GxGlobalConfig + type MonitoringLevel uint8 + const RuleLevel + const SessionLevel + type PolicyClient interface + DisableConnections func(period time.Duration) + EnableConnections func() error + IgnoreAnswer func(request *CreditControlRequest) + SendCreditControlRequest func(server *diameter.DiameterServerConfig, done chan interface{}, ...) error + type PolicyReAuthAnswer struct + ResultCode uint32 + RuleReports []*ChargingRuleReport + SessionID string + func (raa *PolicyReAuthAnswer) FromProto(sessionID string, answer *protos.PolicyReAuthAnswer) *PolicyReAuthAnswer + type PolicyReAuthHandler func(request *PolicyReAuthRequest) *PolicyReAuthAnswer + func GetGxReAuthHandler(cloudRegistry service_registry.GatewayRegistry, ...) PolicyReAuthHandler + type PolicyReAuthRequest struct + EventTriggers []EventTrigger + OriginHost string + Qos *QosInformation + RevalidationTime *time.Time + RulesToInstall []*RuleInstallAVP + RulesToRemove []*RuleRemoveAVP + SessionID string + UsageMonitors []*UsageMonitoringInfo + func (rar *PolicyReAuthRequest) ToProto(imsi, sid string, policyDBClient policydb.PolicyDBClient) *protos.PolicyReAuthRequest + type QosInformation struct + BearerIdentifier string + GbrDL *uint32 + GbrUL *uint32 + MaxReqBwDL *uint32 + MaxReqBwUL *uint32 + Qci *uint32 + func (q *QosInformation) ToProto() *protos.FlowQos + type QosRequestInfo struct + ApnAggMaxBitRateDL uint32 + ApnAggMaxBitRateUL uint32 + PreCapability uint32 + PreVulnerability uint32 + PriLevel uint32 + QosClassIdentifier uint32 + func (qos *QosRequestInfo) FromProtos(pQos *protos.QosInformationRequest) *QosRequestInfo + type RedirectInformation struct + RedirectAddressType uint32 + RedirectServerAddress string + RedirectSupport uint32 + func (r *RedirectInformation) ToProto() *protos.RedirectInformation + type RuleDefinition struct + FlowDescriptions []string + FlowInformations []*FlowInformation + MonitoringKey []byte + Precedence uint32 + Qos *QosInformation + RatingGroup *uint32 + RedirectInformation *RedirectInformation + RuleName string + ServiceIdentifier *uint32 + func (rd *RuleDefinition) GetFlowList() []*protos.FlowDescription + func (rd *RuleDefinition) GetTrackingType() protos.PolicyRule_TrackingType + func (rd *RuleDefinition) ToProto() *protos.PolicyRule + type RuleFailureCode uint32 + const ANGWFailed + const CMAuthorizationRejected + const CMCreditControlNotApplicable + const CMEndUserServiceDenied + const CMRatingFailed + const CMUserUnknown + const FilterRestrictions + const GwPCEFMalfunction + const IncorrectFlowInformation + const MaxNrBearersReached + const MissingBearerID + const MissingFlowInformation + const MissingRedirectServerAddress + const NoBearerFound + const NoNBIFOMSupport + const PsToCsHandover + const RatingGroupError + const ResourceAllocationFailure + const ResourcesLimitation + const RoutingRuleRejection + const ServiceIdentifierError + const TDFApplicationIdentifierError + const UnknownBearerID + const UnknownRoutingAccessInformation + const UnknownRuleName + const UnsuccessfulQoSValidation + type RuleInstallAVP struct + RuleActivationTime *time.Time + RuleBaseNames []string + RuleDeactivationTime *time.Time + RuleDefinitions []*RuleDefinition + RuleNames []string + type RuleRemoveAVP struct + RuleBaseNames []string + RuleNames []string + type UsageMonitoringInfo struct + GrantedServiceUnit *credit_control.GrantedServiceUnit + Level MonitoringLevel + MonitoringKey []byte + func (monitor *UsageMonitoringInfo) ToUsageMonitoringCredit() *protos.UsageMonitoringCredit + type UsageReport struct + InputOctets uint64 + Level MonitoringLevel + MonitoringKey []byte + OutputOctets uint64 + TotalOctets uint64 + func (report *UsageReport) FromUsageMonitorUpdate(update *protos.UsageMonitorUpdate) *UsageReport Other modules containing this package github.com/go-magma/magma