kafka

Documentation

Index

• type Client
  • func New(serviceName string, opts ...OptionFunc) (cli *Client, err error)
  • func (cli *Client) Consume(params interface{}) (err error)
  • func (cli *Client) Produce(ctx context.Context, msg interface{}) (response queue.ProduceResponse, err error)
  • func (cli *Client) Shutdown() (err error)
• type ConsumeParams
• type Consumer
  • func (c *Consumer) Cleanup(sarama.ConsumerGroupSession) error
  • func (c *Consumer) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error
  • func (c *Consumer) Setup(sarama.ConsumerGroupSession) error
• type OptionFunc
  • func AsyncConfig(c *sarama.Config) OptionFunc
  • func ConsumeConfig(c *sarama.Config) OptionFunc
  • func OpenConsumeLog() OptionFunc
  • func RefreshInterval(t time.Duration) OptionFunc
  • func SyncConfig(c *sarama.Config) OptionFunc
• type ProduceParams

Types

type Client

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

func New

func New(serviceName string, opts ...OptionFunc) (cli *Client, err error)

func (*Client) Consume

func (cli *Client) Consume(params interface{}) (err error)

func (*Client) Produce

func (cli *Client) Produce(ctx context.Context, msg interface{}) (
	response queue.ProduceResponse, err error,
)

func (*Client) Shutdown

func (cli *Client) Shutdown() (err error)

type ConsumeParams

type ConsumeParams struct {
	GroupID  string
	Topics   []string
	Consumer queue.Consumer
	// contains filtered or unexported fields
}

type Consumer

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

func (*Consumer) Cleanup

func (c *Consumer) Cleanup(sarama.ConsumerGroupSession) error

func (*Consumer) ConsumeClaim

func (c *Consumer) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error

func (*Consumer) Setup

func (c *Consumer) Setup(sarama.ConsumerGroupSession) error

type OptionFunc

type OptionFunc func(*options)

func AsyncConfig

func AsyncConfig(c *sarama.Config) OptionFunc

func ConsumeConfig

func ConsumeConfig(c *sarama.Config) OptionFunc

func OpenConsumeLog

func OpenConsumeLog() OptionFunc

func RefreshInterval

func RefreshInterval(t time.Duration) OptionFunc

func SyncConfig

func SyncConfig(c *sarama.Config) OptionFunc

type ProduceParams

type ProduceParams struct {
	Async   bool
	Message *sarama.ProducerMessage
}