Package org.apache.maven.archiva.model

Examples of org.apache.maven.archiva.model.RepositoryContentStatistics

176
177
178
179
180
181
182
183
184
185
186
187
        List invalidConsumers = new ArrayList();
        InvalidScanConsumer badconsumer = new InvalidScanConsumer();
        invalidConsumers.add( badconsumer );

        RepositoryScanner scanner = lookupRepositoryScanner();
        RepositoryContentStatistics stats = scanner.scan( repository, knownConsumers, invalidConsumers,
                                                          getIgnoreList(), RepositoryScanner.FRESH_SCAN );

        assertNotNull( "Stats should not be null.", stats );
        assertMinimumHits( "Stats.totalFileCount", actualArtifactPaths.size(), stats.getTotalFileCount() );
        assertMinimumHits( "Processed Count", actualArtifactPaths.size(), consumer.getProcessCount() );
    }
View Full Code Here
212
213
214
215
216
217
218
219
220
221
222
223
        List invalidConsumers = new ArrayList();
        InvalidScanConsumer badconsumer = new InvalidScanConsumer();
        invalidConsumers.add( badconsumer );

        RepositoryScanner scanner = lookupRepositoryScanner();
        RepositoryContentStatistics stats = scanner.scan( repository, knownConsumers, invalidConsumers,
                                                          getIgnoreList(), RepositoryScanner.FRESH_SCAN );

        assertNotNull( "Stats should not be null.", stats );
        assertMinimumHits( "Stats.totalFileCount", actualMetadataPaths.size(), stats.getTotalFileCount() );
        assertMinimumHits( "Processed Count", actualMetadataPaths.size(), knownConsumer.getProcessCount() );
    }
View Full Code Here
248
249
250
251
252
253
254
255
256
257
258
259
        List invalidConsumers = new ArrayList();
        InvalidScanConsumer badconsumer = new InvalidScanConsumer();
        invalidConsumers.add( badconsumer );

        RepositoryScanner scanner = lookupRepositoryScanner();
        RepositoryContentStatistics stats = scanner.scan( repository, knownConsumers, invalidConsumers,
                                                          getIgnoreList(), RepositoryScanner.FRESH_SCAN );

        assertNotNull( "Stats should not be null.", stats );
        assertMinimumHits( "Stats.totalFileCount", actualProjectPaths.size(), stats.getTotalFileCount() );
        assertMinimumHits( "Processed Count", actualProjectPaths.size(), consumer.getProcessCount() );
    }
View Full Code Here
288
289
290
291
292
293
294
295
296
297
298
299
        List invalidConsumers = new ArrayList();
        InvalidScanConsumer badconsumer = new InvalidScanConsumer();
        invalidConsumers.add( badconsumer );

        RepositoryScanner scanner = lookupRepositoryScanner();
        RepositoryContentStatistics stats = scanner.scan( repository, knownConsumers, invalidConsumers,
                                                          getIgnoreList(), RepositoryScanner.FRESH_SCAN );

        assertNotNull( "Stats should not be null.", stats );
        assertMinimumHits( "Stats.totalFileCount", actualArtifactPaths.size(), stats.getTotalFileCount() );
        assertMinimumHits( "Processed Count", actualArtifactPaths.size(), consumer.getProcessCount() );
    }
View Full Code Here
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
            List results = dao.query( new MostRecentRepositoryScanStatistics( arepo.getId() ) );

            if ( CollectionUtils.isNotEmpty( results ) )
            {
                RepositoryContentStatistics lastStats = (RepositoryContentStatistics) results.get( 0 );
                sinceWhen = lastStats.getWhenGathered().getTime() + lastStats.getDuration();
            }

            RepositoryContentStatistics stats = repoScanner.scan( arepo, sinceWhen );

            getLogger().info( "Finished repository task: " + stats.toDump( arepo ) );
           
            stats = (RepositoryContentStatistics) dao.save( stats );
        }
        catch ( ArchivaDatabaseException e )
        {
View Full Code Here
48
49
50
51
52
53
54
55
56
57
58
        Assert.assertEquals( RepositoryContentStatistics.class, constraint.getResultClass() );

        List<RepositoryContentStatistics> stats = new ArrayList<RepositoryContentStatistics>();
        for ( String repo : configuration.getConfiguration().getManagedRepositoriesAsMap().keySet() )
        {
            RepositoryContentStatistics statistics = new RepositoryContentStatistics();
            statistics.setRepositoryId( repo );
            stats.add( statistics );
        }
        return stats;
    }
