Method logSlow

worker/db.go:301–334

(request *types.Request, isFinished bool, tmStart time.Time)

}

func (db *Database) logSlow(request *types.Request, isFinished bool, tmStart time.Time) {
	if request == nil {
		return
	}

	// sample the queries
	querySample := ""

	for _, q := range request.Payload.Queries {
		if len(querySample) < SlowQuerySampleSize {
			querySample += "; "
			querySample += q.Pattern
		} else {
			break
		}
	}

	if len(querySample) >= SlowQuerySampleSize {
		querySample = querySample[:SlowQuerySampleSize-3]
		querySample += "..."
	}

	log.WithFields(log.Fields{
		"finished": isFinished,
		"db":       request.Header.DatabaseID,
		"req_time": request.Header.Timestamp.String(),
		"req_node": request.Header.NodeID,
		"count":    request.Header.BatchCount,
		"type":     request.Header.QueryType.String(),
		"sample":   querySample,
		"start":    tmStart.String(),
		"elapsed":  time.Now().Sub(tmStart).String(),
	}).Error("slow query detected")
}

// Ack defines client response ack interface.
func (db *Database) Ack(ack *types.Ack) (err error) {