kafka

Documentation

Index

• type File
• type KafkaProducer
• type Plugin
  • func NewPlugin(config *config.KafkaPluginConfig) (*Plugin, error)
  • func (p *Plugin) Start(ctx context.Context) chan<- string

Types

type File

type File struct {
	Id     string
	Buffer []byte
	Sent   uint64
}

type KafkaProducer

type KafkaProducer interface {
	Produce(msg *kafka.Message, deliveryChan chan kafka.Event) error
	Close()
}

type Plugin

type Plugin struct {
	Producer    KafkaProducer
	Topic       string
	MessageSize int
	CloseChan   chan bool
	FileSize    uint64
	CurrentFile *File
}

func NewPlugin

func NewPlugin(config *config.KafkaPluginConfig) (*Plugin, error)

func (*Plugin) Start

func (p *Plugin) Start(ctx context.Context) chan<- string

Start produces Kafka messages containing data that is written to the returned channel