Package io.hstream.internal

Class HStreamApiGrpc.HStreamApiBlockingStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractBlockingStub<HStreamApiGrpc.HStreamApiBlockingStub>

io.hstream.internal.HStreamApiGrpc.HStreamApiBlockingStub

Enclosing class:

HStreamApiGrpc

public static final class HStreamApiGrpc.HStreamApiBlockingStub
extends io.grpc.stub.AbstractBlockingStub<HStreamApiGrpc.HStreamApiBlockingStub>

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

Methods inherited from class io.grpc.stub.AbstractBlockingStub

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

Specified by:

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

echo

public EchoResponse echo(EchoRequest request)

createStream

public Stream createStream(Stream request)

 Stream APIs
 

deleteStream

public com.google.protobuf.Empty deleteStream(DeleteStreamRequest request)

trimStream

public com.google.protobuf.Empty trimStream(TrimStreamRequest request)

trimShards

public TrimShardsResponse trimShards(TrimShardsRequest request)

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

getStream

public GetStreamResponse getStream(GetStreamRequest request)

listStreams

public ListStreamsResponse listStreams(ListStreamsRequest request)

listStreamsWithPrefix

public ListStreamsResponse listStreamsWithPrefix(ListStreamsWithPrefixRequest request)

lookupShard

public LookupShardResponse lookupShard(LookupShardRequest request)

append

public AppendResponse append(AppendRequest request)

getTailRecordId

public GetTailRecordIdResponse getTailRecordId(GetTailRecordIdRequest request)

listShards

public ListShardsResponse listShards(ListShardsRequest request)

 Shard APIs
 

trimShard

public com.google.protobuf.Empty trimShard(TrimShardRequest request)

createShardReader

public CreateShardReaderResponse createShardReader(CreateShardReaderRequest request)

lookupShardReader

public LookupShardReaderResponse lookupShardReader(LookupShardReaderRequest request)

readShard

public ReadShardResponse readShard(ReadShardRequest request)

readShardStream

public Iterator<ReadShardStreamResponse> readShardStream(ReadShardStreamRequest request)

listShardReaders

public ListShardReadersResponse listShardReaders(ListShardReadersRequest request)

deleteShardReader

public com.google.protobuf.Empty deleteShardReader(DeleteShardReaderRequest request)

readStream

public Iterator<ReadStreamResponse> readStream(ReadStreamRequest request)

readSingleShardStream

public Iterator<ReadSingleShardStreamResponse> readSingleShardStream(ReadSingleShardStreamRequest request)

createSubscription

public Subscription createSubscription(Subscription request)

 Subscribe APIs
 

getSubscription

public GetSubscriptionResponse getSubscription(GetSubscriptionRequest request)

listSubscriptions

public ListSubscriptionsResponse listSubscriptions(ListSubscriptionsRequest request)

listSubscriptionsWithPrefix

public ListSubscriptionsResponse listSubscriptionsWithPrefix(ListSubscriptionsWithPrefixRequest request)

listConsumers

public ListConsumersResponse listConsumers(ListConsumersRequest request)

checkSubscriptionExist

public CheckSubscriptionExistResponse checkSubscriptionExist(CheckSubscriptionExistRequest request)

deleteSubscription

public com.google.protobuf.Empty deleteSubscription(DeleteSubscriptionRequest request)

lookupSubscription

public LookupSubscriptionResponse lookupSubscription(LookupSubscriptionRequest request)

describeCluster

public DescribeClusterResponse describeCluster(com.google.protobuf.Empty request)

 Cluster APIs
 

lookupResource

public ServerNode lookupResource(LookupResourceRequest request)

lookupKey

public ServerNode lookupKey(LookupKeyRequest request)

sendAdminCommand

public AdminCommandResponse sendAdminCommand(AdminCommandRequest request)

 Admin Command
 

perStreamTimeSeriesStats

public PerStreamTimeSeriesStatsResponse perStreamTimeSeriesStats(PerStreamTimeSeriesStatsRequest request)

 Stats
 

perStreamTimeSeriesStatsAll

public PerStreamTimeSeriesStatsAllResponse perStreamTimeSeriesStatsAll(PerStreamTimeSeriesStatsAllRequest request)

getStats

public GetStatsResponse getStats(GetStatsRequest request)

executeQuery

public CommandQueryResponse executeQuery(CommandQuery request)

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

createQuery

public Query createQuery(CreateQueryRequest request)

 query related apis
 

createQueryWithNamespace

public Query createQueryWithNamespace(CreateQueryWithNamespaceRequest request)

listQueries

public ListQueriesResponse listQueries(ListQueriesRequest request)

getQuery

public Query getQuery(GetQueryRequest request)

terminateQuery

public com.google.protobuf.Empty terminateQuery(TerminateQueryRequest request)

deleteQuery

public com.google.protobuf.Empty deleteQuery(DeleteQueryRequest request)

resumeQuery

public com.google.protobuf.Empty resumeQuery(ResumeQueryRequest request)

pauseQuery

public com.google.protobuf.Empty pauseQuery(PauseQueryRequest request)

parseSql

public ParseSqlResponse parseSql(ParseSqlRequest request)

 parse query sql, return structuralized information
 

registerSchema

public com.google.protobuf.Empty registerSchema(Schema request)

getSchema

public Schema getSchema(GetSchemaRequest request)

unregisterSchema

public com.google.protobuf.Empty unregisterSchema(UnregisterSchemaRequest request)

createConnector

public Connector createConnector(CreateConnectorRequest request)

 connector related apis
 

listConnectors

public ListConnectorsResponse listConnectors(ListConnectorsRequest request)

getConnector

public Connector getConnector(GetConnectorRequest request)

getConnectorSpec

public GetConnectorSpecResponse getConnectorSpec(GetConnectorSpecRequest request)

getConnectorLogs

public GetConnectorLogsResponse getConnectorLogs(GetConnectorLogsRequest request)

deleteConnector

public com.google.protobuf.Empty deleteConnector(DeleteConnectorRequest request)

pauseConnector

public com.google.protobuf.Empty pauseConnector(PauseConnectorRequest request)

resumeConnector

public com.google.protobuf.Empty resumeConnector(ResumeConnectorRequest request)

alterConnectorConfig

public com.google.protobuf.Empty alterConnectorConfig(AlterConnectorConfigRequest request)

listViews

public ListViewsResponse listViews(ListViewsRequest request)

 view related apis
 

getView

public View getView(GetViewRequest request)

deleteView

public com.google.protobuf.Empty deleteView(DeleteViewRequest request)

executeViewQuery

public ExecuteViewQueryResponse executeViewQuery(ExecuteViewQueryRequest request)

executeViewQueryWithNamespace

public ExecuteViewQueryResponse executeViewQueryWithNamespace(ExecuteViewQueryWithNamespaceRequest request)