code: func ConsolidateContext(ctx context.Context, in []schema.Point, aggNum uint32, consolidator Consolidator) []schema.Point {
  	select {
  	case <-ctx.Done():
  		//request canceled
  		return nil
  	default:
  	}
  	return Consolidate(in, aggNum, consolidator)
  }
docs: // ConsolidateContext wraps a Consolidate() call with a context.Context condition