Move "common/config" common types into cfgtypes.

logdog/common/storage/memory/memory.go

 // Copyright 2015 The LUCI Authors. All rights reserved.
 // Use of this source code is governed under the Apache License, Version 2.0
 // that can be found in the LICENSE file.
 
 package memory
 
 import (
         "errors"
         "sync"
         "time"
 
-        "github.com/luci/luci-go/common/config"
         "github.com/luci/luci-go/logdog/common/storage"
         "github.com/luci/luci-go/logdog/common/types"
+        "github.com/luci/luci-go/luci_config/common/cfgtypes"
 )
 
 type logStream struct {
         logs        map[types.MessageIndex][]byte
         latestIndex types.MessageIndex
 }
 
 type rec struct {
         index types.MessageIndex
         data  []byte
 }
 
 type streamKey struct {
-        project config.ProjectName
+        project cfgtypes.ProjectName
         path    types.StreamPath
 }
 
 // Storage is an implementation of the storage.Storage interface that stores
 // data in memory.
 //
 // This is intended for testing, and not intended to be performant.
 type Storage struct {
         // MaxGetCount, if not zero, is the maximum number of records to retrieve from
         // a single Get request.
@@ skipping 104 matching lines @@
                 }
                 if !cb(storage.MakeEntry(dataCopy, r.index)) {
                         break
                 }
         }
 
         return nil
 }
 
 // Tail implements storage.Storage.
-func (s *Storage) Tail(project config.ProjectName, path types.StreamPath) (*storage.Entry, error) {
+func (s *Storage) Tail(project cfgtypes.ProjectName, path types.StreamPath) (*storage.Entry, error) {
         var r *rec
 
         // Find the latest log, then return it.
         err := s.run(func() error {
                 ls := s.getLogStreamLocked(project, path, false)
                 if ls == nil {
                         return storage.ErrDoesNotExist
                 }
 
                 r = &rec{
                         index: ls.latestIndex,
                         data:  ls.logs[ls.latestIndex],
                 }
                 return nil
         })
         if err != nil {
                 return nil, err
         }
         return storage.MakeEntry(r.data, r.index), nil
 }
 
 // Count returns the number of log records for the given stream.
-func (s *Storage) Count(project config.ProjectName, path types.StreamPath) (c int) {
+func (s *Storage) Count(project cfgtypes.ProjectName, path types.StreamPath) (c int) {
         s.run(func() error {
                 if st := s.getLogStreamLocked(project, path, false); st != nil {
                         c = len(st.logs)
                 }
                 return nil
         })
         return
 }
 
 // SetErr sets the storage's error value. If not nil, all operations will fail
@@ skipping 10 matching lines @@
 
         if s.err != nil {
                 return s.err
         }
         if s.closed {
                 return errors.New("storage is closed")
         }
         return f()
 }
 
-func (s *Storage) getLogStreamLocked(project config.ProjectName, path types.StreamPath, create bool) *logStream {
+func (s *Storage) getLogStreamLocked(project cfgtypes.ProjectName, path types.StreamPath, create bool) *logStream {
         key := streamKey{
                 project: project,
                 path:    path,
         }
 
         ls := s.streams[key]
         if ls == nil && create {
                 ls = &logStream{
                         logs:        map[types.MessageIndex][]byte{},
                         latestIndex: -1,
                 }
 
                 if s.streams == nil {
                         s.streams = map[streamKey]*logStream{}
                 }
                 s.streams[key] = ls
         }
 
         return ls
 }