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

package v1beta1

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

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

const (
	ChangefeedService_ListChangefeeds_FullMethodName              = "/v1beta1.ChangefeedService/ListChangefeeds"
	ChangefeedService_GetChangefeed_FullMethodName                = "/v1beta1.ChangefeedService/GetChangefeed"
	ChangefeedService_StartChangefeed_FullMethodName              = "/v1beta1.ChangefeedService/StartChangefeed"
	ChangefeedService_StopChangefeed_FullMethodName               = "/v1beta1.ChangefeedService/StopChangefeed"
	ChangefeedService_CreateChangefeed_FullMethodName             = "/v1beta1.ChangefeedService/CreateChangefeed"
	ChangefeedService_EditChangefeed_FullMethodName               = "/v1beta1.ChangefeedService/EditChangefeed"
	ChangefeedService_ScaleChangefeed_FullMethodName              = "/v1beta1.ChangefeedService/ScaleChangefeed"
	ChangefeedService_DeleteChangefeed_FullMethodName             = "/v1beta1.ChangefeedService/DeleteChangefeed"
	ChangefeedService_TestChangefeed_FullMethodName               = "/v1beta1.ChangefeedService/TestChangefeed"
	ChangefeedService_DescribeSchemaTable_FullMethodName          = "/v1beta1.ChangefeedService/DescribeSchemaTable"
	ChangefeedService_ListChangefeedSpecifications_FullMethodName = "/v1beta1.ChangefeedService/ListChangefeedSpecifications"
)

// 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 *ListChangefeedsReq, opts ...grpc.CallOption) (*Changefeeds, error)
	GetChangefeed(ctx context.Context, in *ChangefeedID, opts ...grpc.CallOption) (*Changefeed, error)
	StartChangefeed(ctx context.Context, in *ChangefeedID, opts ...grpc.CallOption) (*Changefeed, error)
	StopChangefeed(ctx context.Context, in *ChangefeedID, opts ...grpc.CallOption) (*Changefeed, error)
	CreateChangefeed(ctx context.Context, in *CreateChangefeedReq, opts ...grpc.CallOption) (*Changefeed, error)
	EditChangefeed(ctx context.Context, in *EditChangefeedReq, opts ...grpc.CallOption) (*Changefeed, error)
	ScaleChangefeed(ctx context.Context, in *ScaleChangefeedReq, opts ...grpc.CallOption) (*Changefeed, error)
	DeleteChangefeed(ctx context.Context, in *ChangefeedID, opts ...grpc.CallOption) (*Changefeed, error)
	TestChangefeed(ctx context.Context, in *TestChangefeedReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	DescribeSchemaTable(ctx context.Context, in *DescribeSchemaTableReq, opts ...grpc.CallOption) (*DescribeSchemaTableResp, error)
	ListChangefeedSpecifications(ctx context.Context, in *ListChangefeedSpecificationsReq, opts ...grpc.CallOption) (*ListChangefeedSpecificationsResp, error)
}

type changefeedServiceClient struct {
	cc grpc.ClientConnInterface
}

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

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

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

