topicclientinternal

Documentation

Index

• type Client
  • func New(conn grpc.ClientConnInterface, cred credentials.Credentials, ...) *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) Drop(ctx context.Context, path string, opts ...topicoptions.DropOption) error
  • func (c *Client) StartReader(consumer string, readSelectors topicoptions.ReadSelectors, ...) (*topicreader.Reader, error)
  • func (c *Client) StartWriter(producerID, path string, opts ...topicoptions.WriterOption) (*topicwriter.Writer, error)

Types

type Client

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

func New

func New(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

Experimental

Notice: This API is EXPERIMENTAL and may be changed or removed in a later release.

func (*Client) Close

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

Close

Experimental

Notice: This API is EXPERIMENTAL and may be changed or removed in a later release.

func (*Client) Create

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

Create new topic

Experimental

Notice: This API is EXPERIMENTAL and may be changed or removed in a later release.

func (*Client) Describe

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

Describe topic

Experimental

Notice: This API is EXPERIMENTAL and may be changed or removed in a later release.

func (*Client) Drop

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

Drop topic

Experimental

Notice: This API is EXPERIMENTAL and may be changed or removed in a later release.

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

Experimental

Notice: This API is EXPERIMENTAL and may be changed or removed in a later release.

func (*Client) StartWriter

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

StartWriter create new topic writer wrapper

Experimental

Notice: This API is EXPERIMENTAL and may be changed or removed in a later release.