// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
// versions:
// - protoc-gen-go-grpc v1.3.0
// - protoc             v3.20.2
// source: pkg/tidbworker/proto/scaler.proto

package scaler

import (
	context "context"
	grpc "google.golang.org/grpc"
	codes "google.golang.org/grpc/codes"
	status "google.golang.org/grpc/status"
)

// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
// Requires gRPC-Go v1.32.0 or later.
const _ = grpc.SupportPackageIsVersion7

const (
	Scaler_Ping_FullMethodName                = "/Scaler/Ping"
	Scaler_RegisterGC_FullMethodName          = "/Scaler/RegisterGC"
	Scaler_RecycleGC_FullMethodName           = "/Scaler/RecycleGC"
	Scaler_RegisterGCV2_FullMethodName        = "/Scaler/RegisterGCV2"
	Scaler_RecycleGCV2_FullMethodName         = "/Scaler/RecycleGCV2"
	Scaler_UpdateGCLifeTime_FullMethodName    = "/Scaler/UpdateGCLifeTime"
	Scaler_GetBgTaskConfig_FullMethodName     = "/Scaler/GetBgTaskConfig"
	Scaler_RegisterBgTask_FullMethodName      = "/Scaler/RegisterBgTask"
	Scaler_RecycleBgTask_FullMethodName       = "/Scaler/RecycleBgTask"
	Scaler_UpdateBgTaskExecID_FullMethodName  = "/Scaler/UpdateBgTaskExecID"
	Scaler_RegisterRemoteQuery_FullMethodName = "/Scaler/RegisterRemoteQuery"
	Scaler_RegisterTTLTask_FullMethodName     = "/Scaler/RegisterTTLTask"
	Scaler_DeleteTTLTableInfo_FullMethodName  = "/Scaler/DeleteTTLTableInfo"
	Scaler_RecycleTTLTask_FullMethodName      = "/Scaler/RecycleTTLTask"
	Scaler_UpdateTTLJobEnable_FullMethodName  = "/Scaler/UpdateTTLJobEnable"
	Scaler_RegisterAutoAnalyze_FullMethodName = "/Scaler/RegisterAutoAnalyze"
	Scaler_RecycleAutoAnalyze_FullMethodName  = "/Scaler/RecycleAutoAnalyze"
)

// ScalerClient is the client API for Scaler 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.
type ScalerClient interface {
	// Ping checks if the manager is operating normally.
	Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*Response, error)
	// RegisterGC notifies the manager that a GC task has been registered at deletionTs.
	RegisterGC(ctx context.Context, in *RegisterGCRequest, opts ...grpc.CallOption) (*Response, error)
	// RecycleGC notifies the manager that all GC tasks at or before safePoint have been completed.
	RecycleGC(ctx context.Context, in *RecycleGCRequest, opts ...grpc.CallOption) (*Response, error)
	// RegisterGCV2 notifies the manager that a round of GC at safePoint has just been completed.
	// If no more heartbeats are received, a new round of GC should be scheduled after gcLifeTime.
	RegisterGCV2(ctx context.Context, in *RegisterGCV2Request, opts ...grpc.CallOption) (*Response, error)
	// RecycleGCV2 notifies the manager that all GC tasks at or before safePoint have been completed.
	RecycleGCV2(ctx context.Context, in *RecycleGCV2Request, opts ...grpc.CallOption) (*Response, error)
	// UpdateGCLifeTime notifies the manager that the user's GCLifeTime setting has been updated.
	UpdateGCLifeTime(ctx context.Context, in *UpdateGCLifeTimeRequest, opts ...grpc.CallOption) (*Response, error)
	// GetBgTaskConfig retrieves the configuration of the background task.
	GetBgTaskConfig(ctx context.Context, in *GetBgTaskConfigRequest, opts ...grpc.CallOption) (*GetBgTaskConfigResponse, error)
	// RegisterBgTask notifies the manager that a background sub-task has been created.
	RegisterBgTask(ctx context.Context, in *RegisterBgTaskRequest, opts ...grpc.CallOption) (*Response, error)
	// RecycleBgTask notifies the manager that a background global task has been completed.
	RecycleBgTask(ctx context.Context, in *RecycleBgTaskRequest, opts ...grpc.CallOption) (*Response, error)
	// UpdateBgTaskExecID notifies the manager that the execID of a background task has been updated.
	UpdateBgTaskExecID(ctx context.Context, in *UpdateBgTaskExecIDRequest, opts ...grpc.CallOption) (*Response, error)
	// RegisterRemoteQuery notifies the manager that a query has been set to execute remotely.
	RegisterRemoteQuery(ctx context.Context, in *RegisterRemoteQueryRequest, opts ...grpc.CallOption) (*Response, error)
	// RegisterTTLTask notifies the manager that a table with TTL information has been created.
	RegisterTTLTask(ctx context.Context, in *RegisterTTLTaskRequest, opts ...grpc.CallOption) (*Response, error)
	// DeleteTTLTableInfo notifies the manager that a table no longer has TTL settings or has been dropped.
	DeleteTTLTableInfo(ctx context.Context, in *DeleteTTLTableInfoRequest, opts ...grpc.CallOption) (*Response, error)
	// RecycleTTLTask notifies the manager that a TTL task has been completed.
	RecycleTTLTask(ctx context.Context, in *RecycleTTLTaskRequest, opts ...grpc.CallOption) (*Response, error)
	// UpdateTTLJobEnable notifies the manager that the user's 'tidb_ttl_job_enable' variable has been updated.
	UpdateTTLJobEnable(ctx context.Context, in *UpdateTTLJobEnableRequest, opts ...grpc.CallOption) (*Response, error)
	// RegisterAutoAnalyze notifies the manager that an auto-analyze task has been registered.
	RegisterAutoAnalyze(ctx context.Context, in *RegisterAutoAnalyzeRequest, opts ...grpc.CallOption) (*Response, error)
	// RecycleAutoAnalyze notifies the manager that an auto-analyze task has been completed.
	RecycleAutoAnalyze(ctx context.Context, in *RecycleAutoAnalyzeRequest, opts ...grpc.CallOption) (*Response, error)
}

