package Ydb_FederatedQuery_V1

import "github.com/ydb-platform/ydb-go-genproto/draft/Ydb_FederatedQuery_V1"

Index

Constants

const (
	FederatedQueryService_CreateQuery_FullMethodName        = "/FederatedQuery.V1.FederatedQueryService/CreateQuery"
	FederatedQueryService_ListQueries_FullMethodName        = "/FederatedQuery.V1.FederatedQueryService/ListQueries"
	FederatedQueryService_DescribeQuery_FullMethodName      = "/FederatedQuery.V1.FederatedQueryService/DescribeQuery"
	FederatedQueryService_GetQueryStatus_FullMethodName     = "/FederatedQuery.V1.FederatedQueryService/GetQueryStatus"
	FederatedQueryService_ModifyQuery_FullMethodName        = "/FederatedQuery.V1.FederatedQueryService/ModifyQuery"
	FederatedQueryService_DeleteQuery_FullMethodName        = "/FederatedQuery.V1.FederatedQueryService/DeleteQuery"
	FederatedQueryService_ControlQuery_FullMethodName       = "/FederatedQuery.V1.FederatedQueryService/ControlQuery"
	FederatedQueryService_GetResultData_FullMethodName      = "/FederatedQuery.V1.FederatedQueryService/GetResultData"
	FederatedQueryService_ListJobs_FullMethodName           = "/FederatedQuery.V1.FederatedQueryService/ListJobs"
	FederatedQueryService_DescribeJob_FullMethodName        = "/FederatedQuery.V1.FederatedQueryService/DescribeJob"
	FederatedQueryService_CreateConnection_FullMethodName   = "/FederatedQuery.V1.FederatedQueryService/CreateConnection"
	FederatedQueryService_ListConnections_FullMethodName    = "/FederatedQuery.V1.FederatedQueryService/ListConnections"
	FederatedQueryService_DescribeConnection_FullMethodName = "/FederatedQuery.V1.FederatedQueryService/DescribeConnection"
	FederatedQueryService_ModifyConnection_FullMethodName   = "/FederatedQuery.V1.FederatedQueryService/ModifyConnection"
	FederatedQueryService_DeleteConnection_FullMethodName   = "/FederatedQuery.V1.FederatedQueryService/DeleteConnection"
	FederatedQueryService_TestConnection_FullMethodName     = "/FederatedQuery.V1.FederatedQueryService/TestConnection"
	FederatedQueryService_CreateBinding_FullMethodName      = "/FederatedQuery.V1.FederatedQueryService/CreateBinding"
	FederatedQueryService_ListBindings_FullMethodName       = "/FederatedQuery.V1.FederatedQueryService/ListBindings"
	FederatedQueryService_DescribeBinding_FullMethodName    = "/FederatedQuery.V1.FederatedQueryService/DescribeBinding"
	FederatedQueryService_ModifyBinding_FullMethodName      = "/FederatedQuery.V1.FederatedQueryService/ModifyBinding"
	FederatedQueryService_DeleteBinding_FullMethodName      = "/FederatedQuery.V1.FederatedQueryService/DeleteBinding"
)

Variables

var FederatedQueryService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "FederatedQuery.V1.FederatedQueryService",
	HandlerType: (*FederatedQueryServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateQuery",
			Handler:    _FederatedQueryService_CreateQuery_Handler,
		},
		{
			MethodName: "ListQueries",
			Handler:    _FederatedQueryService_ListQueries_Handler,
		},
		{
			MethodName: "DescribeQuery",
			Handler:    _FederatedQueryService_DescribeQuery_Handler,
		},
		{
			MethodName: "GetQueryStatus",
			Handler:    _FederatedQueryService_GetQueryStatus_Handler,
		},
		{
			MethodName: "ModifyQuery",
			Handler:    _FederatedQueryService_ModifyQuery_Handler,
		},
		{
			MethodName: "DeleteQuery",
			Handler:    _FederatedQueryService_DeleteQuery_Handler,
		},
		{
			MethodName: "ControlQuery",
			Handler:    _FederatedQueryService_ControlQuery_Handler,
		},
		{
			MethodName: "GetResultData",
			Handler:    _FederatedQueryService_GetResultData_Handler,
		},
		{
			MethodName: "ListJobs",
			Handler:    _FederatedQueryService_ListJobs_Handler,
		},
		{
			MethodName: "DescribeJob",
			Handler:    _FederatedQueryService_DescribeJob_Handler,
		},
		{
			MethodName: "CreateConnection",
			Handler:    _FederatedQueryService_CreateConnection_Handler,
		},
		{
			MethodName: "ListConnections",
			Handler:    _FederatedQueryService_ListConnections_Handler,
		},
		{
			MethodName: "DescribeConnection",
			Handler:    _FederatedQueryService_DescribeConnection_Handler,
		},
		{
			MethodName: "ModifyConnection",
			Handler:    _FederatedQueryService_ModifyConnection_Handler,
		},
		{
			MethodName: "DeleteConnection",
			Handler:    _FederatedQueryService_DeleteConnection_Handler,
		},
		{
			MethodName: "TestConnection",
			Handler:    _FederatedQueryService_TestConnection_Handler,
		},
		{
			MethodName: "CreateBinding",
			Handler:    _FederatedQueryService_CreateBinding_Handler,
		},
		{
			MethodName: "ListBindings",
			Handler:    _FederatedQueryService_ListBindings_Handler,
		},
		{
			MethodName: "DescribeBinding",
			Handler:    _FederatedQueryService_DescribeBinding_Handler,
		},
		{
			MethodName: "ModifyBinding",
			Handler:    _FederatedQueryService_ModifyBinding_Handler,
		},
		{
			MethodName: "DeleteBinding",
			Handler:    _FederatedQueryService_DeleteBinding_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "draft/ydb_federated_query_v1.proto",
}

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

