code: func (s *Storage) Put(c context.Context, req storage.PutRequest) error {
  	return s.run(func() error {
  		ls := s.getLogStreamLocked(req.Project, req.Path, true)
  
  		for i, v := range req.Values {
  			index := req.Index + types.MessageIndex(i)
  			if _, ok := ls.logs[index]; ok {
  				return storage.ErrExists
  			}
  
  			clone := make([]byte, len(v))
  			copy(clone, v)
  			ls.logs[index] = clone
  			if index > ls.latestIndex {
  				ls.latestIndex = index
  			}
  		}
  		return nil
  	})
  }
docs: // Put implements storage.Storage.