Package io.hstream.internal

Interface HStreamApiGrpc.AsyncService

All Known Implementing Classes:

HStreamApiGrpc.HStreamApiImplBase

Enclosing class:

HStreamApiGrpc

public static interface HStreamApiGrpc.AsyncService

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

Method Summary

Modifier and Type	Method	Description
default void	alterConnectorConfig(AlterConnectorConfigRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
default void	append(AppendRequest request, io.grpc.stub.StreamObserver<AppendResponse> responseObserver)
default void	checkSubscriptionExist(CheckSubscriptionExistRequest request, io.grpc.stub.StreamObserver<CheckSubscriptionExistResponse> responseObserver)
default void	createConnector(CreateConnectorRequest request, io.grpc.stub.StreamObserver<Connector> responseObserver)	connector related apis
default void	createQuery(CreateQueryRequest request, io.grpc.stub.StreamObserver<Query> responseObserver)	query related apis
default void	createQueryWithNamespace(CreateQueryWithNamespaceRequest request, io.grpc.stub.StreamObserver<Query> responseObserver)
default void	createShardReader(CreateShardReaderRequest request, io.grpc.stub.StreamObserver<CreateShardReaderResponse> responseObserver)
default void	createStream(Stream request, io.grpc.stub.StreamObserver<Stream> responseObserver)	Stream APIs
default void	createSubscription(Subscription request, io.grpc.stub.StreamObserver<Subscription> responseObserver)	Subscribe APIs
default void	deleteConnector(DeleteConnectorRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
default void	deleteQuery(DeleteQueryRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
default void	deleteShardReader(DeleteShardReaderRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
default void	deleteStream(DeleteStreamRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
default void	deleteSubscription(DeleteSubscriptionRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
default void	deleteView(DeleteViewRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
default void	describeCluster(com.google.protobuf.Empty request, io.grpc.stub.StreamObserver<DescribeClusterResponse> responseObserver)	Cluster APIs
default void	echo(EchoRequest request, io.grpc.stub.StreamObserver<EchoResponse> responseObserver)
default 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) ...
default void	executeViewQuery(ExecuteViewQueryRequest request, io.grpc.stub.StreamObserver<ExecuteViewQueryResponse> responseObserver)
default void	executeViewQueryWithNamespace(ExecuteViewQueryWithNamespaceRequest request, io.grpc.stub.StreamObserver<ExecuteViewQueryResponse> responseObserver)
default void	getConnector(GetConnectorRequest request, io.grpc.stub.StreamObserver<Connector> responseObserver)
default void	getConnectorLogs(GetConnectorLogsRequest request, io.grpc.stub.StreamObserver<GetConnectorLogsResponse> responseObserver)
default void	getConnectorSpec(GetConnectorSpecRequest request, io.grpc.stub.StreamObserver<GetConnectorSpecResponse> responseObserver)
default void	getQuery(GetQueryRequest request, io.grpc.stub.StreamObserver<Query> responseObserver)
default void	getSchema(GetSchemaRequest request, io.grpc.stub.StreamObserver<Schema> responseObserver)
default void	getStats(GetStatsRequest request, io.grpc.stub.StreamObserver<GetStatsResponse> responseObserver)
default void	getStream(GetStreamRequest request, io.grpc.stub.StreamObserver<GetStreamResponse> responseObserver)
default void	getSubscription(GetSubscriptionRequest request, io.grpc.stub.StreamObserver<GetSubscriptionResponse> responseObserver)
default void	getTailRecordId(GetTailRecordIdRequest request, io.grpc.stub.StreamObserver<GetTailRecordIdResponse> responseObserver)
default void	getView(GetViewRequest request, io.grpc.stub.StreamObserver<View> responseObserver)
default void	listConnectors(ListConnectorsRequest request, io.grpc.stub.StreamObserver<ListConnectorsResponse> responseObserver)
default void	listConsumers(ListConsumersRequest request, io.grpc.stub.StreamObserver<ListConsumersResponse> responseObserver)
default void	listQueries(ListQueriesRequest request, io.grpc.stub.StreamObserver<ListQueriesResponse> responseObserver)
default void	listShardReaders(ListShardReadersRequest request, io.grpc.stub.StreamObserver<ListShardReadersResponse> responseObserver)
default void	listShards(ListShardsRequest request, io.grpc.stub.StreamObserver<ListShardsResponse> responseObserver)	Shard APIs
default void	listStreams(ListStreamsRequest request, io.grpc.stub.StreamObserver<ListStreamsResponse> responseObserver)
default void	listStreamsWithPrefix(ListStreamsWithPrefixRequest request, io.grpc.stub.StreamObserver<ListStreamsResponse> responseObserver)
default void	listSubscriptions(ListSubscriptionsRequest request, io.grpc.stub.StreamObserver<ListSubscriptionsResponse> responseObserver)
default void	listSubscriptionsWithPrefix(ListSubscriptionsWithPrefixRequest request, io.grpc.stub.StreamObserver<ListSubscriptionsResponse> responseObserver)
default void	listViews(ListViewsRequest request, io.grpc.stub.StreamObserver<ListViewsResponse> responseObserver)	view related apis
default void	lookupKey(LookupKeyRequest request, io.grpc.stub.StreamObserver<ServerNode> responseObserver)
default void	lookupResource(LookupResourceRequest request, io.grpc.stub.StreamObserver<ServerNode> responseObserver)
default void	lookupShard(LookupShardRequest request, io.grpc.stub.StreamObserver<LookupShardResponse> responseObserver)
default void	lookupShardReader(LookupShardReaderRequest request, io.grpc.stub.StreamObserver<LookupShardReaderResponse> responseObserver)
default void	lookupSubscription(LookupSubscriptionRequest request, io.grpc.stub.StreamObserver<LookupSubscriptionResponse> responseObserver)
default void	parseSql(ParseSqlRequest request, io.grpc.stub.StreamObserver<ParseSqlResponse> responseObserver)	parse query sql, return structuralized information
default void	pauseConnector(PauseConnectorRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
default void	pauseQuery(PauseQueryRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
default void	perStreamTimeSeriesStats(PerStreamTimeSeriesStatsRequest request, io.grpc.stub.StreamObserver<PerStreamTimeSeriesStatsResponse> responseObserver)	Stats
default void	perStreamTimeSeriesStatsAll(PerStreamTimeSeriesStatsAllRequest request, io.grpc.stub.StreamObserver<PerStreamTimeSeriesStatsAllResponse> responseObserver)
default void	readShard(ReadShardRequest request, io.grpc.stub.StreamObserver<ReadShardResponse> responseObserver)
default void	readShardStream(ReadShardStreamRequest request, io.grpc.stub.StreamObserver<ReadShardStreamResponse> responseObserver)
default void	readSingleShardStream(ReadSingleShardStreamRequest request, io.grpc.stub.StreamObserver<ReadSingleShardStreamResponse> responseObserver)
default void	readStream(ReadStreamRequest request, io.grpc.stub.StreamObserver<ReadStreamResponse> responseObserver)
default io.grpc.stub.StreamObserver<ReadStreamByKeyRequest>	readStreamByKey(io.grpc.stub.StreamObserver<ReadStreamByKeyResponse> responseObserver)
default void	registerSchema(Schema request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
default void	resumeConnector(ResumeConnectorRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
default void	resumeQuery(ResumeQueryRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
default void	sendAdminCommand(AdminCommandRequest request, io.grpc.stub.StreamObserver<AdminCommandResponse> responseObserver)	Admin Command
default io.grpc.stub.StreamObserver<StreamingFetchRequest>	streamingFetch(io.grpc.stub.StreamObserver<StreamingFetchResponse> responseObserver)
default void	terminateQuery(TerminateQueryRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
default void	trimShard(TrimShardRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
default 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)."
default void	trimStream(TrimStreamRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
default void	unregisterSchema(UnregisterSchemaRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)

Method Detail

echo

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

createStream

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

 Stream APIs
 

deleteStream

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

trimStream

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

trimShards

default 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

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

listStreams

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

listStreamsWithPrefix

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

lookupShard

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

append

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

getTailRecordId

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

listShards

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

 Shard APIs
 

trimShard

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

createShardReader

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

lookupShardReader

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

readShard

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

readShardStream

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

listShardReaders

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

deleteShardReader

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

readStream

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

readSingleShardStream

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

readStreamByKey

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

createSubscription

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

 Subscribe APIs
 

getSubscription

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

listSubscriptions

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

listSubscriptionsWithPrefix

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

listConsumers

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

checkSubscriptionExist

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

deleteSubscription

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

lookupSubscription

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

streamingFetch

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

describeCluster

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

 Cluster APIs
 

lookupResource

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

lookupKey

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

sendAdminCommand

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

 Admin Command
 

perStreamTimeSeriesStats

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

 Stats
 

perStreamTimeSeriesStatsAll

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

getStats

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

executeQuery

default 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

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

 query related apis
 

createQueryWithNamespace

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

listQueries

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

getQuery

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

terminateQuery

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

deleteQuery

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

resumeQuery

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

pauseQuery

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

parseSql

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

 parse query sql, return structuralized information
 

registerSchema

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

getSchema

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

unregisterSchema

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

createConnector

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

 connector related apis
 

listConnectors

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

getConnector

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

getConnectorSpec

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

getConnectorLogs

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

deleteConnector

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

pauseConnector

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

resumeConnector

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

alterConnectorConfig

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

listViews

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

 view related apis
 

getView

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

deleteView

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

executeViewQuery

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

executeViewQueryWithNamespace

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