producer

package

v0.5.0 Latest Latest Go to latest Published: Aug 14, 2024 License: MIT Imports: 9 Imported by: 0

Details

Code generated by options-gen. DO NOT EDIT.

This section is empty.

This section is empty.

This section is empty.

type DummyProducer struct{}

func NewDummy() DummyProducer

func (DummyProducer) Close(ctx context.Context) error

func (DummyProducer) Stats() Stats

func (DummyProducer) WriteMessages(ctx context.Context, msgs ...Message) error

type Header struct {
	Key   []byte
	Value []byte
}

type Message struct {
	Offset        int64
	HighWaterMark int64
	Key           []byte
	Value         []byte
	Headers       []Header
}

type OptOptionsSetter func(o *Options)

func WithClientID(opt string) OptOptionsSetter

func WithTls(opt bool) OptOptionsSetter

func WithTopic(opt string) OptOptionsSetter

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

func NewOptions(
	addrs []string,
	options ...OptOptionsSetter,
) Options

func (o *Options) Validate() error

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

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

func (p Producer) Close(_ context.Context) error

func (p Producer) Stats() Stats

func (p Producer) WriteMessages(ctx context.Context, msgs ...Message) error

type Stats = kafka.WriterStats