// Copyright 2026 Google LLC
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//     http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
// versions:
// - protoc-gen-go-grpc v1.3.0
// - protoc             v6.33.2
// source: google/cloud/aiplatform/v1beta1/vertex_rag_data_service.proto

package aiplatformpb

import (
	context "context"

	longrunningpb "cloud.google.com/go/longrunning/autogen/longrunningpb"
	grpc "google.golang.org/grpc"
	codes "google.golang.org/grpc/codes"
	status "google.golang.org/grpc/status"
	emptypb "google.golang.org/protobuf/types/known/emptypb"
)

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

const (
	VertexRagDataService_CreateRagCorpus_FullMethodName           = "/google.cloud.aiplatform.v1beta1.VertexRagDataService/CreateRagCorpus"
	VertexRagDataService_UpdateRagCorpus_FullMethodName           = "/google.cloud.aiplatform.v1beta1.VertexRagDataService/UpdateRagCorpus"
	VertexRagDataService_GetRagCorpus_FullMethodName              = "/google.cloud.aiplatform.v1beta1.VertexRagDataService/GetRagCorpus"
	VertexRagDataService_ListRagCorpora_FullMethodName            = "/google.cloud.aiplatform.v1beta1.VertexRagDataService/ListRagCorpora"
	VertexRagDataService_DeleteRagCorpus_FullMethodName           = "/google.cloud.aiplatform.v1beta1.VertexRagDataService/DeleteRagCorpus"
	VertexRagDataService_UploadRagFile_FullMethodName             = "/google.cloud.aiplatform.v1beta1.VertexRagDataService/UploadRagFile"
	VertexRagDataService_ImportRagFiles_FullMethodName            = "/google.cloud.aiplatform.v1beta1.VertexRagDataService/ImportRagFiles"
	VertexRagDataService_GetRagFile_FullMethodName                = "/google.cloud.aiplatform.v1beta1.VertexRagDataService/GetRagFile"
	VertexRagDataService_ListRagFiles_FullMethodName              = "/google.cloud.aiplatform.v1beta1.VertexRagDataService/ListRagFiles"
	VertexRagDataService_DeleteRagFile_FullMethodName             = "/google.cloud.aiplatform.v1beta1.VertexRagDataService/DeleteRagFile"
	VertexRagDataService_UpdateRagEngineConfig_FullMethodName     = "/google.cloud.aiplatform.v1beta1.VertexRagDataService/UpdateRagEngineConfig"
	VertexRagDataService_GetRagEngineConfig_FullMethodName        = "/google.cloud.aiplatform.v1beta1.VertexRagDataService/GetRagEngineConfig"
	VertexRagDataService_CreateRagDataSchema_FullMethodName       = "/google.cloud.aiplatform.v1beta1.VertexRagDataService/CreateRagDataSchema"
	VertexRagDataService_BatchCreateRagDataSchemas_FullMethodName = "/google.cloud.aiplatform.v1beta1.VertexRagDataService/BatchCreateRagDataSchemas"
	VertexRagDataService_GetRagDataSchema_FullMethodName          = "/google.cloud.aiplatform.v1beta1.VertexRagDataService/GetRagDataSchema"
	VertexRagDataService_ListRagDataSchemas_FullMethodName        = "/google.cloud.aiplatform.v1beta1.VertexRagDataService/ListRagDataSchemas"
	VertexRagDataService_DeleteRagDataSchema_FullMethodName       = "/google.cloud.aiplatform.v1beta1.VertexRagDataService/DeleteRagDataSchema"
	VertexRagDataService_BatchDeleteRagDataSchemas_FullMethodName = "/google.cloud.aiplatform.v1beta1.VertexRagDataService/BatchDeleteRagDataSchemas"
	VertexRagDataService_CreateRagMetadata_FullMethodName         = "/google.cloud.aiplatform.v1beta1.VertexRagDataService/CreateRagMetadata"
	VertexRagDataService_BatchCreateRagMetadata_FullMethodName    = "/google.cloud.aiplatform.v1beta1.VertexRagDataService/BatchCreateRagMetadata"
	VertexRagDataService_UpdateRagMetadata_FullMethodName         = "/google.cloud.aiplatform.v1beta1.VertexRagDataService/UpdateRagMetadata"
	VertexRagDataService_GetRagMetadata_FullMethodName            = "/google.cloud.aiplatform.v1beta1.VertexRagDataService/GetRagMetadata"
	VertexRagDataService_ListRagMetadata_FullMethodName           = "/google.cloud.aiplatform.v1beta1.VertexRagDataService/ListRagMetadata"
	VertexRagDataService_DeleteRagMetadata_FullMethodName         = "/google.cloud.aiplatform.v1beta1.VertexRagDataService/DeleteRagMetadata"
	VertexRagDataService_BatchDeleteRagMetadata_FullMethodName    = "/google.cloud.aiplatform.v1beta1.VertexRagDataService/BatchDeleteRagMetadata"
)

