Package io.lionweb.repoclient.impl

Class ClientForBulkAPIs

java.lang.Object

io.lionweb.repoclient.impl.ClientForBulkAPIs

All Implemented Interfaces:

BulkAPIClient

public class ClientForBulkAPIs
extends Object
implements BulkAPIClient

Field Summary

Fields

Modifier and Type	Field	Description
protected final RepoClientConfiguration	conf
protected final com.google.gson.Gson	gson
protected static final okhttp3.MediaType	JSON

Constructor Summary

Constructors

Constructor	Description
ClientForBulkAPIs(RepoClientConfiguration repoClientConfiguration)

Method Summary

Modifier and Type	Method	Description
protected okhttp3.Request.Builder	addGZipCompressionHeader(okhttp3.Request.Builder builder)
protected okhttp3.Request.Builder	buildRequest(String api)
protected okhttp3.Request.Builder	buildRequest(String api, boolean specifyingClientID, boolean specifyingRepository, boolean considerAuthenticationToken, Map<String,String> additionalParams)
protected okhttp3.HttpUrl.Builder	buildURL(String api)
protected okhttp3.HttpUrl.Builder	buildURL(String api, boolean specifyingClientID, boolean specifyingRepository)
protected okhttp3.Request.Builder	considerAuthenticationToken(okhttp3.Request.Builder builder)
@Nullable RepositoryVersionToken	createPartitions(List<Node> partitions)
@Nullable RepositoryVersionToken	deletePartitions(List<String> ids)
@NotNull LionWebVersion	getLionWebVersion()
protected @Nullable RepositoryVersionToken	getRepoVersionFromResponse(String responseBody)
List<String>	ids(int count)
List<Node>	listPartitions()
protected <R> R	performCall(okhttp3.Request request, io.lionweb.repoclient.impl.LionWebRepoClientImplHelper.ResponseHandler<R> responseHandler)
List<Node>	retrieve(List<String> nodeIds, int limit)
@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.BulkAPIClient

listPartitionsIDs

Field Details

JSON

protected static final okhttp3.MediaType JSON

conf

protected final RepoClientConfiguration conf

gson

protected final com.google.gson.Gson gson

Constructor Details

ClientForBulkAPIs

public ClientForBulkAPIs(RepoClientConfiguration repoClientConfiguration)

Method Details

getLionWebVersion

@NotNull
public @NotNull LionWebVersion getLionWebVersion()

Specified by:

getLionWebVersion in interface BulkAPIClient

createPartitions

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

Specified by:

createPartitions in interface BulkAPIClient

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

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

retrieve

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

Specified by:

retrieve in interface BulkAPIClient

Throws:

IOException

buildURL

protected okhttp3.HttpUrl.Builder buildURL(String api)

buildURL

protected okhttp3.HttpUrl.Builder buildURL(String api,
 boolean specifyingClientID,
 boolean specifyingRepository)

buildRequest

protected okhttp3.Request.Builder buildRequest(String api)

buildRequest

protected okhttp3.Request.Builder buildRequest(String api,
 boolean specifyingClientID,
 boolean specifyingRepository,
 boolean considerAuthenticationToken,
 Map<String,String> additionalParams)

performCall

protected <R> R performCall(okhttp3.Request request,
 io.lionweb.repoclient.impl.LionWebRepoClientImplHelper.ResponseHandler<R> responseHandler)
                     throws IOException

Throws:

IOException

considerAuthenticationToken

protected okhttp3.Request.Builder considerAuthenticationToken(okhttp3.Request.Builder builder)

addGZipCompressionHeader

protected okhttp3.Request.Builder addGZipCompressionHeader(okhttp3.Request.Builder builder)

getRepoVersionFromResponse

@Nullable
protected @Nullable RepositoryVersionToken getRepoVersionFromResponse(String responseBody)