public static final class ResourceMeteringPubSubGrpc.ResourceMeteringPubSubBlockingStub extends io.grpc.stub.AbstractBlockingStub<ResourceMeteringPubSubGrpc.ResourceMeteringPubSubBlockingStub>
TiKV implements ResourceMeteringPubSub service for clients to subscribe to resource metering records.
Modifier and Type | Method and Description |
---|---|
protected ResourceMeteringPubSubGrpc.ResourceMeteringPubSubBlockingStub |
build(io.grpc.Channel channel,
io.grpc.CallOptions callOptions) |
Iterator<ResourceUsageAgentOuterClass.ResourceUsageRecord> |
subscribe(ResourceUsageAgentOuterClass.ResourceMeteringRequest request)
Clients subscribe to resource metering records through this RPC, and TiKV periodically (e.g.
|
protected ResourceMeteringPubSubGrpc.ResourceMeteringPubSubBlockingStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
build
in class io.grpc.stub.AbstractStub<ResourceMeteringPubSubGrpc.ResourceMeteringPubSubBlockingStub>
public Iterator<ResourceUsageAgentOuterClass.ResourceUsageRecord> subscribe(ResourceUsageAgentOuterClass.ResourceMeteringRequest request)
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.
Copyright © 2024 PingCAP. All rights reserved.