Documentation ¶
Index ¶
Constants ¶
const ( ExportService_ExportToYt_FullMethodName = "/Ydb.Export.V1.ExportService/ExportToYt" ExportService_ExportToS3_FullMethodName = "/Ydb.Export.V1.ExportService/ExportToS3" )
Variables ¶
var ExportService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "Ydb.Export.V1.ExportService", HandlerType: (*ExportServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "ExportToYt", Handler: _ExportService_ExportToYt_Handler, }, { MethodName: "ExportToS3", Handler: _ExportService_ExportToS3_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "ydb_export_v1.proto", }
ExportService_ServiceDesc is the grpc.ServiceDesc for ExportService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_ydb_export_v1_proto protoreflect.FileDescriptor
Functions ¶
func RegisterExportServiceServer ¶
func RegisterExportServiceServer(s grpc.ServiceRegistrar, srv ExportServiceServer)
Types ¶
type ExportServiceClient ¶
type ExportServiceClient interface { // Exports data to YT. // Method starts an asynchronous operation that can be cancelled while it is in progress. ExportToYt(ctx context.Context, in *Ydb_Export.ExportToYtRequest, opts ...grpc.CallOption) (*Ydb_Export.ExportToYtResponse, error) // Exports data to S3. // Method starts an asynchronous operation that can be cancelled while it is in progress. ExportToS3(ctx context.Context, in *Ydb_Export.ExportToS3Request, opts ...grpc.CallOption) (*Ydb_Export.ExportToS3Response, error) }
ExportServiceClient is the client API for ExportService 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 NewExportServiceClient ¶
func NewExportServiceClient(cc grpc.ClientConnInterface) ExportServiceClient
type ExportServiceServer ¶
type ExportServiceServer interface { // Exports data to YT. // Method starts an asynchronous operation that can be cancelled while it is in progress. ExportToYt(context.Context, *Ydb_Export.ExportToYtRequest) (*Ydb_Export.ExportToYtResponse, error) // Exports data to S3. // Method starts an asynchronous operation that can be cancelled while it is in progress. ExportToS3(context.Context, *Ydb_Export.ExportToS3Request) (*Ydb_Export.ExportToS3Response, error) // contains filtered or unexported methods }
ExportServiceServer is the server API for ExportService service. All implementations must embed UnimplementedExportServiceServer for forward compatibility
type UnimplementedExportServiceServer ¶
type UnimplementedExportServiceServer struct { }
UnimplementedExportServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedExportServiceServer) ExportToS3 ¶
func (UnimplementedExportServiceServer) ExportToS3(context.Context, *Ydb_Export.ExportToS3Request) (*Ydb_Export.ExportToS3Response, error)
func (UnimplementedExportServiceServer) ExportToYt ¶
func (UnimplementedExportServiceServer) ExportToYt(context.Context, *Ydb_Export.ExportToYtRequest) (*Ydb_Export.ExportToYtResponse, error)
type UnsafeExportServiceServer ¶
type UnsafeExportServiceServer interface {
// contains filtered or unexported methods
}
UnsafeExportServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ExportServiceServer will result in compilation errors.