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 + func GetBaseNameDeserializer() object_store.Deserializer + func GetBaseNameSerializer() object_store.Serializer + func GetFlowDescriptionFromFlowString(descriptorStr string) (*protos.FlowDescription, error) + func GetPolicyDeserializer() object_store.Deserializer + func GetPolicySerializer() object_store.Serializer + func GetRuleMappingDeserializer() object_store.Deserializer + func GetRuleMappingSerializer() object_store.Serializer + type BaseNameStreamListener struct + func NewBaseNameStreamListener(streamMap object_store.ObjectMap) *BaseNameStreamListener + func (listener *BaseNameStreamListener) GetExtraArgs() *any.Any + func (listener *BaseNameStreamListener) GetName() string + func (listener *BaseNameStreamListener) ReportError(e error) error + func (listener *BaseNameStreamListener) Update(ub *orcprotos.DataUpdateBatch) bool + type ChargingKey struct + RatingGroup uint32 + ServiceIdTracking bool + ServiceIdentifier uint32 + func CreateChargingKey(rule *protos.PolicyRule) ChargingKey + func (k ChargingKey) String() string + type OmnipresentRulesStreamListener struct + func NewOmnipresentRulesListener(streamMap object_store.ObjectMap) *OmnipresentRulesStreamListener + func (listener *OmnipresentRulesStreamListener) GetExtraArgs() *any.Any + func (listener *OmnipresentRulesStreamListener) GetName() string + func (listener *OmnipresentRulesStreamListener) ReportError(e error) error + func (listener *OmnipresentRulesStreamListener) Update(ub *orcprotos.DataUpdateBatch) bool + type PolicyDBClient interface + GetChargingKeysForRules func(ruleIDs []string, ruleDefs []*protos.PolicyRule) []ChargingKey + GetOmnipresentRules func() ([]string, []string) + GetPolicyRuleByID func(id string) (*protos.PolicyRule, error) + GetRuleIDsForBaseNames func(baseNames []string) []string + type PolicyDBStreamListener struct + func NewPolicyDBStreamListener(streamMap object_store.ObjectMap) *PolicyDBStreamListener + func (listener *PolicyDBStreamListener) GetExtraArgs() *any.Any + func (listener *PolicyDBStreamListener) GetName() string + func (listener *PolicyDBStreamListener) ReportError(e error) error + func (listener *PolicyDBStreamListener) Update(ub *orcprotos.DataUpdateBatch) bool + type RedisPolicyDBClient struct + BaseNameMap object_store.ObjectMap + OmnipresentRules object_store.ObjectMap + PolicyMap object_store.ObjectMap + StreamerClient streamer.Client + func NewRedisPolicyDBClient(reg service_registry.GatewayRegistry) (*RedisPolicyDBClient, error) + func (client *RedisPolicyDBClient) GetChargingKeysForRules(staticRuleIDs []string, dynamicRuleDefs []*protos.PolicyRule) []ChargingKey + func (client *RedisPolicyDBClient) GetOmnipresentRules() ([]string, []string) + func (client *RedisPolicyDBClient) GetPolicyRuleByID(id string) (*protos.PolicyRule, error) + func (client *RedisPolicyDBClient) GetRuleIDsForBaseNames(baseNames []string) []string Other modules containing this package github.com/go-magma/magma/modules/feg/gateway
Go to main page