var File_draft_ydb_federated_query_v1_proto protoreflect.FileDescriptor

Functions

func RegisterFederatedQueryServiceServer

func RegisterFederatedQueryServiceServer(s grpc.ServiceRegistrar, srv FederatedQueryServiceServer)

Types

type FederatedQueryServiceClient

type FederatedQueryServiceClient interface {
	// Query
	// Query is the text of an SQL request, the results of the last run and the state after the last run (partitions offsets, consumer in YDS)
	// Create a query object with a given SQL
	CreateQuery(ctx context.Context, in *Ydb_FederatedQuery.CreateQueryRequest, opts ...grpc.CallOption) (*Ydb_FederatedQuery.CreateQueryResponse, error)
	// Get a list of brief queries objects
	ListQueries(ctx context.Context, in *Ydb_FederatedQuery.ListQueriesRequest, opts ...grpc.CallOption) (*Ydb_FederatedQuery.ListQueriesResponse, error)
	// Get full information about the object of the query
	DescribeQuery(ctx context.Context, in *Ydb_FederatedQuery.DescribeQueryRequest, opts ...grpc.CallOption) (*Ydb_FederatedQuery.DescribeQueryResponse, error)
	// Get status of the query
	GetQueryStatus(ctx context.Context, in *Ydb_FederatedQuery.GetQueryStatusRequest, opts ...grpc.CallOption) (*Ydb_FederatedQuery.GetQueryStatusResponse, error)
	// Change the attributes of the query (acl, name, ...)
	ModifyQuery(ctx context.Context, in *Ydb_FederatedQuery.ModifyQueryRequest, opts ...grpc.CallOption) (*Ydb_FederatedQuery.ModifyQueryResponse, error)
	// Completely delete the query
	DeleteQuery(ctx context.Context, in *Ydb_FederatedQuery.DeleteQueryRequest, opts ...grpc.CallOption) (*Ydb_FederatedQuery.DeleteQueryResponse, error)
	// Change the state of the query lifecycle
	ControlQuery(ctx context.Context, in *Ydb_FederatedQuery.ControlQueryRequest, opts ...grpc.CallOption) (*Ydb_FederatedQuery.ControlQueryResponse, error)
	// Get a results page
	GetResultData(ctx context.Context, in *Ydb_FederatedQuery.GetResultDataRequest, opts ...grpc.CallOption) (*Ydb_FederatedQuery.GetResultDataResponse, error)
	// Job
	// Job - appears immediately after starting the request and contains the request metadata
	// Get a list of jobs
	ListJobs(ctx context.Context, in *Ydb_FederatedQuery.ListJobsRequest, opts ...grpc.CallOption) (*Ydb_FederatedQuery.ListJobsResponse, error)
	// Get information about the job
	DescribeJob(ctx context.Context, in *Ydb_FederatedQuery.DescribeJobRequest, opts ...grpc.CallOption) (*Ydb_FederatedQuery.DescribeJobResponse, error)
	// Connection
	// Connection - entity that describes connection points. This can be imagined as an analogue of a network address.
	// Create a connection object (ObjectStorage, YDB, YDS, ...)
	CreateConnection(ctx context.Context, in *Ydb_FederatedQuery.CreateConnectionRequest, opts ...grpc.CallOption) (*Ydb_FederatedQuery.CreateConnectionResponse, error)
	// Get a list of connections objects
	ListConnections(ctx context.Context, in *Ydb_FederatedQuery.ListConnectionsRequest, opts ...grpc.CallOption) (*Ydb_FederatedQuery.ListConnectionsResponse, error)
	// Get information about the object of the connection
	DescribeConnection(ctx context.Context, in *Ydb_FederatedQuery.DescribeConnectionRequest, opts ...grpc.CallOption) (*Ydb_FederatedQuery.DescribeConnectionResponse, error)
	// Change the attributes of the connection
	ModifyConnection(ctx context.Context, in *Ydb_FederatedQuery.ModifyConnectionRequest, opts ...grpc.CallOption) (*Ydb_FederatedQuery.ModifyConnectionResponse, error)
	// Completely delete the connection
	DeleteConnection(ctx context.Context, in *Ydb_FederatedQuery.DeleteConnectionRequest, opts ...grpc.CallOption) (*Ydb_FederatedQuery.DeleteConnectionResponse, error)
	// Test the connection (permissions, network, ...)
	TestConnection(ctx context.Context, in *Ydb_FederatedQuery.TestConnectionRequest, opts ...grpc.CallOption) (*Ydb_FederatedQuery.TestConnectionResponse, error)
	// Binding
	// Binding - entity using which a schema is assigned to non-schematic data
	// Create a binding object - bind schema with ObjectStorage object or YDS stream
	CreateBinding(ctx context.Context, in *Ydb_FederatedQuery.CreateBindingRequest, opts ...grpc.CallOption) (*Ydb_FederatedQuery.CreateBindingResponse, error)
	// Get a list of bindings objects
	ListBindings(ctx context.Context, in *Ydb_FederatedQuery.ListBindingsRequest, opts ...grpc.CallOption) (*Ydb_FederatedQuery.ListBindingsResponse, error)
	// Get information about the object of the binding
	DescribeBinding(ctx context.Context, in *Ydb_FederatedQuery.DescribeBindingRequest, opts ...grpc.CallOption) (*Ydb_FederatedQuery.DescribeBindingResponse, error)
	// Change the attributes of the binding
	ModifyBinding(ctx context.Context, in *Ydb_FederatedQuery.ModifyBindingRequest, opts ...grpc.CallOption) (*Ydb_FederatedQuery.ModifyBindingResponse, error)
	// Completely delete the binding
	DeleteBinding(ctx context.Context, in *Ydb_FederatedQuery.DeleteBindingRequest, opts ...grpc.CallOption) (*Ydb_FederatedQuery.DeleteBindingResponse, error)
}

