| OLD | NEW |
| 1 // Copyright 2016 The LUCI Authors. All rights reserved. | 1 // Copyright 2016 The LUCI Authors. All rights reserved. |
| 2 // Use of this source code is governed under the Apache License, Version 2.0 | 2 // Use of this source code is governed under the Apache License, Version 2.0 |
| 3 // that can be found in the LICENSE file. | 3 // that can be found in the LICENSE file. |
| 4 | 4 |
| 5 package main | 5 package cli |
| 6 | 6 |
| 7 import ( | 7 import ( |
| 8 "errors" | 8 "errors" |
| 9 "sync" | 9 "sync" |
| 10 "time" | 10 "time" |
| 11 | 11 |
| 12 "github.com/luci/luci-go/common/clock" | 12 "github.com/luci/luci-go/common/clock" |
| 13 log "github.com/luci/luci-go/common/logging" | 13 log "github.com/luci/luci-go/common/logging" |
| 14 "github.com/luci/luci-go/logdog/api/logpb" | 14 "github.com/luci/luci-go/logdog/api/logpb" |
| 15 "github.com/luci/luci-go/logdog/client/coordinator" | 15 "github.com/luci/luci-go/logdog/client/coordinator" |
| (...skipping 66 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 82 } | 82 } |
| 83 } | 83 } |
| 84 } | 84 } |
| 85 | 85 |
| 86 func (s *coordinatorSource) descriptor() (*logpb.LogStreamDescriptor, error) { | 86 func (s *coordinatorSource) descriptor() (*logpb.LogStreamDescriptor, error) { |
| 87 if s.streamState != nil { | 87 if s.streamState != nil { |
| 88 return &s.streamState.Desc, nil | 88 return &s.streamState.Desc, nil |
| 89 } | 89 } |
| 90 return nil, errors.New("no stream state loaded") | 90 return nil, errors.New("no stream state loaded") |
| 91 } | 91 } |
| OLD | NEW |