org.sonatype.nexus.proxy.repository.Repository.getLocalStatus()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(6.7k)|赞(0)|评价(0)|浏览(115)

本文整理了Java中org.sonatype.nexus.proxy.repository.Repository.getLocalStatus方法的一些代码示例,展示了Repository.getLocalStatus的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Repository.getLocalStatus方法的具体详情如下:
包路径:org.sonatype.nexus.proxy.repository.Repository
类名称:Repository
方法名:getLocalStatus

Repository.getLocalStatus介绍

[英]Gets local status.
[中]获取本地状态。

代码示例

代码示例来源:origin: org.sonatype.nexus.plugins/nexus-indexer-lucene-plugin

/**
 * The repository is in service for indexing purposes
 */
private boolean INSERVICE(Repository repository) {
 return LocalStatus.IN_SERVICE.equals(repository.getLocalStatus());
}

代码示例来源:origin: org.sonatype.nexus/nexus-app

@Deprecated
public Collection<String> evictAllUnusedProxiedItems( ResourceStoreRequest req, long timestamp )
  throws IOException
{
  ArrayList<String> result = new ArrayList<String>();
  for ( Repository repository : repositoryRegistry.getRepositories() )
  {
    if ( LocalStatus.IN_SERVICE.equals( repository.getLocalStatus() ) )
    {
      result.addAll( repository.evictUnusedItems( req, timestamp ) );
    }
  }
  return result;
}

代码示例来源:origin: org.sonatype.nexus/nexus-app

@Deprecated
public void expireAllCaches( ResourceStoreRequest request )
{
  for ( Repository repository : repositoryRegistry.getRepositories() )
  {
    if ( repository.getLocalStatus().shouldServiceRequest() )
    {
      repository.expireCaches( request );
    }
  }
}

代码示例来源:origin: org.sonatype.nexus/nexus-proxy

/**
 * The shadow is delegating it's availability to it's master, but we can still shot down the shadow only.
 */
@Override
public LocalStatus getLocalStatus()
{
  return super.getLocalStatus().shouldServiceRequest()
    && getMasterRepository().getLocalStatus().shouldServiceRequest() ? LocalStatus.IN_SERVICE
    : LocalStatus.OUT_OF_SERVICE;
}

代码示例来源:origin: org.sonatype.nexus/nexus-indexer-lucene-app

public void reindexAllRepositories( String path, boolean fullReindex )
  throws IOException
{
  List<Repository> reposes = repositoryRegistry.getRepositories();
  for ( Repository repository : reposes )
  {
    if ( LocalStatus.IN_SERVICE.equals( repository.getLocalStatus() ) )
    {
      reindexRepository( repository, fullReindex );
    }
  }
  publishAllIndex();
}

代码示例来源:origin: org.sonatype.nexus.plugins/nexus-timeline-plugin

@Subscribe
@AllowConcurrentEvents
public void inspect(final RepositoryEventLocalStatusChanged revt) {
 StringBuilder sb = new StringBuilder("The repository '");
 sb.append(revt.getRepository().getName());
 sb.append("' (ID='").append(revt.getRepository().getId()).append("') was put ");
 LocalStatus newStatus = revt.getNewLocalStatus();
 if (LocalStatus.IN_SERVICE.equals(newStatus)) {
  sb.append("IN SERVICE.");
 }
 else if (LocalStatus.OUT_OF_SERVICE.equals(newStatus)) {
  sb.append("OUT OF SERVICE.");
 }
 else {
  sb.append(revt.getRepository().getLocalStatus().toString()).append(".");
 }
 sb.append(" The previous state was ");
 if (LocalStatus.IN_SERVICE.equals(revt.getOldLocalStatus())) {
  sb.append("IN SERVICE.");
 }
 else if (LocalStatus.OUT_OF_SERVICE.equals(revt.getOldLocalStatus())) {
  sb.append("OUT OF SERVICE.");
 }
 else {
  sb.append(revt.getOldLocalStatus().toString()).append(".");
 }
 getFeedRecorder().addSystemEvent(FeedRecorder.SYSTEM_REPO_LSTATUS_CHANGES_ACTION, sb.toString());
}

代码示例来源:origin: org.sonatype.nexus.plugins/nexus-archetype-plugin

/**
 * Archetype Catalog subjects are Maven2 hosted, proxy and group repositories that are In Service.
 */