FederatedQueryServiceClient is the client API for FederatedQueryService 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 NewFederatedQueryServiceClient

func NewFederatedQueryServiceClient(cc grpc.ClientConnInterface) FederatedQueryServiceClient

type FederatedQueryServiceServer

type FederatedQueryServiceServer interface {
	// Query
	// Query is the text of an SQL request, the results of the last run and the state after the last run (partitions offsets, consumer in YDS)
	// Create a query object with a given SQL
	CreateQuery(context.Context, *Ydb_FederatedQuery.CreateQueryRequest) (*Ydb_FederatedQuery.CreateQueryResponse, error)
	// Get a list of brief queries objects
	ListQueries(context.Context, *Ydb_FederatedQuery.ListQueriesRequest) (*Ydb_FederatedQuery.ListQueriesResponse, error)
	// Get full information about the object of the query
	DescribeQuery(context.Context, *Ydb_FederatedQuery.DescribeQueryRequest) (*Ydb_FederatedQuery.DescribeQueryResponse, error)
	// Get status of the query
	GetQueryStatus(context.Context, *Ydb_FederatedQuery.GetQueryStatusRequest) (*Ydb_FederatedQuery.GetQueryStatusResponse, error)
	// Change the attributes of the query (acl, name, ...)
	ModifyQuery(context.Context, *Ydb_FederatedQuery.ModifyQueryRequest) (*Ydb_FederatedQuery.ModifyQueryResponse, error)
	// Completely delete the query
	DeleteQuery(context.Context, *Ydb_FederatedQuery.DeleteQueryRequest) (*Ydb_FederatedQuery.DeleteQueryResponse, error)
	// Change the state of the query lifecycle
	ControlQuery(context.Context, *Ydb_FederatedQuery.ControlQueryRequest) (*Ydb_FederatedQuery.ControlQueryResponse, error)
	// Get a results page
	GetResultData(context.Context, *Ydb_FederatedQuery.GetResultDataRequest) (*Ydb_FederatedQuery.GetResultDataResponse, error)
	// Job
	// Job - appears immediately after starting the request and contains the request metadata
	// Get a list of jobs
	ListJobs(context.Context, *Ydb_FederatedQuery.ListJobsRequest) (*Ydb_FederatedQuery.ListJobsResponse, error)
	// Get information about the job
	DescribeJob(context.Context, *Ydb_FederatedQuery.DescribeJobRequest) (*Ydb_FederatedQuery.DescribeJobResponse, error)
	// Connection
	// Connection - entity that describes connection points. This can be imagined as an analogue of a network address.
	// Create a connection object (ObjectStorage, YDB, YDS, ...)
	CreateConnection(context.Context, *Ydb_FederatedQuery.CreateConnectionRequest) (*Ydb_FederatedQuery.CreateConnectionResponse, error)
	// Get a list of connections objects
	ListConnections(context.Context, *Ydb_FederatedQuery.ListConnectionsRequest) (*Ydb_FederatedQuery.ListConnectionsResponse, error)
	// Get information about the object of the connection
	DescribeConnection(context.Context, *Ydb_FederatedQuery.DescribeConnectionRequest) (*Ydb_FederatedQuery.DescribeConnectionResponse, error)
	// Change the attributes of the connection
	ModifyConnection(context.Context, *Ydb_FederatedQuery.ModifyConnectionRequest) (*Ydb_FederatedQuery.ModifyConnectionResponse, error)
	// Completely delete the connection
	DeleteConnection(context.Context, *Ydb_FederatedQuery.DeleteConnectionRequest) (*Ydb_FederatedQuery.DeleteConnectionResponse, error)
	// Test the connection (permissions, network, ...)
	TestConnection(context.Context, *Ydb_FederatedQuery.TestConnectionRequest) (*Ydb_FederatedQuery.TestConnectionResponse, error)
	// Binding
	// Binding - entity using which a schema is assigned to non-schematic data
	// Create a binding object - bind schema with ObjectStorage object or YDS stream
	CreateBinding(context.Context, *Ydb_FederatedQuery.CreateBindingRequest) (*Ydb_FederatedQuery.CreateBindingResponse, error)
	// Get a list of bindings objects
	ListBindings(context.Context, *Ydb_FederatedQuery.ListBindingsRequest) (*Ydb_FederatedQuery.ListBindingsResponse, error)
	// Get information about the object of the binding
	DescribeBinding(context.Context, *Ydb_FederatedQuery.DescribeBindingRequest) (*Ydb_FederatedQuery.DescribeBindingResponse, error)
	// Change the attributes of the binding
	ModifyBinding(context.Context, *Ydb_FederatedQuery.ModifyBindingRequest) (*Ydb_FederatedQuery.ModifyBindingResponse, error)
	// Completely delete the binding
	DeleteBinding(context.Context, *Ydb_FederatedQuery.DeleteBindingRequest) (*Ydb_FederatedQuery.DeleteBindingResponse, error)
	// contains filtered or unexported methods
}

