Package io.hstream.internal

Class HStreamApiGrpc

java.lang.Object

io.hstream.internal.HStreamApiGrpc

public final class HStreamApiGrpc
extends Object

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

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	HStreamApiGrpc.AsyncService	--------------------------------------------------------------------------- Stable APIs ---------------------------------------------------------------------------
static class	HStreamApiGrpc.HStreamApiBlockingStub	A stub to allow clients to do synchronous rpc calls to service HStreamApi.
static class	HStreamApiGrpc.HStreamApiFutureStub	A stub to allow clients to do ListenableFuture-style rpc calls to service HStreamApi.
static class	HStreamApiGrpc.HStreamApiImplBase	Base class for the server implementation of the service HStreamApi.
static class	HStreamApiGrpc.HStreamApiStub	A stub to allow clients to do asynchronous rpc calls to service HStreamApi.

Field Summary

Fields

Modifier and Type	Field	Description
static String	SERVICE_NAME

Method Summary

Modifier and Type	Method	Description
static io.grpc.ServerServiceDefinition	bindService(HStreamApiGrpc.AsyncService service)
static io.grpc.MethodDescriptor<AlterConnectorConfigRequest,com.google.protobuf.Empty>	getAlterConnectorConfigMethod()
static io.grpc.MethodDescriptor<AppendRequest,AppendResponse>	getAppendMethod()
static io.grpc.MethodDescriptor<CheckSubscriptionExistRequest,CheckSubscriptionExistResponse>	getCheckSubscriptionExistMethod()
static io.grpc.MethodDescriptor<CreateConnectorRequest,Connector>	getCreateConnectorMethod()
static io.grpc.MethodDescriptor<CreateQueryRequest,Query>	getCreateQueryMethod()
static io.grpc.MethodDescriptor<CreateQueryWithNamespaceRequest,Query>	getCreateQueryWithNamespaceMethod()
static io.grpc.MethodDescriptor<CreateShardReaderRequest,CreateShardReaderResponse>	getCreateShardReaderMethod()
static io.grpc.MethodDescriptor<Stream,Stream>	getCreateStreamMethod()
static io.grpc.MethodDescriptor<Subscription,Subscription>	getCreateSubscriptionMethod()
static io.grpc.MethodDescriptor<DeleteConnectorRequest,com.google.protobuf.Empty>	getDeleteConnectorMethod()
static io.grpc.MethodDescriptor<DeleteQueryRequest,com.google.protobuf.Empty>	getDeleteQueryMethod()
static io.grpc.MethodDescriptor<DeleteShardReaderRequest,com.google.protobuf.Empty>	getDeleteShardReaderMethod()
static io.grpc.MethodDescriptor<DeleteStreamRequest,com.google.protobuf.Empty>	getDeleteStreamMethod()
static io.grpc.MethodDescriptor<DeleteSubscriptionRequest,com.google.protobuf.Empty>	getDeleteSubscriptionMethod()
static io.grpc.MethodDescriptor<DeleteViewRequest,com.google.protobuf.Empty>	getDeleteViewMethod()
static io.grpc.MethodDescriptor<com.google.protobuf.Empty,DescribeClusterResponse>	getDescribeClusterMethod()
static io.grpc.MethodDescriptor<EchoRequest,EchoResponse>	getEchoMethod()
static io.grpc.MethodDescriptor<CommandQuery,CommandQueryResponse>	getExecuteQueryMethod()
static io.grpc.MethodDescriptor<ExecuteViewQueryRequest,ExecuteViewQueryResponse>	getExecuteViewQueryMethod()
static io.grpc.MethodDescriptor<ExecuteViewQueryWithNamespaceRequest,ExecuteViewQueryResponse>	getExecuteViewQueryWithNamespaceMethod()
static io.grpc.MethodDescriptor<GetConnectorLogsRequest,GetConnectorLogsResponse>	getGetConnectorLogsMethod()
static io.grpc.MethodDescriptor<GetConnectorRequest,Connector>	getGetConnectorMethod()
static io.grpc.MethodDescriptor<GetConnectorSpecRequest,GetConnectorSpecResponse>	getGetConnectorSpecMethod()
static io.grpc.MethodDescriptor<GetQueryRequest,Query>	getGetQueryMethod()
static io.grpc.MethodDescriptor<GetSchemaRequest,Schema>	getGetSchemaMethod()
static io.grpc.MethodDescriptor<GetStatsRequest,GetStatsResponse>	getGetStatsMethod()
static io.grpc.MethodDescriptor<GetStreamRequest,GetStreamResponse>	getGetStreamMethod()
static io.grpc.MethodDescriptor<GetSubscriptionRequest,GetSubscriptionResponse>	getGetSubscriptionMethod()
static io.grpc.MethodDescriptor<GetTailRecordIdRequest,GetTailRecordIdResponse>	getGetTailRecordIdMethod()
static io.grpc.MethodDescriptor<GetViewRequest,View>	getGetViewMethod()
static io.grpc.MethodDescriptor<ListConnectorsRequest,ListConnectorsResponse>	getListConnectorsMethod()
static io.grpc.MethodDescriptor<ListConsumersRequest,ListConsumersResponse>	getListConsumersMethod()
static io.grpc.MethodDescriptor<ListQueriesRequest,ListQueriesResponse>	getListQueriesMethod()
static io.grpc.MethodDescriptor<ListShardReadersRequest,ListShardReadersResponse>	getListShardReadersMethod()
static io.grpc.MethodDescriptor<ListShardsRequest,ListShardsResponse>	getListShardsMethod()
static io.grpc.MethodDescriptor<ListStreamsRequest,ListStreamsResponse>	getListStreamsMethod()
static io.grpc.MethodDescriptor<ListStreamsWithPrefixRequest,ListStreamsResponse>	getListStreamsWithPrefixMethod()
static io.grpc.MethodDescriptor<ListSubscriptionsRequest,ListSubscriptionsResponse>	getListSubscriptionsMethod()
static io.grpc.MethodDescriptor<ListSubscriptionsWithPrefixRequest,ListSubscriptionsResponse>	getListSubscriptionsWithPrefixMethod()
static io.grpc.MethodDescriptor<ListViewsRequest,ListViewsResponse>	getListViewsMethod()
static io.grpc.MethodDescriptor<LookupKeyRequest,ServerNode>	getLookupKeyMethod()
static io.grpc.MethodDescriptor<LookupResourceRequest,ServerNode>	getLookupResourceMethod()
static io.grpc.MethodDescriptor<LookupShardRequest,LookupShardResponse>	getLookupShardMethod()
static io.grpc.MethodDescriptor<LookupShardReaderRequest,LookupShardReaderResponse>	getLookupShardReaderMethod()
static io.grpc.MethodDescriptor<LookupSubscriptionRequest,LookupSubscriptionResponse>	getLookupSubscriptionMethod()
static io.grpc.MethodDescriptor<ParseSqlRequest,ParseSqlResponse>	getParseSqlMethod()
static io.grpc.MethodDescriptor<PauseConnectorRequest,com.google.protobuf.Empty>	getPauseConnectorMethod()
static io.grpc.MethodDescriptor<PauseQueryRequest,com.google.protobuf.Empty>	getPauseQueryMethod()
static io.grpc.MethodDescriptor<PerStreamTimeSeriesStatsAllRequest,PerStreamTimeSeriesStatsAllResponse>	getPerStreamTimeSeriesStatsAllMethod()
static io.grpc.MethodDescriptor<PerStreamTimeSeriesStatsRequest,PerStreamTimeSeriesStatsResponse>	getPerStreamTimeSeriesStatsMethod()
static io.grpc.MethodDescriptor<ReadShardRequest,ReadShardResponse>	getReadShardMethod()
static io.grpc.MethodDescriptor<ReadShardStreamRequest,ReadShardStreamResponse>	getReadShardStreamMethod()
static io.grpc.MethodDescriptor<ReadSingleShardStreamRequest,ReadSingleShardStreamResponse>	getReadSingleShardStreamMethod()
static io.grpc.MethodDescriptor<ReadStreamByKeyRequest,ReadStreamByKeyResponse>	getReadStreamByKeyMethod()
static io.grpc.MethodDescriptor<ReadStreamRequest,ReadStreamResponse>	getReadStreamMethod()
static io.grpc.MethodDescriptor<Schema,com.google.protobuf.Empty>	getRegisterSchemaMethod()
static io.grpc.MethodDescriptor<ResumeConnectorRequest,com.google.protobuf.Empty>	getResumeConnectorMethod()
static io.grpc.MethodDescriptor<ResumeQueryRequest,com.google.protobuf.Empty>	getResumeQueryMethod()
static io.grpc.MethodDescriptor<AdminCommandRequest,AdminCommandResponse>	getSendAdminCommandMethod()
static io.grpc.ServiceDescriptor	getServiceDescriptor()
static io.grpc.MethodDescriptor<StreamingFetchRequest,StreamingFetchResponse>	getStreamingFetchMethod()
static io.grpc.MethodDescriptor<TerminateQueryRequest,com.google.protobuf.Empty>	getTerminateQueryMethod()
static io.grpc.MethodDescriptor<TrimShardRequest,com.google.protobuf.Empty>	getTrimShardMethod()
static io.grpc.MethodDescriptor<TrimShardsRequest,TrimShardsResponse>	getTrimShardsMethod()
static io.grpc.MethodDescriptor<TrimStreamRequest,com.google.protobuf.Empty>	getTrimStreamMethod()
static io.grpc.MethodDescriptor<UnregisterSchemaRequest,com.google.protobuf.Empty>	getUnregisterSchemaMethod()
static HStreamApiGrpc.HStreamApiBlockingStub	newBlockingStub(io.grpc.Channel channel)	Creates a new blocking-style stub that supports unary and streaming output calls on the service
static HStreamApiGrpc.HStreamApiFutureStub	newFutureStub(io.grpc.Channel channel)	Creates a new ListenableFuture-style stub that supports unary calls on the service
static HStreamApiGrpc.HStreamApiStub	newStub(io.grpc.Channel channel)	Creates a new async stub that supports all call types for the service

