package Ydb_Import_V1

import "github.com/ydb-platform/ydb-go-genproto/Ydb_Import_V1"

Index

Constants

const (
	ImportService_ImportFromS3_FullMethodName = "/Ydb.Import.V1.ImportService/ImportFromS3"
	ImportService_ImportData_FullMethodName   = "/Ydb.Import.V1.ImportService/ImportData"
)

Variables

var File_ydb_import_v1_proto protoreflect.FileDescriptor
var ImportService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "Ydb.Import.V1.ImportService",
	HandlerType: (*ImportServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ImportFromS3",
			Handler:    _ImportService_ImportFromS3_Handler,
		},
		{
			MethodName: "ImportData",
			Handler:    _ImportService_ImportData_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "ydb_import_v1.proto",
}

ImportService_ServiceDesc is the grpc.ServiceDesc for ImportService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterImportServiceServer

func RegisterImportServiceServer(s grpc.ServiceRegistrar, srv ImportServiceServer)

Types

type ImportServiceClient

type ImportServiceClient interface {
	// Imports data from S3.
	// Method starts an asynchronous operation that can be cancelled while it is in progress.
	ImportFromS3(ctx context.Context, in *Ydb_Import.ImportFromS3Request, opts ...grpc.CallOption) (*Ydb_Import.ImportFromS3Response, error)
	// Writes data to a table.
	// Method accepts serialized data in the selected format and writes it non-transactionally.
	ImportData(ctx context.Context, in *Ydb_Import.ImportDataRequest, opts ...grpc.CallOption) (*Ydb_Import.ImportDataResponse, error)
}

ImportServiceClient is the client API for ImportService 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.

func NewImportServiceClient

func NewImportServiceClient(cc grpc.ClientConnInterface) ImportServiceClient

type ImportServiceServer

type ImportServiceServer interface {
	// Imports data from S3.
	// Method starts an asynchronous operation that can be cancelled while it is in progress.
	ImportFromS3(context.Context, *Ydb_Import.ImportFromS3Request) (*Ydb_Import.ImportFromS3Response, error)
	// Writes data to a table.
	// Method accepts serialized data in the selected format and writes it non-transactionally.
	ImportData(context.Context, *Ydb_Import.ImportDataRequest) (*Ydb_Import.ImportDataResponse, error)
	// contains filtered or unexported methods
}

ImportServiceServer is the server API for ImportService service. All implementations must embed UnimplementedImportServiceServer for forward compatibility

type UnimplementedImportServiceServer

type UnimplementedImportServiceServer struct {
}

UnimplementedImportServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedImportServiceServer) ImportData

func (UnimplementedImportServiceServer) ImportFromS3

type UnsafeImportServiceServer

type UnsafeImportServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeImportServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ImportServiceServer will result in compilation errors.

Source Files

ydb_import_v1.pb.go ydb_import_v1_grpc.pb.go

Version
v0.0.0-20241112172322-ea1f63298f77 (latest)
Published
Nov 12, 2024
Platform
linux/amd64
Imports
8 packages
Last checked
4 weeks ago

Tools for package owners.