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

// gRPC for our DBaaS dataflow service
//
// notably uses gRPC-Gateway with OpenAPI

package consoleapi

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"
	structpb "google.golang.org/protobuf/types/known/structpb"
)

// 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 (
	ChangefeedService_ListChangefeeds_FullMethodName     = "/consoleapi.ChangefeedService/ListChangefeeds"
	ChangefeedService_GetChangefeed_FullMethodName       = "/consoleapi.ChangefeedService/GetChangefeed"
	ChangefeedService_DescribeSchemaTable_FullMethodName = "/consoleapi.ChangefeedService/DescribeSchemaTable"
	ChangefeedService_GetAdminProfile_FullMethodName     = "/consoleapi.ChangefeedService/GetAdminProfile"
	ChangefeedService_ScaleChangefeed_FullMethodName     = "/consoleapi.ChangefeedService/ScaleChangefeed"
	ChangefeedService_CalChangefeedFee_FullMethodName    = "/consoleapi.ChangefeedService/CalChangefeedFee"
	ChangefeedService_ResumeChangefeed_FullMethodName    = "/consoleapi.ChangefeedService/ResumeChangefeed"
	ChangefeedService_PauseChangefeed_FullMethodName     = "/consoleapi.ChangefeedService/PauseChangefeed"
	ChangefeedService_CreateChangefeed_FullMethodName    = "/consoleapi.ChangefeedService/CreateChangefeed"
	ChangefeedService_EditChangefeed_FullMethodName      = "/consoleapi.ChangefeedService/EditChangefeed"
	ChangefeedService_DeleteChangefeed_FullMethodName    = "/consoleapi.ChangefeedService/DeleteChangefeed"
	ChangefeedService_TestChangefeed_FullMethodName      = "/consoleapi.ChangefeedService/TestChangefeed"
	ChangefeedService_GetChangefeedDetail_FullMethodName = "/consoleapi.ChangefeedService/GetChangefeedDetail"
	ChangefeedService_GetTiCDCCluster_FullMethodName     = "/consoleapi.ChangefeedService/GetTiCDCCluster"
	ChangefeedService_ListTiCDCClusters_FullMethodName   = "/consoleapi.ChangefeedService/ListTiCDCClusters"
)

