samsa

Aug 19, 2024

Changes in this version

+ type AsyncKafkaWriter struct

+ func NewAsyncKafkaWriter(conf Config) (*AsyncKafkaWriter, error)

+ func NewAsyncKafkaWriterWithContext(ctx context.Context, conf Config) (writer *AsyncKafkaWriter, err error)

+ func (h *AsyncKafkaWriter) Close() error

+ func (h *AsyncKafkaWriter) Write(buf []byte) (n int, err error)

+ func (h *AsyncKafkaWriter) WriteWithContext(ctx context.Context, buf []byte) (n int, err error)

type Config

+ AsyncProducer sarama.AsyncProducer

+ SyncProducer sarama.SyncProducer

type KafkaWriter

+ func NewSyncKafkaWriter(conf Config) (KafkaWriter, error)

+ func NewSyncKafkaWriterWithContext(ctx context.Context, conf Config) (writer KafkaWriter, err error)

+ Close func() error

+ type SyncKafkaWriter struct

+ func (h *SyncKafkaWriter) Close() error

+ func (h *SyncKafkaWriter) Write(buf []byte) (n int, err error)

+ func (h *SyncKafkaWriter) WriteWithContext(ctx context.Context, buf []byte) (n int, err error)

Mar 24, 2024

Changes in this version

+ type Config struct

+ BufferSize int

+ Endpoints []string

+ Producer sarama.AsyncProducer

+ Topic string

+ type KafkaWriter struct

+ Producer sarama.AsyncProducer

+ func New(conf Config) (*KafkaWriter, error)

+ func NewWithContext(ctx context.Context, conf Config) (writer *KafkaWriter, err error)

+ func (h *KafkaWriter) Write(buf []byte) (n int, err error)

+ func (h *KafkaWriter) WriteWithContext(ctx context.Context, buf []byte) (n int, err error)