context

Documentation

Index

• func GetIPv4Uri() string
• func Init()
• func NewInfluenceDataSubscriptionId() string
• type EeSubscriptionCollection
• type NFContext
• type UDRContext
  • func GetSelf() *UDRContext
  • func (c *UDRContext) AuthorizationCheck(token string, serviceName models.ServiceName) error
  • func (context *UDRContext) GetIPv4GroupUri(udrServiceType UDRServiceType) string
  • func (c *UDRContext) GetTokenCtx(serviceName models.ServiceName, targetNF models.NfType) (context.Context, *models.ProblemDetails, error)
  • func (context *UDRContext) NewAppDataInfluDataSubscriptionID() uint64
  • func (context *UDRContext) Reset()
• type UDRServiceType
• type UEGroupSubsData
• type UESubsData

Functions

func GetIPv4Uri

func GetIPv4Uri() string

func Init

func Init()

func NewInfluenceDataSubscriptionId

func NewInfluenceDataSubscriptionId() string

Types

type EeSubscriptionCollection

type EeSubscriptionCollection struct {
	EeSubscriptions      *models.EeSubscription
	AmfSubscriptionInfos []models.AmfSubscriptionInfo
}

type NFContext

type NFContext interface {
	AuthorizationCheck(token string, serviceName models.ServiceName) error
}

type UDRContext

type UDRContext struct {
	Name                                    string
	UriScheme                               models.UriScheme
	BindingIPv4                             string
	SBIPort                                 int
	NfService                               map[models.ServiceName]models.NfService
	RegisterIPv4                            string // IP register to NRF
	HttpIPv6Address                         string
	NfId                                    string
	NrfUri                                  string
	NrfCertPem                              string
	EeSubscriptionIDGenerator               int
	SdmSubscriptionIDGenerator              int
	SubscriptionDataSubscriptionIDGenerator int
	PolicyDataSubscriptionIDGenerator       int
	InfluenceDataSubscriptionIDGenerator    *rand.Rand
	UESubsCollection                        sync.Map // map[ueId]*UESubsData
	UEGroupCollection                       sync.Map // map[ueGroupId]*UEGroupSubsData
	SubscriptionDataSubscriptions           map[subsId]*models.SubscriptionDataSubscriptions
	PolicyDataSubscriptions                 map[subsId]*models.PolicyDataSubscription
	InfluenceDataSubscriptions              sync.Map

	OAuth2Required bool
	// contains filtered or unexported fields
}

func GetSelf

func GetSelf() *UDRContext

Create new UDR context

func (*UDRContext) AuthorizationCheck

func (c *UDRContext) AuthorizationCheck(token string, serviceName models.ServiceName) error

func (*UDRContext) GetIPv4GroupUri

func (context *UDRContext) GetIPv4GroupUri(udrServiceType UDRServiceType) string

func (*UDRContext) GetTokenCtx

func (c *UDRContext) GetTokenCtx(serviceName models.ServiceName, targetNF models.NfType) (
	context.Context, *models.ProblemDetails, error,
)

func (*UDRContext) NewAppDataInfluDataSubscriptionID

func (context *UDRContext) NewAppDataInfluDataSubscriptionID() uint64

func (*UDRContext) Reset

func (context *UDRContext) Reset()

Reset UDR Context

type UDRServiceType

type UDRServiceType int

const (
	NUDR_DR UDRServiceType = iota
)

type UEGroupSubsData

type UEGroupSubsData struct {
	EeSubscriptions map[subsId]*models.EeSubscription
}

type UESubsData

type UESubsData struct {
	EeSubscriptionCollection map[subsId]*EeSubscriptionCollection
	SdmSubscriptions         map[subsId]*models.SdmSubscription
}