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

package dataapi

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

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

// DataAPIServiceClient is the client API for DataAPIService 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 DataAPIServiceClient interface {
	ExecSqlDirectly(ctx context.Context, in *BasicEndpointReq, opts ...grpc.CallOption) (*ExecSqlResp, error)
	ExecSqlWithSession(ctx context.Context, in *BasicEndpointReq, opts ...grpc.CallOption) (*ExecSqlResp, error)
	CreateSession(ctx context.Context, in *CreateSessionReq, opts ...grpc.CallOption) (*CreateSessionResp, error)
	CloseSession(ctx context.Context, in *CloseSessionReq, opts ...grpc.CallOption) (*CloseSessionResp, error)
	GetDatabaseMeta(ctx context.Context, in *GetDatabaseMetaReq, opts ...grpc.CallOption) (*GetDatabaseMetaResp, error)
	GetClusterMeta(ctx context.Context, in *GetClusterMetaReq, opts ...grpc.CallOption) (*GetClusterMetaResp, error)
	CreateDataApp(ctx context.Context, in *CreateDataAppReq, opts ...grpc.CallOption) (*CreateDataAppResp, error)
	ShowDataApp(ctx context.Context, in *ShowDataAppReq, opts ...grpc.CallOption) (*ShowDataAppResp, error)
	ListDataApp(ctx context.Context, in *ListDataAppReq, opts ...grpc.CallOption) (*ListDataAppResp, error)
	DeleteDataApp(ctx context.Context, in *DeleteDataAppReq, opts ...grpc.CallOption) (*DeleteDataAppResp, error)
	CreateAPIKey(ctx context.Context, in *CreateAPIKeyReq, opts ...grpc.CallOption) (*CreateAPIKeyResp, error)
	DeleteAPIKey(ctx context.Context, in *DeleteAPIKeyReq, opts ...grpc.CallOption) (*DeleteAPIKeyResp, error)
	ListAPIKey(ctx context.Context, in *ListAPIKeyReq, opts ...grpc.CallOption) (*ListAPIKeyResp, error)
	ShowAPIKey(ctx context.Context, in *ShowAPIKeyReq, opts ...grpc.CallOption) (*ShowAPIKeyResp, error)
	AuthAPIKey(ctx context.Context, in *AuthAPIKeyReq, opts ...grpc.CallOption) (*AuthAPIKeyResp, error)
	ParseOneStmt(ctx context.Context, in *ParseOneStmtReq, opts ...grpc.CallOption) (*ParseOneStmtResp, error)
	EndpointCodeExample(ctx context.Context, in *EndpointCodeExampleReq, opts ...grpc.CallOption) (*EndpointCodeExampleResp, error)
	GetClusterStatus(ctx context.Context, in *GetClusterStatusReq, opts ...grpc.CallOption) (*GetClusterStatusResp, error)
}

type dataAPIServiceClient struct {
	cc grpc.ClientConnInterface
}

func NewDataAPIServiceClient(cc grpc.ClientConnInterface) DataAPIServiceClient {
	return &dataAPIServiceClient{cc}
}

