// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
// versions:
// - protoc-gen-go-grpc v1.3.0
// - protoc             (unknown)
// source: agent/agent.proto

package agent

import (
	context "context"
	grpc "google.golang.org/grpc"
	codes "google.golang.org/grpc/codes"
	status "google.golang.org/grpc/status"
	emptypb "google.golang.org/protobuf/types/known/emptypb"
)

// 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 (
	AgentService_PrecheckImportJob_FullMethodName      = "/agent.AgentService/PrecheckImportJob"
	AgentService_CheckS3Access_FullMethodName          = "/agent.AgentService/CheckS3Access"
	AgentService_CheckGcsAccess_FullMethodName         = "/agent.AgentService/CheckGcsAccess"
	AgentService_CheckAzblobAccess_FullMethodName      = "/agent.AgentService/CheckAzblobAccess"
	AgentService_LightningPrecheck_FullMethodName      = "/agent.AgentService/LightningPrecheck"
	AgentService_ExecSQLOnCluster_FullMethodName       = "/agent.AgentService/ExecSQLOnCluster"
	AgentService_LoadDataToCluster_FullMethodName      = "/agent.AgentService/LoadDataToCluster"
	AgentService_GetImportSchemasMeta_FullMethodName   = "/agent.AgentService/GetImportSchemasMeta"
	AgentService_LightningSourcePreview_FullMethodName = "/agent.AgentService/LightningSourcePreview"
	AgentService_EstimateSourceDataSize_FullMethodName = "/agent.AgentService/EstimateSourceDataSize"
	AgentService_CheckDBConnectivity_FullMethodName    = "/agent.AgentService/CheckDBConnectivity"
	AgentService_GetTiDBServerSecret_FullMethodName    = "/agent.AgentService/GetTiDBServerSecret"
	AgentService_GetClusterClientSecret_FullMethodName = "/agent.AgentService/GetClusterClientSecret"
	AgentService_PrecheckDMJob_FullMethodName          = "/agent.AgentService/PrecheckDMJob"
	AgentService_GetUserFileContent_FullMethodName     = "/agent.AgentService/GetUserFileContent"
	AgentService_GetSourceTables_FullMethodName        = "/agent.AgentService/GetSourceTables"
	AgentService_GetSourceBinlogStatus_FullMethodName  = "/agent.AgentService/GetSourceBinlogStatus"
	AgentService_GetClusterTables_FullMethodName       = "/agent.AgentService/GetClusterTables"
	AgentService_NsLookup_FullMethodName               = "/agent.AgentService/NsLookup"
	AgentService_ClearEmptyTables_FullMethodName       = "/agent.AgentService/ClearEmptyTables"
	AgentService_SearchImportFiles_FullMethodName      = "/agent.AgentService/SearchImportFiles"
	AgentService_GetImportFiles_FullMethodName         = "/agent.AgentService/GetImportFiles"
	AgentService_CreateSchemas_FullMethodName          = "/agent.AgentService/CreateSchemas"
	AgentService_PreviewCsvFile_FullMethodName         = "/agent.AgentService/PreviewCsvFile"
	AgentService_PrecheckImportFile_FullMethodName     = "/agent.AgentService/PrecheckImportFile"
	AgentService_DropClusterTables_FullMethodName      = "/agent.AgentService/DropClusterTables"
	AgentService_GetPublicKey_FullMethodName           = "/agent.AgentService/GetPublicKey"
)