// VertexRagDataServiceClient is the client API for VertexRagDataService 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 VertexRagDataServiceClient interface {
	// Creates a RagCorpus.
	CreateRagCorpus(ctx context.Context, in *CreateRagCorpusRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Updates a RagCorpus.
	UpdateRagCorpus(ctx context.Context, in *UpdateRagCorpusRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Gets a RagCorpus.
	GetRagCorpus(ctx context.Context, in *GetRagCorpusRequest, opts ...grpc.CallOption) (*RagCorpus, error)
	// Lists RagCorpora in a Location.
	ListRagCorpora(ctx context.Context, in *ListRagCorporaRequest, opts ...grpc.CallOption) (*ListRagCorporaResponse, error)
	// Deletes a RagCorpus.
	DeleteRagCorpus(ctx context.Context, in *DeleteRagCorpusRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Upload a file into a RagCorpus.
	UploadRagFile(ctx context.Context, in *UploadRagFileRequest, opts ...grpc.CallOption) (*UploadRagFileResponse, error)
	// Import files from Google Cloud Storage or Google Drive into a RagCorpus.
	ImportRagFiles(ctx context.Context, in *ImportRagFilesRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Gets a RagFile.
	GetRagFile(ctx context.Context, in *GetRagFileRequest, opts ...grpc.CallOption) (*RagFile, error)
	// Lists RagFiles in a RagCorpus.
	ListRagFiles(ctx context.Context, in *ListRagFilesRequest, opts ...grpc.CallOption) (*ListRagFilesResponse, error)
	// Deletes a RagFile.
	DeleteRagFile(ctx context.Context, in *DeleteRagFileRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Updates a RagEngineConfig.
	UpdateRagEngineConfig(ctx context.Context, in *UpdateRagEngineConfigRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Gets a RagEngineConfig.
	GetRagEngineConfig(ctx context.Context, in *GetRagEngineConfigRequest, opts ...grpc.CallOption) (*RagEngineConfig, error)
	// Creates a RagDataSchema.
	CreateRagDataSchema(ctx context.Context, in *CreateRagDataSchemaRequest, opts ...grpc.CallOption) (*RagDataSchema, error)
	// Batch Create one or more RagDataSchemas
	BatchCreateRagDataSchemas(ctx context.Context, in *BatchCreateRagDataSchemasRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Gets a RagDataSchema.
	GetRagDataSchema(ctx context.Context, in *GetRagDataSchemaRequest, opts ...grpc.CallOption) (*RagDataSchema, error)
	// Lists RagDataSchemas in a Location.
	ListRagDataSchemas(ctx context.Context, in *ListRagDataSchemasRequest, opts ...grpc.CallOption) (*ListRagDataSchemasResponse, error)
	// Deletes a RagDataSchema.
	DeleteRagDataSchema(ctx context.Context, in *DeleteRagDataSchemaRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Batch Deletes one or more RagDataSchemas
	BatchDeleteRagDataSchemas(ctx context.Context, in *BatchDeleteRagDataSchemasRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Creates a RagMetadata.
	CreateRagMetadata(ctx context.Context, in *CreateRagMetadataRequest, opts ...grpc.CallOption) (*RagMetadata, error)
	// Batch Create one or more RagMetadatas
	BatchCreateRagMetadata(ctx context.Context, in *BatchCreateRagMetadataRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Updates a RagMetadata.
	UpdateRagMetadata(ctx context.Context, in *UpdateRagMetadataRequest, opts ...grpc.CallOption) (*RagMetadata, error)
	// Gets a RagMetadata.
	GetRagMetadata(ctx context.Context, in *GetRagMetadataRequest, opts ...grpc.CallOption) (*RagMetadata, error)
	// Lists RagMetadata in a RagFile.
	ListRagMetadata(ctx context.Context, in *ListRagMetadataRequest, opts ...grpc.CallOption) (*ListRagMetadataResponse, error)
	// Deletes a RagMetadata.
	DeleteRagMetadata(ctx context.Context, in *DeleteRagMetadataRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Batch Deletes one or more RagMetadata.
	BatchDeleteRagMetadata(ctx context.Context, in *BatchDeleteRagMetadataRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
}

type vertexRagDataServiceClient struct {
	cc grpc.ClientConnInterface
}

func NewVertexRagDataServiceClient(cc grpc.ClientConnInterface) VertexRagDataServiceClient {
	return &vertexRagDataServiceClient{cc}
}

func (c *vertexRagDataServiceClient) CreateRagCorpus(ctx context.Context, in *CreateRagCorpusRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error) {
	out := new(longrunningpb.Operation)
	err := c.cc.Invoke(ctx, VertexRagDataService_CreateRagCorpus_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *vertexRagDataServiceClient) UpdateRagCorpus(ctx context.Context, in *UpdateRagCorpusRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error) {
	out := new(longrunningpb.Operation)
	err := c.cc.Invoke(ctx, VertexRagDataService_UpdateRagCorpus_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *vertexRagDataServiceClient) GetRagCorpus(ctx context.Context, in *GetRagCorpusRequest, opts ...grpc.CallOption) (*RagCorpus, error) {
	out := new(RagCorpus)
	err := c.cc.Invoke(ctx, VertexRagDataService_GetRagCorpus_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *vertexRagDataServiceClient) ListRagCorpora(ctx context.Context, in *ListRagCorporaRequest, opts ...grpc.CallOption) (*ListRagCorporaResponse, error) {
	out := new(ListRagCorporaResponse)
	err := c.cc.Invoke(ctx, VertexRagDataService_ListRagCorpora_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *vertexRagDataServiceClient) DeleteRagCorpus(ctx context.Context, in *DeleteRagCorpusRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error) {
	out := new(longrunningpb.Operation)
	err := c.cc.Invoke(ctx, VertexRagDataService_DeleteRagCorpus_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *vertexRagDataServiceClient) UploadRagFile(ctx context.Context, in *UploadRagFileRequest, opts ...grpc.CallOption) (*UploadRagFileResponse, error) {
	out := new(UploadRagFileResponse)
	err := c.cc.Invoke(ctx, VertexRagDataService_UploadRagFile_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *vertexRagDataServiceClient) ImportRagFiles(ctx context.Context, in *ImportRagFilesRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error) {
	out := new(longrunningpb.Operation)
	err := c.cc.Invoke(ctx, VertexRagDataService_ImportRagFiles_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *vertexRagDataServiceClient) GetRagFile(ctx context.Context, in *GetRagFileRequest, opts ...grpc.CallOption) (*RagFile, error) {
	out := new(RagFile)
	err := c.cc.Invoke(ctx, VertexRagDataService_GetRagFile_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *vertexRagDataServiceClient) ListRagFiles(ctx context.Context, in *ListRagFilesRequest, opts ...grpc.CallOption) (*ListRagFilesResponse, error) {
	out := new(ListRagFilesResponse)
	err := c.cc.Invoke(ctx, VertexRagDataService_ListRagFiles_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *vertexRagDataServiceClient) DeleteRagFile(ctx context.Context, in *DeleteRagFileRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error) {
	out := new(longrunningpb.Operation)
	err := c.cc.Invoke(ctx, VertexRagDataService_DeleteRagFile_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *vertexRagDataServiceClient) UpdateRagEngineConfig(ctx context.Context, in *UpdateRagEngineConfigRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error) {
	out := new(longrunningpb.Operation)
	err := c.cc.Invoke(ctx, VertexRagDataService_UpdateRagEngineConfig_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *vertexRagDataServiceClient) GetRagEngineConfig(ctx context.Context, in *GetRagEngineConfigRequest, opts ...grpc.CallOption) (*RagEngineConfig, error) {
	out := new(RagEngineConfig)
	err := c.cc.Invoke(ctx, VertexRagDataService_GetRagEngineConfig_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *vertexRagDataServiceClient) CreateRagDataSchema(ctx context.Context, in *CreateRagDataSchemaRequest, opts ...grpc.CallOption) (*RagDataSchema, error) {
	out := new(RagDataSchema)
	err := c.cc.Invoke(ctx, VertexRagDataService_CreateRagDataSchema_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *vertexRagDataServiceClient) BatchCreateRagDataSchemas(ctx context.Context, in *BatchCreateRagDataSchemasRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error) {
	out := new(longrunningpb.Operation)
	err := c.cc.Invoke(ctx, VertexRagDataService_BatchCreateRagDataSchemas_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *vertexRagDataServiceClient) GetRagDataSchema(ctx context.Context, in *GetRagDataSchemaRequest, opts ...grpc.CallOption) (*RagDataSchema, error) {
	out := new(RagDataSchema)
	err := c.cc.Invoke(ctx, VertexRagDataService_GetRagDataSchema_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *vertexRagDataServiceClient) ListRagDataSchemas(ctx context.Context, in *ListRagDataSchemasRequest, opts ...grpc.CallOption) (*ListRagDataSchemasResponse, error) {
	out := new(ListRagDataSchemasResponse)
	err := c.cc.Invoke(ctx, VertexRagDataService_ListRagDataSchemas_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *vertexRagDataServiceClient) DeleteRagDataSchema(ctx context.Context, in *DeleteRagDataSchemaRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
	out := new(emptypb.Empty)
	err := c.cc.Invoke(ctx, VertexRagDataService_DeleteRagDataSchema_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *vertexRagDataServiceClient) BatchDeleteRagDataSchemas(ctx context.Context, in *BatchDeleteRagDataSchemasRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error) {
	out := new(longrunningpb.Operation)
	err := c.cc.Invoke(ctx, VertexRagDataService_BatchDeleteRagDataSchemas_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *vertexRagDataServiceClient) CreateRagMetadata(ctx context.Context, in *CreateRagMetadataRequest, opts ...grpc.CallOption) (*RagMetadata, error) {
	out := new(RagMetadata)
	err := c.cc.Invoke(ctx, VertexRagDataService_CreateRagMetadata_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *vertexRagDataServiceClient) BatchCreateRagMetadata(ctx context.Context, in *BatchCreateRagMetadataRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error) {
	out := new(longrunningpb.Operation)
	err := c.cc.Invoke(ctx, VertexRagDataService_BatchCreateRagMetadata_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *vertexRagDataServiceClient) UpdateRagMetadata(ctx context.Context, in *UpdateRagMetadataRequest, opts ...grpc.CallOption) (*RagMetadata, error) {
	out := new(RagMetadata)
	err := c.cc.Invoke(ctx, VertexRagDataService_UpdateRagMetadata_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *vertexRagDataServiceClient) GetRagMetadata(ctx context.Context, in *GetRagMetadataRequest, opts ...grpc.CallOption) (*RagMetadata, error) {
	out := new(RagMetadata)
	err := c.cc.Invoke(ctx, VertexRagDataService_GetRagMetadata_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *vertexRagDataServiceClient) ListRagMetadata(ctx context.Context, in *ListRagMetadataRequest, opts ...grpc.CallOption) (*ListRagMetadataResponse, error) {
	out := new(ListRagMetadataResponse)
	err := c.cc.Invoke(ctx, VertexRagDataService_ListRagMetadata_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *vertexRagDataServiceClient) DeleteRagMetadata(ctx context.Context, in *DeleteRagMetadataRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
	out := new(emptypb.Empty)
	err := c.cc.Invoke(ctx, VertexRagDataService_DeleteRagMetadata_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *vertexRagDataServiceClient) BatchDeleteRagMetadata(ctx context.Context, in *BatchDeleteRagMetadataRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error) {
	out := new(longrunningpb.Operation)
	err := c.cc.Invoke(ctx, VertexRagDataService_BatchDeleteRagMetadata_FullMethodName, in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

// VertexRagDataServiceServer is the server API for VertexRagDataService service.
// All implementations should embed UnimplementedVertexRagDataServiceServer
// for forward compatibility
type VertexRagDataServiceServer interface {
	// Creates a RagCorpus.
	CreateRagCorpus(context.Context, *CreateRagCorpusRequest) (*longrunningpb.Operation, error)
	// Updates a RagCorpus.
	UpdateRagCorpus(context.Context, *UpdateRagCorpusRequest) (*longrunningpb.Operation, error)
	// Gets a RagCorpus.
	GetRagCorpus(context.Context, *GetRagCorpusRequest) (*RagCorpus, error)
	// Lists RagCorpora in a Location.
	ListRagCorpora(context.Context, *ListRagCorporaRequest) (*ListRagCorporaResponse, error)
	// Deletes a RagCorpus.
	DeleteRagCorpus(context.Context, *DeleteRagCorpusRequest) (*longrunningpb.Operation, error)
	// Upload a file into a RagCorpus.
	UploadRagFile(context.Context, *UploadRagFileRequest) (*UploadRagFileResponse, error)
	// Import files from Google Cloud Storage or Google Drive into a RagCorpus.
	ImportRagFiles(context.Context, *ImportRagFilesRequest) (*longrunningpb.Operation, error)
	// Gets a RagFile.
	GetRagFile(context.Context, *GetRagFileRequest) (*RagFile, error)
	// Lists RagFiles in a RagCorpus.
	ListRagFiles(context.Context, *ListRagFilesRequest) (*ListRagFilesResponse, error)
	// Deletes a RagFile.
	DeleteRagFile(context.Context, *DeleteRagFileRequest) (*longrunningpb.Operation, error)
	// Updates a RagEngineConfig.
	UpdateRagEngineConfig(context.Context, *UpdateRagEngineConfigRequest) (*longrunningpb.Operation, error)
	// Gets a RagEngineConfig.
	GetRagEngineConfig(context.Context, *GetRagEngineConfigRequest) (*RagEngineConfig, error)
	// Creates a RagDataSchema.
	CreateRagDataSchema(context.Context, *CreateRagDataSchemaRequest) (*RagDataSchema, error)
	// Batch Create one or more RagDataSchemas
	BatchCreateRagDataSchemas(context.Context, *BatchCreateRagDataSchemasRequest) (*longrunningpb.Operation, error)
	// Gets a RagDataSchema.
	GetRagDataSchema(context.Context, *GetRagDataSchemaRequest) (*RagDataSchema, error)
	// Lists RagDataSchemas in a Location.
	ListRagDataSchemas(context.Context, *ListRagDataSchemasRequest) (*ListRagDataSchemasResponse, error)
	// Deletes a RagDataSchema.
	DeleteRagDataSchema(context.Context, *DeleteRagDataSchemaRequest) (*emptypb.Empty, error)
	// Batch Deletes one or more RagDataSchemas
	BatchDeleteRagDataSchemas(context.Context, *BatchDeleteRagDataSchemasRequest) (*longrunningpb.Operation, error)
	// Creates a RagMetadata.
	CreateRagMetadata(context.Context, *CreateRagMetadataRequest) (*RagMetadata, error)
	// Batch Create one or more RagMetadatas
	BatchCreateRagMetadata(context.Context, *BatchCreateRagMetadataRequest) (*longrunningpb.Operation, error)
	// Updates a RagMetadata.
	UpdateRagMetadata(context.Context, *UpdateRagMetadataRequest) (*RagMetadata, error)
	// Gets a RagMetadata.
	GetRagMetadata(context.Context, *GetRagMetadataRequest) (*RagMetadata, error)
	// Lists RagMetadata in a RagFile.
	ListRagMetadata(context.Context, *ListRagMetadataRequest) (*ListRagMetadataResponse, error)
	// Deletes a RagMetadata.
	DeleteRagMetadata(context.Context, *DeleteRagMetadataRequest) (*emptypb.Empty, error)
	// Batch Deletes one or more RagMetadata.
	BatchDeleteRagMetadata(context.Context, *BatchDeleteRagMetadataRequest) (*longrunningpb.Operation, error)
}

// UnimplementedVertexRagDataServiceServer should be embedded to have forward compatible implementations.
type UnimplementedVertexRagDataServiceServer struct {
}

func (UnimplementedVertexRagDataServiceServer) CreateRagCorpus(context.Context, *CreateRagCorpusRequest) (*longrunningpb.Operation, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CreateRagCorpus not implemented")
}
func (UnimplementedVertexRagDataServiceServer) UpdateRagCorpus(context.Context, *UpdateRagCorpusRequest) (*longrunningpb.Operation, error) {
	return nil, status.Errorf(codes.Unimplemented, "method UpdateRagCorpus not implemented")
}
func (UnimplementedVertexRagDataServiceServer) GetRagCorpus(context.Context, *GetRagCorpusRequest) (*RagCorpus, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetRagCorpus not implemented")
}
func (UnimplementedVertexRagDataServiceServer) ListRagCorpora(context.Context, *ListRagCorporaRequest) (*ListRagCorporaResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListRagCorpora not implemented")
}
func (UnimplementedVertexRagDataServiceServer) DeleteRagCorpus(context.Context, *DeleteRagCorpusRequest) (*longrunningpb.Operation, error) {
	return nil, status.Errorf(codes.Unimplemented, "method DeleteRagCorpus not implemented")
}
func (UnimplementedVertexRagDataServiceServer) UploadRagFile(context.Context, *UploadRagFileRequest) (*UploadRagFileResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method UploadRagFile not implemented")
}
func (UnimplementedVertexRagDataServiceServer) ImportRagFiles(context.Context, *ImportRagFilesRequest) (*longrunningpb.Operation, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ImportRagFiles not implemented")
}
func (UnimplementedVertexRagDataServiceServer) GetRagFile(context.Context, *GetRagFileRequest) (*RagFile, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetRagFile not implemented")
}
func (UnimplementedVertexRagDataServiceServer) ListRagFiles(context.Context, *ListRagFilesRequest) (*ListRagFilesResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListRagFiles not implemented")
}
func (UnimplementedVertexRagDataServiceServer) DeleteRagFile(context.Context, *DeleteRagFileRequest) (*longrunningpb.Operation, error) {
	return nil, status.Errorf(codes.Unimplemented, "method DeleteRagFile not implemented")
}
func (UnimplementedVertexRagDataServiceServer) UpdateRagEngineConfig(context.Context, *UpdateRagEngineConfigRequest) (*longrunningpb.Operation, error) {
	return nil, status.Errorf(codes.Unimplemented, "method UpdateRagEngineConfig not implemented")
}
func (UnimplementedVertexRagDataServiceServer) GetRagEngineConfig(context.Context, *GetRagEngineConfigRequest) (*RagEngineConfig, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetRagEngineConfig not implemented")
}
func (UnimplementedVertexRagDataServiceServer) CreateRagDataSchema(context.Context, *CreateRagDataSchemaRequest) (*RagDataSchema, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CreateRagDataSchema not implemented")
}
func (UnimplementedVertexRagDataServiceServer) BatchCreateRagDataSchemas(context.Context, *BatchCreateRagDataSchemasRequest) (*longrunningpb.Operation, error) {
	return nil, status.Errorf(codes.Unimplemented, "method BatchCreateRagDataSchemas not implemented")
}
func (UnimplementedVertexRagDataServiceServer) GetRagDataSchema(context.Context, *GetRagDataSchemaRequest) (*RagDataSchema, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetRagDataSchema not implemented")
}
func (UnimplementedVertexRagDataServiceServer) ListRagDataSchemas(context.Context, *ListRagDataSchemasRequest) (*ListRagDataSchemasResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListRagDataSchemas not implemented")
}
func (UnimplementedVertexRagDataServiceServer) DeleteRagDataSchema(context.Context, *DeleteRagDataSchemaRequest) (*emptypb.Empty, error) {
	return nil, status.Errorf(codes.Unimplemented, "method DeleteRagDataSchema not implemented")
}
func (UnimplementedVertexRagDataServiceServer) BatchDeleteRagDataSchemas(context.Context, *BatchDeleteRagDataSchemasRequest) (*longrunningpb.Operation, error) {
	return nil, status.Errorf(codes.Unimplemented, "method BatchDeleteRagDataSchemas not implemented")
}
func (UnimplementedVertexRagDataServiceServer) CreateRagMetadata(context.Context, *CreateRagMetadataRequest) (*RagMetadata, error) {
	return nil, status.Errorf(codes.Unimplemented, "method CreateRagMetadata not implemented")
}
func (UnimplementedVertexRagDataServiceServer) BatchCreateRagMetadata(context.Context, *BatchCreateRagMetadataRequest) (*longrunningpb.Operation, error) {
	return nil, status.Errorf(codes.Unimplemented, "method BatchCreateRagMetadata not implemented")
}
func (UnimplementedVertexRagDataServiceServer) UpdateRagMetadata(context.Context, *UpdateRagMetadataRequest) (*RagMetadata, error) {
	return nil, status.Errorf(codes.Unimplemented, "method UpdateRagMetadata not implemented")
}
func (UnimplementedVertexRagDataServiceServer) GetRagMetadata(context.Context, *GetRagMetadataRequest) (*RagMetadata, error) {
	return nil, status.Errorf(codes.Unimplemented, "method GetRagMetadata not implemented")
}
func (UnimplementedVertexRagDataServiceServer) ListRagMetadata(context.Context, *ListRagMetadataRequest) (*ListRagMetadataResponse, error) {
	return nil, status.Errorf(codes.Unimplemented, "method ListRagMetadata not implemented")
}
func (UnimplementedVertexRagDataServiceServer) DeleteRagMetadata(context.Context, *DeleteRagMetadataRequest) (*emptypb.Empty, error) {
	return nil, status.Errorf(codes.Unimplemented, "method DeleteRagMetadata not implemented")
}
func (UnimplementedVertexRagDataServiceServer) BatchDeleteRagMetadata(context.Context, *BatchDeleteRagMetadataRequest) (*longrunningpb.Operation, error) {
	return nil, status.Errorf(codes.Unimplemented, "method BatchDeleteRagMetadata not implemented")
}

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

func RegisterVertexRagDataServiceServer(s grpc.ServiceRegistrar, srv VertexRagDataServiceServer) {
	s.RegisterService(&VertexRagDataService_ServiceDesc, srv)
}

func _VertexRagDataService_CreateRagCorpus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CreateRagCorpusRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(VertexRagDataServiceServer).CreateRagCorpus(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: VertexRagDataService_CreateRagCorpus_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(VertexRagDataServiceServer).CreateRagCorpus(ctx, req.(*CreateRagCorpusRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _VertexRagDataService_UpdateRagCorpus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(UpdateRagCorpusRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(VertexRagDataServiceServer).UpdateRagCorpus(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: VertexRagDataService_UpdateRagCorpus_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(VertexRagDataServiceServer).UpdateRagCorpus(ctx, req.(*UpdateRagCorpusRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _VertexRagDataService_GetRagCorpus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetRagCorpusRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(VertexRagDataServiceServer).GetRagCorpus(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: VertexRagDataService_GetRagCorpus_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(VertexRagDataServiceServer).GetRagCorpus(ctx, req.(*GetRagCorpusRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _VertexRagDataService_ListRagCorpora_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListRagCorporaRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(VertexRagDataServiceServer).ListRagCorpora(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: VertexRagDataService_ListRagCorpora_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(VertexRagDataServiceServer).ListRagCorpora(ctx, req.(*ListRagCorporaRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _VertexRagDataService_DeleteRagCorpus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeleteRagCorpusRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(VertexRagDataServiceServer).DeleteRagCorpus(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: VertexRagDataService_DeleteRagCorpus_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(VertexRagDataServiceServer).DeleteRagCorpus(ctx, req.(*DeleteRagCorpusRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _VertexRagDataService_UploadRagFile_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(UploadRagFileRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(VertexRagDataServiceServer).UploadRagFile(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: VertexRagDataService_UploadRagFile_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(VertexRagDataServiceServer).UploadRagFile(ctx, req.(*UploadRagFileRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _VertexRagDataService_ImportRagFiles_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ImportRagFilesRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(VertexRagDataServiceServer).ImportRagFiles(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: VertexRagDataService_ImportRagFiles_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(VertexRagDataServiceServer).ImportRagFiles(ctx, req.(*ImportRagFilesRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _VertexRagDataService_GetRagFile_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetRagFileRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(VertexRagDataServiceServer).GetRagFile(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: VertexRagDataService_GetRagFile_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(VertexRagDataServiceServer).GetRagFile(ctx, req.(*GetRagFileRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _VertexRagDataService_ListRagFiles_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListRagFilesRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(VertexRagDataServiceServer).ListRagFiles(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: VertexRagDataService_ListRagFiles_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(VertexRagDataServiceServer).ListRagFiles(ctx, req.(*ListRagFilesRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _VertexRagDataService_DeleteRagFile_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeleteRagFileRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(VertexRagDataServiceServer).DeleteRagFile(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: VertexRagDataService_DeleteRagFile_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(VertexRagDataServiceServer).DeleteRagFile(ctx, req.(*DeleteRagFileRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _VertexRagDataService_UpdateRagEngineConfig_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(UpdateRagEngineConfigRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(VertexRagDataServiceServer).UpdateRagEngineConfig(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: VertexRagDataService_UpdateRagEngineConfig_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(VertexRagDataServiceServer).UpdateRagEngineConfig(ctx, req.(*UpdateRagEngineConfigRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _VertexRagDataService_GetRagEngineConfig_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetRagEngineConfigRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(VertexRagDataServiceServer).GetRagEngineConfig(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: VertexRagDataService_GetRagEngineConfig_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(VertexRagDataServiceServer).GetRagEngineConfig(ctx, req.(*GetRagEngineConfigRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _VertexRagDataService_CreateRagDataSchema_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CreateRagDataSchemaRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(VertexRagDataServiceServer).CreateRagDataSchema(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: VertexRagDataService_CreateRagDataSchema_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(VertexRagDataServiceServer).CreateRagDataSchema(ctx, req.(*CreateRagDataSchemaRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _VertexRagDataService_BatchCreateRagDataSchemas_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(BatchCreateRagDataSchemasRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(VertexRagDataServiceServer).BatchCreateRagDataSchemas(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: VertexRagDataService_BatchCreateRagDataSchemas_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(VertexRagDataServiceServer).BatchCreateRagDataSchemas(ctx, req.(*BatchCreateRagDataSchemasRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _VertexRagDataService_GetRagDataSchema_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetRagDataSchemaRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(VertexRagDataServiceServer).GetRagDataSchema(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: VertexRagDataService_GetRagDataSchema_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(VertexRagDataServiceServer).GetRagDataSchema(ctx, req.(*GetRagDataSchemaRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _VertexRagDataService_ListRagDataSchemas_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListRagDataSchemasRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(VertexRagDataServiceServer).ListRagDataSchemas(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: VertexRagDataService_ListRagDataSchemas_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(VertexRagDataServiceServer).ListRagDataSchemas(ctx, req.(*ListRagDataSchemasRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _VertexRagDataService_DeleteRagDataSchema_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeleteRagDataSchemaRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(VertexRagDataServiceServer).DeleteRagDataSchema(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: VertexRagDataService_DeleteRagDataSchema_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(VertexRagDataServiceServer).DeleteRagDataSchema(ctx, req.(*DeleteRagDataSchemaRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _VertexRagDataService_BatchDeleteRagDataSchemas_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(BatchDeleteRagDataSchemasRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(VertexRagDataServiceServer).BatchDeleteRagDataSchemas(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: VertexRagDataService_BatchDeleteRagDataSchemas_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(VertexRagDataServiceServer).BatchDeleteRagDataSchemas(ctx, req.(*BatchDeleteRagDataSchemasRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _VertexRagDataService_CreateRagMetadata_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(CreateRagMetadataRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(VertexRagDataServiceServer).CreateRagMetadata(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: VertexRagDataService_CreateRagMetadata_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(VertexRagDataServiceServer).CreateRagMetadata(ctx, req.(*CreateRagMetadataRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _VertexRagDataService_BatchCreateRagMetadata_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(BatchCreateRagMetadataRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(VertexRagDataServiceServer).BatchCreateRagMetadata(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: VertexRagDataService_BatchCreateRagMetadata_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(VertexRagDataServiceServer).BatchCreateRagMetadata(ctx, req.(*BatchCreateRagMetadataRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _VertexRagDataService_UpdateRagMetadata_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(UpdateRagMetadataRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(VertexRagDataServiceServer).UpdateRagMetadata(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: VertexRagDataService_UpdateRagMetadata_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(VertexRagDataServiceServer).UpdateRagMetadata(ctx, req.(*UpdateRagMetadataRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _VertexRagDataService_GetRagMetadata_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(GetRagMetadataRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(VertexRagDataServiceServer).GetRagMetadata(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: VertexRagDataService_GetRagMetadata_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(VertexRagDataServiceServer).GetRagMetadata(ctx, req.(*GetRagMetadataRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _VertexRagDataService_ListRagMetadata_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ListRagMetadataRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(VertexRagDataServiceServer).ListRagMetadata(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: VertexRagDataService_ListRagMetadata_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(VertexRagDataServiceServer).ListRagMetadata(ctx, req.(*ListRagMetadataRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _VertexRagDataService_DeleteRagMetadata_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(DeleteRagMetadataRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(VertexRagDataServiceServer).DeleteRagMetadata(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: VertexRagDataService_DeleteRagMetadata_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(VertexRagDataServiceServer).DeleteRagMetadata(ctx, req.(*DeleteRagMetadataRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _VertexRagDataService_BatchDeleteRagMetadata_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(BatchDeleteRagMetadataRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(VertexRagDataServiceServer).BatchDeleteRagMetadata(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: VertexRagDataService_BatchDeleteRagMetadata_FullMethodName,
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(VertexRagDataServiceServer).BatchDeleteRagMetadata(ctx, req.(*BatchDeleteRagMetadataRequest))
	}
	return interceptor(ctx, in, info, handler)
}

// VertexRagDataService_ServiceDesc is the grpc.ServiceDesc for VertexRagDataService service.
// It's only intended for direct use with grpc.RegisterService,
// and not to be introspected or modified (even as a copy)
var VertexRagDataService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "google.cloud.aiplatform.v1beta1.VertexRagDataService",
	HandlerType: (*VertexRagDataServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateRagCorpus",
			Handler:    _VertexRagDataService_CreateRagCorpus_Handler,
		},
		{
			MethodName: "UpdateRagCorpus",
			Handler:    _VertexRagDataService_UpdateRagCorpus_Handler,
		},
		{
			MethodName: "GetRagCorpus",
			Handler:    _VertexRagDataService_GetRagCorpus_Handler,
		},
		{
			MethodName: "ListRagCorpora",
			Handler:    _VertexRagDataService_ListRagCorpora_Handler,
		},
		{
			MethodName: "DeleteRagCorpus",
			Handler:    _VertexRagDataService_DeleteRagCorpus_Handler,
		},
		{
			MethodName: "UploadRagFile",
			Handler:    _VertexRagDataService_UploadRagFile_Handler,
		},
		{
			MethodName: "ImportRagFiles",
			Handler:    _VertexRagDataService_ImportRagFiles_Handler,
		},
		{
			MethodName: "GetRagFile",
			Handler:    _VertexRagDataService_GetRagFile_Handler,
		},
		{
			MethodName: "ListRagFiles",
			Handler:    _VertexRagDataService_ListRagFiles_Handler,
		},
		{
			MethodName: "DeleteRagFile",
			Handler:    _VertexRagDataService_DeleteRagFile_Handler,
		},
		{
			MethodName: "UpdateRagEngineConfig",
			Handler:    _VertexRagDataService_UpdateRagEngineConfig_Handler,
		},
		{
			MethodName: "GetRagEngineConfig",
			Handler:    _VertexRagDataService_GetRagEngineConfig_Handler,
		},
		{
			MethodName: "CreateRagDataSchema",
			Handler:    _VertexRagDataService_CreateRagDataSchema_Handler,
		},
		{
			MethodName: "BatchCreateRagDataSchemas",
			Handler:    _VertexRagDataService_BatchCreateRagDataSchemas_Handler,
		},
		{
			MethodName: "GetRagDataSchema",
			Handler:    _VertexRagDataService_GetRagDataSchema_Handler,
		},
		{
			MethodName: "ListRagDataSchemas",
			Handler:    _VertexRagDataService_ListRagDataSchemas_Handler,
		},
		{
			MethodName: "DeleteRagDataSchema",
			Handler:    _VertexRagDataService_DeleteRagDataSchema_Handler,
		},
		{
			MethodName: "BatchDeleteRagDataSchemas",
			Handler:    _VertexRagDataService_BatchDeleteRagDataSchemas_Handler,
		},
		{
			MethodName: "CreateRagMetadata",
			Handler:    _VertexRagDataService_CreateRagMetadata_Handler,
		},
		{
			MethodName: "BatchCreateRagMetadata",
			Handler:    _VertexRagDataService_BatchCreateRagMetadata_Handler,
		},
		{
			MethodName: "UpdateRagMetadata",
			Handler:    _VertexRagDataService_UpdateRagMetadata_Handler,
		},
		{
			MethodName: "GetRagMetadata",
			Handler:    _VertexRagDataService_GetRagMetadata_Handler,
		},
		{
			MethodName: "ListRagMetadata",
			Handler:    _VertexRagDataService_ListRagMetadata_Handler,
		},
		{
			MethodName: "DeleteRagMetadata",
			Handler:    _VertexRagDataService_DeleteRagMetadata_Handler,
		},
		{
			MethodName: "BatchDeleteRagMetadata",
			Handler:    _VertexRagDataService_BatchDeleteRagMetadata_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "google/cloud/aiplatform/v1beta1/vertex_rag_data_service.proto",
}
