kafka

Documentation

Index

• type File
• type FileIdGenerator
  • func (g *FileIdGenerator) Generate() string
• type IdGenerator
• type KafkaWriter
• 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 FileIdGenerator

type FileIdGenerator struct{}

func (*FileIdGenerator) Generate

func (g *FileIdGenerator) Generate() string

type IdGenerator

type IdGenerator interface {
	Generate() string
}

type KafkaWriter

type KafkaWriter interface {
	WriteMessages(ctx context.Context, msgs ...kafka.Message) error
	Close() error
}

type Plugin

type Plugin struct {
	Writer      KafkaWriter
	IdGenerator IdGenerator
	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