Package io.lionweb.repoclient

Class LionWebRepoClient

java.lang.Object

io.lionweb.repoclient.LionWebRepoClient

All Implemented Interfaces:

BulkAPIClient, DBAdminAPIClient, HistoryAPIClient, InspectionAPIClient, RawBulkAPIClient

Direct Known Subclasses:

ExtendedLionWebRepoClient

public class LionWebRepoClient
extends Object
implements RawBulkAPIClient, BulkAPIClient, DBAdminAPIClient, InspectionAPIClient, HistoryAPIClient

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	LionWebRepoClient.Builder

Field Summary

Fields

Modifier and Type	Field	Description
protected final String	authorizationToken
protected final String	clientID
protected final String	hostname
protected final okhttp3.OkHttpClient	httpClient
protected static final okhttp3.MediaType	JSON
protected final JsonSerialization	jsonSerialization
protected final int	port
protected final Protocol	protocol
protected final String	repository

Constructor Summary

Constructors

Constructor	Description
LionWebRepoClient(@NotNull LionWebVersion lionWebVersion, @NotNull String hostname, int port, @Nullable String authorizationToken, @NotNull String clientID, @NotNull String repository, long connectTimeoutInSeconds, long callTimeoutInSeconds)
LionWebRepoClient(@NotNull LionWebVersion lionWebVersion, String hostname, int port, String repository)

Method Summary

Modifier and Type	Method	Description
protected RepoClientConfiguration	buildRepositoryConfiguration()
void	createDatabase()	Trigger the creation of the database, according to the configuration provided on the server side.
@Nullable RepositoryVersionToken	createPartition(@NotNull Node partition)
@Nullable RepositoryVersionToken	createPartitions(List<Node> partitions)
void	createRepository(@NotNull RepositoryConfiguration repositoryConfiguration)
@Nullable RepositoryVersionToken	deletePartitions(List<String> ids)
void	deleteRepository(@NotNull String repositoryName)
@NotNull JsonSerialization	getJsonSerialization()
@NotNull LionWebVersion	getLionWebVersion()
List<String>	ids(int count)
List<Node>	listPartitions()
List<Node>	listPartitions(RepositoryVersionToken repoVersion)
List<String>	listPartitionsIDs()
@NotNull Set<RepositoryConfiguration>	listRepositories()
Map<ClassifierKey,ClassifierResult>	nodesByClassifier(@Nullable Integer limit)
Map<String,ClassifierResult>	nodesByLanguage(@Nullable Integer limit)
@Nullable RepositoryVersionToken	rawCreatePartitions(@NotNull String data)
@NotNull String	rawRetrieve(@NotNull List<String> nodeIds, int limit)
@Nullable RepositoryVersionToken	rawStore(@NotNull String nodes)
@NotNull Node	retrieve(@NotNull String nodeId)
List<Node>	retrieve(RepositoryVersionToken repoVersion, List<String> nodeIds, int limit)
List<Node>	retrieve(List<String> nodeIds)
List<Node>	retrieve(List<String> nodeIds, int limit)
@Nullable RepositoryVersionToken	store(@NotNull Node node)
@Nullable RepositoryVersionToken	store(List<Node> nodes)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.lionweb.repoclient.api.HistoryAPIClient

retrieve, retrieve

Methods inherited from interface io.lionweb.repoclient.api.InspectionAPIClient

nodesByClassifier, nodesByLanguage

Methods inherited from interface io.lionweb.repoclient.api.RawBulkAPIClient

rawRetrieve

Field Details

JSON

protected static final okhttp3.MediaType JSON

protocol

protected final Protocol protocol

hostname

protected final String hostname

port

protected final int port

authorizationToken

protected final String authorizationToken

clientID

protected final String clientID

repository

protected final String repository

httpClient

protected final okhttp3.OkHttpClient httpClient

jsonSerialization

protected final JsonSerialization jsonSerialization

Constructor Details

LionWebRepoClient

public LionWebRepoClient(@NotNull
 @NotNull LionWebVersion lionWebVersion,
 String hostname,
 int port,
 String repository)

LionWebRepoClient

public LionWebRepoClient(@NotNull
 @NotNull LionWebVersion lionWebVersion,
 @NotNull
 @NotNull String hostname,
 int port,
 @Nullable
 @Nullable String authorizationToken,
 @NotNull
 @NotNull String clientID,
 @NotNull
 @NotNull String repository,
 long connectTimeoutInSeconds,
 long callTimeoutInSeconds)

Method Details

buildRepositoryConfiguration

protected RepoClientConfiguration buildRepositoryConfiguration()

getJsonSerialization

@NotNull
public @NotNull JsonSerialization getJsonSerialization()