// ChangefeedServiceClient is the client API for ChangefeedService 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 ChangefeedServiceClient interface {
	ListChangefeeds(ctx context.Context, in *ChangefeedListReq, opts ...grpc.CallOption) (*Changefeeds, error)
	GetChangefeed(ctx context.Context, in *ChangefeedID, opts ...grpc.CallOption) (*Changefeed, error)
	DescribeSchemaTable(ctx context.Context, in *DescribeSchemaTableReq, opts ...grpc.CallOption) (*DescribeSchemaTableResp, error)
	GetAdminProfile(ctx context.Context, in *ClusterIdReq, opts ...grpc.CallOption) (*AdminProfile, error)
	ScaleChangefeed(ctx context.Context, in *ChangefeedScaleReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	CalChangefeedFee(ctx context.Context, in *CalChangefeedFeeReq, opts ...grpc.CallOption) (*CalChangefeedFeeResp, error)
	ResumeChangefeed(ctx context.Context, in *ChangefeedID, opts ...grpc.CallOption) (*emptypb.Empty, error)
	PauseChangefeed(ctx context.Context, in *ChangefeedID, opts ...grpc.CallOption) (*emptypb.Empty, error)
	CreateChangefeed(ctx context.Context, in *ChangefeedCreateReq, opts ...grpc.CallOption) (*ChangefeedID, error)
	EditChangefeed(ctx context.Context, in *ChangefeedEditReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	DeleteChangefeed(ctx context.Context, in *ChangefeedID, opts ...grpc.CallOption) (*emptypb.Empty, error)
	TestChangefeed(ctx context.Context, in *ChangefeedCreateReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// For E2E tests
	GetChangefeedDetail(ctx context.Context, in *ChangefeedID, opts ...grpc.CallOption) (*structpb.Struct, error)
	// For E2E tests
	GetTiCDCCluster(ctx context.Context, in *ChangefeedID, opts ...grpc.CallOption) (*structpb.Struct, error)
	ListTiCDCClusters(ctx context.Context, in *ClusterIdReq, opts ...grpc.CallOption) (*structpb.Struct, error)
}

type changefeedServiceClient struct {
	cc grpc.ClientConnInterface
}

func NewChangefeedServiceClient(cc grpc.ClientConnInterface) ChangefeedServiceClient {
	return &changefeedServiceClient{cc}
}

func (c *changefeedServiceClient) ListChangefeeds(ctx context.Context, in *ChangefeedListReq, opts ...grpc.CallOption) (*Changefeeds, error) {
	out := new(Changefeeds)
	err := c.cc.Invoke(ctx, ChangefeedService_ListChangefeeds_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *changefeedServiceClient) GetChangefeed(ctx context.Context, in *ChangefeedID, opts ...grpc.CallOption) (*Changefeed, error) {
	out := new(Changefeed)
	err := c.cc.Invoke(ctx, ChangefeedService_GetChangefeed_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *changefeedServiceClient) DescribeSchemaTable(ctx context.Context, in *DescribeSchemaTableReq, opts ...grpc.CallOption) (*DescribeSchemaTableResp, error) {
	out := new(DescribeSchemaTableResp)
	err := c.cc.Invoke(ctx, ChangefeedService_DescribeSchemaTable_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *changefeedServiceClient) GetAdminProfile(ctx context.Context, in *ClusterIdReq, opts ...grpc.CallOption) (*AdminProfile, error) {
	out := new(AdminProfile)
	err := c.cc.Invoke(ctx, ChangefeedService_GetAdminProfile_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *changefeedServiceClient) ScaleChangefeed(ctx context.Context, in *ChangefeedScaleReq, opts ...grpc.CallOption) (*emptypb.Empty, error) {
	out := new(emptypb.Empty)
	err := c.cc.Invoke(ctx, ChangefeedService_ScaleChangefeed_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *changefeedServiceClient) CalChangefeedFee(ctx context.Context, in *CalChangefeedFeeReq, opts ...grpc.CallOption) (*CalChangefeedFeeResp, error) {
	out := new(CalChangefeedFeeResp)
	err := c.cc.Invoke(ctx, ChangefeedService_CalChangefeedFee_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *changefeedServiceClient) ResumeChangefeed(ctx context.Context, in *ChangefeedID, opts ...grpc.CallOption) (*emptypb.Empty, error) {
	out := new(emptypb.Empty)
	err := c.cc.Invoke(ctx, ChangefeedService_ResumeChangefeed_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *changefeedServiceClient) PauseChangefeed(ctx context.Context, in *ChangefeedID, opts ...grpc.CallOption) (*emptypb.Empty, error) {
	out := new(emptypb.Empty)
	err := c.cc.Invoke(ctx, ChangefeedService_PauseChangefeed_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *changefeedServiceClient) CreateChangefeed(ctx context.Context, in *ChangefeedCreateReq, opts ...grpc.CallOption) (*ChangefeedID, error) {
	out := new(ChangefeedID)
	err := c.cc.Invoke(ctx, ChangefeedService_CreateChangefeed_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *changefeedServiceClient) EditChangefeed(ctx context.Context, in *ChangefeedEditReq, opts ...grpc.CallOption) (*emptypb.Empty, error) {
	out := new(emptypb.Empty)
	err := c.cc.Invoke(ctx, ChangefeedService_EditChangefeed_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *changefeedServiceClient) DeleteChangefeed(ctx context.Context, in *ChangefeedID, opts ...grpc.CallOption) (*emptypb.Empty, error) {
	out := new(emptypb.Empty)
	err := c.cc.Invoke(ctx, ChangefeedService_DeleteChangefeed_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *changefeedServiceClient) TestChangefeed(ctx context.Context, in *ChangefeedCreateReq, opts ...grpc.CallOption) (*emptypb.Empty, error) {
	out := new(emptypb.Empty)
	err := c.cc.Invoke(ctx, ChangefeedService_TestChangefeed_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *changefeedServiceClient) GetChangefeedDetail(ctx context.Context, in *ChangefeedID, opts ...grpc.CallOption) (*structpb.Struct, error) {
	out := new(structpb.Struct)
	err := c.cc.Invoke(ctx, ChangefeedService_GetChangefeedDetail_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *changefeedServiceClient) GetTiCDCCluster(ctx context.Context, in *ChangefeedID, opts ...grpc.CallOption) (*structpb.Struct, error) {
	out := new(structpb.Struct)
	err := c.cc.Invoke(ctx, ChangefeedService_GetTiCDCCluster_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *changefeedServiceClient) ListTiCDCClusters(ctx context.Context, in *ClusterIdReq, opts ...grpc.CallOption) (*structpb.Struct, error) {
	out := new(structpb.Struct)
	err := c.cc.Invoke(ctx, ChangefeedService_ListTiCDCClusters_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

// ChangefeedServiceServer is the server API for ChangefeedService service.
// All implementations must embed UnimplementedChangefeedServiceServer
// for forward compatibility
type ChangefeedServiceServer interface {
	ListChangefeeds(context.Context, *ChangefeedListReq) (*Changefeeds, error)
	GetChangefeed(context.Context, *ChangefeedID) (*Changefeed, error)
	DescribeSchemaTable(context.Context, *DescribeSchemaTableReq) (*DescribeSchemaTableResp, error)
	GetAdminProfile(context.Context, *ClusterIdReq) (*AdminProfile, error)
	ScaleChangefeed(context.Context, *ChangefeedScaleReq) (*emptypb.Empty, error)
	CalChangefeedFee(context.Context, *CalChangefeedFeeReq) (*CalChangefeedFeeResp, error)
	ResumeChangefeed(context.Context, *ChangefeedID) (*emptypb.Empty, error)
	PauseChangefeed(context.Context, *ChangefeedID) (*emptypb.Empty, error)
	CreateChangefeed(context.Context, *ChangefeedCreateReq) (*ChangefeedID, error)
	EditChangefeed(context.Context, *ChangefeedEditReq) (*emptypb.Empty, error)
	DeleteChangefeed(context.Context, *ChangefeedID) (*emptypb.Empty, error)
	TestChangefeed(context.Context, *ChangefeedCreateReq) (*emptypb.Empty, error)
	// For E2E tests
	GetChangefeedDetail(context.Context, *ChangefeedID) (*structpb.Struct, error)
	// For E2E tests
	GetTiCDCCluster(context.Context, *ChangefeedID) (*structpb.Struct, error)
	ListTiCDCClusters(context.Context, *ClusterIdReq) (*structpb.Struct, error)
	mustEmbedUnimplementedChangefeedServiceServer()
}

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

func (UnimplementedChangefeedServiceServer) ListChangefeeds(context.Context, *ChangefeedListReq) (*Changefeeds, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListChangefeeds not implemented")
}
func (UnimplementedChangefeedServiceServer) GetChangefeed(context.Context, *ChangefeedID) (*Changefeed, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetChangefeed not implemented")
}
func (UnimplementedChangefeedServiceServer) DescribeSchemaTable(context.Context, *DescribeSchemaTableReq) (*DescribeSchemaTableResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method DescribeSchemaTable not implemented")
}
func (UnimplementedChangefeedServiceServer) GetAdminProfile(context.Context, *ClusterIdReq) (*AdminProfile, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetAdminProfile not implemented")
}
func (UnimplementedChangefeedServiceServer) ScaleChangefeed(context.Context, *ChangefeedScaleReq) (*emptypb.Empty, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ScaleChangefeed not implemented")
}
func (UnimplementedChangefeedServiceServer) CalChangefeedFee(context.Context, *CalChangefeedFeeReq) (*CalChangefeedFeeResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CalChangefeedFee not implemented")
}
func (UnimplementedChangefeedServiceServer) ResumeChangefeed(context.Context, *ChangefeedID) (*emptypb.Empty, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ResumeChangefeed not implemented")
}
func (UnimplementedChangefeedServiceServer) PauseChangefeed(context.Context, *ChangefeedID) (*emptypb.Empty, error) {
	return nil, status.Errorf(codes.Unimplemented, "method PauseChangefeed not implemented")
}
func (UnimplementedChangefeedServiceServer) CreateChangefeed(context.Context, *ChangefeedCreateReq) (*ChangefeedID, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CreateChangefeed not implemented")
}
func (UnimplementedChangefeedServiceServer) EditChangefeed(context.Context, *ChangefeedEditReq) (*emptypb.Empty, error) {
	return nil, status.Errorf(codes.Unimplemented, "method EditChangefeed not implemented")
}
func (UnimplementedChangefeedServiceServer) DeleteChangefeed(context.Context, *ChangefeedID) (*emptypb.Empty, error) {
	return nil, status.Errorf(codes.Unimplemented, "method DeleteChangefeed not implemented")
}
func (UnimplementedChangefeedServiceServer) TestChangefeed(context.Context, *ChangefeedCreateReq) (*emptypb.Empty, error) {
	return nil, status.Errorf(codes.Unimplemented, "method TestChangefeed not implemented")
}
func (UnimplementedChangefeedServiceServer) GetChangefeedDetail(context.Context, *ChangefeedID) (*structpb.Struct, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetChangefeedDetail not implemented")
}
func (UnimplementedChangefeedServiceServer) GetTiCDCCluster(context.Context, *ChangefeedID) (*structpb.Struct, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetTiCDCCluster not implemented")
}
func (UnimplementedChangefeedServiceServer) ListTiCDCClusters(context.Context, *ClusterIdReq) (*structpb.Struct, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListTiCDCClusters not implemented")
}
func (UnimplementedChangefeedServiceServer) mustEmbedUnimplementedChangefeedServiceServer() {}

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

func RegisterChangefeedServiceServer(s grpc.ServiceRegistrar, srv ChangefeedServiceServer) {
	s.RegisterService(&ChangefeedService_ServiceDesc, srv)
}

func _ChangefeedService_ListChangefeeds_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ChangefeedListReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ChangefeedServiceServer).ListChangefeeds(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ChangefeedService_ListChangefeeds_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ChangefeedServiceServer).ListChangefeeds(ctx, req.(*ChangefeedListReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _ChangefeedService_GetChangefeed_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ChangefeedID)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ChangefeedServiceServer).GetChangefeed(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ChangefeedService_GetChangefeed_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ChangefeedServiceServer).GetChangefeed(ctx, req.(*ChangefeedID))
	}
	return interceptor(ctx, in, info, handler)
}

func _ChangefeedService_DescribeSchemaTable_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DescribeSchemaTableReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ChangefeedServiceServer).DescribeSchemaTable(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ChangefeedService_DescribeSchemaTable_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ChangefeedServiceServer).DescribeSchemaTable(ctx, req.(*DescribeSchemaTableReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _ChangefeedService_GetAdminProfile_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ClusterIdReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ChangefeedServiceServer).GetAdminProfile(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ChangefeedService_GetAdminProfile_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ChangefeedServiceServer).GetAdminProfile(ctx, req.(*ClusterIdReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _ChangefeedService_ScaleChangefeed_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ChangefeedScaleReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ChangefeedServiceServer).ScaleChangefeed(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ChangefeedService_ScaleChangefeed_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ChangefeedServiceServer).ScaleChangefeed(ctx, req.(*ChangefeedScaleReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _ChangefeedService_CalChangefeedFee_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CalChangefeedFeeReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ChangefeedServiceServer).CalChangefeedFee(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ChangefeedService_CalChangefeedFee_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ChangefeedServiceServer).CalChangefeedFee(ctx, req.(*CalChangefeedFeeReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _ChangefeedService_ResumeChangefeed_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ChangefeedID)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ChangefeedServiceServer).ResumeChangefeed(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ChangefeedService_ResumeChangefeed_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ChangefeedServiceServer).ResumeChangefeed(ctx, req.(*ChangefeedID))
	}
	return interceptor(ctx, in, info, handler)
}

func _ChangefeedService_PauseChangefeed_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ChangefeedID)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ChangefeedServiceServer).PauseChangefeed(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ChangefeedService_PauseChangefeed_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ChangefeedServiceServer).PauseChangefeed(ctx, req.(*ChangefeedID))
	}
	return interceptor(ctx, in, info, handler)
}

func _ChangefeedService_CreateChangefeed_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ChangefeedCreateReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ChangefeedServiceServer).CreateChangefeed(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ChangefeedService_CreateChangefeed_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ChangefeedServiceServer).CreateChangefeed(ctx, req.(*ChangefeedCreateReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _ChangefeedService_EditChangefeed_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ChangefeedEditReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ChangefeedServiceServer).EditChangefeed(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ChangefeedService_EditChangefeed_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ChangefeedServiceServer).EditChangefeed(ctx, req.(*ChangefeedEditReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _ChangefeedService_DeleteChangefeed_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ChangefeedID)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ChangefeedServiceServer).DeleteChangefeed(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ChangefeedService_DeleteChangefeed_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ChangefeedServiceServer).DeleteChangefeed(ctx, req.(*ChangefeedID))
	}
	return interceptor(ctx, in, info, handler)
}

func _ChangefeedService_TestChangefeed_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ChangefeedCreateReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ChangefeedServiceServer).TestChangefeed(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ChangefeedService_TestChangefeed_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ChangefeedServiceServer).TestChangefeed(ctx, req.(*ChangefeedCreateReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _ChangefeedService_GetChangefeedDetail_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ChangefeedID)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ChangefeedServiceServer).GetChangefeedDetail(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ChangefeedService_GetChangefeedDetail_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ChangefeedServiceServer).GetChangefeedDetail(ctx, req.(*ChangefeedID))
	}
	return interceptor(ctx, in, info, handler)
}

func _ChangefeedService_GetTiCDCCluster_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ChangefeedID)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ChangefeedServiceServer).GetTiCDCCluster(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ChangefeedService_GetTiCDCCluster_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ChangefeedServiceServer).GetTiCDCCluster(ctx, req.(*ChangefeedID))
	}
	return interceptor(ctx, in, info, handler)
}

func _ChangefeedService_ListTiCDCClusters_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ClusterIdReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ChangefeedServiceServer).ListTiCDCClusters(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ChangefeedService_ListTiCDCClusters_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ChangefeedServiceServer).ListTiCDCClusters(ctx, req.(*ClusterIdReq))
	}
	return interceptor(ctx, in, info, handler)
}

// ChangefeedService_ServiceDesc is the grpc.ServiceDesc for ChangefeedService service.
// It's only intended for direct use with grpc.RegisterService,
// and not to be introspected or modified (even as a copy)
var ChangefeedService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "consoleapi.ChangefeedService",
	HandlerType: (*ChangefeedServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListChangefeeds",
			Handler:    _ChangefeedService_ListChangefeeds_Handler,
		},
		{
			MethodName: "GetChangefeed",
			Handler:    _ChangefeedService_GetChangefeed_Handler,
		},
		{
			MethodName: "DescribeSchemaTable",
			Handler:    _ChangefeedService_DescribeSchemaTable_Handler,
		},
		{
			MethodName: "GetAdminProfile",
			Handler:    _ChangefeedService_GetAdminProfile_Handler,
		},
		{
			MethodName: "ScaleChangefeed",
			Handler:    _ChangefeedService_ScaleChangefeed_Handler,
		},
		{
			MethodName: "CalChangefeedFee",
			Handler:    _ChangefeedService_CalChangefeedFee_Handler,
		},
		{
			MethodName: "ResumeChangefeed",
			Handler:    _ChangefeedService_ResumeChangefeed_Handler,
		},
		{
			MethodName: "PauseChangefeed",
			Handler:    _ChangefeedService_PauseChangefeed_Handler,
		},
		{
			MethodName: "CreateChangefeed",
			Handler:    _ChangefeedService_CreateChangefeed_Handler,
		},
		{
			MethodName: "EditChangefeed",
			Handler:    _ChangefeedService_EditChangefeed_Handler,
		},
		{
			MethodName: "DeleteChangefeed",
			Handler:    _ChangefeedService_DeleteChangefeed_Handler,
		},
		{
			MethodName: "TestChangefeed",
			Handler:    _ChangefeedService_TestChangefeed_Handler,
		},
		{
			MethodName: "GetChangefeedDetail",
			Handler:    _ChangefeedService_GetChangefeedDetail_Handler,
		},
		{
			MethodName: "GetTiCDCCluster",
			Handler:    _ChangefeedService_GetTiCDCCluster_Handler,
		},
		{
			MethodName: "ListTiCDCClusters",
			Handler:    _ChangefeedService_ListTiCDCClusters_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "consoleapi/dataflow.proto",
}