View Full Code Here
75
76
77
78
79
80
81
82
83
84
85
        this.logger = logger;

        this.consumerProcessFile = new ConsumerProcessFileClosure( logger );
        this.consumerWantsFile = new ConsumerWantsFilePredicate();

        stats = new RepositoryContentStatistics();
        stats.setRepositoryId( repository.getId() );

        Closure triggerBeginScan = new TriggerBeginScanClosure( repository, logger );

        CollectionUtils.forAllDo( knownConsumerList, triggerBeginScan );
View Full Code Here
180
181
182
183
184
185
186
187
188
189
190
191
192
193
        RepositoryScanner scanner = (RepositoryScanner) plexus.lookup( RepositoryScanner.class );

        try
        {
            RepositoryContentStatistics stats = scanner.scan( repo, knownConsumerList, invalidConsumerList,
                                                              ignoredContent, RepositoryScanner.FRESH_SCAN );

            System.out.println( "\n" + stats.toDump( repo ) );
        }
        catch ( RepositoryException e )
        {
            e.printStackTrace( System.err );
        }
View Full Code Here
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
            List results = dao.query( new MostRecentRepositoryScanStatistics( arepo.getId() ) );

            if ( CollectionUtils.isNotEmpty( results ) )
            {
                RepositoryContentStatistics lastStats = (RepositoryContentStatistics) results.get( 0 );
                sinceWhen = lastStats.getWhenGathered().getTime() + lastStats.getDuration();
            }

            RepositoryContentStatistics stats = repoScanner.scan( arepo, sinceWhen );

            getLogger().info( "Finished repository task: " + stats.toDump( arepo ) );
           
            stats = (RepositoryContentStatistics) dao.save( stats );
        }
        catch ( ArchivaDatabaseException e )
        {
View Full Code Here
118
119
120
121
122
123
124
125
126
127
128
129
130
        List invalidConsumers = new ArrayList();
        InvalidScanConsumer badconsumer = new InvalidScanConsumer();
        invalidConsumers.add( badconsumer );

        RepositoryScanner scanner = lookupRepositoryScanner();
        RepositoryContentStatistics stats = scanner.scan( repository, knownConsumers, invalidConsumers,
                                                          getIgnoreList(), RepositoryScanner.FRESH_SCAN );

        assertNotNull( "Stats should not be null.", stats );
        assertMinimumHits( "Stats.totalFileCount", 17, stats.getTotalFileCount() );
        assertMinimumHits( "Processed Count", 17, consumer.getProcessCount() );
        assertEquals( "Processed Count (of invalid items)", 6, badconsumer.getProcessCount() );
    }
View Full Code Here
TOP

Related Classes of org.apache.maven.archiva.model.RepositoryContentStatistics

  • org.apache.maven.archiva.cli.ArchivaCli
  • org.apache.maven.archiva.database.constraints.MostRecentRepositoryScanStatisticsTest
  • org.apache.maven.archiva.database.constraints.RepositoryContentStatisticsByRepositoryConstraintTest
  • org.apache.maven.archiva.database.jdo.JdoRepositoryContentStatisticsDAO
  • org.apache.maven.archiva.database.jdo.JdoRepositoryContentStatisticsDAOTest
  • org.apache.maven.archiva.reporting.SimpleRepositoryStatisticsReportGenerator
  • org.apache.maven.archiva.reporting.SimpleRepositoryStatisticsReportGeneratorTest
  • org.apache.maven.archiva.repository.scanner.DefaultRepositoryScanner
  • org.apache.maven.archiva.repository.scanner.RepositoryScannerInstance
  • org.apache.maven.archiva.repository.scanner.RepositoryScannerTest
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.