client

Documentation

Index

• type Client
  • func New(config *sarama.Config) *Client
  • func (c Client) BrokerAddrs() []string
  • func (c *Client) Connect(brokerAddrs []string) (err error)
  • func (c Client) Connected() bool
  • func (c *Client) Disconnect() (errs []error)
  • func (c *Client) Offset(topic string, partition int32, time int64) (offset int64, err error)
  • func (c *Client) PartitionConsumer(topic string, partition int32, offset int64) (partitionConsumer sarama.PartitionConsumer, err error)
  • func (c *Client) Partitions(topic string) (partitions []int32, err error)
  • func (c *Client) Produce(topic string, partition int32, key, value []byte) (offset int64, err error)
  • func (c *Client) Reset()
  • func (c *Client) SetConfig(config *sarama.Config)
  • func (c Client) States() (states []string)
  • func (c *Client) Topics() (topics []string, err error)

Types

type Client

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

func New

func New(config *sarama.Config) *Client

func (Client) BrokerAddrs

func (c Client) BrokerAddrs() []string

func (*Client) Connect

func (c *Client) Connect(brokerAddrs []string) (err error)

func (Client) Connected

func (c Client) Connected() bool

func (*Client) Disconnect

func (c *Client) Disconnect() (errs []error)

func (*Client) Offset

func (c *Client) Offset(topic string, partition int32, time int64) (offset int64, err error)

func (*Client) PartitionConsumer

func (c *Client) PartitionConsumer(topic string, partition int32, offset int64) (partitionConsumer sarama.PartitionConsumer, err error)

func (*Client) Partitions

func (c *Client) Partitions(topic string) (partitions []int32, err error)

func (*Client) Produce

func (c *Client) Produce(topic string, partition int32, key, value []byte) (offset int64, err error)

func (*Client) Reset

func (c *Client) Reset()

func (*Client) SetConfig

func (c *Client) SetConfig(config *sarama.Config)

func (Client) States

func (c Client) States() (states []string)

func (*Client) Topics

func (c *Client) Topics() (topics []string, err error)