service

Documentation

Index

• Constants
• Variables
• func RegisterConnectorServer(s grpc.ServiceRegistrar, srv ConnectorServer)
• type ConnectorClient
  • func NewConnectorClient(cc grpc.ClientConnInterface) ConnectorClient
• type ConnectorServer
• type Connector_ListSplitsClient
• type Connector_ListSplitsServer
• type Connector_ListTablesClient
• type Connector_ListTablesServer
• type Connector_ReadSplitsClient
• type Connector_ReadSplitsServer
• type UnimplementedConnectorServer
  • func (UnimplementedConnectorServer) DescribeTable(context.Context, *protos.TDescribeTableRequest) (*protos.TDescribeTableResponse, error)
  • func (UnimplementedConnectorServer) ListSplits(*protos.TListSplitsRequest, Connector_ListSplitsServer) error
  • func (UnimplementedConnectorServer) ListTables(*protos.TListTablesRequest, Connector_ListTablesServer) error
  • func (UnimplementedConnectorServer) ReadSplits(*protos.TReadSplitsRequest, Connector_ReadSplitsServer) error
• type UnsafeConnectorServer

Constants

const (
	Connector_ListTables_FullMethodName    = "/NYql.NConnector.NApi.Connector/ListTables"
	Connector_DescribeTable_FullMethodName = "/NYql.NConnector.NApi.Connector/DescribeTable"
	Connector_ListSplits_FullMethodName    = "/NYql.NConnector.NApi.Connector/ListSplits"
	Connector_ReadSplits_FullMethodName    = "/NYql.NConnector.NApi.Connector/ReadSplits"
)

Variables

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)

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) DescribeTable

func (UnimplementedConnectorServer) DescribeTable(context.Context, *protos.TDescribeTableRequest) (*protos.TDescribeTableResponse, error)

func (UnimplementedConnectorServer) ListSplits

func (UnimplementedConnectorServer) ListSplits(*protos.TListSplitsRequest, Connector_ListSplitsServer) error

func (UnimplementedConnectorServer) ListTables

func (UnimplementedConnectorServer) ListTables(*protos.TListTablesRequest, Connector_ListTablesServer) error

func (UnimplementedConnectorServer) ReadSplits

func (UnimplementedConnectorServer) ReadSplits(*protos.TReadSplitsRequest, Connector_ReadSplitsServer) error

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.