Encode will encode categorical values and normalize according to configuration
()
| 131 | |
| 132 | // Encode will encode categorical values and normalize according to configuration |
| 133 | func (d *Diameter) Encode() []string { |
| 134 | return filter([]string{ |
| 135 | diameterEncoder.Int64(fieldTimestamp, d.Timestamp), |
| 136 | diameterEncoder.Uint32(fieldVersion, d.Version), // uint32 |
| 137 | diameterEncoder.Uint32(fieldFlags, d.Flags), // uint32 |
| 138 | diameterEncoder.Uint32(fieldMessageLen, d.MessageLen), // uint32 |
| 139 | diameterEncoder.Uint32(fieldCommandCode, d.CommandCode), // uint32 |
| 140 | diameterEncoder.Uint32(fieldApplicationID, d.ApplicationID), // uint32 |
| 141 | diameterEncoder.Uint32(fieldHopByHopID, d.HopByHopID), // uint32 |
| 142 | diameterEncoder.Uint32(fieldEndToEndID, d.EndToEndID), // uint32 |
| 143 | // TODO: flatten |
| 144 | //join(avps...), // []*AVP |
| 145 | diameterEncoder.String(fieldSrcIP, d.SrcIP), |
| 146 | diameterEncoder.String(fieldDstIP, d.DstIP), |
| 147 | diameterEncoder.Int32(fieldSrcPort, d.SrcPort), |
| 148 | diameterEncoder.Int32(fieldDstPort, d.DstPort), |
| 149 | }) |
| 150 | } |
| 151 | |
| 152 | // Analyze will invoke the configured analyzer for the audit record and return a score. |
| 153 | func (d *Diameter) Analyze() { |