Ydb_PersQueue_V1

package
v2.7.0 Latest Latest
Warning

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

Go to latest
Published: Sep 13, 2021 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source
const (
	StreamingWrite         = "/Ydb.PersQueue.V1.PersQueueService/StreamingWrite"
	MigrationStreamingRead = "/Ydb.PersQueue.V1.PersQueueService/MigrationStreamingRead"
	GetReadSessionsInfo    = "/Ydb.PersQueue.V1.PersQueueService/GetReadSessionsInfo"
	DescribeTopic          = "/Ydb.PersQueue.V1.PersQueueService/DescribeTopic"
	DropTopic              = "/Ydb.PersQueue.V1.PersQueueService/DropTopic"
	CreateTopic            = "/Ydb.PersQueue.V1.PersQueueService/CreateTopic"
	AlterTopic             = "/Ydb.PersQueue.V1.PersQueueService/AlterTopic"
	AddReadRule            = "/Ydb.PersQueue.V1.PersQueueService/AddReadRule"
	RemoveReadRule         = "/Ydb.PersQueue.V1.PersQueueService/RemoveReadRule"
	DiscoverClusters       = "/Ydb.PersQueue.V1.ClusterDiscoveryService/DiscoverClusters"
)

Variables

This section is empty.

Functions

func RegisterClusterDiscoveryServiceServer

func RegisterClusterDiscoveryServiceServer(s *grpc.Server, srv ClusterDiscoveryServiceServer)

func RegisterPersQueueServiceServer

func RegisterPersQueueServiceServer(s *grpc.Server, srv PersQueueServiceServer)

Types

type ClusterDiscoveryServiceClient

type ClusterDiscoveryServiceClient interface {
	// Get PQ clusters which are eligible for the specified Write or Read Sessions
	DiscoverClusters(ctx context.Context, in *Ydb_PersQueue_ClusterDiscovery.DiscoverClustersRequest, opts ...grpc.CallOption) (*Ydb_PersQueue_ClusterDiscovery.DiscoverClustersResponse, error)
}

ClusterDiscoveryServiceClient is the client API for ClusterDiscoveryService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

type ClusterDiscoveryServiceServer

type ClusterDiscoveryServiceServer interface {
	// Get PQ clusters which are eligible for the specified Write or Read Sessions
	DiscoverClusters(context.Context, *Ydb_PersQueue_ClusterDiscovery.DiscoverClustersRequest) (*Ydb_PersQueue_ClusterDiscovery.DiscoverClustersResponse, error)
}

ClusterDiscoveryServiceServer is the server API for ClusterDiscoveryService service.

type PersQueueServiceClient

type PersQueueServiceClient interface {
	StreamingWrite(ctx context.Context, opts ...grpc.CallOption) (PersQueueService_StreamingWriteClient, error)
	//*
	// Creates Read Session
	// Pipeline:
	// client                  server
	//         Init(Topics, ClientId, ...)
	//        ---------------->
	//         Init(SessionId)
	//        <----------------
	//         read1
	//        ---------------->
	//         read2
	//        ---------------->
	//         assign(Topic1, Cluster, Partition1, ...) - assigns and releases are optional
	//        <----------------
	//         assign(Topic2, Clutster, Partition2, ...)
	//        <----------------
	//         start_read(Topic1, Partition1, ...) - client must respond to assign request with this message. Only after this client will start recieving messages from this partition
	//        ---------------->
	//         release(Topic1, Partition1, ...)
	//        <----------------
	//         released(Topic1, Partition1, ...) - only after released server will give this parittion to other session.
	//        ---------------->
	//         start_read(Topic2, Partition2, ...) - client must respond to assign request with this message. Only after this client will start recieving messages from this partition
	//        ---------------->
	//         read data(data, ...)
	//        <----------------
	//         commit(cookie1)
	//        ---------------->
	//         committed(cookie1)
	//        <----------------
	//         issue(description, ...)
	//        <----------------
	MigrationStreamingRead(ctx context.Context, opts ...grpc.CallOption) (PersQueueService_MigrationStreamingReadClient, error)
	// Get information about reading
	GetReadSessionsInfo(ctx context.Context, in *Ydb_Persqueue_V1.ReadInfoRequest, opts ...grpc.CallOption) (*Ydb_Persqueue_V1.ReadInfoResponse, error)
	//
	// Describe topic command.
	DescribeTopic(ctx context.Context, in *Ydb_Persqueue_V1.DescribeTopicRequest, opts ...grpc.CallOption) (*Ydb_Persqueue_V1.DescribeTopicResponse, error)
	//
	// Drop topic command.
	DropTopic(ctx context.Context, in *Ydb_Persqueue_V1.DropTopicRequest, opts ...grpc.CallOption) (*Ydb_Persqueue_V1.DropTopicResponse, error)
	//
	// Create topic command.
	CreateTopic(ctx context.Context, in *Ydb_Persqueue_V1.CreateTopicRequest, opts ...grpc.CallOption) (*Ydb_Persqueue_V1.CreateTopicResponse, error)
	//
	// Alter topic command.
	AlterTopic(ctx context.Context, in *Ydb_Persqueue_V1.AlterTopicRequest, opts ...grpc.CallOption) (*Ydb_Persqueue_V1.AlterTopicResponse, error)
	//
	// Add read rule command.
	AddReadRule(ctx context.Context, in *Ydb_Persqueue_V1.AddReadRuleRequest, opts ...grpc.CallOption) (*Ydb_Persqueue_V1.AddReadRuleResponse, error)
	//
	// Remove read rule command.
	RemoveReadRule(ctx context.Context, in *Ydb_Persqueue_V1.RemoveReadRuleRequest, opts ...grpc.CallOption) (*Ydb_Persqueue_V1.RemoveReadRuleResponse, error)
}

