processor

Documentation

Index

• type HandlerResponse
• type Processor
  • func NewProcessor(chf ProcessorChf) (*Processor, error)
  • func (p *Processor) BuildConvergedChargingDataUpdateResopone(chargingData models.ChargingDataRequest) (models.ChargingDataResponse, bool)
  • func (p *Processor) BuildOnlineChargingDataCreateResopone(ue *chf_context.ChfUe, chargingData models.ChargingDataRequest) models.ChargingDataResponse
  • func (p *Processor) ChargingDataCreate(chargingData models.ChargingDataRequest) (*models.ChargingDataResponse, string, *models.ProblemDetails)
  • func (p *Processor) ChargingDataRelease(chargingData models.ChargingDataRequest, chargingSessionId string) *models.ProblemDetails
  • func (p *Processor) ChargingDataUpdate(chargingData models.ChargingDataRequest, chargingSessionId string) (*models.ChargingDataResponse, *models.ProblemDetails)
  • func (p *Processor) CloseCDR(record *cdrType.CHFRecord, partial bool) error
  • func (p *Processor) HandleChargingdataInitial(c *gin.Context, chargingdata models.ChargingDataRequest)
  • func (p *Processor) HandleChargingdataRelease(c *gin.Context, chargingdata models.ChargingDataRequest, ...)
  • func (p *Processor) HandleChargingdataUpdate(c *gin.Context, chargingdata models.ChargingDataRequest, ...)
  • func (p *Processor) NotifyRecharge(ueId string, rg int32)
  • func (p *Processor) OpenCDR(chargingData models.ChargingDataRequest, ue *chf_context.ChfUe, ...) (*cdrType.CHFRecord, error)
  • func (p *Processor) SendChargingNotification(notifyUri string, notifyRequest models.ChargingNotifyRequest)
  • func (p *Processor) UpdateCDR(record *cdrType.CHFRecord, chargingData models.ChargingDataRequest) error
• type ProcessorChf

Types

type HandlerResponse

type HandlerResponse struct {
	Status  int
	Headers map[string][]string
	Body    interface{}
}

type Processor

type Processor struct {
	ProcessorChf
}

func NewProcessor

func NewProcessor(chf ProcessorChf) (*Processor, error)

func (*Processor) BuildConvergedChargingDataUpdateResopone

func (p *Processor) BuildConvergedChargingDataUpdateResopone(
	chargingData models.ChargingDataRequest,
) (models.ChargingDataResponse, bool)

func (*Processor) BuildOnlineChargingDataCreateResopone

func (p *Processor) BuildOnlineChargingDataCreateResopone(
	ue *chf_context.ChfUe, chargingData models.ChargingDataRequest,
) models.ChargingDataResponse

func (*Processor) ChargingDataCreate

func (p *Processor) ChargingDataCreate(chargingData models.ChargingDataRequest) (*models.ChargingDataResponse,
	string, *models.ProblemDetails)

func (*Processor) ChargingDataRelease

func (p *Processor) ChargingDataRelease(
	chargingData models.ChargingDataRequest, chargingSessionId string) *models.ProblemDetails

func (*Processor) ChargingDataUpdate

func (p *Processor) ChargingDataUpdate(
	chargingData models.ChargingDataRequest, chargingSessionId string,
) (*models.ChargingDataResponse, *models.ProblemDetails)

func (*Processor) CloseCDR

func (p *Processor) CloseCDR(record *cdrType.CHFRecord, partial bool) error

func (*Processor) HandleChargingdataInitial

func (p *Processor) HandleChargingdataInitial(
	c *gin.Context,
	chargingdata models.ChargingDataRequest,
)

func (*Processor) HandleChargingdataRelease

func (p *Processor) HandleChargingdataRelease(
	c *gin.Context,
	chargingdata models.ChargingDataRequest,
	chargingSessionId string,
)

func (*Processor) HandleChargingdataUpdate

func (p *Processor) HandleChargingdataUpdate(
	c *gin.Context,
	chargingdata models.ChargingDataRequest,
	chargingSessionId string,
)

func (*Processor) NotifyRecharge

func (p *Processor) NotifyRecharge(ueId string, rg int32)

func (*Processor) OpenCDR

func (p *Processor) OpenCDR(
	chargingData models.ChargingDataRequest, ue *chf_context.ChfUe, sessionId string, partialRecord bool,
) (*cdrType.CHFRecord, error)

func (*Processor) SendChargingNotification

func (p *Processor) SendChargingNotification(notifyUri string, notifyRequest models.ChargingNotifyRequest)

func (*Processor) UpdateCDR

func (p *Processor) UpdateCDR(record *cdrType.CHFRecord, chargingData models.ChargingDataRequest) error

type ProcessorChf

type ProcessorChf interface {
	app.App
}