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.

func NewClusterDiscoveryServiceClient 

func NewClusterDiscoveryServiceClient(cc grpc.ClientConnInterface) ClusterDiscoveryServiceClient

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.

func NewPersQueueServiceClient 

func NewPersQueueServiceClient(cc grpc.ClientConnInterface) PersQueueServiceClient

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 PersQueueService_MigrationStreamingReadClient 

type PersQueueService_MigrationStreamingReadClient interface {
	Send(*Ydb_Persqueue_V1.MigrationStreamingReadClientMessage) error
	Recv() (*Ydb_Persqueue_V1.MigrationStreamingReadServerMessage, error)
	grpc.ClientStream
}

type PersQueueService_MigrationStreamingReadServer 

type PersQueueService_MigrationStreamingReadServer interface {
	Send(*Ydb_Persqueue_V1.MigrationStreamingReadServerMessage) error
	Recv() (*Ydb_Persqueue_V1.MigrationStreamingReadClientMessage, error)
	grpc.ServerStream
}

type PersQueueService_StreamingWriteClient 

type PersQueueService_StreamingWriteClient interface {
	Send(*Ydb_Persqueue_V1.StreamingWriteClientMessage) error
	Recv() (*Ydb_Persqueue_V1.StreamingWriteServerMessage, error)
	grpc.ClientStream
}

type PersQueueService_StreamingWriteServer 

type PersQueueService_StreamingWriteServer interface {
	Send(*Ydb_Persqueue_V1.StreamingWriteServerMessage) error
	Recv() (*Ydb_Persqueue_V1.StreamingWriteClientMessage, error)
	grpc.ServerStream
}

type UnimplementedClusterDiscoveryServiceServer 

type UnimplementedClusterDiscoveryServiceServer struct {
}

UnimplementedClusterDiscoveryServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedClusterDiscoveryServiceServer) DiscoverClusters 

func (*UnimplementedClusterDiscoveryServiceServer) DiscoverClusters(ctx context.Context, req *Ydb_PersQueue_ClusterDiscovery.DiscoverClustersRequest) (*Ydb_PersQueue_ClusterDiscovery.DiscoverClustersResponse, error)

type UnimplementedPersQueueServiceServer 

type UnimplementedPersQueueServiceServer struct {
}

UnimplementedPersQueueServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedPersQueueServiceServer) AddReadRule 

func (*UnimplementedPersQueueServiceServer) AddReadRule(ctx context.Context, req *Ydb_Persqueue_V1.AddReadRuleRequest) (*Ydb_Persqueue_V1.AddReadRuleResponse, error)

func (*UnimplementedPersQueueServiceServer) AlterTopic 

func (*UnimplementedPersQueueServiceServer) AlterTopic(ctx context.Context, req *Ydb_Persqueue_V1.AlterTopicRequest) (*Ydb_Persqueue_V1.AlterTopicResponse, error)

func (*UnimplementedPersQueueServiceServer) CreateTopic 

func (*UnimplementedPersQueueServiceServer) CreateTopic(ctx context.Context, req *Ydb_Persqueue_V1.CreateTopicRequest) (*Ydb_Persqueue_V1.CreateTopicResponse, error)

func (*UnimplementedPersQueueServiceServer) DescribeTopic 

func (*UnimplementedPersQueueServiceServer) DescribeTopic(ctx context.Context, req *Ydb_Persqueue_V1.DescribeTopicRequest) (*Ydb_Persqueue_V1.DescribeTopicResponse, error)

func (*UnimplementedPersQueueServiceServer) DropTopic 

func (*UnimplementedPersQueueServiceServer) DropTopic(ctx context.Context, req *Ydb_Persqueue_V1.DropTopicRequest) (*Ydb_Persqueue_V1.DropTopicResponse, error)

func (*UnimplementedPersQueueServiceServer) GetReadSessionsInfo 

func (*UnimplementedPersQueueServiceServer) GetReadSessionsInfo(ctx context.Context, req *Ydb_Persqueue_V1.ReadInfoRequest) (*Ydb_Persqueue_V1.ReadInfoResponse, error)

func (*UnimplementedPersQueueServiceServer) MigrationStreamingRead 

func (*UnimplementedPersQueueServiceServer) MigrationStreamingRead(srv PersQueueService_MigrationStreamingReadServer) error

func (*UnimplementedPersQueueServiceServer) RemoveReadRule 

func (*UnimplementedPersQueueServiceServer) RemoveReadRule(ctx context.Context, req *Ydb_Persqueue_V1.RemoveReadRuleRequest) (*Ydb_Persqueue_V1.RemoveReadRuleResponse, error)

func (*UnimplementedPersQueueServiceServer) StreamingWrite 

func (*UnimplementedPersQueueServiceServer) StreamingWrite(srv PersQueueService_StreamingWriteServer) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.