FederatedQueryServiceServer is the server API for FederatedQueryService service. All implementations must embed UnimplementedFederatedQueryServiceServer for forward compatibility

type UnimplementedFederatedQueryServiceServer

type UnimplementedFederatedQueryServiceServer struct {
}

UnimplementedFederatedQueryServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedFederatedQueryServiceServer) ControlQuery

func (UnimplementedFederatedQueryServiceServer) CreateBinding

func (UnimplementedFederatedQueryServiceServer) CreateConnection

func (UnimplementedFederatedQueryServiceServer) CreateQuery

func (UnimplementedFederatedQueryServiceServer) DeleteBinding

func (UnimplementedFederatedQueryServiceServer) DeleteConnection

func (UnimplementedFederatedQueryServiceServer) DeleteQuery

func (UnimplementedFederatedQueryServiceServer) DescribeBinding

func (UnimplementedFederatedQueryServiceServer) DescribeConnection

func (UnimplementedFederatedQueryServiceServer) DescribeJob

func (UnimplementedFederatedQueryServiceServer) DescribeQuery

func (UnimplementedFederatedQueryServiceServer) GetQueryStatus

func (UnimplementedFederatedQueryServiceServer) GetResultData

func (UnimplementedFederatedQueryServiceServer) ListBindings

func (UnimplementedFederatedQueryServiceServer) ListConnections

func (UnimplementedFederatedQueryServiceServer) ListJobs

func (UnimplementedFederatedQueryServiceServer) ListQueries

func (UnimplementedFederatedQueryServiceServer) ModifyBinding

func (UnimplementedFederatedQueryServiceServer) ModifyConnection

func (UnimplementedFederatedQueryServiceServer) ModifyQuery

func (UnimplementedFederatedQueryServiceServer) TestConnection

type UnsafeFederatedQueryServiceServer

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

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

Source Files

ydb_federated_query_v1.pb.go ydb_federated_query_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.