package Ydb_Import_V1
import "github.com/ydb-platform/ydb-go-genproto/Ydb_Import_V1"
Index ¶
- Constants
- Variables
- func RegisterImportServiceServer(s grpc.ServiceRegistrar, srv ImportServiceServer)
- type ImportServiceClient
- type ImportServiceServer
- type UnimplementedImportServiceServer
- func (UnimplementedImportServiceServer) ImportData(context.Context, *Ydb_Import.ImportDataRequest) (*Ydb_Import.ImportDataResponse, error)
- func (UnimplementedImportServiceServer) ImportFromS3(context.Context, *Ydb_Import.ImportFromS3Request) (*Ydb_Import.ImportFromS3Response, error)
- type UnsafeImportServiceServer
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) ImportData(context.Context, *Ydb_Import.ImportDataRequest) (*Ydb_Import.ImportDataResponse, error)
func (UnimplementedImportServiceServer) ImportFromS3 ¶
func (UnimplementedImportServiceServer) ImportFromS3(context.Context, *Ydb_Import.ImportFromS3Request) (*Ydb_Import.ImportFromS3Response, error)
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.