processor

package

v1.0.0 Latest Latest Go to latest Published: Sep 13, 2024 License: Apache-2.0 Imports: 24 Imported by: 0

Details

View Source

const (
	COMPLEX_QUERY_TYPE_CNF string = "CNF"
	COMPLEX_QUERY_TYPE_DNF string = "DNF"
)

This section is empty.

This section is empty.

type AtomElem struct {
	// contains filtered or unexported fields
}

type Processor struct {
	ProcessorNrf
}

func NewProcessor(nrf ProcessorNrf) (*Processor, error)

func (p *Processor) AccessTokenProcedure(request models.AccessTokenReq) (
	*models.AccessTokenRsp, *models.AccessTokenErr,
)

func (p *Processor) AccessTokenScopeCheck(req models.AccessTokenReq) *models.AccessTokenErr

func (p *Processor) CreateSubscriptionProcedure(
	subscription models.NrfSubscriptionData,
) (bson.M, *models.ProblemDetails)

func (p *Processor) GetNFInstanceProcedure(c *gin.Context, nfInstanceID string)

func (p *Processor) GetNFInstancesProcedure(nfType string, limit int) (*nrf_context.UriList, *models.ProblemDetails)

func (p *Processor) HandleAccessTokenRequest(c *gin.Context, accessTokenReq models.AccessTokenReq)

func (p *Processor) HandleCreateSubscriptionRequest(
	c *gin.Context,
	subscription models.NrfSubscriptionData,
)

func (p *Processor) HandleGetNFInstanceRequest(c *gin.Context, nfInstanceId string)

func (p *Processor) HandleGetNFInstancesRequest(c *gin.Context, nfType string, limit int)

func (p *Processor) HandleNFDeregisterRequest(c *gin.Context, nfInstanceId string)

func (p *Processor) HandleNFDiscoveryRequest(c *gin.Context, queryParameters url.Values)

func (p *Processor) HandleNFRegisterRequest(c *gin.Context, nfProfile models.NfProfile)

func (p *Processor) HandleRemoveSubscriptionRequest(c *gin.Context, subscriptionID string)

func (p *Processor) HandleUpdateNFInstanceRequest(c *gin.Context, patchJSON []byte, nfInstanceID string)

func (p *Processor) HandleUpdateSubscriptionRequest(
	c *gin.Context,
	subscriptionID string,
	patchJSON []byte,
)

func (p *Processor) NFDeregisterProcedure(nfInstanceID string) *models.ProblemDetails

func (p *Processor) NFDiscoveryProcedure(c *gin.Context, queryParameters url.Values)

func (p *Processor) NFRegisterProcedure(
	c *gin.Context,
	nfProfile models.NfProfile,
)

func (p *Processor) RemoveSubscriptionProcedure(subscriptionID string)

func (p *Processor) UpdateNFInstanceProcedure(nfInstanceID string, patchJSON []byte) map[string]interface{}

func (p *Processor) UpdateSubscriptionProcedure(subscriptionID string, patchJSON []byte) map[string]interface{}

type ProcessorNrf interface {
	app.App
	Consumer() *consumer.Consumer
}