service

package
v0.1.1-rc.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 12, 2024 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var Connector_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "NYql.NConnector.NApi.Connector",
	HandlerType: (*ConnectorServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "DescribeTable",
			Handler:    _Connector_DescribeTable_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ListTables",
			Handler:       _Connector_ListTables_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "ListSplits",
			Handler:       _Connector_ListSplits_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "ReadSplits",
			Handler:       _Connector_ReadSplits_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "ydb/library/yql/providers/generic/connector/api/service/connector.proto",
}

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

View Source
var File_ydb_library_yql_providers_generic_connector_api_service_connector_proto protoreflect.FileDescriptor

Functions

func RegisterConnectorServer

func RegisterConnectorServer(s grpc.ServiceRegistrar, srv ConnectorServer)

Types

type ConnectorClient

type ConnectorClient interface {
	// ListTables returns the list of tables existing in a particular database.
	ListTables(ctx context.Context, in *protos.TListTablesRequest, opts ...grpc.CallOption) (Connector_ListTablesClient, error)
	// DescribeTable returns table's schema.
	DescribeTable(ctx context.Context, in *protos.TDescribeTableRequest, opts ...grpc.CallOption) (*protos.TDescribeTableResponse, error)
	// ListSplits asks Connector to partition the data that are going to be read
	// into elementary parts suitable for parallel reading.
	ListSplits(ctx context.Context, in *protos.TListSplitsRequest, opts ...grpc.CallOption) (Connector_ListSplitsClient, error)
	// ReadSplits reads data associated with splits.
	ReadSplits(ctx context.Context, in *protos.TReadSplitsRequest, opts ...grpc.CallOption) (Connector_ReadSplitsClient, error)
}

ConnectorClient is the client API for Connector 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 NewConnectorClient

func NewConnectorClient(cc grpc.ClientConnInterface) ConnectorClient

type ConnectorServer

type ConnectorServer interface {
	// ListTables returns the list of tables existing in a particular database.
	ListTables(*protos.TListTablesRequest, Connector_ListTablesServer) error
	// DescribeTable returns table's schema.
	DescribeTable(context.Context, *protos.TDescribeTableRequest) (*protos.TDescribeTableResponse, error)
	// ListSplits asks Connector to partition the data that are going to be read
	// into elementary parts suitable for parallel reading.
	ListSplits(*protos.TListSplitsRequest, Connector_ListSplitsServer) error
	// ReadSplits reads data associated with splits.
	ReadSplits(*protos.TReadSplitsRequest, Connector_ReadSplitsServer) error
	// contains filtered or unexported methods
}

ConnectorServer is the server API for Connector service. All implementations must embed UnimplementedConnectorServer for forward compatibility

type Connector_ListSplitsClient

type Connector_ListSplitsClient interface {
	Recv() (*protos.TListSplitsResponse, error)
	grpc.ClientStream
}

type Connector_ListSplitsServer

type Connector_ListSplitsServer interface {
	Send(*protos.TListSplitsResponse) error
	grpc.ServerStream
}

type Connector_ListTablesClient

type Connector_ListTablesClient interface {
	Recv() (*protos.TListTablesResponse, error)
	grpc.ClientStream
}

type Connector_ListTablesServer

type Connector_ListTablesServer interface {
	Send(*protos.TListTablesResponse) error
	grpc.ServerStream
}

type Connector_ReadSplitsClient

type Connector_ReadSplitsClient interface {
	Recv() (*protos.TReadSplitsResponse, error)
	grpc.ClientStream
}

type Connector_ReadSplitsServer

type Connector_ReadSplitsServer interface {
	Send(*protos.TReadSplitsResponse) error
	grpc.ServerStream
}

type UnimplementedConnectorServer

type UnimplementedConnectorServer struct {
}

UnimplementedConnectorServer must be embedded to have forward compatible implementations.

func (UnimplementedConnectorServer) ListSplits

func (UnimplementedConnectorServer) ListTables

func (UnimplementedConnectorServer) ReadSplits

type UnsafeConnectorServer

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

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL