LocalPeerImpl extends HostListener implements LocalPeer, Disposable { ResourceHostDataService createResourceHostDataService() { return new ResourceHostDataService( daoManager.getEntityManagerFactory() ); } LocalPeerImpl( DaoManager daoManager, TemplateManager templateManager, CommandExecutor commandExecutor,
                          HostRegistry hostRegistry, Monitor monitor, SecurityManager securityManager,
                          HealthService healthService ); void setIdentityManager( final IdentityManager identityManager ); void setRelationManager( final RelationManager relationManager ); void init(); @Override boolean isInitialized(); @Override boolean isMHPresent(); @Override PeerInfo getPeerInfo(); @Override void setPeerInfo( final PeerInfo peerInfo ); @Override void dispose(); @Override String getId(); @Override String getName(); @Override String getOwnerId(); @Override ContainerHostState getContainerState( final ContainerId containerId ); @Override Containers getEnvironmentContainers( final EnvironmentId environmentId ); @Override void configureHostsInEnvironment( final EnvironmentId environmentId, final HostAddresses hostAddresses ); @Override SshKeys readOrCreateSshKeysForEnvironment( final EnvironmentId environmentId,
                                                      final SshEncryptionType sshKeyType ); @Override Containers configureSshInEnvironment( final EnvironmentId environmentId, final SshKeys sshKeys ); @Override SshKeys getSshKeys( final EnvironmentId environmentId, final SshEncryptionType sshEncryptionType ); @Override SshKeys getContainerAuthorizedKeys( final ContainerId containerId ); @Override SshKey createSshKey( final EnvironmentId environmentId, final ContainerId containerId,
                                final SshEncryptionType sshEncryptionType ); @Override void addToAuthorizedKeys( final EnvironmentId environmentId, final String sshPublicKey ); @Override void removeFromAuthorizedKeys( final EnvironmentId environmentId, final String sshPublicKey ); @Override void addAuthorizedSshKeyToUser( final String containerId, final String username, final String sshPublicKey ); @Override void removeAuthorizedSshKeyFromUser( final String containerId, final String username,
                                                final String sshPublicKey ); @Override void createUserIfNotExists( final String containerId, final String username ); @Override void removeUserIfExists( final String containerId, final String username ); @RolesAllowed( "Environment-Management|Write" ) @Override PrepareTemplatesResponse prepareTemplates( final PrepareTemplatesRequest request ); @Override boolean isReady(); @Override synchronized FitCheckResult checkResources( final Nodes nodes ); @RolesAllowed( "Environment-Management|Read" ) @Override boolean canAccommodate( final Nodes nodes ); @RolesAllowed( "Environment-Management|Write" ) @Override CreateEnvironmentContainersResponse createEnvironmentContainers(
            final CreateEnvironmentContainersRequest requestGroup ); @RolesAllowed( "Environment-Management|Write" ) @Override void registerContainer( String resourceHostId, String environmentId, String containerId,
                                   String containerHostname, HostArchitecture arch, String templateId, String ownerId,
                                   ContainerQuota quota ); @PermitAll @Override Set<ContainerHost> findContainersByEnvironmentId( final String environmentId ); @PermitAll @Override ContainerHost getContainerHostByHostName( String hostname ); @PermitAll @Override ContainerHost getContainerHostByContainerName( String containerName ); @PermitAll @Override ContainerHost getContainerHostById( final String hostId ); @PermitAll @Override ContainerHost getContainerHostByIp( final String hostIp ); @PermitAll @Override ResourceHost getResourceHostByHostName( String hostname ); @PermitAll @Override ResourceHost getResourceHostById( final String hostId ); @PermitAll @Override ResourceHost getResourceHostByContainerHostName( final String hostname ); @Override ResourceHost getResourceHostByContainerName( final String containerName ); @PermitAll @Override ResourceHost getResourceHostByContainerId( final String hostId ); @Override Host findHost( String id ); @Override Host findHostByName( final String hostname ); @RolesAllowed( "Environment-Management|Update" ) @Override void startContainer( final ContainerId containerId ); @RolesAllowed( "Environment-Management|Update" ) @Override void stopContainer( final ContainerId containerId ); @RolesAllowed( "Environment-Management|Read" ) @Override Snapshots listContainerHostSnapshots( final ContainerId containerId ); @RolesAllowed( "Environment-Management|Update" ) @Override void removeContainerSnapshot( final ContainerId containerId, final String partition, final String label ); @RolesAllowed( "Environment-Management|Update" ) @Override void rollbackToContainerSnapshot( final ContainerId containerId, final String partition, final String label,
                                             final boolean force ); @RolesAllowed( "Environment-Management|Update" ) @Override void addContainerSnapshot( final ContainerId containerId, final String partition, final String label,
                                      final boolean stopContainer ); @RolesAllowed( "Environment-Management|Delete" ) @Override void destroyContainer( final ContainerId containerId ); @Override boolean isConnected( final HostId hostId ); @Override ResourceHost getManagementHost(); @Override Set<ResourceHost> getResourceHosts(); @Override void removeResourceHost( String rhId ); @Override CommandResult execute( final RequestBuilder requestBuilder, final Host host ); @Override CommandResult execute( final RequestBuilder requestBuilder, final Host aHost,
                                  final CommandCallback callback ); @Override void executeAsync( final RequestBuilder requestBuilder, final Host aHost, final CommandCallback callback ); @Override void executeAsync( final RequestBuilder requestBuilder, final Host host ); @Override boolean isLocal(); @PermitAll @Override boolean isOnline(); @Override V sendRequest( final T request, final String recipient, final int requestTimeout,
                                 final Class<V> responseType, final int responseTimeout, Map<String, String> headers ); @Override void sendRequest( final T request, final String recipient, final int requestTimeout,
                                 Map<String, String> headers ); void registerResourceHost( ResourceHostInfo resourceHostInfo ); @Override void onHeartbeat( final ResourceHostInfo resourceHostInfo, Set<QuotaAlertValue> alerts ); @Override void registerManagementContainer( ResourceHost resourceHost ); @RolesAllowed( "Environment-Management|Update" ) @Override SshTunnel setupSshTunnelForContainer( final String containerIp, final int sshIdleTimeout ); @Override List<ContainerHost> getPeerContainers( final String peerId ); @Override void addRequestListener( final RequestListener listener ); void removeRequestListener( final RequestListener listener ); @Override Set<RequestListener> getRequestListeners(); @RolesAllowed( "Environment-Management|Write" ) @Override PublicKeyContainer createPeerEnvironmentKeyPair( RelationLinkDto envLink ); @Override void addPeerEnvironmentPubKey( final String keyId, final PGPPublicKeyRing pubRing ); @Override void updatePeerEnvironmentPubKey( final EnvironmentId environmentId, final PGPPublicKeyRing pubKeyRing ); @Override synchronized Integer reserveNetworkResource( final NetworkResourceImpl networkResource ); @Override ReservedNetworkResources getReservedNetworkResources(); @Override UsedNetworkResources getUsedNetworkResources(); @RolesAllowed( "Environment-Management|Write" ) @Override void setupTunnels( final P2pIps p2pIps, final EnvironmentId environmentId ); @Override void deleteTunnels( P2pIps p2pIps, EnvironmentId environmentId ); @Override void resetSwarmSecretKey( final P2PCredentials p2PCredentials ); @RolesAllowed( "Environment-Management|Update" ) @Override void joinP2PSwarm( final P2PConfig config ); @Override void joinOrUpdateP2PSwarm( final P2PConfig config ); @RolesAllowed( "Environment-Management|Delete" ) @Override void cleanupEnvironment( final EnvironmentId environmentId ); @Override ResourceHostMetrics getResourceHostMetrics(); @Override PeerResources getResourceLimits( PeerId peerId ); @Override PeerResources getResources(); @Override Template getTemplateByName( final String templateName ); @Override Template getTemplateById( final String templateId ); @Override Quota getQuota( final ContainerId containerId, ContainerResourceType containerResourceType ); @Override io.subutai.common.host.Quota getRawQuota( final ContainerId containerId ); @Override ContainerQuota getQuota( final ContainerId containerId ); @Override void setQuota( final ContainerId containerId, final ContainerQuota containerQuota ); @Override void alert( AlertEvent alert ); @Override String getHistoricalMetrics( final HostId hostId, final Date startTime, final Date endTime ); @Override HistoricalMetrics getMetricsSeries( final HostId hostId, final Date startTime, final Date endTime ); @Override void setContainerHostname( final ContainerId containerId, final String hostname ); @Override void setRhHostname( final String rhId, final String hostname ); @Override void updateEtcHostsWithNewContainerHostname( final EnvironmentId environmentId, final String oldHostname,
                                                        final String newHostname ); @Override void removeHostnamesFromEtcHosts( final EnvironmentId environmentId, final HostAddresses hostAddresses ); @Override void updateAuthorizedKeysWithNewContainerHostname( final EnvironmentId environmentId,
                                                              final String oldHostname, final String newHostname,
                                                              final SshEncryptionType sshEncryptionType ); @Override Set<HostUtil.Task> getTasks(); @Override void cancelAllTasks(); @Override HostId getResourceHostIdByContainerId( final ContainerId id ); @Override RegistrationStatus getStatus(); @Override Set<ContainerHostInfo> getNotRegisteredContainers(); @Override boolean destroyNotRegisteredContainer( final String containerId ); @Override Set<ContainerHost> getRegisteredContainers(); @Override Set<ContainerHost> getOrphanContainers(); @Override void removeOrphanContainers(); @Override PeerTemplatesDownloadProgress getTemplateDownloadProgress( final EnvironmentId environmentId ); @Override PeerTemplatesUploadProgress getTemplateUploadProgress( final String templateName ); @Override void exportTemplate( final ContainerId containerId, final String templateName, final String version,
                                final boolean isPrivateTemplate, final String token ); @Override boolean equals( final Object o ); @Override int hashCode(); @Override String getLinkId(); @Override String getUniqueIdentifier(); @Override String getClassPath(); @Override String getContext(); @Override String getKeyId(); void addListener( LocalPeerEventListener listener ); void removeListener( LocalPeerEventListener listener ); @Override void addSnapshotEventListener( final SnapshotEventListener listener );  }
@Test public void testGetResourceHostDataService() throws Exception { assertNotNull( localPeer.createResourceHostDataService() ); }