streamer

Documentation

Index

• type BaseNamesProvider
  • func (p *BaseNamesProvider) GetStreamName() string
  • func (p *BaseNamesProvider) GetUpdates(gatewayId string, extraArgs *any.Any) ([]*protos.DataUpdate, error)
• type NetworkWideRulesProvider
  • func (p *NetworkWideRulesProvider) GetStreamName() string
  • func (p *NetworkWideRulesProvider) GetUpdates(gatewayId string, extraArgs *any.Any) ([]*protos.DataUpdate, error)
• type PoliciesProvider
  • func (p *PoliciesProvider) GetStreamName() string
  • func (p *PoliciesProvider) GetUpdates(gatewayId string, extraArgs *any.Any) ([]*protos.DataUpdate, error)
• type RatingGroupsProvider
  • func (p *RatingGroupsProvider) GetStreamName() string
  • func (provider *RatingGroupsProvider) GetUpdates(gatewayId string, extraArgs *any.Any) ([]*protos.DataUpdate, error)
• type RuleMappingsProvider
  • func (p *RuleMappingsProvider) GetStreamName() string
  • func (p *RuleMappingsProvider) GetUpdates(gatewayId string, extraArgs *any.Any) ([]*protos.DataUpdate, error)

Types

type BaseNamesProvider

type BaseNamesProvider struct{}

func (*BaseNamesProvider) GetStreamName

func (p *BaseNamesProvider) GetStreamName() string

func (*BaseNamesProvider) GetUpdates

func (p *BaseNamesProvider) GetUpdates(gatewayId string, extraArgs *any.Any) ([]*protos.DataUpdate, error)

type NetworkWideRulesProvider

type NetworkWideRulesProvider struct{}

func (*NetworkWideRulesProvider) GetStreamName

func (p *NetworkWideRulesProvider) GetStreamName() string

func (*NetworkWideRulesProvider) GetUpdates

func (p *NetworkWideRulesProvider) GetUpdates(gatewayId string, extraArgs *any.Any) ([]*protos.DataUpdate, error)

type PoliciesProvider

type PoliciesProvider struct{}

func (*PoliciesProvider) GetStreamName

func (p *PoliciesProvider) GetStreamName() string

func (*PoliciesProvider) GetUpdates

func (p *PoliciesProvider) GetUpdates(gatewayId string, extraArgs *any.Any) ([]*protos.DataUpdate, error)

type RatingGroupsProvider

type RatingGroupsProvider struct{}

TODO: need to stream down the infinite credit charging keys from here

func (*RatingGroupsProvider) GetStreamName

func (p *RatingGroupsProvider) GetStreamName() string

func (*RatingGroupsProvider) GetUpdates

func (provider *RatingGroupsProvider) GetUpdates(gatewayId string, extraArgs *any.Any) ([]*protos.DataUpdate, error)

GetUpdates implements GetUpdates for the policies stream provider

type RuleMappingsProvider

type RuleMappingsProvider struct{}

func (*RuleMappingsProvider) GetStreamName

func (p *RuleMappingsProvider) GetStreamName() string

func (*RuleMappingsProvider) GetUpdates

func (p *RuleMappingsProvider) GetUpdates(gatewayId string, extraArgs *any.Any) ([]*protos.DataUpdate, error)

GetUpdates implements GetUpdates for the rule mappings stream provider