writer

Documentation

Index

• func BuildWriteSyncer(out []string) []io.Writer
• type KafkaWriter
  • func NewKafkaWriter(topic string, syncProducer sarama.SyncProducer) *KafkaWriter
  • func (self *KafkaWriter) Write(p []byte) (n int, err error)

Functions

func BuildWriteSyncer

func BuildWriteSyncer(out []string) []io.Writer

BuildWriteSyncer 创建writer

Types

type KafkaWriter

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

func NewKafkaWriter

func NewKafkaWriter(topic string, syncProducer sarama.SyncProducer) *KafkaWriter

func (*KafkaWriter) Write

func (self *KafkaWriter) Write(p []byte) (n int, err error)