input

Documentation

Index

• Constants
• type BatchingCSV
  • func (in BatchingCSV) Read(ctx common.Context) <-chan []Item
• type IPRange
  • func (in IPRange) Read(ctx common.Context) <-chan []Item
• type Item

Constants

const (
	InputBufferSize = 32 * 1024
)

Types

type BatchingCSV

type BatchingCSV struct {
	FilePath       string
	CsvColumnIndex int
	TagColumnIndex int
	Separator      rune
	Offset         uint
	Len            uint
	Log            zerolog.Logger
	BatchSize      uint
	Psl            *model.PSL
}

func (BatchingCSV) Read

func (in BatchingCSV) Read(ctx common.Context) <-chan []Item

type IPRange

type IPRange struct {
	FilePath       string
	CsvColumnIndex int
	Offset         uint
	Len            uint
	Log            zerolog.Logger
}

IPRange allows

func (IPRange) Read

func (in IPRange) Read(ctx common.Context) <-chan []Item

type Item

type Item struct {
	Idx  uint
	Name model.DomainName
	Tags string
}