Function
newSourceLoader
(ctx context.Context, inner config.Source, refreshInterval time.Duration)
Source from the content-addressed store, hash-verified
| 24 | } |
| 25 | |
| 26 | func newSourceLoader(ctx context.Context, inner config.Source, refreshInterval time.Duration) *sourceLoader { |
| 27 | sl := &sourceLoader{ |
| 28 | inner: inner, |
| 29 | refreshInterval: refreshInterval, |
| 30 | } |
| 31 | |
| 32 | sl.load(ctx) |
| 33 | |
| 34 | if refreshInterval > 0 { |
| 35 | go sl.refreshLoop(ctx) |
| 36 | } |
| 37 | |
| 38 | return sl |
| 39 | } |
| 40 | |
| 41 | func (sl *sourceLoader) Name() string { |
| 42 | return sl.inner.Name() |