Methods inherited from class java.lang.Object

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

Field Detail

SERVICE_NAME

public static final String SERVICE_NAME

See Also:

Constant Field Values

Method Detail

getEchoMethod

public static io.grpc.MethodDescriptor<EchoRequest,EchoResponse> getEchoMethod()

getCreateStreamMethod

public static io.grpc.MethodDescriptor<Stream,Stream> getCreateStreamMethod()

getDeleteStreamMethod

public static io.grpc.MethodDescriptor<DeleteStreamRequest,com.google.protobuf.Empty> getDeleteStreamMethod()

getTrimStreamMethod

public static io.grpc.MethodDescriptor<TrimStreamRequest,com.google.protobuf.Empty> getTrimStreamMethod()

getTrimShardsMethod

public static io.grpc.MethodDescriptor<TrimShardsRequest,TrimShardsResponse> getTrimShardsMethod()

getGetStreamMethod

public static io.grpc.MethodDescriptor<GetStreamRequest,GetStreamResponse> getGetStreamMethod()

getListStreamsMethod

public static io.grpc.MethodDescriptor<ListStreamsRequest,ListStreamsResponse> getListStreamsMethod()

getListStreamsWithPrefixMethod

public static io.grpc.MethodDescriptor<ListStreamsWithPrefixRequest,ListStreamsResponse> getListStreamsWithPrefixMethod()

