consumer

Documentation

Index

• type Consumer
  • func NewConsumer(smf app.App) (*Consumer, error)
  • func (s Consumer) CHFSelection(smContext *smf_context.SMContext) error
  • func (s Consumer) GetSmData(ctx context.Context, supi string, ...) ([]models.SessionManagementSubscriptionData, *http.Response, error)
  • func (s Consumer) N1N2MessageTransfer(ctx context.Context, supi string, ...) (*models.N1N2MessageTransferRspData, *int, error)
  • func (s Consumer) NFDiscoveryAMF(smContext *smf_context.SMContext, ctx context.Context) (result models.SearchResult, httpResp *http.Response, localErr error)
  • func (s Consumer) NFDiscoveryPCF(ctx context.Context) (result models.SearchResult, httpResp *http.Response, localErr error)
  • func (s Consumer) NFDiscoveryUDM(ctx context.Context) (result models.SearchResult, httpResp *http.Response, localErr error)
  • func (s Consumer) PCFSelection(smContext *smf_context.SMContext) error
  • func (s Consumer) RegisterNFInstance(ctx context.Context) error
  • func (s Consumer) RetrySendNFRegistration(maxRetry int) error
  • func (s Consumer) SearchNFInstances(ctx context.Context, targetNfType models.NfType, requesterNfType models.NfType, ...) (*models.SearchResult, *http.Response, error)
  • func (s Consumer) SendConvergedChargingRequest(smContext *smf_context.SMContext, requestType smf_context.RequestType, ...) (*models.ChargingDataResponse, *models.ProblemDetails, error)
  • func (s Consumer) SendDeregisterNFInstance() (problemDetails *models.ProblemDetails, err error)
  • func (s Consumer) SendNFDiscoveryPCF() (problemDetails *models.ProblemDetails, err error)
  • func (s Consumer) SendNFDiscoveryServingAMF(smContext *smf_context.SMContext) (*models.ProblemDetails, error)
  • func (s Consumer) SendNFDiscoveryUDM() (*models.ProblemDetails, error)
  • func (s Consumer) SendSMContextStatusNotification(uri string) (*models.ProblemDetails, error)
  • func (s Consumer) SendSMPolicyAssociationCreate(smContext *smf_context.SMContext) (string, *models.SmPolicyDecision, error)
  • func (s Consumer) SendSMPolicyAssociationTermination(smContext *smf_context.SMContext) error
  • func (s Consumer) SendSMPolicyAssociationUpdateByUERequestModification(smContext *smf_context.SMContext, qosRules nasType.QoSRules, ...) (*models.SmPolicyDecision, error)
  • func (s Consumer) SendSearchNFInstances(nrfUri string, targetNfType, requestNfType models.NfType, ...) (*models.SearchResult, error)
  • func (s Consumer) StringToNasBitRate(str string) (uint16, nasType.QoSFlowBitRateUnit, error)
  • func (s Consumer) UeCmDeregistration(smCtx *smf_context.SMContext) (*models.ProblemDetails, error)
  • func (s Consumer) UeCmRegistration(smCtx *smf_context.SMContext) (*models.ProblemDetails, error)

Types

type Consumer

type Consumer struct {
	app.App
	// contains filtered or unexported fields
}

func NewConsumer

func NewConsumer(smf app.App) (*Consumer, error)

func (Consumer) CHFSelection

func (s Consumer) CHFSelection(smContext *smf_context.SMContext) error

CHFSelection will select CHF for this SM Context

func (Consumer) GetSmData

func (s Consumer) GetSmData(ctx context.Context, supi string,
	localVarOptionals *Nudm_SubscriberDataManagement.GetSmDataParamOpts) (
	[]models.SessionManagementSubscriptionData, *http.Response, error,
)

func (Consumer) N1N2MessageTransfer

func (s Consumer) N1N2MessageTransfer(
	ctx context.Context, supi string, n1n2Request models.N1N2MessageTransferRequest, apiPrefix string,
) (*models.N1N2MessageTransferRspData, *int, error)