PersQueueServiceClient is the client API for PersQueueService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

type PersQueueServiceServer

type PersQueueServiceServer interface {
	StreamingWrite(PersQueueService_StreamingWriteServer) error
	//*
	// Creates Read Session
	// Pipeline:
	// client                  server
	//         Init(Topics, ClientId, ...)
	//        ---------------->
	//         Init(SessionId)
	//        <----------------
	//         read1
	//        ---------------->
	//         read2
	//        ---------------->
	//         assign(Topic1, Cluster, Partition1, ...) - assigns and releases are optional
	//        <----------------
	//         assign(Topic2, Clutster, Partition2, ...)
	//        <----------------
	//         start_read(Topic1, Partition1, ...) - client must respond to assign request with this message. Only after this client will start recieving messages from this partition
	//        ---------------->
	//         release(Topic1, Partition1, ...)
	//        <----------------
	//         released(Topic1, Partition1, ...) - only after released server will give this parittion to other session.
	//        ---------------->
	//         start_read(Topic2, Partition2, ...) - client must respond to assign request with this message. Only after this client will start recieving messages from this partition
	//        ---------------->
	//         read data(data, ...)
	//        <----------------
	//         commit(cookie1)
	//        ---------------->
	//         committed(cookie1)
	//        <----------------
	//         issue(description, ...)
	//        <----------------
	MigrationStreamingRead(PersQueueService_MigrationStreamingReadServer) error
	// Get information about reading
	GetReadSessionsInfo(context.Context, *Ydb_Persqueue_V1.ReadInfoRequest) (*Ydb_Persqueue_V1.ReadInfoResponse, error)
	//
	// Describe topic command.
	DescribeTopic(context.Context, *Ydb_Persqueue_V1.DescribeTopicRequest) (*Ydb_Persqueue_V1.DescribeTopicResponse, error)
	//
	// Drop topic command.
	DropTopic(context.Context, *Ydb_Persqueue_V1.DropTopicRequest) (*Ydb_Persqueue_V1.DropTopicResponse, error)
	//
	// Create topic command.
	CreateTopic(context.Context, *Ydb_Persqueue_V1.CreateTopicRequest) (*Ydb_Persqueue_V1.CreateTopicResponse, error)
	//
	// Alter topic command.
	AlterTopic(context.Context, *Ydb_Persqueue_V1.AlterTopicRequest) (*Ydb_Persqueue_V1.AlterTopicResponse, error)
	//
	// Add read rule command.
	AddReadRule(context.Context, *Ydb_Persqueue_V1.AddReadRuleRequest) (*Ydb_Persqueue_V1.AddReadRuleResponse, error)
	//
	// Remove read rule command.
	RemoveReadRule(context.Context, *Ydb_Persqueue_V1.RemoveReadRuleRequest) (*Ydb_Persqueue_V1.RemoveReadRuleResponse, error)
}

PersQueueServiceServer is the server API for PersQueueService service.

type UnimplementedClusterDiscoveryServiceServer

type UnimplementedClusterDiscoveryServiceServer struct {
}

UnimplementedClusterDiscoveryServiceServer can be embedded to have forward compatible implementations.

type UnimplementedPersQueueServiceServer

type UnimplementedPersQueueServiceServer struct {
}

UnimplementedPersQueueServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedPersQueueServiceServer) AlterTopic

func (*UnimplementedPersQueueServiceServer) DropTopic

func (*UnimplementedPersQueueServiceServer) GetReadSessionsInfo

func (*UnimplementedPersQueueServiceServer) MigrationStreamingRead

func (*UnimplementedPersQueueServiceServer) StreamingWrite

Jump to

Keyboard shortcuts

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