rawCreatePartitions

@Nullable
public @Nullable RepositoryVersionToken rawCreatePartitions(@NotNull
 @NotNull String data)
                                                     throws IOException

Specified by:

rawCreatePartitions in interface RawBulkAPIClient

Throws:

IOException

rawStore

@Nullable
public @Nullable RepositoryVersionToken rawStore(@NotNull
 @NotNull String nodes)
                                          throws IOException

Specified by:

rawStore in interface RawBulkAPIClient

Throws:

IOException

rawRetrieve

@NotNull
public @NotNull String rawRetrieve(@NotNull
 @NotNull List<String> nodeIds,
 int limit)
                            throws IOException

Specified by:

rawRetrieve in interface RawBulkAPIClient

Throws:

IOException

createPartitions

@Nullable
public @Nullable RepositoryVersionToken createPartitions(List<Node> partitions)
                                                  throws IOException

Specified by:

createPartitions in interface BulkAPIClient

Throws:

IOException

createPartition

@Nullable
public @Nullable RepositoryVersionToken createPartition(@NotNull
 @NotNull Node partition)
                                                 throws IOException

Throws:

IOException

deletePartitions

@Nullable
public @Nullable RepositoryVersionToken deletePartitions(List<String> ids)
                                                  throws IOException

Specified by:

deletePartitions in interface BulkAPIClient

Throws:

IOException

listPartitions

public List<Node> listPartitions()
                          throws IOException

Specified by:

listPartitions in interface BulkAPIClient

Throws:

IOException

listPartitionsIDs

public List<String> listPartitionsIDs()
                               throws IOException

Specified by:

listPartitionsIDs in interface BulkAPIClient

Throws:

IOException

ids

public List<String> ids(int count)
                 throws IOException

Specified by:

ids in interface BulkAPIClient

Throws:

IOException

store

@Nullable
public @Nullable RepositoryVersionToken store(List<Node> nodes)
                                       throws IOException

Specified by:

store in interface BulkAPIClient

Throws:

IOException

store

@Nullable
public @Nullable RepositoryVersionToken store(@NotNull
 @NotNull Node node)
                                       throws IOException

Throws:

IOException

retrieve

public List<Node> retrieve(List<String> nodeIds)
                    throws IOException

Throws:

IOException

retrieve

@NotNull
public @NotNull Node retrieve(@NotNull
 @NotNull String nodeId)
                       throws IOException

Throws:

IOException

retrieve

public List<Node> retrieve(List<String> nodeIds,
 int limit)
                    throws IOException

Specified by:

retrieve in interface BulkAPIClient

Throws:

IOException

getLionWebVersion

@NotNull
public @NotNull LionWebVersion getLionWebVersion()

Specified by:

getLionWebVersion in interface BulkAPIClient

Specified by:

getLionWebVersion in interface RawBulkAPIClient

createRepository

public void createRepository(@NotNull
 @NotNull RepositoryConfiguration repositoryConfiguration)
                      throws IOException

Specified by:

createRepository in interface DBAdminAPIClient

Throws:

IOException

deleteRepository

public void deleteRepository(@NotNull
 @NotNull String repositoryName)
                      throws IOException

Specified by:

deleteRepository in interface DBAdminAPIClient

Throws:

IOException

createDatabase

public void createDatabase()
                    throws IOException

Description copied from interface: DBAdminAPIClient

Trigger the creation of the database, according to the configuration provided on the server side. In other words, we cannot dictate the name of the configuration of the database, just triggers its creation.

Specified by:

createDatabase in interface DBAdminAPIClient

Throws:

IOException

listRepositories

@NotNull
public @NotNull Set<RepositoryConfiguration> listRepositories()
                                                       throws IOException

Specified by:

listRepositories in interface DBAdminAPIClient

Throws:

IOException

nodesByClassifier

public Map<ClassifierKey,ClassifierResult> nodesByClassifier(@Nullable
 @Nullable Integer limit)
                                                      throws IOException

Specified by:

nodesByClassifier in interface InspectionAPIClient

Throws:

IOException

nodesByLanguage

public Map<String,ClassifierResult> nodesByLanguage(@Nullable
 @Nullable Integer limit)
                                             throws IOException

Specified by:

nodesByLanguage in interface InspectionAPIClient

Throws:

IOException

listPartitions

public List<Node> listPartitions(RepositoryVersionToken repoVersion)
                          throws IOException

Specified by:

listPartitions in interface HistoryAPIClient

Throws:

IOException

retrieve

public List<Node> retrieve(RepositoryVersionToken repoVersion,
 List<String> nodeIds,
 int limit)
                    throws IOException

Specified by:

retrieve in interface HistoryAPIClient

Throws:

IOException