Package io.hstream.internal

Class HStreamApiGrpc.HStreamApiStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractAsyncStub<HStreamApiGrpc.HStreamApiStub>

io.hstream.internal.HStreamApiGrpc.HStreamApiStub

Enclosing class:

HStreamApiGrpc

public static final class HStreamApiGrpc.HStreamApiStub
extends io.grpc.stub.AbstractAsyncStub<HStreamApiGrpc.HStreamApiStub>

A stub to allow clients to do asynchronous rpc calls to service HStreamApi.

 ---------------------------------------------------------------------------
 Stable APIs
 ---------------------------------------------------------------------------
 

Nested Class Summary

Nested classes/interfaces inherited from class io.grpc.stub.AbstractStub

io.grpc.stub.AbstractStub.StubFactory<T extends io.grpc.stub.AbstractStub<T>>

Method Summary

Modifier and Type	Method	Description
void	alterConnectorConfig(AlterConnectorConfigRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
void	append(AppendRequest request, io.grpc.stub.StreamObserver<AppendResponse> responseObserver)
protected HStreamApiGrpc.HStreamApiStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
void	checkSubscriptionExist(CheckSubscriptionExistRequest request, io.grpc.stub.StreamObserver<CheckSubscriptionExistResponse> responseObserver)
void	createConnector(CreateConnectorRequest request, io.grpc.stub.StreamObserver<Connector> responseObserver)	connector related apis
void	createQuery(CreateQueryRequest request, io.grpc.stub.StreamObserver<Query> responseObserver)	query related apis
void	createQueryWithNamespace(CreateQueryWithNamespaceRequest request, io.grpc.stub.StreamObserver<Query> responseObserver)
void	createShardReader(CreateShardReaderRequest request, io.grpc.stub.StreamObserver<CreateShardReaderResponse> responseObserver)
void	createStream(Stream request, io.grpc.stub.StreamObserver<Stream> responseObserver)	Stream APIs
void	createSubscription(Subscription request, io.grpc.stub.StreamObserver<Subscription> responseObserver)	Subscribe APIs
void	deleteConnector(DeleteConnectorRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
void	deleteQuery(DeleteQueryRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
void	deleteShardReader(DeleteShardReaderRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
void	deleteStream(DeleteStreamRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
void	deleteSubscription(DeleteSubscriptionRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
void	deleteView(DeleteViewRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
void	describeCluster(com.google.protobuf.Empty request, io.grpc.stub.StreamObserver<DescribeClusterResponse> responseObserver)	Cluster APIs
void	echo(EchoRequest request, io.grpc.stub.StreamObserver<EchoResponse> responseObserver)
void	executeQuery(CommandQuery request, io.grpc.stub.StreamObserver<CommandQueryResponse> responseObserver)	for execute any sql stmt except push query, e.g., insert, create, show/list, select(without emit changes) ...
void	executeViewQuery(ExecuteViewQueryRequest request, io.grpc.stub.StreamObserver<ExecuteViewQueryResponse> responseObserver)
void	executeViewQueryWithNamespace(ExecuteViewQueryWithNamespaceRequest request, io.grpc.stub.StreamObserver<ExecuteViewQueryResponse> responseObserver)
void	getConnector(GetConnectorRequest request, io.grpc.stub.StreamObserver<Connector> responseObserver)
void	getConnectorLogs(GetConnectorLogsRequest request, io.grpc.stub.StreamObserver<GetConnectorLogsResponse> responseObserver)
void	getConnectorSpec(GetConnectorSpecRequest request, io.grpc.stub.StreamObserver<GetConnectorSpecResponse> responseObserver)
void	getQuery(GetQueryRequest request, io.grpc.stub.StreamObserver<Query> responseObserver)
void	getSchema(GetSchemaRequest request, io.grpc.stub.StreamObserver<Schema> responseObserver)
void	getStats(GetStatsRequest request, io.grpc.stub.StreamObserver<GetStatsResponse> responseObserver)
void	getStream(GetStreamRequest request, io.grpc.stub.StreamObserver<GetStreamResponse> responseObserver)
void	getSubscription(GetSubscriptionRequest request, io.grpc.stub.StreamObserver<GetSubscriptionResponse> responseObserver)
void	getTailRecordId(GetTailRecordIdRequest request, io.grpc.stub.StreamObserver<GetTailRecordIdResponse> responseObserver)
void	getView(GetViewRequest request, io.grpc.stub.StreamObserver<View> responseObserver)
void	listConnectors(ListConnectorsRequest request, io.grpc.stub.StreamObserver<ListConnectorsResponse> responseObserver)
void	listConsumers(ListConsumersRequest request, io.grpc.stub.StreamObserver<ListConsumersResponse> responseObserver)
void	listQueries(ListQueriesRequest request, io.grpc.stub.StreamObserver<ListQueriesResponse> responseObserver)
void	listShardReaders(ListShardReadersRequest request, io.grpc.stub.StreamObserver<ListShardReadersResponse> responseObserver)
void	listShards(ListShardsRequest request, io.grpc.stub.StreamObserver<ListShardsResponse> responseObserver)	Shard APIs
void	listStreams(ListStreamsRequest request, io.grpc.stub.StreamObserver<ListStreamsResponse> responseObserver)
void	listStreamsWithPrefix(ListStreamsWithPrefixRequest request, io.grpc.stub.StreamObserver<ListStreamsResponse> responseObserver)
void	listSubscriptions(ListSubscriptionsRequest request, io.grpc.stub.StreamObserver<ListSubscriptionsResponse> responseObserver)
void	listSubscriptionsWithPrefix(ListSubscriptionsWithPrefixRequest request, io.grpc.stub.StreamObserver<ListSubscriptionsResponse> responseObserver)
void	listViews(ListViewsRequest request, io.grpc.stub.StreamObserver<ListViewsResponse> responseObserver)	view related apis
void	lookupKey(LookupKeyRequest request, io.grpc.stub.StreamObserver<ServerNode> responseObserver)
void	lookupResource(LookupResourceRequest request, io.grpc.stub.StreamObserver<ServerNode> responseObserver)
void	lookupShard(LookupShardRequest request, io.grpc.stub.StreamObserver<LookupShardResponse> responseObserver)
void	lookupShardReader(LookupShardReaderRequest request, io.grpc.stub.StreamObserver<LookupShardReaderResponse> responseObserver)
void	lookupSubscription(LookupSubscriptionRequest request, io.grpc.stub.StreamObserver<LookupSubscriptionResponse> responseObserver)
void	parseSql(ParseSqlRequest request, io.grpc.stub.StreamObserver<ParseSqlResponse> responseObserver)	parse query sql, return structuralized information
void	pauseConnector(PauseConnectorRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
void	pauseQuery(PauseQueryRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
void	perStreamTimeSeriesStats(PerStreamTimeSeriesStatsRequest request, io.grpc.stub.StreamObserver<PerStreamTimeSeriesStatsResponse> responseObserver)	Stats
void	perStreamTimeSeriesStatsAll(PerStreamTimeSeriesStatsAllRequest request, io.grpc.stub.StreamObserver<PerStreamTimeSeriesStatsAllResponse> responseObserver)
void	readShard(ReadShardRequest request, io.grpc.stub.StreamObserver<ReadShardResponse> responseObserver)
void	readShardStream(ReadShardStreamRequest request, io.grpc.stub.StreamObserver<ReadShardStreamResponse> responseObserver)
void	readSingleShardStream(ReadSingleShardStreamRequest request, io.grpc.stub.StreamObserver<ReadSingleShardStreamResponse> responseObserver)
void	readStream(ReadStreamRequest request, io.grpc.stub.StreamObserver<ReadStreamResponse> responseObserver)
io.grpc.stub.StreamObserver<ReadStreamByKeyRequest>	readStreamByKey(io.grpc.stub.StreamObserver<ReadStreamByKeyResponse> responseObserver)
void	registerSchema(Schema request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
void	resumeConnector(ResumeConnectorRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
void	resumeQuery(ResumeQueryRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
void	sendAdminCommand(AdminCommandRequest request, io.grpc.stub.StreamObserver<AdminCommandResponse> responseObserver)	Admin Command
io.grpc.stub.StreamObserver<StreamingFetchRequest>	streamingFetch(io.grpc.stub.StreamObserver<StreamingFetchResponse> responseObserver)
void	terminateQuery(TerminateQueryRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
void	trimShard(TrimShardRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
void	trimShards(TrimShardsRequest request, io.grpc.stub.StreamObserver<TrimShardsResponse> responseObserver)	Find the oldest recordId in each shard, and trim all the records before that recordId(exclude)."
void	trimStream(TrimStreamRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
void	unregisterSchema(UnregisterSchemaRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)

Methods inherited from class io.grpc.stub.AbstractAsyncStub

newStub, newStub

Methods inherited from class io.grpc.stub.AbstractStub

getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOption, withWaitForReady

Methods inherited from class java.lang.Object

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

Method Detail

build

protected HStreamApiGrpc.HStreamApiStub build(io.grpc.Channel channel,
                                              io.grpc.CallOptions callOptions)

Specified by:

build in class io.grpc.stub.AbstractStub<HStreamApiGrpc.HStreamApiStub>

echo

public void echo(EchoRequest request,
                 io.grpc.stub.StreamObserver<EchoResponse> responseObserver)

createStream

public void createStream(Stream request,
                         io.grpc.stub.StreamObserver<Stream> responseObserver)

 Stream APIs
 

deleteStream

public void deleteStream(DeleteStreamRequest request,
                         io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)

trimStream

public void trimStream(TrimStreamRequest request,
                       io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)

trimShards

public void trimShards(TrimShardsRequest request,
                       io.grpc.stub.StreamObserver<TrimShardsResponse> responseObserver)

 Find the oldest recordId in each shard, and trim all the records before
 that recordId(exclude)."
 

getStream

public void getStream(GetStreamRequest request,
                      io.grpc.stub.StreamObserver<GetStreamResponse> responseObserver)

listStreams

public void listStreams(ListStreamsRequest request,
                        io.grpc.stub.StreamObserver<ListStreamsResponse> responseObserver)

listStreamsWithPrefix

public void listStreamsWithPrefix(ListStreamsWithPrefixRequest request,
                                  io.grpc.stub.StreamObserver<ListStreamsResponse> responseObserver)

lookupShard

public void lookupShard(LookupShardRequest request,
                        io.grpc.stub.StreamObserver<LookupShardResponse> responseObserver)

append

public void append(AppendRequest request,
                   io.grpc.stub.StreamObserver<AppendResponse> responseObserver)

getTailRecordId

public void getTailRecordId(GetTailRecordIdRequest request,
                            io.grpc.stub.StreamObserver<GetTailRecordIdResponse> responseObserver)

listShards

public void listShards(ListShardsRequest request,
                       io.grpc.stub.StreamObserver<ListShardsResponse> responseObserver)

 Shard APIs
 

trimShard

public void trimShard(TrimShardRequest request,
                      io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)

createShardReader

public void createShardReader(CreateShardReaderRequest request,
                              io.grpc.stub.StreamObserver<CreateShardReaderResponse> responseObserver)

lookupShardReader

public void lookupShardReader(LookupShardReaderRequest request,
                              io.grpc.stub.StreamObserver<LookupShardReaderResponse> responseObserver)

readShard

public void readShard(ReadShardRequest request,
                      io.grpc.stub.StreamObserver<ReadShardResponse> responseObserver)

readShardStream

public void readShardStream(ReadShardStreamRequest request,
                            io.grpc.stub.StreamObserver<ReadShardStreamResponse> responseObserver)

listShardReaders

public void listShardReaders(ListShardReadersRequest request,
                             io.grpc.stub.StreamObserver<ListShardReadersResponse> responseObserver)

deleteShardReader

public void deleteShardReader(DeleteShardReaderRequest request,
                              io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)

readStream

public void readStream(ReadStreamRequest request,
                       io.grpc.stub.StreamObserver<ReadStreamResponse> responseObserver)

readSingleShardStream

public void readSingleShardStream(ReadSingleShardStreamRequest request,
                                  io.grpc.stub.StreamObserver<ReadSingleShardStreamResponse> responseObserver)

readStreamByKey

public io.grpc.stub.StreamObserver<ReadStreamByKeyRequest> readStreamByKey(io.grpc.stub.StreamObserver<ReadStreamByKeyResponse> responseObserver)

createSubscription

public void createSubscription(Subscription request,
                               io.grpc.stub.StreamObserver<Subscription> responseObserver)

 Subscribe APIs
 

getSubscription

public void getSubscription(GetSubscriptionRequest request,
                            io.grpc.stub.StreamObserver<GetSubscriptionResponse> responseObserver)

listSubscriptions

public void listSubscriptions(ListSubscriptionsRequest request,
                              io.grpc.stub.StreamObserver<ListSubscriptionsResponse> responseObserver)

listSubscriptionsWithPrefix

public void listSubscriptionsWithPrefix(ListSubscriptionsWithPrefixRequest request,
                                        io.grpc.stub.StreamObserver<ListSubscriptionsResponse> responseObserver)

listConsumers

public void listConsumers(ListConsumersRequest request,
                          io.grpc.stub.StreamObserver<ListConsumersResponse> responseObserver)

checkSubscriptionExist

public void checkSubscriptionExist(CheckSubscriptionExistRequest request,
                                   io.grpc.stub.StreamObserver<CheckSubscriptionExistResponse> responseObserver)

deleteSubscription

public void deleteSubscription(DeleteSubscriptionRequest request,
                               io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)

lookupSubscription

public void lookupSubscription(LookupSubscriptionRequest request,
                               io.grpc.stub.StreamObserver<LookupSubscriptionResponse> responseObserver)

streamingFetch

public io.grpc.stub.StreamObserver<StreamingFetchRequest> streamingFetch(io.grpc.stub.StreamObserver<StreamingFetchResponse> responseObserver)

describeCluster

public void describeCluster(com.google.protobuf.Empty request,
                            io.grpc.stub.StreamObserver<DescribeClusterResponse> responseObserver)

 Cluster APIs
 

lookupResource

public void lookupResource(LookupResourceRequest request,
                           io.grpc.stub.StreamObserver<ServerNode> responseObserver)

lookupKey

public void lookupKey(LookupKeyRequest request,
                      io.grpc.stub.StreamObserver<ServerNode> responseObserver)

sendAdminCommand

public void sendAdminCommand(AdminCommandRequest request,
                             io.grpc.stub.StreamObserver<AdminCommandResponse> responseObserver)

 Admin Command
 

perStreamTimeSeriesStats

public void perStreamTimeSeriesStats(PerStreamTimeSeriesStatsRequest request,
                                     io.grpc.stub.StreamObserver<PerStreamTimeSeriesStatsResponse> responseObserver)

 Stats
 

perStreamTimeSeriesStatsAll

public void perStreamTimeSeriesStatsAll(PerStreamTimeSeriesStatsAllRequest request,
                                        io.grpc.stub.StreamObserver<PerStreamTimeSeriesStatsAllResponse> responseObserver)

getStats

public void getStats(GetStatsRequest request,
                     io.grpc.stub.StreamObserver<GetStatsResponse> responseObserver)

executeQuery

public void executeQuery(CommandQuery request,
                         io.grpc.stub.StreamObserver<CommandQueryResponse> responseObserver)

 for execute any sql stmt except push query,
 e.g., insert, create, show/list, select(without emit changes) ...
 

createQuery

public void createQuery(CreateQueryRequest request,
                        io.grpc.stub.StreamObserver<Query> responseObserver)

 query related apis
 

createQueryWithNamespace

public void createQueryWithNamespace(CreateQueryWithNamespaceRequest request,
                                     io.grpc.stub.StreamObserver<Query> responseObserver)

listQueries

public void listQueries(ListQueriesRequest request,
                        io.grpc.stub.StreamObserver<ListQueriesResponse> responseObserver)

getQuery

public void getQuery(GetQueryRequest request,
                     io.grpc.stub.StreamObserver<Query> responseObserver)

terminateQuery

public void terminateQuery(TerminateQueryRequest request,
                           io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)

deleteQuery

public void deleteQuery(DeleteQueryRequest request,
                        io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)

resumeQuery

public void resumeQuery(ResumeQueryRequest request,
                        io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)

pauseQuery

public void pauseQuery(PauseQueryRequest request,
                       io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)

parseSql

public void parseSql(ParseSqlRequest request,
                     io.grpc.stub.StreamObserver<ParseSqlResponse> responseObserver)

 parse query sql, return structuralized information
 

registerSchema

public void registerSchema(Schema request,
                           io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)

getSchema

public void getSchema(GetSchemaRequest request,
                      io.grpc.stub.StreamObserver<Schema> responseObserver)

unregisterSchema

public void unregisterSchema(UnregisterSchemaRequest request,
                             io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)

createConnector

public void createConnector(CreateConnectorRequest request,
                            io.grpc.stub.StreamObserver<Connector> responseObserver)

 connector related apis
 

listConnectors

public void listConnectors(ListConnectorsRequest request,
                           io.grpc.stub.StreamObserver<ListConnectorsResponse> responseObserver)

getConnector

public void getConnector(GetConnectorRequest request,
                         io.grpc.stub.StreamObserver<Connector> responseObserver)

getConnectorSpec

public void getConnectorSpec(GetConnectorSpecRequest request,
                             io.grpc.stub.StreamObserver<GetConnectorSpecResponse> responseObserver)

getConnectorLogs

public void getConnectorLogs(GetConnectorLogsRequest request,
                             io.grpc.stub.StreamObserver<GetConnectorLogsResponse> responseObserver)

deleteConnector

public void deleteConnector(DeleteConnectorRequest request,
                            io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)

pauseConnector

public void pauseConnector(PauseConnectorRequest request,
                           io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)

resumeConnector

public void resumeConnector(ResumeConnectorRequest request,
                            io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)

alterConnectorConfig

public void alterConnectorConfig(AlterConnectorConfigRequest request,
                                 io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)

listViews

public void listViews(ListViewsRequest request,
                      io.grpc.stub.StreamObserver<ListViewsResponse> responseObserver)

 view related apis
 

getView

public void getView(GetViewRequest request,
                    io.grpc.stub.StreamObserver<View> responseObserver)

deleteView

public void deleteView(DeleteViewRequest request,
                       io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)

executeViewQuery

public void executeViewQuery(ExecuteViewQueryRequest request,
                             io.grpc.stub.StreamObserver<ExecuteViewQueryResponse> responseObserver)

executeViewQueryWithNamespace

public void executeViewQueryWithNamespace(ExecuteViewQueryWithNamespaceRequest request,
                                          io.grpc.stub.StreamObserver<ExecuteViewQueryResponse> responseObserver)