Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterRateLimitQuotaServiceServer(s grpc.ServiceRegistrar, srv RateLimitQuotaServiceServer)
- type RateLimitQuotaServiceClient
- type RateLimitQuotaServiceServer
- type RateLimitQuotaService_StreamRateLimitQuotasClient
- type RateLimitQuotaService_StreamRateLimitQuotasServer
- type UnimplementedRateLimitQuotaServiceServer
- type UnsafeRateLimitQuotaServiceServer
Constants ¶
const (
RateLimitQuotaService_StreamRateLimitQuotas_FullMethodName = "/envoy.service.rate_limit_quota.v3.RateLimitQuotaService/StreamRateLimitQuotas"
)
Variables ¶
var RateLimitQuotaService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "envoy.service.rate_limit_quota.v3.RateLimitQuotaService", HandlerType: (*RateLimitQuotaServiceServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "StreamRateLimitQuotas", Handler: _RateLimitQuotaService_StreamRateLimitQuotas_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "envoy/service/rate_limit_quota/v3/rlqs.proto", }
RateLimitQuotaService_ServiceDesc is the grpc.ServiceDesc for RateLimitQuotaService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterRateLimitQuotaServiceServer ¶
func RegisterRateLimitQuotaServiceServer(s grpc.ServiceRegistrar, srv RateLimitQuotaServiceServer)
Types ¶
type RateLimitQuotaServiceClient ¶
type RateLimitQuotaServiceClient interface { // Main communication channel: the data plane sends usage reports to the RLQS server, // and the server asynchronously responding with the assignments. StreamRateLimitQuotas(ctx context.Context, opts ...grpc.CallOption) (RateLimitQuotaService_StreamRateLimitQuotasClient, error) }
RateLimitQuotaServiceClient is the client API for RateLimitQuotaService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewRateLimitQuotaServiceClient ¶
func NewRateLimitQuotaServiceClient(cc grpc.ClientConnInterface) RateLimitQuotaServiceClient
type RateLimitQuotaServiceServer ¶
type RateLimitQuotaServiceServer interface { // Main communication channel: the data plane sends usage reports to the RLQS server, // and the server asynchronously responding with the assignments. StreamRateLimitQuotas(RateLimitQuotaService_StreamRateLimitQuotasServer) error }
RateLimitQuotaServiceServer is the server API for RateLimitQuotaService service. All implementations should embed UnimplementedRateLimitQuotaServiceServer for forward compatibility
type RateLimitQuotaService_StreamRateLimitQuotasClient ¶
type RateLimitQuotaService_StreamRateLimitQuotasClient interface { Send(*v3.RateLimitQuotaUsageReports) error Recv() (*v3.RateLimitQuotaResponse, error) grpc.ClientStream }
type RateLimitQuotaService_StreamRateLimitQuotasServer ¶
type RateLimitQuotaService_StreamRateLimitQuotasServer interface { Send(*v3.RateLimitQuotaResponse) error Recv() (*v3.RateLimitQuotaUsageReports, error) grpc.ServerStream }
type UnimplementedRateLimitQuotaServiceServer ¶
type UnimplementedRateLimitQuotaServiceServer struct { }
UnimplementedRateLimitQuotaServiceServer should be embedded to have forward compatible implementations.
func (UnimplementedRateLimitQuotaServiceServer) StreamRateLimitQuotas ¶
func (UnimplementedRateLimitQuotaServiceServer) StreamRateLimitQuotas(RateLimitQuotaService_StreamRateLimitQuotasServer) error
type UnsafeRateLimitQuotaServiceServer ¶
type UnsafeRateLimitQuotaServiceServer interface {
// contains filtered or unexported methods
}
UnsafeRateLimitQuotaServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RateLimitQuotaServiceServer will result in compilation errors.