getLookupShardMethod

public static io.grpc.MethodDescriptor<LookupShardRequest,LookupShardResponse> getLookupShardMethod()

getAppendMethod

public static io.grpc.MethodDescriptor<AppendRequest,AppendResponse> getAppendMethod()

getGetTailRecordIdMethod

public static io.grpc.MethodDescriptor<GetTailRecordIdRequest,GetTailRecordIdResponse> getGetTailRecordIdMethod()

getListShardsMethod

public static io.grpc.MethodDescriptor<ListShardsRequest,ListShardsResponse> getListShardsMethod()

getTrimShardMethod

public static io.grpc.MethodDescriptor<TrimShardRequest,com.google.protobuf.Empty> getTrimShardMethod()

getCreateShardReaderMethod

public static io.grpc.MethodDescriptor<CreateShardReaderRequest,CreateShardReaderResponse> getCreateShardReaderMethod()

getLookupShardReaderMethod

public static io.grpc.MethodDescriptor<LookupShardReaderRequest,LookupShardReaderResponse> getLookupShardReaderMethod()

getReadShardMethod

public static io.grpc.MethodDescriptor<ReadShardRequest,ReadShardResponse> getReadShardMethod()

getReadShardStreamMethod

public static io.grpc.MethodDescriptor<ReadShardStreamRequest,ReadShardStreamResponse> getReadShardStreamMethod()

getListShardReadersMethod