const (
	DPFeatureService_GetEnabledDPFeaturesForCluster_FullMethodName = "/consoleapi.DPFeatureService/GetEnabledDPFeaturesForCluster"
)

// DPFeatureServiceClient is the client API for DPFeatureService 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 DPFeatureServiceClient interface {
	GetEnabledDPFeaturesForCluster(ctx context.Context, in *EnabledDPFeaturesForClusterReq, opts ...grpc.CallOption) (*EnabledDPFeaturesForClusterResp, error)
}

type dPFeatureServiceClient struct {
	cc grpc.ClientConnInterface
}

func NewDPFeatureServiceClient(cc grpc.ClientConnInterface) DPFeatureServiceClient {
	return &dPFeatureServiceClient{cc}
}

func (c *dPFeatureServiceClient) GetEnabledDPFeaturesForCluster(ctx context.Context, in *EnabledDPFeaturesForClusterReq, opts ...grpc.CallOption) (*EnabledDPFeaturesForClusterResp, error) {
	out := new(EnabledDPFeaturesForClusterResp)
	err := c.cc.Invoke(ctx, DPFeatureService_GetEnabledDPFeaturesForCluster_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

// DPFeatureServiceServer is the server API for DPFeatureService service.
// All implementations must embed UnimplementedDPFeatureServiceServer
// for forward compatibility
type DPFeatureServiceServer interface {
	GetEnabledDPFeaturesForCluster(context.Context, *EnabledDPFeaturesForClusterReq) (*EnabledDPFeaturesForClusterResp, error)
	mustEmbedUnimplementedDPFeatureServiceServer()
}

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

func (UnimplementedDPFeatureServiceServer) GetEnabledDPFeaturesForCluster(context.Context, *EnabledDPFeaturesForClusterReq) (*EnabledDPFeaturesForClusterResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetEnabledDPFeaturesForCluster not implemented")
}
func (UnimplementedDPFeatureServiceServer) mustEmbedUnimplementedDPFeatureServiceServer() {}

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

func RegisterDPFeatureServiceServer(s grpc.ServiceRegistrar, srv DPFeatureServiceServer) {
	s.RegisterService(&DPFeatureService_ServiceDesc, srv)
}

func _DPFeatureService_GetEnabledDPFeaturesForCluster_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(EnabledDPFeaturesForClusterReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DPFeatureServiceServer).GetEnabledDPFeaturesForCluster(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DPFeatureService_GetEnabledDPFeaturesForCluster_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DPFeatureServiceServer).GetEnabledDPFeaturesForCluster(ctx, req.(*EnabledDPFeaturesForClusterReq))
	}
	return interceptor(ctx, in, info, handler)
}

// DPFeatureService_ServiceDesc is the grpc.ServiceDesc for DPFeatureService service.
// It's only intended for direct use with grpc.RegisterService,
// and not to be introspected or modified (even as a copy)
var DPFeatureService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "consoleapi.DPFeatureService",
	HandlerType: (*DPFeatureServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetEnabledDPFeaturesForCluster",
			Handler:    _DPFeatureService_GetEnabledDPFeaturesForCluster_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "consoleapi/dataflow.proto",
}

const (
	ChangefeedSpecService_List_FullMethodName = "/consoleapi.ChangefeedSpecService/List"
)

// ChangefeedSpecServiceClient is the client API for ChangefeedSpecService 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 ChangefeedSpecServiceClient interface {
	List(ctx context.Context, in *ChangefeedSpecListReq, opts ...grpc.CallOption) (*ChangefeedSpecs, error)
}

type changefeedSpecServiceClient struct {
	cc grpc.ClientConnInterface
}

func NewChangefeedSpecServiceClient(cc grpc.ClientConnInterface) ChangefeedSpecServiceClient {
	return &changefeedSpecServiceClient{cc}
}

func (c *changefeedSpecServiceClient) List(ctx context.Context, in *ChangefeedSpecListReq, opts ...grpc.CallOption) (*ChangefeedSpecs, error) {
	out := new(ChangefeedSpecs)
	err := c.cc.Invoke(ctx, ChangefeedSpecService_List_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

// ChangefeedSpecServiceServer is the server API for ChangefeedSpecService service.
// All implementations must embed UnimplementedChangefeedSpecServiceServer
// for forward compatibility
type ChangefeedSpecServiceServer interface {
	List(context.Context, *ChangefeedSpecListReq) (*ChangefeedSpecs, error)
	mustEmbedUnimplementedChangefeedSpecServiceServer()
}

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

func (UnimplementedChangefeedSpecServiceServer) List(context.Context, *ChangefeedSpecListReq) (*ChangefeedSpecs, error) {
	return nil, status.Errorf(codes.Unimplemented, "method List not implemented")
}
func (UnimplementedChangefeedSpecServiceServer) mustEmbedUnimplementedChangefeedSpecServiceServer() {}

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

func RegisterChangefeedSpecServiceServer(s grpc.ServiceRegistrar, srv ChangefeedSpecServiceServer) {
	s.RegisterService(&ChangefeedSpecService_ServiceDesc, srv)
}

func _ChangefeedSpecService_List_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ChangefeedSpecListReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ChangefeedSpecServiceServer).List(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ChangefeedSpecService_List_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ChangefeedSpecServiceServer).List(ctx, req.(*ChangefeedSpecListReq))
	}
	return interceptor(ctx, in, info, handler)
}

// ChangefeedSpecService_ServiceDesc is the grpc.ServiceDesc for ChangefeedSpecService service.
// It's only intended for direct use with grpc.RegisterService,
// and not to be introspected or modified (even as a copy)
var ChangefeedSpecService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "consoleapi.ChangefeedSpecService",
	HandlerType: (*ChangefeedSpecServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "List",
			Handler:    _ChangefeedSpecService_List_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "consoleapi/dataflow.proto",
}

const (
	OpsInternalService_ApplyConfigChanges_FullMethodName                    = "/consoleapi.OpsInternalService/ApplyConfigChanges"
	OpsInternalService_UpdateTiCDCClusterStorage_FullMethodName             = "/consoleapi.OpsInternalService/UpdateTiCDCClusterStorage"
	OpsInternalService_ListInternalChangefeeds_FullMethodName               = "/consoleapi.OpsInternalService/ListInternalChangefeeds"
	OpsInternalService_GetInternalChangefeed_FullMethodName                 = "/consoleapi.OpsInternalService/GetInternalChangefeed"
	OpsInternalService_RestartChangefeed_FullMethodName                     = "/consoleapi.OpsInternalService/RestartChangefeed"
	OpsInternalService_PauseChangefeed_FullMethodName                       = "/consoleapi.OpsInternalService/PauseChangefeed"
	OpsInternalService_ResumeChangefeed_FullMethodName                      = "/consoleapi.OpsInternalService/ResumeChangefeed"
	OpsInternalService_GetInternalTiCDCCluster_FullMethodName               = "/consoleapi.OpsInternalService/GetInternalTiCDCCluster"
	OpsInternalService_RestartTiCDCCluster_FullMethodName                   = "/consoleapi.OpsInternalService/RestartTiCDCCluster"
	OpsInternalService_PauseClusterChangefeeds_FullMethodName               = "/consoleapi.OpsInternalService/PauseClusterChangefeeds"
	OpsInternalService_ResumeClusterChangefeeds_FullMethodName              = "/consoleapi.OpsInternalService/ResumeClusterChangefeeds"
	OpsInternalService_UpdateTableFilterOfClusterChangefeeds_FullMethodName = "/consoleapi.OpsInternalService/UpdateTableFilterOfClusterChangefeeds"
)

