Method Clear

db/event_manager_test.go:355–361

()

}

func (wr *WebhookRequest) Clear() {
	wr.mutex.Lock()
	wr.count = 0
	wr.sum = 0.0
	wr.payloads = nil
	wr.mutex.Unlock()
}

func (em *EventManager) waitForProcessedTotal(ctx context.Context, waitCount int, maxWaitTime time.Duration) error {
	startTime := time.Now()