admin

Documentation

Overview

Code generated by options-gen. DO NOT EDIT.

Index

• type Client
  • func New(opts Options) (*Client, error)
  • func (c *Client) CreateTopic(ctx context.Context, req CreateTopicReq) error
  • func (c *Client) ListTopics(ctx context.Context) ([]string, error)
• type CreateTopicReq
• type ISchema
• type OptOptionsSetter
  • func WithBootstrapServers(opt []string) OptOptionsSetter
  • func WithLogger(opt ILogger) OptOptionsSetter
  • func WithTlsConfig(opt *tls.Config) OptOptionsSetter
• type Options
  • func NewOptions(options ...OptOptionsSetter) Options
  • func (o *Options) Validate() error

Types

type Client

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

func New

func New(opts Options) (*Client, error)

func (*Client) CreateTopic

func (c *Client) CreateTopic(ctx context.Context, req CreateTopicReq) error

CreateTopic will create a topic in cluster. Note: it will not return an error when topic already exists.

func (*Client) ListTopics

func (c *Client) ListTopics(ctx context.Context) ([]string, error)

ListTopics returns list of topics, available in cluster. Actually, this method will read all partitions, not topics. Be careful.

type CreateTopicReq

type CreateTopicReq struct {
	Name              string
	Partitions        uint
	ReplicationFactor uint
	Schema            ISchema
}

type ISchema

type ISchema interface {
	KvPairs() map[string]string
}

type OptOptionsSetter

type OptOptionsSetter func(o *Options)

func WithBootstrapServers

func WithBootstrapServers(opt []string) OptOptionsSetter

func WithLogger

func WithLogger(opt ILogger) OptOptionsSetter

func WithTlsConfig

func WithTlsConfig(opt *tls.Config) OptOptionsSetter

type Options

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

func NewOptions

func NewOptions(
	options ...OptOptionsSetter,
) Options

func (*Options) Validate

func (o *Options) Validate() error