// OpsInternalServiceClient is the client API for OpsInternalService 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 OpsInternalServiceClient interface {
	ApplyConfigChanges(ctx context.Context, in *ApplyConfigChangesReq, opts ...grpc.CallOption) (*ApplyConfigChangesResp, error)
	UpdateTiCDCClusterStorage(ctx context.Context, in *UpdateTiCDCClusterStorageReq, opts ...grpc.CallOption) (*UpdateTiCDCClusterStorageResp, error)
	ListInternalChangefeeds(ctx context.Context, in *ListInternalChangefeedsRequest, opts ...grpc.CallOption) (*ListInternalChangefeedsResponse, error)
	GetInternalChangefeed(ctx context.Context, in *GetInternalChangefeedRequest, opts ...grpc.CallOption) (*InternalChangefeed, error)
	RestartChangefeed(ctx context.Context, in *RestartChangefeedRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	PauseChangefeed(ctx context.Context, in *PauseChangefeedRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ResumeChangefeed(ctx context.Context, in *ResumeChangefeedRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetInternalTiCDCCluster(ctx context.Context, in *GetInternalTiCDCClusterRequest, opts ...grpc.CallOption) (*InternalTiCDCCluster, error)
	RestartTiCDCCluster(ctx context.Context, in *RestartTiCDCClusterRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	PauseClusterChangefeeds(ctx context.Context, in *PauseClusterChangefeedsRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ResumeClusterChangefeeds(ctx context.Context, in *ResumeClusterChangefeedsRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	UpdateTableFilterOfClusterChangefeeds(ctx context.Context, in *UpdateTableFilterOfClusterChangefeedsRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

type opsInternalServiceClient struct {
	cc grpc.ClientConnInterface
}

func NewOpsInternalServiceClient(cc grpc.ClientConnInterface) OpsInternalServiceClient {
	return &opsInternalServiceClient{cc}
}

func (c *opsInternalServiceClient) ApplyConfigChanges(ctx context.Context, in *ApplyConfigChangesReq, opts ...grpc.CallOption) (*ApplyConfigChangesResp, error) {
	out := new(ApplyConfigChangesResp)
	err := c.cc.Invoke(ctx, OpsInternalService_ApplyConfigChanges_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *opsInternalServiceClient) UpdateTiCDCClusterStorage(ctx context.Context, in *UpdateTiCDCClusterStorageReq, opts ...grpc.CallOption) (*UpdateTiCDCClusterStorageResp, error) {
	out := new(UpdateTiCDCClusterStorageResp)
	err := c.cc.Invoke(ctx, OpsInternalService_UpdateTiCDCClusterStorage_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *opsInternalServiceClient) ListInternalChangefeeds(ctx context.Context, in *ListInternalChangefeedsRequest, opts ...grpc.CallOption) (*ListInternalChangefeedsResponse, error) {
	out := new(ListInternalChangefeedsResponse)
	err := c.cc.Invoke(ctx, OpsInternalService_ListInternalChangefeeds_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *opsInternalServiceClient) GetInternalChangefeed(ctx context.Context, in *GetInternalChangefeedRequest, opts ...grpc.CallOption) (*InternalChangefeed, error) {
	out := new(InternalChangefeed)
	err := c.cc.Invoke(ctx, OpsInternalService_GetInternalChangefeed_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *opsInternalServiceClient) RestartChangefeed(ctx context.Context, in *RestartChangefeedRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
	out := new(emptypb.Empty)
	err := c.cc.Invoke(ctx, OpsInternalService_RestartChangefeed_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *opsInternalServiceClient) PauseChangefeed(ctx context.Context, in *PauseChangefeedRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
	out := new(emptypb.Empty)
	err := c.cc.Invoke(ctx, OpsInternalService_PauseChangefeed_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *opsInternalServiceClient) ResumeChangefeed(ctx context.Context, in *ResumeChangefeedRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
	out := new(emptypb.Empty)
	err := c.cc.Invoke(ctx, OpsInternalService_ResumeChangefeed_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *opsInternalServiceClient) GetInternalTiCDCCluster(ctx context.Context, in *GetInternalTiCDCClusterRequest, opts ...grpc.CallOption) (*InternalTiCDCCluster, error) {
	out := new(InternalTiCDCCluster)
	err := c.cc.Invoke(ctx, OpsInternalService_GetInternalTiCDCCluster_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *opsInternalServiceClient) RestartTiCDCCluster(ctx context.Context, in *RestartTiCDCClusterRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
	out := new(emptypb.Empty)
	err := c.cc.Invoke(ctx, OpsInternalService_RestartTiCDCCluster_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *opsInternalServiceClient) PauseClusterChangefeeds(ctx context.Context, in *PauseClusterChangefeedsRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
	out := new(emptypb.Empty)
	err := c.cc.Invoke(ctx, OpsInternalService_PauseClusterChangefeeds_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *opsInternalServiceClient) ResumeClusterChangefeeds(ctx context.Context, in *ResumeClusterChangefeedsRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
	out := new(emptypb.Empty)
	err := c.cc.Invoke(ctx, OpsInternalService_ResumeClusterChangefeeds_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *opsInternalServiceClient) UpdateTableFilterOfClusterChangefeeds(ctx context.Context, in *UpdateTableFilterOfClusterChangefeedsRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
	out := new(emptypb.Empty)
	err := c.cc.Invoke(ctx, OpsInternalService_UpdateTableFilterOfClusterChangefeeds_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

// OpsInternalServiceServer is the server API for OpsInternalService service.
// All implementations must embed UnimplementedOpsInternalServiceServer
// for forward compatibility
type OpsInternalServiceServer interface {
	ApplyConfigChanges(context.Context, *ApplyConfigChangesReq) (*ApplyConfigChangesResp, error)
	UpdateTiCDCClusterStorage(context.Context, *UpdateTiCDCClusterStorageReq) (*UpdateTiCDCClusterStorageResp, error)
	ListInternalChangefeeds(context.Context, *ListInternalChangefeedsRequest) (*ListInternalChangefeedsResponse, error)
	GetInternalChangefeed(context.Context, *GetInternalChangefeedRequest) (*InternalChangefeed, error)
	RestartChangefeed(context.Context, *RestartChangefeedRequest) (*emptypb.Empty, error)
	PauseChangefeed(context.Context, *PauseChangefeedRequest) (*emptypb.Empty, error)
	ResumeChangefeed(context.Context, *ResumeChangefeedRequest) (*emptypb.Empty, error)
	GetInternalTiCDCCluster(context.Context, *GetInternalTiCDCClusterRequest) (*InternalTiCDCCluster, error)
	RestartTiCDCCluster(context.Context, *RestartTiCDCClusterRequest) (*emptypb.Empty, error)
	PauseClusterChangefeeds(context.Context, *PauseClusterChangefeedsRequest) (*emptypb.Empty, error)
	ResumeClusterChangefeeds(context.Context, *ResumeClusterChangefeedsRequest) (*emptypb.Empty, error)
	UpdateTableFilterOfClusterChangefeeds(context.Context, *UpdateTableFilterOfClusterChangefeedsRequest) (*emptypb.Empty, error)
	mustEmbedUnimplementedOpsInternalServiceServer()
}

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

func (UnimplementedOpsInternalServiceServer) ApplyConfigChanges(context.Context, *ApplyConfigChangesReq) (*ApplyConfigChangesResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ApplyConfigChanges not implemented")
}
func (UnimplementedOpsInternalServiceServer) UpdateTiCDCClusterStorage(context.Context, *UpdateTiCDCClusterStorageReq) (*UpdateTiCDCClusterStorageResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method UpdateTiCDCClusterStorage not implemented")
}
func (UnimplementedOpsInternalServiceServer) ListInternalChangefeeds(context.Context, *ListInternalChangefeedsRequest) (*ListInternalChangefeedsResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListInternalChangefeeds not implemented")
}
func (UnimplementedOpsInternalServiceServer) GetInternalChangefeed(context.Context, *GetInternalChangefeedRequest) (*InternalChangefeed, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetInternalChangefeed not implemented")
}
func (UnimplementedOpsInternalServiceServer) RestartChangefeed(context.Context, *RestartChangefeedRequest) (*emptypb.Empty, error) {
	return nil, status.Errorf(codes.Unimplemented, "method RestartChangefeed not implemented")
}
func (UnimplementedOpsInternalServiceServer) PauseChangefeed(context.Context, *PauseChangefeedRequest) (*emptypb.Empty, error) {
	return nil, status.Errorf(codes.Unimplemented, "method PauseChangefeed not implemented")
}
func (UnimplementedOpsInternalServiceServer) ResumeChangefeed(context.Context, *ResumeChangefeedRequest) (*emptypb.Empty, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ResumeChangefeed not implemented")
}
func (UnimplementedOpsInternalServiceServer) GetInternalTiCDCCluster(context.Context, *GetInternalTiCDCClusterRequest) (*InternalTiCDCCluster, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetInternalTiCDCCluster not implemented")
}
func (UnimplementedOpsInternalServiceServer) RestartTiCDCCluster(context.Context, *RestartTiCDCClusterRequest) (*emptypb.Empty, error) {
	return nil, status.Errorf(codes.Unimplemented, "method RestartTiCDCCluster not implemented")
}
func (UnimplementedOpsInternalServiceServer) PauseClusterChangefeeds(context.Context, *PauseClusterChangefeedsRequest) (*emptypb.Empty, error) {
	return nil, status.Errorf(codes.Unimplemented, "method PauseClusterChangefeeds not implemented")
}
func (UnimplementedOpsInternalServiceServer) ResumeClusterChangefeeds(context.Context, *ResumeClusterChangefeedsRequest) (*emptypb.Empty, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ResumeClusterChangefeeds not implemented")
}
func (UnimplementedOpsInternalServiceServer) UpdateTableFilterOfClusterChangefeeds(context.Context, *UpdateTableFilterOfClusterChangefeedsRequest) (*emptypb.Empty, error) {
	return nil, status.Errorf(codes.Unimplemented, "method UpdateTableFilterOfClusterChangefeeds not implemented")
}
func (UnimplementedOpsInternalServiceServer) mustEmbedUnimplementedOpsInternalServiceServer() {}

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

func RegisterOpsInternalServiceServer(s grpc.ServiceRegistrar, srv OpsInternalServiceServer) {
	s.RegisterService(&OpsInternalService_ServiceDesc, srv)
}

func _OpsInternalService_ApplyConfigChanges_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ApplyConfigChangesReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(OpsInternalServiceServer).ApplyConfigChanges(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: OpsInternalService_ApplyConfigChanges_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(OpsInternalServiceServer).ApplyConfigChanges(ctx, req.(*ApplyConfigChangesReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _OpsInternalService_UpdateTiCDCClusterStorage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(UpdateTiCDCClusterStorageReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(OpsInternalServiceServer).UpdateTiCDCClusterStorage(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: OpsInternalService_UpdateTiCDCClusterStorage_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(OpsInternalServiceServer).UpdateTiCDCClusterStorage(ctx, req.(*UpdateTiCDCClusterStorageReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _OpsInternalService_ListInternalChangefeeds_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListInternalChangefeedsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(OpsInternalServiceServer).ListInternalChangefeeds(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: OpsInternalService_ListInternalChangefeeds_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(OpsInternalServiceServer).ListInternalChangefeeds(ctx, req.(*ListInternalChangefeedsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _OpsInternalService_GetInternalChangefeed_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetInternalChangefeedRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(OpsInternalServiceServer).GetInternalChangefeed(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: OpsInternalService_GetInternalChangefeed_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(OpsInternalServiceServer).GetInternalChangefeed(ctx, req.(*GetInternalChangefeedRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _OpsInternalService_RestartChangefeed_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(RestartChangefeedRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(OpsInternalServiceServer).RestartChangefeed(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: OpsInternalService_RestartChangefeed_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(OpsInternalServiceServer).RestartChangefeed(ctx, req.(*RestartChangefeedRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _OpsInternalService_PauseChangefeed_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(PauseChangefeedRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(OpsInternalServiceServer).PauseChangefeed(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: OpsInternalService_PauseChangefeed_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(OpsInternalServiceServer).PauseChangefeed(ctx, req.(*PauseChangefeedRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _OpsInternalService_ResumeChangefeed_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ResumeChangefeedRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(OpsInternalServiceServer).ResumeChangefeed(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: OpsInternalService_ResumeChangefeed_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(OpsInternalServiceServer).ResumeChangefeed(ctx, req.(*ResumeChangefeedRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _OpsInternalService_GetInternalTiCDCCluster_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetInternalTiCDCClusterRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(OpsInternalServiceServer).GetInternalTiCDCCluster(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: OpsInternalService_GetInternalTiCDCCluster_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(OpsInternalServiceServer).GetInternalTiCDCCluster(ctx, req.(*GetInternalTiCDCClusterRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _OpsInternalService_RestartTiCDCCluster_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(RestartTiCDCClusterRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(OpsInternalServiceServer).RestartTiCDCCluster(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: OpsInternalService_RestartTiCDCCluster_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(OpsInternalServiceServer).RestartTiCDCCluster(ctx, req.(*RestartTiCDCClusterRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _OpsInternalService_PauseClusterChangefeeds_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(PauseClusterChangefeedsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(OpsInternalServiceServer).PauseClusterChangefeeds(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: OpsInternalService_PauseClusterChangefeeds_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(OpsInternalServiceServer).PauseClusterChangefeeds(ctx, req.(*PauseClusterChangefeedsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _OpsInternalService_ResumeClusterChangefeeds_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ResumeClusterChangefeedsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(OpsInternalServiceServer).ResumeClusterChangefeeds(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: OpsInternalService_ResumeClusterChangefeeds_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(OpsInternalServiceServer).ResumeClusterChangefeeds(ctx, req.(*ResumeClusterChangefeedsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _OpsInternalService_UpdateTableFilterOfClusterChangefeeds_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(UpdateTableFilterOfClusterChangefeedsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(OpsInternalServiceServer).UpdateTableFilterOfClusterChangefeeds(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: OpsInternalService_UpdateTableFilterOfClusterChangefeeds_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(OpsInternalServiceServer).UpdateTableFilterOfClusterChangefeeds(ctx, req.(*UpdateTableFilterOfClusterChangefeedsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

// OpsInternalService_ServiceDesc is the grpc.ServiceDesc for OpsInternalService service.
// It's only intended for direct use with grpc.RegisterService,
// and not to be introspected or modified (even as a copy)
var OpsInternalService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "consoleapi.OpsInternalService",
	HandlerType: (*OpsInternalServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ApplyConfigChanges",
			Handler:    _OpsInternalService_ApplyConfigChanges_Handler,
		},
		{
			MethodName: "UpdateTiCDCClusterStorage",
			Handler:    _OpsInternalService_UpdateTiCDCClusterStorage_Handler,
		},
		{
			MethodName: "ListInternalChangefeeds",
			Handler:    _OpsInternalService_ListInternalChangefeeds_Handler,
		},
		{
			MethodName: "GetInternalChangefeed",
			Handler:    _OpsInternalService_GetInternalChangefeed_Handler,
		},
		{
			MethodName: "RestartChangefeed",
			Handler:    _OpsInternalService_RestartChangefeed_Handler,
		},
		{
			MethodName: "PauseChangefeed",
			Handler:    _OpsInternalService_PauseChangefeed_Handler,
		},
		{
			MethodName: "ResumeChangefeed",
			Handler:    _OpsInternalService_ResumeChangefeed_Handler,
		},
		{
			MethodName: "GetInternalTiCDCCluster",
			Handler:    _OpsInternalService_GetInternalTiCDCCluster_Handler,
		},
		{
			MethodName: "RestartTiCDCCluster",
			Handler:    _OpsInternalService_RestartTiCDCCluster_Handler,
		},
		{
			MethodName: "PauseClusterChangefeeds",
			Handler:    _OpsInternalService_PauseClusterChangefeeds_Handler,
		},
		{
			MethodName: "ResumeClusterChangefeeds",
			Handler:    _OpsInternalService_ResumeClusterChangefeeds_Handler,
		},
		{
			MethodName: "UpdateTableFilterOfClusterChangefeeds",
			Handler:    _OpsInternalService_UpdateTableFilterOfClusterChangefeeds_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "consoleapi/dataflow.proto",
}

const (
	SinkEndpointService_CreateSinkEndpoint_FullMethodName                       = "/consoleapi.SinkEndpointService/CreateSinkEndpoint"
	SinkEndpointService_ListSinkEndpoints_FullMethodName                        = "/consoleapi.SinkEndpointService/ListSinkEndpoints"
	SinkEndpointService_GetSinkEndpoint_FullMethodName                          = "/consoleapi.SinkEndpointService/GetSinkEndpoint"
	SinkEndpointService_DeleteSinkEndpoint_FullMethodName                       = "/consoleapi.SinkEndpointService/DeleteSinkEndpoint"
	SinkEndpointService_ListSinkAvailabilityZones_FullMethodName                = "/consoleapi.SinkEndpointService/ListSinkAvailabilityZones"
	SinkEndpointService_DescribeEndpointServiceAvailabilityZones_FullMethodName = "/consoleapi.SinkEndpointService/DescribeEndpointServiceAvailabilityZones"
	SinkEndpointService_GenerateSinkAdvertisedListener_FullMethodName           = "/consoleapi.SinkEndpointService/GenerateSinkAdvertisedListener"
	SinkEndpointService_ValidateSinkAdvertisedListenerDomain_FullMethodName     = "/consoleapi.SinkEndpointService/ValidateSinkAdvertisedListenerDomain"
	SinkEndpointService_GetSinkEndpointAuthInfo_FullMethodName                  = "/consoleapi.SinkEndpointService/GetSinkEndpointAuthInfo"
)

// SinkEndpointServiceClient is the client API for SinkEndpointService 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 SinkEndpointServiceClient interface {
	CreateSinkEndpoint(ctx context.Context, in *CreateSinkEndpointRequest, opts ...grpc.CallOption) (*SinkEndpoint, error)
	ListSinkEndpoints(ctx context.Context, in *ListSinkEndpointsRequest, opts ...grpc.CallOption) (*ListSinkEndpointsResponse, error)
	GetSinkEndpoint(ctx context.Context, in *GetSinkEndpointRequest, opts ...grpc.CallOption) (*SinkEndpoint, error)
	DeleteSinkEndpoint(ctx context.Context, in *DeleteSinkEndpointRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ListSinkAvailabilityZones(ctx context.Context, in *ListSinkAvailabilityZonesRequest, opts ...grpc.CallOption) (*ListSinkAvailabilityZonesResponse, error)
	DescribeEndpointServiceAvailabilityZones(ctx context.Context, in *DescribeEndpointServiceAvailabilityZonesRequest, opts ...grpc.CallOption) (*DescribeEndpointServiceAvailabilityZonesResponse, error)
	GenerateSinkAdvertisedListener(ctx context.Context, in *GenerateSinkAdvertisedListenerRequest, opts ...grpc.CallOption) (*GenerateSinkAdvertisedListenerResponse, error)
	ValidateSinkAdvertisedListenerDomain(ctx context.Context, in *ValidateSinkAdvertisedListenerDomainRequest, opts ...grpc.CallOption) (*ValidateSinkAdvertisedListenerDomainResponse, error)
	GetSinkEndpointAuthInfo(ctx context.Context, in *GetSinkEndpointAuthInfoRequest, opts ...grpc.CallOption) (*GetSinkEndpointAuthInfoResponse, error)
}

type sinkEndpointServiceClient struct {
	cc grpc.ClientConnInterface
}

func NewSinkEndpointServiceClient(cc grpc.ClientConnInterface) SinkEndpointServiceClient {
	return &sinkEndpointServiceClient{cc}
}

func (c *sinkEndpointServiceClient) CreateSinkEndpoint(ctx context.Context, in *CreateSinkEndpointRequest, opts ...grpc.CallOption) (*SinkEndpoint, error) {
	out := new(SinkEndpoint)
	err := c.cc.Invoke(ctx, SinkEndpointService_CreateSinkEndpoint_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *sinkEndpointServiceClient) ListSinkEndpoints(ctx context.Context, in *ListSinkEndpointsRequest, opts ...grpc.CallOption) (*ListSinkEndpointsResponse, error) {
	out := new(ListSinkEndpointsResponse)
	err := c.cc.Invoke(ctx, SinkEndpointService_ListSinkEndpoints_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *sinkEndpointServiceClient) GetSinkEndpoint(ctx context.Context, in *GetSinkEndpointRequest, opts ...grpc.CallOption) (*SinkEndpoint, error) {
	out := new(SinkEndpoint)
	err := c.cc.Invoke(ctx, SinkEndpointService_GetSinkEndpoint_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *sinkEndpointServiceClient) DeleteSinkEndpoint(ctx context.Context, in *DeleteSinkEndpointRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
	out := new(emptypb.Empty)
	err := c.cc.Invoke(ctx, SinkEndpointService_DeleteSinkEndpoint_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *sinkEndpointServiceClient) ListSinkAvailabilityZones(ctx context.Context, in *ListSinkAvailabilityZonesRequest, opts ...grpc.CallOption) (*ListSinkAvailabilityZonesResponse, error) {
	out := new(ListSinkAvailabilityZonesResponse)
	err := c.cc.Invoke(ctx, SinkEndpointService_ListSinkAvailabilityZones_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *sinkEndpointServiceClient) DescribeEndpointServiceAvailabilityZones(ctx context.Context, in *DescribeEndpointServiceAvailabilityZonesRequest, opts ...grpc.CallOption) (*DescribeEndpointServiceAvailabilityZonesResponse, error) {
	out := new(DescribeEndpointServiceAvailabilityZonesResponse)
	err := c.cc.Invoke(ctx, SinkEndpointService_DescribeEndpointServiceAvailabilityZones_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *sinkEndpointServiceClient) GenerateSinkAdvertisedListener(ctx context.Context, in *GenerateSinkAdvertisedListenerRequest, opts ...grpc.CallOption) (*GenerateSinkAdvertisedListenerResponse, error) {
	out := new(GenerateSinkAdvertisedListenerResponse)
	err := c.cc.Invoke(ctx, SinkEndpointService_GenerateSinkAdvertisedListener_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *sinkEndpointServiceClient) ValidateSinkAdvertisedListenerDomain(ctx context.Context, in *ValidateSinkAdvertisedListenerDomainRequest, opts ...grpc.CallOption) (*ValidateSinkAdvertisedListenerDomainResponse, error) {
	out := new(ValidateSinkAdvertisedListenerDomainResponse)
	err := c.cc.Invoke(ctx, SinkEndpointService_ValidateSinkAdvertisedListenerDomain_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *sinkEndpointServiceClient) GetSinkEndpointAuthInfo(ctx context.Context, in *GetSinkEndpointAuthInfoRequest, opts ...grpc.CallOption) (*GetSinkEndpointAuthInfoResponse, error) {
	out := new(GetSinkEndpointAuthInfoResponse)
	err := c.cc.Invoke(ctx, SinkEndpointService_GetSinkEndpointAuthInfo_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

// SinkEndpointServiceServer is the server API for SinkEndpointService service.
// All implementations must embed UnimplementedSinkEndpointServiceServer
// for forward compatibility
type SinkEndpointServiceServer interface {
	CreateSinkEndpoint(context.Context, *CreateSinkEndpointRequest) (*SinkEndpoint, error)
	ListSinkEndpoints(context.Context, *ListSinkEndpointsRequest) (*ListSinkEndpointsResponse, error)
	GetSinkEndpoint(context.Context, *GetSinkEndpointRequest) (*SinkEndpoint, error)
	DeleteSinkEndpoint(context.Context, *DeleteSinkEndpointRequest) (*emptypb.Empty, error)
	ListSinkAvailabilityZones(context.Context, *ListSinkAvailabilityZonesRequest) (*ListSinkAvailabilityZonesResponse, error)
	DescribeEndpointServiceAvailabilityZones(context.Context, *DescribeEndpointServiceAvailabilityZonesRequest) (*DescribeEndpointServiceAvailabilityZonesResponse, error)
	GenerateSinkAdvertisedListener(context.Context, *GenerateSinkAdvertisedListenerRequest) (*GenerateSinkAdvertisedListenerResponse, error)
	ValidateSinkAdvertisedListenerDomain(context.Context, *ValidateSinkAdvertisedListenerDomainRequest) (*ValidateSinkAdvertisedListenerDomainResponse, error)
	GetSinkEndpointAuthInfo(context.Context, *GetSinkEndpointAuthInfoRequest) (*GetSinkEndpointAuthInfoResponse, error)
	mustEmbedUnimplementedSinkEndpointServiceServer()
}

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

func (UnimplementedSinkEndpointServiceServer) CreateSinkEndpoint(context.Context, *CreateSinkEndpointRequest) (*SinkEndpoint, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CreateSinkEndpoint not implemented")
}
func (UnimplementedSinkEndpointServiceServer) ListSinkEndpoints(context.Context, *ListSinkEndpointsRequest) (*ListSinkEndpointsResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListSinkEndpoints not implemented")
}
func (UnimplementedSinkEndpointServiceServer) GetSinkEndpoint(context.Context, *GetSinkEndpointRequest) (*SinkEndpoint, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetSinkEndpoint not implemented")
}
func (UnimplementedSinkEndpointServiceServer) DeleteSinkEndpoint(context.Context, *DeleteSinkEndpointRequest) (*emptypb.Empty, error) {
	return nil, status.Errorf(codes.Unimplemented, "method DeleteSinkEndpoint not implemented")
}
func (UnimplementedSinkEndpointServiceServer) ListSinkAvailabilityZones(context.Context, *ListSinkAvailabilityZonesRequest) (*ListSinkAvailabilityZonesResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListSinkAvailabilityZones not implemented")
}
func (UnimplementedSinkEndpointServiceServer) DescribeEndpointServiceAvailabilityZones(context.Context, *DescribeEndpointServiceAvailabilityZonesRequest) (*DescribeEndpointServiceAvailabilityZonesResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method DescribeEndpointServiceAvailabilityZones not implemented")
}
func (UnimplementedSinkEndpointServiceServer) GenerateSinkAdvertisedListener(context.Context, *GenerateSinkAdvertisedListenerRequest) (*GenerateSinkAdvertisedListenerResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GenerateSinkAdvertisedListener not implemented")
}
func (UnimplementedSinkEndpointServiceServer) ValidateSinkAdvertisedListenerDomain(context.Context, *ValidateSinkAdvertisedListenerDomainRequest) (*ValidateSinkAdvertisedListenerDomainResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ValidateSinkAdvertisedListenerDomain not implemented")
}
func (UnimplementedSinkEndpointServiceServer) GetSinkEndpointAuthInfo(context.Context, *GetSinkEndpointAuthInfoRequest) (*GetSinkEndpointAuthInfoResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetSinkEndpointAuthInfo not implemented")
}
func (UnimplementedSinkEndpointServiceServer) mustEmbedUnimplementedSinkEndpointServiceServer() {}

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

func RegisterSinkEndpointServiceServer(s grpc.ServiceRegistrar, srv SinkEndpointServiceServer) {
	s.RegisterService(&SinkEndpointService_ServiceDesc, srv)
}

func _SinkEndpointService_CreateSinkEndpoint_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CreateSinkEndpointRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(SinkEndpointServiceServer).CreateSinkEndpoint(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: SinkEndpointService_CreateSinkEndpoint_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(SinkEndpointServiceServer).CreateSinkEndpoint(ctx, req.(*CreateSinkEndpointRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _SinkEndpointService_ListSinkEndpoints_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListSinkEndpointsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(SinkEndpointServiceServer).ListSinkEndpoints(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: SinkEndpointService_ListSinkEndpoints_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(SinkEndpointServiceServer).ListSinkEndpoints(ctx, req.(*ListSinkEndpointsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _SinkEndpointService_GetSinkEndpoint_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetSinkEndpointRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(SinkEndpointServiceServer).GetSinkEndpoint(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: SinkEndpointService_GetSinkEndpoint_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(SinkEndpointServiceServer).GetSinkEndpoint(ctx, req.(*GetSinkEndpointRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _SinkEndpointService_DeleteSinkEndpoint_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeleteSinkEndpointRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(SinkEndpointServiceServer).DeleteSinkEndpoint(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: SinkEndpointService_DeleteSinkEndpoint_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(SinkEndpointServiceServer).DeleteSinkEndpoint(ctx, req.(*DeleteSinkEndpointRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _SinkEndpointService_ListSinkAvailabilityZones_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListSinkAvailabilityZonesRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(SinkEndpointServiceServer).ListSinkAvailabilityZones(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: SinkEndpointService_ListSinkAvailabilityZones_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(SinkEndpointServiceServer).ListSinkAvailabilityZones(ctx, req.(*ListSinkAvailabilityZonesRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _SinkEndpointService_DescribeEndpointServiceAvailabilityZones_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DescribeEndpointServiceAvailabilityZonesRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(SinkEndpointServiceServer).DescribeEndpointServiceAvailabilityZones(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: SinkEndpointService_DescribeEndpointServiceAvailabilityZones_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(SinkEndpointServiceServer).DescribeEndpointServiceAvailabilityZones(ctx, req.(*DescribeEndpointServiceAvailabilityZonesRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _SinkEndpointService_GenerateSinkAdvertisedListener_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GenerateSinkAdvertisedListenerRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(SinkEndpointServiceServer).GenerateSinkAdvertisedListener(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: SinkEndpointService_GenerateSinkAdvertisedListener_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(SinkEndpointServiceServer).GenerateSinkAdvertisedListener(ctx, req.(*GenerateSinkAdvertisedListenerRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _SinkEndpointService_ValidateSinkAdvertisedListenerDomain_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ValidateSinkAdvertisedListenerDomainRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(SinkEndpointServiceServer).ValidateSinkAdvertisedListenerDomain(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: SinkEndpointService_ValidateSinkAdvertisedListenerDomain_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(SinkEndpointServiceServer).ValidateSinkAdvertisedListenerDomain(ctx, req.(*ValidateSinkAdvertisedListenerDomainRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _SinkEndpointService_GetSinkEndpointAuthInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetSinkEndpointAuthInfoRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(SinkEndpointServiceServer).GetSinkEndpointAuthInfo(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: SinkEndpointService_GetSinkEndpointAuthInfo_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(SinkEndpointServiceServer).GetSinkEndpointAuthInfo(ctx, req.(*GetSinkEndpointAuthInfoRequest))
	}
	return interceptor(ctx, in, info, handler)
}

// SinkEndpointService_ServiceDesc is the grpc.ServiceDesc for SinkEndpointService service.
// It's only intended for direct use with grpc.RegisterService,
// and not to be introspected or modified (even as a copy)
var SinkEndpointService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "consoleapi.SinkEndpointService",
	HandlerType: (*SinkEndpointServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateSinkEndpoint",
			Handler:    _SinkEndpointService_CreateSinkEndpoint_Handler,
		},
		{
			MethodName: "ListSinkEndpoints",
			Handler:    _SinkEndpointService_ListSinkEndpoints_Handler,
		},
		{
			MethodName: "GetSinkEndpoint",
			Handler:    _SinkEndpointService_GetSinkEndpoint_Handler,
		},
		{
			MethodName: "DeleteSinkEndpoint",
			Handler:    _SinkEndpointService_DeleteSinkEndpoint_Handler,
		},
		{
			MethodName: "ListSinkAvailabilityZones",
			Handler:    _SinkEndpointService_ListSinkAvailabilityZones_Handler,
		},
		{
			MethodName: "DescribeEndpointServiceAvailabilityZones",
			Handler:    _SinkEndpointService_DescribeEndpointServiceAvailabilityZones_Handler,
		},
		{
			MethodName: "GenerateSinkAdvertisedListener",
			Handler:    _SinkEndpointService_GenerateSinkAdvertisedListener_Handler,
		},
		{
			MethodName: "ValidateSinkAdvertisedListenerDomain",
			Handler:    _SinkEndpointService_ValidateSinkAdvertisedListenerDomain_Handler,
		},
		{
			MethodName: "GetSinkEndpointAuthInfo",
			Handler:    _SinkEndpointService_GetSinkEndpointAuthInfo_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "consoleapi/dataflow.proto",
}

const (
	DataPipelineService_CreateDataPipeline_FullMethodName                   = "/consoleapi.DataPipelineService/CreateDataPipeline"
	DataPipelineService_GetDataPipeline_FullMethodName                      = "/consoleapi.DataPipelineService/GetDataPipeline"
	DataPipelineService_ListDataPipelines_FullMethodName                    = "/consoleapi.DataPipelineService/ListDataPipelines"
	DataPipelineService_PauseDataPipeline_FullMethodName                    = "/consoleapi.DataPipelineService/PauseDataPipeline"
	DataPipelineService_EditDataPipeline_FullMethodName                     = "/consoleapi.DataPipelineService/EditDataPipeline"
	DataPipelineService_ResumeDataPipeline_FullMethodName                   = "/consoleapi.DataPipelineService/ResumeDataPipeline"
	DataPipelineService_ScaleDataPipeline_FullMethodName                    = "/consoleapi.DataPipelineService/ScaleDataPipeline"
	DataPipelineService_DeleteDataPipeline_FullMethodName                   = "/consoleapi.DataPipelineService/DeleteDataPipeline"
	DataPipelineService_ValidateDataPipelineSourceConnection_FullMethodName = "/consoleapi.DataPipelineService/ValidateDataPipelineSourceConnection"
	DataPipelineService_ValidateDataPipelineDestination_FullMethodName      = "/consoleapi.DataPipelineService/ValidateDataPipelineDestination"
	DataPipelineService_ValidateDataPipelineStaging_FullMethodName          = "/consoleapi.DataPipelineService/ValidateDataPipelineStaging"
	DataPipelineService_GetDataPipelineStagingTrust_FullMethodName          = "/consoleapi.DataPipelineService/GetDataPipelineStagingTrust"
)

// DataPipelineServiceClient is the client API for DataPipelineService 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 DataPipelineServiceClient interface {
	CreateDataPipeline(ctx context.Context, in *CreateDataPipelineRequest, opts ...grpc.CallOption) (*DataPipelineID, error)
	GetDataPipeline(ctx context.Context, in *DataPipelineID, opts ...grpc.CallOption) (*DataPipeline, error)
	// ListDataPipelines returns the same complete resource model as
	// GetDataPipeline so the Console does not need one request per list item.
	ListDataPipelines(ctx context.Context, in *ListDataPipelinesRequest, opts ...grpc.CallOption) (*ListDataPipelinesResponse, error)
	PauseDataPipeline(ctx context.Context, in *DataPipelineID, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// EditDataPipeline fully replaces all editable fields. The Pipeline must be
	// paused before this call, and ResumeDataPipeline applies the new desired
	// configuration to the stopped child resources.
	EditDataPipeline(ctx context.Context, in *EditDataPipelineRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ResumeDataPipeline(ctx context.Context, in *DataPipelineID, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// ScaleDataPipeline changes the TiCDC capacity of a running Pipeline. It is
	// separate from Edit because resizing reconciles shared TiCDC cluster
	// resources asynchronously and is only valid while the Pipeline is running.
	ScaleDataPipeline(ctx context.Context, in *ScaleDataPipelineRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	DeleteDataPipeline(ctx context.Context, in *DataPipelineID, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// ValidateDataPipelineSourceConnection verifies that the supplied TiDB
	// account can connect to the source cluster. Credentials are never returned.
	ValidateDataPipelineSourceConnection(ctx context.Context, in *ValidateDataPipelineSourceConnectionRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// ValidateDataPipelineDestination verifies that the requested destination is
	// supported and its configuration is acceptable before a Pipeline is created.
	ValidateDataPipelineDestination(ctx context.Context, in *ValidateDataPipelineDestinationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// ValidateDataPipelineStaging verifies that the staging bucket can be read
	// and written with the supplied credentials. Secrets are never returned.
	ValidateDataPipelineStaging(ctx context.Context, in *ValidateDataPipelineStagingRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// GetDataPipelineStagingTrust returns everything a customer must put in the
	// trust policy of the IAM role they intend to use for role-ARN staging
	// access, in one answer.
	//
	// Three principals assume that role, from two different systems: the
	// snapshot and incremental producers share one, and the destination uses a
	// second to validate the connection and a third to load the data. Trusting
	// only some of them yields a configuration that passes validation and then
	// fails partway through delivery, which is why they are reported together
	// rather than discovered one failure at a time.
	GetDataPipelineStagingTrust(ctx context.Context, in *GetDataPipelineStagingTrustRequest, opts ...grpc.CallOption) (*DataPipelineStagingTrust, error)
}

type dataPipelineServiceClient struct {
	cc grpc.ClientConnInterface
}

func NewDataPipelineServiceClient(cc grpc.ClientConnInterface) DataPipelineServiceClient {
	return &dataPipelineServiceClient{cc}
}

func (c *dataPipelineServiceClient) CreateDataPipeline(ctx context.Context, in *CreateDataPipelineRequest, opts ...grpc.CallOption) (*DataPipelineID, error) {
	out := new(DataPipelineID)
	err := c.cc.Invoke(ctx, DataPipelineService_CreateDataPipeline_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataPipelineServiceClient) GetDataPipeline(ctx context.Context, in *DataPipelineID, opts ...grpc.CallOption) (*DataPipeline, error) {
	out := new(DataPipeline)
	err := c.cc.Invoke(ctx, DataPipelineService_GetDataPipeline_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataPipelineServiceClient) ListDataPipelines(ctx context.Context, in *ListDataPipelinesRequest, opts ...grpc.CallOption) (*ListDataPipelinesResponse, error) {
	out := new(ListDataPipelinesResponse)
	err := c.cc.Invoke(ctx, DataPipelineService_ListDataPipelines_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataPipelineServiceClient) PauseDataPipeline(ctx context.Context, in *DataPipelineID, opts ...grpc.CallOption) (*emptypb.Empty, error) {
	out := new(emptypb.Empty)
	err := c.cc.Invoke(ctx, DataPipelineService_PauseDataPipeline_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataPipelineServiceClient) EditDataPipeline(ctx context.Context, in *EditDataPipelineRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
	out := new(emptypb.Empty)
	err := c.cc.Invoke(ctx, DataPipelineService_EditDataPipeline_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataPipelineServiceClient) ResumeDataPipeline(ctx context.Context, in *DataPipelineID, opts ...grpc.CallOption) (*emptypb.Empty, error) {
	out := new(emptypb.Empty)
	err := c.cc.Invoke(ctx, DataPipelineService_ResumeDataPipeline_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataPipelineServiceClient) ScaleDataPipeline(ctx context.Context, in *ScaleDataPipelineRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
	out := new(emptypb.Empty)
	err := c.cc.Invoke(ctx, DataPipelineService_ScaleDataPipeline_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataPipelineServiceClient) DeleteDataPipeline(ctx context.Context, in *DataPipelineID, opts ...grpc.CallOption) (*emptypb.Empty, error) {
	out := new(emptypb.Empty)
	err := c.cc.Invoke(ctx, DataPipelineService_DeleteDataPipeline_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataPipelineServiceClient) ValidateDataPipelineSourceConnection(ctx context.Context, in *ValidateDataPipelineSourceConnectionRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
	out := new(emptypb.Empty)
	err := c.cc.Invoke(ctx, DataPipelineService_ValidateDataPipelineSourceConnection_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataPipelineServiceClient) ValidateDataPipelineDestination(ctx context.Context, in *ValidateDataPipelineDestinationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
	out := new(emptypb.Empty)
	err := c.cc.Invoke(ctx, DataPipelineService_ValidateDataPipelineDestination_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataPipelineServiceClient) ValidateDataPipelineStaging(ctx context.Context, in *ValidateDataPipelineStagingRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
	out := new(emptypb.Empty)
	err := c.cc.Invoke(ctx, DataPipelineService_ValidateDataPipelineStaging_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataPipelineServiceClient) GetDataPipelineStagingTrust(ctx context.Context, in *GetDataPipelineStagingTrustRequest, opts ...grpc.CallOption) (*DataPipelineStagingTrust, error) {
	out := new(DataPipelineStagingTrust)
	err := c.cc.Invoke(ctx, DataPipelineService_GetDataPipelineStagingTrust_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

// DataPipelineServiceServer is the server API for DataPipelineService service.
// All implementations must embed UnimplementedDataPipelineServiceServer
// for forward compatibility
type DataPipelineServiceServer interface {
	CreateDataPipeline(context.Context, *CreateDataPipelineRequest) (*DataPipelineID, error)
	GetDataPipeline(context.Context, *DataPipelineID) (*DataPipeline, error)
	// ListDataPipelines returns the same complete resource model as
	// GetDataPipeline so the Console does not need one request per list item.
	ListDataPipelines(context.Context, *ListDataPipelinesRequest) (*ListDataPipelinesResponse, error)
	PauseDataPipeline(context.Context, *DataPipelineID) (*emptypb.Empty, error)
	// EditDataPipeline fully replaces all editable fields. The Pipeline must be
	// paused before this call, and ResumeDataPipeline applies the new desired
	// configuration to the stopped child resources.
	EditDataPipeline(context.Context, *EditDataPipelineRequest) (*emptypb.Empty, error)
	ResumeDataPipeline(context.Context, *DataPipelineID) (*emptypb.Empty, error)
	// ScaleDataPipeline changes the TiCDC capacity of a running Pipeline. It is
	// separate from Edit because resizing reconciles shared TiCDC cluster
	// resources asynchronously and is only valid while the Pipeline is running.
	ScaleDataPipeline(context.Context, *ScaleDataPipelineRequest) (*emptypb.Empty, error)
	DeleteDataPipeline(context.Context, *DataPipelineID) (*emptypb.Empty, error)
	// ValidateDataPipelineSourceConnection verifies that the supplied TiDB
	// account can connect to the source cluster. Credentials are never returned.
	ValidateDataPipelineSourceConnection(context.Context, *ValidateDataPipelineSourceConnectionRequest) (*emptypb.Empty, error)
	// ValidateDataPipelineDestination verifies that the requested destination is
	// supported and its configuration is acceptable before a Pipeline is created.
	ValidateDataPipelineDestination(context.Context, *ValidateDataPipelineDestinationRequest) (*emptypb.Empty, error)
	// ValidateDataPipelineStaging verifies that the staging bucket can be read
	// and written with the supplied credentials. Secrets are never returned.
	ValidateDataPipelineStaging(context.Context, *ValidateDataPipelineStagingRequest) (*emptypb.Empty, error)
	// GetDataPipelineStagingTrust returns everything a customer must put in the
	// trust policy of the IAM role they intend to use for role-ARN staging
	// access, in one answer.
	//
	// Three principals assume that role, from two different systems: the
	// snapshot and incremental producers share one, and the destination uses a
	// second to validate the connection and a third to load the data. Trusting
	// only some of them yields a configuration that passes validation and then
	// fails partway through delivery, which is why they are reported together
	// rather than discovered one failure at a time.
	GetDataPipelineStagingTrust(context.Context, *GetDataPipelineStagingTrustRequest) (*DataPipelineStagingTrust, error)
	mustEmbedUnimplementedDataPipelineServiceServer()
}

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

func (UnimplementedDataPipelineServiceServer) CreateDataPipeline(context.Context, *CreateDataPipelineRequest) (*DataPipelineID, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CreateDataPipeline not implemented")
}
func (UnimplementedDataPipelineServiceServer) GetDataPipeline(context.Context, *DataPipelineID) (*DataPipeline, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetDataPipeline not implemented")
}
func (UnimplementedDataPipelineServiceServer) ListDataPipelines(context.Context, *ListDataPipelinesRequest) (*ListDataPipelinesResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListDataPipelines not implemented")
}
func (UnimplementedDataPipelineServiceServer) PauseDataPipeline(context.Context, *DataPipelineID) (*emptypb.Empty, error) {
	return nil, status.Errorf(codes.Unimplemented, "method PauseDataPipeline not implemented")
}
func (UnimplementedDataPipelineServiceServer) EditDataPipeline(context.Context, *EditDataPipelineRequest) (*emptypb.Empty, error) {
	return nil, status.Errorf(codes.Unimplemented, "method EditDataPipeline not implemented")
}
func (UnimplementedDataPipelineServiceServer) ResumeDataPipeline(context.Context, *DataPipelineID) (*emptypb.Empty, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ResumeDataPipeline not implemented")
}
func (UnimplementedDataPipelineServiceServer) ScaleDataPipeline(context.Context, *ScaleDataPipelineRequest) (*emptypb.Empty, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ScaleDataPipeline not implemented")
}
func (UnimplementedDataPipelineServiceServer) DeleteDataPipeline(context.Context, *DataPipelineID) (*emptypb.Empty, error) {
	return nil, status.Errorf(codes.Unimplemented, "method DeleteDataPipeline not implemented")
}
func (UnimplementedDataPipelineServiceServer) ValidateDataPipelineSourceConnection(context.Context, *ValidateDataPipelineSourceConnectionRequest) (*emptypb.Empty, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ValidateDataPipelineSourceConnection not implemented")
}
func (UnimplementedDataPipelineServiceServer) ValidateDataPipelineDestination(context.Context, *ValidateDataPipelineDestinationRequest) (*emptypb.Empty, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ValidateDataPipelineDestination not implemented")
}
func (UnimplementedDataPipelineServiceServer) ValidateDataPipelineStaging(context.Context, *ValidateDataPipelineStagingRequest) (*emptypb.Empty, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ValidateDataPipelineStaging not implemented")
}
func (UnimplementedDataPipelineServiceServer) GetDataPipelineStagingTrust(context.Context, *GetDataPipelineStagingTrustRequest) (*DataPipelineStagingTrust, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetDataPipelineStagingTrust not implemented")
}
func (UnimplementedDataPipelineServiceServer) mustEmbedUnimplementedDataPipelineServiceServer() {}

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

func RegisterDataPipelineServiceServer(s grpc.ServiceRegistrar, srv DataPipelineServiceServer) {
	s.RegisterService(&DataPipelineService_ServiceDesc, srv)
}

func _DataPipelineService_CreateDataPipeline_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CreateDataPipelineRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataPipelineServiceServer).CreateDataPipeline(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DataPipelineService_CreateDataPipeline_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataPipelineServiceServer).CreateDataPipeline(ctx, req.(*CreateDataPipelineRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DataPipelineService_GetDataPipeline_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DataPipelineID)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataPipelineServiceServer).GetDataPipeline(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DataPipelineService_GetDataPipeline_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataPipelineServiceServer).GetDataPipeline(ctx, req.(*DataPipelineID))
	}
	return interceptor(ctx, in, info, handler)
}

func _DataPipelineService_ListDataPipelines_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListDataPipelinesRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataPipelineServiceServer).ListDataPipelines(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DataPipelineService_ListDataPipelines_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataPipelineServiceServer).ListDataPipelines(ctx, req.(*ListDataPipelinesRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DataPipelineService_PauseDataPipeline_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DataPipelineID)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataPipelineServiceServer).PauseDataPipeline(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DataPipelineService_PauseDataPipeline_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataPipelineServiceServer).PauseDataPipeline(ctx, req.(*DataPipelineID))
	}
	return interceptor(ctx, in, info, handler)
}

func _DataPipelineService_EditDataPipeline_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(EditDataPipelineRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataPipelineServiceServer).EditDataPipeline(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DataPipelineService_EditDataPipeline_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataPipelineServiceServer).EditDataPipeline(ctx, req.(*EditDataPipelineRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DataPipelineService_ResumeDataPipeline_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DataPipelineID)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataPipelineServiceServer).ResumeDataPipeline(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DataPipelineService_ResumeDataPipeline_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataPipelineServiceServer).ResumeDataPipeline(ctx, req.(*DataPipelineID))
	}
	return interceptor(ctx, in, info, handler)
}

func _DataPipelineService_ScaleDataPipeline_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ScaleDataPipelineRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataPipelineServiceServer).ScaleDataPipeline(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DataPipelineService_ScaleDataPipeline_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataPipelineServiceServer).ScaleDataPipeline(ctx, req.(*ScaleDataPipelineRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DataPipelineService_DeleteDataPipeline_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DataPipelineID)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataPipelineServiceServer).DeleteDataPipeline(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DataPipelineService_DeleteDataPipeline_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataPipelineServiceServer).DeleteDataPipeline(ctx, req.(*DataPipelineID))
	}
	return interceptor(ctx, in, info, handler)
}

func _DataPipelineService_ValidateDataPipelineSourceConnection_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ValidateDataPipelineSourceConnectionRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataPipelineServiceServer).ValidateDataPipelineSourceConnection(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DataPipelineService_ValidateDataPipelineSourceConnection_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataPipelineServiceServer).ValidateDataPipelineSourceConnection(ctx, req.(*ValidateDataPipelineSourceConnectionRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DataPipelineService_ValidateDataPipelineDestination_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ValidateDataPipelineDestinationRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataPipelineServiceServer).ValidateDataPipelineDestination(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DataPipelineService_ValidateDataPipelineDestination_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataPipelineServiceServer).ValidateDataPipelineDestination(ctx, req.(*ValidateDataPipelineDestinationRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DataPipelineService_ValidateDataPipelineStaging_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ValidateDataPipelineStagingRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataPipelineServiceServer).ValidateDataPipelineStaging(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DataPipelineService_ValidateDataPipelineStaging_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataPipelineServiceServer).ValidateDataPipelineStaging(ctx, req.(*ValidateDataPipelineStagingRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _DataPipelineService_GetDataPipelineStagingTrust_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetDataPipelineStagingTrustRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataPipelineServiceServer).GetDataPipelineStagingTrust(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: DataPipelineService_GetDataPipelineStagingTrust_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataPipelineServiceServer).GetDataPipelineStagingTrust(ctx, req.(*GetDataPipelineStagingTrustRequest))
	}
	return interceptor(ctx, in, info, handler)
}

// DataPipelineService_ServiceDesc is the grpc.ServiceDesc for DataPipelineService service.
// It's only intended for direct use with grpc.RegisterService,
// and not to be introspected or modified (even as a copy)
var DataPipelineService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "consoleapi.DataPipelineService",
	HandlerType: (*DataPipelineServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateDataPipeline",
			Handler:    _DataPipelineService_CreateDataPipeline_Handler,
		},
		{
			MethodName: "GetDataPipeline",
			Handler:    _DataPipelineService_GetDataPipeline_Handler,
		},
		{
			MethodName: "ListDataPipelines",
			Handler:    _DataPipelineService_ListDataPipelines_Handler,
		},
		{
			MethodName: "PauseDataPipeline",
			Handler:    _DataPipelineService_PauseDataPipeline_Handler,
		},
		{
			MethodName: "EditDataPipeline",
			Handler:    _DataPipelineService_EditDataPipeline_Handler,
		},
		{
			MethodName: "ResumeDataPipeline",
			Handler:    _DataPipelineService_ResumeDataPipeline_Handler,
		},
		{
			MethodName: "ScaleDataPipeline",
			Handler:    _DataPipelineService_ScaleDataPipeline_Handler,
		},
		{
			MethodName: "DeleteDataPipeline",
			Handler:    _DataPipelineService_DeleteDataPipeline_Handler,
		},
		{
			MethodName: "ValidateDataPipelineSourceConnection",
			Handler:    _DataPipelineService_ValidateDataPipelineSourceConnection_Handler,
		},
		{
			MethodName: "ValidateDataPipelineDestination",
			Handler:    _DataPipelineService_ValidateDataPipelineDestination_Handler,
		},
		{
			MethodName: "ValidateDataPipelineStaging",
			Handler:    _DataPipelineService_ValidateDataPipelineStaging_Handler,
		},
		{
			MethodName: "GetDataPipelineStagingTrust",
			Handler:    _DataPipelineService_GetDataPipelineStagingTrust_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "consoleapi/dataflow.proto",
}