Package io.hstream.internal

Class HStreamApiGrpc.HStreamApiFutureStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractFutureStub<HStreamApiGrpc.HStreamApiFutureStub>

io.hstream.internal.HStreamApiGrpc.HStreamApiFutureStub

Enclosing class:

HStreamApiGrpc

public static final class HStreamApiGrpc.HStreamApiFutureStub
extends io.grpc.stub.AbstractFutureStub<HStreamApiGrpc.HStreamApiFutureStub>

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

Methods inherited from class io.grpc.stub.AbstractFutureStub

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.HStreamApiFutureStub build(io.grpc.Channel channel,
                                                    io.grpc.CallOptions callOptions)

Specified by:

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

echo

public com.google.common.util.concurrent.ListenableFuture<EchoResponse> echo(EchoRequest request)

createStream

public com.google.common.util.concurrent.ListenableFuture<Stream> createStream(Stream request)

 Stream APIs
 

deleteStream

public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> deleteStream(DeleteStreamRequest request)

trimStream

public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> trimStream(TrimStreamRequest request)

trimShards

public com.google.common.util.concurrent.ListenableFuture<TrimShardsResponse> trimShards(TrimShardsRequest request)

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

getStream

public com.google.common.util.concurrent.ListenableFuture<GetStreamResponse> getStream(GetStreamRequest request)

listStreams

public com.google.common.util.concurrent.ListenableFuture<ListStreamsResponse> listStreams(ListStreamsRequest request)

listStreamsWithPrefix

public com.google.common.util.concurrent.ListenableFuture<ListStreamsResponse> listStreamsWithPrefix(ListStreamsWithPrefixRequest request)

lookupShard

public com.google.common.util.concurrent.ListenableFuture<LookupShardResponse> lookupShard(LookupShardRequest request)

append

public com.google.common.util.concurrent.ListenableFuture<AppendResponse> append(AppendRequest request)

getTailRecordId

public com.google.common.util.concurrent.ListenableFuture<GetTailRecordIdResponse> getTailRecordId(GetTailRecordIdRequest request)

listShards

public com.google.common.util.concurrent.ListenableFuture<ListShardsResponse> listShards(ListShardsRequest request)

 Shard APIs
 

trimShard

public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> trimShard(TrimShardRequest request)

createShardReader

public com.google.common.util.concurrent.ListenableFuture<CreateShardReaderResponse> createShardReader(CreateShardReaderRequest request)

lookupShardReader

public com.google.common.util.concurrent.ListenableFuture<LookupShardReaderResponse> lookupShardReader(LookupShardReaderRequest request)

readShard

public com.google.common.util.concurrent.ListenableFuture<ReadShardResponse> readShard(ReadShardRequest request)

listShardReaders

public com.google.common.util.concurrent.ListenableFuture<ListShardReadersResponse> listShardReaders(ListShardReadersRequest request)

deleteShardReader

public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> deleteShardReader(DeleteShardReaderRequest request)

createSubscription

public com.google.common.util.concurrent.ListenableFuture<Subscription> createSubscription(Subscription request)

 Subscribe APIs
 

getSubscription

public com.google.common.util.concurrent.ListenableFuture<GetSubscriptionResponse> getSubscription(GetSubscriptionRequest request)

listSubscriptions

public com.google.common.util.concurrent.ListenableFuture<ListSubscriptionsResponse> listSubscriptions(ListSubscriptionsRequest request)

listSubscriptionsWithPrefix

public com.google.common.util.concurrent.ListenableFuture<ListSubscriptionsResponse> listSubscriptionsWithPrefix(ListSubscriptionsWithPrefixRequest request)

listConsumers

public com.google.common.util.concurrent.ListenableFuture<ListConsumersResponse> listConsumers(ListConsumersRequest request)

checkSubscriptionExist

public com.google.common.util.concurrent.ListenableFuture<CheckSubscriptionExistResponse> checkSubscriptionExist(CheckSubscriptionExistRequest request)

deleteSubscription

public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> deleteSubscription(DeleteSubscriptionRequest request)

lookupSubscription

public com.google.common.util.concurrent.ListenableFuture<LookupSubscriptionResponse> lookupSubscription(LookupSubscriptionRequest request)

describeCluster

public com.google.common.util.concurrent.ListenableFuture<DescribeClusterResponse> describeCluster(com.google.protobuf.Empty request)

 Cluster APIs
 