func (Consumer) NFDiscoveryAMF

func (s Consumer) NFDiscoveryAMF(smContext *smf_context.SMContext, ctx context.Context) (
	result models.SearchResult, httpResp *http.Response, localErr error,
)

func (Consumer) NFDiscoveryPCF

func (s Consumer) NFDiscoveryPCF(ctx context.Context) (
	result models.SearchResult, httpResp *http.Response, localErr error,
)

func (Consumer) NFDiscoveryUDM

func (s Consumer) NFDiscoveryUDM(ctx context.Context) (result models.SearchResult,
	httpResp *http.Response, localErr error,
)

func (Consumer) PCFSelection

func (s Consumer) PCFSelection(smContext *smf_context.SMContext) error

PCFSelection will select PCF for this SM Context

func (Consumer) RegisterNFInstance

func (s Consumer) RegisterNFInstance(ctx context.Context) error

func (Consumer) RetrySendNFRegistration

func (s Consumer) RetrySendNFRegistration(maxRetry int) error

func (Consumer) SearchNFInstances

func (s Consumer) SearchNFInstances(ctx context.Context, targetNfType models.NfType, requesterNfType models.NfType,
	localVarOptionals *Nnrf_NFDiscovery.SearchNFInstancesParamOpts,
) (*models.SearchResult, *http.Response, error)

func (Consumer) SendConvergedChargingRequest

func (s Consumer) SendConvergedChargingRequest(smContext *smf_context.SMContext,
	requestType smf_context.RequestType, multipleUnitUsage []models.MultipleUnitUsage,
) (*models.ChargingDataResponse, *models.ProblemDetails, error)

func (Consumer) SendDeregisterNFInstance

func (s Consumer) SendDeregisterNFInstance() (problemDetails *models.ProblemDetails, err error)

func (Consumer) SendNFDiscoveryPCF

func (s Consumer) SendNFDiscoveryPCF() (problemDetails *models.ProblemDetails, err error)

func (Consumer) SendNFDiscoveryServingAMF

func (s Consumer) SendNFDiscoveryServingAMF(smContext *smf_context.SMContext) (*models.ProblemDetails, error)

func (Consumer) SendNFDiscoveryUDM

func (s Consumer) SendNFDiscoveryUDM() (*models.ProblemDetails, error)

func (Consumer) SendSMContextStatusNotification

func (s Consumer) SendSMContextStatusNotification(uri string) (*models.ProblemDetails, error)

func (Consumer) SendSMPolicyAssociationCreate

func (s Consumer) SendSMPolicyAssociationCreate(smContext *smf_context.SMContext) (
	string, *models.SmPolicyDecision, error,
)

SendSMPolicyAssociationCreate create the session management association to the PCF

func (Consumer) SendSMPolicyAssociationTermination

func (s Consumer) SendSMPolicyAssociationTermination(smContext *smf_context.SMContext) error

func (Consumer) SendSMPolicyAssociationUpdateByUERequestModification

func (s Consumer) SendSMPolicyAssociationUpdateByUERequestModification(
	smContext *smf_context.SMContext,
	qosRules nasType.QoSRules, qosFlowDescs nasType.QoSFlowDescs,
) (*models.SmPolicyDecision, error)

func (Consumer) SendSearchNFInstances

func (s Consumer) SendSearchNFInstances(nrfUri string, targetNfType, requestNfType models.NfType,
	param *Nnrf_NFDiscovery.SearchNFInstancesParamOpts,
) (*models.SearchResult, error)

func (Consumer) StringToNasBitRate

func (s Consumer) StringToNasBitRate(str string) (uint16, nasType.QoSFlowBitRateUnit, error)

func (Consumer) UeCmDeregistration

func (s Consumer) UeCmDeregistration(smCtx *smf_context.SMContext) (*models.ProblemDetails, error)

func (Consumer) UeCmRegistration

func (s Consumer) UeCmRegistration(smCtx *smf_context.SMContext) (
	*models.ProblemDetails, error,
)