func (c *dataAPIServiceClient) ExecSqlDirectly(ctx context.Context, in *BasicEndpointReq, opts ...grpc.CallOption) (*ExecSqlResp, error) {
	out := new(ExecSqlResp)
	err := c.cc.Invoke(ctx, "/dataapi.DataAPIService/ExecSqlDirectly", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataAPIServiceClient) ExecSqlWithSession(ctx context.Context, in *BasicEndpointReq, opts ...grpc.CallOption) (*ExecSqlResp, error) {
	out := new(ExecSqlResp)
	err := c.cc.Invoke(ctx, "/dataapi.DataAPIService/ExecSqlWithSession", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataAPIServiceClient) CreateSession(ctx context.Context, in *CreateSessionReq, opts ...grpc.CallOption) (*CreateSessionResp, error) {
	out := new(CreateSessionResp)
	err := c.cc.Invoke(ctx, "/dataapi.DataAPIService/CreateSession", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataAPIServiceClient) CloseSession(ctx context.Context, in *CloseSessionReq, opts ...grpc.CallOption) (*CloseSessionResp, error) {
	out := new(CloseSessionResp)
	err := c.cc.Invoke(ctx, "/dataapi.DataAPIService/CloseSession", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataAPIServiceClient) GetDatabaseMeta(ctx context.Context, in *GetDatabaseMetaReq, opts ...grpc.CallOption) (*GetDatabaseMetaResp, error) {
	out := new(GetDatabaseMetaResp)
	err := c.cc.Invoke(ctx, "/dataapi.DataAPIService/GetDatabaseMeta", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataAPIServiceClient) GetClusterMeta(ctx context.Context, in *GetClusterMetaReq, opts ...grpc.CallOption) (*GetClusterMetaResp, error) {
	out := new(GetClusterMetaResp)
	err := c.cc.Invoke(ctx, "/dataapi.DataAPIService/GetClusterMeta", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataAPIServiceClient) CreateDataApp(ctx context.Context, in *CreateDataAppReq, opts ...grpc.CallOption) (*CreateDataAppResp, error) {
	out := new(CreateDataAppResp)
	err := c.cc.Invoke(ctx, "/dataapi.DataAPIService/CreateDataApp", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataAPIServiceClient) ShowDataApp(ctx context.Context, in *ShowDataAppReq, opts ...grpc.CallOption) (*ShowDataAppResp, error) {
	out := new(ShowDataAppResp)
	err := c.cc.Invoke(ctx, "/dataapi.DataAPIService/ShowDataApp", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataAPIServiceClient) ListDataApp(ctx context.Context, in *ListDataAppReq, opts ...grpc.CallOption) (*ListDataAppResp, error) {
	out := new(ListDataAppResp)
	err := c.cc.Invoke(ctx, "/dataapi.DataAPIService/ListDataApp", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataAPIServiceClient) DeleteDataApp(ctx context.Context, in *DeleteDataAppReq, opts ...grpc.CallOption) (*DeleteDataAppResp, error) {
	out := new(DeleteDataAppResp)
	err := c.cc.Invoke(ctx, "/dataapi.DataAPIService/DeleteDataApp", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataAPIServiceClient) CreateAPIKey(ctx context.Context, in *CreateAPIKeyReq, opts ...grpc.CallOption) (*CreateAPIKeyResp, error) {
	out := new(CreateAPIKeyResp)
	err := c.cc.Invoke(ctx, "/dataapi.DataAPIService/CreateAPIKey", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataAPIServiceClient) DeleteAPIKey(ctx context.Context, in *DeleteAPIKeyReq, opts ...grpc.CallOption) (*DeleteAPIKeyResp, error) {
	out := new(DeleteAPIKeyResp)
	err := c.cc.Invoke(ctx, "/dataapi.DataAPIService/DeleteAPIKey", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataAPIServiceClient) ListAPIKey(ctx context.Context, in *ListAPIKeyReq, opts ...grpc.CallOption) (*ListAPIKeyResp, error) {
	out := new(ListAPIKeyResp)
	err := c.cc.Invoke(ctx, "/dataapi.DataAPIService/ListAPIKey", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataAPIServiceClient) ShowAPIKey(ctx context.Context, in *ShowAPIKeyReq, opts ...grpc.CallOption) (*ShowAPIKeyResp, error) {
	out := new(ShowAPIKeyResp)
	err := c.cc.Invoke(ctx, "/dataapi.DataAPIService/ShowAPIKey", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataAPIServiceClient) AuthAPIKey(ctx context.Context, in *AuthAPIKeyReq, opts ...grpc.CallOption) (*AuthAPIKeyResp, error) {
	out := new(AuthAPIKeyResp)
	err := c.cc.Invoke(ctx, "/dataapi.DataAPIService/AuthAPIKey", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataAPIServiceClient) ParseOneStmt(ctx context.Context, in *ParseOneStmtReq, opts ...grpc.CallOption) (*ParseOneStmtResp, error) {
	out := new(ParseOneStmtResp)
	err := c.cc.Invoke(ctx, "/dataapi.DataAPIService/ParseOneStmt", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataAPIServiceClient) EndpointCodeExample(ctx context.Context, in *EndpointCodeExampleReq, opts ...grpc.CallOption) (*EndpointCodeExampleResp, error) {
	out := new(EndpointCodeExampleResp)
	err := c.cc.Invoke(ctx, "/dataapi.DataAPIService/EndpointCodeExample", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataAPIServiceClient) GetClusterStatus(ctx context.Context, in *GetClusterStatusReq, opts ...grpc.CallOption) (*GetClusterStatusResp, error) {
	out := new(GetClusterStatusResp)
	err := c.cc.Invoke(ctx, "/dataapi.DataAPIService/GetClusterStatus", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

// DataAPIServiceServer is the server API for DataAPIService service.
// All implementations must embed UnimplementedDataAPIServiceServer
// for forward compatibility
type DataAPIServiceServer interface {
	ExecSqlDirectly(context.Context, *BasicEndpointReq) (*ExecSqlResp, error)
	ExecSqlWithSession(context.Context, *BasicEndpointReq) (*ExecSqlResp, error)
	CreateSession(context.Context, *CreateSessionReq) (*CreateSessionResp, error)
	CloseSession(context.Context, *CloseSessionReq) (*CloseSessionResp, error)
	GetDatabaseMeta(context.Context, *GetDatabaseMetaReq) (*GetDatabaseMetaResp, error)
	GetClusterMeta(context.Context, *GetClusterMetaReq) (*GetClusterMetaResp, error)
	CreateDataApp(context.Context, *CreateDataAppReq) (*CreateDataAppResp, error)
	ShowDataApp(context.Context, *ShowDataAppReq) (*ShowDataAppResp, error)
	ListDataApp(context.Context, *ListDataAppReq) (*ListDataAppResp, error)
	DeleteDataApp(context.Context, *DeleteDataAppReq) (*DeleteDataAppResp, error)
	CreateAPIKey(context.Context, *CreateAPIKeyReq) (*CreateAPIKeyResp, error)
	DeleteAPIKey(context.Context, *DeleteAPIKeyReq) (*DeleteAPIKeyResp, error)
	ListAPIKey(context.Context, *ListAPIKeyReq) (*ListAPIKeyResp, error)
	ShowAPIKey(context.Context, *ShowAPIKeyReq) (*ShowAPIKeyResp, error)
	AuthAPIKey(context.Context, *AuthAPIKeyReq) (*AuthAPIKeyResp, error)
	ParseOneStmt(context.Context, *ParseOneStmtReq) (*ParseOneStmtResp, error)
	EndpointCodeExample(context.Context, *EndpointCodeExampleReq) (*EndpointCodeExampleResp, error)
	GetClusterStatus(context.Context, *GetClusterStatusReq) (*GetClusterStatusResp, error)
	mustEmbedUnimplementedDataAPIServiceServer()
}

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

func (UnimplementedDataAPIServiceServer) ExecSqlDirectly(context.Context, *BasicEndpointReq) (*ExecSqlResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ExecSqlDirectly not implemented")
}
func (UnimplementedDataAPIServiceServer) ExecSqlWithSession(context.Context, *BasicEndpointReq) (*ExecSqlResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ExecSqlWithSession not implemented")
}
func (UnimplementedDataAPIServiceServer) CreateSession(context.Context, *CreateSessionReq) (*CreateSessionResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CreateSession not implemented")
}
func (UnimplementedDataAPIServiceServer) CloseSession(context.Context, *CloseSessionReq) (*CloseSessionResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CloseSession not implemented")
}
func (UnimplementedDataAPIServiceServer) GetDatabaseMeta(context.Context, *GetDatabaseMetaReq) (*GetDatabaseMetaResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetDatabaseMeta not implemented")
}
func (UnimplementedDataAPIServiceServer) GetClusterMeta(context.Context, *GetClusterMetaReq) (*GetClusterMetaResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetClusterMeta not implemented")
}
func (UnimplementedDataAPIServiceServer) CreateDataApp(context.Context, *CreateDataAppReq) (*CreateDataAppResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CreateDataApp not implemented")
}
func (UnimplementedDataAPIServiceServer) ShowDataApp(context.Context, *ShowDataAppReq) (*ShowDataAppResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ShowDataApp not implemented")
}
func (UnimplementedDataAPIServiceServer) ListDataApp(context.Context, *ListDataAppReq) (*ListDataAppResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListDataApp not implemented")
}
func (UnimplementedDataAPIServiceServer) DeleteDataApp(context.Context, *DeleteDataAppReq) (*DeleteDataAppResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method DeleteDataApp not implemented")
}
func (UnimplementedDataAPIServiceServer) CreateAPIKey(context.Context, *CreateAPIKeyReq) (*CreateAPIKeyResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CreateAPIKey not implemented")
}
func (UnimplementedDataAPIServiceServer) DeleteAPIKey(context.Context, *DeleteAPIKeyReq) (*DeleteAPIKeyResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method DeleteAPIKey not implemented")
}
func (UnimplementedDataAPIServiceServer) ListAPIKey(context.Context, *ListAPIKeyReq) (*ListAPIKeyResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListAPIKey not implemented")
}
func (UnimplementedDataAPIServiceServer) ShowAPIKey(context.Context, *ShowAPIKeyReq) (*ShowAPIKeyResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ShowAPIKey not implemented")
}
func (UnimplementedDataAPIServiceServer) AuthAPIKey(context.Context, *AuthAPIKeyReq) (*AuthAPIKeyResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method AuthAPIKey not implemented")
}
func (UnimplementedDataAPIServiceServer) ParseOneStmt(context.Context, *ParseOneStmtReq) (*ParseOneStmtResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ParseOneStmt not implemented")
}
func (UnimplementedDataAPIServiceServer) EndpointCodeExample(context.Context, *EndpointCodeExampleReq) (*EndpointCodeExampleResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method EndpointCodeExample not implemented")
}
func (UnimplementedDataAPIServiceServer) GetClusterStatus(context.Context, *GetClusterStatusReq) (*GetClusterStatusResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetClusterStatus not implemented")
}
func (UnimplementedDataAPIServiceServer) mustEmbedUnimplementedDataAPIServiceServer() {}

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

func RegisterDataAPIServiceServer(s grpc.ServiceRegistrar, srv DataAPIServiceServer) {
	s.RegisterService(&DataAPIService_ServiceDesc, srv)
}

func _DataAPIService_ExecSqlDirectly_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(BasicEndpointReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataAPIServiceServer).ExecSqlDirectly(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/dataapi.DataAPIService/ExecSqlDirectly",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataAPIServiceServer).ExecSqlDirectly(ctx, req.(*BasicEndpointReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _DataAPIService_ExecSqlWithSession_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(BasicEndpointReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataAPIServiceServer).ExecSqlWithSession(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/dataapi.DataAPIService/ExecSqlWithSession",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataAPIServiceServer).ExecSqlWithSession(ctx, req.(*BasicEndpointReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _DataAPIService_CreateSession_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CreateSessionReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataAPIServiceServer).CreateSession(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/dataapi.DataAPIService/CreateSession",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataAPIServiceServer).CreateSession(ctx, req.(*CreateSessionReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _DataAPIService_CloseSession_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CloseSessionReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataAPIServiceServer).CloseSession(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/dataapi.DataAPIService/CloseSession",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataAPIServiceServer).CloseSession(ctx, req.(*CloseSessionReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _DataAPIService_GetDatabaseMeta_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetDatabaseMetaReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataAPIServiceServer).GetDatabaseMeta(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/dataapi.DataAPIService/GetDatabaseMeta",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataAPIServiceServer).GetDatabaseMeta(ctx, req.(*GetDatabaseMetaReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _DataAPIService_GetClusterMeta_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetClusterMetaReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataAPIServiceServer).GetClusterMeta(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/dataapi.DataAPIService/GetClusterMeta",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataAPIServiceServer).GetClusterMeta(ctx, req.(*GetClusterMetaReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _DataAPIService_CreateDataApp_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CreateDataAppReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataAPIServiceServer).CreateDataApp(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/dataapi.DataAPIService/CreateDataApp",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataAPIServiceServer).CreateDataApp(ctx, req.(*CreateDataAppReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _DataAPIService_ShowDataApp_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ShowDataAppReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataAPIServiceServer).ShowDataApp(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/dataapi.DataAPIService/ShowDataApp",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataAPIServiceServer).ShowDataApp(ctx, req.(*ShowDataAppReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _DataAPIService_ListDataApp_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListDataAppReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataAPIServiceServer).ListDataApp(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/dataapi.DataAPIService/ListDataApp",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataAPIServiceServer).ListDataApp(ctx, req.(*ListDataAppReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _DataAPIService_DeleteDataApp_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeleteDataAppReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataAPIServiceServer).DeleteDataApp(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/dataapi.DataAPIService/DeleteDataApp",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataAPIServiceServer).DeleteDataApp(ctx, req.(*DeleteDataAppReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _DataAPIService_CreateAPIKey_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CreateAPIKeyReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataAPIServiceServer).CreateAPIKey(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/dataapi.DataAPIService/CreateAPIKey",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataAPIServiceServer).CreateAPIKey(ctx, req.(*CreateAPIKeyReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _DataAPIService_DeleteAPIKey_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeleteAPIKeyReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataAPIServiceServer).DeleteAPIKey(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/dataapi.DataAPIService/DeleteAPIKey",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataAPIServiceServer).DeleteAPIKey(ctx, req.(*DeleteAPIKeyReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _DataAPIService_ListAPIKey_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListAPIKeyReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataAPIServiceServer).ListAPIKey(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/dataapi.DataAPIService/ListAPIKey",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataAPIServiceServer).ListAPIKey(ctx, req.(*ListAPIKeyReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _DataAPIService_ShowAPIKey_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ShowAPIKeyReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataAPIServiceServer).ShowAPIKey(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/dataapi.DataAPIService/ShowAPIKey",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataAPIServiceServer).ShowAPIKey(ctx, req.(*ShowAPIKeyReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _DataAPIService_AuthAPIKey_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(AuthAPIKeyReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataAPIServiceServer).AuthAPIKey(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/dataapi.DataAPIService/AuthAPIKey",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataAPIServiceServer).AuthAPIKey(ctx, req.(*AuthAPIKeyReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _DataAPIService_ParseOneStmt_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ParseOneStmtReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataAPIServiceServer).ParseOneStmt(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/dataapi.DataAPIService/ParseOneStmt",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataAPIServiceServer).ParseOneStmt(ctx, req.(*ParseOneStmtReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _DataAPIService_EndpointCodeExample_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(EndpointCodeExampleReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataAPIServiceServer).EndpointCodeExample(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/dataapi.DataAPIService/EndpointCodeExample",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataAPIServiceServer).EndpointCodeExample(ctx, req.(*EndpointCodeExampleReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _DataAPIService_GetClusterStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetClusterStatusReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataAPIServiceServer).GetClusterStatus(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/dataapi.DataAPIService/GetClusterStatus",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataAPIServiceServer).GetClusterStatus(ctx, req.(*GetClusterStatusReq))
	}
	return interceptor(ctx, in, info, handler)
}

// DataAPIService_ServiceDesc is the grpc.ServiceDesc for DataAPIService service.
// It's only intended for direct use with grpc.RegisterService,
// and not to be introspected or modified (even as a copy)
var DataAPIService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "dataapi.DataAPIService",
	HandlerType: (*DataAPIServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ExecSqlDirectly",
			Handler:    _DataAPIService_ExecSqlDirectly_Handler,
		},
		{
			MethodName: "ExecSqlWithSession",
			Handler:    _DataAPIService_ExecSqlWithSession_Handler,
		},
		{
			MethodName: "CreateSession",
			Handler:    _DataAPIService_CreateSession_Handler,
		},
		{
			MethodName: "CloseSession",
			Handler:    _DataAPIService_CloseSession_Handler,
		},
		{
			MethodName: "GetDatabaseMeta",
			Handler:    _DataAPIService_GetDatabaseMeta_Handler,
		},
		{
			MethodName: "GetClusterMeta",
			Handler:    _DataAPIService_GetClusterMeta_Handler,
		},
		{
			MethodName: "CreateDataApp",
			Handler:    _DataAPIService_CreateDataApp_Handler,
		},
		{
			MethodName: "ShowDataApp",
			Handler:    _DataAPIService_ShowDataApp_Handler,
		},
		{
			MethodName: "ListDataApp",
			Handler:    _DataAPIService_ListDataApp_Handler,
		},
		{
			MethodName: "DeleteDataApp",
			Handler:    _DataAPIService_DeleteDataApp_Handler,
		},
		{
			MethodName: "CreateAPIKey",
			Handler:    _DataAPIService_CreateAPIKey_Handler,
		},
		{
			MethodName: "DeleteAPIKey",
			Handler:    _DataAPIService_DeleteAPIKey_Handler,
		},
		{
			MethodName: "ListAPIKey",
			Handler:    _DataAPIService_ListAPIKey_Handler,
		},
		{
			MethodName: "ShowAPIKey",
			Handler:    _DataAPIService_ShowAPIKey_Handler,
		},
		{
			MethodName: "AuthAPIKey",
			Handler:    _DataAPIService_AuthAPIKey_Handler,
		},
		{
			MethodName: "ParseOneStmt",
			Handler:    _DataAPIService_ParseOneStmt_Handler,
		},
		{
			MethodName: "EndpointCodeExample",
			Handler:    _DataAPIService_EndpointCodeExample_Handler,
		},
		{
			MethodName: "GetClusterStatus",
			Handler:    _DataAPIService_GetClusterStatus_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "dataapi/service.proto",
}

// DataAPIGatewayServiceClient is the client API for DataAPIGatewayService 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 DataAPIGatewayServiceClient interface {
	ExecSql(ctx context.Context, in *BasicEndpointReqV2, opts ...grpc.CallOption) (*ExecSqlRespV2, error)
	TestEndpointV2(ctx context.Context, in *TestEndpointReqV2, opts ...grpc.CallOption) (*ExecSqlRespV2, error)
	ExecSqlTemplateV2(ctx context.Context, in *ExecSqlTemplateReqV2, opts ...grpc.CallOption) (*ExecSqlRespV2, error)
	CreateSession(ctx context.Context, in *CreateSessionReq, opts ...grpc.CallOption) (*CreateSessionResp, error)
	CloseSession(ctx context.Context, in *CloseSessionReq, opts ...grpc.CallOption) (*CloseSessionResp, error)
	GetDatabaseMeta(ctx context.Context, in *GetDatabaseMetaReq, opts ...grpc.CallOption) (*GetDatabaseMetaResp, error)
	ParseOneStmt(ctx context.Context, in *ParseOneStmtReq, opts ...grpc.CallOption) (*ParseOneStmtResp, error)
}

type dataAPIGatewayServiceClient struct {
	cc grpc.ClientConnInterface
}

func NewDataAPIGatewayServiceClient(cc grpc.ClientConnInterface) DataAPIGatewayServiceClient {
	return &dataAPIGatewayServiceClient{cc}
}

func (c *dataAPIGatewayServiceClient) ExecSql(ctx context.Context, in *BasicEndpointReqV2, opts ...grpc.CallOption) (*ExecSqlRespV2, error) {
	out := new(ExecSqlRespV2)
	err := c.cc.Invoke(ctx, "/dataapi.DataAPIGatewayService/ExecSql", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataAPIGatewayServiceClient) TestEndpointV2(ctx context.Context, in *TestEndpointReqV2, opts ...grpc.CallOption) (*ExecSqlRespV2, error) {
	out := new(ExecSqlRespV2)
	err := c.cc.Invoke(ctx, "/dataapi.DataAPIGatewayService/TestEndpointV2", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataAPIGatewayServiceClient) ExecSqlTemplateV2(ctx context.Context, in *ExecSqlTemplateReqV2, opts ...grpc.CallOption) (*ExecSqlRespV2, error) {
	out := new(ExecSqlRespV2)
	err := c.cc.Invoke(ctx, "/dataapi.DataAPIGatewayService/ExecSqlTemplateV2", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataAPIGatewayServiceClient) CreateSession(ctx context.Context, in *CreateSessionReq, opts ...grpc.CallOption) (*CreateSessionResp, error) {
	out := new(CreateSessionResp)
	err := c.cc.Invoke(ctx, "/dataapi.DataAPIGatewayService/CreateSession", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataAPIGatewayServiceClient) CloseSession(ctx context.Context, in *CloseSessionReq, opts ...grpc.CallOption) (*CloseSessionResp, error) {
	out := new(CloseSessionResp)
	err := c.cc.Invoke(ctx, "/dataapi.DataAPIGatewayService/CloseSession", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataAPIGatewayServiceClient) GetDatabaseMeta(ctx context.Context, in *GetDatabaseMetaReq, opts ...grpc.CallOption) (*GetDatabaseMetaResp, error) {
	out := new(GetDatabaseMetaResp)
	err := c.cc.Invoke(ctx, "/dataapi.DataAPIGatewayService/GetDatabaseMeta", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataAPIGatewayServiceClient) ParseOneStmt(ctx context.Context, in *ParseOneStmtReq, opts ...grpc.CallOption) (*ParseOneStmtResp, error) {
	out := new(ParseOneStmtResp)
	err := c.cc.Invoke(ctx, "/dataapi.DataAPIGatewayService/ParseOneStmt", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

// DataAPIGatewayServiceServer is the server API for DataAPIGatewayService service.
// All implementations must embed UnimplementedDataAPIGatewayServiceServer
// for forward compatibility
type DataAPIGatewayServiceServer interface {
	ExecSql(context.Context, *BasicEndpointReqV2) (*ExecSqlRespV2, error)
	TestEndpointV2(context.Context, *TestEndpointReqV2) (*ExecSqlRespV2, error)
	ExecSqlTemplateV2(context.Context, *ExecSqlTemplateReqV2) (*ExecSqlRespV2, error)
	CreateSession(context.Context, *CreateSessionReq) (*CreateSessionResp, error)
	CloseSession(context.Context, *CloseSessionReq) (*CloseSessionResp, error)
	GetDatabaseMeta(context.Context, *GetDatabaseMetaReq) (*GetDatabaseMetaResp, error)
	ParseOneStmt(context.Context, *ParseOneStmtReq) (*ParseOneStmtResp, error)
	mustEmbedUnimplementedDataAPIGatewayServiceServer()
}

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

func (UnimplementedDataAPIGatewayServiceServer) ExecSql(context.Context, *BasicEndpointReqV2) (*ExecSqlRespV2, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ExecSql not implemented")
}
func (UnimplementedDataAPIGatewayServiceServer) TestEndpointV2(context.Context, *TestEndpointReqV2) (*ExecSqlRespV2, error) {
	return nil, status.Errorf(codes.Unimplemented, "method TestEndpointV2 not implemented")
}
func (UnimplementedDataAPIGatewayServiceServer) ExecSqlTemplateV2(context.Context, *ExecSqlTemplateReqV2) (*ExecSqlRespV2, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ExecSqlTemplateV2 not implemented")
}
func (UnimplementedDataAPIGatewayServiceServer) CreateSession(context.Context, *CreateSessionReq) (*CreateSessionResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CreateSession not implemented")
}
func (UnimplementedDataAPIGatewayServiceServer) CloseSession(context.Context, *CloseSessionReq) (*CloseSessionResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CloseSession not implemented")
}
func (UnimplementedDataAPIGatewayServiceServer) GetDatabaseMeta(context.Context, *GetDatabaseMetaReq) (*GetDatabaseMetaResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetDatabaseMeta not implemented")
}
func (UnimplementedDataAPIGatewayServiceServer) ParseOneStmt(context.Context, *ParseOneStmtReq) (*ParseOneStmtResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ParseOneStmt not implemented")
}
func (UnimplementedDataAPIGatewayServiceServer) mustEmbedUnimplementedDataAPIGatewayServiceServer() {}

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

func RegisterDataAPIGatewayServiceServer(s grpc.ServiceRegistrar, srv DataAPIGatewayServiceServer) {
	s.RegisterService(&DataAPIGatewayService_ServiceDesc, srv)
}

func _DataAPIGatewayService_ExecSql_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(BasicEndpointReqV2)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataAPIGatewayServiceServer).ExecSql(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/dataapi.DataAPIGatewayService/ExecSql",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataAPIGatewayServiceServer).ExecSql(ctx, req.(*BasicEndpointReqV2))
	}
	return interceptor(ctx, in, info, handler)
}

func _DataAPIGatewayService_TestEndpointV2_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(TestEndpointReqV2)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataAPIGatewayServiceServer).TestEndpointV2(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/dataapi.DataAPIGatewayService/TestEndpointV2",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataAPIGatewayServiceServer).TestEndpointV2(ctx, req.(*TestEndpointReqV2))
	}
	return interceptor(ctx, in, info, handler)
}

func _DataAPIGatewayService_ExecSqlTemplateV2_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ExecSqlTemplateReqV2)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataAPIGatewayServiceServer).ExecSqlTemplateV2(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/dataapi.DataAPIGatewayService/ExecSqlTemplateV2",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataAPIGatewayServiceServer).ExecSqlTemplateV2(ctx, req.(*ExecSqlTemplateReqV2))
	}
	return interceptor(ctx, in, info, handler)
}

func _DataAPIGatewayService_CreateSession_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CreateSessionReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataAPIGatewayServiceServer).CreateSession(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/dataapi.DataAPIGatewayService/CreateSession",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataAPIGatewayServiceServer).CreateSession(ctx, req.(*CreateSessionReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _DataAPIGatewayService_CloseSession_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CloseSessionReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataAPIGatewayServiceServer).CloseSession(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/dataapi.DataAPIGatewayService/CloseSession",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataAPIGatewayServiceServer).CloseSession(ctx, req.(*CloseSessionReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _DataAPIGatewayService_GetDatabaseMeta_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetDatabaseMetaReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataAPIGatewayServiceServer).GetDatabaseMeta(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/dataapi.DataAPIGatewayService/GetDatabaseMeta",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataAPIGatewayServiceServer).GetDatabaseMeta(ctx, req.(*GetDatabaseMetaReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _DataAPIGatewayService_ParseOneStmt_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ParseOneStmtReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataAPIGatewayServiceServer).ParseOneStmt(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/dataapi.DataAPIGatewayService/ParseOneStmt",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataAPIGatewayServiceServer).ParseOneStmt(ctx, req.(*ParseOneStmtReq))
	}
	return interceptor(ctx, in, info, handler)
}

// DataAPIGatewayService_ServiceDesc is the grpc.ServiceDesc for DataAPIGatewayService service.
// It's only intended for direct use with grpc.RegisterService,
// and not to be introspected or modified (even as a copy)
var DataAPIGatewayService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "dataapi.DataAPIGatewayService",
	HandlerType: (*DataAPIGatewayServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ExecSql",
			Handler:    _DataAPIGatewayService_ExecSql_Handler,
		},
		{
			MethodName: "TestEndpointV2",
			Handler:    _DataAPIGatewayService_TestEndpointV2_Handler,
		},
		{
			MethodName: "ExecSqlTemplateV2",
			Handler:    _DataAPIGatewayService_ExecSqlTemplateV2_Handler,
		},
		{
			MethodName: "CreateSession",
			Handler:    _DataAPIGatewayService_CreateSession_Handler,
		},
		{
			MethodName: "CloseSession",
			Handler:    _DataAPIGatewayService_CloseSession_Handler,
		},
		{
			MethodName: "GetDatabaseMeta",
			Handler:    _DataAPIGatewayService_GetDatabaseMeta_Handler,
		},
		{
			MethodName: "ParseOneStmt",
			Handler:    _DataAPIGatewayService_ParseOneStmt_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "dataapi/service.proto",
}

// DataAPIExecutorServiceClient is the client API for DataAPIExecutorService 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 DataAPIExecutorServiceClient interface {
	CreateSession(ctx context.Context, in *CreateSessionReq, opts ...grpc.CallOption) (*CreateSessionResp, error)
	CloseSession(ctx context.Context, in *CloseSessionReq, opts ...grpc.CallOption) (*CloseSessionResp, error)
	ExecSql(ctx context.Context, in *BasicEndpointReqV2, opts ...grpc.CallOption) (*ExecSqlRespV2, error)
	GetDatabaseMeta(ctx context.Context, in *GetDatabaseMetaReq, opts ...grpc.CallOption) (*GetDatabaseMetaResp, error)
	ParseOneStmt(ctx context.Context, in *ParseOneStmtReq, opts ...grpc.CallOption) (*ParseOneStmtResp, error)
}

type dataAPIExecutorServiceClient struct {
	cc grpc.ClientConnInterface
}

func NewDataAPIExecutorServiceClient(cc grpc.ClientConnInterface) DataAPIExecutorServiceClient {
	return &dataAPIExecutorServiceClient{cc}
}

func (c *dataAPIExecutorServiceClient) CreateSession(ctx context.Context, in *CreateSessionReq, opts ...grpc.CallOption) (*CreateSessionResp, error) {
	out := new(CreateSessionResp)
	err := c.cc.Invoke(ctx, "/dataapi.DataAPIExecutorService/CreateSession", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataAPIExecutorServiceClient) CloseSession(ctx context.Context, in *CloseSessionReq, opts ...grpc.CallOption) (*CloseSessionResp, error) {
	out := new(CloseSessionResp)
	err := c.cc.Invoke(ctx, "/dataapi.DataAPIExecutorService/CloseSession", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataAPIExecutorServiceClient) ExecSql(ctx context.Context, in *BasicEndpointReqV2, opts ...grpc.CallOption) (*ExecSqlRespV2, error) {
	out := new(ExecSqlRespV2)
	err := c.cc.Invoke(ctx, "/dataapi.DataAPIExecutorService/ExecSql", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataAPIExecutorServiceClient) GetDatabaseMeta(ctx context.Context, in *GetDatabaseMetaReq, opts ...grpc.CallOption) (*GetDatabaseMetaResp, error) {
	out := new(GetDatabaseMetaResp)
	err := c.cc.Invoke(ctx, "/dataapi.DataAPIExecutorService/GetDatabaseMeta", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *dataAPIExecutorServiceClient) ParseOneStmt(ctx context.Context, in *ParseOneStmtReq, opts ...grpc.CallOption) (*ParseOneStmtResp, error) {
	out := new(ParseOneStmtResp)
	err := c.cc.Invoke(ctx, "/dataapi.DataAPIExecutorService/ParseOneStmt", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

// DataAPIExecutorServiceServer is the server API for DataAPIExecutorService service.
// All implementations must embed UnimplementedDataAPIExecutorServiceServer
// for forward compatibility
type DataAPIExecutorServiceServer interface {
	CreateSession(context.Context, *CreateSessionReq) (*CreateSessionResp, error)
	CloseSession(context.Context, *CloseSessionReq) (*CloseSessionResp, error)
	ExecSql(context.Context, *BasicEndpointReqV2) (*ExecSqlRespV2, error)
	GetDatabaseMeta(context.Context, *GetDatabaseMetaReq) (*GetDatabaseMetaResp, error)
	ParseOneStmt(context.Context, *ParseOneStmtReq) (*ParseOneStmtResp, error)
	mustEmbedUnimplementedDataAPIExecutorServiceServer()
}

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

func (UnimplementedDataAPIExecutorServiceServer) CreateSession(context.Context, *CreateSessionReq) (*CreateSessionResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CreateSession not implemented")
}
func (UnimplementedDataAPIExecutorServiceServer) CloseSession(context.Context, *CloseSessionReq) (*CloseSessionResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CloseSession not implemented")
}
func (UnimplementedDataAPIExecutorServiceServer) ExecSql(context.Context, *BasicEndpointReqV2) (*ExecSqlRespV2, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ExecSql not implemented")
}
func (UnimplementedDataAPIExecutorServiceServer) GetDatabaseMeta(context.Context, *GetDatabaseMetaReq) (*GetDatabaseMetaResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetDatabaseMeta not implemented")
}
func (UnimplementedDataAPIExecutorServiceServer) ParseOneStmt(context.Context, *ParseOneStmtReq) (*ParseOneStmtResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ParseOneStmt not implemented")
}
func (UnimplementedDataAPIExecutorServiceServer) mustEmbedUnimplementedDataAPIExecutorServiceServer() {
}

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

func RegisterDataAPIExecutorServiceServer(s grpc.ServiceRegistrar, srv DataAPIExecutorServiceServer) {
	s.RegisterService(&DataAPIExecutorService_ServiceDesc, srv)
}

func _DataAPIExecutorService_CreateSession_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CreateSessionReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataAPIExecutorServiceServer).CreateSession(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/dataapi.DataAPIExecutorService/CreateSession",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataAPIExecutorServiceServer).CreateSession(ctx, req.(*CreateSessionReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _DataAPIExecutorService_CloseSession_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CloseSessionReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataAPIExecutorServiceServer).CloseSession(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/dataapi.DataAPIExecutorService/CloseSession",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataAPIExecutorServiceServer).CloseSession(ctx, req.(*CloseSessionReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _DataAPIExecutorService_ExecSql_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(BasicEndpointReqV2)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataAPIExecutorServiceServer).ExecSql(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/dataapi.DataAPIExecutorService/ExecSql",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataAPIExecutorServiceServer).ExecSql(ctx, req.(*BasicEndpointReqV2))
	}
	return interceptor(ctx, in, info, handler)
}

func _DataAPIExecutorService_GetDatabaseMeta_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetDatabaseMetaReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataAPIExecutorServiceServer).GetDatabaseMeta(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/dataapi.DataAPIExecutorService/GetDatabaseMeta",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataAPIExecutorServiceServer).GetDatabaseMeta(ctx, req.(*GetDatabaseMetaReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _DataAPIExecutorService_ParseOneStmt_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ParseOneStmtReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(DataAPIExecutorServiceServer).ParseOneStmt(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/dataapi.DataAPIExecutorService/ParseOneStmt",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(DataAPIExecutorServiceServer).ParseOneStmt(ctx, req.(*ParseOneStmtReq))
	}
	return interceptor(ctx, in, info, handler)
}

// DataAPIExecutorService_ServiceDesc is the grpc.ServiceDesc for DataAPIExecutorService service.
// It's only intended for direct use with grpc.RegisterService,
// and not to be introspected or modified (even as a copy)
var DataAPIExecutorService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "dataapi.DataAPIExecutorService",
	HandlerType: (*DataAPIExecutorServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateSession",
			Handler:    _DataAPIExecutorService_CreateSession_Handler,
		},
		{
			MethodName: "CloseSession",
			Handler:    _DataAPIExecutorService_CloseSession_Handler,
		},
		{
			MethodName: "ExecSql",
			Handler:    _DataAPIExecutorService_ExecSql_Handler,
		},
		{
			MethodName: "GetDatabaseMeta",
			Handler:    _DataAPIExecutorService_GetDatabaseMeta_Handler,
		},
		{
			MethodName: "ParseOneStmt",
			Handler:    _DataAPIExecutorService_ParseOneStmt_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "dataapi/service.proto",
}