Ydb_Experimental_V1

Documentation

Index

• Variables
• func RegisterExperimentalServiceServer(s grpc.ServiceRegistrar, srv ExperimentalServiceServer)
• type ExperimentalServiceClient
  • func NewExperimentalServiceClient(cc grpc.ClientConnInterface) ExperimentalServiceClient
• type ExperimentalServiceServer
• type ExperimentalService_ExecuteStreamQueryClient
• type ExperimentalService_ExecuteStreamQueryServer
• type UnimplementedExperimentalServiceServer
  • func (UnimplementedExperimentalServiceServer) ExecuteStreamQuery(*Ydb_Experimental.ExecuteStreamQueryRequest, ...) error
• type UnsafeExperimentalServiceServer

Variables

var ExperimentalService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "Ydb.Experimental.V1.ExperimentalService",
	HandlerType: (*ExperimentalServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ExecuteStreamQuery",
			Handler:       _ExperimentalService_ExecuteStreamQuery_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "ydb_experimental_v1.proto",
}

ExperimentalService_ServiceDesc is the grpc.ServiceDesc for ExperimentalService 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_experimental_v1_proto protoreflect.FileDescriptor

Functions

func RegisterExperimentalServiceServer

func RegisterExperimentalServiceServer(s grpc.ServiceRegistrar, srv ExperimentalServiceServer)

Types

type ExperimentalServiceClient

type ExperimentalServiceClient interface {
	ExecuteStreamQuery(ctx context.Context, in *Ydb_Experimental.ExecuteStreamQueryRequest, opts ...grpc.CallOption) (ExperimentalService_ExecuteStreamQueryClient, error)
}

ExperimentalServiceClient is the client API for ExperimentalService 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 NewExperimentalServiceClient

func NewExperimentalServiceClient(cc grpc.ClientConnInterface) ExperimentalServiceClient

type ExperimentalServiceServer

type ExperimentalServiceServer interface {
	ExecuteStreamQuery(*Ydb_Experimental.ExecuteStreamQueryRequest, ExperimentalService_ExecuteStreamQueryServer) error
	// contains filtered or unexported methods
}

ExperimentalServiceServer is the server API for ExperimentalService service. All implementations must embed UnimplementedExperimentalServiceServer for forward compatibility

type ExperimentalService_ExecuteStreamQueryClient

type ExperimentalService_ExecuteStreamQueryClient interface {
	Recv() (*Ydb_Experimental.ExecuteStreamQueryResponse, error)
	grpc.ClientStream
}

type ExperimentalService_ExecuteStreamQueryServer

type ExperimentalService_ExecuteStreamQueryServer interface {
	Send(*Ydb_Experimental.ExecuteStreamQueryResponse) error
	grpc.ServerStream
}

type UnimplementedExperimentalServiceServer

type UnimplementedExperimentalServiceServer struct {
}

UnimplementedExperimentalServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedExperimentalServiceServer) ExecuteStreamQuery

func (UnimplementedExperimentalServiceServer) ExecuteStreamQuery(*Ydb_Experimental.ExecuteStreamQueryRequest, ExperimentalService_ExecuteStreamQueryServer) error

type UnsafeExperimentalServiceServer

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

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