private boolean isArchetypeCatalogSubject(final Repository repository) {
 return maven2ContentClass.isCompatible(repository.getRepositoryContentClass())
   && repository.getLocalStatus().shouldServiceRequest()
   && (repository.getRepositoryKind().isFacetAvailable(HostedRepository.class)
   || repository.getRepositoryKind().isFacetAvailable(ProxyRepository.class) ||
   repository.getRepositoryKind().isFacetAvailable(GroupRepository.class));
}

代码示例来源:origin: org.sonatype.nexus/nexus-proxy

if ( LocalStatus.IN_SERVICE.equals( repo.getLocalStatus() ) )

代码示例来源:origin: org.sonatype.nexus/nexus-indexer-lucene-app

public void publishAllIndex()
  throws IOException
{
  List<Repository> reposes = repositoryRegistry.getRepositories();
  for ( Repository repository : reposes )
  {
    if ( LocalStatus.IN_SERVICE.equals( repository.getLocalStatus() )
      && !repository.getRepositoryKind().isFacetAvailable( GroupRepository.class )
      && repository.isIndexable() )
    {
      publishRepositoryIndex( repository );
    }
  }
  List<GroupRepository> groups = repositoryRegistry.getRepositoriesWithFacet( GroupRepository.class );
  for ( GroupRepository group : groups )
  {
    publishRepositoryIndex( group );
  }
}

代码示例来源:origin: org.sonatype.nexus/nexus-proxy

if ( LocalStatus.OUT_OF_SERVICE == context.getRepository().getLocalStatus() )

代码示例来源:origin: org.sonatype.nexus/nexus-app

private boolean process( SnapshotRemovalRequest request, SnapshotRemovalResult result, Repository repository )
{
  // only from maven repositories, stay silent for others and simply skip
  if ( !repository.getRepositoryContentClass().isCompatible( maven2ContentClass ) )
  {
    getLogger().debug( "Skipping '" + repository.getId() + "' is not a maven 2 repository" );
    return false;
  }
  if ( !repository.getLocalStatus().shouldServiceRequest() )
  {
    getLogger().debug( "Skipping '" + repository.getId() + "' the repository is out of service" );
    return false;
  }
  if ( repository.getRepositoryKind().isFacetAvailable( ProxyRepository.class ) )
  {
    getLogger().debug( "Skipping '" + repository.getId() + "' is a proxy repository" );
    return false;
  }
  if ( repository.getRepositoryKind().isFacetAvailable( GroupRepository.class ) )
  {
    process( request, result, repository.adaptToFacet( GroupRepository.class ) );
  }
  else if ( repository.getRepositoryKind().isFacetAvailable( MavenRepository.class ) )
  {
    result.addResult( removeSnapshotsFromMavenRepository( repository.adaptToFacet( MavenRepository.class ),
      request ) );
  }
  return true;
}

代码示例来源:origin: org.sonatype.nexus/nexus-app

@Override
public Object doRun()
  throws Exception
{
  ResourceStoreRequest req = new ResourceStoreRequest( getResourceStorePath() );
  if ( getRepositoryId() != null )
  {
    getRepositoryRegistry().getRepository( getRepositoryId() ).expireCaches( req );
  }
  else
  {
    for ( Repository repository : getRepositoryRegistry().getRepositories() )
    {
      if ( repository.getLocalStatus().shouldServiceRequest() )
      {
        repository.expireCaches( req );
      }
    }
  }
  return null;
}

代码示例来源:origin: org.sonatype.nexus.plugins/nexus-restlet1x-plugin

resource.setLocalStatus(repo.getLocalStatus().toString());

代码示例来源:origin: org.sonatype.nexus/nexus-rest-api

resource.setLocalStatus( repo.getLocalStatus().toString() );

代码示例来源:origin: org.sonatype.nexus/nexus-app

|| repository.getRepositoryContentClass().isCompatible( maven1ContentClass ) )
if ( LocalStatus.OUT_OF_SERVICE.equals( repository.getLocalStatus() ) )

代码示例来源:origin: org.sonatype.nexus/nexus-rest-api

repoRes.getStatus().setLocalStatus( repository.getLocalStatus().toString() );

代码示例来源:origin: org.sonatype.nexus.plugins/nexus-restlet1x-plugin

repoRes.getStatus().setLocalStatus(repository.getLocalStatus().toString());

相关文章

微信公众号

最新文章

更多