public static io.grpc.MethodDescriptor<ListShardReadersRequest,ListShardReadersResponse> getListShardReadersMethod()

getDeleteShardReaderMethod

public static io.grpc.MethodDescriptor<DeleteShardReaderRequest,com.google.protobuf.Empty> getDeleteShardReaderMethod()

getReadStreamMethod

public static io.grpc.MethodDescriptor<ReadStreamRequest,ReadStreamResponse> getReadStreamMethod()

getReadSingleShardStreamMethod

public static io.grpc.MethodDescriptor<ReadSingleShardStreamRequest,ReadSingleShardStreamResponse> getReadSingleShardStreamMethod()

getReadStreamByKeyMethod

public static io.grpc.MethodDescriptor<ReadStreamByKeyRequest,ReadStreamByKeyResponse> getReadStreamByKeyMethod()

getCreateSubscriptionMethod

public static io.grpc.MethodDescriptor<Subscription,Subscription> getCreateSubscriptionMethod()

getGetSubscriptionMethod

public static io.grpc.MethodDescriptor<GetSubscriptionRequest,GetSubscriptionResponse> getGetSubscriptionMethod()

getListSubscriptionsMethod

public static io.grpc.MethodDescriptor<ListSubscriptionsRequest,ListSubscriptionsResponse> getListSubscriptionsMethod()

getListSubscriptionsWithPrefixMethod

public static io.grpc.MethodDescriptor<ListSubscriptionsWithPrefixRequest,ListSubscriptionsResponse> getListSubscriptionsWithPrefixMethod()

getListConsumersMethod

public static io.grpc.MethodDescriptor<ListConsumersRequest,ListConsumersResponse> getListConsumersMethod()

getCheckSubscriptionExistMethod

public static io.grpc.MethodDescriptor<CheckSubscriptionExistRequest,CheckSubscriptionExistResponse> getCheckSubscriptionExistMethod()

getDeleteSubscriptionMethod

public static io.grpc.MethodDescriptor<DeleteSubscriptionRequest,com.google.protobuf.Empty> getDeleteSubscriptionMethod()

getLookupSubscriptionMethod

public static io.grpc.MethodDescriptor<LookupSubscriptionRequest,LookupSubscriptionResponse> getLookupSubscriptionMethod()

getStreamingFetchMethod

public static io.grpc.MethodDescriptor<StreamingFetchRequest,StreamingFetchResponse> getStreamingFetchMethod()

getDescribeClusterMethod

public static io.grpc.MethodDescriptor<com.google.protobuf.Empty,DescribeClusterResponse> getDescribeClusterMethod()

getLookupResourceMethod

public static io.grpc.MethodDescriptor<LookupResourceRequest,ServerNode> getLookupResourceMethod()

getLookupKeyMethod

public static io.grpc.MethodDescriptor<LookupKeyRequest,ServerNode> getLookupKeyMethod()

getSendAdminCommandMethod

public static io.grpc.MethodDescriptor<AdminCommandRequest,AdminCommandResponse> getSendAdminCommandMethod()

getPerStreamTimeSeriesStatsMethod

public static io.grpc.MethodDescriptor<PerStreamTimeSeriesStatsRequest,PerStreamTimeSeriesStatsResponse> getPerStreamTimeSeriesStatsMethod()

getPerStreamTimeSeriesStatsAllMethod

public static io.grpc.MethodDescriptor<PerStreamTimeSeriesStatsAllRequest,PerStreamTimeSeriesStatsAllResponse> getPerStreamTimeSeriesStatsAllMethod()

getGetStatsMethod

public static io.grpc.MethodDescriptor<GetStatsRequest,GetStatsResponse> getGetStatsMethod()

getExecuteQueryMethod

public static io.grpc.MethodDescriptor<CommandQuery,CommandQueryResponse> getExecuteQueryMethod()

getCreateQueryMethod

public static io.grpc.MethodDescriptor<CreateQueryRequest,Query> getCreateQueryMethod()

getCreateQueryWithNamespaceMethod

public static io.grpc.MethodDescriptor<CreateQueryWithNamespaceRequest,Query> getCreateQueryWithNamespaceMethod()

getListQueriesMethod

public static io.grpc.MethodDescriptor<ListQueriesRequest,ListQueriesResponse> getListQueriesMethod()

getGetQueryMethod

public static io.grpc.MethodDescriptor<GetQueryRequest,Query> getGetQueryMethod()