lookupResource

public com.google.common.util.concurrent.ListenableFuture<ServerNode> lookupResource(LookupResourceRequest request)

lookupKey

public com.google.common.util.concurrent.ListenableFuture<ServerNode> lookupKey(LookupKeyRequest request)

sendAdminCommand

public com.google.common.util.concurrent.ListenableFuture<AdminCommandResponse> sendAdminCommand(AdminCommandRequest request)

 Admin Command
 

perStreamTimeSeriesStats

public com.google.common.util.concurrent.ListenableFuture<PerStreamTimeSeriesStatsResponse> perStreamTimeSeriesStats(PerStreamTimeSeriesStatsRequest request)

 Stats
 

perStreamTimeSeriesStatsAll

public com.google.common.util.concurrent.ListenableFuture<PerStreamTimeSeriesStatsAllResponse> perStreamTimeSeriesStatsAll(PerStreamTimeSeriesStatsAllRequest request)

getStats

public com.google.common.util.concurrent.ListenableFuture<GetStatsResponse> getStats(GetStatsRequest request)

executeQuery

public com.google.common.util.concurrent.ListenableFuture<CommandQueryResponse> executeQuery(CommandQuery request)

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

createQuery

public com.google.common.util.concurrent.ListenableFuture<Query> createQuery(CreateQueryRequest request)

 query related apis
 

createQueryWithNamespace

public com.google.common.util.concurrent.ListenableFuture<Query> createQueryWithNamespace(CreateQueryWithNamespaceRequest request)

listQueries

public com.google.common.util.concurrent.ListenableFuture<ListQueriesResponse> listQueries(ListQueriesRequest request)

getQuery

public com.google.common.util.concurrent.ListenableFuture<Query> getQuery(GetQueryRequest request)

terminateQuery

public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> terminateQuery(TerminateQueryRequest request)

deleteQuery

public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> deleteQuery(DeleteQueryRequest request)

resumeQuery

public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> resumeQuery(ResumeQueryRequest request)

pauseQuery

public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> pauseQuery(PauseQueryRequest request)

parseSql

public com.google.common.util.concurrent.ListenableFuture<ParseSqlResponse> parseSql(ParseSqlRequest request)

 parse query sql, return structuralized information
 

registerSchema

public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> registerSchema(Schema request)

getSchema

public com.google.common.util.concurrent.ListenableFuture<Schema> getSchema(GetSchemaRequest request)

unregisterSchema

public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> unregisterSchema(UnregisterSchemaRequest request)

createConnector

public com.google.common.util.concurrent.ListenableFuture<Connector> createConnector(CreateConnectorRequest request)

 connector related apis
 

listConnectors

public com.google.common.util.concurrent.ListenableFuture<ListConnectorsResponse> listConnectors(ListConnectorsRequest request)

getConnector

public com.google.common.util.concurrent.ListenableFuture<Connector> getConnector(GetConnectorRequest request)

getConnectorSpec

public com.google.common.util.concurrent.ListenableFuture<GetConnectorSpecResponse> getConnectorSpec(GetConnectorSpecRequest request)

getConnectorLogs

public com.google.common.util.concurrent.ListenableFuture<GetConnectorLogsResponse> getConnectorLogs(GetConnectorLogsRequest request)

deleteConnector

public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> deleteConnector(DeleteConnectorRequest request)

pauseConnector

public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> pauseConnector(PauseConnectorRequest request)

resumeConnector

public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> resumeConnector(ResumeConnectorRequest request)

alterConnectorConfig

public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> alterConnectorConfig(AlterConnectorConfigRequest request)

listViews

public com.google.common.util.concurrent.ListenableFuture<ListViewsResponse> listViews(ListViewsRequest request)

 view related apis
 

getView

public com.google.common.util.concurrent.ListenableFuture<View> getView(GetViewRequest request)

deleteView

public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> deleteView(DeleteViewRequest request)

executeViewQuery

public com.google.common.util.concurrent.ListenableFuture<ExecuteViewQueryResponse> executeViewQuery(ExecuteViewQueryRequest request)

executeViewQueryWithNamespace

public com.google.common.util.concurrent.ListenableFuture<ExecuteViewQueryResponse> executeViewQueryWithNamespace(ExecuteViewQueryWithNamespaceRequest request)