(appGUID string)
| 38 | } |
| 39 | |
| 40 | func (r *logCacheRepository) RecentLogsFor(appGUID string) ([]Loggable, error) { |
| 41 | logs, err := r.recentLogsFunc(appGUID, r.client) |
| 42 | if err != nil { |
| 43 | return nil, err |
| 44 | } |
| 45 | |
| 46 | loggables := make([]Loggable, len(logs)) |
| 47 | for i, v := range logs { |
| 48 | loggables[i] = NewLogCacheMessage(&terminalColorLogger{}, v) |
| 49 | } |
| 50 | |
| 51 | return loggables, nil |
| 52 | } |
| 53 | |
| 54 | func (r *logCacheRepository) TailLogsFor(appGUID string, onConnect func(), logChan chan<- Loggable, errChan chan<- error) { |
| 55 | messages, logErrs, stopStreaming := r.getStreamingLogsFunc(appGUID, r.client) |
nothing calls this directly
no test coverage detected