org.tikv.kvproto

Interface ResourceMeteringPubSubGrpc.AsyncService

All Known Implementing Classes:

ResourceMeteringPubSubGrpc.ResourceMeteringPubSubImplBase

Enclosing class:

ResourceMeteringPubSubGrpc

public static interface ResourceMeteringPubSubGrpc.AsyncService

 TiKV implements ResourceMeteringPubSub service for clients to subscribe to resource metering records.
 

Method Summary

Modifier and Type	Method and Description
default void	subscribe(ResourceUsageAgentOuterClass.ResourceMeteringRequest request, io.grpc.stub.StreamObserver<ResourceUsageAgentOuterClass.ResourceUsageRecord> responseObserver) Clients subscribe to resource metering records through this RPC, and TiKV periodically (e.g.

Method Detail

subscribe

default void subscribe(ResourceUsageAgentOuterClass.ResourceMeteringRequest request,
                       io.grpc.stub.StreamObserver<ResourceUsageAgentOuterClass.ResourceUsageRecord> responseObserver)

 Clients subscribe to resource metering records through this RPC, and TiKV periodically (e.g. per minute)
 publishes resource metering records to clients via gRPC stream.