type scalerClient struct {
	cc grpc.ClientConnInterface
}

func NewScalerClient(cc grpc.ClientConnInterface) ScalerClient {
	return &scalerClient{cc}
}

func (c *scalerClient) Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*Response, error) {
	out := new(Response)
	err := c.cc.Invoke(ctx, Scaler_Ping_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *scalerClient) RegisterGC(ctx context.Context, in *RegisterGCRequest, opts ...grpc.CallOption) (*Response, error) {
	out := new(Response)
	err := c.cc.Invoke(ctx, Scaler_RegisterGC_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *scalerClient) RecycleGC(ctx context.Context, in *RecycleGCRequest, opts ...grpc.CallOption) (*Response, error) {
	out := new(Response)
	err := c.cc.Invoke(ctx, Scaler_RecycleGC_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *scalerClient) RegisterGCV2(ctx context.Context, in *RegisterGCV2Request, opts ...grpc.CallOption) (*Response, error) {
	out := new(Response)
	err := c.cc.Invoke(ctx, Scaler_RegisterGCV2_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *scalerClient) RecycleGCV2(ctx context.Context, in *RecycleGCV2Request, opts ...grpc.CallOption) (*Response, error) {
	out := new(Response)
	err := c.cc.Invoke(ctx, Scaler_RecycleGCV2_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *scalerClient) UpdateGCLifeTime(ctx context.Context, in *UpdateGCLifeTimeRequest, opts ...grpc.CallOption) (*Response, error) {
	out := new(Response)
	err := c.cc.Invoke(ctx, Scaler_UpdateGCLifeTime_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *scalerClient) GetBgTaskConfig(ctx context.Context, in *GetBgTaskConfigRequest, opts ...grpc.CallOption) (*GetBgTaskConfigResponse, error) {
	out := new(GetBgTaskConfigResponse)
	err := c.cc.Invoke(ctx, Scaler_GetBgTaskConfig_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *scalerClient) RegisterBgTask(ctx context.Context, in *RegisterBgTaskRequest, opts ...grpc.CallOption) (*Response, error) {
	out := new(Response)
	err := c.cc.Invoke(ctx, Scaler_RegisterBgTask_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *scalerClient) RecycleBgTask(ctx context.Context, in *RecycleBgTaskRequest, opts ...grpc.CallOption) (*Response, error) {
	out := new(Response)
	err := c.cc.Invoke(ctx, Scaler_RecycleBgTask_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *scalerClient) UpdateBgTaskExecID(ctx context.Context, in *UpdateBgTaskExecIDRequest, opts ...grpc.CallOption) (*Response, error) {
	out := new(Response)
	err := c.cc.Invoke(ctx, Scaler_UpdateBgTaskExecID_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *scalerClient) RegisterRemoteQuery(ctx context.Context, in *RegisterRemoteQueryRequest, opts ...grpc.CallOption) (*Response, error) {
	out := new(Response)
	err := c.cc.Invoke(ctx, Scaler_RegisterRemoteQuery_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *scalerClient) RegisterTTLTask(ctx context.Context, in *RegisterTTLTaskRequest, opts ...grpc.CallOption) (*Response, error) {
	out := new(Response)
	err := c.cc.Invoke(ctx, Scaler_RegisterTTLTask_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *scalerClient) DeleteTTLTableInfo(ctx context.Context, in *DeleteTTLTableInfoRequest, opts ...grpc.CallOption) (*Response, error) {
	out := new(Response)
	err := c.cc.Invoke(ctx, Scaler_DeleteTTLTableInfo_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *scalerClient) RecycleTTLTask(ctx context.Context, in *RecycleTTLTaskRequest, opts ...grpc.CallOption) (*Response, error) {
	out := new(Response)
	err := c.cc.Invoke(ctx, Scaler_RecycleTTLTask_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *scalerClient) UpdateTTLJobEnable(ctx context.Context, in *UpdateTTLJobEnableRequest, opts ...grpc.CallOption) (*Response, error) {
	out := new(Response)
	err := c.cc.Invoke(ctx, Scaler_UpdateTTLJobEnable_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *scalerClient) RegisterAutoAnalyze(ctx context.Context, in *RegisterAutoAnalyzeRequest, opts ...grpc.CallOption) (*Response, error) {
	out := new(Response)
	err := c.cc.Invoke(ctx, Scaler_RegisterAutoAnalyze_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *scalerClient) RecycleAutoAnalyze(ctx context.Context, in *RecycleAutoAnalyzeRequest, opts ...grpc.CallOption) (*Response, error) {
	out := new(Response)
	err := c.cc.Invoke(ctx, Scaler_RecycleAutoAnalyze_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

// ScalerServer is the server API for Scaler service.
// All implementations must embed UnimplementedScalerServer
// for forward compatibility
type ScalerServer interface {
	// Ping checks if the manager is operating normally.
	Ping(context.Context, *PingRequest) (*Response, error)
	// RegisterGC notifies the manager that a GC task has been registered at deletionTs.
	RegisterGC(context.Context, *RegisterGCRequest) (*Response, error)
	// RecycleGC notifies the manager that all GC tasks at or before safePoint have been completed.
	RecycleGC(context.Context, *RecycleGCRequest) (*Response, error)
	// RegisterGCV2 notifies the manager that a round of GC at safePoint has just been completed.
	// If no more heartbeats are received, a new round of GC should be scheduled after gcLifeTime.
	RegisterGCV2(context.Context, *RegisterGCV2Request) (*Response, error)
	// RecycleGCV2 notifies the manager that all GC tasks at or before safePoint have been completed.
	RecycleGCV2(context.Context, *RecycleGCV2Request) (*Response, error)
	// UpdateGCLifeTime notifies the manager that the user's GCLifeTime setting has been updated.
	UpdateGCLifeTime(context.Context, *UpdateGCLifeTimeRequest) (*Response, error)
	// GetBgTaskConfig retrieves the configuration of the background task.
	GetBgTaskConfig(context.Context, *GetBgTaskConfigRequest) (*GetBgTaskConfigResponse, error)
	// RegisterBgTask notifies the manager that a background sub-task has been created.
	RegisterBgTask(context.Context, *RegisterBgTaskRequest) (*Response, error)
	// RecycleBgTask notifies the manager that a background global task has been completed.
	RecycleBgTask(context.Context, *RecycleBgTaskRequest) (*Response, error)
	// UpdateBgTaskExecID notifies the manager that the execID of a background task has been updated.
	UpdateBgTaskExecID(context.Context, *UpdateBgTaskExecIDRequest) (*Response, error)
	// RegisterRemoteQuery notifies the manager that a query has been set to execute remotely.
	RegisterRemoteQuery(context.Context, *RegisterRemoteQueryRequest) (*Response, error)
	// RegisterTTLTask notifies the manager that a table with TTL information has been created.
	RegisterTTLTask(context.Context, *RegisterTTLTaskRequest) (*Response, error)
	// DeleteTTLTableInfo notifies the manager that a table no longer has TTL settings or has been dropped.
	DeleteTTLTableInfo(context.Context, *DeleteTTLTableInfoRequest) (*Response, error)
	// RecycleTTLTask notifies the manager that a TTL task has been completed.
	RecycleTTLTask(context.Context, *RecycleTTLTaskRequest) (*Response, error)
	// UpdateTTLJobEnable notifies the manager that the user's 'tidb_ttl_job_enable' variable has been updated.
	UpdateTTLJobEnable(context.Context, *UpdateTTLJobEnableRequest) (*Response, error)
	// RegisterAutoAnalyze notifies the manager that an auto-analyze task has been registered.
	RegisterAutoAnalyze(context.Context, *RegisterAutoAnalyzeRequest) (*Response, error)
	// RecycleAutoAnalyze notifies the manager that an auto-analyze task has been completed.
	RecycleAutoAnalyze(context.Context, *RecycleAutoAnalyzeRequest) (*Response, error)
	mustEmbedUnimplementedScalerServer()
}

// UnimplementedScalerServer must be embedded to have forward compatible implementations.
type UnimplementedScalerServer struct {
}

func (UnimplementedScalerServer) Ping(context.Context, *PingRequest) (*Response, error) {
	return nil, status.Errorf(codes.Unimplemented, "method Ping not implemented")
}
func (UnimplementedScalerServer) RegisterGC(context.Context, *RegisterGCRequest) (*Response, error) {
	return nil, status.Errorf(codes.Unimplemented, "method RegisterGC not implemented")
}
func (UnimplementedScalerServer) RecycleGC(context.Context, *RecycleGCRequest) (*Response, error) {
	return nil, status.Errorf(codes.Unimplemented, "method RecycleGC not implemented")
}
func (UnimplementedScalerServer) RegisterGCV2(context.Context, *RegisterGCV2Request) (*Response, error) {
	return nil, status.Errorf(codes.Unimplemented, "method RegisterGCV2 not implemented")
}
func (UnimplementedScalerServer) RecycleGCV2(context.Context, *RecycleGCV2Request) (*Response, error) {
	return nil, status.Errorf(codes.Unimplemented, "method RecycleGCV2 not implemented")
}
func (UnimplementedScalerServer) UpdateGCLifeTime(context.Context, *UpdateGCLifeTimeRequest) (*Response, error) {
	return nil, status.Errorf(codes.Unimplemented, "method UpdateGCLifeTime not implemented")
}
func (UnimplementedScalerServer) GetBgTaskConfig(context.Context, *GetBgTaskConfigRequest) (*GetBgTaskConfigResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetBgTaskConfig not implemented")
}
func (UnimplementedScalerServer) RegisterBgTask(context.Context, *RegisterBgTaskRequest) (*Response, error) {
	return nil, status.Errorf(codes.Unimplemented, "method RegisterBgTask not implemented")
}
func (UnimplementedScalerServer) RecycleBgTask(context.Context, *RecycleBgTaskRequest) (*Response, error) {
	return nil, status.Errorf(codes.Unimplemented, "method RecycleBgTask not implemented")
}
func (UnimplementedScalerServer) UpdateBgTaskExecID(context.Context, *UpdateBgTaskExecIDRequest) (*Response, error) {
	return nil, status.Errorf(codes.Unimplemented, "method UpdateBgTaskExecID not implemented")
}
func (UnimplementedScalerServer) RegisterRemoteQuery(context.Context, *RegisterRemoteQueryRequest) (*Response, error) {
	return nil, status.Errorf(codes.Unimplemented, "method RegisterRemoteQuery not implemented")
}
func (UnimplementedScalerServer) RegisterTTLTask(context.Context, *RegisterTTLTaskRequest) (*Response, error) {
	return nil, status.Errorf(codes.Unimplemented, "method RegisterTTLTask not implemented")
}
func (UnimplementedScalerServer) DeleteTTLTableInfo(context.Context, *DeleteTTLTableInfoRequest) (*Response, error) {
	return nil, status.Errorf(codes.Unimplemented, "method DeleteTTLTableInfo not implemented")
}
func (UnimplementedScalerServer) RecycleTTLTask(context.Context, *RecycleTTLTaskRequest) (*Response, error) {
	return nil, status.Errorf(codes.Unimplemented, "method RecycleTTLTask not implemented")
}
func (UnimplementedScalerServer) UpdateTTLJobEnable(context.Context, *UpdateTTLJobEnableRequest) (*Response, error) {
	return nil, status.Errorf(codes.Unimplemented, "method UpdateTTLJobEnable not implemented")
}
func (UnimplementedScalerServer) RegisterAutoAnalyze(context.Context, *RegisterAutoAnalyzeRequest) (*Response, error) {
	return nil, status.Errorf(codes.Unimplemented, "method RegisterAutoAnalyze not implemented")
}
func (UnimplementedScalerServer) RecycleAutoAnalyze(context.Context, *RecycleAutoAnalyzeRequest) (*Response, error) {
	return nil, status.Errorf(codes.Unimplemented, "method RecycleAutoAnalyze not implemented")
}
func (UnimplementedScalerServer) mustEmbedUnimplementedScalerServer() {}

// UnsafeScalerServer may be embedded to opt out of forward compatibility for this service.
// Use of this interface is not recommended, as added methods to ScalerServer will
// result in compilation errors.
type UnsafeScalerServer interface {
	mustEmbedUnimplementedScalerServer()
}

func RegisterScalerServer(s grpc.ServiceRegistrar, srv ScalerServer) {
	s.RegisterService(&Scaler_ServiceDesc, srv)
}

func _Scaler_Ping_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(PingRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ScalerServer).Ping(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: Scaler_Ping_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ScalerServer).Ping(ctx, req.(*PingRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _Scaler_RegisterGC_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(RegisterGCRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ScalerServer).RegisterGC(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: Scaler_RegisterGC_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ScalerServer).RegisterGC(ctx, req.(*RegisterGCRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _Scaler_RecycleGC_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(RecycleGCRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ScalerServer).RecycleGC(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: Scaler_RecycleGC_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ScalerServer).RecycleGC(ctx, req.(*RecycleGCRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _Scaler_RegisterGCV2_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(RegisterGCV2Request)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ScalerServer).RegisterGCV2(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: Scaler_RegisterGCV2_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ScalerServer).RegisterGCV2(ctx, req.(*RegisterGCV2Request))
	}
	return interceptor(ctx, in, info, handler)
}

func _Scaler_RecycleGCV2_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(RecycleGCV2Request)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ScalerServer).RecycleGCV2(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: Scaler_RecycleGCV2_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ScalerServer).RecycleGCV2(ctx, req.(*RecycleGCV2Request))
	}
	return interceptor(ctx, in, info, handler)
}

func _Scaler_UpdateGCLifeTime_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(UpdateGCLifeTimeRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ScalerServer).UpdateGCLifeTime(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: Scaler_UpdateGCLifeTime_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ScalerServer).UpdateGCLifeTime(ctx, req.(*UpdateGCLifeTimeRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _Scaler_GetBgTaskConfig_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetBgTaskConfigRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ScalerServer).GetBgTaskConfig(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: Scaler_GetBgTaskConfig_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ScalerServer).GetBgTaskConfig(ctx, req.(*GetBgTaskConfigRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _Scaler_RegisterBgTask_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(RegisterBgTaskRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ScalerServer).RegisterBgTask(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: Scaler_RegisterBgTask_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ScalerServer).RegisterBgTask(ctx, req.(*RegisterBgTaskRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _Scaler_RecycleBgTask_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(RecycleBgTaskRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ScalerServer).RecycleBgTask(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: Scaler_RecycleBgTask_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ScalerServer).RecycleBgTask(ctx, req.(*RecycleBgTaskRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _Scaler_UpdateBgTaskExecID_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(UpdateBgTaskExecIDRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ScalerServer).UpdateBgTaskExecID(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: Scaler_UpdateBgTaskExecID_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ScalerServer).UpdateBgTaskExecID(ctx, req.(*UpdateBgTaskExecIDRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _Scaler_RegisterRemoteQuery_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(RegisterRemoteQueryRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ScalerServer).RegisterRemoteQuery(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: Scaler_RegisterRemoteQuery_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ScalerServer).RegisterRemoteQuery(ctx, req.(*RegisterRemoteQueryRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _Scaler_RegisterTTLTask_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(RegisterTTLTaskRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ScalerServer).RegisterTTLTask(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: Scaler_RegisterTTLTask_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ScalerServer).RegisterTTLTask(ctx, req.(*RegisterTTLTaskRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _Scaler_DeleteTTLTableInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeleteTTLTableInfoRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ScalerServer).DeleteTTLTableInfo(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: Scaler_DeleteTTLTableInfo_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ScalerServer).DeleteTTLTableInfo(ctx, req.(*DeleteTTLTableInfoRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _Scaler_RecycleTTLTask_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(RecycleTTLTaskRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ScalerServer).RecycleTTLTask(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: Scaler_RecycleTTLTask_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ScalerServer).RecycleTTLTask(ctx, req.(*RecycleTTLTaskRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _Scaler_UpdateTTLJobEnable_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(UpdateTTLJobEnableRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ScalerServer).UpdateTTLJobEnable(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: Scaler_UpdateTTLJobEnable_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ScalerServer).UpdateTTLJobEnable(ctx, req.(*UpdateTTLJobEnableRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _Scaler_RegisterAutoAnalyze_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(RegisterAutoAnalyzeRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ScalerServer).RegisterAutoAnalyze(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: Scaler_RegisterAutoAnalyze_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ScalerServer).RegisterAutoAnalyze(ctx, req.(*RegisterAutoAnalyzeRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _Scaler_RecycleAutoAnalyze_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(RecycleAutoAnalyzeRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ScalerServer).RecycleAutoAnalyze(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: Scaler_RecycleAutoAnalyze_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ScalerServer).RecycleAutoAnalyze(ctx, req.(*RecycleAutoAnalyzeRequest))
	}
	return interceptor(ctx, in, info, handler)
}

// Scaler_ServiceDesc is the grpc.ServiceDesc for Scaler service.
// It's only intended for direct use with grpc.RegisterService,
// and not to be introspected or modified (even as a copy)
var Scaler_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "Scaler",
	HandlerType: (*ScalerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Ping",
			Handler:    _Scaler_Ping_Handler,
		},
		{
			MethodName: "RegisterGC",
			Handler:    _Scaler_RegisterGC_Handler,
		},
		{
			MethodName: "RecycleGC",
			Handler:    _Scaler_RecycleGC_Handler,
		},
		{
			MethodName: "RegisterGCV2",
			Handler:    _Scaler_RegisterGCV2_Handler,
		},
		{
			MethodName: "RecycleGCV2",
			Handler:    _Scaler_RecycleGCV2_Handler,
		},
		{
			MethodName: "UpdateGCLifeTime",
			Handler:    _Scaler_UpdateGCLifeTime_Handler,
		},
		{
			MethodName: "GetBgTaskConfig",
			Handler:    _Scaler_GetBgTaskConfig_Handler,
		},
		{
			MethodName: "RegisterBgTask",
			Handler:    _Scaler_RegisterBgTask_Handler,
		},
		{
			MethodName: "RecycleBgTask",
			Handler:    _Scaler_RecycleBgTask_Handler,
		},
		{
			MethodName: "UpdateBgTaskExecID",
			Handler:    _Scaler_UpdateBgTaskExecID_Handler,
		},
		{
			MethodName: "RegisterRemoteQuery",
			Handler:    _Scaler_RegisterRemoteQuery_Handler,
		},
		{
			MethodName: "RegisterTTLTask",
			Handler:    _Scaler_RegisterTTLTask_Handler,
		},
		{
			MethodName: "DeleteTTLTableInfo",
			Handler:    _Scaler_DeleteTTLTableInfo_Handler,
		},
		{
			MethodName: "RecycleTTLTask",
			Handler:    _Scaler_RecycleTTLTask_Handler,
		},
		{
			MethodName: "UpdateTTLJobEnable",
			Handler:    _Scaler_UpdateTTLJobEnable_Handler,
		},
		{
			MethodName: "RegisterAutoAnalyze",
			Handler:    _Scaler_RegisterAutoAnalyze_Handler,
		},
		{
			MethodName: "RecycleAutoAnalyze",
			Handler:    _Scaler_RecycleAutoAnalyze_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "pkg/tidbworker/proto/scaler.proto",
}