topicclientinternal

package
v3.79.0 Latest Latest
Warning

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

Go to latest
Published: Sep 5, 2024 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Client

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

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) Drop

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

Drop topic

func (*Client) StartListener added in v3.76.0

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) StartWriter added in v3.38.0

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

StartWriter create new topic writer wrapper

Jump to

Keyboard shortcuts

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