getTerminateQueryMethod

public static io.grpc.MethodDescriptor<TerminateQueryRequest,com.google.protobuf.Empty> getTerminateQueryMethod()

getDeleteQueryMethod

public static io.grpc.MethodDescriptor<DeleteQueryRequest,com.google.protobuf.Empty> getDeleteQueryMethod()

getResumeQueryMethod

public static io.grpc.MethodDescriptor<ResumeQueryRequest,com.google.protobuf.Empty> getResumeQueryMethod()

getPauseQueryMethod

public static io.grpc.MethodDescriptor<PauseQueryRequest,com.google.protobuf.Empty> getPauseQueryMethod()

getParseSqlMethod

public static io.grpc.MethodDescriptor<ParseSqlRequest,ParseSqlResponse> getParseSqlMethod()

getRegisterSchemaMethod

public static io.grpc.MethodDescriptor<Schema,com.google.protobuf.Empty> getRegisterSchemaMethod()

getGetSchemaMethod

public static io.grpc.MethodDescriptor<GetSchemaRequest,Schema> getGetSchemaMethod()

getUnregisterSchemaMethod

public static io.grpc.MethodDescriptor<UnregisterSchemaRequest,com.google.protobuf.Empty> getUnregisterSchemaMethod()

getCreateConnectorMethod

public static io.grpc.MethodDescriptor<CreateConnectorRequest,Connector> getCreateConnectorMethod()

getListConnectorsMethod

public static io.grpc.MethodDescriptor<ListConnectorsRequest,ListConnectorsResponse> getListConnectorsMethod()

getGetConnectorMethod

public static io.grpc.MethodDescriptor<GetConnectorRequest,Connector> getGetConnectorMethod()

getGetConnectorSpecMethod

public static io.grpc.MethodDescriptor<GetConnectorSpecRequest,GetConnectorSpecResponse> getGetConnectorSpecMethod()

getGetConnectorLogsMethod

public static io.grpc.MethodDescriptor<GetConnectorLogsRequest,GetConnectorLogsResponse> getGetConnectorLogsMethod()

getDeleteConnectorMethod

public static io.grpc.MethodDescriptor<DeleteConnectorRequest,com.google.protobuf.Empty> getDeleteConnectorMethod()

getPauseConnectorMethod

public static io.grpc.MethodDescriptor<PauseConnectorRequest,com.google.protobuf.Empty> getPauseConnectorMethod()

getResumeConnectorMethod

public static io.grpc.MethodDescriptor<ResumeConnectorRequest,com.google.protobuf.Empty> getResumeConnectorMethod()

getAlterConnectorConfigMethod

public static io.grpc.MethodDescriptor<AlterConnectorConfigRequest,com.google.protobuf.Empty> getAlterConnectorConfigMethod()

getListViewsMethod

public static io.grpc.MethodDescriptor<ListViewsRequest,ListViewsResponse> getListViewsMethod()

getGetViewMethod

public static io.grpc.MethodDescriptor<GetViewRequest,View> getGetViewMethod()

getDeleteViewMethod

public static io.grpc.MethodDescriptor<DeleteViewRequest,com.google.protobuf.Empty> getDeleteViewMethod()

getExecuteViewQueryMethod

public static io.grpc.MethodDescriptor<ExecuteViewQueryRequest,ExecuteViewQueryResponse> getExecuteViewQueryMethod()

getExecuteViewQueryWithNamespaceMethod

public static io.grpc.MethodDescriptor<ExecuteViewQueryWithNamespaceRequest,ExecuteViewQueryResponse> getExecuteViewQueryWithNamespaceMethod()

newStub

public static HStreamApiGrpc.HStreamApiStub newStub(io.grpc.Channel channel)

Creates a new async stub that supports all call types for the service

newBlockingStub

public static HStreamApiGrpc.HStreamApiBlockingStub newBlockingStub(io.grpc.Channel channel)

Creates a new blocking-style stub that supports unary and streaming output calls on the service

newFutureStub

public static HStreamApiGrpc.HStreamApiFutureStub newFutureStub(io.grpc.Channel channel)

Creates a new ListenableFuture-style stub that supports unary calls on the service

bindService

public static final io.grpc.ServerServiceDefinition bindService(HStreamApiGrpc.AsyncService service)

getServiceDescriptor

public static io.grpc.ServiceDescriptor getServiceDescriptor()