Versions in this module Expand all Collapse all v1 v1.2.1 Aug 20, 2020 v1.2.0 Aug 20, 2020 Changes in this version + const Buffer + const CwagIP + const DirectorydPort + const DirectorydRemote + const GyMaxUsageBytes + const GyMaxUsageTime + const GyValidityTime + const HSSPort + const IPDRControllerIP + const KiloBytes + const MegaBytes + const MockHSSRemote + const MockOCSRemote + const MockOCSRemote2 + const MockPCRFRemote + const MockPCRFRemote2 + const OCSPort + const OCSPort2 + const Op + const PCRFPort + const PCRFPort2 + const PipelinedPort + const PipelinedRemote + const ReAuthMaxUsageBytes + const ReAuthMaxUsageTimeSec + const ReAuthValidityTime + const RedisPort + const RedisRemote + const RevalidationTimeoutEvent + const Secret + const TrafficCltIP + var OCSinstances = []string + var PCRFinstances = []string + type CmdOutput struct + type RecordByIMSI map[string]map[string]*lteprotos.RuleRecord + type RuleManager struct + func NewRuleManager() (*RuleManager, error) + func NewRuleManagerPerInstance(pcrfInstance string) (*RuleManager, error) + func (manager *RuleManager) AddBaseNameMappingToDB(basename string, ruleNames []string) error + func (manager *RuleManager) AddDynamicPassAllToPCRF(imsi, ruleID, monitoringKey string) error + func (manager *RuleManager) AddOmniPresentRulesToDB(keyId string, ruleNames, baseNames []string) error + func (manager *RuleManager) AddRulesToPCRF(imsi string, ruleNames, baseNames []string) error + func (manager *RuleManager) AddStaticPassAllToDB(ruleID string, monitoringKey string, ratingGroup uint32, trackingType string, ...) error + func (manager *RuleManager) AddStaticPassAllToDBAndPCRFforIMSIs(IMSIs []string, ruleID string, monitoringKey string, ratingGroup uint32, ...) error + func (manager *RuleManager) AddStaticRuleToDB(rule *lteProtos.PolicyRule) error + func (manager *RuleManager) AddUsageMonitor(imsi, monitoringKey string, volume, bytesPerGrant uint64) error + func (manager *RuleManager) GetInstalledRulesByIMSI() map[string][]string + func (manager *RuleManager) RemoveInstalledRules() error + func (manager *RuleManager) RemoveOmniPresentRulesFromDB(keyId string) error + type TestRunner struct + func NewTestRunner(t *testing.T) *TestRunner + func NewTestRunnerWithTwoPCRFandOCS(t *testing.T) *TestRunner + func (tr *TestRunner) AssertAllGxExpectationsMetNoError() + func (tr *TestRunner) AssertAllGyExpectationsMetNoError() + func (tr *TestRunner) AssertPolicyEnforcementRecordIsNil(imsi string) + func (tr *TestRunner) Authenticate(imsi, calledStationID string) (*radius.Packet, error) + func (tr *TestRunner) AuthenticateAndAssertFail(imsi string) + func (tr *TestRunner) AuthenticateAndAssertSuccess(imsi string) + func (tr *TestRunner) AuthenticateAndAssertSuccessWithRetries(imsi string, maxRetries int) + func (tr *TestRunner) AuthenticateWithCalledIDAndAssertSuccess(imsi, calledStationID string) + func (tr *TestRunner) CleanUp() error + func (tr *TestRunner) ConfigUEs(numUEs int) ([]*cwfprotos.UEConfig, error) + func (tr *TestRunner) ConfigUEsPerInstance(IMSIs []string, pcrfInstance, ocsInstance string) ([]*cwfprotos.UEConfig, error) + func (tr *TestRunner) Disconnect(imsi, calledStationID string) (*radius.Packet, error) + func (tr *TestRunner) DisconnectAndAssertSuccess(imsi string) + func (tr *TestRunner) GenULTraffic(req *cwfprotos.GenTrafficRequest) (*cwfprotos.GenTrafficResponse, error) + func (tr *TestRunner) GetPolicyUsage() (RecordByIMSI, error) + func (tr *TestRunner) OverwriteMConfig(mconfigPath string, serviceName string) error + func (tr *TestRunner) PauseService(serviceName string) error + func (tr *TestRunner) RestartService(serviceName string) error + func (tr *TestRunner) RunCommandInContainer(serviceName string, cmdList [][]string) ([]*CmdOutput, error) + func (tr *TestRunner) ScanContainerLogs(serviceName string, line string) int + func (tr *TestRunner) WaitForEnforcementStatsToSync() + func (tr *TestRunner) WaitForPoliciesToSync() + func (tr *TestRunner) WaitForReAuthToProcess()