mediator

Documentation

Index

• type FScsvCDR
  • func NewFScsvCDR(cdrRow []string, ...) (*FScsvCDR, error)
  • func (self *FScsvCDR) GetAccId() string
  • func (self *FScsvCDR) GetAccount() string
  • func (self *FScsvCDR) GetAnswerTime() (time.Time, error)
  • func (self *FScsvCDR) GetCdrHost() string
  • func (self *FScsvCDR) GetCgrId() string
  • func (self *FScsvCDR) GetDestination() string
  • func (self *FScsvCDR) GetDirection() string
  • func (self *FScsvCDR) GetDuration() int64
  • func (self *FScsvCDR) GetExtraFields() map[string]string
  • func (self *FScsvCDR) GetReqType() string
  • func (self *FScsvCDR) GetSubject() string
  • func (self *FScsvCDR) GetTOR() string
  • func (self *FScsvCDR) GetTenant() string
• type Mediator
  • func NewMediator(connector engine.Connector, logDb engine.LogStorage, cdrDb engine.CdrStorage, ...) (m *Mediator, err error)
  • func (self *Mediator) MediateRawCDR(dbcdr utils.RawCDR) error

Types

type FScsvCDR

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

func NewFScsvCDR

func NewFScsvCDR(cdrRow []string, accIdIdx, subjectIdx, reqtypeIdx, directionIdx, tenantIdx, torIdx,
	accountIdx, destinationIdx, answerTimeIdx, durationIdx int, cfg *config.CGRConfig) (*FScsvCDR, error)

func (*FScsvCDR) GetAccId

func (self *FScsvCDR) GetAccId() string

func (*FScsvCDR) GetAccount

func (self *FScsvCDR) GetAccount() string

func (*FScsvCDR) GetAnswerTime

func (self *FScsvCDR) GetAnswerTime() (time.Time, error)

func (*FScsvCDR) GetCdrHost

func (self *FScsvCDR) GetCdrHost() string

func (*FScsvCDR) GetCgrId

func (self *FScsvCDR) GetCgrId() string

func (*FScsvCDR) GetDestination

func (self *FScsvCDR) GetDestination() string

func (*FScsvCDR) GetDirection

func (self *FScsvCDR) GetDirection() string

func (*FScsvCDR) GetDuration

func (self *FScsvCDR) GetDuration() int64

func (*FScsvCDR) GetExtraFields

func (self *FScsvCDR) GetExtraFields() map[string]string

func (*FScsvCDR) GetReqType

func (self *FScsvCDR) GetReqType() string

func (*FScsvCDR) GetSubject

func (self *FScsvCDR) GetSubject() string

func (*FScsvCDR) GetTOR

func (self *FScsvCDR) GetTOR() string

func (*FScsvCDR) GetTenant

func (self *FScsvCDR) GetTenant() string

type Mediator

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

func NewMediator

func NewMediator(connector engine.Connector, logDb engine.LogStorage, cdrDb engine.CdrStorage, cfg *config.CGRConfig) (m *Mediator, err error)

func (*Mediator) MediateRawCDR

func (self *Mediator) MediateRawCDR(dbcdr utils.RawCDR) error

Forks original CDR based on original request plus runIds for extra mediation