// AgentServiceClient is the client API for AgentService 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 AgentServiceClient interface {
	// Precheck and return the scan result.
	PrecheckImportJob(ctx context.Context, in *PrecheckImportJobReq, opts ...grpc.CallOption) (*PrecheckImportJobResp, error)
	CheckS3Access(ctx context.Context, in *CheckS3AccessReq, opts ...grpc.CallOption) (*CheckS3AccessResp, error)
	CheckGcsAccess(ctx context.Context, in *CheckGcsAccessReq, opts ...grpc.CallOption) (*CheckGcsAccessResp, error)
	CheckAzblobAccess(ctx context.Context, in *CheckAzblobAccessReq, opts ...grpc.CallOption) (*CheckAzblobAccessResp, error)
	LightningPrecheck(ctx context.Context, in *LightningPrecheckReq, opts ...grpc.CallOption) (*LightningPrecheckResp, error)
	ExecSQLOnCluster(ctx context.Context, in *ExecSQLReq, opts ...grpc.CallOption) (*ExecSQLResp, error)
	LoadDataToCluster(ctx context.Context, in *LoadDataReq, opts ...grpc.CallOption) (*LoadDataResp, error)
	GetImportSchemasMeta(ctx context.Context, in *GetImportSchemasMetaReq, opts ...grpc.CallOption) (*GetImportSchemasMetaResp, error)
	LightningSourcePreview(ctx context.Context, in *LightningSourcePreviewReq, opts ...grpc.CallOption) (*LightningSourcePreviewResp, error)
	EstimateSourceDataSize(ctx context.Context, in *EstimateSourceDataSizeReq, opts ...grpc.CallOption) (*EstimateSourceDataSizeResp, error)
	CheckDBConnectivity(ctx context.Context, in *CheckDBConnectivityReq, opts ...grpc.CallOption) (*CheckDBConnectivityResp, error)
	GetTiDBServerSecret(ctx context.Context, in *GetTiDBServerSecretReq, opts ...grpc.CallOption) (*GetTiDBServerSecretResp, error)
	GetClusterClientSecret(ctx context.Context, in *GetClusterClientSecretReq, opts ...grpc.CallOption) (*GetClusterClientSecretResp, error)
	PrecheckDMJob(ctx context.Context, in *PrecheckDMJobReq, opts ...grpc.CallOption) (*PrecheckDMJobResp, error)
	GetUserFileContent(ctx context.Context, in *GetUserFileReq, opts ...grpc.CallOption) (*GetUserFileResp, error)
	GetSourceTables(ctx context.Context, in *CheckDBConnectivityReq, opts ...grpc.CallOption) (*GetSourceTablesResp, error)
	// get result of "show master status" on source
	GetSourceBinlogStatus(ctx context.Context, in *CheckDBConnectivityReq, opts ...grpc.CallOption) (*GetSourceBinlogStatusResp, error)
	GetClusterTables(ctx context.Context, in *Cluster, opts ...grpc.CallOption) (*GetClusterTablesResp, error)
	NsLookup(ctx context.Context, in *NsLookupReq, opts ...grpc.CallOption) (*NsLookupResp, error)
	// deprecated
	ClearEmptyTables(ctx context.Context, in *ClearEmptyTablesReq, opts ...grpc.CallOption) (*ClearEmptyTablesResp, error)
	SearchImportFiles(ctx context.Context, in *SearchImportFilesReq, opts ...grpc.CallOption) (*SearchImportFilesResp, error)
	GetImportFiles(ctx context.Context, in *GetImportFilesReq, opts ...grpc.CallOption) (*GetImportFilesResp, error)
	CreateSchemas(ctx context.Context, in *CreateSchemasReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	PreviewCsvFile(ctx context.Context, in *PreviewCsvFileReq, opts ...grpc.CallOption) (*PreviewCsvFileResp, error)
	PrecheckImportFile(ctx context.Context, in *PrecheckImportFileReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	DropClusterTables(ctx context.Context, in *DropClusterTablesReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetPublicKey(ctx context.Context, in *GetPublicKeyRequest, opts ...grpc.CallOption) (*GetPublicKeyResponse, error)
}

type agentServiceClient struct {
	cc grpc.ClientConnInterface
}

func NewAgentServiceClient(cc grpc.ClientConnInterface) AgentServiceClient {
	return &agentServiceClient{cc}
}

func (c *agentServiceClient) PrecheckImportJob(ctx context.Context, in *PrecheckImportJobReq, opts ...grpc.CallOption) (*PrecheckImportJobResp, error) {
	out := new(PrecheckImportJobResp)
	err := c.cc.Invoke(ctx, AgentService_PrecheckImportJob_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentServiceClient) CheckS3Access(ctx context.Context, in *CheckS3AccessReq, opts ...grpc.CallOption) (*CheckS3AccessResp, error) {
	out := new(CheckS3AccessResp)
	err := c.cc.Invoke(ctx, AgentService_CheckS3Access_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentServiceClient) CheckGcsAccess(ctx context.Context, in *CheckGcsAccessReq, opts ...grpc.CallOption) (*CheckGcsAccessResp, error) {
	out := new(CheckGcsAccessResp)
	err := c.cc.Invoke(ctx, AgentService_CheckGcsAccess_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentServiceClient) CheckAzblobAccess(ctx context.Context, in *CheckAzblobAccessReq, opts ...grpc.CallOption) (*CheckAzblobAccessResp, error) {
	out := new(CheckAzblobAccessResp)
	err := c.cc.Invoke(ctx, AgentService_CheckAzblobAccess_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentServiceClient) LightningPrecheck(ctx context.Context, in *LightningPrecheckReq, opts ...grpc.CallOption) (*LightningPrecheckResp, error) {
	out := new(LightningPrecheckResp)
	err := c.cc.Invoke(ctx, AgentService_LightningPrecheck_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentServiceClient) ExecSQLOnCluster(ctx context.Context, in *ExecSQLReq, opts ...grpc.CallOption) (*ExecSQLResp, error) {
	out := new(ExecSQLResp)
	err := c.cc.Invoke(ctx, AgentService_ExecSQLOnCluster_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentServiceClient) LoadDataToCluster(ctx context.Context, in *LoadDataReq, opts ...grpc.CallOption) (*LoadDataResp, error) {
	out := new(LoadDataResp)
	err := c.cc.Invoke(ctx, AgentService_LoadDataToCluster_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentServiceClient) GetImportSchemasMeta(ctx context.Context, in *GetImportSchemasMetaReq, opts ...grpc.CallOption) (*GetImportSchemasMetaResp, error) {
	out := new(GetImportSchemasMetaResp)
	err := c.cc.Invoke(ctx, AgentService_GetImportSchemasMeta_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentServiceClient) LightningSourcePreview(ctx context.Context, in *LightningSourcePreviewReq, opts ...grpc.CallOption) (*LightningSourcePreviewResp, error) {
	out := new(LightningSourcePreviewResp)
	err := c.cc.Invoke(ctx, AgentService_LightningSourcePreview_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentServiceClient) EstimateSourceDataSize(ctx context.Context, in *EstimateSourceDataSizeReq, opts ...grpc.CallOption) (*EstimateSourceDataSizeResp, error) {
	out := new(EstimateSourceDataSizeResp)
	err := c.cc.Invoke(ctx, AgentService_EstimateSourceDataSize_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentServiceClient) CheckDBConnectivity(ctx context.Context, in *CheckDBConnectivityReq, opts ...grpc.CallOption) (*CheckDBConnectivityResp, error) {
	out := new(CheckDBConnectivityResp)
	err := c.cc.Invoke(ctx, AgentService_CheckDBConnectivity_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentServiceClient) GetTiDBServerSecret(ctx context.Context, in *GetTiDBServerSecretReq, opts ...grpc.CallOption) (*GetTiDBServerSecretResp, error) {
	out := new(GetTiDBServerSecretResp)
	err := c.cc.Invoke(ctx, AgentService_GetTiDBServerSecret_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentServiceClient) GetClusterClientSecret(ctx context.Context, in *GetClusterClientSecretReq, opts ...grpc.CallOption) (*GetClusterClientSecretResp, error) {
	out := new(GetClusterClientSecretResp)
	err := c.cc.Invoke(ctx, AgentService_GetClusterClientSecret_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentServiceClient) PrecheckDMJob(ctx context.Context, in *PrecheckDMJobReq, opts ...grpc.CallOption) (*PrecheckDMJobResp, error) {
	out := new(PrecheckDMJobResp)
	err := c.cc.Invoke(ctx, AgentService_PrecheckDMJob_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentServiceClient) GetUserFileContent(ctx context.Context, in *GetUserFileReq, opts ...grpc.CallOption) (*GetUserFileResp, error) {
	out := new(GetUserFileResp)
	err := c.cc.Invoke(ctx, AgentService_GetUserFileContent_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentServiceClient) GetSourceTables(ctx context.Context, in *CheckDBConnectivityReq, opts ...grpc.CallOption) (*GetSourceTablesResp, error) {
	out := new(GetSourceTablesResp)
	err := c.cc.Invoke(ctx, AgentService_GetSourceTables_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentServiceClient) GetSourceBinlogStatus(ctx context.Context, in *CheckDBConnectivityReq, opts ...grpc.CallOption) (*GetSourceBinlogStatusResp, error) {
	out := new(GetSourceBinlogStatusResp)
	err := c.cc.Invoke(ctx, AgentService_GetSourceBinlogStatus_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentServiceClient) GetClusterTables(ctx context.Context, in *Cluster, opts ...grpc.CallOption) (*GetClusterTablesResp, error) {
	out := new(GetClusterTablesResp)
	err := c.cc.Invoke(ctx, AgentService_GetClusterTables_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentServiceClient) NsLookup(ctx context.Context, in *NsLookupReq, opts ...grpc.CallOption) (*NsLookupResp, error) {
	out := new(NsLookupResp)
	err := c.cc.Invoke(ctx, AgentService_NsLookup_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentServiceClient) ClearEmptyTables(ctx context.Context, in *ClearEmptyTablesReq, opts ...grpc.CallOption) (*ClearEmptyTablesResp, error) {
	out := new(ClearEmptyTablesResp)
	err := c.cc.Invoke(ctx, AgentService_ClearEmptyTables_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentServiceClient) SearchImportFiles(ctx context.Context, in *SearchImportFilesReq, opts ...grpc.CallOption) (*SearchImportFilesResp, error) {
	out := new(SearchImportFilesResp)
	err := c.cc.Invoke(ctx, AgentService_SearchImportFiles_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentServiceClient) GetImportFiles(ctx context.Context, in *GetImportFilesReq, opts ...grpc.CallOption) (*GetImportFilesResp, error) {
	out := new(GetImportFilesResp)
	err := c.cc.Invoke(ctx, AgentService_GetImportFiles_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentServiceClient) CreateSchemas(ctx context.Context, in *CreateSchemasReq, opts ...grpc.CallOption) (*emptypb.Empty, error) {
	out := new(emptypb.Empty)
	err := c.cc.Invoke(ctx, AgentService_CreateSchemas_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentServiceClient) PreviewCsvFile(ctx context.Context, in *PreviewCsvFileReq, opts ...grpc.CallOption) (*PreviewCsvFileResp, error) {
	out := new(PreviewCsvFileResp)
	err := c.cc.Invoke(ctx, AgentService_PreviewCsvFile_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentServiceClient) PrecheckImportFile(ctx context.Context, in *PrecheckImportFileReq, opts ...grpc.CallOption) (*emptypb.Empty, error) {
	out := new(emptypb.Empty)
	err := c.cc.Invoke(ctx, AgentService_PrecheckImportFile_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentServiceClient) DropClusterTables(ctx context.Context, in *DropClusterTablesReq, opts ...grpc.CallOption) (*emptypb.Empty, error) {
	out := new(emptypb.Empty)
	err := c.cc.Invoke(ctx, AgentService_DropClusterTables_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *agentServiceClient) GetPublicKey(ctx context.Context, in *GetPublicKeyRequest, opts ...grpc.CallOption) (*GetPublicKeyResponse, error) {
	out := new(GetPublicKeyResponse)
	err := c.cc.Invoke(ctx, AgentService_GetPublicKey_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

// AgentServiceServer is the server API for AgentService service.
// All implementations must embed UnimplementedAgentServiceServer
// for forward compatibility
type AgentServiceServer interface {
	// Precheck and return the scan result.
	PrecheckImportJob(context.Context, *PrecheckImportJobReq) (*PrecheckImportJobResp, error)
	CheckS3Access(context.Context, *CheckS3AccessReq) (*CheckS3AccessResp, error)
	CheckGcsAccess(context.Context, *CheckGcsAccessReq) (*CheckGcsAccessResp, error)
	CheckAzblobAccess(context.Context, *CheckAzblobAccessReq) (*CheckAzblobAccessResp, error)
	LightningPrecheck(context.Context, *LightningPrecheckReq) (*LightningPrecheckResp, error)
	ExecSQLOnCluster(context.Context, *ExecSQLReq) (*ExecSQLResp, error)
	LoadDataToCluster(context.Context, *LoadDataReq) (*LoadDataResp, error)
	GetImportSchemasMeta(context.Context, *GetImportSchemasMetaReq) (*GetImportSchemasMetaResp, error)
	LightningSourcePreview(context.Context, *LightningSourcePreviewReq) (*LightningSourcePreviewResp, error)
	EstimateSourceDataSize(context.Context, *EstimateSourceDataSizeReq) (*EstimateSourceDataSizeResp, error)
	CheckDBConnectivity(context.Context, *CheckDBConnectivityReq) (*CheckDBConnectivityResp, error)
	GetTiDBServerSecret(context.Context, *GetTiDBServerSecretReq) (*GetTiDBServerSecretResp, error)
	GetClusterClientSecret(context.Context, *GetClusterClientSecretReq) (*GetClusterClientSecretResp, error)
	PrecheckDMJob(context.Context, *PrecheckDMJobReq) (*PrecheckDMJobResp, error)
	GetUserFileContent(context.Context, *GetUserFileReq) (*GetUserFileResp, error)
	GetSourceTables(context.Context, *CheckDBConnectivityReq) (*GetSourceTablesResp, error)
	// get result of "show master status" on source
	GetSourceBinlogStatus(context.Context, *CheckDBConnectivityReq) (*GetSourceBinlogStatusResp, error)
	GetClusterTables(context.Context, *Cluster) (*GetClusterTablesResp, error)
	NsLookup(context.Context, *NsLookupReq) (*NsLookupResp, error)
	// deprecated
	ClearEmptyTables(context.Context, *ClearEmptyTablesReq) (*ClearEmptyTablesResp, error)
	SearchImportFiles(context.Context, *SearchImportFilesReq) (*SearchImportFilesResp, error)
	GetImportFiles(context.Context, *GetImportFilesReq) (*GetImportFilesResp, error)
	CreateSchemas(context.Context, *CreateSchemasReq) (*emptypb.Empty, error)
	PreviewCsvFile(context.Context, *PreviewCsvFileReq) (*PreviewCsvFileResp, error)
	PrecheckImportFile(context.Context, *PrecheckImportFileReq) (*emptypb.Empty, error)
	DropClusterTables(context.Context, *DropClusterTablesReq) (*emptypb.Empty, error)
	GetPublicKey(context.Context, *GetPublicKeyRequest) (*GetPublicKeyResponse, error)
	mustEmbedUnimplementedAgentServiceServer()
}

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

func (UnimplementedAgentServiceServer) PrecheckImportJob(context.Context, *PrecheckImportJobReq) (*PrecheckImportJobResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method PrecheckImportJob not implemented")
}
func (UnimplementedAgentServiceServer) CheckS3Access(context.Context, *CheckS3AccessReq) (*CheckS3AccessResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CheckS3Access not implemented")
}
func (UnimplementedAgentServiceServer) CheckGcsAccess(context.Context, *CheckGcsAccessReq) (*CheckGcsAccessResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CheckGcsAccess not implemented")
}
func (UnimplementedAgentServiceServer) CheckAzblobAccess(context.Context, *CheckAzblobAccessReq) (*CheckAzblobAccessResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CheckAzblobAccess not implemented")
}
func (UnimplementedAgentServiceServer) LightningPrecheck(context.Context, *LightningPrecheckReq) (*LightningPrecheckResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method LightningPrecheck not implemented")
}
func (UnimplementedAgentServiceServer) ExecSQLOnCluster(context.Context, *ExecSQLReq) (*ExecSQLResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ExecSQLOnCluster not implemented")
}
func (UnimplementedAgentServiceServer) LoadDataToCluster(context.Context, *LoadDataReq) (*LoadDataResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method LoadDataToCluster not implemented")
}
func (UnimplementedAgentServiceServer) GetImportSchemasMeta(context.Context, *GetImportSchemasMetaReq) (*GetImportSchemasMetaResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetImportSchemasMeta not implemented")
}
func (UnimplementedAgentServiceServer) LightningSourcePreview(context.Context, *LightningSourcePreviewReq) (*LightningSourcePreviewResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method LightningSourcePreview not implemented")
}
func (UnimplementedAgentServiceServer) EstimateSourceDataSize(context.Context, *EstimateSourceDataSizeReq) (*EstimateSourceDataSizeResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method EstimateSourceDataSize not implemented")
}
func (UnimplementedAgentServiceServer) CheckDBConnectivity(context.Context, *CheckDBConnectivityReq) (*CheckDBConnectivityResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CheckDBConnectivity not implemented")
}
func (UnimplementedAgentServiceServer) GetTiDBServerSecret(context.Context, *GetTiDBServerSecretReq) (*GetTiDBServerSecretResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetTiDBServerSecret not implemented")
}
func (UnimplementedAgentServiceServer) GetClusterClientSecret(context.Context, *GetClusterClientSecretReq) (*GetClusterClientSecretResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetClusterClientSecret not implemented")
}
func (UnimplementedAgentServiceServer) PrecheckDMJob(context.Context, *PrecheckDMJobReq) (*PrecheckDMJobResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method PrecheckDMJob not implemented")
}
func (UnimplementedAgentServiceServer) GetUserFileContent(context.Context, *GetUserFileReq) (*GetUserFileResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetUserFileContent not implemented")
}
func (UnimplementedAgentServiceServer) GetSourceTables(context.Context, *CheckDBConnectivityReq) (*GetSourceTablesResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetSourceTables not implemented")
}
func (UnimplementedAgentServiceServer) GetSourceBinlogStatus(context.Context, *CheckDBConnectivityReq) (*GetSourceBinlogStatusResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetSourceBinlogStatus not implemented")
}
func (UnimplementedAgentServiceServer) GetClusterTables(context.Context, *Cluster) (*GetClusterTablesResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetClusterTables not implemented")
}
func (UnimplementedAgentServiceServer) NsLookup(context.Context, *NsLookupReq) (*NsLookupResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method NsLookup not implemented")
}
func (UnimplementedAgentServiceServer) ClearEmptyTables(context.Context, *ClearEmptyTablesReq) (*ClearEmptyTablesResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ClearEmptyTables not implemented")
}
func (UnimplementedAgentServiceServer) SearchImportFiles(context.Context, *SearchImportFilesReq) (*SearchImportFilesResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method SearchImportFiles not implemented")
}
func (UnimplementedAgentServiceServer) GetImportFiles(context.Context, *GetImportFilesReq) (*GetImportFilesResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetImportFiles not implemented")
}
func (UnimplementedAgentServiceServer) CreateSchemas(context.Context, *CreateSchemasReq) (*emptypb.Empty, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CreateSchemas not implemented")
}
func (UnimplementedAgentServiceServer) PreviewCsvFile(context.Context, *PreviewCsvFileReq) (*PreviewCsvFileResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method PreviewCsvFile not implemented")
}
func (UnimplementedAgentServiceServer) PrecheckImportFile(context.Context, *PrecheckImportFileReq) (*emptypb.Empty, error) {
	return nil, status.Errorf(codes.Unimplemented, "method PrecheckImportFile not implemented")
}
func (UnimplementedAgentServiceServer) DropClusterTables(context.Context, *DropClusterTablesReq) (*emptypb.Empty, error) {
	return nil, status.Errorf(codes.Unimplemented, "method DropClusterTables not implemented")
}
func (UnimplementedAgentServiceServer) GetPublicKey(context.Context, *GetPublicKeyRequest) (*GetPublicKeyResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetPublicKey not implemented")
}
func (UnimplementedAgentServiceServer) mustEmbedUnimplementedAgentServiceServer() {}

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

func RegisterAgentServiceServer(s grpc.ServiceRegistrar, srv AgentServiceServer) {
	s.RegisterService(&AgentService_ServiceDesc, srv)
}

func _AgentService_PrecheckImportJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(PrecheckImportJobReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentServiceServer).PrecheckImportJob(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentService_PrecheckImportJob_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentServiceServer).PrecheckImportJob(ctx, req.(*PrecheckImportJobReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentService_CheckS3Access_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CheckS3AccessReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentServiceServer).CheckS3Access(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentService_CheckS3Access_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentServiceServer).CheckS3Access(ctx, req.(*CheckS3AccessReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentService_CheckGcsAccess_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CheckGcsAccessReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentServiceServer).CheckGcsAccess(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentService_CheckGcsAccess_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentServiceServer).CheckGcsAccess(ctx, req.(*CheckGcsAccessReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentService_CheckAzblobAccess_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CheckAzblobAccessReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentServiceServer).CheckAzblobAccess(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentService_CheckAzblobAccess_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentServiceServer).CheckAzblobAccess(ctx, req.(*CheckAzblobAccessReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentService_LightningPrecheck_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(LightningPrecheckReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentServiceServer).LightningPrecheck(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentService_LightningPrecheck_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentServiceServer).LightningPrecheck(ctx, req.(*LightningPrecheckReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentService_ExecSQLOnCluster_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ExecSQLReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentServiceServer).ExecSQLOnCluster(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentService_ExecSQLOnCluster_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentServiceServer).ExecSQLOnCluster(ctx, req.(*ExecSQLReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentService_LoadDataToCluster_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(LoadDataReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentServiceServer).LoadDataToCluster(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentService_LoadDataToCluster_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentServiceServer).LoadDataToCluster(ctx, req.(*LoadDataReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentService_GetImportSchemasMeta_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetImportSchemasMetaReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentServiceServer).GetImportSchemasMeta(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentService_GetImportSchemasMeta_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentServiceServer).GetImportSchemasMeta(ctx, req.(*GetImportSchemasMetaReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentService_LightningSourcePreview_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(LightningSourcePreviewReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentServiceServer).LightningSourcePreview(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentService_LightningSourcePreview_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentServiceServer).LightningSourcePreview(ctx, req.(*LightningSourcePreviewReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentService_EstimateSourceDataSize_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(EstimateSourceDataSizeReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentServiceServer).EstimateSourceDataSize(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentService_EstimateSourceDataSize_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentServiceServer).EstimateSourceDataSize(ctx, req.(*EstimateSourceDataSizeReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentService_CheckDBConnectivity_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CheckDBConnectivityReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentServiceServer).CheckDBConnectivity(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentService_CheckDBConnectivity_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentServiceServer).CheckDBConnectivity(ctx, req.(*CheckDBConnectivityReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentService_GetTiDBServerSecret_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetTiDBServerSecretReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentServiceServer).GetTiDBServerSecret(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentService_GetTiDBServerSecret_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentServiceServer).GetTiDBServerSecret(ctx, req.(*GetTiDBServerSecretReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentService_GetClusterClientSecret_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetClusterClientSecretReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentServiceServer).GetClusterClientSecret(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentService_GetClusterClientSecret_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentServiceServer).GetClusterClientSecret(ctx, req.(*GetClusterClientSecretReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentService_PrecheckDMJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(PrecheckDMJobReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentServiceServer).PrecheckDMJob(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentService_PrecheckDMJob_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentServiceServer).PrecheckDMJob(ctx, req.(*PrecheckDMJobReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentService_GetUserFileContent_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetUserFileReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentServiceServer).GetUserFileContent(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentService_GetUserFileContent_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentServiceServer).GetUserFileContent(ctx, req.(*GetUserFileReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentService_GetSourceTables_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CheckDBConnectivityReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentServiceServer).GetSourceTables(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentService_GetSourceTables_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentServiceServer).GetSourceTables(ctx, req.(*CheckDBConnectivityReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentService_GetSourceBinlogStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CheckDBConnectivityReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentServiceServer).GetSourceBinlogStatus(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentService_GetSourceBinlogStatus_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentServiceServer).GetSourceBinlogStatus(ctx, req.(*CheckDBConnectivityReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentService_GetClusterTables_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(Cluster)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentServiceServer).GetClusterTables(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentService_GetClusterTables_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentServiceServer).GetClusterTables(ctx, req.(*Cluster))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentService_NsLookup_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(NsLookupReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentServiceServer).NsLookup(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentService_NsLookup_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentServiceServer).NsLookup(ctx, req.(*NsLookupReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentService_ClearEmptyTables_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ClearEmptyTablesReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentServiceServer).ClearEmptyTables(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentService_ClearEmptyTables_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentServiceServer).ClearEmptyTables(ctx, req.(*ClearEmptyTablesReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentService_SearchImportFiles_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(SearchImportFilesReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentServiceServer).SearchImportFiles(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentService_SearchImportFiles_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentServiceServer).SearchImportFiles(ctx, req.(*SearchImportFilesReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentService_GetImportFiles_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetImportFilesReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentServiceServer).GetImportFiles(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentService_GetImportFiles_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentServiceServer).GetImportFiles(ctx, req.(*GetImportFilesReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentService_CreateSchemas_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CreateSchemasReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentServiceServer).CreateSchemas(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentService_CreateSchemas_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentServiceServer).CreateSchemas(ctx, req.(*CreateSchemasReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentService_PreviewCsvFile_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(PreviewCsvFileReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentServiceServer).PreviewCsvFile(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentService_PreviewCsvFile_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentServiceServer).PreviewCsvFile(ctx, req.(*PreviewCsvFileReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentService_PrecheckImportFile_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(PrecheckImportFileReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentServiceServer).PrecheckImportFile(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentService_PrecheckImportFile_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentServiceServer).PrecheckImportFile(ctx, req.(*PrecheckImportFileReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentService_DropClusterTables_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DropClusterTablesReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentServiceServer).DropClusterTables(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentService_DropClusterTables_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentServiceServer).DropClusterTables(ctx, req.(*DropClusterTablesReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _AgentService_GetPublicKey_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetPublicKeyRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(AgentServiceServer).GetPublicKey(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: AgentService_GetPublicKey_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(AgentServiceServer).GetPublicKey(ctx, req.(*GetPublicKeyRequest))
	}
	return interceptor(ctx, in, info, handler)
}

// AgentService_ServiceDesc is the grpc.ServiceDesc for AgentService service.
// It's only intended for direct use with grpc.RegisterService,
// and not to be introspected or modified (even as a copy)
var AgentService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "agent.AgentService",
	HandlerType: (*AgentServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "PrecheckImportJob",
			Handler:    _AgentService_PrecheckImportJob_Handler,
		},
		{
			MethodName: "CheckS3Access",
			Handler:    _AgentService_CheckS3Access_Handler,
		},
		{
			MethodName: "CheckGcsAccess",
			Handler:    _AgentService_CheckGcsAccess_Handler,
		},
		{
			MethodName: "CheckAzblobAccess",
			Handler:    _AgentService_CheckAzblobAccess_Handler,
		},
		{
			MethodName: "LightningPrecheck",
			Handler:    _AgentService_LightningPrecheck_Handler,
		},
		{
			MethodName: "ExecSQLOnCluster",
			Handler:    _AgentService_ExecSQLOnCluster_Handler,
		},
		{
			MethodName: "LoadDataToCluster",
			Handler:    _AgentService_LoadDataToCluster_Handler,
		},
		{
			MethodName: "GetImportSchemasMeta",
			Handler:    _AgentService_GetImportSchemasMeta_Handler,
		},
		{
			MethodName: "LightningSourcePreview",
			Handler:    _AgentService_LightningSourcePreview_Handler,
		},
		{
			MethodName: "EstimateSourceDataSize",
			Handler:    _AgentService_EstimateSourceDataSize_Handler,
		},
		{
			MethodName: "CheckDBConnectivity",
			Handler:    _AgentService_CheckDBConnectivity_Handler,
		},
		{
			MethodName: "GetTiDBServerSecret",
			Handler:    _AgentService_GetTiDBServerSecret_Handler,
		},
		{
			MethodName: "GetClusterClientSecret",
			Handler:    _AgentService_GetClusterClientSecret_Handler,
		},
		{
			MethodName: "PrecheckDMJob",
			Handler:    _AgentService_PrecheckDMJob_Handler,
		},
		{
			MethodName: "GetUserFileContent",
			Handler:    _AgentService_GetUserFileContent_Handler,
		},
		{
			MethodName: "GetSourceTables",
			Handler:    _AgentService_GetSourceTables_Handler,
		},
		{
			MethodName: "GetSourceBinlogStatus",
			Handler:    _AgentService_GetSourceBinlogStatus_Handler,
		},
		{
			MethodName: "GetClusterTables",
			Handler:    _AgentService_GetClusterTables_Handler,
		},
		{
			MethodName: "NsLookup",
			Handler:    _AgentService_NsLookup_Handler,
		},
		{
			MethodName: "ClearEmptyTables",
			Handler:    _AgentService_ClearEmptyTables_Handler,
		},
		{
			MethodName: "SearchImportFiles",
			Handler:    _AgentService_SearchImportFiles_Handler,
		},
		{
			MethodName: "GetImportFiles",
			Handler:    _AgentService_GetImportFiles_Handler,
		},
		{
			MethodName: "CreateSchemas",
			Handler:    _AgentService_CreateSchemas_Handler,
		},
		{
			MethodName: "PreviewCsvFile",
			Handler:    _AgentService_PreviewCsvFile_Handler,
		},
		{
			MethodName: "PrecheckImportFile",
			Handler:    _AgentService_PrecheckImportFile_Handler,
		},
		{
			MethodName: "DropClusterTables",
			Handler:    _AgentService_DropClusterTables_Handler,
		},
		{
			MethodName: "GetPublicKey",
			Handler:    _AgentService_GetPublicKey_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "agent/agent.proto",
}