Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterThrottlerServer(s grpc.ServiceRegistrar, srv ThrottlerServer)
- type ThrottlerClient
- type ThrottlerServer
- type UnimplementedThrottlerServer
- func (UnimplementedThrottlerServer) GetConfiguration(context.Context, *v16.GetConfigurationRequest) (*v16.GetConfigurationResponse, error)
- func (UnimplementedThrottlerServer) MaxRates(context.Context, *v16.MaxRatesRequest) (*v16.MaxRatesResponse, error)
- func (UnimplementedThrottlerServer) ResetConfiguration(context.Context, *v16.ResetConfigurationRequest) (*v16.ResetConfigurationResponse, error)
- func (UnimplementedThrottlerServer) SetMaxRate(context.Context, *v16.SetMaxRateRequest) (*v16.SetMaxRateResponse, error)
- func (UnimplementedThrottlerServer) UpdateConfiguration(context.Context, *v16.UpdateConfigurationRequest) (*v16.UpdateConfigurationResponse, error)
- type UnsafeThrottlerServer
Constants ¶
const ( Throttler_MaxRates_FullMethodName = "/vitess.throttlerservice.v16.Throttler/MaxRates" Throttler_SetMaxRate_FullMethodName = "/vitess.throttlerservice.v16.Throttler/SetMaxRate" Throttler_GetConfiguration_FullMethodName = "/vitess.throttlerservice.v16.Throttler/GetConfiguration" Throttler_UpdateConfiguration_FullMethodName = "/vitess.throttlerservice.v16.Throttler/UpdateConfiguration" Throttler_ResetConfiguration_FullMethodName = "/vitess.throttlerservice.v16.Throttler/ResetConfiguration" )
Variables ¶
var Throttler_ServiceDesc = grpc.ServiceDesc{ ServiceName: "vitess.throttlerservice.v16.Throttler", HandlerType: (*ThrottlerServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "MaxRates", Handler: _Throttler_MaxRates_Handler, }, { MethodName: "SetMaxRate", Handler: _Throttler_SetMaxRate_Handler, }, { MethodName: "GetConfiguration", Handler: _Throttler_GetConfiguration_Handler, }, { MethodName: "UpdateConfiguration", Handler: _Throttler_UpdateConfiguration_Handler, }, { MethodName: "ResetConfiguration", Handler: _Throttler_ResetConfiguration_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "vitess/throttlerservice/v16/throttlerservice.proto", }
Throttler_ServiceDesc is the grpc.ServiceDesc for Throttler service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterThrottlerServer ¶
func RegisterThrottlerServer(s grpc.ServiceRegistrar, srv ThrottlerServer)
Types ¶
type ThrottlerClient ¶
type ThrottlerClient interface { // MaxRates returns the current max rate for each throttler of the process. MaxRates(ctx context.Context, in *v16.MaxRatesRequest, opts ...grpc.CallOption) (*v16.MaxRatesResponse, error) // SetMaxRate allows to change the current max rate for all throttlers // of the process. SetMaxRate(ctx context.Context, in *v16.SetMaxRateRequest, opts ...grpc.CallOption) (*v16.SetMaxRateResponse, error) // GetConfiguration returns the configuration of the MaxReplicationlag module // for the given throttler or all throttlers if "throttler_name" is empty. GetConfiguration(ctx context.Context, in *v16.GetConfigurationRequest, opts ...grpc.CallOption) (*v16.GetConfigurationResponse, error) // UpdateConfiguration (partially) updates the configuration of the // MaxReplicationlag module for the given throttler or all throttlers if // "throttler_name" is empty. // If "copy_zero_values" is true, fields with zero values will be copied // as well. UpdateConfiguration(ctx context.Context, in *v16.UpdateConfigurationRequest, opts ...grpc.CallOption) (*v16.UpdateConfigurationResponse, error) // ResetConfiguration resets the configuration of the MaxReplicationlag module // to the initial configuration for the given throttler or all throttlers if // "throttler_name" is empty. ResetConfiguration(ctx context.Context, in *v16.ResetConfigurationRequest, opts ...grpc.CallOption) (*v16.ResetConfigurationResponse, error) }
ThrottlerClient is the client API for Throttler 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 NewThrottlerClient ¶
func NewThrottlerClient(cc grpc.ClientConnInterface) ThrottlerClient
type ThrottlerServer ¶
type ThrottlerServer interface { // MaxRates returns the current max rate for each throttler of the process. MaxRates(context.Context, *v16.MaxRatesRequest) (*v16.MaxRatesResponse, error) // SetMaxRate allows to change the current max rate for all throttlers // of the process. SetMaxRate(context.Context, *v16.SetMaxRateRequest) (*v16.SetMaxRateResponse, error) // GetConfiguration returns the configuration of the MaxReplicationlag module // for the given throttler or all throttlers if "throttler_name" is empty. GetConfiguration(context.Context, *v16.GetConfigurationRequest) (*v16.GetConfigurationResponse, error) // UpdateConfiguration (partially) updates the configuration of the // MaxReplicationlag module for the given throttler or all throttlers if // "throttler_name" is empty. // If "copy_zero_values" is true, fields with zero values will be copied // as well. UpdateConfiguration(context.Context, *v16.UpdateConfigurationRequest) (*v16.UpdateConfigurationResponse, error) // ResetConfiguration resets the configuration of the MaxReplicationlag module // to the initial configuration for the given throttler or all throttlers if // "throttler_name" is empty. ResetConfiguration(context.Context, *v16.ResetConfigurationRequest) (*v16.ResetConfigurationResponse, error) }
ThrottlerServer is the server API for Throttler service. All implementations should embed UnimplementedThrottlerServer for forward compatibility
type UnimplementedThrottlerServer ¶
type UnimplementedThrottlerServer struct { }
UnimplementedThrottlerServer should be embedded to have forward compatible implementations.
func (UnimplementedThrottlerServer) GetConfiguration ¶
func (UnimplementedThrottlerServer) GetConfiguration(context.Context, *v16.GetConfigurationRequest) (*v16.GetConfigurationResponse, error)
func (UnimplementedThrottlerServer) MaxRates ¶
func (UnimplementedThrottlerServer) MaxRates(context.Context, *v16.MaxRatesRequest) (*v16.MaxRatesResponse, error)
func (UnimplementedThrottlerServer) ResetConfiguration ¶
func (UnimplementedThrottlerServer) ResetConfiguration(context.Context, *v16.ResetConfigurationRequest) (*v16.ResetConfigurationResponse, error)
func (UnimplementedThrottlerServer) SetMaxRate ¶
func (UnimplementedThrottlerServer) SetMaxRate(context.Context, *v16.SetMaxRateRequest) (*v16.SetMaxRateResponse, error)
func (UnimplementedThrottlerServer) UpdateConfiguration ¶
func (UnimplementedThrottlerServer) UpdateConfiguration(context.Context, *v16.UpdateConfigurationRequest) (*v16.UpdateConfigurationResponse, error)
type UnsafeThrottlerServer ¶
type UnsafeThrottlerServer interface {
// contains filtered or unexported methods
}
UnsafeThrottlerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ThrottlerServer will result in compilation errors.