()
| 19 | } |
| 20 | |
| 21 | func NewUsageInserter() *UsageInserter { |
| 22 | return &UsageInserter{ |
| 23 | discreteEvents: []usagetypes.DiscreteEvent{}, |
| 24 | seenHeartbeats: map[string]struct{}{}, |
| 25 | heartbeatEvents: []usagetypes.HeartbeatEvent{}, |
| 26 | } |
| 27 | } |
| 28 | |
| 29 | func (u *UsageInserter) InsertDiscreteUsageEvent(_ context.Context, _ database.Store, event usagetypes.DiscreteEvent) error { |
| 30 | u.Lock() |
no outgoing calls