db.go

func (db *DB) loadEvent(ctx context.Context, id int) (event, error) {
	timeoutCtx, cancel := context.WithTimeout(ctx, 2*time.Second)
	defer cancel()

	logger := timeoutCtx.Value("logger").(ILogger)

	outChan := make(chan event)
	errChan := make(chan error)

	go func() {
		ev := event{}

		err := db.conn.QueryRow(db.queries["event_by_id"], id).Scan(&ev.ownerID)
		switch {
		case err == sql.ErrNoRows:
			errChan <- fmt.Errorf("No event found with id %d", id)
		case err != nil:
			errChan <- err
		default:
			logger.Debug("Event for id %d: %v", id, ev)
			outChan <- ev
		}
	}()

	select {
	case ev := <-outChan:
		return ev, nil
	case err := <-errChan:
		return event{}, err
	case <-timeoutCtx.Done():
		return event{}, fmt.Errorf("context timeout: %v", timeoutCtx.Err())
	}
}