func (c *changefeedServiceClient) StartChangefeed(ctx context.Context, in *ChangefeedID, opts ...grpc.CallOption) (*Changefeed, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(Changefeed)
	err := c.cc.Invoke(ctx, ChangefeedService_StartChangefeed_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *changefeedServiceClient) StopChangefeed(ctx context.Context, in *ChangefeedID, opts ...grpc.CallOption) (*Changefeed, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(Changefeed)
	err := c.cc.Invoke(ctx, ChangefeedService_StopChangefeed_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *changefeedServiceClient) CreateChangefeed(ctx context.Context, in *CreateChangefeedReq, opts ...grpc.CallOption) (*Changefeed, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(Changefeed)
	err := c.cc.Invoke(ctx, ChangefeedService_CreateChangefeed_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *changefeedServiceClient) EditChangefeed(ctx context.Context, in *EditChangefeedReq, opts ...grpc.CallOption) (*Changefeed, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(Changefeed)
	err := c.cc.Invoke(ctx, ChangefeedService_EditChangefeed_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *changefeedServiceClient) ScaleChangefeed(ctx context.Context, in *ScaleChangefeedReq, opts ...grpc.CallOption) (*Changefeed, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(Changefeed)
	err := c.cc.Invoke(ctx, ChangefeedService_ScaleChangefeed_FullMethodName, in, out, cOpts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

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

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

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

func (c *changefeedServiceClient) ListChangefeedSpecifications(ctx context.Context, in *ListChangefeedSpecificationsReq, opts ...grpc.CallOption) (*ListChangefeedSpecificationsResp, error) {
	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
	out := new(ListChangefeedSpecificationsResp)
	err := c.cc.Invoke(ctx, ChangefeedService_ListChangefeedSpecifications_FullMethodName, in, out, cOpts...)
	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, *ListChangefeedsReq) (*Changefeeds, error)
	GetChangefeed(context.Context, *ChangefeedID) (*Changefeed, error)
	StartChangefeed(context.Context, *ChangefeedID) (*Changefeed, error)
	StopChangefeed(context.Context, *ChangefeedID) (*Changefeed, error)
	CreateChangefeed(context.Context, *CreateChangefeedReq) (*Changefeed, error)
	EditChangefeed(context.Context, *EditChangefeedReq) (*Changefeed, error)
	ScaleChangefeed(context.Context, *ScaleChangefeedReq) (*Changefeed, error)
	DeleteChangefeed(context.Context, *ChangefeedID) (*Changefeed, error)
	TestChangefeed(context.Context, *TestChangefeedReq) (*emptypb.Empty, error)
	DescribeSchemaTable(context.Context, *DescribeSchemaTableReq) (*DescribeSchemaTableResp, error)
	ListChangefeedSpecifications(context.Context, *ListChangefeedSpecificationsReq) (*ListChangefeedSpecificationsResp, error)
	mustEmbedUnimplementedChangefeedServiceServer()
}

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

func (UnimplementedChangefeedServiceServer) ListChangefeeds(context.Context, *ListChangefeedsReq) (*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) StartChangefeed(context.Context, *ChangefeedID) (*Changefeed, error) {
	return nil, status.Errorf(codes.Unimplemented, "method StartChangefeed not implemented")
}
func (UnimplementedChangefeedServiceServer) StopChangefeed(context.Context, *ChangefeedID) (*Changefeed, error) {
	return nil, status.Errorf(codes.Unimplemented, "method StopChangefeed not implemented")
}
func (UnimplementedChangefeedServiceServer) CreateChangefeed(context.Context, *CreateChangefeedReq) (*Changefeed, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CreateChangefeed not implemented")
}
func (UnimplementedChangefeedServiceServer) EditChangefeed(context.Context, *EditChangefeedReq) (*Changefeed, error) {
	return nil, status.Errorf(codes.Unimplemented, "method EditChangefeed not implemented")
}
func (UnimplementedChangefeedServiceServer) ScaleChangefeed(context.Context, *ScaleChangefeedReq) (*Changefeed, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ScaleChangefeed not implemented")
}
func (UnimplementedChangefeedServiceServer) DeleteChangefeed(context.Context, *ChangefeedID) (*Changefeed, error) {
	return nil, status.Errorf(codes.Unimplemented, "method DeleteChangefeed not implemented")
}
func (UnimplementedChangefeedServiceServer) TestChangefeed(context.Context, *TestChangefeedReq) (*emptypb.Empty, error) {
	return nil, status.Errorf(codes.Unimplemented, "method TestChangefeed not implemented")
}
func (UnimplementedChangefeedServiceServer) DescribeSchemaTable(context.Context, *DescribeSchemaTableReq) (*DescribeSchemaTableResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method DescribeSchemaTable not implemented")
}
func (UnimplementedChangefeedServiceServer) ListChangefeedSpecifications(context.Context, *ListChangefeedSpecificationsReq) (*ListChangefeedSpecificationsResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListChangefeedSpecifications 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(ListChangefeedsReq)
	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.(*ListChangefeedsReq))
	}
	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_StartChangefeed_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).StartChangefeed(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ChangefeedService_StartChangefeed_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ChangefeedServiceServer).StartChangefeed(ctx, req.(*ChangefeedID))
	}
	return interceptor(ctx, in, info, handler)
}

func _ChangefeedService_StopChangefeed_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).StopChangefeed(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ChangefeedService_StopChangefeed_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ChangefeedServiceServer).StopChangefeed(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(CreateChangefeedReq)
	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.(*CreateChangefeedReq))
	}
	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(EditChangefeedReq)
	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.(*EditChangefeedReq))
	}
	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(ScaleChangefeedReq)
	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.(*ScaleChangefeedReq))
	}
	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(TestChangefeedReq)
	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.(*TestChangefeedReq))
	}
	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_ListChangefeedSpecifications_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListChangefeedSpecificationsReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(ChangefeedServiceServer).ListChangefeedSpecifications(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: ChangefeedService_ListChangefeedSpecifications_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(ChangefeedServiceServer).ListChangefeedSpecifications(ctx, req.(*ListChangefeedSpecificationsReq))
	}
	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: "v1beta1.ChangefeedService",
	HandlerType: (*ChangefeedServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListChangefeeds",
			Handler:    _ChangefeedService_ListChangefeeds_Handler,
		},
		{
			MethodName: "GetChangefeed",
			Handler:    _ChangefeedService_GetChangefeed_Handler,
		},
		{
			MethodName: "StartChangefeed",
			Handler:    _ChangefeedService_StartChangefeed_Handler,
		},
		{
			MethodName: "StopChangefeed",
			Handler:    _ChangefeedService_StopChangefeed_Handler,
		},
		{
			MethodName: "CreateChangefeed",
			Handler:    _ChangefeedService_CreateChangefeed_Handler,
		},
		{
			MethodName: "EditChangefeed",
			Handler:    _ChangefeedService_EditChangefeed_Handler,
		},
		{
			MethodName: "ScaleChangefeed",
			Handler:    _ChangefeedService_ScaleChangefeed_Handler,
		},
		{
			MethodName: "DeleteChangefeed",
			Handler:    _ChangefeedService_DeleteChangefeed_Handler,
		},
		{
			MethodName: "TestChangefeed",
			Handler:    _ChangefeedService_TestChangefeed_Handler,
		},
		{
			MethodName: "DescribeSchemaTable",
			Handler:    _ChangefeedService_DescribeSchemaTable_Handler,
		},
		{
			MethodName: "ListChangefeedSpecifications",
			Handler:    _ChangefeedService_ListChangefeedSpecifications_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "v1beta1/cdc.proto",
}