Versions in this module Expand all Collapse all v0 v0.1.0 Jun 2, 2022 Changes in this version + type File struct + Buffer []byte + Id string + Sent uint64 + type KafkaProducer interface + Close func() + Produce func(msg *kafka.Message, deliveryChan chan kafka.Event) error + type Plugin struct + CloseChan chan bool + CurrentFile *File + FileSize uint64 + MessageSize int + Producer KafkaProducer + Topic string + func NewPlugin(config *config.KafkaPluginConfig) (*Plugin, error) + func (p *Plugin) Start(ctx context.Context) chan<- string
Go to main page