submitqueue: Result: record startTime during a new MakeResult constructor, return EndTime properly
even without any LogEntries
This commit is contained in:
		
							parent
							
								
									089e551b72
								
							
						
					
					
						commit
						87d09f6163
					
				
					 1 changed files with 12 additions and 2 deletions
				
			
		|  | @ -163,13 +163,23 @@ type Result struct { | ||||||
| 	LogEntries []*logrus.Entry | 	LogEntries []*logrus.Entry | ||||||
| 	Series     []Serie | 	Series     []Serie | ||||||
| 	Error      error | 	Error      error | ||||||
|  | 	startTime  time.Time | ||||||
|  | } | ||||||
|  | 
 | ||||||
|  | func MakeResult() *Result { | ||||||
|  | 	return &Result{ | ||||||
|  | 		startTime: time.Now(), | ||||||
|  | 	} | ||||||
| } | } | ||||||
| 
 | 
 | ||||||
| func (r Result) StartTime() time.Time { | func (r Result) StartTime() time.Time { | ||||||
| 	return r.LogEntries[0].Time | 	return r.startTime | ||||||
| } | } | ||||||
| 
 | 
 | ||||||
| func (r Result) EndTime() time.Time { | func (r Result) EndTime() time.Time { | ||||||
|  | 	if len(r.LogEntries) == 0 { | ||||||
|  | 		return r.startTime | ||||||
|  | 	} | ||||||
| 	return r.LogEntries[len(r.LogEntries)-1].Time | 	return r.LogEntries[len(r.LogEntries)-1].Time | ||||||
| } | } | ||||||
| 
 | 
 | ||||||
|  | @ -184,7 +194,7 @@ func (r *Result) Levels() []logrus.Level { | ||||||
| 
 | 
 | ||||||
| // Run starts the submit and rebase logic. | // Run starts the submit and rebase logic. | ||||||
| func (s *SubmitQueue) Run(fetchOnly bool) *Result { | func (s *SubmitQueue) Run(fetchOnly bool) *Result { | ||||||
| 	r := &Result{} | 	r := MakeResult() | ||||||
| 	//TODO: log decisions made and add to some ring buffer | 	//TODO: log decisions made and add to some ring buffer | ||||||
| 	var err error | 	var err error | ||||||
| 
 | 
 | ||||||
|  |  | ||||||
		Loading…
	
	Add table
		Add a link
		
	
		Reference in a new issue