package topicclientinternal

import "github.com/ydb-platform/ydb-go-sdk/v3/internal/topic/topicclientinternal"

Index ¶

• type Client
• func New( ctx context.Context, conn grpc.ClientConnInterface, cred credentials.Credentials, opts ...topicoptions.TopicOption, ) *Client
• func (c *Client) Alter(ctx context.Context, path string, opts ...topicoptions.AlterOption) error
• func (c *Client) Close(_ context.Context) error
• func (c *Client) Create( ctx context.Context, path string, opts ...topicoptions.CreateOption, ) error
• func (c *Client) Describe( ctx context.Context, path string, opts ...topicoptions.DescribeOption, ) (res topictypes.TopicDescription, _ error)
• func (c *Client) DescribeTopicConsumer( ctx context.Context, path string, consumer string, opts ...topicoptions.DescribeConsumerOption, ) (res topictypes.TopicConsumerDescription, _ error)
• func (c *Client) Drop(ctx context.Context, path string, opts ...topicoptions.DropOption) error
• func (c *Client) StartListener( consumer string, handler topiclistener.EventHandler, readSelectors topicoptions.ReadSelectors, opts ...topicoptions.ListenerOption, ) (*topiclistener.TopicListener, error)
• func (c *Client) StartReader( consumer string, readSelectors topicoptions.ReadSelectors, opts ...topicoptions.ReaderOption, ) (*topicreader.Reader, error)
• func (c *Client) StartTransactionalWriter( transaction tx.Identifier, topicpath string, opts ...topicoptions.WriterOption, ) (*topicwriter.TxWriter, error)
• func (c *Client) StartWriter(topicPath string, opts ...topicoptions.WriterOption) (*topicwriter.Writer, error)

Types ¶

type Client ¶

type Client struct {
	// contains filtered or unexported fields
}

func New ¶

func New(
	ctx context.Context,
	conn grpc.ClientConnInterface,
	cred credentials.Credentials,
	opts ...topicoptions.TopicOption,
) *Client

func (*Client) Alter ¶

func (c *Client) Alter(ctx context.Context, path string, opts ...topicoptions.AlterOption) error

Alter topic options

func (*Client) Close ¶

func (c *Client) Close(_ context.Context) error

Close the client

func (*Client) Create ¶

func (c *Client) Create(
	ctx context.Context,
	path string,
	opts ...topicoptions.CreateOption,
) error

Create new topic

func (*Client) Describe ¶

func (c *Client) Describe(
	ctx context.Context,
	path string,
	opts ...topicoptions.DescribeOption,
) (res topictypes.TopicDescription, _ error)

Describe topic

func (*Client) DescribeTopicConsumer ¶

func (c *Client) DescribeTopicConsumer(
	ctx context.Context,
	path string,
	consumer string,
	opts ...topicoptions.DescribeConsumerOption,
) (res topictypes.TopicConsumerDescription, _ error)

Describe topic consumer

func (*Client) Drop ¶

func (c *Client) Drop(ctx context.Context, path string, opts ...topicoptions.DropOption) error

Drop topic

func (*Client) StartListener ¶

func (c *Client) StartListener(
	consumer string,
	handler topiclistener.EventHandler,
	readSelectors topicoptions.ReadSelectors,
	opts ...topicoptions.ListenerOption,
) (*topiclistener.TopicListener, error)

StartListener starts read listen topic with the handler it is fast non block call, connection starts in background

func (*Client) StartReader ¶

func (c *Client) StartReader(
	consumer string,
	readSelectors topicoptions.ReadSelectors,
	opts ...topicoptions.ReaderOption,
) (*topicreader.Reader, error)

StartReader create new topic reader and start pull messages from server it is fast non block call, connection will start in background

func (*Client) StartTransactionalWriter ¶

func (c *Client) StartTransactionalWriter(
	transaction tx.Identifier,
	topicpath string,
	opts ...topicoptions.WriterOption,
) (*topicwriter.TxWriter, error)

func (*Client) StartWriter ¶

func (c *Client) StartWriter(topicPath string, opts ...topicoptions.WriterOption) (*topicwriter.Writer, error)

StartWriter create new topic writer wrapper

Source Files ¶

client.go