Package org.apache.tika
Class TikaGrpc.TikaStub
- java.lang.Object
-
- io.grpc.stub.AbstractStub<S>
-
- io.grpc.stub.AbstractAsyncStub<TikaGrpc.TikaStub>
-
- org.apache.tika.TikaGrpc.TikaStub
-
- Enclosing class:
- TikaGrpc
public static final class TikaGrpc.TikaStub extends io.grpc.stub.AbstractAsyncStub<TikaGrpc.TikaStub>
A stub to allow clients to do asynchronous rpc calls to service Tika.The Tika Grpc Service definition
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected TikaGrpc.TikaStub
build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
void
deleteFetcher(DeleteFetcherRequest request, io.grpc.stub.StreamObserver<DeleteFetcherReply> responseObserver)
Delete a fetcher from the fetcher store.void
fetchAndParse(FetchAndParseRequest request, io.grpc.stub.StreamObserver<FetchAndParseReply> responseObserver)
Using a Fetcher in the fetcher store, send a FetchAndParse request.io.grpc.stub.StreamObserver<FetchAndParseRequest>
fetchAndParseBiDirectionalStreaming(io.grpc.stub.StreamObserver<FetchAndParseReply> responseObserver)
Using a Fetcher in the fetcher store, send a FetchAndParse request.void
fetchAndParseServerSideStreaming(FetchAndParseRequest request, io.grpc.stub.StreamObserver<FetchAndParseReply> responseObserver)
Using a Fetcher in the fetcher store, send a FetchAndParse request.void
getFetcher(GetFetcherRequest request, io.grpc.stub.StreamObserver<GetFetcherReply> responseObserver)
Get a fetcher's data from the fetcher store.void
getFetcherConfigJsonSchema(GetFetcherConfigJsonSchemaRequest request, io.grpc.stub.StreamObserver<GetFetcherConfigJsonSchemaReply> responseObserver)
Get the Fetcher Config schema for a given fetcher class.void
listFetchers(ListFetchersRequest request, io.grpc.stub.StreamObserver<ListFetchersReply> responseObserver)
List fetchers that are currently in the fetcher store.void
saveFetcher(SaveFetcherRequest request, io.grpc.stub.StreamObserver<SaveFetcherReply> responseObserver)
Save a fetcher to the fetcher store.
-
-
-
Method Detail
-
build
protected TikaGrpc.TikaStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
- Specified by:
build
in classio.grpc.stub.AbstractStub<TikaGrpc.TikaStub>
-
saveFetcher
public void saveFetcher(SaveFetcherRequest request, io.grpc.stub.StreamObserver<SaveFetcherReply> responseObserver)
Save a fetcher to the fetcher store.
-
getFetcher
public void getFetcher(GetFetcherRequest request, io.grpc.stub.StreamObserver<GetFetcherReply> responseObserver)
Get a fetcher's data from the fetcher store.
-
listFetchers
public void listFetchers(ListFetchersRequest request, io.grpc.stub.StreamObserver<ListFetchersReply> responseObserver)
List fetchers that are currently in the fetcher store.
-
deleteFetcher
public void deleteFetcher(DeleteFetcherRequest request, io.grpc.stub.StreamObserver<DeleteFetcherReply> responseObserver)
Delete a fetcher from the fetcher store.
-
fetchAndParse
public void fetchAndParse(FetchAndParseRequest request, io.grpc.stub.StreamObserver<FetchAndParseReply> responseObserver)
Using a Fetcher in the fetcher store, send a FetchAndParse request. This will fetch, parse, and return the FetchParseTuple data output from Tika Pipes. This is a synchronous call that immediately returns 1 result.
-
fetchAndParseServerSideStreaming
public void fetchAndParseServerSideStreaming(FetchAndParseRequest request, io.grpc.stub.StreamObserver<FetchAndParseReply> responseObserver)
Using a Fetcher in the fetcher store, send a FetchAndParse request. This will fetch, parse, and return the FetchParseTuple data output from Tika Pipes. This will stream the data from the server in response.
-
fetchAndParseBiDirectionalStreaming
public io.grpc.stub.StreamObserver<FetchAndParseRequest> fetchAndParseBiDirectionalStreaming(io.grpc.stub.StreamObserver<FetchAndParseReply> responseObserver)
Using a Fetcher in the fetcher store, send a FetchAndParse request. This will fetch, parse, and return the FetchParseTuple data output from Tika Pipes. This serves a bi-directional stream of fetch inputs and parsed outputs.
-
getFetcherConfigJsonSchema
public void getFetcherConfigJsonSchema(GetFetcherConfigJsonSchemaRequest request, io.grpc.stub.StreamObserver<GetFetcherConfigJsonSchemaReply> responseObserver)
Get the Fetcher Config schema for a given fetcher class.
-
-